如何为mysqli_query传入两个连接以跨服务器执行SELECT INTO查询

你遇到的问题本质是MySQL原生的SELECT INTO（除导出到文件场景外）无法直接跨不同服务器执行，因为每个mysqli_connect()对应独立的服务器会话，mysqli_query只能绑定单个连接。下面是几个可行的解决方案：

方法1：PHP双连接分两步操作（最通用） #

先从源服务器查询数据，再逐条/批量插入到目标服务器，无需服务器额外配置，适合中小数据量场景。

示例代码：

// 建立两个独立连接
$sourceConn = mysqli_connect('source_host', 'source_user', 'source_pass', 'source_db');
$targetConn = mysqli_connect('target_host', 'target_user', 'target_pass', 'target_db');

// 检查连接是否成功
if (!$sourceConn || !$targetConn) {
    die('数据库连接失败');
}

// 从源服务器查询数据
$query = "SELECT col1, col2, col3 FROM source_table WHERE your_condition";
$result = mysqli_query($sourceConn, $query);

// 准备目标服务器的插入语句（用预处理防止SQL注入，提升效率）
$insertStmt = mysqli_prepare($targetConn, "INSERT INTO target_table (col1, col2, col3) VALUES (?, ?, ?)");
// 绑定参数，类型根据实际字段调整：s=字符串，i=整数，d=浮点数，b=二进制
mysqli_stmt_bind_param($insertStmt, "sis", $col1, $col2, $col3);

// 循环读取并插入数据
while ($row = mysqli_fetch_assoc($result)) {
    $col1 = $row['col1'];
    $col2 = $row['col2'];
    $col3 = $row['col3'];
    mysqli_stmt_execute($insertStmt);
}

// 清理资源
mysqli_stmt_close($insertStmt);
mysqli_free_result($result);
mysqli_close($sourceConn);
mysqli_close($targetConn);

如果数据量较大，可改为批量插入（比如每1000条执行一次）以减少IO次数：

$batchSize = 1000;
$values = [];
while ($row = mysqli_fetch_assoc($result)) {
    $values[] = "('" . mysqli_real_escape_string($targetConn, $row['col1']) . "', '" . mysqli_real_escape_string($targetConn, $row['col2']) . "', " . $row['col3'] . ")";
    if (count($values) >= $batchSize) {
        $batchQuery = "INSERT INTO target_table (col1, col2, col3) VALUES " . implode(',', $values);
        mysqli_query($targetConn, $batchQuery);
        $values = [];
    }
}
// 插入剩余数据
if (!empty($values)) {
    $batchQuery = "INSERT INTO target_table (col1, col2, col3) VALUES " . implode(',', $values);
    mysqli_query($targetConn, $batchQuery);
}

方法2：用FEDERATED存储引擎映射源表 #

在目标服务器创建一个映射到源服务器表的FEDERATED表，这样就能在目标服务器直接执行INSERT ... SELECT，数据传输在服务器层面完成，速度更快。

操作步骤： #

1. 检查FEDERATED引擎是否开启：
   登录目标服务器MySQL，执行：

SHOW ENGINES;

如果FEDERATED的Support列是YES则已开启；如果是NO，需要修改MySQL配置文件（my.cnf/my.ini），添加federated配置项，然后重启MySQL服务。

2. 创建FEDERATED映射表：
   表结构必须和源表完全一致，示例：

CREATE TABLE source_table_mirror (
    col1 INT NOT NULL,
    col2 VARCHAR(100) NOT NULL,
    col3 DATETIME
) ENGINE=FEDERATED
DEFAULT CHARSET=utf8mb4
CONNECTION='mysql://source_user:source_pass@source_host/source_db/source_table';

3. 执行跨服务器数据迁移：
   在目标服务器执行：

INSERT INTO target_table (col1, col2, col3)
SELECT col1, col2, col3 FROM source_table_mirror;

注意：FEDERATED引擎有一些限制，比如不支持事务、外键，部分存储引擎（如InnoDB）的某些特性可能不兼容，适合一次性或周期性的大数据量迁移。

方法3：用命令行工具迁移（适合一次性大数量） #

如果是一次性操作，直接用mysqldump导出源表数据，再导入到目标服务器，效率最高。

命令示例： #

# 导出源表数据（执行时会提示输入密码）
mysqldump -h source_host -u source_user -p source_db source_table > data_dump.sql

# 导入到目标服务器
mysql -h target_host -u target_user -p target_db < data_dump.sql

如果要在PHP中调用，可以用exec()或shell_exec()，但要注意安全，避免明文传递密码，建议用MySQL配置文件（~/.my.cnf）存储认证信息。

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