diff --git a/integration-tests/__tests__/query.spec.js b/integration-tests/__tests__/query.spec.js
index 590e38ef6..1336a7df6 100644
--- a/integration-tests/__tests__/query.spec.js
+++ b/integration-tests/__tests__/query.spec.js
@@ -119,7 +119,7 @@ describe('Query', () => {
   );
 
   test.each(engines.map(engine => [engine.label, engine]))(
-    'Script - %s',
+    'Script - return data - %s',
     testWrapper(async (conn, driver, engine) => {
       const results = await executeStream(
         driver,
@@ -134,6 +134,18 @@ describe('Query', () => {
     })
   );
 
+  test.each(engines.map(engine => [engine.label, engine]))(
+    'Script - no data - %s',
+    testWrapper(async (conn, driver, engine) => {
+      const results = await executeStream(
+        driver,
+        conn,
+        'CREATE TABLE t1 (id int); INSERT INTO t1 (id) VALUES (1); INSERT INTO t1 (id) VALUES (2) '
+      );
+      expect(results.length).toEqual(0);
+    })
+  );
+
   test.each(engines.map(engine => [engine.label, engine]))(
     'Save data query - %s',
     testWrapper(async (conn, driver, engine) => {
@@ -144,7 +156,7 @@ describe('Query', () => {
         'INSERT INTO t1 (id) VALUES (3);INSERT INTO t1 (id) VALUES (4);UPDATE t1 SET id=10 WHERE id=1;DELETE FROM t1 WHERE id=2;'
       );
       const res = await driver.query(conn, 'SELECT COUNT(*) AS cnt FROM t1');
-      console.log(res);
+      // console.log(res);
       expect(res.rows[0].cnt == 3).toBeTruthy();
     })
   );
diff --git a/packages/api/src/proc/databaseConnectionProcess.js b/packages/api/src/proc/databaseConnectionProcess.js
index e8c3d099d..898697049 100644
--- a/packages/api/src/proc/databaseConnectionProcess.js
+++ b/packages/api/src/proc/databaseConnectionProcess.js
@@ -125,7 +125,7 @@ async function handleRunScript({ msgid, sql }) {
   await waitConnected();
   const driver = requireEngineDriver(storedConnection);
   try {
-    await driver.script(sql);
+    await driver.script(systemConnection, sql);
     process.send({ msgtype: 'response', msgid });
   } catch (err) {
     process.send({ msgtype: 'response', msgid, errorMessage: err.message });