- 修复 读写分离创建 IFreeSql 时如果从库不可用导致 iis 退出的 bug；

Examples/dbcontext_01/Controllers/ValuesController.cs

@@ -235,9 +235,9 @@ namespace dbcontext_01.Controllers
 
         // GET api/values/5
         [HttpGet("{id}")]
-        public ActionResult<string> Get(int id)
+        public ActionResult<object> Get(int id)
         {
-            return "value";
+            return _orm.Select<Song>().Where(a => a.Id == id).First();
         }
 
         // POST api/values

Examples/dbcontext_01/Startup.cs

@@ -20,6 +20,9 @@ namespace dbcontext_01
                 .UseConnectionString(FreeSql.DataType.Sqlite, @"Data Source=|DataDirectory|\document2.db;Pooling=true;Max Pool Size=10")
                 //.UseConnectionString(FreeSql.DataType.SqlServer, "Data Source=.;Integrated Security=True;Initial Catalog=freesqlTest;Pooling=true;Max Pool Size=10")
 
+                //.UseConnectionString(DataType.MySql, "Data Source=192.168.164.10;Port=33061;User ID=root;Password=123456;Initial Catalog=cccddd;Charset=utf8;SslMode=none;Max pool size=5")
+                //.UseSlave("Data Source=192.168.164.10;Port=33062;User ID=root;Password=123456;Initial Catalog=cccddd;Charset=utf8;SslMode=none;Max pool size=5")
+
                 //.UseConnectionString(FreeSql.DataType.Oracle, "user id=user1;password=123456;data source=//127.0.0.1:1521/XE;Pooling=true;Max Pool Size=10")
                 //.UseSyncStructureToUpper(true)
 

Examples/dbcontext_01/dbcontext_01.csproj

@@ -12,6 +12,7 @@
   <ItemGroup>
     <ProjectReference Include="..\..\Extensions\FreeSql.Extensions.LazyLoading\FreeSql.Extensions.LazyLoading.csproj" />
     <ProjectReference Include="..\..\FreeSql.DbContext\FreeSql.DbContext.csproj" />
+    <ProjectReference Include="..\..\Providers\FreeSql.Provider.MySql\FreeSql.Provider.MySql.csproj" />
     <ProjectReference Include="..\..\Providers\FreeSql.Provider.Sqlite\FreeSql.Provider.Sqlite.csproj" />
   </ItemGroup>
 

Providers/FreeSql.Provider.MsAccess/MsAccessAdo/MsAccessConnectionPool.cs

@@ -19,6 +19,8 @@ namespace FreeSql.MsAccess
 
         public MsAccessConnectionPool(string name, string connectionString, Action availableHandler, Action unavailableHandler) : base(null)
         {
+            this.availableHandler = availableHandler;
+            this.unavailableHandler = unavailableHandler;
             var policy = new AccessConnectionPoolPolicy
             {
                 _pool = this,
@@ -26,9 +28,6 @@ namespace FreeSql.MsAccess
             };
             this.Policy = policy;
             policy.ConnectionString = connectionString;
-
-            this.availableHandler = availableHandler;
-            this.unavailableHandler = unavailableHandler;
         }
 
         public void Return(Object<DbConnection> obj, Exception exception, bool isRecreate = false)

Providers/FreeSql.Provider.MySql/MySqlAdo/MySqlConnectionPool.cs

@@ -19,6 +19,8 @@ namespace FreeSql.MySql
 
         public MySqlConnectionPool(string name, string connectionString, Action availableHandler, Action unavailableHandler) : base(null)
         {
+            this.availableHandler = availableHandler;
+            this.unavailableHandler = unavailableHandler;
             var policy = new MySqlConnectionPoolPolicy
             {
                 _pool = this,
@@ -26,9 +28,6 @@ namespace FreeSql.MySql
             };
             this.Policy = policy;
             policy.ConnectionString = connectionString;
-
-            this.availableHandler = availableHandler;
-            this.unavailableHandler = unavailableHandler;
         }
 
         public void Return(Object<DbConnection> obj, Exception exception, bool isRecreate = false)

Providers/FreeSql.Provider.Odbc/Dameng/OdbcDamengAdo/OdbcDamengConnectionPool.cs

@@ -23,6 +23,8 @@ namespace FreeSql.Odbc.Dameng
         {
             this.UserId = OdbcDamengConnectionPool.GetUserId(connectionString);
 
+            this.availableHandler = availableHandler;
+            this.unavailableHandler = unavailableHandler;
             var policy = new OdbcOracleConnectionPoolPolicy
             {
                 _pool = this,
@@ -30,9 +32,6 @@ namespace FreeSql.Odbc.Dameng
             };
             this.Policy = policy;
             policy.ConnectionString = connectionString;
-
-            this.availableHandler = availableHandler;
-            this.unavailableHandler = unavailableHandler;
         }
 
         public static string GetUserId(string connectionString)

