基于Enterprise Library的Winform开发框架实现支持国产达梦数据库的扩展操作

浏览数：25 / 时间：2015年06月12日

由于一个客户朋友的需求，需要我的Winform开发框架支持国产达梦数据库的操作，这个数据库很早就听过，但是真正一般项目用的很少，一般在一些特殊的项目可能需要用到。由于我的Winform开发框架，是基于Enterprise Library的数据访问层的实现，因此增加一个数据库的支持很容易，本文介绍如何在框架层面上支持这种神秘的国产数据库-达梦数据库。

1、达梦数据库的简单介绍

达梦数据库管理系统是达梦公司推出的具有完全自主知识产权的高性能数据库管理系统，简称DM。达梦数据库管理系统的最新版本是7.0版本，简称DM7。DM7提供对SQL92的特性支持以及SQL99的核心级别支持；支持多种数据库开发接口，包括OLE DB、ADO、ODBC、OCI、JDBC、Hibernate、PHP、PDO、DB Express以及.Net DataProvider等。

达梦数据库可以在（http://www.dameng.com/）上下载试用，安装好后提供很多管理工具，安装后可以让它创建一些实例数据库，以方便我们了解数据库的基本操作，本人对这款数据库了解不多，不过它号称支持SQL-92标准的，那么使用起来就不会有什么问题的，只是一些个性化的语法需要查询即可。

技术分享

达梦数据库的分析器，可以在上面执行自己的一些语句，注意它的数据库表必须带上一个模式前缀，类似SqlServer的dbo，不过这个是必须的。

技术分享

2、基于Enterprise Library的Winform开发框架的架构支持处理

我的这款基于Enterprise Library的开发框架，底层使用了微软的数据访问组件Enterprise Library，以适应多种数据库类型的操作，它的分层如下所示，每个DAL层（如DALSQL、DALOracle等）都提供了对应数据库的实现，界面层一下的分层图如下所示。

技术分享

如果增加多一种数据库，那么我们增加多一个Enterprise Library的组件扩展类，并在业务数据模块里面增加对应的DAL层即可。

对于具体的DALSQL这样的数据实现层，我们不需要把数据访问的处理操作在全部的类里面实现一遍，我们可以通过抽象类的方式，把常规的数据库处理操作抽象到基类上面，如下所示。

技术分享

这样在BaseDALSQL层（SqlServer数据库的个性化实现部分），只需要实现部分功能即可，我们把大多数的数据库操作，放到最顶级的数据库访问基类AbstractBaseDAL类上，从而是我们能够尽可能减少增加不同数据库类型，需要改写代码的数量。

最终我们增量增加一个数据访问层就可以实现了另外一种数据库（达梦数据库）的实现了，具体的架构设计图如下所示。

技术分享

3、具体接入测试案例代码

上面小节，我们论证了框架的可扩展性，并且理论上已经具备支持达梦数据库的扩张了，本小节介绍如何具体实现达梦数据库的底层接入操作，并编写一个简单的测试例子进行测试，印证我们的实现思路。

我们知道，Enterprise Library实现其他数据库的支持，需要增加一个组件扩展类，如EntLibContrib.Data.SQLite是用来支持SQLite数据库的，EntLibContrib.Data.MySql是用来支持Mysql的，这个扩展类的内容也不多，主要是用来解析如下的配置文件的.

技术分享

以便能够和Enterprise Library的对象进行无缝的整合，那么我们可以参考MySql数据库的扩展类EntLibContrib.Data.MySql的做法，来创建一个基于国产达梦数据库的Enterprise Library扩展类，大概项目代码如下所示。

技术分享

这样我们就可以增加配置文件如下所示，它就能正常的解析并处理了。

技术分享

下面我们来编写测试的代码来印证我们的扩展类，实现Winform开发框架支持国产达梦数据库的扩展操作。

