From 7e63135abbb19f76562db432e4e61261b71fa025 Mon Sep 17 00:00:00 2001 From: Nikita Sivukhin Date: Thu, 9 Oct 2025 11:38:44 +0400 Subject: [PATCH] reset statement after execution --- bindings/javascript/packages/common/promise.ts | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/bindings/javascript/packages/common/promise.ts b/bindings/javascript/packages/common/promise.ts index db9dcb676..0ea8030b1 100644 --- a/bindings/javascript/packages/common/promise.ts +++ b/bindings/javascript/packages/common/promise.ts @@ -343,7 +343,6 @@ class Statement { */ async run(...bindParameters) { let stmt = await this.stmt.resolve(); - stmt.reset(); bindParams(stmt, bindParameters); @@ -370,6 +369,7 @@ class Statement { return { changes, lastInsertRowid }; } finally { + stmt.reset(); this.execLock.release(); } } @@ -382,7 +382,6 @@ class Statement { async get(...bindParameters) { let stmt = await this.stmt.resolve(); - stmt.reset(); bindParams(stmt, bindParameters); await this.execLock.acquire(); @@ -397,10 +396,12 @@ class Statement { return undefined; } if (stepResult === STEP_ROW) { - return stmt.row(); + const row = stmt.row(); + return row; } } } finally { + stmt.reset(); this.execLock.release(); } } @@ -413,7 +414,6 @@ class Statement { async *iterate(...bindParameters) { let stmt = await this.stmt.resolve(); - stmt.reset(); bindParams(stmt, bindParameters); await this.execLock.acquire(); @@ -432,6 +432,7 @@ class Statement { } } } finally { + stmt.reset(); this.execLock.release(); } } @@ -444,7 +445,6 @@ class Statement { async all(...bindParameters) { let stmt = await this.stmt.resolve(); - stmt.reset(); bindParams(stmt, bindParameters); const rows: any[] = []; @@ -466,6 +466,7 @@ class Statement { return rows; } finally { + stmt.reset(); this.execLock.release(); } }