SqlBulkCopy イベント
SqlBulkCopy クラス
アセンブリ: System.Data (system.data.dll 内)

Public NotInheritable Class SqlBulkCopy Implements IDisposable
public sealed class SqlBulkCopy : IDisposable
public final class SqlBulkCopy implements IDisposable
public final class SqlBulkCopy implements IDisposable

Microsoft SQL Server は、同一サーバー上または異なるサーバー間で、データをあるテーブルから別のテーブルに移動するための手段として、bcp というコマンド プロンプト ユーティリティを備えています。SqlBulkCopy クラスを使用すると、これと同様の機能を提供するマネージ コード ソリューションを作成できます。SQL Server のテーブルにデータを読み込む方法は他にもありますが (INSERT ステートメントなど)、SqlBulkCopy を使用すると、パフォーマンスを大幅に向上させることができます。
SqlBulkCopy クラスは、データの書き込み先が SQL Server のテーブルの場合にしか使用できません。ただし、データ ソースは SQL Server に限定されません。DataTable のインスタンスにデータを読み込んだり、IDataReader のインスタンスでデータを読み取ることができれば、どのようなデータ ソースでも使用できます。

次のコンソール アプリケーションは、SqlBulkCopy クラスを使用してデータを読み込む方法を示しています。この例では、SqlDataReader を使用し、SQL Server 2005 の AdventureWorks データベースに格納された Production.Product テーブルのデータを、同じデータベース内の同等のテーブルにコピーします。
![]() |
---|
このサンプルを実行するには、あらかじめ、「バルク コピーの例のためのテーブルの作成」の説明に従って作業テーブルを作成しておく必要があります。このコードは、SqlBulkCopy を使用する構文を示すためだけに提供されています。同じ SQL Server インスタンスにコピー元テーブルとコピー先テーブルが存在する場合、Transact-SQL の INSERT … SELECT ステートメントを使用した方が容易かつ迅速にデータをコピーできます。 |
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 ' 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
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;"; } }

System.Data.SqlClient.SqlBulkCopy


Windows 98, Windows 2000 SP4, Windows Millennium Edition, Windows Server 2003, Windows XP Media Center Edition, Windows XP Professional x64 Edition, Windows XP SP2, Windows XP Starter Edition
開発プラットフォームの中には、.NET Framework によってサポートされていないバージョンがあります。サポートされているバージョンについては、「システム要件」を参照してください。


SqlBulkCopy コンストラクタ (String)
アセンブリ: System.Data (system.data.dll 内)


connectionString が null の場合、ArgumentNullException がスローされます。connectionString が空の文字列の場合、ArgumentException がスローされます。

次のコンソール アプリケーションでは、文字列として指定された接続を使用して、データの一括読み込みを行います。SqlBulkCopy インスタンスが閉じられると、接続は自動的に解除されます。
この例では、ソース データは最初に SQL Server テーブルから SqlDataReader インスタンスに読み込まれます。なお、ソース データについては、SQL Server に格納されている必要はありません。IDataReader での読み取りと、DataTable への読み込みが可能であれば、どのようなデータ ソースでも使用できます。
![]() |
---|
このサンプルを実行するには、あらかじめ、「バルク コピーの例のためのテーブルの作成」の説明に従って作業テーブルを作成しておく必要があります。このコードは、SqlBulkCopy を使用する構文を示すためだけに提供されています。同じ SQL Server インスタンスにコピー元テーブルとコピー先テーブルが存在する場合、Transact-SQL の INSERT … SELECT ステートメントを使用した方が容易かつ迅速にデータをコピーできます。 |
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
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;"; } }

Windows 98, Windows 2000 SP4, Windows Millennium Edition, Windows Server 2003, Windows XP Media Center Edition, Windows XP Professional x64 Edition, Windows XP SP2, Windows XP Starter Edition
開発プラットフォームの中には、.NET Framework によってサポートされていないバージョンがあります。サポートされているバージョンについては、「システム要件」を参照してください。


