Get all Sqlite connections in the pool

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

@@ -103,4 +103,9 @@ abstract class SqliteDatabase
   factory SqliteDatabase.singleConnection(SqliteConnection connection) {
     return SingleConnectionDatabase(connection);
   }
+
+  /// Returns a list of all the connections (read and write) managed by this database.
+  /// This can be useful to run the same statement on all connections. For instance,
+  /// ATTACHing a database, that is expected to be available in all connections.
+  List<SqliteConnection> getAllConnections();
 }

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

@@ -57,4 +57,9 @@ final class SingleConnectionDatabase
     return connection.writeLock(callback,
         lockTimeout: lockTimeout, debugContext: debugContext);
   }
+
+  @override
+  List<SqliteConnection> getAllConnections() {
+    return [connection];
+  }
 }

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

@@ -64,4 +64,9 @@ class SqliteDatabaseImpl
   Future<bool> getAutoCommit() {
     throw UnimplementedError();
   }
+
+  @override
+  List<SqliteConnection> getAllConnections() {
+    throw UnimplementedError();
+  }
 }

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

@@ -232,6 +232,15 @@ class SqliteConnectionPool with SqliteQueries implements SqliteConnection {
       await connection.refreshSchema();
     }
   }
+
+  List<SqliteConnection> getAllConnections() {
+    final connections = <SqliteConnection>[];
+    if (_writeConnection != null) {
+      connections.add(_writeConnection!);
+    }
+    connections.addAll(_allReadConnections);
+    return connections;
+  }
 }
 
 typedef ReadCallback<T> = Future<T> Function(SqliteReadContext tx);

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

@@ -171,4 +171,9 @@ class SqliteDatabaseImpl
   Future<void> refreshSchema() {
     return _pool.refreshSchema();
   }
+
+  @override
+  List<SqliteConnection> getAllConnections() {
+    return _pool.getAllConnections();
+  }
 }

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

@@ -171,6 +171,11 @@ class WebDatabase
     await isInitialized;
     return _database.fileSystem.flush();
   }
+
+  @override
+  List<SqliteConnection> getAllConnections() {
+    return [this];
+  }
 }
 
 final class _UnscopedContext extends UnscopedContext {

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

@@ -178,4 +178,9 @@ class SqliteDatabaseImpl
   Future<WebDatabaseEndpoint> exposeEndpoint() async {
     return await _connection.exposeEndpoint();
   }
+
+  @override
+  List<SqliteConnection> getAllConnections() {
+    return [_connection];
+  }
 }