SqlBulkCopyとは? わかりやすく解説

SqlBulkCopy イベント


パブリック イベントパブリック イベント

  名前 説明
パブリック イベント SqlRowsCopied NotifyAfter プロパティに指定された行数が処理されるごとに発生します。
参照参照

関連項目

SqlBulkCopy クラス
System.Data.SqlClient 名前空間

その他の技術情報

バルク コピー操作の実行

SqlBulkCopy クラス

メモ : このクラスは、.NET Framework version 2.0 で新しく追加されたものです。

SQL Server のテーブルに対し、他のソースからのデータを効率よく一括読み込みできます。

名前空間: System.Data.SqlClient
アセンブリ: System.Data (system.data.dll 内)
構文構文

Public NotInheritable Class
 SqlBulkCopy
    Implements IDisposable
public final class SqlBulkCopy implements IDisposable
public final class SqlBulkCopy implements IDisposable
解説解説
使用例使用例

次のコンソール アプリケーションは、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.Object
  System.Data.SqlClient.SqlBulkCopy
スレッド セーフスレッド セーフ
この型の public static (Visual Basic では Shared) メンバはすべて、スレッド セーフです。インスタンス メンバの場合は、スレッド セーフであるとは限りません。
プラットフォームプラットフォーム
バージョン情報バージョン情報
参照参照

SqlBulkCopy コンストラクタ (String)

メモ : このコンストラクタは、.NET Framework version 2.0 で新しく追加されたものです。

指定された connectionString に基づいて、SqlConnection の新しいインスタンスを初期化し、接続を確立します。このコンストラクタは、SqlConnection を使用して、SqlBulkCopy クラスの新しいインスタンスを初期化します。

名前空間: System.Data.SqlClient
アセンブリ: System.Data (system.data.dll 内)
構文構文

Public Sub New ( _
    connectionString As String _
)
Dim connectionString As String

Dim instance As New SqlBulkCopy(connectionString)
public SqlBulkCopy (
    string connectionString
)
public:
SqlBulkCopy (
    String^ connectionString
)
public SqlBulkCopy (
    String connectionString
)
public function SqlBulkCopy (
    connectionString : String
)

パラメータ

connectionString

接続を定義する文字列。これによって確立された接続が、SqlBulkCopy のインスタンスによって使用されます。

解説解説

接続は一括コピー操作の最後に自動的に解除されます。

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;";
    }
}
プラットフォームプラットフォーム
バージョン情報バージョン情報
参照参照

SqlBulkCopy コンストラクタ (String, SqlBulkCopyOptions)

メモ : このコンストラクタは、.NET Framework version 2.0 で新しく追加されたものです。

指定された connectionString に基づいて、SqlConnection の新しいインスタンスを初期化し、接続を確立します。このコンストラクタは、SqlConnection を使用して、SqlBulkCopy クラスの新しいインスタンスを初期化します。SqlConnection のインスタンスは、copyOptions パラメータに指定されたオプションに従って動作します。

名前空間: System.Data.SqlClient
アセンブリ: System.Data (system.data.dll 内)
構文構文

Public Sub New ( _
    connectionString As String, _
    copyOptions As SqlBulkCopyOptions _
)
Dim connectionString As String
Dim copyOptions As SqlBulkCopyOptions

Dim instance As New SqlBulkCopy(connectionString,
 copyOptions)
public SqlBulkCopy (
    string connectionString,
    SqlBulkCopyOptions copyOptions
)
public:
SqlBulkCopy (
    String^ connectionString, 
    SqlBulkCopyOptions copyOptions
)
public SqlBulkCopy (
    String connectionString, 
    SqlBulkCopyOptions copyOptions
)
public function SqlBulkCopy (
    connectionString : String, 
    copyOptions : SqlBulkCopyOptions
)

パラメータ

connectionString

接続を定義する文字列。これによって確立された接続が、SqlBulkCopy のインスタンスによって使用されます。

copyOptions

データ ソースから対象のテーブルにコピーする行を決定する、SqlBulkCopyOptions 列挙値の組み合わせ。

解説解説
使用例使用例

次のコンソール アプリケーションでは、文字列として指定された接続を使用して一括読み込みを実行します。対象テーブルへの読み込みを実行するとき、ソース テーブルの 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;";
    }
}
プラットフォームプラットフォーム
バージョン情報バージョン情報
参照参照

SqlBulkCopy コンストラクタ

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 クラス
SqlBulkCopy メンバ
System.Data.SqlClient 名前空間

その他の技術情報

バルク コピー操作の実行

SqlBulkCopy コンストラクタ (SqlConnection)

