c# – 如何使用SqlBulkCopyColumnMappingCollection？

发布时间：2020-12-15 06:47:03 所属栏目：百科来源：网络整理

导读：我想使用一个SqlBulkCopy方法,通过传递参数中的特定数据,我可以使用它的所有批量插入. 现在我需要做一些映射.我不知道如何创建一个SqlBulkCopyColumnMappingCollection,因为我计划传入映射集合并使用它.但是我不知道该怎么做.我不能做一个新的对象. 这是我现

我想使用一个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);
    }
}

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!