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 2005AdventureWorks データベース格納されProduction.Product テーブルデータを、同じデータベース内の同等テーブルコピーします

メモ重要 :

このサンプル実行するには、あらかじめ、「バルク コピー例のためのテーブル作成」の説明に従って作業テーブル作成しておく必要があります。このコードは、SqlBulkCopy使用する構文を示すためだけに提供されています。同じ SQL Server インスタンスコピーテーブルコピーテーブル存在する場合Transact-SQLINSERTSELECT ステートメント使用した方が容易かつ迅速にデータコピーできます

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 のインスタンスによって使用されます。

解説解説

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

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

使用例使用例

次のコンソール アプリケーションでは、文字列として指定され接続使用してデータ一括読み込み行いますSqlBulkCopy インスタンス閉じられると、接続自動的に解除されます。

この例では、ソース データ最初に SQL Server テーブルから SqlDataReader インスタンス読み込まれます。なお、ソース データについては、SQL Server格納されている必要はありません。IDataReader での読み取りと、DataTable への読み込みが可能であればどのようなデータ ソースでも使用できます

メモ重要 :

このサンプル実行するには、あらかじめ、「バルク コピー例のためのテーブル作成」の説明に従って作業テーブル作成しておく必要があります。このコードは、SqlBulkCopy使用する構文を示すためだけに提供されています。同じ SQL Server インスタンスコピーテーブルコピーテーブル存在する場合Transact-SQLINSERTSELECT ステートメント使用した方が容易かつ迅速にデータコピーできます

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-SQLINSERTSELECT ステートメント使用した方が容易かつ迅速にデータコピーできます

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 2005AdventureWorks データベース格納されProduction.Product テーブルデータを、同じデータベース内の同等テーブルコピーします。この例は、デモンストレーションのためだけに作成されています。実際アプリケーションでは、同じデータベース内のテーブル間でデータ移動するために SqlBulkCopy使用することはありません。なお、ソース データについては、SQL Server格納されている必要はありません。IDataReader での読み取りと、DataTable への読み込みが可能であればどのようなデータ ソースでも使用できます

メモ重要 :

このサンプル実行するには、あらかじめ、「バルク コピー例のためのテーブル作成」の説明に従って作業テーブル作成しておく必要があります。このコードは、SqlBulkCopy使用する構文を示すためだけに提供されています。同じ SQL Server インスタンスコピーテーブルコピーテーブル存在する場合Transact-SQLINSERTSELECT ステートメント使用した方が容易かつ迅速にデータコピーできます

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 パラメータ指定されオプションに従って動作します指定されSqlTransactionnullなければトランザクション内でコピー操作実行されます。

名前空間: 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 名前空間

その他の技術情報

バルク コピー操作実行



英和和英テキスト翻訳>> Weblio翻訳
英語⇒日本語日本語⇒英語
  

辞書ショートカット

すべての辞書の索引

「SqlBulkCopy」の関連用語

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

   

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



SqlBulkCopyのページの著作権
Weblio 辞書 情報提供元は 参加元一覧 にて確認できます。

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

©2025 GRAS Group, Inc.RSS