Merge pull request #419 from hargata/Hargata/litedb.concurrency

Added DB Checkpoint for WAL

External/Implementations/Litedb/CollisionRecordDataAccess.cs

@@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<CollisionRecord>(tableName);
             table.Delete(collisionRecordId);
+            db.Checkpoint();
             return true;
         }
         public bool SaveCollisionRecordToVehicle(CollisionRecord collisionRecord)
         {
             var table = db.GetCollection<CollisionRecord>(tableName);
             table.Upsert(collisionRecord);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteAllCollisionRecordsByVehicleId(int vehicleId)
         {
             var table = db.GetCollection<CollisionRecord>(tableName);
             var collisionRecords = table.DeleteMany(Query.EQ(nameof(CollisionRecord.VehicleId), vehicleId));
+            db.Checkpoint();
             return true;
         }
     }

External/Implementations/Litedb/ExtraFieldDataAccess.cs

@@ -21,6 +21,7 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<RecordExtraField>(tableName);
             table.Upsert(record);
+            db.Checkpoint();
             return true;
         }
     }

External/Implementations/Litedb/GasRecordDataAccess.cs

@@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<GasRecord>(tableName);
             table.Delete(gasRecordId);
+            db.Checkpoint();
             return true;
         }
         public bool SaveGasRecordToVehicle(GasRecord gasRecord)
         {
             var table = db.GetCollection<GasRecord>(tableName);
             table.Upsert(gasRecord);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteAllGasRecordsByVehicleId(int vehicleId)
         {
             var table = db.GetCollection<GasRecord>(tableName);
             var gasRecords = table.DeleteMany(Query.EQ(nameof(GasRecord.VehicleId), vehicleId));
+            db.Checkpoint();
             return true;
         }
     }

External/Implementations/Litedb/NoteDataAccess.cs

@@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<Note>(tableName);
             table.Upsert(note);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteNoteById(int noteId)
         {
             var table = db.GetCollection<Note>(tableName);
             table.Delete(noteId);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteAllNotesByVehicleId(int vehicleId)
         {
             var table = db.GetCollection<Note>(tableName);
             var notes = table.DeleteMany(Query.EQ(nameof(Note.VehicleId), vehicleId));
+            db.Checkpoint();
             return true;
         }
     }

External/Implementations/Litedb/OdometerRecordDataAccess.cs

@@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<OdometerRecord>(tableName);
             table.Delete(odometerRecordId);
+            db.Checkpoint();
             return true;
         }
         public bool SaveOdometerRecordToVehicle(OdometerRecord odometerRecord)
         {
             var table = db.GetCollection<OdometerRecord>(tableName);
             table.Upsert(odometerRecord);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteAllOdometerRecordsByVehicleId(int vehicleId)
         {
             var table = db.GetCollection<OdometerRecord>(tableName);
             var odometerRecords = table.DeleteMany(Query.EQ(nameof(OdometerRecord.VehicleId), vehicleId));
+            db.Checkpoint();
             return true;
         }
     }

External/Implementations/Litedb/PlanRecordDataAccess.cs

@@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<PlanRecord>(tableName);
             table.Delete(planRecordId);
+            db.Checkpoint();
             return true;
         }
         public bool SavePlanRecordToVehicle(PlanRecord planRecord)
         {
             var table = db.GetCollection<PlanRecord>(tableName);
             table.Upsert(planRecord);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteAllPlanRecordsByVehicleId(int vehicleId)
         {
             var table = db.GetCollection<PlanRecord>(tableName);
             var planRecords = table.DeleteMany(Query.EQ(nameof(PlanRecord.VehicleId), vehicleId));
+            db.Checkpoint();
             return true;
         }
     }

External/Implementations/Litedb/PlanRecordTemplateDataAccess.cs

@@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<PlanRecordInput>(tableName);
             table.Delete(planRecordId);
+            db.Checkpoint();
             return true;
         }
         public bool SavePlanRecordTemplateToVehicle(PlanRecordInput planRecord)
         {
             var table = db.GetCollection<PlanRecordInput>(tableName);
             table.Upsert(planRecord);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteAllPlanRecordTemplatesByVehicleId(int vehicleId)
         {
             var table = db.GetCollection<PlanRecord>(tableName);
             var planRecords = table.DeleteMany(Query.EQ(nameof(PlanRecordInput.VehicleId), vehicleId));
+            db.Checkpoint();
             return true;
         }
     }

External/Implementations/Litedb/ReminderRecordDataAccess.cs

@@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<ReminderRecord>(tableName);
             table.Delete(reminderRecordId);
+            db.Checkpoint();
             return true;
         }
         public bool SaveReminderRecordToVehicle(ReminderRecord reminderRecord)
         {
             var table = db.GetCollection<ReminderRecord>(tableName);
             table.Upsert(reminderRecord);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteAllReminderRecordsByVehicleId(int vehicleId)
         {
             var table = db.GetCollection<ReminderRecord>(tableName);
             var reminderRecords = table.DeleteMany(Query.EQ(nameof(ReminderRecord.VehicleId), vehicleId));
+            db.Checkpoint();
             return true;
         }
     }

External/Implementations/Litedb/ServiceRecordDataAccess.cs

@@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<ServiceRecord>(tableName);
             table.Delete(serviceRecordId);
