NestedQuery接口用于嵌套类型的查询。嵌套类型不能直接查询,需要通过NestedQuery来包装一下,NestedQuery中需要指定嵌套类型的字段路径(path)以及一个子query(可以是任意query)。

示例
/**
 * 有一类型为NESTED的列,子文档包含nested_1和nested_2两列,现在查询col_nested.nested_1为"tablestore"的数据。
 */
func NestedQuery(client *tablestore.TableStoreClient, tableName string, indexName string) {
    searchRequest := &tablestore.SearchRequest{}
    searchRequest.SetTableName(tableName)
    searchRequest.SetIndexName(indexName)
    query := &search.NestedQuery{ // 设置查询类型为NestedQuery
        Path: "col_nested", // 设置NESTED字段路径
        Query: &search.TermQuery{ // 构造NestedQuery的子查询
            FieldName: "col_nested.nested_1", // 设置字段名,注意带有Nested列的前缀
            Term:      "tablestore",          // 设置要查询的值
        },
        ScoreMode: search.ScoreMode_Avg,
    }
    searchQuery := search.NewSearchQuery()
    searchQuery.SetQuery(query)
    searchRequest.SetSearchQuery(searchQuery)
    // 设置返回所有列
    searchRequest.SetColumnsToGet(&tablestore.ColumnsToGet{
        ReturnAll: true,
    })
    searchResponse, err := client.Search(searchRequest)
    if err != nil {
        fmt.Printf("%#v", err)
        return
    }
    fmt.Println("IsAllSuccess: ", searchResponse.IsAllSuccess) // 查看返回结果是否完整
    fmt.Println("RowCount: ", len(searchResponse.Rows))
    for _, row := range searchResponse.Rows {
        jsonBody, err := json.Marshal(row)
        if err != nil {
            panic(err)
        }
        fmt.Println("Row: ", string(jsonBody))
    }
}