对数据访问层第一种实现（Acc+SQL）的重构

昨天的文章基于.NET平台的分层架构实战（七） 数据 访问 层的 第一 种 实现 ：Access+SQL发布后，很多朋友对我的程序提出了意见和建议，在这里先谢谢你们！！！尤其是金色海洋（jyk），对我的程序提出了很多建设性的意见。 我大体总结了一下，昨天程序的主要

昨天的文章基于.NET平台的分层架构实战（七）——数据访问层的第一种实现：Access+SQL发布后，很多朋友对我的程序提出了意见和建议，在这里先谢谢你们！！！尤其是 金色海洋（jyk），对我的程序提出了很多建设性的意见。

我大体总结了一下，昨天程序的主要缺点有：
1.Connection对象没有关闭
2.DataReader对象没有关闭
3.相似代码太多，造成代码冗余。

其中第一点问题，目前还没有太好的解决方案，主要是因为Connection一旦关闭，DataReader就无法读取了。而且，Connection对象应该会自动在适当的时候关闭（通过观察临时文件得出），并且在实际运行时并无影响（在功能上），所以这里没有专门解决。而针对后面两个问题，我使用了如下解决方案。

对于关闭DataReader的方法，实现起来很简单，在finally里将他关闭就行了。关键是如何去处冗余代码。

经过我的分析，数据访问层的操作可以分为三类：不返回数据，返回单个实体类，返回实体类集合。我将这三种操作的公共部分抽出，写成三个方法放在AccessDALHelper里，类型不同的问题使用泛型解决。

这样做有一个难题，就是不同实体在由DataReader转化为实体类时的代码很不一样，无法抽出。这里，我使用了Strategy模式解决。具体做法是：首先定义一个由DataReader转换为实体类的策略接口，然后为不同的实体编写不同的转换策略，示意图如下：

可以看出，所有转换策略都要实现IDataReaderToEntityStrategy接口，并且每个策略都有一个自组合，这是以为他们都要实现Singleton模式。而AccessDALHelper与具体策略无关，仅与接口耦合。

下面来看一下具体代码：

首先是IDataReaderToEntityStrategy接口

