用Delphi模拟组件的两阶段提交

2/4/2006来源:Delphi教程人气:9432

问题提出:写了一个数据库操作的类TDBOperate_DL,统一对数据库的操作嘛。提供了声明事务开始、提交事务和回滚事务的方法供其他类调用。
TDBOperate_DL = class
  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;
记着保持程序中使用唯一的操作数据库类TDBOperate_DL的实例,记着释放业务类实例,如果是需要事务的,尽量早释放,OK,搞定。
第一个版本,水平有限,还需要在实际应用中完善,全当抛砖引玉,请有经验的大侠们拍砖吧:)