Lindorm:動的カラム

動的カラム機能を使用する前に、次の項目に注意してください。

• LindormTable のバージョンが 2.2.19 以降であることを確認してください。詳細については、「Lindorm インスタンスのマイナーエンジンバージョンのアップグレード」をご参照ください。Lindorm

• LindormTable の動的カラムのデータは VARBINARY 型です。動的カラムのデータをクエリしたり、動的カラムにデータを書き込むときは、動的カラムのデータ型をバイト配列に変換する必要があります。

• Java 用 HBase API を使用してテーブルを作成したり、テーブルにデータを書き込む場合は、Lindorm SQL を使用して、テーブルの動的カラムからデータをクエリしたり、動的カラムにデータを書き込んだりできます。

次のいずれかの方法を使用して、動的カラムを有効にできます。

• テーブルを作成するときに WITH 句を使用して、動的カラムを有効にします。

  CREATE TABLE t_dynamic (p1 INT, c1 INT, c2 VARCHAR, PRIMARY KEY(p1)) WITH (DYNAMIC_COLUMNS='true');

• 既存のテーブルの属性を変更して、動的カラムを有効にします。

  ALTER TABLE t_dynamic SET 'DYNAMIC_COLUMNS' = 'true';

  結果の確認

  次のステートメントを実行して、テーブルに対して動的カラムが有効になっているかどうかを確認できます。

  SHOW TABLE VARIABLES FROM t_dynamic LIKE 'DYNAMIC_COLUMNS';

  説明

  テーブルに対して動的カラムが有効になったら、テーブルの属性を変更して、テーブルのスキーマに新しいカラムを追加できます。たとえば、次のステートメントを実行して、INT データ型の c3 カラムをテーブルのスキーマに追加できます。

  ALTER TABLE t_dynamic ADD COLUMN c3 int;

  テーブルのスキーマに c3 カラムを追加する前に、c3 という名前の動的カラムにデータを書き込むと、c3 に書き込まれたデータの型が VARBINARY であるため、c3 に INT データを挿入したり、c3 の INT データをクエリするときに例外が返されます。スキーマに追加する c3 カラムのデータ型が VARBINARY の場合は、この例外は返されません。したがって、動的カラムが有効になっているテーブルのスキーマを変更するときは、データ型に注意してください。事前に定義されたカラムの名前を、既存の動的カラムの名前に設定しないでください。

動的カラムのデータをクエリできるシナリオは、次のタイプに分類されます。

• クエリするフィールドは、明示的に定義された動的カラムです。動的カラムが有効になっているテーブルのデータをクエリするために使用される構文は、動的カラムが有効になっていないテーブルのデータをクエリするために使用される構文と同じです。テーブルに対して動的カラムを有効にすると、テーブルスキーマで定義されていないカラムのデータをクエリできます。次の例では、c3 と c4 はテーブルの作成後に追加された動的カラムです。

  SELECT p1, c2, c3, c4 FROM t_dynamic WHERE p1 = 1;

  次の結果が返されます。

  +----+----+------+------+
  | p1 | c2 |  c3  |  c4  |
  +----+----+------+------+
  | 1  | 1  | 0x41 | null |
  +----+----+------+------+

• テーブルに含まれる動的カラムを表示するには、SELECT * ステートメントを実行して、テーブル内のすべてのカラムをクエリできます。この場合、ステートメントの最後に LIMIT 句を追加して、返される結果セットのサイズを制限する必要があります。これにより、Lindorm SQL は結果セットのメタデータの整合性を確保できます。

  SELECT * FROM t_dynamic LIMIT 10;

  次の結果が返されます。

  +----+------+------+------+----------+
  | p1 |  c1  |  c2  |  c3  |    c4    |
  +----+------+------+------+----------+
  | 1  | null | 1    | 0x41 | null     |
  | 2  | null | null | null | 0xef0011 |
  | 3  | null | null | null | 0xef0011 |
  +----+------+------+------+----------+

  重要

  SELECT * ステートメントと LIMIT 句を指定して、動的カラムが有効になっているテーブルのデータをクエリする場合、LIMIT のデフォルトの最大値は 5,000 です。最大値を指定できます。クエリされた値が最大値を超えると、エラーが返されます。

• 動的カラムは WHERE 条件で使用されます。

  クエリのパフォーマンスを確保するには、WHERE 条件にプライマリキーカラムまたはインデックスキーカラムを含める必要があります。 Lindorm-cli または SQL ステートメントを使用して動的カラムのデータをクエリする場合、WHERE 条件の動的カラムの値は 16 進文字列である必要があります。

  たとえば、テーブル t_dynamic の c4 カラムが動的カラムの場合、次のステートメントを実行してクエリを正常に実行できます。

  SELECT p1, c4 FROM t_dynamic WHERE p1 = 3 AND c4 = x'ef0011';

  対照的に、次のクエリは、WHERE 条件の c4 カラムの値 1 が 16 進文字列ではないため、失敗します。

  SELECT p1, c1, c4 FROM t_dynamic WHERE p1 = 2 AND c4 = '1';

次の Java コードは、バイト配列を 16 進文字列に変換する方法の例を示しています。

private static final char[] DIGITS = {
  '0', '1', '2', '3', '4', '5', '6', '7',
  '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'
  };

private static String toHexString(byte[] bytes) {
  char[] chars;
  int j = 0;
  chars = new char[bytes.length * 2];
  for (byte b : bytes) {
    chars[j++] = DIGITS[(b & 0xF0) >> 4];
    chars[j++] = DIGITS[b & 0x0F];
  }
  return new String(chars, 0, j);
}

public void testToHexString() {
  String s = "Hello, world";
  // 文字列の getBytes() メソッドを使用して、文字列に対応するバイト配列を取得できます。
  byte[] bytes = s.getBytes(Charset.forName("UTF-8"));
  String hexString = toHexString(bytes);
  System.out.println(hexString); // 出力は 48656c6c6f2c20776f726c64 です。
}