对数据访问层种实现（Acc+SQL）的重构 近日的文章基于.NET平台的分层架构实战（七）——数据访问层的种实现：Access+SQL发布后，很多朋友对我的程序提出了意见和建议，在这里先谢谢你们！！！尤其是金色海洋（jyk），对我的程序提出了很多建设性的意见。 我大体总结了一下，昨天程序的主要缺点有： 1.Connection对象没有关闭 2.DataReader对象没有关闭 3.相似代码太多，造成代码冗余。 其中点问题，目前还没有太好的解决方案，主要是因为Connection一旦关闭，DataReader无法读取了。而且，Connection对象应该会自动在适当的时候关闭（通过观察临时文件得出），并且在实际运行时并无影响（在功能上），所以这里没有专门解决。而针对后面两个问题，我使用了如下解决方案。 对于关闭DataReader的方法，实现起来很简单，在finally里将他关闭行了。关键是如何去处冗余代码。 经过我的分析，数据访问层的操作可以分为三类：不返回数据，返回单个实体类，返回实体类集合。我将这三种操作的公共部分抽出，写成三个方法放在AccessDALHelper里，类型不同的问题使用泛型解决。 这样做有一个难题，是不同实体在由DataReader转化为实体类时的代码很不一样，无法抽出。这里，我使用了Strategy模式解决。具体做法是：首先定义一个由DataReader转换为实体类的策略接口，然后为不同的实体编写不同的转换策略，示意图如下：可以看出，所有转换策略都要实现IDataReaderToEntityStrategy接口，并且每个策略都有一个自组合，这是以为他们都要实现Singleton模式。而AccessDALHelper与具体策略无关，仅与接口耦合。 下面来看一下具体代码： 首先是IDataReaderToEntityStrategy接口 IDataReaderToEntityStrategy1usingSystem;2usingSystem.Collections.Generic;3usingSystem.Text;4usingSystem.Data;5usingSystem.Data.OleDb;67namespaceNGuestBook.AccessDAL8{9/**////10///由DataReader转换成实体类的策略接口11///12publicinterfaceIDataReaderToEntityStrategy13{14/**////15///将DataReader转换为实体类，采用泛型16///17///包含数据的DataReader对象18///实体类19TDataReaderToEntity(OleDbDataReaderdataReader);}21} 然后以Admin为例，看一下策略的具体实现： 1usingSystem;2usingSystem.Collections.Generic;3usingSystem.Web;4usingSystem.Web.Caching;5usingSystem.Configuration;6usingSystem.Data;7usingSystem.Data.OleDb;8usingNGuestBook.Utility;910namespaceNGuestBook.AccessDAL11{12/**////13///Access数据库操作助手14///15publicsealedclassAccessDALHelper16{17/**////18///读取Access数据库的连接字符串19///首先从缓存里读取，如果不存在则到配置文件中读取，并放入缓存///21///Access数据库的连接字符串22privatestaticstringGetConnectionString()23{24if(CacheAccess.GetFromCache("AccessConnectionString")!=null)25{26returnCacheAccess.GetFromCache("AccessConnectionString").ToString();27}28else29{30stringdbPath=ConfigurationManager.AppSettings["AccessPath"];31stringdbAbsolutePath=HttpContext.Current.Server.MapPath(dbPath);32stringconnectionString=ConfigurationManager.AppSettings["AccessConnectionString"];3334CacheDependencyfileDependency=newCacheDependency(HttpContext.Current.Server.MapPath("Web.Config"));35CacheAccess.SaveToCache("AccessConnectionString",connectionString.Replace("{DBPath}",dbAbsolutePath),fileDependency);3637returnconnectionString.Replace("{DBPath}",dbAbsolutePath);38}39}4041/**////42///执行SQL语句并且不返回任何值43///44///所执行的SQL命令45///参数集合46publicstaticvoidExecuteSQLNonQuery(stringSQLCommand,OleDbParameter[]parameters)47{48OleDbConnectionconnection=newOleDbConnection(GetConnectionString());49OleDbCommandcommand=newOleDbCommand(SQLCommand,connection);5051for(inti=0;i{69OleDbConnectionconnection=newOleDbConnection(GetConnectionString());70OleDbCommandcommand=newOleDbCommand(SQLCommand,connection);7172for(inti=0;i{69OleDbConnectionconnection=newOleDbConnection(GetConnectionString());70OleDbCommandcommand=newOleDbCommand(SQLCommand,connection);7172for(inti=0;i