Chris/FlexitimeTracker
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Move the database calls/procedures out into the SQLiteRepository, IRepository implementation.

Browse Source 
created SQLiteProcedures to hold all the strings for procs. Constants also serves similar purpose.
renamed Class1 to SQLiteRepository.cs
added all the necessary nuget packages for SQLite.Net-PCL
This commit is contained in:
chris.watts90@outlook.com 2017-01-31 21:59:42 +00:00
parent 440c1f44ce
commit bc1947a31f
9 changed files with 322 additions and 50 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
DataCenter_Windows/WindowsDataCenter/SQLiteRepository/CardUniqueId.cs Normal file
View File

@ -0,0 +1,12 @@
using SQLite.Net.Attributes;
namespace SQLiteRepository
{
public sealed class CardUniqueId
{
[PrimaryKey, AutoIncrement]
public int Id { get; set; }
public int UserId_FK { get; set; }
public string CardUId { get; set; }
}
}

50
DataCenter_Windows/WindowsDataCenter/SQLiteRepository/Class1.cs
View File

@ -1,50 +0,0 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Interfaces;
using SQLite.Net;
namespace SQLiteRepository
{
public class SQLiteRepository:IRepository
{
private SQLiteConnection _connection;
public UserList GetUsers()
{
throw new NotImplementedException();
}
public User GetUser(int id)
{
throw new NotImplementedException();
}
public TimeLogList GetTimeLogs(int userId)
{
throw new NotImplementedException();
}
public TimeLogList GetTimeLogs(int userId, int calendarWeek)
{
throw new NotImplementedException();
}
public IdentifierList GetUnassignedList()
{
throw new NotImplementedException();
}
public OperationResponse UpdateUser(User user)
{
throw new NotImplementedException();
}
public OperationResponse LogEventTime(Identifier identifier)
{
throw new NotImplementedException();
}
}
}

7
DataCenter_Windows/WindowsDataCenter/SQLiteRepository/Constants.cs Normal file
View File

@ -0,0 +1,7 @@
namespace SQLiteRepository
{
internal class Constants
{
public const int UNASSIGNED_CARD_USER_ID = -1;
}
}

18
DataCenter_Windows/WindowsDataCenter/SQLiteRepository/SQLiteProcedures.cs Normal file
View File

@ -0,0 +1,18 @@
namespace SQLiteRepository
{
internal static class SQLiteProcedures
{
public const string GET_ALL_USERS = "select * from UserIdentity";
public const string GET_USER_BY_ID = "select * from UserIdentity where Id=?";
public const string GET_CARDS_BY_USER_ID = "select * from CardUniqueId where UserId_FK=?";
public const string GET_CARDS_BY_UNIQUE_ID = "select * from CardUniqueId where CardUId=?";
public const string GET_UNASSIGNED_CARD_LIST = "select * from CardUniqueId where UserId_FK=?";
public const string GET_USER_BY_FIRST_AND_LAST =
"select * from UserIdentity where FirstName = ? AND LastName = ?";
public const string UPDATE_CARD_USER_ID = "update CardUniqueId set UserId_FK=? where Id=?";
}
}

243
DataCenter_Windows/WindowsDataCenter/SQLiteRepository/SQLiteRepository.cs Normal file
View File

