BATCH

複数のデータ操作言語（DML）文（INSERT、UPDATE、DELETEなど）を組み合わせて、1つのパーティションがターゲットの場合はアトミック性と分離性を確保し、複数のパーティションがターゲットの場合はアトミック性のみを確保します。

データを利用する前に、バッチを使用して1つのパーティション内のすべてのDML文を適用し、アトミック性と分離性を確保します。1つのパーティションをターゲットとするバッチを効果的に構成すると、クライアント-サーバー間のトラフィックを削減し、単一行のミューテーションでテーブルを効率よく更新することができます。

マルチ・パーティション・バッチでは、ロギングによって、すべてのDML文を確実に適用できます。すべてのバッチ操作が成功するか、すべてのバッチ操作が失敗し、アトミック性が確保されます。バッチ操作が1つのパーティションに書き込まれた場合にのみ、バッチの分離性が得られます。

必要に応じて、バッチによりクライアント指定タイムスタンプを適用できます。バッチを実装または実行する前に、「挿入と更新のバッチ処理」を参照してください。

構文

BEGIN [ ( UNLOGGED | LOGGED ) ] BATCH 
  [ USING TIMESTAMP [ epoch_microseconds ] ]
  dml_statement [ USING TIMESTAMP [ epoch_microseconds ] ] ;
  [ dml_statement [ USING TIMESTAMP [ epoch_microseconds ] ] [ ; ... ] ] ;
  APPLY BATCH ;

バッチには以下のdml_statementsを含めることができます。

• INSERT
• UPDATE
• DELETE

UNLOGGED | COUNTER

UNLOGGEDが指定されていない場合、このバッチはログに記録されます。複数のパーティションが関与している場合、バッチはデフォルトでログに記録されます。ログに記録されたバッチを実行すると、すべてのバッチ操作が成功するか、すべてのバッチ操作が失敗します（アトミック性）。まず、シリアライズされたバッチを、そのバッチをBLOBデータとして消費するバッチログ・システム・テーブルに書き込みます。正常に書き込まれると、各行は保持（ヒンテッド）され、バッチログ・データは削除されます。ロギングにはパフォーマンス・ペナルティーが伴います。バッチログが他の2つのノードに書き込まれるためです。バッチ・サイズに関する警告や障害について、しきい値のオプションを使用できます。

UNLOGGEDは、ペナルティーをログに記録させずにバッチを実行します。操作が多すぎる場合や関係しているパーティションが多すぎる場合、ログに記録されないバッチでは警告が生成されます。単一パーティション・バッチ操作はデフォルトでログに記録されず、ログに記録されないバッチ操作としてはこの操作のみ推奨されます。

ログに記録されるバッチではアトミック性が確保されますが（つまり、バッチ内のすべてのDML文が成功するか、またはすべて失敗することが保証される）、その他のトランザクション制御はバッチ・レベルで実行されません。たとえば、バッチ操作が1つのパーティションに書き込まれない限り、バッチの分離性は確保されません。マルチ・パーティション・バッチ操作では、クライアントは、サーバーで他の行がまだ更新中であっても、バッチによって最初に更新された行を読み取ることができます。単一パーティション・バッチ操作では、クライアントは、バッチが完了するまでどの行の部分的な更新も読み取ることはできません。

バッチ方式カウンター更新には、COUNTERオプションを使用します。他の更新とは異なり、カウンター更新はべき等ではありません。

USING TIMESTAMPS

BATCHで実行されるトランザクションの書き込み時間を設定します。

制約事項: USING TIMESTAMPでは、IF NOT EXISTS句を含むDML文などのLWT（軽量トランザクション）はサポートされていません。

デフォルトでは、データベースではバッチによって変更されたすべてのデータに同じタイムスタンプが適用されます。バッチ内の文の順序は関係ありません。したがって、バッチ文は、特定の順序でタイムスタンプを適用する必要があるデータの書き込みではあまり役立ちません。特定の順序で実行するには、クライアント指定タイムスタンプを使用する必要があります。

