Part 3.

Author: fullstackhub-io

UserManagement.Application/Common/Interfaces/IConfigConstants.cs

@@ -0,0 +1,20 @@
+namespace UserManagement.Application.Common.Interfaces
+{
+    public interface IConfigConstants
+    {
+        string FullStackConnection { get; }
+        string TestFullStackConnection { get; }
+        int LongRunningProcessMilliseconds { get; }
+        string MSG_USER_NULLUSERID { get; }
+        string MSG_USER_NULLFIRSTNAME { get; }
+        string MSG_USER_NULLLASTNAME { get; }
+        string MSG_USER_NULLDOB { get; }
+        string MSG_USER_NULLGENDER { get; }
+        string MSG_USER_GENDER_LEN { get; }
+        string MSG_USER_NULLEMAILADDR { get; }
+        string MSG_USER_NULLPHNUM { get; }
+        string MSG_USER_NULLCITY { get; }
+        string MSG_USER_NULLSTATE { get; }
+        string MSG_USER_NULLCOUNTRY { get; }
+    }
+}

UserManagement.Persistence/Constant/ConfigConstants.cs

@@ -0,0 +1,29 @@
+namespace UserManagement.Persistence.Constant
+{
+    using Microsoft.Extensions.Configuration;
+    using UserManagement.Application.Common.Interfaces;
+    public class ConfigConstants : IConfigConstants
+    {
+        public IConfiguration Configuration { get; }
+        public ConfigConstants(IConfiguration configuration)
+        {
+            this.Configuration = configuration;
+        }
+        public string FullStackConnection => this.Configuration.GetConnectionString("FullStackConnection");
+
+        public string TestFullStackConnection => this.Configuration.GetConnectionString("TestFullStackConnection");
+        public int LongRunningProcessMilliseconds => int.Parse(this.Configuration["AppSettings:LongRunningProcessMilliseconds"]);
+
+        public string MSG_USER_NULLUSERID => this.Configuration["AppSettings:MSG_USER_NULLUSERID"];
+        public string MSG_USER_NULLFIRSTNAME => this.Configuration["AppSettings:MSG_USER_NULLFIRSTNAME"];
+        public string MSG_USER_NULLLASTNAME => this.Configuration["AppSettings:MSG_USER_NULLLASTNAME"];
+        public string MSG_USER_NULLDOB => this.Configuration["AppSettings:MSG_USER_NULLDOB"];
+        public string MSG_USER_NULLGENDER => this.Configuration["AppSettings:MSG_USER_NULLGENDER"];
+        public string MSG_USER_GENDER_LEN => this.Configuration["AppSettings:MSG_USER_GENDER_LEN"];
+        public string MSG_USER_NULLEMAILADDR => this.Configuration["AppSettings:MSG_USER_NULLEMAILADDR"];
+        public string MSG_USER_NULLPHNUM => this.Configuration["AppSettings:MSG_USER_NULLPHNUM"];
+        public string MSG_USER_NULLCITY => this.Configuration["AppSettings:MSG_USER_NULLCITY"];
+        public string MSG_USER_NULLSTATE => this.Configuration["AppSettings:MSG_USER_NULLSTATE"];
+        public string MSG_USER_NULLCOUNTRY => this.Configuration["AppSettings:MSG_USER_NULLCOUNTRY"];
+    }
+}

UserManagement.Persistence/DependencyInjection.cs

@@ -0,0 +1,19 @@
+namespace UserManagement.Persistence
+{
+    using Microsoft.Extensions.DependencyInjection;
+    using System.Data;
+    using System.Data.SqlClient;
+    using UserManagement.Application.Common.Interfaces;
+    using UserManagement.Domain.UnitOfWork;
+    using UserManagement.Persistence.Constant;
+    public static class DependencyInjection
+    {
+        public static IServiceCollection AddPersistance(this IServiceCollection services)
+        {
+            services.AddSingleton<IConfigConstants, ConfigConstants>();
+            services.AddSingleton<IDbConnection>(conn => new SqlConnection(conn.GetService<IConfigConstants>().FullStackConnection));
+            services.AddTransient<IUnitOfWork>(uof => new UnitOfWork.UnitOfWork(uof.GetService<IDbConnection>()));
+            return services;
+        }
+    }
+}