IDataReaderToEntityStrategy 1using System; 2using System.Collections.Generic; 3using System.Text; 4using System.Data; 5using System.Data.OleDb; 6 7namespace NGuestBook.AccessDAL 8{ 9 /**//// 10 /// 由DataReader转换成实体类的策略接口 11 /// 12 public interface IDataReaderToEntityStrategy<T> 13 { 14 /**//// 15 /// 将DataReader转换为实体类，采用泛型 16 /// 17 /// 包含数据的DataReader对象 18 /// 实体类 19 T DataReaderToEntity(OleDbDataReader dataReader); 20 } 21}

然后以Admin为例，看一下策略的具体实现：

1using System; 2using System.Collections.Generic; 3using System.Web; 4using System.Web.Caching; 5using System.Configuration; 6using System.Data; 7using System.Data.OleDb; 8using NGuestBook.Utility; 9 10namespace NGuestBook.AccessDAL 11{ 12 /**//// 13 /// Access数据库操作助手 14 /// 15 public sealed class AccessDALHelper 16 { 17 /**//// 18 /// 读取Access数据库的连接字符串 19 /// 首先从缓存里读取，如果不存在则到配置文件中读取，并放入缓存 20 /// 21 /// Access数据库的连接字符串 22 private static string GetConnectionString() 23 { 24 if (CacheAccess.GetFromCache("AccessConnectionString") != null) 25 { 26 return CacheAccess.GetFromCache("AccessConnectionString").ToString(); 27 } 28 else 29 { 30 string dbPath = ConfigurationManager.AppSettings["AccessPath"]; 31 string dbAbsolutePath = HttpContext.Current.Server.MapPath(dbPath); 32 string connectionString = ConfigurationManager.AppSettings["AccessConnectionString"]; 33 34 CacheDependency fileDependency = new CacheDependency(HttpContext.Current.Server.MapPath("Web.Config")); 35 CacheAccess.SaveToCache("AccessConnectionString", connectionString.Replace("{DBPath}", dbAbsolutePath), fileDependency); 36 37 return connectionString.Replace("{DBPath}", dbAbsolutePath); 38 } 39 } 40 41 /**//// 42 /// 执行SQL语句并且不返回任何值 43 /// 44 /// 所执行的SQL命令 45 /// 参数集合 46 public static void ExecuteSQLNonQuery(string SQLCommand, OleDbParameter[] parameters) 47 { 48 OleDbConnection connection = new OleDbConnection(GetConnectionString()); 49 OleDbCommand command = new OleDbCommand(SQLCommand, connection); 50 51 for (int i = 0; i < parameters.Length; i++) 52 { 53 command.Parameters.Add(parameters[i]); 54 } 55 56 connection.Open(); 57 command.ExecuteNonQuery(); 58 connection.Close(); 59 } 60 61 /**//// 62 /// 执行SQL语句并返回包含查询结果的DataReader 63 /// 64 /// 所执行的SQL命令 65 /// 参数集合 66 /// 67 public static OleDbDataReader ExecuteSQLDataReader(string SQLCommand, OleDbParameter[] parameters) 68 { 69 OleDbConnection connection = new OleDbConnection(GetConnectionString()); 70 OleDbCommand command = new OleDbCommand(SQLCommand, connection); 71 72 for (int i = 0; i < parameters.Length; i++) 73 { 74 command.Parameters.Add(parameters[i]); 75 } 76 77 connection.Open(); 78 OleDbDataReader dataReader = command.ExecuteReader(); 79 //connection.Close(); 80 81 return dataReader; 82 } 83 84 /**//// 85 /// 执行不需要返回数据的操作 86 /// 87 /// SQL命令 88 /// 参数 89 /// 是否成功 90 public static bool OperateNonData(string SQLCommand, OleDbParameter[] parameters) 91 { 92 try 93 { 94 ExecuteSQLNonQuery(SQLCommand, parameters); 95 return true; 96 } 97 catch 98 { 99 return false; 100 } 101 } 102 103 /**//// 104 /// 执行返回单个实体类的操作 105 /// 106 /// 实体类类型 107 /// SQL命令 108 /// 参数 109 /// DataReader到实体类的转换策略 110 /// 实体类 111 public static T OperateEntity<T>(string SQLCommand, OleDbParameter[] parameters, IDataReaderToEntityStrategy<T> strategy) 112 { 113 OleDbDataReader dataReader = ExecuteSQLDataReader(SQLCommand, parameters); 114 try 115 { 116 if (!dataReader.HasRows) 117 { 118 throw new Exception(); 119 } 120 121 dataReader.Read(); 122 return strategy.DataReaderToEntity(dataReader); 123 } 124 catch 125 { 126 return default(T); 127 } 128 finally 129 { 130 dataReader.Close(); 131 } 132 } 133 134 /**//// 135 /// 执行返回实体类集合的操作 136 /// 137 /// 实体类类型 138 /// SQL命令 139 /// 参数 140 /// DataReader到实体类的转换策略 141 /// 实体类 142 public static IList<T> OperateEntityCollection<T>(string SQLCommand, OleDbParameter[] parameters, IDataReaderToEntityStrategy<T> strategy) 143 { 144 OleDbDataReader dataReader = AccessDALHelper.ExecuteSQLDataReader(SQLCommand, null); 145 try 146 { 147 if (!dataReader.HasRows) 148 { 149 & sql 写下你的评论吧 ! 吐个槽吧,看都看了 会员登录 | 用户注册 推荐阅读 mysql 推荐一个ASP的内容管理框架（ASP Nuke）的优势和适用场景 本文推荐了一个ASP的内容管理框架ASP Nuke，并介绍了其主要功能和特点。ASP Nuke支持文章新闻管理、投票、论坛等主要内容，并可以自定义模块。最新版本为0.8，虽然目前仍处于Alpha状态，但作者表示会继续更新完善。文章还分析了使用ASP的原因，包括ASP相对较小、易于部署和较简单等优势，适用于建立门户、网站的组织和小公司等场景。 ... [详细] 蜡笔小新   2023-12-14 18:11:11 json Android 新闻App的本地服务器搭建教程 本文介绍了在开发Android新闻App时，搭建本地服务器的步骤。通过使用XAMPP软件，可以一键式搭建起开发环境，包括Apache、MySQL、PHP、PERL。在本地服务器上新建数据库和表，并设置相应的属性。最后，给出了创建new表的SQL语句。这个教程适合初学者参考。 ... [详细] 蜡笔小新   2023-12-14 17:15:19 数据库 postman测试登录后的接口_使用postman进行接口测试的方法(测试用户管理模块) 本文介绍了使用postman进行接口测试的方法，以测试用户管理模块为例。首先需要下载并安装postman，然后创建基本的请求并填写用户名密码进行登录测试。接下来可以进行用户查询和新增的测试。在新增时，可以进行异常测试，包括用户名超长和输入特殊字符的情况。通过测试发现后台没有对参数长度和特殊字符进行检查和过滤。 ... [详细] 蜡笔小新   2023-12-14 10:29:45 mysql MysqlDump_mysqldump全库备份相关知识详解 本文详细介绍了MysqlDump和mysqldump进行全库备份的相关知识，包括备份命令的使用方法、my.cnf配置文件的设置、binlog日志的位置指定、增量恢复的方式以及适用于innodb引擎和myisam引擎的备份方法。对于需要进行数据库备份的用户来说，本文提供了一些有价值的参考内容。 ... [详细] 蜡笔小新   2023-12-14 10:03:27 数据库 使用 Ubuntu 中的 Python 获取浏览器历史记录 使用Ubuntu中的Python获取浏览器历史记录原文: ... [详细] 蜡笔小新   2023-12-14 08:57:59 mysql PHP中的MySQL函数库及其常用函数介绍 本文由编程笔记小编整理，介绍了PHP中的MySQL函数库及其常用函数，包括mysql_connect、mysql_error、mysql_select_db、mysql_query、mysql_affected_row、mysql_close等。希望对读者有一定的参考价值。 ... [详细] 蜡笔小新   2023-12-14 08:19:53 数据库 Oracle中tnsnames.ora的作用和配置方法 本文介绍了Oracle数据库中tnsnames.ora文件的作用和配置方法。tnsnames.ora文件在数据库启动过程中会被读取，用于解析LOCAL_LISTENER，并且与侦听无关。文章还提供了配置LOCAL_LISTENER和1522端口的示例，并展示了listener.ora文件的内容。 ... [详细] 蜡笔小新   2023-12-14 07:44:06 mysql Spring特性实现接口多类的动态调用详解 本文详细介绍了如何使用Spring特性实现接口多类的动态调用。通过对Spring IoC容器的基础类BeanFactory和ApplicationContext的介绍，以及getBeansOfType方法的应用，解决了在实际工作中遇到的接口及多个实现类的问题。同时，文章还提到了SPI使用的不便之处，并介绍了借助ApplicationContext实现需求的方法。阅读本文，你将了解到Spring特性的实现原理和实际应用方式。 ... [详细] 蜡笔小新   2023-12-14 03:24:19 数据库 Java String与StringBuffer的区别及其应用场景 本文主要介绍了Java中String和StringBuffer的区别，String是不可变的，而StringBuffer是可变的。StringBuffer在进行字符串处理时不生成新的对象，内存使用上要优于String类。因此，在需要频繁对字符串进行修改的情况下，使用StringBuffer更加适合。同时，文章还介绍了String和StringBuffer的应用场景。 ... [详细] 蜡笔小新   2023-12-13 19:21:06 sql Oracle分析函数first_value()和last_value()的用法及原理 本文介绍了Oracle分析函数first_value()和last_value()的用法和原理，以及在查询销售记录日期和部门中的应用。通过示例和解释，详细说明了first_value()和last_value()的功能和不同之处。同时，对于last_value()的结果出现不一样的情况进行了解释，并提供了理解last_value()默认统计范围的方法。该文对于使用Oracle分析函数的开发人员和数据库管理员具有参考价值。 ... [详细] 蜡笔小新   2023-12-13 19:07:23 sql MyBatis错题分析解析及注意事项 本文对MyBatis的错题进行了分析和解析，同时介绍了使用MyBatis时需要注意的一些事项，如resultMap的使用、SqlSession和SqlSessionFactory的获取方式、动态SQL中的else元素和when元素的使用、resource属性和url属性的配置方式、typeAliases的使用方法等。同时还指出了在属性名与查询字段名不一致时需要使用resultMap进行结果映射，而不能使用resultType。 ... [详细] 蜡笔小新   2023-12-13 18:40:17 sql ASP.NET Tips: 获取插入记录的ID的方法详解 本文详细介绍了在ASP.NET中获取插入记录的ID的几种方法，包括使用SCOPE_IDENTITY()和IDENT_CURRENT()函数，以及通过ExecuteReader方法执行SQL语句获取ID的步骤。同时，还提供了使用这些方法的示例代码和注意事项。对于需要获取表中最后一个插入操作所产生的ID或马上使用刚插入的新记录ID的开发者来说，本文提供了一些有用的技巧和建议。 ... [详细] 蜡笔小新   2023-12-13 17:03:18 数据库 VB.NET在线急等问题解决方法，如何统计数据库字段下的数据并显示在文本框里？ 本文介绍了一个在线急等问题解决方法，即如何统计数据库中某个字段下的所有数据，并将结果显示在文本框里。作者提到了自己是一个菜鸟，希望能够得到帮助。作者使用的是ACCESS数据库，并且给出了一个例子，希望得到的结果是560。作者还提到自己已经尝试了使用"select sum(字段2) from 表名"的语句，得到的结果是650，但不知道如何得到560。希望能够得到解决方案。 ... [详细] 蜡笔小新   2023-12-13 15:15:30 sql SpringJdbcTemplate的使用详解 本文详细介绍了Spring的JdbcTemplate的使用方法，包括执行存储过程、存储函数的call()方法，执行任何SQL语句的execute()方法，单个更新和批量更新的update()和batchUpdate()方法，以及单查和列表查询的query()和queryForXXX()方法。提供了经过测试的API供使用。 ... [详细] 蜡笔小新   2023-12-13 14:27:11 数据库 高质量SQL书写的30条建议 本文提供了30条关于优化SQL的建议，包括避免使用select *，使用具体字段，以及使用limit 1等。这些建议是基于实际开发经验总结出来的，旨在帮助读者优化SQL查询。 ... [详细] 蜡笔小新   2023-12-13 13:24:33 mobiledu2502898417 这个家伙很懒，什么也没留下！ Tags | 热门标签 sqlserver elasticsearch oracle insert join sql pymongo database odbc 数据库 mysql hbase sqlite json nosql memcached mysqli firebase mongodb mariadb redis RankList | 热门文章 1Win7电脑自动调节屏幕亮度怎么关闭？Win7旗舰版自动调节屏幕亮度关闭教程 2scrapy采集的图片如何保存在不同的文件夹？ 3【mediasoup】UV封装库DepLibUV 4斯伯克CYBELEC触摸屏维修CybTouch12折弯机特点 5以三星笔记本R429为例设置HDMI连接电视 6天宝DINI03/莱卡DNA03等电子水准仪原始数据编制软件 7重复显示Word文档表格标题行(转) 82022年熔化焊接与热切割考试模拟100题模拟考试平台操作 9终端安全发展 1002325计算机系统结构201810,2018年10月自考02325计算机系统结构真题及答案 11云边协同，Akamai收购Linode这步棋下对了 12爱奇艺Mac版下载视频怎么操作？ 13ppt倒计时3分钟_下班前半个小时，老板发来100页PPT文件让翻译成英文，3分钟搞定... 14MySQL数据库实验报告详解（从实验设计到数据分析全流程介绍） 15windows下sshfs挂载远程目录server could not connect故障解决 PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具 Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有