如何使用 node.js 在 AWS RDS PostgreSQL 上实现回调答案

【问题标题】：How to implement callbacks on AWS RDS PostgreSQL using node.js如何使用 node.js 在 AWS RDS PostgreSQL 上实现回调
【发布时间】：2023-03-29 11:46:02
【问题描述】：

我正在尝试在与 AWS RDS Postgresql 交互的 NodeJS EC2 服务器上实现回调。我不太确定它是如何完成的。 AWS-SDK 的 RDS 模块中似乎有一个 EventEmitter 方法。它专为 MySQL、Aurora 等所有 RDS 实例类型而设计。并非专门针对 postgres。我要做的就是在 INSERT 或 DELETE 查询之后获得某种回调。

【问题讨论】：

像往常一样简单地执行查询和获取数据有什么问题？

标签： node.js postgresql amazon-web-services amazon-ec2 callback

【解决方案1】：

不确定您的 postgres 是 RDS 还是 EC2 上的独立。你需要

var pg = require('pg'); var dbe={"result":null};

function Q(sqlQuery,callback) {
    /* async, vulnerable, simple */
    var conString = "postgres://"+dbUser+":"+dbPass+"@"+dbHost+":"+dbPort+"/"+dbName+"?ssl=true";
    pg.connect(conString, function(err, client, done) {
      if(err) {
        return console.error('error fetching client from pool', err);
      }
      client.query(sqlQuery, function(err, result) {
        done();//call `done()` to release the client back to the pool
        if(err) {
          return console.error('error running query', err);
        }
        dbe.result = result;
        //console.log(JSON.parse(result.setEncoding('utf8');));
        callback();
      });
    });
}

然后打电话

var res = Q('select now()', function(a) {console.log(dbe.result)});

或类似的 - 我没有操场来测试 atm

【讨论】：

换句话说——做一个简单的查询，不需要示例？
我的答案是一个 node.js 函数的例子，它带有查询 postgres 的回调