云原生多模数据库 Lindorm：动态列

如果您需要使用动态列功能，请注意以下几点：

• 确保云原生多模数据库 Lindorm宽表引擎为2.2.19及以上版本，具体操作请参见升级小版本。

• Lindorm宽表中动态列类型均为VARBINARY，查询动态列和写入动态列时都必须将动态列类型转化成字节数组。

• 通过Lindorm SQL管理动态列，查询动态列和写入动态列操作支持以云数据库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
}