Added database synchronization

carvalholuigi25 · Feb 13, 2024 · 8c07883 · 8c07883
1 parent 00de84b
commit 8c07883
Show file tree

Hide file tree

Showing 6 changed files with 82 additions and 7 deletions.
diff --git a/Server/Controllers/Admin/AdminController.cs b/Server/Controllers/Admin/AdminController.cs
@@ -1,15 +1,16 @@
-using Microsoft.AspNetCore.Mvc;
+using Dotmim.Sync.Sqlite;
+using Dotmim.Sync.SqlServer;
+using Dotmim.Sync.PostgreSql;
+using Dotmim.Sync;
+using Dotmim.Sync.MySql;
 using LCPCollection.Shared.Classes;
+using Microsoft.AspNetCore.Mvc;
 using Microsoft.EntityFrameworkCore;
-using Microsoft.AspNetCore.Authorization;
 using Microsoft.Data.SqlClient;
-using NuGet.Protocol;
 using Microsoft.Data.Sqlite;
 using MySqlConnector;
+using NuGet.Protocol;
 using Npgsql;
-using System.Collections;
-using Newtonsoft.Json;
-using Microsoft.SqlServer.Server;
 using System.Diagnostics;
 
 namespace LCPCollection.Server.Controllers
@@ -59,6 +60,65 @@ public IActionResult DoQryRun([FromBody] QryRunner qryrun)
             }
         }
 
+        /// <summary>
+        /// This endpoint synchronizes the specific database to the another database
+        /// </summary>
+        [HttpPost("dbsync")]
+        public async Task<IActionResult> DoDBSync(DBSyncRunner dbsrunner)
+        {
+            Stopwatch stopWatch = new Stopwatch();
+
+            try
+            {
+                stopWatch.Start();
+
+                StringComparison cmp = StringComparison.InvariantCultureIgnoreCase;
+                SqlSyncProvider serverProvider = new SqlSyncProvider(_configuration[$"ConnectionStrings:SQLServer"]);
+                dynamic clientProvider;
+
+                if (dbsrunner.DBMode.Contains("SQLite", cmp))
+                {
+                    clientProvider = new SqliteSyncProvider(_configuration[$"ConnectionStrings:SQLite"]);
+                }
+                else if (dbsrunner.DBMode.Contains("MySQL", cmp))
+                {
+                    clientProvider = new MySqlSyncProvider(_configuration[$"ConnectionStrings:MySQL"]);
+                }
+                else if (dbsrunner.DBMode.Contains("PostgreSQL", cmp))
+                {
+                    clientProvider = new NpgsqlSyncProvider(_configuration[$"ConnectionStrings:PostgreSQL"]);
+                }
+                else
+                {
+                    clientProvider = new SqlSyncProvider(_configuration[$"ConnectionStrings:SQLServer"]);
+                }
+
+                var setup = new SyncSetup("Games", "Movies", "Books", "TVSeries", "Animes", "FilesData", "Softwares", "Websites");
+
+                SyncAgent agent = new SyncAgent(clientProvider, serverProvider);
+
+                var result = await agent.SynchronizeAsync(setup);
+                stopWatch.Stop();
+
+                return Ok(new
+                {
+                    Data = result,
+                    DatabaseMode = dbsrunner.DBMode,
+                    DateTimeExecuted = DateTime.UtcNow,
+                    DateMeasureMsg = string.Format("Elapsed time {0} ms", stopWatch.ElapsedMilliseconds)
+                });
+            } 
+            catch(Exception e)
+            {
+                return Ok(new { 
+                    Data = e.Message,
+                    DatabaseMode = dbsrunner.DBMode,
+                    DateTimeExecuted = DateTime.UtcNow,
+                    DateMeasureMsg = string.Format("Elapsed time {0} ms", stopWatch.ElapsedMilliseconds)
+                });
+            }
+        }
+
         private IActionResult FetchDataSQLServer(QryRunner qryrun, StringComparison cmp) {
             Stopwatch stopWatch = Stopwatch.StartNew();
             var res = new Dictionary<object, object?>();

diff --git a/Server/Databases/SQLite/lcpcollection.db-shm b/Server/Databases/SQLite/lcpcollection.db-shm
diff --git a/Server/Databases/SQLite/lcpcollection.db-wal b/Server/Databases/SQLite/lcpcollection.db-wal
diff --git a/Server/LCPCollection.Server.csproj b/Server/LCPCollection.Server.csproj
@@ -9,6 +9,13 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="Dotmim.Sync.Core" Version="0.9.8" />
+    <PackageReference Include="Dotmim.Sync.MariaDB" Version="0.9.8" />
+    <PackageReference Include="Dotmim.Sync.MySql" Version="0.9.8" />
+    <PackageReference Include="Dotmim.Sync.PostgreSql" Version="0.9.8" />
+    <PackageReference Include="Dotmim.Sync.Sqlite" Version="0.9.8" />
+    <PackageReference Include="Dotmim.Sync.SqlServer" Version="0.9.8" />
+    <PackageReference Include="Dotmim.Sync.SqlServer.ChangeTracking" Version="0.9.8" />
     <PackageReference Include="DynamicExpressions.NET" Version="1.1.0" />
     <PackageReference Include="Microsoft.AspNetCore.Components.WebAssembly.Server" Version="8.0.1" />
     <PackageReference Include="Microsoft.AspNetCore.Identity.UI" Version="8.0.1" />

diff --git a/Server/appsettings.Development.json b/Server/appsettings.Development.json
@@ -6,7 +6,10 @@
     }
   },
   "Serilog": {
-    "Using": [ "Serilog.Sinks.Console", "Serilog.Sinks.File" ],
+    "Using": [
+      "Serilog.Sinks.Console",
+      "Serilog.Sinks.File"
+    ],
     "MinimumLevel": {
       "Default": "Information"
     },

diff --git a/Shared/Classes/QryRunner.cs b/Shared/Classes/QryRunner.cs
@@ -6,6 +6,11 @@ public class QryRunner {
     [Required] public string QryStr { get; set; } = null!;
 }
 
+public class DBSyncRunner
+{
+    [Required] public string DBMode { get; set; } = QryDBModeEnum.SQLServer.ToString();
+}
+
 public enum QryDBModeEnum
 {
     SQLServer,