ユーザー定義タイムスタンプ

USING TIMESTAMP [ epoch_microseconds ]の後にエポック時間をマイクロ秒単位で指定します。時間を指定しない場合、現在の時刻が挿入されます。

すべてのDMLに対して同じタイムスタンプを使用するには、バッチの1行目に挿入します。

BEGIN BATCH USING TIMESTAMP [ epoch_microseconds ]
  DML_statement1 ;
  DML_statement2 ;
  DML_statement3 ;
APPLY BATCH ;

個々のトランザクションの場合は、DMLの末尾に挿入します。

BEGIN BATCH
  DML_statement1 ;
  DML_statement2 USING TIMESTAMP [ epoch_microseconds ] ;
  DML_statement3 ;
APPLY BATCH ;

例

このセクションでは、cyclist_expensesテーブルおよびpopular_countテーブルを使用します。

BEGIN BATCH USING TIMESTAMP 1481124356754405

  INSERT INTO cycling.cyclist_expenses (
    cyclist_name, expense_id, amount, description, paid
  ) VALUES (
    'Vera ADRIAN', 2, 13.44, 'Lunch', true
  );

  INSERT INTO cycling.cyclist_expenses (
    cyclist_name, expense_id, amount, description, paid
  ) VALUES (
    'Vera ADRIAN', 3, 25.00, 'Dinner', true
  );

APPLY BATCH;

EXPAND ON

SELECT
  cyclist_name, expense_id,
  amount, WRITETIME(amount),
  description, WRITETIME(description),
  paid, WRITETIME(paid)
FROM
  cycling.cyclist_expenses
WHERE
  cyclist_name = 'Vera ADRIAN';

@ Row 1
------------------------+------------------
 cyclist_name           | Vera ADRIAN
 expense_id             | 2
 amount                 | 13.44
 writetime(amount)      | 1481124356754405
 description            | Lunch
 writetime(description) | 1481124356754405
 paid                   | True
 writetime(paid)        | 1481124356754405

@ Row 2
------------------------+------------------
 cyclist_name           | Vera ADRIAN
 expense_id             | 3
 amount                 | 25
 writetime(amount)      | 1481124356754405
 description            | Dinner
 writetime(description) | 1481124356754405
 paid                   | True
 writetime(paid)        | 1481124356754405

(2 rows)

BEGIN BATCH USING TIMESTAMP 1481124356754405

  INSERT INTO cycling.cyclist_expenses (
    cyclist_name, expense_id, amount, description, paid
  ) VALUES (
    'Vera ADRIAN', 2, 13.44, 'Lunch', true
  );

  INSERT INTO cycling.cyclist_expenses (
    cyclist_name, expense_id, amount, description, paid
  ) VALUES (
    'Vera ADRIAN', 3, 25.00, 'Dinner', false
  ) IF NOT EXISTS;

APPLY BATCH;

InvalidRequest: Error from server: code=2200 [Invalid query]
message="Cannot provide custom timestamp for conditional BATCH"

BEGIN BATCH

  INSERT INTO cycling.cyclist_expenses (
    cyclist_name, expense_id
  ) VALUES (
    'Joe WALLS', 1
  ) IF NOT EXISTS;

  INSERT INTO cycling.cyclist_expenses (
    cyclist_name, expense_id, amount, description, paid
  ) VALUES (
    'Joe WALLS', 1, 8, 'burrito', false
  );

APPLY BATCH;

BEGIN COUNTER BATCH

  UPDATE cycling.popular_count
  SET popularity = popularity + 1
  WHERE id = 6ab09bec-e68e-48d9-a5f8-97e6fb4c9b47;

  UPDATE cycling.popular_count
  SET popularity = popularity + 125
  WHERE id = 6ab09bec-e68e-48d9-a5f8-97e6fb4c9b47;

  UPDATE cycling.popular_count
  SET popularity = popularity - 64
  WHERE id = 6ab09bec-e68e-48d9-a5f8-97e6fb4c9b47;

APPLY BATCH;