SqlBulkCopyColumnMappingCollection Класс
Определение
Важно!
Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.
Коллекция объектов SqlBulkCopyColumnMapping, наследующих от CollectionBase.
public ref class SqlBulkCopyColumnMappingCollection sealed : System::Collections::CollectionBase
public sealed class SqlBulkCopyColumnMappingCollection : System.Collections.CollectionBase
type SqlBulkCopyColumnMappingCollection = class
inherit CollectionBase
Public NotInheritable Class SqlBulkCopyColumnMappingCollection
Inherits CollectionBase
- Наследование
-
SqlBulkCopyColumnMappingCollection
Примеры
В следующем примере выполняется массовое копирование данных из исходной таблицы в примере базы данных AdventureWorks в целевую таблицу в той же базе данных. Хотя число столбцов в назначении совпадает с количеством столбцов в источнике, имена столбцов и порядковые позиции не совпадают. SqlBulkCopyColumnMapping добавляются в SqlBulkCopyColumnMappingCollection для объекта , SqlBulkCopy чтобы создать карту столбцов для массового копирования.
Важно!
Этот пример не будет выполняться, если вы не создали рабочие таблицы, как описано в разделе Пример установки массового копирования.
Этот код предназначен только для демонстрации синтаксиса использования SqlBulkCopy. Если исходная и целевая таблицы находятся в одном экземпляре SQL Server, проще и быстрее использовать инструкцию Transact-SQL INSERT … SELECT
для копирования данных.
using System;
using System.Data;
using Microsoft.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = GetConnectionString();
// Open a sourceConnection to the AdventureWorks database.
using (SqlConnection sourceConnection =
new SqlConnection(connectionString))
{
sourceConnection.Open();
// Perform an initial count on the destination table.
SqlCommand commandRowCount = new SqlCommand(
"SELECT COUNT(*) FROM " +
"dbo.BulkCopyDemoDifferentColumns;",
sourceConnection);
long countStart = System.Convert.ToInt32(
commandRowCount.ExecuteScalar());
Console.WriteLine("Starting row count = {0}", countStart);
// Get data from the source table as a SqlDataReader.
SqlCommand commandSourceData = new SqlCommand(
"SELECT ProductID, Name, " +
"ProductNumber " +
"FROM Production.Product;", sourceConnection);
SqlDataReader reader =
commandSourceData.ExecuteReader();
// Set up the bulk copy object.
using (SqlBulkCopy bulkCopy =
new SqlBulkCopy(connectionString))
{
bulkCopy.DestinationTableName =
"dbo.BulkCopyDemoDifferentColumns";
// The column order in the source doesn't match the order
// in the destination, so ColumnMappings must be defined.
bulkCopy.ColumnMappings.Add("ProductID", "ProdID");
bulkCopy.ColumnMappings.Add("Name", "ProdName");
bulkCopy.ColumnMappings.Add("ProductNumber", "ProdNum");
// Write from the source to the destination.
try
{
bulkCopy.WriteToServer(reader);
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
finally
{
// Close the SqlDataReader. The SqlBulkCopy
// object is automatically closed at the end
// of the using block.
reader.Close();
}
}
// Perform a final count on the destination
// table to see how many rows were added.
long countEnd = System.Convert.ToInt32(
commandRowCount.ExecuteScalar());
Console.WriteLine("Ending row count = {0}", countEnd);
Console.WriteLine("{0} rows were added.", countEnd - countStart);
Console.WriteLine("Press Enter to finish.");
Console.ReadLine();
}
}
private static string GetConnectionString()
// To avoid storing the sourceConnection string in your code,
// you can retrieve it from a configuration file.
{
return "Data Source=(local); " +
" Integrated Security=true;" +
"Initial Catalog=AdventureWorks;";
}
}
Комментарии
Сопоставления столбцов определяют сопоставление между источником данных и целевой таблицей.
Если сопоставления не определены ( то есть коллекция пуста), ColumnMappings столбцы сопоставляются неявно на основе порядкового положения. При этом исходная и целевая схемы должны совпадать. В противном случае InvalidOperationException создается исключение .
ColumnMappings Если коллекция не пуста, необходимо указывать не все столбцы, присутствующие в источнике данных. Элементы, не сопоставленные с коллекцией, игнорируются.
Обращаться к исходным и целевым столбцам можно по имени или порядковому номеру. В одной коллекции сопоставлений можно сочетать ссылки на столбцы по имени и порядковый номер.
Свойства
Item[Int32] |
Возвращает объект SqlBulkCopyColumnMapping по указанному индексу. |
Методы
Add(Int32, Int32) |
Создает новый SqlBulkCopyColumnMapping и добавляет его в коллекцию, используя порядковые номера исходного столбца и столбца назначения. |
Add(Int32, String) |
Создает новый SqlBulkCopyColumnMapping и добавляет его в коллекцию, используя порядковый номер исходного столбца и строку для столбца назначения. |
Add(SqlBulkCopyColumnMapping) |
Добавляет заданное сопоставление в SqlBulkCopyColumnMappingCollection. |
Add(String, Int32) |
Создает новый SqlBulkCopyColumnMapping и добавляет его в коллекцию, используя имя исходного столбца и порядковый номер столбца назначения. |
Add(String, String) |
Создает новый SqlBulkCopyColumnMapping и добавляет его в коллекцию, используя имена исходного столбца и столбца назначения. |
Clear() |
Удаляет содержимое коллекции. |
Contains(SqlBulkCopyColumnMapping) |
Получает значение, указывающее, существует ли конкретный объект SqlBulkCopyColumnMapping в коллекции. |
CopyTo(SqlBulkCopyColumnMapping[], Int32) |
Копирует элементы коллекции SqlBulkCopyColumnMappingCollection в массив элементов SqlBulkCopyColumnMapping начиная с определенного индекса. |
IndexOf(SqlBulkCopyColumnMapping) |
Возвращает индекс указанного объекта SqlBulkCopyColumnMapping. |
Insert(Int32, SqlBulkCopyColumnMapping) |
Вставляет новый объект SqlBulkCopyColumnMapping по указанному индексу. |
Remove(SqlBulkCopyColumnMapping) |
Удаляет заданный элемент SqlBulkCopyColumnMapping из SqlBulkCopyColumnMappingCollection. |
RemoveAt(Int32) |
Удаляет из коллекции сопоставление с заданным индексом. |