热门：网页模板.net视频教程JQueryMVCjsonExtJs源码示例三级联动JQuery菜单
您现在的位置：.Net中文社区>> AJAX编程>>正文内容

示例在AJAX应用中访问ADO.NET Data Service

发布时间：2010年05月15日点击数： 次佚名

下面这个例子演示了如何使用ASP.NET AJAX的技术访问到ADO.NET Data Service，并且实现了数据的增删改查等常规操作

  1. <%@ Page Language="C#" AutoEventWireup="true" CodeBehind="Default.aspx.cs" Inherits="WebApplication2._Default" %> 
  2.  
  3. <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"> 
  4. <html xmlns="http://www.w3.org/1999/xhtml"> 
  5. <head runat="server"> 
  6.     <title></title> 
  7.  
  8.     <script src="jquery-1.3.2-vsdoc.js" type="text/javascript"></script> 
  9.  
  10.     <script src="MicrosoftAjax.js" type="text/javascript"></script> 
  11.  
  12.     <script src="DataService.js" type="text/javascript"></script> 
  13.  
  14.     <script type="text/javascript" language="javascript"> 
  15.         function GetService() { 
  16.             return new Sys.Data.DataService("/NorthwindService.svc"); 
  17.         } 
  18.  
  19.         $(function() { 
  20.             $("#query").click(function() { 
  21.                 //发起一个异步查询 
  22.                 var proxy = GetService(); 
  23.                 var query = "/Customers()"; //这里构造的查询字符串可以很复杂 
  24.                 proxy.query(query, function(result, context) { 
  25.                     for (idx in result) { 
  26.                         var customer = result[idx]; 
  27.                         $("<li>" + customer.CustomerID + "," + customer.CompanyName + "</li>").appendTo("#result"); 
  28.                     } 
  29.                 }); 
  30.  
  31.             }); 
  32.  
  33.  
  34.             $("#insert").click(function() { 
  35.                 //插入一个新的客户 
  36.                 var proxy = GetService(); 
  37.                 var customer = { 
  38.                     CustomerID: "ABCDE", 
  39.                     CompanyName: "Thinker Inc" 
  40.                 }; 
  41.  
  42.                 proxy.insert(customer, "/Customers", function(result) { 
  43.                     alert("操作已经成功"); 
  44.                 }); 
  45.  
  46.             }); 
  47.  
  48.  
  49.  
  50.             $("#update").click(function() { 
  51.                 //更新一个客户 
  52.                 var proxy = GetService(); 
  53.                 var customer; 
  54.                 proxy.query("/Customers('ABCDE')", function(result) { 
  55.                     customer = result; 
  56.  
  57.                     //修改这个customer 
  58.                     customer.CompanyName = "Changed"; 
  59.                     proxy.update(customer, null, function(result) { 
  60.                         alert("更新成功"); 
  61.                     }); 
  62.                 }); 
  63.  
  64.  
  65.             }); 
  66.  
  67.  
  68.             $("#delete").click(function() { 
  69.                 //删除一个客户 
  70.                 var proxy = GetService(); 
  71.                 var customerID = "ABCDE"; 
  72.                 proxy.remove(null, "/Customers('" + customerID + "')", function(result) { 
  73.                     alert("删除成功"); 
  74.                 }); 
  75.             }); 
  76.  
  77.         }); 
  78.     </script> 
  79.  
  80. </head> 
  81. <body> 
  82.     <form id="form1" runat="server"> 
  83.     <div> 
  84.         <input type="button" value="查询" id="query" /> 
  85.         <input type="button" value="插入" id="insert" /> 
  86.         <input type="button" value="更新" id="update" /> 
  87.         <input type="button" value="删除" id="delete" /> 
  88.     </div> 
  89.     <ol id="result"> 
  90.     </ol> 
  91.     </form> 
  92. </body> 
  93. </html> 

