lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-09-22 20:13:41 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

-

Browse Source
This commit is contained in:
sunkaixuan
2019-05-08 21:35:34 +08:00
parent e6a88d849b
commit c17f88f5c7
2 changed files with 24 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
Src/Asp.Net/SqlServerTest/Demo/Demo0_SqlSugarClient.cs
View File

@@ -278,35 +278,35 @@ namespace OrmTest
// Example 3 // Example 3
Console.WriteLine("Example 3"); Console.WriteLine("Example 3");
var result2 = db.UseTranAsync(() => //var result2 = db.UseTranAsync(() =>
{ //{
db.ChangeDatabase(it => it.DbType == DbType.SqlServer);//use sqlserver // db.ChangeDatabase(it => it.DbType == DbType.SqlServer);//use sqlserver
db.Deleteable<Order>().ExecuteCommand(); // db.Deleteable<Order>().ExecuteCommand();
Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType); // Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
Console.WriteLine(db.Queryable<Order>().Count()); // Console.WriteLine(db.Queryable<Order>().Count());
db.ChangeDatabase(it => it.DbType == DbType.MySql);//use mysql // db.ChangeDatabase(it => it.DbType == DbType.MySql);//use mysql
db.Deleteable<Order>().ExecuteCommand(); // db.Deleteable<Order>().ExecuteCommand();
Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType); // Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
Console.WriteLine(db.Queryable<Order>().Count()); // Console.WriteLine(db.Queryable<Order>().Count());
throw new Exception(""); // throw new Exception("");
}); //});
result2.Wait(); //result2.Wait();
if (result.IsSuccess == false) //if (result.IsSuccess == false)
{ //{
Console.WriteLine("---Roll back"); // Console.WriteLine("---Roll back");
db.ChangeDatabase(it => it.DbType == DbType.SqlServer);//use sqlserver // db.ChangeDatabase(it => it.DbType == DbType.SqlServer);//use sqlserver
Console.WriteLine(db.CurrentConnectionConfig.DbType); // Console.WriteLine(db.CurrentConnectionConfig.DbType);
Console.WriteLine(db.Queryable<Order>().Count()); // Console.WriteLine(db.Queryable<Order>().Count());
db.ChangeDatabase(it => it.DbType == DbType.MySql);//use mysql // db.ChangeDatabase(it => it.DbType == DbType.MySql);//use mysql
Console.WriteLine(db.CurrentConnectionConfig.DbType); // Console.WriteLine(db.CurrentConnectionConfig.DbType);
Console.WriteLine(db.Queryable<Order>().Count()); // Console.WriteLine(db.Queryable<Order>().Count());
} //}
Console.WriteLine("#### Distributed TransactionExample End ####"); //Console.WriteLine("#### Distributed TransactionExample End ####");
} }
} }

13
Src/Asp.Net/SqlSugar/Infrastructure/SqlSugarEngine_Part2.cs
View File

@@ -22,18 +22,6 @@ namespace SqlSugar
_Context = value; _Context = value;
} }
} }
internal SqlSugarEngine ContextAsync
{
get
{
_ContextAsync = this;
return _ContextAsync;
}
set
{
_ContextAsync = value;
}
}
public ConnectionConfig CurrentConnectionConfig { get; set; } public ConnectionConfig CurrentConnectionConfig { get; set; }
public Dictionary<string, object> TempItems { get { if (_TempItems == null) { _TempItems = new Dictionary<string, object>(); } return _TempItems; } set=>_TempItems=value; } public Dictionary<string, object> TempItems { get { if (_TempItems == null) { _TempItems = new Dictionary<string, object>(); } return _TempItems; } set=>_TempItems=value; }
@@ -53,7 +41,6 @@ namespace SqlSugar
public QueueList _Queues; public QueueList _Queues;
protected ISqlBuilder _SqlBuilder; protected ISqlBuilder _SqlBuilder;
protected ISqlSugarClient _Context { get; set; } protected ISqlSugarClient _Context { get; set; }
protected SqlSugarEngine _ContextAsync { get; set; }
protected EntityMaintenance _EntityProvider; protected EntityMaintenance _EntityProvider;
protected IAdo _Ado; protected IAdo _Ado;
protected ILambdaExpressions _LambdaExpressions; protected ILambdaExpressions _LambdaExpressions;