分页解决方案 之 数据访问函数库——另类的思路、另类的写法，造就了不一样的发展道路。

    上一篇：分页解决方案 —— GridView + QuickPager + QuickPager_SQL + DataAccessLibrary + 数据库  

    如何访问数据库？一个老掉牙的问题，方法多了去了，什么直接使用ado.net、使用SQLHelp、使用微软的企业库、使用ORM、使用LinQ to SQL等等，还可以使用自己封装的函数库，这里我就想说一下我的数据访问函数库的使用方法。

    您可能会说了，这么简单的东东还用说吗，重复制作轮子有意义吗？这个嘛，个人有个人的看法了，我也不多说了，先看使用方法吧。

     忘记说了，我的数据访问函数库不是静态的，所以需要先实例化。

DataAccessLibrary dal = DALFactory.CreateDAL();

1、删除一条数据，不使用事务

protected   void  Btn_Del_Click( object  sender, EventArgs e)
         {
            //不用事务，直接删除数据
            string sql = "delete from News_NewsInfo where newsID = 18 ";
            
            //执行SQL语句
            dal.ExecuteNonQuery(sql);

            判断是否出现异常 和 是否真的删除了一条数据#region 判断是否出现异常 和 是否真的删除了一条数据
            //判断是否出现异常
            if (dal.ErrorMessage.Length > 0)
            {
                //出现了异常，客户端弹出提示信息
                Functions.PageRegisterAlert(Page,"删除数据的时候发生异常，请与管理员联系！");
                return;
            }
            //判断是否真的删除了一条数据
            //ExecuteRowCount 会返回操作影响的行数（不包括select语句）
            if (dal.ExecuteRowCount != 1)
            {
                //没有正确删除一条数据，客户端弹出提示信息
                Functions.PageRegisterAlert(Page, "没有正确删除这条数据，请与管理员联系！");
                return;
            }
            #endregion

        }

2、删除多条数据，使用事务

protected   void  Btn_DelMore_Click( object  sender, EventArgs e)
         {
            //使用事务，删除多个表里面的数据

            //开启一个事务
            dal.TranManager.TranBegin();
 
            string sql = "delete from News_NewsInfo where newsID = 13 ";

            //执行SQL语句
            dal.ExecuteNonQuery(sql);

            判断是否出现异常 和 是否真的删除了一条数据#region 判断是否出现异常 和 是否真的删除了一条数据
            //判断是否出现异常
            if (dal.ErrorMessage.Length > 0)
            {
                //出现了异常，客户端弹出提示信息
                //数据访问函数库内部会自动回滚事务，外部不用回滚！
                Functions.PageRegisterAlert(Page, "删除数据的时候发生异常，请与管理员联系！");
                return;
            }
            
            //判断是否真的删除了一条数据
            //ExecuteRowCount 会返回操作影响的行数（不包括select语句）
            if (dal.ExecuteRowCount != 1)
            {
                //没有正确删除一条数据，客户端弹出提示信息
                //没有产生异常，内部并没有自动回滚事务，所以请调用回滚的函数，回滚事务!
                dal.TranManager.TranRollBack();
                Functions.PageRegisterAlert(Page, "没有正确删除这条数据，请与管理员联系！");
                return;
            }
            #endregion

            sql = "delete from News_NewsInfo where newsID = 14  ";
            //执行SQL语句
            dal.ExecuteNonQuery(sql);

            判断是否出现异常 和 是否真的删除了一条数据#region 判断是否出现异常 和 是否真的删除了一条数据
            //判断是否出现异常
            if (dal.ErrorMessage.Length > 0)
            {
                //出现了异常，客户端弹出提示信息
                //数据访问函数库内部会自动回滚事务，外部不用回滚！
                Functions.PageRegisterAlert(Page, "删除数据的时候发生异常，请与管理员联系！");
                return;
            }

            //判断是否真的删除了一条数据
            //ExecuteRowCount 会返回操作影响的行数（不包括select语句）
            if (dal.ExecuteRowCount != 1)
            {
                //没有正确删除一条数据，客户端弹出提示信息
                //没有产生异常，内部并没有自动回滚事务，所以请调用回滚的函数，回滚事务!
                dal.TranManager.TranRollBack();
                Functions.PageRegisterAlert(Page, "没有正确删除这条数据，请与管理员联系！");
                return;
            }
            #endregion

            //可以继续执行其他的操作，不仅仅是删除语句，insert、Update语句都可以执行。
            //执行之后都要进行判断

            //所有的操作都正确执行完毕之后，需要提交事务
            dal.TranManager.TranCommit();

            //注意，事务不支持嵌套！

            
        }