@ -0,0 +1,243 @@
using System;
using System.Collections.Generic;
using System.Linq;
using Interfaces;
using SQLite.Net;
using SQLite.Net.Platform.Win32;
namespace SQLiteRepository
{
public class SQLiteRepository : IRepository
{
private readonly SQLiteConnection _connection;
private string _path = "flexitimedb.db";
public SQLiteRepository()
{
_connection = new SQLiteConnection(new SQLitePlatformWin32(), _path);
_connection.CreateTable<CardUniqueId>();
_connection.CreateTable<UserIdentity>();
_connection.CreateTable<TimeLog>();
}
public UserList GetUsers()
{
var ret = new UserList();
var users = _connection.Query<UserIdentity>(SQLiteProcedures.GET_ALL_USERS);
if (!users.Any())
{
ret.PageNumber = 1;
ret.PageSize = 20;
return ret;
}
foreach (var user in users)
{
var userObj = ChangeToUserObject(user);
var cards = _connection.Query<CardUniqueId>(
SQLiteProcedures.GET_CARDS_BY_USER_ID,
user.Id);
foreach (var card in cards)
{
userObj.AssociatedIdentifiers.Add(new Identifier()
{
UniqueId = card.CardUId,
IsAssociatedToUser = true,
Id = card.Id
});
}
ret.Users.Add(userObj);
}
ret.PageSize = 20;
ret.PageNumber = 1;
return ret;
}
public User GetUser(int id)
{
var ret = new User();
var users = _connection.Query<UserIdentity>(
SQLiteProcedures.GET_USER_BY_ID,
id);
if (!users.Any()) return ret;
var user = users.First();
ret = ChangeToUserObject(user);
var cards = _connection.Query<CardUniqueId>(
SQLiteProcedures.GET_CARDS_BY_USER_ID,
user.Id);
foreach (var card in cards)
{
ret.AssociatedIdentifiers.Add(new Identifier { UniqueId = card.CardUId, IsAssociatedToUser = true, Id = card.Id});
}
return ret;
}
public TimeLogList GetTimeLogs(int userId)
{
throw new NotImplementedException();
}
public TimeLogList GetTimeLogs(int userId, int calendarWeek)
{
throw new NotImplementedException();
}
public IdentifierList GetUnassignedIdentifierList()
{
var ret = new IdentifierList();
var cardQuery = _connection.Query<CardUniqueId>(
SQLiteProcedures.GET_UNASSIGNED_CARD_LIST,
Constants.UNASSIGNED_CARD_USER_ID);
foreach (var card in cardQuery)
{
ret.data.Add(new Identifier
{
Id = card.Id,
IsAssociatedToUser = card.UserId_FK != Constants.UNASSIGNED_CARD_USER_ID,
UniqueId = card.CardUId
});
}
return ret;
}
//TODO: add method which returns userId? maybe as ref?
public OperationResponse UpdateUser(User user)
{
if(user.UserId <=0) return OperationResponse.FAILED;
var ret = OperationResponse.NONE;
var cardIds = new List<int>();
//Get a list of current cards, convert into a list of Identifier Objects..
var currentCards =
_connection.Query<CardUniqueId>(SQLiteProcedures.GET_CARDS_BY_USER_ID, user.UserId)
.Select(x => new Identifier {Id = x.Id, IsAssociatedToUser = true, UniqueId = x.CardUId});
var cardsToRemove = currentCards.Except(user.AssociatedIdentifiers).Select(x=>x.Id).ToList();
#region GetUnique Identifiers (what am i doing here?)
foreach (var card in user.AssociatedIdentifiers)
{
var existingCard = _connection.Query<CardUniqueId>(
SQLiteProcedures.GET_CARDS_BY_UNIQUE_ID, card.UniqueId);
if (!existingCard.Any())
{
var cardInsert = new CardUniqueId { CardUId = card.UniqueId, UserId_FK = -1 };
_connection.Insert(cardInsert);
cardIds.Add(cardInsert.Id);
if (ret < OperationResponse.CREATED)
ret = OperationResponse.CREATED; //only change it if my status supercedes.
}
else
{
cardIds.Add(existingCard.First().Id);
if (ret < OperationResponse.UPDATED)
ret = OperationResponse.UPDATED;
}
}
#endregion
#region Update/Create User
int userId;
var userQuery = _connection.Query<UserIdentity>(
SQLiteProcedures.GET_USER_BY_FIRST_AND_LAST,
user.FirstName, user.LastName);
if (userQuery.Any())
{
userId = userQuery.First().Id;
if (ret < OperationResponse.UPDATED)
ret = OperationResponse.UPDATED;
}
else
{
var userInsert = new UserIdentity
{
FirstName = user.FirstName,
LastName = user.LastName,
HoursPerWeek = user.HoursPerWeek
};
_connection.Insert(userInsert);
userId = userInsert.Id;
if (ret < OperationResponse.CREATED)
ret = OperationResponse.CREATED;
}
#endregion
#region Update Card/Unique Id entries.
foreach (var cardId in cardIds)
{
_connection.Query<CardUniqueId>(
SQLiteProcedures.UPDATE_CARD_USER_ID,
userId, cardId);
}
foreach (var card in cardsToRemove)
{
_connection.Query<CardUniqueId>(
SQLiteProcedures.UPDATE_CARD_USER_ID,
-1, card);
}
#endregion
return ret;
}
public OperationResponse LogEventTime(Identifier identifier)
{
var cardIdQuery = _connection.Query<CardUniqueId>(
SQLiteProcedures.GET_CARDS_BY_UNIQUE_ID,
identifier.UniqueId);
var ident = new CardUniqueId();
if (!cardIdQuery.Any())
{
//new card, create it!
ident.UserId_FK = -1;
ident.CardUId = identifier.UniqueId;
_connection.Insert(ident);
}
else
{
//TODO: handle when more than one comes back. should NEVER happen but....
ident = cardIdQuery.First();
}
var userId = ident.UserId_FK;
//TODO: Handle In/Out Flag..
//TODO: Handle When the identifier is assigned to a user (identifier has -1)
var timeLog = new TimeLog
{
SwipeEventDateTime = DateTime.UtcNow,
UserId_FK = userId,
IdentifierId = ident.Id
};
_connection.Insert(timeLog);
return OperationResponse.SUCCESS;
}
private User ChangeToUserObject(UserIdentity user)
{
return new User
{
UserId = user.Id,
FirstName = user.FirstName,
LastName = user.LastName,
HoursPerWeek = user.HoursPerWeek
};
}
}
}

