diff --git a/packages/api/src/shell/executeQuery.js b/packages/api/src/shell/executeQuery.js index 1a19411dc..4d7bd6c88 100644 --- a/packages/api/src/shell/executeQuery.js +++ b/packages/api/src/shell/executeQuery.js @@ -1,3 +1,4 @@ +const fs = require('fs-extra'); const requireEngineDriver = require('../utility/requireEngineDriver'); const connectUtility = require('../utility/connectUtility'); const { getLogger, getLimitedQuery } = require('dbgate-tools'); @@ -9,6 +10,7 @@ async function executeQuery({ systemConnection = undefined, driver = undefined, sql, + sqlFile = undefined, logScriptItems = false, }) { if (!logScriptItems) { @@ -18,6 +20,11 @@ async function executeQuery({ if (!driver) driver = requireEngineDriver(connection); 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 { logger.info(`Connected.`);