C# 异步查询数据库（第二版）
此文是接着我上篇文章写的，我在上篇文章中讲了异步查询数据库的方法，但例子写的有些草率，我只写了一次查询，没能表现出异步方式无阻塞的优点，因此根据园友的反映，我又对原来的代码做了些修改，增加普通和异步两种方式对数据库的查询操作的示例，希望对大家有所帮助。
主要代码如下：
1 /// <summary>2 /// 当点击执行查询时发生3 /// </summary>4 private void Button_DoSearch_Click(object sender, EventArgs e)5 {6 Application.DoEvents();7 DoSearchAsync();8 //DoSearchNormal();9 } 1 /// <summary> 2 /// 异步方式查询Customers和Orders 3 /// </summary> 4 private void DoSearchAsync() 5 { 6 this.Text = "异步方式查询数据库"; 7 GetAllOrders(); 8 GetAllCustomers(); 9 }10 11 /// <summary>12 /// 普通方式查询Customers和Orders13 /// </summary>14 private void DoSearchNormal()15 {16 this.Text = "普通方式查询数据库";17 mWatch.Start();18 GetAllCustomersNormal();19 GetAllOrdersNormal();20 mWatch.Stop();21 label_Time.Text = "查询耗时：" + mWatch.ElapsedMilliseconds.ToString() + "毫秒";22 }
View Code
1 /// <summary> 2 /// 普通方式查询orders 3 /// </summary> 4 private void GetAllOrdersNormal() 5 { 6 try 7 { 8 mConnection = new SqlConnection(mConnectionString); 9 string sqlString = "select * from Orders"; 10 SqlCommand command = new SqlCommand(sqlString, mConnection); 11 mConnection.Open(); 12 SqlDataReader reader = command.ExecuteReader(); 13 DataTable dataTable = new DataTable(); 14 dataTable.Load(reader); 15 dgv_Data.DataSource = dataTable; 16 } 17 catch (Exception ex) 18 { 19 label_Time.Text = ex.Message; 20 } 21 finally 22 { 23 if (mConnection != null) 24 { 25 mConnection.Close(); 26 } 27 } 28 } 29 30 /// <summary> 31 /// 普通方式查询Customers 32 /// </summary> 33 private void GetAllCustomersNormal() 34 { 35 try 36 { 37 mConnection2 = new SqlConnection(mConnectionString); 38 string sqlString = "select * from Customers"; 39 SqlCommand command = new SqlCommand(sqlString, mConnection2); 40 mConnection2.Open(); 41 SqlDataReader reader = command.ExecuteReader(); 42 DataTable dataTable = new DataTable(); 43 dataTable.Load(reader); 44 dgv_Customer.DataSource = dataTable; 45 } 46 catch (Exception ex) 47 { 48 label_Time2.Text = ex.Message; 49 } 50 finally 51 { 52 if (mConnection2 != null) 53 { 54 mConnection2.Close(); 55 } 56 } 57 } 58 59 /// <summary> 60 /// 异步方式查询orders 61 /// </summary> 62 private void GetAllOrders() 63 { 64 mConnection = new SqlConnection(mConnectionString); 65 string sqlString = "select * from Orders"; 66 SqlCommand command = new SqlCommand(sqlString, mConnection); 67 mConnection.Open(); 68 mWatch.Start(); 69 AsyncCallback callBack = new AsyncCallback(HandleCallback);//注册回调方法 70 //开始执行异步查询，将Command作为参数传递到回调函数以便执行End操作 71 command.BeginExecuteReader(callBack, command); 72 } 73 74 /// <summary> 75 /// 异步方式查询customers 76 /// </summary> 77 private void GetAllCustomers() 78 { 79 mConnection2 = new SqlConnection(mConnectionString); 80 string sqlString = "select * from Customers"; 81 SqlCommand command = new SqlCommand(sqlString, mConnection2); 82 mConnection2.Open(); 83 mCustomerWatch.Start(); 84 AsyncCallback callBack = new AsyncCallback(HandleCustomerCallback); 85 command.BeginExecuteReader(callBack, command); 86 } 87 88 /// <summary> 89 /// 异步查询orders的回调方法 90 /// </summary> 91 /// <param name="MyResult">异步操作状态</param> 92 private void HandleCallback(IAsyncResult MyResult) 93 { 94 try 95 { 96 SqlCommand command = (SqlCommand)MyResult.AsyncState; 97 SqlDataReader reader = command.EndExecuteReader(MyResult); 98 mWatch.Stop(); 99 string callBackTime = mWatch.ElapsedMilliseconds.ToString() + "毫秒";100 DataTable dataTable = new DataTable();101 dataTable.Load(reader); 102 this.Invoke(myTimeDelegate, callBackTime); 103 this.Invoke(myDataDelegate, dataTable);104 }105 catch (Exception MyEx)106 {107 this.Invoke(new DisplayInfoDelegate(DisplayTimeResults), String.Format(MyEx.Message));108 }109 finally110 {111 if (mConnection != null)112 {113 mConnection.Close();114 }115 }116 }117 118 /// <summary>119 /// 异步查询customers的回调方法120 /// </summary>121 /// <param name="MyResult">异步操作状态</param>122 private void HandleCustomerCallback(IAsyncResult MyResult)123 {124 try125 { 126 SqlCommand command = (SqlCommand)MyResult.AsyncState;127 SqlDataReader reader = command.EndExecuteReader(MyResult);128 mCustomerWatch.Stop();129 string callBackTime = mCustomerWatch.ElapsedMilliseconds.ToString() + "毫秒";130 DataTable dataTable = new DataTable();131 dataTable.Load(reader);132 this.Invoke(myCustomerTimeDelegate, callBackTime);133 this.Invoke(myCustomerDelegate, dataTable);134 }135 catch (Exception MyEx)136 {137 this.Invoke(new DisplayInfoDelegate(DisplayTimeResults), String.Format(MyEx.Message));138 }139 finally140 {141 if (mConnection2 != null)142 {143 mConnection2.Close();144 }145 }146 }普通方式查询结果如图1所示：
图1
异步方式查询结果如图2所示：
图2
通过这两张图的对比，我们发现普通方式查询耗时是304毫秒，异步方式两张表的耗时加起来还不到10毫秒，速度差别是很明显的。因为普通方式执行查询的操作同在主线程上，两次操作需要排队，上一个操作未完成就会阻塞线程，这时程序是不能做任何事情的。而异步恰巧可以解决这个问题，两次查询操作都通过回调函数完成查询，程序不会阻塞或挂起线程。
其实，异步操作并没有实质上提高查询数据库的速度，只是发挥了并行的长处。当操作大量的数据时，对数据库的优化是必须的，建立索引，多使用存储过程对提高查询速度都有很大帮助。不得不说的是，异步确实还是有风险的，确定有必要使用时再用。
本文例子可以到这里下载：http://files.cnblogs.com/yanchenglong/%E5%BC%82%E6%AD%A5%E6%96%B9%E5%BC%8F%E6%9F%A5%E8%AF%A2%E6%95%B0%E6%8D%AE%E5%BA%93.rar
转载于:https://www.cnblogs.com/yanchenglong/archive/2012/03/16/2399716.html
C# 异步查询数据库（第二版）相关推荐
- php异步查询数据库,php中mysql数据库异步查询实现
问题 通常一个web应用的性能瓶颈在数据库.因为,通常情况下php中mysql查询是串行的.也就是说,如果指定两条sql语句时,第二条sql语句会等到第一条sql语句执行完毕再去执行.这个时候,如果执 ...
- python异步查询数据库_Python中使用aiomysql异步操作MySQL实例效果
Python异步操作MySQL示例[使用aiomysql] 本文实例讲述了Python异步操作MySQL.分享给大家供大家参考,具体如下: 安装aiomysql 依赖 Python3.4+ async ...
- python异步查询数据库_Python的Tornado框架实现异步非阻塞访问数据库的示例
tornado即是一个http非阻塞服务器, 就要用起来, 我们将用到tornado框架 ,mongodb数据库 以及motor(mongodb的异步驱动).来简单实现tornado的非阻塞功能. 其 ...
- java mysql 异步查询数据库_java 异步操作数据库
@Autowired private ThreadPoolTaskExecutor threadPoolTaskExecutor; threadPoolTaskExecutor.execute(new ...
- MySQL数据库技术 第二版 章末 答案—单元5---思考5
MySQL数据库技术 第二版 章末 答案-单元5 以下是我个人所尝试过得答案,若有不正确的地方请告知,谢谢!由于实在是太多内容了,原谅我省略题目内容 单元5 数据查询 ---- 思考5---- P10 ...
- MySQL数据库技术 第二版 章末 答案—单元5 ----实训5
MySQL数据库技术 第二版 章末 答案-单元5 以下是我个人所尝试过得答案,若有不正确的地方请告知,谢谢! 由于实在是太多内容了,原谅我省略题目内容 单元5 数据查询 ---- 实训5----P10 ...
- springboot mybatis-plus 一个事务里面两次同样的查询，第二次没有查数据库
在一次处理事务中,由于特别需要,需要在一个service里面先后查询两次一样的sql 发现第二次没有执行数据库查询,返回的时候第一次查询的结果. 经过一轮查找,发现是mybatis-plus 调用了m ...
- MySQL数据库技术 第二版 章末 答案—单元8
MySQL数据库技术 第二版 章末 答案-单元8 以下是我个人所尝试过得答案,若有不正确的地方请告知,谢谢!由于实在是太多内容了,原谅我省略题目内容 单元8 数据库编程 ---- P166-P168 ...
- 《Cassandra权威指南》第二版书评及访谈
\ 关键点 \ 了解关于Cassandra NoSQL数据库3.0版的功能: \ 如何安装和配置Cassandra数据库,包括集群管理: \ Cassandra数据库的数据模型(概念.逻辑和物理方面) ...
- Windows 文件系统过滤驱动开发教程 （第二版）
Windows 文件系统过滤驱动开发教程 (第二版) 楚狂人-2007-上海 (MSN:walled_river@hotmail.com) -1. 改版序....... ...
最新文章
- Linux 命令集锦
- 百度相关搜索软件_Python与seo，百度关键词相关搜索关键词采集源码
- 与癌症作战的 12 家 AI 公司，八仙过海各显神通
- Java动态代理代码快速上手
- UA MATH564 概率论 标准二元正态分布的性质
- js 图片 mysql_jQuery+PHP+Mysql在线拍照和在线浏览照片
- robotium诡异的Instrumentation run failed due to 'java.lang.ClassNo
- 系统工程师主要做什么_Filecoin运维工程师在做什么？
- php strpos无效,簡單的PHP strpos功能不起作用，為什么？
- HDU-1232 畅通工程
- layui 按钮点击一次后失效_electron-vue自定义边框后点击事件失效问题
- 带修改离线主席树 + 树状数组 ZOJ - 2112【Dynamic Rankings】
- 色差（color diffference）在不同颜色空间下的计算方式
- ArcPad 10 的安装和部署
- 向 Dockerfile 传参 --build-arg 遇到的一些小坑
- ASP:KU论坛跳转页面
- 【OpenSSL 之五】：HMAC算法分析
- Vs2019创建新项目时，没有任何模板，导致无法创建新项目
- java上传与下载文件_JavaWeb之实现文件上传与下载
- CF 584A Olesya and Rodion