我们专注攀枝花网站设计 攀枝花网站制作 攀枝花网站建设
成都网站建设公司服务热线:400-028-6601

网站建设知识

十年网站开发经验 + 多家企业客户 + 靠谱的建站团队

量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决

包含postgresql说明的词条

postgresql中使用if else语句

1、首先在postgresql数据库中复制表的时候,必须先建立表结构,然后通过insert into语句来实现。

十余年的陆河网站建设经验,针对设计、前端、开发、售后、文案、推广等六对一服务,响应快,48小时及时工作处理。营销型网站建设的优势是能够根据用户设备显示端的尺寸不同,自动调整陆河建站的显示方式,使网站能够适用不同显示终端,在浏览器中调整网站的宽度,无论在任何一种浏览器上浏览网站,都能展现优雅布局与设计,从而大程度地提升浏览体验。创新互联从事“陆河网站设计”,“陆河网站推广”以来,每个客户项目都认真落实执行。

2、如果在复制数据之前没有建立相应的表结构,如下图中的错误信息。

3、在查询数据的时候也可以把两个表联合起来进行查询,通过union关键字来进行查询,如下图。

4、如果在使用union进行查询的进修,两条结果一样人被合并成一条。

5、如果想显示联合查询中相同的语句,可以使用union all来进行查询。

如何学习PostgreSQL SQL语法

我们可以利用psql命令来查询sql语法。

切换到PostgreSql用户下,

[sql] view plain copy

span style="font-size:18px;"[doctor@localhost ~]$ su - postgres

密码:

su: 鉴定故障

[doctor@localhost ~]$ su - postgres

密码:

-bash-4.3$ bash

bash-4.3$ psql

psql (9.4.2)

输入 "help" 来获取帮助信息.

postgres=#

postgres=# help

您正在使用psql, 这是一种用于访问PostgreSQL的命令行界面

键入: \copyright 显示发行条款

\h 显示 SQL 命令的说明

\? 显示 pgsql 命令的说明

\g 或者以分号(;)结尾以执行查询

\q 退出

postgres=#

/span

\h 命令就是我们用来学习sql语法的命令。

[sql] view plain copy

span style="font-size:18px;"postgres=# \h

可用的说明:

ABORT DEALLOCATE

ALTER AGGREGATE DECLARE

ALTER COLLATION DELETE

ALTER CONVERSION DISCARD

ALTER DATABASE DO

ALTER DEFAULT PRIVILEGES DROP AGGREGATE

ALTER DOMAIN DROP CAST

ALTER EVENT TRIGGER DROP COLLATION

ALTER EXTENSION DROP CONVERSION

ALTER FOREIGN DATA WRAPPER DROP DATABASE

ALTER FOREIGN TABLE DROP DOMAIN

ALTER FUNCTION DROP EVENT TRIGGER

ALTER GROUP DROP EXTENSION

ALTER INDEX DROP FOREIGN DATA WRAPPER

ALTER LANGUAGE DROP FOREIGN TABLE

ALTER LARGE OBJECT DROP FUNCTION

ALTER MATERIALIZED VIEW DROP GROUP

ALTER OPERATOR DROP INDEX

ALTER OPERATOR CLASS DROP LANGUAGE

ALTER OPERATOR FAMILY DROP MATERIALIZED VIEW

ALTER ROLE DROP OPERATOR

ALTER RULE DROP OPERATOR CLASS

postgres=# \h select

命令: SELECT

描述: 从资料表或视观表读取资料

语法:

[ WITH [ RECURSIVE ] with查询语句(with_query) [, ...] ]

SELECT [ ALL | DISTINCT [ ON ( 表达式 [, ...] ) ] ]

[ * | 表达式 [ [ AS ] 输出名称 ] [, ...] ]

[ FROM from列表中项 [, ...] ]

[ WHERE 条件 ]

[ GROUP BY 表达式 [, ...] ]

[ HAVING 条件 [, ...] ]