我们创建一个数据库通用操作的辅助类来进行讲解，代码如下所示。

   /// <summary>
    /// 基于Enterprise Library类库的数据访问测试
    /// </summary>
    public class EntLibDmHelper
    {
        public EntLibDmHelper()
        {
        }
        /// <summary>    
        /// 执行SQL查询语句，返回查询结果的所有记录的第一个字段,用逗号分隔。    
        /// </summary>    
        /// <param name="sql">SQL语句</param>    
        /// <returns>    
        /// 返回查询结果的所有记录的第一个字段,用逗号分隔。    
        /// </returns>    
        public string SqlValueList(string sql)
        {
            Database db = DatabaseFactory.CreateDatabase();
            DbCommand command = db.GetSqlStringCommand(sql);

            StringBuilder result = new StringBuilder();
            using (IDataReader dr = db.ExecuteReader(command))
            {
                while (dr.Read())
                {
                    result.AppendFormat("{0},", dr[0].ToString());
                }
            }

            string strResult = result.ToString().Trim(‘,‘);
            return strResult;
        }


        /// <summary>    
        /// 执行SQL查询语句，返回所有记录的DataTable集合。    
        /// </summary>    
        /// <param name="sql">SQL查询语句</param>    
        /// <returns></returns>    
        public  DataTable SqlTable(string sql)
        {
            DataSet ds = new DataSet();

            Database db = DatabaseFactory.CreateDatabase();
            DbCommand command = db.GetSqlStringCommand(sql);

            return db.ExecuteDataSet(command).Tables[0];
        }
    }

注意，上面的代码没有用到达梦的具体对象，而是使用了Enterprise Library的Database等对象来操作，这样也就是非常方便我们进行接口的抽象处理，可以把更多的功能放到数据库访问抽象类里面了。

如果是利用达梦的.NET Provider的对象处理数据库，那么具体的代码应该是这样的。

        /// <summary>    
        /// 执行SQL查询语句，返回查询结果的所有记录的第一个字段,用逗号分隔。    
        /// </summary>    
        /// <param name="sql">SQL语句</param>    
        /// <returns>    
        /// 返回查询结果的所有记录的第一个字段,用逗号分隔。    
        /// </returns>    
        public string SqlValueList(string sql)
        {
            DmConnection connection = new DmConnection(ConnectionString);
            DmCommand cmd = new DmCommand(sql, connection);

            connection.Open();
            StringBuilder result = new StringBuilder();
            using (DmDataReader dr = cmd.ExecuteReader())
            {
                while (dr.Read())
                {
                    result.AppendFormat("{0},", dr[0].ToString());
                }
            }

            string strResult = result.ToString().Trim(‘,‘);
            return strResult;
        }

        /// <summary>    
        /// 执行SQL查询语句，返回所有记录的DataTable集合。    
        /// </summary>    
        /// <param name="sql">SQL查询语句</param>    
        /// <returns></returns>    
        public DataTable SqlTable(string sql)
        {
            DataSet ds = new DataSet();
            DmDataAdapter adpater = new DmDataAdapter(sql, ConnectionString);
            adpater.Fill(ds);

            return ds.Tables[0];
        }

为了方便测试，我编写一个简单的查询例子来进行介绍，如下代码所示，这里我们主要利用了EntLibDmHelper这个辅助类对象，也就是基于Enterprise Library的扩展的处理操作。

        private void btnSearch_Click(object sender, EventArgs e)
        {
            BindData();
        }

        private void BindData()
        {
            string condition = "1=1 ";
            if (this.txtAuthor.Text.Length > 0)
            {
                condition += string.Format("AND Author like ‘%{0}%‘ ", this.txtAuthor.Text);
            }
            if (this.txtName.Text.Length > 0)
            {
                condition += string.Format("AND Name like ‘%{0}%‘ ", this.txtName.Text);
            }
            if (this.txtPublisher.Text.Length > 0)
            {
                condition += string.Format("AND Publisher like ‘%{0}%‘ ", this.txtPublisher.Text);
            }
            string sql = "Select * from PRODUCTION.Product Where " + condition;

            EntLibDmHelper helper = new EntLibDmHelper();
            //DMHelper helper = new DMHelper();
            DataTable dt = helper.SqlTable(sql);
            this.dataGridView1.DataSource = dt;

            sql = "Select count(*) from PRODUCTION.Product Where " + condition;
            string totalCount = helper.SqlValueList(sql);
            this.lblCount.Text = string.Format("共有数据：{0}条", totalCount);
        }