SqlBulkCopy クラス
定義
重要
一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。
別のソースからのデータを含むSQL Server テーブルを効率的に一括読み込みできます。
public ref class SqlBulkCopy sealed : IDisposablepublic sealed class SqlBulkCopy : IDisposabletype SqlBulkCopy = class
interface IDisposablePublic NotInheritable Class SqlBulkCopy
Implements IDisposable- 継承
-
SqlBulkCopy
- 実装
例
次のコンソール アプリケーションは、SqlBulkCopy クラスを使用してデータを読み込む方法を示しています。 この例では、SqlDataReader を使用し、SQL Server の AdventureWorks データベースに格納された Production.Product テーブルのデータを、同じデータベース内の同等のテーブルにコピーします。
Important
このサンプルは、「バルク コピー サンプルのセットアップ」で説明されているように作業テーブルを作成してからでないと動作しません。
このコードでは、SqlBulkCopy だけを使用した構文について説明します。 ソース テーブルと変換先テーブルが同じ SQL Server インスタンス内にある場合は、Transact-SQL INSERT … SELECT ステートメントを使用してデータをコピーする方が簡単かつ迅速です。
using Microsoft.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = GetConnectionString();
// Open a sourceConnection to the AdventureWorks database.
using (SqlConnection sourceConnection =
new SqlConnection(connectionString))
{
sourceConnection.Open();
// Perform an initial count on the destination table.
SqlCommand commandRowCount = new SqlCommand(
"SELECT COUNT(*) FROM " +
"dbo.BulkCopyDemoMatchingColumns;",
sourceConnection);
long countStart = System.Convert.ToInt32(
commandRowCount.ExecuteScalar());
Console.WriteLine("Starting row count = {0}", countStart);
// Get data from the source table as a SqlDataReader.
SqlCommand commandSourceData = new SqlCommand(
"SELECT ProductID, Name, " +
"ProductNumber " +
"FROM Production.Product;", sourceConnection);
SqlDataReader reader =
commandSourceData.ExecuteReader();
// 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;";
}
}
注釈
Microsoft SQL Serverには、bcp という名前の一般的なコマンド プロンプト ユーティリティが含まれています。これは、1 つのサーバー上でもサーバー間でも、テーブル間でデータを移動するためのユーティリティです。 SqlBulkCopy クラスを使用すると、同様の機能を提供するマネージド コード ソリューションを記述できます。 SQL Server テーブルにデータを読み込む方法は他にもありますが (INSERT ステートメントなど)、SqlBulkCopy を使用する方が大幅にパフォーマンスが向上します。 SqlBulkCopy クラスを使用すると、SQL Server のテーブルにのみデータを書き込むことができます。 ただし、データ ソースはSQL Serverに限定されません。DataTable インスタンスにデータを読み込むか、IDataReader インスタンスで読み取ることができる限り、任意のデータ ソースを使用できます。 SqlBulkCopy は、DataTable 型のSqlDateTime 列を、SQL Server 2008 で追加された日付/時刻型の 1 つであるSQL Server列に一括読み込みするときに失敗します。
コンストラクター
| 名前 | 説明 |
|---|---|
| SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction) |
SqlConnectionの指定された既存のオープン インスタンスを使用して、SqlBulkCopy クラスの新しいインスタンスを初期化します。
SqlBulkCopy インスタンスは、 |
| SqlBulkCopy(SqlConnection) |
SqlBulkCopy の指定されたオープン インスタンスを使用して、SqlConnection クラスの新しいインスタンスを初期化します。 |
| SqlBulkCopy(String, SqlBulkCopyOptions) |
指定された SqlConnection に基づいて、 |
| SqlBulkCopy(String) |
指定された SqlConnection に基づいて、 |
プロパティ
| 名前 | 説明 |
|---|---|
| BatchSize |
各バッチに含まれる行数。 各バッチの最後に、バッチ内の行がサーバーに送信されます。 |
| BulkCopyTimeout |
操作がタイムアウトするまでに完了する秒数。 |
| ColumnMappings |
SqlBulkCopyColumnMapping項目のコレクションを返します。 列のマッピングでは、データ ソース内の列とコピー先の列の間の関係を定義します。 |
| ColumnOrderHints |
SqlBulkCopyColumnOrderHint項目のコレクションを返します。 列の順序ヒントは、変換先テーブルのクラスター化インデックス内の列の並べ替え順序を表します。 |
| DestinationTableName |
サーバー上にあるコピー先のテーブルの名前。 |
| EnableStreaming |
IDataReader オブジェクトからデータをストリーミングするSqlBulkCopy オブジェクトを有効または無効にします。 |
| NotifyAfter |
通知イベントを生成する前に処理する行数を定義します。 |
| RowsCopied |
進行中の一括コピー操作で処理された行の数。 |
| RowsCopied64 |
進行中の一括コピー操作で処理された行の数。 |
メソッド
イベント
| 名前 | 説明 |
|---|---|
| SqlRowsCopied |
NotifyAfter プロパティで指定された行数が処理されるたびに発生します。 |
明示的なインターフェイスの実装
| 名前 | 説明 |
|---|---|
| IDisposable.Dispose() |
SqlBulkCopy クラスの現在のインスタンスで使用されているすべてのリソースを解放します。 |