一步一步教你使用AgileEAS.NET基础类库进行应用开发-基础篇-UDA中的委托与应用

上文回顾

      上一篇文章基于AgileEAS.NET平台基础类库进行应用开发-使用UDA操纵SQL语句一文中演示如何使用UDA进行常规的业务进行操作,我们看到两种数据操纵流程,一种是原始的操作流程,另一种是简化的数据操作流程,应用开发人员不用关心数据库的打开与关闭,这些工作由UDA为我们完成,我们只需要实现与业务相关代码即可。

问题引出

       我们现在再看一眼我们在前面提供的数据处理流程:

一步一步教你使用AgileEAS.NET基础类库进行应用开发-基础篇-UDA中的委托与应用
        AgileEAS.NET平台提供两种数据处理流程供我们选择,两种方式的差别在于应用开发人员是否控制连接的打开与关闭,第一种方式应用开发人员管理连接的打开与关闭,我们称为他原生的数据访问方式,第二种方式是数据库的打开与关闭由UDA对象自动控件,我们称他为懒惰方式吧,在执行SQL之前由UDA打开连接,执行完SQL之后由UDA关闭连接,也就是说在Quer和Execute方法中,包含了数据库的打开与关闭操作。

 

        在基于AgileEAS.NET平台的应用开发中,我们推荐第二种方式,但同时一个问题来了,Query方法在执行完SQL语句之后关闭了连接,对于IDataReader这种必须要连接在线的返回类型则第二种方式无法支持,同时,对于事务处理,一个事务中包含多条语句,第二种方式的自动打开与关闭连接不能支持事务处理。

如何解决

 

 

 

        鉴于上面的问题,我们提供了两种解决方法,第一、使用原生模式处理数据访问,当然这是我们不推荐的,第二、UDA的IDataAccessor中提供了两个委托方法DelegateQuery、TransactionExecute及其相关的重载,DelegateQuery实现DataReader访问方式的委托查询,TransactionExecute实现事务委托,有关于这两个委托方法及其delegate定义请参考AgileEAS.NET之统一数据访问一文及AgileEAS.NET基础类库参考手册

委托查询例子

         现在我们来使用委托查询修改上文中IDataReader查询的例子,先贴上原生方式的IDataReader查询:

    /// <summary>
    /// 演示使用IDataReader。
    /// </summary>
    /// <remarks>
    /// IDataReader返回类型必须要求数据库打开,也就是说手工管理连接的打开。
    /// </remarks>
    public void DemeGetDataReader()
    {
        IDataAccessor accessor = UdaContext.DataAccessor;

        accessor.DataConnection.Open();

        try
        {
            IDataReader reader = null;
            try
            {
                reader = accessor.QueryDataReader("Select top 30 * from dbo.product");
                //reader = (IDataReader)accessor.Query("Select top 30 from dbo.product",
                 ResultType.DataReader);  //等效

                while (reader.Read())
                {
                    int count = reader.FieldCount;
                    for (int i = 0; i < count; i++)
                    {
                        System.Console.Write(string.Format("{0}={1}\t", reader.GetName(i), 
                        reader.IsDBNull(i) ? "null" : reader.GetValue(i)));
                    }
                    System.Console.Write("\n");
                }
            }
            finally
            {
                if (reader != null && !reader.IsClosed)
                    reader.Close();
            }
        }
        finally
        {
            accessor.DataConnection.Close();
        }
    }

         下面我们来使用DelegateQuery改造这个方法:

    /// <summary>
    /// 演示代理查询。
    /// </summary>
    public void DemeDelegateQuery()
    {
        IDataAccessor accessor = UdaContext.DataAccessor;
        accessor.DelegateQuery(new DataReaderHandler(this.InternalGetDataReader), 
        "Select top 30 * from dbo.product");
    }

    /// <summary>
    /// 代理方法。
    /// </summary>
    /// <param name="reader"></param>
    void InternalGetDataReader(IDataReader reader)
    {
        while (reader.Read())
        {
            int count = reader.FieldCount;
            for (int i = 0; i < count; i++)
            {
                System.Console.Write(string.Format("{0}={1}\t", reader.GetName(i), 
                reader.IsDBNull(i) ? "null" : reader.GetValue(i)));
            }
            System.Console.Write("\n");
        }
    }
              是不是这种方法感觉很简洁。

          有关本例子所涉及的数据表结构请参考基于AgileEAS.NET平台基础类库进行应用开发-总体说明及数据定义一文,有关数据对象模型定义文件、文档、DDL脚本请下载:http://files.cnblogs.com/eastjade/demo.db.doc.sql.rar,本文代码下载:UDA.Demo2.rar

 

链接

AgileEAS.NET平台开发指南-系列目录

AgileEAS.NET应用开发平台介绍-文章索引

一步一步教你使用AgileEAS.NET基础类库进行应用开发-系列目录

AgileEAS.NET平台应用开发教程-案例计划

AgileEAS.NET官方网站

敏捷软件工程实验室

QQ群:116773358

上一篇:VirtualBox 虚拟Ubuntu系统与主机互ping


下一篇:一起来学ES —— Bulk剖析