WIP

Author: js2702

.DS_Store

@@ -15,8 +15,8 @@ import 'package:sqlite_async/sqlite_async.dart';
 class SqliteAsyncDriftConnection extends DatabaseConnection {
   late StreamSubscription _updateSubscription;
 
-  SqliteAsyncDriftConnection(SqliteConnection db)
-      : super(SqliteAsyncQueryExecutor(db)) {
+  SqliteAsyncDriftConnection(SqliteConnection db, {bool logStatements = false})
+      : super(SqliteAsyncQueryExecutor(db, logStatements: logStatements)) {
     _updateSubscription = (db as SqliteQueries).updates!.listen((event) {
       var setUpdates = <TableUpdate>{};
       for (var tableName in event.tables) {

packages/drift_sqlite_async/lib/src/connection.dart

@@ -9,7 +9,9 @@ class _SqliteAsyncDelegate extends DatabaseDelegate {
   final SqliteConnection db;
   bool _closed = false;
 
-  _SqliteAsyncDelegate(this.db);
+  _SqliteAsyncDelegate(
+    this.db,
+  );
 
   @override
   late final DbVersionDelegate versionDelegate =
@@ -127,10 +129,8 @@ class _SqliteAsyncVersionDelegate extends DynamicVersionDelegate {
 /// Extnral update notifications from the [SqliteConnection] are _not_ forwarded
 /// automatically - use [SqliteAsyncDriftConnection] for that.
 class SqliteAsyncQueryExecutor extends DelegatedDatabase {
-  SqliteAsyncQueryExecutor(SqliteConnection db)
-      : super(
-          _SqliteAsyncDelegate(db),
-        );
+  SqliteAsyncQueryExecutor(SqliteConnection db, {bool logStatements = false})
+      : super(_SqliteAsyncDelegate(db), logStatements: logStatements);
 
   /// The underlying SqliteConnection used by drift to send queries.
   SqliteConnection get db {

packages/drift_sqlite_async/lib/src/executor.dart

@@ -50,6 +50,8 @@ abstract class SqliteDatabase
   /// The maximum number of concurrent read transactions if not explicitly specified.
   static const int defaultMaxReaders = 5;
 
+  int get numConnections;
+
   /// Open a SqliteDatabase.
   ///
   /// Only a single SqliteDatabase per [path] should be opened at a time.

packages/sqlite_async/lib/src/common/sqlite_database.dart

@@ -64,4 +64,7 @@ class SqliteDatabaseImpl
   Future<bool> getAutoCommit() {
     throw UnimplementedError();
   }
+
+  @override
+  int get numConnections => throw UnimplementedError();
 }

packages/sqlite_async/lib/src/impl/stub_sqlite_database.dart

@@ -232,6 +232,10 @@ class SqliteConnectionPool with SqliteQueries implements SqliteConnection {
       await connection.refreshSchema();
     }
   }
+
+  getNumConnections() {
+    return _allReadConnections.length + (_writeConnection == null ? 0 : 1);
+  }
 }
 
 typedef ReadCallback<T> = Future<T> Function(SqliteReadContext tx);

packages/sqlite_async/lib/src/native/database/connection_pool.dart

@@ -95,6 +95,7 @@ class SqliteConnectionImpl
 
   @override
   Future<void> close() async {
+    print("Closing native sqlite Connection ${StackTrace.current}");
     eventsPort?.close();
     await _connectionMutex.lock(() async {
       if (readOnly) {

packages/sqlite_async/lib/src/native/database/native_sqlite_connection_impl.dart

@@ -40,6 +40,9 @@ class SqliteDatabaseImpl
   late final SqliteConnectionImpl _internalConnection;
   late final SqliteConnectionPool _pool;
 
+  @override
+  int get numConnections => _pool.getNumConnections();
+
   final StreamController<UpdateNotification> updatesController =
       StreamController.broadcast();
 

packages/sqlite_async/lib/src/native/database/native_sqlite_database.dart

@@ -129,6 +129,9 @@ class WebDatabase
       }
     }
   }
+
+  @override
+  int get numConnections => 0;
 }
 
 class _SharedContext implements SqliteReadContext {

packages/sqlite_async/lib/src/web/database.dart

@@ -139,4 +139,7 @@ class SqliteDatabaseImpl
     await isInitialized;
     return _connection.getAutoCommit();
   }
+
+  @override
+  int get numConnections => 0;
 }