mORMot Open Source

  fModel := CreateModel;
  fServer := TSQLRestServerDB.Create(fModel, ':memory:', False);
  fServer.AcquireExecutionMode[execORMWrite] := amBackgroundThread;

  fClient := TSQLRestClientDB.Create(fServer);
  fClient.AcquireExecutionMode[execORMWrite] := amBackgroundThread;

   ....   EXECUTING SOME BATCH ...... AND DURING THE QUERY I KILL THE CONNECTION IN THE MySQL DATABASE ....
   
  fClient.Free;
  fServer.Free;    <-------------------- here EXCEPTION "MySQL should be connected"
  fModel.Free;   

   ...
   GetClientDB.Delete(GetSQLRecordClass, GetPrimaryKeyFieldname + ' IN (1,2,3)');
   ...

destructor TSQLModel.Destroy;
var i,j: integer;
begin
  for i := 0 to fTablesMax do begin
    with TableProps[i].Props do begin
      EnterCriticalSection(fLock); // may be called from several threads at once   <---- THEN EXCEPTION HERE
      try
        for j := 0 to fModelMax do
          if fModel[j].Model=self then begin
            // un-associate this TSQLRecord with this model
            Move(fModel[j+1],fModel[j],(fModelMax-j)*sizeof(fModel[j]));
            dec(fModelMax);
            break;
          end;
        TableProps[i].Free;
      finally
        LeaveCriticalSection(fLock);
      end;
    end;
  end;
  inherited;
end;

  TSQLRecordProperties = class
  protected
    ...
    fLock: TRTLCriticalSection;
    ...
  public

http://localhost:888/root/CustomDateTimeService.GetValues

BODY:
{
  "SpecificDateTime":"2015-05-01T23:59:23"
}

{
  "errorCode": 406,
  "errorText": "Shared execution failed (probably due to bad input parameters) for ICustomDateTimeService.GetValues"
}

[[
      {
        "iD": 1,
        "name": "a"
      },
      {
        "iD": 2,
        "name": "b"
      }
]]

uses
  System.Generics.Collections;
  System.SysUtils,
  System.JSON,
  REST.Json,
  mORMot,
  SynCommons;
  
type
  TEstadoObjectList = class(TObjectList<TEstado>);

  IEstadoService = interface(IInvokable)
  ['{A56EA833-873A-4AA5-9786-DA7DC1A7D014}']
    function GetEstados(out AList: TEstadoObjectList): boolean;
  end;

  TEstadoService = class(TInterfacedObject, IEstadoService)
  public
    function GetEstados(out AList: TEstadoObjectList): boolean;
  end; 

 TJSONSerializerEstado = class(TObject)
  public
    class function ReadJSON(const aValue: TObject; aFrom: PUTF8Char; var aValid: Boolean; aOptions: TJSONToObjectOptions): PUTF8Char;
    class procedure WriteJSON(const aSerializer: TJSONSerializer; aValue: TObject; aOptions: TTextWriterWriteObjectOptions);
  end;

implementation

  class function TJSONSerializerEstado.ReadJSON(const aValue: TObject; aFrom: PUTF8Char; var aValid: Boolean; aOptions: TJSONToObjectOptions): PUTF8Char;
  begin
    // not yet written...
  end;

  class procedure TJSONSerializerEstado.WriteJSON(const aSerializer: TJSONSerializer; aValue: TObject; aOptions: TTextWriterWriteObjectOptions);
  var
    I: Integer;
    EL: TEstadoObjectList;
    JSONObject: TJSOnObject;
  begin
    EL := TEstadoObjectList(aValue);
    JSONObject := nil;
    TRY
      JSONObject := TJson.ObjectToJsonObject(EL);
      aSerializer.AddString(JSONObject.Values['items'].ToJSON);
    FINALLY
      for I := (EL.Count-1) downto 0 do
      begin
        EL[i].Free;
        EL[i] := nil;
        EL.Delete(I);
      end;
      FreeAndNil(JSONObject);
    END;
  end;

function TEstadoService.GetEstados(out AList: TEstadoObjectList): boolean;
var
  Estado: TEstado;
  I: Integer;
begin
  AList.Capacity := 10;
  for I := 1 to AList.Capacity do
  begin
    Estado := TEstado.Create;
    Estado.ID := 123456;
    Estado.Name := 'abcdefg';
    AList.Add(Estado);
  end;
  Result := true;
end;


initialization
  TJSONSerializer.RegisterCustomSerializer(TEstadoObjectList, TJSONSerializerEstado.ReadJSON, TJSONSerializerEstado.WriteJSON);

  TJSONSerializer.RegisterClassForJSON([TEstadoObjectList]);

  TInterfaceFactory.RegisterInterfaces([TypeInfo(IEstadoService)]);

finalization

{
  "result": [
    [
      {
        "iD": 123456,
        "name": "abcdefg"
      }

     ...

    ],
  ],
  "id": 1
}

TMyTable = class(TSQLRecord)
published
  Field1: string;
  Field2: string;
end;
...
fServer.CreateMissingTables();
...

  fServer.CreateMissingTables(0, [SetAutoIncrement4TSQLRecordID]);

  // NO SERIALIZATION
  TNumber = (
    One = 1,
    Two = 2,
    Three = 3
  );

  // SERIALIZATION
  TNumber = (
    One,
    Two,
    Three
  );

  TNumberGreaterThenTen = (
    Ten = 10,
    Twenty = 20,
    Thirty = 30
  );

  TSQLTable= class(TSQLRecord)
  private
    fFirstname: RawUTF8;
    fLastname: RawUTF8;
    fPicture: TSQLRawBlob;
   ...
  end;
   
  ...

  fClient.ForceBlobTransfert := True;
  fClient.ForceBlobTransfertTable[TSQLTable] := True; 

  fClient.BatchStart(TSQLTable);

  for I := 0 to aFiles.Count-1 do
  begin
    ...
    DataTable.Firstname:= 'John';
    DataTable.Lastname := 'Dow';
    DataTable.Picture := StringFromFile(aFiles[i]);

    fClient.BatchAdd(DataTable, True);
    ...
  end;

  fClient.BatchSend(ResultIDs);

  ...
    DataTable.Firstname:= 'John';
    DataTable.Lastname := 'Dow';

    RecID := fClient.BatchAdd(DataTable, True);
    fClient.UpdateBlob(TSQLTable, RecID, 'Picture', StringFromFile(aFiles[i]));
  ...