添加提供程序的链接管理

Author: lianggx

src/MyStaging.MySql/MySqlStagingConnection.cs

@@ -0,0 +1,32 @@
+using MySql.Data.MySqlClient;
+using MyStaging.Core;
+using MyStaging.Interface;
+using System.Data.Common;
+
+namespace MyStaging.MySql
+{
+    public partial class MySqlStagingConnection : IStagingConnection
+    {
+        public DbConnection GetConnection(string name, bool readOnly)
+        {
+            var model = ConnectionManager.Get(name, readOnly);
+            var conn = new MySqlConnection(model.ConnectionString);
+
+            return conn;
+        }
+
+        public void Refresh(string name, string master, params string[] slaves)
+        {
+            MySqlConnection.ClearAllPools();
+            ConnectionManager.Remove(name);
+            ConnectionManager.Add(name, master, false);
+            if (slaves?.Length > 0)
+            {
+                foreach (var conn in slaves)
+                {
+                    ConnectionManager.Add(name, conn, true);
+                }
+            }
+        }
+    }
+}

src/MyStaging.MySql/MyStaging.MySql.csproj

@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <TargetFramework>netstandard2.1</TargetFramework>
-    <Version>3.0.3</Version>
+    <Version>3.0.4</Version>
     <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
     <PackageRequireLicenseAcceptance>false</PackageRequireLicenseAcceptance>
   </PropertyGroup>

src/MyStaging.PostgreSQL/MyStaging.PostgreSQL.csproj

@@ -3,7 +3,7 @@
   <PropertyGroup>
     <TargetFramework>netstandard2.1</TargetFramework>
     <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
-    <Version>3.0.3</Version>
+    <Version>3.0.4</Version>
   </PropertyGroup>
 
   <ItemGroup>

src/MyStaging.PostgreSQL/PgStagingConnection.cs

@@ -0,0 +1,38 @@
+using MyStaging.Common;
+using MyStaging.Core;
+using MyStaging.Interface;
+using Npgsql;
+using System;
+using System.Collections.Concurrent;
+using System.Collections.Generic;
+using System.Data.Common;
+using System.Diagnostics;
+using System.Linq;
+
+namespace MyStaging.PostgreSQL
+{
+    public partial class PgStagingConnection : IStagingConnection
+    {
+        public DbConnection GetConnection(string name, bool readOnly)
+        {
+            var model = ConnectionManager.Get(name, readOnly);
+            var conn = new NpgsqlConnection(model.ConnectionString);
+
+            return conn;
+        }
+
+        public void Refresh(string name, string master, params string[] slaves)
+        {
+            NpgsqlConnection.ClearAllPools();
+            ConnectionManager.Remove(name);
+            ConnectionManager.Add(name, master, false);
+            if (slaves?.Length > 0)
+            {
+                foreach (var conn in slaves)
+                {
+                    ConnectionManager.Add(name, conn, true);
+                }
+            }
+        }
+    }
+}