Я использую Snowflake Connector для Python следующим образом:
ctx = snowflake.connector.connect(user=username, password=password, account=account, warehouse=warehouse)
cs = ctx.cursor()
try:
cs.execute(u"begin")
cs.execute("TRUNCATE table1")
cs.execute("TRUNCATE table2")
cs.execute("TRUNCATE table3")
ctx.commit()
except snowflake.connector.errors.ProgrammingError as e:
ctx.rollback()
print("ERROR" + e.msg)
finally:
cs.close()
ctx.close()
По существу я хочу выполнить откат, если есть какие-либо проблемы с любым из SQL (TRUNCATES). Но этот код, похоже, не возвращается.
Есть идеи, что может быть причиной этого?