如何在Perl中跨两个数据库执行INSERT INTO SELECT语句？

首先明确：你手里的两个handlerDB1和handlerDB2是独立的数据库会话连接，没法直接执行跨连接的INSERT INTO tableDB2 SELECT * FROM tableDB1语句——这条SQL需要在同一个数据库会话中同时访问两个库，而两个独立的DBI连接属于不同会话，相互隔离。

但可以根据两个数据库的部署情况，用以下方法解决：

情况1：两个库在同一个MySQL实例上 #

这种情况最简单，直接使用单个DBI连接，通过库名.表名的方式跨库访问，就能直接执行你想要的SQL：

# 连接到其中一个库即可，无需分开连接
my $dbh = DBI->connect("DBI:mysql:database=db1;host=你的主机", $用户名, $密码);
# 用db1.tableDB1和db2.tableDB2明确指定库表
my $sql = "INSERT INTO db2.tableDB2 SELECT col1, col2, col3 FROM db1.tableDB1";
$dbh->do($sql) or die $dbh->errstr;

注意：建议不要用SELECT *，而是明确写出字段列表，避免两张表结构变化（比如字段顺序、数量改变）导致插入失败。

情况2：两个库在不同MySQL实例上（必须用两个连接） #

这种情况下必须自己做数据中转，最简的实现方式如下：

方法1：逐行读取插入（小数据量适用） #

# 从源库读取数据（明确字段）
my $sth_select = $handlerDB1->prepare("SELECT col1, col2, col3 FROM tableDB1");
$sth_select->execute();

# 准备插入语句（对应目标表字段）
my $sth_insert = $handlerDB2->prepare("INSERT INTO tableDB2 (col1, col2, col3) VALUES (?, ?, ?)");

# 逐行读取并插入
while (my @row = $sth_select->fetchrow_array) {
    $sth_insert->execute(@row) or die $handlerDB2->errstr;
}

# 释放资源
$sth_select->finish();
$sth_insert->finish();

方法2：批量插入（大数据量更高效） #

用DBI的execute_array批量处理，减少数据库交互次数：

# 一次性读取所有数据（数据量极大时建议分批读取）
my $sth_select = $handlerDB1->prepare("SELECT col1, col2, col3 FROM tableDB1");
$sth_select->execute();
my $all_rows = $sth_select->fetchall_arrayref;
$sth_select->finish();

if (@$all_rows) {
    # 准备插入语句
    my $sth_insert = $handlerDB2->prepare("INSERT INTO tableDB2 (col1, col2, col3) VALUES (?, ?, ?)");
    
    # 绑定每一列的批量数据
    $sth_insert->bind_param_array(1, [map { $_->[0] } @$all_rows]);
    $sth_insert->bind_param_array(2, [map { $_->[1] } @$all_rows]);
    $sth_insert->bind_param_array(3, [map { $_->[2] } @$all_rows]);
    
    # 执行批量插入
    $sth_insert->execute_array({Slice => {}}) or die $handlerDB2->errstr;
    $sth_insert->finish();
}

提示：如果数据量非常大，不要一次性把所有数据读到内存里，改成每次读取N行（比如1000行）就插入一批，避免内存溢出。

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