基于DotNet构件技术的企业级敏捷软件开发平台 - AgileEAS.NET平台开发指南 - 数据访问

统一数据访问介绍

         统一数据访问(Uniform Data Access,简写为UDA)用于隔离系统和数据平台,使系统可以在各种数据库平台上自由移植。该数据库访问接口要求通过该接口对数据库进行访问的模块要提交标准的SQL语句,而不仅仅是对当前数据库有效的语句。

         统一数据访问与数据层分离是相互相成的两个概念和实践、统一数据访问为数据层分离提供数据库访问环境及接口的独立、接口驱动及数据层体系结构的一致性提供保证。

         统一数据访问内部自动包装ADO.NET,具体使用何种数据库则在外部由系统管理员定义在配置文件中。统一数据访问接口内部提供对数据库连接对象、数据命令对象、事务对象等的管理,因此客户端不需要自己管理这些对象,只需要提交数据库命令即可。

         在UDA中主要的数据结构为“结果数据”。结果数据是数据库操作的结果的包装。如果是一个查询命令,则可能返回一个IDataReader对象、一个DataSet对象、一个DataTable对象、一个IDictionary对象、一个IList对象、一个数据对象(在数据对象管理中定义的数据结构)或者一个单纯的结果等,当然用户可以要求以XML的格式返回数据。

         AgileEAS.NET提供了IDataAccessor和IDataConntion两个接口:

         IDataAccessor提供了对数据的操作:查询结果和执行SQL语句两种基本操作,同时提供了SQL批处理、代理查询和事务委托操作,而IDataConnetion相当于为IDataAccessor提供了一个数据库执行环境。

          数据访问器(IDataAccessor)是统一数据访问中进行数据存取的接口,他生存于数据库环境IDataAccessor之中,客户端只需通过该访问器提供的方法并为这些方法提供适当的参数进行数据库操作。访问器内部自动在当前数据库连接上创建数据库命令,并包装返回的结果。

         目前实现了SQL数据库(SQLServerConnection、SQLServerAccessor)、OleDb数据库(OleDbConnection、OleDbAccessor)、ODBC数据库(ODBCConnection、ODBCAccessor),ORACLE数据库由单独的数据库访问服务程序集实现。

详解Query和Execute

         上面简单的介绍了UDA及其中最主要的两个接口,在这两个接口中,IDataAccessor接口是负责数据操纵业务的,其中定义了最重要的两个重载方法Query和Execute。

         我们来看看Query的重载:

         /// <summary>
         /// 执行给定的数据库查询命令。
         /// </summary>
         /// <param name="commandString">要执行的命令语句。</param>
         /// <param name="commandType">要执行的命令的类型。</param>
         /// <param name="parameters">命令执行需要的参数。</param>
         /// <param name="resultType">调用方要求的返回结果的类型。</param>
         /// <returns>返回查询到的数据结果。</returns>
         object Query(string commandString, System.Data.CommandType commandType, ParameterCollection parameters, EAS.Data.Access.ResultType resultType);

         在AgileEAS.NET中Query针对不同的返回类型只提供一个方法,根据最后一个参数返回类型返回不同的的查询结果,于是产生一次装备操作,上层的调用者需要解决拆箱处理,下面看看返回类型:

         Default:默认。这种类型的结果一般用于返回单个查询值或者一个聚合值(比如 count、max等的值)。

         DataReader:返回一个 IDataReader对象。由于 IDataReader对象数据库的访问是面向连接的,而 Query 方法内部符合前面的IConnection操作模式,因此如果要返回一个 IDataReader,则必须在调用 Query 方法前打开相应的 IConnection,并在对IDataReader操作结束后关闭 IConnection,否则Query方法返回前会关闭 IConnection而导致 IDataReader不可用。可以使用DataReaderHandler委托解决这个问题。

         DataSet:返回一个 System.Data.DataSet对象。用于获取一个非面向连接的数据集合。

         DataTable:返回一个System.Data.DataTable对象。用于获取一个非面向连接的数据集合。

         Dictionary:返回一个 IDictionary接口集合对象。用于获取一个非面向连接的数据库记录。记录的字段映射到字典的键。

         List:返回一个 System.Collections.IList对象。用于获取一个非面向连接的数据库记录的集合,每一个记录只有一个字段。

         接着我们来看看Execute的重载:

         /// <summary>
         /// 执行指定的非查询命令。
         /// </summary>
         /// <param name="commandString">要执行的命令语句。</param>
         /// <param name="commandType">要执行的命令类型。</param>
         /// <param name="parameters">要执行的命令的参数集合。</param>
         /// <returns>返回命令影响的行数。</returns>
         int Execute(string commandString, System.Data.CommandType commandType, ParameterCollection parameters);

         Execute直接返回查询所影响的行数。

