begriffs open source - ai-pg/blob - full-docs/txt/ecpg-lo.txt

   1
   2 34.12. Large Objects #
   3
   4    Large objects are not directly supported by ECPG, but ECPG application
   5    can manipulate large objects through the libpq large object functions,
   6    obtaining the necessary PGconn object by calling the ECPGget_PGconn()
   7    function. (However, use of the ECPGget_PGconn() function and touching
   8    PGconn objects directly should be done very carefully and ideally not
   9    mixed with other ECPG database access calls.)
  10
  11    For more details about the ECPGget_PGconn(), see Section 34.11. For
  12    information about the large object function interface, see Chapter 33.
  13
  14    Large object functions have to be called in a transaction block, so
  15    when autocommit is off, BEGIN commands have to be issued explicitly.
  16
  17    Example 34.2 shows an example program that illustrates how to create,
  18    write, and read a large object in an ECPG application.
  19
  20    Example 34.2. ECPG Program Accessing Large Objects
  21 #include <stdio.h>
  22 #include <stdlib.h>
  23 #include <libpq-fe.h>
  24 #include <libpq/libpq-fs.h>
  25
  26 EXEC SQL WHENEVER SQLERROR STOP;
  27
  28 int
  29 main(void)
  30 {
  31     PGconn     *conn;
  32     Oid         loid;
  33     int         fd;
  34     char        buf[256];
  35     int         buflen = 256;
  36     char        buf2[256];
  37     int         rc;
  38
  39     memset(buf, 1, buflen);
  40
  41     EXEC SQL CONNECT TO testdb AS con1;
  42     EXEC SQL SELECT pg_catalog.set_config('search_path', '', false); EXEC SQL CO
  43 MMIT;
  44
  45     conn = ECPGget_PGconn("con1");
  46     printf("conn = %p\n", conn);
  47
  48     /* create */
  49     loid = lo_create(conn, 0);
  50     if (loid &lt; 0)
  51         printf("lo_create() failed: %s", PQerrorMessage(conn));
  52
  53     printf("loid = %d\n", loid);
  54
  55     /* write test */
  56     fd = lo_open(conn, loid, INV_READ|INV_WRITE);
  57     if (fd &lt; 0)
  58         printf("lo_open() failed: %s", PQerrorMessage(conn));
  59
  60     printf("fd = %d\n", fd);
  61
  62     rc = lo_write(conn, fd, buf, buflen);
  63     if (rc &lt; 0)
  64         printf("lo_write() failed\n");
  65
  66     rc = lo_close(conn, fd);
  67     if (rc &lt; 0)
  68         printf("lo_close() failed: %s", PQerrorMessage(conn));
  69
  70     /* read test */
  71     fd = lo_open(conn, loid, INV_READ);
  72     if (fd &lt; 0)
  73         printf("lo_open() failed: %s", PQerrorMessage(conn));
  74
  75     printf("fd = %d\n", fd);
  76
  77     rc = lo_read(conn, fd, buf2, buflen);
  78     if (rc &lt; 0)
  79         printf("lo_read() failed\n");
  80
  81     rc = lo_close(conn, fd);
  82     if (rc &lt; 0)
  83         printf("lo_close() failed: %s", PQerrorMessage(conn));
  84
  85     /* check */
  86     rc = memcmp(buf, buf2, buflen);
  87     printf("memcmp() = %d\n", rc);
  88
  89     /* cleanup */
  90     rc = lo_unlink(conn, loid);
  91     if (rc &lt; 0)
  92         printf("lo_unlink() failed: %s", PQerrorMessage(conn));
  93
  94     EXEC SQL COMMIT;
  95     EXEC SQL DISCONNECT ALL;
  96     return 0;
  97 }