mirror of
https://github.com/nsnail/FreeSql.git
synced 2025-05-02 23:22:51 +08:00
750 lines
38 KiB
C#
750 lines
38 KiB
C#
using FreeSql.Internal.Model;
|
||
using System;
|
||
using System.Collections;
|
||
using System.Collections.Concurrent;
|
||
using System.Collections.Generic;
|
||
using System.Collections.ObjectModel;
|
||
using System.Data.Common;
|
||
using System.Linq;
|
||
using System.Linq.Expressions;
|
||
using System.Reflection;
|
||
using System.Text;
|
||
using System.Text.RegularExpressions;
|
||
using System.Threading;
|
||
using System.Threading.Tasks;
|
||
|
||
namespace FreeSql.Internal.CommonProvider
|
||
{
|
||
public abstract partial class Select0Provider
|
||
{
|
||
public int _limit, _skip;
|
||
public string _select = "SELECT ", _orderby, _groupby, _having;
|
||
public StringBuilder _where = new StringBuilder();
|
||
public List<DbParameter> _params = new List<DbParameter>();
|
||
public List<SelectTableInfo> _tables = new List<SelectTableInfo>();
|
||
public List<Func<Type, string, string>> _tableRules = new List<Func<Type, string, string>>();
|
||
public Func<Type, string, string> _aliasRule;
|
||
public string _tosqlAppendContent;
|
||
public StringBuilder _join = new StringBuilder();
|
||
public IFreeSql _orm;
|
||
public CommonUtils _commonUtils;
|
||
public CommonExpression _commonExpression;
|
||
public DbTransaction _transaction;
|
||
public DbConnection _connection;
|
||
public int _commandTimeout = 0;
|
||
public Action<object> _trackToList;
|
||
public List<Action<object>> _includeToList = new List<Action<object>>();
|
||
#if net40
|
||
#else
|
||
public List<Func<object, Task>> _includeToListAsync = new List<Func<object, Task>>();
|
||
#endif
|
||
public Dictionary<string, MemberExpression[]> _includeInfo = new Dictionary<string, MemberExpression[]>();
|
||
public bool _distinct;
|
||
public Expression _selectExpression;
|
||
public List<GlobalFilter.Item> _whereGlobalFilter;
|
||
|
||
int _disposeCounter;
|
||
~Select0Provider()
|
||
{
|
||
if (Interlocked.Increment(ref _disposeCounter) != 1) return;
|
||
_where.Clear();
|
||
_params.Clear();
|
||
_tables.Clear();
|
||
_tableRules.Clear();
|
||
_join.Clear();
|
||
_trackToList = null;
|
||
_includeToList.Clear();
|
||
#if net40
|
||
#else
|
||
_includeToListAsync.Clear();
|
||
#endif
|
||
_includeInfo.Clear();
|
||
_selectExpression = null;
|
||
_whereGlobalFilter?.Clear();
|
||
}
|
||
|
||
public static void CopyData(Select0Provider from, Select0Provider to, ReadOnlyCollection<ParameterExpression> lambParms)
|
||
{
|
||
if (to == null) return;
|
||
to._limit = from._limit;
|
||
to._skip = from._skip;
|
||
to._select = from._select;
|
||
to._orderby = from._orderby;
|
||
to._groupby = from._groupby;
|
||
to._having = from._having;
|
||
to._where = new StringBuilder().Append(from._where.ToString());
|
||
to._params = new List<DbParameter>(from._params.ToArray());
|
||
|
||
if (lambParms == null)
|
||
to._tables = new List<SelectTableInfo>(from._tables.ToArray());
|
||
else
|
||
{
|
||
var findedIndexs = new List<int>();
|
||
var _multiTables = to._tables;
|
||
_multiTables[0] = from._tables[0];
|
||
for (var a = 1; a < lambParms.Count; a++)
|
||
{
|
||
var tbIndex = from._tables.FindIndex(b => b.Alias == lambParms[a].Name && b.Table.Type == lambParms[a].Type); ;
|
||
if (tbIndex != -1)
|
||
{
|
||
findedIndexs.Add(tbIndex);
|
||
_multiTables[a] = from._tables[tbIndex];
|
||
}
|
||
else
|
||
{
|
||
_multiTables[a].Alias = lambParms[a].Name;
|
||
_multiTables[a].Parameter = lambParms[a];
|
||
}
|
||
}
|
||
for (var a = 1; a < from._tables.Count; a++)
|
||
{
|
||
if (findedIndexs.Contains(a)) continue;
|
||
_multiTables.Add(from._tables[a]);
|
||
}
|
||
}
|
||
to._tableRules = new List<Func<Type, string, string>>(from._tableRules.ToArray());
|
||
to._aliasRule = from._aliasRule;
|
||
to._join = new StringBuilder().Append(from._join.ToString());
|
||
//to._orm = from._orm;
|
||
//to._commonUtils = from._commonUtils;
|
||
//to._commonExpression = from._commonExpression;
|
||
to._transaction = from._transaction;
|
||
to._connection = from._connection;
|
||
to._trackToList = from._trackToList;
|
||
to._includeToList = new List<Action<object>>(from._includeToList.ToArray());
|
||
#if net40
|
||
#else
|
||
to._includeToListAsync = new List<Func<object, Task>>(from._includeToListAsync.ToArray());
|
||
#endif
|
||
to._distinct = from._distinct;
|
||
to._selectExpression = from._selectExpression;
|
||
to._whereGlobalFilter = new List<GlobalFilter.Item>(from._whereGlobalFilter.ToArray());
|
||
}
|
||
|
||
public Expression ConvertStringPropertyToExpression(string property)
|
||
{
|
||
if (string.IsNullOrEmpty(property)) return null;
|
||
var field = property.Split('.').Select(a => a.Trim()).ToArray();
|
||
Expression exp = null;
|
||
|
||
if (field.Length == 1)
|
||
{
|
||
foreach (var tb in _tables)
|
||
{
|
||
if (tb.Table.ColumnsByCs.TryGetValue(field[0], out var col) &&
|
||
tb.Table.Properties.TryGetValue(field[0], out var prop))
|
||
{
|
||
tb.Parameter = Expression.Parameter(tb.Table.Type, tb.Alias);
|
||
exp = Expression.MakeMemberAccess(tb.Parameter, prop);
|
||
break;
|
||
}
|
||
}
|
||
if (exp == null) throw new Exception($"无法匹配 {property}");
|
||
}
|
||
else
|
||
{
|
||
var firstTb = _tables[0];
|
||
var firstTbs = _tables.Where(a => a.AliasInit == field[0]).ToArray();
|
||
if (firstTbs.Length == 1) firstTb = firstTbs[0];
|
||
|
||
firstTb.Parameter = Expression.Parameter(firstTb.Table.Type, firstTb.Alias);
|
||
var currentType = firstTb.Table.Type;
|
||
Expression currentExp = firstTb.Parameter;
|
||
|
||
for (var x = 0; x < field.Length; x++)
|
||
{
|
||
var tmp1 = field[x];
|
||
if (_commonUtils.GetTableByEntity(currentType).Properties.TryGetValue(tmp1, out var prop) == false)
|
||
throw new ArgumentException($"{currentType.DisplayCsharp()} 无法找到属性名 {tmp1}");
|
||
currentType = prop.PropertyType;
|
||
currentExp = Expression.MakeMemberAccess(currentExp, prop);
|
||
}
|
||
exp = currentExp;
|
||
}
|
||
return exp;
|
||
}
|
||
}
|
||
|
||
public abstract partial class Select0Provider<TSelect, T1> : Select0Provider, ISelect0<TSelect, T1> where TSelect : class
|
||
{
|
||
public Select0Provider(IFreeSql orm, CommonUtils commonUtils, CommonExpression commonExpression, object dywhere)
|
||
{
|
||
_orm = orm;
|
||
_commonUtils = commonUtils;
|
||
_commonExpression = commonExpression;
|
||
_tables.Add(new SelectTableInfo { Table = _commonUtils.GetTableByEntity(typeof(T1)), Alias = "a", On = null, Type = SelectTableInfoType.From });
|
||
this.Where(_commonUtils.WhereObject(_tables.First().Table, "a.", dywhere));
|
||
if (_orm.CodeFirst.IsAutoSyncStructure && typeof(T1) != typeof(object)) _orm.CodeFirst.SyncStructure<T1>();
|
||
}
|
||
|
||
public TSelect TrackToList(Action<object> track)
|
||
{
|
||
_trackToList = track;
|
||
return this as TSelect;
|
||
}
|
||
|
||
public TSelect WithTransaction(DbTransaction transaction)
|
||
{
|
||
_transaction = transaction;
|
||
_connection = _transaction?.Connection;
|
||
return this as TSelect;
|
||
}
|
||
public TSelect WithConnection(DbConnection connection)
|
||
{
|
||
if (_transaction?.Connection != connection) _transaction = null;
|
||
_connection = connection;
|
||
return this as TSelect;
|
||
}
|
||
public TSelect CommandTimeout(int timeout)
|
||
{
|
||
_commandTimeout = timeout;
|
||
return this as TSelect;
|
||
}
|
||
|
||
public TSelect GroupBy(string sql, object parms = null)
|
||
{
|
||
_groupby = sql;
|
||
if (string.IsNullOrEmpty(_groupby)) return this as TSelect;
|
||
_groupby = string.Concat(" \r\nGROUP BY ", _groupby);
|
||
if (parms != null) _params.AddRange(_commonUtils.GetDbParamtersByObject(_groupby, parms));
|
||
return this as TSelect;
|
||
}
|
||
public TSelect Having(string sql, object parms = null)
|
||
{
|
||
if (string.IsNullOrEmpty(_groupby) || string.IsNullOrEmpty(sql)) return this as TSelect;
|
||
_having = string.Concat(_having, " AND (", sql, ")");
|
||
if (parms != null) _params.AddRange(_commonUtils.GetDbParamtersByObject(sql, parms));
|
||
return this as TSelect;
|
||
}
|
||
|
||
public TSelect LeftJoin(Expression<Func<T1, bool>> exp)
|
||
{
|
||
if (exp == null) return this as TSelect;
|
||
_tables[0].Parameter = exp.Parameters[0];
|
||
return this.InternalJoin(exp?.Body, SelectTableInfoType.LeftJoin);
|
||
}
|
||
public TSelect InnerJoin(Expression<Func<T1, bool>> exp)
|
||
{
|
||
if (exp == null) return this as TSelect;
|
||
_tables[0].Parameter = exp.Parameters[0];
|
||
return this.InternalJoin(exp?.Body, SelectTableInfoType.InnerJoin);
|
||
}
|
||
public TSelect RightJoin(Expression<Func<T1, bool>> exp)
|
||
{
|
||
if (exp == null) return this as TSelect; _tables[0].Parameter = exp.Parameters[0];
|
||
return this.InternalJoin(exp?.Body, SelectTableInfoType.RightJoin);
|
||
}
|
||
public TSelect LeftJoin<T2>(Expression<Func<T1, T2, bool>> exp)
|
||
{
|
||
if (exp == null) return this as TSelect;
|
||
_tables[0].Parameter = exp.Parameters[0];
|
||
return this.InternalJoin(exp?.Body, SelectTableInfoType.LeftJoin);
|
||
}
|
||
public TSelect InnerJoin<T2>(Expression<Func<T1, T2, bool>> exp)
|
||
{
|
||
if (exp == null) return this as TSelect;
|
||
_tables[0].Parameter = exp.Parameters[0];
|
||
return this.InternalJoin(exp?.Body, SelectTableInfoType.InnerJoin);
|
||
}
|
||
public TSelect RightJoin<T2>(Expression<Func<T1, T2, bool>> exp)
|
||
{
|
||
if (exp == null) return this as TSelect;
|
||
_tables[0].Parameter = exp.Parameters[0];
|
||
return this.InternalJoin(exp?.Body, SelectTableInfoType.RightJoin);
|
||
}
|
||
|
||
public TSelect InnerJoin(string sql, object parms = null)
|
||
{
|
||
if (string.IsNullOrEmpty(sql)) return this as TSelect;
|
||
_join.Append(" \r\nINNER JOIN ").Append(sql);
|
||
if (parms != null) _params.AddRange(_commonUtils.GetDbParamtersByObject(sql, parms));
|
||
return this as TSelect;
|
||
}
|
||
public TSelect LeftJoin(string sql, object parms = null)
|
||
{
|
||
if (string.IsNullOrEmpty(sql)) return this as TSelect;
|
||
_join.Append(" \r\nLEFT JOIN ").Append(sql);
|
||
if (parms != null) _params.AddRange(_commonUtils.GetDbParamtersByObject(sql, parms));
|
||
return this as TSelect;
|
||
}
|
||
public TSelect RightJoin(string sql, object parms = null)
|
||
{
|
||
if (string.IsNullOrEmpty(sql)) return this as TSelect;
|
||
_join.Append(" \r\nRIGHT JOIN ").Append(sql);
|
||
if (parms != null) _params.AddRange(_commonUtils.GetDbParamtersByObject(sql, parms));
|
||
return this as TSelect;
|
||
}
|
||
public TSelect RawJoin(string sql)
|
||
{
|
||
if (string.IsNullOrEmpty(sql)) return this as TSelect;
|
||
_join.Append(" \r\n").Append(sql);
|
||
return this as TSelect;
|
||
}
|
||
|
||
public TSelect Limit(int limit)
|
||
{
|
||
_limit = limit;
|
||
return this as TSelect;
|
||
}
|
||
public TSelect Master()
|
||
{
|
||
_select = $" {_select.Trim()} ";
|
||
return this as TSelect;
|
||
}
|
||
public TSelect Offset(int offset) => this.Skip(offset) as TSelect;
|
||
|
||
public TSelect OrderBy(string sql, object parms = null) => this.OrderBy(true, sql, parms);
|
||
public TSelect OrderBy(bool condition, string sql, object parms = null)
|
||
{
|
||
if (condition == false) return this as TSelect;
|
||
if (string.IsNullOrEmpty(sql)) _orderby = null;
|
||
var isnull = string.IsNullOrEmpty(_orderby);
|
||
_orderby = string.Concat(isnull ? " \r\nORDER BY " : "", _orderby, isnull ? "" : ", ", sql);
|
||
if (parms != null) _params.AddRange(_commonUtils.GetDbParamtersByObject(sql, parms));
|
||
return this as TSelect;
|
||
}
|
||
public TSelect Page(int pageNumber, int pageSize)
|
||
{
|
||
this.Skip(Math.Max(0, pageNumber - 1) * pageSize);
|
||
return this.Limit(pageSize) as TSelect;
|
||
}
|
||
|
||
public TSelect Skip(int offset)
|
||
{
|
||
_skip = offset;
|
||
return this as TSelect;
|
||
}
|
||
public TSelect Take(int limit) => this.Limit(limit) as TSelect;
|
||
|
||
public TSelect Distinct()
|
||
{
|
||
_distinct = true;
|
||
return this as TSelect;
|
||
}
|
||
|
||
string GetToDeleteWhere(string alias)
|
||
{
|
||
var pks = _tables[0].Table.Primarys;
|
||
var old_selectVal = _select;
|
||
switch (_orm.Ado.DataType)
|
||
{
|
||
case DataType.Dameng:
|
||
case DataType.OdbcDameng: //达梦不能这样
|
||
case DataType.Oracle:
|
||
case DataType.OdbcOracle:
|
||
case DataType.Firebird:
|
||
break;
|
||
default:
|
||
_select = "SELECT ";
|
||
break;
|
||
}
|
||
try
|
||
{
|
||
if (pks.Length == 1)
|
||
return $"{_commonUtils.QuoteSqlName(_tables[0].Table.Primarys[0].Attribute.Name)} in (select * from ({this.ToSql($"{_tables[0].Alias}.{_commonUtils.QuoteSqlName(_tables[0].Table.Primarys[0].Attribute.Name)}")}) {alias})";
|
||
else
|
||
{
|
||
var concatTypes = new Type[pks.Length * 2 - 1];
|
||
var concatMainCols = new string[pks.Length * 2 - 1];
|
||
var concatInCols = new string[pks.Length * 2 - 1];
|
||
var concatSplit = _commonUtils.FormatSql("{0}", $",{alias},");
|
||
for (var a = 0; a < pks.Length; a++)
|
||
{
|
||
concatTypes[a * 2] = pks[a].CsType;
|
||
concatMainCols[a * 2] = _commonUtils.QuoteSqlName(pks[a].Attribute.Name);
|
||
concatInCols[a * 2] = $"{_tables[0].Alias}.{_commonUtils.QuoteSqlName(pks[a].Attribute.Name)}";
|
||
if (a < pks.Length - 1)
|
||
{
|
||
concatTypes[a * 2 + 1] = typeof(string);
|
||
concatMainCols[a * 2 + 1] = concatSplit;
|
||
concatInCols[a * 2 + 1] = concatSplit;
|
||
}
|
||
}
|
||
return $"{_commonUtils.StringConcat(concatMainCols, concatTypes)} in (select * from ({this.ToSql($"{_commonUtils.StringConcat(concatInCols, concatTypes)} as as1")}) {alias})";
|
||
}
|
||
}
|
||
finally
|
||
{
|
||
_select = old_selectVal;
|
||
}
|
||
}
|
||
public IDelete<T1> ToDelete()
|
||
{
|
||
if (_tables[0].Table.Primarys.Any() == false) throw new Exception($"ToDelete 功能要求实体类 {_tables[0].Table.CsName} 必须有主键");
|
||
var del = (_orm as BaseDbProvider).CreateDeleteProvider<T1>(null) as DeleteProvider<T1>;
|
||
if (_tables[0].Table.Type != typeof(T1)) del.AsType(_tables[0].Table.Type);
|
||
if (_params.Any()) del._params = new List<DbParameter>(_params.ToArray());
|
||
if (_whereGlobalFilter.Any()) del._whereGlobalFilter = new List<GlobalFilter.Item>(_whereGlobalFilter.ToArray());
|
||
del.WithConnection(_connection).WithTransaction(_transaction).CommandTimeout(_commandTimeout);
|
||
switch (_orm.Ado.DataType)
|
||
{
|
||
case DataType.Dameng:
|
||
case DataType.OdbcDameng: //达梦不能这样
|
||
case DataType.Oracle:
|
||
case DataType.OdbcOracle:
|
||
case DataType.Firebird:
|
||
break;
|
||
default:
|
||
var beforeSql = this._select;
|
||
if (beforeSql.EndsWith("SELECT ", StringComparison.OrdinalIgnoreCase))
|
||
{
|
||
beforeSql = beforeSql.Substring(0, beforeSql.Length - 7);
|
||
if (string.IsNullOrEmpty(beforeSql) == false)
|
||
del._interceptSql = sb => sb.Insert(0, beforeSql);
|
||
}
|
||
break;
|
||
}
|
||
return del.Where(GetToDeleteWhere("ftb_del"));
|
||
}
|
||
public IUpdate<T1> ToUpdate()
|
||
{
|
||
if (_tables[0].Table.Primarys.Any() == false) throw new Exception($"ToUpdate 功能要求实体类 {_tables[0].Table.CsName} 必须有主键");
|
||
var upd = (_orm as BaseDbProvider).CreateUpdateProvider<T1>(null) as UpdateProvider<T1>;
|
||
if (_tables[0].Table.Type != typeof(T1)) upd.AsType(_tables[0].Table.Type);
|
||
if (_params.Any()) upd._params = new List<DbParameter>(_params.ToArray());
|
||
if (_whereGlobalFilter.Any()) upd._whereGlobalFilter = new List<GlobalFilter.Item>(_whereGlobalFilter.ToArray());
|
||
upd.WithConnection(_connection).WithTransaction(_transaction).CommandTimeout(_commandTimeout);
|
||
switch (_orm.Ado.DataType)
|
||
{
|
||
case DataType.Dameng:
|
||
case DataType.OdbcDameng: //达梦不能这样
|
||
case DataType.Oracle:
|
||
case DataType.OdbcOracle:
|
||
case DataType.Firebird:
|
||
break;
|
||
default:
|
||
var beforeSql = this._select;
|
||
if (beforeSql.EndsWith("SELECT ", StringComparison.OrdinalIgnoreCase))
|
||
{
|
||
beforeSql = beforeSql.Substring(0, beforeSql.Length - 7);
|
||
if (string.IsNullOrEmpty(beforeSql) == false)
|
||
upd._interceptSql = sb => sb.Insert(0, beforeSql);
|
||
}
|
||
break;
|
||
}
|
||
return upd.Where(GetToDeleteWhere("ftb_upd"));
|
||
}
|
||
|
||
protected List<Dictionary<Type, string>> GetTableRuleUnions()
|
||
{
|
||
var unions = new List<Dictionary<Type, string>>();
|
||
var trs = _tableRules.Any() ? _tableRules : new List<Func<Type, string, string>>(new[] { new Func<Type, string, string>((type, oldname) => null) });
|
||
foreach (var tr in trs)
|
||
{
|
||
var dict = new Dictionary<Type, string>();
|
||
foreach (var tb in _tables)
|
||
{
|
||
if (tb.Type == SelectTableInfoType.Parent) continue;
|
||
if (dict.ContainsKey(tb.Table.Type)) continue;
|
||
var name = tr?.Invoke(tb.Table.Type, tb.Table.DbName);
|
||
if (string.IsNullOrEmpty(name)) name = tb.Table.DbName;
|
||
else
|
||
{
|
||
if (name.IndexOf(' ') == -1) //还可以这样：select.AsTable((a, b) => "(select * from tb_topic where clicks > 10)").Page(1, 10).ToList()
|
||
{
|
||
if (_orm.CodeFirst.IsSyncStructureToLower) name = name.ToLower();
|
||
if (_orm.CodeFirst.IsSyncStructureToUpper) name = name.ToUpper();
|
||
if (_orm.CodeFirst.IsAutoSyncStructure) _orm.CodeFirst.SyncStructure(tb.Table.Type, name);
|
||
}
|
||
else
|
||
name = name.Replace(" \r\n", " \r\n ");
|
||
}
|
||
dict.Add(tb.Table.Type, name);
|
||
}
|
||
unions.Add(dict);
|
||
}
|
||
return unions;
|
||
}
|
||
public TSelect AsTable(Func<Type, string, string> tableRule)
|
||
{
|
||
if (tableRule != null) _tableRules.Add(tableRule);
|
||
return this as TSelect;
|
||
}
|
||
public TSelect AsAlias(Func<Type, string, string> aliasRule)
|
||
{
|
||
if (aliasRule != null) _aliasRule = aliasRule;
|
||
return this as TSelect;
|
||
}
|
||
public TSelect AsType(Type entityType)
|
||
{
|
||
if (entityType == typeof(object)) throw new Exception("ISelect.AsType 参数不支持指定为 object");
|
||
if (entityType == _tables[0].Table.Type) return this as TSelect;
|
||
var newtb = _commonUtils.GetTableByEntity(entityType);
|
||
_tables[0].Table = newtb ?? throw new Exception("ISelect.AsType 参数错误，请传入正确的实体类型");
|
||
if (_orm.CodeFirst.IsAutoSyncStructure) _orm.CodeFirst.SyncStructure(entityType);
|
||
return this as TSelect;
|
||
}
|
||
public abstract string ToSql(string field = null);
|
||
|
||
public TSelect Where(string sql, object parms = null) => this.WhereIf(true, sql, parms);
|
||
public TSelect WhereIf(bool condition, string sql, object parms = null)
|
||
{
|
||
if (condition == false || string.IsNullOrEmpty(sql)) return this as TSelect;
|
||
_where.Append(" AND (").Append(sql).Append(")");
|
||
if (parms != null) _params.AddRange(_commonUtils.GetDbParamtersByObject(sql, parms));
|
||
return this as TSelect;
|
||
}
|
||
|
||
public TSelect OrderByPropertyName(string property, bool isAscending = true) => OrderByPropertyNameIf(true, property, isAscending);
|
||
public TSelect OrderByPropertyNameIf(bool condition, string property, bool isAscending = true)
|
||
{
|
||
if (condition == false) return this as TSelect;
|
||
Expression exp = ConvertStringPropertyToExpression(property);
|
||
if (exp == null) return this as TSelect;
|
||
var field = _commonExpression.ExpressionSelectColumn_MemberAccess(_tables, null, SelectTableInfoType.From, exp, true, null);
|
||
if (isAscending) return this.OrderBy(field);
|
||
return this.OrderBy($"{field} DESC");
|
||
}
|
||
|
||
static MethodInfo MethodStringContains = typeof(string).GetMethod("Contains", new[] { typeof(string) });
|
||
static MethodInfo MethodStringStartsWith = typeof(string).GetMethod("StartsWith", new[] { typeof(string) });
|
||
static MethodInfo MethodStringEndsWith = typeof(string).GetMethod("EndsWith", new[] { typeof(string) });
|
||
static ConcurrentDictionary<Type, MethodInfo> MethodEnumerableContainsDic = new ConcurrentDictionary<Type, MethodInfo>();
|
||
static MethodInfo GetMethodEnumerableContains(Type elementType) => MethodEnumerableContainsDic.GetOrAdd(elementType, et => typeof(Enumerable).GetMethods().Where(a => a.Name == "Contains").FirstOrDefault().MakeGenericMethod(elementType));
|
||
public TSelect WhereDynamicFilter(DynamicFilterInfo filter)
|
||
{
|
||
if (filter == null) return this as TSelect;
|
||
var sb = new StringBuilder();
|
||
ParseFilter(DynamicFilterLogic.And, filter, true);
|
||
this.Where(sb.ToString());
|
||
sb.Clear();
|
||
return this as TSelect;
|
||
|
||
void ParseFilter(DynamicFilterLogic logic, DynamicFilterInfo fi, bool isend)
|
||
{
|
||
if (string.IsNullOrEmpty(fi.Field) == false)
|
||
{
|
||
Expression exp = ConvertStringPropertyToExpression(fi.Field);
|
||
switch (fi.Operator)
|
||
{
|
||
case DynamicFilterOperator.Contains: exp = Expression.Call(exp, MethodStringContains, Expression.Constant(Utils.GetDataReaderValue(exp.Type, fi.Value?.ToString()), exp.Type)); break;
|
||
case DynamicFilterOperator.StartsWith: exp = Expression.Call(exp, MethodStringStartsWith, Expression.Constant(Utils.GetDataReaderValue(exp.Type, fi.Value?.ToString()), exp.Type)); break;
|
||
case DynamicFilterOperator.EndsWith: exp = Expression.Call(exp, MethodStringEndsWith, Expression.Constant(Utils.GetDataReaderValue(exp.Type, fi.Value?.ToString()), exp.Type)); break;
|
||
case DynamicFilterOperator.NotContains: exp = Expression.Not(Expression.Call(exp, MethodStringContains, Expression.Constant(Utils.GetDataReaderValue(exp.Type, fi.Value?.ToString()), exp.Type))); break;
|
||
case DynamicFilterOperator.NotStartsWith: exp = Expression.Not(Expression.Call(exp, MethodStringStartsWith, Expression.Constant(Utils.GetDataReaderValue(exp.Type, fi.Value?.ToString()), exp.Type))); break;
|
||
case DynamicFilterOperator.NotEndsWith: exp = Expression.Not(Expression.Call(exp, MethodStringEndsWith, Expression.Constant(Utils.GetDataReaderValue(exp.Type, fi.Value?.ToString()), exp.Type))); break;
|
||
|
||
case DynamicFilterOperator.Eq:
|
||
case DynamicFilterOperator.Equals:
|
||
case DynamicFilterOperator.Equal: exp = Expression.Equal(exp, Expression.Constant(Utils.GetDataReaderValue(exp.Type, fi.Value?.ToString()), exp.Type)); break;
|
||
case DynamicFilterOperator.NotEqual: exp = Expression.NotEqual(exp, Expression.Constant(Utils.GetDataReaderValue(exp.Type, fi.Value?.ToString()), exp.Type)); break;
|
||
|
||
case DynamicFilterOperator.GreaterThan: exp = Expression.Call(typeof(SqlExt).GetMethod("GreaterThan").MakeGenericMethod(exp.Type), exp, Expression.Constant(Utils.GetDataReaderValue(exp.Type, fi.Value?.ToString()), exp.Type)); break;
|
||
case DynamicFilterOperator.GreaterThanOrEqual: exp = Expression.Call(typeof(SqlExt).GetMethod("GreaterThanOrEqual").MakeGenericMethod(exp.Type), exp, Expression.Constant(Utils.GetDataReaderValue(exp.Type, fi.Value?.ToString()), exp.Type)); break;
|
||
case DynamicFilterOperator.LessThan: exp = Expression.Call(typeof(SqlExt).GetMethod("LessThan").MakeGenericMethod(exp.Type), exp, Expression.Constant(Utils.GetDataReaderValue(exp.Type, fi.Value?.ToString()), exp.Type)); break;
|
||
case DynamicFilterOperator.LessThanOrEqual: exp = Expression.Call(typeof(SqlExt).GetMethod("LessThanOrEqual").MakeGenericMethod(exp.Type), exp, Expression.Constant(Utils.GetDataReaderValue(exp.Type, fi.Value?.ToString()), exp.Type)); break;
|
||
case DynamicFilterOperator.Range:
|
||
var fiValueRangeArray = getFiListValue();
|
||
if (fiValueRangeArray.Length != 2) throw new ArgumentException($"Range 要求 Value 应该逗号分割，并且长度为 2");
|
||
exp = Expression.AndAlso(
|
||
Expression.GreaterThanOrEqual(exp, Expression.Constant(Utils.GetDataReaderValue(exp.Type, fiValueRangeArray[0]), exp.Type)),
|
||
Expression.LessThan(exp, Expression.Constant(Utils.GetDataReaderValue(exp.Type, fiValueRangeArray[1]), exp.Type)));
|
||
break;
|
||
case DynamicFilterOperator.DateRange:
|
||
var fiValueDateRangeArray = getFiListValue();
|
||
if (fiValueDateRangeArray?.Length != 2) throw new ArgumentException($"DateRange 要求 Value 应该逗号分割，并且长度为 2");
|
||
if (Regex.IsMatch(fiValueDateRangeArray[1], @"^\d\d\d\d[\-/]\d\d?[\-/]\d\d?$")) fiValueDateRangeArray[1] = DateTime.Parse(fiValueDateRangeArray[1]).AddDays(1).ToString("yyyy-MM-dd HH:mm:ss");
|
||
else if (Regex.IsMatch(fiValueDateRangeArray[1], @"^\d\d\d\d[\-/]\d\d?$")) fiValueDateRangeArray[1] = DateTime.Parse($"{fiValueDateRangeArray[1]}-01").AddMonths(1).ToString("yyyy-MM-dd HH:mm:ss");
|
||
else if (Regex.IsMatch(fiValueDateRangeArray[1], @"^\d\d\d\d$")) fiValueDateRangeArray[1] = DateTime.Parse($"{fiValueDateRangeArray[1]}-01-01").AddYears(1).ToString("yyyy-MM-dd HH:mm:ss");
|
||
else if (Regex.IsMatch(fiValueDateRangeArray[1], @"^\d\d\d\d[\-/]\d\d?[\-/]\d\d? \d\d?$")) fiValueDateRangeArray[1] = DateTime.Parse($"{fiValueDateRangeArray[1]}:00:00").AddHours(1).ToString("yyyy-MM-dd HH:mm:ss");
|
||
else if (Regex.IsMatch(fiValueDateRangeArray[1], @"^\d\d\d\d[\-/]\d\d?[\-/]\d\d? \d\d?:\d\d?$")) fiValueDateRangeArray[1] = DateTime.Parse($"{fiValueDateRangeArray[1]}:00").AddMinutes(1).ToString("yyyy-MM-dd HH:mm:ss");
|
||
else throw new ArgumentException($"DateRange 要求 Value[1] 格式必须为：yyyy、yyyy-MM、yyyy-MM-dd、yyyy-MM-dd HH、yyyy、yyyy-MM-dd HH:mm");
|
||
|
||
if (Regex.IsMatch(fiValueDateRangeArray[0], @"^\d\d\d\d[\-/]\d\d?$")) fiValueDateRangeArray[0] = DateTime.Parse($"{fiValueDateRangeArray[0]}-01").ToString("yyyy-MM-dd HH:mm:ss");
|
||
else if (Regex.IsMatch(fiValueDateRangeArray[0], @"^\d\d\d\d$")) fiValueDateRangeArray[0] = DateTime.Parse($"{fiValueDateRangeArray[0]}-01-01").ToString("yyyy-MM-dd HH:mm:ss");
|
||
else if (Regex.IsMatch(fiValueDateRangeArray[0], @"^\d\d\d\d[\-/]\d\d?[\-/]\d\d? \d\d?$")) fiValueDateRangeArray[0] = DateTime.Parse($"{fiValueDateRangeArray[0]}:00:00").ToString("yyyy-MM-dd HH:mm:ss");
|
||
else if (Regex.IsMatch(fiValueDateRangeArray[0], @"^\d\d\d\d[\-/]\d\d?[\-/]\d\d? \d\d?:\d\d?$")) fiValueDateRangeArray[0] = DateTime.Parse($"{fiValueDateRangeArray[0]}:00").ToString("yyyy-MM-dd HH:mm:ss");
|
||
|
||
exp = Expression.AndAlso(
|
||
Expression.GreaterThanOrEqual(exp, Expression.Constant(Utils.GetDataReaderValue(exp.Type, fiValueDateRangeArray[0]), exp.Type)),
|
||
Expression.LessThan(exp, Expression.Constant(Utils.GetDataReaderValue(exp.Type, fiValueDateRangeArray[1]), exp.Type)));
|
||
break;
|
||
case DynamicFilterOperator.Any:
|
||
case DynamicFilterOperator.NotAny:
|
||
var fiValueAnyArray = getFiListValue();
|
||
if (fiValueAnyArray.Length == 0) break;
|
||
var fiValueAnyArrayType = exp.Type.MakeArrayType();
|
||
exp = Expression.Call(GetMethodEnumerableContains(exp.Type), Expression.Constant(Utils.GetDataReaderValue(fiValueAnyArrayType, fiValueAnyArray), fiValueAnyArrayType), exp);
|
||
if (fi.Operator == DynamicFilterOperator.NotAny) exp = Expression.Not(exp);
|
||
break;
|
||
}
|
||
|
||
string[] getFiListValue()
|
||
{
|
||
if (fi.Value is string fiValueString) return fiValueString.Split(',');
|
||
if (fi.Value is IEnumerable fiValueIe)
|
||
{
|
||
var fiValueList = new List<string>();
|
||
foreach (var fiValueIeItem in fiValueIe)
|
||
fiValueList.Add(string.Concat(fiValueIeItem));
|
||
return fiValueList.ToArray();
|
||
}
|
||
var fiValueType = fi.Value.GetType();
|
||
if (fiValueType.FullName == "System.Text.Json.JsonElement")
|
||
{
|
||
var fiValueKind = fiValueType.GetProperty("ValueKind").GetValue(fi.Value, null).ToString();
|
||
if (fiValueKind == "Array")
|
||
{
|
||
fiValueIe = fiValueType.GetMethod("EnumerateArray", new Type[0])?.Invoke(fi.Value, null) as IEnumerable;
|
||
var fiValueList = new List<string>();
|
||
foreach (var fiValueIeItem in fiValueIe)
|
||
fiValueList.Add(string.Concat(fiValueIeItem));
|
||
return fiValueList.ToArray();
|
||
}
|
||
return fi.Value.ToString().Split(',');
|
||
}
|
||
return new string[0];
|
||
}
|
||
|
||
var sql = _commonExpression.ExpressionWhereLambda(_tables, exp, null, null, _params);
|
||
|
||
sb.Append(sql);
|
||
}
|
||
if (fi.Filters?.Any() == true)
|
||
{
|
||
if (string.IsNullOrEmpty(fi.Field) == false)
|
||
sb.Append(" AND ");
|
||
if (fi.Logic == DynamicFilterLogic.Or) sb.Append("(");
|
||
for (var x = 0; x < fi.Filters.Count; x++)
|
||
ParseFilter(fi.Logic, fi.Filters[x], x == fi.Filters.Count - 1);
|
||
if (fi.Logic == DynamicFilterLogic.Or) sb.Append(")");
|
||
}
|
||
|
||
if (isend == false)
|
||
{
|
||
if (string.IsNullOrEmpty(fi.Field) == false || fi.Filters?.Any() == true)
|
||
{
|
||
switch (logic)
|
||
{
|
||
case DynamicFilterLogic.And: sb.Append(" AND "); break;
|
||
case DynamicFilterLogic.Or: sb.Append(" OR "); break;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
public TSelect DisableGlobalFilter(params string[] name)
|
||
{
|
||
if (_whereGlobalFilter.Any() == false) return this as TSelect;
|
||
if (name?.Any() != true)
|
||
{
|
||
_whereGlobalFilter.Clear();
|
||
return this as TSelect;
|
||
}
|
||
foreach (var n in name)
|
||
{
|
||
if (n == null) continue;
|
||
var idx = _whereGlobalFilter.FindIndex(a => string.Compare(a.Name, n, true) == 0);
|
||
if (idx == -1) continue;
|
||
_whereGlobalFilter.RemoveAt(idx);
|
||
}
|
||
return this as TSelect;
|
||
}
|
||
public TSelect ForUpdate(bool noawait = false)
|
||
{
|
||
if (_transaction == null && _orm.Ado.TransactionCurrentThread == null)
|
||
throw new Exception("安全起见，请务必在事务开启之后，再使用 ForUpdate");
|
||
switch (_orm.Ado.DataType)
|
||
{
|
||
case DataType.MySql:
|
||
case DataType.OdbcMySql:
|
||
_tosqlAppendContent = " for update";
|
||
break;
|
||
case DataType.SqlServer:
|
||
case DataType.OdbcSqlServer:
|
||
_aliasRule = (_, old) => $"{old} With(UpdLock, RowLock{(noawait ? ", NoWait" : "")})";
|
||
break;
|
||
case DataType.PostgreSQL:
|
||
case DataType.OdbcPostgreSQL:
|
||
case DataType.KingbaseES:
|
||
case DataType.OdbcKingbaseES:
|
||
_tosqlAppendContent = $" for update{(noawait ? " nowait" : "")}";
|
||
break;
|
||
case DataType.Oracle:
|
||
case DataType.OdbcOracle:
|
||
case DataType.Dameng:
|
||
case DataType.OdbcDameng:
|
||
_tosqlAppendContent = $" for update{(noawait ? " nowait" : "")}";
|
||
break;
|
||
case DataType.Sqlite:
|
||
break;
|
||
case DataType.ShenTong: //神通测试中发现，不支持 nowait
|
||
_tosqlAppendContent = " for update";
|
||
break;
|
||
case DataType.Firebird:
|
||
_tosqlAppendContent = " for update with lock";
|
||
break;
|
||
}
|
||
return this as TSelect;
|
||
}
|
||
|
||
public bool Any()
|
||
{
|
||
this.Limit(1);
|
||
return this.ToList<int>($"{1}{_commonUtils.FieldAsAlias("as1")}").Sum() > 0; //这里的 Sum 为了分表查询
|
||
}
|
||
public long Count()
|
||
{
|
||
var tmpOrderBy = _orderby;
|
||
_orderby = null; //解决 select count(1) from t order by id 这样的 SQL 错误
|
||
try
|
||
{
|
||
return this.ToList<int>($"count(1){_commonUtils.FieldAsAlias("as1")}").Sum(); //这里的 Sum 为了分表查询
|
||
}
|
||
finally
|
||
{
|
||
_orderby = tmpOrderBy;
|
||
}
|
||
}
|
||
public TSelect Count(out long count)
|
||
{
|
||
count = this.Count();
|
||
return this as TSelect;
|
||
}
|
||
public virtual List<T1> ToList(bool includeNestedMembers = false)
|
||
{
|
||
if (_selectExpression != null) return this.InternalToList<T1>(_selectExpression);
|
||
return this.ToListPrivate(includeNestedMembers == false ? this.GetAllFieldExpressionTreeLevel2() : this.GetAllFieldExpressionTreeLevelAll(), null);
|
||
}
|
||
public T1 ToOne()
|
||
{
|
||
this.Limit(1);
|
||
return this.ToList().FirstOrDefault();
|
||
}
|
||
public T1 First() => this.ToOne();
|
||
|
||
#if net40
|
||
#else
|
||
async public Task<bool> AnyAsync()
|
||
{
|
||
this.Limit(1);
|
||
return (await this.ToListAsync<int>($"1{_commonUtils.FieldAsAlias("as1")}")).Sum() > 0; //这里的 Sum 为了分表查询
|
||
}
|
||
async public Task<long> CountAsync()
|
||
{
|
||
var tmpOrderBy = _orderby;
|
||
_orderby = null;
|
||
try
|
||
{
|
||
return (await this.ToListAsync<int>($"count(1){_commonUtils.FieldAsAlias("as1")}")).Sum(); //这里的 Sum 为了分表查询
|
||
}
|
||
finally
|
||
{
|
||
_orderby = tmpOrderBy;
|
||
}
|
||
}
|
||
public virtual Task<List<T1>> ToListAsync(bool includeNestedMembers = false)
|
||
{
|
||
if (_selectExpression != null) return this.InternalToListAsync<T1>(_selectExpression);
|
||
return this.ToListPrivateAsync(includeNestedMembers == false ? this.GetAllFieldExpressionTreeLevel2() : this.GetAllFieldExpressionTreeLevelAll(), null);
|
||
}
|
||
async public Task<T1> ToOneAsync()
|
||
{
|
||
this.Limit(1);
|
||
return (await this.ToListAsync()).FirstOrDefault();
|
||
}
|
||
public Task<T1> FirstAsync() => this.ToOneAsync();
|
||
#endif
|
||
}
|
||
} |