hargata/lubelog
1
0
Fork 0
mirror of https://github.com/hargata/lubelog.git synced 2025-12-10 00:46:08 -06:00
Code Issues Packages Projects Releases 51 Wiki Activity

Replaced LiteDB's initialization with every DB call with Dependency Injection instead.

Browse Source
This commit is contained in:
DESKTOP-GENO133\IvanPlex 2024-03-20 10:38:32 -06:00
parent 91a5f92df6
commit 300c986abb
20 changed files with 340 additions and 499 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@ -11,3 +11,4 @@ wwwroot/translations/
config/userConfig.json config/userConfig.json
CarCareTracker.csproj.user CarCareTracker.csproj.user
Properties/launchSettings.json Properties/launchSettings.json
data/cartracker-log.db

49
External/Implementations/Litedb/CollisionRecordDataAccess.cs vendored
View File

@ -7,51 +7,40 @@ namespace CarCareTracker.External.Implementations
{ {
public class CollisionRecordDataAccess : ICollisionRecordDataAccess public class CollisionRecordDataAccess : ICollisionRecordDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
private static string tableName = "collisionrecords"; private static string tableName = "collisionrecords";
public CollisionRecordDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
public List<CollisionRecord> GetCollisionRecordsByVehicleId(int vehicleId) public List<CollisionRecord> GetCollisionRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<CollisionRecord>(tableName);
{ var collisionRecords = table.Find(Query.EQ(nameof(CollisionRecord.VehicleId), vehicleId));
var table = db.GetCollection<CollisionRecord>(tableName); return collisionRecords.ToList() ?? new List<CollisionRecord>();
var collisionRecords = table.Find(Query.EQ(nameof(CollisionRecord.VehicleId), vehicleId));
return collisionRecords.ToList() ?? new List<CollisionRecord>();
};
} }
public CollisionRecord GetCollisionRecordById(int collisionRecordId) public CollisionRecord GetCollisionRecordById(int collisionRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<CollisionRecord>(tableName);
{ return table.FindById(collisionRecordId);
var table = db.GetCollection<CollisionRecord>(tableName);
return table.FindById(collisionRecordId);
};
} }
public bool DeleteCollisionRecordById(int collisionRecordId) public bool DeleteCollisionRecordById(int collisionRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<CollisionRecord>(tableName);
{ table.Delete(collisionRecordId);
var table = db.GetCollection<CollisionRecord>(tableName); return true;
table.Delete(collisionRecordId);
return true;
};
} }
public bool SaveCollisionRecordToVehicle(CollisionRecord collisionRecord) public bool SaveCollisionRecordToVehicle(CollisionRecord collisionRecord)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<CollisionRecord>(tableName);
{ table.Upsert(collisionRecord);
var table = db.GetCollection<CollisionRecord>(tableName); return true;
table.Upsert(collisionRecord);
return true;
};
} }
public bool DeleteAllCollisionRecordsByVehicleId(int vehicleId) public bool DeleteAllCollisionRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<CollisionRecord>(tableName);
{ var collisionRecords = table.DeleteMany(Query.EQ(nameof(CollisionRecord.VehicleId), vehicleId));
var table = db.GetCollection<CollisionRecord>(tableName); return true;
var collisionRecords = table.DeleteMany(Query.EQ(nameof(CollisionRecord.VehicleId), vehicleId));
return true;
};
} }
} }
} }

24
External/Implementations/Litedb/ExtraFieldDataAccess.cs vendored
View File

@ -5,26 +5,24 @@ using LiteDB;
namespace CarCareTracker.External.Implementations namespace CarCareTracker.External.Implementations
{ {
public class ExtraFieldDataAccess: IExtraFieldDataAccess public class ExtraFieldDataAccess : IExtraFieldDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
private static string tableName = "extrafields"; private static string tableName = "extrafields";
public ExtraFieldDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
public RecordExtraField GetExtraFieldsById(int importMode) public RecordExtraField GetExtraFieldsById(int importMode)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<RecordExtraField>(tableName);
{ return table.FindById(importMode) ?? new RecordExtraField();
var table = db.GetCollection<RecordExtraField>(tableName);
return table.FindById(importMode) ?? new RecordExtraField();
};
} }
public bool SaveExtraFields(RecordExtraField record) public bool SaveExtraFields(RecordExtraField record)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<RecordExtraField>(tableName);
{ table.Upsert(record);
var table = db.GetCollection<RecordExtraField>(tableName); return true;
table.Upsert(record);
return true;
};
} }
} }
} }

51
External/Implementations/Litedb/GasRecordDataAccess.cs vendored
View File

