[大数据]StringBoot集成Elasticsearch

官方文档 此处

本文使用Elasticsearch版本为7.8.0

创建一个项目
勾选es依赖

编译版本一定是8以上

默认集成的版本 跟我们本地安装的版本不一样

自己指定跟自己es版本匹配即可

<properties>
		<java.version>1.8</java.version>
		<!--自己定义es版本-->
        <elasticsearch.version>7.8.0</elasticsearch.version>
	</properties>

本文的所有依赖

	<properties>
		<java.version>1.8</java.version>
		<!--自己定义es版本-->
        <elasticsearch.version>7.8.0</elasticsearch.version>
	</properties>
	<dependencies>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-devtools</artifactId>
			<scope>runtime</scope>
			<optional>true</optional>
		</dependency>
		<!--json-->
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>fastjson</artifactId>
			<version>1.2.76</version>
		</dependency>
		<dependency>
			<groupId>org.projectlombok</groupId>
			<artifactId>lombok</artifactId>
			<optional>true</optional>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
		</dependency>
	</dependencies>

编写一个配置类创建连接es的客户端

@Configuration
public class ElasticSearchConfig {

    @Bean
    public RestHighLevelClient restHighLevelClient() {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(
                        //配置客户端连接es信息
                        new HttpHost("localhost", 9200, "http")
                ));
        return client;
    }

}

测试索引操作

测试创建索引

@SpringBootTest
class FeiEsApiApplicationTests {

	@Autowired
	private RestHighLevelClient restHighLevelClient;

	/**
	 * 测试索引的创建
	 */
	@SneakyThrows
	@Test
	void testCreate(){
		//1.创建索引请求
		CreateIndexRequest createIndexRequest = new CreateIndexRequest("fei_index");
        //2.客户端执行创建请求
		CreateIndexResponse response = restHighLevelClient
				.indices()
				.create(createIndexRequest, RequestOptions.DEFAULT);
		System.out.println(response);
	}


}

获取索引

/**
	 * 测试获取索引
	 */
	@SneakyThrows
	@Test
	void testGetIndex()  {
		GetIndexRequest request = new GetIndexRequest("fei_index");
		boolean exists = restHighLevelClient
				.indices()
				//判断索引是否存在
				.exists(request, RequestOptions.DEFAULT);
		System.out.println(exists);
	}

删除索引

@SneakyThrows
	@Test
	void testDel(){
		//创建删除索引请求
		DeleteIndexRequest request = new DeleteIndexRequest("fei_index");
		//执行删除
		AcknowledgedResponse response = restHighLevelClient
				.indices()
				.delete(request, RequestOptions.DEFAULT);
		System.out.println(request);
	}

文档操作

添加文档

/**
	 * 测试添加文档
	 */
	@SneakyThrows
	@Test
	void testAddDocument(){
    	//创建对象
		User user = new User("飞飞",24);
		//创建请求
		IndexRequest request = new IndexRequest("fei_index");
        //设置规则
		request.id("1");
		request.timeout(TimeValue.timeValueSeconds(1));
		//将我们的数据放入请求  Json
		request.source(JSON.toJSONString(user), XContentType.JSON);
	    //客户端发送请求  获取响应结果
		IndexResponse response = restHighLevelClient.index(request, RequestOptions.DEFAULT);
		System.out.println(response.toString());
	}

获取文档

/**
	 * 获取文档  判断是否存在
	 */
	@SneakyThrows
	@Test
	void testIsGet(){
		GetRequest request = new GetRequest("fei_index","1");
		//不获取返回的_source 上下文了
		request.fetchSourceContext(new FetchSourceContext(false));
		request.storedFields("_none_");
        //判断是否存在
		boolean exists = restHighLevelClient.exists(request, RequestOptions.DEFAULT);
		System.out.println(exists);
	}

获取文档内容

/**
	 * 获取文档信息
	 */
	@SneakyThrows
	@Test
	void testGetDocument(){
		 GetRequest request = new GetRequest("fei_index", "1");
		 //获取文档信息
		 GetResponse response = restHighLevelClient.get(request, RequestOptions.DEFAULT);
		 //打印文档内容
		 System.out.println(response.getSourceAsString());

	}

更新文档信息

//更新文档信息
	@Test
	@SneakyThrows
	void testGetUpd(){
		UpdateRequest request = new UpdateRequest("fei_index","1");
		//设置超时时间
		request.timeout("1s");
		User user = new User("阿飞", 18);
		//转成json数据    数据的类型
		request.doc(JSON.toJSONString(user),XContentType.JSON);
		//执行更新打印结果
		UpdateResponse update = restHighLevelClient.update(request, RequestOptions.DEFAULT);
		System.out.println(update);
	}

删除文档信息

/**
	 * 删除文档信息
	 */
	@SneakyThrows
	@Test
	void testDelDoc(){
		//创建删除请求  删除 fei_index索引的id为二的文档
		DeleteRequest request = new DeleteRequest("fei_index","2");
		DeleteResponse delete = restHighLevelClient.delete(request, RequestOptions.DEFAULT);
		System.out.println(delete);
	}

批量操作

/**
	 * 特殊的，   批量插入数据
	 */
	@SneakyThrows
	@Test
	void testBulkReq(){
		//创建批量请求
		BulkRequest request = new BulkRequest();
		//设置超时时间
		request.timeout("5s");
		ArrayList<User> list = new ArrayList<>();
		list.add(new User("张三",20));
		list.add(new User("张四",21));
		list.add(new User("张五",22));
		list.add(new User("张六",23));
		list.add(new User("张七",24));

		for (int i = 0; i < list.size(); i++) {
			//插入和删除写对应的请求就可以了
			 request.add(new IndexRequest("fei_index")
			 .id(""+(i+1))
					 .source(JSON.toJSONString(list.get(i)),XContentType.JSON));
		}
		BulkResponse bulk = restHighLevelClient.bulk(request, RequestOptions.DEFAULT);
	}

查询

/**
	 * 查询
	 */
	@SneakyThrows
	@Test
	void testSearch(){
		SearchRequest request = new SearchRequest("fei_index");
		//构建搜索的条件      term精准匹配
		SearchSourceBuilder builder = new SearchSourceBuilder();
		TermQueryBuilder query = QueryBuilders.termQuery("name", "张三");
		builder.query(query);
		//分页
		builder.from(0);
		builder.size(3);
		builder.timeout(new TimeValue(60, TimeUnit.SECONDS));
	    //条件放入请求
		request.source(builder);
	    //执行
		SearchResponse search = restHighLevelClient.search(request, RequestOptions.DEFAULT);
		//打印结果
		System.out.println(JSON.toJSONString(search.getHits()));
	}