Update the repositories to use the new interface

This commit is contained in:
Sébastien André
2019-11-12 14:58:45 +01:00
parent 5d834a97cf
commit 8139ad5ecb
4 changed files with 45 additions and 57 deletions

View File

@@ -11,33 +11,30 @@ namespace skydiveLogs_api.Data
{ {
public class GearRepository : IGearRepository public class GearRepository : IGearRepository
{ {
public IEnumerable<Gear> GetAll() public GearRepository(IDataProvider dataProvider)
{ {
IEnumerable<Gear> result = new List<Gear>(); _dataProvider = dataProvider;
_col = _dataProvider.CollOfGear;
using (var db = new LiteDatabase(@".\Data\MyData.db"))
{
var col = db.GetCollection<Gear>("Gear");
result = col.FindAll().ToList();
} }
return result; public IEnumerable<Gear> GetAll()
{
var results = _col.FindAll().ToList();
_dataProvider.Close();
return results;
} }
public Gear GetById(int id) public Gear GetById(int id)
{ {
Gear result; var result = _col.FindById(new BsonValue(id));
_dataProvider.Close();
using (var db = new LiteDatabase(@".\Data\MyData.db"))
{
var col = db.GetCollection<Gear>("Gear");
result = col.FindById(new BsonValue(id));
}
return result; return result;
} }
private readonly IDataProvider _dataProvider;
private readonly LiteCollection<Gear> _col;
} }
} }

View File

@@ -11,30 +11,24 @@ namespace skydiveLogs_api.Data
{ {
public class JumpRepository : IJumpRepository public class JumpRepository : IJumpRepository
{ {
public IEnumerable<Jump> GetAll() public JumpRepository(IDataProvider dataProvider)
{ {
IEnumerable<Jump> result = new List<Jump>(); _dataProvider = dataProvider;
_col = _dataProvider.CollOfJump;
using (var db = new LiteDatabase(@".\Data\MyData.db"))
{
var col = db.GetCollection<Jump>("Jump");
result = col.FindAll().ToList();
} }
return result; public IEnumerable<Jump> GetAll()
{
var results = _col.FindAll().ToList();
_dataProvider.Close();
return results;
} }
public Jump GetById(int id) public Jump GetById(int id)
{ {
Jump result; var result = _col.FindById(new BsonValue(id));
_dataProvider.Close();
using (var db = new LiteDatabase(@".\Data\MyData.db"))
{
var col = db.GetCollection<Jump>("Jump");
result = col.FindById(new BsonValue(id));
}
return result; return result;
} }
@@ -45,12 +39,8 @@ namespace skydiveLogs_api.Data
try try
{ {
using (var db = new LiteDatabase(@".\Data\MyData.db")) _col.Insert(newJump);
{ _dataProvider.Close();
var col = db.GetCollection<Jump>("Jump");
col.Insert(newJump);
}
} }
catch catch
{ {
@@ -59,5 +49,9 @@ namespace skydiveLogs_api.Data
return result; return result;
} }
private readonly IDataProvider _dataProvider;
private readonly LiteCollection<Jump> _col;
} }
} }

View File

@@ -11,32 +11,29 @@ namespace skydiveLogs_api.Data
{ {
public class JumpTypeRepository : IJumpTypeRepository public class JumpTypeRepository : IJumpTypeRepository
{ {
public IEnumerable<JumpType> GetAll() public JumpTypeRepository(IDataProvider dataProvider)
{ {
IEnumerable<JumpType> result = new List<JumpType>(); _dataProvider = dataProvider;
_col = _dataProvider.CollOfJumpType;
using (var db = new LiteDatabase(@".\Data\MyData.db"))
{
var col = db.GetCollection<JumpType>("JumpType");
result = col.FindAll().ToList();
} }
return result; public IEnumerable<JumpType> GetAll()
{
var results = _col.FindAll().ToList();
_dataProvider.Close();
return results;
} }
public JumpType GetById(int id) public JumpType GetById(int id)
{ {
JumpType result; var result = _col.FindById(new BsonValue(id));
_dataProvider.Close();
using (var db = new LiteDatabase(@".\Data\MyData.db"))
{
var col = db.GetCollection<JumpType>("JumpType");
result = col.FindById(new BsonValue(id));
}
return result; return result;
} }
private readonly IDataProvider _dataProvider;
private readonly LiteCollection<JumpType> _col;
} }
} }

Binary file not shown.