@ -5,53 +5,42 @@ using LiteDB;
namespace CarCareTracker.External.Implementations namespace CarCareTracker.External.Implementations
{ {
public class GasRecordDataAccess: IGasRecordDataAccess public class GasRecordDataAccess : IGasRecordDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
private static string tableName = "gasrecords"; private static string tableName = "gasrecords";
public GasRecordDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
public List<GasRecord> GetGasRecordsByVehicleId(int vehicleId) public List<GasRecord> GetGasRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<GasRecord>(tableName);
{ var gasRecords = table.Find(Query.EQ(nameof(GasRecord.VehicleId), vehicleId));
var table = db.GetCollection<GasRecord>(tableName); return gasRecords.ToList() ?? new List<GasRecord>();
var gasRecords = table.Find(Query.EQ(nameof(GasRecord.VehicleId), vehicleId));
return gasRecords.ToList() ?? new List<GasRecord>();
};
} }
public GasRecord GetGasRecordById(int gasRecordId) public GasRecord GetGasRecordById(int gasRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<GasRecord>(tableName);
{ return table.FindById(gasRecordId);
var table = db.GetCollection<GasRecord>(tableName);
return table.FindById(gasRecordId);
};
} }
public bool DeleteGasRecordById(int gasRecordId) public bool DeleteGasRecordById(int gasRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<GasRecord>(tableName);
{ table.Delete(gasRecordId);
var table = db.GetCollection<GasRecord>(tableName); return true;
table.Delete(gasRecordId);
return true;
};
} }
public bool SaveGasRecordToVehicle(GasRecord gasRecord) public bool SaveGasRecordToVehicle(GasRecord gasRecord)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<GasRecord>(tableName);
{ table.Upsert(gasRecord);
var table = db.GetCollection<GasRecord>(tableName); return true;
table.Upsert(gasRecord);
return true;
};
} }
public bool DeleteAllGasRecordsByVehicleId(int vehicleId) public bool DeleteAllGasRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<GasRecord>(tableName);
{ var gasRecords = table.DeleteMany(Query.EQ(nameof(GasRecord.VehicleId), vehicleId));
var table = db.GetCollection<GasRecord>(tableName); return true;
var gasRecords = table.DeleteMany(Query.EQ(nameof(GasRecord.VehicleId), vehicleId));
return true;
};
} }
} }
} }

22
External/Implementations/Litedb/LiteDBInjection.cs vendored Normal file
View File

@ -0,0 +1,22 @@
using CarCareTracker.Helper;
using LiteDB;
namespace CarCareTracker.External.Implementations
{
public interface ILiteDBInjection
{
LiteDatabase GetLiteDB();
}
public class LiteDBInjection: ILiteDBInjection
{
public LiteDatabase db { get; set; }
public LiteDBInjection()
{
db = new LiteDatabase(StaticHelper.DbName);
}
public LiteDatabase GetLiteDB()
{
return db;
}
}
}

51
External/Implementations/Litedb/NoteDataAccess.cs vendored
View File

@ -5,53 +5,42 @@ using LiteDB;
namespace CarCareTracker.External.Implementations namespace CarCareTracker.External.Implementations
{ {
public class NoteDataAccess: INoteDataAccess public class NoteDataAccess : INoteDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
private static string tableName = "notes"; private static string tableName = "notes";
public NoteDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
public List<Note> GetNotesByVehicleId(int vehicleId) public List<Note> GetNotesByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<Note>(tableName);
{ var noteToReturn = table.Find(Query.EQ(nameof(Note.VehicleId), vehicleId));
var table = db.GetCollection<Note>(tableName); return noteToReturn.ToList() ?? new List<Note>();
var noteToReturn = table.Find(Query.EQ(nameof(Note.VehicleId), vehicleId));
return noteToReturn.ToList() ?? new List<Note>();
};
} }
public Note GetNoteById(int noteId) public Note GetNoteById(int noteId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<Note>(tableName);
{ return table.FindById(noteId);
var table = db.GetCollection<Note>(tableName);
return table.FindById(noteId);
};
} }
public bool SaveNoteToVehicle(Note note) public bool SaveNoteToVehicle(Note note)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<Note>(tableName);
{ table.Upsert(note);
var table = db.GetCollection<Note>(tableName); return true;
table.Upsert(note);
return true;
};
} }
public bool DeleteNoteById(int noteId) public bool DeleteNoteById(int noteId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<Note>(tableName);
{ table.Delete(noteId);
var table = db.GetCollection<Note>(tableName); return true;
table.Delete(noteId);
return true;
};
} }
public bool DeleteAllNotesByVehicleId(int vehicleId) public bool DeleteAllNotesByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<Note>(tableName);
{ var notes = table.DeleteMany(Query.EQ(nameof(Note.VehicleId), vehicleId));
var table = db.GetCollection<Note>(tableName); return true;
var notes = table.DeleteMany(Query.EQ(nameof(Note.VehicleId), vehicleId));
return true;
};
} }
} }
} }

49
External/Implementations/Litedb/OdometerRecordDataAccess.cs vendored
View File

@ -7,51 +7,40 @@ namespace CarCareTracker.External.Implementations
{ {
public class OdometerRecordDataAccess : IOdometerRecordDataAccess public class OdometerRecordDataAccess : IOdometerRecordDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
private static string tableName = "odometerrecords"; private static string tableName = "odometerrecords";
public OdometerRecordDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
public List<OdometerRecord> GetOdometerRecordsByVehicleId(int vehicleId) public List<OdometerRecord> GetOdometerRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<OdometerRecord>(tableName);
{ var odometerRecords = table.Find(Query.EQ(nameof(OdometerRecord.VehicleId), vehicleId));
var table = db.GetCollection<OdometerRecord>(tableName); return odometerRecords.ToList() ?? new List<OdometerRecord>();
var odometerRecords = table.Find(Query.EQ(nameof(OdometerRecord.VehicleId), vehicleId));
return odometerRecords.ToList() ?? new List<OdometerRecord>();
};
} }
public OdometerRecord GetOdometerRecordById(int odometerRecordId) public OdometerRecord GetOdometerRecordById(int odometerRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<OdometerRecord>(tableName);
{ return table.FindById(odometerRecordId);
var table = db.GetCollection<OdometerRecord>(tableName);
return table.FindById(odometerRecordId);
};
} }
public bool DeleteOdometerRecordById(int odometerRecordId) public bool DeleteOdometerRecordById(int odometerRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<OdometerRecord>(tableName);
{ table.Delete(odometerRecordId);
var table = db.GetCollection<OdometerRecord>(tableName); return true;
table.Delete(odometerRecordId);
return true;
};
} }
public bool SaveOdometerRecordToVehicle(OdometerRecord odometerRecord) public bool SaveOdometerRecordToVehicle(OdometerRecord odometerRecord)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<OdometerRecord>(tableName);
{ table.Upsert(odometerRecord);
var table = db.GetCollection<OdometerRecord>(tableName); return true;
table.Upsert(odometerRecord);
return true;
};
} }
public bool DeleteAllOdometerRecordsByVehicleId(int vehicleId) public bool DeleteAllOdometerRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<OdometerRecord>(tableName);
{ var odometerRecords = table.DeleteMany(Query.EQ(nameof(OdometerRecord.VehicleId), vehicleId));
var table = db.GetCollection<OdometerRecord>(tableName); return true;
var odometerRecords = table.DeleteMany(Query.EQ(nameof(OdometerRecord.VehicleId), vehicleId));
return true;
};
} }
} }
} }

