diff --git a/sql/import-from-influx.sql b/sql/import-from-influx.sql index 4583b6d..de39459 100644 --- a/sql/import-from-influx.sql +++ b/sql/import-from-influx.sql @@ -1,3 +1,10 @@ INSERT INTO public."glucose-import" - (SELECT nextval('glucose-import_id_seq'), "glucose"."deviceSerialNumber", "glucose"."deviceType", units, value, time FROM influx.glucose); - + (SELECT nextval('glucose-import_id_seq'), + "glucose"."deviceSerialNumber", + "glucose"."deviceType", + "glucose".units, + "glucose".value, + "glucose".time + FROM influx.glucose + WHERE "glucose".time >= (SELECT max(time) FROM public."glucose-import") + );