Transaktionen bei DBExpress mit MySQL

[mannewolff]

Moin.

Ich habe versucht in obiger Konfiguration eine Transaktion durchzuführen, wobei ich sowohl die Connectio in einem Modul als auch die SQL's in Fachobjekten habe:

Delphi-Quellcode:

function TFrameBestellanfrage.saveBestellposition : boolean;
var
  ...
  transaction : TDBXTransAction;
begin
  ...
  transaction := DatenModul.SQLConnection.BeginTransaction();
  try
    lastbestellposition.save();
    if neu then
    begin
       Zuordnung := TAnfrageZuBestellposition.Create();
       Zuordnung.FK_ANFRAGE := lastAnfrage.id;
       Zuordnung.FK_BESTELLPOSITION := lastbestellposition.id;
       Zuordnung.save();
       Zuordnung.Free();
    end;
    DatenModul.SQLConnection.CommitFreeAndNil(transaction);
    except
      DatenModul.SQLConnection.RollbackFreeAndNil(transaction);
  end;
  setMustSave(false);
end;

Manchmal geht es gut, manchmal bekomme ich eine Exception.

Frage: Ist der Weg denn korrekt, dann kann ich weitersuchen.

-manne

[hoika]

Hallo,

Zitat:

Manchmal geht es gut, manchmal bekomme ich eine Exception.

Welche Exception ?
wo genau ?

Welche MySQL-Engine wird benutzt ?

Delphi-Quellcode:

transaction := DatenModul.SQLConnection.BeginTransaction();

Ist das dein eigener Code, der eine Transaktion "erzeugt" ?

Wenn ja, wo wird die Transaktion den anderen Fach-Objekten
(lastbestellposition, Zuordnung usw. ) zugeordnet ?


Heiko

[mannewolff]

Exception und Engine kann ich erst heute Abend oder morgen liefern, wenn ich wieder an meinem heimischen Arbeitsplatz bin. Ich meine es war eine concurrent modification exception, allerding ist im Moment nur ein Client aktiv.

Vielleicht ist die Architektur ja schon fehlerhaft. Ich habe ein Delphi Datenmodul. In dem Datenmodul habe ich eine TSQLConnection und eine TSQLQuery Komponente. Alle Fachobjekte benutzen die gleiche Query, um ihr SQL abzusetzen (vielleicht ist das schon das Problem).

Ich rufe also die BeginTransaction() Methode der TSQLConnection-Komponente auf. Dann feuern verschiedene Fachobjekte ihre SQLs über die gleiche (!) TSQLQuery Komponente ab. Zum Schluss dann das Commit eben über diese TSQLConnection-Komponente.

Alle Fachobjekte erben von einem TPersistence-Objekt, welches eben die SQL erzeugt und absetzt. Darum auch alle SQLs über das gleiche Query Objekt.

-manne

[hoika]

Hallo,

noch ein interessanter Link zur Benutzung

DBX

Das hat zwar mit deiner Exception nichts zu tun,
aber die Benutzung des raise hier ist interessant.


Heiko

[mannewolff]

Also ich arbeite mit MySQL Server 5.1.

Die Exception, die fliegt: TDBXError 'Commands out of sync; you can't run this command now'.

Es tritt nur auf, wenn ich mehrere SQLs, aus unterschiedlichen Fachobjekten, die mit der gleichen Query abgesetzt worden sind committen will. Wahrscheinlich muss ich für jedes Fachobjekt eine frische Query nehmen. I try.

Nachtrag: Die Exception tritt auch auf, wenn ich für jedes Fachobjekt eine eigene Query benutze.

Manfred

[hoika]

Hallo,

tipp mal "Commands out of sync; you can't run this command now mysql" in google ein.
Es sieht so aus, als ob du die Queries falsch benutzt.
Vielleicht ein Open, ohne die Daten zu holen oder ohne Close.

An deinem obigen Code sehe ich ja, dass du ein Feind von finally bis ...

dein Code

Delphi-Quellcode:

       
Zuordnung := TAnfrageZuBestellposition.Create();
Zuordnung.FK_ANFRAGE := lastAnfrage.id;
Zuordnung.FK_BESTELLPOSITION := lastbestellposition.id;
Zuordnung.save();
Zuordnung.Free();

mit finally

Delphi-Quellcode:

Zuordnung := TAnfrageZuBestellposition.Create();
try
  Zuordnung.FK_ANFRAGE := lastAnfrage.id;
  Zuordnung.FK_BESTELLPOSITION := lastbestellposition.id;
  Zuordnung.save();
finally
  Zuordnung.Free(); 
end;

Bei den Queries muss das genauso sein

Delphi-Quellcode:

with Query do
begin
  SQL.Clear;
  SQL.Add
  Open;
  try
  finally
    Close;
  end;
end;

btw: vielleicht fehlt auch irgendwo das SQL.Clear ?? (bei gemeinsamer Nutzung einer Query)



#Update:
Schau dir mal folgenden Thread an, vor allem im unteren Viertel.
MySQL und DBX



Heiko

[mannewolff]

Vielleich klippst Du das hier rein oder schickst es mir als mail ([e-mail]) ich habe da keinen Zugang und eine 30 Tage Trial mit Kreditkartenangabe mache ich nicht so gerne. Habe leider immer noch keine Lösung gefunden. Inzwischen arbeite ich mit gepoolten Querys. Jedes aktive Fachobjekt hat also eine eigene Query. Aber es ist egal ob offene Query, geschlossene, die Exception kommt immer noch. Ohne Transaktionen habe ich auf die Dauer Angst, dass inkonsistente Daten in die Datenbank kommen.

[hoika]

Hallo,

1

Kommt denn die Meldung sofort beim ersten mal ?
Wie sieht denn deine Abfrage aus ?

Verwechselt du vielleicht ExecSQL und Open
(weiss jetzt nicht, ob DBX das auch trennt)?


Heiko

[mannewolff]

Ich mache in der Transaktion ein update auf zwei verschiedene Queries. Jedes Update sieht wie folgt aus:

Delphi-Quellcode:

  try
  try
     initquery();
     ...
     query.ExecSQL();
  except
     On E: Exception do
     begin
       Error('TPersistenz.save()', E);
       raise(E);
     end;
  end;
  finally
     query.Close();
  end;
end;

[edit=mkinzler]Code-Tag durch Delphi-Tag ersetzt Mfg, mkinzler[/edit]