使用虚拟列功能时,您可以通过修改多元索引Schema或者新建多元索引来实现新字段新数据类型的查询功能,而无需修改表格存储的存储结构及数据。

前提条件

  • 已初始化Client。具体操作,请参见初始化
  • 已创建数据表,且数据表的数据生命周期(timeToLive)必须为-1,最大版本数(maxVersions)必须为1。

注意事项

  • 虚拟列支持不同类型到字符串类型的相互转换,转换规则请参见下表。
    数据表中字段类型虚拟列字段类型
    StringKeyword(含数组)
    StringText(含数组)
    StringLong(含数组)
    StringDouble(含数组)
    StringGeo-point(含数组)
    LongKeyword
    LongText
    DoubleKeyword
    DoubleText
  • 虚拟列目前仅支持用在查询语句中,不能用在ColumnsToGet返回列值,如果需要返回列值,可以指定返回该虚拟列的原始列。

参数

更多信息,请参见创建多元索引

示例

  1. 创建多元索引时指定虚拟列。
    创建一个多元索引,多元索引包含Col_Keyword和Col_Long两列,同时创建虚拟列Col_Keyword_Virtual_Long和Col_Long_Virtual_Keyword。Col_Keyword_Virtual_Long映射为数据表中Col_Keyword列,虚拟列Col_Long_Virtual_Keyword映射为数据表中Col_Long列。
    private static void createSearchIndex(SyncClient client) {
        CreateSearchIndexRequest request = new CreateSearchIndexRequest();
        request.setTableName(tableName); //设置数据表名称。
        request.setIndexName(indexName); //设置多元索引名称。
        IndexSchema indexSchema = new IndexSchema();
        indexSchema.setFieldSchemas(Arrays.asList(
            new FieldSchema("Col_Keyword", FieldType.KEYWORD), //设置字段名和类型。
            new FieldSchema("Col_Keyword_Virtual_Long", FieldType.LONG) //设置字段名和类型。
                .setVirtualField(true) //设置字段是否为虚拟列。
                .setSourceFieldName("Col_Keyword"), //虚拟列对应的数据表中字段。
            new FieldSchema("Col_Long", FieldType.LONG),
            new FieldSchema("Col_Long_Virtual_Keyword", FieldType.KEYWORD)
                .setVirtualField(true)
                .setSourceFieldName("Col_Long")));
        request.setIndexSchema(indexSchema);
        client.createSearchIndex(request); //调用client创建多元索引。
    }
  2. 使用虚拟列查询数据。

    查询表中Col_Long_Virtual_Keyword列的值能够匹配"1000"的数据,返回匹配到的总行数和一些匹配成功的行。

    private static void query(SyncClient client) {
        SearchQuery searchQuery = new SearchQuery();
        TermsQuery termsQuery = new TermsQuery(); //设置查询类型为TermsQuery。
        termsQuery.setFieldName("Col_Long_Virtual_Keyword"); //设置要匹配的字段。
        termsQuery.addTerm(ColumnValue.fromString("1000")); //设置要匹配的值。
        searchQuery.setQuery(termsQuery);
        searchQuery.setGetTotalCount(true); //设置返回匹配的总行数。
        SearchRequest searchRequest = new SearchRequest("tableName", "indexName", searchQuery);
        SearchRequest.ColumnsToGet columnsToGet = new SearchRequest.ColumnsToGet();
        columnsToGet.setReturnAll(true); //设置返回所有列,不支持返回虚拟列。
        searchRequest.setColumnsToGet(columnsToGet);
    
        SearchResponse resp = client.search(searchRequest);
        System.out.println("TotalCount: " + resp.getTotalCount()); //匹配到的总行数,非返回行数。
        System.out.println("Row: " + resp.getRows());
    }