Oracledb (NodeJS) 在我每次创建一个新池时工作，但不是没有需要它来使用已经创建的池

问题描述

遵循教程以使其适用于 Oracle 内部的存储过程。我的 GET/SELECT 语句可以正常工作，其中基于进行 GET 调用的用户会更改池，以便 SELECT 来自正确的用户。

适用于 GET/SELECT 的池创建

async function initialize() {

   await oracledb.createPool({
    user: 'user1',password: 'pass1',connectString: 'oracledb.website/dev',poolAlias: 'pool1'
  });

  await oracledb.createPool({
    user: 'user2',password: 'pass2',poolAlias: 'pool2'
  });

}

可以在此处找到我遵循的存储过程教程：https://blogs.oracle.com/opal/using-dbmsoutput-with-nodejs-and-node-oracledb

您将看到，在此示例中，他为每个请求创建了一个新池。

oracledb.createPool(
  dbconfig,function(err,pool) {
if (err)
console.error(err.message)
else
doit(pool);
});
var doit = function(pool) {

请注意，上面使用的 dbConfig 是一个数组，如：

dbconfig.hrPool.user = 'user3';
dbconfig.hrPool.password = 'pass3';
dbconfig.hrPool.connectString = 'oracle.site/dev';

如果您指定一个 poolAlias，这将导致问题，并且您很快就会尝试创建一个已经存在的池别名，并出现如下错误：

"njs-046: poolAlias "pool1" already exists in the connection pool cache.

我曾尝试自己更新此代码，但我对 asyc/waterfalls/callbacks 不够熟悉，无法让它继续运行。

我尝试的内容如下（它实际上从未运行过任何东西）：

  return new Promise(async (resolve,reject) => {
  async.waterfall(
    [
      function(cb) {
          oracledb.getConnection('pool1');
      },enableDbmsOutput,createDbmsOutput,fetchDbmsOutputLine
    ],function (err,conn,cb) {
      if (err) {
        console.error("In waterfall error cb: ==>",err,"<== THIS IS WHERE THE ORACLE ERROR WILL SHOW!"); 
                 // Release the Oracle Connection
        conn.release(function (err) {
          if (err) console.error(err.message); 
         });
    }
    }
  );

var enableDbmsOutput = function (conn,cb) {
  conn.execute(
    "BEGIN DBMS_OUTPUT.ENABLE(NULL); END;",function(err) { return cb(err,conn); });
};

var createDbmsOutput = function (conn,cb) {
  console.log('I NEVER MAKE IT HERE')
 conn.execute(query,conn); });
};

var fetchDbmsOutputLine = function (conn,cb) {
  conn.execute(
    "BEGIN DBMS_OUTPUT.GET_LINE(:ln,:st); END;",{ ln: { dir: oracledb.BIND_OUT,type: oracledb.STRING,maxSize: 32767 },st: { dir: oracledb.BIND_OUT,type: oracledb.NUMBER } },result) {
      if (err) {
        return cb(err,conn);
      } else if (result.outBinds.st == 1) {
        return cb(null,conn);  // no more output
      } else {
        resolve(result);

        return fetchDbmsOutputLine(conn,cb);
      }
    });
};
})
}

非常感谢您的帮助！

解决方法

您引用的博客是一个命令行脚本，并且只创建一次池。这发生在脚本的开头。这也是一篇旧博客文章。它的所有异步模块调用和 JS 回调现在应该/将被 Node.js 较新的 async/await 语法替换。还要避免直接使用 Promise() - 代码太混乱了。

由于您正在创建某种网络侦听器，您应该在应用启动期间创建池，而不是为每个网络请求创建池。

检查 node-oracledb 示例 webapp.js。

async function init() {
  try {
    await oracledb.createPool({
      user: dbConfig.user,password: dbConfig.password,connectString: dbConfig.connectString
    });

    // Create HTTP server and listen on port httpPort
    const server = http.createServer();
    server.on('error',(err) => {
      console.log('HTTP server problem: ' + err);
    });
    server.on('request',(request,response) => {
      handleRequest(request,response);
    });
    await server.listen(httpPort);
    console.log("Server is running at http://localhost:" + httpPort);
  } catch (err) {
    console.error("init() error: " + err.message);
  }
}

async function handleRequest(request,response) {

...  // Your code to handle each web request goes here.

}


init();

您也可以等待查看 PL/SQL 过程示例 plsqlproc.js。

async-await javascript node-oracledb oracle