MySQL Daten updaten mit Delphi FireDac

[HCB]

Hallo Datenbankprofis!

Ich versuche gerade eine Verbindung zu einem Online-Shop herzustellen und die Daten von einer lokalen Delphi App zum Onlineserver zu übertragen. Es funktioniert auch einwandfrei mit einem Datensatz.
Sobald ich aber die Daten mittels einer Schlaufe ...EOF übertrage, arbeitet das Programm zwar die Schlaufe ab, es wird aber nur der erste Datensatz aktualisiert, die übrigen nicht.

Weiß jemand woran das liegt und kann mir helfen?

Momentan habe ich es so:

Delphi-Quellcode:

 try
     Connection.StartTransaction; // Start a transaction
      while not AccessQuery.EOF do
        begin
        MyQuery.SQL.Text :='update oxarticles set oxprice= :ArtVKPreis_0,oxpricea= :ArtVKPreis_1, oxtprice= :ArtVKPreis_2 where oxid = :ArtNr';
        MyQuery.ParamByName('ArtNr').Value := Q_sArtikelArtNr.Value;
        MyQuery.ParamByName('ArtVKPreis_0').Value := Q_sArtikelArtVkPreis_0.Value;
        MyQuery.ParamByName('ArtVKPreis_1').Value := Q_sArtikelArtVkPreis_1.Value;
        MyQuery.ParamByName('ArtVKPreis_2').Value := Q_sArtikelArtVkPreis_2.Value;
        MyQuery.execsql;
        pgb_updateStatus.Position:=AccessQuery.RecNo;
        AccessQuery.Next;
        end;
        Connection.Commit; // Commit the transaction
     except Connection.Rollback; // Rollback the transaction in case of an error
     raise;

[DeddyH]

Zitat:

Delphi-Quellcode:

MyQuery.ParamByName('ArtNr').Value := Q_sArtikelArtNr.Value;

Ohne ein Next auf Q_sArtikelArtNr bleibt das ja auch immer derselbe Wert.

[Papaschlumpf73]

Deine Parameter scheinen sich nicht zu verändern. Die Schleife läuft durch, es wird aber immer derselbe Datensatz mit denselben werden aktualisiert. Irgendwo müssten die Felder/ Variablen Q_sArtikelArtNr, Q_sArtikelArtVkPreis_0 usw. auch neue Werte abrufen.

[HCB]

Der Vollständigkeitshalber:

Delphi-Quellcode:

    AccessQuery.SQL.Text := 'SELECT ArtNr, ArtVKPreis_0, ArtVKPreis_1, ArtVKPreis_2 FROM sArtikel where ArtInaktiv = false and ArtGSShop = true order by ArtNr';
    AccessQuery.Open;
    AccessQuery.First;
try
     Connection.StartTransaction; // Start a transaction
      while not AccessQuery.EOF do
        begin
        MyQuery.SQL.Text :='update oxarticles set oxprice= :ArtVKPreis_0,oxpricea= :ArtVKPreis_1, oxtprice= :ArtVKPreis_2 where oxid = :ArtNr';
        MyQuery.ParamByName('ArtNr').Value := Q_sArtikelArtNr.Value;
        MyQuery.ParamByName('ArtVKPreis_0').Value := Q_sArtikelArtVkPreis_0.Value;
        MyQuery.ParamByName('ArtVKPreis_1').Value := Q_sArtikelArtVkPreis_1.Value;
        MyQuery.ParamByName('ArtVKPreis_2').Value := Q_sArtikelArtVkPreis_2.Value;
        MyQuery.execsql;
        pgb_updateStatus.Position:=AccessQuery.RecNo;
        AccessQuery.Next;
        end;
        Connection.Commit; // Commit the transaction
     except Connection.Rollback; // Rollback the transaction in case of an error
     raise;
     end;
     AccessQuery.close;
    end;

Die AccessQuery holt also die Daten und wird in der Schlaufe doch nach dem MyQuery.execsql doch mit AccessQuery.Next einen Datensatz weiter gesprungen.
Oder sehe ich das falsch??

LG Harry

[Papaschlumpf73]

