分享
 
 
 

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

王朝delphi·作者佚名  2006-01-08
窄屏简体版  字體: |||超大  

问题提出:写了一个数据库操作的类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,搞定。

第一个版本,水平有限,还需要在实际应用中完善,全当抛砖引玉,请有经验的大侠们拍砖吧:)

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
2023年上半年GDP全球前十五强
 百态   2023-10-24
美众议院议长启动对拜登的弹劾调查
 百态   2023-09-13
上海、济南、武汉等多地出现不明坠落物
 探索   2023-09-06
印度或要将国名改为“巴拉特”
 百态   2023-09-06
男子为女友送行,买票不登机被捕
 百态   2023-08-20
手机地震预警功能怎么开?
 干货   2023-08-06
女子4年卖2套房花700多万做美容:不但没变美脸,面部还出现变形
 百态   2023-08-04
住户一楼被水淹 还冲来8头猪
 百态   2023-07-31
女子体内爬出大量瓜子状活虫
 百态   2023-07-25
地球连续35年收到神秘规律性信号,网友:不要回答!
 探索   2023-07-21
全球镓价格本周大涨27%
 探索   2023-07-09
钱都流向了那些不缺钱的人,苦都留给了能吃苦的人
 探索   2023-07-02
倩女手游刀客魅者强控制(强混乱强眩晕强睡眠)和对应控制抗性的关系
 百态   2020-08-20
美国5月9日最新疫情:美国确诊人数突破131万
 百态   2020-05-09
荷兰政府宣布将集体辞职
 干货   2020-04-30
倩女幽魂手游师徒任务情义春秋猜成语答案逍遥观:鹏程万里
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案神机营:射石饮羽
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案昆仑山:拔刀相助
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案天工阁:鬼斧神工
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案丝路古道:单枪匹马
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:与虎谋皮
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:李代桃僵
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:指鹿为马
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案金陵:小鸟依人
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案金陵:千金买邻
 干货   2019-11-12
 
推荐阅读
 
 
 
>>返回首頁<<
 
靜靜地坐在廢墟上,四周的荒凉一望無際,忽然覺得,淒涼也很美
© 2005- 王朝網路 版權所有