日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷解決方案
代碼分析ADO.NET數(shù)據(jù)異步處理

#T#很多開發(fā)語言都支持異步通信，在ADO.NET中支持異步處理的提供程序有System.Data.SqlClient在針對(duì)大批量數(shù)據(jù)插入過更新時(shí)，使用ADO.NET數(shù)據(jù)異步處理方法可以不用等待多有數(shù)據(jù)更新完畢才能操作或者進(jìn)行下步處理，改善了用戶體驗(yàn)SqlCommand對(duì)象方法如下：

在東西湖等地區(qū)，都構(gòu)建了全面的區(qū)域性戰(zhàn)略布局，加強(qiáng)發(fā)展的系統(tǒng)性、市場(chǎng)前瞻性、產(chǎn)品創(chuàng)新能力，以專注、極致的服務(wù)理念，為客戶提供做網(wǎng)站、成都網(wǎng)站制作 網(wǎng)站設(shè)計(jì)制作定制網(wǎng)站,公司網(wǎng)站建設(shè),企業(yè)網(wǎng)站建設(shè),品牌網(wǎng)站制作,成都全網(wǎng)營(yíng)銷推廣,成都外貿(mào)網(wǎng)站建設(shè),東西湖網(wǎng)站建設(shè)費(fèi)用合理。

ADO.NET數(shù)據(jù)異步處理
◆BeginExecuteNonQueryEndExecuteNonQuery
◆BeginExecuteXmlReaderEndExecuteXmlReader
◆BeginExecuteReaderEndExecuteReader
◆begin前綴的方法傳入?yún)?shù)，end前綴的方法返回輸出參數(shù)和返回值
◆begin前綴方法返回的是IAsyncResult用于追蹤一步方法的執(zhí)行狀態(tài)
◆IAsyncResult.AsnycState用戶自定義的狀態(tài)對(duì)象
◆IAsyncResult.AsnycWaitHandle呼叫代碼的等待形式，是等其中的一個(gè)異步方法完成還是全部完成
◆IAsyncResult.CompletedSynchronously獲取所有異步方法是否同時(shí)完成
◆IAsyncResult.Iscompleted是否執(zhí)行完畢，可以根據(jù)此屬性進(jìn)行下部動(dòng)作

