断线重连接.docVIP

unit UnitDemo; interface uses Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms, Dialogs, StdCtrls; type FrmDemo = class(TForm) Button1: TButton; procedure Button1Click(Sender: TObject); procedure FormCreate(Sender: TObject); procedure FormDestroy(Sender: TObject); private { Private declarations } public { Public declarations } end; var Form2: TForm2; //数据库服务器 gDBServer: String = 127.0.0.1; //数据库名称 gDBName: String = master; //数据库用户名 gDBUser: String = sa; //密码 gDBPass: String = 2001; implementation {$R *.dfm} uses ADODB, UnitADOConnectionPool; const CreateSQL = create procedure TestMyPool (@type sysname) #13#10+ as#13#10+ select * from sysobjects where xtype=@type#13#10+ return @@rowcount; DeleteSQL = if Exists(select 1 from sysobjects where xtype=NP and name=NTestMyPool)#13#10+ drop procedure TestMyPool; var gPoolMan: TADOConnPoolMan = Nil; procedure TForm2.Button1Click(Sender: TObject); var ADOObject:TADOConnPoolObject; ADOStoredProc:TADOStoredProc; Running :Integer; I: Integer; begin //取得一个存储过程资源（含一数据库有效连接） ADOObject := gPoolMan.CreateSP(TestMyPool); if ADOObject = Nil then //取得资源失败 Exit; try ADOStoredProc := ADOObject.ExecObject as TADOStoredProc; Running := 2;//允许重试(两次)操作，以便在操作失败之后达到重连 while Running0 do begin Dec(Running); if ADOObject.NeedRefresh then begin//判断是否有重连标志（比如数据库断开等，可能需要进行重连） if Not ADOObject.Reconnect then Exit; ADOObject.NeedRefresh := Not ADOStoredProc.Parameters.Refresh; if ADOObject.NeedRefresh then Exit; end; for I := 1(*Zero is the *Result* Parameter*) to ADOStoredProc.Parameters.Count - 1 do begin //========================= //传递参数 ADOStoredProc.Parameters.Items[I].Value := U; //========================= end; if Running 0 then try //执行存