diff --git a/build.yaml b/build.yaml
new file mode 100644
index 0000000..b07425b
--- /dev/null
+++ b/build.yaml
@@ -0,0 +1,6 @@
+targets:
+  $default:
+    builders:
+      moor_generator:
+        options:
+          generate_connect_constructor: true
diff --git a/lib/src/database/database.dart b/lib/src/database/database.dart
index 036d885..805330f 100644
--- a/lib/src/database/database.dart
+++ b/lib/src/database/database.dart
@@ -15,6 +15,8 @@ part 'database.g.dart';
 class Database extends _$Database {
   Database(QueryExecutor e) : super(e);
 
+  Database.connect(DatabaseConnection connection) : super.connect(connection);
+
   @override
   int get schemaVersion => 5;
 
diff --git a/lib/src/database/database.g.dart b/lib/src/database/database.g.dart
index e17101d..453053e 100644
--- a/lib/src/database/database.g.dart
+++ b/lib/src/database/database.g.dart
@@ -5361,6 +5361,7 @@ class Files extends Table with TableInfo<Files, DbFile> {
 
 abstract class _$Database extends GeneratedDatabase {
   _$Database(QueryExecutor e) : super(SqlTypeSystem.defaultInstance, e);
+  _$Database.connect(DatabaseConnection c) : super.connect(c);
   Clients _clients;
   Clients get clients => _clients ??= Clients(this);
   UserDeviceKeys _userDeviceKeys;
@@ -6196,23 +6197,6 @@ abstract class _$Database extends GeneratedDatabase {
         }).map(_rowToDbRoomState);
   }
 
-  Selectable<DbRoomState> dbGetUsers(
-      int client_id, List<String> mxids, String room_id) {
-    var $arrayStartIndex = 2;
-    final expandedmxids = $expandVar($arrayStartIndex, mxids.length);
-    $arrayStartIndex += mxids.length;
-    return customSelect(
-        'SELECT * FROM room_states WHERE client_id = :client_id AND type = \'m.room.member\' AND state_key IN ($expandedmxids) AND room_id = :room_id',
-        variables: [
-          Variable.withInt(client_id),
-          for (var $ in mxids) Variable.withString($),
-          Variable.withString(room_id)
-        ],
-        readsFrom: {
-          roomStates
-        }).map(_rowToDbRoomState);
-  }
-
   DbEvent _rowToDbEvent(QueryRow row) {
     return DbEvent(
       clientId: row.readInt('client_id'),