如何通过PowerShell修改脚本实现SQL表数据同步并删除差异记录

看起来你已经搞定了差异对比的部分，接下来就是利用这个结果集完成同步删除的操作对吧？我来给你梳理下具体的实现步骤和代码示例：

核心思路很明确：我们只需要处理$compareResult里标记为SRC = 'Hold_Inv'的那些记录——这些就是Hold_Inv表有但Temp_Hold_Inv表没有的条目，也就是需要从Hold_Inv和Daily_Proc中清理掉的内容。

下面分步骤给出具体的PowerShell实现：

1. 先筛选出待删除的差异记录 #

首先从对比结果里把需要删除的记录挑出来：

# 提取Hold_Inv独有的记录（即Temp里没有的，需要删除的）
$recordsToDelete = $compareResult | Where-Object { $_.SRC -eq 'Hold_Inv' }

2. 执行删除操作（两种方案可选） #

根据数据量大小，你可以选下面两种方式之一：

方案一：适合少量数据的IN子句法 #

如果待删除的记录不多，直接构造IN条件来删除最直接：

if ($recordsToDelete.Count -gt 0) {
    # 把每条记录转换成SQL能识别的元组格式
    $deleteTuples = $recordsToDelete | ForEach-Object {
        "('$($_.Hold)', '$($_.GID)', '$($_.Source)')"
    } -join ', '

    # 构造带事务的删除语句，保证两个表的删除要么都成功要么都回滚
    $deleteScript = @"
BEGIN TRANSACTION;

-- 删除Hold_Inv里的差异记录
DELETE FROM Hold_Inv
WHERE (Hold, GID, Source) IN ($deleteTuples);

-- 删除Daily_Proc里对应的记录（假设用同样的三个字段关联，按需调整）
DELETE FROM Daily_Proc
WHERE (Hold, GID, Source) IN ($deleteTuples);

COMMIT TRANSACTION;
"@

    try {
        Invoke-Sqlcmd -Query $deleteScript -ServerInstance $Server -Database $Database -ErrorAction Stop
        Write-Host "搞定！成功删除了$($recordsToDelete.Count)条差异记录"
    } catch {
        Write-Error "删除出错了：$_"
        # 出错就回滚事务，避免数据不一致
        Invoke-Sqlcmd -Query "ROLLBACK TRANSACTION;" -ServerInstance $Server -Database $Database
    }
} else {
    Write-Host "没有需要删除的差异，两张表已经同步啦"
}

方案二：适合大量数据的临时表法 #

如果待删除的记录很多，IN子句可能会有性能问题，这时用临时表关联删除更高效：

if ($recordsToDelete.Count -gt 0) {
    # 第一步：创建临时表用来存待删除的记录
    Invoke-Sqlcmd -Query @"
CREATE TABLE #TempDeleteList (
    Hold VARCHAR(255),
    GID VARCHAR(255),
    Source VARCHAR(255)
);
"@ -ServerInstance $Server -Database $Database

    # 第二步：把待删除的记录批量插入临时表
    foreach ($record in $recordsToDelete) {
        Invoke-Sqlcmd -Query @"
INSERT INTO #TempDeleteList (Hold, GID, Source)
VALUES ('$($record.Hold)', '$($record.GID)', '$($record.Source)');
"@ -ServerInstance $Server -Database $Database
    }

    # 第三步：关联临时表执行删除，同样用事务保证原子性
    $deleteScript = @"
BEGIN TRANSACTION;

DELETE h
FROM Hold_Inv h
INNER JOIN #TempDeleteList t ON h.Hold = t.Hold AND h.GID = t.GID AND h.Source = t.Source;

DELETE d
FROM Daily_Proc d
INNER JOIN #TempDeleteList t ON d.Hold = t.Hold AND d.GID = t.GID AND d.Source = t.Source;

COMMIT TRANSACTION;

DROP TABLE #TempDeleteList;
"@

    try {
        Invoke-Sqlcmd -Query $deleteScript -ServerInstance $Server -Database $Database -ErrorAction Stop
        Write-Host "成功删除$($recordsToDelete.Count)条记录，同步完成！"
    } catch {
        Write-Error "删除失败：$_"
        Invoke-Sqlcmd -Query "ROLLBACK TRANSACTION; DROP TABLE #TempDeleteList;" -ServerInstance $Server -Database $Database
    }
} else {
    Write-Host "无差异记录，无需操作"
}

几个重要的注意点 #

• SQL注入风险：上面的示例用了字符串拼接，生产环境建议换成参数化查询（比如用Invoke-Sqlcmd的-Parameter参数，或者直接用.NET的SqlCommand对象），避免注入问题。
• 同步完整性：如果还需要把Temp_Hold_Inv里新增的记录同步到Hold_Inv，可以对$compareResult里SRC = 'Temp_Hold_Inv'的记录执行INSERT操作，这样就实现双向同步了。
• 先测试再上线：在生产环境跑之前，一定要先把DELETE换成SELECT，确认待删除的记录完全符合预期，避免误删数据！

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