数据访问层
在应用程序的设计中,数据库的访问是非常重要的,我们通常需要将对数据库的访问集中起来,以保证良好的封装性和可维护性。在.Net中,数据库的访问,对于微软自家的SqlServer和其他数据库(支持OleDb),采用不同的访问方法,这些类分别分布于System.Data.SqlClient和System.Data.OleDb名称空间中。微软后来又推出了专门用于访问Oracle数据库的类库。我们希望在编写应用系统的时候,不因这么多类的不同而受到影响,能够尽量做到数据库无关,当后台数据库发生变更的时候,不需要更改客户端的代码。
有的时候,为了性能和其他原因,我们也希望提供对数据库访问的缓存,特别是数据库连接的缓存。虽然微软给我们内置了数据库缓存,但是,自己控制缓存,无疑可以提供更大的灵活性和效率。
public class BaseDataAccess : IDisposable
{
/// 数据适配器
private SqlDataAdapter dsAdapter;
/// 数据更新事务句柄
SqlTransaction dsTransaction;
private SqlCommand selectCommand;
private SqlCommand updateCommand;
private SqlCommand insertCommand;
private SqlCommand deleteCommand;
// 数据库连接
private SqlConnection dbConnection;
private DBConfigration dbConfigration = new DBConfigration();
public BaseDataAccess()
{
/// 创建数据适配器对象“OldDbDataAdapter”
dsAdapter = new SqlDataAdapter();
/// 获取数据操纵连接
dbConnection = new SqlConnection(DBConfigration.BitSoftConnectionString);
}
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(true);
}
protected virtual void Dispose(bool disposing)
{
if (! disposing)
return;
if (dsAdapter != null )
{
if (dsAdapter.SelectCommand != null)
{
if( dsAdapter.SelectCommand.Connection != null)
dsAdapter.SelectCommand.Connection.Dispose();
dsAdapter.SelectCommand.Dispose();
}
dsAdapter.Dispose();
dsAdapter = null;
}
}
/// <summary>
/// 检查传入的单个数据表单(DataTable)字段域,自动获得该数据表单的“Update”命令。
/// </summary>
/// <param name="DataTable">单个数据表单</param>
/// <returns>SqlCommand</returns>
private SqlCommand GetUpdateByIdCommand(DataTable oneTable)
{
string sqlFirst = " UPDATE ";
string sqlSecond = " WHERE ";
sqlFirst = sqlFirst + oneTable.TableName + " SET ";
/// 创建 SqlCommand 对象
if ( updateCommand == null )
{
updateCommand = new SqlCommand(sqlFirst, dbConnection);
}
/// Update 语句的参数表集合
SqlParameterCollection updateParams = updateCommand.Parameters;
updateCommand.Parameters.Clear();
/// 遍历 DataTable 字段,生成 SQL UPDATE 语句
bool isFirstColumn = true;
bool isFirstKeyColumn = true;
foreach (BaseDataColumn dc in oneTable.Columns)
{
/// 忽略无用字段
if ( dc.IsValidColumn() )
{
/// 获取关键字字段
if ( dc.IsKeyColumn() )
{
if ( isFirstKeyColumn )
{
sqlSecond = sqlSecond + dc.ColumnName + " = @"+dc.ColumnName;
isFirstKeyColumn = false;
}
else
sqlSecond = sqlSecond + " AND " + dc.ColumnName + " = @"+dc.ColumnName;
}
else
{