From 888ba0ed5a6ac2da6a56a40766572103c9dda15e Mon Sep 17 00:00:00 2001 From: xuejiaming <326308290@qq.com> Date: Thu, 16 Dec 2021 14:25:09 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=8A=A8=E6=80=81=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E6=BA=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Controllers/TestController.cs | 11 +++++++++++ .../DefaultDataSourceInitializer.cs | 2 +- .../DynamicDataSources/IDataSourceInitializer`1.cs | 1 + 3 files changed, 13 insertions(+), 1 deletion(-) diff --git a/samples/Sample.SqlServerShardingAll/Controllers/TestController.cs b/samples/Sample.SqlServerShardingAll/Controllers/TestController.cs index e211baa8..62c31ba3 100644 --- a/samples/Sample.SqlServerShardingAll/Controllers/TestController.cs +++ b/samples/Sample.SqlServerShardingAll/Controllers/TestController.cs @@ -4,6 +4,9 @@ using System.Threading.Tasks; using Microsoft.AspNetCore.Mvc; using Microsoft.EntityFrameworkCore; using Sample.SqlServerShardingAll.Entities; +using ShardingCore; +using ShardingCore.Core.VirtualDatabase.VirtualDataSources; +using ShardingCore.DynamicDataSources; namespace Sample.SqlServerShardingAll.Controllers { @@ -19,6 +22,14 @@ namespace Sample.SqlServerShardingAll.Controllers } public async Task Query() { + #region 动态数据源 + //var virtualDataSource = ShardingContainer.GetService>(); + + //var virtualDataSourceRoute = virtualDataSource.GetRoute(typeof(Order)); + //virtualDataSourceRoute.AddDataSourceName("D"); + //DynamicDataSourceHelper.DynamicAppendDataSource("D", "连接字符串"); + #endregion + var sysUser =await _myDbContext.Set().Where(o=>o.Id=="1").FirstOrDefaultAsync(); var sysUserA1 =await _myDbContext.Set().Where(o=>o.Id=="1" && o.Area == "A").FirstOrDefaultAsync(); var dateTime = new DateTime(2021,3,5); diff --git a/src/ShardingCore/DynamicDataSources/DefaultDataSourceInitializer.cs b/src/ShardingCore/DynamicDataSources/DefaultDataSourceInitializer.cs index d1215a75..0075691e 100644 --- a/src/ShardingCore/DynamicDataSources/DefaultDataSourceInitializer.cs +++ b/src/ShardingCore/DynamicDataSources/DefaultDataSourceInitializer.cs @@ -54,7 +54,7 @@ namespace ShardingCore.DynamicDataSources } public void InitConfigure(string dataSourceName, string connectionString) { - InitConfigure(dataSourceName,connectionString, _shardingConfigOption.EnsureCreatedWithOutShardingTable); + InitConfigure(dataSourceName,connectionString, true); } public void InitConfigure(string dataSourceName, string connectionString, bool createDatabase) diff --git a/src/ShardingCore/DynamicDataSources/IDataSourceInitializer`1.cs b/src/ShardingCore/DynamicDataSources/IDataSourceInitializer`1.cs index 78b9f332..71be2bb1 100644 --- a/src/ShardingCore/DynamicDataSources/IDataSourceInitializer`1.cs +++ b/src/ShardingCore/DynamicDataSources/IDataSourceInitializer`1.cs @@ -10,6 +10,7 @@ namespace ShardingCore.DynamicDataSources { public interface IDataSourceInitializer where TShardingDbContext : DbContext, IShardingDbContext { + [Obsolete("plz use method InitConfigure(string dataSourceName, string connectionString,bool createDatabase)")] void InitConfigure(string dataSourceName, string connectionString); void InitConfigure(string dataSourceName, string connectionString,bool createDatabase); }