Merge pull request #79 from DPIclimate/postgis_and_db_v2

Convert device table location columns to PostGIS geometry datatype

compose/docker-compose.yml

@@ -2,8 +2,8 @@ version: '3.1'
 
 services:
   db:
-    image: postgres:14.2
-    restart: "no"
+    image: postgis/postgis:14-3.4
+    restart: always
     env_file:
       - .env
     volumes:
@@ -18,7 +18,7 @@ services:
   mq:
     hostname: "mq"
     image: rabbitmq:3.9-management
-    restart: "no"
+    restart: always
     env_file:
       - .env
     volumes:

db/init.d/init_db.sql

@@ -1,3 +1,6 @@
+CREATE EXTENSION postgis;
+CREATE EXTENSION pgcrypto;
+
 create table if not exists sources (
     source_name text primary key not null
 );
@@ -6,7 +9,7 @@ create table if not exists physical_devices (
     uid integer generated always as identity primary key,
     source_name text not null references sources,
     name text not null,
-    location point,
+    location geometry('POINT', 4283),
     last_seen timestamptz,
     -- Store only top level key value pairs here; it is used
     -- for quickly finding a device using information carried
@@ -72,7 +75,7 @@ create table if not exists device_blobs (
 create table if not exists logical_devices (
     uid integer generated always as identity primary key,
     name text not null,
-    location point,
+    location geometry('POINT', 4283),
     last_seen timestamptz,
     properties jsonb not null default '{}'
 );
@@ -107,4 +110,4 @@ create table if not exists version (
 create index if not exists pd_src_id_idx on physical_devices using GIN (source_ids);
 
 insert into sources values ('ttn'), ('greenbrain'), ('wombat'), ('ydoc'), ('ict_eagleio');
-insert into version values (1);
+insert into version values (2);

db/upgrade/002.sql

@@ -0,0 +1,17 @@
+CREATE EXTENSION postgis;
+CREATE EXTENSION pgcrypto;
+
+SELECT AddGeometryColumn('logical_devices','geom',4283,'POINT',2);
+SELECT AddGeometryColumn('physical_devices','geom',4283,'POINT',2);
+
+UPDATE logical_devices SET geom = ST_MakePoint(location[1], location[0]) WHERE location IS NOT NULL;
+UPDATE physical_devices SET geom = ST_MakePoint(location[1], location[0]) WHERE location IS NOT NULL;
+
+ALTER TABLE logical_devices DROP COLUMN location;
+ALTER TABLE physical_devices DROP COLUMN location;
+
+ALTER TABLE logical_devices RENAME COLUMN geom TO location;
+ALTER TABLE physical_devices RENAME COLUMN geom TO location;
+
+TRUNCATE version;
+insert into version values (2);