Das siehst du falsch... :-) Q_sArtikelArtNr.Value wird nirgendwo abgeholt - ist immer derselbe Wert.

[HCB]

Blödsinn was ich geschrieben habe. Mit einem Datensatz funktioniert das Update. (Hat auch den ersten Datensatz geändert).
Hab aber übersehen, dass der geänderte Datensatz noch vom Einzelupdate stammt.

Tatsächlich wird die Schlaufe abgearbeitet aber KEIN Datensatz wird aktualisiert.
Es kommt auch keine Fehlermekdung.

LG Harry

[Klaus01]

wo wird denn z.B ArtVKPreis_0 auf Q_sArtikelArtVkPreis_0.Value gemappt?

Ich sehe zwischen den Parametern und der Query keinen Zusammenhang.

[Delphi.Narium]

Welcher Zusammenhang besteht denn zwischen AccessQuery und Q_sArtikelArtNr?
Ist irgendwo definiert, dass das den Inhalt der Spalte ArtNr der Abfrage AccessQuery repräsentiert?

Delphi-Quellcode:

        MyQuery.ParamByName('ArtNr').Value := AccessQuery.Fields[0].Value;
        MyQuery.ParamByName('ArtVKPreis_0').Value := AccessQuery.Fields[1].Value;
        MyQuery.ParamByName('ArtVKPreis_1').Value := AccessQuery.Fields[2].Value;
        MyQuery.ParamByName('ArtVKPreis_2').Value := AccessQuery.Fields[3].Value;

oder

Delphi-Quellcode:

        MyQuery.ParamByName('ArtNr').Value := AccessQuery.FieldByName('ArtNr').Value;
        MyQuery.ParamByName('ArtVKPreis_0').Value := AccessQuery.FieldByName('ArtVKPreis_0').Value;
        MyQuery.ParamByName('ArtVKPreis_1').Value := AccessQuery.FieldByName('ArtVKPreis_1').Value;
        MyQuery.ParamByName('ArtVKPreis_2').Value := AccessQuery.FieldByName('ArtVKPreis_2').Value;

oder

Delphi-Quellcode:

  AccessQuery.Open;
  Q_sArtikelArtNr := AccessQuery.FieldByName('ArtNr')
  Q_sArtikelArtVkPreis_0 := AccessQuery.FieldByName('ArtVKPreis_0');
  Q_sArtikelArtVkPreis_1 := AccessQuery.FieldByName('ArtVKPreis_1');
  Q_sArtikelArtVkPreis_2 := AccessQuery.FieldByName('ArtVKPreis_2');
  AccessQuery.First;

Die Zeile

Delphi-Quellcode:

MyQuery.SQL.Text :='update oxarticles set oxprice= :ArtVKPreis_0,oxpricea= :ArtVKPreis_1, oxtprice= :ArtVKPreis_2 where oxid = :ArtNr';

kannst Du vor das

Delphi-Quellcode:

AccessQuery.Open;

verschieben. Das muss nur einmal gemacht werden und nicht pro Datensatz.

[HCB]

Ich habe es jetzt so geändert, was leider das selbe (Nicht)ergebnis bringt.

Delphi-Quellcode:

 while not AccessQuery.EOF do
        begin
        MyQuery.SQL.Text :='update oxarticles set oxprice= :ArtVKPreis_0,oxpricea= :ArtVKPreis_1, oxtprice= :ArtVKPreis_2 where oxid = :ArtNr';
        MyQuery.ParamByName('ArtNr').Value := AccessQuery.FieldByName('ArtNr').Value;
        MyQuery.ParamByName('ArtVKPreis_0').Value := AccessQuery.FieldByName('ArtVKPreis_0').Value;
        MyQuery.ParamByName('ArtVKPreis_1').Value := AccessQuery.FieldByName('ArtVKPreis_1').Value;
        MyQuery.ParamByName('ArtVKPreis_2').Value := AccessQuery.FieldByName('ArtVKPreis_1').Value;
        MyQuery.execsql;
        ShowMessage(AccessQuery.FieldByName('ArtNr').Value);
        pgb_updateStatus.Position:=AccessQuery.RecNo;
        AccessQuery.Next;
        end;