Providers/FreeSql.Provider.Odbc/Default/OdbcAdo/OdbcConnectionPool.cs

@@ -19,6 +19,8 @@ namespace FreeSql.Odbc.Default
 
         public OdbcConnectionPool(string name, string connectionString, Action availableHandler, Action unavailableHandler) : base(null)
         {
+            this.availableHandler = availableHandler;
+            this.unavailableHandler = unavailableHandler;
             var policy = new OdbcConnectionPoolPolicy
             {
                 _pool = this,
@@ -26,9 +28,6 @@ namespace FreeSql.Odbc.Default
             };
             this.Policy = policy;
             policy.ConnectionString = connectionString;
-
-            this.availableHandler = availableHandler;
-            this.unavailableHandler = unavailableHandler;
         }
 
         public void Return(Object<DbConnection> obj, Exception exception, bool isRecreate = false)

Providers/FreeSql.Provider.Odbc/GBase/OdbcGBaseAdo/OdbcGBaseConnectionPool.cs

@@ -22,6 +22,8 @@ namespace FreeSql.Odbc.GBase
 
         public OdbcGBaseConnectionPool(string name, string connectionString, Action availableHandler, Action unavailableHandler) : base(null)
         {
+            this.availableHandler = availableHandler;
+            this.unavailableHandler = unavailableHandler;
             var policy = new OdbcPostgreSQLConnectionPoolPolicy
             {
                 _pool = this,
@@ -29,9 +31,6 @@ namespace FreeSql.Odbc.GBase
             };
             this.Policy = policy;
             policy.ConnectionString = connectionString;
-
-            this.availableHandler = availableHandler;
-            this.unavailableHandler = unavailableHandler;
         }
 
         public void Return(Object<DbConnection> obj, Exception exception, bool isRecreate = false)

Providers/FreeSql.Provider.Odbc/MySql/OdbcMySqlAdo/OdbcMySqlConnectionPool.cs

@@ -19,6 +19,8 @@ namespace FreeSql.Odbc.MySql
 
         public OdbcMySqlConnectionPool(string name, string connectionString, Action availableHandler, Action unavailableHandler) : base(null)
         {
+            this.availableHandler = availableHandler;
+            this.unavailableHandler = unavailableHandler;
             var policy = new OdbcMySqlConnectionPoolPolicy
             {
                 _pool = this,
@@ -26,9 +28,6 @@ namespace FreeSql.Odbc.MySql
             };
             this.Policy = policy;
             policy.ConnectionString = connectionString;
-
-            this.availableHandler = availableHandler;
-            this.unavailableHandler = unavailableHandler;
         }
 
         public void Return(Object<DbConnection> obj, Exception exception, bool isRecreate = false)

Providers/FreeSql.Provider.Odbc/Oracle/OdbcOracleAdo/OdbcOracleConnectionPool.cs

@@ -23,6 +23,8 @@ namespace FreeSql.Odbc.Oracle
         {
             this.UserId = OdbcOracleConnectionPool.GetUserId(connectionString);
 
+            this.availableHandler = availableHandler;
+            this.unavailableHandler = unavailableHandler;
             var policy = new OdbcOracleConnectionPoolPolicy
             {
                 _pool = this,
@@ -30,9 +32,6 @@ namespace FreeSql.Odbc.Oracle
             };
             this.Policy = policy;
             policy.ConnectionString = connectionString;
-
-            this.availableHandler = availableHandler;
-            this.unavailableHandler = unavailableHandler;
         }
 
         public static string GetUserId(string connectionString)

Providers/FreeSql.Provider.Odbc/PostgreSQL/OdbcPostgreSQLAdo/OdbcPostgreSQLConnectionPool.cs

@@ -20,6 +20,8 @@ namespace FreeSql.Odbc.PostgreSQL
 
         public OdbcPostgreSQLConnectionPool(string name, string connectionString, Action availableHandler, Action unavailableHandler) : base(null)
         {
+            this.availableHandler = availableHandler;
+            this.unavailableHandler = unavailableHandler;
             var policy = new OdbcPostgreSQLConnectionPoolPolicy
             {
                 _pool = this,
@@ -27,9 +29,6 @@ namespace FreeSql.Odbc.PostgreSQL
             };
             this.Policy = policy;
             policy.ConnectionString = connectionString;
-
-            this.availableHandler = availableHandler;
-            this.unavailableHandler = unavailableHandler;
         }
 
         public void Return(Object<DbConnection> obj, Exception exception, bool isRecreate = false)

