datensätze mit events aktualisieren (fibplus)

[sancho1980]

hi
ich muss ein bisschen ausholen, um mein problem zu beschreiben; hoffentlich liest sich das einer durch:

meine anwendung soll es ermöglichen, dass mehrere benutzer gleichzeitig auf ein und dieselbe datenbank zugreifen; trotzdem sollen alle daten in jeder instanz des programms immer aktuell sein.

die anwendung verwendet ein grid zur darstellung der datensätze beim user. es sind immer maximal 20 records im dataset des users.

wie mache ich das mit dem aktualisieren:

ich habe in meiner datenbank 2 trigger definiert, die folgende events ablassen:

SQL-Code:

CREATE trigger dicentries_ad0 for dicentries
active after delete position 0
as
begin
  post_event 'dicentries delete ' || old.id;
end

SQL-Code:

CREATE trigger dicentries_au1 for dicentries
active after update position 1
as
begin
  post_event 'dicentries update ' || new.id;
end

sobald ein dataset beim user geöffnet wird, registriert sich der zugehörige eventalerter für die ihn betreffenden events:

Delphi-Quellcode:

procedure TDataModule1.DataSetDicEntriesAfterOpen(DataSet: TDataSet);
begin
  //hier nicht relevanter code
  self.RegisterForDicentries();
end;

Delphi-Quellcode:

procedure TDataModule1.RegisterForDicentries;
var
  bm: TBookMark;
begin
  try
    bm := self.DataSetDicEntries.GetBookmark();
    self.DataSetDicEntries.First();
    while not self.DataSetDicEntries.Eof do
      begin
        self.DicentriesAlerter.Events.Add('dicentries delete ' + IntToStr(self.DataSetDicEntriesID.AsInt64));
        self.DicentriesAlerter.Events.Add('dicentries update ' + IntToStr(self.DataSetDicEntriesID.AsInt64));
        self.DataSetDicEntries.Next();
      end;
    self.DicentriesAlerter.RegisterEvents();
    self.DataSetDicEntries.GotoBookmark(bm);
  except
  end;
end;

wenn das dataset geschlossen wird, wird die registrierung natürlich auch wieder aufgehoben:

Delphi-Quellcode:

procedure TDataModule1.DataSetDicEntriesBeforeClose(DataSet: TDataSet);
begin
  try
    self.DicentriesAlerter.UnRegisterEvents();
    self.DicentriesAlerter.Events.Clear();
  except
  end;
end;

so, in der routine, die ein event behandelt, wird der entsprechende eintrag aktualisiert:

Delphi-Quellcode:

procedure TDataModule1.DicentriesAlerterEventAlert(Sender: TObject;
  EventName: String; EventCount: Integer);
var
  bm: TBookMark;
  i: Int64;
begin
  if Tokenize(EventName,' ')[1] = 'update' then
    begin
      bm := self.DataSetDicEntries.GetBookmark();
      id := StrToInt64(Tokenize(EventName,' ')[2]);
      self.DataSetDicEntries.First();
      while self.DataSetDicEntriesID.AsInt64 <> id do
        self.DataSetDicEntries.Next();
      self.DataSetDicEntries.Refresh();
      self.DataSetDicEntries.GotoBookmark(bm);
    end
  else
    begin
      self.DataSetDicEntries.Close();
      self.DataSetDicEntries.Open();
    end;
end;

So, wenn ich jetzt in meiner Anwendung (EINE Instanz der Anwendung) ZWEI Instanzen derselben Datenbank öffne (also mit zwei Instanzen des DataModule) und sich die geladenen Datensätze der beiden Datasets überschneiden, dann funktioniert das zwar mit dem Update problemlos, aber beim Delete hängt sich das Prog auf, als wäre es in irgendeiner Endlosschleife...

Weiß da einer vielleicht weiter?

Danke,

Martin

[sancho1980]

habe mittlerweile folgendes rausgefunden:

Zitat:

OnEventAlert wird in einem eigenen Thread ausgeführt, um eine echte asynchrone Ereignisverarbeitung zu ermöglichen. Die IBEvents-Komponente stellt aber durch den entsprechenden Quelltext sicher, dass immer nur eine Ereignisbehandlungsroutine ausgeführt werden kann.

Das Quote stammt zwar aus den Docs zu IBX, aber ich nehme an, dass trifft auf FIB auch zu. Habe durch Probieren einfach mal rausgefunden, dass in dem Handler zu OnEventAlert bestimmte Dinge einfach mal nicht gehen und das Prog einfrieren (zum Beispiel das Öffnen und Schließen von Datasets). Meine Vermutung ist, dass es damit zusammenhängt, dass die Procedure in einem eigenen Thread ausgeführt wird. Jetzt dachte ich, vielleicht kann ich den Thread irgendwie beenden und die entsprechenden Jobs regulär im Programm ausführen...aber wie könnt ich das anstellen? Wenn ich aus dem Handler eine neue Procedure aufrufe bin ich immer noch im selben Thread, oder? Hat jemand von dem ganzen Thread-Zeugs Ahnung?

