From 350e3102c682bf8a35026db486c9c508afb2368d Mon Sep 17 00:00:00 2001
From: Ian Harrigan <ianharrigan@hotmail.com>
Date: Tue, 5 Dec 2023 12:15:40 +0100
Subject: [PATCH] manually close statements

---
 src/sqlite/impl/cpp/SqliteDatabase.hx | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/sqlite/impl/cpp/SqliteDatabase.hx b/src/sqlite/impl/cpp/SqliteDatabase.hx
index bcc6aa3..6449dd7 100644
--- a/src/sqlite/impl/cpp/SqliteDatabase.hx
+++ b/src/sqlite/impl/cpp/SqliteDatabase.hx
@@ -24,6 +24,7 @@ class SqliteDatabase extends DatabaseBase {
                 }
                 var stmt = prepareStatement(sql);
                 stmt.executeStatement();
+                stmt.close();
                 resolve(new SqliteResult(this, true));
             } catch (e:Dynamic) {
                 reject(new SqliteError("Error", "SQLITE_ERROR: " + e));
@@ -41,11 +42,14 @@ class SqliteDatabase extends DatabaseBase {
                 var stmt = prepareStatement(sql, param);
                 var rs = stmt.executeQuery();
                 if (!rs.hasNext()) {
+                    stmt.close();
                     resolve(new SqliteResult(this, null));
                     return;
                 }
 
-                resolve(new SqliteResult(this, rs.next()));
+                var result = rs.next();
+                stmt.close();
+                resolve(new SqliteResult(this, result));
             } catch (e:Dynamic) {
                 reject(new SqliteError("Error", "SQLITE_ERROR: " + e));
             }
@@ -65,6 +69,7 @@ class SqliteDatabase extends DatabaseBase {
                 while (rs.hasNext()) {
                     records.push(rs.next());
                 }
+                stmt.close();
                 resolve(new SqliteResult(this, records));
             } catch (e:Dynamic) {
                 reject(new SqliteError("Error", "SQLITE_ERROR: " + e));
@@ -81,6 +86,7 @@ class SqliteDatabase extends DatabaseBase {
                 }
                 var stmt = prepareStatement(sql, param);
                 stmt.executeStatement();
+                stmt.close();
                 if (sql.indexOf("INSERT ") != -1) {
                     var lastInsertedId = _nativeDB.lastInsertRowId();
                     resolve(new SqliteResult(this, {