SqlBulkCopy コンストラクタ (String, SqlBulkCopyOptions)
アセンブリ: System.Data (system.data.dll 内)

Dim connectionString As String Dim copyOptions As SqlBulkCopyOptions Dim instance As New SqlBulkCopy(connectionString, copyOptions)


次のコンソール アプリケーションでは、文字列として指定された接続を使用して一括読み込みを実行します。対象テーブルへの読み込みを実行するとき、ソース テーブルの ID 列の値を使用するようにオプションが設定されています。この例では、ソース データは最初に SQL Server テーブルから SqlDataReader インスタンスに読み込まれます。読み込み元のテーブルと読み込み先のテーブルには、それぞれ ID 列が存在します。読み込み先のテーブルには、追加された行ごとに ID 列の新しい値が既定で生成されます。この例では、接続が確立されたとき、一括読み込みプロセスに、読み込み元テーブル側の ID 値が使用されるように、オプションを設定しています。このオプションが一括読み込みの動作にどのように影響しているかを確認するには、dbo.BulkCopyDemoMatchingColumns テーブルを空にした状態でサンプルを実行します。すべての行はソースから読み込まれます。次に、このテーブルを空にせずに、もう一度サンプルを実行します。例外がスローされ、主キー制約の違反によって行が追加されなかったことを通知するコンソール メッセージが出力されます。
![]() |
---|
このサンプルを実行するには、あらかじめ、「バルク コピーの例のためのテーブルの作成」の説明に従って作業テーブルを作成しておく必要があります。このコードは、SqlBulkCopy を使用する構文を示すためだけに提供されています。同じ SQL Server インスタンスにコピー元テーブルとコピー先テーブルが存在する場合、Transact-SQL の INSERT … SELECT ステートメントを使用した方が容易かつ迅速にデータをコピーできます。 |
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
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;"; } }

Windows 98, Windows 2000 SP4, Windows Millennium Edition, Windows Server 2003, Windows XP Media Center Edition, Windows XP Professional x64 Edition, Windows XP SP2, Windows XP Starter Edition
開発プラットフォームの中には、.NET Framework によってサポートされていないバージョンがあります。サポートされているバージョンについては、「システム要件」を参照してください。


SqlBulkCopy コンストラクタ

名前 | 説明 |
---|---|
SqlBulkCopy (SqlConnection) | 既に接続の確立されている SqlConnection のインスタンスを使用し、SqlBulkCopy クラスの新しいインスタンスを初期化します。 |
SqlBulkCopy (String) | 指定された connectionString に基づいて、SqlConnection の新しいインスタンスを初期化し、接続を確立します。このコンストラクタは、SqlConnection を使用して、SqlBulkCopy クラスの新しいインスタンスを初期化します。 |
SqlBulkCopy (String, SqlBulkCopyOptions) | 指定された connectionString に基づいて、SqlConnection の新しいインスタンスを初期化し、接続を確立します。このコンストラクタは、SqlConnection を使用して、SqlBulkCopy クラスの新しいインスタンスを初期化します。SqlConnection のインスタンスは、copyOptions パラメータに指定されたオプションに従って動作します。 |
SqlBulkCopy (SqlConnection, SqlBulkCopyOptions, SqlTransaction) | 既に接続の確立されている SqlConnection のインスタンスを使用し、SqlBulkCopy クラスの新しいインスタンスを初期化します。SqlBulkCopy のインスタンスは、copyOptions パラメータに指定されたオプションに従って動作します。指定された SqlTransaction が null でなければ、トランザクション内でコピー操作が実行されます。 |

SqlBulkCopy コンストラクタ (SqlConnection)
アセンブリ: System.Data (system.data.dll 内)

