()
| 226 | |
| 227 | |
| 228 | def test_execute_query(): |
| 229 | mylogger.info(f'\n\ntest_execute_query\n{"-"*30}') |
| 230 | sxt = SpaceAndTime() |
| 231 | sxt.authenticate() |
| 232 | success, data = sxt.execute_query('Select * from SXTLabs.Singularity limit 1') |
| 233 | assert success |
| 234 | assert data[0]['NAME'] == 'Singularity' |
| 235 | assert type(data) == list |
| 236 | assert type(data[0]) == dict |
| 237 | |
| 238 | success, data = sxt.execute_query('Select * from SXTLabs.Singularity limit 1', |
| 239 | sql_type=sxt.SQLTYPE.DQL, resources=['SXTLabs.Singularity'], |
| 240 | output_format = sxt.OUTPUT_FORMAT.PARQUET ) |
| 241 | assert success |
| 242 | assert type(data) == bytes |
| 243 | |
| 244 | success, data = sxt.execute_query('Select * from SXTLabs.Singularity limit 1', |
| 245 | sql_type=sxt.SQLTYPE.DQL, resources=['SXTLabs.Singularity'], |
| 246 | output_format = sxt.OUTPUT_FORMAT.DATAFRAME ) |
| 247 | assert success |
| 248 | assert type(data) == pandas.DataFrame |
| 249 | |
| 250 | success, data = sxt.execute_query('Select * from SXTLabs.Singularity limit 1', |
| 251 | sql_type=sxt.SQLTYPE.DQL, resources=['SXTLabs.Singularity'], |
| 252 | output_format = sxt.OUTPUT_FORMAT.CSV ) |
| 253 | assert success |
| 254 | assert type(data) == list |
| 255 | assert type(data[0]) == str # header |
| 256 | assert type(data[1]) == str # data |
| 257 | assert len(data) == 2 # header + 1 data row |
| 258 | assert data[1].count(',') > 3 |
| 259 | |
| 260 | |
| 261 | def test_discovery(): |
nothing calls this directly
no test coverage detected