3、使用参数化SQL语句添加数据

参数化SQL语句的方式添加数据 #region 参数化SQL语句的方式添加数据
            //清除参数
            dal.ParameterManager.ClearParameter();
            //添加参数
            dal.ParameterManager.AddNewInParameter("@Title", "参数化SQL语句的标题", 50);    //nvarchar类型的参数，需要指定长度
            dal.ParameterManager.AddNewInParameter("@Content", "嘻嘻哈哈");                 //ntext 类型的不需要指定长度
            dal.ParameterManager.AddNewInParameter("@AddedDate", DateTime.Now);           //日期型的
            dal.ParameterManager.AddNewInParameter("@Hits", 3);                             //int型的

            //执行参数化的SQL语句，返回新添加的数据的ID值，只限于自增字段的表。
            string newID = dal.InsertData("News_NewsInfo"); 

            Response.Write(newID);
            Response.Write("<BR>" + dal.ExecuteRowCount);

            判断是否出现异常 和 是否真的删除了一条数据#region 判断是否出现异常 和 是否真的删除了一条数据
            //判断是否出现异常
            if (dal.ErrorMessage.Length > 0)
            {
                //出现了异常，客户端弹出提示信息
                Functions.PageRegisterAlert(Page, "添加数据的时候发生异常，请与管理员联系！");
                return;
            }

            //判断是否真的添加了一条数据
            //ExecuteRowCount 会返回操作影响的行数（不包括select语句）
            //由于最后使用了select scope_identity() as a1 来得到新增记录的主键值，所以ExecuteRowCount值为零。
            //我还不知道没能正确添加数据的话 scope_identity()会返回什么？所以这里就不知道要怎么判断了，呵呵
            //if (newID != 0)
            //{
            //    //没有正确删除一条数据，客户端弹出提示信息
            //    Functions.PageRegisterAlert(Page, "没有正确添加这条数据，请与管理员联系！");
            //    return;
            //}
            #endregion

            #endregion

4、使用储存过程添加数据

             存储过程的方式添加数据 #region 存储过程的方式添加数据
            //和参数化的SQL语句基本相同，不同点有两个地方，一个是要事先建立存储过程，一是使用ExecuteNonQuery。

            //清除参数
            dal.ParameterManager.ClearParameter();
            //添加参数
            dal.ParameterManager.AddNewInParameter("@Title", "储存过程的标题", 50);    //nvarchar类型的参数，需要指定长度
            dal.ParameterManager.AddNewInParameter("@Content", "嘻嘻哈哈");                 //ntext 类型的不需要指定长度
            dal.ParameterManager.AddNewInParameter("@AddedDate", DateTime.Now);           //日期型的
            dal.ParameterManager.AddNewInParameter("@Hits", 3);                             //int型的

            //添加返回型的参数
            dal.ParameterManager.AddNewOutParameter("@NewsID",DbType.Int32 );

            //存储过程的名称要以Proc开头
            //如果您不习惯Proc开头的话，那么需要修改数据访问函数库的内部函数。
            //不建议使用xp_、sp_等开头，因为系统的存储过程的名称是以这些开头的。

            //执行储存过程
            dal.ExecuteNonQuery("Proc_News_Mod");

            //获取储存过程的参数
            newID = dal.ParameterManager["@NewsID"].Value.ToString();

            Response.Write("<BR>" + newID);
            Response.Write("<BR>" + dal.ExecuteRowCount);

            判断是否出现异常 和 是否真的添加了一条数据#region 判断是否出现异常 和 是否真的添加了一条数据
            //判断是否出现异常
            if (dal.ErrorMessage.Length > 0)
            {
                //出现了异常，客户端弹出提示信息
                Functions.PageRegisterAlert(Page, "添加数据的时候发生异常，请与管理员联系！");
                return;
            }

            //判断是否真的添加了一条数据
            //ExecuteRowCount 会返回操作影响的行数（不包括select语句）
            if (dal.ExecuteRowCount != 1)
            {
                //没有正确添加一条数据，客户端弹出提示信息
                Functions.PageRegisterAlert(Page, "没有正确添加这条数据，请与管理员联系！");
                return;
            }
            #endregion
            #endregion

