用Delphi模拟组件的两阶段提交
| 问题提出：写了一个数据库操作的类TDBOperate_DL，统一对数据库的操作嘛。提供了声明事务开始、提交事务和回滚事务的方法供其他类调用。 private ADOC:TADOConnection; ADOQ:TADOQuery; isDestroyADOC:Boolean; //是否销毁自己的ADOC？ fIsInTrans:Boolean; //是否已经开始事务 public isCommit:Boolean; //是否要提交事务，缺省是真，如果有类投票说反对提交，就为假 function IsInTrans:Boolean; constructor Create(const newADOC:TADOConnection);overload; constructor Create(const ServerName,DataBaseName,UserID,Password:String);overload; destructor Destroy;override; procedure BeginTrans; procedure CommitTrans; procedure RollbackTrans; procedure Execute(const sqlString:String); function GetDataset(const sqlString:String):_Recordset; function GetConnection:TADOConnection; procedure SetConnection(const newADOC:TADOConnection); end; 一些函数的实现： procedure TDBOperate_DL.BeginTrans; //开始事务 begin self.ADOC.BeginTrans; self.fIsInTrans := true; end; procedure TDBOperate_DL.CommitTrans; //提交事务 begin self.ADOC.CommitTrans; self.fIsInTrans := false; end; procedure TDBOperate_DL.RollbackTrans; //回滚事务 begin self.ADOC.RollbackTrans; self.fIsInTrans := false; end; function TDBOperate_DL.IsInTrans: Boolean; //查看事务是否已开始 begin result := self.fIsInTrans; end; 写了一个TThing类，用于向数据库中添加、修改或删除有关某种东西的记录，调用TDBOperate_DL类完成。为了调用方便，因此有关的事务就放在了TThing类中，外部调用时不用考虑事务了。 procedure Tthing.Drop(const thing:String); var sqlString:String; begin sqlString := 删除的SQL语句; self.DBOperate.BeginTrans; // DBOperate是TDBOperate_DL类型的私有变量，创建Tthing类实例时传入的参数。 try self.DBOperate.Execute(sqlString); self.DBOperate.CommitTrans; except self. DBOperate.RollbackTrans; raise; end; end; 后来又写了个TPerson类，用于向数据库中添加、修改或删除有关人的记录。同样事务放在了TPerson类中，现在我想删除人的记录时顺便调用TThing类删除和人有关的东西，事务问题就出现啦：事务不能嵌套啊。如果先删除TThing，再重新声明事务删除TPerson，如果TPerson出错，还怎么回滚TThing？ 如： procedure Tperson.Drop(const person:String); var sqlString:String; thing:Tthing; begin sqlString := 删除的SQL语句; thing := Tthing.Create(self.DBOperate); //TDBOperate_DL类型的DBOperate是作为参数传进去的。 Self.DBOperate.BeginTrans; Try Thing.Drop(person); //里面有事务见上面的代码 Self.DBOperate.Execute(sqlString); self.DBOperate.CommitTrans; except self.DBOperate.RollbackTrans; raise; end; end; 解决方法，两阶段提交，先粘点背景知识： 不论两层或三层体系，事物处理都是通过两阶段提交实现的。在第一阶段，每个执行的的资源/记录被写入 事物环境（Transcation Context）中,然后资源协调者顺序查询每一个参与事物的执行是否成功，如果都没有问题的话，就进入第二阶段，每个执行都开始Commit它的操作。如果有一个执行有问题的话，资源协调者通知所有下属的执行放弃Commit,恢复数据原状态。 参考COM+的事务运行，如果一个组件是需要事务的，那么在组件创建时，事务就已经开始了，在组件销毁时进行事务投票，如果是根事务，则进行提交或回滚事务。（如果组件支持池化，这两种情况发生在组件激活和休眠事件中）。于是我们定义一个类如下。 //业务类的祖先类，用于提供统一的事务支持 TTS_DL = class private isRootTrans:Boolean; //是否是根事务 isNeedTrans:Boolean; //是否需要事务 public DBOperate:TDBOperate_DL; //操作数据库的类的实例 procedure SetComplete; procedure SetAbort; constructor Create(const newDBOperate:TDBOperate_DL;needTrans:Boolean);//是否需要事务支持 destructor Destroy;override; end; 在该类创建时，除了传递进操作数据库的类的实例外，再传入一个是否需要事务的标志，因为如果是只做读取数据库的操作，就用不着事务了。 类实现代码如下： constructor TTS_DL.Create(const newDBOperate: TDBOperate_DL; needTrans: Boolean); begin inherited Create; self.DBOperate := newDBOperate; self.isNeedTrans := needTrans; //赋值是否需要事务 if self.isNeedTrans then begin //如果在事务里，就不是根事务，保留事务上下文里isCommit的值不变 if self.DBOperate.isInTrans then self.isRootTrans := false else begin self.DBOperate.BeginTrans; //是根事务，就开始事务 self.isRootTrans := true; self.DBOperate.isCommit := true; //初始化提交标志为要提交事务 end; end; end; destructor TTS_DL.Destroy; begin if self.isNeedTrans then begin //如果是根事务，就按照投票结果进行事务提交或回滚 if self.isRootTrans then begin if self.DBOperate.isCommit then self.DBOperate.CommitTrans else self.DBOperate.RollbackTrans; end; end; inherited; end; procedure TTS_DL.SetAbort; begin self.DBOperate.isCommit := self.DBOperate.isCommit And false; //投票说要回滚 end; procedure TTS_DL.SetComplete; begin self.DBOperate.isCommit := self.DBOperate.isCommit And true; //投票说要提交 end; 回到刚才的业务类Tthing和Tperson，这次都从TTS_DL类继承下来。 Tthing = class(TTS_DL); Tperson = class(TTS_DL); Tthing的删除代码该为如下： procedure Tthing.Drop(const thing:String); var sqlString:String; begin sqlString := 删除的SQL语句; try self. DBOperate.Execute(sqlString); self. DBOperate.SetComplete; //投票提交 except self. DBOperate.SetAbort; //投票回滚 raise; end; end; Tperson的删除代码如下： procedure Tperson.Drop(const person:String); var sqlString:String; thing:Tthing; begin sqlString := 删除的SQL语句; thing := Tthing.Create(self. DBOperate,true); //TDBOperate_DL类型的DBOperate是作为参数传进去的，true代表需要事务。 Try Try Thing.Drop(person); Self.DBOperate.Execute(sqlString); self.DBOperate.SetComplete; //投票提交 except self. DBOperate.SetAbort; //投票回滚 raise; end; finally thing.free; //记着一定要释放 end; end; |