Commit a5245c8c by Owo Sugiana

Mengganti engine.execute() dengan conn.execute()

1 parent 0abe80fa
0.8.2 14-3-2024
---------------
- Mengganti engine.execute() dengan conn.execute() sesuai SQLAlchemy yang baru.
0.8.1 21-5-2023
---------------
- Memahami mirror status versi 9.1
......
......@@ -33,7 +33,8 @@ def main(argv=sys.argv[1:]):
trigger_name = f'log_table_{operation}'
sql = f'DROP TRIGGER {trigger_name} ON {table_name}'
try:
engine.execute(text(sql))
with engine.connect() as conn:
conn.execute(text(sql))
except exc.ProgrammingError as e:
s = str(e)
if s.find('does not exist') == -1:
......@@ -41,4 +42,5 @@ def main(argv=sys.argv[1:]):
sql = f'CREATE TRIGGER {trigger_name} '\
f'AFTER {operation} ON {table_name} '\
f'FOR EACH ROW EXECUTE PROCEDURE log_table_after_{operation}()'
engine.execute(text(sql))
with engine.connect() as conn:
conn.execute(text(sql))
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!