using System; using System.Collections.Generic; using System.Data; using System.Dynamic; using System.Linq; using System.Linq.Expressions; namespace SqlSugar { /// /// ** description:Create datathis.access object /// ** author:sunkaixuan /// ** date:2017/1/2 /// ** email:610262374@qq.com /// public partial class SqlSugarClient : IDisposable { #region Constructor public SqlSugarClient(ConnectionConfig config) { this.Context = this; this.CurrentConnectionConfig = config; this.ContextID = Guid.NewGuid(); Check.ArgumentNullException(config, "config is null"); switch (config.DbType) { case DbType.MySql: DependencyManagement.TryMySqlData(); break; case DbType.SqlServer: break; case DbType.Sqlite: DependencyManagement.TrySqlite(); break; case DbType.Oracle: DependencyManagement.TryOracle(); break; case DbType.PostgreSQL: throw new Exception("Development 50%"); default: throw new Exception("ConnectionConfig.DbType is null"); } } #endregion Constructor #region ADO Methods /// ///Datathis.operation /// public virtual IAdo Ado { get { if (this.ContextAdo == null) { var result = InstanceFactory.GetAdo(this.Context.CurrentConnectionConfig); this.ContextAdo = result; result.Context = this.Context; return result; } return this.Context._Ado; } } #endregion ADO Methods #region Aop Log Methods public virtual AopProvider Aop { get { return new AopProvider(this.Context); } } #endregion Aop Log Methods #region Util Methods [Obsolete("Use SqlSugarClient.Utilities")] public virtual IContextMethods RewritableMethods { get { return this.Context.Utilities; } set { this.Context.Utilities = value; } } public virtual IContextMethods Utilities { get { if (ContextRewritableMethods == null) { ContextRewritableMethods = new ContextMethods { Context = this.Context }; } return ContextRewritableMethods; } set { ContextRewritableMethods = value; } } #endregion Util Methods #region Queryable /// /// Get datebase time /// /// public DateTime GetDate() { var sqlBuilder = InstanceFactory.GetSqlbuilder(this.Context.CurrentConnectionConfig); return this.Ado.GetDateTime(sqlBuilder.FullSqlDateNow); } /// /// Lambda Query operation /// public virtual ISugarQueryable Queryable() where T : class, new() { InitMppingInfo(); var result = this.CreateQueryable(); return result; } /// /// Lambda Query operation /// /// todo: describe shortName parameter on Queryable public virtual ISugarQueryable Queryable(string shortName) where T : class, new() { var queryable = Queryable(); queryable.SqlBuilder.QueryBuilder.TableShortName = shortName; return queryable; } /// /// Lambda Query operation /// /// todo: describe tableName parameter on Queryable /// todo: describe shortName parameter on Queryable public virtual ISugarQueryable Queryable(string tableName, string shortName) { var queryable = Queryable(); queryable.SqlBuilder.QueryBuilder.EntityName = tableName; queryable.SqlBuilder.QueryBuilder.TableShortName = shortName; return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateQueryJoin(joinExpression, types, queryable); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateQueryJoin(joinExpression, types, queryable); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateQueryJoin(joinExpression, types, queryable); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4), typeof(T5) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateQueryJoin(joinExpression, types, queryable); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4), typeof(T5), typeof(T6) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateQueryJoin(joinExpression, types, queryable); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4), typeof(T5), typeof(T6), typeof(T7) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateQueryJoin(joinExpression, types, queryable); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4), typeof(T5), typeof(T6), typeof(T7), typeof(T8) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateQueryJoin(joinExpression, types, queryable); return queryable; } #region 9-12 public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4), typeof(T5), typeof(T6), typeof(T7), typeof(T8), typeof(T9) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateQueryJoin(joinExpression, types, queryable); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4), typeof(T5), typeof(T6), typeof(T7), typeof(T8), typeof(T9), typeof(T10) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateQueryJoin(joinExpression, types, queryable); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4), typeof(T5), typeof(T6), typeof(T7), typeof(T8), typeof(T9), typeof(T10), typeof(T11) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateQueryJoin(joinExpression, types, queryable); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4), typeof(T5), typeof(T6), typeof(T7), typeof(T8), typeof(T9), typeof(T10), typeof(T11), typeof(T12) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateQueryJoin(joinExpression, types, queryable); return queryable; } #endregion 9-12 public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateEasyQueryJoin(joinExpression, types, queryable); queryable.Where(joinExpression); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateEasyQueryJoin(joinExpression, types, queryable); queryable.Where(joinExpression); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateEasyQueryJoin(joinExpression, types, queryable); queryable.Where(joinExpression); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4), typeof(T5) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateEasyQueryJoin(joinExpression, types, queryable); queryable.Where(joinExpression); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4), typeof(T5), typeof(T6) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateEasyQueryJoin(joinExpression, types, queryable); queryable.Where(joinExpression); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4), typeof(T5), typeof(T6), typeof(T7) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateEasyQueryJoin(joinExpression, types, queryable); queryable.Where(joinExpression); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4), typeof(T5), typeof(T6), typeof(T7), typeof(T8) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateEasyQueryJoin(joinExpression, types, queryable); queryable.Where(joinExpression); return queryable; } #region 9-12 public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4), typeof(T5), typeof(T6), typeof(T7), typeof(T8), typeof(T9) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateEasyQueryJoin(joinExpression, types, queryable); queryable.Where(joinExpression); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4), typeof(T5), typeof(T6), typeof(T7), typeof(T8), typeof(T9), typeof(T10) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateEasyQueryJoin(joinExpression, types, queryable); queryable.Where(joinExpression); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4), typeof(T5), typeof(T6), typeof(T7), typeof(T8), typeof(T9), typeof(T10), typeof(T11) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateEasyQueryJoin(joinExpression, types, queryable); queryable.Where(joinExpression); return queryable; } public virtual ISugarQueryable Queryable(Expression> joinExpression) where T : class, new() { InitMppingInfo(); var types = new Type[] { typeof(T2), typeof(T3), typeof(T4), typeof(T5), typeof(T6), typeof(T7), typeof(T8), typeof(T9), typeof(T10), typeof(T11), typeof(T12) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); this.CreateEasyQueryJoin(joinExpression, types, queryable); queryable.Where(joinExpression); return queryable; } public virtual ISugarQueryable Queryable( ISugarQueryable joinQueryable1, ISugarQueryable joinQueryable2, Expression> joinExpression) where T : class, new() where T2 : class, new() { return Queryable(joinQueryable1, joinQueryable2, JoinType.Inner, joinExpression); } public virtual ISugarQueryable Queryable( ISugarQueryable joinQueryable1, ISugarQueryable joinQueryable2, JoinType joinType, Expression> joinExpression) where T : class, new() where T2 : class, new() { Check.Exception(joinQueryable1.QueryBuilder.Take != null || joinQueryable1.QueryBuilder.Skip != null || joinQueryable1.QueryBuilder.OrderByValue.HasValue(), "joinQueryable1 Cannot have 'Skip' 'ToPageList' 'Take' Or 'OrderBy'"); Check.Exception(joinQueryable2.QueryBuilder.Take != null || joinQueryable2.QueryBuilder.Skip != null || joinQueryable2.QueryBuilder.OrderByValue.HasValue(), "joinQueryable2 Cannot have 'Skip' 'ToPageList' 'Take' Or 'OrderBy'"); var sqlBuilder = InstanceFactory.GetSqlbuilder(this.Context.CurrentConnectionConfig); sqlBuilder.Context = this.Context; InitMppingInfo(); var types = new Type[] { typeof(T2) }; var queryable = InstanceFactory.GetQueryable(this.CurrentConnectionConfig); queryable.Context = this.Context; queryable.SqlBuilder = sqlBuilder; queryable.QueryBuilder = InstanceFactory.GetQueryBuilder(this.CurrentConnectionConfig); queryable.QueryBuilder.JoinQueryInfos = new List(); queryable.QueryBuilder.Builder = sqlBuilder; queryable.QueryBuilder.Context = this.Context; queryable.QueryBuilder.EntityType = typeof(T); queryable.QueryBuilder.LambdaExpressions = InstanceFactory.GetLambdaExpressions(this.CurrentConnectionConfig); //master var shortName1 = joinExpression.Parameters[0].Name; var sqlObj1 = joinQueryable1.ToSql(); var sql1 = sqlObj1.Key; UtilMethods.RepairReplicationParameters(ref sql1, sqlObj1.Value.ToArray(), 0); queryable.QueryBuilder.EntityName = sqlBuilder.GetPackTable(sql1, shortName1); ; queryable.QueryBuilder.Parameters.AddRange(sqlObj1.Value); //join table 1 var shortName2 = joinExpression.Parameters[1].Name; var sqlObj2 = joinQueryable2.ToSql(); var sql2 = sqlObj2.Key; UtilMethods.RepairReplicationParameters(ref sql2, sqlObj2.Value.ToArray(), 1); queryable.QueryBuilder.Parameters.AddRange(sqlObj2.Value); var exp = queryable.QueryBuilder.GetExpressionValue(joinExpression, ResolveExpressType.WhereMultiple); queryable.QueryBuilder.JoinQueryInfos.Add(new JoinQueryInfo { JoinIndex = 0, JoinType = joinType, JoinWhere = exp.GetResultString(), TableName = sqlBuilder.GetPackTable(sql2, shortName2) }); return queryable; } #endregion 9-12 public virtual ISugarQueryable UnionAll(params ISugarQueryable[] queryables) where T : class, new() { var sqlBuilder = InstanceFactory.GetSqlbuilder(this.Context.CurrentConnectionConfig); Check.Exception(queryables.IsNullOrEmpty(), "UnionAll.queryables is null "); var i = 1; var allItems = new List>>(); foreach (var item in queryables) { var sqlObj = item.ToSql(); var sql = sqlObj.Key; UtilMethods.RepairReplicationParameters(ref sql, sqlObj.Value.ToArray(), i); if (sqlObj.Value.HasValue()) allItems.Add(new KeyValuePair>(sql, sqlObj.Value)); else allItems.Add(new KeyValuePair>(sql, new List())); i++; } var allSql = sqlBuilder.GetUnionAllSql(allItems.Select(it => it.Key).ToList()); var allParameters = allItems.SelectMany(it => it.Value).ToArray(); var resulut = this.Context.Queryable().AS(UtilMethods.GetPackTable(allSql, "unionTable")).With(SqlWith.Null); resulut.AddParameters(allParameters); return resulut.Select(sqlBuilder.SqlSelectAll); } public virtual ISugarQueryable UnionAll(List> queryables) where T : class, new() { Check.Exception(queryables.IsNullOrEmpty(), "UnionAll.queryables is null "); return UnionAll(queryables.ToArray()); } #endregion Queryable #region SqlQueryable public ISugarQueryable SqlQueryable(string sql) where T : class, new() { var sqlBuilder = InstanceFactory.GetSqlbuilder(this.Context.CurrentConnectionConfig); return this.Context.Queryable().AS(sqlBuilder.GetPackTable(sql, sqlBuilder.GetDefaultShortName())).With(SqlWith.Null).Select(sqlBuilder.GetDefaultShortName() + ".*"); } #endregion SqlQueryable #region Insertable public virtual IInsertable Insertable(T[] insertObjs) where T : class, new() { InitMppingInfo(); var result = this.CreateInsertable(insertObjs); return result; } public virtual IInsertable Insertable(List insertObjs) where T : class, new() { Check.ArgumentNullException(insertObjs, "Insertable.insertObjs can't be null"); return this.Context.Insertable(insertObjs.ToArray()); } public virtual IInsertable Insertable(T insertObj) where T : class, new() { return this.Context.Insertable(new T[] { insertObj }); } public virtual IInsertable Insertable(Dictionary columnDictionary) where T : class, new() { InitMppingInfo(); Check.Exception(columnDictionary == null || columnDictionary.Count == 0, "Insertable.columnDictionary can't be null"); var insertObject = this.Context.Utilities.DeserializeObject(this.Context.Utilities.SerializeObject(columnDictionary)); var columns = columnDictionary.Select(it => it.Key).ToList(); return this.Context.Insertable(insertObject).InsertColumns(it => columns.Any(c => it.Equals(c, StringComparison.CurrentCultureIgnoreCase))); ; } public virtual IInsertable Insertable(dynamic insertDynamicObject) where T : class, new() { InitMppingInfo(); if (insertDynamicObject is T) { return this.Context.Insertable((T)insertDynamicObject); } else { var columns = ((object)insertDynamicObject).GetType().GetProperties().Select(it => it.Name).ToList(); Check.Exception(columns.IsNullOrEmpty(), "Insertable.updateDynamicObject can't be null"); T insertObject = this.Context.Utilities.DeserializeObject(this.Context.Utilities.SerializeObject(insertDynamicObject)); return this.Context.Insertable(insertObject).InsertColumns(it => columns.Any(c => it.Equals(c, StringComparison.CurrentCultureIgnoreCase))); } } #endregion Insertable #region Deleteable public virtual IDeleteable Deleteable() where T : class, new() { InitMppingInfo(); var result = this.CreateDeleteable(); return result; } public virtual IDeleteable Deleteable(Expression> expression) where T : class, new() { InitMppingInfo(); return this.Context.Deleteable().Where(expression); } public virtual IDeleteable Deleteable(dynamic primaryKeyValue) where T : class, new() { InitMppingInfo(); return this.Context.Deleteable().In(primaryKeyValue); } public virtual IDeleteable Deleteable(dynamic[] primaryKeyValues) where T : class, new() { InitMppingInfo(); return this.Context.Deleteable().In(primaryKeyValues); } public virtual IDeleteable Deleteable(List pkValue) where T : class, new() { InitMppingInfo(); return this.Context.Deleteable().In(pkValue); } public virtual IDeleteable Deleteable(T deleteObj) where T : class, new() { InitMppingInfo(); return this.Context.Deleteable().Where(deleteObj); } public virtual IDeleteable Deleteable(List deleteObjs) where T : class, new() { InitMppingInfo(); return this.Context.Deleteable().Where(deleteObjs); } #endregion Deleteable #region Updateable public virtual IUpdateable Updateable(T[] UpdateObjs) where T : class, new() { InitMppingInfo(); var result = this.CreateUpdateable(UpdateObjs); return result; } public virtual IUpdateable Updateable(List UpdateObjs) where T : class, new() { Check.ArgumentNullException(UpdateObjs, "Updateable.UpdateObjs can't be null"); return Updateable(UpdateObjs.ToArray()); } public virtual IUpdateable Updateable(T UpdateObj) where T : class, new() { return this.Context.Updateable(new T[] { UpdateObj }); } public virtual IUpdateable Updateable() where T : class, new() { return this.Context.Updateable(new T[] { new T() }); } public virtual IUpdateable Updateable(Dictionary columnDictionary) where T : class, new() { InitMppingInfo(); Check.Exception(columnDictionary == null || columnDictionary.Count == 0, "Updateable.columnDictionary can't be null"); var updateObject = this.Context.Utilities.DeserializeObject(this.Context.Utilities.SerializeObject(columnDictionary)); var columns = columnDictionary.Select(it => it.Key).ToList(); return this.Context.Updateable(updateObject).UpdateColumns(it => columns.Any(c => it.Equals(c, StringComparison.CurrentCultureIgnoreCase))); } public virtual IUpdateable Updateable(dynamic updateDynamicObject) where T : class, new() { InitMppingInfo(); if (updateDynamicObject is T) { return this.Context.Updateable((T)updateDynamicObject); } else { var columns = ((object)updateDynamicObject).GetType().GetProperties().Select(it => it.Name).ToList(); Check.Exception(columns.IsNullOrEmpty(), "Updateable.updateDynamicObject can't be null"); T updateObject = this.Context.Utilities.DeserializeObject(this.Context.Utilities.SerializeObject(updateDynamicObject)); return this.Context.Updateable(updateObject).UpdateColumns(it => columns.Any(c => it.Equals(c, StringComparison.CurrentCultureIgnoreCase))); ; } } #endregion Updateable #region DbFirst public virtual IDbFirst DbFirst { get { var dbFirst = InstanceFactory.GetDbFirst(this.Context.CurrentConnectionConfig); dbFirst.Context = this.Context; dbFirst.Init(); return dbFirst; } } #endregion DbFirst #region CodeFirst public virtual ICodeFirst CodeFirst { get { var codeFirst = InstanceFactory.GetCodeFirst(this.Context.CurrentConnectionConfig); codeFirst.Context = this.Context; return codeFirst; } } #endregion CodeFirst #region Db Maintenance public virtual IDbMaintenance DbMaintenance { get { if (this.Context._DbMaintenance == null) { var maintenance = InstanceFactory.GetDbMaintenance(this.Context.CurrentConnectionConfig); this.Context._DbMaintenance = maintenance; maintenance.Context = this.Context; } return this.Context._DbMaintenance; } } #endregion Db Maintenance #region Entity Maintenance [Obsolete("Use SqlSugarClient.EntityMaintenance")] public virtual EntityMaintenance EntityProvider { get { return this.Context.EntityMaintenance; } set { this.Context.EntityMaintenance = value; } } public virtual EntityMaintenance EntityMaintenance { get { if (this.Context._EntityProvider == null) { this.Context._EntityProvider = new EntityMaintenance { Context = this.Context }; } return this.Context._EntityProvider; } set { this.Context._EntityProvider = value; } } #endregion Entity Maintenance #region Gobal Filter public virtual QueryFilterProvider QueryFilter { get { if (this.Context._QueryFilterProvider == null) { this.Context._QueryFilterProvider = new QueryFilterProvider { Context = this.Context }; } return this.Context._QueryFilterProvider; } set { this.Context._QueryFilterProvider = value; } } #endregion Gobal Filter #region SimpleClient [Obsolete("Use SqlSugarClient.GetSimpleClient() Or SqlSugarClient.GetSimpleClient() ")] public virtual SimpleClient GetSimpleClient() where T : class, new() { return new SimpleClient(this.Context); } public virtual SimpleClient GetSimpleClient() { if (this.Context._SimpleClient == null) this.Context._SimpleClient = new SimpleClient(this.Context); return this.Context._SimpleClient; } #endregion SimpleClient #region Dispose OR Close public virtual void Close() { if (this.Context.Ado != null) this.Context.Ado.Close(); } public virtual void Open() { if (this.Context.Ado != null) this.Context.Ado.Open(); } public virtual void Dispose() { if (this.Context.Ado != null) this.Context.Ado.Dispose(); } #endregion Dispose OR Close } }