位置: 编程技术 - 正文

异步的SQL数据库封装详解(数据库 异步)

编辑:rootadmin

推荐整理分享异步的SQL数据库封装详解(数据库 异步),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:异步的sql数据库有哪些,异步mysql,数据库 异步,数据库异步io,数据库异步io,sql异步执行,异步的sql数据库是什么,异步的sql数据库有哪些,内容如对您有帮助,希望把文章链接给更多的朋友!

引言

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

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

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

背景

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

使用

这个库由两个类组成:

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

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

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

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

异步的SQL数据库封装详解(数据库 异步)

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

再看看这个示例:

在这个例子中,我们调用 `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=`,通过userData.ScalarValue 取得返回的结果。对于存储过程,只有一种需要传入 ExecuteStoredProcedure 的数据类型。但在声明变量时你需要指明存储过程的返回值类型:

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

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

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

数据库状态

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

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

有趣的地方

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

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

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

标签: 数据库 异步

本文链接地址:https://www.jiuchutong.com/biancheng/347391.html 转载请保留说明!

上一篇:sql语句实现四种九九乘法表(sql四种功能)

下一篇:SQL Server 2016 CTP2.3 的关键特性总结

  • 怎么把预付账款转到管理费用
  • 全年一次性奖金税收计算器
  • 小微企业免交增值税,月末结转到营业外收入吗
  • 行政事业单位会计制度
  • 小微企业增值税免税政策2023年
  • 报无票收入又开发票了怎么办?
  • 收到去年所得税汇算清缴退税账务处理
  • 确定发出存货实际成本的方法
  • 纳税总额包括代扣代缴个人所得税吗
  • 未达起征点纳税申报表怎么填
  • 补充养老保险交200和500差别
  • 机动车类专用发票
  • 医院开发票需要税号吗
  • 建筑业增值税税率由11调整到10
  • 税法相关问题
  • 公司支付媒体广告费用必须签订合同吗?如果没有签订合同是否不能税前扣除?
  • 代购本无罪,逃避关税须处罚
  • 专项维修基金和契税有什么区别
  • 利润分配可以用现金吗
  • 加油卡预付卡销户怎么办
  • 河道管理费入什么科目
  • 企业发给员工的福利要交税吗
  • 债权性投资和权益性投资的区别
  • 进项税额转出再转入
  • 房地产商铺增值税税率是多少
  • 结转成本的会计分录摘要怎么写
  • 开具的电子发票需要打印出来做账吗
  • 危险废物处置是冶金行业吗
  • 计提企业所得税费用会计分录
  • 分公司可以独立诉讼吗
  • 解除劳动关系取公积金
  • php两个多维数组合在一起
  • 联想小新Air15如何进入bois
  • 异地使用支票的提示付款期限
  • 企业注销后账上有结余怎么办
  • OSError: [WinError 1455] 页面文件太小,无法完成操作。 Error loading “C:\ProgramData\Anaconda3\lib\site-packages\to
  • post请求怎么用
  • wamp怎么运行php文件
  • 项目辅材计入什么科目
  • 违约金开什么票据
  • 金蝶怎么加人
  • go开发web项目
  • 前端种类
  • 集团对子公司拨款的规定
  • 折扣方式销售有哪些类型
  • 企业年报网上申报入口贵州
  • js变量作用范围
  • python装饰器如何保留原函数信息
  • 财务费用相关指标
  • 公司土地使用权可以自主转让吗
  • 未确认融资费用含税吗
  • 公司对于子公司的股权投资
  • 企业自有房产的认定标准
  • 债务转为股份的协议
  • 安装调试费收费标准
  • 去年计提的费用今年取得发票 汇算清缴
  • 如何处理固定资产报废
  • 会计里面的管理费用
  • 本月取得的发票入账后次月对方能红冲吗
  • 公司每个月申报怎么报的
  • sqlserver数据库恢复挂起状态
  • 动态创建数据库表
  • 隐藏在大山深处的罪恶
  • w10预览版新功能
  • mac os x10.6
  • 电脑xp系统改装win7系统可以吗
  • linux系统解压tar.gz文件
  • win7系统如何添加打印机
  • linux block io
  • opengl 三角形
  • 微信小程序倒计时乱跳
  • javascript入门经典
  • 防止arp攻击的措施
  • shell脚本switch
  • sqlserver 服务器
  • lua脚本语言零基础教程
  • javascript常见的数据类型
  • jquery有自定义选择器吗
  • 医保预交金可以取出来吗
  • 新一轮税制改革的背景是什么
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设