diff --git a/External/Implementations/Litedb/CollisionRecordDataAccess.cs b/External/Implementations/Litedb/CollisionRecordDataAccess.cs index 9965013..08b4336 100644 --- a/External/Implementations/Litedb/CollisionRecordDataAccess.cs +++ b/External/Implementations/Litedb/CollisionRecordDataAccess.cs @@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.Delete(collisionRecordId); + db.Checkpoint(); return true; } public bool SaveCollisionRecordToVehicle(CollisionRecord collisionRecord) { var table = db.GetCollection(tableName); table.Upsert(collisionRecord); + db.Checkpoint(); return true; } public bool DeleteAllCollisionRecordsByVehicleId(int vehicleId) { var table = db.GetCollection(tableName); var collisionRecords = table.DeleteMany(Query.EQ(nameof(CollisionRecord.VehicleId), vehicleId)); + db.Checkpoint(); return true; } } diff --git a/External/Implementations/Litedb/ExtraFieldDataAccess.cs b/External/Implementations/Litedb/ExtraFieldDataAccess.cs index 608255c..2b28513 100644 --- a/External/Implementations/Litedb/ExtraFieldDataAccess.cs +++ b/External/Implementations/Litedb/ExtraFieldDataAccess.cs @@ -21,6 +21,7 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.Upsert(record); + db.Checkpoint(); return true; } } diff --git a/External/Implementations/Litedb/GasRecordDataAccess.cs b/External/Implementations/Litedb/GasRecordDataAccess.cs index 0ee3a18..fa2ebb8 100644 --- a/External/Implementations/Litedb/GasRecordDataAccess.cs +++ b/External/Implementations/Litedb/GasRecordDataAccess.cs @@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.Delete(gasRecordId); + db.Checkpoint(); return true; } public bool SaveGasRecordToVehicle(GasRecord gasRecord) { var table = db.GetCollection(tableName); table.Upsert(gasRecord); + db.Checkpoint(); return true; } public bool DeleteAllGasRecordsByVehicleId(int vehicleId) { var table = db.GetCollection(tableName); var gasRecords = table.DeleteMany(Query.EQ(nameof(GasRecord.VehicleId), vehicleId)); + db.Checkpoint(); return true; } } diff --git a/External/Implementations/Litedb/NoteDataAccess.cs b/External/Implementations/Litedb/NoteDataAccess.cs index dea52bc..7ebeeaf 100644 --- a/External/Implementations/Litedb/NoteDataAccess.cs +++ b/External/Implementations/Litedb/NoteDataAccess.cs @@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.Upsert(note); + db.Checkpoint(); return true; } public bool DeleteNoteById(int noteId) { var table = db.GetCollection(tableName); table.Delete(noteId); + db.Checkpoint(); return true; } public bool DeleteAllNotesByVehicleId(int vehicleId) { var table = db.GetCollection(tableName); var notes = table.DeleteMany(Query.EQ(nameof(Note.VehicleId), vehicleId)); + db.Checkpoint(); return true; } } diff --git a/External/Implementations/Litedb/OdometerRecordDataAccess.cs b/External/Implementations/Litedb/OdometerRecordDataAccess.cs index f2041b5..96325ca 100644 --- a/External/Implementations/Litedb/OdometerRecordDataAccess.cs +++ b/External/Implementations/Litedb/OdometerRecordDataAccess.cs @@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.Delete(odometerRecordId); + db.Checkpoint(); return true; } public bool SaveOdometerRecordToVehicle(OdometerRecord odometerRecord) { var table = db.GetCollection(tableName); table.Upsert(odometerRecord); + db.Checkpoint(); return true; } public bool DeleteAllOdometerRecordsByVehicleId(int vehicleId) { var table = db.GetCollection(tableName); var odometerRecords = table.DeleteMany(Query.EQ(nameof(OdometerRecord.VehicleId), vehicleId)); + db.Checkpoint(); return true; } } diff --git a/External/Implementations/Litedb/PlanRecordDataAccess.cs b/External/Implementations/Litedb/PlanRecordDataAccess.cs index 639caba..8e559a2 100644 --- a/External/Implementations/Litedb/PlanRecordDataAccess.cs +++ b/External/Implementations/Litedb/PlanRecordDataAccess.cs @@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.Delete(planRecordId); + db.Checkpoint(); return true; } public bool SavePlanRecordToVehicle(PlanRecord planRecord) { var table = db.GetCollection(tableName); table.Upsert(planRecord); + db.Checkpoint(); return true; } public bool DeleteAllPlanRecordsByVehicleId(int vehicleId) { var table = db.GetCollection(tableName); var planRecords = table.DeleteMany(Query.EQ(nameof(PlanRecord.VehicleId), vehicleId)); + db.Checkpoint(); return true; } } diff --git a/External/Implementations/Litedb/PlanRecordTemplateDataAccess.cs b/External/Implementations/Litedb/PlanRecordTemplateDataAccess.cs index e208fbe..1ed0fe6 100644 --- a/External/Implementations/Litedb/PlanRecordTemplateDataAccess.cs +++ b/External/Implementations/Litedb/PlanRecordTemplateDataAccess.cs @@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.Delete(planRecordId); + db.Checkpoint(); return true; } public bool SavePlanRecordTemplateToVehicle(PlanRecordInput planRecord) { var table = db.GetCollection(tableName); table.Upsert(planRecord); + db.Checkpoint(); return true; } public bool DeleteAllPlanRecordTemplatesByVehicleId(int vehicleId) { var table = db.GetCollection(tableName); var planRecords = table.DeleteMany(Query.EQ(nameof(PlanRecordInput.VehicleId), vehicleId)); + db.Checkpoint(); return true; } } diff --git a/External/Implementations/Litedb/ReminderRecordDataAccess.cs b/External/Implementations/Litedb/ReminderRecordDataAccess.cs index 822dc0a..e6628e0 100644 --- a/External/Implementations/Litedb/ReminderRecordDataAccess.cs +++ b/External/Implementations/Litedb/ReminderRecordDataAccess.cs @@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.Delete(reminderRecordId); + db.Checkpoint(); return true; } public bool SaveReminderRecordToVehicle(ReminderRecord reminderRecord) { var table = db.GetCollection(tableName); table.Upsert(reminderRecord); + db.Checkpoint(); return true; } public bool DeleteAllReminderRecordsByVehicleId(int vehicleId) { var table = db.GetCollection(tableName); var reminderRecords = table.DeleteMany(Query.EQ(nameof(ReminderRecord.VehicleId), vehicleId)); + db.Checkpoint(); return true; } } diff --git a/External/Implementations/Litedb/ServiceRecordDataAccess.cs b/External/Implementations/Litedb/ServiceRecordDataAccess.cs index be1709c..b0ebd8e 100644 --- a/External/Implementations/Litedb/ServiceRecordDataAccess.cs +++ b/External/Implementations/Litedb/ServiceRecordDataAccess.cs @@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.Delete(serviceRecordId); + db.Checkpoint(); return true; } public bool SaveServiceRecordToVehicle(ServiceRecord serviceRecord) { var table = db.GetCollection(tableName); table.Upsert(serviceRecord); + db.Checkpoint(); return true; } public bool DeleteAllServiceRecordsByVehicleId(int vehicleId) { var table = db.GetCollection(tableName); var serviceRecords = table.DeleteMany(Query.EQ(nameof(ServiceRecord.VehicleId), vehicleId)); + db.Checkpoint(); return true; } } diff --git a/External/Implementations/Litedb/SupplyRecordDataAccess.cs b/External/Implementations/Litedb/SupplyRecordDataAccess.cs index ab57656..17a1de6 100644 --- a/External/Implementations/Litedb/SupplyRecordDataAccess.cs +++ b/External/Implementations/Litedb/SupplyRecordDataAccess.cs @@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.Delete(supplyRecordId); + db.Checkpoint(); return true; } public bool SaveSupplyRecordToVehicle(SupplyRecord supplyRecord) { var table = db.GetCollection(tableName); table.Upsert(supplyRecord); + db.Checkpoint(); return true; } public bool DeleteAllSupplyRecordsByVehicleId(int vehicleId) { var table = db.GetCollection(tableName); var supplyRecords = table.DeleteMany(Query.EQ(nameof(SupplyRecord.VehicleId), vehicleId)); + db.Checkpoint(); return true; } } diff --git a/External/Implementations/Litedb/TaxRecordDataAccess.cs b/External/Implementations/Litedb/TaxRecordDataAccess.cs index ffbcd93..be3eab2 100644 --- a/External/Implementations/Litedb/TaxRecordDataAccess.cs +++ b/External/Implementations/Litedb/TaxRecordDataAccess.cs @@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.Delete(taxRecordId); + db.Checkpoint(); return true; } public bool SaveTaxRecordToVehicle(TaxRecord taxRecord) { var table = db.GetCollection(tableName); table.Upsert(taxRecord); + db.Checkpoint(); return true; } public bool DeleteAllTaxRecordsByVehicleId(int vehicleId) { var table = db.GetCollection(tableName); var taxRecords = table.DeleteMany(Query.EQ(nameof(TaxRecord.VehicleId), vehicleId)); + db.Checkpoint(); return true; } } diff --git a/External/Implementations/Litedb/TokenRecordDataAccess.cs b/External/Implementations/Litedb/TokenRecordDataAccess.cs index 4ff6396..7bf18fe 100644 --- a/External/Implementations/Litedb/TokenRecordDataAccess.cs +++ b/External/Implementations/Litedb/TokenRecordDataAccess.cs @@ -33,12 +33,14 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.Insert(token); + db.Checkpoint(); return true; } public bool DeleteToken(int tokenId) { var table = db.GetCollection(tableName); table.Delete(tokenId); + db.Checkpoint(); return true; } } diff --git a/External/Implementations/Litedb/UpgradeRecordDataAccess.cs b/External/Implementations/Litedb/UpgradeRecordDataAccess.cs index e36aab6..5d6eb07 100644 --- a/External/Implementations/Litedb/UpgradeRecordDataAccess.cs +++ b/External/Implementations/Litedb/UpgradeRecordDataAccess.cs @@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.Delete(upgradeRecordId); + db.Checkpoint(); return true; } public bool SaveUpgradeRecordToVehicle(UpgradeRecord upgradeRecord) { var table = db.GetCollection(tableName); table.Upsert(upgradeRecord); + db.Checkpoint(); return true; } public bool DeleteAllUpgradeRecordsByVehicleId(int vehicleId) { var table = db.GetCollection(tableName); var upgradeRecords = table.DeleteMany(Query.EQ(nameof(UpgradeRecord.VehicleId), vehicleId)); + db.Checkpoint(); return true; } } diff --git a/External/Implementations/Litedb/UserAccessDataAcces.cs b/External/Implementations/Litedb/UserAccessDataAcces.cs index de6b61d..d088c9f 100644 --- a/External/Implementations/Litedb/UserAccessDataAcces.cs +++ b/External/Implementations/Litedb/UserAccessDataAcces.cs @@ -36,12 +36,14 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.Upsert(userAccess); + db.Checkpoint(); return true; } public bool DeleteUserAccess(int userId, int vehicleId) { var table = db.GetCollection(tableName); table.DeleteMany(x => x.Id.UserId == userId && x.Id.VehicleId == vehicleId); + db.Checkpoint(); return true; } /// @@ -53,6 +55,7 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.DeleteMany(x => x.Id.VehicleId == vehicleId); + db.Checkpoint(); return true; } /// @@ -64,6 +67,7 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.DeleteMany(x => x.Id.UserId == userId); + db.Checkpoint(); return true; } } diff --git a/External/Implementations/Litedb/UserConfigDataAccess.cs b/External/Implementations/Litedb/UserConfigDataAccess.cs index 458f237..b2627f3 100644 --- a/External/Implementations/Litedb/UserConfigDataAccess.cs +++ b/External/Implementations/Litedb/UserConfigDataAccess.cs @@ -21,12 +21,14 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.Upsert(userConfigData); + db.Checkpoint(); return true; } public bool DeleteUserConfig(int userId) { var table = db.GetCollection(tableName); table.Delete(userId); + db.Checkpoint(); return true; } } diff --git a/External/Implementations/Litedb/UserRecordDataAccess.cs b/External/Implementations/Litedb/UserRecordDataAccess.cs index f9bb016..19673f0 100644 --- a/External/Implementations/Litedb/UserRecordDataAccess.cs +++ b/External/Implementations/Litedb/UserRecordDataAccess.cs @@ -39,12 +39,14 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); table.Upsert(userRecord); + db.Checkpoint(); return true; } public bool DeleteUserRecord(int userId) { var table = db.GetCollection(tableName); table.Delete(userId); + db.Checkpoint(); return true; } } diff --git a/External/Implementations/Litedb/VehicleDataAccess.cs b/External/Implementations/Litedb/VehicleDataAccess.cs index da49458..7c645fb 100644 --- a/External/Implementations/Litedb/VehicleDataAccess.cs +++ b/External/Implementations/Litedb/VehicleDataAccess.cs @@ -16,12 +16,15 @@ namespace CarCareTracker.External.Implementations { var table = db.GetCollection(tableName); var result = table.Upsert(vehicle); + db.Checkpoint(); return true; } public bool DeleteVehicle(int vehicleId) { var table = db.GetCollection(tableName); - return table.Delete(vehicleId); + var result = table.Delete(vehicleId); + db.Checkpoint(); + return result; } public List GetVehicles() {