diff --git a/AmalgamationTool/DynamORM.Amalgamation.cs b/AmalgamationTool/DynamORM.Amalgamation.cs index 062b17f..d364bc4 100644 --- a/AmalgamationTool/DynamORM.Amalgamation.cs +++ b/AmalgamationTool/DynamORM.Amalgamation.cs @@ -33,31 +33,31 @@ * * DYNAMORM_OMMIT_TRYPARSE - Remove TryParse helpers (also applies DYNAMORM_OMMIT_GENERICEXECUTION) */ -using System; -using System.Collections; +using DynamORM.Builders.Extensions; +using DynamORM.Builders.Implementation; +using DynamORM.Builders; +using DynamORM.Helpers.Dynamics; +using DynamORM.Helpers; +using DynamORM.Mapper; using System.Collections.Concurrent; using System.Collections.Generic; using System.Collections.Specialized; -using System.Data; +using System.Collections; using System.Data.Common; +using System.Data; using System.Dynamic; using System.IO; -using System.Linq; using System.Linq.Expressions; +using System.Linq; using System.Reflection; using System.Runtime.CompilerServices; +using System.Runtime.InteropServices; using System.Runtime.Serialization; using System.Text; -using DynamORM.Builders; -using DynamORM.Builders.Extensions; -using DynamORM.Builders.Implementation; -using DynamORM.Helpers; -using DynamORM.Helpers.Dynamics; -using DynamORM.Mapper; +using System; [module: System.Diagnostics.CodeAnalysis.SuppressMessage("StyleCop.CSharp.MaintainabilityRules", "SA1402:FileMayOnlyContainASingleClass", Justification = "This is a generated file which generates all the necessary support classes.")] [module: System.Diagnostics.CodeAnalysis.SuppressMessage("StyleCop.CSharp.MaintainabilityRules", "SA1403:FileMayOnlyContainASingleNamespace", Justification = "This is a generated file which generates all the necessary support classes.")] - namespace DynamORM { /// Small utility class to manage single columns. @@ -2687,11 +2687,14 @@ namespace DynamORM /// Database supports limit offset syntax (SELECT ... FROM ... LIMIT x OFFSET y). SupportLimitOffset = 0x00000040, + /// Database supports limit offset syntax (SELECT FIRST x SKIP y ... FROM ...). + SupportFirstSkip = 0x00000020, + /// Database support standard schema. SupportSchema = 0x00000010, /// Database support stored procedures (EXEC procedure ...). - SupportStoredProcedures = 0x00000020, + SupportStoredProcedures = 0x00000100, /// Debug option allowing to enable command dumps by default. DumpCommands = 0x01000000, @@ -4101,7 +4104,7 @@ namespace DynamORM /// Returns true if it does. public static bool IsGenericEnumerable(this Type type) { - return type.IsGenericType && type.GetInterfaces().Any(t => t.GetGenericTypeDefinition() == typeof(IEnumerable<>)); + return type.IsGenericType && type.GetInterfaces().Any(t => t.IsGenericType && t.GetGenericTypeDefinition() == typeof(IEnumerable<>)); } /// Check if type implements IEnumerable<> interface. @@ -5807,7 +5810,7 @@ namespace DynamORM } namespace Builders - { + { /// Dynamic delete query builder interface. /// This interface it publically available. Implementation should be hidden. public interface IDynamicDeleteQueryBuilder : IDynamicQueryBuilder @@ -5815,7 +5818,7 @@ namespace DynamORM /// Execute this builder. /// Result of an execution.. int Execute(); - + /// /// Adds to the 'Where' clause the contents obtained from parsing the dynamic lambda expression given. The condition /// is parsed to the appropriate syntax, where the specific customs virtual methods supported by the parser are used @@ -5827,25 +5830,25 @@ namespace DynamORM /// The specification. /// This instance to permit chaining. IDynamicDeleteQueryBuilder Where(Func func); - + /// Add where condition. /// Condition column with operator and value. /// Builder instance. IDynamicDeleteQueryBuilder Where(DynamicColumn column); - + /// Add where condition. /// Condition column. /// Condition operator. /// Condition value. /// Builder instance. IDynamicDeleteQueryBuilder Where(string column, DynamicColumn.CompareOperator op, object value); - + /// Add where condition. /// Condition column. /// Condition value. /// Builder instance. IDynamicDeleteQueryBuilder Where(string column, object value); - + /// Add where condition. /// Set conditions as properties and values of an object. /// If true use schema to determine key columns and ignore those which @@ -5853,7 +5856,8 @@ namespace DynamORM /// Builder instance. IDynamicDeleteQueryBuilder Where(object conditions, bool schema = false); } - + + /// Dynamic insert query builder interface. /// This interface it publically available. Implementation should be hidden. public interface IDynamicInsertQueryBuilder : IDynamicQueryBuilder @@ -5861,7 +5865,7 @@ namespace DynamORM /// Execute this builder. /// Result of an execution.. int Execute(); - + /// /// Specifies the columns to insert using the dynamic lambda expressions given. Each expression correspond to one /// column, and can: @@ -5872,59 +5876,61 @@ namespace DynamORM /// The specifications. /// This instance to permit chaining. IDynamicInsertQueryBuilder Values(Func fn, params Func[] func); - + /// Add insert fields. /// Insert column. /// Insert value. /// Builder instance. IDynamicInsertQueryBuilder Insert(string column, object value); - + /// Add insert fields. /// Set insert value as properties and values of an object. /// Builder instance. IDynamicInsertQueryBuilder Insert(object o); } - + + /// Dynamic query builder base interface. /// This interface it publically available. Implementation should be hidden. public interface IDynamicQueryBuilder : IExtendedDisposable { /// Gets instance. DynamicDatabase Database { get; } - + /// Gets tables information. IList Tables { get; } - + /// Gets the tables used in this builder. IDictionary Parameters { get; } - + /// Gets or sets a value indicating whether add virtual parameters. bool VirtualMode { get; set; } - + /// Gets a value indicating whether database supports standard schema. bool SupportSchema { get; } - + /// Fill command with query. /// Command to fill. /// Filled instance of . IDbCommand FillCommand(IDbCommand command); - + /// /// Generates the text this command will execute against the underlying database. /// /// The text to execute against the underlying database. /// This method must be override by derived classes. string CommandText(); - + /// Gets or sets the on create temporary parameter actions. /// This is exposed to allow setting schema of column. List> OnCreateTemporaryParameter { get; set; } - + /// Gets or sets the on create real parameter actions. /// This is exposed to allow modification of parameter. List> OnCreateParameter { get; set; } } - + + /// Dynamic select query builder interface. /// This interface it publically available. Implementation should be hidden. public interface IDynamicSelectQueryBuilder : IDynamicQueryBuilder ////, IEnumerable @@ -5932,32 +5938,32 @@ namespace DynamORM /// Execute this builder. /// Enumerator of objects expanded from query. IEnumerable Execute(); - + /// Execute this builder and map to given type. /// Type of object to map on. /// Enumerator of objects expanded from query. IEnumerable Execute() where T : class; - + /// Execute this builder as a data reader. /// Action containing reader. void ExecuteDataReader(Action reader); - + /// Returns a single result. /// Result of a query. object Scalar(); - -#if !DYNAMORM_OMMIT_GENERICEXECUTION && !DYNAMORM_OMMIT_TRYPARSE - + + #if !DYNAMORM_OMMIT_GENERICEXECUTION && !DYNAMORM_OMMIT_TRYPARSE + /// Returns a single result. /// Type to parse to. /// Default value. /// Result of a query. T ScalarAs(T defaultValue = default(T)); - -#endif - + + #endif + #region From/Join - + /// /// Adds to the 'From' clause the contents obtained by parsing the dynamic lambda expressions given. The supported /// formats are: @@ -5970,7 +5976,7 @@ namespace DynamORM /// The specification. /// This instance to permit chaining. IDynamicSelectQueryBuilder From(Func fn, params Func[] func); - + /// /// Adds to the 'Join' clause the contents obtained by parsing the dynamic lambda expressions given. The supported /// formats are: @@ -5988,11 +5994,11 @@ namespace DynamORM /// The specification. /// This instance to permit chaining. IDynamicSelectQueryBuilder Join(params Func[] func); - + #endregion From/Join - + #region Where - + /// /// Adds to the 'Where' clause the contents obtained from parsing the dynamic lambda expression given. The condition /// is parsed to the appropriate syntax, where the specific customs virtual methods supported by the parser are used @@ -6004,36 +6010,36 @@ namespace DynamORM /// The specification. /// This instance to permit chaining. IDynamicSelectQueryBuilder Where(Func func); - + /// Add where condition. /// Condition column with operator and value. /// Builder instance. IDynamicSelectQueryBuilder Where(DynamicColumn column); - + /// Add where condition. /// Condition column. /// Condition operator. /// Condition value. /// Builder instance. IDynamicSelectQueryBuilder Where(string column, DynamicColumn.CompareOperator op, object value); - + /// Add where condition. /// Condition column. /// Condition value. /// Builder instance. IDynamicSelectQueryBuilder Where(string column, object value); - + /// Add where condition. /// Set conditions as properties and values of an object. /// If true use schema to determine key columns and ignore those which /// aren't keys. /// Builder instance. IDynamicSelectQueryBuilder Where(object conditions, bool schema = false); - + #endregion Where - + #region Select - + /// /// Adds to the 'Select' clause the contents obtained by parsing the dynamic lambda expressions given. The supported /// formats are: @@ -6047,23 +6053,23 @@ namespace DynamORM /// The specification. /// This instance to permit chaining. IDynamicSelectQueryBuilder Select(Func fn, params Func[] func); - + /// Add select columns. /// Columns to add to object. /// Builder instance. IDynamicSelectQueryBuilder SelectColumn(params DynamicColumn[] columns); - + /// Add select columns. /// Columns to add to object. /// Column format consist of Column Name, Alias and /// Aggregate function in this order separated by ':'. /// Builder instance. IDynamicSelectQueryBuilder SelectColumn(params string[] columns); - + #endregion Select - + #region GroupBy - + /// /// Adds to the 'Group By' clause the contents obtained from from parsing the dynamic lambda expression given. /// @@ -6071,23 +6077,23 @@ namespace DynamORM /// The specification. /// This instance to permit chaining. IDynamicSelectQueryBuilder GroupBy(Func fn, params Func[] func); - + /// Add select columns. /// Columns to group by. /// Builder instance. IDynamicSelectQueryBuilder GroupByColumn(params DynamicColumn[] columns); - + /// Add select columns. /// Columns to group by. /// Column format consist of Column Name and /// Alias in this order separated by ':'. /// Builder instance. IDynamicSelectQueryBuilder GroupByColumn(params string[] columns); - + #endregion GroupBy - + #region OrderBy - + /// /// Adds to the 'Order By' clause the contents obtained from from parsing the dynamic lambda expression given. It /// accepts a multipart column specification followed by an optional Ascending() or Descending() virtual methods @@ -6098,46 +6104,47 @@ namespace DynamORM /// The specification. /// This instance to permit chaining. IDynamicSelectQueryBuilder OrderBy(Func fn, params Func[] func); - + /// Add select columns. /// Columns to order by. /// Builder instance. IDynamicSelectQueryBuilder OrderByColumn(params DynamicColumn[] columns); - + /// Add select columns. /// Columns to order by. /// Column format consist of Column Name and /// Alias in this order separated by ':'. /// Builder instance. IDynamicSelectQueryBuilder OrderByColumn(params string[] columns); - + #endregion OrderBy - + #region Top/Limit/Offset/Distinct - + /// Set top if database support it. /// How many objects select. /// Builder instance. IDynamicSelectQueryBuilder Top(int? top); - + /// Set top if database support it. /// How many objects select. /// Builder instance. IDynamicSelectQueryBuilder Limit(int? limit); - + /// Set top if database support it. /// How many objects skip selecting. /// Builder instance. IDynamicSelectQueryBuilder Offset(int? offset); - + /// Set distinct mode. /// Distinct mode. /// Builder instance. IDynamicSelectQueryBuilder Distinct(bool distinct = true); - + #endregion Top/Limit/Offset/Distinct } - + + /// Dynamic update query builder interface. /// This interface it publically available. Implementation should be hidden. public interface IDynamicUpdateQueryBuilder : IDynamicQueryBuilder @@ -6145,24 +6152,24 @@ namespace DynamORM /// Execute this builder. /// Result of an execution.. int Execute(); - + #region Update - + /// Add update value or where condition using schema. /// Update or where column name. /// Column value. /// Builder instance. IDynamicUpdateQueryBuilder Update(string column, object value); - + /// Add update values and where condition columns using schema. /// Set values or conditions as properties and values of an object. /// Builder instance. IDynamicUpdateQueryBuilder Update(object conditions); - + #endregion Update - + #region Values - + /// /// Specifies the columns to update using the dynamic lambda expressions given. Each expression correspond to one /// column, and can: @@ -6172,22 +6179,22 @@ namespace DynamORM /// The specifications. /// This instance to permit chaining. IDynamicUpdateQueryBuilder Set(params Func[] func); - + /// Add insert fields. /// Insert column. /// Insert value. /// Builder instance. IDynamicUpdateQueryBuilder Values(string column, object value); - + /// Add insert fields. /// Set insert value as properties and values of an object. /// Builder instance. IDynamicUpdateQueryBuilder Values(object o); - + #endregion Values - + #region Where - + /// /// Adds to the 'Where' clause the contents obtained from parsing the dynamic lambda expression given. The condition /// is parsed to the appropriate syntax, where the specific customs virtual methods supported by the parser are used @@ -6199,87 +6206,90 @@ namespace DynamORM /// The specification. /// This instance to permit chaining. IDynamicUpdateQueryBuilder Where(Func func); - + /// Add where condition. /// Condition column with operator and value. /// Builder instance. IDynamicUpdateQueryBuilder Where(DynamicColumn column); - + /// Add where condition. /// Condition column. /// Condition operator. /// Condition value. /// Builder instance. IDynamicUpdateQueryBuilder Where(string column, DynamicColumn.CompareOperator op, object value); - + /// Add where condition. /// Condition column. /// Condition value. /// Builder instance. IDynamicUpdateQueryBuilder Where(string column, object value); - + /// Add where condition. /// Set conditions as properties and values of an object. /// If true use schema to determine key columns and ignore those which /// aren't keys. /// Builder instance. IDynamicUpdateQueryBuilder Where(object conditions, bool schema = false); - + #endregion Where } - + + /// Interface describing parameter info. public interface IParameter : IExtendedDisposable { /// Gets the parameter position in command. /// Available after filling the command. int Ordinal { get; } - + /// Gets the parameter temporary name. string Name { get; } - + /// Gets or sets the parameter value. object Value { get; set; } - + /// Gets or sets a value indicating whether name of temporary parameter is well known. bool WellKnown { get; set; } - + /// Gets or sets a value indicating whether this is virtual. bool Virtual { get; set; } - + /// Gets or sets the parameter schema information. DynamicSchemaColumn? Schema { get; set; } } - + + /// Interface describing table information. public interface ITableInfo : IExtendedDisposable { /// Gets table owner name. string Owner { get; } - + /// Gets table name. string Name { get; } - + /// Gets table alias. string Alias { get; } - + /// Gets table schema. Dictionary Schema { get; } } + namespace Extensions - { + { internal static class DynamicModifyBuilderExtensions { internal static T Table(this T builder, Func func) where T : DynamicModifyBuilder { if (func == null) throw new ArgumentNullException("Function cannot be null."); - + using (DynamicParser parser = DynamicParser.Parse(func)) { object result = parser.Result; - + // If the expression result is string. if (result is string) return builder.Table((string)result); @@ -6289,38 +6299,38 @@ namespace DynamORM { // Or if it resolves to a dynamic node DynamicParser.Node node = (DynamicParser.Node)result; - + string owner = null; string main = null; - + while (true) { // Deny support for the AS() virtual method... if (node is DynamicParser.Node.Method && ((DynamicParser.Node.Method)node).Name.ToUpper() == "AS") throw new ArgumentException(string.Format("Alias is not supported on modification builders. (Parsing: {0})", result)); - + // Support for table specifications... if (node is DynamicParser.Node.GetMember) { if (owner != null) throw new ArgumentException(string.Format("Owner '{0}.{1}' is already set when parsing '{2}'.", owner, main, result)); - + if (main != null) owner = ((DynamicParser.Node.GetMember)node).Name; else main = ((DynamicParser.Node.GetMember)node).Name; - + node = node.Host; continue; } - + // Support for generic sources... if (node is DynamicParser.Node.Invoke) { if (owner == null && main == null) { DynamicParser.Node.Invoke invoke = (DynamicParser.Node.Invoke)node; - + if (invoke.Arguments.Length == 1 && invoke.Arguments[0] is Type) return builder.Table((Type)invoke.Arguments[0]); else if (invoke.Arguments.Length == 1 && invoke.Arguments[0] is String) @@ -6333,51 +6343,51 @@ namespace DynamORM else if (main != null) throw new ArgumentException(string.Format("Main '{0}' is already set when parsing '{1}'.", main, result)); } - + if (!string.IsNullOrEmpty(main)) return builder.Table(string.Format("{0}{1}", string.IsNullOrEmpty(owner) ? string.Empty : string.Format("{0}.", owner), main)); } } - + throw new ArgumentException(string.Format("Unable to set table parsing '{0}'", result)); } } - + internal static T Table(this T builder, string tableName, Dictionary schema = null) where T : DynamicModifyBuilder { Tuple tuple = tableName.Validated("Table Name").SplitSomethingAndAlias(); - + if (!string.IsNullOrEmpty(tuple.Item2)) throw new ArgumentException(string.Format("Can not use aliases in INSERT steatement. ({0})", tableName), "tableName"); - + string[] parts = tuple.Item1.Split('.'); - + if (parts.Length > 2) throw new ArgumentException(string.Format("Table name can consist only from name or owner and name. ({0})", tableName), "tableName"); - + builder.Tables.Clear(); builder.Tables.Add(new DynamicQueryBuilder.TableInfo(builder.Database, builder.Database.StripName(parts.Last()).Validated("Table"), null, parts.Length == 2 ? builder.Database.StripName(parts.First()).Validated("Owner", canbeNull: true) : null)); - + if (schema != null) (builder.Tables[0] as DynamicQueryBuilder.TableInfo).Schema = schema; - + return builder; } - + internal static T Table(this T builder, Type type) where T : DynamicQueryBuilder { if (type.IsAnonymous()) throw new InvalidOperationException(string.Format("Cant assign anonymous type as a table ({0}).", type.FullName)); - + DynamicTypeMap mapper = DynamicMapperCache.GetMapper(type); - + if (mapper == null) throw new InvalidOperationException("Cant assign unmapable type as a table."); - + if (builder is DynamicModifyBuilder) { builder.Tables.Clear(); @@ -6385,34 +6395,35 @@ namespace DynamORM } else if (builder is DynamicSelectQueryBuilder) (builder as DynamicSelectQueryBuilder).From(x => x(type)); - + return builder; } } - + + internal static class DynamicWhereQueryExtensions { #region Where - + internal static T InternalWhere(this T builder, Func func) where T : DynamicQueryBuilder, DynamicQueryBuilder.IQueryWithWhere { return builder.InternalWhere(false, false, func); } - + internal static T InternalWhere(this T builder, bool addBeginBrace, bool addEndBrace, Func func) where T : DynamicQueryBuilder, DynamicQueryBuilder.IQueryWithWhere { if (func == null) throw new ArgumentNullException("Array of functions cannot be null."); - + using (DynamicParser parser = DynamicParser.Parse(func)) { string condition = null; bool and = true; - + object result = parser.Result; if (result is string) { condition = (string)result; - + if (condition.ToUpper().IndexOf("OR") == 0) { and = false; @@ -6435,19 +6446,19 @@ namespace DynamORM object[] args = ((DynamicParser.Node.Method)node).Arguments; if (args == null) throw new ArgumentNullException("arg", string.Format("{0} is not a parameterless method.", name)); if (args.Length != 1) throw new ArgumentException(string.Format("{0} requires one and only one parameter: {1}.", name, args.Sketch())); - + and = name == "AND" ? true : false; result = args[0]; } } - + // Just parsing the contents now... condition = builder.Parse(result, pars: builder.Parameters).Validated("Where condition"); } - + if (addBeginBrace) builder.OpenBracketsCount++; if (addEndBrace) builder.OpenBracketsCount--; - + if (builder.WhereCondition == null) builder.WhereCondition = string.Format("{0}{1}{2}", addBeginBrace ? "(" : string.Empty, condition, addEndBrace ? ")" : string.Empty); @@ -6455,27 +6466,27 @@ namespace DynamORM builder.WhereCondition = string.Format("{0} {1} {2}{3}{4}", builder.WhereCondition, and ? "AND" : "OR", addBeginBrace ? "(" : string.Empty, condition, addEndBrace ? ")" : string.Empty); } - + return builder; } - + internal static T InternalWhere(this T builder, DynamicColumn column) where T : DynamicQueryBuilder, DynamicQueryBuilder.IQueryWithWhere { bool virt = builder.VirtualMode; if (column.VirtualColumn.HasValue) builder.VirtualMode = column.VirtualColumn.Value; - + Action modParam = (p) => { if (column.Schema.HasValue) p.Schema = column.Schema; - + if (!p.Schema.HasValue) p.Schema = column.Schema ?? builder.GetColumnFromSchema(column.ColumnName); }; - + builder.CreateTemporaryParameterAction(modParam); - + // It's kind of uglu, but... well it works. if (column.Or) switch (column.Operator) @@ -6507,32 +6518,32 @@ namespace DynamORM case DynamicColumn.CompareOperator.Gte: builder.InternalWhere(column.BeginBlock, column.EndBlock, x => x(builder.FixObjectName(column.ColumnName)) >= column.Value); break; case DynamicColumn.CompareOperator.Between: builder.InternalWhere(column.BeginBlock, column.EndBlock, x => x(builder.FixObjectName(column.ColumnName)).Between(column.Value)); break; } - + builder.OnCreateTemporaryParameter.Remove(modParam); builder.VirtualMode = virt; - + return builder; } - + internal static T InternalWhere(this T builder, string column, DynamicColumn.CompareOperator op, object value) where T : DynamicQueryBuilder, DynamicQueryBuilder.IQueryWithWhere { if (value is DynamicColumn) { DynamicColumn v = (DynamicColumn)value; - + if (string.IsNullOrEmpty(v.ColumnName)) v.ColumnName = column; - + return builder.InternalWhere(v); } else if (value is IEnumerable) { foreach (DynamicColumn v in (IEnumerable)value) builder.InternalWhere(v); - + return builder; } - + return builder.InternalWhere(new DynamicColumn { ColumnName = column, @@ -6540,12 +6551,12 @@ namespace DynamORM Value = value }); } - + internal static T InternalWhere(this T builder, string column, object value) where T : DynamicQueryBuilder, DynamicQueryBuilder.IQueryWithWhere { return builder.InternalWhere(column, DynamicColumn.CompareOperator.Eq, value); } - + internal static T InternalWhere(this T builder, object conditions, bool schema = false) where T : DynamicQueryBuilder, DynamicQueryBuilder.IQueryWithWhere { if (conditions is DynamicColumn) @@ -6554,50 +6565,52 @@ namespace DynamORM { foreach (DynamicColumn v in (IEnumerable)conditions) builder.InternalWhere(v); - + return builder; } - + IDictionary dict = conditions.ToDictionary(); DynamicTypeMap mapper = DynamicMapperCache.GetMapper(conditions.GetType()); string table = dict.TryGetValue("_table").NullOr(x => x.ToString(), string.Empty); - + foreach (KeyValuePair condition in dict) { if (mapper.Ignored.Contains(condition.Key) || condition.Key == "_table") continue; - + string colName = mapper != null ? mapper.PropertyMap.TryGetValue(condition.Key) ?? condition.Key : condition.Key; - + DynamicSchemaColumn? col = null; - + // This should be used on typed queries or update/delete steatements, which usualy operate on a single table. if (schema) { col = builder.GetColumnFromSchema(colName, mapper, table); - + if ((!col.HasValue || !col.Value.IsKey) && (mapper == null || mapper.ColumnsMap.TryGetValue(colName).NullOr(m => m.Ignore || m.Column.NullOr(c => !c.IsKey, true), true))) continue; - + colName = col.HasValue ? col.Value.Name : colName; } - + if (!string.IsNullOrEmpty(table)) builder.InternalWhere(x => x(builder.FixObjectName(string.Format("{0}.{1}", table, colName))) == condition.Value); else builder.InternalWhere(x => x(builder.FixObjectName(colName)) == condition.Value); } - + return builder; } - + #endregion Where } + + } namespace Implementation - { + { /// Implementation of dynamic delete query builder. internal class DynamicDeleteQueryBuilder : DynamicModifyBuilder, IDynamicDeleteQueryBuilder, DynamicQueryBuilder.IQueryWithWhere { @@ -6609,7 +6622,7 @@ namespace DynamORM : base(db) { } - + /// /// Initializes a new instance of the class. /// @@ -6619,7 +6632,7 @@ namespace DynamORM : base(db, tableName) { } - + /// Generates the text this command will execute against the underlying database. /// The text to execute against the underlying database. /// This method must be override by derived classes. @@ -6632,9 +6645,9 @@ namespace DynamORM string.IsNullOrEmpty(WhereCondition) ? string.Empty : " WHERE ", WhereCondition); } - + #region Where - + /// /// Adds to the 'Where' clause the contents obtained from parsing the dynamic lambda expression given. The condition /// is parsed to the appropriate syntax, where the specific customs virtual methods supported by the parser are used @@ -6649,7 +6662,7 @@ namespace DynamORM { return this.InternalWhere(func); } - + /// Add where condition. /// Condition column with operator and value. /// Builder instance. @@ -6657,7 +6670,7 @@ namespace DynamORM { return this.InternalWhere(column); } - + /// Add where condition. /// Condition column. /// Condition operator. @@ -6667,7 +6680,7 @@ namespace DynamORM { return this.InternalWhere(column, op, value); } - + /// Add where condition. /// Condition column. /// Condition value. @@ -6676,7 +6689,7 @@ namespace DynamORM { return this.InternalWhere(column, value); } - + /// Add where condition. /// Set conditions as properties and values of an object. /// If true use schema to determine key columns and ignore those which @@ -6686,16 +6699,17 @@ namespace DynamORM { return this.InternalWhere(conditions, schema); } - + #endregion Where } - + + /// Implementation of dynamic insert query builder. internal class DynamicInsertQueryBuilder : DynamicModifyBuilder, IDynamicInsertQueryBuilder { private string _columns; private string _values; - + /// /// Initializes a new instance of the class. /// @@ -6704,7 +6718,7 @@ namespace DynamORM : base(db) { } - + /// /// Initializes a new instance of the class. /// @@ -6714,7 +6728,7 @@ namespace DynamORM : base(db, tableName) { } - + /// Generates the text this command will execute against the underlying database. /// The text to execute against the underlying database. /// This method must be override by derived classes. @@ -6725,9 +6739,9 @@ namespace DynamORM string.IsNullOrEmpty(info.Owner) ? string.Empty : string.Format("{0}.", Database.DecorateName(info.Owner)), Database.DecorateName(info.Name), _columns, _values); } - + #region Insert - + /// /// Specifies the columns to insert using the dynamic lambda expressions given. Each expression correspond to one /// column, and can: @@ -6741,42 +6755,42 @@ namespace DynamORM { if (fn == null) throw new ArgumentNullException("Array of specifications cannot be null."); - + int index = InsertFunc(-1, fn); - + if (func != null) foreach (Func f in func) index = InsertFunc(index, f); - + return this; } - + private int InsertFunc(int index, Func f) { index++; - + if (f == null) throw new ArgumentNullException(string.Format("Specification #{0} cannot be null.", index)); - + using (DynamicParser parser = DynamicParser.Parse(f)) { object result = parser.Result; if (result == null) throw new ArgumentException(string.Format("Specification #{0} resolves to null.", index)); - + string main = null; string value = null; string str = null; - + // When 'x => x.Table.Column = value' or 'x => x.Column = value'... if (result is DynamicParser.Node.SetMember) { DynamicParser.Node.SetMember node = (DynamicParser.Node.SetMember)result; - + DynamicSchemaColumn? col = GetColumnFromSchema(node.Name); main = Database.DecorateName(node.Name); value = Parse(node.Value, ref col, pars: Parameters, nulls: true); - + _columns = _columns == null ? main : string.Format("{0}, {1}", _columns, main); _values = _values == null ? value : string.Format("{0}, {1}", _values, value); return index; @@ -6786,7 +6800,7 @@ namespace DynamORM Insert(result); return index; } - + // Other specifications are considered invalid... string err = string.Format("Specification '{0}' is invalid.", result); str = Parse(result); @@ -6794,7 +6808,7 @@ namespace DynamORM throw new ArgumentException(err); } } - + /// Add insert fields. /// Insert column. /// Insert value. @@ -6804,20 +6818,20 @@ namespace DynamORM if (value is DynamicColumn) { DynamicColumn v = (DynamicColumn)value; - + if (string.IsNullOrEmpty(v.ColumnName)) v.ColumnName = column; - + return Insert(v); } - + return Insert(new DynamicColumn { ColumnName = column, Value = value, }); } - + /// Add insert fields. /// Set insert value as properties and values of an object. /// Builder instance. @@ -6827,19 +6841,19 @@ namespace DynamORM { DynamicColumn column = (DynamicColumn)o; DynamicSchemaColumn? col = column.Schema ?? GetColumnFromSchema(column.ColumnName); - + string main = FixObjectName(column.ColumnName, onlyColumn: true); string value = Parse(column.Value, ref col, pars: Parameters, nulls: true); - + _columns = _columns == null ? main : string.Format("{0}, {1}", _columns, main); _values = _values == null ? value : string.Format("{0}, {1}", _values, value); - + return this; } - + IDictionary dict = o.ToDictionary(); DynamicTypeMap mapper = DynamicMapperCache.GetMapper(o.GetType()); - + if (mapper != null) { foreach (KeyValuePair con in dict) @@ -6847,7 +6861,7 @@ namespace DynamORM { string colName = mapper.PropertyMap.TryGetValue(con.Key) ?? con.Key; DynamicPropertyInvoker propMap = mapper.ColumnsMap.TryGetValue(colName.ToLower()); - + if (propMap == null || propMap.Column == null || !propMap.Column.IsNoInsert) Insert(colName, con.Value); } @@ -6855,26 +6869,27 @@ namespace DynamORM else foreach (KeyValuePair con in dict) Insert(con.Key, con.Value); - + return this; } - + #endregion Insert - + #region IExtendedDisposable - + /// Performs application-defined tasks associated with /// freeing, releasing, or resetting unmanaged resources. public override void Dispose() { base.Dispose(); - + _columns = _values = null; } - + #endregion IExtendedDisposable } - + + /// Base query builder for insert/update/delete statements. internal abstract class DynamicModifyBuilder : DynamicQueryBuilder { @@ -6887,7 +6902,7 @@ namespace DynamORM { VirtualMode = false; } - + /// /// Initializes a new instance of the class. /// @@ -6899,7 +6914,7 @@ namespace DynamORM VirtualMode = false; this.Table(tableName); } - + /// Execute this builder. /// Result of an execution.. public virtual int Execute() @@ -6913,7 +6928,8 @@ namespace DynamORM } } } - + + /// Implementation of dynamic query builder base interface. internal abstract class DynamicQueryBuilder : IDynamicQueryBuilder { @@ -6922,15 +6938,15 @@ namespace DynamORM { /// Gets or sets the where condition. string WhereCondition { get; set; } - + /// Gets or sets the amount of not closed brackets in where statement. int OpenBracketsCount { get; set; } } - + private DynamicQueryBuilder _parent = null; - + #region TableInfo - + /// Table information. internal class TableInfo : ITableInfo { @@ -6941,7 +6957,7 @@ namespace DynamORM { IsDisposed = false; } - + /// /// Initializes a new instance of the class. /// @@ -6955,11 +6971,11 @@ namespace DynamORM Name = name; Alias = alias; Owner = owner; - + if (!name.ContainsAny(StringExtensions.InvalidMemberChars)) Schema = db.GetSchema(name, owner: owner); } - + /// /// Initializes a new instance of the class. /// @@ -6971,45 +6987,45 @@ namespace DynamORM : this() { DynamicTypeMap mapper = DynamicMapperCache.GetMapper(type); - + Name = mapper.Table == null || string.IsNullOrEmpty(mapper.Table.Name) ? mapper.Type.Name : mapper.Table.Name; - + Owner = (mapper.Table != null) ? mapper.Table.Owner : owner; Alias = alias; - + Schema = db.GetSchema(type); } - + /// Gets or sets table owner name. public string Owner { get; internal set; } - + /// Gets or sets table name. public string Name { get; internal set; } - + /// Gets or sets table alias. public string Alias { get; internal set; } - + /// Gets or sets table schema. public Dictionary Schema { get; internal set; } - + /// Gets a value indicating whether this instance is disposed. public bool IsDisposed { get; private set; } - + /// Performs application-defined tasks associated with /// freeing, releasing, or resetting unmanaged resources. public virtual void Dispose() { IsDisposed = true; - + if (Schema != null) Schema.Clear(); - + Owner = Name = Alias = null; Schema = null; } } - + /// Generic based table information. /// Type of class that is represented in database. internal class TableInfo : TableInfo @@ -7025,11 +7041,11 @@ namespace DynamORM { } } - + #endregion TableInfo - + #region Parameter - + /// Interface describing parameter info. internal class Parameter : IParameter { @@ -7039,44 +7055,44 @@ namespace DynamORM { IsDisposed = false; } - + /// Gets or sets the parameter position in command. /// Available after filling the command. public int Ordinal { get; internal set; } - + /// Gets or sets the parameter temporary name. public string Name { get; internal set; } - + /// Gets or sets the parameter value. public object Value { get; set; } - + /// Gets or sets a value indicating whether name of temporary parameter is well known. public bool WellKnown { get; set; } - + /// Gets or sets a value indicating whether this is virtual. public bool Virtual { get; set; } - + /// Gets or sets the parameter schema information. public DynamicSchemaColumn? Schema { get; set; } - + /// Gets a value indicating whether this instance is disposed. public bool IsDisposed { get; private set; } - + /// Performs application-defined tasks associated with /// freeing, releasing, or resetting unmanaged resources. public virtual void Dispose() { IsDisposed = true; - + Name = null; Schema = null; } } - + #endregion Parameter - + #region Constructor - + /// /// Initializes a new instance of the class. /// @@ -7087,17 +7103,17 @@ namespace DynamORM VirtualMode = false; Tables = new List(); Parameters = new Dictionary(); - + WhereCondition = null; OpenBracketsCount = 0; - + Database = db; if (Database != null) Database.AddToCache(this); - + SupportSchema = (db.Options & DynamicDatabaseOptions.SupportSchema) == DynamicDatabaseOptions.SupportSchema; } - + /// Initializes a new instance of the class. /// The database. /// The parent query. @@ -7106,51 +7122,51 @@ namespace DynamORM { _parent = parent; } - + #endregion Constructor - + #region IQueryWithWhere - + /// Gets or sets the where condition. public string WhereCondition { get; set; } - + /// Gets or sets the amount of not closed brackets in where statement. public int OpenBracketsCount { get; set; } - + #endregion IQueryWithWhere - + #region IDynamicQueryBuilder - + /// Gets instance. public DynamicDatabase Database { get; private set; } - + /// Gets the tables used in this builder. public IList Tables { get; private set; } - + /// Gets the tables used in this builder. public IDictionary Parameters { get; private set; } - + /// Gets or sets a value indicating whether add virtual parameters. public bool VirtualMode { get; set; } - + /// Gets or sets the on create temporary parameter actions. /// This is exposed to allow setting schema of column. public List> OnCreateTemporaryParameter { get; set; } - + /// Gets or sets the on create real parameter actions. /// This is exposed to allow modification of parameter. public List> OnCreateParameter { get; set; } - + /// Gets a value indicating whether database supports standard schema. public bool SupportSchema { get; private set; } - + /// /// Generates the text this command will execute against the underlying database. /// /// The text to execute against the underlying database. /// This method must be override by derived classes. public abstract string CommandText(); - + /// Fill command with query. /// Command to fill. /// Filled instance of . @@ -7165,7 +7181,7 @@ namespace DynamORM OpenBracketsCount--; } } - + return command.SetCommand(CommandText() .FillStringWithVariables(s => { @@ -7174,21 +7190,21 @@ namespace DynamORM IDbDataParameter param = (IDbDataParameter)command .AddParameter(this, p.Schema, p.Value) .Parameters[command.Parameters.Count - 1]; - + (p as Parameter).Ordinal = command.Parameters.Count - 1; - + if (OnCreateParameter != null) OnCreateParameter.ForEach(x => x(p, param)); - + return param.ParameterName; }, s); })); } - + #endregion IDynamicQueryBuilder - + #region Parser - + /// Parses the arbitrary object given and translates it into a string with the appropriate /// syntax for the database this parser is specific to. /// The object to parse and translate. It can be any arbitrary object, including null values (if @@ -7206,10 +7222,10 @@ namespace DynamORM internal virtual string Parse(object node, IDictionary pars = null, bool rawstr = false, bool nulls = false, bool decorate = true, bool isMultiPart = true) { DynamicSchemaColumn? c = null; - + return Parse(node, ref c, pars, rawstr, nulls, decorate, isMultiPart); } - + /// Parses the arbitrary object given and translates it into a string with the appropriate /// syntax for the database this parser is specific to. /// The object to parse and translate. It can be any arbitrary object, including null values (if @@ -7232,29 +7248,29 @@ namespace DynamORM { if (!nulls) throw new ArgumentNullException("node", "Null nodes are not accepted."); - + return Dispatch(node, ref columnSchema, pars, decorate); } - + // Nodes that are strings are parametrized or not depending the "rawstr" flag... if (node is string) { if (rawstr) return (string)node; else return Dispatch(node, ref columnSchema, pars, decorate); } - + // If node is a delegate, parse it to create the logical tree... if (node is Delegate) { using (DynamicParser p = DynamicParser.Parse((Delegate)node)) node = p.Result; - + return Parse(node, ref columnSchema, pars, rawstr, decorate: decorate); // Intercept containers as in (x => "string") } - + return Dispatch(node, ref columnSchema, pars, decorate, isMultiPart); } - + private string Dispatch(object node, ref DynamicSchemaColumn? columnSchema, IDictionary pars = null, bool decorate = true, bool isMultiPart = true) { if (node != null) @@ -7269,35 +7285,35 @@ namespace DynamORM else if (node is DynamicParser.Node.Invoke) return ParseInvoke((DynamicParser.Node.Invoke)node, ref columnSchema, pars); else if (node is DynamicParser.Node.Convert) return ParseConvert((DynamicParser.Node.Convert)node, pars); } - + // All other cases are considered constant parameters... return ParseConstant(node, pars, columnSchema); } - + internal virtual string ParseCommand(DynamicQueryBuilder node, IDictionary pars = null) { // Getting the command's text... string str = node.CommandText(); // Avoiding spurious "OUTPUT XXX" statements - + // If there are parameters to transform, but cannot store them, it is an error if (node.Parameters.Count != 0 && pars == null) throw new InvalidOperationException(string.Format("The parameters in this command '{0}' cannot be added to a null collection.", node.Parameters)); - + // Copy parameters to new comand foreach (KeyValuePair parameter in node.Parameters) pars.Add(parameter.Key, parameter.Value); - + return string.Format("({0})", str); } - + protected virtual string ParseArgument(DynamicParser.Node.Argument node, bool isMultiPart = true, bool isOwner = false) { if (!string.IsNullOrEmpty(node.Name) && (isOwner || (isMultiPart && IsTableAlias(node.Name)))) return node.Name; - + return null; } - + protected virtual string ParseGetMember(DynamicParser.Node.GetMember node, ref DynamicSchemaColumn? columnSchema, IDictionary pars = null, bool decorate = true, bool isMultiPart = true) { if (node.Host is DynamicParser.Node.Argument && IsTableAlias(node.Name)) @@ -7305,7 +7321,7 @@ namespace DynamORM decorate = false; isMultiPart = false; } - + // This hack allows to use argument as alias, but when it is not nesesary use other column. // Let say we hace a table Users with alias usr, and we join to table with alias ua which also has a column Users // This allow use of usr => usr.ua.Users to result in ua."Users" instead of "Users" or usr."ua"."Users", se tests for examples. @@ -7322,17 +7338,17 @@ namespace DynamORM else if (isMultiPart) parent = Parse(node.Host, pars, isMultiPart: isMultiPart); } - + ////string parent = node.Host == null || !isMultiPart ? null : Parse(node.Host, pars, isMultiPart: !IsTable(node.Name, node.Host.Name)); string name = parent == null ? decorate ? Database.DecorateName(node.Name) : node.Name : string.Format("{0}.{1}", parent, decorate ? Database.DecorateName(node.Name) : node.Name); - + columnSchema = GetColumnFromSchema(name); - + return name; } - + protected virtual string ParseSetMember(DynamicParser.Node.SetMember node, ref DynamicSchemaColumn? columnSchema, IDictionary pars = null, bool decorate = true, bool isMultiPart = true) { if (node.Host is DynamicParser.Node.Argument && IsTableAlias(node.Name)) @@ -7340,7 +7356,7 @@ namespace DynamORM decorate = false; isMultiPart = false; } - + string parent = null; if (node.Host != null) { @@ -7354,18 +7370,18 @@ namespace DynamORM else if (isMultiPart) parent = Parse(node.Host, pars, isMultiPart: isMultiPart); } - + ////string parent = node.Host == null || !isMultiPart ? null : Parse(node.Host, pars, isMultiPart: !IsTable(node.Name, node.Host.Name)); string name = parent == null ? decorate ? Database.DecorateName(node.Name) : node.Name : string.Format("{0}.{1}", parent, decorate ? Database.DecorateName(node.Name) : node.Name); - + columnSchema = GetColumnFromSchema(name); - + string value = Parse(node.Value, ref columnSchema, pars, nulls: true); return string.Format("{0} = ({1})", name, value); } - + protected virtual string ParseUnary(DynamicParser.Node.Unary node, IDictionary pars = null) { switch (node.Operation) @@ -7373,19 +7389,19 @@ namespace DynamORM // Artifacts from the DynamicParser class that are not usefull here... case ExpressionType.IsFalse: case ExpressionType.IsTrue: return Parse(node.Target, pars); - + // Unary supported operations... case ExpressionType.Not: return string.Format("(NOT {0})", Parse(node.Target, pars)); case ExpressionType.Negate: return string.Format("!({0})", Parse(node.Target, pars)); } - + throw new ArgumentException("Not supported unary operation: " + node); } - + protected virtual string ParseBinary(DynamicParser.Node.Binary node, IDictionary pars = null) { string op = string.Empty; - + switch (node.Operation) { // Arithmetic binary operations... @@ -7395,35 +7411,35 @@ namespace DynamORM case ExpressionType.Divide: op = "/"; break; case ExpressionType.Modulo: op = "%"; break; case ExpressionType.Power: op = "^"; break; - + case ExpressionType.And: op = "AND"; break; case ExpressionType.Or: op = "OR"; break; - + // Logical comparisons... case ExpressionType.GreaterThan: op = ">"; break; case ExpressionType.GreaterThanOrEqual: op = ">="; break; case ExpressionType.LessThan: op = "<"; break; case ExpressionType.LessThanOrEqual: op = "<="; break; - + // Comparisons against 'NULL' require the 'IS' or 'IS NOT' operator instead the numeric ones... case ExpressionType.Equal: op = node.Right == null && !VirtualMode ? "IS" : "="; break; case ExpressionType.NotEqual: op = node.Right == null && !VirtualMode ? "IS NOT" : "<>"; break; - + default: throw new ArgumentException("Not supported operator: '" + node.Operation); } - + DynamicSchemaColumn? columnSchema = null; string left = Parse(node.Left, ref columnSchema, pars); // Not nulls: left is assumed to be an object string right = Parse(node.Right, ref columnSchema, pars, nulls: true); return string.Format("({0} {1} {2})", left, op, right); } - + protected virtual string ParseMethod(DynamicParser.Node.Method node, ref DynamicSchemaColumn? columnSchema, IDictionary pars = null) { string method = node.Name.ToUpper(); string parent = node.Host == null ? null : Parse(node.Host, ref columnSchema, pars: pars); string item = null; - + // Root-level methods... if (node.Host == null) { @@ -7435,7 +7451,7 @@ namespace DynamORM return string.Format("(NOT {0})", item); } } - + // Column-level methods... if (node.Host != null) { @@ -7445,47 +7461,47 @@ namespace DynamORM { if (node.Arguments == null || node.Arguments.Length == 0) throw new ArgumentException("BETWEEN method expects at least one argument: " + node.Arguments.Sketch()); - + if (node.Arguments.Length > 2) throw new ArgumentException("BETWEEN method expects at most two arguments: " + node.Arguments.Sketch()); - + object[] arguments = node.Arguments; - + if (arguments.Length == 1 && (arguments[0] is IEnumerable || arguments[0] is Array) && !(arguments[0] is byte[])) { IEnumerable vals = arguments[0] as IEnumerable; - + if (vals == null && arguments[0] is Array) vals = ((Array)arguments[0]).Cast() as IEnumerable; - + if (vals != null) arguments = vals.ToArray(); else throw new ArgumentException("BETWEEN method expects single argument to be enumerable of exactly two elements: " + node.Arguments.Sketch()); } - + return string.Format("{0} BETWEEN {1} AND {2}", parent, Parse(arguments[0], ref columnSchema, pars: pars), Parse(arguments[1], ref columnSchema, pars: pars)); } - + case "IN": { if (node.Arguments == null || node.Arguments.Length == 0) throw new ArgumentException("IN method expects at least one argument: " + node.Arguments.Sketch()); - + bool firstParam = true; StringBuilder sbin = new StringBuilder(); foreach (object arg in node.Arguments) { if (!firstParam) sbin.Append(", "); - + if ((arg is IEnumerable || arg is Array) && !(arg is byte[])) { IEnumerable vals = arg as IEnumerable; - + if (vals == null && arg is Array) vals = ((Array)arg).Cast() as IEnumerable; - + if (vals != null) foreach (object val in vals) { @@ -7493,7 +7509,7 @@ namespace DynamORM sbin.Append(", "); else firstParam = false; - + sbin.Append(Parse(val, ref columnSchema, pars: pars)); } else @@ -7501,32 +7517,32 @@ namespace DynamORM } else sbin.Append(Parse(arg, ref columnSchema, pars: pars)); - + firstParam = false; } - + return string.Format("{0} IN({1})", parent, sbin.ToString()); } - + case "NOTIN": { if (node.Arguments == null || node.Arguments.Length == 0) throw new ArgumentException("IN method expects at least one argument: " + node.Arguments.Sketch()); - + bool firstParam = true; StringBuilder sbin = new StringBuilder(); foreach (object arg in node.Arguments) { if (!firstParam) sbin.Append(", "); - + if ((arg is IEnumerable || arg is Array) && !(arg is byte[])) { IEnumerable vals = arg as IEnumerable; - + if (vals == null && arg is Array) vals = ((Array)arg).Cast() as IEnumerable; - + if (vals != null) foreach (object val in vals) { @@ -7534,7 +7550,7 @@ namespace DynamORM sbin.Append(", "); else firstParam = false; - + sbin.Append(Parse(val, ref columnSchema, pars: pars)); } else @@ -7542,91 +7558,91 @@ namespace DynamORM } else sbin.Append(Parse(arg, ref columnSchema, pars: pars)); - + firstParam = false; } - + return string.Format("{0} NOT IN({1})", parent, sbin.ToString()); } - + case "LIKE": if (node.Arguments == null || node.Arguments.Length != 1) throw new ArgumentException("LIKE method expects one argument: " + node.Arguments.Sketch()); - + return string.Format("{0} LIKE {1}", parent, Parse(node.Arguments[0], ref columnSchema, pars: pars)); - + case "NOTLIKE": if (node.Arguments == null || node.Arguments.Length != 1) throw new ArgumentException("NOT LIKE method expects one argument: " + node.Arguments.Sketch()); - + return string.Format("{0} NOT LIKE {1}", parent, Parse(node.Arguments[0], ref columnSchema, pars: pars)); - + case "AS": if (node.Arguments == null || node.Arguments.Length != 1) throw new ArgumentException("AS method expects one argument: " + node.Arguments.Sketch()); - + item = Parse(node.Arguments[0], pars: null, rawstr: true, isMultiPart: false); // pars=null to avoid to parameterize aliases item = item.Validated("Alias"); // Intercepting null and empty aliases return string.Format("{0} AS {1}", parent, item); - + case "COUNT": if (node.Arguments != null && node.Arguments.Length > 1) throw new ArgumentException("COUNT method expects one or none argument: " + node.Arguments.Sketch()); - + if (node.Arguments == null || node.Arguments.Length == 0) return "COUNT(*)"; - + return string.Format("COUNT({0})", Parse(node.Arguments[0], ref columnSchema, pars: Parameters, nulls: true)); } } - + // Default case: parsing the method's name along with its arguments... method = parent == null ? node.Name : string.Format("{0}.{1}", parent, node.Name); StringBuilder sb = new StringBuilder(); sb.AppendFormat("{0}(", method); - + if (node.Arguments != null && node.Arguments.Length != 0) { bool first = true; - + foreach (object argument in node.Arguments) { if (!first) sb.Append(", "); else first = false; - + sb.Append(Parse(argument, ref columnSchema, pars, nulls: true)); // We don't accept raw strings here!!! } } - + sb.Append(")"); return sb.ToString(); } - + protected virtual string ParseInvoke(DynamicParser.Node.Invoke node, ref DynamicSchemaColumn? columnSchema, IDictionary pars = null) { // This is used as an especial syntax to merely concatenate its arguments. It is used as a way to extend the supported syntax without the need of treating all the possible cases... if (node.Arguments == null || node.Arguments.Length == 0) return string.Empty; - + StringBuilder sb = new StringBuilder(); foreach (object arg in node.Arguments) { if (arg is string) { sb.Append((string)arg); - + if (node.Arguments.Length == 1 && !columnSchema.HasValue) columnSchema = GetColumnFromSchema((string)arg); } else sb.Append(Parse(arg, ref columnSchema, pars, rawstr: true, nulls: true)); } - + return sb.ToString(); } - + protected virtual string ParseConvert(DynamicParser.Node.Convert node, IDictionary pars = null) { // The cast mechanism is left for the specific database implementation, that should override this method @@ -7634,16 +7650,16 @@ namespace DynamORM string r = Parse(node.Target, pars); return r; } - + protected virtual string ParseConstant(object node, IDictionary pars = null, DynamicSchemaColumn? columnSchema = null) { if (node == null && !VirtualMode) return ParseNull(); - + if (pars != null) { bool wellKnownName = VirtualMode && node is String && ((String)node).StartsWith("[$") && ((String)node).EndsWith("]") && ((String)node).Length > 4; - + // If we have a list of parameters to store it, let's parametrize it Parameter par = new Parameter() { @@ -7653,60 +7669,60 @@ namespace DynamORM Virtual = VirtualMode, Schema = columnSchema, }; - + // If we are adding parameter we inform external sources about this. if (OnCreateTemporaryParameter != null) OnCreateTemporaryParameter.ForEach(x => x(par)); - + pars.Add(par.Name, par); - + return string.Format("[${0}]", par.Name); } - + return node.ToString(); // Last resort case } - + protected virtual string ParseNull() { return "NULL"; // Override if needed } - + #endregion Parser - + #region Helpers - + internal bool IsTableAlias(string name) { DynamicQueryBuilder builder = this; - + while (builder != null) { if (builder.Tables.Any(t => t.Alias == name)) return true; - + builder = builder._parent; } - + return false; } - + internal bool IsTable(string name, string owner) { DynamicQueryBuilder builder = this; - + while (builder != null) { if ((string.IsNullOrEmpty(owner) && builder.Tables.Any(t => t.Name.ToLower() == name.ToLower())) || (!string.IsNullOrEmpty(owner) && builder.Tables.Any(t => t.Name.ToLower() == name.ToLower() && !string.IsNullOrEmpty(t.Owner) && t.Owner.ToLower() == owner.ToLower()))) return true; - + builder = builder._parent; } - + return false; } - + internal string FixObjectName(string main, bool onlyColumn = false) { if (main.IndexOf("(") > 0 && main.IndexOf(")") > 0) @@ -7714,124 +7730,124 @@ namespace DynamORM else return FixObjectNamePrivate(main, onlyColumn); } - + private string FixObjectNamePrivate(string f, bool onlyColumn = false) { IEnumerable objects = f.Split('.') .Select(x => Database.StripName(x)); - + if (onlyColumn || objects.Count() == 1) f = Database.DecorateName(objects.Last()); else if (!IsTableAlias(objects.First())) f = string.Join(".", objects.Select(o => Database.DecorateName(o))); else f = string.Format("{0}.{1}", objects.First(), string.Join(".", objects.Skip(1).Select(o => Database.DecorateName(o)))); - + return f; } - + internal DynamicSchemaColumn? GetColumnFromSchema(string colName, DynamicTypeMap mapper = null, string table = null) { // This is tricky and will not always work unfortunetly. ////if (colName.ContainsAny(StringExtensions.InvalidMultipartMemberChars)) //// return null; - + // First we need to get real column name and it's owner if exist. string[] parts = colName.Split('.'); for (int i = 0; i < parts.Length; i++) parts[i] = Database.StripName(parts[i]); - + string columnName = parts.Last(); - + // Get table name from mapper string tableName = table; - + if (string.IsNullOrEmpty(tableName)) { tableName = (mapper != null && mapper.Table != null) ? mapper.Table.Name : string.Empty; - + if (parts.Length > 1 && string.IsNullOrEmpty(tableName)) { // OK, we have a multi part identifier, that's good, we can get table name tableName = string.Join(".", parts.Take(parts.Length - 1)); } } - + // Try to get table info from cache ITableInfo tableInfo = !string.IsNullOrEmpty(tableName) ? Tables.FirstOrDefault(x => !string.IsNullOrEmpty(x.Alias) && x.Alias.ToLower() == tableName) ?? Tables.FirstOrDefault(x => x.Name.ToLower() == tableName.ToLower()) ?? Tables.FirstOrDefault() : this is DynamicModifyBuilder ? Tables.FirstOrDefault() : null; - + // Try to get column from schema if (tableInfo != null && tableInfo.Schema != null) return tableInfo.Schema.TryGetNullable(columnName.ToLower()); - + // Well, we failed to find a column return null; } - + #endregion Helpers - + #region IExtendedDisposable - + /// Gets a value indicating whether this instance is disposed. public bool IsDisposed { get; private set; } - + /// Performs application-defined tasks associated with /// freeing, releasing, or resetting unmanaged resources. public virtual void Dispose() { IsDisposed = true; - + if (Database != null) Database.RemoveFromCache(this); - + if (Parameters != null) { foreach (KeyValuePair p in Parameters) p.Value.Dispose(); - + Parameters.Clear(); Parameters = null; } - + if (Tables != null) { foreach (ITableInfo t in Tables) if (t != null) t.Dispose(); - + Tables.Clear(); Tables = null; } - + WhereCondition = null; Database = null; } - + #endregion IExtendedDisposable } - + + /// Implementation of dynamic select query builder. internal class DynamicSelectQueryBuilder : DynamicQueryBuilder, IDynamicSelectQueryBuilder, DynamicQueryBuilder.IQueryWithWhere { - private int? _top = null; private int? _limit = null; private int? _offset = null; private bool _distinct = false; - + private string _select; private string _from; private string _join; private string _groupby; private string _orderby; - + /// /// Gets a value indicating whether this instance has select columns. /// public bool HasSelectColumns { get { return !string.IsNullOrEmpty(_select); } } - + /// /// Initializes a new instance of the class. /// @@ -7840,7 +7856,7 @@ namespace DynamORM : base(db) { } - + /// /// Initializes a new instance of the class. /// @@ -7850,28 +7866,53 @@ namespace DynamORM : base(db, parent) { } - + /// Generates the text this command will execute against the underlying database. /// The text to execute against the underlying database. public override string CommandText() { + bool lused = false; + bool oused = false; + StringBuilder sb = new StringBuilder("SELECT"); if (_distinct) sb.AppendFormat(" DISTINCT"); - if (_top.HasValue) sb.AppendFormat(" TOP {0}", _top); + + if (_limit.HasValue) + { + if ((Database.Options & DynamicDatabaseOptions.SupportTop) == DynamicDatabaseOptions.SupportTop) + { + sb.AppendFormat(" TOP {0}", _limit); + lused = true; + } + else if ((Database.Options & DynamicDatabaseOptions.SupportFirstSkip) == DynamicDatabaseOptions.SupportFirstSkip) + { + sb.AppendFormat(" FIRST {0}", _limit); + lused = true; + } + } + + if (_offset.HasValue && (Database.Options & DynamicDatabaseOptions.SupportFirstSkip) == DynamicDatabaseOptions.SupportFirstSkip) + { + sb.AppendFormat(" SKIP {0}", _offset); + oused = true; + } + if (_select != null) sb.AppendFormat(" {0}", _select); else sb.Append(" *"); if (_from != null) sb.AppendFormat(" FROM {0}", _from); if (_join != null) sb.AppendFormat(" {0}", _join); if (WhereCondition != null) sb.AppendFormat(" WHERE {0}", WhereCondition); if (_groupby != null) sb.AppendFormat(" GROUP BY {0}", _groupby); if (_orderby != null) sb.AppendFormat(" ORDER BY {0}", _orderby); - if (_limit.HasValue) sb.AppendFormat(" LIMIT {0}", _limit); - if (_offset.HasValue) sb.AppendFormat(" OFFSET {0}", _offset); - + if (_limit.HasValue && !lused && (Database.Options & DynamicDatabaseOptions.SupportLimitOffset) == DynamicDatabaseOptions.SupportLimitOffset) + sb.AppendFormat(" LIMIT {0}", _limit); + if (_offset.HasValue && !oused && (Database.Options & DynamicDatabaseOptions.SupportLimitOffset) == DynamicDatabaseOptions.SupportLimitOffset) + sb.AppendFormat(" OFFSET {0}", _offset); + return sb.ToString(); } - + #region Execution - + /// Execute this builder. /// Enumerator of objects expanded from query. public virtual IEnumerable Execute() @@ -7884,7 +7925,7 @@ namespace DynamORM while (rdr.Read()) { dynamic val = null; - + // Work around to avoid yield being in try...catchblock: // http://stackoverflow.com/questions/346365/why-cant-yield-return-appear-inside-a-try-block-with-a-catch try @@ -7895,25 +7936,25 @@ namespace DynamORM { StringBuilder sb = new StringBuilder(); cmd.Dump(sb); - + throw new ArgumentException(string.Format("{0}{1}{2}", argex.Message, Environment.NewLine, sb), argex.InnerException.NullOr(a => a, argex)); } - + yield return val; } } - + /// Execute this builder and map to given type. /// Type of object to map on. /// Enumerator of objects expanded from query. public virtual IEnumerable Execute() where T : class { DynamicTypeMap mapper = DynamicMapperCache.GetMapper(); - + if (mapper == null) throw new InvalidOperationException("Type can't be mapped for unknown reason."); - + using (IDbConnection con = Database.Open()) using (IDbCommand cmd = con.CreateCommand()) { @@ -7923,7 +7964,7 @@ namespace DynamORM while (rdr.Read()) { dynamic val = null; - + // Work around to avoid yield being in try...catchblock: // http://stackoverflow.com/questions/346365/why-cant-yield-return-appear-inside-a-try-block-with-a-catch try @@ -7934,16 +7975,16 @@ namespace DynamORM { StringBuilder sb = new StringBuilder(); cmd.Dump(sb); - + throw new ArgumentException(string.Format("{0}{1}{2}", argex.Message, Environment.NewLine, sb), argex.InnerException.NullOr(a => a, argex)); } - + yield return mapper.Create(val) as T; } } } - + /// Execute this builder as a data reader. /// Action containing reader. public virtual void ExecuteDataReader(Action reader) @@ -7955,7 +7996,7 @@ namespace DynamORM .ExecuteReader()) reader(rdr); } - + /// Returns a single result. /// Result of a query. public virtual object Scalar() @@ -7968,9 +8009,9 @@ namespace DynamORM .ExecuteScalar(); } } - -#if !DYNAMORM_OMMIT_GENERICEXECUTION && !DYNAMORM_OMMIT_TRYPARSE - + + #if !DYNAMORM_OMMIT_GENERICEXECUTION && !DYNAMORM_OMMIT_TRYPARSE + /// Returns a single result. /// Type to parse to. /// Default value. @@ -7985,13 +8026,13 @@ namespace DynamORM .ExecuteScalarAs(defaultValue); } } - -#endif - + + #endif + #endregion Execution - + #region From/Join - + /// /// Adds to the 'From' clause the contents obtained by parsing the dynamic lambda expressions given. The supported /// formats are: @@ -8007,25 +8048,25 @@ namespace DynamORM { if (fn == null) throw new ArgumentNullException("Array of functions cannot be or contain null."); - + int index = FromFunc(-1, fn); foreach (Func f in func) index = FromFunc(index, f); - + return this; } - + private int FromFunc(int index, Func f) { if (f == null) throw new ArgumentNullException("Array of functions cannot be or contain null."); - + index++; ITableInfo tableInfo = null; using (DynamicParser parser = DynamicParser.Parse(f)) { object result = parser.Result; - + // If the expression result is string. if (result is string) { @@ -8042,24 +8083,24 @@ namespace DynamORM Type type = (Type)result; if (type.IsAnonymous()) throw new InvalidOperationException(string.Format("Cant assign anonymous type as a table ({0}). Parsing {1}", type.FullName, result)); - + DynamicTypeMap mapper = DynamicMapperCache.GetMapper(type); - + if (mapper == null) throw new InvalidOperationException(string.Format("Cant assign unmapable type as a table ({0}). Parsing {1}", type.FullName, result)); - + tableInfo = new TableInfo(Database, type); } else if (result is DynamicParser.Node) { // Or if it resolves to a dynamic node DynamicParser.Node node = (DynamicParser.Node)result; - + string owner = null; string main = null; string alias = null; Type type = null; - + while (true) { // Support for the AS() virtual method... @@ -8067,48 +8108,48 @@ namespace DynamORM { if (alias != null) throw new ArgumentException(string.Format("Alias '{0}' is already set when parsing '{1}'.", alias, result)); - + object[] args = ((DynamicParser.Node.Method)node).Arguments; - + if (args == null) throw new ArgumentNullException("arg", "AS() is not a parameterless method."); - + if (args.Length != 1) throw new ArgumentException("AS() requires one and only one parameter: " + args.Sketch()); - + alias = Parse(args[0], rawstr: true, decorate: false).Validated("Alias"); - + node = node.Host; continue; } - + /*if (node is DynamicParser.Node.Method && ((DynamicParser.Node.Method)node).Name.ToUpper() == "subquery") { main = Parse(this.SubQuery(((DynamicParser.Node.Method)node).Arguments.Where(p => p is Func).Cast>().ToArray()), Parameters); continue; }*/ - + // Support for table specifications... if (node is DynamicParser.Node.GetMember) { if (owner != null) throw new ArgumentException(string.Format("Owner '{0}.{1}' is already set when parsing '{2}'.", owner, main, result)); - + if (main != null) owner = ((DynamicParser.Node.GetMember)node).Name; else main = ((DynamicParser.Node.GetMember)node).Name; - + node = node.Host; continue; } - + // Support for generic sources... if (node is DynamicParser.Node.Invoke) { if (owner != null) throw new ArgumentException(string.Format("Owner '{0}.{1}' is already set when parsing '{2}'.", owner, main, result)); - + if (main != null) owner = string.Format("{0}", Parse(node, rawstr: true, pars: Parameters)); else @@ -8119,66 +8160,66 @@ namespace DynamORM type = (Type)invoke.Arguments[0]; if (type.IsAnonymous()) throw new InvalidOperationException(string.Format("Cant assign anonymous type as a table ({0}). Parsing {1}", type.FullName, result)); - + DynamicTypeMap mapper = DynamicMapperCache.GetMapper(type); - + if (mapper == null) throw new InvalidOperationException(string.Format("Cant assign unmapable type as a table ({0}). Parsing {1}", type.FullName, result)); - + main = mapper.Table == null || string.IsNullOrEmpty(mapper.Table.Name) ? mapper.Type.Name : mapper.Table.Name; - + owner = (mapper.Table != null) ? mapper.Table.Owner : owner; } else main = string.Format("{0}", Parse(node, rawstr: true, pars: Parameters)); } - + node = node.Host; continue; } - + // Just finished the parsing... if (node is DynamicParser.Node.Argument) break; - + // All others are assumed to be part of the main element... if (main != null) main = Parse(node, pars: Parameters); else main = Parse(node, pars: Parameters); - + break; } - + if (!string.IsNullOrEmpty(main)) tableInfo = type == null ? new TableInfo(Database, main, alias, owner) : new TableInfo(Database, type, alias, owner); else throw new ArgumentException(string.Format("Specification #{0} is invalid: {1}", index, result)); } - + // Or it is a not supported expression... if (tableInfo == null) throw new ArgumentException(string.Format("Specification #{0} is invalid: {1}", index, result)); - + Tables.Add(tableInfo); - + // We finally add the contents... StringBuilder sb = new StringBuilder(); - + if (!string.IsNullOrEmpty(tableInfo.Owner)) sb.AppendFormat("{0}.", Database.DecorateName(tableInfo.Owner)); - + sb.Append(tableInfo.Name.ContainsAny(StringExtensions.InvalidMemberChars) ? tableInfo.Name : Database.DecorateName(tableInfo.Name)); - + if (!string.IsNullOrEmpty(tableInfo.Alias)) sb.AppendFormat(" AS {0}", tableInfo.Alias); - + _from = string.IsNullOrEmpty(_from) ? sb.ToString() : string.Format("{0}, {1}", _from, sb.ToString()); } - + return index; } - + /// /// Adds to the 'Join' clause the contents obtained by parsing the dynamic lambda expressions given. The supported /// formats are: @@ -8200,7 +8241,7 @@ namespace DynamORM // We need to do two passes to add aliases first. return JoinInternal(true, func).JoinInternal(false, func); } - + /// /// Adds to the 'Join' clause the contents obtained by parsing the dynamic lambda expressions given. The supported /// formats are: @@ -8221,36 +8262,36 @@ namespace DynamORM protected virtual DynamicSelectQueryBuilder JoinInternal(bool justAddTables, params Func[] func) { if (func == null) throw new ArgumentNullException("Array of functions cannot be null."); - + int index = -1; - + foreach (Func f in func) { index++; ITableInfo tableInfo = null; - + if (f == null) throw new ArgumentNullException(string.Format("Specification #{0} cannot be null.", index)); - + using (DynamicParser parser = DynamicParser.Parse(f)) { object result = parser.Result; if (result == null) throw new ArgumentException(string.Format("Specification #{0} resolves to null.", index)); - + string type = null; string main = null; string owner = null; string alias = null; string condition = null; Type tableType = null; - + // If the expression resolves to a string... if (result is string) { string node = (string)result; - + int n = node.ToUpper().IndexOf("JOIN "); - + if (n < 0) main = node; else @@ -8259,15 +8300,15 @@ namespace DynamORM type = node.Substring(0, n + 4); main = node.Substring(n + 4); } - + n = main.ToUpper().IndexOf("ON"); - + if (n >= 0) { condition = main.Substring(n + 3); main = main.Substring(0, n).Trim(); } - + Tuple tuple = main.SplitSomethingAndAlias(); // In this case we split on the remaining 'main' string[] parts = tuple.Item1.Split('.'); main = Database.StripName(parts.Last()).Validated("Table"); @@ -8285,64 +8326,64 @@ namespace DynamORM { if (condition != null) throw new ArgumentException(string.Format("Condition '{0}' is already set when parsing '{1}'.", alias, result)); - + object[] args = ((DynamicParser.Node.Method)node).Arguments; if (args == null) throw new ArgumentNullException("arg", "ON() is not a parameterless method."); - + if (args.Length != 1) throw new ArgumentException("ON() requires one and only one parameter: " + args.Sketch()); - + condition = Parse(args[0], rawstr: true, pars: justAddTables ? null : Parameters); - + node = node.Host; continue; } - + // Support for the AS() virtual method... if (node is DynamicParser.Node.Method && ((DynamicParser.Node.Method)node).Name.ToUpper() == "AS") { if (alias != null) throw new ArgumentException(string.Format("Alias '{0}' is already set when parsing '{1}'.", alias, result)); - + object[] args = ((DynamicParser.Node.Method)node).Arguments; - + if (args == null) throw new ArgumentNullException("arg", "AS() is not a parameterless method."); - + if (args.Length != 1) throw new ArgumentException("AS() requires one and only one parameter: " + args.Sketch()); - + alias = Parse(args[0], rawstr: true, decorate: false, isMultiPart: false).Validated("Alias"); - + node = node.Host; continue; } - + // Support for table specifications... if (node is DynamicParser.Node.GetMember) { if (owner != null) throw new ArgumentException(string.Format("Owner '{0}.{1}' is already set when parsing '{2}'.", owner, main, result)); - + if (main != null) owner = ((DynamicParser.Node.GetMember)node).Name; else main = ((DynamicParser.Node.GetMember)node).Name; - + node = node.Host; continue; } - + // Support for Join Type specifications... if (node is DynamicParser.Node.Method && (node.Host is DynamicParser.Node.Argument || node.Host is DynamicParser.Node.Invoke)) { if (type != null) throw new ArgumentException(string.Format("Join type '{0}' is already set when parsing '{1}'.", main, result)); type = ((DynamicParser.Node.Method)node).Name; - + bool avoid = false; object[] args = ((DynamicParser.Node.Method)node).Arguments; - + if (args != null && args.Length > 0) { avoid = args[0] is bool && !((bool)args[0]); @@ -8350,7 +8391,7 @@ namespace DynamORM if (!string.IsNullOrEmpty(proposedType)) type = proposedType; } - + type = type.ToUpper(); // Normalizing, and stepping out the trivial case... if (type != "JOIN") { @@ -8359,13 +8400,13 @@ namespace DynamORM type = type.Replace("OUTER", " OUTER ") .Replace(" ", " ") .Trim(' '); - + // x => x.Left()... int n = type.IndexOf("JOIN"); - + if (n < 0 && !avoid) type += " JOIN"; - + // x => x.InnerJoin() / x => x.JoinLeft() ... else { @@ -8376,17 +8417,17 @@ namespace DynamORM } } } - + node = node.Host; continue; } - + // Support for generic sources... if (node is DynamicParser.Node.Invoke) { if (owner != null) throw new ArgumentException(string.Format("Owner '{0}.{1}' is already set when parsing '{2}'.", owner, main, result)); - + if (main != null) owner = string.Format("{0}", Parse(node, rawstr: true, pars: justAddTables ? null : Parameters)); else @@ -8396,23 +8437,23 @@ namespace DynamORM { tableType = (Type)invoke.Arguments[0]; DynamicTypeMap mapper = DynamicMapperCache.GetMapper(tableType); - + if (mapper == null) throw new InvalidOperationException(string.Format("Cant assign unmapable type as a table ({0}).", tableType.FullName)); - + main = mapper.Table == null || string.IsNullOrEmpty(mapper.Table.Name) ? mapper.Type.Name : mapper.Table.Name; - + owner = (mapper.Table != null) ? mapper.Table.Owner : owner; } else main = string.Format("{0}", Parse(node, rawstr: true, pars: justAddTables ? null : Parameters)); } - + node = node.Host; continue; } - + // Just finished the parsing... if (node is DynamicParser.Node.Argument) break; throw new ArgumentException(string.Format("Specification #{0} is invalid: {1}", index, result)); @@ -8423,17 +8464,17 @@ namespace DynamORM // Or it is a not supported expression... throw new ArgumentException(string.Format("Specification #{0} is invalid: {1}", index, result)); } - + // We annotate the aliases being conservative... main = main.Validated("Main"); - + if (justAddTables) { if (!string.IsNullOrEmpty(main)) tableInfo = tableType == null ? new TableInfo(Database, main, alias, owner) : new TableInfo(Database, tableType, alias, owner); else throw new ArgumentException(string.Format("Specification #{0} is invalid: {1}", index, result)); - + Tables.Add(tableInfo); } else @@ -8442,37 +8483,37 @@ namespace DynamORM tableInfo = string.IsNullOrEmpty(alias) ? Tables.SingleOrDefault(t => t.Name == main && string.IsNullOrEmpty(t.Alias)) : Tables.SingleOrDefault(t => t.Alias == alias); - + // We finally add the contents if we can... StringBuilder sb = new StringBuilder(); if (string.IsNullOrEmpty(type)) type = "JOIN"; - + sb.AppendFormat("{0} ", type); - + if (!string.IsNullOrEmpty(tableInfo.Owner)) sb.AppendFormat("{0}.", Database.DecorateName(tableInfo.Owner)); - + sb.Append(tableInfo.Name.ContainsAny(StringExtensions.InvalidMemberChars) ? tableInfo.Name : Database.DecorateName(tableInfo.Name)); - + if (!string.IsNullOrEmpty(tableInfo.Alias)) sb.AppendFormat(" AS {0}", tableInfo.Alias); - + if (!string.IsNullOrEmpty(condition)) sb.AppendFormat(" ON {0}", condition); - + _join = string.IsNullOrEmpty(_join) ? sb.ToString() : string.Format("{0} {1}", _join, sb.ToString()); // No comma in this case } } } - + return this; } - + #endregion From/Join - + #region Where - + /// /// Adds to the 'Where' clause the contents obtained from parsing the dynamic lambda expression given. The condition /// is parsed to the appropriate syntax, where the specific customs virtual methods supported by the parser are used @@ -8487,7 +8528,7 @@ namespace DynamORM { return this.InternalWhere(func); } - + /// Add where condition. /// Condition column with operator and value. /// Builder instance. @@ -8495,7 +8536,7 @@ namespace DynamORM { return this.InternalWhere(column); } - + /// Add where condition. /// Condition column. /// Condition operator. @@ -8505,7 +8546,7 @@ namespace DynamORM { return this.InternalWhere(column, op, value); } - + /// Add where condition. /// Condition column. /// Condition value. @@ -8514,7 +8555,7 @@ namespace DynamORM { return this.InternalWhere(column, value); } - + /// Add where condition. /// Set conditions as properties and values of an object. /// If true use schema to determine key columns and ignore those which @@ -8524,11 +8565,11 @@ namespace DynamORM { return this.InternalWhere(conditions, schema); } - + #endregion Where - + #region Select - + /// /// Adds to the 'Select' clause the contents obtained by parsing the dynamic lambda expressions given. The supported /// formats are: @@ -8545,41 +8586,41 @@ namespace DynamORM { if (fn == null) throw new ArgumentNullException("Array of specifications cannot be null."); - + int index = SelectFunc(-1, fn); if (func != null) foreach (Func f in func) index = SelectFunc(index, f); - + return this; } - + private int SelectFunc(int index, Func f) { index++; if (f == null) throw new ArgumentNullException(string.Format("Specification #{0} cannot be null.", index)); - + using (DynamicParser parser = DynamicParser.Parse(f)) { object result = parser.Result; if (result == null) throw new ArgumentException(string.Format("Specification #{0} resolves to null.", index)); - + string main = null; string alias = null; bool all = false; bool anon = false; - + // If the expression resolves to a string... if (result is string) { string node = (string)result; Tuple tuple = node.SplitSomethingAndAlias(); main = tuple.Item1.Validated("Table and/or Column"); - + main = FixObjectName(main); - + alias = tuple.Item2.Validated("Alias", canbeNull: true); } else if (result is DynamicParser.Node) @@ -8590,7 +8631,7 @@ namespace DynamORM else if (result.GetType().IsAnonymous()) { anon = true; - + foreach (KeyValuePair prop in result.ToDictionary()) { if (prop.Value is string) @@ -8598,7 +8639,7 @@ namespace DynamORM string node = (string)prop.Value; Tuple tuple = node.SplitSomethingAndAlias(); main = FixObjectName(tuple.Item1.Validated("Table and/or Column")); - + ////alias = tuple.Item2.Validated("Alias", canbeNull: true); } else if (prop.Value is DynamicParser.Node) @@ -8611,7 +8652,7 @@ namespace DynamORM // Or it is a not supported expression... throw new ArgumentException(string.Format("Specification #{0} in anonymous type is invalid: {1}", index, prop.Value)); } - + alias = Database.DecorateName(prop.Key); ParseSelectAddColumn(main, alias, all); } @@ -8621,14 +8662,14 @@ namespace DynamORM // Or it is a not supported expression... throw new ArgumentException(string.Format("Specification #{0} is invalid: {1}", index, result)); } - + if (!anon) ParseSelectAddColumn(main, alias, all); } - + return index; } - + /// Add select columns. /// Columns to add to object. /// Builder instance. @@ -8636,10 +8677,10 @@ namespace DynamORM { foreach (DynamicColumn col in columns) Select(x => col.ToSQLSelectColumn(Database)); - + return this; } - + /// Add select columns. /// Columns to add to object. /// Column format consist of Column Name, Alias and @@ -8650,14 +8691,14 @@ namespace DynamORM DynamicColumn[] cols = new DynamicColumn[columns.Length]; for (int i = 0; i < columns.Length; i++) cols[i] = DynamicColumn.ParseSelectColumn(columns[i]); - + return SelectColumn(cols); } - + #endregion Select - + #region GroupBy - + /// /// Adds to the 'Group By' clause the contents obtained from from parsing the dynamic lambda expression given. /// @@ -8668,19 +8709,19 @@ namespace DynamORM { if (fn == null) throw new ArgumentNullException("Array of specifications cannot be null."); - + int index = GroupByFunc(-1, fn); - + if (func != null) for (int i = 0; i < func.Length; i++) { Func f = func[i]; index = GroupByFunc(index, f); } - + return this; } - + private int GroupByFunc(int index, Func f) { index++; @@ -8691,24 +8732,24 @@ namespace DynamORM object result = parser.Result; if (result == null) throw new ArgumentException(string.Format("Specification #{0} resolves to null.", index)); - + string main = null; - + if (result is string) main = FixObjectName(result as string); else main = Parse(result, pars: Parameters); - + main = main.Validated("Group By"); if (_groupby == null) _groupby = main; else _groupby = string.Format("{0}, {1}", _groupby, main); } - + return index; } - + /// Add select columns. /// Columns to group by. /// Builder instance. @@ -8719,10 +8760,10 @@ namespace DynamORM DynamicColumn col = columns[i]; GroupBy(x => col.ToSQLGroupByColumn(Database)); } - + return this; } - + /// Add select columns. /// Columns to group by. /// Column format consist of Column Name and @@ -8732,11 +8773,11 @@ namespace DynamORM { return GroupByColumn(columns.Select(c => DynamicColumn.ParseSelectColumn(c)).ToArray()); } - + #endregion GroupBy - + #region OrderBy - + /// /// Adds to the 'Order By' clause the contents obtained from from parsing the dynamic lambda expression given. It /// accepts a multipart column specification followed by an optional Ascending() or Descending() virtual methods @@ -8750,44 +8791,44 @@ namespace DynamORM { if (fn == null) throw new ArgumentNullException("Array of specifications cannot be null."); - + int index = OrderByFunc(-1, fn); - + if (func != null) for (int i = 0; i < func.Length; i++) { Func f = func[i]; index = OrderByFunc(index, f); } - + return this; } - + private int OrderByFunc(int index, Func f) { index++; if (f == null) throw new ArgumentNullException(string.Format("Specification #{0} cannot be null.", index)); - + using (DynamicParser parser = DynamicParser.Parse(f)) { object result = parser.Result; if (result == null) throw new ArgumentException(string.Format("Specification #{0} resolves to null.", index)); - + string main = null; bool ascending = true; - + if (result is int) main = result.ToString(); else if (result is string) { string[] parts = ((string)result).Split(' '); main = Database.StripName(parts.First()); - + int colNo; if (!Int32.TryParse(main, out colNo)) main = FixObjectName(main); - + ascending = parts.Length != 2 || parts.Last().ToUpper() == "ASCENDING" || parts.Last().ToUpper() == "ASC"; } else @@ -8804,9 +8845,9 @@ namespace DynamORM throw new ArgumentException(string.Format("{0} must be a parameterless method, but found: {1}.", name, args.Sketch())); else if ((args == null || args.Length != 1) && node.Host is DynamicParser.Node.Argument) throw new ArgumentException(string.Format("{0} requires one numeric parameter, but found: {1}.", name, args.Sketch())); - + ascending = (name == "ASCENDING" || name == "ASC") ? true : false; - + if (args != null && args.Length == 1) { int col = -1; @@ -8822,28 +8863,28 @@ namespace DynamORM else main = Parse(args[0], pars: Parameters); } - + result = node.Host; } } - + // Just parsing the contents... if (!(result is DynamicParser.Node.Argument)) main = Parse(result, pars: Parameters); } - + main = main.Validated("Order By"); main = string.Format("{0} {1}", main, ascending ? "ASC" : "DESC"); - + if (_orderby == null) _orderby = main; else _orderby = string.Format("{0}, {1}", _orderby, main); } - + return index; } - + /// Add select columns. /// Columns to order by. /// Builder instance. @@ -8854,10 +8895,10 @@ namespace DynamORM DynamicColumn col = columns[i]; OrderBy(x => col.ToSQLOrderByColumn(Database)); } - + return this; } - + /// Add select columns. /// Columns to order by. /// Column format consist of Column Name and @@ -8867,47 +8908,46 @@ namespace DynamORM { return OrderByColumn(columns.Select(c => DynamicColumn.ParseOrderByColumn(c)).ToArray()); } - + #endregion OrderBy - + #region Top/Limit/Offset/Distinct - + /// Set top if database support it. /// How many objects select. /// Builder instance. public virtual IDynamicSelectQueryBuilder Top(int? top) { - if ((Database.Options & DynamicDatabaseOptions.SupportTop) != DynamicDatabaseOptions.SupportTop) - throw new NotSupportedException("Database doesn't support TOP clause."); - - _top = top; - return this; + return Limit(top); } - + /// Set top if database support it. /// How many objects select. /// Builder instance. public virtual IDynamicSelectQueryBuilder Limit(int? limit) { - if ((Database.Options & DynamicDatabaseOptions.SupportLimitOffset) != DynamicDatabaseOptions.SupportLimitOffset) + if ((Database.Options & DynamicDatabaseOptions.SupportLimitOffset) != DynamicDatabaseOptions.SupportLimitOffset && + (Database.Options & DynamicDatabaseOptions.SupportFirstSkip) != DynamicDatabaseOptions.SupportFirstSkip && + (Database.Options & DynamicDatabaseOptions.SupportTop) != DynamicDatabaseOptions.SupportTop) throw new NotSupportedException("Database doesn't support LIMIT clause."); - + _limit = limit; return this; } - + /// Set top if database support it. /// How many objects skip selecting. /// Builder instance. public virtual IDynamicSelectQueryBuilder Offset(int? offset) { - if ((Database.Options & DynamicDatabaseOptions.SupportLimitOffset) != DynamicDatabaseOptions.SupportLimitOffset) + if ((Database.Options & DynamicDatabaseOptions.SupportLimitOffset) != DynamicDatabaseOptions.SupportLimitOffset && + (Database.Options & DynamicDatabaseOptions.SupportFirstSkip) != DynamicDatabaseOptions.SupportFirstSkip) throw new NotSupportedException("Database doesn't support OFFSET clause."); - + _offset = offset; return this; } - + /// Set distinct mode. /// Distinct mode. /// Builder instance. @@ -8916,31 +8956,31 @@ namespace DynamORM _distinct = distinct; return this; } - + #endregion Top/Limit/Offset/Distinct - + #region Helpers - + private void ParseSelectAddColumn(string main, string alias, bool all) { // We annotate the aliases being conservative... main = main.Validated("Main"); - + ////if (alias != null && !main.ContainsAny(StringExtensions.InvalidMemberChars)) TableAliasList.Add(new KTableAlias(main, alias)); - + // If all columns are requested... if (all) main += ".*"; - + // We finally add the contents... string str = (alias == null || all) ? main : string.Format("{0} AS {1}", main, alias); _select = _select == null ? str : string.Format("{0}, {1}", _select, str); } - + private void ParseSelectNode(object result, ref string column, ref string alias, ref bool all) { string main = null; - + DynamicParser.Node node = (DynamicParser.Node)result; while (true) { @@ -8949,59 +8989,59 @@ namespace DynamORM { if (alias != null) throw new ArgumentException(string.Format("Alias '{0}' is already set when parsing '{1}'.", alias, result)); - + object[] args = ((DynamicParser.Node.Method)node).Arguments; - + if (args == null) throw new ArgumentNullException("arg", "AS() is not a parameterless method."); - + if (args.Length != 1) throw new ArgumentException("AS() requires one and only one parameter: " + args.Sketch()); - + // Yes, we decorate columns alias = Parse(args[0], rawstr: true, decorate: true, isMultiPart: false).Validated("Alias"); - + node = node.Host; continue; } - + // Support for the ALL() virtual method... if (node is DynamicParser.Node.Method && ((DynamicParser.Node.Method)node).Name.ToUpper() == "ALL") { if (all) throw new ArgumentException(string.Format("Flag to select all columns is already set when parsing '{0}'.", result)); - + object[] args = ((DynamicParser.Node.Method)node).Arguments; - + if (args != null) throw new ArgumentException("ALL() must be a parameterless virtual method, but found: " + args.Sketch()); - + all = true; - + node = node.Host; continue; } - + // Support for table and/or column specifications... if (node is DynamicParser.Node.GetMember) { if (main != null) throw new ArgumentException(string.Format("Main '{0}' is already set when parsing '{1}'.", main, result)); - + main = ((DynamicParser.Node.GetMember)node).Name; - + if (node.Host is DynamicParser.Node.GetMember) { // If leaf then decorate main = Database.DecorateName(main); - + // Supporting multipart specifications... node = node.Host; - + // Get table/alias name string table = ((DynamicParser.Node.GetMember)node).Name; bool isAlias = node.Host is DynamicParser.Node.Argument && IsTableAlias(table); - + if (isAlias) main = string.Format("{0}.{1}", table, main); else if (node.Host is DynamicParser.Node.GetMember) @@ -9017,7 +9057,7 @@ namespace DynamORM else if (node.Host is DynamicParser.Node.Argument) { string table = ((DynamicParser.Node.Argument)node.Host).Name; - + if (IsTableAlias(table)) main = string.Format("{0}.{1}", table, Database.DecorateName(main)); else if (!IsTableAlias(main)) @@ -9025,74 +9065,75 @@ namespace DynamORM } else if (!(node.Host is DynamicParser.Node.Argument && IsTableAlias(main))) main = Database.DecorateName(main); - + node = node.Host; - + continue; } - + // Support for generic sources... if (node is DynamicParser.Node.Invoke) { if (main != null) throw new ArgumentException(string.Format("Main '{0}' is already set when parsing '{1}'.", main, result)); - + main = string.Format("{0}", Parse(node, rawstr: true, pars: Parameters)); - + node = node.Host; continue; } - + // Just finished the parsing... if (node is DynamicParser.Node.Argument) { if (string.IsNullOrEmpty(main) && IsTableAlias(node.Name)) main = node.Name; - + break; } - + // All others are assumed to be part of the main element... if (main != null) throw new ArgumentException(string.Format("Main '{0}' is already set when parsing '{1}'.", main, result)); main = Parse(node, pars: Parameters); - + break; } - + column = main; } - + #endregion Helpers - + #region IExtendedDisposable - + /// Performs application-defined tasks associated with /// freeing, releasing, or resetting unmanaged resources. public override void Dispose() { base.Dispose(); - + _select = _from = _join = _groupby = _orderby = null; } - + #endregion IExtendedDisposable } - + + /// Update query builder. internal class DynamicUpdateQueryBuilder : DynamicModifyBuilder, IDynamicUpdateQueryBuilder, DynamicQueryBuilder.IQueryWithWhere { private string _columns; - + internal DynamicUpdateQueryBuilder(DynamicDatabase db) : base(db) { } - + public DynamicUpdateQueryBuilder(DynamicDatabase db, string tableName) : base(db, tableName) { } - + /// Generates the text this command will execute against the underlying database. /// The text to execute against the underlying database. /// This method must be override by derived classes. @@ -9105,9 +9146,9 @@ namespace DynamORM string.IsNullOrEmpty(WhereCondition) ? string.Empty : " WHERE ", WhereCondition); } - + #region Update - + /// Add update value or where condition using schema. /// Update or where column name. /// Column value. @@ -9115,18 +9156,18 @@ namespace DynamORM public virtual IDynamicUpdateQueryBuilder Update(string column, object value) { DynamicSchemaColumn? col = GetColumnFromSchema(column); - + if (!col.HasValue && SupportSchema) throw new InvalidOperationException(string.Format("Column '{0}' not found in schema, can't use universal approach.", column)); - + if (col.HasValue && col.Value.IsKey) Where(column, value); else Values(column, value); - + return this; } - + /// Add update values and where condition columns using schema. /// Set values or conditions as properties and values of an object. /// Builder instance. @@ -9135,58 +9176,58 @@ namespace DynamORM if (conditions is DynamicColumn) { DynamicColumn column = (DynamicColumn)conditions; - + DynamicSchemaColumn? col = column.Schema ?? GetColumnFromSchema(column.ColumnName); - + if (!col.HasValue && SupportSchema) throw new InvalidOperationException(string.Format("Column '{0}' not found in schema, can't use universal approach.", column)); - + if (col.HasValue && col.Value.IsKey) Where(column); else Values(column.ColumnName, column.Value); - + return this; } - + IDictionary dict = conditions.ToDictionary(); DynamicTypeMap mapper = DynamicMapperCache.GetMapper(conditions.GetType()); - + foreach (KeyValuePair con in dict) { if (mapper.Ignored.Contains(con.Key)) continue; - + string colName = mapper != null ? mapper.PropertyMap.TryGetValue(con.Key) ?? con.Key : con.Key; DynamicSchemaColumn? col = GetColumnFromSchema(colName); - + if (!col.HasValue && SupportSchema) throw new InvalidOperationException(string.Format("Column '{0}' not found in schema, can't use universal approach.", colName)); - + if (col.HasValue) { colName = col.Value.Name; - + if (col.Value.IsKey) { Where(colName, con.Value); - + continue; } } - + DynamicPropertyInvoker propMap = mapper.ColumnsMap.TryGetValue(colName.ToLower()); if (propMap == null || propMap.Column == null || !propMap.Column.IsNoUpdate) Values(colName, con.Value); } - + return this; } - + #endregion Update - + #region Values - + /// /// Specifies the columns to update using the dynamic lambda expressions given. Each expression correspond to one /// column, and can: @@ -9199,35 +9240,35 @@ namespace DynamORM { if (func == null) throw new ArgumentNullException("Array of specifications cannot be null."); - + int index = -1; foreach (Func f in func) { index++; if (f == null) throw new ArgumentNullException(string.Format("Specification #{0} cannot be null.", index)); - + object result = null; - + using (DynamicParser p = DynamicParser.Parse(f)) result = p.Result; - + if (result == null) throw new ArgumentException(string.Format("Specification #{0} resolves to null.", index)); - + string main = null; string value = null; string str = null; - + // When 'x => x.Table.Column = value' or 'x => x.Column = value'... if (result is DynamicParser.Node.SetMember) { DynamicParser.Node.SetMember node = (DynamicParser.Node.SetMember)result; - + DynamicSchemaColumn? col = GetColumnFromSchema(node.Name); main = Database.DecorateName(node.Name); value = Parse(node.Value, ref col, pars: Parameters, nulls: true); - + str = string.Format("{0} = {1}", main, value); _columns = _columns == null ? str : string.Format("{0}, {1}", _columns, str); continue; @@ -9237,17 +9278,17 @@ namespace DynamORM Values(result); continue; } - + // Other specifications are considered invalid... string err = string.Format("Specification '{0}' is invalid.", result); str = Parse(result); if (str.Contains("=")) err += " May have you used a '==' instead of a '=' operator?"; throw new ArgumentException(err); } - + return this; } - + /// Add insert fields. /// Insert column. /// Insert value. @@ -9257,20 +9298,20 @@ namespace DynamORM if (value is DynamicColumn) { DynamicColumn v = (DynamicColumn)value; - + if (string.IsNullOrEmpty(v.ColumnName)) v.ColumnName = column; - + return Values(v); } - + return Values(new DynamicColumn { ColumnName = column, Value = value, }); } - + /// Add insert fields. /// Set insert value as properties and values of an object. /// Builder instance. @@ -9280,19 +9321,19 @@ namespace DynamORM { DynamicColumn column = (DynamicColumn)o; DynamicSchemaColumn? col = column.Schema ?? GetColumnFromSchema(column.ColumnName); - + string main = FixObjectName(column.ColumnName, onlyColumn: true); string value = Parse(column.Value, ref col, pars: Parameters, nulls: true); - + string str = string.Format("{0} = {1}", main, value); _columns = _columns == null ? str : string.Format("{0}, {1}", _columns, str); - + return this; } - + IDictionary dict = o.ToDictionary(); DynamicTypeMap mapper = DynamicMapperCache.GetMapper(o.GetType()); - + if (mapper != null) { foreach (KeyValuePair con in dict) @@ -9302,14 +9343,14 @@ namespace DynamORM else foreach (KeyValuePair con in dict) Values(con.Key, con.Value); - + return this; } - + #endregion Values - + #region Where - + /// /// Adds to the 'Where' clause the contents obtained from parsing the dynamic lambda expression given. The condition /// is parsed to the appropriate syntax, where the specific customs virtual methods supported by the parser are used @@ -9324,7 +9365,7 @@ namespace DynamORM { return this.InternalWhere(func); } - + /// Add where condition. /// Condition column with operator and value. /// Builder instance. @@ -9332,7 +9373,7 @@ namespace DynamORM { return this.InternalWhere(column); } - + /// Add where condition. /// Condition column. /// Condition operator. @@ -9342,7 +9383,7 @@ namespace DynamORM { return this.InternalWhere(column, op, value); } - + /// Add where condition. /// Condition column. /// Condition value. @@ -9351,7 +9392,7 @@ namespace DynamORM { return this.InternalWhere(column, value); } - + /// Add where condition. /// Set conditions as properties and values of an object. /// If true use schema to determine key columns and ignore those which @@ -9361,27 +9402,30 @@ namespace DynamORM { return this.InternalWhere(conditions, schema); } - + #endregion Where - + #region IExtendedDisposable - + /// Performs application-defined tasks associated with /// freeing, releasing, or resetting unmanaged resources. public override void Dispose() { base.Dispose(); - + _columns = null; } - + #endregion IExtendedDisposable } + + } + } namespace Helpers - { + { /// Defines methods to support the comparison of collections for equality. /// The type of collection to compare. public class CollectionComparer : IEqualityComparer> @@ -9394,7 +9438,7 @@ namespace DynamORM { return Equals(first, second); } - + /// Returns a hash code for the specified object. /// The enumerable for which a hash code is to be returned. /// A hash code for the specified object. @@ -9402,20 +9446,20 @@ namespace DynamORM { return GetHashCode(enumerable); } - + /// Returns a hash code for the specified object. /// The enumerable for which a hash code is to be returned. /// A hash code for the specified object. public static int GetHashCode(IEnumerable enumerable) { int hash = 17; - + foreach (T val in enumerable.OrderBy(x => x)) hash = (hash * 23) + val.GetHashCode(); - + return hash; } - + /// Determines whether the specified objects are equal. /// The first object of type T to compare. /// The second object of type T to compare. @@ -9424,42 +9468,42 @@ namespace DynamORM { if ((first == null) != (second == null)) return false; - + if (!object.ReferenceEquals(first, second) && (first != null)) { if (first.Count() != second.Count()) return false; - + if ((first.Count() != 0) && HaveMismatchedElement(first, second)) return false; } - + return true; } - + private static bool HaveMismatchedElement(IEnumerable first, IEnumerable second) { int firstCount; int secondCount; - + Dictionary firstElementCounts = GetElementCounts(first, out firstCount); Dictionary secondElementCounts = GetElementCounts(second, out secondCount); - + if (firstCount != secondCount) return true; - + foreach (KeyValuePair kvp in firstElementCounts) if (kvp.Value != (secondElementCounts.TryGetNullable(kvp.Key) ?? 0)) return true; - + return false; } - + private static Dictionary GetElementCounts(IEnumerable enumerable, out int nullCount) { Dictionary dictionary = new Dictionary(); nullCount = 0; - + foreach (T element in enumerable) { if (element == null) @@ -9470,44 +9514,45 @@ namespace DynamORM dictionary[element] = ++count; } } - + return dictionary; } } - + + /// Framework detection and specific implementations. public static class FrameworkTools { #region Mono or .NET Framework detection - + /// This is pretty simple trick. private static bool _isMono = Type.GetType("Mono.Runtime") != null; - + /// Gets a value indicating whether application is running under mono runtime. public static bool IsMono { get { return _isMono; } } - + #endregion Mono or .NET Framework detection - + static FrameworkTools() { _frameworkTypeArgumentsGetter = CreateTypeArgumentsGetter(); } - + #region GetGenericTypeArguments - + private static Func> _frameworkTypeArgumentsGetter = null; - + private static Func> CreateTypeArgumentsGetter() { // HACK: Creating binders assuming types are correct... this may fail. if (IsMono) { Type binderType = typeof(Microsoft.CSharp.RuntimeBinder.RuntimeBinderException).Assembly.GetType("Microsoft.CSharp.RuntimeBinder.CSharpInvokeMemberBinder"); - + if (binderType != null) { ParameterExpression param = Expression.Parameter(typeof(InvokeMemberBinder), "o"); - + return Expression.Lambda>>( Expression.TypeAs( Expression.Field( @@ -9518,16 +9563,16 @@ namespace DynamORM else { Type inter = typeof(Microsoft.CSharp.RuntimeBinder.RuntimeBinderException).Assembly.GetType("Microsoft.CSharp.RuntimeBinder.ICSharpInvokeOrInvokeMemberBinder"); - + if (inter != null) { PropertyInfo prop = inter.GetProperty("TypeArguments"); - + if (!prop.CanRead) return null; - + ParameterExpression objParm = Expression.Parameter(typeof(InvokeMemberBinder), "o"); - + return Expression.Lambda>>( Expression.TypeAs( Expression.Property( @@ -9535,10 +9580,10 @@ namespace DynamORM typeof(IList)), objParm).Compile(); } } - + return null; } - + /// Extension method allowing to easily extract generic type /// arguments from assuming that it /// inherits from @@ -9555,16 +9600,16 @@ namespace DynamORM // First try to use delegate if exist if (_frameworkTypeArgumentsGetter != null) return _frameworkTypeArgumentsGetter(binder); - + if (_isMono) { // HACK: Using Reflection // In mono this is trivial. - + // First we get field info. FieldInfo field = binder.GetType().GetField("typeArguments", BindingFlags.Instance | BindingFlags.Public | BindingFlags.NonPublic | BindingFlags.Static); - + // If this was a success get and return it's value if (field != null) return field.GetValue(binder) as IList; @@ -9573,28 +9618,29 @@ namespace DynamORM { // HACK: Using Reflection // In this case, we need more aerobic :D - + // First, get the interface Type inter = binder.GetType().GetInterface("Microsoft.CSharp.RuntimeBinder.ICSharpInvokeOrInvokeMemberBinder"); - + if (inter != null) { // Now get property. PropertyInfo prop = inter.GetProperty("TypeArguments"); - + // If we have a property, return it's value if (prop != null) return prop.GetValue(binder, null) as IList; } } - + // Sadly return null if failed. return null; } - + #endregion GetGenericTypeArguments } - + + /// Extends interface. public interface IExtendedDisposable : IDisposable { @@ -9606,7 +9652,8 @@ namespace DynamORM /// bool IsDisposed { get; } } - + + /// Extends interface. public interface IFinalizerDisposable : IExtendedDisposable { @@ -9615,7 +9662,8 @@ namespace DynamORM /// If set to true dispose object. void Dispose(bool disposing); } - + + /// Class containing useful string extensions. internal static class StringExtensions { @@ -9624,20 +9672,20 @@ namespace DynamORM InvalidMultipartMemberChars = _InvalidMultipartMemberChars.ToCharArray(); InvalidMemberChars = _InvalidMemberChars.ToCharArray(); } - + private static readonly string _InvalidMultipartMemberChars = " +-*/^%[]{}()!\"\\&=?¿"; private static readonly string _InvalidMemberChars = "." + _InvalidMultipartMemberChars; - + /// /// Gets an array with some invalid characters that cannot be used with multipart names for class members. /// public static char[] InvalidMultipartMemberChars { get; private set; } - + /// /// Gets an array with some invalid characters that cannot be used with names for class members. /// public static char[] InvalidMemberChars { get; private set; } - + /// /// Provides with an alternate and generic way to obtain an alternate string representation for this instance, /// applying the following rules: @@ -9659,34 +9707,34 @@ namespace DynamORM { if (obj == null) return nullString; if (obj is string) return (string)obj; - + Type type = obj.GetType(); if (type.IsEnum) return obj.ToString(); - + // If the ToString() method has been overriden (by the type itself, or by its parents), let's use it... MethodInfo method = type.GetMethod("ToString", Type.EmptyTypes); if (method.DeclaringType != typeof(object)) return obj.ToString(); - + // For alll other cases... StringBuilder sb = new StringBuilder(); bool first = true; - + // Dictionaries... if (obj is IDictionary) { if (brackets == null || brackets.Length < 2) brackets = "[]".ToCharArray(); - + sb.AppendFormat("{0}", brackets[0]); first = true; foreach (DictionaryEntry kvp in (IDictionary)obj) { if (!first) sb.Append(", "); else first = false; sb.AppendFormat("'{0}'='{1}'", kvp.Key.Sketch(), kvp.Value.Sketch()); } - + sb.AppendFormat("{0}", brackets[1]); return sb.ToString(); } - + // IEnumerables... IEnumerator ator = null; if (obj is IEnumerable) @@ -9697,7 +9745,7 @@ namespace DynamORM if (method != null) ator = (IEnumerator)method.Invoke(obj, null); } - + if (ator != null) { if (brackets == null || brackets.Length < 2) brackets = "[]".ToCharArray(); @@ -9706,27 +9754,27 @@ namespace DynamORM if (!first) sb.Append(", "); else first = false; sb.AppendFormat("{0}", ator.Current.Sketch()); } - + sb.AppendFormat("{0}", brackets[1]); - + if (ator is IDisposable) ((IDisposable)ator).Dispose(); - + return sb.ToString(); } - + // As a last resort, using the public properties (or fields if needed, or type name)... BindingFlags flags = BindingFlags.Public | BindingFlags.Instance | BindingFlags.FlattenHierarchy; PropertyInfo[] props = type.GetProperties(flags); FieldInfo[] infos = type.GetFields(flags); - + if (props.Length == 0 && infos.Length == 0) sb.Append(type.FullName); // Fallback if needed else { if (brackets == null || brackets.Length < 2) brackets = "{}".ToCharArray(); sb.AppendFormat("{0}", brackets[0]); first = true; - + if (props.Length != 0) { foreach (PropertyInfo prop in props) @@ -9746,14 +9794,14 @@ namespace DynamORM } } } - + sb.AppendFormat("{0}", brackets[1]); } - + // And returning... return sb.ToString(); } - + /// /// Returns true if the target string contains any of the characters given. /// @@ -9764,12 +9812,12 @@ namespace DynamORM { if (source == null) throw new ArgumentNullException("source", "Source string cannot be null."); if (items == null) throw new ArgumentNullException("items", "Array of characters to test cannot be null."); - + if (items.Length == 0) return false; // No characters to validate int ix = source.IndexOfAny(items); return ix >= 0 ? true : false; } - + /// /// Returns a new validated string using the rules given. /// @@ -9797,14 +9845,14 @@ namespace DynamORM { // Assuring a valid descriptor... if (string.IsNullOrWhiteSpace(desc)) desc = "Source"; - + // Validating if null sources are accepted... if (source == null) { if (!canbeNull) throw new ArgumentNullException(desc, string.Format("{0} cannot be null.", desc)); return null; } - + // Trimming if needed... if (trim && !(trimStart || trimEnd)) source = source.Trim(); else @@ -9812,47 +9860,47 @@ namespace DynamORM if (trimStart) source = source.TrimStart(' '); if (trimEnd) source = source.TrimEnd(' '); } - + // Adjusting lenght... if (minLen > 0) { if (padLeft != '\0') source = source.PadLeft(minLen, padLeft); if (padRight != '\0') source = source.PadRight(minLen, padRight); } - + if (maxLen > 0) { if (padLeft != '\0') source = source.PadLeft(maxLen, padLeft); if (padRight != '\0') source = source.PadRight(maxLen, padRight); } - + // Validating emptyness and lenghts... if (source.Length == 0) { if (!canbeEmpty) throw new ArgumentException(string.Format("{0} cannot be empty.", desc)); return string.Empty; } - + if (minLen >= 0 && source.Length < minLen) throw new ArgumentException(string.Format("Lenght of {0} '{1}' is lower than '{2}'.", desc, source, minLen)); if (maxLen >= 0 && source.Length > maxLen) throw new ArgumentException(string.Format("Lenght of {0} '{1}' is bigger than '{2}'.", desc, source, maxLen)); - + // Checking invalid chars... if (invalidChars != null) { int n = source.IndexOfAny(invalidChars); if (n >= 0) throw new ArgumentException(string.Format("Invalid character '{0}' found in {1} '{2}'.", source[n], desc, source)); } - + // Checking valid chars... if (validChars != null) { int n = validChars.ToString().IndexOfAny(source.ToCharArray()); if (n >= 0) throw new ArgumentException(string.Format("Invalid character '{0}' found in {1} '{2}'.", validChars.ToString()[n], desc, source)); } - + return source; } - + /// /// Splits the given string with the 'something AS alias' format, returning a tuple containing its 'something' and 'alias' parts. /// If no alias is detected, then its component in the tuple returned is null and all the contents from the source @@ -9863,11 +9911,11 @@ namespace DynamORM public static Tuple SplitSomethingAndAlias(this string source) { source = source.Validated("[Something AS Alias]"); - + string something = null; string alias = null; int n = source.LastIndexOf(" AS ", StringComparison.OrdinalIgnoreCase); - + if (n < 0) something = source; else @@ -9875,10 +9923,10 @@ namespace DynamORM something = source.Substring(0, n); alias = source.Substring(n + 4); } - + return new Tuple(something, alias); } - + /// Allows to replace parameters inside of string. /// String containing parameters in format [$ParameterName]. /// Function that should return value that will be placed in string in place of placed parameter. @@ -9890,29 +9938,30 @@ namespace DynamORM int startPos = 0, endPos = 0; prefix.Validated(); sufix.Validated(); - + startPos = stringToFill.IndexOf(prefix, startPos); while (startPos >= 0) { endPos = stringToFill.IndexOf(sufix, startPos + prefix.Length); int nextStartPos = stringToFill.IndexOf(prefix, startPos + prefix.Length); - + if (endPos > startPos + prefix.Length + 1 && (nextStartPos > endPos || nextStartPos == -1)) { string paramName = stringToFill.Substring(startPos + prefix.Length, endPos - (startPos + prefix.Length)); - + stringToFill = stringToFill .Remove(startPos, (endPos - startPos) + sufix.Length) .Insert(startPos, getValue(paramName)); } - + startPos = stringToFill.IndexOf(prefix, startPos + prefix.Length); } - + return stringToFill; } } - + + /// Class contains unclassified extensions. internal static class UnclassifiedExtensions { @@ -9934,7 +9983,7 @@ namespace DynamORM return obj != null && obj != DBNull.Value ? func(obj) : elseValue; } - + /// Easy way to use conditional value. /// Includes . /// Input object type to check. @@ -9954,7 +10003,7 @@ namespace DynamORM return obj != null && obj != DBNull.Value ? func(obj) : elseFunc != null ? elseFunc() : default(R); } - + /// Simple distinct by selector extension. /// The enumerator of elements distinct by specified selector. /// Source collection. @@ -9969,16 +10018,17 @@ namespace DynamORM yield return element; } } + namespace Dynamics - { + { /// /// Class able to parse dynamic lambda expressions. Allows to create dynamic logic. /// public class DynamicParser : IExtendedDisposable { #region Node - + /// /// Generic bindable operation where some of its operands is a dynamic argument, or a dynamic member or /// a method of that argument. @@ -9987,9 +10037,9 @@ namespace DynamORM public class Node : IDynamicMetaObjectProvider, IFinalizerDisposable, ISerializable { private DynamicParser _parser = null; - + #region MetaNode - + /// /// Represents the dynamic binding and a binding logic of /// an object participating in the dynamic binding. @@ -10006,20 +10056,20 @@ namespace DynamORM : base(parameter, rest, value) { } - + // Func was cool but caused memory leaks private DynamicMetaObject GetBinder(Node node) { Node o = (Node)this.Value; node.Parser = o.Parser; o.Parser.Last = node; - + ParameterExpression p = Expression.Variable(typeof(Node), "ret"); BlockExpression exp = Expression.Block(new ParameterExpression[] { p }, Expression.Assign(p, Expression.Constant(node))); - + return new MetaNode(exp, this.Restrictions, node); } - + /// /// Performs the binding of the dynamic get member operation. /// @@ -10031,7 +10081,7 @@ namespace DynamORM { return GetBinder(new GetMember((Node)this.Value, binder.Name)); } - + /// /// Performs the binding of the dynamic set member operation. /// @@ -10044,7 +10094,7 @@ namespace DynamORM { return GetBinder(new SetMember((Node)this.Value, binder.Name, value.Value)); } - + /// /// Performs the binding of the dynamic get index operation. /// @@ -10057,7 +10107,7 @@ namespace DynamORM { return GetBinder(new GetIndex((Node)this.Value, MetaList2List(indexes))); } - + /// /// Performs the binding of the dynamic set index operation. /// @@ -10071,7 +10121,7 @@ namespace DynamORM { return GetBinder(new SetIndex((Node)this.Value, MetaList2List(indexes), value.Value)); } - + /// /// Performs the binding of the dynamic invoke operation. /// @@ -10084,7 +10134,7 @@ namespace DynamORM { return GetBinder(new Invoke((Node)this.Value, MetaList2List(args))); } - + /// /// Performs the binding of the dynamic invoke member operation. /// @@ -10097,7 +10147,7 @@ namespace DynamORM { return GetBinder(new Method((Node)this.Value, binder.Name, MetaList2List(args))); } - + /// /// Performs the binding of the dynamic binary operation. /// @@ -10110,7 +10160,7 @@ namespace DynamORM { return GetBinder(new Binary((Node)this.Value, binder.Operation, arg.Value)); } - + /// /// Performs the binding of the dynamic unary operation. /// @@ -10123,20 +10173,20 @@ namespace DynamORM Node o = (Node)this.Value; Unary node = new Unary(o, binder.Operation) { Parser = o.Parser }; o.Parser.Last = node; - + // If operation is 'IsTrue' or 'IsFalse', we will return false to keep the engine working... object ret = node; if (binder.Operation == ExpressionType.IsTrue) ret = (object)false; if (binder.Operation == ExpressionType.IsFalse) ret = (object)false; - + ParameterExpression p = Expression.Variable(ret.GetType(), "ret"); // the type is now obtained from "ret" BlockExpression exp = Expression.Block( new ParameterExpression[] { p }, Expression.Assign(p, Expression.Constant(ret))); // the expression is now obtained from "ret" - + return new MetaNode(exp, this.Restrictions, node); } - + /// /// Performs the binding of the dynamic conversion operation. /// @@ -10149,11 +10199,11 @@ namespace DynamORM Node o = (Node)this.Value; Convert node = new Convert(o, binder.ReturnType) { Parser = o.Parser }; o.Parser.Last = node; - + // Reducing the object to return if this is an assignment node... object ret = o; bool done = false; - + while (!done) { if (ret is SetMember) @@ -10163,7 +10213,7 @@ namespace DynamORM else done = true; } - + // Creating an instance... if (binder.ReturnType == typeof(string)) ret = ret.ToString(); else @@ -10181,31 +10231,31 @@ namespace DynamORM ret = new object(); } } - + ParameterExpression p = Expression.Variable(binder.ReturnType, "ret"); BlockExpression exp = Expression.Block( new ParameterExpression[] { p }, Expression.Assign(p, Expression.Constant(ret, binder.ReturnType))); // specifying binder.ReturnType - + return new MetaNode(exp, this.Restrictions, node); } - + private static object[] MetaList2List(DynamicMetaObject[] metaObjects) { if (metaObjects == null) return null; - + object[] list = new object[metaObjects.Length]; for (int i = 0; i < metaObjects.Length; i++) list[i] = metaObjects[i].Value; - + return list; } } - + #endregion MetaNode - + #region Argument - + /// /// Describe a dynamic argument used in a dynamic lambda expression. /// @@ -10220,7 +10270,7 @@ namespace DynamORM : base(name) { } - + /// /// Initializes a new instance of the class. /// @@ -10230,7 +10280,7 @@ namespace DynamORM : base(info, context) { } - + /// Returns a that represents this instance. /// A that represents this instance. public override string ToString() @@ -10240,11 +10290,11 @@ namespace DynamORM return Name; } } - + #endregion Argument - + #region GetMember - + /// /// Describe a 'get member' operation, as in 'x => x.Member'. /// @@ -10260,7 +10310,7 @@ namespace DynamORM : base(host, name) { } - + /// /// Initializes a new instance of the class. /// @@ -10270,7 +10320,7 @@ namespace DynamORM : base(info, context) { } - + /// Returns a that represents this instance. /// A that represents this instance. public override string ToString() @@ -10280,11 +10330,11 @@ namespace DynamORM return string.Format("{0}.{1}", Host.Sketch(), Name.Sketch()); } } - + #endregion GetMember - + #region SetMember - + /// /// Describe a 'set member' operation, as in 'x => x.Member = y'. /// @@ -10296,7 +10346,7 @@ namespace DynamORM /// assigned to this instance, or if this instance is disposed. /// public object Value { get; private set; } - + /// /// Initializes a new instance of the class. /// @@ -10308,7 +10358,7 @@ namespace DynamORM { Value = value; } - + /// /// Initializes a new instance of the class. /// @@ -10320,7 +10370,7 @@ namespace DynamORM string type = info.GetString("MemberType"); Value = type == "NULL" ? null : info.GetValue("MemberValue", Type.GetType(type)); } - + /// /// Gets the object data. /// @@ -10331,10 +10381,10 @@ namespace DynamORM info.AddValue("MemberType", Value == null ? "NULL" : Value.GetType().AssemblyQualifiedName); if (Value != null) info.AddValue("MemberValue", Value); - + base.GetObjectData(info, context); } - + /// Returns a that represents this instance. /// A that represents this instance. public override string ToString() @@ -10344,11 +10394,11 @@ namespace DynamORM return string.Format("({0}.{1} = {2})", Host.Sketch(), Name.Sketch(), Value.Sketch()); } } - + #endregion SetMember - + #region GetIndex - + /// /// Describe a 'get indexed' operation, as in 'x => x.Member[...]'. /// @@ -10357,7 +10407,7 @@ namespace DynamORM { /// Gets the indexes. public object[] Indexes { get; internal set; } - + /// /// Initializes a new instance of the class. /// @@ -10372,10 +10422,10 @@ namespace DynamORM throw new ArgumentNullException("indexes", "Indexes array cannot be null."); if (indexes.Length == 0) throw new ArgumentException("Indexes array cannot be empty."); - + Indexes = indexes; } - + /// /// Initializes a new instance of the class. /// @@ -10385,7 +10435,7 @@ namespace DynamORM : base(info, context) { int count = (int)info.GetValue("IndexCount", typeof(int)); - + if (count != 0) { Indexes = new object[count]; for (int i = 0; i < count; i++) @@ -10396,7 +10446,7 @@ namespace DynamORM } } } - + /// /// Gets the object data. /// @@ -10410,25 +10460,25 @@ namespace DynamORM info.AddValue("IndexType" + i, Indexes[i] == null ? "NULL" : Indexes[i].GetType().AssemblyQualifiedName); if (Indexes[i] != null) info.AddValue("IndexValue" + i, Indexes[i]); } - + base.GetObjectData(info, context); } - + /// Returns a that represents this instance. /// A that represents this instance. public override string ToString() { if (IsDisposed) return "{DynamicParser::Node::GetIndex::Disposed}"; - + return string.Format("{0}{1}", Host.Sketch(), Indexes == null ? "[empty]" : Indexes.Sketch()); } } - + #endregion GetIndex - + #region SetIndex - + /// /// Describe a 'set indexed' operation, as in 'x => x.Member[...] = Value'. /// @@ -10440,7 +10490,7 @@ namespace DynamORM /// assigned to this instance, or if this instance is disposed. /// public object Value { get; private set; } - + /// /// Initializes a new instance of the class. /// @@ -10452,7 +10502,7 @@ namespace DynamORM { Value = value; } - + /// /// Initializes a new instance of the class. /// @@ -10464,7 +10514,7 @@ namespace DynamORM string type = info.GetString("MemberType"); Value = type == "NULL" ? null : info.GetValue("MemberValue", Type.GetType(type)); } - + /// /// Gets the object data. /// @@ -10474,25 +10524,25 @@ namespace DynamORM { info.AddValue("MemberType", Value == null ? "NULL" : Value.GetType().AssemblyQualifiedName); if (Value != null) info.AddValue("MemberValue", Value); - + base.GetObjectData(info, context); } - + /// Returns a that represents this instance. /// A that represents this instance. public override string ToString() { if (IsDisposed) return "{DynamicParser::Node::SetIndex::Disposed}"; - + return string.Format("({0}{1} = {2})", Host.Sketch(), Indexes == null ? "[empty]" : Indexes.Sketch(), Value.Sketch()); } } - + #endregion SetIndex - + #region Invoke - + /// /// Describe a method invocation operation, as in 'x => x.Method(...)". /// @@ -10501,7 +10551,7 @@ namespace DynamORM { /// Gets the arguments. public object[] Arguments { get; internal set; } - + /// /// Initializes a new instance of the class. /// @@ -10512,7 +10562,7 @@ namespace DynamORM { Arguments = arguments == null || arguments.Length == 0 ? null : arguments; } - + /// /// Initializes a new instance of the class. /// @@ -10522,7 +10572,7 @@ namespace DynamORM : base(info, context) { int count = (int)info.GetValue("ArgumentCount", typeof(int)); - + if (count != 0) { Arguments = new object[count]; for (int i = 0; i < count; i++) @@ -10533,7 +10583,7 @@ namespace DynamORM } } } - + /// /// Gets the object data. /// @@ -10547,25 +10597,25 @@ namespace DynamORM info.AddValue("ArgumentType" + i, Arguments[i] == null ? "NULL" : Arguments[i].GetType().AssemblyQualifiedName); if (Arguments[i] != null) info.AddValue("ArgumentValue" + i, Arguments[i]); } - + base.GetObjectData(info, context); } - + /// Returns a that represents this instance. /// A that represents this instance. public override string ToString() { if (IsDisposed) return "{DynamicParser::Node::Invoke::Disposed}"; - + return string.Format("{0}{1}", Host.Sketch(), Arguments == null ? "()" : Arguments.Sketch(brackets: "()".ToCharArray())); } } - + #endregion Invoke - + #region Method - + /// /// Describe a method invocation operation, as in 'x => x.Method(...)". /// @@ -10574,7 +10624,7 @@ namespace DynamORM { /// Gets the arguments. public object[] Arguments { get; internal set; } - + /// /// Initializes a new instance of the class. /// @@ -10586,7 +10636,7 @@ namespace DynamORM { Arguments = arguments == null || arguments.Length == 0 ? null : arguments; } - + /// /// Initializes a new instance of the class. /// @@ -10596,7 +10646,7 @@ namespace DynamORM : base(info, context) { int count = (int)info.GetValue("ArgumentCount", typeof(int)); - + if (count != 0) { Arguments = new object[count]; for (int i = 0; i < count; i++) @@ -10607,7 +10657,7 @@ namespace DynamORM } } } - + /// /// Gets the object data. /// @@ -10621,25 +10671,25 @@ namespace DynamORM info.AddValue("ArgumentType" + i, Arguments[i] == null ? "NULL" : Arguments[i].GetType().AssemblyQualifiedName); if (Arguments[i] != null) info.AddValue("ArgumentValue" + i, Arguments[i]); } - + base.GetObjectData(info, context); } - + /// Returns a that represents this instance. /// A that represents this instance. public override string ToString() { if (IsDisposed) return "{DynamicParser::Node::Method::Disposed}"; - + return string.Format("{0}.{1}{2}", Host.Sketch(), Name.Sketch(), Arguments == null ? "()" : Arguments.Sketch(brackets: "()".ToCharArray())); } } - + #endregion Method - + #region Binary - + /// /// Represents a binary operation between a dynamic element and an arbitrary object, including null ones, as in /// 'x => (x && null)'. The left operand must be an instance of , whereas the right one @@ -10650,13 +10700,13 @@ namespace DynamORM { /// Gets the operation. public ExpressionType Operation { get; private set; } - + /// Gets host of the . public Node Left { get { return Host; } } - + /// Gets the right side value. public object Right { get; private set; } - + /// /// Initializes a new instance of the class. /// @@ -10669,7 +10719,7 @@ namespace DynamORM Operation = operation; Right = right; } - + /// /// Initializes a new instance of the class. /// @@ -10679,11 +10729,11 @@ namespace DynamORM : base(info, context) { Operation = (ExpressionType)info.GetValue("Operation", typeof(ExpressionType)); - + string type = info.GetString("RightType"); Right = type == "NULL" ? null : (Node)info.GetValue("RightItem", Type.GetType(type)); } - + /// /// Gets the object data. /// @@ -10692,47 +10742,47 @@ namespace DynamORM public override void GetObjectData(SerializationInfo info, StreamingContext context) { info.AddValue("Operation", Operation); - + info.AddValue("RightType", Right == null ? "NULL" : Right.GetType().AssemblyQualifiedName); if (Right != null) info.AddValue("RightItem", Right); - + base.GetObjectData(info, context); } - + /// Returns a that represents this instance. /// A that represents this instance. public override string ToString() { if (IsDisposed) return "{DynamicParser::Node::Binary::Disposed}"; - + return string.Format("({0} {1} {2})", Host.Sketch(), Operation, Right.Sketch()); } - + /// Performs application-defined tasks associated with /// freeing, releasing, or resetting unmanaged resources. /// If set to true dispose object. public override void Dispose(bool disposing) { base.Dispose(disposing); - + if (disposing && Right != null && Right is Node) { Node n = (Node)Right; - + if (!n.IsDisposed) n.Dispose(disposing); - + Right = null; } } } - + #endregion Binary - + #region Unary - + /// /// Represents an unary operation, as in 'x => !x'. The target must be a instance. There /// is no distinction between pre- and post- version of the same operation. @@ -10742,10 +10792,10 @@ namespace DynamORM { /// Gets the operation. public ExpressionType Operation { get; private set; } - + /// Gets host of the . public Node Target { get { return Host; } } - + /// /// Initializes a new instance of the class. /// @@ -10756,7 +10806,7 @@ namespace DynamORM { Operation = operation; } - + /// /// Initializes a new instance of the class. /// @@ -10767,7 +10817,7 @@ namespace DynamORM { Operation = (ExpressionType)info.GetValue("Operation", typeof(ExpressionType)); } - + /// /// Gets the object data. /// @@ -10776,25 +10826,25 @@ namespace DynamORM public override void GetObjectData(SerializationInfo info, StreamingContext context) { info.AddValue("Operation", Operation); - + base.GetObjectData(info, context); } - + /// Returns a that represents this instance. /// A that represents this instance. public override string ToString() { if (IsDisposed) return "{DynamicParser::Node::Binary::Disposed}"; - + return string.Format("({0} {1})", Operation, Host.Sketch()); } } - + #endregion Unary - + #region Convert - + /// /// Represents a conversion operation, as in 'x => (string)x'. /// @@ -10803,10 +10853,10 @@ namespace DynamORM { /// Gets the new type to which value will be converted. public Type NewType { get; private set; } - + /// Gets host of the . public Node Target { get { return Host; } } - + /// /// Initializes a new instance of the class. /// @@ -10817,7 +10867,7 @@ namespace DynamORM { NewType = newType; } - + /// /// Initializes a new instance of the class. /// @@ -10828,7 +10878,7 @@ namespace DynamORM { NewType = (Type)info.GetValue("NewType", typeof(Type)); } - + /// /// Gets the object data. /// @@ -10837,21 +10887,21 @@ namespace DynamORM public override void GetObjectData(SerializationInfo info, StreamingContext context) { info.AddValue("NewType", NewType); - + base.GetObjectData(info, context); } } - + #endregion Convert - + /// /// Gets the name of the member. It might be null if this instance is disposed. /// public string Name { get; internal set; } - + /// Gets host of the . public Node Host { get; internal set; } - + /// Gets reference to the parser. public DynamicParser Parser { @@ -10863,7 +10913,7 @@ namespace DynamORM _parser._allNodes.Add(this); } } - + /// /// Initializes a new instance of the class. /// @@ -10871,7 +10921,7 @@ namespace DynamORM { IsDisposed = false; } - + /// /// Initializes a new instance of the class. /// @@ -10881,10 +10931,10 @@ namespace DynamORM { if (host == null) throw new ArgumentNullException("host", "Host cannot be null."); - + Host = host; } - + /// /// Initializes a new instance of the class. /// @@ -10894,7 +10944,7 @@ namespace DynamORM { Name = name.Validated("Name"); } - + /// /// Initializes a new instance of the class. /// @@ -10906,7 +10956,7 @@ namespace DynamORM { Name = name.Validated("Name"); } - + /// /// Initializes a new instance of the class. /// @@ -10915,23 +10965,23 @@ namespace DynamORM protected Node(SerializationInfo info, StreamingContext context) { Name = info.GetString("MemberName"); - + string type = info.GetString("HostType"); Host = type == "NULL" ? null : (Node)info.GetValue("HostItem", Type.GetType(type)); } - + /// Returns a that represents this instance. /// A that represents this instance. public override string ToString() { if (IsDisposed) return "{DynamicParser::Node::Disposed}"; - + return "{DynamicParser::Node::Empty}"; } - + #region Implementation of IDynamicMetaObjectProvider - + /// Returns the responsible /// for binding operations performed on this object. /// The expression tree representation of the runtime value. @@ -10941,26 +10991,26 @@ namespace DynamORM { if (IsDisposed) throw new ObjectDisposedException("DynamicParser.Node"); - + return new MetaNode( parameter, BindingRestrictions.GetInstanceRestriction(parameter, this), this); } - + #endregion Implementation of IDynamicMetaObjectProvider - + #region Implementation of IFinalizerDisposable - + /// Finalizes an instance of the class. ~Node() { Dispose(false); } - + /// Gets a value indicating whether this instance is disposed. public bool IsDisposed { get; private set; } - + /// Performs application-defined tasks associated with /// freeing, releasing, or resetting unmanaged resources. public virtual void Dispose() @@ -10968,7 +11018,7 @@ namespace DynamORM Dispose(true); GC.SuppressFinalize(this); } - + /// Performs application-defined tasks associated with /// freeing, releasing, or resetting unmanaged resources. /// If set to true dispose object. @@ -10977,20 +11027,20 @@ namespace DynamORM if (disposing) { IsDisposed = true; - + if (Host != null && !Host.IsDisposed) Host.Dispose(); - + Host = null; - + Parser = null; } } - + #endregion Implementation of IFinalizerDisposable - + #region Implementation of ISerializable - + /// /// Populates a with the data needed to serialize the target object. /// @@ -11000,30 +11050,30 @@ namespace DynamORM { if (!string.IsNullOrEmpty(Name)) info.AddValue("MemberName", Name); - + info.AddValue("HostType", Host == null ? "NULL" : Host.GetType().AssemblyQualifiedName); if (Host != null) info.AddValue("HostItem", Host); } - + #endregion Implementation of ISerializable } - + #endregion Node - + #region Data - + private List _arguments = new List(); private List _allNodes = new List(); private object _uncertainResult; - + #endregion Data - + #region Properties - + /// Gets the last node (root of the tree). public Node Last { get; internal set; } - + /// /// Gets an enumeration containing the dynamic arguments used in the dynamic lambda expression parsed. /// @@ -11034,15 +11084,15 @@ namespace DynamORM List list = new List(); if (!IsDisposed && _arguments != null) list.AddRange(_arguments); - + foreach (Node.Argument arg in list) yield return arg; - + list.Clear(); list = null; } } - + /// /// Gets the number of dynamic arguments used in the dynamic lambda expression parsed. /// @@ -11050,7 +11100,7 @@ namespace DynamORM { get { return _arguments == null ? 0 : _arguments.Count; } } - + /// /// Gets the result of the parsing of the dynamic lambda expression. This result can be either an arbitrary object, /// including null, if the expression resolves to it, or an instance of the class that @@ -11060,9 +11110,9 @@ namespace DynamORM { get { return _uncertainResult ?? Last; } } - + #endregion Properties - + private DynamicParser(Delegate f) { // I know this can be almost a one liner @@ -11079,10 +11129,10 @@ namespace DynamORM else throw new ArgumentException(string.Format("Argument '{0}' must be dynamic.", p.Name)); } - + _uncertainResult = f.DynamicInvoke(_arguments.ToArray()); } - + /// /// Parses the dynamic lambda expression given in the form of a delegate, and returns a new instance of the /// class that holds the dynamic arguments used in the dynamic lambda expression, and @@ -11094,19 +11144,19 @@ namespace DynamORM { return new DynamicParser(f); } - + /// Returns a that represents this instance. /// A that represents this instance. public override string ToString() { if (IsDisposed) return "{DynamicParser::Disposed}"; - + StringBuilder sb = new StringBuilder(); - + sb.Append("("); bool first = true; - + if (_arguments != null) { foreach (Node.Argument arg in _arguments) @@ -11115,58 +11165,59 @@ namespace DynamORM sb.Append(arg); } } - + sb.Append(")"); - + sb.AppendFormat(" => {0}", Result.Sketch()); - + return sb.ToString(); } - + #region Implementation of IExtendedDisposable - + /// Gets a value indicating whether this instance is disposed. public bool IsDisposed { get; private set; } - + /// /// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources. /// public void Dispose() { IsDisposed = true; - + if (_uncertainResult != null && _uncertainResult is Node) { ((Node)_uncertainResult).Dispose(); _uncertainResult = null; } - + if (Last != null && !Last.IsDisposed) { Last.Dispose(); Last = null; } - + if (_arguments != null) { _arguments.ForEach(x => { if (!x.IsDisposed) x.Dispose(); }); - + _arguments.Clear(); _arguments = null; } - + if (_allNodes != null) { _allNodes.ForEach(x => { if (!x.IsDisposed) x.Dispose(); }); - + _allNodes.Clear(); _allNodes = null; } } - + #endregion Implementation of IExtendedDisposable } - + + /// Class that allows to use interfaces as dynamic objects. /// Type of class to proxy. /// This is temporary solution. Which allows to use builders as a dynamic type. @@ -11176,7 +11227,7 @@ namespace DynamORM private Type _type; private Dictionary _properties; private Dictionary _methods; - + /// /// Initializes a new instance of the class. /// @@ -11186,18 +11237,18 @@ namespace DynamORM { if (proxiedObject == null) throw new ArgumentNullException("proxiedObject"); - + _proxy = proxiedObject; _type = typeof(T); - + DynamicTypeMap mapper = Mapper.DynamicMapperCache.GetMapper(); - + _properties = mapper .ColumnsMap .ToDictionary( k => k.Value.Name, v => v.Value); - + _methods = GetAllMembers(_type) .Where(x => x is MethodInfo) .Cast() @@ -11218,7 +11269,7 @@ namespace DynamORM } }); } - + /// Provides implementation for type conversion operations. /// Classes derived from the /// class can override this method to specify dynamic behavior for @@ -11243,17 +11294,17 @@ namespace DynamORM result = _proxy; return true; } - + if (_proxy != null && binder.Type.IsAssignableFrom(_proxy.GetType())) { result = _proxy; return true; } - + return base.TryConvert(binder, out result); } - + /// Provides the implementation for operations that get member /// values. Classes derived from the /// class can override this method to specify dynamic behavior for @@ -11278,9 +11329,9 @@ namespace DynamORM try { DynamicPropertyInvoker prop = _properties.TryGetValue(binder.Name); - + result = prop.NullOr(p => p.Get.NullOr(g => g(_proxy), null), null); - + return prop != null && prop.Get != null; } catch (Exception ex) @@ -11288,7 +11339,7 @@ namespace DynamORM throw new InvalidOperationException(string.Format("Cannot get member {0}", binder.Name), ex); } } - + /// Provides the implementation for operations that set member /// values. Classes derived from the /// class can override this method to specify dynamic behavior for operations @@ -11313,13 +11364,13 @@ namespace DynamORM try { DynamicPropertyInvoker prop = _properties.TryGetValue(binder.Name); - + if (prop != null && prop.Setter != null) { prop.Set(_proxy, value); return true; } - + return false; } catch (Exception ex) @@ -11327,7 +11378,7 @@ namespace DynamORM throw new InvalidOperationException(string.Format("Cannot set member {0} to '{1}'", binder.Name, value), ex); } } - + /// Provides the implementation for operations that invoke a member. /// Classes derived from the /// class can override this method to specify dynamic behavior for @@ -11353,58 +11404,58 @@ namespace DynamORM { return TryInvokeMethod(binder.Name, out result, args) || base.TryInvokeMember(binder, args, out result); } - + private bool TryInvokeMethod(string name, out object result, object[] args) { result = null; - + MethodInfo mi = _methods.Keys .Where(m => m.Name == name) .FirstOrDefault(m => CompareTypes(m.GetParameters().ToArray(), args.Select(a => a.GetType()).ToArray())); - + Delegate d = _methods.TryGetValue(mi); - + if (d != null) { result = d.DynamicInvoke(CompleteArguments(mi.GetParameters().ToArray(), args)); - + if (d.Method.ReturnType == _type && result is T) result = new DynamicProxy((T)result); - + return true; } else if (mi != null) { result = mi.Invoke(_proxy, CompleteArguments(mi.GetParameters().ToArray(), args)); - + if (mi.ReturnType == _type && result is T) result = new DynamicProxy((T)result); - + return true; } - + return false; } - + private bool CompareTypes(ParameterInfo[] parameters, Type[] types) { if (parameters.Length < types.Length || parameters.Count(p => !p.IsOptional) > types.Length) return false; - + for (int i = 0; i < types.Length; i++) if (types[i] != parameters[i].ParameterType && !parameters[i].ParameterType.IsAssignableFrom(types[i])) return false; - + return true; } - + private object[] CompleteArguments(ParameterInfo[] parameters, object[] arguments) { return arguments.Concat(parameters.Skip(arguments.Length).Select(p => p.DefaultValue)).ToArray(); } - + private IEnumerable GetAllMembers(Type type) { if (type.IsInterface) @@ -11412,117 +11463,120 @@ namespace DynamORM List members = new List(); List considered = new List(); Queue queue = new Queue(); - + considered.Add(type); queue.Enqueue(type); - + while (queue.Count > 0) { Type subType = queue.Dequeue(); foreach (Type subInterface in subType.GetInterfaces()) { if (considered.Contains(subInterface)) continue; - + considered.Add(subInterface); queue.Enqueue(subInterface); } - + MemberInfo[] typeProperties = subType.GetMembers( BindingFlags.FlattenHierarchy | BindingFlags.Public | BindingFlags.Instance); - + IEnumerable newPropertyInfos = typeProperties .Where(x => !members.Contains(x)); - + members.InsertRange(0, newPropertyInfos); } - + return members; } - + return type.GetMembers(BindingFlags.FlattenHierarchy | BindingFlags.Public | BindingFlags.Instance); } - + /// Performs application-defined tasks associated with /// freeing, releasing, or resetting unmanaged resources. public void Dispose() { object res; TryInvokeMethod("Dispose", out res, new object[] { }); - + _properties.Clear(); - + _methods = null; _properties = null; _type = null; _proxy = default(T); } } + + } + } namespace Mapper - { + { /// Allows to add table name to class. [AttributeUsage(AttributeTargets.Property)] public class ColumnAttribute : Attribute { /// Gets or sets name. public string Name { get; set; } - + /// Gets or sets column type. /// Used when overriding schema. public DbType? Type { get; set; } - + /// Gets or sets a value indicating whether column is a key. public bool IsKey { get; set; } - + /// Gets or sets a value indicating whether column should have unique value. /// Used when overriding schema. public bool? IsUnique { get; set; } - + /// Gets or sets column size. /// Used when overriding schema. public int? Size { get; set; } - + /// Gets or sets column precision. /// Used when overriding schema. public byte? Precision { get; set; } - + /// Gets or sets column scale. /// Used when overriding schema. public byte? Scale { get; set; } - + /// Gets or sets a value indicating whether this column is no allowed to be inserted. /// This is only a suggestion to automated mapping. public bool IsNoInsert { get; set; } - + /// Gets or sets a value indicating whether this column is no allowed to be updated. /// This is only a suggestion to automated mapping. public bool IsNoUpdate { get; set; } - + #region Constructors - + /// Initializes a new instance of the class. public ColumnAttribute() { } - + /// Initializes a new instance of the class. /// Name of column. public ColumnAttribute(string name) { Name = name; } - + /// Initializes a new instance of the class. /// Set column as a key column. public ColumnAttribute(bool isKey) { IsKey = isKey; } - + /// Initializes a new instance of the class. /// Name of column. /// Set column as a key column. @@ -11531,7 +11585,7 @@ namespace DynamORM { IsKey = isKey; } - + /// Initializes a new instance of the class. /// Set column as a key column. /// Set column type. @@ -11540,7 +11594,7 @@ namespace DynamORM { Type = type; } - + /// Initializes a new instance of the class. /// Name of column. /// Set column as a key column. @@ -11550,7 +11604,7 @@ namespace DynamORM { Type = type; } - + /// Initializes a new instance of the class. /// Name of column. /// Set column as a key column. @@ -11561,7 +11615,7 @@ namespace DynamORM { Size = size; } - + /// Initializes a new instance of the class. /// Name of column. /// Set column as a key column. @@ -11574,7 +11628,7 @@ namespace DynamORM Precision = precision; Scale = scale; } - + /// Initializes a new instance of the class. /// Name of column. /// Set column as a key column. @@ -11587,7 +11641,7 @@ namespace DynamORM { Size = size; } - + /// Initializes a new instance of the class. /// Name of column. /// Set column as a key column. @@ -11601,10 +11655,11 @@ namespace DynamORM { IsUnique = isUnique; } - + #endregion Constructors } - + + /// Type cast helper. public static class DynamicCast { @@ -11615,7 +11670,7 @@ namespace DynamORM { return type.IsValueType ? TypeDefaults.GetOrAdd(type, t => Activator.CreateInstance(t)) : null; } - + /// Casts the object to this type. /// The type to which cast value. /// The value to cast. @@ -11624,23 +11679,23 @@ namespace DynamORM { return GetConverter(type, val)(val); } - + private static readonly ConcurrentDictionary TypeDefaults = new ConcurrentDictionary(); private static readonly ConcurrentDictionary> TypeAsCasts = new ConcurrentDictionary>(); private static readonly ConcurrentDictionary> TypeConvert = new ConcurrentDictionary>(); private static readonly ParameterExpression ConvParameter = Expression.Parameter(typeof(object), "val"); - + [MethodImpl(MethodImplOptions.Synchronized)] private static Func GetConverter(Type targetType, object val) { Func fn; - + if (!targetType.IsValueType && !val.GetType().IsValueType) { if (!TypeAsCasts.TryGetValue(targetType, out fn)) { UnaryExpression instanceCast = Expression.TypeAs(ConvParameter, targetType); - + fn = Expression.Lambda>(Expression.TypeAs(instanceCast, typeof(object)), ConvParameter).Compile(); TypeAsCasts.AddOrUpdate(targetType, fn, (t, f) => fn); } @@ -11651,51 +11706,52 @@ namespace DynamORM var key = new PairOfTypes(fromType, targetType); if (TypeConvert.TryGetValue(key, out fn)) return fn; - + fn = (Func)Expression.Lambda(Expression.Convert(Expression.Convert(Expression.Convert(ConvParameter, fromType), targetType), typeof(object)), ConvParameter).Compile(); TypeConvert.AddOrUpdate(key, fn, (t, f) => fn); } - + return fn; } - + private class PairOfTypes { private readonly Type _first; private readonly Type _second; - + public PairOfTypes(Type first, Type second) { this._first = first; this._second = second; } - + public override int GetHashCode() { return (31 * _first.GetHashCode()) + _second.GetHashCode(); } - + public override bool Equals(object obj) { if (obj == this) return true; - + var other = obj as PairOfTypes; if (other == null) return false; - + return _first.Equals(other._first) && _second.Equals(other._second); } } } - + + /// Class with mapper cache. public static class DynamicMapperCache { private static readonly object SyncLock = new object(); private static Dictionary _cache = new Dictionary(); - + /// Get type mapper. /// Type of mapper. /// Type mapper. @@ -11703,7 +11759,7 @@ namespace DynamORM { return GetMapper(typeof(T)); } - + /// Get type mapper. /// Type of mapper. /// Type mapper. @@ -11713,54 +11769,61 @@ namespace DynamORM return null; /*if (type.IsAnonymous()) return null;*/ - + DynamicTypeMap mapper = null; - + lock (SyncLock) { if (!_cache.TryGetValue(type, out mapper)) { mapper = new DynamicTypeMap(type); - + if (mapper != null) _cache.Add(type, mapper); } } - + return mapper; } } - + + /// Dynamic property invoker. public class DynamicPropertyInvoker { internal class ParameterSpec { public string Name { get; set; } - + public DbType Type { get; set; } - + public int Ordinal { get; set; } } - + + private Type _arrayType; + private bool _genericEnumerable; + /// Gets the type of property. public Type Type { get; private set; } - + /// Gets value getter. public Func Get { get; private set; } - + /// Gets value setter. public Action Setter { get; private set; } - + /// Gets name of property. public string Name { get; private set; } - + /// Gets type column description. public ColumnAttribute Column { get; private set; } - + /// Gets a value indicating whether this is ignored in some cases. public bool Ignore { get; private set; } - + + /// Gets a value indicating whether this instance hold data contract type. + public bool IsDataContract { get; private set; } + /// Initializes a new instance of the class. /// Property info to be invoked in the future. /// Column attribute if exist. @@ -11768,27 +11831,41 @@ namespace DynamORM { Name = property.Name; Type = property.PropertyType; - + object[] ignore = property.GetCustomAttributes(typeof(IgnoreAttribute), false); - + Ignore = ignore != null && ignore.Length > 0; - + + _arrayType = Type.IsArray ? Type.GetElementType() : + Type.IsGenericEnumerable() ? Type.GetGenericArguments().First() : + Type; + + _genericEnumerable = Type.IsGenericEnumerable(); + + IsDataContract = _arrayType.GetCustomAttributes(false).Any(x => x.GetType().Name == "DataContractAttribute"); + + if (_arrayType.IsArray) + throw new InvalidOperationException("Jagged arrays are not supported"); + + if (_arrayType.IsGenericEnumerable()) + throw new InvalidOperationException("Enumerables of enumerables are not supported"); + Column = attr; - + if (property.CanRead) Get = CreateGetter(property); - + if (property.CanWrite) Setter = CreateSetter(property); } - + private Func CreateGetter(PropertyInfo property) { if (!property.CanRead) return null; - + ParameterExpression objParm = Expression.Parameter(typeof(object), "o"); - + return Expression.Lambda>( Expression.Convert( Expression.Property( @@ -11796,15 +11873,15 @@ namespace DynamORM property.Name), typeof(object)), objParm).Compile(); } - + private Action CreateSetter(PropertyInfo property) { if (!property.CanWrite) return null; - + ParameterExpression objParm = Expression.Parameter(typeof(object), "o"); ParameterExpression valueParm = Expression.Parameter(typeof(object), "value"); - + return Expression.Lambda>( Expression.Assign( Expression.Property( @@ -11813,138 +11890,161 @@ namespace DynamORM Expression.Convert(valueParm, property.PropertyType)), objParm, valueParm).Compile(); } - + /// Sets the specified value to destination object. /// The destination object. /// The value. public void Set(object dest, object val) { - Type type = Nullable.GetUnderlyingType(Type) ?? Type; - bool nullable = Type.IsGenericType && Type.GetGenericTypeDefinition() == typeof(Nullable<>); - + object value = null; + try { - if (val == null && type.IsValueType) + if (Type.IsArray || _genericEnumerable) { - if (nullable) - Setter(dest, null); - else - Setter(dest, Activator.CreateInstance(Type)); - } - else if ((val == null && !type.IsValueType) || (val != null && type == val.GetType())) - Setter(dest, val); - else if (type.IsEnum && val.GetType().IsValueType) - Setter(dest, Enum.ToObject(type, val)); - else if (type.IsEnum) - Setter(dest, Enum.Parse(type, val.ToString())); - else if (Type == typeof(string) && val.GetType() == typeof(Guid)) - Setter(dest, val.ToString()); - else if (Type == typeof(Guid) && val.GetType() == typeof(string)) - { - Guid g; - Setter(dest, Guid.TryParse((string)val, out g) ? g : Guid.Empty); + var lst = (val as IEnumerable).Select(x => GetElementVal(_arrayType, x)).ToList(); + + value = Array.CreateInstance(_arrayType, lst.Count); + + int i = 0; + foreach (var e in lst) + ((Array)value).SetValue(e, i++); } else - Setter(dest, Convert.ChangeType(val, type)); + value = GetElementVal(Type, val); + + Setter(dest, value); } catch (Exception ex) { throw new InvalidCastException( - string.Format("Error trying to convert value '{0}' of type '{1}' to value of type '{2}{3}' in object of type '{4}'", - val.ToString(), val.GetType(), type.FullName, nullable ? "(NULLABLE)" : string.Empty, dest.GetType().FullName), + string.Format("Error trying to convert value '{0}' of type '{1}' to value of type '{2}' in object of type '{3}'", + (val ?? string.Empty).ToString(), val.GetType(), Type.FullName, dest.GetType().FullName), ex); } } - + + private object GetElementVal(System.Type etype, object val) + { + bool nullable = etype.IsGenericType && etype.GetGenericTypeDefinition() == typeof(Nullable<>); + Type type = Nullable.GetUnderlyingType(etype) ?? etype; + + if (val == null && type.IsValueType) + { + if (nullable) + return null; + else + return Activator.CreateInstance(Type); + } + else if ((val == null && !type.IsValueType) || (val != null && type == val.GetType())) + return val; + else if (type.IsEnum && val.GetType().IsValueType) + return Enum.ToObject(type, val); + else if (type.IsEnum) + return Enum.Parse(type, val.ToString()); + else if (Type == typeof(string) && val.GetType() == typeof(Guid)) + return val.ToString(); + else if (Type == typeof(Guid) && val.GetType() == typeof(string)) + { + Guid g; + return Guid.TryParse((string)val, out g) ? g : Guid.Empty; + } + else if (IsDataContract) + return val.Map(type); + else + return Convert.ChangeType(val, type); + } + #region Type command cache - + internal ParameterSpec InsertCommandParameter { get; set; } - + internal ParameterSpec UpdateCommandParameter { get; set; } - + internal ParameterSpec DeleteCommandParameter { get; set; } - + #endregion Type command cache } - + + /// Represents type columnMap. public class DynamicTypeMap { /// Gets mapper destination type creator. public Type Type { get; private set; } - + /// Gets type table description. public TableAttribute Table { get; private set; } - + /// Gets object creator. public Func Creator { get; private set; } - + /// Gets map of columns to properties. /// Key: Column name (lower), Value: . public Dictionary ColumnsMap { get; private set; } - + /// Gets map of properties to column. /// Key: Property name, Value: Column name. public Dictionary PropertyMap { get; private set; } - + /// Gets list of ignored properties. public List Ignored { get; private set; } - + /// Initializes a new instance of the class. /// Type to which columnMap objects. public DynamicTypeMap(Type type) { Type = type; - + object[] attr = type.GetCustomAttributes(typeof(TableAttribute), false); - + if (attr != null && attr.Length > 0) Table = (TableAttribute)attr[0]; - + Creator = CreateCreator(); CreateColumnAndPropertyMap(); } - + private void CreateColumnAndPropertyMap() { Dictionary columnMap = new Dictionary(); Dictionary propertyMap = new Dictionary(); List ignored = new List(); - + foreach (PropertyInfo pi in GetAllMembers(Type).Where(x => x is PropertyInfo).Cast()) { ColumnAttribute attr = null; - + object[] attrs = pi.GetCustomAttributes(typeof(ColumnAttribute), true); - + if (attrs != null && attrs.Length > 0) attr = (ColumnAttribute)attrs[0]; - + string col = attr == null || string.IsNullOrEmpty(attr.Name) ? pi.Name : attr.Name; - + DynamicPropertyInvoker val = new DynamicPropertyInvoker(pi, attr); columnMap.Add(col.ToLower(), val); - + propertyMap.Add(pi.Name, col); - + if (val.Ignore) ignored.Add(pi.Name); } - + ColumnsMap = columnMap; PropertyMap = propertyMap; - + Ignored = ignored; ////columnMap.Where(i => i.Value.Ignore).Select(i => i.Value.Name).ToList(); } - + private Func CreateCreator() { if (Type.GetConstructor(Type.EmptyTypes) != null) return Expression.Lambda>(Expression.New(Type)).Compile(); - + return null; } - + /// Create object of type and fill values from source. /// Object containing values that will be mapped to newly created object. /// New object of type with matching values from source. @@ -11952,7 +12052,7 @@ namespace DynamORM { return Map(source, Creator()); } - + /// Fill values from source to object in destination. /// Object containing values that will be mapped to newly created object. /// Object of type to which copy values from source. @@ -11960,17 +12060,17 @@ namespace DynamORM public object Map(object source, object destination) { DynamicPropertyInvoker dpi = null; - + foreach (KeyValuePair item in source.ToDictionary()) { if (ColumnsMap.TryGetValue(item.Key.ToLower(), out dpi) && item.Value != null) if (dpi.Setter != null) dpi.Set(destination, item.Value); } - + return destination; } - + private IEnumerable GetAllMembers(Type type) { if (type.IsInterface) @@ -11978,71 +12078,77 @@ namespace DynamORM List members = new List(); List considered = new List(); Queue queue = new Queue(); - + considered.Add(type); queue.Enqueue(type); - + while (queue.Count > 0) { Type subType = queue.Dequeue(); foreach (Type subInterface in subType.GetInterfaces()) { if (considered.Contains(subInterface)) continue; - + considered.Add(subInterface); queue.Enqueue(subInterface); } - + MemberInfo[] typeProperties = subType.GetMembers( BindingFlags.FlattenHierarchy | BindingFlags.Public | BindingFlags.Instance); - + IEnumerable newPropertyInfos = typeProperties .Where(x => !members.Contains(x)); - + members.InsertRange(0, newPropertyInfos); } - + return members; } - + return type.GetMembers(BindingFlags.FlattenHierarchy | BindingFlags.Public | BindingFlags.Instance); } - + #region Type command cache - + internal string InsertCommandText { get; set; } - + internal string UpdateCommandText { get; set; } - + internal string DeleteCommandText { get; set; } - + #endregion Type command cache } - + + /// Allows to add ignore action to property. /// Property still get's mapped from output. [AttributeUsage(AttributeTargets.Property)] public class IgnoreAttribute : Attribute { } - + + /// Allows to add table name to class. [AttributeUsage(AttributeTargets.Class)] public class TableAttribute : Attribute { /// Gets or sets table owner name. public string Owner { get; set; } - + /// Gets or sets name. public string Name { get; set; } - + /// Gets or sets a value indicating whether override database /// schema values. /// If database doesn't support schema, you still have to /// set this to true to get schema from type. public bool Override { get; set; } } + + } -} \ No newline at end of file + +} + diff --git a/DynamORM/Builders/Implementation/DynamicSelectQueryBuilder.cs b/DynamORM/Builders/Implementation/DynamicSelectQueryBuilder.cs index 398cb2e..a5c14cc 100644 --- a/DynamORM/Builders/Implementation/DynamicSelectQueryBuilder.cs +++ b/DynamORM/Builders/Implementation/DynamicSelectQueryBuilder.cs @@ -44,7 +44,6 @@ namespace DynamORM.Builders.Implementation /// Implementation of dynamic select query builder. internal class DynamicSelectQueryBuilder : DynamicQueryBuilder, IDynamicSelectQueryBuilder, DynamicQueryBuilder.IQueryWithWhere { - private int? _top = null; private int? _limit = null; private int? _offset = null; private bool _distinct = false; @@ -83,17 +82,42 @@ namespace DynamORM.Builders.Implementation /// The text to execute against the underlying database. public override string CommandText() { + bool lused = false; + bool oused = false; + StringBuilder sb = new StringBuilder("SELECT"); if (_distinct) sb.AppendFormat(" DISTINCT"); - if (_top.HasValue) sb.AppendFormat(" TOP {0}", _top); + + if (_limit.HasValue) + { + if ((Database.Options & DynamicDatabaseOptions.SupportTop) == DynamicDatabaseOptions.SupportTop) + { + sb.AppendFormat(" TOP {0}", _limit); + lused = true; + } + else if ((Database.Options & DynamicDatabaseOptions.SupportFirstSkip) == DynamicDatabaseOptions.SupportFirstSkip) + { + sb.AppendFormat(" FIRST {0}", _limit); + lused = true; + } + } + + if (_offset.HasValue && (Database.Options & DynamicDatabaseOptions.SupportFirstSkip) == DynamicDatabaseOptions.SupportFirstSkip) + { + sb.AppendFormat(" SKIP {0}", _offset); + oused = true; + } + if (_select != null) sb.AppendFormat(" {0}", _select); else sb.Append(" *"); if (_from != null) sb.AppendFormat(" FROM {0}", _from); if (_join != null) sb.AppendFormat(" {0}", _join); if (WhereCondition != null) sb.AppendFormat(" WHERE {0}", WhereCondition); if (_groupby != null) sb.AppendFormat(" GROUP BY {0}", _groupby); if (_orderby != null) sb.AppendFormat(" ORDER BY {0}", _orderby); - if (_limit.HasValue) sb.AppendFormat(" LIMIT {0}", _limit); - if (_offset.HasValue) sb.AppendFormat(" OFFSET {0}", _offset); + if (_limit.HasValue && !lused && (Database.Options & DynamicDatabaseOptions.SupportLimitOffset) == DynamicDatabaseOptions.SupportLimitOffset) + sb.AppendFormat(" LIMIT {0}", _limit); + if (_offset.HasValue && !oused && (Database.Options & DynamicDatabaseOptions.SupportLimitOffset) == DynamicDatabaseOptions.SupportLimitOffset) + sb.AppendFormat(" OFFSET {0}", _offset); return sb.ToString(); } @@ -1105,11 +1129,7 @@ namespace DynamORM.Builders.Implementation /// Builder instance. public virtual IDynamicSelectQueryBuilder Top(int? top) { - if ((Database.Options & DynamicDatabaseOptions.SupportTop) != DynamicDatabaseOptions.SupportTop) - throw new NotSupportedException("Database doesn't support TOP clause."); - - _top = top; - return this; + return Limit(top); } /// Set top if database support it. @@ -1117,7 +1137,9 @@ namespace DynamORM.Builders.Implementation /// Builder instance. public virtual IDynamicSelectQueryBuilder Limit(int? limit) { - if ((Database.Options & DynamicDatabaseOptions.SupportLimitOffset) != DynamicDatabaseOptions.SupportLimitOffset) + if ((Database.Options & DynamicDatabaseOptions.SupportLimitOffset) != DynamicDatabaseOptions.SupportLimitOffset && + (Database.Options & DynamicDatabaseOptions.SupportFirstSkip) != DynamicDatabaseOptions.SupportFirstSkip && + (Database.Options & DynamicDatabaseOptions.SupportTop) != DynamicDatabaseOptions.SupportTop) throw new NotSupportedException("Database doesn't support LIMIT clause."); _limit = limit; @@ -1129,7 +1151,8 @@ namespace DynamORM.Builders.Implementation /// Builder instance. public virtual IDynamicSelectQueryBuilder Offset(int? offset) { - if ((Database.Options & DynamicDatabaseOptions.SupportLimitOffset) != DynamicDatabaseOptions.SupportLimitOffset) + if ((Database.Options & DynamicDatabaseOptions.SupportLimitOffset) != DynamicDatabaseOptions.SupportLimitOffset && + (Database.Options & DynamicDatabaseOptions.SupportFirstSkip) != DynamicDatabaseOptions.SupportFirstSkip) throw new NotSupportedException("Database doesn't support OFFSET clause."); _offset = offset; diff --git a/DynamORM/DynamicDatabaseOptions.cs b/DynamORM/DynamicDatabaseOptions.cs index 0b61a22..d1bc190 100644 --- a/DynamORM/DynamicDatabaseOptions.cs +++ b/DynamORM/DynamicDatabaseOptions.cs @@ -50,11 +50,14 @@ namespace DynamORM /// Database supports limit offset syntax (SELECT ... FROM ... LIMIT x OFFSET y). SupportLimitOffset = 0x00000040, + /// Database supports limit offset syntax (SELECT FIRST x SKIP y ... FROM ...). + SupportFirstSkip = 0x00000020, + /// Database support standard schema. SupportSchema = 0x00000010, /// Database support stored procedures (EXEC procedure ...). - SupportStoredProcedures = 0x00000020, + SupportStoredProcedures = 0x00000100, /// Debug option allowing to enable command dumps by default. DumpCommands = 0x01000000, diff --git a/DynamORM/DynamicExtensions.cs b/DynamORM/DynamicExtensions.cs index 8d020e1..5315265 100644 --- a/DynamORM/DynamicExtensions.cs +++ b/DynamORM/DynamicExtensions.cs @@ -1283,7 +1283,7 @@ namespace DynamORM /// Returns true if it does. public static bool IsGenericEnumerable(this Type type) { - return type.IsGenericType && type.GetInterfaces().Any(t => t.GetGenericTypeDefinition() == typeof(IEnumerable<>)); + return type.IsGenericType && type.GetInterfaces().Any(t => t.IsGenericType && t.GetGenericTypeDefinition() == typeof(IEnumerable<>)); } /// Check if type implements IEnumerable<> interface. diff --git a/DynamORM/Mapper/DynamicPropertyInvoker.cs b/DynamORM/Mapper/DynamicPropertyInvoker.cs index 9fb14ae..9ebb0ed 100644 --- a/DynamORM/Mapper/DynamicPropertyInvoker.cs +++ b/DynamORM/Mapper/DynamicPropertyInvoker.cs @@ -27,7 +27,9 @@ */ using System; +using System.Collections.Generic; using System.Data; +using System.Linq; using System.Linq.Expressions; using System.Reflection; @@ -45,6 +47,9 @@ namespace DynamORM.Mapper public int Ordinal { get; set; } } + private Type _arrayType; + private bool _genericEnumerable; + /// Gets the type of property. public Type Type { get; private set; } @@ -63,6 +68,9 @@ namespace DynamORM.Mapper /// Gets a value indicating whether this is ignored in some cases. public bool Ignore { get; private set; } + /// Gets a value indicating whether this instance hold data contract type. + public bool IsDataContract { get; private set; } + /// Initializes a new instance of the class. /// Property info to be invoked in the future. /// Column attribute if exist. @@ -75,6 +83,20 @@ namespace DynamORM.Mapper Ignore = ignore != null && ignore.Length > 0; + _arrayType = Type.IsArray ? Type.GetElementType() : + Type.IsGenericEnumerable() ? Type.GetGenericArguments().First() : + Type; + + _genericEnumerable = Type.IsGenericEnumerable(); + + IsDataContract = _arrayType.GetCustomAttributes(false).Any(x => x.GetType().Name == "DataContractAttribute"); + + if (_arrayType.IsArray) + throw new InvalidOperationException("Jagged arrays are not supported"); + + if (_arrayType.IsGenericEnumerable()) + throw new InvalidOperationException("Enumerables of enumerables are not supported"); + Column = attr; if (property.CanRead) @@ -121,43 +143,65 @@ namespace DynamORM.Mapper /// The value. public void Set(object dest, object val) { - Type type = Nullable.GetUnderlyingType(Type) ?? Type; - bool nullable = Type.IsGenericType && Type.GetGenericTypeDefinition() == typeof(Nullable<>); + object value = null; try { - if (val == null && type.IsValueType) + if (Type.IsArray || _genericEnumerable) { - if (nullable) - Setter(dest, null); - else - Setter(dest, Activator.CreateInstance(Type)); - } - else if ((val == null && !type.IsValueType) || (val != null && type == val.GetType())) - Setter(dest, val); - else if (type.IsEnum && val.GetType().IsValueType) - Setter(dest, Enum.ToObject(type, val)); - else if (type.IsEnum) - Setter(dest, Enum.Parse(type, val.ToString())); - else if (Type == typeof(string) && val.GetType() == typeof(Guid)) - Setter(dest, val.ToString()); - else if (Type == typeof(Guid) && val.GetType() == typeof(string)) - { - Guid g; - Setter(dest, Guid.TryParse((string)val, out g) ? g : Guid.Empty); + var lst = (val as IEnumerable).Select(x => GetElementVal(_arrayType, x)).ToList(); + + value = Array.CreateInstance(_arrayType, lst.Count); + + int i = 0; + foreach (var e in lst) + ((Array)value).SetValue(e, i++); } else - Setter(dest, Convert.ChangeType(val, type)); + value = GetElementVal(Type, val); + + Setter(dest, value); } catch (Exception ex) { throw new InvalidCastException( - string.Format("Error trying to convert value '{0}' of type '{1}' to value of type '{2}{3}' in object of type '{4}'", - val.ToString(), val.GetType(), type.FullName, nullable ? "(NULLABLE)" : string.Empty, dest.GetType().FullName), + string.Format("Error trying to convert value '{0}' of type '{1}' to value of type '{2}' in object of type '{3}'", + (val ?? string.Empty).ToString(), val.GetType(), Type.FullName, dest.GetType().FullName), ex); } } + private object GetElementVal(System.Type etype, object val) + { + bool nullable = etype.IsGenericType && etype.GetGenericTypeDefinition() == typeof(Nullable<>); + Type type = Nullable.GetUnderlyingType(etype) ?? etype; + + if (val == null && type.IsValueType) + { + if (nullable) + return null; + else + return Activator.CreateInstance(Type); + } + else if ((val == null && !type.IsValueType) || (val != null && type == val.GetType())) + return val; + else if (type.IsEnum && val.GetType().IsValueType) + return Enum.ToObject(type, val); + else if (type.IsEnum) + return Enum.Parse(type, val.ToString()); + else if (Type == typeof(string) && val.GetType() == typeof(Guid)) + return val.ToString(); + else if (Type == typeof(Guid) && val.GetType() == typeof(string)) + { + Guid g; + return Guid.TryParse((string)val, out g) ? g : Guid.Empty; + } + else if (IsDataContract) + return val.Map(type); + else + return Convert.ChangeType(val, type); + } + #region Type command cache internal ParameterSpec InsertCommandParameter { get; set; }