DataRabbit 轻量的数据访问框架(08) -- DataRabbit 的入口点:TransactionScopeFactory和TransactionScope

   (完全限定类名:DataRabbit.Application.TransactionScopeFactory ,DataRabbit.Application.TransactionScope) 
     

     关于TransactionScopeFactory首先要提醒以下几点:
(1)TransactionScopeFactory是DataRabbit框架的入口点,所有的访问器、分页管理器大纲操作者都可以从TransactionScopeFactory生成的TransactionScope(事务范围)处获取。
(2)TransactionScopeFactory针对的是一个数据库,对于一个特定的数据库,应用程序只需要维护一个TransactionScopeFactory实例(引用)即可。

(3)可以按照类似下面的代码来构造TransactionScopeFactory实例: 

DataConfiguration config = new DataConfiguration(DataBaseType.SqlServer, "127.0.0.1", "sa", pwd", "TestDB", null);
config.MaxPoolSize = 100; //连接池最大连接数
config.MinPoolSize = 0;   //连接池最小连接数
config.CommandTimeoutInSecs = 30; //执行命令的最大超时时间(s)

TransactionScopeFactory transactionScopeFactory = new TransactionScopeFactory();
transactionScopeFactory.DataConfiguration = config;
transactionScopeFactory.DBExceptionFilter = new DBExceptionFilter("DBException.txt"); 
transactionScopeFactory.Initialize();

     DBExceptionFilter 用于捕获数据库访问时抛出的任何异常,上面的示例代码表示将会把所有的详细异常信息记录到当前目录的DBException.txt文件中。关于DBExceptionFilter 更详细的介绍,可参见这里

   前面讲了多种访问器,并且这些访问器都继承了ITransactionAccesser接口。我们已经知道,ITransactionAccesser的含义在于:访问器对象即可以工作于一个事务(Transaction)上下文中,也可以在脱离事务的环境中工作。前面举的所有示例中都没有涉及到事务,本文我们将介绍在DataRabbit中如何使用事务。      
   TransactionScope,表示一个事务的范围,我们可以从TransactionScope中获取前述的所有访问器实例,并且从中获取的访问器都是基于事务的(访问器的生命期将随事务的结束而结束)。TransactionScope的类图如下所示:

   首先,我们看到了一些以“New”打头的方法,这些方法用于创建各种基于事务的访问器对象。
   TransactionScope会在构造函数中启动事务,所以我们只有在需要事务的地方才构建TransactionScope实例。TransactionScope实例通常在Business Flow子层中创建。另外,TransactionScope支持两种使用模式:
 (1)自动模式:使用using块 ,将在异常发生时,自动回滚事务。
 (2)手动模式:不使用using块,可根据业务需要手动回滚事务(调用TransactionScope的Rollback方法),更具灵活性。
   
     我们可以通过DataRabbit.Application.TransactionScopeFactory来获得TransactionScope对象。

     下面我们举个非常简单的事务访问的例子,假设某个业务逻辑要求我们在Update某个student的Age的时候,必须在Book表中插入一条相关记录,这是一个事务性的动作。使用TransactionScope,我们可以轻易达成目标:

 

            //transactionScopeFactory通常以singleton模式使用
            TransactionScopeFactory transactionScopeFactory = ...;

            using (TransactionScope scope = transactionScopeFactory.NewTransactionScope(true))               
            {               
                IOrmAccesser<Student> stuOrmAccesser = scope.NewOrmAccesser<Student>();
                IOrmAccesser<Book> bookOrmAccesser = scope.NewOrmAccesser<Book>();

                //更新Student
                Student stu = new Student();
                stu.ID = 33;
                stu.Age = 28;
                stuOrmAccesser.Update(stu);

                //插入Book
                Book book = new Book();
                book.ID = 9;
                book.StudentID = stu.ID;
                bookOrmAccesser.Insert(book);

                scope.Commit(); //提交事务,别忘了这句            
            }

 

     上述代码如果在Update或Insert的时候抛出异常,事务将会自动回滚,这是在TransactionScope的Dispose方法中做到的。

     如果不需要事务支持,则transactionScopeFactory.NewTransactionScope(true)方法的参数由true改为false即可,其它的都不用作任何改变,这使得开启/关闭事务的控制变得非常的简单。             

转到:DataRabbit 轻量的数据访问框架 -- 序

时间: 2024-10-22 22:16:50

DataRabbit 轻量的数据访问框架(08) -- DataRabbit 的入口点:TransactionScopeFactory和TransactionScope的相关文章

DataRabbit 轻量的数据访问框架(09) -- IDataSchemaAccesser

   (完全限定类名:DataRabbit.Schema.IDataSchemaAccesser)    在前面介绍的很多访问器的实现中,都不需要使用者提供任何关于数据库表结构的信息(比如,主键.主外键关系等),这是因为它们都借助于IDataSchemaAccesser来获取目标数据表的大纲信息,本文就来介绍如何使用DataRabbit框架中的IDataSchemaAccesser来访问和操作数据表的大纲.    我们可以从DataRabbit的入口点IDataAccesser中获取IDataS

DataRabbit 轻量的数据访问框架(10) -- IPagerManager

   (完全限定类名:DataRabbit.Core.IPagerManager)    DataRabbit框架提供了对单表查询的结果进行分页的功能,这就是IPagerManager所完成的目标.我们可以从DataRabbit的入口点IDataAccesser中获取IPagerManager引用:     PagerParameters param = ...; //构建分页参数    IPagerManager pagerManager= dataAccesser.GetPagerManag

DataRabbit 轻量的数据访问框架(06) -- IRelationAccesser

   (完全限定类名:DataRabbit.Relation.IRelationAccesser)       前面介绍的IOrmAccesser是对单表进行ORM访问,而ITableAccesser是对单表进行基于关系的访问,如果我们要进行联合查询这样的跨表搜索,则使用它们就无法达成目标.这时,你可以使用IRelationAccesser.与IOrmAccesser和ITableAccesser的针对性不同(它们针对数据库中的某个表),IRelationAccesser针对的是整个目标数据库.

DataRabbit 轻量的数据访问框架(07) -- ISPAccesser

   (完全限定类名:DataRabbit.Relation.ISPAccesser)       虽然IRelationAccesser可以调用一些不含out参数的存储过程,但是在DataRabbit中调用存储过程最好是通过ISPAccesser接口来进行.   存储过程不仅可以有返回值,还可以有[in,out]参数,在对存储过程的调用进行封装之前,首先必须抽象存储过程的参数表示.DataRabbit使用SPParameter来表示存储过程的参数.   注意,Name属性表示参数名,该参数名不

DataRabbit 轻量的数据访问框架(13)--DataRabbit 3.0 ORM性能大幅度提升!

   DataRabbit 3.0重写了DataRabbit 2.0的ORM实现的内核,性能提升了90倍左右,结果是DataRabbit 3.0的ORM性能与直接使用ADO.NET的性能已经非常接近.这是如何做到的?   主要是基于两点:(1)DataRabbit 2.0 基于泛型和反射实现,而DataRabbit 3.0 基于泛型和Emit动态程序集实现.   DataRabbit 2.0使用反射机制将值在O和R之间传递,如此大量使用反射会使性能折损不少.DataRabbit 3.0在运行时,

DataRabbit 轻量的数据访问框架(03) -- IOrmAccesser(续)

   本文将接着 DataRabbit 轻量的数据访问框架 -- IOrmAccesser 继续介绍IOrmAccesser的一些高级功能.这些高级功能需要DataRabbit.ORM.ISmartEntity接口的支持.注意,对于Entity class 来说,该接口并不是强制的. (1)关于含自增字段的Entity插入:      插入后,Entity中对应自增字段的属性将被正确地赋为数据库中自增结果值.    如果Entity class 继承了ISmartEntity接口,那么这个Ent

DataRabbit 轻量的数据访问框架(05) -- ITableAccesser

   (完全限定类名:DataRabbit.Relation.ITableAccesser)       ORM并不能完成所有的事情,有些数据库访问还是需要基于关系来进行,对于那些不提供基于关系进行数据访问操作的纯ORM框架,我认为是不明智的.在DataRabbit中,基于ORM的访问和基于关系进行数据访问各占了一半的天空,这使得我们在无法用ORM达成的地方,可以转向使用基于关系的访问器来达成.DataRabbit.Relation命名空间下的类和接口用于提供基于关系的数据库访问操作,主要包括:

DataRabbit 轻量的数据访问框架(04) -- IEntityRelationLoader

  (完全限定类名:DataRabbit.ORM.IEntityRelationLoader)    在DataRabbit框架提供的ORM功能之中,除了IOrmAccesser接口展现的核心ORM功能外,IEntityRelationLoader接口也提供了一些有意义的功能.正如其名,IEntityRelationLoader是通过数据表的主外键关系来加载当前Entity的Parent和Children.    现在对我们前面示例经常用到的Student数据表做个扩充,假设,Student表的

DataRabbit 轻量的数据访问框架(15)-- IOrmAccesser的BatchInsert批量插入!

   DataRabbit3.0为ORM访问器提供了批量插入的功能,其方法定义如下:         /// <summary>        /// BatchInsert 批量插入一组记录.忽略所有Blob字段.        /// </summary>               void BatchInsert(IList<EntityType> entityList);     当我们需要一次性向同一Table中插入大量(如千条以上)的记录时,使用Batch