13
DataCenter_Windows/WindowsDataCenter/SQLiteRepository/SQLiteRepository.csproj
View File

@ -34,6 +34,14 @@
<HintPath>..\packages\SQLite.Net.Core-PCL.3.1.1\lib\portable-win8+net45+wp8+wpa81+MonoAndroid1+MonoTouch1\SQLite.Net.dll</HintPath>
<Private>True</Private>
</Reference>
<Reference Include="SQLite.Net.Platform.Generic, Version=3.1.0.0, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\packages\SQLite.Net-PCL.3.1.1\lib\net40\SQLite.Net.Platform.Generic.dll</HintPath>
<Private>True</Private>
</Reference>
<Reference Include="SQLite.Net.Platform.Win32, Version=3.1.0.0, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\packages\SQLite.Net-PCL.3.1.1\lib\net4\SQLite.Net.Platform.Win32.dll</HintPath>
<Private>True</Private>
</Reference>
<Reference Include="System" />
<Reference Include="System.Core" />
<Reference Include="System.Xml.Linq" />
@ -44,8 +52,13 @@
<Reference Include="System.Xml" />
</ItemGroup>
<ItemGroup>
<Compile Include="CardUniqueId.cs" />
<Compile Include="Class1.cs" />
<Compile Include="Constants.cs" />
<Compile Include="Properties\AssemblyInfo.cs" />
<Compile Include="SQLiteProcedures.cs" />
<Compile Include="TimeLog.cs" />
<Compile Include="UserIdentity.cs" />
</ItemGroup>
<ItemGroup>
<ProjectReference Include="..\Interfaces\Interfaces.csproj">

15
DataCenter_Windows/WindowsDataCenter/SQLiteRepository/TimeLog.cs Normal file
View File

@ -0,0 +1,15 @@
using System;
using SQLite.Net.Attributes;
namespace SQLiteRepository
{
public sealed class TimeLog
{
[PrimaryKey, AutoIncrement]
public int Id { get; set; }
public int UserId_FK { get; set; }
public int IdentifierId { get; set; }
public bool InOut { get; set; }
public DateTimeOffset SwipeEventDateTime { get; set; }
}
}

13
DataCenter_Windows/WindowsDataCenter/SQLiteRepository/UserIdentity.cs Normal file
View File

@ -0,0 +1,13 @@
using SQLite.Net.Attributes;
namespace SQLiteRepository
{
public sealed class UserIdentity
{
[PrimaryKey, AutoIncrement]
public int Id { get; set; }
public string FirstName { get; set; }
public string LastName { get; set; }
public float HoursPerWeek { get; set; }
}
}

1
DataCenter_Windows/WindowsDataCenter/SQLiteRepository/packages.config
View File

@ -1,4 +1,5 @@
<?xml version="1.0" encoding="utf-8"?>
<packages>
<package id="SQLite.Net.Core-PCL" version="3.1.1" targetFramework="net452" />
<package id="SQLite.Net-PCL" version="3.1.1" targetFramework="net452" />
</packages>