能否在PostgreSQL的PL/Perl函数中使用DBI访问外部数据库？

当然可以在PostgreSQL的PL/Perl函数中使用DBI访问外部数据库，但你现在遇到的DBI.pm加载失败问题，主要是PL/Perl的安全模式限制和依赖配置没到位导致的。下面一步步帮你解决，同时也给你提供更适合需求的替代方案：

1. 解决DBI加载失败的核心问题 #

切换到非安全PL/Perl模式（plperlu） #

PL/Perl默认的plperl是安全模式，会限制加载非核心Perl模块的行为。要使用DBI，你必须改用plperlu语言模式（无安全限制的PL/Perl），这是最关键的一步。

确保安装了正确的Perl依赖 #

PostgreSQL的PL/Perl会使用系统的Perl环境，你需要确保：

• 安装了DBI模块：可以用包管理器（比如apt install libdbi-perl或yum install perl-DBI），或者通过cpan DBI手动安装。
• 安装对应数据库的DBD驱动：比如访问Oracle需要DBD::Oracle（需要先安装Oracle Instant Client并配置环境变量），访问MSSQL可以用DBD::ODBC，访问其他PG实例用DBD::Pg。
• 验证PostgreSQL运行用户（通常是postgres）能访问这些模块：可以切换到postgres用户，执行perl -e 'use DBI; use DBD::Oracle; print "Loaded successfully\n"'来测试依赖是否正常加载。

2. 修正后的PL/Perl函数示例 #

下面是调整后的函数，包含错误处理、数据同步逻辑（把Oracle查询结果插入PostgreSQL表）：

CREATE OR REPLACE FUNCTION sel_ora() RETURNS VOID AS $$
use strict;
use warnings;
use DBI;

my ($dbh, $sth);
eval {
    # 连接Oracle数据库
    $dbh = DBI->connect(
        "dbi:Oracle:DBKUNDEN",
        "stadl",
        "sysadm",
        { RaiseError => 1, AutoCommit => 0, PrintError => 0 }
    );

    # 执行Oracle查询
    $sth = $dbh->prepare("SELECT col1, col2 FROM your_oracle_table");
    $sth->execute();

    # 将结果插入PostgreSQL本地表
    while (my $row = $sth->fetchrow_hashref) {
        # 使用PL/Perl内置的spi_exec_query操作PostgreSQL
        spi_exec_query(
            "INSERT INTO local_pg_table (col1, col2) VALUES (?, ?)",
            undef,
            $row->{col1}, $row->{col2}
        );
    }

    $dbh->commit();
};

# 错误处理
if ($@) {
    $dbh->rollback() if $dbh;
    die "操作失败: $@";
}

# 清理资源
$sth->finish() if $sth;
$dbh->disconnect() if $dbh;
$$ LANGUAGE plperlu;

说明：

• 使用eval捕获异常，避免函数直接崩溃
• 用spi_exec_query（PL/Perl内置函数）操作PostgreSQL本地表，不需要额外模块
• 开启事务保证数据一致性

3. 更简单的替代方案：外部数据包装器（FDW） #

如果你的需求只是同步外部数据库的SELECT结果到PostgreSQL，FDW会比PL/Perl更简单、更易维护，不需要处理Perl依赖问题：

Oracle FDW示例 #

-- 安装Oracle外部数据包装器（需要先编译安装扩展）
CREATE EXTENSION oracle_fdw;

-- 创建外部服务器（指向Oracle实例）
CREATE SERVER oracle_server FOREIGN DATA WRAPPER oracle_fdw 
OPTIONS (dbserver 'DBKUNDEN');

-- 创建用户映射（Oracle的账号密码）
CREATE USER MAPPING FOR postgres SERVER oracle_server 
OPTIONS (user 'stadl', password 'sysadm');

-- 创建外部表（映射Oracle的远程表结构）
CREATE FOREIGN TABLE oracle_remote_table (
    col1 varchar(50),
    col2 integer
) SERVER oracle_server 
OPTIONS (table 'your_oracle_table');

-- 同步数据到PostgreSQL本地表
INSERT INTO local_pg_table (col1, col2) 
SELECT col1, col2 FROM oracle_remote_table;

类似的，MSSQL可以用tds_fdw，其他PG实例用postgres_fdw，原理完全一致。

4. 常见问题排查 #

• 如果还是加载不了DBI：在函数里添加warn join("\n", @INC);，查看Perl的模块搜索路径，确认DBI所在目录在其中。
• Oracle驱动加载失败：确保Oracle Instant Client的路径被PostgreSQL进程加载，比如在PostgreSQL启动脚本中设置LD_LIBRARY_PATH。
• 权限问题：PostgreSQL运行用户（postgres）需要有访问Perl模块和数据库客户端库的权限，避免用root用户运行PostgreSQL。

内容的提问来源于stack exchange，提问作者guhl