自然框架之数据访问

以前也写过几篇关于数据访问的，这里是***的总结。麻雀虽小五脏俱全，数据访问也许不起眼，但是也要好好的设计一翻。从2004年开始用自己的数据访问，一直到现在，经历过两次大的改版，随着需求的变化，也增加了不少的功能，小修小改那就更多了。目的就是能够让自己更轻松一点。整理思路、整理代码，写点东西，一个是给自己留个脚印；另外一个，说不定也许能够给大家帮个小忙。

汪清ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景，ssl证书未来市场广阔！成为创新互联公司的ssl证书销售渠道，可以享受市场价格4-6折优惠！如果有意向欢迎电话联系或者加微信：18980820575（备注：SSL证书合作）期待与您的合作！

目标：

简单、好用、易扩展、稳定、性能。

特点：

  1. 基于ADO.net 2.0 编写，理论上可以支持多种数据库，目前测试了SQL Server 和Access，一位朋友帮忙测试了MySQL。Orcale等其他数据库没有测试过。
  2. 使用非常简单。
  3. 支持事务、存储过程、参数化SQL等。
  4. 对存储过程的参数进行封装，更便于操作和更换数据库。
  5. 如果运行是出现异常，可以把异常信息、出错的SQL保存到文本文件里面，便于调试、修改错误。
  6. 可以方便的扩展相关功能，遵循关闭开放原则。

不承担的责任：

不对SQL语句进行检查。

不负责防止SQL注入。

不负责分页。

图示：

结构：

1、 两个工厂

CommonFactory：生成Db系列的实例，比如DbConnection、DbCommand等。内部使用。他们都是抽象基类不能直接new，需要相应的子类的实例，比如new SqlConnection、new SqlCommand等。这个就需要根据当前的需求（驱动类型）来确定了，也就是这个工厂的职责。
DALFactory：调用者使用的工厂，通过这个工厂，根据数据驱动类型，生成数据访问的实例。

2、 主体部分

DataAccessLibrary：这个是数据访问的核心部分，相当于大树的主干。定义了一个DbCommand Command，通过他来实现各种功能。

主体部分仅实现最基本的功能，定义内部结构、成员，实现输入和输出的功能。

输入主要是ExecuteNonQuery。通过他来传递添加、修改、删除的SQL语句（包括参数化SQL和存储过程）。还有一个 ExecuteExists，用来判断数据库里是否存在指定的记录。

输出部分主要是ExecuteReader，这个大家都不陌生吧。其他的原则上都是通过扩展（配件）的方式来实现，不过为了便于调用，还是增加了ExecuteString、T ExecuteScalar(string text)两个函数。这个对于我来说比较常用，所以就放在主体部分里面了。

另外可以通过子类来实现支持不同数据库的差异的部分。

3、 配件部分

这个就比较多了，比如对事务的处理、对存储过程的参数的封装、对Json 的处理、对添加、修改用SQL（包括参数化SQL）的处理等。每一个都是一个“配件”，这样就可以通过增加配件的方式增加需要的功能。比如以前是不支持Json格式的记录的，但是想玩玩ajax，选择json来传递数据，那么就需要把提取出来的数据转换Json格式。那么就可以增加一个“配件”，就是增加一个类，而不影响其他代码。

增加功能，并不影响其他的代码，这个就是对扩展开放，对修改关闭。

