【自然框架】之数据访问 —— 再小的类库也需要设计。

简介:   以前也写过几篇关于数据访问的,这里是最新的总结。麻雀虽小五脏俱全,数据访问也许不起眼,但是也要好好的设计一翻。从2004年开始用自己的数据访问,一直到现在,经历过两次大的改版,随着需求的变化,也增加了不少的功能,小修小改那就更多了。

 

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

 

目标:

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

 

特点:


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

不承担的责任:
1、 不对SQL语句进行检查。
2、 不负责防止SQL注入。
3、 不负责分页。

 

图示:

 

 

结构:


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

 

2、 主体部分
  DataAccessLibrary:这个是数据访问的核心部分,相当于大树的主干。定义了一个DbCommand Command,通过他来实现各种功能。
主体部分仅实现最基本的功能,定义内部结构、成员,实现输入和输出的功能。
输入主要是ExecuteNonQuery。通过他来传递添加、修改、删除的SQL语句(包括参数化SQL和存储过程)。还有一个 ExecuteExists,用来判断数据库里是否存在指定的记录。

  输出部分主要是ExecuteReader,这个大家都不陌生吧。其他的原则上都是通过扩展(配件)的方式来实现,不过为了便于调用,还是增加了ExecuteString、T ExecuteScalar<T>(string text)两个函数。这个对于我来说比较常用,所以就放在主体部分里面了。
另外可以通过子类来实现支持不同数据库的差异的部分。

 

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

 


实例

 

// 发回复  

Reply.bodyUBB 
=  Request.Form[ " Editor " ];  

Reply.topicID 
=   int .Parse( this .DataID);  

#region  验证信息  

if  (Reply.bodyUBB.Length  <   10 )  

{  

    Functions.PageRegisterAlert(Page, 
" 请填写内容,或者内容太短!至少也得写10个字,对吧。 " );  

    
return ;  

}  

#endregion   

#region  内部字段  

int  userID  =   int .Parse(UserInfo.UserID);  

string  ip  =  Request.UserHostAddress;  

DateTime dateTime 
=  DateTime.Now;  

string  bodyHTML;  

#endregion   

#region  处理UBB  

bodyHTML 
=  bodyUBB.Replace( " \r " " <BR> " );  

// 其他略  

#endregion   

// 开启事务  

Dal.ManagerTran.TranBegin();  

ManagerParameter parm 
=  Dal.ManagerParameter;  

#region  设置参数  

parm.ClearParameter();  

parm.AddNewInParameter(
" TopicID " , Reply.topicID);         //    

parm.AddNewInParameter(
" 回复内容 " , bodyUBB);  

parm.AddNewInParameter(
" 内容HTML " , bodyHTML);  

parm.AddNewInParameter(
" 回复人ID " , userID);  

parm.AddNewInParameter(
" 回复人IP " , ip,  15 );  

parm.AddNewInParameter(
" 回复时间 " , dateTime);  

#endregion   

              

#region  保存回复,表名:BBS_Reply  

Dal.ModifyData.InsertData(
" BBS_Reply " );  

if  (Dal.ErrorMessage.Length  >   0 )  

{  

    
// 出现异常  

    Functions.PageRegisterAlert(Page, 
" 保存您发的回复的时候出现意外情况! " );  

    
return ;  

}  

#endregion   

string  sql;  

#region  更新回复人的回复数量,回复时间,以及各种积分。  

sql 
=   @" update BBS_Topic set 回复次数 = 回复次数 + 1 ,最后回复时间 = GetDate(),  

最后回复人ID = {0},   where TopicID ={1}
" ;  

Dal.ExecuteNonQuery(
string .Format(sql, userID,topicID));  

if  (Dal.ErrorMessage.Length  >   0 )  

{  

    
// 出现异常  

    Functions.PageRegisterAlert(Page, 
" 更新回复数量的时候出现意外情况! " );  

    
return ;  

}  

#endregion   

#region  更新回复人的参与讨论的帖子  

sql 
=   " select top 1 UserInTopicID from BBS_UserInTopic where UserID ={0} and TopicID={1}  " ;  

string  userInTopicID  =  Dal.ExecuteString( string .Format(sql, userID, topicID));  

sql 
=   " select top 1 回复次数 from BBS_Topic where TopicID={0}  " ;  

string  reCount  =  Dal.ExecuteString( string .Format(sql, topicID))  ??   " 0 " ;  

