Update demo

This commit is contained in:
sunkaixuna 2021-11-03 15:48:42 +08:00
parent eb6fb58c74
commit c4eea1b407
5 changed files with 20 additions and 25 deletions

View File

@ -308,23 +308,23 @@ namespace OrmTest
// Example 3 // Example 3
Console.WriteLine("Example 3"); Console.WriteLine("Example 3");
var result2 = db.UseTranAsync(() => var result2 = db.UseTranAsync(async () =>
{ {
db.ChangeDatabase("1");//use db1 db.ChangeDatabase("1");//use db1
db.Deleteable<Order>().ExecuteCommand(); await db.Deleteable<Order>().ExecuteCommandAsync();
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("2");//use db2 db.ChangeDatabase("2");//use db2
db.Deleteable<Order>().ExecuteCommand(); await db.Deleteable<Order>().ExecuteCommandAsync();
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 (result2.Result.IsSuccess == false)
{ {
Console.WriteLine("---Roll back"); Console.WriteLine("---Roll back");
db.ChangeDatabase("1");//use sqlserver db.ChangeDatabase("1");//use sqlserver
@ -336,7 +336,6 @@ namespace OrmTest
Console.WriteLine(db.Queryable<Order>().Count()); Console.WriteLine(db.Queryable<Order>().Count());
} }
Console.WriteLine("#### Distributed TransactionExample End ####");
} }
} }

View File

@ -308,23 +308,23 @@ namespace OrmTest
// Example 3 // Example 3
Console.WriteLine("Example 3"); Console.WriteLine("Example 3");
var result2 = db.UseTranAsync(() => var result2 = db.UseTranAsync(async () =>
{ {
db.ChangeDatabase("1");//use db1 db.ChangeDatabase("1");//use db1
db.Deleteable<Order>().ExecuteCommand(); await db.Deleteable<Order>().ExecuteCommandAsync();
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("2");//use db2 db.ChangeDatabase("2");//use db2
db.Deleteable<Order>().ExecuteCommand(); await db.Deleteable<Order>().ExecuteCommandAsync();
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 (result2.Result.IsSuccess == false)
{ {
Console.WriteLine("---Roll back"); Console.WriteLine("---Roll back");
db.ChangeDatabase("1");//use sqlserver db.ChangeDatabase("1");//use sqlserver
@ -336,7 +336,6 @@ namespace OrmTest
Console.WriteLine(db.Queryable<Order>().Count()); Console.WriteLine(db.Queryable<Order>().Count());
} }
Console.WriteLine("#### Distributed TransactionExample End ####");
} }
} }

View File

@ -308,23 +308,23 @@ namespace OrmTest
// Example 3 // Example 3
Console.WriteLine("Example 3"); Console.WriteLine("Example 3");
var result2 = db.UseTranAsync(() => var result2 = db.UseTranAsync(async () =>
{ {
db.ChangeDatabase("1");//use db1 db.ChangeDatabase("1");//use db1
db.Deleteable<Order>().ExecuteCommand(); await db.Deleteable<Order>().ExecuteCommandAsync();
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("2");//use db2 db.ChangeDatabase("2");//use db2
db.Deleteable<Order>().ExecuteCommand(); await db.Deleteable<Order>().ExecuteCommandAsync();
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 (result2.Result.IsSuccess == false)
{ {
Console.WriteLine("---Roll back"); Console.WriteLine("---Roll back");
db.ChangeDatabase("1");//use sqlserver db.ChangeDatabase("1");//use sqlserver
@ -336,7 +336,6 @@ namespace OrmTest
Console.WriteLine(db.Queryable<Order>().Count()); Console.WriteLine(db.Queryable<Order>().Count());
} }
Console.WriteLine("#### Distributed TransactionExample End ####");
} }
} }

View File

@ -309,23 +309,23 @@ namespace OrmTest
// Example 3 // Example 3
Console.WriteLine("Example 3"); Console.WriteLine("Example 3");
var result2 = db.UseTranAsync(() => var result2 = db.UseTranAsync(async () =>
{ {
db.ChangeDatabase("1");//use db1 db.ChangeDatabase("1");//use db1
db.Deleteable<Order>().ExecuteCommand(); await db.Deleteable<Order>().ExecuteCommandAsync();
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("2");//use db2 db.ChangeDatabase("2");//use db2
db.Deleteable<Order>().ExecuteCommand(); await db.Deleteable<Order>().ExecuteCommandAsync();
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 (result2.Result.IsSuccess == false)
{ {
Console.WriteLine("---Roll back"); Console.WriteLine("---Roll back");
db.ChangeDatabase("1");//use sqlserver db.ChangeDatabase("1");//use sqlserver
@ -337,7 +337,6 @@ namespace OrmTest
Console.WriteLine(db.Queryable<Order>().Count()); Console.WriteLine(db.Queryable<Order>().Count());
} }
Console.WriteLine("#### Distributed TransactionExample End ####");
} }
} }

View File

@ -308,23 +308,23 @@ namespace OrmTest
// Example 3 // Example 3
Console.WriteLine("Example 3"); Console.WriteLine("Example 3");
var result2 = db.UseTranAsync(() => var result2 = db.UseTranAsync(async () =>
{ {
db.ChangeDatabase("1");//use db1 db.ChangeDatabase("1");//use db1
db.Deleteable<Order>().ExecuteCommand(); await db.Deleteable<Order>().ExecuteCommandAsync();
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("2");//use db2 db.ChangeDatabase("2");//use db2
db.Deleteable<Order>().ExecuteCommand(); await db.Deleteable<Order>().ExecuteCommandAsync();
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 (result2.Result.IsSuccess == false)
{ {
Console.WriteLine("---Roll back"); Console.WriteLine("---Roll back");
db.ChangeDatabase("1");//use sqlserver db.ChangeDatabase("1");//use sqlserver
@ -336,7 +336,6 @@ namespace OrmTest
Console.WriteLine(db.Queryable<Order>().Count()); Console.WriteLine(db.Queryable<Order>().Count());
} }
Console.WriteLine("#### Distributed TransactionExample End ####");
} }
} }