首页 > 数据库 > PostgreSQL > 正文

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

2019-09-08 23:34:15
字体：大 中 小
来源：转载
供稿：网友
第五十章.　函数
用户可调用的函数的参考．
注意：本节需要人来写．愿当支援者吗？


第五十一章.　大对象
内容　
历史信息　
实现的特点　
接口　
内建的已注册函数　
从　LIBPQ　里访问大对象　
例子程序　
在　Postgres　里，记录存储在数据页面里并且单个记录里的数据大小不能超过数据页面的大小．因为数据页面大小是　8192　字节，所以数据值的大小是相当小的．为了存储更大的不可分割数值（原子数值），Postgres　提供了大对象接口．这个接口给用户提供对定义为大对象的用户数据的面向文件的接口．本节描述　Postgres　大对象数据的实现，编程和查询语言接口．　
历史信息
最初，Postgres　4.2　支持三种大对象的标准实现：作为　Postgres　的文件扩展，作为由　Postgres　管理的　UNIX　文件，以及作为存储在　Postgres　数据库里面的数据．这样做容易导致用户的迷惑．结果是，我们只支持把大对象作为数据存储在Postgres　数据库里，即使这样做令数据访问变得有些慢，但却保证了更严格的数据完整性．由于历史原因，这种存储机制被称为倒转大对象．（我们将在本章中交互使用倒转和大对象来表示同一个意思）。
--------------------------------------------------------------------------------

实现的特点
倒转大对象把大对象分解成"块"　（"chunks"），然后把块存放在数据库记录里面．在随机读写时使用一个B-tree　索引保证对正确的块（chunk）号的检索．

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

接口
Postgres　提供的用于访问大对象的机制，包括作为用户定义函数的后端的一部分或者作为使用接口的前端应用的一部分，都在下面描述．对于熟悉　Postgres　4.2　的用户，PostgreSQL　有一套新的函数提供更连贯的接口．　
注意：所有大对象的操作都必须在一个SQL事务里实现。这在　Postgres　v6.5　里有严格的要求，尽管在以前的版本里就隐含这样的要求，如果忽略这一点会导致错误的表现。
Postgres　大对象接口是对　UNIX　文件系统的模仿，有仿真的　open(2)，read(2)，write(2)，lseek(2)，等．用户函数调用这些路径从一个大对象中检索她们感兴趣的数据．例如，如果一个名为　mugshot　的大对象类型存在，在其中保存面孔的图象，那么可以在　mugshot　数据上定义一个叫　beard　（胡子）的函数．Beard　（胡子函数）会检查图片的下三分之一区域，并且如果存在胡子的话判断胡子的颜色．整个大对象的值不需要被　brard　函数缓存起来或者甚至是作些检查．大对象可以从动态装载的　C　函数或者是链接该库的数据库客户程序访问．Postgres　提供一套过程支持对大对象的打开，读，写，关闭和搜索。　
创建大对象
过程　
Oid　lo_creat(PGconn　*conn,　int　mode)
创建一个新的大对象．mode　是一个位掩码，描述新对象的不同属性．这里列出的符号常量在　$PGROOT/src/backend/libpq/libpq-fs.h．访问类型（读，写或者两者）是对位　INV_READ　和　INV_WRITE进行　OR　（或）操作构成的．如果大对象应被归档--也就是说，如果因历史原因它应该被周期地移到一个特殊的归档关系（表）中--那么就要设置　INV_ARCHIVE　位．掩码的低十六位是大对象要存放于内的存储管理器号．对于除　Berkeley　（伯克利）以外的节点，这些位都应总是零．下面的命令创建一个（倒转的）大对象：　
inv_oid　=　lo_creat(INV_READ|INV_WRITE|INV_ARCHIVE);
输入大对象
要把一个　UNIX　文件输入成为大对象，调用　
Oid　lo_import(PGconn　*conn,　const　char　*filename)
filename　参数指明要被输入成为大对象的　UNIX　文件路径名．　
输出大对象
要把一个大对象输出为　UNIX　文件，调用　
int　lo_export(PGconn　*conn,　Oid　lobjId,　const　char　*filename)
lobjId　参数指明要输出的大对象　Oid，filename　参数指明　UNIX　文件的路径名．
打开一个现有的大对象
要打开一个现存的大对象，调用　
int　lo_open(PGconn　*conn,　Oid　lobjId,　int　mode)
参数　lobjId　指明要打开的大对象的　Oid　（对象标识）．mode　位控制该对象是用于读（INV_READ），写还是读写．一个大对象在其创建之前不能被打开．lo_open　返回一个大对象标识用于以后的　lo_read，lo_write，lo_lseek，lo_tell，and　lo_close。
向大对象中写数据
过程　
int　lo_write(PGconn　*conn,　int　fd,　const　char　*buf,　size_t　len)
从　buf　中向大对象　fd　中写　len　字节．参数　fd　必须是前面一个　lo_open　的返回．返回实际写的字节数．出错时返回负数．
从大对象中读取数据
过程　
int　lo_read(PGconn　*conn,　int　fd,　char　*buf,　size_t　len)
从大对象中读取　len　字节数据到　buf　中。fd　参数必须是前面的一个　lo_open　调用的返回。返回实际读取的字节数。出错时，返回一个负数。
对大对象中数据的查找
要改变当前大对象的读或写位置，调用　
int　lo_lseek(PGconn　*conn,　int　fd,　int　offset,　int　whence)
这个过程把当前　fd　代表的大对象位置指针移动到　offset　指明的新的位置．参数　whence　的合法的取值是　SEEK_SET　SEEK_CUR　和　SEEK_END．
关闭一个大对象描述符
可以通过调用　
int　lo_close(PGconn　*conn,　int　fd)
关闭一个大对象，这里　fd　是　lo_open　返回的大对象的描述符．成功时，lo_close　返回零．错误时，返回值是负数．

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

