バッチ処理
CData ADO.NET Provider for Amazon Athena では、AmazonAthenaDataAdapters を通じて、Amazon Athena の一括ロードサポートを活用することができます。Batch API を使用して、関連するSQL データ操作ステートメントを同時に実行できます。本製品 はバッチ内のすべてのSQL クエリを単一のリクエストに変換します。
ADO.NET Batch API の使用
バッチ更新を実行するには、次の基本的な手順を実行します。
- AmazonAthenaCommand オブジェクトで、パラメータ化されたカスタムSQL ステートメントを定義します。
- AmazonAthenaCommand オブジェクトのUpdatedRowSource プロパティを"UpdateRowSource.None" に設定します。
- AmazonAthenaCommand オブジェクトをAmazonAthenaDataAdapter に割り当てます。
- パラメータをコマンドに追加します。
- AmazonAthenaDataAdapter のUpdate メソッドを呼び出します。変更を含むDataSet またはDataTable を渡します。
バッチサイズの制御
要求のサイズ、ネットワークリソース、サーバーのパフォーマンスなどの要因に応じて、より小さなバッチ要求をいくつか実行することでパフォーマンスを向上させることができます。各バッチのサイズは、AmazonAthenaDataAdapter のUpdateBatchSize プロパティを正の整数に設定することで制御できます。
一括INSERT
次のコードはレコードを一括で挿入する単一のバッチを準備します。。 この例では、"Added" 状態の新しいDataRows の一括INSERT を実行します。
C#
AmazonAthenaDataAdapter adapter = new AmazonAthenaDataAdapter(); using (AmazonAthenaConnection conn = new AmazonAthenaConnection("AWSAccessKey='a123';AWSSecretKey='s123';AWSRegion='IRELAND';Database='sampledb';S3StagingDirectory='s3://bucket/staging/';")) { conn.Open(); adapter.InsertCommand = conn.CreateCommand(); adapter.InsertCommand.CommandText = "INSERT INTO [AwsDataCatalog].[sampledb].Customers (TotalDue) VALUES (@TotalDue)"; adapter.InsertCommand.UpdatedRowSource = UpdateRowSource.None; adapter.InsertCommand.Parameters.Add("@TotalDue", "TotalDue"); DataTable batchDataTable = new DataTable(); batchDataTable.Columns.Add("TotalDue", typeof(string)); batchDataTable.Rows.Add("Jon Doe"); batchDataTable.Rows.Add("'John', 4"); adapter.UpdateBatchSize = 2; adapter.Update(batchDataTable); }
VB.NET
Dim adapter As New AmazonAthenaDataAdapter()
Using conn As New AmazonAthenaConnection("AWSAccessKey='a123';AWSSecretKey='s123';AWSRegion='IRELAND';Database='sampledb';S3StagingDirectory='s3://bucket/staging/';")
conn.Open()
adapter.InsertCommand = conn.CreateCommand()
adapter.InsertCommand.CommandText = "INSERT INTO [AwsDataCatalog].[sampledb].Customers (Name) VALUES (@TotalDue)"
adapter.InsertCommand.UpdatedRowSource = UpdateRowSource.None
adapter.InsertCommand.Parameters.Add("@TotalDue", "TotalDue")
Dim batchDataTable As New DataTable()
batchDataTable.Columns.Add("TotalDue", GetType(String))
batchDataTable.Rows.Add("'John', 4")
batchDataTable.Rows.Add("Jon Doe")
adapter.UpdateBatchSize = 2
adapter.Update(batchDataTable)
End Using