DataSnap TFDJSONDataSets in die DB schreiben

[Kostas]

Hallo Zusammen,


das Problem vorab: oStream.read(FJSONDataSets, SizeOf(FJSONDataSets)); SizeOf liefert nicht die Objektgröße
von FJSONDataSets sondern vermutlich die Anzahl der Tabellen.


Ich habe eine Hand voll Tabellen aus denen ich markierte Datensätze von einem DataSnap Client zu einen Data Server
übertragen muss. Alle Daten sollen zu einem Paket zusammengefasst werden. Es bietet sich an ein TFDJSONDataSets
zu verwenden da es mehrere Tabellen aufnehmen kann. Das FJSONDataSets wird auch komplett richtig übertragen. Testhalber
habe ich einzelne Tabellen nach dem Empfang ausgelesen und als XML in ein File gespeichert. Der Transport funktioniert also.

Das Problem ist nun, ich würde gerne das komplette FJSONDataSets Object in ein Blob schreiben um es später zu verarbeiten.
Genau das gelingt mir nicht. Leider hat FJSONDataSets kein SaveToStream. Ich habe es versucht mit einem TMemoStream. Vermutlich
mache ich etwas falsch denn SizeOf(FJSONDataSets) gibt immer 4 aus obwohl es deutlich größer ist.

Hat jemand eine Idee wie das mit dem TMemoStream funktioniert?
FJSONDataSets wird ja auch serialisiert über DataSnap. Eigentlich müsste es dafür Methoden geben.

Delphi-Quellcode:

function TdmDALPostfach.SavePaketInDB(FJSONDataSets:TFDJSONDataSets): integer;
var

  id: Integer;
begin
  result := 0;

  TThread.Synchronize(nil, procedure
  var
    oConn:  TFDConnection;
    oCmd: TFDCommand;
    oStream: TMemoryStream;
  begin

    oStream := TMemoryStream.Create();
    oConn  := TFDConnection.Create(nil);
    oCmd := TFDCommand.Create(nil);

    try
      oStream.read(FJSONDataSets, SizeOf(FJSONDataSets));


      oConn.ConnectionDefName := PostfachConnectionDefName;

      oCmd.Connection := oConn;

      oCmd.CommandText.Text := 'INSERT INTO PAKETE(LIZENZID, INHALT, ZEITPUNKT) values (:LIZENZID, :INHALT, :ZEITPUNKT)';
      oCmd.Params[0].AsInteger := 1;
      oCmd.Params[1].LoadFromStream(oStream,ftBlob);
      oCmd.Execute;
      oConn.Close;
    finally
      oConn.Free;
      oCmd.Free;
      oStream.Free;
    end;
  end);
end;

Gruß Kostas