test/ref_conn arguments should be an instance of DbConnection
(self, query_profile, ref_conn,
test_conn, query_timeout_seconds, flatten_dialect=None)
| 71 | DECIMAL_PLACES = 2 |
| 72 | |
| 73 | def __init__(self, query_profile, ref_conn, |
| 74 | test_conn, query_timeout_seconds, flatten_dialect=None): |
| 75 | '''test/ref_conn arguments should be an instance of DbConnection''' |
| 76 | self.ref_conn = ref_conn |
| 77 | self.ref_sql_writer = SqlWriter.create( |
| 78 | dialect=ref_conn.db_type, nulls_order_asc=query_profile.nulls_order_asc()) |
| 79 | self.test_conn = test_conn |
| 80 | self.test_sql_writer = SqlWriter.create(dialect=test_conn.db_type) |
| 81 | |
| 82 | compat.setup_ref_database(self.ref_conn) |
| 83 | |
| 84 | ref_cursor = ref_conn.cursor() |
| 85 | test_cursor = test_conn.cursor() |
| 86 | |
| 87 | self.query_executor = QueryExecutor( |
| 88 | [ref_cursor, test_cursor], |
| 89 | [self.ref_sql_writer, self.test_sql_writer], |
| 90 | query_timeout_seconds=query_timeout_seconds, |
| 91 | flatten_dialect=flatten_dialect) |
| 92 | |
| 93 | @property |
| 94 | def test_db_type(self): |
nothing calls this directly
no test coverage detected