c# - 使用 SqlBulkCopy 时如何检索服务器生成的标识值

Question

我知道我可以通过不指定 SqlBulkCopyOptions.KeepIdentity 来批量插入带有标识列的表，如前所述 here .

我希望能够做的是获取服务器生成的身份值并将它们放入我的数据表，甚至列表中。我看到了this发布，但我希望我的代码是通用的，并且我不能在所有表中都有版本列。非常感谢任何建议。这是我的代码:

public void BulkInsert(DataTable dataTable, string DestinationTbl, int batchSize)
{
    // Get the DataTable 
    DataTable dtInsertRows = dataTable;

    using (SqlBulkCopy sbc = new SqlBulkCopy(sConnectStr))
    {
        sbc.DestinationTableName = DestinationTbl;

        // Number of records to be processed in one go
        sbc.BatchSize = batchSize;

        // Add your column mappings here
        foreach (DataColumn dCol in dtInsertRows.Columns)
        {
            sbc.ColumnMappings.Add(dCol.ColumnName, dCol.ColumnName);
        }

        // Finally write to server
        sbc.WriteToServer(dtInsertRows);
    }
}

Answer 1

据我所知，你不能。

获取身份字段值的唯一方法(据我所知)是使用 SCOPE_IDENTITY()当您逐行插入时；或者使用 OUTPUT插入整个集合时的方法。

“最简单”的方法可能是您将 SqlBulkCopy 表中的记录，然后稍后再次取回它们。问题可能是很难再次从服务器正确(快速)获取这些行。 (例如，使用 WHERE 子句和 IN (guid1, guid2, .., guid999998, guid999999) = 会很丑陋(而且很慢)

我假设这里的性能是一个问题，因为您已经在使用 SqlBulkCopy，所以我建议使用 OUTPUT在这种情况下，您首先需要一个暂存表来 SqlBulkCopy 您的记录。然后，该表应包含某种批处理标识符(GUID？)，以允许多个线程并排运行。您需要一个存储过程来 INSERT <table> OUTPUT inserted.* SELECT将临时表中的数据放入实际目标表中，并再次清理临时表。来自所述过程的返回记录集然后将 1:1 匹配到负责填充登台表的原始数据集，但当然你不应该依赖它的顺序。换句话说:您的下一个挑战是将返回的身份字段与应用程序中的原始记录匹配。

仔细想想，我会说在所有情况下——除了逐行和 SCOPY_IDENTITY() 方法，它会很慢——你需要拥有(或添加)数据的“ key ”，用于将生成的 ID 链接回原始数据 =/