dede合并数据库

<?php
// 数据库连接信息
$db1_host = 'localhost';
$db1_user = 'user1';
$db1_pass = 'pass1';
$db1_name = 'db1';

$db2_host = 'localhost';
$db2_user = 'user2';
$db2_pass = 'pass2';
$db2_name = 'db2';

// 连接数据库
$db1 = new mysqli($db1_host, $db1_user, $db1_pass, $db1_name);
$db2 = new mysqli($db2_host, $db2_user, $db2_pass, $db2_name);

if ($db1->connect_error || $db2->connect_error) {
    die("连接失败: " . ($db1->connect_error ? $db1->connect_error : $db2->connect_error));
}

// 假设我们要合并的表名为 'articles'
$table_name = 'articles';

// 获取表结构
$sql = "SHOW CREATE TABLE `$table_name`";
$result = $db1->query($sql);
$table_structure = $result->fetch_assoc()['Create Table'];

// 在目标数据库中创建表
$db2->query("DROP TABLE IF EXISTS `$table_name`");
$db2->query($table_structure);

// 获取源数据库中的所有数据
$sql = "SELECT * FROM `$table_name`";
$result = $db1->query($sql);

// 插入数据到目标数据库
while ($row = $result->fetch_assoc()) {
    $keys = implode(', ', array_keys($row));
    $values = implode(', ', array_map(function($value) { return is_numeric($value) ? $value : "'$value'"; }, $row));
    $db2->query("INSERT INTO `$table_name` ($keys) VALUES ($values)");
}

echo "数据合并完成！";

// 关闭连接
$db1->close();
$db2->close();
?>