Public Sub New ( _ connection As SqlConnection _ )
Dim connection As SqlConnection Dim instance As New SqlBulkCopy(connection)
public SqlBulkCopy ( SqlConnection connection )
public: SqlBulkCopy ( SqlConnection^ connection )
public SqlBulkCopy ( SqlConnection connection )
public function SqlBulkCopy ( connection : SqlConnection )


次のコンソール アプリケーションでは、既に確立された接続を使用して、データの一括読み込みを行います。この例では、SqlDataReader を使用し、SQL Server 2005 の AdventureWorks データベースに格納された Production.Product テーブルのデータを、同じデータベース内の同等のテーブルにコピーします。この例は、デモンストレーションのためだけに作成されています。実際のアプリケーションでは、同じデータベース内のテーブル間でデータを移動するために SqlBulkCopy を使用することはありません。なお、ソース データについては、SQL Server に格納されている必要はありません。IDataReader での読み取りと、DataTable への読み込みが可能であれば、どのようなデータ ソースでも使用できます。
![]() |
---|
このサンプルを実行するには、あらかじめ、「バルク コピーの例のためのテーブルの作成」の説明に従って作業テーブルを作成しておく必要があります。このコードは、SqlBulkCopy を使用する構文を示すためだけに提供されています。同じ SQL Server インスタンスにコピー元テーブルとコピー先テーブルが存在する場合、Transact-SQL の INSERT … SELECT ステートメントを使用した方が容易かつ迅速にデータをコピーできます。 |
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 ' 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
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;"; } }

Windows 98, Windows 2000 SP4, Windows Millennium Edition, Windows Server 2003, Windows XP Media Center Edition, Windows XP Professional x64 Edition, Windows XP SP2, Windows XP Starter Edition
開発プラットフォームの中には、.NET Framework によってサポートされていないバージョンがあります。サポートされているバージョンについては、「システム要件」を参照してください。


SqlBulkCopy コンストラクタ (SqlConnection, SqlBulkCopyOptions, SqlTransaction)
アセンブリ: System.Data (system.data.dll 内)

Public Sub New ( _ connection As SqlConnection, _ copyOptions As SqlBulkCopyOptions, _ externalTransaction As SqlTransaction _ )
Dim connection As SqlConnection Dim copyOptions As SqlBulkCopyOptions Dim externalTransaction As SqlTransaction Dim instance As New SqlBulkCopy(connection, copyOptions, externalTransaction)
public SqlBulkCopy ( SqlConnection connection, SqlBulkCopyOptions copyOptions, SqlTransaction externalTransaction )
public: SqlBulkCopy ( SqlConnection^ connection, SqlBulkCopyOptions copyOptions, SqlTransaction^ externalTransaction )
public SqlBulkCopy ( SqlConnection connection, SqlBulkCopyOptions copyOptions, SqlTransaction externalTransaction )
public function SqlBulkCopy ( connection : SqlConnection, copyOptions : SqlBulkCopyOptions, externalTransaction : SqlTransaction )

オプションに UseInternalTransaction が指定されているとき、externalTransaction 引数が null 以外の場合、InvalidArgumentException がスローされます。
トランザクションで SqlBulkCopy を使用する方法の例については、「トランザクションでのバルク コピー操作の実行」を参照してください。

Windows 98, Windows 2000 SP4, Windows Millennium Edition, Windows Server 2003, Windows XP Media Center Edition, Windows XP Professional x64 Edition, Windows XP SP2, Windows XP Starter Edition
開発プラットフォームの中には、.NET Framework によってサポートされていないバージョンがあります。サポートされているバージョンについては、「システム要件」を参照してください。


SqlBulkCopy プロパティ

名前 | 説明 | |
---|---|---|
![]() | BatchSize | バッチごとに処理される行数。各バッチ処理の最後に、そこで処理された行がサーバーに送信されます。 |
![]() | BulkCopyTimeout | 操作がタイムアウトするまでの秒数。 |
![]() | ColumnMappings | SqlBulkCopyColumnMapping 項目のコレクションを返します。列マップにより、データ ソースとコピー先の列間の関係が定義されます。 |
![]() | DestinationTableName | サーバー上のコピー先テーブルの名前。 |
![]() | NotifyAfter | 通知イベントを生成するまでに処理する行数を定義します。 |

