UniDAC 断线重连方法

procedure TkbmMWUNIDACConnection.InternalOpenConnection(ConnectionPool:TkbmMWCustomConnectionPool);
begin
  // Create new database connection using template.
  with TkbmMWUNIDACConnectionPool(ConnectionPool).FDBTemplate do
  begin
    //  针对UniDAC需要增加这个语句，否则连接数据库失败
    FDatabase.Server := Server;

    FDatabase.Database := Database;
    FDatabase.Username := UserName;
    FDatabase.Password := Password;
    FDatabase.LoginPrompt := False;
    FDatabase.ProviderName := ProviderName;

    
    FDatabase.Port := Port;

    FDatabase.SpecificOptions.Assign(SpecificOptions);

    // 支持unidac重联
    FDatabase.Options.LocalFailover:=Options.LocalFailover;
    FDatabase.OnConnectionLost:=OnConnectionLost;
    FDatabase.AfterConnect:=AfterConnect;

    with TkbmMWUNIDACConnectionPool(ConnectionPool) do
      if Assigned(FOnSetupDBConnection) then
        FOnSetupDBConnection(self,FDatabase);
  end;
 
  if FDatabase.ProviderName=‘SQL Server‘  then
    CoInitialize(nil);

  FDatabase.Open;
end;

procedure TDM.CON_AConnectionLost(Sender: TObject; Component: TComponent;
  ConnLostCause: TConnLostCause; var RetryMode: TRetryMode);
begin
  //断线重联
  if (Sender as TUniConnection).Tag<1 then
  begin
    RetryMode:=rmReconnectExecute;
    (Sender as TUniConnection).Tag:=(Sender as TUniConnection).Tag+1;
  end
  else
  begin
    RetryMode:=rmRaise;
    (Sender as TUniConnection).Tag:=0;
  end;
end;