教你如何来进行编写通用的数据访问

引言

　　在负责咨询工作的过去 6 年中，我曾多次听说关于数据访问和操作方面的问题，它时刻困扰着用户：“如何编写应用程序，以便只需对其进行很少的改动或不进行改动即可使用数据库服务器 x、y 和 z？”由于知道数据访问层仍然是现代应用程序的最关键部分，并且通常是经验不足的开发人员的头号敌人，因此我的第一反应始终是：根本办不到！

　　面对着人们惶惶不安的面孔以及“使用 Microsoft 在 ADO 中提供的通用数据访问方法如何？”这样的问题，我决定针对此问题提供更详细的说明以及建议的解决方案。

　　问题在于，如果应用程序是较小的原型，或者如果并发用户较少并且数据访问逻辑比较简单，那么即使您选择下面这些最简单的方法，也不会遇到任何问题：使用 RAD 工具（如 Data Environment in Microsoft® Visual Basic® 6.0），或某些“一揽子”解决方案（如 ActiveX® Data Control 和其他第三方组件），这些解决方案通常会隐藏应用程序与特定数据源之间进行的复杂交互。然而，当用户数量增加使得必须解决并发操作问题时，由于频繁使用动态记录集、服务器端光标以及不必要的锁定策略，导致出现许多性能问题。为达到用户目标而必须对系统所做的设计和代码更改将花费您大量的时间，因为您从开始时就没有考虑过这一问题。

　　使用通用数据访问方法

　　在将 ADO 可靠地并入 MDAC（Microsoft Data Access Components 2.1 版）后，Microsoft 掀起了通用数据访问的使用高潮。其主导思想是向开发人员展示，通过使用简单的对象模型（“连接”、“命令”和“记录集”），可以编写出能够与各种不同的数据源（无论是关系数据源还是非关系数据源）连接的应用程序。文档（以及当时的大多数文章和示例）中通常未曾提及的是，即使使用相同的数据访问技术，各种数据源的可编程性和特征也千差万别。

　　其结果是，在需要从多个数据源获取数据的应用程序中，最简单的方法是使用所有数据源所提供的功能的“共同点”，但因此会失去使用数据源特定选项的好处，即为访问和操作各种 RDBMS 中的信息提供最佳方法。

　　我对该方法始终存在的怀疑是，经过与我的客户进行更详细的分析后，我们通常一致认为与应用程序中处理显示和业务逻辑的其他部分相比，与数据源进行交互的只是应用程序很小的一部分。通过进行精心的模块化设计，可以将 RDBMS 特定代码隔离在一些容易互换的模块中，从而避免对数据访问使用“通用”方法。然而，我们可以使用非常特定的数据访问代码（根据数据源的不同，使用存储过程、命令批处理和其他特性），而不触及其他大多数应用程序代码。这总是提醒大家：正确的设计是编写可移植的有效代码的关键。

    ADO.NET 将一些重要的变化引入到数据访问编码领域，如专用 .NET 数据提供程序这样的概念。使用特定的提供程序，可以绕过为数众多但有时没必要的一系列软件接口和服务（它们是 OLE DB 和 ODBC 层在数据访问代码与数据库服务器之间插入的内容），从而以最佳方式连接到数据源。但每个数据源仍然存在不同的特征和特性（具有不同的 SQL Dialect），且编写高效的应用程序仍然必须使用这些特定特征而不是“共同点”。从可移植性观点看来，托管和非托管的数据访问技术仍然非常类似。

　　除“利用数据源的唯一特征”外，编写良好数据访问层所必需的其他规则对每个数据源通常都是相同的：

　　• 在可能的情况下使用连接池机制。

　　• 节约使用数据库服务器的有限资源。

　　• 注意网络的往返。

　　• 在适当的情况下，增强执行计划的重复使用率并避免重复编译。

　　• 使用适当的锁定模型管理并发性。

　　从我使用模块化设计方法的个人经验来看，整个应用程序中专用于处理特定数据源的代码量不会超过总量的 10%。显而易见，这比仅仅更改配置文件中的连接字符串更复杂，但我认为，这样做会获得性能收益，因此这是一个可接受的折衷办法。

　　使用基本接口

　　此处的目标是使用抽象，并将特定于特殊数据源的代码封装在类层中，从而使应用程序的其他部分独立于后端数据库服务器或免受其影响。

