(self)
| 293 | return 3 |
| 294 | |
| 295 | def setup(self): |
| 296 | execute_sql(self.host, self.port, f"DROP TABLE IF EXISTS {self.table_name}") |
| 297 | execute_sql(self.host, self.port, f""" |
| 298 | CREATE TABLE {self.table_name} ( |
| 299 | sym_8 SYMBOL, |
| 300 | sym_3 SYMBOL, |
| 301 | sym_2 SYMBOL, |
| 302 | value DOUBLE, |
| 303 | ts TIMESTAMP |
| 304 | ) TIMESTAMP(ts) PARTITION BY DAY BYPASS WAL |
| 305 | """) |
| 306 | execute_sql(self.host, self.port, f""" |
| 307 | INSERT INTO {self.table_name} |
| 308 | SELECT |
| 309 | rnd_symbol('A','B','C','D','E','F','G','H') as sym_8, |
| 310 | rnd_symbol('X','Y','Z') as sym_3, |
| 311 | rnd_symbol('ONE','TWO') as sym_2, |
| 312 | rnd_double() as value, |
| 313 | timestamp_sequence('2024-01-01', 1000000) as ts |
| 314 | FROM long_sequence({self.expected_row_count}) |
| 315 | """) |
| 316 | |
| 317 | def teardown(self): |
| 318 | execute_sql(self.host, self.port, f"DROP TABLE IF EXISTS {self.table_name}") |
nothing calls this directly
no test coverage detected