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

Update Queue

Browse Source
This commit is contained in:
sunkaixuan
2019-04-10 08:03:06 +08:00
parent c474368f2c
commit f981f49fa0
2 changed files with 25 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
Src/Asp.Net/SqlServerTest/Demos/H_Queue.cs
View File

@@ -30,8 +30,10 @@ namespace OrmTest.Demo
db.Queryable<Student>().AddQueue(); db.Queryable<Student>().AddQueue();
db.Queryable<School>().AddQueue(); db.Queryable<School>().AddQueue();
db.AddQueue("select @id", new { id = 1 }); SqlSugar.SugarParameter p = new SqlSugar.SugarParameter("@id",1);
var result2 = db.SaveQueues<Student, School, int>(); db.AddQueue("select @id", p);
db.AddQueue("select @id", p);
var result2 = db.SaveQueues<Student, School, int,int>();

23
Src/Asp.Net/SqlSugar/SqlSugarClient.cs
View File

@@ -788,6 +788,22 @@ namespace SqlSugar
} }
this.Queues.Add(sql,this.Context.Ado.GetParameters(parsmeters)); this.Queues.Add(sql,this.Context.Ado.GetParameters(parsmeters));
} }
public void AddQueue(string sql, SugarParameter parsmeter)
{
if (Queues == null)
{
Queues = new QueueList();
}
this.Queues.Add(sql, new List<SugarParameter>() { parsmeter });
}
public void AddQueue(string sql, List<SugarParameter> parsmeters)
{
if (Queues == null)
{
Queues = new QueueList();
}
this.Queues.Add(sql, parsmeters);
}
public QueueList Queues = new QueueList(); public QueueList Queues = new QueueList();
private T SaveQueuesProvider<T>(bool isTran, Func<string, List<SugarParameter>, T> func) private T SaveQueuesProvider<T>(bool isTran, Func<string, List<SugarParameter>, T> func)
@@ -812,14 +828,17 @@ namespace SqlSugar
if (item.Parameters == null) if (item.Parameters == null)
item.Parameters = new SugarParameter[] { }; item.Parameters = new SugarParameter[] { };
var itemParsmeters = item.Parameters.OrderByDescending(it => it.ParameterName.Length).ToList(); var itemParsmeters = item.Parameters.OrderByDescending(it => it.ParameterName.Length).ToList();
List<SugarParameter> addParameters = new List<SugarParameter>();
var itemSql = item.Sql; var itemSql = item.Sql;
foreach (var itemParameter in itemParsmeters) foreach (var itemParameter in itemParsmeters)
{ {
var newName = itemParameter.ParameterName + "_q_" + index; var newName = itemParameter.ParameterName + "_q_" + index;
SugarParameter parameter = new SugarParameter(newName, itemParameter.Value);
parameter.DbType = itemParameter.DbType;
itemSql = itemSql.Replace(itemParameter.ParameterName, newName); itemSql = itemSql.Replace(itemParameter.ParameterName, newName);
itemParameter.ParameterName = newName; addParameters.Add(parameter);
} }
parsmeters.AddRange(itemParsmeters); parsmeters.AddRange(addParameters);
itemSql = itemSql.TrimEnd(';')+";"; itemSql = itemSql.TrimEnd(';')+";";
sqlBuilder.AppendLine(itemSql); sqlBuilder.AppendLine(itemSql);
index++; index++;