pt/tps
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

update srce_set to create associated type

Browse Source
This commit is contained in:
Paul Trowbridge 2018-02-27 23:18:50 -05:00
parent 5e6af10c0d
commit e137977e94
2 changed files with 71 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
deploy/ubm_schema.sql
View File

@ -30,6 +30,19 @@ COMMENT ON SCHEMA tps IS 'third party source';
SET search_path = tps, pg_catalog; SET search_path = tps, pg_catalog;
--
-- Name: DCARD; Type: TYPE; Schema: tps; Owner: -
--
CREATE TYPE "DCARD" AS (
"Trans. Date" date,
"Post Date" date,
"Description" text,
"Amount" numeric,
"Category" text
);
-- --
-- Name: dcard; Type: TYPE; Schema: tps; Owner: - -- Name: dcard; Type: TYPE; Schema: tps; Owner: -
-- --
@ -362,6 +375,7 @@ DECLARE
_cnt int; _cnt int;
_conflict BOOLEAN; _conflict BOOLEAN;
_message jsonb; _message jsonb;
_sql text;
BEGIN BEGIN
@ -395,10 +409,11 @@ BEGIN
return _message; return _message;
END IF; END IF;
/*-----------------schema validation--------------------- /*-------------------------------------------------------
yeah dont feel like it right now schema validation
---------------------------------------------------------*/ ---------------------------------------------------------*/
-------------------insert definition----------------------------------------
INSERT INTO INSERT INTO
tps.srce tps.srce
SELECT SELECT
@ -407,6 +422,31 @@ BEGIN
SET SET
defn = _defn; defn = _defn;
------------------drop existing type-----------------------------------------
EXECUTE format('DROP TYPE IF EXISTS tps.%I',_name);
------------------create new type--------------------------------------------
SELECT
string_agg(quote_ident(prs.key)||' '||prs.type,',')
INTO
_sql
FROM
tps.srce
--unwrap the schema definition array
LEFT JOIN LATERAL jsonb_populate_recordset(null::tps.srce_defn_schema, defn->'schema') prs ON TRUE
WHERE
srce = _name
GROUP BY
srce;
RAISE NOTICE 'CREATE TYPE tps.% AS (%)',_name,_sql;
EXECUTE format('CREATE TYPE tps.%I AS (%s)',_name,_sql);
----------------set message-----------------------------------------------------
_message = _message =
$$ $$
{ {

31
functions/srce_edit.sql
View File

@ -6,6 +6,7 @@ DECLARE
_cnt int; _cnt int;
_conflict BOOLEAN; _conflict BOOLEAN;
_message jsonb; _message jsonb;
_sql text;
BEGIN BEGIN
@ -39,10 +40,11 @@ BEGIN
return _message; return _message;
END IF; END IF;
/*-----------------schema validation--------------------- /*-------------------------------------------------------
yeah dont feel like it right now schema validation
---------------------------------------------------------*/ ---------------------------------------------------------*/
-------------------insert definition----------------------------------------
INSERT INTO INSERT INTO
tps.srce tps.srce
SELECT SELECT
@ -51,6 +53,31 @@ BEGIN
SET SET
defn = _defn; defn = _defn;
------------------drop existing type-----------------------------------------
EXECUTE format('DROP TYPE IF EXISTS tps.%I',_name);
------------------create new type--------------------------------------------
SELECT
string_agg(quote_ident(prs.key)||' '||prs.type,',')
INTO
_sql
FROM
tps.srce
--unwrap the schema definition array
LEFT JOIN LATERAL jsonb_populate_recordset(null::tps.srce_defn_schema, defn->'schema') prs ON TRUE
WHERE
srce = _name
GROUP BY
srce;
RAISE NOTICE 'CREATE TYPE tps.% AS (%)',_name,_sql;
EXECUTE format('CREATE TYPE tps.%I AS (%s)',_name,_sql);
----------------set message-----------------------------------------------------
_message = _message =
$$ $$
{ {