Wie wird SqlBulkCopyColumnMappingCollection verwendet?

Question

Ich möchte eine SqlBulkCopy-Methode erstellen, die ich für alle meine Masseneinfügungen verwenden kann, indem bestimmte Daten über die Parameter übergeben werden.

Jetzt muss ich auf einige von ihnen Mapping tun. Ich weiß nicht, wie ich eine SqlBulkCopyColumnMappingCollection erstellen soll, da dies mein Plan war, in der Mapping-Sammlung zu übergeben und sie zu verwenden. Aber ich weiß nicht, wie ich es machen soll. Ich kann kein neues Objekt daraus machen.

Dies ist, was ich jetzt habe. Wie kann ich es hinzufügen?

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); 
    } 
} 

Answer 1

Sie benötigen keine neue Instanz davon zu schaffen - die SqlBulkCopy Klasse hat eine Eigenschaft, die eine Abbildung Sammlung, die Sie verwenden können:

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; 

     // Add your column mappings here 
     sbc.ColumnMappings.Add("field1","field3"); 
     sbc.ColumnMappings.Add("foo","bar"); 

     // Finally write to server 
     sbc.WriteToServer(dtInsertRows); 
    }  
} 

EDIT:

Basierend auf den Kommentaren war das Ziel, eine generische Funktion, z muss das Mapping nicht explizit in der Funktion fest codieren. Da die ColumnMappingCollection nicht instanziiert werden kann, würde ich empfehlen, eine List<string> oder eine ähnliche Datei, die die Spaltenzuordnungsdefinition enthält, an die Funktion zu übergeben. Zum Beispiel:

var columnMapping = new List<string>(); 
columnMapping.Add("field1,field3"); 
columnMapping.Add("foo,bar"); 

Dann neu definieren die Funktion als

public void BatchBulkCopy(DataTable dataTable, string DestinationTbl, 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); 
    } 
}