SqlBulkCopy не работает

Ну это правда? Существуют ли имена столбцов с обеих сторон?

Если честно, я никогда не возился с маппингами. Я предпочитаю, чтобы все было просто - у меня есть промежуточная таблица, которая выглядит как ввод на сервере, затем я SqlBulkCopy в промежуточную таблицу и, наконец, запускаю хранимую процедуру для перемещения таблицы из промежуточной таблицы в фактическую таблицу; преимущества:

• нет проблем с повреждением данных в реальном времени, если импорт не удался в любой момент
• Я могу разместить транзакцию прямо вокруг SPROC
• Я могу заставить bcp работать без регистрации, зная, что SPROC будет зарегистрирован
• это просто ;-p (не возиться с сопоставлениями)

И напоследок: если вы имеете дело с большими объемами данных, вы можете повысить пропускную способность, используя IDataReader (поскольку это API потоковой передачи, а DataTable - это API с буферизацией). Например, я обычно подключаю импорт CSV, используя CsvReader в качестве источника для SqlBulkCopy. В качестве альтернативы я написал прокладки вокруг XmlReader, чтобы представить каждый элемент первого уровня в виде строки в IDataReader - очень быстро.

Я столкнулся с той же проблемой при копировании данных из доступа к SQLSERVER 2005, и я обнаружил, что сопоставления столбцов чувствительны к регистру в обоих источниках данных независимо от чувствительности баз данных.

Ответ Марка был бы моей рекомендацией (по использованию промежуточной таблицы). Это гарантирует, что если ваш источник не изменится, у вас будет меньше проблем с импортом в будущем.

Однако, по моему опыту, вы можете проверить следующие проблемы:

Имена столбцов совпадают в источнике и таблице Соответствие типов столбцов

Если вы думаете, что сделали это, но безуспешно. Вы можете попробовать следующее.

1 - Разрешить нули во всех столбцах таблицы 2 - закомментировать все сопоставления столбцов 3 - повторно запускать добавление одного столбца за раз, пока не обнаружишь, в чем заключается проблема

Это должно выявить ошибку

Одна из причин заключается в том, что: SqlBukCOpy чувствителен к регистру. Следуйте инструкциям:

1. В этом случае сначала вам нужно найти свой столбец в исходной таблице с помощью метода «Содержать» в C #.
2. Как только ваш целевой столбец сопоставлен с исходным столбцом, получите индекс этого столбца и укажите его имя в SqlBukCOpy.

Например: `

//Get Column from Source table 
  string sourceTableQuery = "Select top 1 * from sourceTable";
   DataTable dtSource=SQLHelper.SqlHelper.ExecuteDataset(transaction, CommandType.Text, sourceTableQuery).Tables[0];// i use sql helper for executing query you can use corde sw

 for (int i = 0; i < destinationTable.Columns.Count; i++)
                        {    //check if destination Column Exists in Source table
                            if (dtSource.Columns.Contains(destinationTable.Columns[i].ToString()))//contain method is not case sensitive
                            {
                                int sourceColumnIndex = dtSource.Columns.IndexOf(destinationTable.Columns[i].ToString());//Once column matched get its index
                                bulkCopy.ColumnMappings.Add(dtSource.Columns[sourceColumnIndex].ToString(), dtSource.Columns[sourceColumnIndex].ToString());//give coluns name of source table rather then destination table so that it would avoid case sensitivity
                            }

                        }
                        bulkCopy.WriteToServer(destinationTable);
                        bulkCopy.Close();

Я обнаружил, что столбцы в таблице и столбцы во входных данных должны как минимум совпадать. У вас может быть больше столбцов в таблице, но ввод все равно будет загружаться. Если у вас меньше, вы получите сообщение об ошибке.

Долгое время думал об ответе ... Даже если имена столбцов одинаковы, если тип данных отличается, вы получите ту же ошибку. Поэтому проверьте имена столбцов и их тип данных.

P.S .: промежуточные таблицы - это окончательный способ импорта.

Я бы согласился с идеей постановки, но вот мой подход к учету регистра. Рад, что меня критикуют на моем linq

using (SqlConnection connection = new SqlConnection(conn_str))
{
        connection.Open();
        using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connection))
        {
            bulkCopy.DestinationTableName = string.Format("[{0}].[{1}].[{2}]", targetDatabase, targetSchema, targetTable);
            var targetColumsAvailable = GetSchema(conn_str, targetTable).ToArray();
            foreach (var column in dt.Columns)
            {
                if (targetColumsAvailable.Select(x => x.ToUpper()).Contains(column.ToString().ToUpper()))
                {
                    var tc = targetColumsAvailable.Single(x => String.Equals(x, column.ToString(), StringComparison.CurrentCultureIgnoreCase));
                    bulkCopy.ColumnMappings.Add(column.ToString(), tc);
                }
            }

            // Write from the source to the destination.
            bulkCopy.WriteToServer(dt);
            bulkCopy.Close();
        }
}

и вспомогательный метод

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"];
                }
            }
        }
    }