バッチ処理
CData JDBC Driver for Avro では、JDBC batch API を通じて、Avro の一括ロードサポートを活用することができます。batch API を使用して、関連するSQL データ操作ステートメントを同時に実行できます。
JDBC Batch API の使用
次の例は、PreparedStatement を使用して一括操作を実行する方法を示しています。
一括挿入
PreparedStatement を使用して一括挿入を実行するには、一括挿入の一部として実行するパラメータのセットごとにaddBatch を呼び出します。すべてのパラメータのセットをバッチに追加したら、executeBatch を呼び出して一括挿入を実行できます。
Note: For bulk INSERT in Avro, first create a new table using CREATE TABLE ステートメント. The new table would be created in the directory specified using the URI connection property. Currently, bulk INSERT works only if URI points to a local file or a local directory.
executeBatch メソッドは、各ステートメントの更新数を含む配列を返します。次に例を示します。
String query = "INSERT INTO SampleTable_1 (Column1) VALUES (?)"; PreparedStatement pstmt = conn.prepareStatement(query); pstmt.setString(1, "Jon Doe"); pstmt.addBatch(); pstmt.setString(1, "John"); pstmt.addBatch(); int[] r = pstmt.executeBatch(); for(int i: r) System.out.println(i);
バッチサイズの設定
サーバーに送信されるリクエストのサイズに制限がある場合は、バッチサイズの最大値を設定する必要があります。BatchSize プロパティを設定して、バッチ全体を指定された値のバッチに分割します。各バッチは、個別にサーバーに送信されます。
または、BatchSize を0 に設定して、バッチ全体を送信します。