昨天的文章基于.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接口
1  using System;2  using System.Collections.Generic;3 using System.Text;4  using System.Data;5 using System.Data.OleDb;6 7 namespace NGuestBook.AccessDAL8   {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; 2  using System.Collections.Generic;3 using System.Web;4 using System.Web.Caching;5 using System.Configuration;6 using System.Data;7 using System.Data.OleDb;8 using NGuestBook.Utility;9 10 namespace NGuestBook.AccessDAL11  {12 13  /// Access数据库操作助手14  /// 15 public sealed class AccessDALHelper16 {17  18 /// 读取Access数据库的连接字符串19 /// 首先从缓存里读取，如果不存在则到配置文件中读取，并放入缓存20 /// 21 /// 22 private static string GetConnectionString()23  {24 if (CacheAccess.GetFromCache("AccessConnectionString") != null)25  {26 return CacheAccess.GetFromCache("AccessConnectionString").ToString();27 }28 else29 {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语句并返回包含查询结果的DataReader63 /// 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 try93 {94 ExecuteSQLNonQuery(SQLCommand, parameters);95 return true;96 }97 catch98 {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 try115 {116 if (!dataReader.HasRows)117 {118 throw new Exception();119 }120 121 dataReader.Read();122 return strategy.DataReaderToEntity(dataReader);123 }124 catch125 {126 return default(T);127 }128 finally129 {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 try146 {147 if (!dataReader.HasRows)148 {149 & 写下你的评论吧 !
推荐阅读
|
京公网安备 11010802041100号