Транзакция и откат в коннекторе Snowflake для Python - PullRequest
0 голосов
/ 25 февраля 2020

Я использую 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). Но этот код, похоже, не возвращается.

Есть идеи, что может быть причиной этого?

...