package org.springblade.es.service;
|
|
import org.elasticsearch.action.search.SearchRequest;
|
import org.elasticsearch.action.search.SearchResponse;
|
import org.elasticsearch.client.RequestOptions;
|
import org.elasticsearch.client.RestHighLevelClient;
|
import org.elasticsearch.index.query.QueryBuilders;
|
import org.elasticsearch.search.builder.SearchSourceBuilder;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.io.IOException;
|
|
@Service
|
public class ElasticsearchSearchService {
|
|
@Autowired
|
private RestHighLevelClient client;
|
|
public SearchResponse search(String index, String query) throws IOException {
|
SearchRequest searchRequest = new SearchRequest(index);
|
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
|
searchSourceBuilder.query(QueryBuilders.matchQuery("field1", query)); // 搜索field1字段
|
searchSourceBuilder.query(QueryBuilders.matchQuery("field2", query)); // 搜索field2字段
|
searchRequest.source(searchSourceBuilder);
|
|
return client.search(searchRequest, RequestOptions.DEFAULT);
|
}
|
}
|
