Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- async insertCSHealthCheck(connMsg) {
- const { connection, cert } = getConfig().postgresConf.cshealthcheck;
- clog.info('connection --> ' + connection)
- const postgresCS = new Postgres(connection, cert);
- const query = `INSERT INTO cs_health_check(id,org,info,is_send)
- VALUES('${connMsg.csHealthCheckID}','${connMsg.orgID}','${JSON.stringify((connMsg))}',false)`;
- clog.debug(query);
- // await postgresCS.client.connect();
- const { rowCount } = await postgresCS.client.query(query);
- // await postgresCS.client.end();
- return rowCount;
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement