您的位置：首页 > 数据库

用设计模式开发通用数据库访问器

2005-08-16 14:39 393 查看

用设计模式开发通用数据库访问器

我们都希望在开发软件的时候能少写一些代码，希望能到处使用，希望不用管什么样的数据库软件都能用，我们该怎么办呢？

我们操作数据库时用到些什么类

一般来说，我们对数据库进行操作时都会用到一些类，下面我就对着些类做个总结：1． SQLServer：a) System.Data.SqlClient.SqlDataAdapter：SQL数据适配器。表示用于填充 DataSet 和更新 SQL Server 数据库的一组数据命令和一个数据库连接。无法继承此类。该类继承于System.Data.Common.DbDataAdapter和实现接口System.Data.IDbDataAdapter。采用Adapter模式设计。b) System.Data.SqlClient.SqlConnection：SQL数据库连接。表示 SQL Server 数据库的一个打开的连接。无法继承此类。c) System.Data.SqlClient.SqlCommandBuilder：SQL数据库命令生成器。自动生成具有以下用途的单表命令：使对 DataSet 所做的更改与关联的 SQL Server 数据库相协调。无法继承此类。采用Builder模式设计。另外还有一些，但是在本文中将用不到，所以这里也就不再叙述了。2． Oracle：a) System.Data.OracleClient.OracleDataAdapter：Oracle数据适配器。表示用于填充 DataSet 和更新Oracle数据库的一组数据命令和到数据库的连接。无法继承此类。该类继承于System.Data.Common.DbDataAdapter和实现接口System.Data.IDbDataAdapter。采用Adapter模式设计。b) System.Data.OracleClient.OracleConnection：Oracle数据库连接。表示一个到Oracle数据库的打开的连接。无法继承此类。c) System.Data.OracleClient.OracleCommandBuilder：Oracle数据库命令生成器。自动生成用于协调 DataSet 的更改与关联的Oracle数据库的单表命令。无法继承此类。采用Builder模式设计。3． Odbc：a) System.Data.Odbc.OdbcDataAdapter：Odbc类型数据数据适配器。表示数据命令集和到Odbc数据源的连接，它们用于填充 DataSet 以及更新该数据源。无法继承此类。。该类继承于System.Data.Common.DbDataAdapter和实现接口System.Data.IDbDataAdapter。采用Adapter模式设计。b) System.Data.Odbc.OdbcConnection：Odbc数据库连接。表示到Odbc数据源的连接是打开的。c) System.Data.Odbc.OdbcCommandBuilder：Odbc数据库命令生成器。自动生成用于协调 DataSet 的更改与关联的Odbc类型数据源的单表命令。无法继承此类。采用Builder模式设计。4． OleDb：a) System.Data.OleDb.OleDbDataAdapter：Odbc类型数据数据适配器。表示数据命令集和到OleDb数据源的连接，它们用于填充 DataSet 以及更新该数据源。无法继承此类。。该类继承于System.Data.Common.DbDataAdapter和实现接口System.Data.IDbDataAdapter。采用Adapter模式设计。b) System.Data.OleDb.OleDbConnection：OleDb数据库连接。表示到OleDb数据源的连接是打开的。c) System.Data.OleDb.OleDbCommandBuilder：OleDb数据库命令生成器。自动生成用于协调 DataSet 的更改与关联的OleDb类型数据源的单表命令。无法继承此类。采用Builder模式设计。

我们需要什么样的数据操作器

当然是越简单越好了，功能倒不一定要强大，够用就行。希望能支持多种数据库，使用这个操作器的程序不用再考虑是那种数据库；希望能对多个数据库操作，一个项目使用多个数据库却不对增加编程复杂度；希望支持事务，失败能够自动回滚。功能嘛，能读取数据、更新数据就可以了。

通用数据操作器的思路

