对数据访问层第一种实现（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 写下你的评论吧 ! 吐个槽吧,看都看了 会员登录 | 用户注册 推荐阅读 database MySQL 数据库迁移指南：从本地到远程及磁盘间迁移 本文详细介绍了如何在不同场景下进行 MySQL 数据库的迁移，包括从一个硬盘迁移到另一个硬盘、从一台计算机迁移到另一台计算机，以及解决迁移过程中可能遇到的问题。 ... [详细] 蜡笔小新   2024-12-26 13:21:38 数据库 Hadoop入门与核心组件详解 本文详细介绍了Hadoop的基础知识及其核心组件，包括HDFS、MapReduce和YARN。通过本文，读者可以全面了解Hadoop的生态系统及应用场景。 ... [详细] 蜡笔小新   2024-12-26 13:12:48 数据库 MySQL索引详解与优化 本文深入探讨了MySQL中的索引机制，包括索引的基本概念、优势与劣势、分类及其实现原理，并详细介绍了索引的使用场景和优化技巧。通过具体示例，帮助读者更好地理解和应用索引以提升数据库性能。 ... [详细] 蜡笔小新   2024-12-25 19:52:47 数据库 深入理解领域驱动设计及其实践 本文探讨了领域驱动设计（DDD）的核心概念、应用场景及其实现方式，详细介绍了其在企业级软件开发中的优势和挑战。通过对比事务脚本与领域模型，展示了DDD如何提升系统的可维护性和扩展性。 ... [详细] 蜡笔小新   2024-12-25 18:45:55 mongodb 对MariaDB未来发展的思考与担忧 本文探讨了MariaDB在当前数据库市场中的地位和挑战，分析其可能面临的困境，并提出了对未来发展的几点看法。 ... [详细] 蜡笔小新   2024-12-25 18:20:32 数据库 Oracle SQL 动态执行与事务管理：动态SQL是否支持回滚？ 本文探讨了在Oracle数据库中，动态SQL语句的执行及其对事务管理的影响，特别是关于回滚操作的有效性。重点讨论了一个具体场景：将预警短信从当前表迁移到历史表时遇到的字段长度不匹配问题及相应的异常处理。 ... [详细] 蜡笔小新   2024-12-25 16:52:29 数据库 掌握Java EE的全面指南 探讨如何真正掌握Java EE，包括所需技能、工具和实践经验。资深软件教学总监李刚分享了对毕业生简历中常见问题的看法，并提供了详尽的标准。 ... [详细] 蜡笔小新   2024-12-25 13:38:29 mongodb Python入门指南：从零开始的全面学习路线 本文详细介绍了Python编程语言的学习路径，涵盖基础语法、常用组件、开发工具、数据库管理、Web服务开发、大数据分析、人工智能、爬虫开发及办公自动化等多个方向。通过系统化的学习计划，帮助初学者快速掌握Python的核心技能。 ... [详细] 蜡笔小新   2024-12-25 12:54:33 数据库 C++面试高频题 作者：守望者1028链接：https:www.nowcoder.comdiscuss55353来源：牛客网面试高频题：校招过程中参考过牛客诸位大佬的面经，但是具体哪一块是参考谁的我 ... [详细] 蜡笔小新   2024-12-25 12:32:36 sql IMPDP分区表导入的关键注意事项 本文将深入探讨使用IMPDP工具进行分区表导入时需要注意的事项，涵盖最佳实践和常见问题。通过详细的分析与解释，帮助读者更好地理解和应用这些知识。 ... [详细] 蜡笔小新   2024-12-25 11:49:44 database PostgreSQL 10 离线安装指南 本文详细介绍了如何在无法联网的服务器上进行 PostgreSQL 10 的离线安装，并涵盖了从下载安装包到配置远程访问的完整步骤。 ... [详细] 蜡笔小新   2024-12-25 11:46:55 sql SQL 类似查询语句中正则表达式解析 探讨如何使用正则表达式从类 SQL 查询语句中提取字段及其对应的值。 ... [详细] 蜡笔小新   2024-12-25 11:01:15 数据库 TCP长连接设备管理平台：架构与功能概览 本文介绍了基于TCP长连接的设备管理平台的设计理念、技术选型及主要功能模块。最初，项目旨在实现简单的协议测试，但随着需求扩展，逐步演变为一个完整的前后端分离系统。 ... [详细] 蜡笔小新   2024-12-25 09:07:38 数据库 ASP.NET Core 3.1 中的Startup类 Startup 类配置服务和应用的请求管道。Startup类ASP.NETCore应用使用 Startup 类，按照约定命名为 Startup。 Startup 类：可选择性地包括 ... [详细] 蜡笔小新   2024-12-25 02:13:25 数据库 使用Pandas高效读取SQL脚本中的数据 本文详细介绍了如何利用Pandas直接读取和解析SQL脚本，提供了一种高效的数据处理方法。该方法适用于各种数据库导出的SQL脚本，并且能够显著提升数据导入的速度和效率。 ... [详细] 蜡笔小新   2024-12-24 21:56:10 mobiledu2502898417 这个家伙很懒，什么也没留下！ Tags | 热门标签 mysqli join memcached sql mariadb nosql redis insert oracle odbc mysql hbase json sqlite 数据库 pymongo elasticsearch database mongodb sqlserver firebase RankList | 热门文章 1Unity Project Wizard (最近打开的项目记录) 2BaseMap道路压盖体现 3分享下自己的源代码(DirectShow)，顺便请人帮忙看下程序的实现方式是否正确 4辛苦了，开心一下，记住：工作永远干不完，生命却一直在倒计时 5《把时间当作朋友》媒体&读者见面会于京举行 6ps如何制作双重曝光效果？ps怎么给图片做出双重曝光？ 7管理项目失败的教训 8结果分析TPS和响应时间 9在德国看德国队的比赛（二） 10钟薛高布局线下渠道见成效 11大家有没有什么适合公司员工娱乐做的小游戏节目啊，快推荐两个，小弟感激不尽,放分100 12比亚迪全新概念车发布！基于e平台3.0打造 13个人做网站还有前途吗 14找了自己的第一份工作 15【tool】有效的用例编写规则 PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具 Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有