diff --git a/Src/Asp.Net/MySqlTest/Demos/H_Queue.cs b/Src/Asp.Net/MySqlTest/Demos/H_Queue.cs new file mode 100644 index 000000000..6b7074070 --- /dev/null +++ b/Src/Asp.Net/MySqlTest/Demos/H_Queue.cs @@ -0,0 +1,65 @@ +using OrmTest.Demo; +using OrmTest.Models; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; + +namespace OrmTest.Demo +{ + public class Queue : DemoBase + { + public static void Init() + { + var db = GetInstance(); + db.Insertable(new Student() { Name = "a" }).AddQueue(); + db.Insertable(new Student() { Name = "b" }).AddQueue(); + var x= db.SaveQueues(); + + db.Insertable(new Student() { Name = "a" }).AddQueue(); + db.Insertable(new Student() { Name = "b" }).AddQueue(); + db.Insertable(new Student() { Name = "c" }).AddQueue(); + db.Insertable(new Student() { Name = "d" }).AddQueue(); + var ar = db.SaveQueuesAsync(); + ar.Wait(); + + + db.Queryable().AddQueue(); + db.Queryable().AddQueue(); + var result = db.SaveQueues(); + + db.Queryable().AddQueue(); + db.Queryable().AddQueue(); + db.AddQueue("select @id", new { id = 1 }); + var result2 = db.SaveQueues(); + + + + db.AddQueue("select 1"); + db.AddQueue("select 2"); + db.AddQueue("select 3"); + db.AddQueue("select 4"); + db.AddQueue("select 5"); + db.AddQueue("select 6"); + db.AddQueue("select 7"); + + var result3 = db.SaveQueues(); + + + db.AddQueue("select 1"); + var result4 = db.SaveQueues(); + + + db.AddQueue("select 1"); + db.AddQueue("select 2"); + var result5 = db.SaveQueues(); + + + db.AddQueue("select 1"); + db.AddQueue("select 2"); + db.AddQueue("select 3"); + var result6 = db.SaveQueuesAsync(); + result6.Wait(); + } + } +} diff --git a/Src/Asp.Net/MySqlTest/MySqlTest.csproj b/Src/Asp.Net/MySqlTest/MySqlTest.csproj index b7379697f..0021dd547 100644 --- a/Src/Asp.Net/MySqlTest/MySqlTest.csproj +++ b/Src/Asp.Net/MySqlTest/MySqlTest.csproj @@ -59,6 +59,7 @@ + diff --git a/Src/Asp.Net/MySqlTest/Program.cs b/Src/Asp.Net/MySqlTest/Program.cs index 5507e386b..572a7e2ce 100644 --- a/Src/Asp.Net/MySqlTest/Program.cs +++ b/Src/Asp.Net/MySqlTest/Program.cs @@ -45,6 +45,7 @@ namespace OrmTest OrmTest.Demo.ComplexModel.Init(); OrmTest.Demo.CodeFirst.Init();; OrmTest.Demo.MasterSlave.Init(); ; + OrmTest.Demo.Queue.Init(); ; } } } diff --git a/Src/Asp.Net/SqlSugar/SqlSugarClient.cs b/Src/Asp.Net/SqlSugar/SqlSugarClient.cs index 4e8fbe0af..727bb796a 100644 --- a/Src/Asp.Net/SqlSugar/SqlSugarClient.cs +++ b/Src/Asp.Net/SqlSugar/SqlSugarClient.cs @@ -817,6 +817,7 @@ namespace SqlSugar itemParameter.ParameterName = newName; } parsmeters.AddRange(itemParsmeters); + itemSql = itemSql.TrimEnd(';')+";"; sqlBuilder.AppendLine(itemSql); index++; } diff --git a/Src/Asp.Net/SqliteTest/DataBase/SqlSugar4xTest.sqlite b/Src/Asp.Net/SqliteTest/DataBase/SqlSugar4xTest.sqlite index 8b3de73db..6cf0040ce 100644 Binary files a/Src/Asp.Net/SqliteTest/DataBase/SqlSugar4xTest.sqlite and b/Src/Asp.Net/SqliteTest/DataBase/SqlSugar4xTest.sqlite differ