AGB  ·  Datenschutz  ·  Impressum  







Anmelden
Nützliche Links
Registrieren
Thema durchsuchen
Ansicht
Themen-Optionen

ADO Queries per Thread aktualisieren

Ein Thema von Schwarzesshaaf666 · begonnen am 24. Jan 2025 · letzter Beitrag vom 30. Jan 2025
Antwort Antwort
Schwarzesshaaf666

Registriert seit: 14. Apr 2006
Ort: Herford
13 Beiträge
 
#1

AW: ADO Queries per Thread aktualisieren

  Alt 27. Jan 2025, 14:37
Warum es funktioniert kann ich nicht sagen. Meine Vermutung: FreeOnTerminate ist eine Variable aus TThread und deswegen schon erreichbar.
_________________
FREI STATT BAYERN
  Mit Zitat antworten Zitat
Schwarzesshaaf666

Registriert seit: 14. Apr 2006
Ort: Herford
13 Beiträge
 
#2

AW: ADO Queries per Thread aktualisieren

  Alt 27. Jan 2025, 14:44
Hier meine aktuelle, lauffähige Version des Threads, falls jemand etwas ähnliches braucht:

Delphi-Quellcode:
interface

type
  TQThread = class(TThread)
  private
    FQuery: TADOQuery;
    FDataSource: TDataSource;
    FRightsPk: Integer;
    FRecordCount: Integer;
    FIsRunning: Boolean;
    FQueryName: string;
  protected
    procedure Execute; override;

  public
    constructor Create(DataSource: TDataSource);
    destructor Destroy; override;

    property RightsPk: Integer read FRightsPk write FRightsPk;
    property RecordCount: Integer read FRecordCount write FRecordCount;
    property IsRunning: Boolean read FIsRunning write FIsRunning;
    property QueryName: string read FQueryName write FQueryName;
  end;

implementation

constructor TQThread.Create(DataSource: TDataSource);
begin
  inherited Create(True);

  FDataSource := DataSource;
  FreeOnTerminate := True;
end;

destructor TQThread.Destroy;
begin
  inherited;
end;