对数据库的操作其实就是两件事：出和进。出呢就是从数据库中读取数据，进就是将数据写回数据库，包括新增数据、更新数据、删除数据。那么对这两个件事情该怎么做呢？读取数据时，我们是打开一个连接，实例化一个数据适配器然后填充数据集，关闭连接，即可。这里要注意的是，由于数据集里的表经常是数据库里多个数据表join的结果，所以你甭想让操作器自动生成查询语句，得你自己写。写入数据的时候，就会有一些麻烦，但因为都是执行单表操作所以你可以不用自己写SQL语句，让操作器自己生成好了。那么一步步怎么做呢？先打开一个数据库连接，再生成一个查询字符串，接着这两个东东实例化一个数据适配器，在生成一个CommandBuilder的实例并注册为DataAdapter的侦听器，接着配置事务。然后更新数据库，最后关闭连接。事务不能更早配置，是因为配置的事务之后便不允许数据适配器的命令为空。思路有了，后面就很简单了，我们只需要为每一种数据库连接定义这些操作，然后根据实际情况调用就可以了。当然我们不希望使用哪种数据库的由调用它的系统作为参数传入，定义在配置文件中似乎更好一些。由于可能有多个数据库，所以我们应当体现这种情况。比如我们可以定义默认数据库连接为“DBCon”，数据库A的连接为“ADBCon”。由于要实现多张表的操作，所以我们要定义一个数据集表和表名的映射。

代码实现

