diff --git a/integrations/acquisition/covidcast/test_covidcast_meta_caching.py b/integrations/acquisition/covidcast/test_covidcast_meta_caching.py index 9c4d69683..f1f9c4ef9 100644 --- a/integrations/acquisition/covidcast/test_covidcast_meta_caching.py +++ b/integrations/acquisition/covidcast/test_covidcast_meta_caching.py @@ -67,14 +67,26 @@ def test_caching(self): # insert dummy data self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'state', 20200422, 'pa', 123, 1, 2, 3, 456, 1, 20200422, 0, 1, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}), (0, 'src', 'sig', 'day', 'state', 20200422, 'wa', 789, 1, 2, 3, 456, 1, 20200423, 1, 1, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}) ''') self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (100, 'src', 'wip_sig', 'day', 'state', 20200422, 'pa', 456, 4, 5, 6, 789, -1, 20200422, 0, 1, True, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}) ''') diff --git a/integrations/client/test_delphi_epidata.py b/integrations/client/test_delphi_epidata.py index 063fb61f0..8d3560a68 100644 --- a/integrations/client/test_delphi_epidata.py +++ b/integrations/client/test_delphi_epidata.py @@ -67,7 +67,13 @@ def test_covidcast(self): # insert dummy data self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'county', 20200414, '01234', 123, 1.5, 2.5, 3.5, 456, 4, 20200414, 0, 0, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}), @@ -331,7 +337,13 @@ def test_geo_value(self): # insert dummy data self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'county', 20200414, '11111', 123, 10, 11, 12, 456, 13, 20200414, 0, 1, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}), @@ -432,7 +444,13 @@ def test_covidcast_meta(self): # insert dummy data self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'county', 20200414, '01234', 123, 1.5, 2.5, 3.5, 456, 4, 20200414, 0, 0, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}), @@ -562,7 +580,13 @@ def test_covidcast_nowcast(self): def test_async_epidata(self): # insert dummy data self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'county', 20200414, '11111', 123, 10, 11, 12, 456, 13, 20200414, 0, 1, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}), diff --git a/integrations/server/test_covidcast.py b/integrations/server/test_covidcast.py index c6b65850e..36e4cd880 100644 --- a/integrations/server/test_covidcast.py +++ b/integrations/server/test_covidcast.py @@ -45,7 +45,13 @@ def test_round_trip(self): # insert dummy data self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'county', 20200414, '01234', 123, 1.5, 2.5, 3.5, 456, 4, 20200414, 0, 1, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}) @@ -92,7 +98,13 @@ def test_round_trip(self): # # insert dummy data # self.cur.execute(f''' - # insert into covidcast values + # INSERT INTO + # `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + # `time_value`, `geo_value`, `value_updated_timestamp`, + # `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + # `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + # `missing_stderr`,`missing_sample_size`) + # VALUES # (0, 'src', 'sig', 'day', 'county', 20200414, '01234', # 123, 1.5, 2.5, 3.5, 456, 4, 20200414, 0, 1, False, # {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}) @@ -129,7 +141,13 @@ def test_csv_format(self): # insert dummy data self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'county', 20200414, '01234', 123, 1.5, 2.5, 3.5, 456, 4, 20200414, 0, 1, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}) @@ -163,7 +181,13 @@ def test_raw_json_format(self): # insert dummy data self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'county', 20200414, '01234', 123, 1.5, 2.5, 3.5, 456, 4, 20200414, 0, 1, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}) @@ -205,7 +229,13 @@ def test_fields(self): # insert dummy data self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'county', 20200414, '01234', 123, 1.5, 2.5, 3.5, 456, 4, 20200414, 0, 1, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}) @@ -326,7 +356,13 @@ def test_location_wildcard(self): # insert dummy data self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'county', 20200414, '11111', 123, 10, 11, 12, 456, 13, 20200414, 0, 1, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}), @@ -414,7 +450,13 @@ def test_geo_value(self): # insert dummy data self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'county', 20200414, '11111', 123, 10, 11, 12, 456, 13, 20200414, 0, 1, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}), @@ -530,7 +572,13 @@ def test_location_timeline(self): # insert dummy data self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'county', 20200411, '01234', 123, 10, 11, 12, 456, 13, 20200413, 2, 1, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}), @@ -618,7 +666,13 @@ def test_unique_key_constraint(self): # insert dummy data self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'county', 20200414, '01234', 0, 0, 0, 0, 0, 0, 20200414, 0, 1, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}) @@ -628,7 +682,13 @@ def test_unique_key_constraint(self): # fail to insert different dummy data under the same key with self.assertRaises(mysql.connector.errors.IntegrityError): self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'county', 20200414, '01234', 1, 1, 1, 1, 1, 1, 20200414, 0, 1, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}) @@ -636,7 +696,13 @@ def test_unique_key_constraint(self): # succeed to insert different dummy data under a different issue self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'county', 20200414, '01234', 1, 1, 1, 1, 1, 1, 20200415, 1, 1, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}) @@ -647,7 +713,13 @@ def test_nullable_columns(self): # insert dummy data self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'county', 20200414, '01234', 123, 0.123, NULL, NULL, 456, NULL, 20200414, 0, 1, False, {Nans.NOT_MISSING}, {Nans.OTHER}, {Nans.OTHER}) @@ -693,7 +765,13 @@ def test_temporal_partitioning(self): # insert dummy data self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'hour', 'state', 2020041714, 'vi', 123, 10, 11, 12, 456, 13, 2020041714, 0, 1, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}), @@ -750,7 +828,13 @@ def test_date_formats(self): # insert dummy data self.cur.execute(f''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, 'src', 'sig', 'day', 'county', 20200411, '01234', 123, 10, 11, 12, 456, 13, 20200413, 0, 1, False, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}, {Nans.NOT_MISSING}), diff --git a/integrations/server/test_covidcast_endpoints.py b/integrations/server/test_covidcast_endpoints.py index 1f08c429b..84dceb352 100644 --- a/integrations/server/test_covidcast_endpoints.py +++ b/integrations/server/test_covidcast_endpoints.py @@ -127,7 +127,13 @@ def _insert_rows(self, rows: Iterable[CovidcastRow]): sql = ",\n".join((str(r) for r in rows)) self.cur.execute( f""" - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES {sql} """ ) diff --git a/integrations/server/test_covidcast_meta.py b/integrations/server/test_covidcast_meta.py index bfdbc1be6..36a68c3a8 100644 --- a/integrations/server/test_covidcast_meta.py +++ b/integrations/server/test_covidcast_meta.py @@ -47,7 +47,13 @@ def test_round_trip(self): # insert dummy data and accumulate expected results (in sort order) template = ''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, "%s", "%s", "%s", "%s", %d, "%s", 123, %d, 0, 0, 456, 0, %d, 0, 1, %d, %d, %d, %d) ''' @@ -100,7 +106,13 @@ def test_filter(self): # insert dummy data and accumulate expected results (in sort order) template = ''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, "%s", "%s", "%s", "%s", %d, "%s", 123, %d, 0, 0, 456, 0, %d, 0, 1, %d, %d, %d, %d) ''' @@ -218,7 +230,13 @@ def test_suppress_work_in_progress(self): # insert dummy data and accumulate expected results (in sort order) template = ''' - insert into covidcast values + INSERT INTO + `covidcast` (`id`, `source`, `signal`, `time_type`, `geo_type`, + `time_value`, `geo_value`, `value_updated_timestamp`, + `value`, `stderr`, `sample_size`, `direction_updated_timestamp`, + `direction`, `issue`, `lag`, `is_latest_issue`, `is_wip`,`missing_value`, + `missing_stderr`,`missing_sample_size`) + VALUES (0, "%s", "%s", "%s", "%s", %d, "%s", 123, %d, 0, 0, 456, 0, %d, 0, 1, %d, %d, %d, %d) ''' diff --git a/integrations/server/test_fluview.py b/integrations/server/test_fluview.py index 9dc2a0841..8bfc18376 100644 --- a/integrations/server/test_fluview.py +++ b/integrations/server/test_fluview.py @@ -48,7 +48,11 @@ def test_round_trip(self): # insert dummy data self.cur.execute(''' - insert into fluview values + INSERT INTO + `fluview` (`id`, `release_date`, `issue`, `epiweek`, `region`, + `lag`, `num_ili`, `num_patients`, `num_providers`, `wili`, `ili`, + `num_age_0`, `num_age_1`, `num_age_2`, `num_age_3`, `num_age_4`, `num_age_5`) + VALUES (0, "2020-04-07", 202021, 202020, "nat", 1, 2, 3, 4, 3.14159, 1.41421, 10, 11, 12, 13, 14, 15) ''') diff --git a/integrations/server/test_fluview_meta.py b/integrations/server/test_fluview_meta.py index 32c2514b9..137e9464a 100644 --- a/integrations/server/test_fluview_meta.py +++ b/integrations/server/test_fluview_meta.py @@ -48,7 +48,11 @@ def test_round_trip(self): # insert dummy data self.cur.execute(''' - insert into fluview values + INSERT INTO + `fluview` (`id`, `release_date`, `issue`, `epiweek`, `region`, + `lag`, `num_ili`, `num_patients`, `num_providers`, `wili`, `ili`, + `num_age_0`, `num_age_1`, `num_age_2`, `num_age_3`, `num_age_4`, `num_age_5`) + VALUES (0, "2020-04-07", 202021, 202020, "nat", 1, 2, 3, 4, 3.14159, 1.41421, 10, 11, 12, 13, 14, 15), (0, "2020-04-28", 202022, 202022, "hhs1", 5, 6, 7, 8, 1.11111, 2.22222,