（转）c#下各种数据库操作的封装！(支持ACCESS,SQLSERVER,DB2,ORACLE,MYSQL)

c#下各种数据库操作的封装！(支持ACCESS,SQLSERVER,DB2,ORACLE,MYSQL)

首先定义数据库操作的标准接口IDBAccess,定义接口的基本功能；

通过基本的接口设置，完成数据访问的统一抽象。

public interface IDBAccess
...{
void Init(string strServer, string strDataBase, string strUser, string strPwd);
void Open();
void Close();
bool TestConn();
int RunNoQuery(string strCmd);
DataTable RunQuery(string strCmd);
DBType DBType ...{ get;}
int GetFiledMax(string strTable, string strField);
DataTable Tables ...{ get; }
DataTable GetColumns();
DataTable GetColumns(string strTable);
}

Trackback: http://tb.blog.csdn.net/TrackBack.aspx?PostId=2242981
使用静态工厂模式，通过传入枚举型参数 ，动态创建访问实例

实现模式上采用基本实现接口，派生类继承基类的虚函数，从而实现代码的耦合较低，有很好的扩展性。

public enum DBType
...{
Access,
SQL,
DB2,
Oracle,
MySQL
}

public static class DBAccessFactory
...{
public static IDBAccess Create(DBType type)
...{
IDBAccess IRet = null;
switch (type)
...{
case DBType.Access:
IRet = new Access(type);
break;

case DBType.SQL:
IRet = new SQL(type);
break;

default:
break;
}
return IRet;
}

private abstract class DBAccess : IDBAccess
...{
protected DbConnection m_oConn = null;
protected const string CON_strServer = "Server";
protected const string CON_strDataBase = "Data Source";
protected const string CON_strUser = "UID";
protected const string CON_strPwd = "PWD";
protected const string CON_strConnTimeOut = "Connect Timeout = 2";
private DBType m_eDBType = DBType.Access;

protected DBAccess(DBType type)
...{
this.m_eDBType = type;
}

public DBType DBType
...{
get ...{ return this.m_eDBType; }
}

public void Init(string strServer, string strDataBase, string strUser, string strPwd)
...{
this.InitConn(strServer, strDataBase, strUser, strPwd);
}

public void Open()
...{
if (this.m_oConn != null)
...{
this.m_oConn.Open();
}
}

public int RunNoQuery(string strCmd)
...{
int iRet = 0;
try
...{
DbCommand oCmd = this.GetCmd(strCmd);
if (oCmd != null)
...{
iRet = oCmd.ExecuteNonQuery();
}
}
catch (Exception ex)
...{
throw (new Exception(ex.Message));
}
return iRet;
}

public int GetFiledMax(string strTable, string strField)
...{
int iRet = -1;
DataTable dt = this.RunQuery("Select Max(" + strField + ") From " + strTable);
if (dt != null && dt.Rows.Count == 1)
...{
iRet = dt.Rows[0][0] is DBNull ? 0 : Convert.ToInt32(dt.Rows[0][0]);
}
return iRet;
}

public DataTable RunQuery(string strCmd)
...{
DataTable dt = new DataTable();
DbDataAdapter adp = this.DbAdp;
adp.SelectCommand = this.GetCmd(strCmd);
adp.Fill(dt);
return dt;
}

public void Close()
...{
if (this.m_oConn != null && this.m_oConn.State == System.Data.ConnectionState.Open)
...{
this.m_oConn.Close();
}
}

public bool TestConn()
...{
bool bRet = true;
try
...{
if (this.m_oConn.State != System.Data.ConnectionState.Open)
...{
this.m_oConn.Open();
}
bRet = this.m_oConn.State == System.Data.ConnectionState.Open;
}
catch
...{
bRet = false;
}
this.Close();
return bRet;
}

public abstract DataTable Tables ...{ get; }
public abstract DataTable GetColumns();
public abstract DataTable GetColumns(string strTable);

protected abstract void InitConn(string strServer, string strDataBase, string strUser, string strPwd);
protected abstract DbCommand GetCmd(string strCmd);
protected abstract DbDataAdapter DbAdp ...{ get;}
}
}

各派生类的具体实现，此时只要实现DBAccess的各个虚函数即可。

