|
问题提出：写了一个数据库操作的类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
[1] [2] [3] 下一页 | 
