Как я могу выполнить объединение нескольких запросов, используя peewee Execute_sql? ⇐ Python

[Anonymous]

Код: Выделить всё

USE_DB_POOL = db_pool_enabled() and not is_test_environment()
if USE_DB_POOL:
db_manager = PooledDatabaseManager(db_config)
else:
db_manager = DatabaseManager(db_config)

class MySQLClient(DBClient):
def op(self, qry):
self.reconnect_if_needed()
cursor = None
data = None
try:
cursor = self.db.execute_sql(qry)
data = cursor.fetchall()
self.db.commit()  # Commit for all executed queries
logger.info(f"Query executed successfully: {qry}")
except Exception as e:
logger.error(f"Error executing query: {e}")
self.db.rollback()  # Rollback in case of error
finally:
if cursor:
cursor.close()
return data

Выше приведен мой код на Python. Я пытаюсь выполнить тот же запрос sql, используя BigQuery или MySQL. Моя служба уже использовала библиотеку peewee с вышеупомянутым пулом соединений.
Запрос sql, который я хочу выполнить, имеет несколько запросов на обновление. разделенные точкой с запятой. и НАЧАТЬ ТРАНЗАКЦИЮ в начале. Но я получаю сообщение об ошибке в моем sql. Тот же запрос хорошо работал с библиотекой соединителей MySQL. Пожалуйста, помогите

Подробнее здесь: https://stackoverflow.com/questions/786 ... xecute-sql