本文介绍在 PHP 中通过 PDO 操作 MSSQL 时，如何确保 TRUNCATE TABLE 完全执行完毕后再执行批量 INSERT，从而彻底避免因异步执行或事务延迟导致的旧数据残留问题。
本文介绍在 php 中通过 pdo 操作 mssql 时，如何确保 `truncate table` 完全执行完毕后再执行批量 `insert`，从而彻底避免因异步执行或事务延迟导致的旧数据残留问题。
在高并发或快速连续调用的场景下，直接顺序书写 TRUNCATE TABLE 和后续 INSERT 语句（如原代码所示）看似线性，实则存在隐式竞态风险：PDO 的 query() 方法虽为同步调用，但若未显式检查其执行结果或未启用事务隔离，数据库引擎可能因锁释放时机、连接缓冲、或驱动层行为差异，导致 INSERT 在 TRUNCATE 的物理清理尚未完全提交前即开始写入——尤其在 SQL Server 中，TRUNCATE 是 DDL 操作，会隐式提交事务并重置标识列，但其完成信号需由驱动明确返回后才应视为“就绪”。
✅ 正确做法是：将 TRUNCATE 的执行结果作为控制流判断依据，并推荐包裹在显式事务中增强原子性与一致性。以下是优化后的健壮实现：
try {
$connPdo->beginTransaction(); // 开启事务（TRUNCATE 在事务中仍生效，且确保后续 INSERT 同属一个上下文）
// 执行 TRUNCATE 并验证是否成功
$truncateResult = $connPdo->exec("TRUNCATE TABLE [Table]");
if ($truncateResult === false) {
throw new Exception("TRUNCATE TABLE failed: " . implode(", ", $connPdo->errorInfo()));
}
// 获取远程数据
$get_data = callAPI('GET', 'https://api...');
$response = json_decode($get_data, true);
if (json_last_error() !== JSON_ERROR_NONE || !isset($response['FOO'])) {
throw new Exception("Invalid API response format");
}
// 批量安全插入（强烈建议使用预处理语句防止 SQL 注入）
$stmt = $connPdo->prepare("INSERT INTO [Table] (FEE, FIE) VALUES (?, ?)");
foreach ($response['FOO'] as $line) {
// 注意：$line['A'] 和 $line['B'] 需确保键名正确（原文中 $Lines[A] 缺少引号，属严重语法错误）
$stmt->execute([$line['A'] ?? '', $line['B'] ?? '']);
}
$connPdo->commit();
echo "Data refreshed successfully.";
} catch (Exception $e) {
$connPdo->rollback();
error_log("Refresh failed: " . $e->getMessage());
throw $e;
}
⚠️ 关键注意事项：
-
永远不要拼接 SQL 字符串：原文中
"VALUES('".$Lines[A]."','" .$Lines[B]."')"存在双重风险——PHP 数组键未加引号（$Lines[A]→$Lines['A']）会触发E_NOTICE并取常量值；更严重的是，若$Lines['A']含单引号或恶意内容，将导致 SQL 注入。务必使用预处理语句（prepare+execute）。 -
TRUNCATE不可回滚？不完全准确：在显式事务中对用户表执行TRUNCATE，SQL Server 允许回滚（自 SQL Server 2005 起），因此beginTransaction()/rollback()可保障操作整体原子性。 -
性能提示：若数据量极大，可考虑
INSERT ... SELECT或临时表交换方案替代逐行INSERT，进一步减少网络往返与日志开销。
总结：解决 TRUNCATE-INSERT 竞态的核心不是“等待”，而是强制执行顺序依赖 + 显式错误反馈 + 事务兜底。通过校验 exec() 返回值（非 query()，因 TRUNCATE 无结果集）、启用事务、改用参数化查询，即可 100% 规避旧数据残留问题。