procedure TQThread.Execute;
begin
  inherited;

  CoInitialize(nil);

  try
    try
      FQuery := TADOQuery(FDataSource.DataSet);

      RightsPk := FDataSource.Tag;
      IsRunning := True;
      RecordCount := 0;
      QueryName := FQuery.Name;

      FQuery.Close;
      FQuery.Open;

      RecordCount := FQuery.RecordCount;
      IsRunning := False;
    except
      on Ex: Exception do
      begin
        dxMessageDlg('Fehler beim Ausführen des Query-Thead! (' + FQuery.Name + ', ' + Self.QualifiedClassName + ')' + #13#10#13#10 + 'Fehlermeldung: ' + Ex.Message + #13#10 + Ex.StackTrace + #13#10 + 'SQL: ' + FQuery.SQL.Text, mtError, [mbOK], 0);
      end;
    end;
  finally

    CoUninitialize();
  end;
end;
Um die Ergebnisse abzufragen, nutze ich das Event OnTerminate:
Delphi-Quellcode:
procedure TForm1.TerminateThread(Sender: TObject);
var
  RightsPk: Integer;
  RecordCount: Integer;
begin
  RightsPk := TQThread(Sender).RightsPk;
  RecordCount := TQThread(Sender).RecordCount;

  // Verarbeitung der Variablen
end
Ich sehe gerade, IsRunning ist hier sogar völlig überflüssig...

PS: Kann ich den ersten Beitrag nicht bearbeiten, um den Thread als "gelöst" zu markieren?
_________________
FREI STATT BAYERN

Geändert von Schwarzesshaaf666 (27. Jan 2025 um 14:47 Uhr)
  Mit Zitat antworten Zitat
HolgerX

Registriert seit: 10. Apr 2006
Ort: Leverkusen
989 Beiträge
 
Delphi 6 Professional
 
#3

AW: ADO Queries per Thread aktualisieren

  Alt 27. Jan 2025, 15:38
Hmm...
Zitat:
Code:
CoInitialize(nil);
  try
    try
      FQuery := TADOQuery(FDataSource.DataSet);

      RightsPk := FDataSource.Tag;
      IsRunning := True;
      RecordCount := 0;
      QueryName := FQuery.Name;

      FQuery.Close;
      FQuery.Open;

      RecordCount := FQuery.RecordCount;
Dir ist bewusst, dass der ADOQuery 'außerhalb' des Thread erzeugt wird und du somit innerhalb Execute auf die Komponente 'außerhalb' deines Threads zugreifst und das alle (eventuellen) Messages der ADOQuery im Hauptthread stattfinden?
Ich vermute, dass du eine ADOConnection mit diesem Query verwendest, welche auch außerhalb des Threads genutzt wird?
Also diese außerhalb deines Threads ist!

So weit ich weiß sollte jeder Thread seine eigende ADOQuery/ADOConnection selber erstellen, nur so ist sichergestellt, dass diese auch im Kontext des Threads läuft!

Also den Connectionstring, sowie den SQL-String an den Thread geben und nicht das ADOQuery selber!.

Irgendwo habe ich nen Sourcecode gesehen, welcher dann das Record-Set Thread Save aus dem Thread an den MainThread zurück gibt, weiß aber nicht mehr wo....
(Ja ich Verwende Delphi 6 Pro und will NICHT wechseln!)
  Mit Zitat antworten Zitat
Schwarzesshaaf666

Registriert seit: 14. Apr 2006
Ort: Herford
13 Beiträge
 
#4

AW: ADO Queries per Thread aktualisieren

  Alt 30. Jan 2025, 07:55
Nein, bewusst war mir das nicht. Hab nach dem genannten Code gesucht und ihn hier gefunden. Hab ihn noch etwas angepasst, da ich die Threads irgendwie in OnTerminate identifizieren muss.

Delphi-Quellcode:
type
  TFieldInfoRecord = Record
    DataType: TFieldType;
    Name: String;
    Size: Integer;
    Value: Variant;
    Attributes: TParameterAttributes;
  End;

  TDBThread = class(TThread)
    constructor Create(Const AConnectionString, ASql: string; FDArray: TFieldInfoArray; ARightsPk: Integer);
  private
    FConnectionString, FSql: string;
    FRecordSet: _RecordSet;
    FRightsPk: Integer;
    FFDArray: TFieldInfoArray;
  protected
    procedure Execute; override;
  public
    property RecordSet: _RecordSet read FRecordSet;
    property RightsPk: Integer read FRightsPk write FRightsPk;
  end;

implementation

constructor TDBThread.Create(Const AConnectionString, ASql: string; FDArray: TFieldInfoArray; ARightsPk: Integer);
var
  i: Integer;
begin
  inherited Create(False);

  FConnectionString := AConnectionString;
  FSql := ASql;
  SetLength(FFDArray, Length(FDArray));
  for i := 0 to High(FDArray) do
  begin
    FFDArray[i].DataType := FDArray[i].DataType;
    FFDArray[i].Size := FDArray[i].Size;
    FFDArray[i].Name := FDArray[i].Name;
    FFDArray[i].Value := FDArray[i].Value;
    FFDArray[i].Attributes := FDArray[i].Attributes;
  end;
  FRightsPk := ARightsPk;
end;

procedure TDBThread.Execute;
var
  i: Integer;
begin
  inherited;

  CoInitialize(nil);
  try
    With TADODataSet.Create(nil) do
      try
        try
          CommandTimeOut := 600;
          ConnectionString := FConnectionString;
          Commandtext := FSql;
          Parameters.ParseSQL(FSql, True); // extract parameters
          for i := Low(FFDArray) to High(FFDArray) do // set parametervalues
          begin
            Parameters.ParamByName(FFDArray[i].Name).DataType := FFDArray[i].DataType;
            Parameters.ParamByName(FFDArray[i].Name).Size := FFDArray[i].Size;
            Parameters.ParamByName(FFDArray[i].Name).Value := FFDArray[i].Value;
            Parameters.ParamByName(FFDArray[i].Name).Attributes := FFDArray[i].Attributes;
          end;
          Open;
          FRecordSet := RecordSet; // keep recordset
        except
          on Ex: Exception do
            MessageDlg('Error in Thread: ' + Ex.Message + sLineBreak + 'SQL: ' + FSql, mtError, [mbOK], 0);
        end;
      finally
        Free;
      end;
  finally
    CoUninitialize;
  end;
end;
_________________
FREI STATT BAYERN
  Mit Zitat antworten Zitat
Antwort Antwort


Forumregeln

Es ist dir nicht erlaubt, neue Themen zu verfassen.
Es ist dir nicht erlaubt, auf Beiträge zu antworten.
Es ist dir nicht erlaubt, Anhänge hochzuladen.
Es ist dir nicht erlaubt, deine Beiträge zu bearbeiten.

BB-Code ist an.
Smileys sind an.
[IMG] Code ist an.
HTML-Code ist aus.
Trackbacks are an
Pingbacks are an
Refbacks are aus

Gehe zu:

Impressum · AGB · Datenschutz · Nach oben
Alle Zeitangaben in WEZ +1. Es ist jetzt 13:11 Uhr.
Powered by vBulletin® Copyright ©2000 - 2025, Jelsoft Enterprises Ltd.
LinkBacks Enabled by vBSEO © 2011, Crawlability, Inc.
Delphi-PRAXiS (c) 2002 - 2023 by Daniel R. Wolf, 2024-2025 by Thomas Breitkreuz