dxdatabaseservercore.pas

Well known and usefull component for delphi 7

   AddBasicEvent('ISEOF',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandISEMPTY(value:DatabaseTBasicEvent);
Begin
   fOnCommandISEMPTY:=Value;
   AddBasicEvent('ISEMPTY',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandCANMODIFY(value:DatabaseTBasicEvent);
Begin
   fOnCommandCANMODIFY:=Value;
   AddBasicEvent('CANMODIFY',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandFIELDCOUNT(value:DatabaseTBasicEvent);
Begin
   fOnCommandFIELDCOUNT:=Value;
   AddBasicEvent('FIELDCOUNT',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandRECORDCOUNT(value:DatabaseTBasicEvent);
Begin
   fOnCommandRECORDCOUNT:=Value;
   AddBasicEvent('RECORDCOUNT',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandRECORDSIZE(value:DatabaseTBasicEvent);
Begin
   fOnCommandRECORDSIZE:=Value;
   AddBasicEvent('RECORDSIZE',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandFOUND(value:DatabaseTBasicEvent);
Begin
   fOnCommandFOUND:=Value;
   AddBasicEvent('FOUND',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandMODIFIED(value:DatabaseTBasicEvent);
Begin
   fOnCommandMODIFIED:=Value;
   AddBasicEvent('MODIFIED',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandCREATEDATASET(value:DatabaseTSimpleEvent);
Begin
   fOnCommandCREATEDATASET:=Value;
   AddSimpleEvent('CREATEDATASET',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandDISPOSEDATASET(value:DatabaseTSimpleEvent);
Begin
   fOnCommandDISPOSEDATASET:=Value;
   AddSimpleEvent('DISPOSEDATASET',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandOPEN(value:DatabaseTBasicEvent);
Begin
   fOnCommandOPEN:=Value;
   AddBasicEvent('OPEN',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandCLOSE(value:DatabaseTBasicEvent);
Begin
   fOnCommandCLOSE:=Value;
   AddBasicEvent('CLOSE',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandFIRST(value:DatabaseTBasicEvent);
Begin
   fOnCommandFIRST:=Value;
   AddBasicEvent('FIRST',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandNEXT(value:DatabaseTBasicEvent);
Begin
   fOnCommandNEXT:=Value;
   AddBasicEvent('NEXT',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandPRIOR(value:DatabaseTBasicEvent);
Begin
   fOnCommandPRIOR:=Value;
   AddBasicEvent('PRIOR',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandLAST(value:DatabaseTBasicEvent);
Begin
   fOnCommandLAST:=Value;
   AddBasicEvent('LAST',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandMOVEBY(value:DatabaseTSimpleEvent);
Begin
   fOnCommandMOVEBY:=Value;
   AddSimpleEvent('MOVEBY',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandFINDFIRST(value:DatabaseTBasicEvent);
Begin
   fOnCommandFINDFIRST:=Value;
   AddBasicEvent('FINDFIRST',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandFINDLAST(value:DatabaseTBasicEvent);
Begin
   fOnCommandFINDLAST:=Value;
   AddBasicEvent('FINDLAST',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandFINDNEXT(value:DatabaseTBasicEvent);
Begin
   fOnCommandFINDNEXT:=Value;
   AddBasicEvent('FINDNEXT',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandFINDPRIOR(value:DatabaseTBasicEvent);
Begin
   fOnCommandFINDPRIOR:=Value;
   AddBasicEvent('FINDPRIOR',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandFINDFIELD(value:DatabaseTSimpleEvent);
Begin
   fOnCommandFINDFIELD:=Value;
   AddSimpleEvent('FINDFIELD',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandGETFIELDLIST(value:DatabaseTBasicEvent);
Begin
   fOnCommandGETFIELDLIST:=Value;
   AddBasicEvent('GETFIELDLIST',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandLOCATECASEINSENSITIVE(value:DatabaseTSimpleEvent);
Begin
   fOnCommandLOCATECaseInsensitive:=Value;
   AddSimpleEvent('LOCATECASEINSENSITIVE',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandLOCATEPARTIALKEY(value:DatabaseTSimpleEvent);
Begin
   fOnCommandLOCATEPARTIALKEY:=Value;
   AddSimpleEvent('LOCATEPARTIALKEY',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandLOCATENOOPTIONS(value:DatabaseTBasicEvent);
Begin
   fOnCommandLOCATENOOPTIONS:=Value;
   AddBasicEvent('LOCATENOOPTIONS',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandLOCATEBOTHOPTIONS(value:DatabaseTBasicEvent);
Begin
   fOnCommandLOCATEBOTHOPTIONS:=Value;
   AddBasicEvent('LOCATEBOTHOPTIONS',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandLOCATE(value:DatabaseTComplexEvent);
Begin
   fOnCommandLOCATE:=Value;
   AddComplexEvent('LOCATE',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandAPPEND(value:DatabaseTBasicEvent);
Begin
   fOnCommandAPPEND:=Value;
   AddBasicEvent('APPEND',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandINSERT(value:DatabaseTBasicEvent);
Begin
   fOnCommandINSERT:=Value;
   AddBasicEvent('INSERT',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandEDIT(value:DatabaseTBasicEvent);
Begin
   fOnCommandEDIT:=Value;
   AddBasicEvent('EDIT',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandDELETE(value:DatabaseTBasicEvent);
Begin
   fOnCommandDELETE:=Value;
   AddBasicEvent('DELETE',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandPOST(value:DatabaseTBasicEvent);
Begin
   fOnCommandPOST:=Value;
   AddBasicEvent('POST',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandCANCEL(value:DatabaseTBasicEvent);
Begin
   fOnCommandCANCEL:=Value;
   AddBasicEvent('CANCEL',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandREFRESH(value:DatabaseTBasicEvent);
Begin
   fOnCommandREFRESH:=Value;
   AddBasicEvent('REFRESH',Value);
End;

Procedure TDXDatabaseServerCore.SetOnCommandFIELDBYNAME(value:DatabaseTComplexEvent);
Begin
   fOnCommandFIELDBYNAME:=Value;
   AddComplexEvent('FIELDBYNAME',Value);
End;

procedure TDXDatabaseServerCore.ProcessSession(ClientThread: TDXClientThread);
var
  s, sCmd: string;
  Loop:Integer;
  WasHandled:Boolean;
  OutData:Pointer;

  procedure NotHandled(CMD: string);
  Var
     Ws:String;

  begin
     Ws:='500 command not recognized (' + CMD + ')';
     ClientThread.Socket.Writeln(Ws);
  end;

begin
   fbForceAbort:=False;
   with ClientThread.Socket do begin
      While Connected do Begin
         s:=ReadLn(Timeout);
         If LastReadTimeout or (Not ValidSocket) or (fbForceAbort) then Exit;
         if assigned({$IFDEF TLS_EDITION}OnReadFilter{$ELSE}OnFilter{$ENDIF}) then begin
            Loop:=FilterRead(@S[1],OutData,Length(S),ClientThread);
            SetLength(S,Loop);
            If Assigned(Outdata) then Begin
               FastMove(TDXBSArray(OutData^),S[1],Loop);
{$IFDEF TLS_EDITION}OnReadFilter{$ELSE}OnFilter{$ENDIF}(ddFreePointer,nil,OutData,Loop,Loop,WasHandled,ClientThread) ;
            End;
         End;
         sCmd:=UpperCase(Fetch(s,#32,False));
         Loop:=0;
         WasHandled:=False;
         While (Loop<fEventArray.Count) and (Not WasHandled) do Begin
            If PDatabaseSimpleEvent(fEventArray[Loop]).Command=sCMD then Begin
               Case PDatabaseSimpleEvent(fEventArray[Loop]).Tag of
                  1:if Assigned(PDatabaseSimpleEvent(fEventArray[Loop]).EventProcedure) then
                       DatabaseTSimpleEvent(PDatabaseSimpleEvent(fEventArray[Loop]).EventProcedure)(ClientThread,s);
                  2:if Assigned(PDatabaseBasicEvent(fEventArray[Loop]).EventProcedure) then
                       DatabaseTBasicEvent(PDatabaseBasicEvent(fEventArray[Loop]).EventProcedure)(ClientThread);
                  3:if Assigned(PDatabaseComplexEvent(fEventArray[Loop]).EventProcedure) then
                       DatabaseTComplexEvent(PDatabaseComplexEvent(fEventArray[Loop]).EventProcedure)(ClientThread,FetchByChar(S,#32,False),S);
               End;
               WasHandled:=True;
            End
            Else Inc(Loop);
         End;
         If Not WasHandled then Begin
            if assigned(OnCommandOther) then
               OnCommandOther(ClientThread,sCmd,s,WasHandled);
         end;
         if not WasHandled then NotHandled(sCmd);
      end;
   end;
end;

end.