SqlBulkCopy Конструкторы
Определение
Важно!
Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.
Инициализирует новый экземпляр класса SqlBulkCopy.
Перегрузки
| Имя | Описание |
|---|---|
| SqlBulkCopy(SqlConnection) |
Инициализирует новый экземпляр класса SqlBulkCopy, используя указанный открытый экземпляр SqlConnection. |
| SqlBulkCopy(String) |
Инициализирует и открывает новый экземпляр класса SqlConnection в зависимости от предоставленного параметра |
| SqlBulkCopy(String, SqlBulkCopyOptions) |
Инициализирует и открывает новый экземпляр класса SqlConnection в зависимости от предоставленного параметра |
| SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction) |
Инициализирует новый экземпляр класса с помощью предоставленного SqlBulkCopy существующего открытого экземпляра SqlConnection. Экземпляр SqlBulkCopy ведет себя в соответствии с параметрами, указанными в параметре |
SqlBulkCopy(SqlConnection)
- Исходный код:
- System.Data.SqlClient.notsupported.cs
Инициализирует новый экземпляр класса SqlBulkCopy, используя указанный открытый экземпляр SqlConnection.
public:
SqlBulkCopy(System::Data::SqlClient::SqlConnection ^ connection);
public SqlBulkCopy(System.Data.SqlClient.SqlConnection connection);
new System.Data.SqlClient.SqlBulkCopy : System.Data.SqlClient.SqlConnection -> System.Data.SqlClient.SqlBulkCopy
Public Sub New (connection As SqlConnection)
Параметры
- connection
- SqlConnection
Уже открытый SqlConnection экземпляр, который будет использоваться для выполнения операции массового копирования. Если строка подключения не используется Integrated Security = true, можно использовать SqlCredential для передачи идентификатора пользователя и пароля более безопасно, чем путем указания идентификатора пользователя и пароля в виде текста в строке подключения.
Примеры
В следующем консольном приложении показано, как выполнять массовую загрузку данных с помощью уже открытого подключения. В этом примере объект SqlDataReader используется, чтобы скопировать данные из таблицы Production.Product в базе данных SQL Server AdventureWorks в такую же таблицу в этой же базе данных. Этот пример предназначен только для демонстрационных целей. Вы не будете использовать SqlBulkCopy для перемещения данных из одной таблицы в другую в той же базе данных в рабочем приложении. Обратите внимание, что исходные данные не должны находиться в SQL Server; вы можете использовать любой IDataReader источник данных, который можно считывать или загружать в объект DataTable.
Important
Этот пример не будет выполняться, если вы не создали рабочие таблицы, как описано в разделе "Пример настройки массового копирования". Этот код предназначен только для демонстрации синтаксиса использования SqlBulkCopy. Если исходные и целевые таблицы находятся в одном экземпляре SQL Server, проще и быстрее использовать инструкцию Transact-SQL INSERT ... SELECT для копирования данных.
using System.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();
// Open the destination connection. In the real world you would
// not use SqlBulkCopy to move data from one table to the other
// in the same database. This is for demonstration purposes only.
using (SqlConnection destinationConnection =
new SqlConnection(connectionString))
{
destinationConnection.Open();
// Set up the bulk copy object.
// Note that the column positions in the source
// data reader match the column positions in
// the destination table so there is no need to
// map columns.
using (SqlBulkCopy bulkCopy =
new SqlBulkCopy(destinationConnection))
{
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;";
}
}
Imports System.Data.SqlClient
Module Module1
Sub Main()
Dim connectionString As String = GetConnectionString()
' Open a connection to the AdventureWorks database.
Using sourceConnection As SqlConnection = _
New SqlConnection(connectionString)
sourceConnection.Open()
' Perform an initial count on the destination table.
Dim commandRowCount As New SqlCommand( _
"SELECT COUNT(*) FROM dbo.BulkCopyDemoMatchingColumns;", _
sourceConnection)
Dim countStart As Long = _
System.Convert.ToInt32(commandRowCount.ExecuteScalar())
Console.WriteLine("Starting row count = {0}", countStart)
' Get data from the source table as a SqlDataReader.
Dim commandSourceData As New SqlCommand( _
"SELECT ProductID, Name, ProductNumber " & _
"FROM Production.Product;", sourceConnection)
Dim reader As SqlDataReader = commandSourceData.ExecuteReader
' Open the destination connection. In the real world you would
' not use SqlBulkCopy to move data from one table to the other
' in the same database. This is for demonstration purposes only.
Using destinationConnection As SqlConnection = _
New SqlConnection(connectionString)
destinationConnection.Open()
' Set up the bulk copy object.
' The column positions in the source data reader
' match the column positions in the destination table,
' so there is no need to map columns.
Using bulkCopy As SqlBulkCopy = _
New SqlBulkCopy(destinationConnection)
bulkCopy.DestinationTableName = _
"dbo.BulkCopyDemoMatchingColumns"
Try
' Write from the source to the destination.
bulkCopy.WriteToServer(reader)
Catch ex As Exception
Console.WriteLine(ex.Message)
Finally
' Close the SqlDataReader. The SqlBulkCopy
' object is automatically closed at the end
' of the Using block.
reader.Close()
End Try
End Using
' Perform a final count on the destination table
' to see how many rows were added.
Dim countEnd As Long = _
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()
End Using
End Using
End Sub
Private Function GetConnectionString() As String
' 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;"
End Function
End Module
Комментарии
Так как подключение уже открыто при SqlBulkCopy инициализации экземпляра, подключение остается открытым после закрытия экземпляра SqlBulkCopy .
connection Если аргумент имеет значение NULL, ArgumentNullException создается исключение.
См. также раздел
Применяется к
SqlBulkCopy(String)
- Исходный код:
- System.Data.SqlClient.notsupported.cs
Инициализирует и открывает новый экземпляр класса SqlConnection в зависимости от предоставленного параметра connectionString. Конструктор использует SqlConnection для инициализации нового экземпляра класса SqlBulkCopy.
public:
SqlBulkCopy(System::String ^ connectionString);
public SqlBulkCopy(string connectionString);
new System.Data.SqlClient.SqlBulkCopy : string -> System.Data.SqlClient.SqlBulkCopy
Public Sub New (connectionString As String)
Параметры
- connectionString
- String
Строка, определяющая соединение, которое будет открыто для использования экземпляром SqlBulkCopy . Если строка подключения не использует Integrated Security = true, можно использовать SqlBulkCopy(SqlConnection) или SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction) и SqlCredential для передачи идентификатора пользователя и пароля более безопасно, чем путем указания идентификатора пользователя и пароля в виде текста в строка подключения.
Примеры
В следующем консольном приложении показано, как массово загружать данные с помощью подключения, указанного в виде строки. Подключение автоматически закрывается при закрытии экземпляра SqlBulkCopy .
В этом примере исходные данные сначала считываются из таблицы SQL Server в SqlDataReader экземпляр. Исходные данные не должны находиться в SQL Server; вы можете использовать любой IDataReader источник данных, который можно считывать или загружать в объект DataTable.
Important
Этот пример не будет выполняться, если вы не создали рабочие таблицы, как описано в разделе "Пример настройки массового копирования". Этот код предназначен только для демонстрации синтаксиса использования SqlBulkCopy. Если исходные и целевые таблицы находятся в одном экземпляре SQL Server, проще и быстрее использовать инструкцию Transact-SQL INSERT ... SELECT для копирования данных.
using System.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();
// Set up the bulk copy object using a connection string.
// 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))
{
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;";
}
}
Imports System.Data.SqlClient
Module Module1
Sub Main()
Dim connectionString As String = GetConnectionString()
' Open a connection to the AdventureWorks database.
Using sourceConnection As SqlConnection = _
New SqlConnection(connectionString)
sourceConnection.Open()
' Perform an initial count on the destination table.
Dim commandRowCount As New SqlCommand( _
"SELECT COUNT(*) FROM dbo.BulkCopyDemoMatchingColumns;", _
sourceConnection)
Dim countStart As Long = _
System.Convert.ToInt32(commandRowCount.ExecuteScalar())
Console.WriteLine("Starting row count = {0}", countStart)
' Get data from the source table as a SqlDataReader.
Dim commandSourceData As SqlCommand = New SqlCommand( _
"SELECT ProductID, Name, ProductNumber " & _
"FROM Production.Product;", sourceConnection)
Dim reader As SqlDataReader = commandSourceData.ExecuteReader
' Set up the bulk copy object using a connection string.
' In the real world you would not use SqlBulkCopy to move
' data from one table to the other in the same database.
Using bulkCopy As SqlBulkCopy = New SqlBulkCopy(connectionString)
bulkCopy.DestinationTableName = _
"dbo.BulkCopyDemoMatchingColumns"
Try
' Write from the source to the destination.
bulkCopy.WriteToServer(reader)
Catch ex As Exception
Console.WriteLine(ex.Message)
Finally
' Close the SqlDataReader. The SqlBulkCopy
' object is automatically closed at the end
' of the Using block.
reader.Close()
End Try
End Using
' Perform a final count on the destination table
' to see how many rows were added.
Dim countEnd As Long = _
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()
End Using
End Sub
Private Function GetConnectionString() As String
' 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;"
End Function
End Module
Комментарии
Подключение автоматически закрывается в конце операции массового копирования.
Если connectionString имеет значение NULL, ArgumentNullException создается исключение. Если connectionString это пустая строка, ArgumentException создается исключение.
См. также раздел
Применяется к
SqlBulkCopy(String, SqlBulkCopyOptions)
- Исходный код:
- System.Data.SqlClient.notsupported.cs
Инициализирует и открывает новый экземпляр класса SqlConnection в зависимости от предоставленного параметра connectionString. Конструктор использует этот SqlConnection метод для инициализации нового экземпляра SqlBulkCopy класса. Экземпляр SqlConnection ведет себя в соответствии с параметрами, указанными в параметре copyOptions .
public:
SqlBulkCopy(System::String ^ connectionString, System::Data::SqlClient::SqlBulkCopyOptions copyOptions);
public SqlBulkCopy(string connectionString, System.Data.SqlClient.SqlBulkCopyOptions copyOptions);
new System.Data.SqlClient.SqlBulkCopy : string * System.Data.SqlClient.SqlBulkCopyOptions -> System.Data.SqlClient.SqlBulkCopy
Public Sub New (connectionString As String, copyOptions As SqlBulkCopyOptions)
Параметры
- connectionString
- String
Строка, определяющая соединение, которое будет открыто для использования экземпляром SqlBulkCopy . Если строка подключения не использует Integrated Security = true, можно использовать SqlBulkCopy(SqlConnection) или SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction) и SqlCredential для передачи идентификатора пользователя и пароля более безопасно, чем путем указания идентификатора пользователя и пароля в виде текста в строка подключения.
- copyOptions
- SqlBulkCopyOptions
Сочетание значений из SqlBulkCopyOptions перечисления, определяющее, какие строки источника данных копируются в целевую таблицу.
Примеры
В следующем консольном приложении показано, как выполнять массовую нагрузку с помощью подключения, указанного в виде строки. Параметр устанавливается для использования значения в столбце удостоверений исходной таблицы при загрузке целевой таблицы. В этом примере исходные данные сначала считываются из таблицы SQL Server в SqlDataReader экземпляр. Исходная таблица и целевая таблица включают столбец Identity. По умолчанию новое значение для столбца Identity создается в целевой таблице для каждой добавленной строки. В этом примере параметр устанавливается при открытии подключения, который заставляет процесс массовой загрузки использовать значения удостоверений из исходной таблицы. Чтобы узнать, как параметр изменяет способ работы массовой загрузки, запустите пример с помощью dbo. Пустая таблица BulkCopyDemoMatchingColumns . Все строки загружают из источника. Затем снова запустите пример, не опустив таблицу. Исключение возникает, и код записывает сообщение в консоль, уведомляя вас о том, что строки не были добавлены из-за нарушений ограничений первичного ключа.
Important
Этот пример не будет выполняться, если вы не создали рабочие таблицы, как описано в разделе "Пример настройки массового копирования". Этот код предназначен только для демонстрации синтаксиса использования SqlBulkCopy. Если исходные и целевые таблицы находятся в одном экземпляре SQL Server, проще и быстрее использовать инструкцию Transact-SQL INSERT ... SELECT для копирования данных.
using System.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;";
}
}
Imports System.Data.SqlClient
Module Module1
Sub Main()
Dim connectionString As String = GetConnectionString()
' Open a connection to the AdventureWorks database.
Using sourceConnection As SqlConnection = _
New SqlConnection(connectionString)
sourceConnection.Open()
' Perform an initial count on the destination table.
Dim commandRowCount As New SqlCommand( _
"SELECT COUNT(*) FROM dbo.BulkCopyDemoMatchingColumns;", _
sourceConnection)
Dim countStart As Long = _
System.Convert.ToInt32(commandRowCount.ExecuteScalar())
Console.WriteLine("Starting row count = {0}", countStart)
' Get data from the source table as a SqlDataReader.
Dim commandSourceData As SqlCommand = New SqlCommand( _
"SELECT ProductID, Name, ProductNumber " & _
"FROM Production.Product;", sourceConnection)
Dim reader As SqlDataReader = 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 bulkCopy As SqlBulkCopy = _
New SqlBulkCopy(connectionString, SqlBulkCopyOptions.KeepIdentity)
bulkCopy.DestinationTableName = "dbo.BulkCopyDemoMatchingColumns"
Try
' Write from the source to the destination.
bulkCopy.WriteToServer(reader)
Catch ex As Exception
Console.WriteLine(ex.Message)
Finally
' Close the SqlDataReader. The SqlBulkCopy
' object is automatically closed at the end
' of the Using block.
reader.Close()
End Try
End Using
' Perform a final count on the destination table
' to see how many rows were added.
Dim countEnd As Long = _
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()
End Using
End Sub
Private Function GetConnectionString() As String
' 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;"
End Function
End Module
Комментарии
Подробные сведения о всех параметрах массового копирования в SqlBulkCopyOptions разделе можно получить.
См. также раздел
Применяется к
SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction)
- Исходный код:
- System.Data.SqlClient.notsupported.cs
Инициализирует новый экземпляр класса с помощью предоставленного SqlBulkCopy существующего открытого экземпляра SqlConnection. Экземпляр SqlBulkCopy ведет себя в соответствии с параметрами, указанными в параметре copyOptions . Если задано значение NULL SqlTransaction , операции копирования будут выполняться в рамках этой транзакции.
public:
SqlBulkCopy(System::Data::SqlClient::SqlConnection ^ connection, System::Data::SqlClient::SqlBulkCopyOptions copyOptions, System::Data::SqlClient::SqlTransaction ^ externalTransaction);
public SqlBulkCopy(System.Data.SqlClient.SqlConnection connection, System.Data.SqlClient.SqlBulkCopyOptions copyOptions, System.Data.SqlClient.SqlTransaction externalTransaction);
new System.Data.SqlClient.SqlBulkCopy : System.Data.SqlClient.SqlConnection * System.Data.SqlClient.SqlBulkCopyOptions * System.Data.SqlClient.SqlTransaction -> System.Data.SqlClient.SqlBulkCopy
Public Sub New (connection As SqlConnection, copyOptions As SqlBulkCopyOptions, externalTransaction As SqlTransaction)
Параметры
- connection
- SqlConnection
Уже открытый SqlConnection экземпляр, который будет использоваться для массового копирования. Если строка подключения не используется Integrated Security = true, можно использовать SqlCredential для передачи идентификатора пользователя и пароля более безопасно, чем путем указания идентификатора пользователя и пароля в виде текста в строке подключения.
- copyOptions
- SqlBulkCopyOptions
Сочетание значений из SqlBulkCopyOptions перечисления, определяющее, какие строки источника данных копируются в целевую таблицу.
- externalTransaction
- SqlTransaction
Существующий SqlTransaction экземпляр, в котором будет выполняться массовая копия.
Комментарии
Если параметры включаются UseInternalTransaction и externalTransaction аргумент не имеет значения NULL, создается исключение InvalidArgumentException .
Примеры, демонстрирующие использование SqlBulkCopy в транзакции, см. в разделе "Операции транзакций и массового копирования".