tps/interface/source_maint/srce_set_dev.sql

DO $f$

DECLARE
_defn jsonb;
_cnt int;
_conflict BOOLEAN;
_message jsonb;
_sql text;
_cur_sch jsonb;

BEGIN

    SELECT  
        $$
        {
            "name":"dcard",
            "source":"client_file",
            "loading_function":"csv",
            "constraint":[
                "{Trans. Date}",
                "{Post Date}"
            ],
            "schemas":{
                "default":[
                    {
                        "path":"{Trans. Date}",
                        "type":"date",
                        "column_name":"Trans. Date"
                    },
                    {
                        "path":"{Post Date}",
                        "type":"date",
                        "column_name":"Post Date"
                    },
                    {
                        "path":"{Description}",
                        "type":"text",
                        "column_name":"Description"
                    },
                    {
                        "path":"{Amount}",
                        "type":"numeric",
                        "column_name":"Amount"
                    },
                    {
                        "path":"{Category}",
                        "type":"text",
                        "column_name":"Category"
                    }
                ],
                "version2":[]
            }
        }
        $$
    INTO
        _defn;
/*
1. determine if insert or update
2. if update, determine if conflicts exists
3. do merge
*/

    -------extract current source schema for compare--------------------------
    SELECT
        defn#>'{schemas,default}'
    INTO
        _cur_sch
    FROM
        tps.srce
    WHERE
        srce = _defn->>'name';

    -------check for transctions already existing under this source-----------
    SELECT
        COUNT(*)
    INTO
        _cnt
    FROM
        tps.trans
    WHERE
        srce = _defn->>'name';

    --if there are transaction already and the schema is different stop--------
    IF _cnt > 0 THEN
        IF _cur_sch <> _defn->'schema' THEN
            _conflict = TRUE;
            --get out of the function somehow
            _message = 
            $$
                    {
    "message": "transactions already exist under source profile and there is a pending schema change",
    "status": "error"
}
            $$: :jsonb;
            return _message;
        END IF;
    END IF;

    /*-------------------------------------------------------
    do schema validation fo _defn object?
    ---------------------------------------------------------*/
    
    -------------------insert definition----------------------------------------
    INSERT INTO
        tps.srce
    SELECT
        _defn->>'name', _defn
    ON CONFLICT ON CONSTRAINT srce_pkey DO UPDATE
        SET
            defn = _defn;

    ------------------drop existing type-----------------------------------------

    EXECUTE format('DROP TYPE IF EXISTS tps.%I',_defn->>'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 = _defn->>'name'
    GROUP BY
        srce;

    RAISE NOTICE 'CREATE TYPE tps.% AS (%)',_defn->>'name',_sql;

    EXECUTE format('CREATE TYPE tps.%I AS (%s)',_defn->>'name',_sql);

    EXECUTE format('COMMENT ON TYPE tps.%I IS %L',_defn->>'name',(_defn->>'description'));

    ----------------set message-----------------------------------------------------
    
    _message = 
        $$
                {
    "message": "definition set",
    "status": "success"
}
        $$: :jsonb;
    return _message;

END;
$f$
LANGUAGE plpgsql