如何使用 SqlBulkCopy.WriteToServer 将行批量插入 SQL Server（仅当不存在时）

Question

我们使用 SqlBulkCopy.WriteToServer 批量插入到 SQL Server，效果非常好。但是，当记录已存在时，它会失败。我们需要的是“忽略”那些已经存在的行，并插入不存在的行。

SqlException：违反主键约束“PK__Pharmacy__3214EC072C1E8537”。 无法在对象“dbo.Pharmacy”中插入重复的键。重复的键值是 (797cba76-8bbd-4dbd-a360-4f8e8a6ef85b)

我们如何使用 SqlBulkCopy.WriteToServer 插入行（如果它们不存在）而不破坏或失败。

try
{
    // Write from the source to the destination.
    bulkCopy.WriteToServer(dt);
}
catch (Exception ex)
{
    throw new Exception($"BulkInject error in {dt.TableName}", ex);
}

更新： 值得一提的是，这在大多数情况下都运行良好，98% 的情况下都能正确批量插入。只有 2% 的情况下，某些行已经存在，这会导致批量插入失败。

我们需要什么：我们需要“忽略”这些行（如果存在）

我们要做的：将源数据库的数据传输到目标数据库。这不是完整的转移。我们传输源数据的子集。目标数据库不为空。它已经包含数据。所以更新不是一个选择。如果不存在，我们需要插入。

我们将大约 30 个表从源数据库批量插入到目标数据库。所以我们有一个通用函数来执行字段映射、批量插入等...它与处理所有这些表的函数相同。

再说一遍，我们需要什么：我们正在使用 SqlBulkCopy.WriteToServer，并且我们需要“忽略”行（如果存在）。谢谢

Answer 1

SqlBulkCopy顾名思义是用于复制（插入）批量记录，它不能执行更新操作。因此表值参数来救援，它允许我们使用 DataTable 将多条记录传递到存储过程，我们可以在存储过程中进行处理...

SQL Server 2008（或更高版本）提出了一个名为 MERGE 的好函数，它允许当记录不存在时执行 INSERT 操作，当表中存在记录时执行 UPDATE 操作。

您可以在 SQL Server 中创建用户定义的表类型

最后，创建以下类似类型的存储过程，它将接受整个 DataTable 作为参数，然后将表中不存在的和已经存在的所有记录插入到表中存在将被更新。

CREATE PROCEDURE [dbo].[Update_Pharmacy]
      @tblCustomers CustomerType READONLY
AS
BEGIN
      SET NOCOUNT ON;
 
      MERGE INTO Customers c1
      USING @tblCustomers c2
      ON c1.CustomerId=c2.Id
      WHEN MATCHED THEN
      UPDATE SET c1.Name = c2.Name
            ,c1.Country = c2.Country
      WHEN NOT MATCHED THEN
      INSERT VALUES(c2.Id, c2.Name, c2.Country);
END

性能将不如批量复制实用程序，但不知何故，它是我在实时数据库处理报告数据库时使用的选项之一。