int  intReCount  =   int .Parse(reCount);  

if  (userInTopicID  ==   null )  

{  

    
#region  没有参与过,添加记录  

    parm.ClearParameter();  

    parm.AddNewInParameter(
" UserID " , userID);  

    parm.AddNewInParameter(
" TopicID " , topicID);  

    parm.AddNewInParameter(
" 最后查看时间 " , dateTime);  

    parm.AddNewInParameter(
" 最后查看回复数 " , intReCount);  

    Dal.ModifyData.InsertData(
" BBS_UserInTopic " );  

    
if  (Dal.ErrorMessage.Length  >   0 )  

    {  

        
// 出现异常  

        Functions.PageRegisterAlert(Page, 
" 增加您参与讨论的帖子的时候出现意外情况! " );  

        
return ;  

    }  

    
#endregion   

}  

else  

{  

    
#region  参与过,修改记录  

    parm.ClearParameter();  

    parm.AddNewInParameter(
" 最后查看时间 " , dateTime);  

    parm.AddNewInParameter(
" 最后查看回复数 " , intReCount);  

    Dal.ModifyData.UpdateData(
" BBS_UserInTopic " " UserInTopicID= "   +  userInTopicID);  

    
if  (Dal.ErrorMessage.Length  >   0 )  

    {  

        
// 出现异常  

        Functions.PageRegisterAlert(Page, 
" 更新参与讨论的帖子的时候出现意外情况! " );  

        
return ;  

    }  

    
#endregion   

}  

#endregion   

// 提交事务  

Dal.ManagerTran.TranCommit();  

// 正常  

lblMsg.Text 
=   " 发表回复成功!感谢您的参与!1秒后重新加载帖子。 " ;  

Functions.PageRegisterJavascript(Page, 
" reload() " ); 

 


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

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

相关文章
|
3月前
|
安全 前端开发 Java
随着企业应用复杂度提升,Java Spring框架以其强大与灵活特性简化开发流程,成为构建高效、可维护应用的理想选择
随着企业应用复杂度提升,Java Spring框架以其强大与灵活特性简化开发流程,成为构建高效、可维护应用的理想选择。依赖注入使对象管理交由Spring容器处理,实现低耦合高内聚;AOP则分离横切关注点如事务管理,增强代码模块化。Spring还提供MVC、Data、Security等模块满足多样需求,并通过Spring Boot简化配置与部署,加速微服务架构构建。掌握这些核心概念与工具,开发者能更从容应对挑战,打造卓越应用。
43 1
|
4月前
|
SQL 前端开发 API
Laravel框架的主要优点是什么?
【7月更文挑战第2天】Laravel框架的主要优点是什么?
99 0
|
6月前
|
算法 测试技术 数据处理
【C++ 设计思路】优化C++项目:高效解耦库接口的实战指南
【C++ 设计思路】优化C++项目:高效解耦库接口的实战指南
175 5
|
6月前
|
C#
.NET开发中合理使用对象映射库,简化和提高工作效率
.NET开发中合理使用对象映射库,简化和提高工作效率
191 0
|
小程序 前端开发 API
阿里云小程序框架优点
阿里云小程序框架优点
|
存储 缓存 固态存储
如何写出高性能代码(四)优化数据访问
同一份逻辑,不同人的实现的代码性能会出现数量级的差异; 同一份代码,你可能微调几个字符或者某行代码的顺序,就会有数倍的性能提升;同一份代码,也可能在不同处理器上运行也会有几倍的性能差异;十倍程序员不是只存在于传说中,可能在我们的周围也比比皆是。十倍体现在程序员的方法面面,而代码性能却是其中最直观的一面。
145 0
如何写出高性能代码(四)优化数据访问
【自然框架】内部类库、控件的引用关系(最新整理,基本稳定)
  和以前相比,减少了一个项目,把Control_Interface合并到CommonFunction里面。这样引用关系就简单多了。   基本上分为三个层次:类库、自定义控件、页面基类。其中的 MetaData 负责元数据的定义和加载。
647 0
【自然框架】之“解耦”初探
      解耦,在以前确实做不到,但是周四和“横刀天笑”聊了之后,发现解耦是可以实现的。其实很简单,只要弄出来一个“实体类”就可以搞定了。                如果是简单的情况,那么就让表单控件“全权负责”了,这时候是不需要些什么代码的,点点鼠标,打几个字就可以了。
1160 0
|
存储 关系型数据库 BI