mORMot Open Source

CREATE TABLE `user` (
  `id` bigint(255) NOT NULL AUTO_INCREMENT,
  `name` varchar(50) NOT NULL,
  `age` int(11) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

CREATE DEFINER=`root`@`%` PROCEDURE `GetUserByLevel`(IN `ALevel` int(4))
BEGIN
  IF ALevel = 0 THEN
    SELECT `name`, `age` FROM `user` WHERE `age` BETWEEN 0 AND 6 ORDER BY `age`;
  ELSEIF ALevel = 1 THEN
    SELECT `name`, `age` FROM `user` WHERE `age` BETWEEN 6 AND 18 ORDER BY `age`;
  ELSE
    SELECT `name`, `age` FROM `user` WHERE `age` > 18 ORDER BY `age`; 
  END IF;

END

program Project11;

{$APPTYPE CONSOLE}

{$R *.res}

uses
  System.SysUtils, SynCommons, SynDB, SynDBODBC;

var
  Props: TODBCConnectionProperties;

procedure InsertRecords;
begin
  Props.Execute('TRUNCATE TABLE user', []);
  Props.Execute('INSERT INTO user (name, age) VALUES (?, ?)', ['John', 1]);
  Props.Execute('INSERT INTO user (name, age) VALUES (?, ?)', ['Mary', 10]);
  Props.Execute('INSERT INTO user (name, age) VALUES (?, ?)', ['Lucas', 20]);
end;

procedure CallStoredProcedure;
var
  Row: ISQLDBRows;
begin
  Row := Props.Execute('CALL GetUserByLevel(?)', [1]);
  while Row.Step do
    Writeln(FormatUTF8('name: %, age: %', [Row['name'], Row['age']]));
end;

const
  CONN_STRING = 'Driver=MySQL ODBC 5.3 UNICODE Driver;Database=test;Server=127.0.0.1;Port=3306;UID=test;Pwd=';
begin
  Props := TODBCConnectionProperties.Create('', CONN_STRING, '', '');
  try
    try
      InsertRecords;                 // If comment this line
      CallStoredProcedure;
      CallStoredProcedure;           // error occurs
    except
      on E: Exception do
        Writeln(E.ClassName, ': ', E.Message);
    end;
  finally
    Props.Free;
  end;
end.

program TestHttpApiServer;

{$APPTYPE CONSOLE}

{$R *.res}

uses
  System.SysUtils, SynCommons, SynCrtSock, SynLog;

type
  TMyServer = class
    constructor Create;
    destructor Destroy; override;
  private
    fServer: THttpApiServer;
    function Process(Ctxt: THttpServerRequest): Cardinal;
  public
    procedure Start;
  end;

var
  ILog: ISynLog;
  Server: TMyServer;

{ TMyServer }

constructor TMyServer.Create;
begin
  fServer := THttpApiServer.Create(True);
  fServer.OnRequest := Process;
  fServer.AddUrl('root', '8080', False, '+', True);
end;

destructor TMyServer.Destroy;
begin
  fServer.Free;
  inherited;
end;

function TMyServer.Process(Ctxt: THttpServerRequest): Cardinal;
begin
  ILog.Log(sllDebug, '% : % %', [NowUTCToString, Ctxt.Method, Ctxt.URL]);

  Sleep(3000);

  ILog.Log(sllDebug, '% : % % => %', [NowUTCToString, Ctxt.Method, Ctxt.URL, 'OK']);
  Ctxt.OutContent := 'OK';
  Result := 200;
end;

procedure TMyServer.Start;
begin
  fServer.Start;
  ILog.Log(sllInfo, ': server start!');
end;

begin
  with TSynLog.Family do
  begin
    Level := LOG_VERBOSE;
    EchoToConsole := LOG_VERBOSE;
    PerThreadLog := ptOneFilePerThread;
  end;
  ILog := TSynLog.Add;

  Server := TMyServer.Create;
  Server.Start;

  Readln;
end.