Sqlserver
 sql >> Base de Dados >  >> RDS >> Sqlserver

Recebeu um comprimento de coluna inválido do cliente bcp para colid 6


Eu sei que este post é antigo, mas me deparei com esse mesmo problema e finalmente descobri uma solução para determinar qual coluna estava causando o problema e reportá-lo conforme necessário. Eu determinei que colid retornado no SqlException não é baseado em zero, então você precisa subtrair 1 dele para obter o valor. Depois disso, é usado como o índice do _sortedColumnMappings ArrayList da instância SqlBulkCopy não é o índice dos mapeamentos de coluna que foram adicionados à instância SqlBulkCopy. Uma coisa a notar é que SqlBulkCopy irá parar no primeiro erro recebido, então este pode não ser o único problema, mas pelo menos ajuda a descobrir isso.
try
{
    bulkCopy.WriteToServer(importTable);
    sqlTran.Commit();
}    
catch (SqlException ex)
{
    if (ex.Message.Contains("Received an invalid column length from the bcp client for colid"))
    {
        string pattern = @"\d+";
        Match match = Regex.Match(ex.Message.ToString(), pattern);
        var index = Convert.ToInt32(match.Value) -1;

        FieldInfo fi = typeof(SqlBulkCopy).GetField("_sortedColumnMappings", BindingFlags.NonPublic | BindingFlags.Instance);
        var sortedColumns = fi.GetValue(bulkCopy);
        var items = (Object[])sortedColumns.GetType().GetField("_items", BindingFlags.NonPublic | BindingFlags.Instance).GetValue(sortedColumns);

        FieldInfo itemdata = items[index].GetType().GetField("_metadata", BindingFlags.NonPublic | BindingFlags.Instance);
        var metadata = itemdata.GetValue(items[index]);

        var column = metadata.GetType().GetField("column", BindingFlags.Public | BindingFlags.NonPublic | BindingFlags.Instance).GetValue(metadata);
        var length = metadata.GetType().GetField("length", BindingFlags.Public | BindingFlags.NonPublic | BindingFlags.Instance).GetValue(metadata);
        throw new DataFormatException(String.Format("Column: {0} contains data with a length greater than: {1}", column, length));
    }

    throw;
}