node.js - Nodejs - Postgres - 通知 - 错误绑定(bind)消息

Question

我正在使用 node-postgres (v-6.1.2)

这是我正在重构的代码，因为查询中有未参数化的参数。这不是我写的代码!

我有以下函数 publish，其中 pubClient 是

的结果

new pg.Client(pubsubUri).connect((err, client) => {
    if(err) return logger.error('database-connect', err.message)

    pubClient = client
})

当我运行 publish 时，出现以下错误:

错误:绑定(bind)消息提供 2 个参数，但准备语句“”需要 0 个

这是我的发布方法:(类型和消息都是字符串类型)

let publish = ( type, message) => {
    if (pubClient) {
        pubClient.query('NOTIFY "$1", \'$2\'', [type, message], (err, res) => {
            if (err) {
                console.log(err)
              return
            }
          return true
        })

    }

    return false
}

我不知道查询的正确语法是什么，也不知道为什么会出现此错误。

如有任何帮助，我们将不胜感激!

Answer 1

NOTIFY channel [ , payload ]

channel 不能参数化。尝试使用 pg_notify:

let publish = (type, message) => {
    if (pubClient) {
        pubClient.query('SELECT pg_notify($1, $2)', [type, message], (err, res) => {
            if (err) {
                console.log(err)
              return
            }
          return true
        })

    }

    return false
}