数据处理过程

         AgileEAS.NET平台在访问数据库时定了一个原则:IDataAccessor不得随意变更IDataConnetion的状态,我们知道在访问数据库时需要打开和关闭数据库操作,所以在IDataAccessor执行SQL命令过程上,首先判读IDataConnetion是否打开,如果未打开则执行IDataConnetion.Open()并在执行SQL完毕进行IDataConnetion.Close()。

         bool open = this.Connection.IsOpen;
         if(!open)
         this.Connection.Open();
         try
             {
                 //执行SQL
             }
         finally
             {
                  if(!open)
                           this.Connection.Close();
         }

委托查询

         而在执行查询命令时有一种返回结果IDataReader,这种状态需要数据库一直保持打开状态,所以我们增加了一个委托方法DelegateQuery,委托DataReaderHandler定义如下:

         /// <summary>
         /// 定义以DataReader作为结果返回时的数据访问委托。
         /// </summary>
         /// <remarks>
         /// 该委托的实例可以由Accessor.DelegateQuery方法在内部调用,这样委托实例就不需要考虑关闭DataReader的问题。
         /// </remarks>
         public delegate void DataReaderHandler(System.Data.IDataReader dataReader);

         程序员在开发过程中如果需要不处理数据库打开和关闭操作而需要返回IDataReader类型的处理结果,可以使用如下形式的处理:

         private void button3_Click(object sender, EventArgs e)
        {
         IDataAccessor dataAccessor = new OleDbConnection().CreateDataAccessor();;
            dataAccessor.DelegateQuery(new DataReaderHandler(LoadToUI), "SELECT * FROM Table1");
        }
         private void LoadToUI(IDataReader reader)
        {
         while (reader.Read())
            {
         // 业务代码
            }
   }

事务委托

         在数据库事务这一块,提供了除正常的开启事务、关闭事务之后,我更推荐一种事务委托和方式去执行,IDataAccessor提供了TransactionExecute方法,其委托TransactionHandler定义:

         /// <summary>
         /// 定义数据库操作的事务处理委托。该委托将代表客户执行数据库事务,这样使用者不需要考虑事务的开始和结束。
         /// </summary>
         public delegate int TransactionHandler(IDataAccessor Accessor);

         下面列一个例程:

         private void button3_Click(object sender, EventArgs e)
        {
                 IDataAccessor dataAccessor = new OleDbConnection().CreateDataAccessor();;            
                  dataAccessor.TransactionExecute(new TransactionHandler(SaveData));
        }
         private int SaveData(IDataAccessor accessor)
        {
                  int iAff = 0;
                     iAff+=accessor.Execute("...");
                           //
                     iAff += accessor.Execute("...");
                  return iAff;
        }

