mORMot Open Source

constructor TSynRestDataSet.Create(AOwner: TComponent);
begin
  inherited Create(AOwner);
  //RedirectCode(@TSynRestDataset.DataConvert, @TSynRestDataset.DataConvertPatch, @fDataConvertPatchBackup);
  fProvider := TDataSetProvider.Create(Self);
  fProvider.Name := 'InternalProvider';                 { Do not localize }
  fProvider.SetSubComponent(True);
  fProvider.Options := fProvider.Options+[poAllowCommandText];
  fProvider.OnUpdateError := DoOnUpdateError;
  SetProvider(fProvider);
  fDataSet := TSynRestSQLDataSet.Create(Self);
  fDataSet.Name := 'InternalDataSet';                   { Do not localize }
  fDataSet.AfterInsert := Self.DoOnAfterInsert;
  fDataSet.AfterOpen := Self.DoOnAfterOpen;
  fDataSet.SetSubComponent(True);
  fProvider.DataSet := fDataSet;
end;

destructor TSynRestDataSet.Destroy;
begin
  fDataSet.AfterInsert := nil;

  fProvider.DataSet := nil;
  FreeAndNil(fDataSet);
  FreeAndNil(fProvider);

  //RedirectCodeRestore(@TSynRestDataset.DataConvert, fDataConvertPatchBackup);

  inherited;
end;

begin
  // set logging abilities
  SQLite3Log.Family.Level := LOG_VERBOSE;
  //SQLite3Log.Family.EchoToConsole := LOG_VERBOSE;
  SQLite3Log.Family.PerThreadLog := ptIdentifiedInOnFile;
  // ODBC driver e.g. from http://ftp.postgresql.org/pub/odbc/versions/msi

  //aProps := TODBCConnectionProperties.Create('','Driver=PostgreSQL Unicode'+
  //    {$ifdef CPU64}'(x64)'+{$endif}';Database=postgres;'+
  //    'Server=localhost;Port=5433;UID=postgres;Pwd=postgresPassword','','');




    FDPhysMySQLDriverLink := TFDPhysMySQLDriverLink.Create(Nil);
    aProps := TSQLDBFireDACConnectionProperties.Create('MySQL?Server='+_SERVERIP,_DBNAME,_DBUSRNAME,_DBPASSWD);
   // aProps.ForcedSchemaName := 'sam';
  try
    // get the shared data model
    aModel := DataModel;
    VirtualTableExternalRegisterAll(aModel, aProps, false);


    try
      // create the main mORMot server
      aRestServer := TSQLRestServerDB.Create(aModel,SQLITE_MEMORY_DATABASE_NAME,false); // authentication=false

      try
        // create tables or fields if missing
       aRestServer.CreateMissingTables;

        // serve aRestServer data over HTTP
        aHttpServer := TSQLHttpServer.Create(SERVER_PORT,[aRestServer],'+',useHttpApiRegisteringURI);
        try
          aHttpServer.AccessControlAllowOrigin := '*'; // allow cross-site AJAX queries
          writeln('Background server is running.'#10);
          write('Press [Enter] to close the server.');
          readln;
        finally
          aHttpServer.Free;
        end;
      finally
        aRestServer.Free;
      end;
    finally
      aModel.Free;
    end;
  finally
    aProps.Free;
  end;
end.