首先定义一个枚举，以指定可以支持哪些数据库：[align=left]/// <summary>[/align][align=left] /// 数据库类型枚举[/align][align=left] /// </summary>[/align][align=left] public enum DBType[/align][align=left] {[/align][align=left] /// <summary>[/align][align=left] /// SQLServer[/align][align=left] /// </summary>[/align][align=left] SQLServer,[/align][align=left] /// <summary>[/align][align=left] /// Oracle[/align][align=left] /// </summary>[/align][align=left] Oracle,[/align][align=left] /// <summary>[/align][align=left] /// OleDB[/align][align=left] /// </summary>[/align][align=left] OleDb,[/align][align=left] /// <summary>[/align][align=left] /// Odbc[/align][align=left] /// </summary>[/align][align=left] Odbc[/align] }　定义一个类来扩展DataTable:[align=left] /// <summary>[/align][align=left] /// 用于更新数据库的数据表、库表名对[/align][align=left] /// </summary>[/align][align=left] public class DataTableExtend[/align][align=left] {[/align][align=left] /// <summary>[/align][align=left] /// 数据表[/align][align=left] /// </summary>[/align][align=left] public System.Data.DataTable dataTable;[/align][align=left]　[/align][align=left] /// <summary>[/align][align=left] /// 数据表映射到数据库的表名[/align][align=left] /// </summary>[/align][align=left] public string dataTableName;[/align][align=left]　[/align][align=left] /// <summary>[/align][align=left] /// 用于更新数据库的数据表、库表名对构造函数[/align][align=left] /// </summary>[/align][align=left] /// <param name="myTable">用于更新数据库的数据表</param>[/align][align=left] /// <param name="myTableName">数据表映射到数据库的表名</param>[/align][align=left] public DataTableExtend(System.Data.DataTable myTable, string myTableName)[/align][align=left] {[/align][align=left] dataTable = myTable;[/align][align=left] dataTableName = myTableName;[/align][align=left] }[/align] }　然后写一个类来读取配置文件并获取数据库连接字符串：[align=left] /// <summary>[/align][align=left] /// DBSetting 的摘要说明。[/align][align=left] /// </summary>[/align][align=left] public class DBSetting[/align][align=left] {[/align][align=left] /// <summary>[/align][align=left] /// 数据库连接字符串后缀[/align][align=left] /// </summary>[/align][align=left] public static string DBConnectionEnds[/align][align=left] {[/align][align=left] get[/align][align=left] {[/align][align=left] return "DBCon";[/align][align=left] }[/align][align=left] }[/align][align=left]　[/align][align=left] /// <summary>[/align][align=left] /// 数据库类型后缀[/align][align=left] /// </summary>[/align][align=left] public static string DBTypeEnds[/align][align=left] {[/align][align=left] get[/align][align=left] {[/align][align=left] return "DBType";[/align][align=left] }[/align] }[align=left]/// <summary>[/align][align=left] /// 获取指定数据库的类型[/align][align=left] /// </summary>[/align][align=left] /// <param name="dbName">指定的数据库名</param>[/align][align=left] /// <returns>指定数据库的类型</returns>[/align][align=left] public static DBType GetDBType(string dbName)[/align][align=left] {[/align][align=left] string dbType = null;[/align][align=left] dbType = AppConfig.GetAppSetting(dbName + DBTypeEnds);[/align][align=left] if (dbType.ToLower() == DBType.Oracle.ToString().ToLower())[/align][align=left] {[/align][align=left] return DBType.Oracle;[/align][align=left] }[/align][align=left] if (dbType.ToLower() == DBType.Odbc.ToString().ToLower())[/align][align=left] {[/align][align=left] return DBType.Odbc;[/align][align=left] }[/align][align=left] if (dbType.ToLower() == DBType.OleDb.ToString().ToLower())[/align][align=left] {[/align][align=left] return DBType.OleDb;[/align][align=left] }[/align][align=left] else[/align][align=left] {[/align][align=left] return DBType.SQLServer;[/align][align=left] }[/align] }[align=left]/// <summary>[/align][align=left] /// 保存指定数据库的类型[/align][align=left] /// </summary>[/align][align=left] /// <param name="dbType">指定数据库的类型</param>[/align][align=left] /// <param name="dbName">指定的数据库名</param>[/align][align=left] public static void SaveDBType(DBType dbType,string dbName)[/align][align=left] {[/align][align=left] AppConfig.SaveAppSetting(dbName + DBTypeEnds,dbType.ToString());[/align] }[align=left]/// <summary>[/align][align=left] /// 获取指定数据库的连接字符串[/align][align=left] /// </summary>[/align][align=left] /// <param name="dbName">指定的数据库名</param>[/align][align=left] /// <returns>指定数据库的连接字符串</returns>[/align][align=left] public static string GetDBConnectionString(string dbName)[/align][align=left] {[/align][align=left] return AppConfig.GetAppSetting(dbName + DBConnectionEnds);[/align] }　[align=left] /// <summary>[/align][align=left] /// 保存指定数据库的连接字符串[/align][align=left] /// </summary>[/align][align=left] /// <param name="connectionString">连接字符串</param>[/align][align=left] /// <param name="dbName">指定的数据库名</param>[/align][align=left] public static void SaveDBConnectionString(string connectionString, string dbName)[/align][align=left] {[/align][align=left] AppConfig.SaveAppSetting(dbName + DBConnectionEnds,connectionString);[/align] }}　接着为每一种数据库写一个类来执行针对该数据库的操作，例如针对SQL Server：[align=left]/// <summary>[/align][align=left] /// 用于SQL数据源操作的类[/align][align=left] /// </summary>[/align][align=left] public class SQLExec[/align] {[align=left] /// <summary>[/align][align=left] /// 获取数据库连接，读取由Storm.AppSetting的配置文件中dbName + "DBCon"的设置(如针对数据库Test的配置键是“TestDBCon”),若没有，则抛出异常[/align][align=left] /// </summary>[/align][align=left] /// <param name="dbName">要获取数据连接的数据库名</param>[/align][align=left] /// <returns>得到的数据库连接</returns>[/align][align=left] public static SqlConnection GetDBConnection(string dbName)[/align][align=left] {[/align][align=left] return new SqlConnection(DBSetting.GetDBConnectionString());[/align] }　[align=left]private void ModifyDataBase(DataTableExtend[] dts, string dbName)[/align][align=left] {[/align][align=left] //打开连接[/align][align=left] SqlConnection sqlCon = GetDBConnection(dbName);[/align][align=left] sqlCon.Open();[/align][align=left] //根据数据表的多少生成多个数据适配器并分别生成SQL语句[/align][align=left] int length = dts.Length;[/align][align=left] SqlDataAdapter[] myDataAdapters = new SqlDataAdapter[length];[/align][align=left] for (int i = 0; i < length; i++)[/align][align=left] {[/align][align=left] string selectText = GetSelectCommand(dts[i].dataTableName);[/align][align=left] myDataAdapters[i] = new SqlDataAdapter(selectText, sqlCon);[/align][align=left] SqlCommandBuilder cb = new SqlCommandBuilder(myDataAdapters[i]);[/align][align=left] myDataAdapters[i].InsertCommand = cb.GetInsertCommand();[/align][align=left] myDataAdapters[i].UpdateCommand = cb.GetUpdateCommand();[/align][align=left] myDataAdapters[i].DeleteCommand = cb.GetDeleteCommand();[/align][align=left] }[/align][align=left] //配置事务[/align][align=left] SqlTransaction myTrans;[/align][align=left] myTrans = sqlCon.BeginTransaction(IsolationLevel.RepeatableRead);[/align][align=left] try[/align][align=left] {[/align][align=left] for (int i = 0; i < length; i++)[/align][align=left] {[/align][align=left] myDataAdapters[i].SelectCommand.Transaction = myTrans;[/align][align=left] myDataAdapters[i].InsertCommand.Transaction = myTrans;[/align][align=left] myDataAdapters[i].UpdateCommand.Transaction = myTrans;[/align][align=left] myDataAdapters[i].DeleteCommand.Transaction = myTrans;[/align][align=left] //更新数据库[/align][align=left] myDataAdapters[i].Update(dts[i].dataTable);[/align][align=left] }[/align][align=left] myTrans.Commit();[/align][align=left] sqlCon.Close();[/align][align=left] for(int i = 0; i < length ; i++)[/align][align=left] {[/align][align=left] dts[i].dataTable.AcceptChanges();[/align][align=left] }[/align][align=left] }[/align][align=left] //如果失败，则自动回滚[/align][align=left] catch(Exception ee)[/align][align=left] {[/align][align=left] myTrans.Rollback();[/align][align=left] sqlCon.Close();[/align][align=left] for(int i = 0; i < length ; i++)[/align][align=left] {[/align][align=left] dts[i].dataTable.RejectChanges();[/align][align=left] }[/align][align=left] throw ee;[/align][align=left] }[/align] } [align=left]/// <summary>[/align][align=left] /// 从数据库中读取数据[/align][align=left] /// </summary>[/align][align=left] /// <param name="dt">要承载数据的数据表</param>[/align][align=left] /// <param name="selectString">查询语句</param>[/align] public void GetData(DataTable dt, string selectString, string dbName) {[align=left]SqlDataAdapter myDataAdapter = new SqlDataAdapter(selectString,SQLConfig.GetDBConnection(dbName));[/align] myDataAdapter.Fill(dt); } //自动生成查询语句[align=left]private static string GetSelectCommand(string dataTableName)[/align][align=left] {[/align][align=left] string strGet = "SELECT * FROM " +dataTableName;[/align][align=left] return strGet;[/align] }}　然后就是写一个类来根据实际情况调用这些东东了：[align=left]public class DatabaseExecute[/align][align=left] {[/align][align=left] private string dbName;[/align][align=left] /// <summary>[/align][align=left] /// 目标数据库[/align][align=left] /// </summary>[/align][align=left] public string DBName[/align][align=left] {[/align][align=left] get{ return dbName; }[/align][align=left] set{ dbName = value; }[/align][align=left] }[/align][align=left] [/align][align=left] /// <summary>[/align][align=left] /// 生成DatabaseExecute的实例[/align][align=left] /// </summary>[/align][align=left] public DatabaseExecute()[/align][align=left] {[/align][align=left] dbName = null;[/align][align=left] }[/align][align=left]　[/align][align=left] /// <summary>[/align][align=left] /// 用指定的目标数据库生成DatabaseModifier的实例[/align][align=left] /// </summary>[/align][align=left] /// <param name="dbName"></param>[/align][align=left] public DatabaseExecute(string dbName)[/align][align=left] {[/align][align=left] this.dbName = dbName;[/align][align=left] }[/align][align=left] /// <summary>[/align][align=left] /// 从数据库中读取数据[/align][align=left] /// </summary>[/align][align=left] /// <param name="dt">要承载数据的数据表</param>[/align][align=left] /// <param name="selectString">查询语句</param>[/align][align=left] public void GetData(DataTable dt, string selectString)[/align][align=left] {[/align][align=left] //操作指定数据库[/align][align=left] if (DBName != null)[/align][align=left] {[/align][align=left] if (DBSetting.GetDBType(dbName) == DBType.SQLServer)[/align][align=left] {[/align][align=left] SQLExec mySQLExec = new SQLExec();[/align][align=left] mySQLExec. GetData(dt, selectString, DBName);[/align][align=left] }[/align][align=left] else if (DBSetting.GetDBType(dbName) == DBType.Odbc)[/align][align=left] {[/align][align=left] OdbcExec myOdbcExec = new OdbcExec();[/align][align=left] myOdbcExec. GetData(dt, selectString, DBName);[/align][align=left] }[/align][align=left] else if (DBSetting.GetDBType(dbName) == DBType.OleDb)[/align][align=left] {[/align][align=left] OleDbExec myOleDbExec = new OleDbExec();[/align][align=left] mySQLExec. GetData(dt, selectString, DBName);[/align][align=left] }[/align][align=left] else [/align][align=left] {[/align][align=left] OracleExec myOracleExec = new OracleExec();[/align][align=left] myOracleExec. GetData(dt, selectString, DBName);[/align][align=left] }[/align][align=left] }[/align][align=left] //操作默认数据库[/align][align=left] else[/align][align=left] {[/align][align=left] if (DBSetting.GetDBType(“”) == DBType.SQLServer)[/align][align=left] {[/align][align=left] SQLExec mySQLExec = new SQLExec();[/align][align=left] mySQLExec. GetData(dt, selectString, “”);[/align][align=left] }[/align][align=left] else if (DBSetting.GetDBType(“”) == DBType.Odbc)[/align][align=left] {[/align][align=left] OdbcExec myOdbcExec = new OdbcExec();[/align][align=left] myOdbcExec. GetData(dt, selectString, “”);[/align][align=left] }[/align][align=left] else if (DBSetting.GetDBType(dbName) == DBType.OleDb)[/align][align=left] {[/align][align=left] OleDbExec myOleDbExec = new OleDbExec();[/align][align=left] mySQLExec. GetData(dt, selectString, “”);[/align][align=left] }[/align][align=left] else [/align][align=left] {[/align][align=left] OracleExec myOracleExec = new OracleExec();[/align][align=left] myOracleExec. GetData(dt, selectString, “”);[/align][align=left] }[/align][align=left] }[/align][align=left] }[/align][align=left]　[/align][align=left] /// <summary>[/align][align=left] /// 根据数据表组更新数据库[/align][align=left] /// </summary>[/align][align=left] /// <param name="dts">要更新的数据表组</param>[/align][align=left] public void ModifyDataBase(DataTableExtend[] dts)[/align][align=left] {[/align][align=left] //操作指定数据库[/align][align=left] if (dbName != null)[/align][align=left] {[/align][align=left] if (DBSetting.GetDBType(dbName) == DBType.SQLServer)[/align][align=left] {[/align][align=left] SQLExec mySQLExec = new SQLExec();[/align][align=left] mySQLExec ModifyDataBase(dts,dbName);[/align][align=left] }[/align][align=left] else if (DBSetting.GetDBType(dbName) == DBType.Odbc)[/align][align=left] {[/align][align=left] OdbcExec mySQLExec = new OdbcExec();[/align][align=left] myOdbcExec ModifyDataBase(dts,dbName);[/align][align=left] }[/align][align=left] else if (DBSetting.GetDBType(dbName) == DBType.OleDb)[/align][align=left] {[/align][align=left] OleDbExec mySQLExec = new OleDbExec();[/align][align=left] myOleDbExec ModifyDataBase(dts,dbName);[/align][align=left] }[/align][align=left] else[/align][align=left] {[/align][align=left] OracleExec mySQLExec = new OracleExec();[/align][align=left] myOracleExec ModifyDataBase(dts,dbName);[/align][align=left] }[/align][align=left] }[/align][align=left] //操作默认数据库[/align][align=left] else[/align][align=left] {[/align][align=left] if (DBSetting.GetDBType(“”) == DBType.SQLServer)[/align][align=left] {[/align][align=left] SQLExec mySQLExec = new SQLExec();[/align][align=left] mySQLExec ModifyDataBase(dts, “”);[/align][align=left] }[/align][align=left] else if (DBSetting.GetDBType(dbName) == DBType.Odbc)[/align][align=left] {[/align][align=left] OdbcExec mySQLExec = new OdbcExec();[/align][align=left] myOdbcExec ModifyDataBase(dts, “”);[/align][align=left] }[/align][align=left] else if (DBSetting.GetDBType(dbName) == DBType.OleDb)[/align][align=left] {[/align][align=left] OleDbExec mySQLExec = new OleDbExec();[/align][align=left] myOleDbExec ModifyDataBase(dts, “”);[/align][align=left] }[/align][align=left] else[/align][align=left] {[/align][align=left] OracleExec mySQLExec = new OracleExec();[/align][align=left] myOracleExec ModifyDataBase(dts, “”);[/align][align=left] }[/align][align=left] }[/align]}　这样，在项目中只要引用这个DatabaseExecute类就可以了。最后，要注意的几点：1．对于多表操作而言，因为表间有关联，所以操作的顺序很重要，本构件操作的顺序是从数据表数组的前向后处理，请千万注意表处理的顺序！2．默认数据库连接由配置文件中“DBCon”的设置决定，非默认数据库连接由配置文件中“*DBCon”的设置决定，其中星号代表数据库标识3．默认数据库类型由配置文件中“DBCon”的设置决定，非默认数据库类型由配置文件中“*DBCon”的设置决定，其中星号代表数据库标识4．针对每一个数据库都有两个配置，分别是数据库连接和数据库类型。

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签：

相关文章推荐

新的分享

章节导航