在数据库迁移、分库分表的场景中，我们常常需要将某个数据库的结构和数据完整地复制到另一个数据库中。本文将以 MySQL 数据库为例，详细讲解如何将数据库 A 中的 voice 数据库迁移到数据库 B 中，并命名为 voice1。我们将从理论分析到具体代码实现，层层展开。

实现思路

获取 A 数据库中 voice 的表结构和数据：

在 B 数据库中创建 voice1 数据库：

验证迁移结果：

实现方法一：使用 MySQL 的命令行工具

如果你对命令行工具熟悉，可以用以下命令快速完成迁移：

# 导出 voice 数据库的结构和数据
mysqldump -u username -p --databases voice > voice.sql
# 将 voice.sql 导入到 B 数据库中并创建 voice1
mysql -u username -p -h B_host
CREATE DATABASE voice1;
USE voice1;
SOURCE /path/to/voice.sql;

这种方法简单直接，但在复杂业务场景中可能需要更多控制。因此，接下来我们将通过 PHP 代码实现该操作。

实现方法二：用 PHP 脚本实现迁移步骤 1：准备环境

确保 PHP 具备以下扩展：

步骤 2：核心代码实现连接到 A 和 B 数据库

// 数据库 A 和 B 的配置
$configA = [
    'host' => 'A_host',
    'user' => 'A_user',
    'pass' => 'A_password',
    'dbname' => 'voice'
];
$configB = [
    'host' => 'B_host',
    'user' => 'B_user',
    'pass' => 'B_password',
    'dbname' => 'voice1'
];
// 连接函数
function connectDatabase($config) {
    $dsn = "mysql:host={$config['host']};dbname={$config['dbname']};charset=utf8mb4";
    try {
        return new PDO($dsn, $config['user'], $config['pass'], [
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
            PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC
        ]);
    } catch (PDOException $e) {
        die("数据库连接失败: " . $e->getMessage());
    }
}
$dbA = connectDatabase($configA);
$dbB = connectDatabase($configB);
echo "数据库连接成功\n";
?>

复制数据库表结构

// 获取 A 数据库的表结构
function getTableSchema($db, $tableName) {
    $query = $db->query("SHOW CREATE TABLE `$tableName`");
    $result = $query->fetch();
    return $result['Create Table'] ?? '';
}
// 在 B 数据库创建表
function createTableInDatabase($dbB, $tableSchema) {
    $dbB->exec($tableSchema);
}
// 从 A 数据库获取所有表
function getAllTables($db) {
    $query = $db->query("SHOW TABLES");
    $tables = [];

    while ($row = $query->fetch()) {
        $tables[] = array_values($row)[0];
    }
    return $tables;
}
// 获取表结构并在 B 中创建
$tables = getAllTables($dbA);
foreach ($tables as $table) {
    $tableSchema = getTableSchema($dbA, $table);
    createTableInDatabase($dbB, $tableSchema);
    echo "已复制表结构: $table\n";
}
?>

复制表数据

// 从 A 数据库读取数据并插入到 B 数据库
function copyTableData($dbA, $dbB, $table) {
    // 查询数据
    $query = $dbA->query("SELECT * FROM `$table`");
    $data = $query->fetchAll();
    if (!empty($data)) {
        // 拼接插入 SQL
        $columns = implode(',', array_keys($data[0]));
        $placeholders = implode(',', array_fill(0, count($data[0]), '?'));
        $insertSQL = "INSERT INTO `$table` ($columns) VALUES ($placeholders)";
        $stmt = $dbB->prepare($insertSQL);
        // 批量插入数据
        foreach ($data as $row) {
            $stmt->execute(array_values($row));
        }
        echo "已复制数据到表: $table，共插入 " . count($data) . " 条记录\n";
    } else {
        echo "表: $table 无数据，无需插入\n";
    }
}
// 复制所有表的数据
foreach ($tables as $table) {
    copyTableData($dbA, $dbB, $table);
}
?>

步骤 3：验证迁移结果

迁移完成后，验证数据的一致性：

function verifyData($dbA, $dbB, $tables) {
    foreach ($tables as $table) {
        $countA = $dbA->query("SELECT COUNT(*) FROM `$table`")->fetchColumn();
        $countB = $dbB->query("SELECT COUNT(*) FROM `$table`")->fetchColumn();
        
        if ($countA === $countB) {
            echo "表 $table 数据一致，共有 $countA 条记录。\n";
        } else {
            echo "表 $table 数据不一致！A: $countA 条, B: $countB 条。\n";
        }
    }
}
verifyData($dbA, $dbB, $tables);
?>

完整脚本

将以上代码组合在一起，形成一个完整的迁移工具，执行后即可完成数据库的结构和数据迁移。

总结

通过以上代码，我们成功实现了从 A 数据库中提取 voice 数据库的表结构和数据，并将其迁移到 B 数据库的 voice1 中。相比直接使用命令行，PHP 提供了更高的灵活性，方便我们对迁移流程进行定制化处理。

无论是小型项目的数据库迁移，还是大型系统的分库分表，这种方式都能很好地满足需求！希望对你有所帮助 ！