Insert/Update脚本初始批次无更新，单条记录处理逻辑问题排查

我来帮你拆解下这个问题——核心是脚本能正常执行插入，但初始批次（目标表为空时）的更新逻辑完全没触发，哪怕你已经加了foreach逐条处理主查询记录。结合你给出的业务逻辑和测试数据，我整理了几个排查方向和解决思路：

1. 先确认循环的执行有效性 #

你提到已经加了foreach循环，但有没有真的验证过每一条主查询返回的记录都被遍历到了？

• 比如有些数据库的结果集是游标形式，如果不先把结果集转成数组再循环，可能只会处理第一条记录；
• 建议在循环内部加日志输出，比如打印当前处理的经销商ID、SKU，以及当前是执行插入还是更新判断，这样能快速定位循环是否真的跑了800次，以及每一次的分支走向。

示例日志代码（以PHP为例）：

foreach ($main_query_results as $row) {
    // 打印当前处理的核心标识
    error_log("Processing: Dealer={$row['dealer_id']}, SKU={$row['sku']}");
    
    // 后续的查询校验、插入/更新逻辑...
}

2. 排查更新触发的条件逻辑 #

你说更新逻辑没执行，先确认两个关键点：

（1）目标表记录的查询是否准确 #

当目标表已有记录时，你的「查询经销商+SKU是否存在」的语句有没有真的找到对应记录？

• 检查查询语句的WHERE条件是不是完整：是不是同时匹配了dealer_id和sku？有没有漏掉其他必要的过滤条件？
• 比如测试数据里的第四条记录(12346, 133, 1234, '2018-03-02', 30, 10)，经销商是12346，和前三条的12345不一样——如果你的查询逻辑误把store_id当成了经销商标识，那肯定匹配不到之前的记录，自然不会触发更新。

（2）更新的业务条件是否满足 #

你的更新触发条件是「数量大于门店数 + 日期早于expire_date」，要确认：

• 日期比较的方向是不是写反了？比如把当前记录日期 < expire_date写成了>；
• 门店数的取值是不是正确？是取目标表中已存在记录的store_count，还是主查询里的？比如测试数据里第四条的门店数是10，数量是30，满足30>10，但如果你的逻辑误拿了目标表的数量和主查询的门店数比，就会不满足条件。

3. 改用数据库原生UPSERT语句替代手动逻辑 #

手动写「查询-判断-插入/更新」很容易出现逻辑漏洞，而且会有并发风险。大部分数据库都支持原生的插入/更新合并语法，能简化逻辑还保证原子性：

MySQL 示例（ON DUPLICATE KEY UPDATE） #

首先给目标表创建唯一索引，确保「经销商+SKU」是唯一标识：

CREATE UNIQUE INDEX idx_dealer_sku ON target_table (dealer_id, sku);

然后用UPSERT语法处理数据：

INSERT INTO target_table (dealer_id, store_id, sku, `date`, qty, store_count)
VALUES 
(12345, 133, 1234, '2018-02-02', 10, 10),
(12345, 133, 1235, '2018-02-02', 10, 10),
(12345, 133, 1236, '2018-02-02', 10, 10),
(12346, 133, 1234, '2018-03-02', 30, 10)
ON DUPLICATE KEY UPDATE
    qty = CASE WHEN VALUES(qty) > store_count THEN VALUES(qty) ELSE qty END,
    `date` = CASE WHEN VALUES(`date`) < expire_date THEN VALUES(`date`) ELSE `date` END;

SQL Server 示例（MERGE） #

MERGE INTO target_table AS t
USING (
    VALUES 
    (12345, 133, 1234, '2018-02-02', 10, 10),
    (12345, 133, 1235, '2018-02-02', 10, 10),
    (12345, 133, 1236, '2018-02-02', 10, 10),
    (12346, 133, 1234, '2018-03-02', 30, 10)
) AS s (dealer_id, store_id, sku, `date`, qty, store_count)
ON t.dealer_id = s.dealer_id AND t.sku = s.sku
WHEN MATCHED AND s.qty > t.store_count AND s.`date` < t.expire_date THEN
    UPDATE SET t.qty = s.qty, t.`date` = s.`date`
WHEN NOT MATCHED THEN
    INSERT (dealer_id, store_id, sku, `date`, qty, store_count)
    VALUES (s.dealer_id, s.store_id, s.sku, s.`date`, s.qty, s.store_count);

这种方式完全替代了手动的循环判断，能避免很多人为逻辑错误，效率也更高。

4. 调试更新语句本身 #

如果确认了条件都满足，但更新还是没执行，那要检查更新语句的语法：

• 是不是漏掉了WHERE条件，导致没匹配到目标记录？
• 是不是字段名写错了？比如把qty写成了quantity？
• 可以单独把更新语句拿出来，用测试数据手动执行，看是否能正常更新目标记录。

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