Lindorm：動態列

如果您需要使用動態列功能，請注意以下幾點：

• 確保Lindorm寬表引擎為2.2.19及以上版本，具體操作請參見升級小版本。

• Lindorm寬表中動態列類型均為VARBINARY，查詢動態列和寫入動態列時都必須將動態列類型轉化成位元組數組。

• 通過Lindorm SQL管理動態列，查詢動態列和寫入動態列操作支援以ApsaraDB for HBase相容方式建立和寫入的表。

動態列的開啟可以通過以下兩種方式：

• 在建立表格時通過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';

  說明

  開啟動態列後，您可以修改表的屬性或者在表的Schema中增加新的列，例如執行以下語句表示新增c3列，資料類型為INT。

  ALTER TABLE t_dynamic ADD COLUMN c3 int;

  如果您在此之前寫入過名為c3的動態列，由於寫入的資料類型均為VARBINARY，查詢資料和寫入資料時會拋出異常，如果新增列的資料類型為VARBINARY就不會出現這個異常。因此，變更動態列表的Schema時需要注意資料類型不同的情況，盡量避免預定義列和動態列重名。

查詢動態列的情境分為以下幾種：

• 顯式指定查詢欄位為動態列。查詢動態列表的文法與查詢普通列表的文法一致，開啟動態列之後，可以查詢沒有預先在Schema中定義的列，如下樣本，c3和c4是建立表後新增的動態列。

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

  返回結果如下：

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

• 不確定表中已包含哪些動態列時，可以使用SELECT *查詢動態列表。Lindorm SQL為了保證結果集中繼資料的正確性，強制要求在此類查詢語句後添加LIMIT子句來限定結果集的大小。

  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的預設最大值為5000，超過最大值會報錯。

• 在WHERE條件中使用動態列。

  為了確保查詢語句的效能WHERE條件中需包含主鍵或索引列，如果您希望在查詢的過濾條件中使用動態列進行過濾，那麼使用SQL文字查詢時，動態列的過濾條件必須指定為HexString；使用綁參方式進行查詢時，過濾條件建議直接指定為原始的位元組數組。

  例如表t_dynamic中c4為動態列，那麼查詢成功的語句如下樣本：

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

  作為對比，下述查詢樣本中由於給動態列c4指定的過濾條件1不是一個HexString，所以該查詢執行失敗。

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

在Java中，使用下述代碼可以將一個位元組數群組轉換為HexString。

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";
  // 對於字串類型，可以直接使用String的getBytes方法獲得對象對應的byte[]
  byte[] bytes = s.getBytes(Charset.forName("UTF-8"));
  String hexString = toHexString(bytes);
  System.out.println(hexString); //列印結果為： 48656c6c6f2c20776f726c64
}