　　.NET Framework 的面向对象这一特性将在该过程中为我们提供帮助，使我们能够选择要使用的抽象级别。选项之一是使用每个 .NET 数据提供程序都必须实现的基本接口（IDbConnection、IDbCommand、IDataReader 等）。另一个选项是创建一组类（数据访问层），用于管理应用程序的所有数据访问逻辑（例如，使用 CRUD 范例）。为检查这两种可能性，我们首先从基于 Northwind 数据库的订单输入应用程序示例入手，然后插入和检索不同数据源中的信息。

　　数据提供程序基本接口标识应用程序与数据源进行交互通常所需的典型行为：

　　• 定义连接字符串。

　　• 打开和关闭与数据源的物理连接。

　　• 定义命令和相关参数。

　　• 执行可以创建的不同种类的命令。

　　• 返回一组数据。

　　• 返回标量值。

　　• 对数据执行操作但不返回任何内容。

　　• 对返回的数据集提供只向前型访问和只读型访问。

　　• 定义使数据集与数据源（数据适配器）的内容保持同步所需的一组操作。

　　但事实上，如果将检索、插入、更新和删除不同数据源（使用不同的数据提供程序）中的信息所需的各种操作封装在数据访问层中，并且只公开基本接口的成员，则可以实现第一级抽象-至少从数据提供程序的角度来看是这样。让我们看一看以下演示该设计思想的代码：using System;

using System.Data;
using System.Data.Common;
using System.Data.SqlClient;
using System.Data.OleDb;
using System.Data.OracleClient;
namespace DAL
{
　 public enum DatabaseType
　 {
　　　Access,
　　　SQLServer,
　　　Oracle
　　　// 任何其他数据源类型
　 }
　 public enum ParameterType
　 {
　　　Integer,
　　　Char,
　　　VarChar
　　　// 定义公用参数类型集
　 }
　 public class DataFactory
　 {
　　　private DataFactory(){}
　　　public static IDbConnection CreateConnection
　　　　 (string ConnectionString,
　　　　 DatabaseType dbtype)
　　　{
　　　　 IDbConnection cnn;
　　　　 switch(dbtype)
　　　　 {
　　　　　　case DatabaseType.Access:
　　　　　　　 cnn = new OleDbConnection
　　　　　　　　　(ConnectionString);
　　　　　　　 break;
　　　　　　case DatabaseType.SQLServer:
　　　　　　　 cnn = new SqlConnection
　　　　　　　　　(ConnectionString);
　　　　　　　 break;
　　　　　　case DatabaseType.Oracle:
　　　　　　　 cnn = new OracleConnection
　　　　　　　　　(ConnectionString);
　　　　　　　 break;
　　　　　　default:
　　　　　　　 cnn = new SqlConnection
　　　　　　　　　(ConnectionString);
　　　　　　　 break;　　　　　　　
　　　　 }
　　　　 return cnn;
　　　}
　　　public static IDbCommand CreateCommand
　　　　 (string CommandText, DatabaseType dbtype,
　　　　 IDbConnection cnn)
　　　{
　　　　 IDbCommand cmd;
　　　　 switch(dbtype)
　　　　 {
　　　　　　case DatabaseType.Access:
　　　　　　　 cmd = new OleDbCommand
　　　　　　　　　(CommandText,
　　　　　　　　　(OleDbConnection)cnn);
　　　　　　　 break;
　　　　　　case DatabaseType.SQLServer:
　　　　　　　 cmd = new SqlCommand
　　　　　　　　　(CommandText,
　　　　　　　　　(SqlConnection)cnn);
　　　　　　　 break;
　　　　　　case DatabaseType.Oracle:
　　　　　　　 cmd = new OracleCommand
　　　　　　　　　(CommandText,
　　　　　　　　　(OracleConnection)cnn);
　　　　　　　 break;
　　　　　　default:
　　　　　　　 cmd = new SqlCommand
　　　　　　　　　(CommandText,
　　　　　　　　　(SqlConnection)cnn);
　　　　　　　 break;
　　　　 }
　　　　 return cmd;
　　　}
　　　public static DbDataAdapter CreateAdapter
　　　　 (IDbCommand cmd, DatabaseType dbtype)
　　　{
　　　　 DbDataAdapter da;
　　　　 switch(dbtype)
　　　　 {
　　　　　　case DatabaseType.Access:
　　　　　　　 da = new OleDbDataAdapter
　　　　　　　　　((OleDbCommand)cmd);
　　　　　　　 break;
　　　　　　case DatabaseType.SQLServer:
　　　　　　　 da = new SqlDataAdapter
　　　　　　　　　((SqlCommand)cmd);
　　　　　　　 break;
　　　　　　case DatabaseType.Oracle:
　　　　　　　 da = new OracleDataAdapter
　　　　　　　　　((OracleCommand)cmd);
　　　　　　　 break;
　　　　　　default:
　　　　　　　 da = new SqlDataAdapter
　　　　　　　　　((SqlCommand)cmd);
　　　　　　　 break;
　　　　 }
　　　　 return da;
　　　}
　 }
}