在連接字符串中加入"async＝true"如果所有的命令都是同步的建議在連接字符串中顯施加入，"async＝false"如果有一部分命令是異步執(zhí)行，又有一部分是同步同步執(zhí)行，建議分別建立兩個(gè)連接對(duì)象，如果"async＝true"時(shí)，也可以執(zhí)行同步命令，但是會(huì)損失一些資源

 
 
    
  
  
  1. /**/////obtainconnectionstringsfromconfigurationfilesor  
    2. 
  
  
  2. ////similarfacility  
    3. 
  
  
  3. ////NOTE:theseconnectionstringshavetoinclude"async=true",for  
    4. 
  
  
  4. ////example:  
    5. 
  
  
  5. ////"server=myserver;database=mydb;integratedsecurity=true;async=true"  
    6. 
  
  
  6. //stringconnstrAccouting=GetConnString("accounting");  
    7. 
  
  
  7. //stringconnstrHR=GetConnString("humanresources");  
    8. 
  
  
  8. /**/////definetwoconnectionobjects,oneforeachdatabase  
    9. 
  
  
  9. //using(SqlConnectionconnAcc=newSqlConnection(connstrAccounting))  
    10. 
  
  
  10. //using(SqlConnectionconnHumanRes=newSqlConnection(connstrHR))  
    11. 
  
  
  11. //{  
    12. 
  
  
  12. ////openthefirstconnection  
    13. 
  
  
  13. //connAcc.Open();  
    14. 
  
  
  14. ////starttheexecutionofthefirstquerycontainedinthe  
    15. 
  
  
  15. ////"employee_info"stored-procedure  
    16. 
  
  
  16. //SqlCommandcmdAcc=newSqlCommand("employee_info",connAcc);  
    17. 
  
  
  17. //cmdAcc.CommandType=CommandType.StoredProcedure;  
    18. 
  
  
  18. //cmdAcc.Parameters.AddWithValue("@empl_id",employee_id);  
    19. 
  
  
  19. //IAsyncResultarAcc=cmdAcc.BeginExecuteReader();  
    20. 
  
  
  20. ////atthispoint,the"employee_info"stored-procisexecutingon  
    21. 
  
  
  21. ////theserver,andthisthreadisrunningatthesametime  
    22. 
  
  
  22. ////nowopenthesecondconnection  
    23. 
  
  
  23. //connHumanRes.Open();  
    24. 
  
  
  24. ////starttheexecutionofthesecondstored-procagainst  
    25. 
  
  
  25. ////thehuman-resourcesserver  
    26. 
  
  
  26. //SqlCommandcmdHumanRes=newSqlCommand("employee_hrinfo",  
    27. 
  
  
  27. //connHumanRes);  
    28. 
  
  
  28. //cmdHumanRes.Parameters.AddWithValue("@empl_id",employee_id);  
    29. 
  
  
  29. //IAsyncResultarHumanRes=cmdHumanRes.BeginExecuteReader();  
    30. 
  
  
  30. ////nowbothqueriesarerunningatthesametime  
    31. 
  
  
  31. ////atthispoint;moreworkcanbedonefromthisthread,orwe  
    32. 
  
  
  32. ////cansimplywaituntilbothcommandsfinish-inourcasewe'll  
    33. 
  
  
  33. ////wait  
    34. 
  
  
  34. //SqlDataReaderdrAcc=cmdAcc.EndExecuteReader(arAcc);  
    35. 
  
  
  35. //SqlDataReaderdrHumanRes=cmdHumanRes.EndExecuteReader(arHumanRes);  
    36. 
  
  
  36. ////nowwecanrendertheresults,forexample,bindthereaderstoanASP.NET  
    37. 
  
  
  37. ////webcontrol,orscanthereaderanddrawtheinformationina  
    38. 
  
  
  38. ////WebFormsform.  
    39. 
  
  
  39. //}  
    40. 
  
  
  40.  
    41. 
  
  
  41. stringcustid="ALFKI";  
    42. 
  
  
  42. stringorderid="10643";  
    43. 
  
  
  43.  
    44. 
  
  
  44. //NOTE:connectionstringsdenotedby"connstring"havetoinclude  
    45. 
  
  
  45. //"async=true",forexample:  
    46. 
  
  
  46. stringconnstring="server=(local);database=northwind;integratedsecurity=true;async=true";  
    47. 
  
  
  47. //we'llusethreeconnectionsforthis  
    48. 
  
  
  48. using(SqlConnectionc1=newSqlConnection(connstring))  
    49. 
  
  
  49. using(SqlConnectionc2=newSqlConnection(connstring))  
    50. 
  
  
  50. using(SqlConnectionc3=newSqlConnection(connstring))  
    51. 
  
  
  51. {  
    52. 
  
  
  52. //getcustomerinfo  
    53. 
  
  
  53. c1.Open();  
    54. 
  
  
  54. SqlCommandcmd1=newSqlCommand(  
    55. 
  
  
  55. "SELECTCustomerID,CompanyName,ContactNameFROMCustomersWHERECustomerID=@id",c1);  
    56. 
  
  
  56. cmd1.Parameters.Add("@id",SqlDbType.Char,5).Value=custid;  
    57. 
  
  
  57. IAsyncResultarCustomer=cmd1.BeginExecuteReader();  
    58. 
  
  
  58. //getorders  
    59. 
  
  
  59. c2.Open();  
    60. 
  
  
  60. SqlCommandcmd2=newSqlCommand("SELECT*FROMOrdersWHERECustomerID=@id",c2);  
    61. 
  
  
  61. cmd2.Parameters.Add("@id",SqlDbType.Char,5).Value=custid;  
    62. 
  
  
  62. IAsyncResultarOrders=cmd2.BeginExecuteReader();  
    63. 
  
  
  63. //getorderdetailifuserpickedanorder  
    64. 
  
  
  64. IAsyncResultarDetails=null;  
    65. 
  
  
  65. SqlCommandcmd3=null;  
    66. 
  
  
  66. if(null!=orderid)  
    67. 
  
  
  67. {  
    68. 
  
  
  68. c3.Open();  
    69. 
  
  
  69. cmd3=newSqlCommand("SELECT*FROM[OrderDetails]WHEREOrderID=@id",c3);  
    70. 
  
  
  70. cmd3.Parameters.Add("@id",SqlDbType.Int).Value=int.Parse(orderid);  
    71. 
  
  
  71. arDetails=cmd3.BeginExecuteReader();  
    72. 
  
  
  72. }  
    73. 
  
  
  73. //buildthewaithandlearrayforWaitForMultipleObjects  
    74. 
  
  
  74. WaitHandle[]handles=newWaitHandle[null==arDetails?2:3];  
    75. 
  
  
  75. handles[0]=arCustomer.AsyncWaitHandle;  
    76. 
  
  
  76. handles[1]=arOrders.AsyncWaitHandle;  
    77. 
  
  
  77. if(null!=arDetails)  
    78. 
  
  
  78. handles[2]=arDetails.AsyncWaitHandle;  
    79. 
  
  
  79. //waitforcommandstocompleteandrenderpagecontrolsaswe  
    80. 
  
  
  80. //getdataback  
    81. 
  
  
  81. SqlDataReaderr;  
    82. 
  
  
  82. DataTabledt;  
    83. 
  
  
  83. for(intresults=(null==arDetails)?1:0;results<3;results++)  
    84. 
  
  
  84. {  
    85. 
  
  
  85. //waitforanyhandle,thenprocessresultsastheycome  
    86. 
  
  
  86. intindex=WaitHandle.WaitAny(handles,5000,false);//5secs  
    87. 
  
  
  87. if(WaitHandle.WaitTimeout==index)  
    88. 
  
  
  88. thrownewException("Timeout");  
    89. 
  
  
  89. switch(index)  
    90. 
  
  
  90. {  
    91. 
  
  
  91. case0://customerqueryisready  
    92. 
  
  
  92. r=cmd1.EndExecuteReader(arCustomer);  
    93. 
  
  
  93. if(!r.Read())  
    94. 
  
  
  94. continue;  
    95. 
  
  
  95. lblCustomerID.Text=r.GetString(0);  
    96. 
  
  
  96. lblCompanyName.Text=r.GetString(1);  
    97. 
  
  
  97. lblContact.Text=r.GetString(2);  
    98. 
  
  
  98. r.Close();  
    99. 
  
  
  99. break;  
    100. 
  
  
  100. case1://ordersqueryisready  
    101. 
  
  
  101. r=cmd2.EndExecuteReader(arOrders);  
    102. 
  
  
  102. dt=newDataTable();  
    103. 
  
  
  103. dt.Load(r);  
    104. 
  
  
  104. dgOrders.DataSource=dt;//data-bindtotheordersgrid  
    105. 
  
  
  105. dgOrders.Refresh();  
    106. 
  
  
  106. r.Close();  
    107. 
  
  
  107. break;  
    108. 
  
  
  108. case2://detailsqueryisready  
    109. 
  
  
  109. r=cmd3.EndExecuteReader(arDetails);  
    110. 
  
  
  110. dt=newDataTable();  
    111. 
  
  
  111. dt.Load(r);  
    112. 
  
  
  112. dgDetails.DataSource=dt;//data-bindtothedetailsgrid  
    113. 
  
  
  113. dgDetails.Refresh();  
    114. 
  
  
  114. r.Close();  
    115. 
  
  
  115. break;  
    116. 
  
  
  116.  
    117. 
  
  
  117. }  
    118. 
  
  
  118. }  
    119. 
  
  
  119. } 
    120.

以上就是ADO.NET數(shù)據(jù)異步處理用戶體驗(yàn)的一個(gè)解決方案，大家快試試。


文章標(biāo)題：代碼分析ADO.NET數(shù)據(jù)異步處理
轉(zhuǎn)載來源：http://m.5511xx.com/article/cdopopd.html