DataServiceRequest.cs source code in C# .NET

Source code for the .NET framework in C#

                        
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 IEnumerable Materialize(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 IEnumerable Execute(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, Func response);

        /// 
        /// 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 IEnumerable Materialize(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 IEnumerable Execute(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, Func response);

        /// 
        /// 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

Network programming in C#, Network Programming in VB.NET, Network Programming in .NET
This book is available now!
Buy at Amazon US or
Buy at Amazon UK