mORMot Open Source

  TFinancialYears=class(TSQLRecord)
  private
    fEndDate: TDateTime;
    fClosed: Boolean;
    fClosedByUserId: Integer;
    fStartDate: TDateTime;
    fCloseDate: TDateTime;
    fCompanyId: integer;
  published
    property  CompanyId: integer read fCompanyId write fCompanyId;
    property  StartDate :TDateTime read fStartDate write fStartDate;
    property EndDate :TDateTime read fEndDate write fEndDate;
    property Closed:Boolean read fClosed write fClosed;
    property ClosedByUserId:Integer read fClosedByUserId write fClosedByUserId;
    property CloseDate :TDateTime read fCloseDate write fCloseDate;
  end;

 
type
  TConnection = class(TInterfacedObject, IConnection)
  protected
    fProps: TOleDBMSSQL2012ConnectionProperties;
  public
    destructor Destroy; override;
  public // implements IRemoteSQL methods
    procedure Connect(const aServerName, aDatabaseName,
      aUserID, aPassWord: RawUTF8);
  end;

implementation

{ TServiceRemoteSQL }

procedure TConnection.Connect(const aServerName, aDatabaseName, aUserID,
  aPassWord: RawUTF8);
begin
  if fProps<>nil then
    raise Exception.Create('Connect called more than once');
    fProps := TOleDBMSSQL2012ConnectionProperties.Create(aServerName,
              aDatabaseName,aUserID,aPassWord);
 end;

procedure TFaezERPHttpService.DoStart(Sender: TService);
var
  aModel: TSQLModel;
  aServer: TSQLRestServerFullMemory;
  aHTTPServer: TSQLHttpServer;
begin
  // define the log level
  with TSQLLog.Family do begin
    Level := LOG_VERBOSE;
    EchoToConsole := LOG_VERBOSE; // log all events to the console
    PerThreadLog := ptIdentifiedInOnFile;
  end;
  AllocConsole;
  TextColor(ccLightGray); // needed to notify previous AllocConsole
  TModel.CreateModel(aModel);
  try
    aServer := TSQLRestServerFullMemory.Create(aModel,'users.json',false,true);
    try
      TregisterService.RegisterAllServices(AServer);
      aHTTPServer := TSQLHttpServer.Create(PORT_NAME,[aServer],'+',HTTP_DEFAULT_MODE);
      try
        aHTTPServer.AccessControlAllowOrigin := '*'; // for AJAX requests to work
        Sleep(200); // allow all HTTP threads to be launched and logged
        writeln(#10'Background server is running.'#10);
        writeln('Press [Enter] to close the server.'#10);
        ConsoleWaitForEnterKey;
      finally
        aHTTPServer.Free;
      end;
    finally
      aServer.Free;
    end;
  finally
    aModel.Free;
  end;
end;

Type
  TRegisterService=class

  public
   class  procedure RegisterAllServices(var server:TSQLRestServerFullMemory);
   class  procedure RegisterClientServices(var server:TSQLRestClientURI);
  end;

  TModel= Class
  public
   class  Procedure CreateModel(Var Model:TSQLModel);
  End;

  TDatabaseConfiguration=class
  public
   class  procedure RegisterVirtualTable(var model:TSQLModel;
          var Props:TOleDBMSSQL2012ConnectionProperties);
  end;

const
  ROOT_NAME = 'root';
  PORT_NAME = '8888';
  APPLICATION_NAME = 'RestService';

implementation

uses UntConnection,UntIConnection,UntUsers;

{ TRegisterService }

class procedure TRegisterService.RegisterAllServices(
  var server: TSQLRestServerFullMemory);
begin
    Server.ServiceDefine(TConnection,[IConnection],sicClientDriven);
end;

class procedure TRegisterService.RegisterClientServices(
  var server: TSQLRestClientURI);
begin
   Server.ServiceDefine([IConnection],sicClientDriven);
end;

{ TModel }

class procedure TModel.CreateModel(var Model: TSQLModel);
begin
   Model := TSQLModel.Create([TSQLSampleRecord],Root_Name);

end;

{ TDatabaseConfiguration }

class procedure TDatabaseConfiguration.RegisterVirtualTable(
  var model: TSQLModel; var Props: TOleDBMSSQL2012ConnectionProperties);
begin
  VirtualTableExternalMap(Model,TSQLSampleRecord,Props,'TestTable');
end;

 
unit UntIConnectionProperties;

interface
uses
  syncommons;

Type
  TConnectionData=packed record
    fServerName :RawUTF8;
    fUserName :RawUTF8;
    fPassword :RawUTF8;
  end;

  IConnectionProperties =Interface(IInvokable)
    ['{391FC485-33AF-42C8-B4C7-1C87EF850D0D}']
    function GetConnectionData: TConnectionData;
    procedure SetConnectionData(aValue :TConnectionData);
    property ConnectionData :TConnectionData read GetConnectionData write SetConnectionData;
  End;

 
unit UntTConnectionProperties;

interface
uses
  UntIConnectionProperties,
  inifiles,
  System.SysUtils,SynCommons;

Type
  TConnectionProperties =Class(TInterfacedObject,IConnectionProperties)
  private
    fConnectionINI: TIniFile;
  public
    constructor create;
    destructor Destroy; override;
    property ConnectionINI :TIniFile read fConnectionINI write fConnectionINI;
    function GetConnectionData:TConnectionData;
    procedure SetConnectionData(aValue :TConnectionData);
  published
    property ConnectionData :TConnectionData read GetConnectionData write SetConnectionData;
  End;

 
    aServer.ServiceRegister(TConnectionProperties,[Typeinfo(IConnectionProperties)],sicClientDriven).
            SetOptions([],[optExecInMainThread,optFreeInMainThread]);