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);
	}
}