37.2. 从 PL/Perl 访问数据库 — PostgreSQL 8.0

已结束支持的版本： 8.4 / 8.3 / 8.2 / 8.1 / 8.0 / 7.4 / 7.3

历史版本。 PostgreSQL 8.0 已结束支持。请参阅当前版本手册.

37.2. 从 PL/Perl 访问数据库
上一页	上一级	第 37 章 PL/Perl - Perl 过程语言	起始页	下一页

37.2. 从 PL/Perl 访问数据库 #

在 Perl 函数中访问数据库本身，可以通过下文描述的函数 spi_exec_query，也可以通过一个实验性模块 DBD::PgSPI（也可以从 CPAN 镜像站点获取）。该模块提供了一个名为 $pg_dbh 的、符合 DBI 的数据库句柄，可用普通的 DBI 语法执行查询。

PL/Perl 本身目前提供两个附加的 Perl 命令：

spi_exec_query(query [, max-rows]) spi_exec_query(command)

执行一条 SQL 命令。下面是一个查询（SELECT 命令）的示例，指定了可选的最大行数：

$rv = spi_exec_query('SELECT * FROM my_table', 5);

这会返回最多 5 行，来自表 my_table。如果 my_table 包含列 my_column，就可以取得结果中第 $i 行的该列值，方法如下：

$foo = $rv->{rows}[$i]->{my_column};

要取得 SELECT 查询返回的总行数，可以这样做：

$nrows = $rv->{processed}

下面是使用另一种命令类型的示例：

$query = "INSERT INTO my_table VALUES (1, 'test')";
$rv = spi_exec_query($query);

可以这样访问命令状态（例如 SPI_OK_INSERT）：

$res = $rv->{status};

要获取受影响的行数，可使用：

$nrows = $rv->{processed};

这里是一个完整的示例：

CREATE TABLE test (
    i int,
    v varchar
);

INSERT INTO test (i, v) VALUES (1, 'first line');
INSERT INTO test (i, v) VALUES (2, 'second line');
INSERT INTO test (i, v) VALUES (3, 'third line');
INSERT INTO test (i, v) VALUES (4, 'immortal');

CREATE FUNCTION test_munge() RETURNS SETOF test AS $$
    my $res = [];
    my $rv = spi_exec_query('select i, v from test;');
    my $status = $rv->{status};
    my $nrows = $rv->{processed};
    foreach my $rn (0 .. $nrows - 1) {
        my $row = $rv->{rows}[$rn];
        $row->{i} += 200 if defined($row->{i});
        $row->{v} =~ tr/A-Za-z/a-zA-Z/ if (defined($row->{v}));
        push @$res, $row;
    }
    return $res;
$$ LANGUAGE plperl;

SELECT * FROM test_munge();

elog(level, msg)

发出日志消息或错误信息。可用级别包括 DEBUG、LOG、INFO、NOTICE、WARNING以及ERROR。ERROR 会引发错误条件；如果周围的 Perl 代码没有捕获它，错误就会传播到调用查询，导致当前事务或子事务被中止。这实质上等同于 Perl 的 die 命令。其他级别只会生成不同优先级的消息。某一优先级的消息是报告给客户端、写入服务器日志，还是两者兼有，由配置变量log_min_messages和client_min_messages控制。详见第 16.4 节。

上一页	上一级	下一页
第 37 章 PL/Perl - Perl 过程语言	起始页	37.3. PL/Perl 中的数据值

报告文档问题

阅读上游文档. 反馈更正前请先核对当前版本手册.