(conn)
| 53 | |
| 54 | |
| 55 | def drop_tables(conn): |
| 56 | with conn.cursor() as cur: |
| 57 | cur.execute( |
| 58 | """ |
| 59 | DROP SCHEMA public CASCADE; |
| 60 | CREATE SCHEMA public; |
| 61 | DROP SCHEMA IF EXISTS schema1 CASCADE; |
| 62 | DROP SCHEMA IF EXISTS schema2 CASCADE""" |
| 63 | ) |
| 64 | |
| 65 | |
| 66 | def run(executor, sql, join=False, expanded=False, pgspecial=None, exception_formatter=None): |