如何在 MySQL 中跨服务器将数据从远程数据库插入本地表-php教程-PHP中文网

如何在 MySQL 中跨服务器将数据从远程数据库插入本地表

本文介绍通过安全、可靠的方式实现 mysql 跨服务器数据同步：利用导出/导入脚本配合定时任务，规避直连远程数据库的安全与网络限制。

本文介绍通过安全、可靠的方式实现 mysql 跨服务器数据同步：利用导出/导入脚本配合定时任务，规避直连远程数据库的安全与网络限制。

在实际开发中，直接通过 PHP 使用 mysqli_connect() 连接远程 MySQL 服务器（尤其是虚拟主机或云托管环境）往往不可行——多数托管服务默认禁用远程连接（3306 端口不对外开放），且强制开启存在严重安全风险（如弱密码暴露、暴力扫描）。你当前代码中尝试用 $result.$tableName 动态拼接数据库表引用，不仅语法错误（mysqli_query() 返回结果集而非数据库对象），更因无法建立稳定远程连接而必然失败。

✅ 正确实践方案：基于文件的异步数据同步
该方案不依赖实时数据库连接，而是通过“本地导出 → 安全传输 → 远程导入”三步闭环完成数据流转，兼顾安全性、可控性与可维护性：

本地导出脚本（export_counter.php）
在 localhost 运行，查询本地 contador 库中的 counter 表，生成结构清晰的 SQL 插入语句（推荐使用 INSERT ... ON DUPLICATE KEY UPDATE 防重）：

<?php $conn = mysqli_connect('localhost', 'root', '', 'contador');
if (!$conn) die("本地连接失败: " . mysqli_error($conn));

$sql = "SELECT Data, price FROM counter WHERE DATE(Data) = CURDATE()";
$result = mysqli_query($conn, $sql);
$lines = ["-- 导出时间: " . date('Y-m-d H:i:s')];

while ($row = mysqli_fetch_assoc($result)) {
    $data = mysqli_real_escape_string($conn, $row['Data']);
    $price = (float)$row['price'];
    $lines[] = "INSERT INTO counter (Data, price) VALUES ('$data', $price) 
                ON DUPLICATE KEY UPDATE price = VALUES(price);";
}

file_put_contents('/tmp/counter_sync.sql', implode("\n", $lines));
echo "导出完成：/tmp/counter_sync.sql\n";
?>

通过 SFTP 安全上传（替代不安全的 FTP）
使用 phpseclib 或系统 scp 命令上传（示例为 Shell 脚本，可由 cron 触发）：
```
#!/bin/bash
scp -o StrictHostKeyChecking=no /tmp/counter_sync.sql user@hostingIP:/home/user/db_import/
```

远程导入脚本（import_counter.php，部署在托管服务器）
在远程服务器上执行，确保数据库用户具备目标表写权限：

<?php // 远程服务器上运行，连接自身数据库
$conn = mysqli_connect('localhost', 'userIp', 'userPass', 'dbHosting');
if (!$conn) die("远程连接失败: " . mysqli_error($conn));

$sqlFile = '/home/user/db_import/counter_sync.sql';
if (!file_exists($sqlFile)) {
    die("SQL 文件不存在\n");
}

$sqlContent = file_get_contents($sqlFile);
// 按分号分割并逐条执行（需确保无复杂嵌套分号）
foreach (array_filter(array_map('trim', explode(';', $sqlContent))) as $stmt) {
    if (!empty($stmt) && stripos($stmt, 'INSERT') === 0) {
        if (!mysqli_query($conn, $stmt)) {
            error_log("导入失败: " . mysqli_error($conn) . " | SQL: $stmt");
        }
    }
}
unlink($sqlFile); // 导入后清理临时文件
echo "导入完成\n";
?>

⚠️ 关键注意事项