lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-11-10 19:35:09 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update Async

Browse Source
This commit is contained in:
sunkaixuan
2019-05-09 12:56:26 +08:00
parent 87a0c5c8f3
commit 0e8606e34b
7 changed files with 33 additions and 54 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
Console.WriteLine("Example 3");
//var result2 = db.UseTranAsync(() =>
//{
var result2 = db.UseTranAsync(() =>
{
// db.ChangeDatabase(it => it.DbType == DbType.SqlServer);//use sqlserver
// db.Deleteable<Order>().ExecuteCommand();
// Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
// Console.WriteLine(db.Queryable<Order>().Count());
db.ChangeDatabase(it => it.DbType == DbType.SqlServer);//use sqlserver
db.Deleteable<Order>().ExecuteCommand();
Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
Console.WriteLine(db.Queryable<Order>().Count());
// db.ChangeDatabase(it => it.DbType == DbType.MySql);//use mysql
// db.Deleteable<Order>().ExecuteCommand();
// Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
// Console.WriteLine(db.Queryable<Order>().Count());
// throw new Exception("");
db.ChangeDatabase(it => it.DbType == DbType.MySql);//use mysql
db.Deleteable<Order>().ExecuteCommand();
Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
Console.WriteLine(db.Queryable<Order>().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<Order>().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<Order>().Count());
// db.ChangeDatabase(it => it.DbType == DbType.MySql);//use mysql
// Console.WriteLine(db.CurrentConnectionConfig.DbType);
// Console.WriteLine(db.Queryable<Order>().Count());
//}
db.ChangeDatabase(it => it.DbType == DbType.MySql);//use mysql
Console.WriteLine(db.CurrentConnectionConfig.DbType);
Console.WriteLine(db.Queryable<Order>().Count());
}
//Console.WriteLine("#### Distributed TransactionExample End ####");
Console.WriteLine("#### Distributed TransactionExample End ####");
}
}