From 1ff4fbed696075435582a51264762dfe1466a944 Mon Sep 17 00:00:00 2001 From: sunkaixuan <610262374@qq.com> Date: Mon, 20 May 2019 18:31:50 +0800 Subject: [PATCH] Update Demo --- Src/Asp.Net/SqlServerTest/Demo/Demo6_Queue.cs | 39 ++++++++++++++++++- 1 file changed, 38 insertions(+), 1 deletion(-) diff --git a/Src/Asp.Net/SqlServerTest/Demo/Demo6_Queue.cs b/Src/Asp.Net/SqlServerTest/Demo/Demo6_Queue.cs index f0bf7140f..666fd27ee 100644 --- a/Src/Asp.Net/SqlServerTest/Demo/Demo6_Queue.cs +++ b/Src/Asp.Net/SqlServerTest/Demo/Demo6_Queue.cs @@ -1,4 +1,5 @@ -using System; +using SqlSugar; +using System; using System.Collections.Generic; using System.Linq; using System.Text; @@ -10,6 +11,42 @@ namespace OrmTest { public static void Init() { + Console.WriteLine(""); + Console.WriteLine("#### Queue Start ####"); + + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.SqlServer, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + db.Insertable(new Order() { Name = "a" }).AddQueue(); + db.Insertable(new Order() { Name = "b" }).AddQueue(); + db.SaveQueues(); + + + db.Insertable(new Order() { Name = "a" }).AddQueue(); + db.Insertable(new Order() { Name = "b" }).AddQueue(); + db.Insertable(new Order() { Name = "c" }).AddQueue(); + db.Insertable(new Order() { Name = "d" }).AddQueue(); + var ar = db.SaveQueuesAsync(); + ar.Wait(); + + db.Queryable().AddQueue(); + db.Queryable().AddQueue(); + db.AddQueue("select * from [Order] where id=@id", new { id = 10000 }); + var result2 = db.SaveQueues(); + + Console.WriteLine("#### Queue End ####"); } } }