Also showMessage zeigt mir nacheinander die richtigen Artikelnummen an. Die ArtNr ändert sich also innerhalb der Schlaufe korrekt.

Komisch.

[stifflersmom]

Kann denn der update Befehl ohne gequotete Artikelnummer überhaupt funktionieren?

[HCB]

Warum geht es beim Update nur eines Datensatzes ohne die ArtNr in QuotedStr zu setzen?
Trotzdem habe ich es mal so probiert:

Delphi-Quellcode:

MyQuery.ParamByName('ArtNr').Value := QuotedStr(AccessQuery.FieldByName('ArtNr').Value);

was leider auch nicht zum Erfolg führt.

[ggscholz]

Was ist denn hiermit:

Code:

where oxid = :ArtNr

?
Ist oxid = ArtNr?

[Delphi.Narium]

Gib doch mal zusätzlich im ShowMessage RowsAffected mit aus:

Delphi-Quellcode:

ShowMessage(Format('ArtNr: %d - aktuallisierte Zeilen: %d',] AccessQuery.FieldByName('ArtNr').Value, MyQuery.RowsAffected]));

Da oxid keine Zeichenfolge ist, geht es ohne Quotes.

Hast Du mal geprüft, ob es die Werte für die ArtNr in der MySQL-Tabelle auch gibt?

Wenn es sie nicht gibt, wirft das Update keine Fehler. Es wird dann eben kein Datensatz akuallisiert. RowsAffected sollte dann = 0 sein.

Wie prüfst Du denn in der MySQL-Datenbank, ob Deine Routine Erfolg hatte oder nicht?

Musst Du bei der Prüfung eventuell in dem Werkzeug eine neue Transaktion starten, weil Du sonst ggfls. nur die Daten aus der schon laufenden Transaktion siehst und nicht die in weiteren Transaktionen Deines Programmes aktuallisierten Werte?

[HCB]

ShowMessage(Format('ArtNr: %d ',[AccessQuery.FieldByName('ArtNr').Value, MyQuery.RowsAffected]));

Fehler: Format 'ArtNr: %d ungültig oder nicht kompatibel mit Argument.

>Hast Du mal geprüft, ob es die Werte für die ArtNr in der MySQL-Tabelle auch gibt?<
Die Felder mit ox... sind inder MySQL Tabelle vorhanden - oxprice, oxpricea und oxtprice und oxid.
Das muss passen, wie gesagt ohne den while EOF Loop updated ja das Programm den einen Datensatz korrekt.

>Wie prüfst Du denn in der MySQL-Datenbank, ob Deine Routine Erfolg hatte oder nicht?<
Mit dem phpMyAdmin kann ich direkt auf dem Server die Tabelle oxArticles einsehen.

>Ist oxid = ArtNr? > Ja

[Delphi.Narium]

Delphi-Quellcode:

ShowMessage(Format('ArtNr: %s - aktuallisierte Zeilen: %d',] AccessQuery.FieldByName('ArtNr').AsString, MyQuery.RowsAffected]));

[ggscholz]

>Ist oxid = ArtNr? > Ja
Gleicher Typ? Value ist ja für vieles gut, wenn das eine String und das andere Integer...
Oder es gibt noch ein Leerzeichen vorne oder hinten?

[fisipjm]

Zitat:

Zitat von HCB (Beitrag 1545988)

Delphi-Quellcode:

MyQuery.ParamByName('ArtNr').Value := QuotedStr(AccessQuery.FieldByName('ArtNr').Value);

Nur eine Kleinigkeit, aber mach das bitte so:

Delphi-Quellcode:

MyQuery.ParamByName('ArtNr').AsString := AccessQuery.FieldByName('ArtNr').AsString;

Die Parameter kümmern sich dann um Quotation etc.

[HCB]

Das mit dem Rat

Delphi-Quellcode:

MyQuery.ParamByName('ArtNr').AsString := AccessQuery.FieldByName('ArtNr').AsString;

habe ich probiert, ist aber nicht korrekt. Als Preis wurde statt 995,50 nur 995 übertragen!

