--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/Source/Data/Linq/ExpressionQuery.cs	Thu Mar 27 21:46:09 2014 +0400
@@ -0,0 +1,159 @@
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Linq;
+using System.Linq.Expressions;
+using System.Reflection;
+
+using JetBrains.Annotations;
+
+namespace BLToolkit.Data.Linq
+{
+	using Reflection;
+
+	public abstract class ExpressionQuery<T> : IOrderedQueryable<T>, IQueryProvider
+	{
+		#region Init
+
+		protected void Init(IDataContextInfo dataContextInfo, Expression expression)
+		{
+#if SILVERLIGHT
+			if (dataContextInfo == null) throw new ArgumentNullException("dataContextInfo");
+
+			DataContextInfo = dataContextInfo;
+#else
+			DataContextInfo = dataContextInfo ?? new DefaultDataContextInfo();
+#endif
+			Expression      = expression      ?? Expression.Constant(this);
+		}
+
+		[NotNull] public Expression       Expression      { get; set; }
+		[NotNull] public IDataContextInfo DataContextInfo { get; set; }
+
+		internal  Query<T> Info;
+		internal  object[] Parameters;
+
+		#endregion
+
+		#region Public Members
+
+		[DebuggerBrowsable(DebuggerBrowsableState.Never)]
+		private string _sqlTextHolder;
+
+// ReSharper disable InconsistentNaming
+		[UsedImplicitly]
+		private string _sqlText { get { return SqlText; }}
+// ReSharper restore InconsistentNaming
+
+		public  string  SqlText
+		{
+			get
+			{
+				if (_sqlTextHolder == null)
+				{
+					var info = GetQuery(Expression, true);
+					_sqlTextHolder = info.GetSqlText(DataContextInfo.DataContext, Expression, Parameters, 0);
+				}
+
+				return _sqlTextHolder;
+			}
+		}
+
+		#endregion
+
+		#region Execute
+
+		IEnumerable<T> Execute(IDataContextInfo dataContextInfo, Expression expression)
+		{
+			return GetQuery(expression, true).GetIEnumerable(null, dataContextInfo, expression, Parameters);
+		}
+
+		Query<T> GetQuery(Expression expression, bool cache)
+		{
+			if (cache && Info != null)
+				return Info;
+
+			var info = Query<T>.GetQuery(DataContextInfo, expression);
+
+			if (cache)
+				Info = info;
+
+			return info;
+		}
+
+		#endregion
+
+		#region IQueryable Members
+
+		Type IQueryable.ElementType
+		{
+			get { return typeof(T); }
+		}
+
+		Expression IQueryable.Expression
+		{
+			get { return Expression; }
+		}
+
+		IQueryProvider IQueryable.Provider
+		{
+			get { return this; }
+		}
+
+		#endregion
+
+		#region IQueryProvider Members
+
+		IQueryable<TElement> IQueryProvider.CreateQuery<TElement>(Expression expression)
+		{
+			if (expression == null)
+				throw new ArgumentNullException("expression");
+
+			return new ExpressionQueryImpl<TElement>(DataContextInfo, expression);
+		}
+
+		IQueryable IQueryProvider.CreateQuery(Expression expression)
+		{
+			if (expression == null)
+				throw new ArgumentNullException("expression");
+
+			var elementType = TypeHelper.GetElementType(expression.Type) ?? expression.Type;
+
+			try
+			{
+				return (IQueryable)Activator.CreateInstance(typeof(ExpressionQueryImpl<>).MakeGenericType(elementType), new object[] { DataContextInfo, expression });
+			}
+			catch (TargetInvocationException ex)
+			{
+				throw ex.InnerException;
+			}
+		}
+
+		TResult IQueryProvider.Execute<TResult>(Expression expression)
+		{
+			return (TResult)GetQuery(expression, false).GetElement(null, DataContextInfo, expression, Parameters);
+		}
+
+		object IQueryProvider.Execute(Expression expression)
+		{
+			return GetQuery(expression, false).GetElement(null, DataContextInfo, expression, Parameters);
+		}
+
+		#endregion
+
+		#region IEnumerable Members
+
+		IEnumerator<T> IEnumerable<T>.GetEnumerator()
+		{
+			return Execute(DataContextInfo, Expression).GetEnumerator();
+		}
+
+		IEnumerator IEnumerable.GetEnumerator()
+		{
+			return Execute(DataContextInfo, Expression).GetEnumerator();
+		}
+
+		#endregion
+	}
+}