0

我已经使用 IDataReader 实现了一个类,作为使用 SqlBulkCopy 的项目的一部分。我在这里发布了一些相关代码

public bool Read()
{
    var result = !fileStream.EndOfStream;
    if (result)
    {
        delimRow = fileStream.ReadLine();    
        splitRowValues = delimRow.Split(_delimiters);
        readRowCount++;
    }    
    return result;
}

private string[] Row
{
    get { return splitRowValues; }
}

public object GetValue(int i)
{
    return Row[i];
}

使用 SqlBulkCopy 和 IDataReader 的代码片段

SqlBulkCopy bulkInsert = new SqlBulkCopy(Constants.DBConnection, SqlBulkCopyOptions.UseInternalTransaction);
bulkInsert.BatchSize = 500;
bulkInsert.DestinationTableName = Constants.DestinationTable;
bulkInsert.WriteToServer(reader);

运行 WriteToServer 方法时,我注意到第一次调用 GetValue() 时索引值为 1,并且索引的最终值比列数小一。由于这个问题,批量加载最终会跳过一列。

我无法找到为什么 GetValue() 中的索引不将值从 1 到列数。实际上,该值应该从 0 开始,并且比列数少一。如果有人帮我找到原因,请告诉我。

4

1 回答 1

0

您没有指定映射。因此,默认情况下SqlBulkCopy可能会尝试按序号与数据库进行自动映射。

例如,如果您在数据库中的第一列是标识列(很有可能是这种情况),它将跳过index 0并以index 1替代开头。

于 2017-11-18T17:29:57.937 回答