注意，这个DataService.js是单独的，它实际上是封装了四个操作

  1. //------------------------------------------------------------------------------ 
  2. // <copyright file="DataService.js" company="Microsoft"> 
  3. //     Copyright (c) Microsoft Corporation.  All rights reserved. 
  4. // </copyright> 
  5. //------------------------------------------------------------------------------ 
  6.  
  7. Type.registerNamespace('Sys.Data'); 
  8.  
  9. Sys.Data.ActionResult = function(result, error, actionContext, operation) { 
  10.     /// <summary>Represents the result of a single operation in an action sequence batch.</summary> 
  11.     /// <param name="result" mayBeNull="true">Result (if any) of the operation.</param> 
  12.     /// <param name="error" mayBeNull="true" type="Sys.Data.DataServiceError">Error that occurred during the operation.</param> 
  13.     /// <param name="actionContext" mayBeNull="true">Context object passed to the executor.</param> 
  14.     /// <param name="operation" type="String">Short description of the operation performed.</param> 
  15.     this._result = result; 
  16.     this._error = error; 
  17.     this._actionContext = actionContext; 
  18.     this._operation = operation; 
  19. } 
  20.  
  21. Sys.Data.ActionResult.prototype = { 
  22.  
  23.     /* 
  24.      * PROPERTIES 
  25.      */ 
  26.  
  27.     get_result: function() { 
  28.         /// <summary>Gets the result (if any) of the operation.</summary> 
  29.         /// <value mayBeNull="true">Operation result.</value> 
  30.         return this._result; 
  31.     }, 
  32.     get_error: function() { 
  33.         /// <summary>Gets the error that occurred during the operation.  Returns null if no error occurred.</summary> 
  34.         /// <value mayBeNull="true" type="Sys.Data.DataServiceError">Operation error.</value> 
  35.         return this._error; 
  36.     }, 
  37.     get_actionContext: function() { 
  38.         /// <summary>Gets the context object passed to the executor.</summary> 
  39.         /// <value mayBeNull="true">Operation context object.</value> 
  40.         return this._actionContext; 
  41.     }, 
  42.     get_operation: function() { 
  43.         /// <summary>Gets a short description of the operation performed.</summary> 
  44.         /// <value type="String">Operation description.</value> 
  45.         return this._operation; 
  46.     } 
  47.      
  48. }; 
  49.  
  50. Sys.Data.ActionResult.registerClass("Sys.Data.ActionResult"); 
  51.  
  52. Sys.Data.ActionSequence = function(dataService) { 
  53.     /// <summary>Exposes methods for performing batch operations against a web-based data service.</summary> 
  54.     /// <param name="dataService" type="Sys.Data.DataService">The DataService object against which to perform operations.</param> 
  55.     this._dataService = dataService; 
  56.     this._actionQueue = new Array(); 
  57. } 
  58.  
  59. Sys.Data.ActionSequence.prototype = { 
  60.  
  61.     /* 
  62.      * PROPERTIES 
  63.      */ 
  64.       
  65.     get_service: function() { 
  66.         /// <summary>Gets the DataService object against which operations are performed.</summary> 
  67.         /// <value type="Sys.Data.DataService">The DataService.</value> 
  68.         return this._dataService; 
  69.     }, 
  70.      
  71.     /* 
  72.      * METHODS 
  73.      */ 
  74.  
  75.     addInsertAction: function(item, resourceSetUri, actionContext) { 
  76.         /// <summary>Adds an insertion to the execution queue.</summary> 
  77.         /// <param name="item" type="Object">Item to insert.</param> 
  78.         /// <param name="resourceSetUri" type="String" mayBeNull="true">Resource set into which the item should be inserted.</param> 
  79.         /// <param name="actionContext" mayBeNull="true" optional="true">A context object associated with this operation.</param> 
  80.          
  81.         var dataService = this._dataService; 
  82.         Array.enqueue(this._actionQueue, function(o) { dataService.insert( 
  83.             item, 
  84.             resourceSetUri, 
  85.             Sys.Data.ActionSequence._genSuccessCallback(o), 
  86.             Sys.Data.ActionSequence._genFailureCallback(o), 
  87.             actionContext // userContext (per-action) 
  88.         )}); 
  89.     }, 
  90.      
  91.     addUpdateAction: function(item, resourceUri, actionContext) { 
  92.         /// <summary>Adds an update to the execution queue.</summary> 
  93.         /// <param name="item" type="Object">Item to update.</param> 
  94.         /// <param name="resourceUri" type="String" mayBeNull="true" optional="true">Resource set in which the item should be updated.</param> 
  95.         /// <param name="actionContext" mayBeNull="true" optional="true">A context object associated with this operation.</param> 
  96.          
  97.         var dataService = this._dataService; 
  98.         Array.enqueue(this._actionQueue, function(o) { dataService.update( 
  99.             item, 
  100.             resourceUri, 
  101.             Sys.Data.ActionSequence._genSuccessCallback(o), 
  102.             Sys.Data.ActionSequence._genFailureCallback(o), 
  103.             actionContext // userContext (per-action) 
  104.         )}); 
  105.     }, 
  106.  
  107.     addRemoveAction: function(item, resourceUri, actionContext) { 
  108.         /// <summary>Adds a removal to the execution queue.</summary> 
  109.         /// <param name="item" type="Object" mayBeNull="true">Item to remove.</param> 
  110.         /// <param name="resourceUri" type="String" mayBeNull="true" optional="true">Resource set from which the item should be removed.</param> 
  111.         /// <param name="actionContext" mayBeNull="true" optional="true">A context object associated with this operation.</param> 
  112.          
  113.         var dataService = this._dataService; 
  114.         Array.enqueue(this._actionQueue, function(o) { dataService.remove( 
  115.             item, 
  116.             resourceUri, 
  117.             Sys.Data.ActionSequence._genSuccessCallback(o), 
  118.             Sys.Data.ActionSequence._genFailureCallback(o), 
  119.             actionContext // userContext (per-action) 
  120.         )}); 
  121.     }, 
  122.      
  123.     clearActions : function() { 
  124.         /// <summary>Clears the action queue.</summary> 
  125.         Array.clear(this._actionQueue); 
  126.     }, 
  127.      
  128.     executeActions: function(actionsCallback, userContext) { 
  129.         /// <summary>Executes operations in the action queue.</summary> 
  130.         /// <param name="actionsCallback" type="Function" mayBeNull="true" optional="true">Callback to execute upon completion of all operations.</param> 
  131.         /// <param name="userContext" mayBeNull="true" optional="true">A context object associated with this batch.</param> 
  132.      
  133.         // state object for internal callback methods 
  134.         var o = { 
  135.             actionResultQueue: new Array(), 
  136.             hasError: false, 
  137.             remainingActions: this._actionQueue 
  138.         }; 
  139.          
  140.         // break reference to array so user can't modify after kickoff 
  141.         this._actionQueue = new Array(); 
  142.          
  143.         // kickoff - ensure final callback is asynchronous so as not to break method contract 
  144.         Array.enqueue(o.remainingActions, function(o) { 
  145.             if (actionsCallback) { 
  146.                 window.setTimeout(function() { actionsCallback(o.actionResultQueue, o.hasError, userContext); }, 0); 
  147.             } 
  148.         }); 
  149.         Array.dequeue(o.remainingActions)(o); 
  150.     } 
  151.      
  152. } 
  153.  
  154. /* 
  155.  * STATIC INTERNAL HELPER METHODS 
  156.  */ 
  157.  
  158. // generates an onSuccess callback 
  159. Sys.Data.ActionSequence._genSuccessCallback = function(o) { 
  160.     return function(result, actionContext, operation) { 
  161.         var newAR = new Sys.Data.ActionResult(result, null, actionContext, operation); 
  162.         Array.enqueue(o.actionResultQueue, newAR); 
  163.         Array.dequeue(o.remainingActions)(o); // kickoff next function 
  164.     }; 
  165. }; 
  166.  
  167. // generates an onFailure callback 
  168. Sys.Data.ActionSequence._genFailureCallback = function(o) { 
  169.     return function(error, actionContext, operation) { 
  170.         o.hasError = true; 
  171.         var newAR = new Sys.Data.ActionResult(null, error, actionContext, operation); 
  172.         Array.enqueue(o.actionResultQueue, newAR); 
  173.         Array.dequeue(o.remainingActions)(o); // kickoff next function 
  174.     }; 
  175. }; 
  176.  
  177. Sys.Data.ActionSequence.registerClass("Sys.Data.ActionSequence"); 
  178.  
  179. Sys.Data.DataService = function(serviceUri) { 
  180.     /// <summary>Exposes methods for interacting with a web-based data service.</summary> 
  181.     /// <param name="serviceUri" type="String">URI (absolute or relative) of the data service.</param> 
  182.     this._serviceUri = serviceUri; 
  183.     this._timeout = 0; 
  184.     this._defaultUserContext = null; 
  185.     this._defaultSucceededCallback = null; 
  186.     this._defaultFailedCallback = null; 
  187. } 
  188.  
  189. Sys.Data.DataService.prototype = { 
  190.  
  191.     /* 
  192.      * PROPERTIES 
  193.      */ 
  194.  
  195.     get_serviceUri: function() { 
  196.         /// <summary>Gets the URI of the data service.</summary> 
  197.         /// <value type="String">The URI of the data service.</value> 
  198.         return this._serviceUri; 
  199.     }, 
  200.      
  201.     get_timeout: function() { 
  202.         /// <summary>Gets the timeout period of each operation.</summary> 
  203.         /// <value type="Number" integer="true">The timeout period (in milliseconds) for each operation.</value> 
  204.         if (this._timeout === 0) { 
  205.             return Sys.Net.WebRequestManager.get_defaultTimeout(); 
  206.         } 
  207.         return this._timeout; 
  208.     }, 
  209.     set_timeout: function(value) { 
  210.         this._timeout = value; 
  211.     }, 
  212.      
  213.     get_defaultUserContext: function() { 
  214.         /// <summary>Gets the default user context (state object) of each operation.</summary> 
  215.         /// <value mayBeNull="true">The default user context for each operation.</value> 
  216.         return this._defaultUserContext; 
  217.     }, 
  218.     set_defaultUserContext: function(value) { 
  219.         this._defaultUserContext = value; 
  220.     }, 
  221.      
  222.     get_defaultSucceededCallback: function() { 
  223.         /// <summary>Gets the default callback executed after each successful operation.</summary> 
  224.         /// <value type="Function" mayBeNull="true">The default success callback for each operation.</value> 
  225.         return this._defaultSucceededCallback; 
  226.     }, 
  227.     set_defaultSucceededCallback: function(value) { 
  228.         this._defaultSucceededCallback = value; 
  229.     }, 
  230.  
  231.     get_defaultFailedCallback: function() { 
  232.         /// <summary>Gets the default callback executed after each unsuccessful operation.</summary> 
  233.         /// <value type="Function" mayBeNull="true">The default failure callback for each operation.</value> 
  234.         return this._defaultFailedCallback; 
  235.     }, 
  236.     set_defaultFailedCallback: function(value) { 
  237.         this._defaultFailedCallback = value; 
  238.     }, 
  239.      
  240.     /* 
  241.      * METHODS 
  242.      */ 
  243.      
  244.     query: function(query, succeededCallback, failedCallback, userContext, webRequest) { 
  245.         /// <summary>Performs a query (read) against the data service.</summary> 
  246.         /// <param name="query" type="String" mayBeNull="true" optional="true">Path to query.</param> 
  247.         /// <param name="succeededCallback" type="Function" mayBeNull="true" optional="true">Callback to execute upon successful completion of the operation.</param> 
  248.         /// <param name="failedCallback" type="Function" mayBeNull="true" optional="true">Callback to execute upon unsuccessful completion of the operation.</param> 
  249.         /// <param name="userContext" mayBeNull="true" optional="true">A context object associated with this operation.</param> 
  250.         /// <param name="webRequest" type="Sys.Net.WebRequest" mayBeNull="true" optional="true">A WebRequest object to use for this operation.</param> 
  251.          
  252.         var wRequest = this._prepWebRequest(null, query, "GET", succeededCallback, failedCallback, userContext, query, webRequest); 
  253.         wRequest.invoke(); 
  254.     }, 
  255.      
  256.     loadProperty: function(item, property, succeededCallback, failedCallback, userContext, webRequest) { 
  257.         /// <summary>Populates the property of a given item.</summary> 
  258.         /// <param name="item" type="Object">Item containing the property to be populated.</param> 
  259.         /// <param name="property" type="String">Name of the property which should be populated.</param> 
  260.         /// <param name="succeededCallback" type="Function" mayBeNull="true" optional="true">Callback to execute upon successful completion of the operation.</param> 
  261.         /// <param name="failedCallback" type="Function" mayBeNull="true" optional="true">Callback to execute upon unsuccessful completion of the operation.</param> 
  262.         /// <param name="userContext" mayBeNull="true" optional="true">A context object associated with this operation.</param> 
  263.         /// <param name="webRequest" type="Sys.Net.WebRequest" mayBeNull="true" optional="true">A WebRequest object to use for this operation.</param> 
  264.          
  265.         var succeededHelper = function(result, context, operation) { 
  266.             item[operation] = result; 
  267.             if (!succeededCallback) { 
  268.                 succeededCallback = this._defaultSucceededCallback; 
  269.             } 
  270.             if (succeededCallback) { 
  271.                 succeededCallback(item, context, operation); 
  272.             } 
  273.         }; 
  274.          
  275.         var uri; 
  276.         if (item[property] && item[property].__metadata && item[property].__metadata.uri) { 
  277.             uri = item[property].__metadata.uri; 
  278.         } 
  279.         else if (item.__metadata && item.__metadata.uri) { 
  280.             uri = item.__metadata.uri + '/' + property; 
  281.         } 
  282.         else { 
  283.             throw Error.create(Sys.Data.Res.dataServiceLoadPropertyUriNotPresent); 
  284.         } 
  285.          
  286.         var wRequest = this._prepWebRequest(null, uri, "GET", succeededHelper, failedCallback, userContext, property, webRequest); 
  287.         wRequest.invoke(); 
  288.     }, 
  289.      
  290.     insert: function(item, resourceSetUri, succeededCallback, failedCallback, userContext, webRequest) { 
  291.         /// <summary>Performs an insertion against the data service.</summary> 
  292.         /// <param name="item" type="Object">Item to insert.</param> 
  293.         /// <param name="resourceSetUri" type="String" mayBeNull="true">Resource set into which the item should be inserted.</param> 
  294.         /// <param name="succeededCallback" type="Function" mayBeNull="true" optional="true">Callback to execute upon successful completion of the operation.</param> 
  295.         /// <param name="failedCallback" type="Function" mayBeNull="true" optional="true">Callback to execute upon unsuccessful completion of the operation.</param> 
  296.         /// <param name="userContext" mayBeNull="true" optional="true">A context object associated with this operation.</param> 
  297.         /// <param name="webRequest" type="Sys.Net.WebRequest" mayBeNull="true" optional="true">A WebRequest object to use for this operation.</param> 
  298.          
  299.         var wRequest = this._prepWebRequest(null, resourceSetUri, "POST", succeededCallback, failedCallback, userContext, "insert", webRequest); 
  300.          
  301.         // moved serialization logic out since we ignore metadata 
  302.         wRequest.set_body(Sys.Serialization.JavaScriptSerializer.serialize(item));                 
  303.         wRequest.get_headers()["Content-Type"] = "application/json"; 
  304.         wRequest.invoke(); 
  305.     }, 
  306.  
  307.     update: function(item, resourceUri, succeededCallback, failedCallback, userContext, webRequest) { 
  308.         /// <summary>Performs an update against the data service.</summary> 
  309.         /// <param name="item" type="Object">Item to update.</param> 
  310.         /// <param name="resourceUri" type="String" mayBeNull="true">Resource set in which the item should be updated.</param> 
  311.         /// <param name="succeededCallback" type="Function" mayBeNull="true" optional="true">Callback to execute upon successful completion of the operation.</param> 
  312.         /// <param name="failedCallback" type="Function" mayBeNull="true" optional="true">Callback to execute upon unsuccessful completion of the operation.</param> 
  313.         /// <param name="userContext" mayBeNull="true" optional="true">A context object associated with this operation.</param> 
  314.         /// <param name="webRequest" type="Sys.Net.WebRequest" mayBeNull="true" optional="true">A WebRequest object to use for this operation.</param> 
  315.  
  316.         var wRequest = this._prepWebRequest(item, resourceUri, "PUT", succeededCallback, failedCallback, userContext, "update", webRequest); 
  317.         wRequest.get_headers()["Content-Type"] = "application/json"; 
  318.         wRequest.invoke(); 
  319.     }, 
  320.      
  321.     remove: function(item, resourceUri, succeededCallback, failedCallback, userContext, webRequest) { 
  322.         /// <summary>Performs a removal against the data service.</summary> 
  323.         /// <param name="item" type="Object" mayBeNull="true">Item to remove.</param> 
  324.         /// <param name="resourceUri" type="String" mayBeNull="true" optional="true">Resource set from which the item should be removed.</param> 
  325.         /// <param name="succeededCallback" type="Function" mayBeNull="true" optional="true">Callback to execute upon successful completion of the operation.</param> 
  326.         /// <param name="failedCallback" type="Function" mayBeNull="true" optional="true">Callback to execute upon unsuccessful completion of the operation.</param> 
  327.         /// <param name="userContext" mayBeNull="true" optional="true">A context object associated with this operation.</param> 
  328.         /// <param name="webRequest" type="Sys.Net.WebRequest" mayBeNull="true" optional="true">A WebRequest object to use for this operation.</param> 
  329.          
  330.         if (!((item && item.__metadata && item.__metadata.uri) || resourceUri)) { 
  331.             // must specify URI in item metadata or as parameter 
  332.             throw Error.create(Sys.Data.Res.dataServiceRemoveUriNotPresent); 
  333.         } 
  334.          
  335.         var wRequest = this._prepWebRequest(item, resourceUri, "DELETE", 
  336.             this._cbReplaceResult(succeededCallback, null) /* don't return any object to success callback */, 
  337.             failedCallback, userContext, "remove", webRequest); 
  338.          
  339.         // we can't actually serialize an item when we perform a removal 
  340.         delete wRequest.get_headers()["Content-Type"]; 
  341.         wRequest.set_body(null); 
  342.          
  343.         wRequest.invoke(); 
  344.     }, 
  345.      
  346.     invoke: function(operationUri, httpVerb, parameters, succeededCallback, failedCallback, userContext, webRequest) { 
  347.         /// <summary>Invokes a method exposed by the data service.</summary> 
  348.         /// <param name="operationUri" type="String">Path to the service operation to invoke.</param> 
  349.         /// <param name="httpVerb" type="String" maybeNull="true" optional="true">HTTP verb to be used for this service call.</param> 
  350.         /// <param name="parameters" type="Object" maybeNull="true" optional="true">Dictionary of parameters to be passed to the service method.</param> 
  351.         /// <param name="succeededCallback" type="Function" mayBeNull="true" optional="true">Callback to execute upon successful completion of the operation.</param> 
  352.         /// <param name="failedCallback" type="Function" mayBeNull="true" optional="true">Callback to execute upon unsuccessful completion of the operation.</param> 
  353.         /// <param name="userContext" mayBeNull="true" optional="true">A context object associated with this operation.</param> 
  354.         /// <param name="webRequest" type="Sys.Net.WebRequest" mayBeNull="true" optional="true">A WebRequest object to use for this operation.</param> 
  355.          
  356.         var qb = new Sys.Data.QueryBuilder(operationUri); 
  357.         for (key in parameters) { 
  358.             qb.get_queryParams()[encodeURIComponent(key)] = encodeURIComponent(parameters[key]); 
  359.         } 
  360.          
  361.         var wRequest = this._prepWebRequest(null, qb.toString(), httpVerb, succeededCallback, failedCallback, userContext, operationUri, webRequest); 
  362.         if (httpVerb == "POST") { 
  363.             // prevents CSRF (SQLBUDT 554530) 
  364.             wRequest.get_headers()["X-Service-Post"] = "true"; 
  365.         } 
  366.         wRequest.invoke();         
  367.     }, 
  368.      
  369.     createActionSequence: function() { 
  370.         /// <summary>Creates a new action sequence for execution against this data service.</summary> 
  371.         /// <returns type="Sys.Data.ActionSequence">An ActionSequence object.</returns> 
  372.         return new Sys.Data.ActionSequence(this); 
  373.     }, 
  374.      
  375.     /* 
  376.      * INTERNAL HELPER FUNCTIONS 
  377.      */ 
  378.      
  379.     // common code for preparing a WebRequest 
  380.     _prepWebRequest: function(item, relUri, verb, onSuccess, onFailure, context, operation, wRequest) { 
  381.      
  382.         if (!relUri) { 
  383.             relUri = ""; 
  384.         } 
  385.         if (!wRequest) { 
  386.             wRequest = new Sys.Net.WebRequest(); 
  387.         } 
  388.      
  389.         wRequest.set_url(Sys.Data.DataService._concatUris(this._serviceUri, relUri)); 
  390.         wRequest.set_httpVerb(verb); 
  391.         wRequest.set_timeout(this.get_timeout()); 
  392.          
  393.         var headers = wRequest.get_headers(); 
  394.         headers["Accept"] = "application/json"; 
  395.          
  396.         if (item) { 
  397.             wRequest.set_body(Sys.Serialization.JavaScriptSerializer.serialize(item));                 
  398.             headers["Content-Type"] = "application/json"; 
  399.             if (item.__metadata && item.__metadata.uri) 
  400.                 wRequest.set_url(item.__metadata.uri); 
  401.         } 
  402.          
  403.         // set defaults 
  404.         if (!onSuccess) { 
  405.             onSuccess = this._defaultSucceededCallback;     
  406.         } 
  407.         if (!onFailure) { 
  408.             onFailure = this._defaultFailedCallback; 
  409.         } 
  410.         if (!context) { 
  411.             context = this._defaultUserContext; 
  412.         } 
  413.          
  414.         wRequest.add_completed(function(executor, eventArgs) { 
  415.             Sys.Data.DataService._callbackHelper(executor, eventArgs, onSuccess, onFailure, context, operation); 
  416.         }); 
  417.          
  418.         return wRequest; 
  419.      
  420.     }, 
  421.      
  422.     // helper to replace the result object for callbacks 
  423.     _cbReplaceResult: function(cb, retVal) { 
  424.         if (!cb) { 
  425.             cb = this._defaultSucceededCallback; 
  426.         } 
  427.         return (cb) 
  428.             ? function(result, context, operation) { cb(retVal, context, operation); } 
  429.             : null; 
  430.     } 
  431.  
  432. } 
  433.  
  434. /* 
  435.  * STATIC INTERNAL HELPER FUNCTIONS 
  436.  */ 
  437.  
  438. // concatenation of URIs 
  439. Sys.Data.DataService._concatUris = function(serviceUri, resourceUri) { 
  440.  
  441.     if (serviceUri.endsWith('/')) { 
  442.         serviceUri = serviceUri.substr(0, serviceUri.length - 1); 
  443.     } 
  444.          
  445.     if (resourceUri.startsWith('/')) { 
  446.         resourceUri = resourceUri.substr(1); 
  447.     } 
  448.      
  449.     return serviceUri + '/' + resourceUri; 
  450.  
  451. }; 
  452.  
  453. // heavily modified preexisting WebServiceProxy code handles deserialization of data service responses 
  454. Sys.Data.DataService._callbackHelper = function(executor, eventArgs, onSuccess, onFailure, userContext, operation) { 
  455.     if (executor.get_responseAvailable()) { 
  456.         var statusCode = executor.get_statusCode(); 
  457.         // works around an IE bug where 204 responses to PUT requests get turned into 1223 errors. 
  458.         if (statusCode == 1223) { 
  459.             statusCode = 204; 
  460.         } 
  461.         var result = null; 
  462.         
  463.         try { 
  464.             var contentType = executor.getResponseHeader("Content-Type"); 
  465.             if (contentType.startsWith("application/json")) { 
  466.                 result = executor.get_object(); 
  467.             } 
  468.             else if (contentType.startsWith("text/xml")) { 
  469.                 result = executor.get_xml(); 
  470.             } 
  471.             // Default to the executor text 
  472.             else { 
  473.                 result = executor.get_responseData(); 
  474.             } 
  475.         } catch (ex) { 
  476.         } 
  477.  
  478.         var error = executor.getResponseHeader("jsonerror"); 
  479.         var errorObj = (error === "true"); 
  480.         if (errorObj) { 
  481.             if (result) { 
  482.                 result = new Sys.Data.DataServiceError(false, result.Message, result.StackTrace, result.ExceptionType); 
  483.             } 
  484.         } 
  485.         else if (contentType.startsWith("application/json")) { 
  486.             if (!result || typeof(result.d) === "undefined") { 
  487.                 throw Sys.Data.DataService._createFailedError(operation, String.format("The data operation '{0}' returned invalid data. The JSON wrapper is incorrect.", operation)); 
  488.             } 
  489.             result = result.d; 
  490.         } 
  491.         if (((statusCode < 200) || (statusCode >= 300)) || errorObj) { 
  492.             if (onFailure) { 
  493.                 if (!result || !errorObj) { 
  494.                     result = new Sys.Data.DataServiceError(false /*timedout*/, String.format("The data operation '{0}' failed.", operation), "", ""); 
  495.                 } 
  496.                 result._statusCode = statusCode; 
  497.                 onFailure(result, userContext, operation); 
  498.             } 
  499.             // #if DEBUG 
  500.             else { 
  501.                 // In debug mode, if no error was registered, display some trace information 
  502.                 if (result && errorObj) { 
  503.                     // If we got a result, we're likely dealing with an error in the method itself 
  504.                     error = result.get_exceptionType() + "-- " + result.get_message(); 
  505.                 } 
  506.                 else { 
  507.                     // Otherwise, it's probably a 'top-level' error, in which case we dump the 
  508.                     // whole response in the trace 
  509.                     error = executor.get_responseData(); 
  510.                 } 
  511.                 throw Sys.Data.DataService._createFailedError(operation, String.format("The data operation '{0}' failed with the following error: {1}", operation, error)); 
  512.             } 
  513.             // #endif 
  514.         } 
  515.         else if (onSuccess) { 
  516.             onSuccess(result, userContext, operation); 
  517.         } 
  518.     } 
  519.     else { 
  520.         var msg; 
  521.         if (executor.get_timedOut()) { 
  522.             msg = String.format("The data operation '{0}' timed out.", operation); 
  523.         } 
  524.         else { 
  525.             msg = String.format("The data operation '{0}' failed.", operation) 
  526.         } 
  527.         if (onFailure) { 
  528.             onFailure(new Sys.Data.DataServiceError(executor.get_timedOut(), msg, "", ""), userContext, operation); 
  529.         } 
  530.         // #if DEBUG 
  531.         else { 
  532.             // In debug mode, if no error was registered, display some trace information 
  533.             throw Sys.Data.DataService._createFailedError(operation, msg); 
  534.         } 
  535.         // #endif 
  536.     } 
  537. }; 
  538.  
  539. //#if DEBUG 
  540. Sys.Data.DataService._createFailedError = function(operation, errorMessage) { 
  541.     var displayMessage = "Sys.Data.DataServiceFailedException: " + errorMessage; 
  542.     var e = Error.create(displayMessage, { 'name': 'Sys.Data.DataServiceFailedException', 'operation': operation }); 
  543.     e.popStackFrame(); 
  544.     return e; 
  545. } 
  546. //#endif 
  547.  
  548. Sys.Data.DataService.registerClass("Sys.Data.DataService"); 
  549.  
  550. Sys.Data.DataServiceError = function(timedOut, message, stackTrace, exceptionType) { 
  551.     /// <summary>Represents a web-based data service error.</summary> 
  552.     /// <param name="timedOut" type="Boolean">Whether the operation failed because of a timeout.</param> 
  553.     /// <param name="message" type="String" mayBeNull="true">The error message.</param> 
  554.     /// <param name="stackTrace" type="String" mayBeNull="true">The stack trace of the error.</param> 
  555.     /// <param name="exceptionType" type="String" mayBeNull="true">The server exception type.</param> 
  556.     this._timedOut = timedOut; 
  557.     this._message = message; 
  558.     this._stackTrace = stackTrace; 
  559.     this._exceptionType = exceptionType; 
  560.     this._statusCode = -1; 
  561. } 
  562.  
  563. Sys.Data.DataServiceError.prototype = { 
  564.  
  565.     /* 
  566.      * PROPERTIES 
  567.      */ 
  568.  
  569.     get_timedOut: function() { 
  570.         /// <summary>True if the data service operation failed due to timeout.</summary> 
  571.         /// <value type="Boolean">Whether the operation failed due to timeout.</value> 
  572.         return this._timedOut; 
  573.     }, 
  574.  
  575.     get_statusCode: function() { 
  576.         /// <summary>HTTP status code of the response if any, defaults to -1 otherwise</summary> 
  577.         /// <value type="Number">Int representing the status of the response.</value> 
  578.         return this._statusCode; 
  579.     }, 
  580.  
  581.     get_message: function() { 
  582.         /// <summary>Error message</summary> 
  583.         /// <value type="String">Error message</value> 
  584.         return this._message; 
  585.     }, 
  586.  
  587.     get_stackTrace: function() { 
  588.         /// <summary>Stack trace of the error</summary> 
  589.         /// <value type="String">Stack trace of the error.</value> 
  590.         return this._stackTrace; 
  591.     }, 
  592.  
  593.     get_exceptionType: function() { 
  594.         /// <summary>Exception type of the error</summary> 
  595.         /// <value type="String">Exception type of the error.</value> 
  596.         return this._exceptionType; 
  597.     } 
  598. } 
  599.  
  600. Sys.Data.DataServiceError.registerClass("Sys.Data.DataServiceError"); 
  601.  
  602. Sys.Data.QueryBuilder = function(uri) { 
  603.     /// <summary>Allows construction of ADO.NET Data Service queries.</summary> 
  604.     /// <param name="uri" type="String">The URI (absolute or relative) to parse.</param> 
  605.     this._queryparams = new Object(); 
  606.     this._uri = uri; 
  607.      
  608.     var idxQuery = uri.indexOf('?'); 
  609.     if (idxQuery >= 0) { 
  610.         // split query string if already exists 
  611.         this._uri = uri.substr(0, idxQuery); 
  612.         var params = uri.substr(idxQuery + 1).split('&'); 
  613.         for (var i in params) { 
  614.             param = params[i]; 
  615.             var idxValue = param.indexOf('='); 
  616.             if (idxValue >= 0) { 
  617.                 this._queryparams[param.substr(0, idxValue)] = param.substr(idxValue + 1); 
  618.             } 
  619.             else { 
  620.                 this._queryparams[param] = ""; 
  621.             } 
  622.         } 
  623.     } 
  624. } 
  625.  
  626. Sys.Data.QueryBuilder.prototype = { 
  627.  
  628.     /* 
  629.      * PROPERTIES 
  630.      */ 
  631.       
  632.     get_skip: function() { 
  633.         /// <summary>Gets the starting index at which elements should be returned.</summary> 
  634.         /// <value type="Number" integer="true" mayBeNull="true">The number of elements to skip when returning results, 
  635.         /// or null if no skip value is specified.</value> 
  636.         return this._getIntParam("$skip"); 
  637.     }, 
  638.     set_skip: function(value) { 
  639.         this._setParam("$skip", value); 
  640.     }, 
  641.      
  642.     get_top: function() { 
  643.         /// <summary>Gets the maximum number of elements to return.</summary> 
  644.         /// <value type="Number" integer="true" mayBeNull="true">The maximum number of elements to return, 
  645.         /// or null if no maximum is specified.</value> 
  646.         return this._getIntParam("$top"); 
  647.     }, 
  648.     set_top: function(value) { 
  649.         this._setParam("$top", value); 
  650.     }, 
  651.      
  652.     get_orderby: function() { 
  653.         /// <summary>Gets the ordering string that should be applied to the result set.</summary> 
  654.         /// <value type="String" mayBeNull="true">The ordering applied to the result set, 
  655.         /// or null if no ordering is specified.</value> 
  656.         return this._getStringParam("$orderby"); 
  657.     }, 
  658.     set_orderby: function(value) { 
  659.         this._setParam("$orderby", value); 
  660.     }, 
  661.      
  662.     get_filter: function() { 
  663.         /// <summary>Gets the filter string that should be applied to the result set.</summary> 
  664.         /// <value type="String" mayBeNull="true">The filter applied to the result set, 
  665.         /// or null if no filter is specified.</value> 
  666.         return this._getStringParam("$filter"); 
  667.     }, 
  668.     set_filter: function(value) { 
  669.         this._setParam("$filter", value); 
  670.     }, 
  671.      
  672.     get_expand: function() { 
  673.         /// <summary>Gets the property expansion string that should be applied to the result set.</summary> 
  674.         /// <value type="String" mayBeNull="true">The property expansion applied to the result set, 
  675.         /// or null if no property expansion is specified.</value> 
  676.         return this._getStringParam("$expand"); 
  677.     }, 
  678.     set_expand: function(value) { 
  679.         this._setParam("$expand", value); 
  680.     }, 
  681.      
  682.     get_resourcePath: function() { 
  683.         /// <summary>Gets the resource path (without query parameters) originally passed as an argument to 
  684.         /// this object's constructor.</summary> 
  685.         /// <value type="string">The resource path of this QueryBuilder object.</value> 
  686.         return this._uri; 
  687.     }, 
  688.     /* setter temporarily removed until we can figure out how to spec it 
  689.     set_resourcePath: function(value) { 
  690.         var idxQuery = value.indexOf('?'); 
  691.         this._uri = (idxQuery >= 0) ? value.substr(0, idxQuery) : value; 
  692.     }, */ 
  693.      
  694.     get_queryParams: function() { 
  695.         /// <summary>Gets the dictionary of query parameters for the current QueryBuilder.</summary> 
  696.         /// <value type="Object">A dictionary of query parameters.  This object will be non-null but may 
  697.         /// contain no fields if no query parameters have been set.</value> 
  698.         return this._queryparams; 
  699.     }, 
  700.      
  701.     /* 
  702.      * METHODS 
  703.      */ 
  704.      
  705.     toString: function() { 
  706.         /// <summary>Generates a complete query string based on this object's resource path and parameter dictionary.</summary> 
  707.         /// <returns type="string">The complete query string.</returns> 
  708.         var params = new Array(); 
  709.         for (var key in this._queryparams) { 
  710.             if (!Array.contains(Sys.Data.QueryBuilder._queryOptions, key)) { 
  711.                 var value = this._queryparams 

随机文章推荐

本站热点业务

更多模板/案例展示

热门推荐

最近更新

关于我们 | 联系我们 | 团队日志 | 网站地图 | 网站合作
本站部份资源来于互联网,只供学习之用,不得用于商业,如有侵犯版权请联系告知,本站将第一时间删除!
copyright © 2008-2010 .Net中文社区 ASPXCS.NET™.All Rights Reserved 滇ICP备08102132号