[ WINDOW 窗口名称 AS ( 窗口定义 ) [, ...] ]

[ { UNION | INTERSECT | EXCEPT } [ ALL | DISTINCT ] 查询 ]

[ ORDER BY 表达式 [ ASC | DESC | USING 运算子 ] [ NULLS { FIRST | LAST } ] [

, ...] ]

[ LIMIT { 查询所用返回记录的最大数量 | ALL } ]

[ OFFSET 起始值 [ ROW | ROWS ] ]

[ FETCH { FIRST | NEXT } [ 查询所用返回记录的最大数量 ] { ROW | ROWS } ONLY

]

[ FOR { UPDATE | NO KEY UPDATE | SHARE | KEY SHARE } [ OF 表名 [, ...] ] [ N

OWAIT ] [...] ]

from 列表中的项可以是下列内容之一

[ ONLY ] 表名 [ * ] [ [ AS ] 化名 [ ( 列的化名 [, ...] ) ] ]

[ LATERAL ] ( 查询 ) [ AS ] 化名 [ ( 列的化名 [, ...] ) ]

WITH查询语句名称(with_query_name) [ [ AS ] 化名 [ ( 列的化名 [, ...] ) ] ]

[ LATERAL ] 函数名称 ( [ 参数 [, ...] ] )

[ WITH ORDINALITY ] [ [ AS ] 化名 [ ( 列的化名 [, ...] ) ] ]

[ LATERAL ] 函数名称 ( [ 参数 [, ...] ] ) [ AS ] 化名 ( 列定义 [, ...] )

[ LATERAL ] 函数名称 ( [ 参数 [, ...] ] ) AS ( 列定义 [, ...] )

[ LATERAL ] ROWS FROM( 函数名称 ( [ 参数 [, ...] ] ) [ AS ( 列定义 [, ...] )

] [, ...] )

[ WITH ORDINALITY ] [ [ AS ] 化名 [ ( 列的化名 [, ...] ) ] ]

from列表中项 [ NATURAL ] 连接操作的类型 from列表中项 [ ON 用连接操作的条件 |

USING ( 用于连接操作的列 [, ...] ) ]

with查询语句是:

WITH查询语句名称(with_query_name) [ ( 列名称 [, ...] ) ] AS ( 查询 | 值 | in

sert | update | delete )

TABLE [ ONLY ] 表名 [ * ]

postgres=# /span

看这命令对于学习sql语法很有用。

如何设置PostgreSQL允许被远程访问

postgresql默认情况下,远程访问不能成功,如果需要允许远程访问,需要修改两个配置文件,说明如下:

1.postgresql.conf

将该文件中的listen_addresses项值设定为“*”,在9.0 Windows版中,该项配置已经是“*”无需修改。

2.pg_hba.conf

在该配置文件的host all all 127.0.0.1/32 md5行下添加以下配置,或者直接将这一行修改为以下配置

host all all 0.0.0.0/0 md5

如果不希望允许所有IP远程访问,则可以将上述配置项中的0.0.0.0设定为特定的IP值。

postgresql 建立索引

一、索引的类型:

PostgreSQL提供了多种索引类型:B-Tree、Hash、GiST和GIN,由于它们使用了不同的算法,因此每种索引类型都有其适合的查询类型,缺省时,CREATE INDEX命令将创建B-Tree索引。

1. B-Tree:

CREATE TABLE test1 (

id integer,

content varchar

);

CREATE INDEX test1_id_index ON test1 (id);

B-Tree索引主要用于等于和范围查询,特别是当索引列包含操作符" 、=和"作为查询条件时,PostgreSQL的查询规划器都会考虑使用B-Tree索引。在使用BETWEEN、IN、IS NULL和IS NOT NULL的查询中,PostgreSQL也可以使用B-Tree索引。然而对于基于模式匹配操作符的查询,如LIKE、ILIKE、~和 ~*,仅当模式存在一个常量,且该常量位于模式字符串的开头时,如col LIKE 'foo%'或col ~ '^foo',索引才会生效,否则将会执行全表扫描,如:col LIKE '%bar'。

