dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-04-27 06:46:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

removed incorrent readonly check

Browse Source
This commit is contained in:
Jan Prochazka
2022-06-23 10:42:12 +02:00
parent faedcfa64d
commit 8662353071
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
packages/api/src/proc/databaseConnectionProcess.js
View File

@@ -156,11 +156,11 @@ function resolveAnalysedPromises() {
afterAnalyseCallbacks = []; afterAnalyseCallbacks = [];
} }
async function handleRunScript({ msgid, sql }) { async function handleRunScript({ msgid, sql }, skipReadonlyCheck = false) {
await waitConnected(); await waitConnected();
const driver = requireEngineDriver(storedConnection); const driver = requireEngineDriver(storedConnection);
try { try {
ensureExecuteCustomScript(driver); if (!skipReadonlyCheck) ensureExecuteCustomScript(driver);
await driver.script(systemConnection, sql); await driver.script(systemConnection, sql);
process.send({ msgtype: 'response', msgid }); process.send({ msgtype: 'response', msgid });
} catch (err) { } catch (err) {
@@ -168,11 +168,11 @@ async function handleRunScript({ msgid, sql }) {
} }
} }
async function handleQueryData({ msgid, sql }) { async function handleQueryData({ msgid, sql }, skipReadonlyCheck = false) {
await waitConnected(); await waitConnected();
const driver = requireEngineDriver(storedConnection); const driver = requireEngineDriver(storedConnection);
try { try {
ensureExecuteCustomScript(driver); if (!skipReadonlyCheck) ensureExecuteCustomScript(driver);
const res = await driver.query(systemConnection, sql); const res = await driver.query(systemConnection, sql);
process.send({ msgtype: 'response', msgid, ...res }); process.send({ msgtype: 'response', msgid, ...res });
} catch (err) { } catch (err) {
@@ -184,7 +184,7 @@ async function handleSqlSelect({ msgid, select }) {
const driver = requireEngineDriver(storedConnection); const driver = requireEngineDriver(storedConnection);
const dmp = driver.createDumper(); const dmp = driver.createDumper();
dumpSqlSelect(dmp, select); dumpSqlSelect(dmp, select);
return handleQueryData({ msgid, sql: dmp.s }); return handleQueryData({ msgid, sql: dmp.s }, true);
} }
async function handleDriverDataCore(msgid, callMethod) { async function handleDriverDataCore(msgid, callMethod) {