CREATE INDEX

二级索引

搜索索引

列存索引

二级索引

异步构建索引

不设置构建方法时，默认异步构建索引。

CREATE INDEX idx1 ON test(c1 desc) include(c3,c4) WITH (COMPRESSION='ZSTD');

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

创建联合索引

为c1，c2，c3列同步创建联合索引。

CREATE INDEX idx1 ON test(c1, c2, c3) include(c4) SYNC WITH ( COMPRESSION ='ZSTD');

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

冗余所有列

CREATE INDEX idx1 ON test(c4 desc) WITH (INDEX_COVERED_TYPE ='COVERED_ALL_COLUMNS_IN_SCHEMA');

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

冗余所有动态列

CREATE INDEX idx1 ON test(c4 desc) WITH (INDEX_COVERED_TYPE='COVERED_DYNAMIC_COLUMNS');

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

设置索引表的预分区数

设置索引表的预分区数为32。

CREATE INDEX idx1 ON test(c4 desc) include(c5,c6)  WITH (NUMREGIONS ='32');

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

指定索引表的起止Key

创建二级索引时指定索引表的起止Key和预分区数，将索引表在11111111和9999999之间分成32个预分区。

CREATE INDEX idx1 ON test(c3 desc) include(c5,c6) WITH (NUMREGIONS ='32', STARTKEY ='11111111', ENDKEY = '9999999');

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

创建Z-ORDER二级索引

为面数据类型列c5创建Z-ORDER二级索引。​

CREATE INDEX idx1 ON test(Z-ORDER(c5));

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

创建网格二级索引

1. 为面类型列c5创建网格二级索引。目前仅支持异步创建模式。

   CREATE INDEX idx1 ON test(S2(c5, 10));

2. 构建网格二级索引。

   BUILD INDEX s2_idx ON test;

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

转换指定列的数据类型

将c3列的数据类型转换为INTEGER类型后创建二级索引。​

CREATE INDEX idx1 ON test(CAST(c3 AS INTEGER));

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

搜索索引

异步构建索引

CREATE INDEX IF NOT EXISTS idx2 USING SEARCH ON test(p1, p2, c1, c2, c3);

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

为所有列创建索引

为所有列创建搜索索引，不指定具体列属性时，均为默认值。

CREATE INDEX IF NOT EXISTS idx2 USING SEARCH ON test('*');

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

添加索引键属性

• 添加非自定义索引键属性

  创建所有列的搜索索引，如果索引列有c3, 索引列的属性都为type=text，analyzer=ik，indexed=true。

  CREATE INDEX IF NOT EXISTS idx2 USING SEARCH ON test('*',c3(type=text,analyzer=ik,indexed=true));

  结果验证

  您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

• 添加自定义索引键属性

  假设表结构如下：

  CREATE TABLE test (
    p1 VARCHAR NOT NULL,
    p2 INTEGER NOT NULL,
    c1 BIGINT,
    c2 DOUBLE,
    c3 VARCHAR,
    c4 TIMESTAMP,
    PRIMARY KEY(p1, p2)
  ) WITH (CONSISTENCY = 'strong', MUTABILITY='MUTABLE_LATEST');

  创建所有列的搜索索引，其中索引列c3指定类型为text，分词器为ik_max_word。

  CREATE INDEX IF NOT EXISTS idx2 USING SEARCH ON test('*',c3(mapping='{
    "type": "text",
    "analyzer": "ik_max_word"
  }'));

  重要

  • mapping参数仅适用于搜索引擎Elasticsearch兼容版本。

  • 若使用了mapping参数，该索引键的其它所有参数将无效。

  结果验证

  您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

设置索引状态

指定列，并指定部分列属性，同时指定搜索索引状态为ACTIVE。

CREATE INDEX IF NOT EXISTS idx2 USING SEARCH ON test(c1, c3(type=text,analyzer=ik)) WITH (indexState=ACTIVE,numShards=4);

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

设置自定义索引属性

创建搜索索引，指定搜索索引状态为ACTIVE，并通过自定义设置指定索引的分片数量为4，压缩方式为ZSTD，刷新时间间隔为10秒。

CREATE INDEX IF NOT EXISTS idx2 USING SEARCH ON test(c1, c3(type=text,analyzer=ik)) WITH (indexState=ACTIVE,INDEX_SETTINGS='{
  "index": {
    "codec": "zstd",
    "refresh_interval": "10s",
    "number_of_shards": 4
   }
}');

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

设置时间分区

按时间列c4分区，从30天前开始，每7天自动分区，默认保留90天的分区数据。

CREATE INDEX IF NOT EXISTS idx2 USING SEARCH ON test (c1, c2, c3, c4)
PARTITION BY RANGE TIME(c4) PARTITIONS 16
WITH (indexState=ACTIVE, RANGE_TIME_PARTITION_START='30', RANGE_TIME_PARTITION_INTERVAL='7', RANGE_TIME_PARTITION_TTL='90', RANGE_TIME_PARTITION_MAX_OVERLAP='90');

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

列存索引

创建索引

CREATE INDEX IF NOT EXISTS idx3 USING COLUMNAR
ON test(p1, p2, c1, c2, c3)
PARTITION BY ENUMERABLE (p1, p2, bucket(128, p1, p2));

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

自定义列存表名

创建列存索引，将索引表命名为my_index_tbl。

CREATE INDEX IF NOT EXISTS idx3 USING COLUMNAR ON test(*)
PARTITION BY ENUMERABLE (p1, p2, bucket(128, p1, p2))
WITH (`lindorm_columnar.user.index.database` = 'my_index_db',
`lindorm_columnar.user.index.table` = 'my_index_tbl');

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

创建增量列存索引

创建一个仅为增量数据构建列存索引的索引。

CREATE INDEX IF NOT EXISTS idx3 USING COLUMNAR ON test(*)
PARTITION BY ENUMERABLE (p1, p2, bucket(128, p1, p2))
WITH (`lindorm_columnar.user.syncer.skip.fullsync` = 'true');

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。

为JSON列展开后的字段创建索引

针对JSON列展开后的字段创建列存索引。假设包含JSON列的表建表语句如下：

CREATE TABLE IF NOT EXISTS my_json_tbl(id BIGINT, col1 INTEGER, col2 DOUBLE, json_col JSON, PRIMARY KEY(id));

写入JSON数据的结构如下：

{
 "a": {
 "b": {
 "c": "hello,world",
 "d": 123
 },
 "e": false
 },
 "f": 3.14
}

创建列存索引时，基于WITH关键字，指定展开JSON字段的映射规则。

CREATE INDEX IF NOT EXISTS columnar_idx USING COLUMNAR ON my_json_tbl(*) 
 PARTITION BY ENUMERABLE (id%16, bucket(16,id)) 
 WITH (
 `lindorm_columnar.user.syncer.lci.jsonMapping.json_col` = 'a.b.c VARCHAR, a.e BOOLEAN ,f DOUBLE');

结果验证

您可以执行SHOW INDEX FROM test;查看索引是否已创建成功。