PostgreSQL7.0手册-接口-50. 函数 51. 大对象

　　WHERE　name　=　'beautiful　image';

--------------------------------------------------------------------------------
--------------------------------------------------------------------------------

通过　LIBPQ　访问大对象
下面是一个例子程序，显示如何使用　LIBPQ　里大对象接口的．程序的一部分是注释掉的，但仍然保留在源码里面供读者参考．这个程序可以在　../src/test/examples　里找到．使用　LIBPQ　里大对象接口的前端应用应该包括头文件libpq/libpq-fs.h　并且联接　libpq　库．

--------------------------------------------------------------------------------
--------------------------------------------------------------------------------

例子程序
/*--------------------------------------------------------------
　*
　*　testlo.c--
　*　　　　test　using　large　objects　with　libpq
　*
　*　Copyright　(c)　1994,　Regents　of　the　University　of　California
　*
　*
　*　IDENTIFICATION
　*　　　　/usr/local/devel/pglite/cvs/src/doc/manual.me,v　1.16　1995/09/01　23:55:00　jolly　Exp
　*
　*--------------------------------------------------------------
　*/
#include　
#include　"libpq-fe.h"
#include　"libpq/libpq-fs.h"

#define　BUFSIZE　　　　　　　　　　1024

/*
　*　importFile　*　　　　import　file　"in_filename"　into　database　as　large　object　"lobjOid"
　*
　*/
Oid　importFile(PGconn　*conn,　char　*filename)
{
　　　　Oid　lobjId;
　　　　int　lobj_fd;
　　　　char　buf[BUFSIZE];
　　　　int　nbytes,　tmp;
　　　　int　fd;

　　　　/*
　　　　　*　open　the　file　to　be　read　in
　　　　　*/
　　　　fd　=　open(filename,　O_RDONLY,　0666);
　　　　if　(fd　<　0)　　{　　　/*　error　*/
　　　　　fprintf(stderr,　"can't　open　unix　file　%s\n",　filename);
　　　　}

　　　　/*
　　　　　*　create　the　large　object
　　　　　*/
　　　　lobjId　=　lo_creat(conn,　INV_READ|INV_WRITE);
　　　　if　(lobjId　==　0)　{
　　　　　fprintf(stderr,　"can't　create　large　object\n");
　　　　}

　　　　lobj_fd　=　lo_open(conn,　lobjId,　INV_WRITE);
　　　　/*
　　　　　*　read　in　from　the　Unix　file　and　write　to　the　inversion　file
　　　　　*/
　　　　while　((nbytes　=　read(fd,　buf,　BUFSIZE))　>　0)　{
　　　　　tmp　=　lo_write(conn,　lobj_fd,　buf,　nbytes);
　　　　　if　(tmp　<　nbytes)　{
　　　　　　　　　fprintf(stderr,　"error　while　reading　large　object\n");
　　　　　}
　　　　}

　　　　(void)　close(fd);
　　　　(void)　lo_close(conn,　lobj_fd);

　　　　return　lobjId;
}

void　pickout(PGconn　*conn,　Oid　lobjId,　int　start,　int　len)
{
　　　　int　lobj_fd;
　　　　char*　buf;
　　　　int　nbytes;
　　　　int　nread;

　　　　lobj_fd　=　lo_open(conn,　lobjId,　INV_READ);
　　　　if　(lobj_fd　<　0)　{
　　　　　fprintf(stderr,"can't　open　large　object　%d\n",
　　　　　　　　　　lobjId);
　　　　}

　　　　lo_lseek(conn,　lobj_fd,　start,　SEEK_SET);
　　　　buf　=　malloc(len+1);

　　　　nread　=　0;
　　　　while　(len　-　nread　>　0)　{
　　　　　nbytes　=　lo_read(conn,　lobj_fd,　buf,　len　-　nread);
　　　　　buf[nbytes]　=　'　';
　　　　　fprintf(stderr,">>>　%s",　buf);
　　　　　nread　+=　nbytes;
　　　　}
　　　　fprintf(stderr,"\n");
　　　　lo_close(conn,　lobj_fd);
}

void　overwrite(PGconn　*conn,　Oid　lobjId,　int　start,　int　len)
{
　　　　int　lobj_fd;
　　　　char*　buf;
　　　　int　nbytes;
　　　　int　nwritten;
　　　　int　i;

　　　　lobj_fd　=　lo_open(conn,　lobjId,　INV_READ);
　　　　if　(lobj_fd　<　0)　{
　　　　　fprintf(stderr,"can't　open　large　object　%d\n",
　　　　　　　　　　lobjId);
　　　　}

　　　　lo_lseek(conn,　lobj_fd,　start,　SEEK_SET);
　　　　buf　=　malloc(len+1);

　　　　for　(i=0;i　　　　　buf[i]　=　'X';
　　　　buf[i]　=　'　';

　　　　nwritten　=　0;
　　　　while　(len　-　nwritten　>　0)　{
　　　　　nbytes　=　lo_write(conn,　lobj_fd,　buf　+　nwritten,　len　-　nwritten);
　　　　　nwritten　+=　nbytes;
　　　　}
　　　　fprintf(stderr,"\n");
　　　　lo_close(conn,　lobj_fd);
}

/*
　*　exportFile　*　　　　export　large　object　"lobjOid"　to　file　"out_filename"
　*
　*/
void　exportFile(PGconn　*conn,　Oid　lobjId,　char　*filename)
{
　　　　int　lobj_fd;
　　　　char　buf[BUFSIZE];
　　　　int　nbytes,　tmp;
　　　　int　fd;

　　　　/*
　　　　　*　create　an　inversion　"object"
　　　　　*/
　　　　lobj_fd　=　lo_open(conn,　lobjId,　INV_READ);
　　　　if　(lobj_fd　<　0)　{
　　　　　fprintf(stderr,"can't　open　large　object　%d\n",
　　　　　　　　　　lobjId);
　　　　}

　　　　/*
　　　　　*　open　the　file　to　be　written　to
　　　　　*/
　　　　fd　=　open(filename,　O_CREAT|O_WRONLY,　0666);
　　　　if　(fd　<　0)　　{　　　/*　error　*/
　　　　　fprintf(stderr,　"can't　open　unix　file　%s\n",
　　　　　　　　　　filename);
　　　　}

　　　　/*
　　　　　*　read　in　from　the　Unix　file　and　write　to　the　inversion　file
　　　　　*/
　　　　while　((nbytes　=　lo_read(conn,　lobj_fd,　buf,　BUFSIZE))　>　0)　{
　　　　　tmp　=　write(fd,　buf,　nbytes);
　　　　　　　　if　(tmp　<　nbytes)　{
　　　　　　　　　f