5、使用参数化SQL语句修改数据

             参数化SQL语句的方式修改数据 #region 参数化SQL语句的方式修改数据
            //添加参数
            dal.ParameterManager.ClearParameter();
            dal.ParameterManager.AddNewInParameter("@Title", "参数化SQL语句的标题", 50);    //nvarchar类型的参数，需要指定长度
            dal.ParameterManager.AddNewInParameter("@Content", "嘻嘻哈哈");                 //ntext 类型的不需要指定长度
            dal.ParameterManager.AddNewInParameter("@AddedDate", DateTime.Now);             //日期型的
            dal.ParameterManager.AddNewInParameter("@Hits", 3);                             //int型的

            //修改存储过程的参数的值
            dal.ParameterManager["@Title"].Value  = "后来修改了";

            //执行参数化的SQL语句，设置条件已修改数据。
            dal.UpdateData ("News_NewsInfo","NewsID = 21");

            Response.Write("<BR>" + dal.ExecuteRowCount);

            判断是否出现异常 和 是否真的修改了一条数据#region 判断是否出现异常 和 是否真的修改了一条数据
            //判断是否出现异常
            if (dal.ErrorMessage.Length > 0)
            {
                //出现了异常，客户端弹出提示信息
                Functions.PageRegisterAlert(Page, "修改数据的时候发生异常，请与管理员联系！");
                return;
            }

            //判断是否真的修改了一条数据
            if (dal.ExecuteRowCount != 1)
            {
                //没有正确删除一条数据，客户端弹出提示信息
                Functions.PageRegisterAlert(Page, "没有正确修改这条数据，请与管理员联系！");
                return;
            }
            #endregion

            #endregion

6、使用储存过程修改数据

            存储过程的方式修改数据 #region 存储过程的方式修改数据
            //和参数化的SQL语句基本相同，不同点有两个地方，一个是要事先建立存储过程，一是使用ExecuteNonQuery。

            //清除参数
            dal.ParameterManager.ClearParameter();
            //添加参数
            dal.ParameterManager.AddNewInParameter("@Title", "储存过程的标题有修改了————", 50);    //nvarchar类型的参数，需要指定长度
            dal.ParameterManager.AddNewInParameter("@Content", "嘻嘻哈哈");                 //ntext 类型的不需要指定长度
            dal.ParameterManager.AddNewInParameter("@AddedDate", DateTime.Now);           //日期型的
            dal.ParameterManager.AddNewInParameter("@Hits", 3);                             //int型的

            dal.ParameterManager.AddNewInParameter("@NewsID", 25);  //修改条件

            //存储过程的名称要以Proc开头
            //如果您不习惯Proc开头的话，那么需要修改数据访问函数库的内部函数。
            //不建议使用xp_、sp_等开头，因为系统的存储过程的名称是以这些开头的。

            //执行储存过程
            dal.ExecuteNonQuery("Proc_News_Mod");

            Response.Write("<BR>" + dal.ExecuteRowCount);

            判断是否出现异常 和 是否真的修改了一条数据#region 判断是否出现异常 和 是否真的修改了一条数据
            //判断是否出现异常
            if (dal.ErrorMessage.Length > 0)
            {
                //出现了异常，客户端弹出提示信息
                Functions.PageRegisterAlert(Page, "修改数据的时候发生异常，请与管理员联系！");
                return;
            }

            //判断是否真的添加了一条数据
            //ExecuteRowCount 会返回操作影响的行数（不包括select语句）
            if (dal.ExecuteRowCount != 1)
            {
                //没有正确添加一条数据，客户端弹出提示信息
                Functions.PageRegisterAlert(Page, "没有正确修改这条数据，请与管理员联系！");
                return;
            }
            #endregion
            #endregion

        获取数据 #region 获取数据
        protected void Btn_DataTable_Click(object sender, EventArgs e)
        {
            string sql = "select * from News_NewsInfo";

            //获取DataTable
            DataTable dt = dal.ExecuteFillDataTable(sql);

            //获取DataSet
            DataSet ds = dal.ExecuteFillDataSet(sql);

            //获取第一条记录的第一个字段
            sql = "select top 1 title from News_NewsInfo where NewsID = 21";
            string NewsTitle = dal.ExecuteString(sql);

            //获取第一条记录的多个字段，用于字段比较少的情况
            sql = "select top 1 title,Content,AddedDate,Hits from News_NewsInfo where NewsID = 21";
            string[] NewsInfo = dal.ExecuteStringsBySingleRow(sql);

            //获取每一条记录的第一个字段，有的时候会需要
            sql = "select hits from News_NewsInfo";
            string[] HitList = dal.ExecuteStringsByColumns(sql);

            //判断是否存在一条记录
            sql = "select top 1 1 from News_NewsInfo where title = '一个标题'";
            if (dal.ExecuteExists(sql))
            {
                //存在这条记录
            }
            else
            {
                //没有找到这条记录
            }

        }
        #endregion

    数据访问函数库的特点

