我已经使用 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 开始,并且比列数少一。如果有人帮我找到原因,请告诉我。