pg-promise 中的查询超时
Query timeout in pg-promise
我想为 pg-promise 查询添加超时,这样如果数据库尚未响应,它们将在一段时间后失败。
有没有推荐的方法来做到这一点,或者我应该制作自定义包装器来处理计时器并在为时已晚时拒绝承诺?
来自pg-promise的作者...
pg-promise 不支持查询取消,因为它是一种解决不正确的数据库设计或错误的查询执行的技巧。
PostgreSQL 支持在执行耗时查询时应使用的事件,因此可以设置一个事件侦听器,以便在特定 data/view 可用时触发。请参阅 LISTEN/NOTIFY 示例。
您可以使用您自己的自定义查询方法扩展 pg-promise,该方法会因拒绝而超时(参见下面的示例),但这又是另一个解决设计问题的方法。
使用 Bluebird 的示例:
const Promise = require('bluebird');
Promise.config({
cancellation: true
});
const initOptions = {
promiseLib: Promise,
extend(obj) {
obj.queryTimeout = (query, values, delay) => {
return obj.any(query, values).timeout(delay);
}
}
};
const pgp = require('pg-promise')(initOptions);
const db = pgp(/* connection details */);
然后你就可以在每一关都使用db.queryTimeout(query, values, delay)
了。
或者,如果您正在使用 Bluebird,您可以将 .timeout(delay)
链接到任何现有方法:
db.any(query, values)
.timeout(500)
.then(data => {})
.catch(error => {})
另请参阅:
更新
从版本 8.5.3 开始,pg-promise 通过连接对象中的 属性 query_timeout
开始支持查询超时。
您可以覆盖默认值:
pgp.pg.defaults.query_timeout = 3000; // timeout every query after 3 seconds
或者在连接对象中指定:
const db = pgp({
/* all connection details */
query_timeout: 3000
});
我想为 pg-promise 查询添加超时,这样如果数据库尚未响应,它们将在一段时间后失败。 有没有推荐的方法来做到这一点,或者我应该制作自定义包装器来处理计时器并在为时已晚时拒绝承诺?
来自pg-promise的作者...
pg-promise 不支持查询取消,因为它是一种解决不正确的数据库设计或错误的查询执行的技巧。
PostgreSQL 支持在执行耗时查询时应使用的事件,因此可以设置一个事件侦听器,以便在特定 data/view 可用时触发。请参阅 LISTEN/NOTIFY 示例。
您可以使用您自己的自定义查询方法扩展 pg-promise,该方法会因拒绝而超时(参见下面的示例),但这又是另一个解决设计问题的方法。
使用 Bluebird 的示例:
const Promise = require('bluebird');
Promise.config({
cancellation: true
});
const initOptions = {
promiseLib: Promise,
extend(obj) {
obj.queryTimeout = (query, values, delay) => {
return obj.any(query, values).timeout(delay);
}
}
};
const pgp = require('pg-promise')(initOptions);
const db = pgp(/* connection details */);
然后你就可以在每一关都使用db.queryTimeout(query, values, delay)
了。
或者,如果您正在使用 Bluebird,您可以将 .timeout(delay)
链接到任何现有方法:
db.any(query, values)
.timeout(500)
.then(data => {})
.catch(error => {})
另请参阅:
更新
从版本 8.5.3 开始,pg-promise 通过连接对象中的 属性 query_timeout
开始支持查询超时。
您可以覆盖默认值:
pgp.pg.defaults.query_timeout = 3000; // timeout every query after 3 seconds
或者在连接对象中指定:
const db = pgp({
/* all connection details */
query_timeout: 3000
});