# connect to database
self.engine = sqlalchemy.create_engine(uri)
+ con = self.engine.connect()
# fill database
with open('tests/testdb.sql', 'r') as f:
sql = f.read()
- self.engine.execute(sql)
+ con.execute(sql)
# update dates
- con = self.engine.connect()
seconds_diff, = con.execute("SELECT TIMESTAMPDIFF(SECOND, '2017-03-31 07:00', now())").fetchone()
seconds_diff = int(seconds_diff)
con.execute("UPDATE wrreport SET date_report = DATE(date_report + INTERVAL %s SECOND) WHERE time_report IS NULL", (seconds_diff,))