Ich habe das ganze Gedöns um Transaktionen rausgeschmissen ( Connection.StartTransaction; Connection.Commit; und Connection.Rollback ) und jetzt funktioniert das Updaten der MySQL Datenbank korrekt! Vielleicht habe ich diese Transaktionssache falsch eingebunden. Muss ich mich mal näher damit beschäftigen.

Also vielen Dank an alle die mich dabei unterstützt haben den Fehler zu finden.

LG Harry

[Delphi.Narium]

Zitat:

Zitat von HCB (Beitrag 1546027)

Das mit dem Rat

Delphi-Quellcode:

MyQuery.ParamByName('ArtNr').AsString := AccessQuery.FieldByName('ArtNr').AsString;

habe ich probiert, ist aber nicht korrekt. Als Preis wurde statt 995,50 nur 995 übertragen!

Die ArtNr ist nicht der Preis, von daher gibt es da keinen Zusammenhang.

Und wenn die Artnr vom Typ Integer ist, dann wird

Delphi-Quellcode:

MyQuery.ParamByName('ArtNr').AsInteger := AccessQuery.FieldByName('ArtNr').AsInteger;

genommen. Ist damit typsicher und spart beiden Seiten die Typkonvertierung. Dem Programm von Integer nach String, der Datenbank von String nach Integer.

Die Preis stehen in

Delphi-Quellcode:

MyQuery.ParamByName('ArtVKPreis_0').Value := AccessQuery.FieldByName('ArtVKPreis_0').Value;
MyQuery.ParamByName('ArtVKPreis_1').Value := AccessQuery.FieldByName('ArtVKPreis_1').Value;
MyQuery.ParamByName('ArtVKPreis_2').Value := AccessQuery.FieldByName('ArtVKPreis_1').Value;

Von welchem Datentyp sind die Felder in den Datenbanken? Gleitkomma ...

Delphi-Quellcode:

MyQuery.ParamByName('ArtVKPreis_0').AsFloat := AccessQuery.FieldByName('ArtVKPreis_0').AsFloat;
MyQuery.ParamByName('ArtVKPreis_1').AsFloat := AccessQuery.FieldByName('ArtVKPreis_1').AsFloat;
MyQuery.ParamByName('ArtVKPreis_2').AsFloat := AccessQuery.FieldByName('ArtVKPreis_1').AsFloat;

Value ist vom Typ Variant, da muss man immer damit rechnen, dass der Inhalt interpretiert wird. Und das kann (erfahrungsgemäß) schonmal schiefgehen. Wenn ich weiß von welchem Datentyp eine Spalte ist, dann nutze ich immer die

Delphi-Quellcode:

.AsBekannterDatenTyp

-Variante. Das ist dann typsicher und sorgt bei nicht passendem Datentyp für einen entsprechenden Fehler. Bei Value wird (überspitzt formuliert) das nächstbeste irgendwie passende genommen und das muss dann nicht zwingend das Gewünschte sein.

Aus Deinem Quelltext geht nicht hervor, zu wem Connection gehört?
Zu MyQuery oder zu AccessQuery?

Die Transaktion muss zur MyQuery gehören!

Da Du mit zwei Datenbanken arbeitest, nutzt Du (höchstwahrscheinlich) auch zwei Datenbankverbindungen.

Vesuche es mit den Transaktionen doch mal in einer abgewandelten Variante:

