diff --git a/scripts/helm/db/init_dbs/postgresql/1.5.X/1.5.X.sql b/scripts/helm/db/init_dbs/postgresql/1.5.X/1.5.X.sql index c8efda38c..b774c4bea 100644 --- a/scripts/helm/db/init_dbs/postgresql/1.5.X/1.5.X.sql +++ b/scripts/helm/db/init_dbs/postgresql/1.5.X/1.5.X.sql @@ -7,37 +7,47 @@ $$ SELECT 'v1.5.X' $$ LANGUAGE sql IMMUTABLE; +CREATE TYPE events_common.http_method AS ENUM ('GET','HEAD','POST','PUT','DELETE','CONNECT','OPTIONS','TRACE','PATCH'); --- Split requests-URL: -UPDATE events_common.requests -SET schema=CASE WHEN POSITION('://' IN url) > 0 THEN SUBSTRING(url, 1, POSITION('://' IN url) - 1) END, - host=CASE - WHEN POSITION('://' IN url) = 0 THEN NULL - WHEN POSITION('/' IN SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1)) > 0 THEN SUBSTRING( - SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1), 1, - POSITION('/' IN SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1)) - 1) - ELSE SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1) END, - base_path=CASE - WHEN POSITION('://' IN url) = 0 THEN - CASE - WHEN POSITION('?' IN url) > 0 THEN - SUBSTRING(url, 1, POSITION('?' IN url) - 1) - ELSE url END - WHEN POSITION('/' IN SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1)) > 0 THEN - CASE - WHEN POSITION('?' IN SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1)) > 0 THEN - SUBSTRING(SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1), - POSITION('/' IN SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1)) + 1, - POSITION('?' IN SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1)) - - POSITION('/' IN SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1)) - 1) - ELSE SUBSTRING(SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1), - POSITION('/' IN SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1)) + - 1) END - END, - query_string=CASE - WHEN POSITION('?' IN url) > 0 THEN SUBSTRING(url, POSITION('?' IN url) + 1) - END; +ALTER TABLE events_common.requests + ADD COLUMN IF NOT EXISTS schema text NULL, + ADD COLUMN IF NOT EXISTS host text NULL, + ADD COLUMN IF NOT EXISTS base_path text NULL, + ADD COLUMN IF NOT EXISTS query_string text NULL, + ADD COLUMN IF NOT EXISTS request_body text NULL, + ADD COLUMN IF NOT EXISTS response_body text NULL, + ADD COLUMN IF NOT EXISTS status_code text NULL, + ADD COLUMN IF NOT EXISTS method events_common.http_method NULL; +-- Split requests-URL: Takes too long to use +-- UPDATE events_common.requests +-- SET schema=CASE WHEN POSITION('://' IN url) > 0 THEN SUBSTRING(url, 1, POSITION('://' IN url) - 1) END, +-- host=CASE +-- WHEN POSITION('://' IN url) = 0 THEN NULL +-- WHEN POSITION('/' IN SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1)) > 0 THEN SUBSTRING( +-- SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1), 1, +-- POSITION('/' IN SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1)) - 1) +-- ELSE SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1) END, +-- base_path=CASE +-- WHEN POSITION('://' IN url) = 0 THEN +-- CASE +-- WHEN POSITION('?' IN url) > 0 THEN +-- SUBSTRING(url, 1, POSITION('?' IN url) - 1) +-- ELSE url END +-- WHEN POSITION('/' IN SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1)) > 0 THEN +-- CASE +-- WHEN POSITION('?' IN SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1)) > 0 THEN +-- SUBSTRING(SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1), +-- POSITION('/' IN SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1)) + 1, +-- POSITION('?' IN SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1)) - +-- POSITION('/' IN SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1)) - 1) +-- ELSE SUBSTRING(SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1), +-- POSITION('/' IN SUBSTRING(SUBSTRING(url, POSITION('://' IN url) + 3), 1)) + +-- 1) END +-- END, +-- query_string=CASE +-- WHEN POSITION('?' IN url) > 0 THEN SUBSTRING(url, POSITION('?' IN url) + 1) +-- END; COMMIT; \ No newline at end of file