Mercurial > gemma

comparison schema/gemma.sql @ 1012:875b0a9a3c92

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Fixed schema definition of import queue.
author Sascha L. Teichmann <sascha.teichmann@intevation.de>
date Tue, 23 Oct 2018 11:32:47 +0200
parents 75e65599ea52
children 72cad6277e3a
comparison
equal deleted inserted replaced
1011:9d4af4b1c5c8 1012:875b0a9a3c92
498 OR forecast_generation_time IS NOT NULL), 498 OR forecast_generation_time IS NOT NULL),
499 value_lifetime timestamp with time zone, 499 value_lifetime timestamp with time zone,
500 CHECK(measure_type = 'minimum guaranteed' 500 CHECK(measure_type = 'minimum guaranteed'
501 OR value_lifetime IS NOT NULL) 501 OR value_lifetime IS NOT NULL)
502 ) 502 )
503
504 --
505 -- Import queue and respective logging
506 --
507 CREATE TYPE import_state AS ENUM ('queued', 'running', 'successful', 'failed')
508
509 CREATE TABLE imports (
510 id int PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY,
511 state import_state NOT NULL DEFAULT 'queued',
512 enqueued timestamp NOT NULL DEFAULT now(),
513 kind varchar NOT NULL,
514 username varchar NOT NULL
515 REFERENCES internal.user_profiles(username)
516 ON DELETE CASCADE ON UPDATE CASCADE,
517 data TEXT
518 )
519
520 CREATE INDEX enqueued_idx ON imports(enqueued, state)
521
522 CREATE TYPE log_type AS ENUM ('info', 'warn', 'error')
523
524 CREATE TABLE import_logs (
525 import_id int NOT NULL REFERENCES imports(id),
526 time timestamp NOT NULL DEFAULT now(),
527 kind log_type NOT NULL DEFAULT 'info',
528 msg TEXT NOT NULL
529 )
530 ; 503 ;
531 504
505 --
506 -- Import queue and respective logging
507 --
508 CREATE TYPE waterway.import_state AS ENUM ('queued', 'running', 'successful', 'failed');
509
510 CREATE TABLE waterway.imports (
511 id int PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY,
512 state waterway.import_state NOT NULL DEFAULT 'queued',
513 enqueued timestamp NOT NULL DEFAULT now(),
514 kind varchar NOT NULL,
515 username varchar NOT NULL
516 REFERENCES internal.user_profiles(username)
517 ON DELETE CASCADE ON UPDATE CASCADE,
518 data TEXT
519 );
520
521 CREATE INDEX enqueued_idx ON waterway.imports(enqueued, state);
522
523 CREATE TYPE waterway.log_type AS ENUM ('info', 'warn', 'error');
524
525 CREATE TABLE waterway.import_logs (
526 import_id int NOT NULL REFERENCES waterway.imports(id),
527 time timestamp NOT NULL DEFAULT now(),
528 kind waterway.log_type NOT NULL DEFAULT 'info',
529 msg TEXT NOT NULL
530 );
531
532 COMMIT; 532 COMMIT;