Delphi-Quellcode:

  MyQuery.SQL.Text     := 'update oxarticles set oxprice = :ArtVKPreis_0,oxpricea = :ArtVKPreis_1, oxtprice = :ArtVKPreis_2 where oxid = :ArtNr';
  AccessQuery.SQL.Text := 'SELECT ArtNr, ArtVKPreis_0, ArtVKPreis_1, ArtVKPreis_2 FROM sArtikel where ArtInaktiv = false and ArtGSShop = true order by ArtNr';
  AccessQuery.Open;
  try
    MyQuery.Connction.StartTransaction;
    while not AccessQuery.EOF do
    begin
      MyQuery.ParamByName('ArtNr').AsInteger      := Q_sArtikelArtNr.AsInteger;      // <-- korrekten Typ nehmen
      MyQuery.ParamByName('ArtVKPreis_0').AsFloat := Q_sArtikelArtVkPreis_0.AsFloat; // <-- korrekten Typ nehmen
      MyQuery.ParamByName('ArtVKPreis_1').AsFloat := Q_sArtikelArtVkPreis_1.AsFloat; // <-- korrekten Typ nehmen
      MyQuery.ParamByName('ArtVKPreis_2').AsFloat := Q_sArtikelArtVkPreis_2.AsFloat; // <-- korrekten Typ nehmen
      MyQuery.ExecSql;
      // Hier rate ich mal: pgb_updateStatus sei eine Progressbar
      pgb_updateStatus.Caption  := Format('ArtNr: %.5d - aktuallisierte Sätze: %.5d',[Q_sArtikelArtNr.AsInteger, MyQuery.RowsAffected]));
      pgb_updateStatus.Position := AccessQuery.RecNo;
      AccessQuery.Next;
    end;
    MyQuery.Connction.Commit;
  except
    on e : Exception do
    begin
      pgb_updateStatus.Caption := e.Message;
      MyQuery.Connection.Rollback;
      raise;
    end;
  end;
  AccessQuery.Close;

[HCB]

@Delphi.Narium
Das mit den Parametern habe ich schon verstanden.
Ich meinte

Delphi-Quellcode:

 MyQuery.ParamByName('ArtVKPreis_0').AsString := AccessQuery.FieldByName('ArtVKPreis_0').AsString;

was die Nachkommastellen nicht nimmt.
Mit Value oder mit asFloat ist es korrekt.

Ich habe mal deine Variante eingesetzt. Es erfolgt kein Update obwohl der Loop durchläuft.
Interessanterweise zeitgte mir

Delphi-Quellcode:

 pgb_updateStatus.Caption := Format('ArtNr: %.5d - aktuallisierte Sätze: %.5d',[Q_sArtikelArtNr.AsInteger, MyQuery.RowsAffected]);

nur den ersten Datensatz. Eine Veränderung findet nicht statt.

Ohne die Transaktionsachen läuft es korrekt.
------------------------------------------------------------------------------------
Nebenbei ist mir noch etwas nicht klar:

Delphi-Quellcode:

begin
     FDMSAccessService.Database:='E:\Preisdateien\K000110_p.mdb';
     FDConnection.Connected := False;
     FDMSAccessService.Compact;
end;

sollte doch eigentlich ganz easy die Datenbank komprimieren. Was es aber nicht tut.
Es kommt die Fehlermeldung: Unbekannter OLE-Fehler ['' konnte nicht verwendet werden; Datei wird bereits verwendet]

Im MS Access Demoprogramm funktioniert es ebenso mit gleicher Fehlermeldung nicht!
Was ist denn da schon wieder verkehrt? Ich zweifel ernsthaft an meinen schon ohnehin geringen Fähigkeiten bezg. Delphi.

LG Harry

[Delphi.Narium]

Zitat:

Zitat von HCB (Beitrag 1546049)

@Delphi.Narium
Das mit den Parametern habe ich schon verstanden.
Ich meinte

Delphi-Quellcode:

 MyQuery.ParamByName('ArtVKPreis_0').AsString := AccessQuery.FieldByName('ArtVKPreis_0').AsString;

was die Nachkommastellen nicht nimmt.

Naja, .AsString ist ja für nummerische Werte auch nicht korrekt. Da kann man nicht erwarten das es korrekt funktioniert.

Zitat:

Zitat von HCB (Beitrag 1546049)

Mit Value oder mit asFloat ist es korrekt.

Value interpretiert, wird meist richtig sein wird. .AsFloat dürfte in dem Fall der Preise die einzig richtige Variante sein.

Zitat:

Zitat von HCB (Beitrag 1546049)

Ich habe mal deine Variante eingesetzt. Es erfolgt kein Update obwohl der Loop durchläuft.
Interessanterweise zeitgte mir

