diff --git a/Src/Asp.NetCore2/SqlSeverTest/MySqlTest/Demos/H_Queue.cs b/Src/Asp.NetCore2/SqlSeverTest/MySqlTest/Demos/H_Queue.cs new file mode 100644 index 000000000..b9957cc5c --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/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(); + 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.NetCore2/SqlSeverTest/MySqlTest/Program.cs b/Src/Asp.NetCore2/SqlSeverTest/MySqlTest/Program.cs index e239e2b6f..d25102e4f 100644 --- a/Src/Asp.NetCore2/SqlSeverTest/MySqlTest/Program.cs +++ b/Src/Asp.NetCore2/SqlSeverTest/MySqlTest/Program.cs @@ -38,6 +38,7 @@ namespace MySqlTest OrmTest.Demo.Filter.Init(); OrmTest.Demo.ComplexModel.Init(); OrmTest.Demo.CodeFirst.Init(); + OrmTest.Demo.Queue.Init(); } } } diff --git a/Src/Asp.NetCore2/SqlSeverTest/PgSqlTest/Demos/1_Query.cs b/Src/Asp.NetCore2/SqlSeverTest/PgSqlTest/Demos/1_Query.cs index d829a1d2a..d6ce73026 100644 --- a/Src/Asp.NetCore2/SqlSeverTest/PgSqlTest/Demos/1_Query.cs +++ b/Src/Asp.NetCore2/SqlSeverTest/PgSqlTest/Demos/1_Query.cs @@ -260,6 +260,7 @@ namespace OrmTest.Demo var db = GetInstance(); var getAll22 = db.Queryable().ToDataTable(); var getAll220 = db.Ado.GetDataSetAll("select 1"); + var getAll22222 = db.Queryable().Where(it => it.Id == 1).ToSql(); var dbTime = db.GetDate(); var getAll = db.Queryable().Select("*").ToList(); var getAll2 = db.Queryable().ToList(); diff --git a/Src/Asp.NetCore2/SqlSeverTest/SqlSeverTest/Demos/1_Query.cs b/Src/Asp.NetCore2/SqlSeverTest/SqlSeverTest/Demos/1_Query.cs index b26f0b87d..2f944d914 100644 --- a/Src/Asp.NetCore2/SqlSeverTest/SqlSeverTest/Demos/1_Query.cs +++ b/Src/Asp.NetCore2/SqlSeverTest/SqlSeverTest/Demos/1_Query.cs @@ -327,6 +327,7 @@ namespace OrmTest.Demo var getAll22 = db.Queryable().ToDataTable(); var getAll220 = db.Ado.GetDataSetAll("select 1"); var getAll222 = db.Queryable().ToJson(); + var getAll22222 = db.Queryable().Where(it=>it.Id==1).ToSql(); var getAll2222 = db.Queryable().OrderBy(it=>it.Name.Length).ToJson(); var getAll3 = db.Queryable().OrderBy(it => new { it.Id, it.Name }).GroupBy(it => new { it.Id, it.Name }).Select("id").ToList(); var getRandomList = db.Queryable().OrderBy(it => SqlFunc.GetRandom()).ToList();