如何使用`createPool()` 从 Node.js 连接到 Oracle DB

Question

我尝试将 oracle 数据库连接到我的项目。我使用 createpool 以便在将来为来自数据库的所有必要请求调用此函数。我的 config.js 文件：

const oracledb = require('oracledb')
oracledb.outFormat = oracledb.OUT_FORMAT_OBJECT

const init = async function (query) {
  try {
    await oracledb.createPool({
      user: 'almat',
      password: 'almat789456123',
      connectString: '(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=localhost)(PORT=1521))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=xepdb1)))'
    })

    console.log('Connection pool started')

    await dostuff(query)
  } catch (err) {
    console.error('init() error: ' + err.message)
  } finally {
    // await closePoolAndExit()
  }
}

async function dostuff (query) {
  let connection
  try {
    connection = await oracledb.getConnection()
    const sql = query
    const binds = [1]
    const options = { outFormat: oracledb.OUT_FORMAT_OBJECT }
    const result = await connection.execute(sql, binds, options)
    console.log(result)
  } catch (err) {
    console.error(err)
  } finally {
    if (connection) {
      try {
        await connection.close()
      } catch (err) {
        console.error(err)
      }
    }
  }
}

async function closePoolAndExit () {
  console.log('\nTerminating')
  try {
    await oracledb.getPool().close(10)
    console.log('Pool closed')
    process.exit(0)
  } catch (err) {
    console.error(err.message)
    process.exit(1)
  }
}

process
  .once('SIGTERM', closePoolAndExit)
  .once('SIGINT', closePoolAndExit)

module.exports.init = init

我的 app.js 文件：

const express = require('express');
const config = require('./utils/config');

const app = express();

app.listen(3000, function () {
  console.log('Server running at port 3000')
})

app.set('view engine', 'ejs')
app.get('/', function (req, res) {
  return res.render('index')
})

app.get('/login', function (req, res) {
  return res.render('login')
})

app.get('/getCustomerName', function (req, res) {
  const query = 'SELECT firstname FROM customer WHERE :b = 1'
  const result = config.init(query)
  //console.log(typeof result)
  return res.send(result)
})

module.exports = app

当我请求 http://localhost:3000/getCustomerName 时，它​​返回空 json 文件，终端抛出此错误：NJS-047: poolAlias "default" not found in the connection pool cache

Answer 1

createPool() 调用应在应用程序初始化期间运行一次，例如在您调用express() 的时候。来自createPool() doc：

此方法使用指定的用户名、密码和连接字符串创建连接池。池通常在应用程序初始化期间创建一次。

init() 不应调用 doStuff()。创建池后，您的 Web 侦听器处理程序可以调用 dostuff()。

看基本的​​例子webapp.js。

另请参阅 Oracle 杂志系列 Build REST APIs for Node.js，其源代码为 here。