我正在Heroku上编写一个node.js应用程序,并使用pg模块。我无法弄清楚为查询数据库所需的每个请求获取客户端对象的“正确”方法。
该文档使用如下代码:
pg.connect(conString, function(err, client) { // Use the client to do things here });
但是,您肯定不需要pg.connect在使用数据库的每个函数中调用对吗?我看过其他执行此操作的代码:
pg.connect
var conString = process.env.DATABASE_URL || "tcp://postgres:1234@localhost/postgres"; var client = new pg.Client(conString); client.connect(); // client is a global so you can use it anywhere now
我倾向于第二种选择,因为我相信Heroku的免费数据库实例无论如何都仅限于一个连接,但是以这种方式进行操作是否有任何弊端?每次使用之前,是否需要检查我的客户端对象是否仍处于连接状态?
我是node-postgres的作者。首先,我很抱歉文档未能阐明正确的选项:这是我的错。我会尝试改善它。我刚才写了一份Gist来解释这一点,因为对话对于Twitter来说时间太长了。
使用pg.connect是在Web环境中使用 的方式 。 PostgreSQL服务器每次连接一次只能处理1个查询。这意味着如果您有1个全局new pg.Client()连接到后端,则基于postgres响应查询的速度,整个应用程序将成为瓶颈。它实际上将所有内容排列在一起,对每个查询进行排队。是的,它是异步的,所以没关系…但是您不是将吞吐量乘以10倍吗?使用pg.connect 将设置 pg.defaults.poolSize为合理(我们进行25-100次,尚不确定正确的数字)。 new pg.Client当您知道自己在做什么时。当出于某种原因需要单个长期存在的客户端,或者需要非常仔细地控制生命周期时。一个很好的例子是使用 LISTEN/NOTIFY。侦听客户端需要在周围并且连接并且不共享,以便它可以正确处理NOTIFY消息。另一个示例是在打开1-off客户端以杀死某些挂起的东西或在命令行脚本中时。
使用pg.connect是在Web环境中使用 的方式 。
PostgreSQL服务器每次连接一次只能处理1个查询。这意味着如果您有1个全局new pg.Client()连接到后端,则基于postgres响应查询的速度,整个应用程序将成为瓶颈。它实际上将所有内容排列在一起,对每个查询进行排队。是的,它是异步的,所以没关系…但是您不是将吞吐量乘以10倍吗?使用pg.connect 将设置 pg.defaults.poolSize为合理(我们进行25-100次,尚不确定正确的数字)。
new pg.Client()
pg.defaults.poolSize
new pg.Client当您知道自己在做什么时。当出于某种原因需要单个长期存在的客户端,或者需要非常仔细地控制生命周期时。一个很好的例子是使用 LISTEN/NOTIFY。侦听客户端需要在周围并且连接并且不共享,以便它可以正确处理NOTIFY消息。另一个示例是在打开1-off客户端以杀死某些挂起的东西或在命令行脚本中时。
new pg.Client
LISTEN/NOTIFY
NOTIFY
一件事很有帮助,就是将对应用程序中数据库的所有访问集中到一个文件中。pg.connect在整个过程中,请勿乱扔电话或新客户。有一个像db.js这样的文件:
db.js
module.exports = { query: function(text, values, cb) { pg.connect(function(err, client, done) { client.query(text, values, function(err, result) { done(); cb(err, result); }) }); } }
这样,您可以将实现从pg.connect更改为自定义客户端池或任何其他内容,而只需要在一处更改。
看一下执行此操作的node-pg-query模块。