49
External/Implementations/Litedb/PlanRecordDataAccess.cs vendored
View File

@ -7,51 +7,40 @@ namespace CarCareTracker.External.Implementations
{ {
public class PlanRecordDataAccess : IPlanRecordDataAccess public class PlanRecordDataAccess : IPlanRecordDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
private static string tableName = "planrecords"; private static string tableName = "planrecords";
public PlanRecordDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
public List<PlanRecord> GetPlanRecordsByVehicleId(int vehicleId) public List<PlanRecord> GetPlanRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<PlanRecord>(tableName);
{ var planRecords = table.Find(Query.EQ(nameof(PlanRecord.VehicleId), vehicleId));
var table = db.GetCollection<PlanRecord>(tableName); return planRecords.ToList() ?? new List<PlanRecord>();
var planRecords = table.Find(Query.EQ(nameof(PlanRecord.VehicleId), vehicleId));
return planRecords.ToList() ?? new List<PlanRecord>();
};
} }
public PlanRecord GetPlanRecordById(int planRecordId) public PlanRecord GetPlanRecordById(int planRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<PlanRecord>(tableName);
{ return table.FindById(planRecordId);
var table = db.GetCollection<PlanRecord>(tableName);
return table.FindById(planRecordId);
};
} }
public bool DeletePlanRecordById(int planRecordId) public bool DeletePlanRecordById(int planRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<PlanRecord>(tableName);
{ table.Delete(planRecordId);
var table = db.GetCollection<PlanRecord>(tableName); return true;
table.Delete(planRecordId);
return true;
};
} }
public bool SavePlanRecordToVehicle(PlanRecord planRecord) public bool SavePlanRecordToVehicle(PlanRecord planRecord)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<PlanRecord>(tableName);
{ table.Upsert(planRecord);
var table = db.GetCollection<PlanRecord>(tableName); return true;
table.Upsert(planRecord);
return true;
};
} }
public bool DeleteAllPlanRecordsByVehicleId(int vehicleId) public bool DeleteAllPlanRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<PlanRecord>(tableName);
{ var planRecords = table.DeleteMany(Query.EQ(nameof(PlanRecord.VehicleId), vehicleId));
var table = db.GetCollection<PlanRecord>(tableName); return true;
var planRecords = table.DeleteMany(Query.EQ(nameof(PlanRecord.VehicleId), vehicleId));
return true;
};
} }
} }
} }

49
External/Implementations/Litedb/PlanRecordTemplateDataAccess.cs vendored
View File

@ -7,51 +7,40 @@ namespace CarCareTracker.External.Implementations
{ {
public class PlanRecordTemplateDataAccess : IPlanRecordTemplateDataAccess public class PlanRecordTemplateDataAccess : IPlanRecordTemplateDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
private static string tableName = "planrecordtemplates"; private static string tableName = "planrecordtemplates";
public PlanRecordTemplateDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
public List<PlanRecordInput> GetPlanRecordTemplatesByVehicleId(int vehicleId) public List<PlanRecordInput> GetPlanRecordTemplatesByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<PlanRecordInput>(tableName);
{ var planRecords = table.Find(Query.EQ(nameof(PlanRecordInput.VehicleId), vehicleId));
var table = db.GetCollection<PlanRecordInput>(tableName); return planRecords.ToList() ?? new List<PlanRecordInput>();
var planRecords = table.Find(Query.EQ(nameof(PlanRecordInput.VehicleId), vehicleId));
return planRecords.ToList() ?? new List<PlanRecordInput>();
};
} }
public PlanRecordInput GetPlanRecordTemplateById(int planRecordId) public PlanRecordInput GetPlanRecordTemplateById(int planRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<PlanRecordInput>(tableName);
{ return table.FindById(planRecordId);
var table = db.GetCollection<PlanRecordInput>(tableName);
return table.FindById(planRecordId);
};
} }
public bool DeletePlanRecordTemplateById(int planRecordId) public bool DeletePlanRecordTemplateById(int planRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<PlanRecordInput>(tableName);
{ table.Delete(planRecordId);
var table = db.GetCollection<PlanRecordInput>(tableName); return true;
table.Delete(planRecordId);
return true;
};
} }
public bool SavePlanRecordTemplateToVehicle(PlanRecordInput planRecord) public bool SavePlanRecordTemplateToVehicle(PlanRecordInput planRecord)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<PlanRecordInput>(tableName);
{ table.Upsert(planRecord);
var table = db.GetCollection<PlanRecordInput>(tableName); return true;
table.Upsert(planRecord);
return true;
};
} }
public bool DeleteAllPlanRecordTemplatesByVehicleId(int vehicleId) public bool DeleteAllPlanRecordTemplatesByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<PlanRecord>(tableName);
{ var planRecords = table.DeleteMany(Query.EQ(nameof(PlanRecordInput.VehicleId), vehicleId));
var table = db.GetCollection<PlanRecord>(tableName); return true;
var planRecords = table.DeleteMany(Query.EQ(nameof(PlanRecordInput.VehicleId), vehicleId));
return true;
};
} }
} }
} }

