如何在contacts表ID已存在时生成新ID？跨数据库联系人数据复制脚本优化求助

没问题，我来帮你调整这个脚本，实现当数据库2的contacts表中已存在相同ID时，自动生成新ID插入数据，同时还能避免SQL注入风险，让脚本更安全可靠。

核心思路 #

假设你的contacts表的id字段是自增主键（这是最常见的业务场景），我们可以通过以下逻辑实现需求：

• 先检查目标库（数据库2）中是否存在指定ID的数据
• 如果不存在：直接插入原数据（保留原ID）
• 如果存在：插入时排除id字段，让数据库自动生成新的自增ID
• 使用预处理语句避免SQL注入（原脚本直接拼接$_GET['id']存在安全风险）

修改后的完整脚本 #

// 连接源数据库（包含待复制数据的contacts表）
$mysqli = mysqli_connect($databaseHost, $databaseUsername, $databasePassword, $sourceDatabaseName);

// 检查数据库连接是否成功
if (!$mysqli) {
    die("数据库连接失败: " . mysqli_connect_error());
}

$targetId = $_GET['id'];

// 1. 检查目标数据库（exdigita_vadercic）中是否存在该ID
$checkSql = "SELECT id FROM exdigita_vadercic.contacts WHERE id = ?";
$checkStmt = mysqli_prepare($mysqli, $checkSql);
mysqli_stmt_bind_param($checkStmt, "i", $targetId);
mysqli_stmt_execute($checkStmt);
mysqli_stmt_store_result($checkStmt);

// 根据检查结果选择插入逻辑
if (mysqli_stmt_num_rows($checkStmt) > 0) {
    // 2. ID已存在，插入时排除id字段，让数据库自动生成新ID
    // 注意：替换成你contacts表中除id外的所有实际字段
    $insertSql = "INSERT INTO exdigita_vadercic.contacts 
                  (name, email, phone, address, create_time)  
                  SELECT name, email, phone, address, create_time 
                  FROM contacts WHERE id = ?";
} else {
    // 3. ID不存在，直接插入原数据（保留原ID）
    $insertSql = "INSERT INTO exdigita_vadercic.contacts 
                  SELECT * FROM contacts WHERE id = ?";
}

// 执行插入操作
$insertStmt = mysqli_prepare($mysqli, $insertSql);
mysqli_stmt_bind_param($insertStmt, "i", $targetId);

if (mysqli_stmt_execute($insertStmt)) {
    if (mysqli_stmt_num_rows($checkStmt) > 0) {
        echo "目标库已存在相同ID，已自动生成新ID完成数据复制";
    } else {
        echo "数据复制成功";
    }
} else {
    echo "复制失败: " . mysqli_error($mysqli);
}

// 关闭数据库语句和连接
mysqli_stmt_close($checkStmt);
mysqli_stmt_close($insertStmt);
mysqli_close($mysqli);

关键注意事项 #

1. 字段替换：必须把脚本中的name, email, phone, address, create_time替换成你contacts表中除id之外的所有实际字段，否则无法正确复制数据。
2. 多库连接说明：如果源表和目标表在不同的数据库服务器上，需要分别建立两个数据库连接，再分别执行查询和插入操作。
3. 非自增ID的处理：如果你的id字段不是自增类型，可以手动生成不重复的新ID，示例逻辑如下：

// 查询目标库中最大的ID，生成新ID
$getMaxIdSql = "SELECT MAX(id) AS max_id FROM exdigita_vadercic.contacts";
$maxIdResult = mysqli_query($mysqli, $getMaxIdSql);
$maxIdRow = mysqli_fetch_assoc($maxIdResult);
$newId = $maxIdRow['max_id'] + 1;

// 插入时使用新ID
$insertSql = "INSERT INTO exdigita_vadercic.contacts 
              (id, name, email, ...) 
              SELECT ?, name, email, ... 
              FROM contacts WHERE id = ?";
$insertStmt = mysqli_prepare($mysqli, $insertSql);
mysqli_stmt_bind_param($insertStmt, "ii", $newId, $targetId);

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