Implement sql server data provider.

Author: mo-esmp

src/Serilog.Ui.Core/Models/LogModel.cs

@@ -4,6 +4,8 @@ namespace Serilog.Ui.Core
 {
     public class LogModel
     {
+        public int Id { get; set; }
+
         public string Level { get; set; }
 
         public string Message { get; set; }

src/Serilog.Ui.Core/OptionsBuilder/RelationalDbOptions.cs

@@ -6,6 +6,6 @@ public class RelationalDbOptions
 
         public string TableName { get; set; }
 
-        public string Schema { get; set; }
+        public string Schema { get; set; } = "dbo";
     }
 }

src/Serilog.Ui.MsSqlServerProvider/Extensions/DataProviderOptionsBuilderExtensions.cs

@@ -27,6 +27,7 @@ public static void UseSqlServer(
             };
 
             ((IDataProviderOptionsBuilder)optionsBuilder).Services.AddSingleton(relationProvider);
+            ((IDataProviderOptionsBuilder)optionsBuilder).Services.AddScoped<IDataProvider, SqlServerDataProvider>();
         }
     }
 }

src/Serilog.Ui.MsSqlServerProvider/Serilog.Ui.MsSqlServerProvider.csproj

@@ -12,4 +12,9 @@
     <Folder Include="Extensions\" />
   </ItemGroup>
 
+  <ItemGroup>
+    <PackageReference Include="Dapper" Version="2.0.30" />
+    <PackageReference Include="System.Data.SqlClient" Version="4.8.1" />
+  </ItemGroup>
+
 </Project>

src/Serilog.Ui.MsSqlServerProvider/SqlServerDataProvider.cs

@@ -1,5 +1,8 @@
-using Serilog.Ui.Core;
+using Dapper;
+using Serilog.Ui.Core;
 using System.Collections.Generic;
+using System.Data;
+using System.Data.SqlClient;
 using System.Threading.Tasks;
 
 namespace Serilog.Ui.MsSqlServerProvider
@@ -13,9 +16,33 @@ public SqlServerDataProvider(RelationalDbOptions options)
             _options = options;
         }
 
-        public Task<(IEnumerable<LogModel>, int)> FetchDataAsync(int page, int count)
+        public async Task<(IEnumerable<LogModel>, int)> FetchDataAsync(int page, int count)
         {
-            throw new System.NotImplementedException();
+            using (IDbConnection connection = new SqlConnection(_options.ConnectionString))
+            {
+                var logsTask = GetLogsAsync(connection, page - 1, count);
+                var logCountTask = CountLogsAsync(connection);
+
+                await Task.WhenAll(logsTask, logCountTask);
+
+                return (await logsTask, await logCountTask);
+            }
+        }
+
+        private Task<IEnumerable<LogModel>> GetLogsAsync(IDbConnection connection, int page, int count)
+        {
+            var query =
+                $"SELECT [Id], [Message],[Level], [TimeStamp], [Exception], [Properties] FROM [{_options.Schema}].[{_options.TableName}] " +
+                "ORDER BY Id DESC OFFSET @Offset ROWS FETCH NEXT @Count ROWS ONLY";
+
+            return connection.QueryAsync<LogModel>(query, new { page, count });
+        }
+
+        public async Task<int> CountLogsAsync(IDbConnection connection)
+        {
+            var query = $"SELECT COUNT(Id) FROM [{_options.Schema}].[{_options.TableName}]";
+
+            return await connection.ExecuteScalarAsync<int>(query);
         }
     }
 }