Oracle contains num > 1000

This commit is contained in:
sunkaixuan 2020-11-10 19:33:27 +08:00
parent 15573551bf
commit f71fb3d9d8
3 changed files with 85 additions and 1 deletions

View File

@ -0,0 +1,46 @@
using SqlSugar;
using System;
using System.Collections.Generic;
using System.ComponentModel.DataAnnotations;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace OrmTest.Test
{
public class BugTest1
{
public static void Init()
{
SqlSugarClient Db = new SqlSugarClient(new ConnectionConfig()
{
ConnectionString = Config.ConnectionString,
DbType = DbType.Oracle,
IsAutoCloseConnection = true,
InitKeyType = InitKeyType.Attribute,
});
//调式代码 用来打印SQL
Db.Aop.OnLogExecuting = (sql, pars) =>
{
Console.WriteLine(sql);
};
var id=Enumerable.Range(0, 100).ToList();
// id = null;
Db.Queryable<Order>().Where(it => id.Contains(it.Id)).ToList();
}
}
public class testmmxxxmm121
{
[SugarColumn(IsPrimaryKey =true,IsIdentity =true)]
public int id { get; set; }
[SugarColumn(ColumnDataType ="float4",IsNullable =true)]
public float? name { get; set; }
[SugarColumn(ColumnDataType = "float4", IsNullable = false)]
public float? name2 { get; set; }
}
}

View File

@ -46,6 +46,7 @@
<Reference Include="System.Xml" />
</ItemGroup>
<ItemGroup>
<Compile Include="Bugs\BugTest1.cs" />
<Compile Include="Config.cs" />
<Compile Include="Demo\Demo0_SqlSugarClient.cs" />
<Compile Include="Demo\Demo1_Queryable.cs" />

View File

@ -1,4 +1,5 @@
using System;
using System.Collections;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Linq;
@ -14,7 +15,7 @@ namespace SqlSugar
public SqlSugarProvider Context { get; set; }
public OracleExpressionContext()
{
base.DbMehtods = new OracleMethod();
base.DbMehtods = new OracleMethod();
}
public override string SqlParameterKeyWord
{
@ -40,6 +41,42 @@ namespace SqlSugar
}
public partial class OracleMethod : DefaultDbMethod, IDbMethods
{
private void PageEach<T>(IEnumerable<T> pageItems, int pageSize, Action<List<T>> action)
{
if (pageItems != null && pageItems.Any())
{
int totalRecord = pageItems.Count();
int pageCount = (totalRecord + pageSize - 1) / pageSize;
for (int i = 1; i <= pageCount; i++)
{
var list = pageItems.Skip((i - 1) * pageSize).Take(pageSize).ToList();
action(list);
}
}
}
public override string ContainsArray(MethodCallExpressionModel model)
{
if (model.Args[0].MemberValue == null)
{
return base.ContainsArray(model);
}
var inValueIEnumerable = ((IEnumerable)model.Args[0].MemberValue).Cast<object>().ToArray();
if (inValueIEnumerable.Count() < 1000)
{
return base.ContainsArray(model);
}
else
{
string result = "";
PageEach(inValueIEnumerable, 999, it =>
{
model.Args.First().MemberValue = it;
result+= (base.ContainsArray(model) + " OR ");
});
return " ( "+result.TrimEnd(' ').TrimEnd('R').TrimEnd('O')+" ) ";
}
}
public override string ToInt64(MethodCallExpressionModel model)
{
var parameter = model.Args[0];