SqlBulkCopyOptions Перечисление
Определение
Важно!
Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.
Побитовый флаг, указывающий один или несколько вариантов использования с экземпляром SqlBulkCopy.
Это перечисление поддерживает побитовую комбинацию значений его членов.
public enum class SqlBulkCopyOptions
[System.Flags]
public enum SqlBulkCopyOptions
[<System.Flags>]
type SqlBulkCopyOptions =
Public Enum SqlBulkCopyOptions
- Наследование
-
SqlBulkCopyOptions
- Атрибуты
Поля
| Имя | Значение | Описание |
|---|---|---|
| Default | 0 | Используйте значения по умолчанию для всех параметров. |
| KeepIdentity | 1 | Сохранять идентификационные значения источника. Если это не указано, значения удостоверений назначаются назначением. |
| CheckConstraints | 2 | Проверка ограничений при вставке данных. По умолчанию ограничения не проверяются. |
| TableLock | 4 | Применить блокировку массового обновления на время операции массового копирования. Если не указано, используются блокировки строк. |
| KeepNulls | 8 | Сохранять значения null в целевой таблице независимо от значений параметров по умолчанию. Если значение не указано, значения NULL заменяются значениями по умолчанию, если это применимо. |
| FireTriggers | 16 | При указании сервер вызовет триггеры вставки для строк, вставляемых в базу данных. |
| UseInternalTransaction | 32 | При указании каждый пакет операции массового копирования будет выполняться в рамках транзакции. Если вы указываете этот параметр, а также предоставляете SqlTransaction объект конструктору, возникает событие ArgumentException . |
| AllowEncryptedValueModifications | 64 | При указании AllowEncryptedValueModifications позволяет массово копировать зашифрованные данные между таблицами или базами данных без расшифровки данных. Как правило, приложение выбирает данные из зашифрованных столбцов в одной таблице, не расшифровывая их (для подключения к базе данных используется ключевое слово Column Encryption Setting со значением Disabled), а затем с помощью этого параметра выполняет массовую вставку данных, которые по-прежнему зашифрованы. Используйте осторожность при указании AllowEncryptedValueModifications , так как это может привести к повреждению базы данных, так как драйвер не проверяет, зашифрованы ли данные действительно, или если он правильно зашифрован с использованием того же типа шифрования, алгоритма и ключа, что и целевой столбец. |
| CacheMetadata | 128 | При указании cacheMetadata кэширует метаданные целевой таблицы после первой операции массового копирования, что позволяет последующим операциям в ту же таблицу пропускать запрос обнаружения метаданных. Это может повысить производительность при выполнении нескольких операций массового копирования в одну целевую таблицу. Предупреждение: Используйте этот параметр, только если вы уверены, что схема целевой таблицы не изменится между операциями массового копирования. Если схема таблицы изменяется (столбцы добавлены, удалены или изменены), использование кэшированных метаданных может привести к повреждению данных, сбоям операций или неожиданному поведению. Вызовите ClearCachedMetadata() для очистки кэша, если схема изменяется. Кэш автоматически недействителен при DestinationTableName изменении другой таблицы. Для ColumnMappings изменения между операциями не требуется недопустимое кэширование, так как кэшированные метаданные описывают только схему целевой таблицы, а не сопоставление столбцов исходного назначения. Кэш не является автоматически недействительным при изменении контекста подключения. Если базовая SqlConnection база данных изменений (например, через ChangeDatabase(String)) или повторно подключается к другому серверу из-за отработки отказа, вызывающие должны вызываться ClearCachedMetadata() , чтобы обеспечить обновление метаданных. |
Примеры
В следующем консольном приложении показано, как выполнить массовую нагрузку, которая копирует значение в столбце удостоверений исходной таблицы в соответствующий столбец в целевой таблице, а не создает новое значение для столбца удостоверений каждой строки.
Чтобы узнать, как параметр изменяет способ работы массовой загрузки, запустите пример с помощью dbo. Пустая таблица BulkCopyDemoMatchingColumns . Все строки загружают из источника. Затем запустите пример еще раз, не опустив таблицу. Создается исключение, и код записывает сообщение в окно консоли, уведомляющее вас о том, что строки не были добавлены из-за нарушений первичного ключа.
Это важно
Этот пример не будет выполняться, если вы не создали рабочие таблицы, как описано в разделе "Пример настройки массового копирования". Этот код предназначен только для демонстрации синтаксиса использования SqlBulkCopy. Если исходные и целевые таблицы находятся в одном экземпляре SQL Server, проще и быстрее использовать инструкцию Transact-SQL INSERT … SELECT для копирования данных.
namespace SqlBulkCopy_KeepIdentity;
using System;
using System.Data;
// <Snippet1>
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.BulkCopyDemoMatchingColumns;",
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();
// Create the SqlBulkCopy object using a connection string
// and the KeepIdentity option.
// In the real world you would not use SqlBulkCopy to move
// data from one table to the other in the same database.
using (SqlBulkCopy bulkCopy =
new SqlBulkCopy(connectionString, SqlBulkCopyOptions.KeepIdentity))
{
bulkCopy.DestinationTableName =
"dbo.BulkCopyDemoMatchingColumns";
try
{
// Write from the source to the destination.
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;";
}
}
// </Snippet1>
Комментарии
Перечисление SqlBulkCopyOptions можно использовать при создании экземпляра SqlBulkCopy для изменения WriteToServer(DbDataReader) поведения методов для этого экземпляра.