dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-05-03 08:13:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

shell.executeQuery supports sqlFile

Browse Source
This commit is contained in:
SPRINX0\prochazka
2024-11-12 08:26:24 +01:00
parent 8976c9e653
commit 473bfcbec5
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
packages/api/src/shell/executeQuery.js
View File

@@ -1,3 +1,4 @@
const fs = require('fs-extra');
const requireEngineDriver = require('../utility/requireEngineDriver'); const requireEngineDriver = require('../utility/requireEngineDriver');
const connectUtility = require('../utility/connectUtility'); const connectUtility = require('../utility/connectUtility');
const { getLogger, getLimitedQuery } = require('dbgate-tools'); const { getLogger, getLimitedQuery } = require('dbgate-tools');
@@ -9,6 +10,7 @@ async function executeQuery({
systemConnection = undefined, systemConnection = undefined,
driver = undefined, driver = undefined,
sql, sql,
sqlFile = undefined,
logScriptItems = false, logScriptItems = false,
}) { }) {
if (!logScriptItems) { if (!logScriptItems) {
@@ -18,6 +20,11 @@ async function executeQuery({
if (!driver) driver = requireEngineDriver(connection); if (!driver) driver = requireEngineDriver(connection);
const dbhan = systemConnection || (await connectUtility(driver, connection, 'script')); const dbhan = systemConnection || (await connectUtility(driver, connection, 'script'));
if (sqlFile) {
logger.debug(`Loading SQL file ${sqlFile}`);
sql = await fs.readFile(sqlFile, { encoding: 'utf-8' });
}
try { try {
logger.info(`Connected.`); logger.info(`Connected.`);