在应用程序的设计中数据库的访问是非常重要的我们通常需要将对数据库的访问集中起来以保证良好的封装性和可维护性在Net中数据库的访问对于微软自家的SqlServer和其他数据库（支持OleDb）采用不同的访问方法这些类分别分布于SystemDataSqlClient和SystemDataOleDb名称空间中微软后来又推出了专门用于访问Oracle数据库的类库我们希望在编写应用系统的时候不因这么多类的不同而受到影响能够尽量做到数据库无关当后台数据库发生变更的时候不需要更改客户端的代码
有的时候为了性能和其他原因我们也希望提供对数据库访问的缓存特别是数据库连接的缓存虽然微软给我们内置了数据库缓存但是自己控制缓存无疑可以提供更大的灵活性和效率
这就需要我们在实际开发过程中将这些数据库访问类再作一次封装这里介绍一种在实际应用中得到了非常好的效果的实作策略Factory和Silgleton设计模式是使用的主要方法
我们先来看看Factory的含义定义一个用于创建对象的接口让子类决定实例化哪一个类FactoryMethod使一个类的实例化延迟到其子类我们这里可能会处理对多种数据库的操作因此需要首先定义一个操纵数据库的接口然后根据数据库的不同由类工厂决定实例化哪个类
下面我们首先来定义这个访问接口为了方便说明问题我们为这个类定义了比较少的方法其他的方法是很容易参照添加的同时注意我这里使用了abstractclass来定义这个访问接口而不是interface理由在后面可以看到
public abstract class DBOperator
{
public abstract IDbConnection Connection{get;} //得到数据库连接
public abstract void Open(); //打开数据库连接
public abstract void Close(); //关闭数据库连接
public abstract void BeginTrans(); //开始一个事务
public abstract void CommitTrans(); //提交一个事务
public abstract void RollbackTrans(); //回滚一个事务
public abstract void exeSql(string strSqlstring[] strParamsobject[] objValues);
//执行Sql语句没有返回值
public abstract DataSet exeSqlForDataSet(string QueryString);//执行Sql返回DataSet
}
然后我们分别为Sql Server和OleDb数据库编写两个数据访问的具体实现类
Sql Server的数据库访问类
internal class SqlDBOperator: DBOperator
{
private SqlConnection conn; //数据库连接
private SqlTransaction trans; //事务处理类
private bool inTransaction=false; //指示当前是否正处于事务中
public override IDbConnection Connection
{
get{return nn;}
}
public SqlDBOperator(string strConnection)
{
nn= new SqlConnection(strConnection);
}
public override void Open()
{
if(connStateToString()ToUpper()!=OPEN)
nnOpen();
}
public override void Close()
{
if (connStateToString()ToUpper()==OPEN)
nnClose();
}
public override void BeginTrans()
{
trans=connBeginTransaction() ;
inTransaction=true;
}
public override void CommitTrans()
{
transCommit();
inTransaction=false;
}
public override void RollbackTrans()
{
transRollback();
inTransaction=false;
}
public override void exeSql(string strSqlstring[] strParamsobject[] strValues)
{
SqlCommand cmd=new SqlCommand();
cmdConnection=nn ;
if(inTransaction)
cmdTransaction=trans;
if((strParams!=null)&&(strParamsLength!=strValuesLength) )
throw new ParamValueNotMatchException(查询参数和值不对应!);
cmdCommandText=strSql;
if(strParams!=null)
{
for(int i=;i cmd.Parameters.Add(strParams[i],strValues[i]);}
cmd.ExecuteNonQuery();
}
public override DataSet exeSqlForDataSet(string QueryString)
{
SqlCommand cmd=new SqlCommand();
cmd.Connection=nn ;
if(inTransaction)
cmd.Transaction=trans;
DataSet ds = new DataSet();
SqlDataAdapter ad = new SqlDataAdapter();
cmd.CommandText=QueryString;
ad.SelectCommand =cmd;
ad.Fill(ds);
return ds;
}
}
OleDb数据库操作的类同Sql Server数据库操作的类非常相似，只是把相应的Sql类替换成OleDb类。tW.wINgWIt.cOM需要注意的是，因为OleDb和SqlServer的参数传递方式不一致，所以，这里需要做一点小小的转换，将"@参数名"类型的参数转换成"？"，这个细节希望读者能够注意到。代码如下：
internal class OleDBOperator : DBOperator
{
private OleDbConnection conn;
private OleDbTransaction trans;
private bool inTransaction=false;
public OleDBOperator(string strConnection)
{
nn= new OleDbConnection(strConnection);
}
public override IDbConnection Connection
{
get{return nn;}
}
public override void Open()
{
if(conn.State.ToString().ToUpper()!="OPEN")
nn.Open();
}
public override void Close()
{
if (conn.State.ToString().ToUpper()=="OPEN")
nn.Close();
}
public override void BeginTrans()
{
trans=conn.BeginTransaction() ;
inTransaction=true;
}
public override void CommitTrans()
{
trans.Commit();
inTransaction=false;
}
public override void RollbackTrans()
{
trans.Rollback();
inTransaction=false;
}
public override void exeSql(string strSql,string[] strParams,object[] strValues)
{
OleDbCommand cmd=new OleDbCommand();
cmd.Connection=nn ;
if(inTransaction)
cmd.Transaction=trans;
if((strParams!=null)&&(strParams.Length!=strValues.Length) )
throw new ParamValueNotMatchException("查询参数和值不对应!");
cmd.CommandText=this.ChangeQueryString(strSql);
if(strParams!=null)
{
for(int i=0;i cmd.Parameters.Add(strParams[i],strValues[i]);}
cmd.ExecuteNonQuery();
}
public override DataSet exeSqlForDataSet(string QueryString)
{
OleDbCommand cmd=new OleDbCommand();
cmd.Connection=nn ;
if(inTransaction)
cmd.Transaction=trans;
DataSet ds = new DataSet();
OleDbDataAdapter ad = new OleDbDataAdapter();
cmd.CommandText=QueryString;
ad.SelectCommand =cmd;
ad.Fill(ds);
return ds;
}
}
现在我们已经完成了所要的功能，下面，我们需要创建一个Factory类，来实现自动数据库切换的管理。这个类很简单，主要的功能就是根据数据库连接字符串，判断使用什么数据库，然后，返回适当的数据库操纵类。在这里，判断的方法很简单，只是根据两种数据库连接字符串的不同来判断。在实际中，随着数据库类的增加，判断的方法可能会有所变化，读者应当根据自己的实际情况来做相应的调整。
public class DBOperatorFactory
{
public static DBOperator GetDBOperator(string strConnection)
{
if(strConnection.IndexOf("provider=")<0) //SqlServer
{
return new SqlDB
