diff --git a/plugins/dbgate-plugin-mongo/src/backend/driver.js b/plugins/dbgate-plugin-mongo/src/backend/driver.js index 4a795bc42..b2e76ccac 100644 --- a/plugins/dbgate-plugin-mongo/src/backend/driver.js +++ b/plugins/dbgate-plugin-mongo/src/backend/driver.js @@ -547,6 +547,10 @@ const driver = { })), }; }, + + async close(dbhan) { + return dbhan.client.close(); + }, }; module.exports = driver; diff --git a/plugins/dbgate-plugin-oracle/src/backend/driver.js b/plugins/dbgate-plugin-oracle/src/backend/driver.js index b1c3f39c2..8a44b77ef 100644 --- a/plugins/dbgate-plugin-oracle/src/backend/driver.js +++ b/plugins/dbgate-plugin-oracle/src/backend/driver.js @@ -5,7 +5,6 @@ const driverBase = require('../frontend/driver'); const Analyser = require('./Analyser'); const { createBulkInsertStreamBase, makeUniqueColumnNames } = global.DBGATE_PACKAGES['dbgate-tools']; const createOracleBulkInsertStream = require('./createOracleBulkInsertStream'); -const { platform } = require('os'); let requireOracledb; let platformInfo; @@ -94,7 +93,7 @@ const driver = { }; }, async close(dbhan) { - return dbhan.client.end(); + return dbhan.client.close(); }, async query(dbhan, sql) { if (sql == null || sql.trim() == '') { diff --git a/plugins/dbgate-plugin-redis/src/backend/driver.js b/plugins/dbgate-plugin-redis/src/backend/driver.js index b9864d027..d33f83962 100644 --- a/plugins/dbgate-plugin-redis/src/backend/driver.js +++ b/plugins/dbgate-plugin-redis/src/backend/driver.js @@ -371,6 +371,10 @@ const driver = { } return null; }, + + async close(dbhan) { + return dbhan.client.quit(); + }, }; module.exports = driver; diff --git a/plugins/dbgate-plugin-sqlite/src/backend/driver.js b/plugins/dbgate-plugin-sqlite/src/backend/driver.js index 4c7860f6e..1e624aea1 100644 --- a/plugins/dbgate-plugin-sqlite/src/backend/driver.js +++ b/plugins/dbgate-plugin-sqlite/src/backend/driver.js @@ -70,7 +70,8 @@ const driver = { }; }, async close(dbhan) { - return dbhan.client.close(); + // sqlite close is sync, returns this + dbhan.client.close(); }, // @ts-ignore async query(dbhan, sql) {