Method execute

MySQLdb/cursors.py:157–210

Execute a query. query -- string, query to execute on server args -- optional sequence or mapping, parameters to use with query. Note: If args is a sequence, then %s must be used as the parameter placeholder in the query. If a mapping is used, %(key)

(self, query, args=None)

        return self.connection
    
    def execute(self, query, args=None):

        """Execute a query.
        
        query -- string, query to execute on server
        args -- optional sequence or mapping, parameters to use with query.

        Note: If args is a sequence, then %s must be used as the
        parameter placeholder in the query. If a mapping is used,
        %(key)s must be used as the placeholder.

        Returns long integer rows affected, if any

        """
        del self.messages[:]
        db = self._get_db()

        charset = db.character_set_name()

        if args is not None:
            if isinstance(query, bytes):
                query = query.decode();

            if isinstance(args, dict):
                query = query.format( **db.literal(args) )
            elif isinstance(args, tuple) or isinstance(args, list):
                query = query.format( *db.literal(args) )
            else:
                query = query.format( db.literal(args) )

        if isinstance(query, str):
            query = query.encode(charset);

        try:
            r = None
            r = self._query(query)
        except TypeError as m:
            if m.args[0] in ("not enough arguments for format string",
                             "not all arguments converted"):
                self.messages.append((ProgrammingError, m.args[0]))
                self.errorhandler(self, ProgrammingError, m.args[0])
            else:
                self.messages.append((TypeError, m))
                self.errorhandler(self, TypeError, m)
        except (SystemExit, KeyboardInterrupt):
            raise
        except:
            exc, value, tb = sys.exc_info()
            del tb
            self.messages.append((exc, value))
            self.errorhandler(self, exc, value)
        self._executed = query
        if not self._defer_warnings: self._warning_check()
        return r

    def executemany(self, query, args):