Danke,

Martin

[Bernhard Geyer]

Hast Du dir mal den Aufrufstack für diesen Fall angesehen?

Ich denke dein Aufrufstack beinhaltet auch die "Änderungsmethode" und da wird es vermutlich probleme gegen da du dem Auslöser die Daten und dem Hintern wegziehst.

Probier mal folgendes: Merk dir den Evenname und Eventcount und für die Arbeiten erst in einer Methode aus die du mittels PostMessage "aktivierst". Diese kommt erst wenn auch deine "Auslösermethode" abgearbeitet wurde.

[sancho1980]

Zitat:

Zitat von Bernhard Geyer

Hast Du dir mal den Aufrufstack für diesen Fall angesehen?

Ich denke dein Aufrufstack beinhaltet auch die "Änderungsmethode" und da wird es vermutlich probleme gegen da du dem Auslöser die Daten und dem Hintern wegziehst.

Kannst du das bitte bisschen genauer erklären? Was meinst du mit Änderungsmethode. Und wie ist das mit dem Hintern wegziehen gemeint?

Zitat:

Zitat von Bernhard Geyer

Probier mal folgendes: Merk dir den Evenname und Eventcount und für die Arbeiten erst in einer Methode aus die du mittels PostMessage "aktivierst". Diese kommt erst wenn auch deine "Auslösermethode" abgearbeitet wurde.

Wie stell ich das an? Kannst du das mal mit bisschen Pseudocode skizzieren?

Danke,

Martin

[Bernhard Geyer]

Delphi-Quellcode:

procedure TDataModule1.DicentriesAlerterEventAlert(Sender: TObject;
  EventName: String; EventCount: Integer); 
begin
  // Evtl. in Liste speichern da mehrere EventAlert kommen könnten vor abarbeitung
  FEventname := EventName;
  FEventCount := EventCount;
  PostMessage(self.Handle, WM_DicentriesAlerterEventAlert);
end;

procedure TDataModule1.DicentriesAlerterEventAlert(...)
begin
  // Ursprünglicher Code von DicentriesAlerterEventAlert
end;

[sancho1980]

Zitat:

Zitat von Bernhard Geyer

Delphi-Quellcode:

procedure TDataModule1.DicentriesAlerterEventAlert(Sender: TObject;
  EventName: String; EventCount: Integer); 
begin
  // Evtl. in Liste speichern da mehrere EventAlert kommen könnten vor abarbeitung
  FEventname := EventName;
  FEventCount := EventCount;
  PostMessage(self.Handle, WM_DicentriesAlerterEventAlert);
end;

procedure TDataModule1.DicentriesAlerterEventAlert(...)
begin
  // Ursprünglicher Code von DicentriesAlerterEventAlert
end;

Danke, ich wollt das direkt mal ausprobieren, aber da gibt's ein Problem: self.Handle gibt es nur für TForms und nicht für Datenmodule..was mach ich da? Und was hat es mit WM_DicentriesAlerterEventAlert auf sich??

[Bernhard Geyer]

Fehlt noch was:

const
DicentriesAlerterEventAlert = WM_USER + 101;

type
TDataModule1 = class(TDataModule)

Delphi-Quellcode:

procedure WMDicentriesAlerterEventAlert(...) message WM_DicentriesAlerterEventAlert;

...

procedure TDataModule1.WMDicentriesAlerterEventAlert(...)
begin
  // Ursprünglicher Code von DicentriesAlerterEventAlert
end;

Evtl. könntest Du dich mit einem (versteckten) Hilfsfenster behelfen.

[sancho1980]

in welcher unit ist denn wm_user definiert?

[sancho1980]

hab das jetzt hinbekommen und es lag tatsächlich daran! danke..trotzdem würd mich nochmal der hintergrund interessieren, von wegen ich zieh der "methode den hintern weg"...kannst du mir irgendwas zeigen, wo das beschrieben steht..dann musste jetz keine romane schreiben ^^

danke nochmal,

martin

[Bernhard Geyer]

In Funktion Verursacher wird Methode CallMethodeWelchemeine2teMethodeAufruft aufgerufen welche ihrerseits
EventCalledBy_CallMethodeWelchemeine2teMethodeAufr uft aufruft. Nach der Abarbeitung von EventCalledBy_CallMethodeWelchemeine2teMethodeAufr uft kommt der Ablauf in die Funktion Verursacher zurück und du arbeitest dann mit einem ungültigen Zeiger weiter.

Delphi-Quellcode:

TForm1.Verursacher;
var
  MyLocalVar: TZeigeraufirgendwas;
begin
  MyLocalVar := Zeigerwoandersher;
  CallMethodeWelchemeine2teMethodeAufruft
  MyLocalVar.Machwas;
end;

TForm1.EventCalledBy_CallMethodeWelchemeine2teMethodeAufruft;
begin
  Zeigerwoandersher.Free;
  Zeigerwoandersher := DoCreatezeigerNeu; 
end;