System.InvalidOperationException：给定的 ColumnMapping 与源或目标中的任何列不匹配

Question

嗨，大家好...

我遇到以下错误：

System.InvalidOperationException：给定的 ColumnMapping 与源或目标中的任何列都不匹配。 在 System.Data.SqlClient.SqlBulkCopy.AnalyzeTargetAndCreateUpdateBulkCommand （BulkCopySimpleResultSet internalResults） 在 System.Data.SqlClient.SqlBulkCopy.WriteToServerInternalRestContinuedAsync（BulkCopySimpleResultSet internalResults、 CancellationToken cts、 TaskCompletionSource1 源） 在 System.Data.SqlClient.SqlBulkCopy.WriteToServerInternalAsync （CancellationToken ctoken） 在 System.Data.SqlClient.SqlBulkCopy.WriteRowSourceToServerAsync（Int32 columnCount， CancellationToken ctoken） 在 System.Data.SqlClient.SqlBulkCopy.WriteToServer （DataTable 表，DataRowState rowState）...1 source) at System.Data.SqlClient.SqlBulkCopy.WriteToServerInternalRestAsync(CancellationToken cts, TaskCompletionSource

执行 sqlBulkCopy.WriteToServer（dataTable） 时引发异常。请看下面的代码：

    using (var sqlConnection = new SqlConnection(connectionString))  
    {  
        sqlConnection.Open();  
        using (var sqlBulkCopy = new SqlBulkCopy(connectionString, SqlBulkCopyOptions.KeepIdentity))  
        {  
            sqlBulkCopy.DestinationTableName = dataTable.TableName;  

            foreach (DataColumn column in dataTable.Columns)  
                sqlBulkCopy.ColumnMappings.Add(column.ColumnName, column.ColumnName);  

            //var i = 0;  

            //foreach (DataColumn column in dataTable.Columns)  
            //{  
            //    SqlBulkCopyColumnMapping columnMapping = sqlBulkCopy.ColumnMappings[i++];  
            //    Console.WriteLine("{0}\t{1}\t{2}", column.ColumnName, column.ColumnName == columnMapping.SourceColumn, column.ColumnName == columnMapping.DestinationColumn);  
            //}  

            sqlBulkCopy.WriteToServer(dataTable);  
        }  
    }  

注释的调试代码生成以下输出：

我花了几个小时在这上面。我错过了什么？我做错了什么？

Note：此问题总结整理于: System.InvalidOperationException: The given ColumnMapping does not match up with any column in the source or destination

Answer 1

出错的原因是某些列名不一致，即使所有列都显示为 true。

以下代码段导致此错误：

 foreach (DataColumn column in dataTable.Columns)  
          sqlBulkCopy.ColumnMappings.Add(column.ColumnName, column.ColumnName);  

sqlBulkCopy.ColumnMappings 的数据来自 Datatable，然后你用它来和 Datatable 中的列名做对比，它永远是相等的。

我认为您应该将 Datatable 的列名与数据库中表的列名进行比较。

我建议你使用以下代码来检查它：

                    using (SqlCommand command = new SqlCommand("SELECT COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME = N'scoretable'", sqlConnection))  
                    {  
                        DataTable columnNames = new DataTable();  
                        columnNames.Load(command.ExecuteReader());  
  
                        int i = 0;  
                        foreach (DataColumn column in dataTable.Columns)  
                        {  
                            string columnNameInDB = columnNames.Rows[i++]["COLUMN_NAME"].ToString();  
                            Console.WriteLine("{0}\t{1}\t{2}", column.ColumnName, columnNameInDB, columnNameInDB == column.ColumnName);  
                        }  
                    }  

---

如果回复有帮助，请点击“接受答案”并点赞。 注意：如果您想接收此线程的相关电子邮件通知，请按照我们文档中的步骤启用电子邮件通知。