From 9270e5e35b2a240a20fb64fe5848ceca9f95ce38 Mon Sep 17 00:00:00 2001 From: quinhe Date: Tue, 9 Jun 2015 23:55:27 +0800 Subject: [PATCH 1/2] =?UTF-8?q?=E4=BA=8B=E5=8A=A1=20=E8=AF=BB=E4=B8=BB?= =?UTF-8?q?=E5=BA=93?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../MasterSlaves/DbMasterSlaveCommandInterceptor.cs | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/01.Infrastructure/NDF.Data.Entity/MasterSlaves/DbMasterSlaveCommandInterceptor.cs b/01.Infrastructure/NDF.Data.Entity/MasterSlaves/DbMasterSlaveCommandInterceptor.cs index 2dd26e9..4ac132b 100644 --- a/01.Infrastructure/NDF.Data.Entity/MasterSlaves/DbMasterSlaveCommandInterceptor.cs +++ b/01.Infrastructure/NDF.Data.Entity/MasterSlaves/DbMasterSlaveCommandInterceptor.cs @@ -135,13 +135,20 @@ where this.ValidateContextCanApplyTo(context) /// protected virtual void UpdateToSlaveIfNeed(DbCommand command, DbInterceptionContext interceptionContext) { + // 判断当前会话是否处于分布式事务中 + bool isDistributedTran = Transaction.Current != null && Transaction.Current.TransactionInformation.Status != TransactionStatus.Committed; + var contexts = from context in interceptionContext.DbContexts where this.ValidateContextCanApplyTo(context) select context; foreach (var context in contexts) { - string connectionString = this.GetSlaveConnectionString(context); + // 判断该 context 是否处于普通数据库事务中 + bool isDbTran = context.Database.CurrentTransaction != null; + // 如果处于分布式事务或普通事务中，则“禁用”读写分离，处于事务中的所有读写操作都指向 Master + string connectionString = isDistributedTran || isDbTran ? this.MasterConnectionString : this.GetSlaveConnectionString(context); + this.UpdateConnectionStringIfNeed(command, context.Database.Connection, connectionString); this.StartServersStateScanIfNeed(context); } From 5213aebccad552d6cdb24bbc39236b8ecb0b62ab Mon Sep 17 00:00:00 2001 From: quinhe Date: Wed, 10 Jun 2015 00:01:52 +0800 Subject: [PATCH 2/2] =?UTF-8?q?1.=E4=BA=8B=E5=8A=A1=E8=BD=AC=E4=B8=BB?= =?UTF-8?q?=E5=BA=93=202.=E6=94=AF=E6=8C=81=E5=A4=9A=E4=B8=AA=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E5=BA=93=E6=97=B6=E9=83=A8=E5=88=86=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E5=BA=93=E8=AF=BB=E5=86=99=E5=88=86=E7=A6=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../DbMasterSlaveConnectionInterceptor.cs | 23 ++++++++++++++++++- 1 file changed, 22 insertions(+), 1 deletion(-) diff --git a/01.Infrastructure/NDF.Data.Entity/MasterSlaves/DbMasterSlaveConnectionInterceptor.cs b/01.Infrastructure/NDF.Data.Entity/MasterSlaves/DbMasterSlaveConnectionInterceptor.cs index b65fbc1..f89a91a 100644 --- a/01.Infrastructure/NDF.Data.Entity/MasterSlaves/DbMasterSlaveConnectionInterceptor.cs +++ b/01.Infrastructure/NDF.Data.Entity/MasterSlaves/DbMasterSlaveConnectionInterceptor.cs @@ -35,6 +35,16 @@ internal DbMasterSlaveConfigContext Config } + /// + /// 在开启一个数据库事务动作执行前瞬间触发。 + /// + /// + /// + public override void BeginningTransaction(DbConnection connection, BeginTransactionInterceptionContext interceptionContext) + { + UpdateToMasterIfNeed(connection, interceptionContext, this.Config); + } + /// /// 在打开数据库连接动作执行前瞬间触发。将数据库连接字符串更新至 EF 数据库主从读写分离服务中配置的相关值。 /// @@ -42,8 +52,19 @@ internal DbMasterSlaveConfigContext Config /// public override void Opening(DbConnection connection, DbConnectionInterceptionContext interceptionContext) { - string connectionString = this.Config.UsableMasterConnectionString; + UpdateToMasterIfNeed(connection, interceptionContext, this.Config); + } + internal static void UpdateToMasterIfNeed(DbConnection connection, + DbInterceptionContext interceptionContexts, DbMasterSlaveConfigContext config) + { + //判断是否是该过滤器的数据库 + if (!interceptionContexts.DbContexts.Any(config.CanApplyTo)) + { + return; + } + //比较连接字符串 + string connectionString = config.UsableMasterConnectionString; if (!DbMasterSlaveCommandInterceptor.ConnectionStringEquals(connection, connectionString)) { DbMasterSlaveCommandInterceptor.UpdateConnectionString(connection, connectionString);