Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / DataWeb / Client / System / Data / Services / Client / DataServiceQueryOfT.cs / 1305376 / DataServiceQueryOfT.cs
//---------------------------------------------------------------------- //// Copyright (c) Microsoft Corporation. All rights reserved. // //// query object // //--------------------------------------------------------------------- namespace System.Data.Services.Client { using System; using System.Collections.Generic; using System.Diagnostics; using System.IO; using System.Linq; using System.Linq.Expressions; #if !ASTORIA_LIGHT // Data.Services http stack using System.Net; #else using System.Data.Services.Http; #endif using System.Reflection; using System.Collections; ////// query object /// ///type of object to materialize [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Naming", "CA1710:IdentifiersShouldHaveCorrectSuffix", Justification = "required for this feature")] public class DataServiceQuery: DataServiceQuery, IQueryable { #region Private fields. /// Linq Expression private readonly Expression queryExpression; ///Linq Query Provider private readonly DataServiceQueryProvider queryProvider; ///Uri, Projection, Version for translated query private QueryComponents queryComponents; #endregion Private fields. ////// query object /// /// expression for query /// query provider for query private DataServiceQuery(Expression expression, DataServiceQueryProvider provider) { Debug.Assert(null != provider.Context, "null context"); Debug.Assert(expression != null, "null expression"); Debug.Assert(provider is DataServiceQueryProvider, "Currently only support Web Query Provider"); this.queryExpression = expression; this.queryProvider = provider; } #region IQueryable implementation ////// Element Type /// public override Type ElementType { get { return typeof(TElement); } } ////// Linq Expression /// public override Expression Expression { get { return this.queryExpression; } } ////// Linq Query Provider /// public override IQueryProvider Provider { get { return this.queryProvider; } } #endregion ////// gets the URI for a the query /// public override Uri RequestUri { get { return this.Translate().Uri; } } ///The ProjectionPlan for the request (if precompiled in a previous page). internal override ProjectionPlan Plan { get { return null; } } ////// gets the UriTranslateResult for a the query /// internal override QueryComponents QueryComponents { get { return this.Translate(); } } ////// Begins an asynchronous request to an Internet resource. /// /// The AsyncCallback delegate. /// The state object for this request. ///An IAsyncResult that references the asynchronous request for a response. public new IAsyncResult BeginExecute(AsyncCallback callback, object state) { return base.BeginExecute(this, this.queryProvider.Context, callback, state); } ////// Ends an asynchronous request to an Internet resource. /// /// The pending request for a response. ///An IEnumerable that contains the response from the Internet resource. public new IEnumerableEndExecute(IAsyncResult asyncResult) { return DataServiceRequest.EndExecute (this, this.queryProvider.Context, asyncResult); } #if !ASTORIA_LIGHT // Synchronous methods not available /// /// Returns an IEnumerable from an Internet resource. /// ///An IEnumerable that contains the response from the Internet resource. public new IEnumerableExecute() { return this.Execute (this.queryProvider.Context, this.Translate()); } #endif /// /// Sets Expand option /// /// Path to expand ///New DataServiceQuery with expand option public DataServiceQueryExpand(string path) { Util.CheckArgumentNull(path, "path"); Util.CheckArgumentNotEmpty(path, "path"); MethodInfo mi = typeof(DataServiceQuery ).GetMethod("Expand"); return (DataServiceQuery )this.Provider.CreateQuery ( Expression.Call( Expression.Convert(this.Expression, typeof(DataServiceQuery .DataServiceOrderedQuery)), mi, new Expression[] { Expression.Constant(path) })); } /// /// Turn the inline counting option on for the query /// ///New DataServiceQuery with count option public DataServiceQueryIncludeTotalCount() { MethodInfo mi = typeof(DataServiceQuery ).GetMethod("IncludeTotalCount"); return (DataServiceQuery )this.Provider.CreateQuery ( Expression.Call( Expression.Convert(this.Expression, typeof(DataServiceQuery .DataServiceOrderedQuery)), mi)); } /// /// Sets user option /// /// name of value /// value of option ///New DataServiceQuery with expand option public DataServiceQueryAddQueryOption(string name, object value) { Util.CheckArgumentNull(name, "name"); Util.CheckArgumentNull(value, "value"); MethodInfo mi = typeof(DataServiceQuery ).GetMethod("AddQueryOption"); return (DataServiceQuery )this.Provider.CreateQuery ( Expression.Call( Expression.Convert(this.Expression, typeof(DataServiceQuery .DataServiceOrderedQuery)), mi, new Expression[] { Expression.Constant(name), Expression.Constant(value, typeof(object)) })); } /// /// get an enumerator materializes the objects the Uri request /// ///an enumerator #if !ASTORIA_LIGHT // Synchronous methods not available public IEnumeratorGetEnumerator() { return this.Execute().GetEnumerator(); } #else IEnumerator IEnumerable .GetEnumerator() { throw Error.NotSupported(Strings.DataServiceQuery_EnumerationNotSupportedInSL); } #endif /// /// gets the URI for the query /// ///a string with the URI public override string ToString() { try { return base.ToString(); } catch (NotSupportedException e) { return Strings.ALinq_TranslationError(e.Message); } } ////// get an enumerator materializes the objects the Uri request /// ///an enumerator System.Collections.IEnumerator System.Collections.IEnumerable.GetEnumerator() { #if !ASTORIA_LIGHT // Synchronous methods not available return this.GetEnumerator(); #else throw Error.NotSupported(); #endif } #if !ASTORIA_LIGHT /// Synchronous methods not available ////// Returns an IEnumerable from an Internet resource. /// ///An IEnumerable that contains the response from the Internet resource. internal override IEnumerable ExecuteInternal() { return this.Execute(); } #endif ////// Begins an asynchronous request to an Internet resource. /// /// The AsyncCallback delegate. /// The state object for this request. ///An IAsyncResult that references the asynchronous request for a response. internal override IAsyncResult BeginExecuteInternal(AsyncCallback callback, object state) { return this.BeginExecute(callback, state); } ////// Ends an asynchronous request to an Internet resource. /// /// The pending request for a response. ///An IEnumerable that contains the response from the Internet resource. internal override IEnumerable EndExecuteInternal(IAsyncResult asyncResult) { return this.EndExecute(asyncResult); } ////// gets the query components for the query after translating /// ///QueryComponents for query private QueryComponents Translate() { if (this.queryComponents == null) { this.queryComponents = this.queryProvider.Translate(this.queryExpression); } return this.queryComponents; } ////// Ordered DataServiceQuery which implements IOrderedQueryable. /// internal class DataServiceOrderedQuery : DataServiceQuery, IOrderedQueryable , IOrderedQueryable { /// /// constructor /// /// expression for query /// query provider for query internal DataServiceOrderedQuery(Expression expression, DataServiceQueryProvider provider) : base(expression, provider) { } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. //---------------------------------------------------------------------- //// Copyright (c) Microsoft Corporation. All rights reserved. // //// query object // //--------------------------------------------------------------------- namespace System.Data.Services.Client { using System; using System.Collections.Generic; using System.Diagnostics; using System.IO; using System.Linq; using System.Linq.Expressions; #if !ASTORIA_LIGHT // Data.Services http stack using System.Net; #else using System.Data.Services.Http; #endif using System.Reflection; using System.Collections; ////// query object /// ///type of object to materialize [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Naming", "CA1710:IdentifiersShouldHaveCorrectSuffix", Justification = "required for this feature")] public class DataServiceQuery: DataServiceQuery, IQueryable { #region Private fields. /// Linq Expression private readonly Expression queryExpression; ///Linq Query Provider private readonly DataServiceQueryProvider queryProvider; ///Uri, Projection, Version for translated query private QueryComponents queryComponents; #endregion Private fields. ////// query object /// /// expression for query /// query provider for query private DataServiceQuery(Expression expression, DataServiceQueryProvider provider) { Debug.Assert(null != provider.Context, "null context"); Debug.Assert(expression != null, "null expression"); Debug.Assert(provider is DataServiceQueryProvider, "Currently only support Web Query Provider"); this.queryExpression = expression; this.queryProvider = provider; } #region IQueryable implementation ////// Element Type /// public override Type ElementType { get { return typeof(TElement); } } ////// Linq Expression /// public override Expression Expression { get { return this.queryExpression; } } ////// Linq Query Provider /// public override IQueryProvider Provider { get { return this.queryProvider; } } #endregion ////// gets the URI for a the query /// public override Uri RequestUri { get { return this.Translate().Uri; } } ///The ProjectionPlan for the request (if precompiled in a previous page). internal override ProjectionPlan Plan { get { return null; } } ////// gets the UriTranslateResult for a the query /// internal override QueryComponents QueryComponents { get { return this.Translate(); } } ////// Begins an asynchronous request to an Internet resource. /// /// The AsyncCallback delegate. /// The state object for this request. ///An IAsyncResult that references the asynchronous request for a response. public new IAsyncResult BeginExecute(AsyncCallback callback, object state) { return base.BeginExecute(this, this.queryProvider.Context, callback, state); } ////// Ends an asynchronous request to an Internet resource. /// /// The pending request for a response. ///An IEnumerable that contains the response from the Internet resource. public new IEnumerableEndExecute(IAsyncResult asyncResult) { return DataServiceRequest.EndExecute (this, this.queryProvider.Context, asyncResult); } #if !ASTORIA_LIGHT // Synchronous methods not available /// /// Returns an IEnumerable from an Internet resource. /// ///An IEnumerable that contains the response from the Internet resource. public new IEnumerableExecute() { return this.Execute (this.queryProvider.Context, this.Translate()); } #endif /// /// Sets Expand option /// /// Path to expand ///New DataServiceQuery with expand option public DataServiceQueryExpand(string path) { Util.CheckArgumentNull(path, "path"); Util.CheckArgumentNotEmpty(path, "path"); MethodInfo mi = typeof(DataServiceQuery ).GetMethod("Expand"); return (DataServiceQuery )this.Provider.CreateQuery ( Expression.Call( Expression.Convert(this.Expression, typeof(DataServiceQuery .DataServiceOrderedQuery)), mi, new Expression[] { Expression.Constant(path) })); } /// /// Turn the inline counting option on for the query /// ///New DataServiceQuery with count option public DataServiceQueryIncludeTotalCount() { MethodInfo mi = typeof(DataServiceQuery ).GetMethod("IncludeTotalCount"); return (DataServiceQuery )this.Provider.CreateQuery ( Expression.Call( Expression.Convert(this.Expression, typeof(DataServiceQuery .DataServiceOrderedQuery)), mi)); } /// /// Sets user option /// /// name of value /// value of option ///New DataServiceQuery with expand option public DataServiceQueryAddQueryOption(string name, object value) { Util.CheckArgumentNull(name, "name"); Util.CheckArgumentNull(value, "value"); MethodInfo mi = typeof(DataServiceQuery ).GetMethod("AddQueryOption"); return (DataServiceQuery )this.Provider.CreateQuery ( Expression.Call( Expression.Convert(this.Expression, typeof(DataServiceQuery .DataServiceOrderedQuery)), mi, new Expression[] { Expression.Constant(name), Expression.Constant(value, typeof(object)) })); } /// /// get an enumerator materializes the objects the Uri request /// ///an enumerator #if !ASTORIA_LIGHT // Synchronous methods not available public IEnumeratorGetEnumerator() { return this.Execute().GetEnumerator(); } #else IEnumerator IEnumerable .GetEnumerator() { throw Error.NotSupported(Strings.DataServiceQuery_EnumerationNotSupportedInSL); } #endif /// /// gets the URI for the query /// ///a string with the URI public override string ToString() { try { return base.ToString(); } catch (NotSupportedException e) { return Strings.ALinq_TranslationError(e.Message); } } ////// get an enumerator materializes the objects the Uri request /// ///an enumerator System.Collections.IEnumerator System.Collections.IEnumerable.GetEnumerator() { #if !ASTORIA_LIGHT // Synchronous methods not available return this.GetEnumerator(); #else throw Error.NotSupported(); #endif } #if !ASTORIA_LIGHT /// Synchronous methods not available ////// Returns an IEnumerable from an Internet resource. /// ///An IEnumerable that contains the response from the Internet resource. internal override IEnumerable ExecuteInternal() { return this.Execute(); } #endif ////// Begins an asynchronous request to an Internet resource. /// /// The AsyncCallback delegate. /// The state object for this request. ///An IAsyncResult that references the asynchronous request for a response. internal override IAsyncResult BeginExecuteInternal(AsyncCallback callback, object state) { return this.BeginExecute(callback, state); } ////// Ends an asynchronous request to an Internet resource. /// /// The pending request for a response. ///An IEnumerable that contains the response from the Internet resource. internal override IEnumerable EndExecuteInternal(IAsyncResult asyncResult) { return this.EndExecute(asyncResult); } ////// gets the query components for the query after translating /// ///QueryComponents for query private QueryComponents Translate() { if (this.queryComponents == null) { this.queryComponents = this.queryProvider.Translate(this.queryExpression); } return this.queryComponents; } ////// Ordered DataServiceQuery which implements IOrderedQueryable. /// internal class DataServiceOrderedQuery : DataServiceQuery, IOrderedQueryable , IOrderedQueryable { /// /// constructor /// /// expression for query /// query provider for query internal DataServiceOrderedQuery(Expression expression, DataServiceQueryProvider provider) : base(expression, provider) { } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- ColorIndependentAnimationStorage.cs
- ConfigurationValidatorAttribute.cs
- Dispatcher.cs
- ArcSegment.cs
- SerialReceived.cs
- SecurityState.cs
- BigInt.cs
- ImageInfo.cs
- ComponentResourceKey.cs
- Triplet.cs
- UnsafeNativeMethods.cs
- DictionaryEntry.cs
- UnsafeNativeMethods.cs
- XmlIgnoreAttribute.cs
- IndependentAnimationStorage.cs
- SelectionChangedEventArgs.cs
- ActivityExecutionContextCollection.cs
- CapiSafeHandles.cs
- CopyOnWriteList.cs
- ExpressionEditorAttribute.cs
- LoginViewDesigner.cs
- ThemeDictionaryExtension.cs
- QilBinary.cs
- HasActivatableWorkflowEvent.cs
- TableLayoutPanel.cs
- NavigatorInvalidBodyAccessException.cs
- ProxyWebPartManager.cs
- ExpandedWrapper.cs
- Internal.cs
- EventHandlers.cs
- PathGradientBrush.cs
- Geometry.cs
- versioninfo.cs
- PassportIdentity.cs
- UserControlCodeDomTreeGenerator.cs
- IisTraceListener.cs
- CapabilitiesRule.cs
- SubclassTypeValidator.cs
- CanonicalFormWriter.cs
- XmlReflectionImporter.cs
- XmlSchemaObject.cs
- FontUnit.cs
- ObjectStateEntryDbUpdatableDataRecord.cs
- XamlRtfConverter.cs
- XmlQualifiedName.cs
- TypeElement.cs
- MsmqIntegrationBindingCollectionElement.cs
- DuplicateWaitObjectException.cs
- SkinBuilder.cs
- StructuredTypeEmitter.cs
- HttpListenerException.cs
- GPRECT.cs
- TextEndOfLine.cs
- SafeNativeMethods.cs
- AQNBuilder.cs
- CardSpaceSelector.cs
- IResourceProvider.cs
- QilDataSource.cs
- HGlobalSafeHandle.cs
- SmiGettersStream.cs
- InputLanguageCollection.cs
- _ScatterGatherBuffers.cs
- ByteStack.cs
- QilUnary.cs
- Select.cs
- HtmlInputRadioButton.cs
- RenamedEventArgs.cs
- SoapAttributeAttribute.cs
- TdsParser.cs
- ContractCodeDomInfo.cs
- TextEditorLists.cs
- PartialCachingAttribute.cs
- WebAdminConfigurationHelper.cs
- PackageRelationship.cs
- XmlSchemaNotation.cs
- _DisconnectOverlappedAsyncResult.cs
- TcpHostedTransportConfiguration.cs
- SafeArrayRankMismatchException.cs
- IndentTextWriter.cs
- GridItem.cs
- AccessibilityApplicationManager.cs
- TraceSource.cs
- MenuBindingsEditor.cs
- HttpCachePolicyBase.cs
- DataRow.cs
- XamlClipboardData.cs
- BufferModeSettings.cs
- ToolStripHighContrastRenderer.cs
- RewritingPass.cs
- XmlSerializerSection.cs
- Point3DIndependentAnimationStorage.cs
- SplineKeyFrames.cs
- XmlChildNodes.cs
- webeventbuffer.cs
- Utility.cs
- IndentedTextWriter.cs
- PropertyChangedEventManager.cs
- QilValidationVisitor.cs
- cookiecollection.cs
- SqlClientFactory.cs