2. Hash:

CREATE INDEX name ON table USING hash (column);

散列(Hash)索引只能处理简单的等于比较。当索引列使用等于操作符进行比较时,查询规划器会考虑使用散列索引。

这里需要额外说明的是,PostgreSQL散列索引的性能不比B-Tree索引强,但是散列索引的尺寸和构造时间则更差。另外,由于散列索引操作目前没有记录WAL日志,因此一旦发生了数据库崩溃,我们将不得不用REINDEX重建散列索引。

3. GiST:

GiST索引不是一种单独的索引类型,而是一种架构,可以在该架构上实现很多不同的索引策略。从而可以使GiST索引根据不同的索引策略,而使用特定的操作符类型。

4. GIN:

GIN索引是反转索引,它可以处理包含多个键的值(比如数组)。与GiST类似,GIN同样支持用户定义的索引策略,从而可以使GIN索引根据不同的索引策略,而使用特定的操作符类型。作为示例,PostgreSQL的标准发布中包含了用于一维数组的GIN操作符类型,如:、=、等。

二、复合索引:

PostgreSQL中的索引可以定义在数据表的多个字段上,如:

CREATE TABLE test2 (

major int,

minor int,

name varchar

}

CREATE INDEX test2_mm_idx ON test2 (major, minor);

1. B-Tree类型的复合索引:

在B-Tree类型的复合索引中,该索引字段的任意子集均可用于查询条件,不过,只有当复合索引中的第一个索引字段(最左边)被包含其中时,才可以获得最高效率。

2. GiST类型的复合索引:

在GiST类型的复合索引中,只有当第一个索引字段被包含在查询条件中时,才能决定该查询会扫描多少索引数据,而其他索引字段上的条件只是会限制索引返回的条目。假如第一个索引字段上的大多数数据都有相同的键值,那么此时应用GiST索引就会比较低效。

3. GIN类型的复合索引:

与B-Tree和GiST索引不同的是,GIN复合索引不会受到查询条件中使用了哪些索引字段子集的影响,无论是哪种组合,都会得到相同的效率。

使用复合索引应该谨慎。在大多数情况下,单一字段上的索引就已经足够了,并且还节约时间和空间。除非表的使用模式非常固定,否则超过三个字段的索引几乎没什么用处。

三、组合多个索引:

PostgreSQL可以在查询时组合多个索引(包括同一索引的多次使用),来处理单个索引扫描不能实现的场合。与此同时,系统还可以在多个索引扫描之间组成AND和OR的条件。比如,一个类似WHERE x = 42 OR x = 47 OR x = 53 OR x = 99的查询,可以被分解成四个独立的基于x字段索引的扫描,每个扫描使用一个查询子句,之后再将这些扫描结果OR在一起并生成最终的结果。另外一个例子是,如果我们在x和y上分别存在独立的索引,那么一个类似WHERE x = 5 AND y = 6的查询,就会分别基于这两个字段的索引进行扫描,之后再将各自扫描的结果进行AND操作并生成最终的结果行。

为了组合多个索引,系统扫描每个需要的索引,然后在内存里组织一个BITMAP,它将给出索引扫描出的数据在数据表中的物理位置。然后,再根据查询的需要,把这些位图进行AND或者OR的操作并得出最终的BITMAP。最后,检索数据表并返回数据行。表的数据行是按照物理顺序进行访问的,因为这是位图的布局,这就意味着任何原来的索引的排序都将消失。如果查询中有ORDER BY子句,那么还将会有一个额外的排序步骤。因为这个原因,以及每个额外的索引扫描都会增加额外的时间,这样规划器有时候就会选择使用简单的索引扫描,即使有多个索引可用也会如此。

四、唯一索引:

CREATE UNIQUE INDEX name ON table (column [, ...]);

五、表达式索引:

表达式索引主要用于在查询条件中存在基于某个字段的函数或表达式的结果与其他值进行比较的情况,如:

SELECT * FROM test1 WHERE lower(col1) = 'value';

此时,如果我们仅仅是在col1字段上建立索引,那么该查询在执行时一定不会使用该索引,而是直接进行全表扫描。如果该表的数据量较大,那么执行该查询也将会需要很长时间。解决该问题的办法非常简单,在test1表上建立基于col1字段的表达式索引,如:

CREATE INDEX test1_lower_col1_idx ON test1 (lower(col1));

SELECT * FROM people WHERE (first_name || ' ' || last_name) = 'John Smith';

和上面的例子一样,尽管我们可能会为first_name和last_name分别创建独立索引,或者是基于这两个字段的复合索引,在执行该查询语句时,这些索引均不会被使用,该查询能够使用的索引只有我们下面创建的表达式索引。

CREATE INDEX people_names ON people ((first_name || ' ' || last_name));

CREATE INDEX命令的语法通常要求在索引表达式周围书写圆括弧,就像我们在第二个例子里显示的那样。如果表达式只是一个函数调用,那么可以省略,就像我们在第一个例子里显示的那样。

从索引维护的角度来看,索引表达式要相对低效一些,因为在插入数据或者更新数据的时候,都必须为该行计算表达式的结果,并将该结果直接存储到索引里。然而在查询时,PostgreSQL就会把它们看做WHERE idxcol = 'constant',因此搜索的速度等效于基于简单索引的查询。通常而言,我们只是应该在检索速度比插入和更新速度更重要的场景下使用表达式索引。

六、部分索引:

部分索引(partial index)是建立在一个表的子集上的索引,而该子集是由一个条件表达式定义的(叫做部分索引的谓词)。该索引只包含表中那些满足这个谓词的行。

由于不是在所有的情况下都需要更新索引,因此部分索引会提高数据插入和数据更新的效率。然而又因为部分索引比普通索引要小,因此可以更好的提高确实需要索引部分的查询效率。见以下三个示例:

1. 索引字段和谓词条件字段一致:

CREATE INDEX access_log_client_ip_ix ON access_log(client_ip)

WHERE NOT (client_ip inet '192.168.100.0' AND client_ip inet '192.168.100.255');

下面的查询将会用到该部分索引:

SELECT * FROM access_log WHERE url = '/index.html' AND client_ip = inet '212.78.10.32';

下面的查询将不会用该部分索引:

一个不能使用这个索引的查询可以是

SELECT * FROM access_log WHERE client_ip = inet '192.168.100.23';

2. 索引字段和谓词条件字段不一致:

PostgreSQL支持带任意谓词的部分索引,唯一的约束是谓词的字段也要来自于同样的数据表。注意,如果你希望你的查询语句能够用到部分索引,那么就要求该查询语句的条件部分必须和部分索引的谓词完全匹配。 准确说,只有在PostgreSQL能够识别出该查询的WHERE条件在数学上涵盖了该索引的谓词时,这个部分索引才能被用于该查询。

CREATE INDEX orders_unbilled_index ON orders(order_nr) WHERE billed is not true;

下面的查询一定会用到该部分索引:

SELECT * FROM orders WHERE billed is not true AND order_nr 10000;

那么对于如下查询呢?

SELECT * FROM orders WHERE billed is not true AND amount 5000.00;

这个查询将不像上面那个查询这么高效,毕竟查询的条件语句中没有用到索引字段,然而查询条件"billed is not true"却和部分索引的谓词完全匹配,因此PostgreSQL将扫描整个索引。这样只有在索引数据相对较少的情况下,该查询才能更有效一些。

下面的查询将不会用到部分索引。

SELECT * FROM orders WHERE order_nr = 3501;

3. 数据表子集的唯一性约束:

CREATE TABLE tests (

subject text,

target text,

success boolean,

...

);

CREATE UNIQUE INDEX tests_success_constraint ON tests(subject, target) WHERE success;

