/*
Copyright (c) 2000-2023 Greg Sabino Mullane and others: see the Changes file
Portions Copyright (c) 1997-2000 Edmund Mergl
Portions Copyright (c) 1994-1997 Tim Bunce
You may distribute under the terms of either the GNU General Public
License or the Artistic License, as specified in the Perl README file.
*/
#define NEED_newSVpvn_flags
#include "Pg.h"
#ifdef _MSC_VER
#define strncasecmp(a,b,c) _strnicmp((a),(b),(c))
#endif
MODULE = DBD::Pg PACKAGE = DBD::Pg
I32
constant(name=Nullch)
char *name
PROTOTYPE:
ALIAS:
PG_ACLITEM = 1033
PG_ACLITEMARRAY = 1034
PG_ANY = 2276
PG_ANYARRAY = 2277
PG_ANYCOMPATIBLE = 5077
PG_ANYCOMPATIBLEARRAY = 5078
PG_ANYCOMPATIBLEMULTIRANGE = 4538
PG_ANYCOMPATIBLENONARRAY = 5079
PG_ANYCOMPATIBLERANGE = 5080
PG_ANYELEMENT = 2283
PG_ANYENUM = 3500
PG_ANYMULTIRANGE = 4537
PG_ANYNONARRAY = 2776
PG_ANYRANGE = 3831
PG_BIT = 1560
PG_BITARRAY = 1561
PG_BOOL = 16
PG_BOOLARRAY = 1000
PG_BOX = 603
PG_BOXARRAY = 1020
PG_BPCHAR = 1042
PG_BPCHARARRAY = 1014
PG_BYTEA = 17
PG_BYTEAARRAY = 1001
PG_CHAR = 18
PG_CHARARRAY = 1002
PG_CID = 29
PG_CIDARRAY = 1012
PG_CIDR = 650
PG_CIDRARRAY = 651
PG_CIRCLE = 718
PG_CIRCLEARRAY = 719
PG_CSTRING = 2275
PG_CSTRINGARRAY = 1263
PG_DATE = 1082
PG_DATEARRAY = 1182
PG_DATEMULTIRANGE = 4535
PG_DATEMULTIRANGEARRAY = 6155
PG_DATERANGE = 3912
PG_DATERANGEARRAY = 3913
PG_EVENT_TRIGGER = 3838
PG_FDW_HANDLER = 3115
PG_FLOAT4 = 700
PG_FLOAT4ARRAY = 1021
PG_FLOAT8 = 701
PG_FLOAT8ARRAY = 1022
PG_GTSVECTOR = 3642
PG_GTSVECTORARRAY = 3644
PG_INDEX_AM_HANDLER = 325
PG_INET = 869
PG_INETARRAY = 1041
PG_INT2 = 21
PG_INT2ARRAY = 1005
PG_INT2VECTOR = 22
PG_INT2VECTORARRAY = 1006
PG_INT4 = 23
PG_INT4ARRAY = 1007
PG_INT4MULTIRANGE = 4451
PG_INT4MULTIRANGEARRAY = 6150
PG_INT4RANGE = 3904
PG_INT4RANGEARRAY = 3905
PG_INT8 = 20
PG_INT8ARRAY = 1016
PG_INT8MULTIRANGE = 4536
PG_INT8MULTIRANGEARRAY = 6157
PG_INT8RANGE = 3926
PG_INT8RANGEARRAY = 3927
PG_INTERNAL = 2281
PG_INTERVAL = 1186
PG_INTERVALARRAY = 1187
PG_JSON = 114
PG_JSONARRAY = 199
PG_JSONB = 3802
PG_JSONBARRAY = 3807
PG_JSONPATH = 4072
PG_JSONPATHARRAY = 4073
PG_LANGUAGE_HANDLER = 2280
PG_LINE = 628
PG_LINEARRAY = 629
PG_LSEG = 601
PG_LSEGARRAY = 1018
PG_MACADDR = 829
PG_MACADDR8 = 774
PG_MACADDR8ARRAY = 775
PG_MACADDRARRAY = 1040
PG_MONEY = 790
PG_MONEYARRAY = 791
PG_NAME = 19
PG_NAMEARRAY = 1003
PG_NUMERIC = 1700
PG_NUMERICARRAY = 1231
PG_NUMMULTIRANGE = 4532
PG_NUMMULTIRANGEARRAY = 6151
PG_NUMRANGE = 3906
PG_NUMRANGEARRAY = 3907
PG_OID = 26
PG_OIDARRAY = 1028
PG_OIDVECTOR = 30
PG_OIDVECTORARRAY = 1013
PG_PATH = 602
PG_PATHARRAY = 1019
PG_PG_ATTRIBUTE = 75
PG_PG_ATTRIBUTEARRAY = 270
PG_PG_BRIN_BLOOM_SUMMARY = 4600
PG_PG_BRIN_MINMAX_MULTI_SUMMARY = 4601
PG_PG_CLASS = 83
PG_PG_CLASSARRAY = 273
PG_PG_DDL_COMMAND = 32
PG_PG_DEPENDENCIES = 3402
PG_PG_LSN = 3220
PG_PG_LSNARRAY = 3221
PG_PG_MCV_LIST = 5017
PG_PG_NDISTINCT = 3361
PG_PG_NODE_TREE = 194
PG_PG_PROC = 81
PG_PG_PROCARRAY = 272
PG_PG_SNAPSHOT = 5038
PG_PG_SNAPSHOTARRAY = 5039
PG_PG_TYPE = 71
PG_PG_TYPEARRAY = 210
PG_POINT = 600
PG_POINTARRAY = 1017
PG_POLYGON = 604
PG_POLYGONARRAY = 1027
PG_RECORD = 2249
PG_RECORDARRAY = 2287
PG_REFCURSOR = 1790
PG_REFCURSORARRAY = 2201
PG_REGCLASS = 2205
PG_REGCLASSARRAY = 2210
PG_REGCOLLATION = 4191
PG_REGCOLLATIONARRAY = 4192
PG_REGCONFIG = 3734
PG_REGCONFIGARRAY = 3735
PG_REGDICTIONARY = 3769
PG_REGDICTIONARYARRAY = 3770
PG_REGNAMESPACE = 4089
PG_REGNAMESPACEARRAY = 4090
PG_REGOPER = 2203
PG_REGOPERARRAY = 2208
PG_REGOPERATOR = 2204
PG_REGOPERATORARRAY = 2209
PG_REGPROC = 24
PG_REGPROCARRAY = 1008
PG_REGPROCEDURE = 2202
PG_REGPROCEDUREARRAY = 2207
PG_REGROLE = 4096
PG_REGROLEARRAY = 4097
PG_REGTYPE = 2206
PG_REGTYPEARRAY = 2211
PG_TABLE_AM_HANDLER = 269
PG_TEXT = 25
PG_TEXTARRAY = 1009
PG_TID = 27
PG_TIDARRAY = 1010
PG_TIME = 1083
PG_TIMEARRAY = 1183
PG_TIMESTAMP = 1114
PG_TIMESTAMPARRAY = 1115
PG_TIMESTAMPTZ = 1184
PG_TIMESTAMPTZARRAY = 1185
PG_TIMETZ = 1266
PG_TIMETZARRAY = 1270
PG_TRIGGER = 2279
PG_TSMULTIRANGE = 4533
PG_TSMULTIRANGEARRAY = 6152
PG_TSM_HANDLER = 3310
PG_TSQUERY = 3615
PG_TSQUERYARRAY = 3645
PG_TSRANGE = 3908
PG_TSRANGEARRAY = 3909
PG_TSTZMULTIRANGE = 4534
PG_TSTZMULTIRANGEARRAY = 6153
PG_TSTZRANGE = 3910
PG_TSTZRANGEARRAY = 3911
PG_TSVECTOR = 3614
PG_TSVECTORARRAY = 3643
PG_TXID_SNAPSHOT = 2970
PG_TXID_SNAPSHOTARRAY = 2949
PG_UNKNOWN = 705
PG_UUID = 2950
PG_UUIDARRAY = 2951
PG_VARBIT = 1562
PG_VARBITARRAY = 1563
PG_VARCHAR = 1043
PG_VARCHARARRAY = 1015
PG_VOID = 2278
PG_XID = 28
PG_XID8 = 5069
PG_XID8ARRAY = 271
PG_XIDARRAY = 1011
PG_XML = 142
PG_XMLARRAY = 143
PG_ASYNC = 1
PG_OLDQUERY_CANCEL = 2
PG_OLDQUERY_WAIT = 4
CODE:
if (0==ix) {
if (!name) {
name = GvNAME(CvGV(cv));
}
croak("Unknown DBD::Pg constant '%s'", name);
}
else {
RETVAL = ix;
}
OUTPUT:
RETVAL
INCLUDE: Pg.xsi
# ------------------------------------------------------------
# db functions
# ------------------------------------------------------------
MODULE=DBD::Pg PACKAGE = DBD::Pg::db
SV*
quote(dbh, to_quote_sv, type_sv=Nullsv)
SV* dbh
SV* to_quote_sv
SV* type_sv
CODE:
{
bool utf8;
D_imp_dbh(dbh);
SvGETMAGIC(to_quote_sv);
/* Reject references other than overloaded objects (presumed
stringifiable) and arrays (will make a PostgreSQL array). */
if (SvROK(to_quote_sv) && !SvAMAGIC(to_quote_sv)) {
if (SvTYPE(SvRV(to_quote_sv)) != SVt_PVAV)
croak("Cannot quote a reference");
to_quote_sv = pg_stringify_array(to_quote_sv, ",", imp_dbh->pg_server_version, imp_dbh->client_encoding_utf8);
}
/* Null is always returned as "NULL", so we can ignore any type given */
if (!SvOK(to_quote_sv)) {
RETVAL = newSVpvn("NULL", 4);
}
else {
sql_type_info_t *type_info;
char *quoted;
const char *to_quote;
STRLEN retlen=0;
STRLEN len=0;
/* If no valid type is given, we default to unknown */
if (!type_sv || !SvOK(type_sv)) {
type_info = pg_type_data(PG_UNKNOWN);
}
else {
if SvMAGICAL(type_sv)
(void)mg_get(type_sv);
if (SvNIOK(type_sv)) {
type_info = sql_type_data(SvIV(type_sv));
}
else {
SV **svp;
/* Currently the type argument must be a hashref, so throw an exception if not */
if (!SvROK(type_sv) || SvTYPE(SvRV(type_sv)) != SVt_PVHV)
croak("Second argument to quote must be a hashref");
if ((svp = hv_fetch((HV*)SvRV(type_sv),"pg_type", 7, 0)) != NULL) {
type_info = pg_type_data(SvIV(*svp));
}
else if ((svp = hv_fetch((HV*)SvRV(type_sv),"type", 4, 0)) != NULL) {
type_info = sql_type_data(SvIV(*svp));
}
else {
type_info = NULL;
}
}
if (!type_info) {
if (NULL == type_info)
warn("No type given, defaulting to UNKNOWN");
else
warn("Unknown type %" IVdf ", defaulting to UNKNOWN", SvIV(type_sv));
type_info = pg_type_data(PG_UNKNOWN);
}
}
/* At this point, type_info points to a valid struct, one way or another */
utf8 = imp_dbh->client_encoding_utf8
&& PG_BYTEA != type_info->type_id
&& SQL_BLOB != type_info->type_id
&& SQL_BINARY != type_info->type_id
&& SQL_VARBINARY != type_info->type_id
&& SQL_LONGVARBINARY != type_info->type_id;
if (SvMAGICAL(to_quote_sv))
(void)mg_get(to_quote_sv);
/* avoid up- or down-grading the argument */
to_quote_sv = pg_rightgraded_sv(aTHX_ to_quote_sv, utf8);
to_quote = SvPV(to_quote_sv, len);
/* Need good debugging here */
quoted = type_info->quote(aTHX_ to_quote, len, &retlen, imp_dbh->pg_server_version >= 80100 ? 1 : 0);
RETVAL = newSVpvn_utf8(quoted, retlen, utf8);
Safefree (quoted);
}
}
OUTPUT:
RETVAL
# ------------------------------------------------------------
# database level interface PG specific
# ------------------------------------------------------------
MODULE = DBD::Pg PACKAGE = DBD::Pg::db
void state(dbh)
SV *dbh
CODE:
D_imp_dbh(dbh);
ST(0) = strEQ(imp_dbh->sqlstate,"00000")
? &PL_sv_no
: sv_2mortal(newSVpv(imp_dbh->sqlstate, 5));
void do(dbh, statement_sv, attr=Nullsv, ...)
SV * dbh
SV * statement_sv
SV * attr
PROTOTYPE: $$;$@
CODE:
{
long retval;
int asyncflag = 0;
char *statement;
D_imp_dbh(dbh);
/* Always reset the last stored sth */
imp_dbh->do_tmp_sth = NULL;
statement_sv = pg_rightgraded_sv(aTHX_ statement_sv, imp_dbh->pg_utf8_flag);
statement = SvPV_nolen(statement_sv);
if (statement[0] == '\0') { /* Corner case */
XST_mUNDEF(0);
return;
}
if (attr && SvROK(attr) && SvTYPE(SvRV(attr)) == SVt_PVHV) {
SV **svp;
if ((svp = hv_fetch((HV*)SvRV(attr),"pg_async", 8, 0)) != NULL) {
asyncflag = (int)SvIV(*svp);
}
}
if (items < 4) { /* No bind arguments */
/* Quick run via PQexec */
retval = pg_quickexec(dbh, statement, asyncflag);
}
else { /* We've got bind arguments, so we do the whole prepare/execute route */
imp_sth_t *imp_sth;
SV * const sth = dbixst_bounce_method("prepare", 3);
if (!SvROK(sth))
XSRETURN_UNDEF;
imp_sth = (imp_sth_t*)(DBIh_COM(sth));
if (!dbdxst_bind_params(sth, imp_sth, items-2, ax+2))
XSRETURN_UNDEF;
imp_sth->async_flag = asyncflag;
imp_dbh->do_tmp_sth = imp_sth;
retval = dbd_st_execute(sth, imp_sth);
}
if (retval == 0)
XST_mPV(0, "0E0");
else if (retval < -1)
XST_mUNDEF(0);
else
XST_mIV(0, retval);
}
void
_ping(dbh)
SV * dbh
CODE:
ST(0) = sv_2mortal(newSViv(dbd_db_ping(dbh)));
void
getfd(dbh)
SV * dbh
CODE:
int ret;
D_imp_dbh(dbh);
ret = pg_db_getfd(imp_dbh);
ST(0) = sv_2mortal( newSViv( ret ) );
void
pg_endcopy(dbh)
SV * dbh
CODE:
ST(0) = (pg_db_endcopy(dbh)!=0) ? &PL_sv_no : &PL_sv_yes;
void
pg_error_field(dbh, fieldname)
SV * dbh
char * fieldname;
CODE:
ST(0) = pg_db_error_field(dbh, fieldname);
void
pg_notifies(dbh)
SV * dbh
CODE:
D_imp_dbh(dbh);
ST(0) = pg_db_pg_notifies(dbh, imp_dbh);
void
pg_savepoint(dbh,name)
SV * dbh
char * name
CODE:
D_imp_dbh(dbh);
if (DBIc_has(imp_dbh,DBIcf_AutoCommit) && DBIc_WARN(imp_dbh))
warn("savepoint ineffective with AutoCommit enabled");
ST(0) = (pg_db_savepoint(dbh, imp_dbh, name)!=0) ? &PL_sv_yes : &PL_sv_no;
void
pg_rollback_to(dbh,name)
SV * dbh
char * name
CODE:
D_imp_dbh(dbh);
if (DBIc_has(imp_dbh,DBIcf_AutoCommit) && DBIc_WARN(imp_dbh))
warn("rollback_to ineffective with AutoCommit enabled");
ST(0) = (pg_db_rollback_to(dbh, imp_dbh, name)!=0) ? &PL_sv_yes : &PL_sv_no;
void
pg_release(dbh,name)
SV * dbh
char * name
CODE:
D_imp_dbh(dbh);
if (DBIc_has(imp_dbh,DBIcf_AutoCommit) && DBIc_WARN(imp_dbh))
warn("release ineffective with AutoCommit enabled");
ST(0) = (pg_db_release(dbh, imp_dbh, name)!=0) ? &PL_sv_yes : &PL_sv_no;
void
pg_lo_creat(dbh, mode)
SV * dbh
int mode
CODE:
const unsigned int ret = pg_db_lo_creat(dbh, mode);
ST(0) = (ret > 0) ? sv_2mortal(newSVuv(ret)) : &PL_sv_undef;
void
pg_lo_open(dbh, lobjId, mode)
SV * dbh
unsigned int lobjId
int mode
CODE:
const int ret = pg_db_lo_open(dbh, lobjId, mode);
ST(0) = (ret >= 0) ? sv_2mortal(newSViv(ret)) : &PL_sv_undef;
void
pg_lo_write(dbh, fd, buf, len)
SV * dbh
int fd
char * buf
size_t len
CODE:
const int ret = pg_db_lo_write(dbh, fd, buf, len);
ST(0) = (ret >= 0) ? sv_2mortal(newSViv(ret)) : &PL_sv_undef;
void
pg_lo_read(dbh, fd, buf, len)
SV * dbh
int fd
char * buf
size_t len
PREINIT:
SV * const bufsv = SvROK(ST(2)) ? SvRV(ST(2)) : ST(2);
int ret;
CODE:
sv_setpvn(bufsv,"",0); /* Make sure we can grow it safely */
buf = SvGROW(bufsv, len + 1);
ret = pg_db_lo_read(dbh, fd, buf, len);
if (ret > 0) {
SvCUR_set(bufsv, ret);
*SvEND(bufsv) = '\0';
sv_setpvn(ST(2), buf, (unsigned)ret);
SvSETMAGIC(ST(2));
}
ST(0) = (ret >= 0) ? sv_2mortal(newSViv(ret)) : &PL_sv_undef;
void
pg_lo_lseek(dbh, fd, offset, whence)
SV * dbh
int fd
IV offset
int whence
ALIAS:
pg_lo_lseek64 = 1
CODE:
const IV ret = pg_db_lo_lseek(dbh, fd, offset, whence);
ST(0) = (ret >= 0) ? sv_2mortal(newSViv(ret)) : &PL_sv_undef;
void
pg_lo_tell(dbh, fd)
SV * dbh
int fd
ALIAS:
pg_lo_tell64 = 1
CODE:
const IV ret = pg_db_lo_tell(dbh, fd);
ST(0) = (ret >= 0) ? sv_2mortal(newSViv(ret)) : &PL_sv_undef;
void
pg_lo_truncate(dbh, fd, len)
SV * dbh
int fd
UV len
ALIAS:
pg_lo_truncate64 = 1
CODE:
const IV ret = pg_db_lo_truncate(dbh, fd, len);
ST(0) = (ret >= 0) ? sv_2mortal(newSViv(ret)) : &PL_sv_undef;
void
pg_lo_close(dbh, fd)
SV * dbh
int fd
CODE:
ST(0) = (pg_db_lo_close(dbh, fd) >= 0) ? &PL_sv_yes : &PL_sv_no;
void
pg_lo_unlink(dbh, lobjId)
SV * dbh
unsigned int lobjId
CODE:
ST(0) = (pg_db_lo_unlink(dbh, lobjId) >= 1) ? &PL_sv_yes : &PL_sv_no;
void
pg_lo_import(dbh, filename)
SV * dbh
char * filename
CODE:
const unsigned int ret = pg_db_lo_import(dbh, filename);
ST(0) = (ret > 0) ? sv_2mortal(newSVuv(ret)) : &PL_sv_undef;
void
pg_lo_import_with_oid(dbh, filename, lobjId)
SV * dbh
char * filename
unsigned int lobjId
CODE:
const unsigned int ret = (lobjId==0) ? pg_db_lo_import(dbh, filename)
: pg_db_lo_import_with_oid(dbh, filename, lobjId);
ST(0) = (ret > 0) ? sv_2mortal(newSVuv(ret)) : &PL_sv_undef;
void
pg_lo_export(dbh, lobjId, filename)
SV * dbh
unsigned int lobjId
char * filename
CODE:
ST(0) = (pg_db_lo_export(dbh, lobjId, filename) >= 1) ? &PL_sv_yes : &PL_sv_no;
void
lo_creat(dbh, mode)
SV * dbh
int mode
CODE:
const unsigned int ret = pg_db_lo_creat(dbh, mode);
ST(0) = (ret > 0) ? sv_2mortal(newSVuv(ret)) : &PL_sv_undef;
void
lo_open(dbh, lobjId, mode)
SV * dbh
unsigned int lobjId
int mode
CODE:
const int ret = pg_db_lo_open(dbh, lobjId, mode);
ST(0) = (ret >= 0) ? sv_2mortal(newSViv(ret)) : &PL_sv_undef;
void
lo_write(dbh, fd, buf, len)
SV * dbh
int fd
char * buf
size_t len
CODE:
const int ret = pg_db_lo_write(dbh, fd, buf, len);
ST(0) = (ret >= 0) ? sv_2mortal(newSViv(ret)) : &PL_sv_undef;
void
lo_read(dbh, fd, buf, len)
SV * dbh
int fd
char * buf
size_t len
PREINIT:
SV * const bufsv = SvROK(ST(2)) ? SvRV(ST(2)) : ST(2);
int ret;
CODE:
sv_setpvn(bufsv,"",0); /* Make sure we can grow it safely */
buf = SvGROW(bufsv, len + 1);
ret = pg_db_lo_read(dbh, fd, buf, len);
if (ret > 0) {
SvCUR_set(bufsv, ret);
*SvEND(bufsv) = '\0';
sv_setpvn(ST(2), buf, (unsigned)ret);
SvSETMAGIC(ST(2));
}
ST(0) = (ret >= 0) ? sv_2mortal(newSViv(ret)) : &PL_sv_undef;
void
lo_lseek(dbh, fd, offset, whence)
SV * dbh
int fd
int offset
int whence
CODE:
const int ret = pg_db_lo_lseek(dbh, fd, offset, whence);
ST(0) = (ret >= 0) ? sv_2mortal(newSViv(ret)) : &PL_sv_undef;
void
lo_tell(dbh, fd)
SV * dbh
int fd
CODE:
const int ret = pg_db_lo_tell(dbh, fd);
ST(0) = (ret >= 0) ? sv_2mortal(newSViv(ret)) : &PL_sv_undef;
void
lo_close(dbh, fd)
SV * dbh
int fd
CODE:
ST(0) = (pg_db_lo_close(dbh, fd) >= 0) ? &PL_sv_yes : &PL_sv_no;
void
lo_unlink(dbh, lobjId)
SV * dbh
unsigned int lobjId
CODE:
ST(0) = (pg_db_lo_unlink(dbh, lobjId) >= 1) ? &PL_sv_yes : &PL_sv_no;
void
lo_import(dbh, filename)
SV * dbh
char * filename
CODE:
const unsigned int ret = pg_db_lo_import(dbh, filename);
ST(0) = (ret > 0) ? sv_2mortal(newSVuv(ret)) : &PL_sv_undef;
void
lo_export(dbh, lobjId, filename)
SV * dbh
unsigned int lobjId
char * filename
CODE:
ST(0) = (pg_db_lo_export(dbh, lobjId, filename) >= 1) ? &PL_sv_yes : &PL_sv_no;
void
pg_putline(dbh, buf)
SV * dbh
SV * buf
CODE:
ST(0) = (pg_db_putline(dbh, buf)!=0) ? &PL_sv_no : &PL_sv_yes;
void
putline(dbh, buf)
SV * dbh
SV * buf
CODE:
ST(0) = (pg_db_putline(dbh, buf)!=0) ? &PL_sv_no : &PL_sv_yes;
void
pg_getline(dbh, buf, len)
PREINIT:
SV *bufsv = SvROK(ST(1)) ? SvRV(ST(1)) : ST(1);
INPUT:
SV * dbh
unsigned int len
char * buf
CODE:
int ret;
bufsv = SvROK(ST(1)) ? SvRV(ST(1)) : ST(1);
sv_setpvn(bufsv,"",0); /* Make sure we can grow it safely */
buf = SvGROW(bufsv, 3);
if (len > 3)
buf = SvGROW(bufsv, len);
ret = pg_db_getline(dbh, bufsv, (int)len);
sv_setpv((SV*)ST(1), buf);
SvSETMAGIC(ST(1));
ST(0) = (-1 != ret) ? &PL_sv_yes : &PL_sv_no;
I32
pg_getcopydata(dbh, dataline)
INPUT:
SV * dbh
CODE:
RETVAL = pg_db_getcopydata(dbh, SvROK(ST(1)) ? SvRV(ST(1)) : ST(1), 0);
OUTPUT:
RETVAL
I32
pg_getcopydata_async(dbh, dataline)
INPUT:
SV * dbh
CODE:
RETVAL = pg_db_getcopydata(dbh, SvROK(ST(1)) ? SvRV(ST(1)) : ST(1), 1);
OUTPUT:
RETVAL
I32
pg_putcopydata(dbh, dataline)
INPUT:
SV * dbh
SV * dataline
CODE:
RETVAL = pg_db_putcopydata(dbh, dataline);
OUTPUT:
RETVAL
I32
pg_putcopyend(dbh)
INPUT:
SV * dbh
CODE:
RETVAL = pg_db_putcopyend(dbh);
OUTPUT:
RETVAL
void
getline(dbh, buf, len)
PREINIT:
SV *bufsv = SvROK(ST(1)) ? SvRV(ST(1)) : ST(1);
INPUT:
SV * dbh
unsigned int len
char * buf
CODE:
int ret;
sv_setpvn(bufsv,"",0); /* Make sure we can grow it safely */
buf = SvGROW(bufsv, 3);
if (len > 3)
buf = SvGROW(bufsv, len);
ret = pg_db_getline(dbh, bufsv, (int)len);
sv_setpv((SV*)ST(1), buf);
SvSETMAGIC(ST(1));
ST(0) = (-1 != ret) ? &PL_sv_yes : &PL_sv_no;
void
endcopy(dbh)
SV * dbh
CODE:
ST(0) = (-1 != pg_db_endcopy(dbh)) ? &PL_sv_yes : &PL_sv_no;
void
pg_server_trace(dbh,fh)
SV * dbh
FILE * fh
CODE:
pg_db_pg_server_trace(dbh,fh);
void
pg_server_untrace(dbh)
SV * dbh
CODE:
pg_db_pg_server_untrace(dbh);
void
_pg_type_info (type_sv=Nullsv)
SV* type_sv
CODE:
{
int type_num = 0;
if (type_sv && SvOK(type_sv)) {
sql_type_info_t *type_info;
if SvMAGICAL(type_sv)
(void)mg_get(type_sv);
type_info = pg_type_data(SvIV(type_sv));
type_num = type_info ? type_info->type.sql : SQL_VARCHAR;
}
ST(0) = sv_2mortal( newSViv( type_num ) );
}
void
pg_result(dbh)
SV * dbh
CODE:
int ret;
D_imp_dbh(dbh);
ret = pg_db_result(dbh, imp_dbh);
if (ret == 0)
XST_mPV(0, "0E0");
else if (ret < -1)
XST_mUNDEF(0);
else
XST_mIV(0, ret);
void
pg_ready(dbh)
SV *dbh
CODE:
D_imp_dbh(dbh);
ST(0) = sv_2mortal(newSViv(pg_db_ready(dbh, imp_dbh)));
void
pg_cancel(dbh)
SV *dbh
CODE:
D_imp_dbh(dbh);
ST(0) = pg_db_cancel(dbh, imp_dbh) ? &PL_sv_yes : &PL_sv_no;
# -- end of DBD::Pg::db
# ------------------------------------------------------------
# statement level interface PG specific
# ------------------------------------------------------------
MODULE = DBD::Pg PACKAGE = DBD::Pg::st
void state(sth)
SV *sth;
CODE:
D_imp_sth(sth);
D_imp_dbh_from_sth;
ST(0) = strEQ(imp_dbh->sqlstate,"00000")
? &PL_sv_no
: sv_2mortal(newSVpv(imp_dbh->sqlstate, 5));
void
pg_ready(sth)
SV *sth
CODE:
D_imp_sth(sth);
D_imp_dbh_from_sth;
ST(0) = sv_2mortal(newSViv(pg_db_ready(sth, imp_dbh)));
void
pg_cancel(sth)
SV *sth
CODE:
D_imp_sth(sth);
ST(0) = pg_db_cancel_sth(sth, imp_sth) ? &PL_sv_yes : &PL_sv_no;
void
cancel(sth)
SV *sth
CODE:
D_imp_sth(sth);
ST(0) = dbd_st_cancel(sth, imp_sth) ? &PL_sv_yes : &PL_sv_no;
void
pg_result(sth)
SV * sth
CODE:
long ret;
D_imp_sth(sth);
D_imp_dbh_from_sth;
ret = pg_db_result(sth, imp_dbh);
if (ret == 0)
XST_mPV(0, "0E0");
else if (ret < -1)
XST_mUNDEF(0);
else
XST_mIV(0, ret);
SV*
pg_canonical_ids(sth)
SV *sth
CODE:
D_imp_sth(sth);
RETVAL = dbd_st_canonical_ids(sth, imp_sth);
OUTPUT:
RETVAL
SV*
pg_canonical_names(sth)
SV *sth
CODE:
D_imp_sth(sth);
RETVAL = dbd_st_canonical_names(sth, imp_sth);
OUTPUT:
RETVAL
# end of Pg.xs