实例

 
 
 
 
    
  
  
  
  
  1. //发回复    
    2.   
  
  
  
  2. Reply.bodyUBB = Request.Form["Editor"];    
    3.   
  
  
  
  3. Reply.topicID = int.Parse(this.DataID);    
    4.   
  
  
  
  4. #region 验证信息    
    5.   
  
  
  
  5. if (Reply.bodyUBB.Length < 10)    
    6.   
  
  
  
  6. {    
    7.   
  
  
  
  7.     Functions.PageRegisterAlert(Page, "请填写内容，或者内容太短！至少也得写10个字，对吧。");    
    8.   
  
  
  
  8.     return;    
    9.   
  
  
  
  9. }    
    10.   
  
  
  
  10.  
    11.   
  
  
  
  11. #endregion    
    12.   
  
  
  
  12. #region 内部字段    
    13.   
  
  
  
  13. int userID = int.Parse(UserInfo.UserID);    
    14.   
  
  
  
  14. string ip = Request.UserHostAddress;    
    15.   
  
  
  
  15. DateTime dateTime = DateTime.Now;    
    16.   
  
  
  
  16. string bodyHTML;    
    17.   
  
  
  
  17. #endregion    
    18.   
  
  
  
  18. #region 处理UBB    
    19.   
  
  
  
  19. bodyHTML = bodyUBB.Replace("\r", "
    ");    
    20.   
  
  
  
  20. //其他略    
    21.   
  
  
  
  21. #endregion    
    22.   
  
  
  
  22. //开启事务    
    23.   
  
  
  
  23. Dal.ManagerTran.TranBegin();    
    24.   
  
  
  
  24. ManagerParameter parm = Dal.ManagerParameter;    
    25.   
  
  
  
  25. #region 设置参数    
    26.   
  
  
  
  26. parm.ClearParameter();    
    27.   
  
  
  
  27. parm.AddNewInParameter("TopicID", Reply.topicID);        //     
    28.   
  
  
  
  28. parm.AddNewInParameter("回复内容", bodyUBB);    
    29.   
  
  
  
  29. parm.AddNewInParameter("内容HTML", bodyHTML);    
    30.   
  
  
  
  30. parm.AddNewInParameter("回复人ID", userID);    
    31.   
  
  
  
  31. parm.AddNewInParameter("回复人IP", ip, 15);    
    32.   
  
  
  
  32. parm.AddNewInParameter("回复时间", dateTime);    
    33.   
  
  
  
  33. #endregion                  
    34.   
  
  
  
  34. #region 保存回复，表名：BBS_Reply    
    35.   
  
  
  
  35. Dal.ModifyData.InsertData("BBS_Reply");    
    36.   
  
  
  
  36. if (Dal.ErrorMessage.Length > 0)    
    37.   
  
  
  
  37. {    
    38.   
  
  
  
  38.     //出现异常    
    39.   
  
  
  
  39.     Functions.PageRegisterAlert(Page, "保存您发的回复的时候出现意外情况！");    
    40.   
  
  
  
  40.     return;    
    41.   
  
  
  
  41. }    
    42.   
  
  
  
  42. #endregion    
    43.   
  
  
  
  43. string sql;    
    44.   
  
  
  
  44. #region 更新回复人的回复数量，回复时间，以及各种积分。    
    45.   
  
  
  
  45. sql = @"update BBS_Topic set 回复次数 = 回复次数 + 1 ,***回复时间 = GetDate(),    
    46.   
  
  
  
  46. ***回复人ID = {0},   where TopicID ={1}";    
    47.   
  
  
  
  47. Dal.ExecuteNonQuery(string.Format(sql, userID,topicID));    
    48.   
  
  
  
  48. if (Dal.ErrorMessage.Length > 0)    
    49.   
  
  
  
  49. {    
    50.   
  
  
  
  50.     //出现异常    
    51.   
  
  
  
  51.     Functions.PageRegisterAlert(Page, "更新回复数量的时候出现意外情况！");    
    52.   
  
  
  
  52.     return;    
    53.   
  
  
  
  53. }    
    54.   
  
  
  
  54. #endregion    
    55.   
  
  
  
  55. #region 更新回复人的参与讨论的帖子    
    56.   
  
  
  
  56. sql = "select top 1 UserInTopicID from BBS_UserInTopic where UserID ={0} and TopicID={1} ";    
    57.   
  
  
  
  57. string userInTopicID = Dal.ExecuteString(string.Format(sql, userID, topicID));    
    58.   
  
  
  
  58. sql = "select top 1 回复次数 from BBS_Topic where TopicID={0} ";    
    59.   
  
  
  
  59. string reCount = Dal.ExecuteString(string.Format(sql, topicID)) ?? "0";    
    60.   
  
  
  
  60. int intintReCount = int.Parse(reCount);    
    61.   
  
  
  
  61. if (userInTopicID == null)    
    62.   
  
  
  
  62. {    
    63.   
  
  
  
  63.     #region 没有参与过，添加记录    
    64.   
  
  
  
  64.     parm.ClearParameter();    
    65.   
  
  
  
  65.     parm.AddNewInParameter("UserID", userID);    
    66.   
  
  
  
  66.     parm.AddNewInParameter("TopicID", topicID);    
    67.   
  
  
  
  67.     parm.AddNewInParameter("***查看时间", dateTime);    
    68.   
  
  
  
  68.     parm.AddNewInParameter("***查看回复数", intReCount);    
    69.   
  
  
  
  69.     Dal.ModifyData.InsertData("BBS_UserInTopic");    
    70.   
  
  
  
  70.     if (Dal.ErrorMessage.Length > 0)    
    71.   
  
  
  
  71.     {    
    72.   
  
  
  
  72.         //出现异常    
    73.   
  
  
  
  73.         Functions.PageRegisterAlert(Page, "增加您参与讨论的帖子的时候出现意外情况！");    
    74.   
  
  
  
  74.         return;    
    75.   
  
  
  
  75.     }    
    76.   
  
  
  
  76.     #endregion    
    77.   
  
  
  
  77. }    
    78.   
  
  
  
  78. else   
    79.   
  
  
  
  79.  
    80.   
  
  
  
  80. {    
    81.   
  
  
  
  81.     #region 参与过，修改记录    
    82.   
  
  
  
  82.     parm.ClearParameter();    
    83.   
  
  
  
  83.     parm.AddNewInParameter("***查看时间", dateTime);    
    84.   
  
  
  
  84.     parm.AddNewInParameter("***查看回复数", intReCount);    
    85.   
  
  
  
  85.     Dal.ModifyData.UpdateData("BBS_UserInTopic", "UserInTopicID=" + userInTopicID);    
    86.   
  
  
  
  86.     if (Dal.ErrorMessage.Length > 0)    
    87.   
  
  
  
  87.     {    
    88.   
  
  
  
  88.         //出现异常    
    89.   
  
  
  
  89.         Functions.PageRegisterAlert(Page, "更新参与讨论的帖子的时候出现意外情况！");    
    90.   
  
  
  
  90.         return;    
    91.   
  
  
  
  91.     }    
    92.   
  
  
  
  92.     #endregion    
    93.   
  
  
  
  93. }    
    94.   
  
  
  
  94. #endregion    
    95.   
  
  
  
  95. //提交事务    
    96.   
  
  
  
  96. Dal.ManagerTran.TranCommit();    
    97.   
  
  
  
  97. //正常    
    98.   
  
  
  
  98. lblMsg.Text = "发表回复成功！感谢您的参与！1秒后重新加载帖子。";    
    99.   
  
  
  
  99. Functions.PageRegisterJavascript(Page, "reload()");    
    100.

简单写一个，以论坛的回复为例，这个大家都熟悉，不是太简单也不是很复杂。

这个没有按照三层的方式来写，因为我分不出来哪些是业务逻辑，哪些是数据访问，都写到一起了，呵呵。但是这并不是说数据访问只能写成这个样子。这个只是一个具体的、综合性的例子。也可以把他分一分，找到业务逻辑的部分，提取出去，放在业务层；把数据访问的部分也提出出去，放在数据层。

这里仅仅是一个数据访问的调用的示例，并不是说要不要分层。

原文出处：http://www.cnblogs.com/jyk/archive/2011/03/28/1998254.html

【编辑推荐】

  1. 晒晒我的通用数据访问层
  2. 几步走，教你创建简单访问数据库方法
  3. 一句代码实现批量数据绑定 下
  4. 一步一步设计你的数据库1
  5. 不重复随机数列生成算法

当前名称：自然框架之数据访问
文章路径：http://www.shufengxianlan.com/qtweb/news36/124236.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

响应式网站知识

行业网站建设

成都画册设计公司　　 　成都网站推广　　 　成都400电话申请　　 　达州电信机房　　 　成都艺考培训　　 　名片　　 　广安园林景观设计　　 　小谭建站　　 　蜜朵婚庆　　 　江油网站建设　　 　网站运维托管　　 　成都网站建设　　 　成都宣传海报　　 　广汉锦华建材　　 　成都企业网站建设公司　　 　成都营销型网站建设　　 　成都网站设计公司　　 　定制级高端网站建设　　 　和正兴机械　　 　服务器托管