Close connection on invalidate/destroy

OP-Engineering · Dec 14, 2024 · 31044c6 · 31044c6
1 parent b904ff2
commit 31044c6
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 9 deletions.
diff --git a/cpp/DBHostObject.cpp b/cpp/DBHostObject.cpp
@@ -32,8 +32,8 @@ void DBHostObject::flush_pending_reactive_queries(
     std::shared_ptr<std::vector<SmartHostObject>> metadata =
         std::make_shared<std::vector<SmartHostObject>>();
 
-    auto status = opsqlite_execute_prepared_statement(db, query->stmt,
-                                                      &results, metadata);
+    auto status = opsqlite_execute_prepared_statement(db, query->stmt, &results,
+                                                      metadata);
 
     if (status.type == SQLiteError) {
       invoker->invokeAsync(
@@ -892,8 +892,14 @@ void DBHostObject::set(jsi::Runtime &rt, const jsi::PropNameID &name,
   throw std::runtime_error("You cannot write to this object!");
 }
 
-void DBHostObject::invalidate() { invalidated = true; }
+void DBHostObject::invalidate() {
+  invalidated = true;
+  opsqlite_close(db);
+}
 
-DBHostObject::~DBHostObject() { invalidated = true; }
+DBHostObject::~DBHostObject() {
+  invalidated = true;
+  opsqlite_close(db);
+}
 
 } // namespace opsqlite
diff --git a/example/src/App.tsx b/example/src/App.tsx
@@ -39,13 +39,13 @@ export default function App() {
   useEffect(() => {
     runTests(
       queriesTests,
-      // dbSetupTests,
-      // blobTests,
+      dbSetupTests,
+      blobTests,
       // registerHooksTests,
-      // preparedStatementsTests,
-      // constantsTests,
+      preparedStatementsTests,
+      constantsTests,
       // reactiveTests,
-      // tokenizerTests,
+      tokenizerTests,
     )
       .then(results => {
         setServerResults(results as any);