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

简介:
上文回顾
      上一篇文章 基于AgileEAS.NET平台基础类库进行应用开发-使用UDA操纵SQL语句一文中演示如何使用UDA进行常规的业务进行操作,我们看到两种数据操纵流程,一种是原始的操作流程,另一种是简化的数据操作流程,应用开发人员不用关心数据库的打开与关闭,这些工作由UDA为我们完成,我们只需要实现与业务相关代码即可。
问题引出
       我们现在再看一眼我们在前面提供的数据处理流程:
image
        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
 
链接
QQ群:116773358

本文转自 agilelab 51CTO博客,原文链接:http://blog.51cto.com/agilelab/603010

相关文章