| PostgreSQL 8.0.0 中文文件(轉譯自 PostgreSQL 中國 製作的簡體中文版本) | ||||
|---|---|---|---|---|
| Prev | Fast Backward | Chapter 37. PL/Perl - Perl 過程語言 | Fast Forward | Next |
從您的 Perl 函數里存取資料庫本身可以透過下面描述的 spi_exec_query 或者一個試驗模塊 DBD::PgSPI (也可以在 CPAN 鏡像站 獲取)。 這個模塊讓用戶可以使用一個DBI兼容的叫 $pg_dbh 的資料庫句柄, 用戶可以用它以普通的 DBI 語法執行查詢。
PL/Perl 本身目前只提供兩個額外的 Perl 命令:
執行一個 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();
發出一條日誌或者錯誤訊息。可能的級別時 DEBUG,LOG, INFO,NOTICE,WARNING,和 ERROR。 ERROR 拋出一個錯誤條件:如果這個錯誤沒有被周圍的 Perl 代碼捕獲, 那麼錯誤將傳播到調用的查詢裡,導致目前交易或者子交易退出。 這實際上相當於 Perl 的 die 命令。 其他級別只是生成不同優先級的消息。 特定優先級的消息是否報告給客戶端,寫到伺服器日誌裡,或者兩個都做, 是由配置參數 log_min_messages 和 client_min_messages 控制的。參閱 Section 16.4 獲取更多訊息。