mORMot Open Source

procedure TDFSynDBStringBuilder.CreateTempTable(const AIDs: TIDDynArray; var ATablename: String);
begin
  TSynLog.Enter('Create Temp Table for % IDs', [System.Length(AIDs)], Self);
  if ATablename.IsEmpty then
    ATablename := 'tmp_ids_' + StringReplace(TGUID.NewGuid.ToString, '{', '', []).Replace('}', '').Replace('-', '');

  var LConnection := TSqlDBUniDACConnection(FConnectionProperties.MainConnection);
  var LInTransaction := LConnection.InTransaction;
  if not LInTransaction then begin
    if not LConnection.Connected then
      LConnection.Connect;
    LConnection.StartTransaction;
  end;
  try
    var LScript := TUniScript.Create(nil);
    var LSQLStream := TStringStream.Create;
    LScript.Connection := LConnection.Database;
    try
      var LBatchSize := 1000;
      case DBMS of
        dMySQL : begin
          LBatchSize := 10000;  // Teste
          SimpleQuery('create temporary table '+ATableName+' (TempID bigint primary key)'); // .ExecuteInlined(false);
          LSQLStream.WriteString(ToString);
        end;
        dMSSQL : begin
          ATablename := '#'+ATablename;
          LBatchSize := 1000;
          SimpleQuery('create table '+ATableName+' (TempID bigint primary key)'); // .ExecuteInlined(false);
          LSQLStream.WriteString(ToString);
        end;
      end;

    // Benutze UniDac Batch Insert Methode ! (Leider auch maximal 1000 / Execute !)
  //    var Q := TUniQuery.Create(nil);
  //    try
  //      Q.Connection := LConnection.Database;
  //      Q.SQL.Text := 'INSERT INTO '+ATablename+' (TempID) VALUES (:id)';
  //      Q.ParamByName('id').DataType := ftLargeInt;
  //      Q.Params.ValueCount := System.Length(AIDs);
  //
  //      for var i := 0 to High(AIDs) do
  //        Q.Params[0][i].AsLargeInt := AIDs[i];
  //
  //      Q.Execute(System.Length(AIDs));
  //    finally
  //      Q.Free;
  //    end;
  // Maximal 1000 Werte pro Zeile !
      var i := 0;
      while i < System.Length(AIDs) do begin
        SimpleQuery('insert into '+ATableName+' (TempID) values ');
        for var j := 0 to LBatchSize - 1 do begin
          if i >= System.Length(AIDs) then
            Break;
          Append('(').Append(AIDs[i]).Append('),');
          Inc(i);
        end;
        // letztes Komma entfernen
        Length := Length - 1;
        LSQLStream.WriteString(ToString);
//        ExecuteInlined(false);
       end;
  //    case DBMS of
  //      dMySQL : SimpleQuery('CREATE UNIQUE CLUSTERED INDEX idx_tempid ON '+ATableName+' (TempID)').ExecuteInlined(false);
  //      dMSSQL : SimpleQuery('CREATE UNIQUE INDEX idx_tempid ON '+ATableName+' (TempID)').ExecuteInlined(false);
  //    end;

      LScript.ExecuteStream(LSQLStream);
      if not LInTransaction then
        LConnection.Commit;
    finally
      FreeAndNil(LSQLStream);
      FreeAndNil(LScript);
    end;
  except
    if not LInTransaction then
      LConnection.Rollback;
    raise;
  end;
end;

  TBild = class(TDFDomBase)
  private
    fBildID : TBildBildID;
    fGUID : TBildGUID;
    fBinaerdaten : RawBlob;
  public
    procedure SetBinaerdaten(const ABinaerdaten : RawBlob);
  published
    property BildID: TBildBildID read fBildID;
    property GUID: TBildGUID read fGUID;
    property Binaerdaten : RawBlob read fBinaerdaten;
    property Datenformat : RawUtf8 read fDatenformat;
  end;

function FillBildStreamFromBDS(var ABild : TBild) : TresultRec; 
begin
  var LBinaerdaten : RawBlob;
  Result := GetBildBinaerdaten(ABild.GUID, LBinaerdaten);
  if Result.Erfolgreich then
    ABild.SetBinaerdaten(LBinaerdaten);
end;

procedure TRest.InternalLogResponse(const aContent: RawByteString;
  const aContext: shortstring; Level: TSynLogLevel);
begin // caller checked that self<>nil and sllServiceReturn in fLogLevel
//  fLogFamily.Add.LogEscape(Level, '%', [aContext], pointer(aContent), length(aContent), self);
  fLogFamily.Add.Log(Level, aContent, self, MAX_SIZE_RESPONSE_LOG);
end;