From 6cff7b3c308af4ae7f0d31c172f62bdb685bd1cb Mon Sep 17 00:00:00 2001
From: "SPRINX0\\prochazka" <jan.prochazka@sprinx.com>
Date: Thu, 24 Apr 2025 15:16:39 +0200
Subject: [PATCH] duckdb: catch syntax error in query

---
 .../dbgate-plugin-duckdb/src/backend/driver.js    | 15 ++++++++-------
 1 file changed, 8 insertions(+), 7 deletions(-)

diff --git a/plugins/dbgate-plugin-duckdb/src/backend/driver.js b/plugins/dbgate-plugin-duckdb/src/backend/driver.js
index c7e5d54d5..08aa46bce 100644
--- a/plugins/dbgate-plugin-duckdb/src/backend/driver.js
+++ b/plugins/dbgate-plugin-duckdb/src/backend/driver.js
@@ -56,10 +56,11 @@ const driver = {
   },
   async stream(dbhan, sql, options) {
     const duckdb = getDuckDb();
-    const statements = await dbhan.client.extractStatements(sql);
-    const count = statements.count;
 
     try {
+      const statements = await dbhan.client.extractStatements(sql);
+      const count = statements.count;
+
       for (let i = 0; i < count; i++) {
         let hasSentColumns = false;
         const stmt = await statements.prepare(i);
@@ -77,11 +78,11 @@ const driver = {
           continue;
         }
 
-        options.info({
-          message: JSON.stringify(res),
-          time: new Date(),
-          severity: 'info',
-        });
+        // options.info({
+        //   message: JSON.stringify(res),
+        //   time: new Date(),
+        //   severity: 'info',
+        // });
 
         if (!hasSentColumns) {
           const columnNames = res.columnNames();