该部分索引将只会对success字段值为true的数据进行唯一性约束。在实际的应用中,如果成功的数据较少,而不成功的数据较多时,该实现方法将会非常高效。

七、检查索引的使用:

见以下四条建议:

1. 总是先运行ANALYZE。

该命令将会收集表中数值分布状况的统计。在估算一个查询返回的行数时需要这个信息,而规划器则需要这个行数以便给每个可能的查询规划赋予真实的开销值。如果缺乏任何真实的统计信息,那么就会使用一些缺省数值,这样肯定是不准确的。因此,如果还没有运行ANALYZE就检查一个索引的使用状况,那将会是一次失败的检查。

2. 使用真实的数据做实验。

用测试数据填充数据表,那么该表的索引将只会基于测试数据来评估该如何使用索引,而不是对所有的数据都如此使用。比如从100000行中选1000行,规划器可能会考虑使用索引,那么如果从100行中选1行就很难说也会使用索引了。因为100行的数据很可能是存储在一个磁盘页面中,然而没有任何查询规划能比通过顺序访问一个磁盘页面更加高效了。与此同时,在模拟测试数据时也要注意,如果这些数据是非常相似的数据、完全随机的数据,或按照排序顺序插入的数据,都会令统计信息偏离实际数据应该具有的特征。

3. 如果索引没有得到使用,那么在测试中强制它的使用也许会有些价值。有一些运行时参数可以关闭各种各样的查询规划。

4. 强制使用索引用法将会导致两种可能:一是系统选择是正确的,使用索引实际上并不合适,二是查询计划的开销计算并不能反映现实情况。这样你就应该对使用和不使用索引的查询进行计时,这个时候EXPLAIN ANALYZE命令就很有用了。

postgresql里边的数组怎么操作

1. 数组可以作为字段类型

PostgreSQL中数据是一种基本的数据类型,可以作为字段的类型定义。例如,

CREATE TABLE ads.tb_mo_item

(

mo_key integer NOT NULL,

input_flow integer[] NOT NULL DEFAULT ARRAY[]::integer[] 

);

2. 可以用array[]来初始化一个数组

select array[1, 3, 4]::int[];

3. 操作数组有一系列函数, 可以实现数组比较,添加新元素,一般数组是否包含另一数组的判断,等等。具体参考PostgreSQL说明文档中函数和操作符中有关Array的部分。

操作符有: =, , , , =, =, @, @, , ||

函数有: array_append, array_cat, array_ndims, array_dims, array_fill, array_length, array_lower, array_remove, array_replace, array_to_string, array_upper, string_to_array, unnest等.

其中,常用的是: array_append,  array_length, unnest

4. 使用数组下标获得数组的元素,下标是从1开始的

select (array[1, 3, 4]::int[])[2];

5. 可以用unnest将数组转换成一个结果集,个人觉得这个很有用处

select a.a from unnest(array[1, 3, 4]::int[]) a;

postgreSQL触发器

PostgreSQL 提供按行与按语句触发的触发器。按行触发的触发器函数为触发语句影响的每一行执行一次;按语句触发的触发器函数为每条触发语句执行一次,而不管影响的行数。特别是,一个影响零行的语句将仍然导致按语句触发的触发器执行。这两种类型的触发器有时候分别叫做行级触发器和语句级触发器。触发器还通常分成 before 触发器和 after 触发器。语句级别的"before"触发器通常在语句开始做任何事情之前触发,而语句级别的"after"触发器在语句结束时触发。行级别的"before"触发器在对特定行进行操作之前触发,而行级别的"after"触发器在语句结束的时候触发(但是在任何语句级别的"after"触发器之前)。

一个触发器是一种声明,告诉数据库应该在执行特定的操作的时候执行特定的函数。触发器可以定义在一个 INSERT, UPDATE, DELETE 命令之前或者之后执行,要么是对每行执行一次,要么是对每条 SQL 语句执行一次。如果发生触发器事件,那么将在合适的时刻调用触发器函数以处理该事件。触发器函数必须在创建触发器之前,作为一个没有参数并且返回 trigger 类型的函数定义。触发器函数通过特殊的 TriggerData 结构接收其输入,而不是用普通的函数参数方式.