1、支持多种数据库。基于ado.net2.0 ，使用System.Data.Common.DbProviderFactory 来实现。

2、调用方便、简捷。一般一行语句即可搞定。

3、对事务、储存过程的参数进行了封装，以达到简单好用的目的。

4、可以在内部拼接参数化的SQL语句，省去了在外部写参数化的SQL语句的烦恼。

5、使用一个属性来代替异常处理，只需要检查这个属性值，即可知道是否发生异常。

6、产生异常的时候会记录下SQL语句（或者储存过程的名称）、错误描述、时间、网页即URL参数，以便于调试、修改错误。

这些代码应该写在哪一层？

    从语法的角度来讲，写在哪一层都可以通过编译。从流行的角度来讲呢，应该写在数据层。从我个人的角度来说呢，我是直接写在了aspx.cs文件里了，为什么要这么做呢？方便！

    另一个原因就是——我不知道要怎么分？不都写在aspx.cs文件里面写在哪呢？建立一个.cs文件，美其名曰“数据层”，写一个函数，把代码拷贝进去。然后在建立一个.cs文件，美其名曰“业务逻辑层”，再在这里调用刚写的那个函数，最后在.aspx.cs文件里面调用？这可就是纯粹为了分层而分层了。我觉得没有必要，呵呵。

    另外，就是这个操作习惯上的差别，让我走到了和主流不一样的道路！至少到目前为止，我还是觉得我的这个方向是没有错误的。

Ps:

    我的思路有一点另类，我的目的就是外部调用的时候一定要简单，不必要的“啰嗦”一定要去掉，而数据访问函数库的内部代码可以多一点，函数的功能可以细致一些（比如获取数据的地方，设置了好几个函数）。

    使用SQLHelp的时候，为什么要在外部实例化一个connection？为什么要在外部建立储存过程的参数？这么麻烦，为什么不能把这些都封装进去呢？所以我把这些都封装进去了。

变与不变

  neverlost 写的 《2条路 代码生成 or 配置 》里有人问：“数据库字段修改了， sql 存储过程的参数修改了····如何通过你的说的可配置部分维护？”。我估计我们的思路应该差不多。

我说一下我的想法。就以上面的例子举例。假设News_NewsInfo表里面的“Title”字段想要改名，改成“NewsTitle”，那么我的代码要怎么改呢？

我只需要把

  dal.ParameterManager.AddNewInParameter("@Title", "参数化SQL语句的标题", 50);

改成

  dal.ParameterManager.AddNewInParameter("@NewsTitle", "参数化SQL语句的标题", 50);

就可以了，那么本质上我修改了什么呢？我修改了一个字符串的值！

    函数本身是不变的，变化的是参数值，就是那个字符串，就是那个字段名。不知道说道这里您有答案了没？就是说我可以把表名、字段名放在“配置”里面，用的时候读取出来，给函数的参数赋值，这样当字段名变化的时候，我只需要修改“配置”里的信息就可以了，不需要修改代码。

  您可能会问了，修改代码里的字符串是修改，修改“配置”也是修改，后者有什么优势吗？优势那可就大了。留一个想象的空间吧，暂时先不说了。

 源代码下载：http://www.cnblogs.com/jyk/archive/2008/07/29/1255891.html