连接失败，自动重试的实现？(100分)

清越小生 · 2008-01-02

程序开始时进行数据库的连接，在程序进行数据库操作过程中出现数据库连接失败，怎么样实现自动进行重新连接，而不显示“连接失败”，当重试次数达到一定数量时才进行提示呢？请高手赐教！

Dstorm · 2008-01-02

var   bConnOk : boolean; bConnOk := false; for i := 0 to retryCount -1 do begin   try     Conn.Connect;     bConnOk := true;     Break;   except   end; end;   if not bConnOk then   begin     MessageBox('连接数据库失败!');     Exit;   end;

Delphiguanshui · 2008-01-02

新年同樂啊。。。。。

清越小生 · 2008-01-02

楼上的朋友，这个我知道，我的问题是在已经连接成功的情况下，发生了“连接断了”的时候，该怎样让其自动重新连接呢？

Delphizhou · 2008-01-02

設置個時間自動刷新吧。

清越小生 · 2008-01-02

问题的关键是“连接中断”的时候系统会自动出一个提示，而不是我程序控制，我的目的就是不自动出提示，而是我自己进行重新连接！

xcplates · 2008-01-02

在合适的地方用try块包起来。 这是我的一个代码，连接到sql  server 数据库的，你自己看看吧 unit main; interface uses   Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,   Dialogs,IniFiles,bsSkinData, BusinessSkinForm, bsSkinCtrls,   ExtCtrls,   MIDASLIB, Grids, DBGrids, DB, ADODB, StdCtrls, ComCtrls, bsSkinTabs,   bsMessages, cxStyles, cxCustomData, cxGraphics, cxFilter, cxData,   cxDataStorage, cxEdit, cxDBData, cxGridLevel, cxClasses, cxControls,   cxGridCustomView, cxGridCustomTableView, cxGridTableView,   cxGridDBTableView, cxGrid, bsSkinBoxCtrls, Buttons; type   TFrmMain = class(TForm)     bsBusinessSkinForm1: TbsBusinessSkinForm;     bsSkinData1: TbsSkinData;     bsCompressedStoredSkin1: TbsCompressedStoredSkin;     bsSkinStatusBar1: TbsSkinStatusBar;     bsSkinStatusPanel1: TbsSkinStatusPanel;     Timer1: TTimer;     bsSkinPanel1: TbsSkinPanel;     bsSkinButton1: TbsSkinButton;     ListBox1: TListBox;     bsSkinPageControl1: TbsSkinPageControl;     bsSkinTabSheet1: TbsSkinTabSheet;     bsSkinTabSheet2: TbsSkinTabSheet;     bsSkinTabSheet3: TbsSkinTabSheet;     bsSkinButton2: TbsSkinButton;     Label1: TLabel;     ADOConnection1: TADOConnection;     bsSkinMessage1: TbsSkinMessage;     btnOpenDB: TbsSkinButton;     ADO_TuserOnline: TADOQuery;     dsADO_TuserOnline: TDataSource;     cxGrid1DBTableView1: TcxGridDBTableView;     cxGrid1Level1: TcxGridLevel;     cxGrid1: TcxGrid;     bsSkinCheckRadioBox1: TbsSkinCheckRadioBox;     bsSkinSpinEdit1: TbsSkinSpinEdit;     Label2: TLabel;     bsSkinButton3: TbsSkinButton;     cxGrid1DBTableView1UserID: TcxGridDBColumn;     cxGrid1DBTableView1UserLoginTime: TcxGridDBColumn;     cxGrid1DBTableView1UserUpdateTime: TcxGridDBColumn;     cxGrid1DBTableView1UserOnlineTime: TcxGridDBColumn;     cxGrid1DBTableView1UserEvent: TcxGridDBColumn;     cxGrid1DBTableView1UserMCode: TcxGridDBColumn;     ADOQ_TUserLogs: TADOQuery;     dsADOQ_TUserLogs: TDataSource;     cxGrid2DBTableView1: TcxGridDBTableView;     cxGrid2Level1: TcxGridLevel;     cxGrid2: TcxGrid;     cxGrid2DBTableView1UserID: TcxGridDBColumn;     cxGrid2DBTableView1UserLogEvent: TcxGridDBColumn;     cxGrid2DBTableView1UserLoginDate: TcxGridDBColumn;     cxGrid2DBTableView1UserMCode: TcxGridDBColumn;     cxGrid2DBTableView1UserIP: TcxGridDBColumn;     bsSkinCheckRadioBox2: TbsSkinCheckRadioBox;     bsSkinSpinEdit2: TbsSkinSpinEdit;     Label3: TLabel;     bsSkinButton4: TbsSkinButton;     bsSkinButton5: TbsSkinButton;     cxGrid1DBTableView1UserName: TcxGridDBColumn;     cxGrid1DBTableView1TypeName: TcxGridDBColumn;     ADOQ_TUserLogsUserType: TSmallintField;     ADOQ_TUserLogsUserPass: TStringField;     ADOQ_TUserLogsUserName: TStringField;     ADOQ_TUserLogsUserID: TStringField;     ADOQ_TUserLogsUserLogEvent: TStringField;     ADOQ_TUserLogsUserLoginDate: TDateTimeField;     ADOQ_TUserLogsUserMCode: TStringField;     ADOQ_TUserLogsUserIP: TStringField;     ADOQ_TUserLogsTypeName: TStringField;     cxGrid2DBTableView1UserName: TcxGridDBColumn;     cxGrid2DBTableView1TypeName: TcxGridDBColumn;     bsSkinCheckRadioBox3: TbsSkinCheckRadioBox;     bsSkinSpinEdit3: TbsSkinSpinEdit;     Label4: TLabel;     Label6: TLabel;     Label7: TLabel;     Label8: TLabel;     Label9: TLabel;     bsSkinGroupBox1: TbsSkinGroupBox;     ADO_TuserOnlineID: TAutoIncField;     ADO_TuserOnlineUserID: TStringField;     ADO_TuserOnlineUserLoginTime: TDateTimeField;     ADO_TuserOnlineUserUpdateTime: TDateTimeField;     ADO_TuserOnlineUserOnlineTime: TIntegerField;     ADO_TuserOnlineUserEvent: TStringField;     ADO_TuserOnlineUserMCode: TStringField;     ADO_TuserOnlineTypeName: TStringField;     ADO_TuserOnlineUserName: TStringField;     ADO_TuserOnlineUserType: TSmallintField;     procedure FormCreate(Sender: TObject);     procedure bsSkinButton1Click(Sender: TObject);     procedure ADOConnection1AfterConnect(Sender: TObject);     procedure ADOConnection1AfterDisconnect(Sender: TObject);     procedure btnOpenDBClick(Sender: TObject);     procedure bsSkinButton3Click(Sender: TObject);     procedure bsSkinButton4Click(Sender: TObject);     procedure bsSkinButton5Click(Sender: TObject);     procedure Timer1Timer(Sender: TObject);     procedure FormClose(Sender: TObject; var Action: TCloseAction);     procedure bsSkinButton2Click(Sender: TObject);   private     { Private declarations }   public     { Public declarations }     function  SetServerINFO:string;//读取服务器信息并     procedure ConnectIn(i:integer);     procedure OpenDB(COnStr:string;ShowMSG:boolean);// 连接到数据库服务器     procedure SVRUpdateOnlineInfo(lUpDateTimes:integer);//服务器定时更新用户在线信息   end; var   FrmMain: TFrmMain;   SerIP:string;//服务器IP   ConnStr:string;//连接串   listened:boolean;//是否处在监听状态   ConSum:longInt;//总连接数   DBConnected:boolean;//数据库服务器是否可连接   UpDateTimes:integer=100;//客户端超过100秒没有更新，说明已经非正常掉线，删除其在线信息。   UpDateTimesCount:integer;//自动刷新计时器   UpdateOnlineTimes:integer;//用户在线信息自动刷新计时器   UpdateUserLogsTimes:integer;//用户登录信息自动刷新计时器   ConnDisconnected:boolean;//数据库非正常断开   ConnTimes:integer;//连接数据库时间的计时器 implementation  uses  SetINI,u_Const; {$R *.dfm} procedure TFrmMain.SVRUpdateOnlineInfo(lUpDateTimes:integer);//服务器定时更新用户在线信息     //*@UserID VARCHAR(16),     //@UserEvent VARCHAR(100),     //@UserMCode VARCHAR(50) var   ADOSPTemp: TADOStoredProc; begin   ADOSPTemp:=TADOStoredProc.Create(self);   ADOSPTemp.Connection :=ADOConnection1;   ADOSPTemp.Parameters.Clear;   try     with ADOSPTemp do     begin      Parameters.Clear;      ProcedureName:='U_SVRUpdateOnlineInfo';      Parameters.CreateParameter('@UpDateTimes',ftInteger,pdInput,6,lUpDateTimes);      Parameters.ParamByName('@UpDateTimes').Value:=lUpDateTimes;      ExecProc;     end;   finally     ADOSPTemp.Free;   end; end; procedure TFrmMain.openDB(ConStr:string;ShowMSG:boolean);// 连接到数据库服务器 begin    try      if ADOQ_TUserLogs.Active then         ADOQ_TUserLogs.Close;      if ADO_TuserOnline.Active then         ADO_TuserOnline.Close;      if ADOConnection1.Connected then        ADOConnection1.Close;      ADOConnection1.ConnectionString:=ConStr;      ADOConnection1.Open;      ADOQ_TUserLogs.Open;      ADO_TuserOnline.Open;      ConnDisconnected:=false;    except      ConnDisconnected:=true;      ConnTimes:=0;      UpdateOnlineTimes:=0;      UpdateUserLogsTimes:=0;      DBConnected:=false;      if ShowMSG then      begin      timer1.Enabled:=false;      bsSkinMessage1.MessageDlg('连接到数据库服务器失败'#13'可能的原因：'#13'1、网络故障，'+                                '请检查网络后重新再试！'#13'2、你设置的帐号没有登录权限，'+                                '请向你们的管理员咨询。'#13'3、数据库服务器没有运行，请向系统管理员咨询',                                (mtinformation),[mbOK],0);      timer1.Enabled:=true;      end;    end; end; procedure TFrmMain.ConnectIn(i:integer); var  p:TUser; begin   ConSum:=ConSum+(i);   showmessage(p.SysAut); end; function  TFrmMain.SetServerINFO:string;//读取服务器信息并 var   ServerINI:string;   ini:tinifile;   ConStr:string;   ID,IP,PWD:string; begin   ServerINI:=ExtractFilePath(Application.ExeName)+'Server.INI';   if not FileExists(ServerINI) then   begin     Showmessage('你是第一次运行本程序，请单击确定设置服务器信息!');     FrmSetINI:=TFrmSetINI.Create(self);     FrmSetINI.ShowModal;   end;   ini:=tinifile.Create(ServerINI);   IP:=INI.ReadString('SERVER','IP','192.168.0.1');   ID:=INI.ReadString('SERVER','UserName','sa');   PWD:=INI.ReadString('SERVER','UserPWD','system');   INI.Free;   ConStr:='Provider=SQLOLEDB.1;Password='+PWD+';Persist Security Info=True;'+           'User ID='+ID+';Initial Catalog=NK;Data Source='+IP;   SerIP:=IP;   SetServerINFO:=ConStr; end; procedure TFrmMain.FormCreate(Sender: TObject); begin   ConSum:=0;   listened:=false;   ConnStr:=SetServerINFO;   Label7.Caption:='数据库服务器地址：'+serIP;   Label6.Caption:='开始运行时间：'+DateTimeToStr(now());   Application.Title:='网上作业系统--伺服器';   ConnDisconnected:=false;   openDB(ConnStr,true);   Timer1.Enabled :=true; end; procedure TFrmMain.bsSkinButton1Click(Sender: TObject); begin    if not DBConnected then    begin       bsSkinMessage1.MessageDlg('请连接到数据库服务器以后再开始监听！',(mtinformation),[mbOK],0);       Abort;    end;    Listened:=not(Listened);    if Listened then    begin       Label8.Caption:='伺服器状态：在2001端口监听';       bsSkinButton1.Caption:='停止监听';    end    else    begin       bsSkinButton1.Caption:='开始监听';       Label8.Caption:='伺服器状态：停止监听';    end; end; procedure TFrmMain.ADOConnection1AfterConnect(Sender: TObject); begin    Label9.Caption :='数据库服务器状态：已连接';    DBConnected:=ADOConnection1.Connected;    ConnDisconnected:=false; end; procedure TFrmMain.ADOConnection1AfterDisconnect(Sender: TObject); begin    DBConnected:=ADOConnection1.Connected;    Label9.Caption :='数据库服务器状态：未连接'; end; procedure TFrmMain.btnOpenDBClick(Sender: TObject); begin    openDB(ConnStr,true);    //btnOpenDB.Enabled :=not(DBConnected); end; procedure TFrmMain.bsSkinButton3Click(Sender: TObject); begin   try     ADO_TuserOnline.Close;     ADO_TuserOnline.Open;   except      ConnDisconnected:=true;      ConnTimes:=0;      Label9.Caption:='连接到数据库服务器失败，系统将在10秒后尝试重新连接';      DBConnected:=false;   end; end; procedure TFrmMain.bsSkinButton4Click(Sender: TObject); begin   try     ADOQ_TUserLogs.Close;     ADOQ_TUserLogs.Open;   except    ConnDisconnected:=true;    ConnTimes:=0;    DBConnected:=false;    Label9.Caption:='连接到数据库服务器失败，系统将在10秒后尝试重新连接';   end; end; procedure TFrmMain.bsSkinButton5Click(Sender: TObject); begin     FrmSetINI:=TFrmSetINI.Create(self);     FrmSetINI.btnCancel.Enabled :=true;     FrmSetINI.ShowModal;     ConnStr:=SetServerINFO;     openDB(ConnStr,true); end; procedure TFrmMain.Timer1Timer(Sender: TObject); var  LMsg:string; begin   if ConnDisconnected then   begin    ConnTimes:=ConnTimes+1;    Label9.Caption:='连接到数据库服务器失败，系统将在'+IntToStr(ConnTimes)+'秒后尝试重新连接';    if ConnTimes>10 then    begin      Label9.Caption:='尝试连接到数据库服务器...';      //showmessage('aa'+SerIP);      OpenDB(ConnStr,false);    end;    //Abort;   end;   if bsSkinCheckRadioBox3.Checked then   begin     if listbox1.Items.Count>bsSkinSpinEdit3.Value then        listbox1.Items.Clear;   end;   if (DBConnected  and bsSkinCheckRadioBox1.Checked)then //自动刷新用户在线信息   begin     UpdateOnlineTimes:=UpdateOnlineTimes+1;     if UpdateOnlineTimes>StrToInt(bsSkinSpinEdit1.Text)*60 then     begin       try        ADO_TuserOnline.Close;        ADO_TuserOnline.Open;       except        ConnDisconnected:=true;        ConnTimes:=0;        Label9.Caption:='连接到数据库服务器失败，系统将在10秒后尝试重新连接';        DBConnected:=false;       end;     end;   end   else     UpdateOnlineTimes:=0;   if (DBConnected  and bsSkinCheckRadioBox2.Checked)then //自动刷新用户登录信息   begin     UpdateUserLogsTimes:=UpdateUserLogsTimes+1;     if UpdateUserLogsTimes>StrToInt(bsSkinSpinEdit2.Text)*60 then     begin       try       UpdateUserLogsTimes:=0;       ADOQ_TUserLogs.Close;       ADOQ_TUserLogs.Open;       except        ConnDisconnected:=true;        ConnTimes:=0;        Label9.Caption:='连接到数据库服务器失败，系统将在10秒后尝试重新连接';        DBConnected:=false;       end;      end;   end   else     UpdateUserLogsTimes:=0;   if not(listened and DBConnected) then     UpDateTimesCount:=0   else   begin     UpDateTimesCount:=UpDateTimesCount+1;     if UpDateTimesCount>UpDateTimes then //开始刷新     begin       try          Timer1.Enabled :=false;//停止计时器          LMsg:=Label6.Caption;          Label6.Caption :='正刷新在线用户状态';          SVRUpdateOnlineInfo(UpDateTimes);          UpDateTimesCount:=0;          ADO_TuserOnline.Close;          ADO_TuserOnline.Open;       finally          Label6.Caption :=LMsg;          Timer1.Enabled :=true;//恢复计时器       end;     end;   end;  end; procedure TFrmMain.FormClose(Sender: TObject; var Action: TCloseAction); begin    if  Listened then    begin      bsSkinMessage1.MessageDlg('请停止监听后再退出伺服器！',(mtinformation),[mbOK],0);      Abort;    end; end; procedure TFrmMain.bsSkinButton2Click(Sender: TObject); begin   ListBox1.Items.Clear; end; end.

xcplates · 2008-01-02

我上面这段代码是用在一个三层应用的伺服器上的，运行良好。

bbscom · 2008-01-03

其实主要对数据源连接的接口重新再连接一次就可以了。 这个问题我以前也是这样，但现在都是通过这个方法解决的　。

连接失败，自动重试的实现？(100分)

清越小生

Unregistered / Unconfirmed

Dstorm

Unregistered / Unconfirmed

Delphiguanshui

Unregistered / Unconfirmed

清越小生

Unregistered / Unconfirmed

Delphizhou

Unregistered / Unconfirmed

清越小生

Unregistered / Unconfirmed

xcplates

Unregistered / Unconfirmed

xcplates

Unregistered / Unconfirmed

bbscom

Unregistered / Unconfirmed

Similar threads