pg.Pool 的 query 用法

pg.Pool | node-postgreshttps://node-postgres.com/api/pool用法1：

const { Pool } = require('pg');class DB {constructor() {const init = (async () => {this.pool = new Pool(dbConfig);this.connect = await this.pool.connect(); // Calling connect() is necessary.delete this.thenreturn this})()this.then = init.then.bind(init)}async storeSqsEvent(event) {const message_id = Parser.parseMessageId_From_Sqs_Event(event);const message_body_str = event.body;const event_str = JSON.stringify(event);const sql = `INSERT INTO "message"."sqs_events" ("message_id", "message_body", "event") VALUES ('${message_id}','${message_body_str}','${event_str}');`;//注意：此处使用 pool.query(sql)await this.pool.query(sql);}
}

用法2：

const { Pool } = require('pg');class DB {constructor() {const init = (async () => {this.pool = new Pool(dbConfig);this.connect = await this.pool.connect(); // Calling connect() is necessary.delete this.thenreturn this})()this.then = init.then.bind(init)}async storeSqsEvent(event) {const message_id = Parser.parseMessageId_From_Sqs_Event(event);const message_body_str = event.body;const event_str = JSON.stringify(event);const sql = `INSERT INTO "message"."sqs_events" ("message_id", "message_body", "event") VALUES ($1, $2, $3);`;const values = [message_id, message_body_str, event_str];// 注意：此处使用 connect.query(sql, values)await this.connect.query(sql, values);}
}

错误用法：不会报错，但是无法写入postgres。

await this.pool.query(sql, values);

另外，INSERT 语句中不要包含为空的字段，否则无法写入。

pg.Pool 的 query 用法相关推荐

python Pool常用函数用法总结
在本篇内容里小编给大家整理的是一篇关于python Pool常用函数用法总结内容,有需要的朋友们可以学习下. 1.说明 apply_async(func[,args[,kwds]):使用非堵塞调用fu ...
oracle中$的用法,关于expdp 中query用法小结
今天看到群里有人问到关于在使用expdp导出数据中使用query参数报错的解决方法,自己也出于好奇心瞎折腾了一把,现记录如下 1.第一次尝试的时候[oracle@DB ~]$ expdp scott/ ...
MongoDB官方C#驱动中查询条件Query用法
MongoDB条件查询的基本语法. 1 Query.All("name", "a", "b");//通过多个元素来匹配数组 2 3 Quer ...
Golang sync.Pool 简介与用法
文章目录 1.简介 2.应用 2.1 标准库的应用 2.2 复用 bytes.Buffer 参考文章 1.简介 Pool 是可伸缩.并发安全的临时对象池,用来存放已经分配但暂时不用的临时对象,通过对象 ...
JPA的@Query用法
文章目录 @Query作用使用例子简单使用 like表达式原生sql 传参方式 SPEL表达式 nativeQuery 作用更新操作删除操作 @query返回自定义字段 @query返回自定 ...
oracle+app_query,query用法
[转]https://blog.csdn.net/tangzihao_c/article/details/52927347 一. 数据库介绍 1.数据库简介设计数据库要保证冗余(重复)度小,数据的 ...
ceph分布式存储-常见 PG 故障处理
3. 常见 PG 故障处理 3.1 PG 无法达到 CLEAN 状态创建一个新集群后,PG 的状态一直处于 active , active + remapped 或 active + degrade ...
【ceph】Ceph之PG状态详解--研读笔记
原文:分布式存储Ceph之PG状态详解 - 简书 Ceph中一些PG相关的状态说明和基本概念说明.故障模拟_pansaky的博客-CSDN博客 1. PG介绍继上次分享的<Ceph介绍及原理架 ...
Spring Data JPA 从入门到精通~@Query详解
语法及其源码 public @interface Query {/*** 指定JPQL的查询语句.(nativeQuery=true的时候,是原生的Sql语句)*/String value() def ...

pg.Pool 的 query 用法

pg.Pool 的 query 用法相关推荐

最新文章

热门文章