内建的已注册函数
有两个内建的已注册函数，lo_import　和　lo_export　可以很方便的在　SQL　查询里面使用．下面是一些例子　
CREATE　TABLE　image　(
　　　　name　　　　　　　　　　　　text,
　　　　raster　　　　　　　　　　oid
);

INSERT　INTO　image　(name,　raster)
　　　　VALUES　('beautiful　image',　lo_import('/etc/motd'));

SELECT　lo_export(image.raster,　'/tmp/motd')　from　image
　　　　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　=　'X';
　　　　buf　=　'　';

　　　　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)　{
　　　　　　　　　fprintf(stderr,"error　while　writing　%s/n",
　　　　　　　　　　　　　　filename);
　　　　　}
　　　　}

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

　　　　return;
}

void
exit_nicely(PGconn*　conn)
{
　　PQfinish(conn);
　　exit(1);
}

int
main(int　argc,　char　**argv)
{
　　　　char　*in_filename,　*out_filename;
　　　　char　*database;
　　　　Oid　lobjOid;
　　　　PGconn　*conn;
　　　　PGresult　*res;

　　　　if　(argc　!=　4)　{
　　　　　fprintf(stderr,　"Usage:　%s　database_name　in_filename　out_filename/n",
　　　　　　　　　　argv[0]);
　　　　　exit(1);
　　　　}

　　　　database　=　argv[1];
　　　　in_filename　=　argv[2];
　　　　out_filename　=　argv[3];

　　　　/*
　　　　　*　set　up　the　connection
　　　　　*/
　　　　conn　=　PQsetdb(NULL,　NULL,　NULL,　NULL,　database);

　　　　/*　check　to　see　that　the　backend　connection　was　successfully　made　*/
　　　　if　(PQstatus(conn)　==　CONNECTION_BAD)　{
　　　　　fprintf(stderr,"Connection　to　database　'%s'　failed./n",　database);
　　　　　fprintf(stderr,"%s",PQerrorMessage(conn));
　　　　　exit_nicely(conn);
　　　　}

　　　　res　=　PQexec(conn,　"begin");
　　　　PQclear(res);

　　　　printf("importing　file　%s/n",　in_filename);
/*　　lobjOid　=　importFile(conn,　in_filename);　*/
　　　　lobjOid　=　lo_import(conn,　in_filename);
/*
　　　　printf("as　large　object　%d./n",　lobjOid);

　　　　printf("picking　out　bytes　1000-2000　of　the　large　object/n");
　　　　pickout(conn,　lobjOid,　1000,　1000);

　　　　printf("overwriting　bytes　1000-2000　of　the　large　object　with　X's/n");
　　　　overwrite(conn,　lobjOid,　1000,　1000);
*/

　　　　printf("exporting　large　object　to　file　%s/n",　out_filename);
/*　　　　exportFile(conn,　lobjOid,　out_filename);　*/
　　　　lo_export(conn,　lobjOid,out_filename);

　　　　res　=　PQexec(conn,　"end");
　　　　PQclear(res);
　　　　PQfinish(conn);
　　　　exit(0);
}

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



发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表
学习交流
更多

浅谈数码相机照片发灰的问题

前几天，化名“夭”的朋友在摄影论坛发帖，反映用数码机拍摄的照...
热门图片
更多
猜你喜欢的新闻
猜你喜欢的关注

新闻热点

滴滴英文服务上线两周年 用户已超200万
2019-09-26 08:57:12
华为推出全球至快AI训练集群Atlas900
2019-09-25 08:46:36
马斯克：特斯拉正组建中国技术团队
2019-09-25 08:15:43
10年后6G将问世 速度有望比5G快100倍
2019-09-25 08:12:18
WeworkCEO称已开始考虑未来职位 不排除放弃CEO一职
2019-09-24 08:22:58
谷歌软件商店模式变革：推出5美元会员 可用数百个软件
2019-09-24 08:07:08

疑难解答

图片精选

网友关注

关于本站 - 网上投稿 - 商务合作 - 隐私政策 - 网站地图
Copyright © 2008 - 2019 VEVB.COM. All Rights Reserved.武林网 版权所有