paweld/fpc
1
0
Fork 0
mirror of https://gitlab.com/freepascal.org/fpc/source.git synced 2025-05-05 04:43:46 +02:00
Code Issues Packages Projects Releases Wiki Activity
55850b063a
fpc/packages/base/postgres/postgres.pp
peter 952e80a72f * old logs removed and tabs fixed
2002-09-07 15:40:30 +00:00

338 lines
13 KiB
ObjectPascal
Raw Blame History

unit postgres;
interface
uses dllist;
{$linklib pq}
{$linklib c}
{ Not always needed. If you have problems linking, try to add this }
{ $linklib crypt}
{ $include "libpq/pqcomm.h"}
Type
Oid = cardinal;
MsgType = Cardinal;
PLongint = ^Longint;
TSockAddr = Array [1..112] of byte; { Testded using C version sizeof() }
Const
NAMEDATALEN = 32;
OIDNAMELEN = 36;
Type
TFILE = Longint;
PFIle = ^TFILE;
type
TConnStatusType = (CONNECTION_OK,CONNECTION_BAD);
PConnStatusType= ^TConnStatusType;
TExecStatusType = (PGRES_EMPTY_QUERY,PGRES_COMMAND_OK,PGRES_TUPLES_OK,
PGRES_COPY_OUT,
PGRES_COPY_IN,
PGRES_BAD_RESPONSE,
PGRES_NONFATAL_ERROR,
PGRES_FATAL_ERROR
);
PExecStatusType= ^TExecStatusType;
{
extern const char pgresStatus[];
}
const
ERROR_MSG_LENGTH = 4096;
COMMAND_LENGTH = 20;
REMARK_LENGTH = 80;
PORTAL_NAME_LENGTH = 16;
type
TPQArgBlock = record
len : longint;
isint : longint;
u : record
case longint of
0 : ( ptr:Plongint );
1 : ( integer:longint );
end;
end;
PPQArgBlock= ^TPQArgBlock;
TPGresAttDesc = record
name : Pchar;
adtid : Oid;
adtsize : integer;
end;
PPGresAttDesc= ^TPGresAttDesc;
PPPGresAttDesc= ^PPGresAttDesc;
const
NULL_LEN = -1;
type
TPGresAttValue = record
len : longint;
value : Pchar;
end;
PPGresAttValue= ^TPGresAttValue;
PPPGresAttValue= ^PPGresAttValue;
TPGnotify = record
relname : array[0..(NAMEDATALEN)-1] of char;
be_pid : longint;
end;
PPGnotify= ^TPGnotify;
TPGlobjfuncs = record
fn_lo_open : Oid;
fn_lo_close : Oid;
fn_lo_creat : Oid;
fn_lo_unlink : Oid;
fn_lo_lseek : Oid;
fn_lo_tell : Oid;
fn_lo_read : Oid;
fn_lo_write : Oid;
end;
PPGlobjfuncs= ^TPGlobjfuncs;
TPGconn = record
pghost : Pchar;
pgtty : Pchar;
pgport : Pchar;
pgoptions : Pchar;
dbName : Pchar;
status : TConnStatusType;
errorMessage : array[0..(ERROR_MSG_LENGTH)-1] of char;
Pfin : PFILE;
Pfout : PFILE;
Pfdebug : PFILE;
sock : longint;
laddr : TSockAddr;
raddr : TSockAddr;
salt : array[0..(2)-1] of char;
asyncNotifyWaiting : longint;
notifyList : PDllist;
pguser : Pchar;
pgpass : Pchar;
lobjfuncs : PPGlobjfuncs;
end;
PPGconn= ^TPGconn;
const
CMDSTATUS_LEN = 40;
type
TPGresult = record
ntups : longint;
numAttributes : longint;
attDescs : PPGresAttDesc;
tuples : PPPGresAttValue;
tupArrSize : longint;
resultStatus : TExecStatusType;
cmdStatus : array[0..(CMDSTATUS_LEN)-1] of char;
binary : longint;
conn : PPGconn;
end;
PPGresult= ^TPGresult;
pqbool = char;
TPQprintopt = record
header : pqbool;
align : pqbool;
standard : pqbool;
html3 : pqbool;
expanded : pqbool;
pager : pqbool;
fieldSep : Pchar;
tableOpt : Pchar;
caption : Pchar;
end;
PPQprintopt= ^TPQprintopt;
TPQconninfoOption = Record
keyword : pchar;
environ : pchar;
compiled : pchar;
val : pchar;
Thelabel : pchar;
dispchar : pchar;
dispsize : longint;
end;
PPQconninfoOption = ^TPQconninfoOption;
Function PQconnectdb(conninfo:Pchar):PPGconn; cdecl;
Function PQconndefaults:PPQconninfoOption; cdecl;
Function PQsetdbLogin(pghost,pgport,pgoptions,pgtty,dbName,login,pwd : pchar):PPGConn; cdecl;
{$ifdef PGSQL6_2_1}
Function PQsetdb(pghost,pgport,pgoptions,pgtty,dbName : pchar):PPGConn; cdecl;
{$else}
Function PQsetdb(pghost,pgport,pgoptions,pgtty,dbName : pchar):PPGConn;
{$endif}
procedure PQfinish(conn:PPGconn); cdecl;
procedure PQreset(conn:PPGconn); cdecl;
Function PQdb(conn:PPGconn):Pchar; cdecl;
Function PQuser(conn:PPGconn):Pchar; cdecl;
Function PQhost(conn:PPGconn):Pchar; cdecl;
Function PQoptions(conn:PPGconn):Pchar; cdecl;
Function PQport(conn:PPGconn):Pchar; cdecl;
Function PQtty(conn:PPGconn):Pchar; cdecl;
Function PQstatus(conn:PPGconn):TConnStatusType; cdecl;
Function PQerrorMessage(conn:PPGconn):Pchar; cdecl;
procedure PQtrace(conn:PPGconn; debug_port:PFILE); cdecl;
procedure PQuntrace(conn:PPGconn); cdecl;
Function PQexec(conn:PPGconn; query:Pchar):PPGresult; cdecl;
Function PQgetline(conn:PPGconn; str:Pchar; len:longint):longint; cdecl;
Function PQendcopy(conn:PPGconn):longint; cdecl;
Function PQputline(conn:PPGconn; str:Pchar) : longint; cdecl;
Function PQresultStatus(res:PPGresult):TExecStatusType; cdecl;
Function PQntuples(res:PPGresult):longint; cdecl;
Function PQnfields(res:PPGresult):longint; cdecl;
Function PQfname(res:PPGresult; field_num:longint):Pchar; cdecl;
Function PQfnumber(res:PPGresult; field_name:Pchar):longint; cdecl;
Function PQftype(res:PPGresult; field_num:longint):Oid; cdecl;
Function PQfsize(res:PPGresult; field_num:longint):integer; cdecl;
Function PQcmdStatus(res:PPGresult):Pchar; cdecl;
Function PQoidStatus(res : PPGresult) : pchar; cdecl;
Function PQcmdTuples(res : PPGresult) : pchar; cdecl;
Function PQgetvalue(res:PPGresult; tup_num:longint; field_num:longint):Pchar; cdecl;
Function PQgetlength(res:PPGresult; tup_num:longint; field_num:longint):longint; cdecl;
Function PQgetisnull(res:PPGresult; tup_num:longint; field_num:longint):longint; cdecl;
procedure PQclear(res:PPGresult);cdecl;
procedure PQdisplayTuples(res:PPGresult; fp:PFILE; fillAlign:longint; fieldSep:Pchar; printHeader:longint; quiet:longint);cdecl;
procedure PQprintTuples(res:PPGresult; fout:PFILE; printAttName:longint; terseOutput:longint; width:longint);cdecl;
procedure PQprint(fout:PFILE; res:PPGresult; ps:PPQprintOpt);cdecl;
Function PQnotifies(conn:PPGconn):PPGnotify; cdecl;
Function PQfn(conn:PPGconn; fnid:longint; result_buf:Plongint; result_len:Plongint; result_is_int:longint; args:PPQArgBlock; nargs:longint):PPGresult; cdecl;
Function fe_getauthsvc(PQerrormsg:Pchar):MsgType; cdecl;
procedure fe_setauthsvc(name:Pchar; PQerrormsg:Pchar);cdecl;
Function fe_getauthname(PQerrormsg:Pchar):Pchar; cdecl;
Function pqGets(s:Pchar; maxlen:longint; stream:PFILE; debug:PFILE):longint; cdecl;
Function pqGetnchar(s:Pchar; maxlen:longint; stream:PFILE; debug:PFILE):longint; cdecl;
Function pqPutnchar(s:Pchar; maxlen:longint; stream:PFILE; debug:PFILE):longint; cdecl;
Function pqPuts(s:Pchar; stream:PFILE; debug:PFILE):longint; cdecl;
Function pqGetc(stream:PFILE; debug:PFILE):longint; cdecl;
Function pqGetInt(result:Plongint; bytes:longint; stream:PFILE; debug:PFILE):longint; cdecl;
Function pqPutInt(n:longint; bytes:longint; stream:PFILE; debug:PFILE):longint; cdecl;
procedure pqFlush(stream:PFILE; debug:PFILE);cdecl;
Function lo_open(conn:PPGconn; lobjId:Oid; mode:longint):longint; cdecl;
Function lo_close(conn:PPGconn; fd:longint):longint; cdecl;
Function lo_read(conn:PPGconn; fd:longint; buf:Pchar; len:longint):longint; cdecl;
Function lo_write(conn:PPGconn; fd:longint; buf:Pchar; len:longint):longint; cdecl;
Function lo_lseek(conn:PPGconn; fd:longint; offset:longint; whence:longint):longint; cdecl;
Function lo_creat(conn:PPGconn; mode:longint):Oid; cdecl;
Function lo_tell(conn:PPGconn; fd:longint):longint; cdecl;
Function lo_unlink(conn:PPGconn; lobjId:Oid):longint; cdecl;
Function lo_import(conn:PPGconn; filename:Pchar):Oid; cdecl;
Function lo_export(conn:PPGconn; lobjId:Oid; filename:Pchar):longint; cdecl;
const
MAX_MESSAGE_LEN = 8193;
BYTELEN = 8;
MAX_FIELDS = 512;
DefaultHost : pchar = 'localhost';
DefaultTty : pchar = '';
DefaultOption : pchar = '';
DefaultAuthtype : pchar = '';
DefaultPassword : pchar = '';
type
TTUPLE = pointer;
PTUPLE = ^TTUPLE;
implementation
function PQconnectdb(conninfo:Pchar):PPGconn;cdecl; external;
function PQconndefaults:PPQconninfoOption;cdecl; external;
function PQsetdbLogin(pghost,pgport,pgoptions,pgtty,dbName,login,pwd : pchar):PPGConn;cdecl;external;
procedure PQfinish(conn:PPGconn);cdecl; external;
procedure PQreset(conn:PPGconn);cdecl; external;
function PQdb(conn:PPGconn):Pchar;cdecl; external;
function PQuser(conn:PPGconn):Pchar;cdecl; external;
function PQhost(conn:PPGconn):Pchar;cdecl; external;
function PQoptions(conn:PPGconn):Pchar;cdecl; external;
function PQport(conn:PPGconn):Pchar;cdecl; external;
function PQtty(conn:PPGconn):Pchar;cdecl; external;
function PQstatus(conn:PPGconn):TConnStatusType;cdecl; external;
function PQerrorMessage(conn:PPGconn):Pchar;cdecl; external;
procedure PQtrace(conn:PPGconn; debug_port:PFILE);cdecl; external;
procedure PQuntrace(conn:PPGconn);cdecl; external;
function PQexec(conn:PPGconn; query:Pchar):PPGresult;cdecl; external;
function PQgetline(conn:PPGconn; str:Pchar; len:longint):longint;cdecl; external;
function PQendcopy(conn:PPGconn):longint;cdecl; external;
function PQputline(conn:PPGconn; str:Pchar) : longint;cdecl; external;
function PQresultStatus(res:PPGresult):TExecStatusType;cdecl; external;
function PQntuples(res:PPGresult):longint;cdecl; external;
function PQnfields(res:PPGresult):longint;cdecl; external;
function PQfname(res:PPGresult; field_num:longint):Pchar;cdecl; external;
function PQfnumber(res:PPGresult; field_name:Pchar):longint;cdecl; external;
function PQftype(res:PPGresult; field_num:longint):Oid;cdecl; external;
function PQfsize(res:PPGresult; field_num:longint):integer;cdecl; external;
function PQcmdStatus(res:PPGresult):Pchar;cdecl; external;
function PQgetvalue(res:PPGresult; tup_num:longint; field_num:longint):Pchar;cdecl; external;
function PQgetlength(res:PPGresult; tup_num:longint; field_num:longint):longint;cdecl; external;
function PQgetisnull(res:PPGresult; tup_num:longint; field_num:longint):longint;cdecl; external;
procedure PQclear(res:PPGresult);cdecl; external;
procedure PQdisplayTuples(res:PPGresult; fp:PFILE; fillAlign:longint; fieldSep:Pchar; printHeader:longint; quiet:longint);cdecl; external;
procedure PQprintTuples(res:PPGresult; fout:PFILE; printAttName:longint; terseOutput:longint; width:longint);cdecl; external;
procedure PQprint(fout:PFILE; res:PPGresult; ps:PPQprintOpt);cdecl; external;
function PQnotifies(conn:PPGconn):PPGnotify;cdecl; external;
function PQfn(conn:PPGconn; fnid:longint; result_buf:Plongint; result_len:Plongint; result_is_int:longint; args:PPQArgBlock; nargs:longint):PPGresult;cdecl; external;
function fe_getauthsvc(PQerrormsg:Pchar):MsgType;cdecl; external;
procedure fe_setauthsvc(name:Pchar; PQerrormsg:Pchar);cdecl; external;
function fe_getauthname(PQerrormsg:Pchar):Pchar;cdecl; external;
function pqGets(s:Pchar; maxlen:longint; stream:PFILE; debug:PFILE):longint;cdecl; external;
function pqGetnchar(s:Pchar; maxlen:longint; stream:PFILE; debug:PFILE):longint;cdecl; external;
function pqPutnchar(s:Pchar; maxlen:longint; stream:PFILE; debug:PFILE):longint;cdecl; external;
function pqPuts(s:Pchar; stream:PFILE; debug:PFILE):longint;cdecl; external;
function pqGetc(stream:PFILE; debug:PFILE):longint;cdecl; external;
function pqGetInt(result:Plongint; bytes:longint; stream:PFILE; debug:PFILE):longint;cdecl; external;
function pqPutInt(n:longint; bytes:longint; stream:PFILE; debug:PFILE):longint;cdecl; external;
procedure pqFlush(stream:PFILE; debug:PFILE);cdecl; external;
function PQoidStatus(res : PPGresult) : pchar;cdecl;external;
function PQcmdTuples(res : PPGresult) : pchar;cdecl;external;
function lo_open(conn:PPGconn; lobjId:Oid; mode:longint):longint; cdecl; external;
function lo_close(conn:PPGconn; fd:longint):longint; cdecl; external;
function lo_read(conn:PPGconn; fd:longint; buf:Pchar; len:longint):longint; cdecl; external;
function lo_write(conn:PPGconn; fd:longint; buf:Pchar; len:longint):longint; cdecl; external;
function lo_lseek(conn:PPGconn; fd:longint; offset:longint; whence:longint):longint; cdecl; external;
function lo_creat(conn:PPGconn; mode:longint):Oid;cdecl;external;
function lo_tell(conn:PPGconn; fd:longint):longint; cdecl; external;
function lo_unlink(conn:PPGconn; lobjId:Oid):longint; cdecl; external;
function lo_import(conn:PPGconn; filename:Pchar):Oid;cdecl;external;
function lo_export(conn:PPGconn; lobjId:Oid; filename:Pchar):longint; cdecl; external;
{ Define helper functions }
{
In version 6.2.xxx, PGsetdb is a function in libpq.
in version 6.3.xxx, PGsetdb is a macro, pointing to setdblogin !!
}
{$ifdef PGSQL6_2_1}
Function PQsetdb(pghost,pgport,pgoptions,pgtty,dbName : pchar):PPGConn; cdecl;external;
{$else}
function PQsetdb(pghost,pgport,pgoptions,pgtty,dbName : pchar):PPGConn;
begin
PQsetdb:=PQsetdbLogin(pghost,pgport,pgoptions,pgtty,dbName,nil,nil);
end;
{$endif}
end. $Log$
end. Revision 1.2 2002-09-07 15:42:53 peter
end. * old logs removed and tabs fixed
end.
end. Revision 1.1 2002/01/29 17:54:56 peter
end. * splitted to base and extra
end.
}
Reference in New Issue View Git Blame Copy Permalink