UserManagement.Persistence/Repositories/Repository.cs

@@ -0,0 +1,14 @@
+namespace UserManagement.Persistence.Repositories
+{
+    using System.Data;
+    public class Repository
+    {
+        protected IDbConnection DbConnection { get; }
+        protected IDbTransaction DbTransaction { get; }
+        public Repository(IDbConnection dbConnection, IDbTransaction dbTransaction)
+        {
+            DbTransaction = dbTransaction;
+            DbConnection = dbConnection;
+        }
+    }
+}

UserManagement.Persistence/Repositories/UserRepository.cs

@@ -0,0 +1,50 @@
+namespace UserManagement.Persistence.Repositories
+{
+    using Dapper.Contrib.Extensions;
+    using System;
+    using System.Collections.Generic;
+    using System.Data;
+    using System.Threading.Tasks;
+    using UserManagement.Domain.Entities;
+    using UserManagement.Domain.Repositories;
+
+    public class UserRepository : Repository, IUserRepository
+    {
+        public UserRepository(IDbConnection dbConnection, IDbTransaction dbtransaction)
+            : base(dbConnection, dbtransaction)
+        {
+        }
+        public Task<int> AddUser(User user)
+        {
+            user.DateAdded = DateTime.Now;
+            user.DateUpdated = null;
+            return DbConnection.InsertAsync(user, DbTransaction);
+        }
+
+        public Task<bool> DeleteUser(int userId)
+        {
+            return DbConnection.DeleteAsync(new User { UserID = userId }, DbTransaction);
+        }
+
+        public Task<IEnumerable<User>> GetAllUsers()
+        {
+            return DbConnection.GetAllAsync<User>();
+        }
+
+        public Task<User> GetUser(long userId)
+        {
+            return DbConnection.GetAsync<User>(userId);
+        }
+
+        public Task<bool> UpdateUser(User user)
+        {
+            user.DateUpdated = DateTime.Now;
+            return DbConnection.UpdateAsync(user, DbTransaction);
+        }
+
+        public Task<bool> DeleteAllUser()
+        {
+            return DbConnection.DeleteAllAsync<User>();
+        }
+    }
+}

UserManagement.Persistence/UnitOfWork/UnitOfWork.cs

@@ -0,0 +1,47 @@
+namespace UserManagement.Persistence.UnitOfWork
+{
+    using System.Data;
+    using UserManagement.Domain.Repositories;
+    using UserManagement.Domain.UnitOfWork;
+    using UserManagement.Persistence.Repositories;
+
+    public class UnitOfWork : IUnitOfWork
+    {
+        private IDbConnection dbConnection;
+        private IDbTransaction transaction;
+        public UnitOfWork(IDbConnection dbConnection)
+        {
+            this.dbConnection = dbConnection;
+            this.ManageConnection();
+        }
+        public IUserRepository Users => new UserRepository(this.dbConnection, this.transaction);
+
+        public void StartTransaction()
+        {
+
+            if (this.transaction == null)
+            {
+                this.transaction = this.dbConnection.BeginTransaction();
+            }
+        }
+        public void Commit()
+        {
+            try
+            {
+                this.transaction.Commit();
+            }
+            catch
+            {
+                this.transaction.Rollback();
+            }
+        }
+
+        private void ManageConnection()
+        {
+            if (this.dbConnection.State == ConnectionState.Closed)
+            {
+                this.dbConnection.Open();
+            }
+        }
+    }
+}

UserManagement.Persistence/UserManagement.Persistence.csproj

@@ -4,4 +4,16 @@
     <TargetFramework>netstandard2.0</TargetFramework>
   </PropertyGroup>
 
+  <ItemGroup>
+    <PackageReference Include="Dapper.Contrib" Version="2.0.35" />
+    <PackageReference Include="Microsoft.Extensions.Configuration.Abstractions" Version="3.1.9" />
+    <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="3.1.9" />
+    <PackageReference Include="System.Data.SqlClient" Version="4.8.2" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\UserManagement.Application\UserManagement.Application.csproj" />
+    <ProjectReference Include="..\UserManagement.Domain\UserManagement.Domain.csproj" />
+  </ItemGroup>
+
 </Project>