连接池永远不会使用node-oracledb和nodejs关闭

如何解决连接池永远不会使用node-oracledb和nodejs关闭

我正在使用Node Js和Oracle制作一些API，为此使用了node-oracledb。我受以下文章的指导：API with OracleDB and Node JS

项目文件包含以下内容：

/services/web-server.js

const http = require('http');
const morgan = require('morgan');
const express = require('express');
const webServerConfig = require('../config/web-server');

let httpServer;

function initialize(){
    return new Promise((resolve,reject) => {
        const app = express();
        httpServer = http.createServer(app);

        app.use(morgan('combined'));

        app.get('/',(req,res) => {
            res.end('Hello World');
        });

        httpServer.listen(webServerConfig.port,err => {
            if(err){
                reject(err);
                return;
            }          
            
            console.log(`Web server listening on localhost:${webServerConfig.port}`);

            resolve();
        });
    });
}

module.exports.initialize = initialize;

function close(){
    return new Promise((resolve,reject) => {
        httpServer.close(err => {
            if(err){
                reject(err);
                return;
            }

            resolve();
        });
    });
}

module.exports.close = close;

/services/database.js

const oracledb = require('oracledb');
const dbConfig = require('../config/database');

async function initialize(){
    const pool = await oracledb.createPool(dbConfig.gtsmpPool);
}

module.exports.initialize = initialize;

async function close(){
    await oracledb.getPool().close();
}

module.exports.close = close;

和/index.js

const webServer = require('./services/web-server');
const database = require('./services/database');
const dbConfig = require('./config/database');
const defaultThreadPoolSize = 4;

// Increase thread pool size by poolMax
process.env.UV_THREADPOOL_SIZE = dbConfig.gtsmpPool.poolMax + defaultThreadPoolSize;

async function startup(){
    console.log('Starting application');
    
    try{
        console.log('Initializing database module');

        await database.initialize();
    }catch(err){
        console.error(err);

        process.exit(1);    // Non-zero failure code
    }


    try{
        console.log('Initializing web server module');

        await webServer.initialize();
    }catch(err){
        console.error(err);

        process.exit(1);    // Non-zero failure code
    }
}

startup();

async function shutdown(e){
    let err = e;

    console.log('Shutting down');

    try{
        console.log('Closing web server module');

        await webServer.close();
    }catch(e){
        console.log('Encountered error',e);

        err = err || e;
    }

    console.log('Exiting process');

    try{
        console.log('Closing database module');

        await database.close();
    }catch(err){
        console.log('Encountered error',err);

        err = err || e;
    }

    if(err){
        process.exit(1);    // Non-zero failure code
    }else{
        process.exit(0);
    }
}

process.on('SIGTERM',() => {
    console.log('Received SIGTERM');

    shutdown();
});

process.on('SIGINT',() => {
    console.log('Received SIGINT');

    shutdown();
});
  
process.on('uncaughtException',err => {
    console.log('Uncaught exception');
    console.error(err);

    shutdown(err);
});

/config/database.js

module.exports = {    
    gtsmpPool: {
        user: process.env.GTSMP_USER,password: process.env.GTSMP_PASSWORD,connectString: process.env.GTSMP_CONNECTIONSTRING,poolMin: 10,poolMax: 10,poolIncrement: 0    
    }
};

与数据库的连接成功。问题是，当我想终止应用程序并关闭连接池时，await语句 oracledb.getPool（）。close（）从未解决，似乎卡住了。

如果我尝试强制完成，则会收到以下消息

Encountered error Error [ERR_SERVER_NOT_RUNNING]: Server is not running.
    at Server.close (net.js:1604:12)
    at Object.onceWrapper (events.js:416:28)
    at Server.emit (events.js:310:20)
    at emitCloseNT (net.js:1657:8)
    at processTicksAndRejections (internal/process/task_queues.js:83:21) {
  code: 'ERR_SERVER_NOT_RUNNING'

和

Encountered error Error: NJS-002: invalid pool

我正在docker容器，节点v12.16.3和Instantclient_18_5上使用Oracle 18c XE

任何想法如何解决？ 谢谢。

解决方法

node-oracledb pool example ...中有一些笔记

    // Get the pool from the pool cache and close it when no
    // connections are in use,or force it closed after 10 seconds.
    // If this hangs,you may need DISABLE_OOB=ON in a sqlnet.ora file.
    // This setting should not be needed if both Oracle Client and Oracle
    // Database are 19c (or later).
    await oracledb.getPool().close(10);