MySQL 数据插入与更新：基于两表合并的实战教程-php教程-PHP中文网

MySQL 数据插入与更新：基于两表合并的实战教程

心靈之曲

发布： 2025-08-20 17:30:46

原创

517人浏览过

mysql 数据插入与更新：基于两表合并的实战教程

本文旨在指导开发者如何高效地将数据从一个 MySQL 表（例如 parts）插入或更新到另一个表（例如 magazzino）中。我们将探讨如何检查目标表中是否存在特定记录，并根据情况执行插入新记录或更新现有记录的操作，同时提供优化的 SQL 查询语句和代码示例，帮助读者掌握 INSERT ON DUPLICATE KEY UPDATE 语句的用法，从而简化数据同步过程。

场景描述

假设我们有两个表：parts 和 magazzino。parts 表包含零件信息（codice, pezzi, durata），magazzino 表用于存储库存信息（codiceM, pezziM, durataM）。我们需要将 parts 表中的数据同步到 magazzino 表中，具体逻辑如下：

如果 parts 表中的 codice 在 magazzino 表中不存在对应的 codiceM，则将 parts 表中的 codice, pezzi, durata 插入到 magazzino 表中。
如果 parts 表中的 codice 在 magazzino 表中已存在对应的 codiceM，则将 parts 表中的 pezzi 和 durata 分别加到 magazzino 表中对应记录的 pezziM 和 durataM 字段上。

解决方案：使用 INSERT ON DUPLICATE KEY UPDATE

MySQL 提供的 INSERT ON DUPLICATE KEY UPDATE 语句非常适合解决此类问题。该语句允许我们尝试插入一条新记录，如果该记录的主键或唯一键与表中已存在的记录冲突，则执行更新操作，而无需手动检查记录是否存在。

SQL 语句示例

假设 magazzino 表的 codiceM 字段是主键或唯一键，可以使用以下 SQL 语句实现数据同步：

INSERT INTO magazzino (codiceM, pezziM, durataM)
SELECT codice, pezzi, durata FROM parts
ON DUPLICATE KEY UPDATE
pezziM = pezziM + VALUES(pezziM),
durataM = durataM + VALUES(durataM);

登录后复制

解释：

硅基智能

基于Web3.0的元宇宙，去中心化的互联网，高质量、沉浸式元宇宙直播平台，用数字化重新定义直播

查看详情

INSERT INTO magazzino (codiceM, pezziM, durataM) SELECT codice, pezzi, durata FROM parts：尝试将 parts 表中的数据插入到 magazzino 表中。
ON DUPLICATE KEY UPDATE：如果插入过程中发生主键或唯一键冲突（即 codiceM 已经存在），则执行后面的更新操作。
pezziM = pezziM + VALUES(pezziM)：将 magazzino 表中已存在记录的 pezziM 字段的值加上 parts 表中对应记录的 pezzi 字段的值。VALUES(pezziM) 表示要插入的新记录的 pezziM 值。
durataM = durataM + VALUES(durataM)：类似地，将 magazzino 表中已存在记录的 durataM 字段的值加上 parts 表中对应记录的 durata 字段的值。

PHP 代码示例

以下是一个使用 PHP 执行上述 SQL 语句的示例：

<?php

$servername = "localhost";
$username = "root";
$password = "";
$dbname = "provaMagazzino";

// 创建连接
$conn = new mysqli($servername, $username, $password, $dbname);

// 检测连接
if ($conn->connect_error) {
    die("连接失败: " . $conn->connect_error);
}

$sql = "
INSERT INTO magazzino (codiceM, pezziM, durataM)
SELECT codice, pezzi, durata FROM parts
ON DUPLICATE KEY UPDATE
pezziM = pezziM + VALUES(pezziM),
durataM = durataM + VALUES(durataM);
";

if ($conn->query($sql) === TRUE) {
    echo "记录插入/更新成功";
} else {
    echo "Error: " . $sql . "<br>" . $conn->error;
}

$conn->close();

?>

登录后复制

注意：