对数据访问层第一种实现（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 & 数据 访问 一种 实现 Acc+SQL 重构 昨天 文章 基PHP课程HTML视频教程CSS视频JS视频教程Vue视频教程 声明：本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn核实处理。 上一条：AspCms_v1.5_2011.03.03 多个0day漏洞及修复 下一条：曝苹果收购小型数据库公司FoundationDB 编程学习群 技术答疑交流 关注公众号 获取学习资源 相关文章 查看更多 最详细的 MySQL 执行计划和索引优化！ 普通程序员必须掌握的SQL优化技巧 MySQL中如何进行数据的去嵌套和扁平化处理？ 学习MySQL的数据一致性和事务隔离级别设置技巧有哪些？ 如何在MySQL中使用外键来维护数据的完整性？ 热门课程 TP6.0 搭建个人博客实战（玉女心经版） ￥71 ￥79 已抢186677个 抢 php mysql实战：学生信息管理系统（玉女心经版） ￥89 ￥99 已抢67316个 抢 CSS视频教程-玉女心经版 ￥62 ￥69 已抢353137个 抢 JavaScript极速入门_玉女心经系列 ￥62 ￥69 已抢667406个 抢 零基础php开发视频教程VIP视频课 ￥99 ￥299 已抢122584个 抢 前端基础到实战（HTML5+CSS3+ES6+NPM） ￥800 ￥1200 已抢24081个 抢 打开APP，随时随地在线学习！ 首页 课程 文章 问答 博客 词典 手册 资源 搜索 APP下载 PHP培训新 首页 课程 路径 文章 PHP培训 精品课 下载