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

revert to rebuilding the sql

Browse Source
This commit is contained in:
fleetside72 2018-12-04 00:53:45 -05:00
parent 136bb030c9
commit 765a239408
1 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
server.js
View File

@ -52,13 +52,22 @@ server.get("/source", function (inReq, inRes)
Postgres.FirstRow(sql,[], inRes); Postgres.FirstRow(sql,[], inRes);
}); });
//returns message about status and error description //returns message about status and error description
server.post("/sourc_single", bodyParser.json(), function (inReq, inRes)// remove body parsing, just pass post body to the sql string build
{
for (var i =0; i < x.length; i++) {
var sql = "SELECT x.message FROM tps.srce_set($1::jsonb) as x(message)";
}
Postgres.FirstRow(sql,inReq.body, inRes);
});
server.post("/source", bodyParser.json(), function (inReq, inRes)// remove body parsing, just pass post body to the sql string build server.post("/source", bodyParser.json(), function (inReq, inRes)// remove body parsing, just pass post body to the sql string build
{ {
x = inReq.body; x = inReq.body;
for (var i =0; i < x.length; i++) { var sql = "SELECT\
var sql = "SELECT x.message FROM tps.srce_set($1::jsonb) as x(message)"; jsonb_agg(x.message) message\
FROM\
jsonb_array_elements($1::jsonb) d(def)\
JOIN LATERAL tps.srce_set(d.def) x(message) ON TRUE";
Postgres.FirstRow(sql,[JSON.stringify(x[i])], inRes); Postgres.FirstRow(sql,[JSON.stringify(x[i])], inRes);
}
}); });
//----------------------------------------------------------regex instrUctions------------------------------------------------------------------------------------------------------------------------- //----------------------------------------------------------regex instrUctions-------------------------------------------------------------------------------------------------------------------------