49
External/Implementations/Litedb/ReminderRecordDataAccess.cs vendored
View File

@ -7,51 +7,40 @@ namespace CarCareTracker.External.Implementations
{ {
public class ReminderRecordDataAccess : IReminderRecordDataAccess public class ReminderRecordDataAccess : IReminderRecordDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
private static string tableName = "reminderrecords"; private static string tableName = "reminderrecords";
public ReminderRecordDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
public List<ReminderRecord> GetReminderRecordsByVehicleId(int vehicleId) public List<ReminderRecord> GetReminderRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<ReminderRecord>(tableName);
{ var reminderRecords = table.Find(Query.EQ(nameof(ReminderRecord.VehicleId), vehicleId));
var table = db.GetCollection<ReminderRecord>(tableName); return reminderRecords.ToList() ?? new List<ReminderRecord>();
var reminderRecords = table.Find(Query.EQ(nameof(ReminderRecord.VehicleId), vehicleId));
return reminderRecords.ToList() ?? new List<ReminderRecord>();
};
} }
public ReminderRecord GetReminderRecordById(int reminderRecordId) public ReminderRecord GetReminderRecordById(int reminderRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<ReminderRecord>(tableName);
{ return table.FindById(reminderRecordId);
var table = db.GetCollection<ReminderRecord>(tableName);
return table.FindById(reminderRecordId);
};
} }
public bool DeleteReminderRecordById(int reminderRecordId) public bool DeleteReminderRecordById(int reminderRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<ReminderRecord>(tableName);
{ table.Delete(reminderRecordId);
var table = db.GetCollection<ReminderRecord>(tableName); return true;
table.Delete(reminderRecordId);
return true;
};
} }
public bool SaveReminderRecordToVehicle(ReminderRecord reminderRecord) public bool SaveReminderRecordToVehicle(ReminderRecord reminderRecord)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<ReminderRecord>(tableName);
{ table.Upsert(reminderRecord);
var table = db.GetCollection<ReminderRecord>(tableName); return true;
table.Upsert(reminderRecord);
return true;
};
} }
public bool DeleteAllReminderRecordsByVehicleId(int vehicleId) public bool DeleteAllReminderRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<ReminderRecord>(tableName);
{ var reminderRecords = table.DeleteMany(Query.EQ(nameof(ReminderRecord.VehicleId), vehicleId));
var table = db.GetCollection<ReminderRecord>(tableName); return true;
var reminderRecords = table.DeleteMany(Query.EQ(nameof(ReminderRecord.VehicleId), vehicleId));
return true;
};
} }
} }
} }

52
External/Implementations/Litedb/ServiceRecordDataAccess.cs vendored
View File

@ -1,57 +1,45 @@
using CarCareTracker.External.Interfaces; using CarCareTracker.External.Interfaces;
using CarCareTracker.Helper;
using CarCareTracker.Models; using CarCareTracker.Models;
using LiteDB; using LiteDB;
namespace CarCareTracker.External.Implementations namespace CarCareTracker.External.Implementations
{ {
public class ServiceRecordDataAccess: IServiceRecordDataAccess public class ServiceRecordDataAccess : IServiceRecordDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
private static string tableName = "servicerecords"; private static string tableName = "servicerecords";
public ServiceRecordDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
public List<ServiceRecord> GetServiceRecordsByVehicleId(int vehicleId) public List<ServiceRecord> GetServiceRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<ServiceRecord>(tableName);
{ var serviceRecords = table.Find(Query.EQ(nameof(ServiceRecord.VehicleId), vehicleId));
var table = db.GetCollection<ServiceRecord>(tableName); return serviceRecords.ToList() ?? new List<ServiceRecord>();
var serviceRecords = table.Find(Query.EQ(nameof(ServiceRecord.VehicleId), vehicleId));
return serviceRecords.ToList() ?? new List<ServiceRecord>();
};
} }
public ServiceRecord GetServiceRecordById(int serviceRecordId) public ServiceRecord GetServiceRecordById(int serviceRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<ServiceRecord>(tableName);
{ return table.FindById(serviceRecordId);
var table = db.GetCollection<ServiceRecord>(tableName);
return table.FindById(serviceRecordId);
};
} }
public bool DeleteServiceRecordById(int serviceRecordId) public bool DeleteServiceRecordById(int serviceRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<ServiceRecord>(tableName);
{ table.Delete(serviceRecordId);
var table = db.GetCollection<ServiceRecord>(tableName); return true;
table.Delete(serviceRecordId);
return true;
};
} }
public bool SaveServiceRecordToVehicle(ServiceRecord serviceRecord) public bool SaveServiceRecordToVehicle(ServiceRecord serviceRecord)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<ServiceRecord>(tableName);
{ table.Upsert(serviceRecord);
var table = db.GetCollection<ServiceRecord>(tableName); return true;
table.Upsert(serviceRecord);
return true;
};
} }
public bool DeleteAllServiceRecordsByVehicleId(int vehicleId) public bool DeleteAllServiceRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<ServiceRecord>(tableName);
{ var serviceRecords = table.DeleteMany(Query.EQ(nameof(ServiceRecord.VehicleId), vehicleId));
var table = db.GetCollection<ServiceRecord>(tableName); return true;
var serviceRecords = table.DeleteMany(Query.EQ(nameof(ServiceRecord.VehicleId), vehicleId));
return true;
};
} }
} }
} }