メモ : このコンストラクタは、.NET Framework version 2.0 で新しく追加されたものです。

既に接続の確立されている SqlConnection のインスタンスを使用し、SqlBulkCopy クラスの新しいインスタンスを初期化します。

名前空間: System.Data.SqlClient
アセンブリ: 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
)

パラメータ

connection

既に接続の確立されている SqlConnection のインスタンス。一括コピー操作を実行するために使用されます。

解説解説

SqlBulkCopy のインスタンスを初期化する時点で接続が確立されているため、SqlBulkCopy インスタンスを閉じた後も接続は維持されます。

connection 引数が null の場合、ArgumentNullException がスローされます。

使用例使用例

次のコンソール アプリケーションでは、既に確立された接続を使用して、データの一括読み込みを行います。この例では、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;";
    }
}
プラットフォームプラットフォーム
バージョン情報バージョン情報
参照参照

SqlBulkCopy コンストラクタ (SqlConnection, SqlBulkCopyOptions, SqlTransaction)

メモ : このコンストラクタは、.NET Framework version 2.0 で新しく追加されたものです。

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

名前空間: System.Data.SqlClient
アセンブリ: 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
)

パラメータ

connection

既に接続の確立されている SqlConnection のインスタンス。一括コピーを実行するために使用されます。

copyOptions

データ ソースから対象のテーブルにコピーする行を決定する、SqlBulkCopyOptions 列挙値の組み合わせ。

externalTransaction

一括コピーを実行する既存の SqlTransaction インスタンス。

解説解説

オプションに UseInternalTransaction が指定されているとき、externalTransaction 引数が null 以外の場合、InvalidArgumentException がスローされます。

トランザクションで SqlBulkCopy を使用する方法の例については、「トランザクションでのバルク コピー操作の実行」を参照してください。

プラットフォームプラットフォーム
バージョン情報バージョン情報
参照参照

SqlBulkCopy プロパティ


パブリック プロパティパブリック プロパティ

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

関連項目

SqlBulkCopy クラス
System.Data.SqlClient 名前空間

その他の技術情報

バルク コピー操作の実行

SqlBulkCopy メソッド


パブリック メソッドパブリック メソッド

プロテクト メソッドプロテクト メソッド
明示的インターフェイスの実装明示的インターフェイスの実装
  名前 説明
インターフェイスの明示的な実装 System.IDisposable.Dispose SqlBulkCopy のインスタンスを閉じます。
参照参照

関連項目

SqlBulkCopy クラス
System.Data.SqlClient 名前空間

その他の技術情報

バルク コピー操作の実行

SqlBulkCopy メンバ

SQL Server のテーブルに対し、他のソースからのデータを効率よく一括読み込みできます。

SqlBulkCopy データ型で公開されるメンバを以下の表に示します。


パブリック コンストラクタパブリック コンストラクタ
パブリック プロパティパブリック プロパティ
  名前 説明
パブリック プロパティ BatchSize バッチごとに処理される行数。各バッチ処理の最後に、そこで処理された行がサーバーに送信されます。
パブリック プロパティ BulkCopyTimeout 操作がタイムアウトするまでの秒数。
パブリック プロパティ ColumnMappings SqlBulkCopyColumnMapping 項目のコレクションを返します。列マップにより、データ ソースとコピー先の列間の関係が定義されます。
パブリック プロパティ DestinationTableName サーバー上のコピー先テーブルの名前。
パブリック プロパティ NotifyAfter 通知イベントを生成するまでに処理する行数を定義します。
パブリック メソッドパブリック メソッド
プロテクト メソッドプロテクト メソッド
パブリック イベントパブリック イベント
  名前 説明
パブリック イベント SqlRowsCopied NotifyAfter プロパティに指定された行数が処理されるごとに発生します。
明示的インターフェイスの実装明示的インターフェイスの実装
  名前 説明
インターフェイスの明示的な実装 System.IDisposable.Dispose SqlBulkCopy のインスタンスを閉じます。
参照参照

関連項目

SqlBulkCopy クラス
System.Data.SqlClient 名前空間

その他の技術情報

バルク コピー操作の実行



英和和英テキスト翻訳

英語⇒日本語日本語⇒英語

辞書ショートカット

すべての辞書の索引

「SqlBulkCopy」の関連用語

SqlBulkCopyのお隣キーワード
検索ランキング

   

英語⇒日本語
日本語⇒英語
   



SqlBulkCopyのページの著作権

   
日本マイクロソフト株式会社日本マイクロソフト株式会社
© 2026 Microsoft.All rights reserved.

©2026 GRAS Group, Inc.RSS