代码分析ADO.NET数据异步处理
创始人
2024-06-10 14:10:54
0

#T#很多开发语言都支持异步通信,在ADO.NET中支持异步处理的提供程序有System.Data.SqlClient在针对大批量数据插入过更新时,使用ADO.NET数据异步处理方法可以不用等待多有数据更新完毕才能操作或者进行下步处理,改善了用户体验SqlCommand对象方法如下:

ADO.NET数据异步处理
BeginExecuteNonQueryEndExecuteNonQuery
◆BeginExecuteXmlReaderEndExecuteXmlReader
◆BeginExecuteReaderEndExecuteReader
◆begin前缀的方法传入参数,end前缀的方法返回输出参数和返回值
◆begin前缀方法返回的是IAsyncResult用于追踪一步方法的执行状态
◆IAsyncResult.AsnycState用户自定义的状态对象
◆IAsyncResult.AsnycWaitHandle呼叫代码的等待形式,是等其中的一个异步方法完成还是全部完成
◆IAsyncResult.CompletedSynchronously获取所有异步方法是否同时完成
◆IAsyncResult.Iscompleted是否执行完毕,可以根据此属性进行下部动作

在连接字符串中加入"async=true"如果所有的命令都是同步的建议在连接字符串中显施加入,"async=false"如果有一部分命令是异步执行,又有一部分是同步同步执行,建议分别建立两个连接对象,如果"async=true"时,也可以执行同步命令,但是会损失一些资源

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


以上就是ADO.NET数据异步处理用户体验的一个解决方案,大家快试试。

相关内容

热门资讯

如何允许远程连接到MySQL数... [[277004]]【51CTO.com快译】默认情况下,MySQL服务器仅侦听来自localhos...
如何利用交换机和端口设置来管理... 在网络管理中,总是有些人让管理员头疼。下面我们就将介绍一下一个网管员利用交换机以及端口设置等来进行D...
施耐德电气数据中心整体解决方案... 近日,全球能效管理专家施耐德电气正式启动大型体验活动“能效中国行——2012卡车巡展”,作为该活动的...
Windows恶意软件20年“... 在Windows的早期年代,病毒游走于系统之间,偶尔删除文件(但被删除的文件几乎都是可恢复的),并弹...
规避非法攻击 用好路由器远程管... 单位在市区不同位置设立了科技服务点,每一个服务点的员工都通过宽带路由器进行共享上网,和单位网络保持联...
20个非常棒的扁平设计免费资源 Apple设备的平面图标PSD免费平板UI 平板UI套件24平图标Freen平板UI套件PSD径向平...
范例解读VB.NET获取环境变... VB.NET编程语言的使用范围非常广泛,可以帮助开发人员处理各种程序中的需求,而且还能对移动设备进行...
德国电信门户网站可实时显示全球... 德国电信周三推出一个门户网站,直观地实时提供其安装在全球各地的传感器网络检测到的网络攻击状况。该网站...