3

我在 PostgreSQL 数据库中有一个名为“posts”的表。

所以我想做的是观看帖子表并在插入任何数据时获得通知。

所以我创建了这个 notify_changes_of_posts_Table 函数像这样：

CREATE OR REPLACE FUNCTION notify_changes_of_posts_Table()
RETURNS trigger AS $$
BEGIN
  PERFORM pg_notify(
    'posts_changes',
    json_build_object(
      'operation', TG_OP,
      'record', row_to_json(NEW)
    )::text
  );

  RETURN NEW;
END;
$$ LANGUAGE plpgsql;

我还创建了事件触发器，如下所示：

CREATE TRIGGER posts_changes
AFTER INSERT 
ON posts
FOR EACH ROW
EXECUTE PROCEDURE notify_changes_of_posts_Table()

我的服务器像这样连接到数据库：

const db = knex({
  client: 'pg',
  connection: {
    host : '127.0.0.1',
    user : 'postgres',
    password : 'admin',
    database : 'mydb'
  }
});

请注意，服务器 Nodejs 使用 knex.js 工具连接到数据库。

所以为了获得通知，我需要使用“ LISTEN ”，但我不知道如何实现，我检查了 knex.js 的官方文档，找不到与该主题相关的任何信息。

所以伙计们，我在这里完成这项工作感到困惑，所以如果我错了，如果有人可以在这里帮助我提供代码或建议，因为我现在非常困惑。
提前谢谢你们<3

4

1 回答 1

6

可能这会在未来帮助某人：

async function notify(){
const connection = await db.client.acquireConnection();
connection.query('LISTEN addedrecordp');
connection.on('notification', (msg) => {
   console.log("got " + msg.channel + " payload " + msg.payload);
   
   })

});

await db.client.releaseConnection(connection);

}
于 2020-11-14T06:26:01.897 回答