def commit(query, params): c = database.cursor(MySQLdb.cursors.Cursor) try: c.execute(query, params) database.commit() except Exception as ex: database.rollback() print ex print c._last_executed