使用 SQLBulkCopy 插入相关表

Question

我正在使用 SQL 批量复制将数据从 Excel 读取到 SQL DB。在数据库中，我有两个表，我需要从 Excel 中插入这些数据。 Table A 和 Table B 使用来自 Table A 的 ID（主键 IDENTITY）将相应的行记录插入到 Table B。
我可以使用以下代码插入一个表 (Table A)。

using (SqlConnection connection = new SqlConnection(strConnection)) {
    connection.Open();
    using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connection)) {
        bulkCopy.DestinationTableName = "dbo.[EMPLOYEEINFO]";
        try {
            // Write from the source to the destination.
            SqlBulkCopyColumnMapping NameMap = new SqlBulkCopyColumnMapping(data.Columns[0].ColumnName, "EmployeeName");
            SqlBulkCopyColumnMapping GMap = new SqlBulkCopyColumnMapping(data.Columns[1].ColumnName, "Gender");
            SqlBulkCopyColumnMapping CMap = new SqlBulkCopyColumnMapping(data.Columns[2].ColumnName, "City");
            SqlBulkCopyColumnMapping AMap = new SqlBulkCopyColumnMapping(data.Columns[3].ColumnName, "HomeAddress");

            bulkCopy.ColumnMappings.Add(NameMap);
            bulkCopy.ColumnMappings.Add(GMap);
            bulkCopy.ColumnMappings.Add(CMap);
            bulkCopy.ColumnMappings.Add(AMap);

            bulkCopy.WriteToServer(data);
        }
        catch (Exception ex) {
            Console.WriteLine(ex.Message);
        }
    }
}

但是我不知道如何为两个受外键关系绑定的表扩展它。特别是，Table B 使用来自Table A 的标识值任何示例都会很棒。我用谷歌搜索了它，SO 上的所有线程都无法给出一个工作示例。

Answer 1

AFAIK 批量复制只能用于上传到单个表中。为了实现将批量上传到两个表中，您将需要两次批量上传。您的问题来自使用作为身份的外键。但是，您可以解决此问题。我很确定批量复制是按顺序上传的，这意味着如果您上传 1,000 条记录，最后一条记录的 ID 为 10,197，那么第一条记录的 ID 为 9,198！所以我的建议是上传你的第一个表，上传后检查最大 id，减去记录数，然后从那里开始工作！

当然，在高使用率的数据库中，有人可能会在您之后插入，因此您需要通过选择与您的最后一条记录匹配的其他详细信息来获取顶部 id（假设（最多）所有字段的组合将是保证是唯一的）。只有您知道这是否可能是一个问题。

替代方法是首先不使用标识列，但我认为您无法控制设计？在我年轻的时候，我犯了使用身份的错误，我现在从来没有这样做过。他们总能找到办法回来咬人！

例如添加第二条数据：

DataTable secondTable = new DataTable("SecondTable");
secondTable.Columns.Add("ForeignKey", typeof(int));
secondTable.Columns.Add("DataField", typeof(yourDataType));

...

将数据添加到 secondTable。

（取决于第二个数据的格式）

int cnt = 0;
foreach (var d in mySecondData)
{
    DataRow newRow = secondTable.NewRow();
    newRow["ForeignKey"] = cnt;
    newRow["DataField"] = d.YourData;
    secondTable.Rows.Add(newRow);
}

然后在你找到起始身份（int startID）之后。

for (int i = 0; i < secondTable.Rows.Count; i++)
{
    secondTable["ForeignKey"] = secondTable["ForeignKey"] + startID;
}

最后：

bulkCopy.DestinationTableName = "YourSecondTable";
bulkCopy.WriteToServer(secondTable);