Devart Forums

Code: Select all

var
	Connection : TUniConnection;
	Query : TUniQuery;
	i : integer;

begin
		Connection := TUniConnection.Create(nil);
		Connection.ProviderName := TPostgreSQLUniProvider.GetProviderName();
		Connection.SpecificOptions.Values['CharSet'] := 'UTF8';
		Connection.SpecificOptions.Values['UseUnicode'] := 'True';
		Connection.SpecificOptions.Values['ProtocolVersion'] := 'pv30';
        	// multiconnection must be False
		Connection.SpecificOptions.Values['MultipleConnections'] := 'False';
		Connection.Server := 'localhost';
		Connection.Database := 'XXX';
		Connection.Username := 'XXX';
		Connection.Password := 'XXX';
		Connection.Connect;

		// create temp table with records
		Query := TUniQuery.Create(nil);
		Query.Connection := Connection;
		Query.SQL.Text := 'CREATE TEMP TABLE FOOBAR (Key INTEGER)';
		Query.ExecSQL;
		for i := 0 to 100 do begin
			Query.SQL.Text := 'INSERT INTO FOOBAR (Key) VALUES (' + i.ToString + ')';
			Query.ExecSQL;
		end;

		// setup unidirectional, prepared query
		Query.SQL.Text := 'SELECT * FROM FOOBAR';
		Query.Prepared := True;
		Query.UniDirectional := True;

		Query.Open;
		Query.First;
		Query.Close;

		
		if Connection.Connected then
			Connection.Ping; // check connection state -> raises exception
	

Code: Select all

unit PGClassesUni;

(...)

class procedure TPgBinaryConverter.ReadDate(Source: TPgSQLNet; Dest: IntPtr);

Code: Select all

try
		Con := TUniConnection.Create(nil);
		try
			Con.Database := 'xxxx';
			Con.Username := 'xxxx';
			Con.Password := 'xxxx';
			Con.Options.EnableBCD := True;
			Con.Options.EnableFMTBCD := True;
			Con.ProviderName := TPostgreSQLUniProvider.GetProviderName();
			Con.SpecificOptions.Values['ProtocolVersion'] := 'pv30';
			Con.SpecificOptions.Values['MultipleConnections'] := 'False';
			Con.Connect;

			Query := TUniQuery.Create(nil);
			try
				Query.Connection := Con;
				Query.SQL.Text := 'CREATE TEMP TABLE xyz (dummy VARCHAR(20))';
				Query.ExecSQL;

				for i := 1 to 100 do begin
					Query.SQL.Text := 'INSERT INTO xyz (dummy) VALUES (''test'')';
					Query.ExecSQL;
				end;
				Query.SQL.Text := 'INSERT INTO xyz (dummy) VALUES (CONCAT(E''\u4f60'', E''\u597d'', E''\uff0c'', E''\u4e16'', E''\u754c''))';
				Query.ExecSQL;
				for i := 1 to 100 do begin
					Query.SQL.Text := 'INSERT INTO xyz (dummy) VALUES (''test'')';
					Query.ExecSQL;
				end;

				Query.SQL.Text := 'SELECT * FROM xyz';
				Query.Open;

				while not Query.Eof do begin
					Writeln(Query.FieldByName('dummy').AsString);
					Query.Next;
				end;

			finally
				Query.Free();
			end;

		finally
			Con.Free();
		end;
	except
		on E : Exception do
			Writeln(E.ClassName, ': ', E.Message);
	end;

Code: Select all

function TPgSQLReadStream.HasData: boolean;
(....)
        if FCurrentPosition < PageSize then
          Result := True
        else
          Result := False;  // in this case the record count will be set to 1 and stays 1 for ever

Code: Select all

procedure TPgSQLRecordSet.FetchBlock(Block: PBlockHeader; FetchBack: boolean; out RowsObtained: Integer);
(...)
      Command.FReadStream.UseUnicode := Protocol.Net.UseUnicode;
      if Command.FReadStream.HasData or not Command.FReadStream.IsLastRow then
        RowsObtained := Command.FReadStream.FetchStmt(FFetchRows, Block, ReceiveFetchBuffer)
      else
        RowsObtained := 0;
 (...)
 end;

Code: Select all

	Con := TUniConnection.Create(nil);
	Con.Database := 'xxxx';
	Con.Username := 'xxxx';
	Con.Password := 'xxxx';
	Con.Options.EnableBCD := True;
	Con.Options.EnableFMTBCD := True;
	Con.ProviderName := TPostgreSQLUniProvider.GetProviderName();
	Con.SpecificOptions.Values['ProtocolVersion'] := 'pv30';
	Con.SpecificOptions.Values['MultipleConnections'] := 'False';
	Con.SpecificOptions.Values['UseUnicode'] := 'True';
	Con.SpecificOptions.Values['CharSet'] := 'UTF8';
	Con.SpecificOptions.Values['Schema'] := 'xxxx';
	Con.SpecificOptions.Values['ApplicationName'] := 'foobar';
	Con.Connect;

	Query := TUniQuery.Create(nil);
	try
		Query.Connection := Con;
		Query.SQL.Text := 'SELECT SAK_KONTO, SAK_DATUMAB FROM AGF_SAK ORDER BY SAK_KONTO, SAK_DATUMAB';
		Query.Open;
	finally
		Query.Free();
	end;

	Con.Free();
  except
    on E: Exception do
      Writeln(E.ClassName, ': ', E.Message);
  end;

Code: Select all

TPgSQLRecordSet.GetExtFieldsInfo;

Code: Select all

TPgSQLCommand(RecordSet.GetCommand).FForceSwapConnection := True;

Code: Select all

uses
	System.SysUtils,
	Uni,
	PostgreSQLUniProvider;

procedure Test(const DisableMultipleConnection : boolean);
var
	UniC : TUniConnection;
	UniQ : TUniQuery;
begin
	try
		UniC := TUniConnection.Create(nil);
		try
			UniC.ProviderName := TPostgreSQLUniProvider.GetProviderName();
			UniC.Database := 'postgres';
			UniC.Username := 'postgres';
			UniC.Password := 'postgres';

			if DisableMultipleConnection then begin
				UniC.SpecificOptions.Values['MultipleConnections'] := 'False';
			end;

			UniQ := TUniQuery.Create(nil);
			try
				UniQ.Connection := UniC;
				UniQ.SQL.Text := 'CREATE TEMP TABLE foobar (foobar integer)';
				UniQ.ExecSQL;
				UniQ.SQL.Text := 'INSERT INTO foobar (foobar) VALUES (1)';
				UniQ.ExecSQL;
				UniQ.SQL.Text := 'SELECT * FROM foobar';
				UniQ.Open;
				UniQ.Close;
				UniQ.SQL.Text := 'DROP TABLE foobar';
				UniQ.ExecSQL;
			finally
				UniQ.Free;
			end;

		finally
			UniC.Free;
		end;

		Writeln('Success');
	except
		on E : Exception do
			Writeln(E.ClassName, ': ', E.Message);
	end;
end;

begin
	try
		Test(True);
		Test(False);
	except
		on E : Exception do
			Writeln(E.ClassName, ': ', E.Message);
	end;
	Readln;