Pg.xs

/*

  Copyright (c) 2000-2022 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