注意:

一.按语句触发的触发器应该总是返回 NULL.

二.如果必要,按行触发的触发器函数可以给调用它的执行者返回一行数据(一个类型为 HeapTuple 的数值),那些在操作之前触发的触发器有以下选择

1. 它可以返回 NULL 以忽略对当前行的操作。这就指示执行器不要执行调用该触

发器的行级别操作(对特定行的插入或者更改)。

2.只用于 INSERT 和 UPDATE 行触发器:返回的行将成为被插入的行或者是成为

将要更新的行。这样就允许触发器函数修改将要被插入或者更新的行。

一个无意导致任何这类行为的在操作之前触发的行级触发器必须仔细返回那个被当作新行传进来的行。也就是说,对于 INSERT 和 UPDATE 触发器而言,是 NEW 行,对于 DELETE触发器而言,是 OLD 行。

三. 对于在操作之后触发的行级触发器,其返回值会被忽略,因此可以回NULL。

下面通过具体的例子来说明在postgresql中触发器的建立和使用(老规矩先写代码然后讲解)

#include postgres.h

#include executor/spi.h

#include funcapi.h

#include commands/trigger.h

#include fmgr.h

extern Datum pg_trigf(PG_FUNCTION_ARGS);

#ifdef PG_MODULE_MAGIC

PG_MODULE_MAGIC;

#endif

PG_FUNCTION_INFO_V1(pg_trigf);

Datum

pg_trigf(PG_FUNCTION_ARGS)