获取UDA对象

         UDA中的IDataConnection对象继承自EAS.Sessions.ISessionResource接口,也就是说UDA中的数据连接也是一种会话资源,可以通过取于上下文提供的会议中读取:

         //取当前会话连接
         IDataConnection dbcn = session.Resouces.FindResources(typeof(IDataConnection))[0] as IDataConnection;
         //访问器
         IDataAccessor dataAccessor = dataConnection.CreateDataAccessor();

         或者直接从上下文环境的IOC容器中直接获取:

         EAS.Objects.IContainer container = ContextHelper.Context.Container;
         //取数据连接
         IDataConnection dbcn = container.GetServiceComponentInstance(typeof(IDataConnection)) as IDataConnection;
         //访问器
         IDataAccessor dataAccessor = dataConnection.CreateDataAccessor();

         不同通过何种方式获取UDA对象,我们都无法在编程时预先知道他的具体实现,AgileEAS.NET平台实践着而向接口驱动的思想,UDA对象的具体实例类型写在配置文件中:

  <object name="MasterDataAccessor" assembly="EAS.Data" type="EAS.Data.Access.OleDbAccessor" LifestyleType="Singleton">
  <property name="Connection" type="object" value="MasterDbConnection" />
  </object>
  <object name="MasterDbConnection" assembly="EAS.Data" type="EAS.Data.Access.OleDbConnection" LifestyleType="Singleton">
  <property name="ConnectionString" type="string" value="Provider=SQLOLEDB.1;Persist Security Info=False;User ID=sa;Password=sa;Initial Catalog=EAS;Data Source=vm2003" />
  </object>

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏黑白安全

宽字节注入详解分析

简介  宽字节注入,它的作用可以绕过转义,也是绕过转义的其中一个办法  宽字节注入源于程序员设置MySQL连接时错误配置为:set character_set_...

65220
来自专栏运维

Python Elasticsearch API操作ES集群

关键是DSL语法的编写涉及查询与聚合可以通过kibana的visualize或者devtool先测试出正确语法,然后结合python对列表、字典、除法、字符串等...

29910
来自专栏腾讯Bugly的专栏

Android 平台 Native 代码的崩溃捕获机制及实现

一、背景 在Android平台,native crash一直是crash里的大头。native crash具有上下文不全、出错信息模糊、难以捕捉等特点,比jav...

1.2K70
来自专栏jouypub

修改MYSQL中group_concat的长度限制

在mysql中,有个函数叫“group_concat”,平常使用可能发现不了问题,在处理大数据的时候,会发现内容被截取了,

1.4K20
来自专栏小樱的经验随笔

【经验分享】后台常用的万能密码

这万能密码好几年前就有了。我都不当回事,结果这次真派上用场了,还真进了后台了 网站后台万能密码就是在用户名与密码处都写入下列字符,如果知道管理员帐号的话直接添...

1.2K50
来自专栏PHP在线

mysqli_stmt::get_result 方法的替代方案

作者:西瓜玩偶(racnil070512 at hotmail dot com) 我们都知道,在mysqli库中,通过 mysqli_stmt::execut...

358120
来自专栏Java后端技术栈

Java多线程编程-(12)-单例模式几种写法的错与对

在所有的主流23中设计模式中,单例模式作为最简单也最容易理解也是使用最普遍的设计模式,他是一种对象创建模式,用于产生一个对象的具体实例,他可以确保系统中一个类只...

9120
来自专栏小勇DW3

Java设计模式-单例模式

作为对象的创建模式,单例模式确保其某一个类只有一个实例,而且自行实例化并向整个系统提供这个实例,这个类称为单例类。单例模式有以下特点:

12750
来自专栏Django Scrapy

python3 下调用zabbix api 获取多个机房的IP

根据工作的需要,需要查看监控中的所有ip,我们一共有三个机房,每个机房都部署了同样的zabbix监控 根据三个园区的 监控api的url 实现功能:不输入参数 ...

37550
来自专栏Java架构师进阶

Mybatis的二级缓存配置

 缓存将使用LRU(Least Recently Used)最近最少使用策略算法来回收

7120

扫码关注云+社区

领取腾讯云代金券