37.2. �� PL/Perl ��������ݿ�

����� 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 ���������һ�����ж������������IJ�ѯ��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 ���벶�� ��ô���󽫴��������õIJ�ѯ����µ�ǰ��������������˳��� ��ʵ�����൱�� Perl �� die ��� ��������ֻ�����ɲ�ͬ���ȼ�����Ϣ�� �ض����ȼ�����Ϣ�Ƿ񱨸���ͻ��ˣ�д����������־��������������� �������ò��� log_min_messages �� client_min_messages ���Ƶġ����� Section 16.4 ��ȡ������Ϣ��