+ def store_database_report(self, date):
+ try:
+ report_query = 'INSERT INTO reports("date", "market_config_id", "debug") VALUES (%s, %s, %s) RETURNING id;'
+ line_query = 'INSERT INTO report_lines("date", "report_id", "type", "payload") VALUES (%s, %s, %s, %s);'
+ connection = psycopg2.connect(**self.pg_config)
+ cursor = connection.cursor()
+ cursor.execute(report_query, (date, self.market_id, self.debug))
+ report_id = cursor.fetchone()[0]
+ for date, type_, payload in self.report.to_json_array():
+ cursor.execute(line_query, (date, report_id, type_, payload))
+
+ connection.commit()
+ cursor.close()
+ connection.close()
+ except Exception as e:
+ print("impossible to store report to database: {}; {}".format(e.__class__.__name__, e))
+