mORMot Open Source

program SocketTest;

{$APPTYPE CONSOLE}

{$R *.res}

uses
  System.SysUtils,
  mormot,
  SynCrtSock,
  SynBidirSock;

type
TMySocket = class(TAsynchConnection)
public
function OnRead(Sender: TAsynchConnections): TPollAsynchSocketOnRead; override;
end;

var
Server:TAsynchServer;

{ TMySocket }

function TMySocket.OnRead(Sender: TAsynchConnections): TPollAsynchSocketOnRead;
begin
Sender.Write(self,'Hello!');
end;

begin
  try
  Server:=TAsynchServer.Create('333',nil,nil,TMySocket,'test',TSQLLog, [] ,50);
  Readln(Input);
  except
    on E: Exception do
      Writeln(E.ClassName, ': ', E.Message);
  end;
end.

          if added>0 then
            try
              inc(fReadCount);
              inc(fReadBytes,added);
              if OnRead(connection)=sorClose then
                CloseConnection;
            except
              CloseConnection; // any exception will force socket shutdown
            end;

        finally
          slot.UnLock;
        end;

procedure TPollAsynchSockets.ProcessRead(timeoutMS: integer);
var notif: TPollSocketResult;
    connection: TObject;
    slot: PPollSocketsSlot;
    res,added: integer;
    temp: array[0..$7fff] of byte; // read up to 32KB chunks
  procedure CloseConnection;
  begin
    if connection=nil then
      exit;
    Stop(connection); // will shutdown the socket
    try
      OnClose(connection); // do connection.Free
    except
      connection := nil;
    end;
    slot := nil; // ignore pseClosed
  end;
begin
  if (self=nil) or fRead.Terminated then
    exit;
  InterlockedIncrement(fProcessing);
  try
    if not fRead.GetOne(timeoutMS,notif) then
      exit;
    connection := TObject(notif.tag);
    slot := SlotFromConnection(connection);
    if (slot=nil) or (slot.socket=0) then
      exit;
    if pseError in notif.events then
      if not OnError(connection,notif.events) then begin // false = shutdown
        CloseConnection;
        exit;
      end;
    if pseRead in notif.events then begin
      if slot.Lock then // ensure read slot not already processed in another thread
        try
          added := 0;
          repeat
            if fRead.Terminated then
              exit;
            res := AsynchRecv(slot.socket,@temp,sizeof(temp));
            if res<0 then       // error - probably "may block"
              break;
            if res=0 then begin // socket closed -> abort
              CloseConnection;
              exit;
            end;
            AppendData(slot.readbuf,temp,res);
            inc(added,res);
          until false;
//          if added>0 then
//            try
//              inc(fReadCount);
//              inc(fReadBytes,added);
//              if OnRead(connection)=sorClose then
//                CloseConnection;
//            except
//              CloseConnection; // any exception will force socket shutdown
//            end;
        finally
          slot.UnLock;
        end;
          if added>0 then
            try
              inc(fReadCount);
              inc(fReadBytes,added);
              if OnRead(connection)=sorClose then
                CloseConnection;
            except
              CloseConnection; // any exception will force socket shutdown
            end;
    end;
    if (slot<>nil) and (pseClosed in notif.events) then begin
      CloseConnection;
      exit;
    end;
  finally
    InterlockedDecrement(fProcessing);
  end;
end;

 dMSSQL,dMySQL, dPostgreSQL: FMT :=
    'select COLUMN_NAME, DATA_TYPE, CHARACTER_MAXIMUM_LENGTH, NUMERIC_PRECISION,'+
    ' NUMERIC_SCALE, 0 INDEX_COUNT'+ // INDEX_COUNT=0 here (done via OleDB)
    ' from INFORMATION_SCHEMA.COLUMNS'+
    ' where UPPER(TABLE_SCHEMA) = ''%'' and UPPER(TABLE_NAME) = ''%''';

    dMSSQL: FMT:=
      ' select  '+
      ' sys.all_columns.name as COLUMN_NAME,'+
      ' sys.types.name as DATA_TYPE,'+
      ' iif(is_ansi_padded=1,sys.all_columns.max_length,null) as CHARACTER_MAXIMUM_LENGTH, '+
      ' iif(is_ansi_padded=0,sys.all_columns.precision,null) as NUMERIC_PRECISION, '+
      ' iif(is_ansi_padded=0,sys.all_columns.scale,null) as NUMERIC_PRECISION,'+
      ' count(sys.index_columns.object_id) as INDEX_COUNT'+
      ' from '+
      ' sys.all_columns join sys.types on sys.all_columns.user_type_id=sys.types.user_type_id'+
      ' left join sys.index_columns on sys.all_columns.object_id = sys.index_columns.object_id and sys.all_columns.column_id = sys.index_columns.column_id'+
      ' where  sys.all_columns.object_id=object_id(''%.%'')'+
      ' group by '+
      ' sys.all_columns.name,'+
      ' sys.types.name,'+
      ' iif(is_ansi_padded=1,sys.all_columns.max_length,null), '+
      ' iif(is_ansi_padded=0,sys.all_columns.precision,null), '+
      ' iif(is_ansi_padded=0,sys.all_columns.scale,null)';