　　该类的作用是向应用程序的较高级别隐藏与创建特定类型（来自特定的数据提供程序）的实例有关的细节，应用程序现在可以使用通过基本接口公开的一般行为与数据源进行交互。

　　让我们了解一下如何从应用程序的其他部分使用该类：

using System;
using System.Data;
using System.Data.Common;
using System.Configuration;　　
namespace DAL
{
　 public class CustomersData
　 {
　　　public DataTable GetCustomers()
　　　{
　　　　 string ConnectionString =
　　　　　　ConfigurationSettings.AppSettings
　　　　　　["ConnectionString"];
　　　　 DatabaseType dbtype =
　　　　　　(DatabaseType)Enum.Parse
　　　　　　(typeof(DatabaseType),
　　　　　　ConfigurationSettings.AppSettings
　　　　　　["DatabaseType"]);
　　　　 IDbConnection cnn =
　　　　　　DataFactory.CreateConnection
　　　　　　(ConnectionString,dbtype);
　　　　 string cmdString = "SELECT CustomerID" +
　　　　　　",CompanyName,ContactName FROM Customers";
　　　　 IDbCommand cmd =
　　　　　　DataFactory.CreateCommand(
　　　　　　cmdString, dbtype,cnn);
　　　　　　DbDataAdapter da =
　　　　　　　 DataFactory.CreateAdapter(cmd,dbtype);
　　　　 DataTable dt = new DataTable("Customers");
　　　　 da.Fill(dt);
　　　　 return dt;
　　　}
　　　　
　　　public CustomersDS GetCustomerOrders(string CustomerID)
　　　{
　　　　 // 待定
　　　　 return null;
　　　}
　　　public CustomersList GetCustomersByCountry
　　　　 (string CountryCode)
　　　{
　　　　 // 待定
　　　　 return null;
　　　}
　　　public bool InsertCustomer()
　　　{
　　　　 // 待定
　　　　 return false;
　　　}
　 }
}

　　在 CustomerData 类的 GetCustomers() 方法中，我们可以看到通过读取配置文件中的信息。可以使用 DataFactory 类通过特定连接字符串创建 XxxConnection 实例，并编写与基本数据源没有特定依赖性的其余代码部分。

　　与数据层交互的一个业务层类示例看起来可能类似下面这样：using System;

using System.Data;
using DAL;
namespace BLL
{
　　public class Customers
　　{
　　　　public DataTable GetAllCustomers()
　　　　{
　　　　　　CustomersData cd = new CustomersData();　
　　　　　　DataTable dt = cd.GetCustomers();
　　　　　　return dt;
　　　　}
　　　　public DataSet GetCustomerOrders()
　　　　{
　　　　　　// 待定
　　　　　　return null;
　　　　}
　　}
}

　　这样看来，此方法出现什么问题了？此处的问题是，只有一个重要细节将代码绑定到特定数据源：命令字符串的 SQL 语法！实际上，如果以这种方式编写应用程序，则使其具有可移植性的唯一办法是采用可以由任何数据源解释的基本 SQL 语法，但这样可能会失去从特定数据源的特定功能获得好处的机会。如果应用程序只对数据进行很简单和很标准的操作，并且如果您不希望使用特定数据源中的高级功能（如 XML 支持），这可能是个小问题。但通常此方法将导致性能降低，因为您无法使用每个数据源的最佳特性。

　　编写专门的数据访问层

