PHP结合MySQL实现数据迁移

在PHP中结合MySQL实现数据迁移，通常涉及以下几个步骤：

1. 连接到MySQL数据库：使用PHP的MySQLi或PDO扩展来连接到目标数据库。

2. 查询源数据库数据：编写SQL查询语句从源数据库中提取数据。

3. 处理数据：根据需要对数据进行清洗、转换或格式化。

4. 连接到目标数据库：同样使用PHP的MySQLi或PDO扩展来连接到目标数据库。

5. 插入或更新数据：将处理后的数据插入到目标数据库中，或者更新现有记录。

6. 错误处理：确保在数据迁移过程中能够妥善处理可能出现的错误。

7. 日志记录：记录数据迁移的进度和结果，便于后续跟踪和审计。

下面是一个简单的示例，展示了如何使用PHP和MySQLi实现数据迁移：

<?php
// 数据库配置
$source_host = 'localhost';
$source_user = 'source_username';
$source_pass = 'source_password';
$source_db = 'source_database';

$target_host = 'localhost';
$target_user = 'target_username';
$target_pass = 'target_password';
$target_db = 'target_database';

// 创建连接
$source_conn = new mysqli($source_host, $source_user, $source_pass, $source_db);
$target_conn = new mysqli($target_host, $target_user, $target_pass, $target_db);

// 检查连接
if ($source_conn->connect_error || $target_conn->connect_error) {
    die('连接失败: ' . $source_conn->connect_error . ' -> ' . $target_conn->connect_error);
}

// 查询源数据库数据
$sql = "SELECT id, name, email FROM users";
$result = $source_conn->query($sql);

if ($result->num_rows > 0) {
    // 插入或更新数据到目标数据库
    while($row = $result->fetch_assoc()) {
        $id = $row['id'];
        $name = $row['name'];
        $email = $row['email'];

        // 插入新记录
        $target_sql = "INSERT INTO users (id, name, email) VALUES ($id, '$name', '$email')";
        if (!$target_conn->query($target_sql)) {
            echo "Error: " . $target_sql . "<br>" . $target_conn->error;
        }
    }
} else {
    echo "0 结果";
}

// 关闭连接
$source_conn->close();
$target_conn->close();
?>

在这个示例中，我们首先定义了源数据库和目标数据库的配置信息，然后创建了两个MySQLi连接对象。接着，我们执行了一个查询来获取源数据库中的users表数据。对于查询结果中的每一行数据，我们构建了一个插入语句，并将其发送到目标数据库中。如果在插入过程中发生错误，我们会输出错误信息。最后，我们关闭了数据库连接。

请注意，这只是一个简单的示例，实际的数据迁移可能需要更复杂的逻辑，例如处理大量数据的分批迁移、数据转换、事务管理等。此外，对于生产环境中的数据迁移，建议先在测试环境中进行充分的测试。