Add SQL table creator

Author: mo-esmp

src/DynamicAuthorization.Mvc.JsonStore/Extensions/DynamicAuthorizationJsonBuilderExtensions.cs

@@ -7,7 +7,7 @@
 
 namespace DynamicAuthorization.Mvc.JsonStore.Extensions
 {
-    public static class ServiceCollectionExtensions
+    public static class DynamicAuthorizationBuilderExtensions
     {
         private static readonly string Directory = Path.GetDirectoryName(typeof(RoleAccessStore).GetTypeInfo().Assembly.Location);
 

src/DynamicAuthorization.Mvc.MsSqlServerStore/DynamicAuthorization.Mvc.MsSqlServerStore.csproj

@@ -6,6 +6,7 @@
 
   <ItemGroup>
     <PackageReference Include="Dapper" Version="2.0.30" />
+    <PackageReference Include="Microsoft.Data.SqlClient" Version="2.1.1" />
   </ItemGroup>
 
   <ItemGroup>

src/DynamicAuthorization.Mvc.MsSqlServerStore/Extensions/DynamicAuthorizationBuilderExtensions.cs

@@ -0,0 +1,34 @@
+using DynamicAuthorization.Mvc.Core;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+using System;
+
+namespace DynamicAuthorization.Mvc.MsSqlServerStore
+{
+    public static class DynamicAuthorizationBuilderExtensions
+    {
+        public static IDynamicAuthorizationBuilder AddSqlServerStore(this IDynamicAuthorizationBuilder builder, Action<SqlOptions> options)
+        {
+            if (builder == null)
+                throw new ArgumentNullException(nameof(builder));
+
+            var sqlOptions = new SqlOptions();
+            options.Invoke(sqlOptions);
+
+            var serviceProvider = builder.Services.BuildServiceProvider();
+            var scope = serviceProvider.CreateScope();
+            var logger = scope.ServiceProvider.GetService<ILogger<SqlTableCreator>>();
+
+            var tableCreator = new SqlTableCreator(sqlOptions, logger);
+            tableCreator.CreateTable();
+
+            scope.Dispose();
+            serviceProvider.Dispose();
+
+            builder.Services.AddSingleton(sqlOptions);
+            builder.Services.AddScoped<IRoleAccessStore, RoleAccessStore>();
+
+            return builder;
+        }
+    }
+}

src/DynamicAuthorization.Mvc.MsSqlServerStore/SqlTableCreator.cs

@@ -1,19 +1,30 @@
 using DynamicAuthorization.Mvc.Core.Models;
+using Microsoft.Data.SqlClient;
+using Microsoft.Extensions.Logging;
 using System;
 using System.Text;
 
 namespace DynamicAuthorization.Mvc.MsSqlServerStore
 {
     internal class SqlTableCreator
     {
+        private readonly SqlOptions _options;
+        private readonly ILogger<SqlTableCreator> _logger;
+
+        public SqlTableCreator(SqlOptions options, ILogger<SqlTableCreator> logger)
+        {
+            _options = options;
+            _logger = logger;
+        }
+
         public void CreateTable()
         {
             try
             {
-                using (var conn = _sqlConnectionFactory.Create())
+                using (var conn = new SqlConnection(_options.ConnectionString))
                 {
                     var sql = GetTableDdl();
-                    using (var cmd = conn.CreateCommand(sql))
+                    using (var cmd = new SqlCommand(sql, conn))
                     {
                         conn.Open();
                         cmd.ExecuteNonQuery();
@@ -22,7 +33,7 @@ public void CreateTable()
             }
             catch (Exception ex)
             {
-                Console.WriteLine($"Exception creating table AccessRole:\n{ex}");
+                _logger.LogError(ex, "An error has occurred while creating RoleAccess table");
             }
         }
 
@@ -37,8 +48,8 @@ private string GetTableDdl()
             sql.AppendLine("[Access] nvarchar(max) COLLATE SQL_Latin1_General_CP1_CI_AS  NULL );");
             sql.AppendLine("ALTER TABLE [dbo].[RoleAccess] SET (LOCK_ESCALATION = TABLE);");
             sql.AppendLine("DBCC CHECKIDENT ('[dbo].[RoleAccess]', RESEED, 1);");
-            sql.AppendLine("CREATE NONCLUSTERED INDEX [IX_AspNetRoleClaims_RoleId] ");
-            sql.AppendLine("ON [dbo].[AspNetRoleClaims] ([RoleId] ASC);");
+            sql.AppendLine("CREATE NONCLUSTERED INDEX [IX_RoleAccess_RoleId] ");
+            sql.AppendLine("ON [dbo].[RoleAccess] ([RoleId] ASC);");
             sql.AppendLine("ALTER TABLE [dbo].[RoleAccess] ADD CONSTRAINT [PK_RoleAccess] PRIMARY KEY CLUSTERED ([Id]) ");
             sql.AppendLine("WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ");
             sql.AppendLine("ON [PRIMARY];");