Close database connections referenced in transaction.

examples/transactions/index.mjs

@@ -16,33 +16,36 @@ await client.batch(
 const names = ["John Doe", "Mary Smith", "Alice Jones", "Mark Taylor"];
 
 let transaction, secondTransaction;
-try {
-    transaction = await client.transaction("write");
 
+transaction = await client.transaction("write");
+try{
     for (const name of names) {
         await transaction.execute({
             sql: "INSERT INTO users (name) VALUES (?)",
             args: [name],
         });
     }
     await transaction.rollback();
+}finally {
+    secondTransaction?.close();
+}
 
-    secondTransaction = await client.transaction("write");
-
+secondTransaction = await client.transaction("write");
+try{
     for (const name of names) {
         await secondTransaction.execute({
             sql: "INSERT INTO users (name) VALUES (?)",
             args: [name],
         });
     }
-
     await secondTransaction.commit();
 } catch (e) {
-    console.error(e);
-    await transaction?.rollback();
-    await secondTransaction?.rollback();
+    await secondTransaction.rollback();
+}finally {
+    secondTransaction?.close();
 }
 
+
 const result = await client.execute("SELECT * FROM users");
 
 console.log("Users:", result.rows);

packages/libsql-client/src/sqlite3.ts

@@ -247,11 +247,13 @@ export class Sqlite3Client implements Client {
 export class Sqlite3Transaction implements Transaction {
     #database: Database.Database;
     #intMode: IntMode;
+    #dbClosed: boolean;
 
     /** @private */
     constructor(database: Database.Database, intMode: IntMode) {
         this.#database = database;
         this.#intMode = intMode;
+        this.#dbClosed = false;
     }
 
     async execute(stmt: InStatement): Promise<ResultSet>;
@@ -307,8 +309,19 @@ export class Sqlite3Transaction implements Transaction {
     }
 
     close(): void {
-        if (this.#database.inTransaction) {
-            executeStmt(this.#database, "ROLLBACK", this.#intMode);
+        try {
+            if (this.#database.inTransaction) {
+                executeStmt(this.#database, "ROLLBACK", this.#intMode);
+            }
+        } finally {
+            this.#dbClose();
+        }
+    }
+
+    #dbClose(): void {
+        if (!this.#dbClosed) {
+            this.#dbClosed = true;
+            this.#database.close();
         }
     }