异步的SQL数据库封装详解
引言
我一直在寻找一种简单有效的库，它能在简化数据库相关的编程的同时提供一种异步的方法来预防死锁。
我找到的大部分库要么太繁琐，要么灵活性不足，所以我决定自己写个。
使用这个库，你可以轻松地连接到任何SQL-Server数据库，执行任何存储过程或T-SQL查询，并异步地接收查询结果。这个库采用C#开发，没有其他外部依赖。
背景
你可能需要一些事件驱动编程的背景知识，但这不是必需的。
使用
这个库由两个类组成：
1、BLL(BusinessLogicLayer)提供访问MS-SQL数据库、执行命令和查询并将结果返回给调用者的方法和属性。你不能直接调用这个类的对象，它只供其他类继承.
2、DAL(DataAccessLayer)你需要自己编写执行SQL存储过程和查询的函数，并且对于不同的表你可能需要不同的DAL类。
首先，你需要像这样创建DAL类：
namespaceSQLWrapper
{
publicclassDAL:BLL
{
publicDAL(stringserver,stringdb,stringuser,stringpass)
{
base.Start(server,db,user,pass);
}
~DAL()
{
base.Stop(eStopType.ForceStopAll);
}
///////////////////////////////////////////////////////////
//TODO:Hereyoucanaddyourcodehere...
}
}
由于BLL类维护着处理异步查询的线程，你需要提供必要的数据来拼接连接字符串。千万别忘了调用`Stop`函数，否则析构函数会强制调用它。
NOTE：如果需要连接其他非MS-SQL数据库，你可以通过修改BLL类中的`CreateConnectionString`函数来生成合适的连接字符串。
为了调用存储过程，你应该在DAL中编写这种函数:
publicintMyStoreProcedure(intparam1,stringparam2)
{
//根据存储过程的返回类型创建用户数据
StoredProcedureCallbackResultuserData=newStoredProcedureCallbackResult(eRequestType.Scalar);
//在此定义传入存储过程的参数，如果没有参数可以省略<spanstyle="line-height:1.5;font-size:9pt;">userData.Parameters=newSystem.Data.SqlClient.SqlParameter[]{</span>
newSystem.Data.SqlClient.SqlParameter("@param1",param1),
newSystem.Data.SqlClient.SqlParameter("@param2",param2),
};
//Executeprocedure...
if(!ExecuteStoredProcedure("usp_MyStoreProcedure",userData))
thrownewException("Executionfailed");
//等待执行完成...
//等待时长为<userdata.tswaitforresult>
//执行未完成返回<timeout>
if(WaitSqlCompletes(userData)!=eWaitForSQLResult.Success)
thrownewException("Executionfailed");
//Gettheresult...
returnuserData.ScalarValue;
}
正如你所看到的，存储过程的返回值类型可以是`Scalar`,`Reader`和`NonQuery`。对于`Scalar`，`userData`的`ScalarValue`参数有意义(即返回结果)；对于`NonQuery`，`userData`的`AffectedRows`参数就是受影响的行数；对于`Reader`类型，`ReturnValue`就是函数的返回值，另外你可以通过`userData`的`resultDataReader`参数访问recordset。
再看看这个示例:
publicboolMySQLQuery(intparam1,stringparam2)
{
//CreateuserdataaccordingtoreturntypeofstoreprocedureinSQL(这个注释没有更新,说明《注释是魔鬼》有点道理)
ReaderQueryCallbackResultuserData=newReaderQueryCallbackResult();
stringsqlCommand=string.Format("SELECTTOP(1)*FROMtbl1
WHEREcode={0}ANDnameLIKE'%{1}%'",param1,param2);
//Executeprocedure...
if(!ExecuteSQLStatement(sqlCommand,userData))
returnfalse;
//Waituntilitfinishes...
//Note,itwillwait(userData.tsWaitForResult)
//forthecommandtobecompletedotherwisereturns<timeout>
if(WaitSqlCompletes(userData)!=eWaitForSQLResult.Success)
returnfalse;
//Gettheresult...
if(userData.resultDataReader.HasRows&&userData.resultDataReader.Read())
{
//Dowhateveryouwant....
intfield1=GetIntValueOfDBField(userData.resultDataReader["Field1"],-1);
stringfield2=GetStringValueOfDBField(userData.resultDataReader["Field2"],null);
Nullable<datetime>field3=GetDateValueOfDBField(userData.resultDataReader["Field3"],null);
floatfield4=GetFloatValueOfDBField(userData.resultDataReader["Field4"],0);
longfield5=GetLongValueOfDBField(userData.resultDataReader["Field5"],-1);
}
userData.resultDataReader.Dispose();
returntrue;
}
在这个例子中，我们调用`ExecuteSQLStatement`直接执行了一个SQL查询，但思想跟`ExecuteStoredProcedure`是一样的。
我们使用`resultDataReader`的`.Read()`方法来迭代处理返回的结果集。另外提供了一些helper方法来避免叠代中由于NULL字段、GetIntValueOfDBField等引起的异常。
如果你要执行SQL命令而不是存储过程，需要传入ExecuteSQLStatement的userData有三类：
1、ReaderQueryCallbackResultuserData：适用于有返回recordset的语句，可以通过userData.resultDataReader获得对返回的recordset的访问。
2、NonQueryCallbackResultuserData：适用于像UPDATE这种没有返回内容的语句，可以使用userData.AffectedRows检查执行的结果。
3、ScalarQueryCallbackResultuserData：用于查询语句只返回一个标量值的情况，例如`SELECTcodeFROMtblWHENID=10`，通过userData.ScalarValue取得返回的结果。
对于存储过程，只有一种需要传入ExecuteStoredProcedure的数据类型。但在声明变量时你需要指明存储过程的返回值类型：
StoredProcedureCallbackResultuserData(eRequestType)：除了声明不同外，其他操作与上面相同。
异步地使用代码
假使你不希望调用线程被查询阻塞，你需要周期性地调用`WaitSqlCompletes`来检查查询是否完成，执行是否失败。
///<summary>
///你需要周期性地调用WaitSqlCompletes(userData,10)
///来查看结果是否可用!
///</summary>
publicStoredProcedureCallbackResultMyStoreProcedureASYNC(intparam1,stringparam2)
{
//CreateuserdataaccordingtoreturntypeofstoreprocedureinSQL
StoredProcedureCallbackResultuserData=newStoredProcedureCallbackResult(eRequestType.Reader);
//Ifyourstoreprocedureacceptssomeparameters,definethemhere,
//oryoucanomititincasethereisnoparameterdefinition
userData.Parameters=newSystem.Data.SqlClient.SqlParameter[]{
newSystem.Data.SqlClient.SqlParameter("@param1",param1),
newSystem.Data.SqlClient.SqlParameter("@param2",param2),
};
//Executeprocedure...
if(!ExecuteStoredProcedure("usp_MyStoreProcedure",userData))
thrownewException("Executionfailed");
returnuserData;
}
在调用线程中你需要这样做:
...
DAL.StoredProcedureCallbackResultuserData=myDal.MyStoreProcedureASYNC(10,"hello");
...
//eachtimewewait10millisecondstoseetheresult...
switch(myDal.WaitSqlCompletes(userData,10))
{
caseeWaitForSQLResult.Waiting:
gotoWAIT_MORE;
caseeWaitForSQLResult.Success:
gotoGET_THE_RESULT;
default:
gotoEXECUTION_FAILED;
}
...
数据库状态
在BLL中只有一个异步地提供数据库状态的事件。如果数据库连接被断开了(通常是由于网络问题)，OnDatabaseStatusChanged事件就会被挂起。
另外，如果连接恢复了，这个事件会被再次挂起来通知你新的数据库状态。
有趣的地方
在我开发代码的时候，我明白了连接字符串中的连接时限（connectiontimeout）和SQL命令对象的执行时限（executiontimeout）同样重要。
首先，你必须意识到最大容许时限是在连接字符串中定义的，并可以给出一些执行指令比连接字符串中的超时时间更长的时间。
其次，每一个命令都有着它们自己的执行时限，在这里的代码中默认为30秒。你可以很容易地修改它，使它适用于所有类型的命令，就像这样：
userData.tsWaitForResult=TimeSpan.FromSeconds(15);
以上就是异步的SQL数据库封装全部过程，希望对大家的学习有所帮助。