　　因此，只使用基本接口不足以通过不同数据源提供可接受级别的抽象。这种情况下，一个好的解决方案是提高此抽象的级别，即创建一组类（如 Customer、Order 等）来封装特定数据提供程序的使用，并通过与特定数据源、类型化的“数据集”、对象集合等无关的数据结构与应用程序的其他级别交换信息。

　　可以在特定程序集内部创建此层的专用类（为每个受支持的数据源分别创建一个专用类），并可以在需要的情况下按照配置文件中的说明从应用程序加载它们。这样，如果您希望向应用程序中添加全新的数据源，唯一要做的事情是针对一组通用接口组中定义的“合同”实现一组新类。

　　让我们看一个实际例子：如果希望将 Microsoft® SQL Server™ 和 Microsoft® Access 作为数据源为其提供支持，则应该在 Microsoft® Visual Studio® .NET 中创建两个不同项目，每个数据源分别创建一个。

　　为 SQL Server 创建的项目将类似于如下所示：

using System;
using System.Data;
using System.Data.Common;
using System.Data.SqlClient;　
using System.Configuration;　　
using Common;
namespace DAL
{
　 public class CustomersData : IDbCustomers
　 {
　　　public DataTable GetCustomers()
　　　{
　　　　 string ConnectionString =
　　　　　　ConfigurationSettings.AppSettings
　　　　　　["ConnectionString"];
　　　　 using (SqlConnection cnn = new SqlConnection
　　　　　　　　　(ConnectionString))
　　　　 {
　　　　　　string cmdString = "SELECT CustomerID," +
　　　　　　　 "CompanyName,ContactName " +
　　　　　　　 "FROM Customers";
　　　　　　SqlCommand cmd =
　　　　　　　 new SqlCommand (cmdString, cnn);
　　　　　　SqlDataAdapter da = new SqlDataAdapter(cmd);
　　　　　　DataTable dt = new DataTable("Customers");
　　　　　　da.Fill(dt);
　　　　　　return dt;
　　　　 }
　　　}
　　　public DataTable GetCustomerOrders(string CustomerID)
　　　{
　　　　 // 待定
　　　　 return null;
　　　}
　　　public DataTable GetCustomersByCountry
　　　　 (string CountryCode)
　　　{
　　　　 // 待定
　　　　 return null;
　　　}
　　　public bool InsertCustomer()
　　　{
　　　　 // 待定
　　　　 return false;
　　　}
　 }
}

　　从 Microsoft® Access 进行数据检索的代码类似于如下所示：using System;

using System.Data;
using System.Data.Common;
using System.Data.OleDb;　
using System.Configuration;　　
using Common;
namespace DAL
{
　 public class CustomersData : IDbCustomers
　 {
　　　public DataTable GetCustomers()
　　　{
　　　　 string ConnectionString =
　　　　　　ConfigurationSettings.AppSettings
　　　　　　["ConnectionString"];
　　　　 using (OleDbConnection cnn = new OleDbConnection
　　　　　　　　　(ConnectionString))
　　　　 {
　　　　　　string cmdString = "SELECT CustomerID," +
　　　　　　　 "CompanyName,ContactName " +
　　　　　　　 "FROM Customers";
　　　　　　OleDbCommand cmd =
　　　　　　　 new OleDbCommand (cmdString, cnn);
　　　　　　OleDbDataAdapter da = new
　　　　　　　 OleDbDataAdapter(cmd);
　　　　　　DataTable dt = new DataTable("Customers");
　　　　　　da.Fill(dt);
　　　　　　return dt;
　　　　 }
　　　}
　　　public DataTable GetCustomerOrders(string CustomerID)
　　　{
　　　　 // 待定
　　　　 return null;
　　　}
　　　public DataTable GetCustomersByCountry
　　　　 (string CountryCode)
　　　{
　　　　 // 待定
　　　　 return null;
　　　}
　　　public bool InsertCustomer()
　　　{
　　　　 // 待定
　　　　 return false;
　　　}
　 }
}

　　CustomersData 类实现 IdbCustomers 接口。需要支持新数据源时，只能创建一个实现该接口的新类。

　　此类型的接口可以类似于如下所示：

using System;
using System.Data;
namespace Common
{
　　public interface IDbCustomers
　　{
　　　　DataTable GetCustomers();
　　　　DataTable GetCustomerOrders(string CustomerID);
　　　　DataTable GetCustomersByCountry(string CountryCode);
　　　　bool InsertCustomer();
　　}