导航

• 首页

• 随机页
• 创建新页
• 所有页面
• 分类

• 系统管理
• 文件管理

• 登录/注销
• 选择语言
• 个人设置
• 创建账户

• Wiki 帮助

• 中国最大的.NET技术门户

专业.NET技术社区

Enterprise Library 3.1中文帮助：数据访问应用程序块

1 - 数据访问应用程序块介绍

• 使用了由 ADO.NET 2.0 提供的功能并与其一起使用，可以同时使用 ADO.NET 和应用程序块的功能。
• 减少编写重复代码完成标准任务的需要。
• 有助于维护一致的数据访问实践，无论是在应用程序内部还是企业间。
• 减少了变更数据库类型的困难。
• 将开发人员从学习用于不同数据库的不同编程模型中解放出来。
• 减少了在开发人员移植应用程序到另一种数据库时不得不编写的代码的数量。

• 创建一个 database 对象。
• 提供用于命令的参数，如果需要的话。
• 调用适当的方法，这些方法已经过性能优化，并且是可移植的。

Database db = DatabaseFactory.CreateDatabase();

DbCommand dbCommand = db.GetStoredProcCommand("GetProductsByCategory");

// Retrieve products from category 7.
db.AddInParameter(dbCommand, "CategoryID", DbType.Int32, 7);

DataSet productDataSet = db.ExecuteDataSet(dbCommand); 

Dim db As Database = DatabaseFactory.CreateDatabase()

Dim dbCommand As DbCommand = db.GetStoredProcCommand("GetProductsByCategory")

' Retrieve products from the category 7.
db.AddInParameter(dbCommand, "CategoryID", DbType.Int32, 7)

Dim productDataSet As DataSet = = db.ExecuteDataSet(dbCommand)

• Microsoft Visual Studio 2005 开发系统 (下列任何版本):
  • Visual Studio 2005 专业版
  • Visual Studio 2005 团队系统版
  • Visual Studio 2005 标准版
• .NET Framework version 2.0
• Microsoft SQL Server, Microsoft SQL Server CE 或者 Oracle 数据库

• Microsoft Windows XP Professional, Windows Server 2003, 或者 Windows Vista 操作系统
• Microsoft .NET Framework 2.0
• Microsoft Visual Studio 2005 开发系统 (任何下列版本):
  • Microsoft Visual Studio 2005 Standard Edition
  • Microsoft Visual Studio 2005 Professional Edition
  • Microsoft Visual Studio 2005 Team Edition for Software Developers
  • Microsoft Visual Studio 2005 Team Edition for Software Testers
  • Microsoft Visual Studio 2005 Team Edition for Software Architects
  • Microsoft Visual Studio 2005 Team Suite
• 运行受 .NET Framework 2.0 数据提供程序支持数据库的数据库服务器。包含 SQL Server 2000或更新版本，SQL Server CE 和 Oracle 9i 或更新版本。运行服务器也可以运行受用于 OLE DB 或 ODBC 的 .NET Framework 2.0 数据提供程序支持的数据库。

• 内核库功能。Enterprise Library 内核提供了服务，如度量和配置，是一个所有 Enterprise Library 应用程序块的共享依赖。内核库功能包含在程序集 Microsoft.Practices.EnterpriseLibrary.Common.dll 中。
• ObjectBuilder 子系统。ObjectBuilder 子系统完成所有重复且必要的和销毁对象实例的任务，同时提供了高度的灵活性。Enterprise Library 将 ObjectBuilder 子系统用于如注入配置到程序块的类中以及连接度量类到应用程序块这样的任务。ObjectBuilder 子系统包含在程序集 Microsoft.Practices.ObjectBuilder.dll 中。

• 使用数据访问应用程序块开发应用程序。此节被分割成了几个子章节。输入配置信息描述了如何配置应用程序块。添加应用程序代码描述了如何为使用数据访问应用程序块来准备应用程序。下一小节，关键场景，示例了如何使用应用程序块完成绝大多数典型的数据访问操作。最后一小节，开发任务细节，包括关于创建 database 对象、创建 command 、处理参数和处理异常的深度信息。
• 数据访问应用程序块的设计。此节描述了设计应用程序块及相关的决定。
• 扩展和修改数据访问应用程序块。此节描述了如何通过添加自己的数据库提供程序来扩展应用程序及给出了修改源代码的建议。
• 部署和操作。此节描述子如何部署和更新应用程序块程序集，还包括关于配置和 SQL Server 安全的信息。
• 快速入门。此节描述了如何安装和配置快速入门应用程序，还包括了一系列的示范了如何添加普通数据访问操作到应用程序中的漫游。

• Application Architecture for .NET: Designing Applications and Services
• .NET Data Access Architecture Guide
• INFO: Microsoft Guide for Designing Data Tier Components and Passing Data Through Tiers
• Improving Web Application Security: Threats and Countermeasures
• Improving .NET Application Performance and Scalability

1.1 - 场景和目标

• 使用 DataReader 获取多行数据
• 使用 DataSet 获取多行数据
• 运行一个命令并获取输出参数
• 运行一个命令并获取单值项
• 在一个事务中执行多个操作
• 从 SQL Server 中获取 XML 数据
• 使用包含在 DataSet 对象中的数据更新数据库

2 - 用数据访问应用程序块开发应用程序

2.1 - 输入配置信息

1. 打开配置文件。更多信息，请参数配置应用程序块。
2. 右单击Application Configuration，指向 New ，然后单击 Data Access Application Block。