49
External/Implementations/Litedb/SupplyRecordDataAccess.cs vendored
View File

@ -7,51 +7,40 @@ namespace CarCareTracker.External.Implementations
{ {
public class SupplyRecordDataAccess : ISupplyRecordDataAccess public class SupplyRecordDataAccess : ISupplyRecordDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
private static string tableName = "supplyrecords"; private static string tableName = "supplyrecords";
public SupplyRecordDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
public List<SupplyRecord> GetSupplyRecordsByVehicleId(int vehicleId) public List<SupplyRecord> GetSupplyRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<SupplyRecord>(tableName);
{ var supplyRecords = table.Find(Query.EQ(nameof(SupplyRecord.VehicleId), vehicleId));
var table = db.GetCollection<SupplyRecord>(tableName); return supplyRecords.ToList() ?? new List<SupplyRecord>();
var supplyRecords = table.Find(Query.EQ(nameof(SupplyRecord.VehicleId), vehicleId));
return supplyRecords.ToList() ?? new List<SupplyRecord>();
};
} }
public SupplyRecord GetSupplyRecordById(int supplyRecordId) public SupplyRecord GetSupplyRecordById(int supplyRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<SupplyRecord>(tableName);
{ return table.FindById(supplyRecordId);
var table = db.GetCollection<SupplyRecord>(tableName);
return table.FindById(supplyRecordId);
};
} }
public bool DeleteSupplyRecordById(int supplyRecordId) public bool DeleteSupplyRecordById(int supplyRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<SupplyRecord>(tableName);
{ table.Delete(supplyRecordId);
var table = db.GetCollection<SupplyRecord>(tableName); return true;
table.Delete(supplyRecordId);
return true;
};
} }
public bool SaveSupplyRecordToVehicle(SupplyRecord supplyRecord) public bool SaveSupplyRecordToVehicle(SupplyRecord supplyRecord)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<SupplyRecord>(tableName);
{ table.Upsert(supplyRecord);
var table = db.GetCollection<SupplyRecord>(tableName); return true;
table.Upsert(supplyRecord);
return true;
};
} }
public bool DeleteAllSupplyRecordsByVehicleId(int vehicleId) public bool DeleteAllSupplyRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<SupplyRecord>(tableName);
{ var supplyRecords = table.DeleteMany(Query.EQ(nameof(SupplyRecord.VehicleId), vehicleId));
var table = db.GetCollection<SupplyRecord>(tableName); return true;
var supplyRecords = table.DeleteMany(Query.EQ(nameof(SupplyRecord.VehicleId), vehicleId));
return true;
};
} }
} }
} }

49
External/Implementations/Litedb/TaxRecordDataAccess.cs vendored
View File

@ -7,51 +7,40 @@ namespace CarCareTracker.External.Implementations
{ {
public class TaxRecordDataAccess : ITaxRecordDataAccess public class TaxRecordDataAccess : ITaxRecordDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
private static string tableName = "taxrecords"; private static string tableName = "taxrecords";
public TaxRecordDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
public List<TaxRecord> GetTaxRecordsByVehicleId(int vehicleId) public List<TaxRecord> GetTaxRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<TaxRecord>(tableName);
{ var taxRecords = table.Find(Query.EQ(nameof(TaxRecord.VehicleId), vehicleId));
var table = db.GetCollection<TaxRecord>(tableName); return taxRecords.ToList() ?? new List<TaxRecord>();
var taxRecords = table.Find(Query.EQ(nameof(TaxRecord.VehicleId), vehicleId));
return taxRecords.ToList() ?? new List<TaxRecord>();
};
} }
public TaxRecord GetTaxRecordById(int taxRecordId) public TaxRecord GetTaxRecordById(int taxRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<TaxRecord>(tableName);
{ return table.FindById(taxRecordId);
var table = db.GetCollection<TaxRecord>(tableName);
return table.FindById(taxRecordId);
};
} }
public bool DeleteTaxRecordById(int taxRecordId) public bool DeleteTaxRecordById(int taxRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<TaxRecord>(tableName);
{ table.Delete(taxRecordId);
var table = db.GetCollection<TaxRecord>(tableName); return true;
table.Delete(taxRecordId);
return true;
};
} }
public bool SaveTaxRecordToVehicle(TaxRecord taxRecord) public bool SaveTaxRecordToVehicle(TaxRecord taxRecord)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<TaxRecord>(tableName);
{ table.Upsert(taxRecord);
var table = db.GetCollection<TaxRecord>(tableName); return true;
table.Upsert(taxRecord);
return true;
};
} }
public bool DeleteAllTaxRecordsByVehicleId(int vehicleId) public bool DeleteAllTaxRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<TaxRecord>(tableName);
{ var taxRecords = table.DeleteMany(Query.EQ(nameof(TaxRecord.VehicleId), vehicleId));
var table = db.GetCollection<TaxRecord>(tableName); return true;
var taxRecords = table.DeleteMany(Query.EQ(nameof(TaxRecord.VehicleId), vehicleId));
return true;
};
} }
} }
} }

