Omitir algunas columnas en SqlBulkCopy

Question

Estoy usando SqlBulkCopy contra dos SQL Server 2008 con diferentes conjuntos de columnas (va a mover algunos datos del servidor prod al dev). Así que quiero omitir algunas columnas que aún no existen/aún no se eliminaron.

¿Cómo puedo hacer eso? Algún truco con ColumnMappings?

Editar:

es el siguiente paso:

DataTable table = new DataTable(); 
using (var adapter = new SqlDataAdapter(sourceCommand)) 
{ 
    adapter.Fill(table); 
} 

table.Columns 
    .OfType<DataColumn>() 
    .ForEach(c => bulk.ColumnMappings.Add(
     new SqlBulkCopyColumnMapping(c.ColumnName, c.ColumnName))); 

bulk.WriteToServer(table) 

y sale:

El ColumnMapping dado no coincide con ninguna columna en el origen o destino.

Answer 1

DataTable table = new DataTable(); 
using (var adapter = new SqlDataAdapter(sourceCommand)) 
{ 
    adapter.Fill(table); 
} 

using (SqlBulkCopy bulk = new SqlBulkCopy(targetConnection, SqlBulkCopyOptions.KeepIdentity, null) { DestinationTableName = tableName }) 
{ 
    foreach (string columnName in GetMapping(stringSource, stringTarget, tableName)) 
    { 
     bulk.ColumnMappings.Add(new SqlBulkCopyColumnMapping(columnName, columnName)); 
    } 

    targetConnection.Open(); 
    bulk.WriteToServer(table); 
} 

private static IEnumerable<string> GetMapping(string stringSource, string stringTarget, string tableName) 
{ 
    return Enumerable.Intersect(
     GetSchema(stringSource, tableName), 
     GetSchema(stringTarget, tableName), 
     StringComparer.Ordinal); // or StringComparer.OrdinalIgnoreCase 
} 

private static IEnumerable<string> GetSchema(string connectionString, string tableName) 
{ 
    using (SqlConnection connection = new SqlConnection(connectionString)) 
    using (SqlCommand command = connection.CreateCommand()) 
    { 
     command.CommandText = "sp_Columns"; 
     command.CommandType = CommandType.StoredProcedure; 

     command.Parameters.Add("@table_name", SqlDbType.NVarChar, 384).Value = tableName; 

     connection.Open(); 
     using (var reader = command.ExecuteReader()) 
     { 
      while (reader.Read()) 
      { 
       yield return (string)reader["column_name"]; 
      } 
     } 
    } 
} 

Answer 2

probar esto: SqlBulkCopyColumnMapping Class

esperamos que están buscando el mismo

Answer 3

Cuando se utiliza SqlBulkCopyColumnMapping, sólo las columnas para los que se crearon las asignaciones serán copiados.

Si no crea una asignación para una columna, será ignorado por el proceso de copia.

Puede ver esto en el código de demostración here - la tabla fuente de muestra en la base de datos de demostración de AdventureWorks contiene más columnas de las que se asignan o copian.

EDITAR

Es difícil estar seguro, sin más información acerca del esquema de base de datos, pero a ojo el problema es con esta declaración:

new SqlBulkCopyColumnMapping(c.ColumnName, c.ColumnName) 

Desde su descripción, parece que no se todas las columnas en la tabla fuente existen en la tabla de destino. Necesita un filtro en su ciclo de construcción SqlBulkCopyColumnMapping para omitir cualquier columna que no exista en el destino.

Mi C# no es lo suficientemente bueno para dar un ejemplo de lo que estoy seguro va a funcionar, pero en pseudocódigo sería

foreach column c in sourcetable 
{ 
    if c.ColumnName exists in destination_table.columns 
    { 
      new SqlBulkCopyColumnMapping(c.ColumnName, c.ColumnName) 
    } 
} 

(estoy seguro de que es posible convertir esto en una expresión lambda)

Tenga en cuenta que esto no es particularmente robusto en el escenario donde los nombres de columna coinciden pero los tipos de datos son incompatibles.

Answer 4

Ed Harper, esto es lo que parece, no hay código de pseudo (en este caso de DataTable dt (totalmente definido) a una tabla existente en el PP:

using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connectionString)) 
{ 
    bulkCopy.DestinationTableName = "dbo.DepartmentsItems"; 

    // Write from the source to the destination. 
    foreach (DataColumn c in dt.Columns) 
    { 
     bulkCopy.ColumnMappings.Add(c.ColumnName, c.ColumnName); 
    } 

    bulkCopy.WriteToServer(dt); 
    return dt.Rows.Count; 
}