Delphi-Quellcode:

 pgb_updateStatus.Caption := Format('ArtNr: %.5d - aktuallisierte Sätze: %.5d',[Q_sArtikelArtNr.AsInteger, MyQuery.RowsAffected]);

nur den ersten Datensatz. Eine Veränderung findet nicht statt.

Wenn nur der erste Datensatz angezeigt wird, läuft die Schleife nicht (zwingend) durch. Hier würde ich eher erwarten, dass ein Fehler auftritt, der aber "irgendwo" verschluckt wird.
Kommt das Programm denn im Except-Block an? Wird dort dann das Rollback ausgeführt? Mal den Programmablauf im Debugger überprüft, nachvollzogen?

Zitat:

Zitat von HCB (Beitrag 1546049)

Ohne die Transaktionsachen läuft es korrekt.

Irgendwas scheint da gewaltig schiefzulaufen :-(

Zitat:

Zitat von HCB (Beitrag 1546049)

Nebenbei ist mir noch etwas nicht klar:

Delphi-Quellcode:

begin
     FDMSAccessService.Database:='E:\Preisdateien\K000110_p.mdb';
     FDConnection.Connected := False;
     FDMSAccessService.Compact;
end;

sollte doch eigentlich ganz easy die Datenbank komprimieren. Was es aber nicht tut.
Es kommt die Fehlermeldung: Unbekannter OLE-Fehler ['' konnte nicht verwendet werden; Datei wird bereits verwendet]

Im MS Access Demoprogramm funktioniert es ebenso mit gleicher Fehlermeldung nicht!
Was ist denn da schon wieder verkehrt? Ich zweifel ernsthaft an meinen schon ohnehin geringen Fähigkeiten bezg. Delphi.

Die Fehlermeldung besagt, dass die Datenbankdatei in Benutzung ist. Ein Compact geht nur, wenn kein Prozess auf die Datenbankdatei zugreift. Es wird ein exklusiver Dateizugriff benötigt.

Wenn z. B. in der IDE eine Connection auf True steht und Du dann das Programm ausführst, reicht dies aus, um diese Fehlermeldung zu erhalten.

Compact geht nur, wenn absolut sichergestellt ist, dass kein Prozess noch eine Verbindung zur Datenbank hat. Auch alle Connections im eigenen Programm, alle Querys, ... müssen geschlossen sein. Ebenso alle anderen Programme, die auf diese Datenbankdatei zugreifen können.

[HCB]

FDConnection.Connected := False;
reicht das nicht aus? Es sind doch dann alle die an der Verbindung hängen automatisch geschlossen.
Im Demoprogramm geht aus bei mir ja auch nicht. Da habe ich überhaupt nichts daran verändert!

In der Fehlermeldung sieht es so aus, als wenn keine Datei angegeben ist. (Beide Hochkommas) ['' konnte nicht verwendet werden; Datei wird bereits verwendet]

Sehr merkwürdig.

[Delphi.Narium]

Es müssen alle Verbindungen zur Datenbank geschlossen sein, nicht nur die im eigenen Programm.

Sind in der IDE noch Datenbankverbindungen offen?
Stehen das irgendwelche Connections auf True oder sind irgendwelche Querys aktiv?
Greifen weitere Programme auf die Datenbank zu?
...

Dass da kein Dateiname in der Fehlermeldung steht, ist unschön, aber normal. Da wurde wohl bei der Programmierung (irgendwo in den Tiefen der Schnittstelle) geschlampt.

Hast Du den Process-Explorer auf Deinem Rechner? Wenn ja, dann schau mit dem mal nach, welche Prozesse auf die Datenbankdatei zugreifen.

[HCB]

@Delphi.Narium

Danke vielmals für Deine ständige Unterstützung. Wieder einmal hast du mir sehr geholfen.
Ich hatte die externe Datei 'E:\Preisdateien\K000110_p.mdb' mit AssignFile(F, FileName)zwar verbunden, aber nicht mehr freigegeben!
Das FDConnection.Connected := False bezieht sich ja offenbar nur auf interne Queries etc.

Alles gut soweit.

Mit den Transaktionen muss ich mich mal näher befassen.

LG Harry