Devart Forums

Code: Select all

program devart_dbx_too_many_clients_already;

{$APPTYPE CONSOLE}

{$R *.res}

uses
  SysUtils,
  DBXDevartPostgreSQL,
  MidasLib,
  Data.SqlExpr,
  Windows,
  DB;

procedure WritelnPID(ACon: TSQLConnection);
var DS: TDataSet;
begin
  ACon.Execute('select pg_backend_pid()', nil, DS);
  try
    Writeln('PID=' + DS.Fields[0].AsString);
  finally
    DS.Free;
  end;
end;

var
  Con: TSQLConnection;
  SQLDS: TSQLDataSet;

begin
  try
    SetConsoleOutputCP(CP_UTF8);
    Con := TSQLConnection.Create(nil);

    Con.ConnectionName := 'DevartPostgreSQL';
    Con.DriverName := 'DevartPostgreSQL';

    Con.LoginPrompt := False;
    Con.Params.Values['Hostname'] := 'set up db:port';
    Con.Params.Values['Database'] := 'set up database';
    Con.Params.Values['SchemaName'] := 'set up schema;
    Con.Params.Values['User_Name'] := 'set up user';
    Con.Params.Values['Password'] := 'set up password';

    try
      Writeln('Create test tables');
      Con.Open;
      Con.Execute('CREATE TABLE IF NOT EXISTS devart_table1(field1 varchar(20))', nil);
      Con.Execute('INSERT INTO devart_table1 VALUES(''field1'')', nil);
      Con.Execute('CREATE TABLE IF NOT EXISTS devart_table2(field2 varchar(20))', nil);
      Con.Execute('INSERT INTO devart_table2 VALUES(''field2'')', nil);
      Con.Execute('CREATE TABLE IF NOT EXISTS devart_table3(field3 varchar(20))', nil);
      Con.Execute('INSERT INTO devart_table3 VALUES(''field3'')', nil);
      Con.Close;

      SQLDS := TSQLDataSet.Create(nil);
      SQLDS.SQLConnection := Con;
      try

        Writeln('Press ENTER to start test');
        Readln;

        Con.Open;
        SQLDS.CommandText := 'update devart_table1 set field1 = ''field1'' ';
        SQLDS.ExecSQL;
        WritelnPID(Con);

        SQLDS.Close;
        SQLDS.CommandText := 'select 1 from devart_table2';
        SQLDS.Open;
        WritelnPID(Con);

        SQLDS.Close;
        SQLDS.CommandText := 'update devart_table3 set field3 = ''field3'' ';
        SQLDS.ExecSQL;
        WritelnPID(Con);

      finally
        SQLDS.Free;
      end;

      Writeln('Finish. Press ENTER to exit.');
    finally
      Con.Free;
    end;
  except
    on E: Exception do
    begin
      Writeln(E.ClassName, ': ', E.Message);
    end;
  end;
  Readln;
end.

Code: Select all

  oStringStreamXML := TStringStream.Create('TESTE ÉÍÓÇ');
  oparams := TParams.Create(nil);
  oparams.CreateParam(ftMemo, 'blob', ptInput);
  oparams.ParamByName('blob').AsMemo := oStringStreamXML.DataString;
  PSQLDataSet1.CommandText := 'update tb_teste set texto = :blob';
  PSQLDataSet1.Params := oparams;
  PSQLDataSet1.ExecSQL();