SqlBulkCopy не работает

Ответ 1

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

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

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

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

Ответ 2

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

Ответ 3

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

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

Имена столбцов соответствуют источнику и таблице То, что типы столбцов соответствуют

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

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

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

Ответ 4

Одна из причин: SqlBukCOpy чувствителен к регистру. Выполните следующие шаги:

• В этом случае сначала вам нужно найти столбец в исходной таблице используя метод "Содержать" в С#.
• После того, как столбец "Место назначения" соответствует столбцу источника, введите индекс этот столбец и укажите его имя столбца в 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();

Ответ 5

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

Ответ 6

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

P.S.: стоповые таблицы являются окончательным способом импорта.

Ответ 7

Я бы пошел с постановкой, но вот мой подход к обработке чувствительной к регистру природы. Счастлив, чтобы меня критиковали за мой 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"];
                }
            }
        }
    }