Get all connections

Author: js2702

packages/sqlite_async/lib/src/common/connection/sync_sqlite_connection.dart

@@ -50,6 +50,11 @@ class SyncSqliteConnection extends SqliteConnection with SqliteQueries {
   Future<bool> getAutoCommit() async {
     return db.autocommit;
   }
+
+  @override
+  int getNumConnections() {
+    return -1;
+  }
 }
 
 class SyncReadContext implements SqliteReadContext {

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

@@ -51,6 +51,7 @@ abstract class SqliteDatabase
   static const int defaultMaxReaders = 5;
 
   int get numConnections;
+  List<SqliteConnection> getAllConnections();
 
   /// Open a SqliteDatabase.
   ///

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

@@ -67,4 +67,14 @@ class SqliteDatabaseImpl
 
   @override
   int get numConnections => throw UnimplementedError();
+
+  @override
+  int getNumConnections() {
+    throw UnimplementedError();
+  }
+
+  @override
+  List<SqliteConnection> getAllConnections() {
+    throw UnimplementedError();
+  }
 }

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

@@ -233,7 +233,18 @@ class SqliteConnectionPool with SqliteQueries implements SqliteConnection {
     }
   }
 
-  getNumConnections() {
+  List<SqliteConnection> getAllConnections() {
+    final connections = <SqliteConnection>[];
+    if (_writeConnection != null) {
+      connections.add(_writeConnection!);
+    }
+    connections.addAll(_allReadConnections);
+    return connections;
+  }
+
+  int getNumConnections() {
+    print(
+        "TESTING READ: ${_allReadConnections.length} WRITE: ${_writeConnection == null ? 0 : 1}");
     return _allReadConnections.length + (_writeConnection == null ? 0 : 1);
   }
 }

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

@@ -159,6 +159,11 @@ class SqliteConnectionImpl
       });
     }, timeout: lockTimeout);
   }
+
+  @override
+  int getNumConnections() {
+    return -1;
+  }
 }
 
 int _nextCtxId = 1;

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

@@ -174,4 +174,14 @@ class SqliteDatabaseImpl
   Future<void> refreshSchema() {
     return _pool.refreshSchema();
   }
+
+  @override
+  int getNumConnections() {
+    return -1;
+  }
+
+  @override
+  List<SqliteConnection> getAllConnections() {
+    return _pool.getAllConnections();
+  }
 }

packages/sqlite_async/lib/src/sqlite_connection.dart

@@ -134,6 +134,8 @@ abstract class SqliteConnection extends SqliteWriteContext {
   /// Queries and watch calls can potentially use outdated schema information after a schema update.
   Future<void> refreshSchema();
 
+  int getNumConnections();
+
   /// Returns true if the connection is closed
   @override
   bool get closed;

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

@@ -132,6 +132,16 @@ class WebDatabase
 
   @override
   int get numConnections => 0;
+
+  @override
+  int getNumConnections() {
+    return -1;
+  }
+
+  @override
+  List<SqliteConnection> getAllConnections() {
+    throw UnimplementedError();
+  }
 }
 
 class _SharedContext implements SqliteReadContext {

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

@@ -142,4 +142,14 @@ class SqliteDatabaseImpl
 
   @override
   int get numConnections => 0;
+
+  @override
+  int getNumConnections() {
+    return -1;
+  }
+
+  @override
+  List<SqliteConnection> getAllConnections() {
+    throw UnimplementedError();
+  }
 }