From c17f88f5c762ed6cbc9d733de1bd5827a61797b5 Mon Sep 17 00:00:00 2001 From: sunkaixuan <610262374@qq.com> Date: Wed, 8 May 2019 21:35:34 +0800 Subject: [PATCH] - --- .../Demo/Demo0_SqlSugarClient.cs | 48 +++++++++---------- .../Infrastructure/SqlSugarEngine_Part2.cs | 13 ----- 2 files changed, 24 insertions(+), 37 deletions(-) diff --git a/Src/Asp.Net/SqlServerTest/Demo/Demo0_SqlSugarClient.cs b/Src/Asp.Net/SqlServerTest/Demo/Demo0_SqlSugarClient.cs index a63e7abc8..c0aec6c76 100644 --- a/Src/Asp.Net/SqlServerTest/Demo/Demo0_SqlSugarClient.cs +++ b/Src/Asp.Net/SqlServerTest/Demo/Demo0_SqlSugarClient.cs @@ -278,35 +278,35 @@ namespace OrmTest // Example 3 Console.WriteLine("Example 3"); - var result2 = db.UseTranAsync(() => - { + //var result2 = db.UseTranAsync(() => + //{ - db.ChangeDatabase(it => it.DbType == DbType.SqlServer);//use sqlserver - db.Deleteable().ExecuteCommand(); - Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType); - Console.WriteLine(db.Queryable().Count()); + // db.ChangeDatabase(it => it.DbType == DbType.SqlServer);//use sqlserver + // db.Deleteable().ExecuteCommand(); + // Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType); + // Console.WriteLine(db.Queryable().Count()); - db.ChangeDatabase(it => it.DbType == DbType.MySql);//use mysql - db.Deleteable().ExecuteCommand(); - Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType); - Console.WriteLine(db.Queryable().Count()); - throw new Exception(""); + // db.ChangeDatabase(it => it.DbType == DbType.MySql);//use mysql + // db.Deleteable().ExecuteCommand(); + // Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType); + // Console.WriteLine(db.Queryable().Count()); + // throw new Exception(""); - }); - result2.Wait(); - if (result.IsSuccess == false) - { - Console.WriteLine("---Roll back"); - db.ChangeDatabase(it => it.DbType == DbType.SqlServer);//use sqlserver - Console.WriteLine(db.CurrentConnectionConfig.DbType); - Console.WriteLine(db.Queryable().Count()); + //}); + //result2.Wait(); + //if (result.IsSuccess == false) + //{ + // Console.WriteLine("---Roll back"); + // db.ChangeDatabase(it => it.DbType == DbType.SqlServer);//use sqlserver + // Console.WriteLine(db.CurrentConnectionConfig.DbType); + // Console.WriteLine(db.Queryable().Count()); - db.ChangeDatabase(it => it.DbType == DbType.MySql);//use mysql - Console.WriteLine(db.CurrentConnectionConfig.DbType); - Console.WriteLine(db.Queryable().Count()); - } + // db.ChangeDatabase(it => it.DbType == DbType.MySql);//use mysql + // Console.WriteLine(db.CurrentConnectionConfig.DbType); + // Console.WriteLine(db.Queryable().Count()); + //} - Console.WriteLine("#### Distributed TransactionExample End ####"); + //Console.WriteLine("#### Distributed TransactionExample End ####"); } } diff --git a/Src/Asp.Net/SqlSugar/Infrastructure/SqlSugarEngine_Part2.cs b/Src/Asp.Net/SqlSugar/Infrastructure/SqlSugarEngine_Part2.cs index 8a9380474..fc8dbdc2a 100644 --- a/Src/Asp.Net/SqlSugar/Infrastructure/SqlSugarEngine_Part2.cs +++ b/Src/Asp.Net/SqlSugar/Infrastructure/SqlSugarEngine_Part2.cs @@ -22,18 +22,6 @@ namespace SqlSugar _Context = value; } } - internal SqlSugarEngine ContextAsync - { - get - { - _ContextAsync = this; - return _ContextAsync; - } - set - { - _ContextAsync = value; - } - } public ConnectionConfig CurrentConnectionConfig { get; set; } public Dictionary TempItems { get { if (_TempItems == null) { _TempItems = new Dictionary(); } return _TempItems; } set=>_TempItems=value; } @@ -53,7 +41,6 @@ namespace SqlSugar public QueueList _Queues; protected ISqlBuilder _SqlBuilder; protected ISqlSugarClient _Context { get; set; } - protected SqlSugarEngine _ContextAsync { get; set; } protected EntityMaintenance _EntityProvider; protected IAdo _Ado; protected ILambdaExpressions _LambdaExpressions;