我想使用一个sqlBulkCopy方法,通过传递参数中的特定数据,我可以使用它的所有批量插入.
现在我需要做一些映射.我不知道如何创建一个sqlBulkCopyColumnMappingCollection,因为我计划传入映射集合并使用它.但是我不知道该怎么做.我不能做一个新的对象.
这是我现在所在如何添加它做映射放通过？
public void BatchBulkCopy(DataTable dataTable,string DestinationTbl,int batchSize)
{
// Get the DataTable
DataTable dtInsertRows = dataTable;
using (sqlBulkCopy sbc = new sqlBulkCopy(connectionString,sqlBulkCopyOptions.KeepIdentity))
{
sbc.DestinationTableName = DestinationTbl;
// Number of records to be processed in one go
sbc.BatchSize = batchSize;
// Finally write to server
sbc.WriteToServer(dtInsertRows);
}
}
解决方法
您不需要创建一个新的实例–sqlBulkCopy类有一个属性,它是一个可以使用的映射集合：
public void BatchBulkCopy(DataTable dataTable,sqlBulkCopyOptions.KeepIdentity)) { sbc.DestinationTableName = DestinationTbl; // Number of records to be processed in one go sbc.BatchSize = batchSize; // Add your column mappings here sbc.ColumnMappings.Add("field1","field3"); sbc.ColumnMappings.Add("foo","bar"); // Finally write to server sbc.WriteToServer(dtInsertRows); } }
编辑：
根据意见,目标是制定一般的功能,例如不必在函数中显式地对映射进行硬编码.由于ColumnMappingCollection不能被实例化,我建议传递一个List< string>或类似的包含列映射定义到函数中.例如：
var columnMapping = new List<string>();
columnMapping.Add("field1,field3");
columnMapping.Add("foo,bar");
然后将功能重新定义为
public void BatchBulkCopy(DataTable dataTable,int batchSize,List<string> columnMapping)
{
// Get the DataTable
DataTable dtInsertRows = dataTable;
using (sqlBulkCopy sbc = new sqlBulkCopy(connectionString,sqlBulkCopyOptions.KeepIdentity))
{
sbc.DestinationTableName = DestinationTbl;
// Number of records to be processed in one go
sbc.BatchSize = batchSize;
// Add your column mappings here
foreach(var mapping in columnMapping)
{
var split = mapping.Split(new[] { ',' });
sbc.ColumnMappings.Add(split.First(),split.Last());
}
// Finally write to server
sbc.WriteToServer(dtInsertRows);
}
}
