Crud School [Data and Domain]

mobile/lib/core/data/database.dart

@@ -1,8 +1,11 @@
 import 'package:mobile/features/class_management/data/models/classroom_model.dart';
+import 'package:mobile/features/school_management/data/models/school_model.dart';
 import 'package:mobile/features/student_management/data/models/student_model.dart';
 import 'package:mobile/features/text_management/data/models/text_model.dart';
 import 'package:mobile/features/user_management/data/models/user_model.dart';
-import 'package:mobile/features/user_management/domain/entities/user.dart';
+import "../../features/user_management/domain/entities/user.dart";
+import "../../features/school_management/domain/entities/school.dart";
+import 'serializer.dart';
 import 'package:moor/ffi.dart';
 import 'package:path_provider/path_provider.dart';
 import 'package:path/path.dart' as p;
@@ -26,7 +29,13 @@ LazyDatabase openConnection() {
   });
 }
 
-@UseMoor(tables: [UserModels, ClassroomModels, StudentModels, TextModels])
+@UseMoor(tables: [
+  UserModels,
+  ClassroomModels,
+  StudentModels,
+  TextModels,
+  SchoolModels
+])
 class Database extends _$Database {
   Database(QueryExecutor e) : super(e);
   Database.customExecutor(QueryExecutor executor) : super(executor);
@@ -86,6 +95,26 @@ class Database extends _$Database {
     return update(textModels).replace(entry);
   }
 
+  /// returns the pk of the added entry
+  Future<int> insertSchool(SchoolModelsCompanion modelCompanion) async {
+    return into(schoolModels).insert(modelCompanion);
+  }
+
+  ///Returns the number of deleted rows
+  Future<int> deleteSchool(int id) async {
+    return (delete(schoolModels)..where((t) => t.localId.equals(id))).go();
+  }
+
+  ///Returns a list of schoolModels, and an empty list when the table is empty
+  Future<List<SchoolModel>> getSchools(int userId) async {
+    return (select(schoolModels)..where((t) => t.userId.equals(userId))).get();
+  }
+
+  ///Returns true if the school was updated, false otherwise
+  Future<bool> updateSchool(SchoolModel entry) async {
+    return update(schoolModels).replace(entry);
+  }
+
   @override
   int get schemaVersion => 3;
 }