Devel

data/.gitignore

@@ -0,0 +1,2 @@
+*
+!.gitignore

db/Dockerfile

@@ -1,2 +1,5 @@
 FROM ghcr.io/amacneil/dbmate as dbmate
-COPY ./ db/
+COPY migrations/ db/migrations/
+COPY entrypoint.sh .
+ENTRYPOINT ["/entrypoint.sh"]
+CMD ["dbmate", "--no-dump-schema", "up"]

db/entrypoint.sh

@@ -0,0 +1,7 @@
+#!/bin/sh
+
+set -ex
+
+dbmate wait
+
+exec "$@"

db/migrations/20231122005008_logger_instrumentation_unique_filename.sql

@@ -0,0 +1,5 @@
+-- migrate:up
+
+alter table logger_instrumentation add constraint logger_instrumentation_filename_key unique (filename);
+
+-- migrate:down

db/migrations/20240116110423_import_fields_view.sql

@@ -0,0 +1,13 @@
+-- migrate:up
+
+create materialized view import_fields as 
+(SELECT column_name, is_nullable
+  FROM information_schema.columns
+ WHERE table_schema = 'public'
+   AND table_name   = 'import');
+
+grant select on import_fields to web_anon;
+
+
+-- migrate:down
+

db/migrations/20240117072241_row_to_json_errors_detail.sql

@@ -0,0 +1,36 @@
+-- migrate:up
+
+create or replace function import() returns trigger language  plpgsql
+as $$
+begin
+    if new.ring_number is null then
+        new.ring_number = 'AUTO_' || nextval('auto_ring_id_seq')::text;
+    end if;
+    if new.gps_deployment_date is not null and new.gps_logger_id is null then
+        new.gps_logger_id = 'AUTO_' || nextval('auto_logger_id_seq')::text;
+    end if;
+    if new.gls_deployment_date is not null and new.gls_logger_id is null then
+        new.gls_logger_id = 'AUTO_' || nextval('auto_logger_id_seq')::text;
+    end if;
+    if new.tdr_deployment_date is not null and new.tdr_logger_id is null then
+        new.tdr_logger_id = 'AUTO_' || nextval('auto_logger_id_seq')::text;
+    end if;
+    if new.accelerometer_deployment_date is not null and new.accelerometer_logger_id is null then
+        new.accelerometer_logger_id = 'AUTO_' || nextval('auto_logger_id_seq')::text;
+    end if;
+    perform import_animal_and_ring(new);
+    perform import_colony(new);
+    perform import_deployment_and_chick(new);
+    perform import_logger_and_logger_instrumentation(new);
+    return null;
+exception
+    when others then
+        raise exception using
+            errcode = sqlstate,
+            message = sqlerrm,
+            detail = row_to_json(new);
+end;
+$$;
+
+-- migrate:down
+

db/migrations/20240117081051_import_filename_constraint.sql

@@ -0,0 +1,53 @@
+-- migrate:up
+
+create or replace function import() returns trigger language  plpgsql
+as $$
+begin
+    -- perform some checks
+    if new.gps_deployment_date is not null and new.gps_raw_datafile_name is null then
+        raise exception 'gps_raw_datafile_name cannot be empty if gps_deployment_date is defined';
+    end if;
+
+    if new.gls_deployment_date is not null and new.gls_raw_datafile_name is null then
+        raise exception 'gls_raw_datafile_name cannot be empty if gls_deployment_date is defined';
+    end if;
+
+    if new.tdr_deployment_date is not null and new.tdr_raw_datafile_name is null then
+        raise exception 'tdr_raw_datafile_name cannot be empty if tdr_deployment_date is defined';
+    end if;
+
+    if new.accelerometer_deployment_date is not null and new.accelerometer_raw_datafile_name is null then
+        raise exception 'accelerometer_raw_datafile_name cannot be empty if accelerometer_deployment_date is defined';
+    end if;
+
+    if new.ring_number is null then
+        new.ring_number = 'AUTO_' || nextval('auto_ring_id_seq')::text;
+    end if;
+    if new.gps_deployment_date is not null and new.gps_logger_id is null then
+        new.gps_logger_id = 'AUTO_' || nextval('auto_logger_id_seq')::text;
+    end if;
+    if new.gls_deployment_date is not null and new.gls_logger_id is null then
+        new.gls_logger_id = 'AUTO_' || nextval('auto_logger_id_seq')::text;
+    end if;
+    if new.tdr_deployment_date is not null and new.tdr_logger_id is null then
+        new.tdr_logger_id = 'AUTO_' || nextval('auto_logger_id_seq')::text;
+    end if;
+    if new.accelerometer_deployment_date is not null and new.accelerometer_logger_id is null then
+        new.accelerometer_logger_id = 'AUTO_' || nextval('auto_logger_id_seq')::text;
+    end if;
+    perform import_animal_and_ring(new);
+    perform import_colony(new);
+    perform import_deployment_and_chick(new);
+    perform import_logger_and_logger_instrumentation(new);
+    return null;
+exception
+    when others then
+        raise exception using
+            errcode = sqlstate,
+            message = sqlerrm,
+            detail = row_to_json(new);
+end;
+$$;
+
+-- migrate:down
+