javaでElasticsearchのページングクエリを実装する方法
Javaでは、ElasticsearchのJavaクライアントライブラリを使用して、ESのページングクエリを実装できます。以下に簡単なサンプルコードを示します。
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.sort.SortBuilders;
import org.elasticsearch.search.sort.SortOrder;
public class ElasticsearchPaginationExample {
private static final String INDEX_NAME = "your_index_name";
private static final int PAGE_SIZE = 10;
public static void main(String[] args) {
try (RestHighLevelClient client = new RestHighLevelClient(
RestClient.builder("localhost:9200"))) {
int pageNumber = 1;
SearchRequest searchRequest = new SearchRequest(INDEX_NAME);
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
// 设置分页
searchSourceBuilder.from((pageNumber - 1) * PAGE_SIZE);
searchSourceBuilder.size(PAGE_SIZE);
// 设置排序
searchSourceBuilder.sort(SortBuilders.fieldSort("your_field_name").order(SortOrder.ASC));
// 设置查询条件
searchSourceBuilder.query(QueryBuilders.matchAllQuery());
searchRequest.source(searchSourceBuilder);
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
// 处理搜索结果
// searchResponse.getHits().getHits() 返回的是一个 SearchHit[] 数组,包含了查询到的文档
// 可以根据需要进行处理
} catch (Exception e) {
e.printStackTrace();
}
}
}
上記のコードでは、RestHighLevelClientオブジェクトを作成してElasticsearchサーバーと接続します。SearchRequestを使用してクエリリクエストを作成します。SearchSourceBuilderを使用してページネーション、ソート、クエリ条件を設定します。最後に、client.search()メソッドを使用してクエリを実行し、返されたSearchResponseオブジェクトの結果を処理します。