- class ForeignKeysListener(PoolListener):
- def connect(self, dbapi_con, con_record):
- db_cursor = dbapi_con.execute('pragma foreign_keys=ON')
- self.engine = create_engine(db, connect_args={'check_same_thread': False}, poolclass=NullPool, listeners=[ForeignKeysListener()])
+ def my_on_connect(dbapi_conn, connection_rec, connection_proxy):
+ db_cursor = dbapi_conn.execute('pragma foreign_keys=ON')
+ self.engine = create_engine(db, connect_args={'check_same_thread': False}, poolclass=NullPool)
+ event.listen(self.engine, 'checkout', my_on_connect)