Code:
/ Dotnetfx_Vista_SP2 / Dotnetfx_Vista_SP2 / 8.0.50727.4016 / DEVDIV / depot / DevDiv / releases / Orcas / QFE / ndp / fx / src / DataWeb / Client / System / Data / Services / Client / DataServiceRequest.cs / 1 / DataServiceRequest.cs
//---------------------------------------------------------------------- //// Copyright (c) Microsoft Corporation. All rights reserved. // //// query request object // //--------------------------------------------------------------------- namespace System.Data.Services.Client { using System; using System.Collections.Generic; using System.Diagnostics; using System.IO; #if !ASTORIA_LIGHT // Data.Services http stack using System.Net; #else using System.Data.Services.Http; #endif using System.Xml; ///non-generic placeholder for generic implementation public abstract class DataServiceRequest { ///internal constructor so that only our assembly can provide an implementation internal DataServiceRequest() { } ///Element Type public abstract Type ElementType { get; } ///Gets the URI for a the query public abstract Uri RequestUri { get; } ///Gets the URI for a the query ///a string with the URI public override string ToString() { return this.RequestUri.ToString(); } ////// get an enumerable materializes the objects the response /// ///element type /// context /// reader /// elementType ///an enumerable internal static object CreateMaterializer(DataServiceContext context, XmlReader reader, Type elementType) { Debug.Assert(null == elementType, "non-null elementType with strongly typed create delegate"); return new MaterializeAtom.MaterializeAtomT (context, reader); } /// /// get an enumerable materializes the objects the response /// ///element type /// context /// contentType /// method to get http response stream ///an enumerable internal static IEnumerableMaterialize (DataServiceContext context, string contentType, Func response) { Func create = CreateMaterializer ; return (IEnumerable )context.GetMaterializer(null, contentType, response, create); } /// /// Creates a instance of strongly typed DataServiceRequest with the given element type. /// /// element type for the DataServiceRequest. /// constructor parameter. ///returns the strongly typed DataServiceRequest instance. internal static DataServiceRequest GetInstance(Type elementType, Uri requestUri) { Type genericType = typeof(DataServiceRequest<>).MakeGenericType(elementType); return (DataServiceRequest)Activator.CreateInstance(genericType, new object[] { requestUri }); } #if !ASTORIA_LIGHT // Synchronous methods not available ////// execute uri and materialize result /// ///element type /// context /// uri to execute ///enumerable of results internal IEnumerableExecute (DataServiceContext context, Uri requestUri) { Debug.Assert(null != context, "context is null"); IEnumerable result = null; QueryAsyncResult response = null; try { DataServiceRequest serviceRequest = new DataServiceRequest (requestUri); HttpWebRequest request = context.CreateRequest(requestUri, XmlConstants.HttpMethodGet, false, null); response = new QueryAsyncResult(this, "Execute", serviceRequest, request, null, null); response.Execute(null); if (HttpStatusCode.NoContent != response.StatusCode) { result = Materialize (context, response.ContentType, response.GetResponseStream); } return (IEnumerable )response.GetResponse(result, typeof(TElement)); } catch (InvalidOperationException ex) { QueryOperationResponse operationResponse = response.GetResponse(result, typeof(TElement)); if (null != operationResponse) { operationResponse.Error = ex; throw new DataServiceQueryException(Strings.DataServiceException_GeneralError, ex, operationResponse); } throw; } } #endif /// enumerable list of materialized objects from stream without having to know T /// context /// contentType /// function to get response stream ///see summary internal abstract System.Collections.IEnumerable Materialize(DataServiceContext context, string contentType, Funcresponse); /// /// Begins an asynchronous request to an Internet resource. /// /// source of execute (DataServiceQuery or DataServiceContext /// context /// The AsyncCallback delegate. /// The state object for this request. ///An IAsyncResult that references the asynchronous request for a response. internal IAsyncResult BeginExecute(object source, DataServiceContext context, AsyncCallback callback, object state) { Debug.Assert(null != context, "context is null"); HttpWebRequest request = context.CreateRequest(this.RequestUri, XmlConstants.HttpMethodGet, false, null); QueryAsyncResult result = new QueryAsyncResult(source, "Execute", this, request, callback, state); result.BeginExecute(null); return result; } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. //---------------------------------------------------------------------- //// Copyright (c) Microsoft Corporation. All rights reserved. // //// query request object // //--------------------------------------------------------------------- namespace System.Data.Services.Client { using System; using System.Collections.Generic; using System.Diagnostics; using System.IO; #if !ASTORIA_LIGHT // Data.Services http stack using System.Net; #else using System.Data.Services.Http; #endif using System.Xml; ///non-generic placeholder for generic implementation public abstract class DataServiceRequest { ///internal constructor so that only our assembly can provide an implementation internal DataServiceRequest() { } ///Element Type public abstract Type ElementType { get; } ///Gets the URI for a the query public abstract Uri RequestUri { get; } ///Gets the URI for a the query ///a string with the URI public override string ToString() { return this.RequestUri.ToString(); } ////// get an enumerable materializes the objects the response /// ///element type /// context /// reader /// elementType ///an enumerable internal static object CreateMaterializer(DataServiceContext context, XmlReader reader, Type elementType) { Debug.Assert(null == elementType, "non-null elementType with strongly typed create delegate"); return new MaterializeAtom.MaterializeAtomT (context, reader); } /// /// get an enumerable materializes the objects the response /// ///element type /// context /// contentType /// method to get http response stream ///an enumerable internal static IEnumerableMaterialize (DataServiceContext context, string contentType, Func response) { Func create = CreateMaterializer ; return (IEnumerable )context.GetMaterializer(null, contentType, response, create); } /// /// Creates a instance of strongly typed DataServiceRequest with the given element type. /// /// element type for the DataServiceRequest. /// constructor parameter. ///returns the strongly typed DataServiceRequest instance. internal static DataServiceRequest GetInstance(Type elementType, Uri requestUri) { Type genericType = typeof(DataServiceRequest<>).MakeGenericType(elementType); return (DataServiceRequest)Activator.CreateInstance(genericType, new object[] { requestUri }); } #if !ASTORIA_LIGHT // Synchronous methods not available ////// execute uri and materialize result /// ///element type /// context /// uri to execute ///enumerable of results internal IEnumerableExecute (DataServiceContext context, Uri requestUri) { Debug.Assert(null != context, "context is null"); IEnumerable result = null; QueryAsyncResult response = null; try { DataServiceRequest serviceRequest = new DataServiceRequest (requestUri); HttpWebRequest request = context.CreateRequest(requestUri, XmlConstants.HttpMethodGet, false, null); response = new QueryAsyncResult(this, "Execute", serviceRequest, request, null, null); response.Execute(null); if (HttpStatusCode.NoContent != response.StatusCode) { result = Materialize (context, response.ContentType, response.GetResponseStream); } return (IEnumerable )response.GetResponse(result, typeof(TElement)); } catch (InvalidOperationException ex) { QueryOperationResponse operationResponse = response.GetResponse(result, typeof(TElement)); if (null != operationResponse) { operationResponse.Error = ex; throw new DataServiceQueryException(Strings.DataServiceException_GeneralError, ex, operationResponse); } throw; } } #endif /// enumerable list of materialized objects from stream without having to know T /// context /// contentType /// function to get response stream ///see summary internal abstract System.Collections.IEnumerable Materialize(DataServiceContext context, string contentType, Funcresponse); /// /// Begins an asynchronous request to an Internet resource. /// /// source of execute (DataServiceQuery or DataServiceContext /// context /// The AsyncCallback delegate. /// The state object for this request. ///An IAsyncResult that references the asynchronous request for a response. internal IAsyncResult BeginExecute(object source, DataServiceContext context, AsyncCallback callback, object state) { Debug.Assert(null != context, "context is null"); HttpWebRequest request = context.CreateRequest(this.RequestUri, XmlConstants.HttpMethodGet, false, null); QueryAsyncResult result = new QueryAsyncResult(source, "Execute", this, request, callback, state); result.BeginExecute(null); return result; } } } // 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
- Columns.cs
- ListViewGroupItemCollection.cs
- BindUriHelper.cs
- XmlUTF8TextReader.cs
- WindowsFont.cs
- BaseTemplateBuildProvider.cs
- GridView.cs
- ListViewGroupConverter.cs
- ConsumerConnectionPointCollection.cs
- InheritablePropertyChangeInfo.cs
- coordinatorscratchpad.cs
- ContentTextAutomationPeer.cs
- MediaContextNotificationWindow.cs
- ServiceElement.cs
- CompiledIdentityConstraint.cs
- PrinterSettings.cs
- TemplateNodeContextMenu.cs
- UserUseLicenseDictionaryLoader.cs
- WindowsFormsSynchronizationContext.cs
- SystemResources.cs
- MultiAsyncResult.cs
- SafeNativeMethodsCLR.cs
- ZipIOModeEnforcingStream.cs
- StringHandle.cs
- SqlUserDefinedAggregateAttribute.cs
- SafeSecurityHandles.cs
- QilPatternFactory.cs
- MetadataArtifactLoaderResource.cs
- StatusBarItemAutomationPeer.cs
- SponsorHelper.cs
- InheritanceContextChangedEventManager.cs
- SafeArrayTypeMismatchException.cs
- WebConfigurationManager.cs
- XmlTypeMapping.cs
- GridViewItemAutomationPeer.cs
- AssociationSet.cs
- MessageDescriptionCollection.cs
- RequestUriProcessor.cs
- MaterialGroup.cs
- GridViewDeleteEventArgs.cs
- Int32AnimationUsingKeyFrames.cs
- UserMapPath.cs
- SequentialActivityDesigner.cs
- ConnectionPoolManager.cs
- TemplatedControlDesigner.cs
- OracleConnectionString.cs
- XmlMtomReader.cs
- DiscoveryMessageSequenceGenerator.cs
- ProcessModuleCollection.cs
- RelationshipWrapper.cs
- IndexedString.cs
- DrawToolTipEventArgs.cs
- WmlPageAdapter.cs
- ConnectionsZoneDesigner.cs
- HttpRuntimeSection.cs
- HttpCacheVary.cs
- Rect3DConverter.cs
- AvtEvent.cs
- DbConvert.cs
- CrossContextChannel.cs
- JavascriptCallbackMessageInspector.cs
- PartialClassGenerationTask.cs
- ListManagerBindingsCollection.cs
- SqlTypesSchemaImporter.cs
- LogEntrySerializer.cs
- ErrorFormatterPage.cs
- InstanceLockedException.cs
- DigestTraceRecordHelper.cs
- FontFamilyConverter.cs
- NavigationFailedEventArgs.cs
- ActivityInterfaces.cs
- ObjectAssociationEndMapping.cs
- counter.cs
- TextDecorationCollection.cs
- DataGridViewDataConnection.cs
- DependencyPropertyKey.cs
- TemplatePropertyEntry.cs
- WindowsTreeView.cs
- BaseTemplateBuildProvider.cs
- TransformerConfigurationWizardBase.cs
- XmlSchemaComplexContentExtension.cs
- SHA1.cs
- ReverseQueryOperator.cs
- RootBrowserWindowAutomationPeer.cs
- TextFindEngine.cs
- PerspectiveCamera.cs
- Vector3DKeyFrameCollection.cs
- ColumnPropertiesGroup.cs
- WebConfigurationHost.cs
- TreeWalker.cs
- CookieParameter.cs
- DefaultEventAttribute.cs
- WebPartUserCapability.cs
- BypassElementCollection.cs
- NameTable.cs
- AdCreatedEventArgs.cs
- DecoderNLS.cs
- DNS.cs
- TemplateBindingExpression.cs
- HashStream.cs