diff --git a/plugins/dbgate-plugin-duckdb/src/backend/driver.js b/plugins/dbgate-plugin-duckdb/src/backend/driver.js index 7be4ebfda..5e8626eb8 100644 --- a/plugins/dbgate-plugin-duckdb/src/backend/driver.js +++ b/plugins/dbgate-plugin-duckdb/src/backend/driver.js @@ -73,16 +73,16 @@ const driver = { duckdb.StatementType.LOGICAL_PLAN, ]; - if (!returningStatementTypes.includes(stmt.statementType)) { - continue; - } - const result = await stmt.stream(); let hasSentColumns = false; while (true) { const chunk = await result.fetchChunk(); + if (!returningStatementTypes.includes(stmt.statementType)) { + break; + } + if (!chunk || chunk.rowCount === 0) { break; }