通用数据库访问类
Factory设计模式
含义：定义一个用于创建对象的接口，让子类决定实例化哪一个类。FactoryMethod使一个类的实例化延迟到其子类。我们这里可能会处理对多种数据库的操作，因此，需要首先定义一个操纵数据库的接口，然后，根据数据库的不同，由类工厂决定实例化哪个类。
下面，我们首先来定义这个访问接口。为了方便说明问题，我们为这个类定义了比较少的方法，其他的方法是很容易参照添加的。同时注意，我这里使用了abstract class来定义这个访问接口，而不是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 strSql,string[] strParams,object[] objValues);
//执行Sql语句，没有返回值
public abstract DataSet exeSqlForDataSet(string QueryString);
//执行Sql，返回DataSet
}
我们编写数据访问的具体实现类:
Sql Server的数据库访问类：
internal class SqlDBOperator: DBOperator
{
private SqlConnection conn;
//数据库连接
private SqlTransaction trans;
//事务处理类
private bool inTransaction=false;
//指示当前是否正处于事务中
public override IDbConnection Connection
{
get{
return this.conn;
}
}
//SQL数据库的连接方法
public SqlDBOperator(string strConnection)
{
this.conn= new SqlConnection(strConnection);
}
//打开数据连接
public override void Open()
{
if(conn.State.ToString().ToUpper()!="OPEN")
this.conn.Open();
}
//关闭数据连接
public override void Close()
{
if (conn.State.ToString().ToUpper()=="OPEN")
this.conn.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;
}
//执行SQL语句的操作，无返回值
public override void exeSql(string strSql,string[] strParams,object[] strValues)
{
SqlCommand cmd=new SqlCommand();
cmd.Connection=this.conn ;
if(inTransaction)
cmd.Transaction=trans;
if((strParams!=null)&&(strParams.Length!=strValues.Length) )
throw new ParamValueNotMatchException("查询参数和值不对应!");
cmd.CommandText=strSql;
if(strParams!=null)
{
for(int i=0;i<strParams.Length;i++)
cmd.Parameters.Add(strParams[i],strValues[i]);
}
cmd.ExecuteNonQuery();
}
//重载执行SQL语句的操作，返回数据集
public override DataSet exeSqlForDataSet(string QueryString)
{
SqlCommand cmd=new SqlCommand();
cmd.Connection=this.conn ;
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的数据库访问类：