1. 在右面板中，展开 DefaultDatabase 属性。
2. 为 DefaultDatabase 属性输入连接字符串的名称或者从下拉列表中选择它。默认的连接字符串名称是 ConnectionString 。
3. (可选的)输入一个新的名称来设计 Name 属性，默认名称是 ConnectionString。
4. 在 ProviderName 属性节，如果愿意，可能修改提供程序的名称。输入提供程序的名称或者从下拉列表中选择它。提供程序的默认名称是 System.Data.SqlClient 。ProviderName 属性必须是一个在 DBProviderFactory 类中指定的提供程序的名称。

Database=Database;Server=(local)\SQLEXPRESS;Integrated Security=SSPI;

1. 单击 ConnectionString 节点。
2. (可选的)输入一个新的名称以设置 Name 属性，这是 ConnectionString 节点的名称。默认的名称是 ConnectionString 。
3. (可选的)在 ProviderName 属性节，修改提供程序的名称。输入提供程序的名称或者从下拉列表中选择它。默认的提供程序的名称是 System.Data.SqlClient 。ProviderName 属性必须是一个指定在 DbProviderFactory 类中的提供程序的名称。
4. 用下列值更新 ConnectionString 属性。

Database=Database;Server=(local)\SQLEXPRESS;Integrated Security=SSPI

1. 右单击 Custom Provider Mappings，指向 New ，然后单击 Provider Mapping 。
2. 在属性面板中单击 TypeName 属性。单击省略号(...)按钮。
3. 在 Type Selector 中，找到并双击 SqlCeDatabase 。
4. 在 ConnectionStrings 节点上右单击并单击 New ，然后单击 Connection String 。
5. (可选的)输入新的名称以设置 Name 属性。这是 ConnectionString 节点的名称。默认的名称是 ConnectionString 。
6. 在 ProviderName 属性节，修改提供程序的名称为 Microsoft.SqlServerCe.Client 。
7. 在 ConnectionString 属性节，输入理想的 SQL Server CE 连接字符串，例如：

Data Source='C:\MyApp\MyDatabase.sdf'

1. 右单击 ConnectionString ，指向 New ，然后单击 OraclePackages 。
2. 单击 OraclePackage 。
3. 输入 Oracle 包的名称以修改 Name 属性。默认为 OraclePackage 。
4. 输入 Prefix 属性的值。

1. 右单击 CustomProviderMappings 节点，指向 New ，然后单击 ProviderMapping 。
2. (可选的)输入新的名称以设置 Name 属性。输入提供程序的名称或从下拉列表中选择。默认的提供程序是 System.Data.SqlClient 。ProviderName 属性必须是一个在 DbProviderFactory 类中指定的提供程序名称。
3. 在 TypeName 属性节中。单击省略号按钮(...)并使用'Type Selector 选择 Enterprise Library 数据库类型的全名称。

• 在使用配置控制台打开已存在的包含数据访问应用程序块的应用程序配置文件时，它会显示存储于 Machine.config 文件中的连接字符串。虽然配置控制台的 GUI 接口允许编辑连接串，配置控制台无法修改 Machine.config 文件，而且所做的修改也不会起作用。配置控制台仅保存存储在应用程序配置文件中的连接字符串的修改。
• 配置文件是不加密的。配置文件可能包含关于连接字符串、用户标识、密码、数据库服务器和分类的敏感信息。可以使用加密技术来保护这些信息拒绝未授权的读写操作。关于加密配置文件的信息，请参见配置应用程序块。

2.1.1 - 数据访问应用程序块的源模式

<configSections>
  <section name="dataConfiguration"
   type="Microsoft.Practices.EnterpriseLibrary.Data.Configuration.DatabaseSettings,
   Microsoft.Practices.EnterpriseLibrary.Data, Version=3.1.0.0, Culture=neutral, PublicKeyToken=null" />
  <section name="oracleConnectionSettings" 
  type="Microsoft.Practices.EnterpriseLibrary.Data.Oracle.Configuration.OracleConnectionSettings,
  Microsoft.Practices.EnterpriseLibrary.Data, Version=3.1.0.0, Culture=neutral, PublicKeyToken=null" />
</configSections>

2.2 - 添加应用程序代码

