本文讲解如何避免 truncate table 与后续 insert 之间的竞态条件，确保表被彻底清空后再写入新数据，防止残留旧记录。核心方案是显式检查 truncate 执行成功后再进行插入操作，并推荐使用事务和参数化查询提升健壮性与安全性。
本文讲解如何避免 truncate table 与后续 insert 之间的竞态条件，确保表被彻底清空后再写入新数据，防止残留旧记录。核心方案是显式检查 truncate 执行成功后再进行插入操作，并推荐使用事务和参数化查询提升健壮性与安全性。
在 PHP 与 SQL Server（如 MSSQL v12）交互的典型 ETL 场景中，常需“先清空、再填充”目标表。但直接顺序调用 TRUNCATE TABLE 和 INSERT 并不天然线程安全——尤其在高并发或网络延迟波动时，PDO 的 query() 方法虽为同步调用，TRUNCATE 的完成确认仍依赖返回值判断。若忽略该返回值，PHP 可能因未等待底层事务提交而提前发起 INSERT，导致部分旧数据未被清除即被新数据覆盖（而非完全替换），引发数据不一致。
✅ 正确做法是：将 TRUNCATE 视为一个必须成功前置步骤，并通过其执行结果控制后续流程。以下是优化后的完整实现：
try {
// 开启事务以确保原子性（强烈推荐）
$connPdo->beginTransaction();
// 执行 TRUNCATE 并验证是否成功
$truncateResult = $connPdo->query("TRUNCATE TABLE [Table]");
if (!$truncateResult) {
throw new RuntimeException("TRUNCATE TABLE failed: " . implode(", ", $connPdo->errorInfo()));
}
// 获取远程数据
$get_data = callAPI('GET', 'https://api...');
$response = json_decode($get_data, true);
// 使用预处理语句防止 SQL 注入（关键安全改进）
$stmt = $connPdo->prepare("INSERT INTO [Table] (FEE, FIE) VALUES (?, ?)");
foreach ($response['FOO'] as $line) {
// 假设 $line['A'] 和 $line['B'] 是合法键名，实际使用前应校验
if (!isset($line['A']) || !isset($line['B'])) {
continue; // 跳过缺失字段的数据行
}
$stmt->execute([$line['A'], $line['B']]);
}
// 提交事务
$connPdo->commit();
} catch (Exception $e) {
$connPdo->rollback();
error_log("Data sync failed: " . $e->getMessage());
throw $e;
}
? 关键注意事项：
-
永远不要拼接 SQL 字符串：原文中
VALUES('".$Lines[A]."','" .$Lines[B]."')存在严重 SQL 注入风险，且易因特殊字符（如单引号、NULL）导致语法错误；务必改用PDO::prepare()+execute()。 -
启用事务：
TRUNCATE本身不可回滚（在 SQL Server 中是 DDL 操作），但包裹在事务中可确保：若后续 INSERT 失败，至少能及时发现并告警；更重要的是，事务能阻止其他会话在 TRUNCATE 完成前读取到中间状态（依赖隔离级别，如READ COMMITTED）。 -
错误处理不可省略：
$connPdo->query()返回false表示执行失败（如权限不足、表不存在），必须显式检查并处理。 -
考虑替代方案：若业务允许，
DELETE FROM [Table]配合SET IDENTITY_INSERT OFF更易回滚，但性能低于 TRUNCATE；对于超大表，还可结合SWITCH PARTITION实现毫秒级清空。
综上，解决 TRUNCATE-INSERT 竞态的本质，不是“加锁”或“延时”，而是建立明确的执行依赖链 + 采用防御性编程实践。通过验证语句结果、使用预处理、引入事务边界，即可在保持高性能的同时，彻底规避数据残留风险。