+            db.Checkpoint();
             return true;
         }
         public bool SaveServiceRecordToVehicle(ServiceRecord serviceRecord)
         {
             var table = db.GetCollection<ServiceRecord>(tableName);
             table.Upsert(serviceRecord);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteAllServiceRecordsByVehicleId(int vehicleId)
         {
             var table = db.GetCollection<ServiceRecord>(tableName);
             var serviceRecords = table.DeleteMany(Query.EQ(nameof(ServiceRecord.VehicleId), vehicleId));
+            db.Checkpoint();
             return true;
         }
     }

External/Implementations/Litedb/SupplyRecordDataAccess.cs

@@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<SupplyRecord>(tableName);
             table.Delete(supplyRecordId);
+            db.Checkpoint();
             return true;
         }
         public bool SaveSupplyRecordToVehicle(SupplyRecord supplyRecord)
         {
             var table = db.GetCollection<SupplyRecord>(tableName);
             table.Upsert(supplyRecord);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteAllSupplyRecordsByVehicleId(int vehicleId)
         {
             var table = db.GetCollection<SupplyRecord>(tableName);
             var supplyRecords = table.DeleteMany(Query.EQ(nameof(SupplyRecord.VehicleId), vehicleId));
+            db.Checkpoint();
             return true;
         }
     }

External/Implementations/Litedb/TaxRecordDataAccess.cs

@@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<TaxRecord>(tableName);
             table.Delete(taxRecordId);
+            db.Checkpoint();
             return true;
         }
         public bool SaveTaxRecordToVehicle(TaxRecord taxRecord)
         {
             var table = db.GetCollection<TaxRecord>(tableName);
             table.Upsert(taxRecord);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteAllTaxRecordsByVehicleId(int vehicleId)
         {
             var table = db.GetCollection<TaxRecord>(tableName);
             var taxRecords = table.DeleteMany(Query.EQ(nameof(TaxRecord.VehicleId), vehicleId));
+            db.Checkpoint();
             return true;
         }
     }

External/Implementations/Litedb/TokenRecordDataAccess.cs

@@ -33,12 +33,14 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<Token>(tableName);
             table.Insert(token);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteToken(int tokenId)
         {
             var table = db.GetCollection<Token>(tableName);
             table.Delete(tokenId);
+            db.Checkpoint();
             return true;
         }
     }

External/Implementations/Litedb/UpgradeRecordDataAccess.cs

@@ -27,18 +27,21 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<UpgradeRecord>(tableName);
             table.Delete(upgradeRecordId);
+            db.Checkpoint();
             return true;
         }
         public bool SaveUpgradeRecordToVehicle(UpgradeRecord upgradeRecord)
         {
             var table = db.GetCollection<UpgradeRecord>(tableName);
             table.Upsert(upgradeRecord);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteAllUpgradeRecordsByVehicleId(int vehicleId)
         {
             var table = db.GetCollection<UpgradeRecord>(tableName);
             var upgradeRecords = table.DeleteMany(Query.EQ(nameof(UpgradeRecord.VehicleId), vehicleId));
+            db.Checkpoint();
             return true;
         }
     }

External/Implementations/Litedb/UserAccessDataAcces.cs

@@ -36,12 +36,14 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<UserAccess>(tableName);
             table.Upsert(userAccess);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteUserAccess(int userId, int vehicleId)
         {
             var table = db.GetCollection<UserAccess>(tableName);
             table.DeleteMany(x => x.Id.UserId == userId && x.Id.VehicleId == vehicleId);
+            db.Checkpoint();
             return true;
         }
         /// <summary>
@@ -53,6 +55,7 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<UserAccess>(tableName);
             table.DeleteMany(x => x.Id.VehicleId == vehicleId);
+            db.Checkpoint();
             return true;
         }
         /// <summary>
@@ -64,6 +67,7 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<UserAccess>(tableName);
             table.DeleteMany(x => x.Id.UserId == userId);
+            db.Checkpoint();
             return true;
         }
     }

External/Implementations/Litedb/UserConfigDataAccess.cs

@@ -21,12 +21,14 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<UserConfigData>(tableName);
             table.Upsert(userConfigData);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteUserConfig(int userId)
         {
             var table = db.GetCollection<UserConfigData>(tableName);
             table.Delete(userId);
+            db.Checkpoint();
             return true;
         }
     }

External/Implementations/Litedb/UserRecordDataAccess.cs

@@ -39,12 +39,14 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<UserData>(tableName);
             table.Upsert(userRecord);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteUserRecord(int userId)
         {
             var table = db.GetCollection<UserData>(tableName);
             table.Delete(userId);
+            db.Checkpoint();
             return true;
         }
     }

External/Implementations/Litedb/VehicleDataAccess.cs

@@ -16,12 +16,15 @@ namespace CarCareTracker.External.Implementations
         {
             var table = db.GetCollection<Vehicle>(tableName);
             var result = table.Upsert(vehicle);
+            db.Checkpoint();
             return true;
         }
         public bool DeleteVehicle(int vehicleId)
         {
             var table = db.GetCollection<Vehicle>(tableName);
-            return table.Delete(vehicleId);
+            var result = table.Delete(vehicleId);
+            db.Checkpoint();
+            return result;
         }
         public List<Vehicle> GetVehicles()
         {