49
External/Implementations/Litedb/TokenRecordDataAccess.cs vendored
View File

@ -7,51 +7,40 @@ namespace CarCareTracker.External.Implementations
{ {
public class TokenRecordDataAccess : ITokenRecordDataAccess public class TokenRecordDataAccess : ITokenRecordDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
private static string tableName = "tokenrecords"; private static string tableName = "tokenrecords";
public TokenRecordDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
public List<Token> GetTokens() public List<Token> GetTokens()
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<Token>(tableName);
{ return table.FindAll().ToList();
var table = db.GetCollection<Token>(tableName);
return table.FindAll().ToList();
};
} }
public Token GetTokenRecordByBody(string tokenBody) public Token GetTokenRecordByBody(string tokenBody)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<Token>(tableName);
{ var tokenRecord = table.FindOne(Query.EQ(nameof(Token.Body), tokenBody));
var table = db.GetCollection<Token>(tableName); return tokenRecord ?? new Token();
var tokenRecord = table.FindOne(Query.EQ(nameof(Token.Body), tokenBody));
return tokenRecord ?? new Token();
};
} }
public Token GetTokenRecordByEmailAddress(string emailAddress) public Token GetTokenRecordByEmailAddress(string emailAddress)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<Token>(tableName);
{ var tokenRecord = table.FindOne(Query.EQ(nameof(Token.EmailAddress), emailAddress));
var table = db.GetCollection<Token>(tableName); return tokenRecord ?? new Token();
var tokenRecord = table.FindOne(Query.EQ(nameof(Token.EmailAddress), emailAddress));
return tokenRecord ?? new Token();
};
} }
public bool CreateNewToken(Token token) public bool CreateNewToken(Token token)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<Token>(tableName);
{ table.Insert(token);
var table = db.GetCollection<Token>(tableName); return true;
table.Insert(token);
return true;
};
} }
public bool DeleteToken(int tokenId) public bool DeleteToken(int tokenId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<Token>(tableName);
{ table.Delete(tokenId);
var table = db.GetCollection<Token>(tableName); return true;
table.Delete(tokenId);
return true;
};
} }
} }
} }

49
External/Implementations/Litedb/UpgradeRecordDataAccess.cs vendored
View File

@ -7,51 +7,40 @@ namespace CarCareTracker.External.Implementations
{ {
public class UpgradeRecordDataAccess : IUpgradeRecordDataAccess public class UpgradeRecordDataAccess : IUpgradeRecordDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
public UpgradeRecordDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
private static string tableName = "upgraderecords"; private static string tableName = "upgraderecords";
public List<UpgradeRecord> GetUpgradeRecordsByVehicleId(int vehicleId) public List<UpgradeRecord> GetUpgradeRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UpgradeRecord>(tableName);
{ var upgradeRecords = table.Find(Query.EQ(nameof(UpgradeRecord.VehicleId), vehicleId));
var table = db.GetCollection<UpgradeRecord>(tableName); return upgradeRecords.ToList() ?? new List<UpgradeRecord>();
var upgradeRecords = table.Find(Query.EQ(nameof(UpgradeRecord.VehicleId), vehicleId));
return upgradeRecords.ToList() ?? new List<UpgradeRecord>();
};
} }
public UpgradeRecord GetUpgradeRecordById(int upgradeRecordId) public UpgradeRecord GetUpgradeRecordById(int upgradeRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UpgradeRecord>(tableName);
{ return table.FindById(upgradeRecordId);
var table = db.GetCollection<UpgradeRecord>(tableName);
return table.FindById(upgradeRecordId);
};
} }
public bool DeleteUpgradeRecordById(int upgradeRecordId) public bool DeleteUpgradeRecordById(int upgradeRecordId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UpgradeRecord>(tableName);
{ table.Delete(upgradeRecordId);
var table = db.GetCollection<UpgradeRecord>(tableName); return true;
table.Delete(upgradeRecordId);
return true;
};
} }
public bool SaveUpgradeRecordToVehicle(UpgradeRecord upgradeRecord) public bool SaveUpgradeRecordToVehicle(UpgradeRecord upgradeRecord)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UpgradeRecord>(tableName);
{ table.Upsert(upgradeRecord);
var table = db.GetCollection<UpgradeRecord>(tableName); return true;
table.Upsert(upgradeRecord);
return true;
};
} }
public bool DeleteAllUpgradeRecordsByVehicleId(int vehicleId) public bool DeleteAllUpgradeRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UpgradeRecord>(tableName);
{ var upgradeRecords = table.DeleteMany(Query.EQ(nameof(UpgradeRecord.VehicleId), vehicleId));
var table = db.GetCollection<UpgradeRecord>(tableName); return true;
var upgradeRecords = table.DeleteMany(Query.EQ(nameof(UpgradeRecord.VehicleId), vehicleId));
return true;
};
} }
} }
} }

64
External/Implementations/Litedb/UserAccessDataAcces.cs vendored
View File

