Node.js oracledb module -- TypeError: Cannot read property 'close' of undefined
Node.js oracledb module -- TypeError: Cannot read property 'close' of undefined
我正在尝试使用适用于 Nodejs 的 Oracledb npm 运行 简单 SQL 语句。这在过去没有问题,但突然间我在不同的环境中遇到了这个错误。可能是由于别名?我不确定。
导致问题的线路的目标是在连接完成或失败后关闭连接。我直接在 Oracle 的文档中找到了逻辑:http://oracle.github.io/node-oracledb/doc/api.html#connectionclose
非常感谢任何帮助!
const oracledb = require('oracledb');
const async = require('async');
const {getAwsSecret} = require('./awssecret');
var alias = "";
async function initialize() {
// Set Oracle Pool Settings
let hrPool = {
poolMin: 10,
poolMax: 10,
poolIncrement: 0
}
var secret = await getAwsSecret('MAIN');
const secretJSON = JSON.parse(secret);
hrPool.user = secretJSON[process.env.CURENV + 'username'];
hrPool.password = secretJSON[process.env.CURENV + 'password'];
hrPool.connectString = secretJSON[process.env.CURENV + 'host'] + '/' + secretJSON[process.env.CURENV + 'dbname'];
hrPool.poolAlias = secretJSON.alias;
alias = secretJSON.alias;
try {
await oracledb.createPool(hrPool);
} catch (err) {
console.log(err);
}
}
module.exports.initialize = initialize;
async function close() {
await oracledb.getPool().close();
}
module.exports.close = close;
async function simpleExecute(statement, binds = [],clientdetails = [], opts = {}) {
let conn;
opts.outFormat = oracledb.OBJECT;
opts.autoCommit = true;
try {
// Get Connection
conn = await oracledb.getConnection(alias);
// Run Query
const result = await conn.execute(statement, binds, opts);
///////////// POST EXECUTION HANDLING /////////////
if (conn) { // conn assignment worked, need to close
try {
// Close Connection
await conn.close();
// Return Result
return result;
} catch (err) {
console.log(err);
}
}
///////////// POST EXECUTION HANDLING /////////////
} catch (err) {
await conn.close();
}
}
module.exports.simpleExecute = simpleExecute;
错误:
TypeError: Cannot read property 'close' of undefined 2021-04-23T14:36:51.269-04:00 at
Object.simpleExecute (/usr/src/app/services/database.js:59:18)
如果获取连接时出错,您的 catch 块会在没有有效 conn
的情况下调用 conn.close()
。这给出了您看到的错误。这可能不是唯一的原因,但整理代码会有所帮助。
您的 conn.close()
可能只在 finally()
块中出现一次。查看 example.js 之类的示例,例如喜欢:
let connection;
try {
connection = await oracledb.getConnection(dbConfig);
result = await connection.execute(sql, binds, options);
console.dir(result, { depth: null });
} catch (err) {
console.error(err);
} finally {
if (connection) {
try {
await connection.close();
} catch (err) {
console.error(err);
}
}
}
一些其他提示:
- 如果您的代码要连续执行几条语句,那么不要对每条语句执行
getConnection()
/close()
。这会影响池的可伸缩性,因为共享池资源上有一些锁定,并且它会在整个步骤中添加额外的代码。
- 避免总是犯错。这可能会破坏事务的一致性并在不必要的情况下增加开销。
- 在
pool.close()
调用中使用明确的 drainTime
以确保它已关闭,请参阅 webapp.js。
我正在尝试使用适用于 Nodejs 的 Oracledb npm 运行 简单 SQL 语句。这在过去没有问题,但突然间我在不同的环境中遇到了这个错误。可能是由于别名?我不确定。
导致问题的线路的目标是在连接完成或失败后关闭连接。我直接在 Oracle 的文档中找到了逻辑:http://oracle.github.io/node-oracledb/doc/api.html#connectionclose
非常感谢任何帮助!
const oracledb = require('oracledb');
const async = require('async');
const {getAwsSecret} = require('./awssecret');
var alias = "";
async function initialize() {
// Set Oracle Pool Settings
let hrPool = {
poolMin: 10,
poolMax: 10,
poolIncrement: 0
}
var secret = await getAwsSecret('MAIN');
const secretJSON = JSON.parse(secret);
hrPool.user = secretJSON[process.env.CURENV + 'username'];
hrPool.password = secretJSON[process.env.CURENV + 'password'];
hrPool.connectString = secretJSON[process.env.CURENV + 'host'] + '/' + secretJSON[process.env.CURENV + 'dbname'];
hrPool.poolAlias = secretJSON.alias;
alias = secretJSON.alias;
try {
await oracledb.createPool(hrPool);
} catch (err) {
console.log(err);
}
}
module.exports.initialize = initialize;
async function close() {
await oracledb.getPool().close();
}
module.exports.close = close;
async function simpleExecute(statement, binds = [],clientdetails = [], opts = {}) {
let conn;
opts.outFormat = oracledb.OBJECT;
opts.autoCommit = true;
try {
// Get Connection
conn = await oracledb.getConnection(alias);
// Run Query
const result = await conn.execute(statement, binds, opts);
///////////// POST EXECUTION HANDLING /////////////
if (conn) { // conn assignment worked, need to close
try {
// Close Connection
await conn.close();
// Return Result
return result;
} catch (err) {
console.log(err);
}
}
///////////// POST EXECUTION HANDLING /////////////
} catch (err) {
await conn.close();
}
}
module.exports.simpleExecute = simpleExecute;
错误:
TypeError: Cannot read property 'close' of undefined 2021-04-23T14:36:51.269-04:00 at
Object.simpleExecute (/usr/src/app/services/database.js:59:18)
如果获取连接时出错,您的 catch 块会在没有有效 conn
的情况下调用 conn.close()
。这给出了您看到的错误。这可能不是唯一的原因,但整理代码会有所帮助。
您的 conn.close()
可能只在 finally()
块中出现一次。查看 example.js 之类的示例,例如喜欢:
let connection;
try {
connection = await oracledb.getConnection(dbConfig);
result = await connection.execute(sql, binds, options);
console.dir(result, { depth: null });
} catch (err) {
console.error(err);
} finally {
if (connection) {
try {
await connection.close();
} catch (err) {
console.error(err);
}
}
}
一些其他提示:
- 如果您的代码要连续执行几条语句,那么不要对每条语句执行
getConnection()
/close()
。这会影响池的可伸缩性,因为共享池资源上有一些锁定,并且它会在整个步骤中添加额外的代码。 - 避免总是犯错。这可能会破坏事务的一致性并在不必要的情况下增加开销。
- 在
pool.close()
调用中使用明确的drainTime
以确保它已关闭,请参阅 webapp.js。