private class Access : DBAccess
...{
public Access(DBType type)
: base(type)
...{
}

protected override void InitConn(string strServer, string strDataBase, string strUser, string strPwd)
...{
string strConn = "Provider = ";
switch (strDataBase.Substring(strDataBase.LastIndexOf('.') + 1).ToLower())
...{
case "mdb": // 2000, 2003
strConn += "Microsoft.Jet.OleDb.4.0;";
break;

case "accdb": // 2007
strConn += "Microsoft.ACE.OLEDB.12.0;";
break;

default:
throw (new Exception("Unknown Access Version."));
//break;
}
strConn += CON_strDataBase + " = " + strDataBase;
//strConn += CON_strUser + " = " + strUser;
//strConn += CON_strPwd + " = " + strPwd;
base.m_oConn = new OleDbConnection(strConn);
}

protected override DbCommand GetCmd(string strCmd)
...{
return new OleDbCommand(strCmd, (OleDbConnection)base.m_oConn);
}

protected override DbDataAdapter DbAdp
...{
get ...{ return new OleDbDataAdapter(); }
}

public override DataTable Tables
...{
get
...{
return ((OleDbConnection)base.m_oConn).GetOleDbSchemaTable(OleDbSchemaGuid.Tables, new object[] ...{ null, null, null, "Table" });
}
}

public override DataTable GetColumns()
...{
DataTable dt = new DataTable();
foreach (DataRow row in this.Tables.Rows)
...{
dt.Merge(this.GetColumns(row["TABLE_NAME"].ToString()));
}
return dt;
}

public override DataTable GetColumns(string strTable)
...{
return ((OleDbConnection)base.m_oConn).GetOleDbSchemaTable(OleDbSchemaGuid.Columns, new object[] ...{ null, null, strTable, null });
}
}

private class SQL : DBAccess
...{
public SQL(DBType type)
: base(type)
...{
}

protected override void InitConn(string strServer, string strDataBase, string strUser, string strPwd)
...{
string strConn = CON_strServer + " = " + strServer + ";";
strConn += CON_strDataBase + " = " + strDataBase + ";";
strConn += CON_strUser + " = " + strUser + ";";
strConn += CON_strPwd + " = " + strPwd + ";";
strConn += CON_strConnTimeOut;
base.m_oConn = new SqlConnection(strConn);
}

protected override DbCommand GetCmd(string strCmd)
...{
return new SqlCommand(strCmd, (SqlConnection)base.m_oConn);
}

protected override DbDataAdapter DbAdp
...{
get ...{ return new SqlDataAdapter(); }
}

public override DataTable Tables
...{
get ...{ return ((SqlConnection)base.m_oConn).GetSchema("Tables", null); }
}

public override DataTable GetColumns()
...{
return ((SqlConnection)base.m_oConn).GetSchema("Columns", null);
}

public override DataTable GetColumns(string strTable)
...{
return ((SqlConnection)base.m_oConn).GetSchema("Columns", new string[] ...{ null, null, strTable, null });
}
}

整个例子的完整代码如下，VS2008下编译测试通过，本人已通过它实现N个项目，欢迎大家评测，谢谢指教

public enum DBType
...{
Access,
SQL,
DB2,
Oracle,
MySQL
}

public interface IDBAccess
...{
void Init(string strServer, string strDataBase, string strUser, string strPwd);
void Open();
void Close();
bool TestConn();
int RunNoQuery(string strCmd);
DataTable RunQuery(string strCmd);
DBType DBType ...{ get;}
int GetFiledMax(string strTable, string strField);
DataTable Tables ...{ get; }
DataTable GetColumns();
DataTable GetColumns(string strTable);
}

