开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > 查看源码
Pg.xs
资源名称：postgresql-6.5.2.tar.gz　[点击查看]
上传用户：blenddy
上传日期：2007-01-07
资源大小：6495k
文件大小：18k
源码类别：

数据库系统

开发平台：

Unix_Linux

Pg.xs：源码内容
  1. /*-------------------------------------------------------
  2.  *
  3.  * $Id: Pg.xs,v 1.12 1999/02/19 23:27:17 tgl Exp $
  4.  *
  5.  * Copyright (c) 1997, 1998  Edmund Mergl
  6.  *
  7.  *-------------------------------------------------------*/
  9. #include "EXTERN.h"
  10. #include "perl.h"
  11. #include "XSUB.h"
  12. #include <string.h>
  13. #include <stdio.h>
  14. #include <fcntl.h>
  16. #include "libpq-fe.h"
  18. typedef struct pg_conn *PG_conn;
  19. typedef struct pg_result *PG_result;
  21. typedef struct pg_results
  22. {
  23.   PGresult *result;
  24.   int row;
  25. } PGresults;
  27. typedef struct pg_results *PG_results;
  30. static double
  31. constant(name, arg)
  32. char *name;
  33. int arg; {
  34.     errno = 0;
  35.     switch (*name) {
  36.     case 'A':
  37. break;
  38.     case 'B':
  39. break;
  40.     case 'C':
  41. break;
  42.     case 'D':
  43. break;
  44.     case 'E':
  45. break;
  46.     case 'F':
  47. break;
  48.     case 'G':
  49. break;
  50.     case 'H':
  51. break;
  52.     case 'I':
  53. break;
  54.     case 'J':
  55. break;
  56.     case 'K':
  57. break;
  58.     case 'L':
  59. break;
  60.     case 'M':
  61. break;
  62.     case 'N':
  63. break;
  64.     case 'O':
  65. break;
  66.     case 'P':
  67. if (strEQ(name, "PGRES_CONNECTION_OK"))
  68. return 0;
  69. if (strEQ(name, "PGRES_CONNECTION_BAD"))
  70. return 1;
  71. if (strEQ(name, "PGRES_INV_SMGRMASK"))
  72. return 0x0000ffff;
  73. if (strEQ(name, "PGRES_INV_ARCHIVE"))
  74. return 0x00010000;
  75. if (strEQ(name, "PGRES_INV_WRITE"))
  76. return 0x00020000;
  77. if (strEQ(name, "PGRES_INV_READ"))
  78. return 0x00040000;
  79. if (strEQ(name, "PGRES_InvalidOid"))
  80. return 0;
  81. if (strEQ(name, "PGRES_EMPTY_QUERY"))
  82. return 0;
  83. if (strEQ(name, "PGRES_COMMAND_OK"))
  84. return 1;
  85. if (strEQ(name, "PGRES_TUPLES_OK"))
  86. return 2;
  87. if (strEQ(name, "PGRES_COPY_OUT"))
  88. return 3;
  89. if (strEQ(name, "PGRES_COPY_IN"))
  90. return 4;
  91. if (strEQ(name, "PGRES_BAD_RESPONSE"))
  92. return 5;
  93. if (strEQ(name, "PGRES_NONFATAL_ERROR"))
  94. return 6;
  95. if (strEQ(name, "PGRES_FATAL_ERROR"))
  96. return 7;
  97. break;
  98.     case 'Q':
  99. break;
  100.     case 'R':
  101. break;
  102.     case 'S':
  103. break;
  104.     case 'T':
  105. break;
  106.     case 'U':
  107. break;
  108.     case 'V':
  109. break;
  110.     case 'W':
  111. break;
  112.     case 'X':
  113. break;
  114.     case 'Y':
  115. break;
  116.     case 'Z':
  117. break;
  118.     case 'a':
  119. break;
  120.     case 'b':
  121. break;
  122.     case 'c':
  123. break;
  124.     case 'd':
  125. break;
  126.     case 'e':
  127. break;
  128.     case 'f':
  129. break;
  130.     case 'g':
  131. break;
  132.     case 'h':
  133. break;
  134.     case 'i':
  135. break;
  136.     case 'j':
  137. break;
  138.     case 'k':
  139. break;
  140.     case 'l':
  141. break;
  142.     case 'm':
  143. break;
  144.     case 'n':
  145. break;
  146.     case 'o':
  147. break;
  148.     case 'p':
  149. break;
  150.     case 'q':
  151. break;
  152.     case 'r':
  153. break;
  154.     case 's':
  155. break;
  156.     case 't':
  157. break;
  158.     case 'u':
  159. break;
  160.     case 'v':
  161. break;
  162.     case 'w':
  163. break;
  164.     case 'x':
  165. break;
  166.     case 'y':
  167. break;
  168.     case 'z':
  169. break;
  170.     }
  171.     errno = EINVAL;
  172.     return 0;
  174. not_there:
  175.     errno = ENOENT;
  176.     return 0;
  177. }
  182. MODULE = Pg PACKAGE = Pg
  184. PROTOTYPES: DISABLE
  187. double
  188. constant(name,arg)
  189. char * name
  190. int arg
  193. PGconn *
  194. PQconnectdb(conninfo)
  195. char * conninfo
  196. CODE:
  197. /* convert dbname to lower case if not surrounded by double quotes */
  198. char *ptr = strstr(conninfo, "dbname");
  199. if (ptr) {
  200. while (*ptr && *ptr != '=') {
  201. ptr++;
  202. }
  203.                         ptr++;
  204. while (*ptr == ' ' || *ptr == 't') {
  205. ptr++;
  206. }
  207. if (*ptr == '"') {
  208. *ptr++ = ' ';
  209. while (*ptr && *ptr != '"') {
  210. ptr++;
  211. }
  212. if (*ptr == '"') {
  213. *ptr++ = ' ';
  214. }
  215. } else {
  216. while (*ptr && *ptr != ' ' && *ptr != 't') {
  217.       *ptr = tolower(*ptr);
  218.       ptr++;
  219. }
  220. }
  221. }
  222. RETVAL = PQconnectdb((const char *)conninfo);
  223. OUTPUT:
  224. RETVAL
  227. PGconn *
  228. PQsetdbLogin(pghost, pgport, pgoptions, pgtty, dbname, login, pwd)
  229. char * pghost
  230. char * pgport
  231. char * pgoptions
  232. char * pgtty
  233. char * dbname
  234. char * login
  235. char * pwd
  238. PGconn *
  239. PQsetdb(pghost, pgport, pgoptions, pgtty, dbname)
  240. char * pghost
  241. char * pgport
  242. char * pgoptions
  243. char * pgtty
  244. char * dbname
  247. HV *
  248. PQconndefaults()
  249. CODE:
  250. PQconninfoOption *infoOption;
  251. RETVAL = newHV();
  252.                 if (infoOption = PQconndefaults()) {
  253. while (infoOption->keyword != NULL) {
  254. if (infoOption->val != NULL) {
  255. hv_store(RETVAL, infoOption->keyword, strlen(infoOption->keyword), newSVpv(infoOption->val, 0), 0);
  256. } else {
  257. hv_store(RETVAL, infoOption->keyword, strlen(infoOption->keyword), newSVpv("", 0), 0);
  258. }
  259. infoOption++;
  260. }
  261. }
  262. OUTPUT:
  263. RETVAL
  266. void
  267. PQfinish(conn)
  268. PGconn * conn
  271. void
  272. PQreset(conn)
  273. PGconn * conn
  276. int
  277. PQrequestCancel(conn)
  278. PGconn * conn
  280. char *
  281. PQdb(conn)
  282. PGconn * conn
  285. char *
  286. PQuser(conn)
  287. PGconn * conn
  290. char *
  291. PQpass(conn)
  292. PGconn * conn
  295. char *
  296. PQhost(conn)
  297. PGconn * conn
  300. char *
  301. PQport(conn)
  302. PGconn * conn
  305. char *
  306. PQtty(conn)
  307. PGconn * conn
  310. char *
  311. PQoptions(conn)
  312. PGconn * conn
  315. ConnStatusType
  316. PQstatus(conn)
  317. PGconn * conn
  320. char *
  321. PQerrorMessage(conn)
  322. PGconn * conn
  325. int
  326. PQsocket(conn)
  327. PGconn * conn
  330. int
  331. PQbackendPID(conn)
  332. PGconn * conn
  335. void
  336. PQtrace(conn, debug_port)
  337. PGconn * conn
  338. FILE * debug_port
  341. void
  342. PQuntrace(conn)
  343. PGconn * conn
  347. PGresult *
  348. PQexec(conn, query)
  349. PGconn * conn
  350. char * query
  351. CODE:
  352. RETVAL = PQexec(conn, query);
  353. if (! RETVAL) {
  354. RETVAL = PQmakeEmptyPGresult(conn, PGRES_FATAL_ERROR);
  355. }
  356. OUTPUT:
  357. RETVAL
  360. void
  361. PQnotifies(conn)
  362. PGconn * conn
  363. PREINIT:
  364. PGnotify *notify;
  365. PPCODE:
  366. notify = PQnotifies(conn);
  367. if (notify) {
  368. XPUSHs(sv_2mortal(newSVpv((char *)notify->relname, 0)));
  369. XPUSHs(sv_2mortal(newSViv(notify->be_pid)));
  370. free(notify);
  371. }
  374. int
  375. PQsendQuery(conn, query)
  376. PGconn * conn
  377. char * query
  380. PGresult *
  381. PQgetResult(conn)
  382. PGconn * conn
  383. CODE:
  384. RETVAL = PQgetResult(conn);
  385. if (! RETVAL) {
  386. RETVAL = PQmakeEmptyPGresult(conn, PGRES_FATAL_ERROR);
  387. }
  388. OUTPUT:
  389. RETVAL
  392. int
  393. PQisBusy(conn)
  394. PGconn * conn
  397. int
  398. PQconsumeInput(conn)
  399. PGconn * conn
  402. int
  403. PQgetline(conn, string, length)
  404. PREINIT:
  405. SV *bufsv = SvROK(ST(1)) ? SvRV(ST(1)) : ST(1);
  406. INPUT:
  407. PGconn * conn
  408. int length
  409. char * string = sv_grow(bufsv, length);
  410. CODE:
  411. RETVAL = PQgetline(conn, string, length);
  412. OUTPUT:
  413. RETVAL
  414. string
  417. int
  418. PQputline(conn, string)
  419. PGconn * conn
  420. char * string
  423. int
  424. PQgetlineAsync(conn, buffer, bufsize)
  425. PREINIT:
  426. SV *bufsv = SvROK(ST(1)) ? SvRV(ST(1)) : ST(1);
  427. INPUT:
  428. PGconn * conn
  429. int bufsize
  430. char * buffer = sv_grow(bufsv, bufsize);
  431. CODE:
  432. RETVAL = PQgetlineAsync(conn, buffer, bufsize);
  433. OUTPUT:
  434. RETVAL
  435. buffer
  438. int
  439. PQputnbytes(conn, buffer, nbytes)
  440. PGconn * conn
  441. char * buffer
  442. int nbytes
  445. int
  446. PQendcopy(conn)
  447. PGconn * conn
  450. PGresult *
  451. PQmakeEmptyPGresult(conn, status)
  452. PGconn * conn
  453. ExecStatusType status
  456. ExecStatusType
  457. PQresultStatus(res)
  458. PGresult * res
  461. int
  462. PQntuples(res)
  463. PGresult * res
  466. int
  467. PQnfields(res)
  468. PGresult * res
  471. int
  472. PQbinaryTuples(res)
  473. PGresult * res
  476. char *
  477. PQfname(res, field_num)
  478. PGresult * res
  479. int field_num
  482. int
  483. PQfnumber(res, field_name)
  484. PGresult * res
  485. char * field_name
  488. Oid
  489. PQftype(res, field_num)
  490. PGresult * res
  491. int field_num
  494. short
  495. PQfsize(res, field_num)
  496. PGresult * res
  497. int field_num
  500. int
  501. PQfmod(res, field_num)
  502. PGresult * res
  503. int field_num
  506. char *
  507. PQcmdStatus(res)
  508. PGresult * res
  511. char *
  512. PQoidStatus(res)
  513. PGresult * res
  514. CODE:
  515. RETVAL = (char *)PQoidStatus(res);
  516. OUTPUT:
  517. RETVAL
  520. char *
  521. PQcmdTuples(res)
  522. PGresult * res
  523. CODE:
  524. RETVAL = (char *)PQcmdTuples(res);
  525. OUTPUT:
  526. RETVAL
  529. char *
  530. PQgetvalue(res, tup_num, field_num)
  531. PGresult * res
  532. int tup_num
  533. int field_num
  536. int
  537. PQgetlength(res, tup_num, field_num)
  538. PGresult * res
  539. int tup_num
  540. int field_num
  543. int
  544. PQgetisnull(res, tup_num, field_num)
  545. PGresult * res
  546. int tup_num
  547. int field_num
  550. void
  551. PQclear(res)
  552. PGresult * res
  555. void
  556. PQprint(fout, res, header, align, standard, html3, expanded, pager, fieldSep, tableOpt, caption, ...)
  557. FILE * fout
  558. PGresult * res
  559. pqbool header
  560. pqbool align
  561. pqbool standard
  562. pqbool html3
  563. pqbool expanded
  564. pqbool pager
  565. char * fieldSep
  566. char * tableOpt
  567. char * caption
  568. PREINIT:
  569. PQprintOpt ps;
  570. int i;
  571. CODE:
  572. ps.header    = header;
  573. ps.align     = align;
  574. ps.standard  = standard;
  575. ps.html3     = html3;
  576. ps.expanded  = expanded;
  577. ps.pager     = pager;
  578. ps.fieldSep  = fieldSep;
  579. ps.tableOpt  = tableOpt;
  580. ps.caption   = caption;
  581. Newz(0, ps.fieldName, items + 1 - 11, char*);
  582. for (i = 11; i < items; i++) {
  583. ps.fieldName[i - 11] = (char *)SvPV(ST(i), na);
  584. }
  585. PQprint(fout, res, &ps);
  586. Safefree(ps.fieldName);
  589. void
  590. PQdisplayTuples(res, fp, fillAlign, fieldSep, printHeader, quiet)
  591. PGresult * res
  592. FILE * fp
  593. int fillAlign
  594. char * fieldSep
  595. int printHeader
  596. int quiet
  597. CODE:
  598. PQdisplayTuples(res, fp, fillAlign, (const char *)fieldSep, printHeader, quiet);
  601. void
  602. PQprintTuples(res, fout, printAttName, terseOutput, width)
  603. PGresult * res
  604. FILE * fout
  605. int printAttName
  606. int terseOutput
  607. int width
  610. int
  611. lo_open(conn, lobjId, mode)
  612. PGconn * conn
  613. Oid lobjId
  614. int mode
  615. ALIAS:
  616. PQlo_open = 1
  619. int
  620. lo_close(conn, fd)
  621. PGconn * conn
  622. int fd
  623. ALIAS:
  624. PQlo_close = 1
  627. int
  628. lo_read(conn, fd, buf, len)
  629. ALIAS:
  630. PQlo_read = 1
  631. PREINIT:
  632. SV *bufsv = SvROK(ST(2)) ? SvRV(ST(2)) : ST(2);
  633. INPUT:
  634. PGconn * conn
  635. int fd
  636. int len
  637. char * buf = sv_grow(bufsv, len + 1);
  638. CODE:
  639. RETVAL = lo_read(conn, fd, buf, len);
  640. if (RETVAL > 0) {
  641. SvCUR_set(bufsv, RETVAL);
  642. *SvEND(bufsv) = '';
  643. }
  644. OUTPUT:
  645. RETVAL
  646. buf
  648. int
  649. lo_write(conn, fd, buf, len)
  650. PGconn * conn
  651. int fd
  652. char * buf
  653. int len
  654. ALIAS:
  655. PQlo_write = 1
  658. int
  659. lo_lseek(conn, fd, offset, whence)
  660. PGconn * conn
  661. int fd
  662. int offset
  663. int whence
  664. ALIAS:
  665. PQlo_lseek = 1
  668. Oid
  669. lo_creat(conn, mode)
  670. PGconn * conn
  671. int mode
  672. ALIAS:
  673. PQlo_creat = 1
  676. int
  677. lo_tell(conn, fd)
  678. PGconn * conn
  679. int fd
  680. ALIAS:
  681. PQlo_tell = 1
  684. int
  685. lo_unlink(conn, lobjId)
  686. PGconn * conn
  687. Oid lobjId
  688. ALIAS:
  689. PQlo_unlink = 1
  692. Oid
  693. lo_import(conn, filename)
  694. PGconn * conn
  695. char * filename
  696. ALIAS:
  697. PQlo_import = 1
  700. int
  701. lo_export(conn, lobjId, filename)
  702. PGconn * conn
  703. Oid lobjId
  704. char * filename
  705. ALIAS:
  706. PQlo_export = 1
  711. PG_conn
  712. connectdb(conninfo)
  713. char * conninfo
  714. CODE:
  715. /* convert dbname to lower case if not surrounded by double quotes */
  716. char *ptr = strstr(conninfo, "dbname");
  717. if (ptr) {
  718. ptr += 6;
  719. while (*ptr && *ptr++ != '=') {
  720. ;
  721. }
  722. while (*ptr && (*ptr == ' ' || *ptr == 't')) {
  723. ptr++;
  724. }
  725. if (*ptr == '"') {
  726. *ptr++ = ' ';
  727. while (*ptr && *ptr != '"') {
  728. ptr++;
  729. }
  730. if (*ptr == '"') {
  731. *ptr++ = ' ';
  732. }
  733. } else {
  734. while (*ptr && *ptr != ' ' && *ptr != 't') {
  735. *ptr = tolower(*ptr);
  736. ptr++;
  737. }
  738. }
  739. }
  740. RETVAL = PQconnectdb((const char *)conninfo);
  741. OUTPUT:
  742. RETVAL
  745. PG_conn
  746. setdbLogin(pghost, pgport, pgoptions, pgtty, dbname, login, pwd)
  747. char * pghost
  748. char * pgport
  749. char * pgoptions
  750. char * pgtty
  751. char * dbname
  752. char * login
  753. char * pwd
  754. CODE:
  755. RETVAL = PQsetdbLogin(pghost, pgport, pgoptions, pgtty, dbname,
  756.   login, pwd);
  757. OUTPUT:
  758. RETVAL
  761. PG_conn
  762. setdb(pghost, pgport, pgoptions, pgtty, dbname)
  763. char * pghost
  764. char * pgport
  765. char * pgoptions
  766. char * pgtty
  767. char * dbname
  768. CODE:
  769. RETVAL = PQsetdb(pghost, pgport, pgoptions, pgtty, dbname);
  770. OUTPUT:
  771. RETVAL
  774. HV *
  775. conndefaults()
  776. CODE:
  777. PQconninfoOption *infoOption;
  778. RETVAL = newHV();
  779.                 if (infoOption = PQconndefaults()) {
  780. while (infoOption->keyword != NULL) {
  781. if (infoOption->val != NULL) {
  782. hv_store(RETVAL, infoOption->keyword, strlen(infoOption->keyword), newSVpv(infoOption->val, 0), 0);
  783. } else {
  784. hv_store(RETVAL, infoOption->keyword, strlen(infoOption->keyword), newSVpv("", 0), 0);
  785. }
  786. infoOption++;
  787. }
  788. }
  789. OUTPUT:
  790. RETVAL
  798. MODULE = Pg PACKAGE = PG_conn PREFIX = PQ
  800. PROTOTYPES: DISABLE
  803. void
  804. DESTROY(conn)
  805. PG_conn conn
  806. CODE:
  807. /* printf("DESTROY connectionn"); */
  808. PQfinish(conn);
  811. void
  812. PQreset(conn)
  813. PG_conn conn
  816. int
  817. PQrequestCancel(conn)
  818. PG_conn conn
  821. char *
  822. PQdb(conn)
  823. PG_conn conn
  826. char *
  827. PQuser(conn)
  828. PG_conn conn
  831. char *
  832. PQpass(conn)
  833. PG_conn conn
  836. char *
  837. PQhost(conn)
  838. PG_conn conn
  841. char *
  842. PQport(conn)
  843. PG_conn conn
  846. char *
  847. PQtty(conn)
  848. PG_conn conn
  851. char *
  852. PQoptions(conn)
  853. PG_conn conn
  856. ConnStatusType
  857. PQstatus(conn)
  858. PG_conn conn
  861. char *
  862. PQerrorMessage(conn)
  863. PG_conn conn
  866. int
  867. PQsocket(conn)
  868. PG_conn conn
  871. int
  872. PQbackendPID(conn)
  873. PG_conn conn
  876. void
  877. PQtrace(conn, debug_port)
  878. PG_conn conn
  879. FILE * debug_port
  882. void
  883. PQuntrace(conn)
  884. PG_conn conn
  887. PG_results
  888. PQexec(conn, query)
  889. PG_conn conn
  890. char * query
  891. CODE:
  892. RETVAL = (PG_results)calloc(1, sizeof(PGresults));
  893. if (RETVAL) {
  894. RETVAL->result = PQexec((PGconn *)conn, query);
  895. if (!RETVAL->result) {
  896. RETVAL->result = PQmakeEmptyPGresult((PGconn *)conn, PGRES_FATAL_ERROR);
  897. }
  898. }
  899. OUTPUT:
  900. RETVAL
  903. void
  904. PQnotifies(conn)
  905. PG_conn conn
  906. PREINIT:
  907. PGnotify *notify;
  908. PPCODE:
  909. notify = PQnotifies(conn);
  910. if (notify) {
  911. XPUSHs(sv_2mortal(newSVpv((char *)notify->relname, 0)));
  912. XPUSHs(sv_2mortal(newSViv(notify->be_pid)));
  913. free(notify);
  914. }
  917. int
  918. PQsendQuery(conn, query)
  919. PG_conn conn
  920. char * query
  923. PG_results
  924. PQgetResult(conn)
  925. PG_conn conn
  926. CODE:
  927. RETVAL = (PG_results)calloc(1, sizeof(PGresults));
  928. if (RETVAL) {
  929. RETVAL->result = PQgetResult((PGconn *)conn);
  930. if (!RETVAL->result) {
  931. RETVAL->result = PQmakeEmptyPGresult((PGconn *)conn, PGRES_FATAL_ERROR);
  932. }
  933. }
  934. OUTPUT:
  935. RETVAL
  938. int
  939. PQisBusy(conn)
  940. PG_conn conn
  943. int
  944. PQconsumeInput(conn)
  945. PG_conn conn
  948. int
  949. PQgetline(conn, string, length)
  950. PREINIT:
  951. SV *bufsv = SvROK(ST(1)) ? SvRV(ST(1)) : ST(1);
  952. INPUT:
  953. PG_conn conn
  954. int length
  955. char * string = sv_grow(bufsv, length);
  956. CODE:
  957. RETVAL = PQgetline(conn, string, length);
  958. OUTPUT:
  959. RETVAL
  960. string
  963. int
  964. PQputline(conn, string)
  965. PG_conn conn
  966. char * string
  969. int
  970. PQgetlineAsync(conn, buffer, bufsize)
  971. PREINIT:
  972. SV *bufsv = SvROK(ST(1)) ? SvRV(ST(1)) : ST(1);
  973. INPUT:
  974. PG_conn conn
  975. int bufsize
  976. char * buffer = sv_grow(bufsv, bufsize);
  977. CODE:
  978. RETVAL = PQgetline(conn, buffer, bufsize);
  979. OUTPUT:
  980. RETVAL
  981. buffer
  984. int
  985. PQendcopy(conn)
  986. PG_conn conn
  989. PG_results
  990. PQmakeEmptyPGresult(conn, status)
  991. PG_conn conn
  992. ExecStatusType status
  993. CODE:
  994. RETVAL = (PG_results)calloc(1, sizeof(PGresults));
  995. if (RETVAL) {
  996. RETVAL->result = PQmakeEmptyPGresult((PGconn *)conn, status);
  997. }
  998. OUTPUT:
  999. RETVAL
  1002. int
  1003. lo_open(conn, lobjId, mode)
  1004. PG_conn conn
  1005. Oid lobjId
  1006. int mode
  1009. int
  1010. lo_close(conn, fd)
  1011. PG_conn conn
  1012. int fd
  1015. int
  1016. lo_read(conn, fd, buf, len)
  1017. PREINIT:
  1018. SV *bufsv = SvROK(ST(2)) ? SvRV(ST(2)) : ST(2);
  1019. INPUT:
  1020. PG_conn conn
  1021. int fd
  1022. int len
  1023. char * buf = sv_grow(bufsv, len + 1);
  1024. CODE:
  1025. RETVAL = lo_read(conn, fd, buf, len);
  1026. if (RETVAL > 0) {
  1027. SvCUR_set(bufsv, RETVAL);
  1028. *SvEND(bufsv) = '';
  1029. }
  1030. OUTPUT:
  1031. RETVAL
  1032. buf
  1035. int
  1036. lo_write(conn, fd, buf, len)
  1037. PG_conn conn
  1038. int fd
  1039. char * buf
  1040. int len
  1043. int
  1044. lo_lseek(conn, fd, offset, whence)
  1045. PG_conn conn
  1046. int fd
  1047. int offset
  1048. int whence
  1051. Oid
  1052. lo_creat(conn, mode)
  1053. PG_conn conn
  1054. int mode
  1057. int
  1058. lo_tell(conn, fd)
  1059. PG_conn conn
  1060. int fd
  1063. int
  1064. lo_unlink(conn, lobjId)
  1065. PG_conn conn
  1066. Oid lobjId
  1069. Oid
  1070. lo_import(conn, filename)
  1071. PG_conn conn
  1072. char * filename
  1075. int
  1076. lo_export(conn, lobjId, filename)
  1077. PG_conn conn
  1078. Oid lobjId
  1079. char * filename
  1084. MODULE = Pg PACKAGE = PG_results PREFIX = PQ
  1086. PROTOTYPES: DISABLE
  1089. void
  1090. DESTROY(res)
  1091. PG_results res
  1092. CODE:
  1093. /* printf("DESTROY resultn"); */
  1094. PQclear(res->result);
  1095. Safefree(res);
  1097. ExecStatusType
  1098. PQresultStatus(res)
  1099. PG_results res
  1100. CODE:
  1101. RETVAL = PQresultStatus(res->result);
  1102. OUTPUT:
  1103. RETVAL
  1105. int
  1106. PQntuples(res)
  1107. PG_results res
  1108. CODE:
  1109. RETVAL = PQntuples(res->result);
  1110. OUTPUT:
  1111. RETVAL
  1114. int
  1115. PQnfields(res)
  1116. PG_results res
  1117. CODE:
  1118. RETVAL = PQnfields(res->result);
  1119. OUTPUT:
  1120. RETVAL
  1123. int
  1124. PQbinaryTuples(res)
  1125. PG_results res
  1126. CODE:
  1127. RETVAL = PQbinaryTuples(res->result);
  1128. OUTPUT:
  1129. RETVAL
  1132. char *
  1133. PQfname(res, field_num)
  1134. PG_results res
  1135. int field_num
  1136. CODE:
  1137. RETVAL = PQfname(res->result, field_num);
  1138. OUTPUT:
  1139. RETVAL
  1142. int
  1143. PQfnumber(res, field_name)
  1144. PG_results res
  1145. char * field_name
  1146. CODE:
  1147. RETVAL = PQfnumber(res->result, field_name);
  1148. OUTPUT:
  1149. RETVAL
  1152. Oid
  1153. PQftype(res, field_num)
  1154. PG_results res
  1155. int field_num
  1156. CODE:
  1157. RETVAL = PQftype(res->result, field_num);
  1158. OUTPUT:
  1159. RETVAL
  1162. short
  1163. PQfsize(res, field_num)
  1164. PG_results res
  1165. int field_num
  1166. CODE:
  1167. RETVAL = PQfsize(res->result, field_num);
  1168. OUTPUT:
  1169. RETVAL
  1172. int
  1173. PQfmod(res, field_num)
  1174. PG_results res
  1175. int field_num
  1176. CODE:
  1177. RETVAL = PQfmod(res->result, field_num);
  1178. OUTPUT:
  1179. RETVAL
  1182. char *
  1183. PQcmdStatus(res)
  1184. PG_results res
  1185. CODE:
  1186. RETVAL = PQcmdStatus(res->result);
  1187. OUTPUT:
  1188. RETVAL
  1191. char *
  1192. PQoidStatus(res)
  1193. PG_results res
  1194. CODE:
  1195. RETVAL = (char *)PQoidStatus(res->result);
  1196. OUTPUT:
  1197. RETVAL
  1200. char *
  1201. PQcmdTuples(res)
  1202. PG_results res
  1203. CODE:
  1204. RETVAL = (char *)PQcmdTuples(res->result);
  1205. OUTPUT:
  1206. RETVAL
  1209. char *
  1210. PQgetvalue(res, tup_num, field_num)
  1211. PG_results res
  1212. int tup_num
  1213. int field_num
  1214. CODE:
  1215. RETVAL = PQgetvalue(res->result, tup_num, field_num);
  1216. OUTPUT:
  1217. RETVAL
  1220. int
  1221. PQgetlength(res, tup_num, field_num)
  1222. PG_results res
  1223. int tup_num
  1224. int field_num
  1225. CODE:
  1226. RETVAL = PQgetlength(res->result, tup_num, field_num);
  1227. OUTPUT:
  1228. RETVAL
  1231. int
  1232. PQgetisnull(res, tup_num, field_num)
  1233. PG_results res
  1234. int tup_num
  1235. int field_num
  1236. CODE:
  1237. RETVAL = PQgetisnull(res->result, tup_num, field_num);
  1238. OUTPUT:
  1239. RETVAL
  1242. void
  1243. PQfetchrow(res)
  1244. PG_results res
  1245. PPCODE:
  1246. if (res && res->result) {
  1247. int cols = PQnfields(res->result);
  1248. if (PQntuples(res->result) > res->row) {
  1249. int col = 0;
  1250. EXTEND(sp, cols);
  1251. while (col < cols) {
  1252. if (PQgetisnull(res->result, res->row, col)) {
  1253. PUSHs(&sv_undef);
  1254. } else {
  1255. char *val = PQgetvalue(res->result, res->row, col);
  1256. PUSHs(sv_2mortal((SV*)newSVpv(val, 0)));
  1257. }
  1258. ++col;
  1259. }
  1260. ++res->row;
  1261. }
  1262. }
  1265. void
  1266. PQprint(res, fout, header, align, standard, html3, expanded, pager, fieldSep, tableOpt, caption, ...)
  1267. FILE * fout
  1268. PG_results res
  1269. pqbool header
  1270. pqbool align
  1271. pqbool standard
  1272. pqbool html3
  1273. pqbool expanded
  1274. pqbool pager
  1275. char * fieldSep
  1276. char * tableOpt
  1277. char * caption
  1278. PREINIT:
  1279. PQprintOpt ps;
  1280. int i;
  1281. CODE:
  1282. ps.header    = header;
  1283. ps.align     = align;
  1284. ps.standard  = standard;
  1285. ps.html3     = html3;
  1286. ps.expanded  = expanded;
  1287. ps.pager     = pager;
  1288. ps.fieldSep  = fieldSep;
  1289. ps.tableOpt  = tableOpt;
  1290. ps.caption   = caption;
  1291. Newz(0, ps.fieldName, items + 1 - 11, char*);
  1292. for (i = 11; i < items; i++) {
  1293. ps.fieldName[i - 11] = (char *)SvPV(ST(i), na);
  1294. }
  1295. PQprint(fout, res->result, &ps);
  1296. Safefree(ps.fieldName);
  1299. void
  1300. PQdisplayTuples(res, fp, fillAlign, fieldSep, printHeader, quiet)
  1301. PG_results res
  1302. FILE * fp
  1303. int fillAlign
  1304. char * fieldSep
  1305. int printHeader
  1306. int quiet
  1307. CODE:
  1308. PQdisplayTuples(res->result, fp, fillAlign, (const char *)fieldSep, printHeader, quiet);
  1311. void
  1312. PQprintTuples(res, fout, printAttName, terseOutput, width)
  1313. PG_results res
  1314. FILE * fout
  1315. int printAttName
  1316. int terseOutput
  1317. int width
  1318. CODE:
  1319. PQprintTuples(res->result, fout, printAttName, terseOutput, width);