diff --git a/srce.pgsql b/srce.pgsql index 1bf3a42..39657aa 100644 --- a/srce.pgsql +++ b/srce.pgsql @@ -2,15 +2,18 @@ DO $$ declare _t text; +declare _c text; begin ----------------------------------------------------build the column list of the temp table---------------------------------------------------------------- SELECT - string_agg(quote_ident(prs.key)||' '||prs.type,',') + string_agg(quote_ident(prs.key)||' '||prs.type,','), + string_agg(quote_ident(prs.key),',') INTO - _t + _t, + _c FROM TPS.srce --unwrap the schema definition array @@ -24,6 +27,7 @@ begin _t := format('CREATE TEMP TABLE csv_i (%s)', _t); raise notice '%', _t; + raise notice '%', _c; ----------------------------------------------------build the table----------------------------------------------------------------------------------------- @@ -32,15 +36,29 @@ begin EXECUTE _t; - COPY csv_i FROM 'C:\Users\fleet\downloads\dc.csv' WITH (HEADER TRUE,DELIMITER ',', FORMAT CSV, ENCODING 'SQL_ASCII',QUOTE '"'); + ALTER TABLE csv_i ADD COLUMN id SERIAL; + + --the column list needs to be dynamic forcing this whole line to be dynamic + COPY csv_i ("Trans. Date","Post Date","Description","Amount","Category")FROM 'C:\Users\fleet\downloads\dc.csv' WITH (HEADER TRUE,DELIMITER ',', FORMAT CSV, ENCODING 'SQL_ASCII',QUOTE '"'); end $$; -SELECT * FROM csv_i; - +--SELECT * FROM csv_i; +SELECT + jsonb_build_object( + (ae.e::text[])[1], --the key name + (row_to_json(i)::jsonb) #> ae.e::text[] --get the target value from the key from the csv row that has been converted to json + ) json_key, + srce, + ae.rn +FROM + csv_i i + INNER JOIN tps.srce s ON + s.srce = 'DCARD' + LEFT JOIN LATERAL JSONB_ARRAY_ELEMENTS_TEXT(defn->'unique_constraint'->'fields') WITH ORDINALITY ae(e, rn) ON TRUE; /* INSERT INTO