异步的SQL数据库封装详解


引言

我一直在寻找一种简单有效的库,它能在简化数据库相关的编程的同时提供一种异步的方法来预防死锁。

我找到的大部分库要么太繁琐,要么灵活性不足,所以我决定自己写个。

使用这个库,你可以轻松地连接到任何 SQL-Server 数据库,执行任何存储过程或 T-SQL 查询,并异步地接收查询结果。这个库采用 C# 开发,没有其他外部依赖。

背景

你可能需要一些事件驱动编程的背景知识,但这不是必需的。

使用

这个库由两个类组成:

1、BLL (Business Logic Layer) 提供访问MS-SQL数据库、执行命令和查询并将结果返回给调用者的方法和属性。你不能直接调用这个类的对象,它只供其他类继承.
2、DAL (Data Access Layer) 你需要自己编写执行SQL存储过程和查询的函数,并且对于不同的表你可能需要不同的DAL类。
首先,你需要像这样创建 DAL 类:

namespace SQLWrapper 
{ 
 public class DAL : BLL 
 { 
  public DAL(string server, string db, string user, string pass) 
  { 
   base.Start(server, db, user, pass); 
  } 
 
  ~DAL() 
  { 
   base.Stop(eStopType.ForceStopAll); 
  } 
 
  /////////////////////////////////////////////////////////// 
  // TODO: Here you can add your code here... 
 } 
} 

由于BLL类维护着处理异步查询的线程,你需要提供必要的数据来拼接连接字符串。千万别忘了调用`Stop`函数,否则析构函数会强制调用它。

NOTE:如果需要连接其他非MS-SQL数据库,你可以通过修改BLL类中的`CreateConnectionString`函数来生成合适的连接字符串。

为了调用存储过程,你应该在DAL中编写这种函数:

public int MyStoreProcedure(int param1, string param2) 
{ 
  // 根据存储过程的返回类型创建用户数据 
  StoredProcedureCallbackResult userData = new StoredProcedureCallbackResult(eRequestType.Scalar); 
   
  // 在此定义传入存储过程的参数,如果没有参数可以省略 <span style="line-height:1.5;font-size:9pt;">userData.Parameters = new System.Data.SqlClient.SqlParameter[] { </span>     
 new System.Data.SqlClient.SqlParameter("@param1", param1), 
    new System.Data.SqlClient.SqlParameter("@param2", param2), 
  }; 
   
  // Execute procedure... 
  if (!ExecuteStoredProcedure("usp_MyStoreProcedure", userData)) 
    throw new Exception("Execution failed"); 
     
  // 等待执行完成... 
  // 等待时长为 <userdata.tswaitforresult> 
  // 执行未完成返回 <timeout> 
  if (WaitSqlCompletes(userData) != eWaitForSQLResult.Success) 
    throw new Exception("Execution failed"); 
     
  // Get the result... 
  return userData.ScalarValue; 
} 

正如你所看到的,存储过程的返回值类型可以是`Scalar`,`Reader`和`NonQuery`。对于 `Scalar`,`userData`的`ScalarValue`参数有意义(即返回结果);对于`NonQuery`,`userData`的 `AffectedRows`参数就是受影响的行数;对于`Reader`类型,`ReturnValue`就是函数的返回值,另外你可以通过 `userData`的`resultDataReader`参数访问recordset。

再看看这个示例:

public bool MySQLQuery(int param1, string param2) 
{ 
  // Create user data according to return type of store procedure in SQL(这个注释没有更新,说明《注释是魔鬼》有点道理) 
  ReaderQueryCallbackResult userData = new ReaderQueryCallbackResult(); 
   
  string sqlCommand = string.Format("SELECT TOP(1) * FROM tbl1 
   WHERE code = {0} AND name LIKE '%{1}%'", param1, param2); 
   
  // Execute procedure... 
  if (!ExecuteSQLStatement(sqlCommand, userData)) 
    return false; 
     
  // Wait until it finishes... 
  // Note, it will wait (userData.tsWaitForResult) 
  // for the command to be completed otherwise returns <timeout> 
  if (WaitSqlCompletes(userData) != eWaitForSQLResult.Success) 
    return false; 
     
  // Get the result... 
  if(userData.resultDataReader.HasRows && userData.resultDataReader.Read()) 
  { 
    // Do whatever you want.... 
    int field1 = GetIntValueOfDBField(userData.resultDataReader["Field1"], -1); 
    string field2 = GetStringValueOfDBField(userData.resultDataReader["Field2"], null); 
    Nullable<datetime> field3 = GetDateValueOfDBField(userData.resultDataReader["Field3"], null); 
    float field4 = GetFloatValueOfDBField(userData.resultDataReader["Field4"], 0); 
    long field5 = GetLongValueOfDBField(userData.resultDataReader["Field5"], -1); 
  } 
  userData.resultDataReader.Dispose(); 
   
  return true; 
} 

在这个例子中,我们调用 `ExecuteSQLStatement` 直接执行了一个SQL查询,但思想跟 `ExecuteStoredProcedure` 是一样的。

我们使用 `resultDataReader` 的 `.Read()` 方法来迭代处理返回的结果集。另外提供了一些helper方法来避免叠代中由于NULL字段、GetIntValueOfDBField 等引起的异常。

如果你要执行 SQL 命令而不是存储过程,需要传入 ExecuteSQLStatement 的 userData 有三类:

1、ReaderQueryCallbackResult userData:适用于有返回recordset的语句,可以通过userData.resultDataReader获得对返回的recordset的访问。
2、NonQueryCallbackResult userData:适用于像UPDATE这种没有返回内容的语句,可以使用userData.AffectedRows检查执行的结果。
3、ScalarQueryCallbackResult userData:用于查询语句只返回一个标量值的情况,例如`SELECT code FROM tbl WHEN ID=10`,通过userData.ScalarValue 取得返回的结果。
对于存储过程,只有一种需要传入 ExecuteStoredProcedure 的数据类型。但在声明变量时你需要指明存储过程的返回值类型:

StoredProcedureCallbackResult userData(eRequestType):除了声明不同外,其他操作与上面相同。
异步地使用代码

假使你不希望调用线程被查询阻塞,你需要周期性地调用 `WaitSqlCompletes` 来检查查询是否完成,执行是否失败。

/// <summary> 
/// 你需要周期性地调用WaitSqlCompletes(userData, 10) 
/// 来查看结果是否可用! 
/// </summary> 
public StoredProcedureCallbackResult MyStoreProcedureASYNC(int param1, string param2) 
{ 
  // Create user data according to return type of store procedure in SQL 
  StoredProcedureCallbackResult userData = new StoredProcedureCallbackResult(eRequestType.Reader); 
   
  // If your store procedure accepts some parameters, define them here, 
  // or you can omit it incase there is no parameter definition 
  userData.Parameters = new System.Data.SqlClient.SqlParameter[] { 
    new System.Data.SqlClient.SqlParameter("@param1", param1), 
    new System.Data.SqlClient.SqlParameter("@param2", param2), 
  }; 
   
  // Execute procedure... 
  if (!ExecuteStoredProcedure("usp_MyStoreProcedure", userData)) 
    throw new Exception("Execution failed"); 
     
  return userData; 
} 

在调用线程中你需要这样做:

... 
DAL.StoredProcedureCallbackResult userData = myDal.MyStoreProcedureASYNC(10,"hello"); 
... 
// each time we wait 10 milliseconds to see the result... 
switch(myDal.WaitSqlCompletes(userData, 10)) 
{ 
case eWaitForSQLResult.Waiting: 
 goto WAIT_MORE; 
case eWaitForSQLResult.Success: 
 goto GET_THE_RESULT; 
default: 
 goto EXECUTION_FAILED; 
} 
... 

数据库状态

在 BLL 中只有一个异步地提供数据库状态的事件。如果数据库连接被断开了(通常是由于网络问题),OnDatabaseStatusChanged 事件就会被挂起。

另外,如果连接恢复了,这个事件会被再次挂起来通知你新的数据库状态。

有趣的地方

在我开发代码的时候,我明白了连接字符串中的连接时限(connection timeout)和SQL命令对象的执行时限(execution timeout)同样重要。

首先,你必须意识到最大容许时限是在连接字符串中定义的,并可以给出一些执行指令比连接字符串中的超时时间更长的时间。

其次,每一个命令都有着它们自己的执行时限,在这里的代码中默认为30秒。你可以很容易地修改它,使它适用于所有类型的命令,就像这样:

userData.tsWaitForResult = TimeSpan.FromSeconds(15); 

以上就是异步的SQL数据库封装全部过程,希望对大家的学习有所帮助。



相关阅读:
JQuery页面地址处理插件jqURL详解
win10手机预览版微软账户怎么添加 win10手机预览版微软账户添加设置图文教程
[Oracle] dbms_metadata.get_ddl 的使用方法总结
Android Activity回收与操作超时处理
js获取时间精确到秒(年月日)
STL区间成员函数及区间算法总结
详解Java中对象序列化与反序列化
详解JavaScript函数
Win10预览版10122怎么快速建立本地账户?
纯css3实现的动画按钮的实例教程
ajax浏览器兼容的问题探讨
SQL Server出现System.OutOfMemoryException异常的解决方法
javascript中slice(),splice(),split(),substring(),substr()使用方法
mysql压力测试脚本实例
快速导航
PHP MySQL HTML CSS JavaScript MSSQL AJAX .NET JSP Linux Mac ASP 服务器 SQL jQuery C# C++ java Android IOS oracle MongoDB SQLite wamp 交通频道 作文范文 镇远-邵武 黑井-甸心 沂水-赤壁 怀柔-五龙背 海宁-兴城 南平北-商丘 德惠-肇东 开封-沈阳 合肥-旬阳 锦州-中卫 太谷-桐梓 对青山-讷尔克气 呼和浩特-江津 神池-安塘 兰州西-绵阳 大石头-磐石 定边-绥德 鄯善-滁州北 平庄南-乃林 富拉尔基-铁力 黄村-蓝村 高桥镇-营北 邵东-衢州 阳平关-淄博 古田北-安顺西 蔡家坡-沙湾县 安庆西-任丘 上海虹桥-公主岭南 泗水-西平 前磨头-郓城 绵阳-邯郸 金昌-大庆 石嘴山-暖泉 岱岳-石家庄北 赣州-昆山 六道河-延吉 小南海-迎祥街 冷水江东-上海南 汝州-贵阳 黄陵南-芜湖 平原-德惠 晋州-亳州 通辽-白山乡 钦州东-藤县 东通化-五道沟 湘乡-深州 嘉兴南-萧县北 广水-张家口南 东来-八面城 九台-绥中北 临汾-曲靖 商洛-新县 新余-岑溪 东大坝-汤头沟 杨陵-宝鸡 江桥-黑水 枣庄东-莱阳 合肥-溆浦 铁岭-朗乡 鄯善北-泰山 广州-沈阳北 南昌西-新晃西 祁县东-襄汾西 桂林北-岳阳东 潢川-武当山 赵光-鞍山 绕阳河-山海关 互助-阿城 文水-四平 恩施-江山 淮滨-龙市 白音察干-德日斯图 双流西-成都南 玉山-海宁 查布嘎-正镶白旗 枣子林-普雄 三门县-普宁 下板城-三十家 吐鲁番北-柳园 达拉特西-江津 从淮海中路(太平洋百货或者无限度附近)到虹口区车站北路凉
我的是惠普CQ42 COMPAQ用了不到一年硬盘坏了我惠州买的现在
谁有河南南阳至濮阳的车次,发车时间,终点站是哪南阳有直
深圳到四川自贡市富顺县的快递
我是南方人,想去北京旅游,想看看长城长什么样,想逛逛北京...
现在还有没有2136次火车的票
我想把台式电脑(纯平显示器)从成都寄到达州 用什么方式好,
湖南邵阳到广西南宁的火车列车票价
平顶山那个证券公司招人 听说没有从业资格证的也行 可以先学习
我想带孩子从成都到敦煌自助旅游,有什么好的建议?
怎样做公交车从广州的省客车站到中山一院
2011年4月6日杭州到重庆火车列车1271/1274这例车票难买吗
石家莊到貴陽飛機票
第一次出门 包头到石家庄
从深圳开车到天水,费用要多少啊
广州至长沙的火车列车_广州至长沙的火车列车
从长春师范学院坐几路车到长春市解放大路小学
请问从柳州火车列车站到柳州一职校该怎么走喃
请问从天津火车列车站如何去万源龙顺度假庄园谢谢。
手机上面怎么安装一个“火车列车时刻表”啊
扬州三日游
西安到盘锦的列车火车票
可否提供下天津到长春的列车火车的票价以及车次
我现在在嘉兴,请问能从嘉兴火车列车站买到从成都到西昌的火车列车票
从商丘到驻马店有哪几趟火车列车
急求云南详细行政区划,详细到乡镇的,谢谢啊!
请问下从成都到寻龙山怎样坐车??
我现在人在深圳南山,我想去湛江,请有在哪有车到那边,票介
开车从成都到兰州怎么坐车
扬州到郑州的客车是到郑州哪个站我要转车去新乡。请问如何

Copyright © 2016 phpStudy |