上文回顾
上一篇文章基于AgileEAS.NET平台基础类库进行应用开发-使用UDA操纵SQL语句一文中演示如何使用UDA进行常规的业务进行操作,我们看到两种数据操纵流程,一种是原始的操作流程,另一种是简化的数据操作流程,应用开发人员不用关心数据库的打开与关闭,这些工作由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基础类库进行应用开发-系列目录
QQ群:116773358