public static class DBAccessFactory
...{
public static IDBAccess Create(DBType type)
...{
IDBAccess IRet = null;
switch (type)
...{
case DBType.Access:
IRet = new Access(type);
break;

case DBType.SQL:
IRet = new SQL(type);
break;

default:
break;
}
return IRet;
}

private abstract class DBAccess : IDBAccess
...{
protected DbConnection m_oConn = null;
protected const string CON_strServer = "Server";
protected const string CON_strDataBase = "Data Source";
protected const string CON_strUser = "UID";
protected const string CON_strPwd = "PWD";
protected const string CON_strConnTimeOut = "Connect Timeout = 2";
private DBType m_eDBType = DBType.Access;

protected DBAccess(DBType type)
...{
this.m_eDBType = type;
}

public DBType DBType
...{
get ...{ return this.m_eDBType; }
}

public void Init(string strServer, string strDataBase, string strUser, string strPwd)
...{
this.InitConn(strServer, strDataBase, strUser, strPwd);
}

public void Open()
...{
if (this.m_oConn != null)
...{
this.m_oConn.Open();
}
}

public int RunNoQuery(string strCmd)
...{
int iRet = 0;
try
...{
DbCommand oCmd = this.GetCmd(strCmd);
if (oCmd != null)
...{
iRet = oCmd.ExecuteNonQuery();
}
}
catch (Exception ex)
...{
throw (new Exception(ex.Message));
}
return iRet;
}

public int GetFiledMax(string strTable, string strField)
...{
int iRet = -1;
DataTable dt = this.RunQuery("Select Max(" + strField + ") From " + strTable);
if (dt != null && dt.Rows.Count == 1)
...{
iRet = dt.Rows[0][0] is DBNull ? 0 : Convert.ToInt32(dt.Rows[0][0]);
}
return iRet;
}

public DataTable RunQuery(string strCmd)
...{
DataTable dt = new DataTable();
DbDataAdapter adp = this.DbAdp;
adp.SelectCommand = this.GetCmd(strCmd);
adp.Fill(dt);
return dt;
}

public void Close()
...{
if (this.m_oConn != null && this.m_oConn.State == System.Data.ConnectionState.Open)
...{
this.m_oConn.Close();
}
}

public bool TestConn()
...{
bool bRet = true;
try
...{
if (this.m_oConn.State != System.Data.ConnectionState.Open)
...{
this.m_oConn.Open();
}
bRet = this.m_oConn.State == System.Data.ConnectionState.Open;
}
catch
...{
bRet = false;
}
this.Close();
return bRet;
}

public abstract DataTable Tables ...{ get; }
public abstract DataTable GetColumns();
public abstract DataTable GetColumns(string strTable);

protected abstract void InitConn(string strServer, string strDataBase, string strUser, string strPwd);
protected abstract DbCommand GetCmd(string strCmd);
protected abstract DbDataAdapter DbAdp ...{ get;}
}

Access, SQL#region Access, SQL

private class Access : DBAccess
...{
public Access(DBType type)
: base(type)
...{
}

protected override void InitConn(string strServer, string strDataBase, string strUser, string strPwd)
...{
string strConn = "Provider = ";
switch (strDataBase.Substring(strDataBase.LastIndexOf('.') + 1).ToLower())
...{
case "mdb": // 2000, 2003
strConn += "Microsoft.Jet.OleDb.4.0;";
break;

case "accdb": // 2007
strConn += "Microsoft.ACE.OLEDB.12.0;";
break;

default:
throw (new Exception("Unknown Access Version."));
//break;
}
strConn += CON_strDataBase + " = " + strDataBase;
//strConn += CON_strUser + " = " + strUser;
//strConn += CON_strPwd + " = " + strPwd;
base.m_oConn = new OleDbConnection(strConn);
}

protected override DbCommand GetCmd(string strCmd)
...{
return new OleDbCommand(strCmd, (OleDbConnection)base.m_oConn);
}

protected override DbDataAdapter DbAdp
...{
get ...{ return new OleDbDataAdapter(); }
}

public override DataTable Tables
...{
get
...{
return ((OleDbConnection)base.m_oConn).GetOleDbSchemaTable(OleDbSchemaGuid.Tables, new object[] ...{ null, null, null, "Table" });
}
}

public override DataTable GetColumns()
...{
DataTable dt = new DataTable();
foreach (DataRow row in this.Tables.Rows)
...{
dt.Merge(this.GetColumns(row["TABLE_NAME"].ToString()));
}
return dt;
}

public override DataTable GetColumns(string strTable)
...{
return ((OleDbConnection)base.m_oConn).GetOleDbSchemaTable(OleDbSchemaGuid.Columns, new object[] ...{ null, null, strTable, null });
}
}

private class SQL : DBAccess
...{
public SQL(DBType type)
: base(type)
...{
}

protected override void InitConn(string strServer, string strDataBase, string strUser, string strPwd)
...{
string strConn = CON_strServer + " = " + strServer + ";";
strConn += CON_strDataBase + " = " + strDataBase + ";";
strConn += CON_strUser + " = " + strUser + ";";
strConn += CON_strPwd + " = " + strPwd + ";";
strConn += CON_strConnTimeOut;
base.m_oConn = new SqlConnection(strConn);
}

protected override DbCommand GetCmd(string strCmd)
...{
return new SqlCommand(strCmd, (SqlConnection)base.m_oConn);
}

protected override DbDataAdapter DbAdp
...{
get ...{ return new SqlDataAdapter(); }
}

public override DataTable Tables
...{
get ...{ return ((SqlConnection)base.m_oConn).GetSchema("Tables", null); }
}

public override DataTable GetColumns()
...{
return ((SqlConnection)base.m_oConn).GetSchema("Columns", null);
}

public override DataTable GetColumns(string strTable)
...{
return ((SqlConnection)base.m_oConn).GetSchema("Columns", new string[] ...{ null, null, strTable, null });
}
}

#endregion
}