从 PL/Perl 里访问数据库-服务器专区

从 PL/Perl 里访问数据库

作者：网络　佚名编辑： IT168 2005-09-21 00:00

【IT168 服务器学院】从你的 Perl 函数里访问数据库本身可以通过下面描述的 spi_exec_query 或者一个试验模块 DBD::PgSPI （也可以在 CPAN 镜像站获取）。这个模块让用户可以使用一个DBI兼容的叫 $pg_dbh 的数据库句柄，用户可以用它以普通的 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);

它从 my_table 里返回最多 5 行。如果 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 控制的。

关注我们