@ -1,5 +1,4 @@
using CarCareTracker.External.Interfaces; using CarCareTracker.External.Interfaces;
using CarCareTracker.Helper;
using CarCareTracker.Models; using CarCareTracker.Models;
using LiteDB; using LiteDB;
@ -7,8 +6,12 @@ namespace CarCareTracker.External.Implementations
{ {
public class UserAccessDataAccess : IUserAccessDataAccess public class UserAccessDataAccess : IUserAccessDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
private static string tableName = "useraccessrecords"; private static string tableName = "useraccessrecords";
public UserAccessDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
/// <summary> /// <summary>
/// Gets a list of vehicles user have access to. /// Gets a list of vehicles user have access to.
/// </summary> /// </summary>
@ -16,45 +19,30 @@ namespace CarCareTracker.External.Implementations
/// <returns></returns> /// <returns></returns>
public List<UserAccess> GetUserAccessByUserId(int userId) public List<UserAccess> GetUserAccessByUserId(int userId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UserAccess>(tableName);
{ return table.Find(x => x.Id.UserId == userId).ToList();
var table = db.GetCollection<UserAccess>(tableName);
return table.Find(x=>x.Id.UserId == userId).ToList();
};
} }
public UserAccess GetUserAccessByVehicleAndUserId(int userId, int vehicleId) public UserAccess GetUserAccessByVehicleAndUserId(int userId, int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UserAccess>(tableName);
{ return table.Find(x => x.Id.UserId == userId && x.Id.VehicleId == vehicleId).FirstOrDefault();
var table = db.GetCollection<UserAccess>(tableName);
return table.Find(x => x.Id.UserId == userId && x.Id.VehicleId == vehicleId).FirstOrDefault();
};
} }
public List<UserAccess> GetUserAccessByVehicleId(int vehicleId) public List<UserAccess> GetUserAccessByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UserAccess>(tableName);
{ return table.Find(x => x.Id.VehicleId == vehicleId).ToList();
var table = db.GetCollection<UserAccess>(tableName);
return table.Find(x => x.Id.VehicleId == vehicleId).ToList();
};
} }
public bool SaveUserAccess(UserAccess userAccess) public bool SaveUserAccess(UserAccess userAccess)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UserAccess>(tableName);
{ table.Upsert(userAccess);
var table = db.GetCollection<UserAccess>(tableName); return true;
table.Upsert(userAccess);
return true;
};
} }
public bool DeleteUserAccess(int userId, int vehicleId) public bool DeleteUserAccess(int userId, int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UserAccess>(tableName);
{ table.DeleteMany(x => x.Id.UserId == userId && x.Id.VehicleId == vehicleId);
var table = db.GetCollection<UserAccess>(tableName); return true;
table.DeleteMany(x => x.Id.UserId == userId && x.Id.VehicleId == vehicleId);
return true;
};
} }
/// <summary> /// <summary>
/// Delete all access records when a vehicle is deleted. /// Delete all access records when a vehicle is deleted.
@ -63,12 +51,9 @@ namespace CarCareTracker.External.Implementations
/// <returns></returns> /// <returns></returns>
public bool DeleteAllAccessRecordsByVehicleId(int vehicleId) public bool DeleteAllAccessRecordsByVehicleId(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UserAccess>(tableName);
{ table.DeleteMany(x => x.Id.VehicleId == vehicleId);
var table = db.GetCollection<UserAccess>(tableName); return true;
table.DeleteMany(x=>x.Id.VehicleId == vehicleId);
return true;
};
} }
/// <summary> /// <summary>
/// Delee all access records when a user is deleted. /// Delee all access records when a user is deleted.
@ -77,12 +62,9 @@ namespace CarCareTracker.External.Implementations
/// <returns></returns> /// <returns></returns>
public bool DeleteAllAccessRecordsByUserId(int userId) public bool DeleteAllAccessRecordsByUserId(int userId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UserAccess>(tableName);
{ table.DeleteMany(x => x.Id.UserId == userId);
var table = db.GetCollection<UserAccess>(tableName); return true;
table.DeleteMany(x => x.Id.UserId == userId);
return true;
};
} }
} }
} }

34
External/Implementations/Litedb/UserConfigDataAccess.cs vendored
View File

@ -1,39 +1,33 @@
using CarCareTracker.External.Interfaces; using CarCareTracker.External.Interfaces;
using CarCareTracker.Helper;
using CarCareTracker.Models; using CarCareTracker.Models;
using LiteDB; using LiteDB;
namespace CarCareTracker.External.Implementations namespace CarCareTracker.External.Implementations
{ {
public class UserConfigDataAccess: IUserConfigDataAccess public class UserConfigDataAccess : IUserConfigDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
private static string tableName = "userconfigrecords"; private static string tableName = "userconfigrecords";
public UserConfigDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
public UserConfigData GetUserConfig(int userId) public UserConfigData GetUserConfig(int userId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UserConfigData>(tableName);
{ return table.FindById(userId);
var table = db.GetCollection<UserConfigData>(tableName);
return table.FindById(userId);
};
} }
public bool SaveUserConfig(UserConfigData userConfigData) public bool SaveUserConfig(UserConfigData userConfigData)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UserConfigData>(tableName);
{ table.Upsert(userConfigData);
var table = db.GetCollection<UserConfigData>(tableName); return true;
table.Upsert(userConfigData);
return true;
};
} }
public bool DeleteUserConfig(int userId) public bool DeleteUserConfig(int userId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UserConfigData>(tableName);
{ table.Delete(userId);
var table = db.GetCollection<UserConfigData>(tableName); return true;
table.Delete(userId);
return true;
};
} }
} }
} }

59
External/Implementations/Litedb/UserRecordDataAccess.cs vendored
View File