1. 添加到数据访问应用程序块程序集的引用。在 Visual Studio 中，在解决方案管理器中右单击项目节点，然后单击添加引用。单击浏览标签，然后导航到 Microsoft.Practices.EnterpriseLibrary.Data.dll 的位置。选择程序集，然后单击确定以添加引用。
2. 按同样的步骤，添加到 Enterprise Library 内核程序集 Microsoft.Practices.EnterpriseLibrary.Common.dll 和 Microsoft.Practices.ObjectBuilder.dll 的引用。
3. (可选的) 要不带完整的精确的元素引用使用来自加密应用程序块的元素，可以添加下列的 using 语句(C#)或者 Imports 语句(Visual Basic)到源代码文件的顶部。

using Microsoft.Practices.EnterpriseLibrary.Data;
using System.Data;

Imports Microsoft.Practices.EnterpriseLibrary.Data
Imports System.Data

Database db = DatabaseFactory.CreateDatabase();

Dim db As Database = DatabaseFactory.CreateDatabase()

Database db = DatabaseFactory.CreateDatabase("Sales");

Dim db As Database = DatabaseFactory.CreateDatabase("Sales")

// Assume the method GetConnectionString exists in your application and 
// returns a valid connection string.
string myConnectionString = GetConnectionString();

SqlDatabase sqlDatabase = new SqlDatabase(myConnectionString);

' Assume the method GetConnectionString exists in your application and 
' returns a valid connection string.
Dim myConnectionString As String = GetConnectionString()

Dim db As SqlDatabase = New SqlDatabase(myConnectionString)  

• 有可以接受 ADO.NET 2.0 DbCommand 对象的重载。这些重载为每个方法提供了最大的灵活性和控制。
• 有接受存储过程名称和用于存储过程参数值的值集合的重载。这些重载在应用程序调用仅有输入参数的存储过程时比较方便。
• 有接受 System.Data.CommandType 和表示命令的字符串的重载。这些方便的重载在应用程序执行不带参数的内联 SQL 语句或存储过程时使用。
• 最后，以上每个重载都包含一个接受一个事务的重载。这允许在一个已存在的事务中执行方法时使用需要的重载类型。

3 - 开发任务的细节

• 创建一个 Database 对象。
• 使用 GetStoredProcCommand 方法或者 GetSqlStringCommand 方法创建 DbCommand 对象。
• 使用参数。
• 打开和关闭连接。
• 处理异常。

3.1 - 创建 Database 对象的细节

Database dbSvc = DatabaseFactory.CreateDatabase();

Dim dbSvc As Database = DatabaseFactory.CreateDatabase()

// Use a named database instance that refers to an arbitrary database type, 
// which is determined by configuration information.
Database myDb = DatabaseFactory.CreateDatabase("Sales");

' Use a named database instance that refers to an arbitrary database type, 
' which is determined by configuration information.
Dim myDb As Database = DatabaseFactory.CreateDatabase("Sales")

// Create a SQL database.
SqlDatabase dbSQL = DatabaseFactory.CreateDatabase("Sales") as SqlDatabase;

' Create a SQL database.
Dim dbSQL As SqlDatabase = DirectCast(DatabaseFactory.CreateDatabase("Sales"), SqlDatabase)

// Assume your application contains the routine GetConnectionString. 
string myConnectionString = GetConnectionString();

SqlDatabase sqlDatabase = new SqlDatabase(myConnectionString);

' Assume your application contains the routine GetConnectionString. 
Dim myConnectionString As String = GetConnectionString()

Dim db As SqlDatabase = New SqlDatabase(myConnectionString)  

GenericDatabase db = new GenericDatabase(connectionString, OdbcFactory.Instance);

Dim db As GenericDatabase = New GenericDatabase(connectionstring, OdbcFactory.Instance)  

3.2 - 创建 DbCommand 对象

• 表示存储过程调用的那些方法(例如，GetCustomers)
• 表示 SQL 文本命令的那些方法(例如，Select CustomerID, Fullname From Customers )

• GetStoredProcCommand。此方法用于存储过程命令。
• GetSqlStringCommand。此方法用于 SQL 文本命令。

Database db = DatabaseFactory.CreateDatabase();
string sqlCommand = "Select CustomerID, LastName, FirstName From Customers";
DbCommand dbCommand = db.GetSqlStringCommand(sqlCommand);

Dim db As Database = DatabaseFactory.CreateDatabase()
Dim sqlCommand As String = "Select CustomerID, LastName, FirstName From Customers"
Dim dbCommand As DbCommand = db.GetSqlStringCommand(sqlCommand)

Database db = DatabaseFactory.CreateDatabase();

DbCommand dbCommand = db.GetStoredProcCommand("GetProductsByCategory"); 

Dim db As Database = DatabaseFactory.CreateDatabase()

Dim dbCommand As DbCommand 
dbCommand = db.GetStoredProcCommand("GetProductsByCategory")

3.3 - 管理连接

Database db = DatabaseFactory.CreateDatabase();

string sqlCommand = "Select ProductID, ProductName From Products";
DbCommand dbCommand = db.GetSqlStringCommand(sqlCommand); 

// No need to open the connection; just make the call.
DataSet customerDataSet = db.ExecuteDataSet(dbCommand);

Dim db As Database = DatabaseFactory.CreateDatabase()

Dim sqlCommand As String = "Select ProductID, ProductName From Products"
Dim dbCommand As DbCommand = db.GetSqlStringCommand(sqlCommand)

' No need to open the connection; just make the call.
Dim customerDataSet As DataSet = db.ExecuteDataSet(dbCommand)

Database db = DatabaseFactory.CreateDatabase();

DbCommand dbCommand = db.GetSqlStringCommand("Select Name, Address From Customers");
using (IDataReader dataReader = db.ExecuteReader(dbCommand))
{
// Process results
} 

Dim db As Database = DatabaseFactory.CreateDatabase()

Dim dbCommand As DbCommand = db.GetSqlStringCommand("Select Name, Address From Customers")

Using dataReader As IDataReader = db.ExecuteReader(dbCommand)

  ' Process results

End Using

3.4 - 使用 TransactionScope 类

using (TransactionScope scope = new 
           TransactionScope(TransactionScopeOption.RequiresNew))
{
    int rows = db.ExecuteNonQuery(CommandType.Text, insertString);
    rows = db.ExecuteNonQuery(CommandType.Text, insertString2);
}

3.5 - 创建可移植的数据库应用程序

Database db = DatabaseFactory.CreateDatabase();

object results = new object2;
DbCommand dbCommand = db.GetStoredProcCommand("GetCustomersAndSuppliers", results);

Dim results As Object = New Object(2) {}
Dim dbCommand As DbCommand = db.GetStoredProcCommand("GetCustomersAndSuppliers", results)

• 避免用存储过程参数名使用数据库专用令牌。用于特定提供程序的 Database 派生类包含了调整需要的参数名的代码。例如，在支持到 SQL Server 数据库的存储过程参数名中不要包含 "@" 字符。下列代码展示了如何调用 AddInParameter 方法通过名称 CategoryID 创建参数。当使用 SqlDatabase 对象执行此代码时，提供程序用 "@" 做为参数名的开头。

Database db = DatabaseFactory.CreateDatabase();

DbCommand dbCommand = db.GetStoredProcCommand("GetProductsByCategory");

db.AddInParameter(dbCommand, "CategoryID", DbType.Int32, 100);

Dim db As Database = DatabaseFactory.CreateDatabase()

Dim dbCommand As DbCommand = db. GetStoredProcCommand("GetProductsByCategory")

db.AddInParameter(dbCommand, "CategoryID", DbType.Int32, 100)

• 总是通过 database 对象获取参数值。
• 考虑后端关系数据库管理系统(RDBMS)的大小写敏感。例如，在 SQL Server 2000 中的字符串比较是大小写不敏感的，但是在 Oracle 8i 和 DB2 中是大小写敏感的。要开发一个可移植的应用程序，就必须编写自己的比较逻辑为大小写不敏感的或者强迫应用程序仅为在比较操作中使用的列存储大写或小写。
• 避免使用 RDBMS 专用数据类型，例如 OracleBlob。
• 在执行存储过程时避免使用返回值，而是使用输出参数。
• 在添加参数到参数集合中时，确认在应用程序代码中的顺序与数据库中的顺序相匹配。OLE DB 提供程序使用顺序来执行存储过程而不是名称，所以以正确的顺序添加集合是很重要的。
• 如果在应用程序代码必须使用内联的 SQL ，确认 SQL 语法对于应用程序将运行的数据库类型都是可用的。
• 避免传递 null 值到值类型的存储过程参数。如果需要通过 SQLJ 存储过程使用 DB2 的可移植接口，这些做将可能无法正常工作。

3.6 - 处理异常

• CreateDatabase 方法使用配置信息，其可能的结果在配置相关的异常中。
• Database 方法使用 ADO.NET 和底层数据库提供程序。由 ADO.NET 抛出的异常由数据访问应用程序块为度量的目的而捕获，然后再次抛出。
• 充分处理异常通常要求访问特定的异常类型。可以包含用于特定数据库提供程序的异常如 SqlException 的 catch 语句。然而数据库提供程序专用的异常类型在不同提供程序之间不能移植。
• 使用 CommandBehavior.CloseConnection 调用 ExecuteReader。它在 DataReader 关闭时关闭连接。如果在一个 try 块中使用 ExecuteReader ，可以添加一个 finally 语句并关闭返回的 DataReader 对象，就像展示在下列示例中的一样。

Database db = DatabaseFactory.CreateDatabase();
DbCommand dbCommand = db.GetStoredProcCommand("GetProductsByCategory"); 

IDataReader dataReader = null;

try
{
  //...
  dataReader = db.ExecuteReader(dbCommand);
}
catch(Exception ex)
{
  // Process exception
}
finally
{
  if (dataReader != null)
    dataReader.Close();
}

Dim db As Database = DatabaseFactory.CreateDatabase()
Dim dbCommand As DbCommand = db.GetStoredProcCommand("GetProductsByCategory")

Dim dataReader As IDataReader = Nothing

Try
  ' ...
  dataReader = db.ExecuteReader(dbCommand)
Catch ex As Exception
  ' Process exception
Finally
  If (Not dataReader Is Nothing) Then
    dataReader.Close()
  End If
End Try

Database db = DatabaseFactory.CreateDatabase();
DbCommand dbCommand = db.GetStoredProcCommand("GetProductsByCategory"); 

using (IDataReader dataReader = db.ExecuteReader(dbCommand))
{
    // Process results
}

Dim db As Database = DatabaseFactory.CreateDatabase()
Dim dbCommand As DbCommand = db.GetStoredProcCommand("GetProductsByCategory")

Using dataReader As IDataReader = db.ExecuteReader(dbCommand)

  ' Process results

End Using

3.7 - 处理参数

• AddParameter。此方法传递一个参数(输入或输出)到存储过程。
• AddInParameter。此方法传递输入参数到一个存储过程。
• AddOutParameter。此方法添加了一个输出参数到存储过程。
• GetParameterValue。此方法查找指定的参数的值。
• SetParameterValue。此方法在使用同样的连接和命令，但有不同的参数值时进行多个插入时设置指定参数的值。

Database db = DatabaseFactory.CreateDatabase();
string sqlCommand = "GetProductDetails";
DbCommand dbCommand = db.GetStoredProcCommand(sqlCommand);

db.AddInParameter(dbCommand, "ProductID", DbType.Int32, 5);
db.AddOutParameter(dbCommand, "ProductName", DbType.String, 50);
db.AddOutParameter(dbCommand, "UnitPrice", DbType.Currency, 8);

Dim db As Database = DatabaseFactory.CreateDatabase()
Dim sqlCommand As String = "GetProductDetails"
Dim dbCommand As DbCommand = db.GetStoredProcCommand(sqlCommand)

db.AddInParameter(dbCommand, "ProductID", DbType.Int32, 5)
db.AddOutParameter(dbCommand, "ProductName", DbType.String, 50)
db.AddOutParameter(dbCommand, "UnitPrice", DbType.Currency, 8)

Database db = DatabaseFactory.CreateDatabase();
string sqlCommand = "GetProductDetails";
DbCommand dbCommand = db.GetStoredProcCommand(sqlCommand);

db.AddInParameter(dbCommand, "@ProductID", DbType.Int32, 5);
db.AddOutParameter(dbCommand, "@ProductName", DbType.String, 50);
db.AddOutParameter(dbCommand, "@UnitPrice", DbType.Currency, 8);

Dim sqlCommand As String = "GetProductDetails"
Dim dbCommand As DbCommand = db.GetStoredProcCommand(sqlCommand)

db.AddInParameter(dbCommand, "@ProductID", DbType.Int32, 5)
db.AddOutParameter(dbCommand, "@ProductName", DbType.String, 50)
db.AddOutParameter(dbCommand, "@UnitPrice", DbType.Currency, 8)

Database db = DatabaseFactory.CreateDatabase();

DbCommand insertCommand = db.GetStoredProcCommand("AddProduct");
db.AddInParameter(insertCommand, "ProductName", DbType.String, "ProductName", DataRowVersion.Current);
db.AddInParameter(insertCommand, "CategoryID", DbType.Int32, "CategoryID", DataRowVersion.Current);
db.AddInParameter(insertCommand, "UnitPrice", DbType.Currency, "UnitPrice", DataRowVersion.Current);

Dim db As Database = DatabaseFactory.CreateDatabase()
Dim insertCommand As DbCommand = db.GetStoredProcCommand("AddProduct")
db.AddInParameter(insertCommand, "ProductName", DbType.String, "ProductName", DataRowVersion.Current)
db.AddInParameter(insertCommand, "CategoryID", DbType.Int32, "CategoryID", DataRowVersion.Current)
db.AddInParameter(insertCommand, "UnitPrice", DbType.Currency, "UnitPrice", DataRowVersion.Current)

Database db = DatabaseFactory.CreateDatabase();
string sqlCommand = "UpdateProduct";
DbCommand dbCommand = db.GetStoredProcCommand(sqlCommand, 11, "Queso Cabrales", 4, 25);

Dim db As Database = DatabaseFactory.CreateDatabase()
Dim sqlCommand As string = "UpdateProduct"
Dim dbCommand As DbCommand = db.GetStoredProcCommand(sqlCommand, 11, "Queso Cabrales", 4, 25)

4 - 关键场景

• 使用 DbDataReader 获取多行数据。此场景示范了如何能使用 ExecuteReader 方法从数据库中获取多行数据以用表格的形式显示，没有显式的缓存数据，使用 DataSet 对象来操作它，或者将它传递给应用程序中的其他组件。换句话说，它示范了如何尽快的显示结果。
• 使用 DataSet 来获取多行数据。此场景示范了如何能使用 ExecuteDataSet 方法在组件和多层应用程序层之间传递数据。数据以一个或多个数据表组件，以及可选的将数据链接在一起的关系。
• 执行一个命令并访问输出参数。此场景示范了如何使用 ExecuteNonQuery 方法来获取包含多个列值的单行数据。
• 执行一个命令并访问单项结果。此场景示范了如何使用 ExecuteScalar 方法来完成单项查询。
• 在一个事务中完成多个更新。此场景示范了如何在一个事务中使用 ExecuteNonQuery 中完成对一个数据库的多个操作，它本质上是所有操作要么全部成功，要么全部不成功。
• 使用 DataSet 更新数据库。此场景示范了如何在修改 DataSet 对象后，可以使用 UpdateDataSet 方法来更新数据库，以使修改持久保存。
• 获取多行数据为 XML 。此场景示范了如何使用 ExecuteXmlReader 方法从 SQL Server 中获取数据，并得到以 XML 格式返回的数据。

• .NET Data Access Architecture Guide
• INFO: Microsoft Guide for Designing Data Tier Components and Passing Data Through Tiers
• Improving .NET Application Performance and Scalability

4.1 - 使用 DbDataReader 获取多行数据

• 为只读的目的获取数据，这在大多数情况下是要显示数据。
• 绑定到 Web Form 控件以显示。
• 不需要要缓存数据。在使用后，数据将被销毁。

Database db = DatabaseFactory.CreateDatabase();

using (IDataReader dataReader = db.ExecuteReader(CommandType.Text, "Select Name, Address, City From Customers" ))
{
  customerGrid.DataSource = dataReader;
  customerGrid.DataBind();
}

Dim db As Database = DatabaseFactory.CreateDatabase()

Using dataReader As IDataReader = db.ExecuteReader(CommandType.Text, "Select Name, Address, City From Customers")

  customerGrid.DataSource = dataReader
  customerGrid.DataBind()

End Using

4.2 - 使用 DataSet 获取多行数据

• 要获取多个表或者从不同的数据源中获取表。
• 要与其他应用程序或者组件如 XML Web 服务交换数据。
• 不得不完成对从数据库中获取的每个记录的昂贵处理。如果使用数据命令和数据读取器，在读取时处理每条记录，会导致连接长时间打开，然后会影响应用程序的性能和可扩展性。
• 为数据处理访问相互依赖的记录（例如，在相关记录中查找信息）。
• 要完成 XML 操作，例如在数据上的 XSLT 转换。

Database db = DatabaseFactory.CreateDatabase();

string sqlCommand = "GetProductsByCategory";
DbCommand dbCommand = db.GetStoredProcCommand(sqlCommand);

// Retrieve products from category 7.
int category = 7;
db.AddInParameter(dbCommand, "CategoryID", DbType.Int32, category);

DataSet productDataSet = db.ExecuteDataSet(dbCommand); 

Dim db As Database = DatabaseFactory.CreateDatabase()

Dim sqlCommand As String = "GetProductsByCategory"
Dim dbCommand As DbCommand = db.GetStoredProcCommand(sqlCommand)

' Retrieve products from the category 7.
Dim category As Integer = 7
db.AddInParameter(dbCommand, "CategoryID", DbType.Int32, category)

' DataSet that will hold the returned results
Dim customerproductDataSet As DataSet = Nothing

customerproductDataSet = db.ExecuteDataSet(dbCommand)

• 数据访问应用程序块用用于所包含的 DataTable 对象的默认名称生成 DataSet 对象，例如，Table、Table1 和 Table2。
• 如果要重新使用已存在的 DataSet 而不是新创建一个来保持查询的结果，可以使用 Database 类的 LoadDataSet 方法。

4.3 - 执行一个 Command 并访问输出参数

Database db = DatabaseFactory.CreateDatabase();

string sqlCommand = "GetProductDetails";
DbCommand dbCommand = db.GetStoredProcCommand(sqlCommand);

db.AddInParameter(dbCommand, "ProductID", DbType.Int32, 3);
db.AddOutParameter(dbCommand, "ProductName", DbType.String, 50);
db.AddOutParameter(dbCommand, "UnitPrice", DbType.Currency, 8);

db.ExecuteNonQuery(dbCommand);

string results = string.Format(CultureInfo.CurrentCulture, "{0}, {1}, {2:C} ",
  db.GetParameterValue(dbCommand, "ProductID"),
  db.GetParameterValue(dbCommand, "ProductName"),
  db.GetParameterValue(dbCommand, "UnitPrice"));

Dim db As Database = DatabaseFactory.CreateDatabase()

Dim sqlCommand As String = "GetProductDetails"
Dim dbCommand As DbCommand = db.GetStoredProcCommand(sqlCommand)

db.AddInParameter(dbCommand, "ProductID", DbType.Int32, 3)
db.AddOutParameter(dbCommand, "ProductName", DbType.String, 50)
db.AddOutParameter(dbCommand, "UnitPrice", DbType.Currency, 8)

db.ExecuteNonQuery(dbCommand)

Dim results As String = String.Format(CultureInfo.CurrentCulture, "{0}, {1}, {2:C} ", _
  db.GetParameterValue(dbCommand, "ProductID"), _
  db.GetParameterValue(dbCommand, "ProductName"), _
  db.GetParameterValue(dbCommand, "UnitPrice"))

• ExecuteNonQuery 方法返回查询所影响的行数(通常是 Insert、Update、或者 Delete 操作)。
• 可以使用 ExecuteNonQuery 方法修改数据库中的数据，而不需要通过执行 Insert、Update 或者 Delete 操作来使用 DataSet。

4.4 - 执行一个 Command 并访问单项结果

Database db = DatabaseFactory.CreateDatabase();

string sqlCommand = "GetProductName";
int productId = 7;
DbCommand dbCommand = db.GetStoredProcCommand(sqlCommand,  productId);

string productName = (string)db.ExecuteScalar(dbCommand);

Dim db As Database = DatabaseFactory.CreateDatabase()

Dim sqlCommand As String = "GetProductName"
Dim productId As Integer = 7
Dim dbCommand As DbCommand = db.GetStoredProcCommand(sqlCommand, productId)

Dim productName As String = DirectCast(db.ExecuteScalar(dbCommand), String) 

• 获取单项数据的另一种方法是使用存储过程的输出参数或返回值，并结合使用 ExecuteNonQuery 方法。这种方法在不同的困难程度上都行之有效。在这种情况下的代码简单的展示在执行命令并访问输出参数的场景中。关于用于查找单个项目的适当方法的选择的更多信息，请参见 .NET Data Access Architecture Guide。

SELECT CAST(@@Identity AS INTEGER)

4.5 - 在一个事务中完成多个更新

public bool Transfer(int transactionAmount, int sourceAccount, int destinationAccount)
{
  bool result = false;

  // Create the database object, using the default database service. The
  // default database service is determined through configuration.
  Database db = DatabaseFactory.CreateDatabase();

  // Two operations, one to credit an account, and one to debit another
  // account.
  string sqlCommand = "CreditAccount";
  DbCommand creditCommand = db.GetStoredProcCommand(sqlCommand);

  db.AddInParameter(creditCommand, "AccountID", DbType.Int32, sourceAccount);
  db.AddInParameter(creditCommand, "Amount", DbType.Int32, transactionAmount);

  sqlCommand = "DebitAccount";
  DbCommand debitCommand = db.GetStoredProcCommand(sqlCommand);

  db.AddInParameter(debitCommand, "AccountID", DbType.Int32, destinationAccount);
  db.AddInParameter(debitCommand, "Amount", DbType.Int32, transactionAmount);

  using (DbConnection connection = db.CreateConnection())
  {
    connection.Open();
    DbTransaction transaction = connection.BeginTransaction();

    try
    {
      // Credit the first account.
      db.ExecuteNonQuery(creditCommand, transaction);
      // Debit the second account.
      db.ExecuteNonQuery(debitCommand, transaction);

      // Commit the transaction.
      transaction.Commit();

      result = true;
    }
    catch
    {
      // Roll back the transaction. 
      transaction.Rollback();
    }
    connection.Close();

    return result;
  }
} 

Public Function Transfer(ByRef transactionAmount As Integer, ByRef sourceAccount As Integer, ByRef destinationAccount As Integer) As Boolean

  Dim result As Boolean = False

  ' Create the database object, using the default database service. The
  ' default database service is determined through configuration.
  Dim db As Database = DatabaseFactory.CreateDatabase()

  ' Two operations, one to credit an account, and one to debit another
  ' account.
  Dim sqlCommand As String = "CreditAccount"
  Dim creditCommand As DbCommand = db.GetStoredProcCommand(sqlCommand)

  db.AddInParameter(creditCommand, "AccountID", DbType.Int32, sourceAccount)
  db.AddInParameter(creditCommand, "Amount", DbType.Int32, transactionAmount)

  sqlCommand = "DebitAccount"
  Dim debitCommand As DbCommand = db.GetStoredProcCommand(sqlCommand)
  db.AddInParameter(debitCommand, "AccountID", DbType.Int32, destinationAccount)
  db.AddInParameter(debitCommand, "Amount", DbType.Int32, transactionAmount)

  Using connection As DbConnection = db.CreateConnection()
    connection.Open()
    Dim transaction As DbTransaction = connection.BeginTransaction()

    Try

      ' Credit the first account.
      db.ExecuteNonQuery(creditCommand, transaction)
      ' Debit the second account.
      db.ExecuteNonQuery(debitCommand, transaction)
      ' Commit the transaction.
      transaction.Commit()

      result = True
    Catch
      ' Roll back the transaction. 
      transaction.Rollback()
    End Try

    connection.Close()
    Return result
  End Using
End Function

4.6 - 使用 DataSet 更新数据库

Database db = DatabaseFactory.CreateDatabase();

DataSet productsDataSet = new DataSet();

string sqlCommand = "Select Select ProductID, ProductName, CategoryID, UnitPrice, LastUpdate From Products";
DbCommand dbCommand = db.GetSqlStringCommand(sqlCommand);

string productsTable = "Products";

// Retrieve the initial data.
db.LoadDataSet(dbCommand, productsDataSet, productsTable);

// Get the table that will be modified.
DataTable table = productsDataSet.Tables[productsTable];

// Add a new product to existing DataSet.
DataRow addedRow = table.Rows.Add(new object[] {DBNull.Value, "New product", 11, 25});

// Modify an existing product.
table.Rows[0]["ProductName"] = "Modified product";

// Establish the Insert, Delete, and Update commands.
DbCommand insertCommand = db.GetStoredProcCommand("AddProduct");
db.AddInParameter(insertCommand, "ProductName", DbType.String, "ProductName", DataRowVersion.Current);
db.AddInParameter(insertCommand, "CategoryID", DbType.Int32, "CategoryID", DataRowVersion.Current);
db.AddInParameter(insertCommand, "UnitPrice", DbType.Currency, "UnitPrice", DataRowVersion.Current);

DbCommand deleteCommand = db.GetStoredProcCommand("DeleteProduct");
db.AddInParameter(deleteCommand , "ProductID", DbType.Int32, "ProductID", DataRowVersion.Current);

DbCommand updateCommand = db.GetStoredProcCommand("UpdateProduct");
db.AddInParameter(updateCommand, "ProductID", DbType.Int32, "ProductID", DataRowVersion.Current);
db.AddInParameter(updateCommand, "ProductName", DbType.String, "ProductName", DataRowVersion.Current);
db.AddInParameter(updateCommand, "LastUpdate", DbType.DateTime, "LastUpdate", DataRowVersion.Current);

// Submit the DataSet, capturing the number of rows that were affected.
int rowsAffected = db.UpdateDataSet(productsDataSet, "Products", insertCommand, updateCommand, deleteCommand, Microsoft.Practices.EnterpriseLibrary.Data.UpdateBehavior.Standard);

Dim db As Database = DatabaseFactory.CreateDatabase()

Dim productsDataSet As DataSet = new DataSet()

Dim sqlCommand As String = "Select Select ProductID, ProductName, CategoryID, UnitPrice, LastUpdate From Products"
Dim dbCommand As DbCommand = db.GetSqlStringCommand(sqlCommand)

Dim productsTable As String = "Products"

' Retrieve the initial data.
db.LoadDataSet(dbCommand, productsDataSet, productsTable)

' Get the table that will be modified.
Dim table As DataTable = productsDataSet.Tables(productsTable)

' Add a new product to existing DataSet.
Dim addedRow As DataRow = table.Rows.Add(New Object() {DBNull.Value, "New product", 11, 25})

' Modify an existing product.
table.Rows(0)("ProductName") = "Modified product"

' Establish the Insert, Delete, and Update commands.
Dim insertCommand As DbCommand = db.GetStoredProcCommand("AddProduct")
db.AddInParameter(insertCommand, "ProductName", DbType.String, "ProductName", DataRowVersion.Current)
db.AddInParameter(insertCommand, "CategoryID", DbType.Int32, "CategoryID", DataRowVersion.Current)
db.AddInParameter(insertCommand, "UnitPrice", DbType.Currency, "UnitPrice", DataRowVersion.Current)

Dim deleteCommand As DbCommand = db.GetStoredProcCommand("DeleteProduct")
db.AddInParameter(deleteCommand, "@ProductID", DbType.Int32, "ProductID", DataRowVersion.Current)

Dim updateCommand As DbCommand = db.GetStoredProcCommand("UpdateProduct")
db.AddInParameter(updateCommand, "ProductID", DbType.Int32, "ProductID", DataRowVersion.Current)
db.AddInParameter(updateCommand, "ProductName", DbType.String, "ProductName", DataRowVersion.Current)
db.AddInParameter(updateCommand, "LastUpdate", DbType.DateTime, "LastUpdate", DataRowVersion.Current)

' Submit the DataSet, capturing the number of rows that were affected.
Dim rowsAffected As Integer = db.UpdateDataSet(productsDataSet, "Products", insertCommand, updateCommand, _
  deleteCommand, Microsoft.Practices.EnterpriseLibrary.Data.UpdateBehavior.Standard)

• Standard。这不会干涉 DataAdapter 对象的 Update 命令。如果 Update 命令遇到一个错误，更新将停止。Datatable 中的其他行将不会受影响。
• Continue。DataAdapter 对象的 Update 命令遇到一个错误，更新将继续。Update 命令将尝试更新余下的行。
• Transactional。如何 DataAdapter 对象遇到一个错误，所有更新的行将回滚。

4.7 - 获取多行 XML 数据

SqlDatabase dbSQL = DatabaseFactory.CreateDatabase("EntLibQuickStartsSql") as SqlDatabase;

// Use "FOR XML AUTO" to have SQL return XML data.
string sqlCommand = "SELECT ProductID, ProductName FROM Products FOR XML AUTO";
DbCommand dbCommand = dbSQL.GetSqlStringCommand(sqlCommand);

XmlReader productsReader = null;
StringBuilder productList = new StringBuilder();

try
{
  productsReader = dbSQL.ExecuteXmlReader(dbCommand);

  // Iterate through the XmlReader and put the data into our results.
  while (!productsReader.EOF)
  {
    if (productsReader.IsStartElement()) 
    {
      productList.Append(productsReader.ReadOuterXml());
      productList.Append(Environment.NewLine);
    }
  }   
}
finally
{
  // Close the Reader.
  if (productsReader != null)
  {
    productsReader.Close();
  }
}

Dim dbSQL As SqlDatabase = DirectCast(DatabaseFactory.CreateDatabase("EntLibQuickStartsSql"), SqlDatabase)

' Use "FOR XML AUTO" to have SQL return XML data.
Dim sqlCommand As String = "SELECT ProductID, ProductName FROM Products FOR XML AUTO"
Dim dbCommand As DbCommand = dbSQL.GetSqlStringCommand(sqlCommand)

Dim productsReader As XmlReader = Nothing
Dim productList As StringBuilder = New StringBuilder()

Try

  productsReader = dbSQL.ExecuteXmlReader(dbCommand)

  ' Iterate through the XmlReader and put the data into our results.
  While (Not productsReader.EOF)
    If (productsReader.IsStartElement()) Then
      productList.Append(productsReader.ReadOuterXml())
      productList.Append(Environment.NewLine)
    End If
  End While

Finally
  ' Close the Reader if there is no active transaction.
  If (Not productsReader Is Nothing And Transaction.Current Is Nothing) Then
    productsReader.Close()
  End If
End Try

5 - 数据访问应用程序块的设计

• 用不同数据库系统工作的简单而有效的方法（请参见用于简单数据访问的设计）
• 开发数据库诊断应用程序的方法（请参见用于数据库诊断应用程序的设计）
• 调整和验证数据库配置设置的简单方法

• 封装用于完成绝大多数普通数据访问任务的逻辑。
• 消除常见代码错误，如错误的关闭连接。
• 减轻开发人员为常见数据访问任务编写重复代码的需要。
• 减少定制代码的需要。
• 为数据访问加入最佳实践，就像在.NET Data Access Architecture Guide中描述的一样。
• 确保应用程序块的功能尽可能的可以与不同的数据库类型一起工作。
• 确保为一种数据库编写的应用程序，在数据访问方面，也同样是为另一种数据库类型编写的应用程序。

图 1 数据访问应用程序块中关键类之间的关系

• 如果客户代码传递在配置文件中的标识连接字符串的数据库实例名称，工厂将使用那个字符串来创建 Database 对象。

• 如果客户代码不传递数据库实例名称，工厂将由配置文件中的默认实例设置标识连接字符串。在 dataConfiguration 配置节中的 defaultDatabase 属性控件了默认实例。下列来自配置文件的 XML 片段展示了与 Production 连接字符串对应的默认实例。

<dataConfiguration defaultDatabase="Production">

5.1 - 用于简化数据访问的设计

• 仅暴露了少量的开发人员需要理解的方法。
• 封装了常见的内部任务。
• 使其易于处理参数。
• 提供了很好的性能。
• 简化数据库对象的创建。

• ExecuteDataSet
• LoadDataSet
• ExecuteReader
• ExecuteScalar
• ExecuteNonQuery
• UpdateDataSet

Database db = DatabaseFactory.CreateDatabase();

DbCommand dbCommand = db.GetStoredProcCommand("GetProductList"); 

DataSet productsDataSet = db.ExecuteDataSet(dbCommand);

Dim db As Database = DatabaseFactory.CreateDatabase()

Dim dbCommand As DbCommand = db.GetStoredProcCommand("GetProductList")

Dim productsDataSet As DataSet = db.ExecuteDataSet(dbCommand)