第一步 实现函数
增加的函数都放在src/backend/utils目录下,我要实现的函数是从服务器查询,并返回给调用者。 char * sys_test(const uint32 id, const uint32 age) 开发者需要根据自己的需要,选择目录和文件: 我需要实现的功能在现有的文件中不存在相关性,我在adt目录下自己创建了一个文件:test.c,文件内容如下: #include "postgres.h" #include <sys/file.h> #include <sys/stat.h> #include <unistd.h> #include <dirent.h> #include "access/heapam.h" #include "catalog/pg_type.h" #include "funcapi.h" #include "miscadmin.h" #include "postmaster/syslogger.h" #include "storage/fd.h" #include "utils/builtins.h" /* * Read a page, returning it as binary */ Datum sys_test(PG_FUNCTION_ARGS) { uint32 id = PG_GETARG_INT32(0); uint32 age = PG_GETARG_INT32(1); printf("111111111111111111111\n"); strcpy(buf, "xxxxxxxxxxxxxxxxxx"); SET_VARSIZE(buf, nbytes + VARHDRSZ); PG_RETURN_TEXT_P(buf); }
实际功能还需要实现,我就打个样。 如果你实现的函数,在现有的文件中实现,就不需要修改Makefile。 第二步 支持外部访问
打开文件:src/include/utils/builtins.h,在文件尾部增加自己的函数。 第三步 注册到名字空间打开:src/include/catalog/pg_proc.h,找一个合适的位置增加自己的函数定义: DATA(insert OID = 13624 ( sys_test PGNSP 0 PGUID 12 t f f f t f v 2 17 17 i f i f f "23 23" _null_ _null_ _null_ _null_ _null_ _null_ sys_read_page 2D _null_ )); DESCR("sys_test"); 其中的OID,不可重复,自己YY。
第四步 编译和验证函数可用重新编译代码,使其修改重新编译。 make && make install 这种函数如果修改了pg_proc.h就必须要重新初始化数据库,不然不会生效: ./initdb ../data 在bin目录下启动服务进程: ./postgres 使用isql连接服务器: ./psql postgres 查询函数定义: postgres-# \df+ SYS_TEST 功能列表 Schema | Name | Result data type | Argument data types | Owner | Language | Source code | Description -------------+---------------+------------------+----------------------+--------+----------+---------------+------------- SYS_CATALOG | SYS_TEST | BYTEA | TEXT, BIGINT, BIGINT | SYSTEM | INTERNAL | sys_test | 我们仔细看,函数参数“TEXT, BIGINT, BIGINT”,其实是错误的,与我们的函数定义: char * sys_test(const uint32 id, const uint32 age)
是不一样的,参数列表错误,下面我们要找到原因,并修改。 在pg_proc.h中插入的记录是什么含义?
"25 20 20" 改为 “23 23”, 23表示int4,继续往下看,有说明。
TEST=# select oid,typname from pg_type where oid in (1082,23,1114,1184,17,25); OID | TYPNAME ------+------------- 17 | BYTEA 23 | INT4 25 | TEXT 1082 | DATE 1114 | TIMESTAMP 1184 | TIMESTAMPTZ
我们再次来看看,是不是都对了 postgres=# \df sys_test 功能列表 Schema | Name | Result data type | Argument data types -------------+---------------+------------------+--------------------- SYS_CATALOG | SYS_TEST | BYTEA | INTEGER, INTEGER 第五步 调用函数postgres=# select SYS_TEST(1,2); 其他可用输出参数: 信息报告 \d [NAME] 描述表, 索引, 序列, 或者视图 \d{t|i|s|v|S} [PATTERN] (附加 "+" 获取更多信息) 列出表/索引/序列/视图/系统表 \da [PATTERN] 列出聚集函数 \db [PATTERN] 列出表空间(附加 "+" 获取更多信息) \dc [PATTERN] 列出编码转换 \dC 列出定义的转换 \dd [PATTERN] 列出对象的注释 \dD [PATTERN] 列出域 \df [PATTERN] 列出函数(附加 "+" 获得更多信息) \dF [PATTERN] 列出全文搜索配置(附加 "+" 获得更多信息) \dFd [PATTERN] 列出全文搜索词典(附加 "+" 获得更多信息) \dFt [PATTERN] 列出全文搜索模板 \dFp [PATTERN] 列出全文搜索分析器(附加 "+" 获得更多信息) \dm[S+] [PATTERN] list materialized views \dn [PATTERN] 列出模式(附加 "+" 获得更多信息) \do [NAME] 列出操作符 \dp [PATTERN] 列出表, 视图, 及序列的访问权限 \dP [PATTERN] 列出包(附加 "+" 获得更多信息) \dr [PATTERN] 列出角色 \dT [PATTERN] 列出数据类型(附加 "+" 获得更多信息) \du [PATTERN] 列出用户 \l 列出所有数据库(附加 "+" 获得更多信息) \ll [PATTERN] 列出锁 \llc 列出锁总数 \lx 列出xid最大值 \lredolog 列出当前的重做日志 \lc [PATTERN] 列出所有连接 \lac [PATTERN] 列出活动连接 \lfc [PATTERN] 列出空闲连接 \lwc [PATTERN] 列出等待连接 \lmc 列出最大连接数 \lstatdb [PATTERN] 列出数据库统计信息 \lstatidx [PATTERN] 列出索引统计信息 \lstatseq [PATTERN] 列出序列统计信息 \lstattable [PATTERN] 列出表格统计信息 (责任编辑:IT) |