SqlBulkCopy メソッド

名前 | 説明 | |
---|---|---|
![]() | Close | SqlBulkCopy のインスタンスを閉じます。 |
![]() | Equals | オーバーロードされます。 2 つの Object インスタンスが等しいかどうかを判断します。 ( Object から継承されます。) |
![]() | GetHashCode | 特定の型のハッシュ関数として機能します。GetHashCode は、ハッシュ アルゴリズムや、ハッシュ テーブルのようなデータ構造での使用に適しています。 ( Object から継承されます。) |
![]() | GetType | 現在のインスタンスの Type を取得します。 ( Object から継承されます。) |
![]() | ReferenceEquals | 指定した複数の Object インスタンスが同一かどうかを判断します。 ( Object から継承されます。) |
![]() | ToString | 現在の Object を表す String を返します。 ( Object から継承されます。) |
![]() | WriteToServer | オーバーロードされます。 データ ソースのすべての行を、SqlBulkCopy オブジェクトの DestinationTableName プロパティで指定された対象テーブルにコピーします。 |

名前 | 説明 | |
---|---|---|
![]() | Finalize | Object がガベージ コレクションにより収集される前に、その Object がリソースを解放し、その他のクリーンアップ操作を実行できるようにします。 ( Object から継承されます。) |
![]() | MemberwiseClone | 現在の Object の簡易コピーを作成します。 ( Object から継承されます。) |


SqlBulkCopy メンバ
SQL Server のテーブルに対し、他のソースからのデータを効率よく一括読み込みできます。
SqlBulkCopy データ型で公開されるメンバを以下の表に示します。


名前 | 説明 | |
---|---|---|
![]() | BatchSize | バッチごとに処理される行数。各バッチ処理の最後に、そこで処理された行がサーバーに送信されます。 |
![]() | BulkCopyTimeout | 操作がタイムアウトするまでの秒数。 |
![]() | ColumnMappings | SqlBulkCopyColumnMapping 項目のコレクションを返します。列マップにより、データ ソースとコピー先の列間の関係が定義されます。 |
![]() | DestinationTableName | サーバー上のコピー先テーブルの名前。 |
![]() | NotifyAfter | 通知イベントを生成するまでに処理する行数を定義します。 |

名前 | 説明 | |
---|---|---|
![]() | Close | SqlBulkCopy のインスタンスを閉じます。 |
![]() | Equals | オーバーロードされます。 2 つの Object インスタンスが等しいかどうかを判断します。 (Object から継承されます。) |
![]() | GetHashCode | 特定の型のハッシュ関数として機能します。GetHashCode は、ハッシュ アルゴリズムや、ハッシュ テーブルのようなデータ構造での使用に適しています。 (Object から継承されます。) |
![]() | GetType | 現在のインスタンスの Type を取得します。 (Object から継承されます。) |
![]() | ReferenceEquals | 指定した複数の Object インスタンスが同一かどうかを判断します。 (Object から継承されます。) |
![]() | ToString | 現在の Object を表す String を返します。 (Object から継承されます。) |
![]() | WriteToServer | オーバーロードされます。 データ ソースのすべての行を、SqlBulkCopy オブジェクトの DestinationTableName プロパティで指定された対象テーブルにコピーします。 |

名前 | 説明 | |
---|---|---|
![]() | Finalize | Object がガベージ コレクションにより収集される前に、その Object がリソースを解放し、その他のクリーンアップ操作を実行できるようにします。 (Object から継承されます。) |
![]() | MemberwiseClone | 現在の Object の簡易コピーを作成します。 (Object から継承されます。) |



- SqlBulkCopyのページへのリンク