引言
我一直在寻找一种简单有效的库，它能在简化数据库相关的编程的同时提供一种异步的方法来预防死锁。
我找到的大部分库要么太繁琐，要么灵活性不足，所以我决定自己写个。
使用这个库，你可以轻松地连接到任何 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数据库封装全部过程，希望对大家的学习有所帮助。
免责声明：本站文章均来自网站采集或用户投稿，网站不提供任何软件下载或自行开发的软件！ 如有用户或公司发现本站内容信息存在侵权行为，请邮件告知！ 858582#qq.com
3月27日消息，苹果宣布2024年全球开发者大会（WWDC）将于6月10日至6月14日举行，巧合的是，这次大会与端午假期重合。
苹果官方表示：
在线参加 Apple 每年规模最大的开发者盛会。亲眼见证 Apple 最新平台、技术和工具的发布。了解如何创建和改进你的 App 和游戏。与 Apple 设计师和工程师互动交流，与全球开发者社区建立联系。以上活动均免费在线举行。
探索各种新的工具、框架和功能，助力你打造出理想的 App 和游戏。通过视频讲座学习新技能，与 Apple 专家进行一对一会面，以推进你的项目，完善你的构思。
Swift Student Challenge 旨在支持和鼓舞下一代开发者、创作者和企业家。太平洋时间 3 月 28 日，我们将公布今年的获奖者名单。获奖者将有资格参加在 Apple Park 举办的特别活动。我们还会选出 50 名杰出获胜者，他们将受邀前往库比提诺，获得为期三天的非凡体验，包括参加 Apple Park 的特别活动。
RTX 5090要首发 性能要翻倍！三星展示GDDR7显存
三星在GTC上展示了专为下一代游戏GPU设计的GDDR7内存。
首次推出的GDDR7内存模块密度为16GB，每个模块容量为2GB。其速度预设为32 Gbps（PAM3），但也可以降至28 Gbps，以提高产量和初始阶段的整体性能和成本效益。
据三星表示，GDDR7内存的能效将提高20%，同时工作电压仅为1.1V，低于标准的1.2V。通过采用更新的封装材料和优化的电路设计，使得在高速运行时的发热量降低，GDDR7的热阻比GDDR6降低了70%。