Providers/FreeSql.Provider.Odbc/SqlServer/OdbcSqlServerAdo/OdbcSqlServerConnectionPool.cs

@@ -19,6 +19,8 @@ namespace FreeSql.Odbc.SqlServer
 
         public OdbcSqlServerConnectionPool(string name, string connectionString, Action availableHandler, Action unavailableHandler) : base(null)
         {
+            this.availableHandler = availableHandler;
+            this.unavailableHandler = unavailableHandler;
             var policy = new OdbcSqlServerConnectionPoolPolicy
             {
                 _pool = this,
@@ -26,9 +28,6 @@ namespace FreeSql.Odbc.SqlServer
             };
             this.Policy = policy;
             policy.ConnectionString = connectionString;
-
-            this.availableHandler = availableHandler;
-            this.unavailableHandler = unavailableHandler;
         }
 
         public void Return(Object<DbConnection> obj, Exception exception, bool isRecreate = false)

Providers/FreeSql.Provider.Oracle/OracleAdo/OracleConnectionPool.cs

@@ -21,6 +21,8 @@ namespace FreeSql.Oracle
 
         public OracleConnectionPool(string name, string connectionString, Action availableHandler, Action unavailableHandler) : base(null)
         {
+            this.availableHandler = availableHandler;
+            this.unavailableHandler = unavailableHandler;
             this.UserId = OracleConnectionPool.GetUserId(connectionString);
 
             var policy = new OracleConnectionPoolPolicy
@@ -30,9 +32,6 @@ namespace FreeSql.Oracle
             };
             this.Policy = policy;
             policy.ConnectionString = connectionString;
-
-            this.availableHandler = availableHandler;
-            this.unavailableHandler = unavailableHandler;
         }
 
         public static string GetUserId(string connectionString)

Providers/FreeSql.Provider.PostgreSQL/PostgreSQLAdo/PostgreSQLConnectionPool.cs

@@ -20,6 +20,8 @@ namespace FreeSql.PostgreSQL
 
         public PostgreSQLConnectionPool(string name, string connectionString, Action availableHandler, Action unavailableHandler) : base(null)
         {
+            this.availableHandler = availableHandler;
+            this.unavailableHandler = unavailableHandler;
             var policy = new PostgreSQLConnectionPoolPolicy
             {
                 _pool = this,
@@ -27,9 +29,6 @@ namespace FreeSql.PostgreSQL
             };
             this.Policy = policy;
             policy.ConnectionString = connectionString;
-
-            this.availableHandler = availableHandler;
-            this.unavailableHandler = unavailableHandler;
         }
 
         public void Return(Object<DbConnection> obj, Exception exception, bool isRecreate = false)

Providers/FreeSql.Provider.SqlServer/SqlServerAdo/SqlServerConnectionPool.cs

@@ -19,6 +19,8 @@ namespace FreeSql.SqlServer
 
         public SqlServerConnectionPool(string name, string connectionString, Action availableHandler, Action unavailableHandler) : base(null)
         {
+            this.availableHandler = availableHandler;
+            this.unavailableHandler = unavailableHandler;
             var policy = new SqlServerConnectionPoolPolicy
             {
                 _pool = this,
@@ -26,9 +28,6 @@ namespace FreeSql.SqlServer
             };
             this.Policy = policy;
             policy.ConnectionString = connectionString;
-
-            this.availableHandler = availableHandler;
-            this.unavailableHandler = unavailableHandler;
         }
 
         public void Return(Object<DbConnection> obj, Exception exception, bool isRecreate = false)

Providers/FreeSql.Provider.Sqlite/SqliteAdo/SqliteConnectionPool.cs

@@ -21,6 +21,8 @@ namespace FreeSql.Sqlite
 
         public SqliteConnectionPool(string name, string connectionString, Action availableHandler, Action unavailableHandler) : base(null)
         {
+            this.availableHandler = availableHandler;
+            this.unavailableHandler = unavailableHandler;
             policy = new SqliteConnectionPoolPolicy
             {
                 _pool = this,
@@ -28,9 +30,6 @@ namespace FreeSql.Sqlite
             };
             this.Policy = policy;
             policy.ConnectionString = connectionString;
-
-            this.availableHandler = availableHandler;
-            this.unavailableHandler = unavailableHandler;
         }
 
         public void Return(Object<DbConnection> obj, Exception exception, bool isRecreate = false)