{

TriggerData *trigdata = (TriggerData *)fcinfo-context;

HeapTuple rettuple = NULL;

int ret;

int proc; /* to store the value of SPI_processed (actual row number)*/

/* to be sure this function will be called by trigger */

if (!(CALLED_AS_TRIGGER(fcinfo))) {

elog(ERROR, "trigf: not called by triggermanager");

}

/* should be fired by statement */

if (TRIGGER_FIRED_FOR_ROW(trigdata-tg_event)) {

elog(ERROR, "cannot process row events");

}

/* should be fired before event */

if (TRIGGER_FIRED_AFTER(trigdata-tg_event)) {

elog(ERROR, "must be fired before event");

}

/* connect spi manager */

if ((ret = SPI_connect()) 0) {

elog(INFO, "SPI_connect failed: SPI_connectreturned: %d", ret);

return PointerGetDatum(rettuple);

}

/* check the permanent table name(perm_user) existsor not*/

ret = SPI_exec("SELECT tablename FROM pg_tables WHERE tablename LIKE'perm!_user' ESCAPE '!';", 1);

proc = SPI_processed;

if (ret != SPI_OK_SELECT) {

elog(INFO, "SPI_exec execute error: user table.");

SPI_finish();

return PointerGetDatum(rettuple);

}

/* create the permanent table(perm_user) if it does not exist */

if (proc 1) {

/* create permanent table: perm_user */

ret = SPI_exec("CREATE TABLE perm_user ASSELECT * FROM tbl_user;", 0);

if (ret != SPI_OK_SELINTO ) {

elog(INFO, "SPI_execexecute error: fail to create perm_user");

SPI_finish();

returnPointerGetDatum(rettuple);

}

/* set attribute to perm_user */

ret = SPI_exec("ALTER TABLE perm_user ADD PRIMARYKEY (user_name);", 0);

if (ret != SPI_OK_SELINTO) {

elog(INFO, "SPI_execexecute error: fail to add primary key to perm_user");

SPI_finish();

returnPointerGetDatum(rettuple);

}

/* set attribute to perm_user*/

ret = SPI_exec("ALTER TABLE perm_user ALTERuser_passwd SET NOT NULL;", 0);

if (ret != SPI_OK_SELINTO) {

elog(INFO, "SPI_execexecute error: fail to set attribute to password.");

SPI_finish();

returnPointerGetDatum(rettuple);

}

}

.....

/* check the permanent table name(perm_member) exists or not */

ret = SPI_exec("SELECT tablename FROM pg_tables WHERE tablename LIKE'perm!_member' ESCAPE '!';", 1);

proc = SPI_processed;

if (ret != SPI_OK_SELECT) {

elog(INFO, "SPI_exec execute errortbl_member");

SPI_finish();

return PointerGetDatum(rettuple);

}

/* create the permanent table(perm_member) if it does not exist */

if (proc 1) {

/* create permanent table: perm_member */

ret = SPI_exec("CREATE TABLE perm_member ASSELECT * FROM tbl_member;", 0);

if (ret != SPI_OK_SELINTO) {

elog(INFO, "SPI_execexecute error");

SPI_finish();

returnPointerGetDatum(rettuple);

}

/* set attribute to perm_member */

ret = SPI_exec("ALTER TABLE perm_member ADDCONSTRAINT user_fk FOREIGN KEY (user_name) REFERENCES perm_user(user_name) ONDELETE CASCADE ON UPDATE CASCADE;", 0);

if (ret != SPI_OK_UTILITY) {

elog(INFO, "SPI_execexecute error: fail to set attribute to user_name.");

SPI_finish();

returnPointerGetDatum(rettuple);

}

/* set attribute to perm_member */

ret = SPI_exec("ALTER TABLE perm_member ADDCONSTRAINT group_fk FOREIGN KEY (grp_name) REFERENCES perm_group(grp_name) ONDELETE CASCADE ON UPDATE CASCADE;", 0);

if (ret != SPI_OK_UTILITY) {

elog(INFO, "SPI_execexecute error: fail to set attribute to grp_name.");

SPI_finish();

return PointerGetDatum(rettuple);

}

/* add primary key to perm_member */

ret = SPI_exec("ALTER TABLE perm_member ADDPRIMARY KEY (user_name, grp_name);", 0);

if (ret != SPI_OK_UTILITY) {

elog(INFO, "SPI_execexecute error: fail to add primary key to perm_member.");

SPI_finish();

returnPointerGetDatum(rettuple);

}

}

/*close connect with SPI manager */

SPI_finish();

/* return back must be NULL*/

return PointerGetDatum(rettuple);

}

这个函数写法与postgresql服务端函数的写法很相似, 但是不完全相同.具体需要注意的地方是:

1. 需要多添加头文件:#include commands/trigger.h

2. 这个函数的返回值一定是trigger类型的.

3. 函数的开始最好确认这个函数是供触发器调用的并且明确一下自己要写的触发器的类型是什么,然后做一下判断,以免别的语句也触发的触发器.

二. 接下来的事情是编译:

gcc -fpic -c trigger.c-I/usr/local/postgreSQL/include/postgresql/server

gcc -shared -o trigger.so trigger.o

如果不明白可以参考手册(说句题外话,手册的作用实在是太大了,在手册中也提供了一例子).

三. 在数据库中创建函数和触发器:

/* create a trigger used to write memory and configmemory */

CREATE OR REPLACE FUNCTION pg_trigf() RETURNS trigger

AS 'filename'

LANGUAGE C IMMUTABLESTRICT;

CREATE TRIGGER tbuser BEFORE INSERT OR UPDATE OR DELETE

ON tbl_user FOR EACH STATEMENT

EXECUTE PROCEDURE pg_trigf();

CREATE TRIGGER tbgroup BEFORE INSERT OR UPDATE OR DELETE

创建的触发器是语句触发器,这个和手册上的不一样, 手册上的是行触发器.

然后在数据库中使用SQL语句就可以看到触发器的效果了.


网站栏目:包含postgresql说明的词条
本文地址:http://mswzjz.cn/article/dsccjdc.html

其他资讯