腾讯云CTSDB: 使用Java API查询数据

    BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
    boolQueryBuilder.must(QueryBuilders.termQuery("phone", terminalId));
    DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm:ss");
    // 判断时间范围.
    boolQueryBuilder.must(
        QueryBuilders.rangeQuery("createDateTime")
            .gte(LocalDateTime.of(2022, 9, 14, 19, 0, 0).format(dateTimeFormatter))
            .lte(LocalDateTime.now().format(dateTimeFormatter)));
    SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
    searchSourceBuilder.query(boolQueryBuilder);
    searchSourceBuilder.size(100);
    searchSourceBuilder
        .docValueField("_id")
        .docValueField("phone")
        .docValueField("createDateTime")
        .docValueField("userName");
    searchSourceBuilder.sort(SortBuilders.fieldSort("createDateTime").order(SortOrder.DESC));

    SearchRequest searchRequest = new SearchRequest("user_info");
    searchRequest.source(searchSourceBuilder);
    try {
      var searchResponse = ctsdbElasticsearchClient.search(searchRequest, RequestOptions.DEFAULT);
      SearchHits hits = searchResponse.getHits();
      SearchHit[] searchHits = hits.getHits();
      log.info(
          objectMapper.writeValueAsString(
              Arrays.stream(searchHits).map(SearchHit::getFields).toList()));
    } catch (IOException e) {
      log.error("读取数据异常!");
    }