PHP/MySQL如何检测Listings表的商品价格变动？

首先咱们得先搞清楚为什么触发器方案会失效：TRUNCATE是DDL语句，它直接释放表的数据页，不会触发任何行级的BEFORE DELETE或AFTER DELETE触发器——这和DELETE FROM listings完全不同，后者是逐行删除，会触发触发器。所以你用TRUNCATE清空表的话，依赖触发器生成历史记录的逻辑直接就断了。

接下来给你几个最优的实现思路，按推荐程度排序：

方案1：增量同步+应用层主动记录价格历史（最推荐） #

放弃全量TRUNCATE+插入的思路，改成对比新旧数据，只处理变化项，同时在PHP脚本里主动写入历史记录，完全不依赖数据库触发器。好处是性能更高，逻辑更可控，还能避免TRUNCATE的问题。

具体步骤：

• 拉取最新数据：通过Shopify API获取当前所有Listings的JSON数据，解析成PHP数组（用json_decode()），以产品的唯一标识（比如product_id或handle）作为数组的键，方便后续对比。
• 读取现有数据：从你的Listings表中查询所有记录，同样以唯一标识为键存入数组，记录每个产品的当前价格。
• 处理价格变化与下架：
  • 遍历现有数据的每个产品：
    • 如果新数据中没有这个产品：标记为「下架」（或者直接删除），并往Listings_history插入一条记录（包含产品ID、旧价格、操作类型「下架」、时间戳）。
    • 如果新数据中有这个产品，但价格不同：先往Listings_history插入旧价格的记录，再更新Listings表中的价格。
• 处理新增产品：遍历新数据的每个产品，如果现有数据中不存在，直接插入Listings表，同时可以往Listings_history插入初始价格的记录（可选，看你是否需要跟踪首次上架的价格）。

简化代码示例（PDO版） #

// 1. 拉取Shopify数据
$shopifyUrl = 'https://your-shop.myshopify.com/admin/api/2024-01/products.json?limit=250';
$headers = [
    'X-Shopify-Access-Token: YOUR_ACCESS_TOKEN',
    'Content-Type: application/json'
];
$ch = curl_init($shopifyUrl);
curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
$response = curl_exec($ch);
curl_close($ch);
$newListings = json_decode($response, true)['products'];
$newListingMap = [];
foreach ($newListings as $item) {
    // 假设用第一个变体的价格（多变体场景需调整逻辑）
    $price = $item['variants'][0]['price'];
    $newListingMap[$item['id']] = [
        'title' => $item['title'],
        'price' => $price,
        'handle' => $item['handle']
    ];
}

// 2. 读取现有数据
$pdo = new PDO('mysql:host=localhost;dbname=your_db', 'user', 'pass');
$stmt = $pdo->query("SELECT product_id, price FROM Listings");
$existingListingMap = [];
while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
    $existingListingMap[$row['product_id']] = $row['price'];
}

// 3. 处理现有产品的变化/下架
$historyStmt = $pdo->prepare("INSERT INTO Listings_history (product_id, old_price, change_type, created_at) VALUES (?, ?, ?, NOW())");
$updateStmt = $pdo->prepare("UPDATE Listings SET price = ?, title = ?, handle = ? WHERE product_id = ?");
$deleteStmt = $pdo->prepare("DELETE FROM Listings WHERE product_id = ?");

foreach ($existingListingMap as $productId => $oldPrice) {
    if (!isset($newListingMap[$productId])) {
        // 产品下架
        $historyStmt->execute([$productId, $oldPrice, 'removed']);
        $deleteStmt->execute([$productId]);
    } else {
        $newPrice = $newListingMap[$productId]['price'];
        if ($oldPrice != $newPrice) {
            // 价格变化，记录历史
            $historyStmt->execute([$productId, $oldPrice, 'price_changed']);
            // 更新当前价格
            $updateStmt->execute([
                $newPrice,
                $newListingMap[$productId]['title'],
                $newListingMap[$productId]['handle'],
                $productId
            ]);
        }
        // 价格没变化，标记已处理，剩下的就是新增产品
        unset($newListingMap[$productId]);
    }
}

// 4. 处理新增产品
$insertStmt = $pdo->prepare("INSERT INTO Listings (product_id, title, price, handle, created_at) VALUES (?, ?, ?, ?, NOW())");
$insertHistoryStmt = $pdo->prepare("INSERT INTO Listings_history (product_id, old_price, change_type, created_at) VALUES (?, ?, ?, NOW())");

foreach ($newListingMap as $productId => $data) {
    $insertStmt->execute([
        $productId,
        $data['title'],
        $data['price'],
        $data['handle']
    ]);
    // 可选：记录首次上架的历史
    $insertHistoryStmt->execute([$productId, $data['price'], 'added']);
}

方案2：全量同步+先对比再TRUNCATE（兼容原有习惯） #

如果你坚持要用TRUNCATE来清空表（比如数据量极大，全量插入比增量更新更快），那可以调整顺序：先对比新旧数据，生成历史记录，再TRUNCATE，最后插入新数据。

步骤：

1. 拉取新数据，读取现有数据（和方案1前两步一致）。
2. 对比新旧数据，找出价格变化的产品，批量插入Listings_history。
3. 执行TRUNCATE TABLE Listings清空旧数据（建议用事务包裹，避免中途故障导致表为空）。
4. 批量插入所有新数据到Listings表。

这个方案保留了你用TRUNCATE的习惯，但缺点是同步过程中若出现故障，可能导致Listings表暂时为空，需要额外的容错处理。

为什么不推荐继续用触发器？ #

除了TRUNCATE不触发DELETE触发器的问题，触发器还有这些局限：

• 逻辑耦合在数据库层，调试和修改都不如应用层灵活。
• 如果后续需要跟踪更多字段变化（比如库存、标题），触发器的逻辑会越来越复杂。
• 全量DELETE+INSERT的性能远不如增量同步，尤其是当Listings数量很大的时候。

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