@ -1,5 +1,4 @@
using CarCareTracker.External.Interfaces; using CarCareTracker.External.Interfaces;
using CarCareTracker.Helper;
using CarCareTracker.Models; using CarCareTracker.Models;
using LiteDB; using LiteDB;
@ -7,60 +6,46 @@ namespace CarCareTracker.External.Implementations
{ {
public class UserRecordDataAccess : IUserRecordDataAccess public class UserRecordDataAccess : IUserRecordDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
private static string tableName = "userrecords"; private static string tableName = "userrecords";
public UserRecordDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
public List<UserData> GetUsers() public List<UserData> GetUsers()
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UserData>(tableName);
{ return table.FindAll().ToList();
var table = db.GetCollection<UserData>(tableName);
return table.FindAll().ToList();
};
} }
public UserData GetUserRecordByUserName(string userName) public UserData GetUserRecordByUserName(string userName)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UserData>(tableName);
{ var userRecord = table.FindOne(Query.EQ(nameof(UserData.UserName), userName));
var table = db.GetCollection<UserData>(tableName); return userRecord ?? new UserData();
var userRecord = table.FindOne(Query.EQ(nameof(UserData.UserName), userName));
return userRecord ?? new UserData();
};
} }
public UserData GetUserRecordByEmailAddress(string emailAddress) public UserData GetUserRecordByEmailAddress(string emailAddress)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UserData>(tableName);
{ var userRecord = table.FindOne(Query.EQ(nameof(UserData.EmailAddress), emailAddress));
var table = db.GetCollection<UserData>(tableName); return userRecord ?? new UserData();
var userRecord = table.FindOne(Query.EQ(nameof(UserData.EmailAddress), emailAddress));
return userRecord ?? new UserData();
};
} }
public UserData GetUserRecordById(int userId) public UserData GetUserRecordById(int userId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UserData>(tableName);
{ var userRecord = table.FindById(userId);
var table = db.GetCollection<UserData>(tableName); return userRecord ?? new UserData();
var userRecord = table.FindById(userId);
return userRecord ?? new UserData();
};
} }
public bool SaveUserRecord(UserData userRecord) public bool SaveUserRecord(UserData userRecord)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UserData>(tableName);
{ table.Upsert(userRecord);
var table = db.GetCollection<UserData>(tableName); return true;
table.Upsert(userRecord);
return true;
};
} }
public bool DeleteUserRecord(int userId) public bool DeleteUserRecord(int userId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<UserData>(tableName);
{ table.Delete(userId);
var table = db.GetCollection<UserData>(tableName); return true;
table.Delete(userId);
return true;
};
} }
} }
} }

39
External/Implementations/Litedb/VehicleDataAccess.cs vendored
View File

@ -1,46 +1,37 @@
using CarCareTracker.External.Interfaces; using CarCareTracker.External.Interfaces;
using CarCareTracker.Helper;
using CarCareTracker.Models; using CarCareTracker.Models;
using LiteDB; using LiteDB;
namespace CarCareTracker.External.Implementations namespace CarCareTracker.External.Implementations
{ {
public class VehicleDataAccess: IVehicleDataAccess public class VehicleDataAccess : IVehicleDataAccess
{ {
private static string dbName = StaticHelper.DbName; private LiteDatabase db { get; set; }
private static string tableName = "vehicles"; private static string tableName = "vehicles";
public VehicleDataAccess(ILiteDBInjection liteDB)
{
db = liteDB.GetLiteDB();
}
public bool SaveVehicle(Vehicle vehicle) public bool SaveVehicle(Vehicle vehicle)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<Vehicle>(tableName);
{ var result = table.Upsert(vehicle);
var table = db.GetCollection<Vehicle>(tableName); return true;
var result = table.Upsert(vehicle);
return true;
};
} }
public bool DeleteVehicle(int vehicleId) public bool DeleteVehicle(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<Vehicle>(tableName);
{ return table.Delete(vehicleId);
var table = db.GetCollection<Vehicle>(tableName);
return table.Delete(vehicleId);
};
} }
public List<Vehicle> GetVehicles() public List<Vehicle> GetVehicles()
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<Vehicle>(tableName);
{ return table.FindAll().ToList();
var table = db.GetCollection<Vehicle>(tableName);
return table.FindAll().ToList();
};
} }
public Vehicle GetVehicleById(int vehicleId) public Vehicle GetVehicleById(int vehicleId)
{ {
using (var db = new LiteDatabase(dbName)) var table = db.GetCollection<Vehicle>(tableName);
{ return table.FindById(vehicleId);
var table = db.GetCollection<Vehicle>(tableName);
return table.FindById(vehicleId);
};
} }
} }
} }

1
Program.cs
View File

@ -38,6 +38,7 @@ if (!string.IsNullOrWhiteSpace(builder.Configuration["POSTGRES_CONNECTION"])){
} }
else else
{ {
builder.Services.AddSingleton<ILiteDBInjection, LiteDBInjection>();
builder.Services.AddSingleton<IVehicleDataAccess, VehicleDataAccess>(); builder.Services.AddSingleton<IVehicleDataAccess, VehicleDataAccess>();
builder.Services.AddSingleton<INoteDataAccess, NoteDataAccess>(); builder.Services.AddSingleton<INoteDataAccess, NoteDataAccess>();
builder.Services.AddSingleton<IServiceRecordDataAccess, ServiceRecordDataAccess>(); builder.Services.AddSingleton<IServiceRecordDataAccess, ServiceRecordDataAccess>();