- Java后端-学习路线-笔记汇总表【黑马程序员】
- ElasticSearch-学习笔记01【ElasticSearch基本介绍】【day01】
- ElasticSearch-学习笔记02【ElasticSearch索引库维护】
- ElasticSearch-学习笔记03【ElasticSearch集群】
- ElasticSearch-学习笔记04【Java客户端操作索引库】【day02】
- ElasticSearch-学习笔记05【SpringDataElasticSearch】
目录
12-SpringDataElasticsearch工程搭建
01、导入pom.xml坐标
02、配置applicationContext.xml文件
13-SpringDataES工程配置
14-SpringDataES创建索引
15-SpringDataES添加文档
16-SpringDataES删除文档
17-SpringDataES更新文档
18-SpringDataES简单查询
19-自定义查询方法查询
20-使用NativeSearchQuery查询
21-ElasticSearch课程总结
01、项目文件一览图
02、工程详细代码
01、Article.java
02、ArticleRepository.java
03、SpringDataElasticSearchTest.java
12-SpringDataElasticsearch工程搭建
一、使用Java客户端管理ES
1、创建索引库
2、使用Java客户端设置Mappings
3、添加文档(一行数据)
4、添加文档的第二种方式二、使用ES客户端实现搜索
1、根据id搜索
2、根据Term查询（关键词）
3、QueryString查询方式（带分析的查询）
4、分页的处理
5、查询结果高亮显示三、SpringDataElasticSearch
1、工程搭建
1）创建一个java工程。
2）把相关jar包添加到工程中，如果maven工程就添加坐标。
3）创建一个spring的配置文件
1、配置elasticsearch:transport-client
2、配置elasticsearch:repositories，包扫描器，扫描dao
3、配置elasticsearchTemplate对象，就是一个bean
01、导入pom.xml坐标
新建maven工程“springdata-elasticsearch”，导入jar包：
02、配置applicationContext.xml文件
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:elasticsearch="http://www.springframework.org/schema/data/elasticsearch"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/data/elasticsearch
http://www.springframework.org/schema/data/elasticsearch/spring-elasticsearch-1.0.xsd
">
<!--elastic客户对象的配置-->
<elasticsearch:transport-client id="esClient" cluster-name="my-elasticsearch" cluster-nodes="127.0.0.1:9301, 127.0.0.1:9302, 127.0.0.1:9303"/>
<!--配置包扫描器，扫描dao的接口-->
<elasticsearch:repositories base-package="com.itheima.repositories"/>
<!--bean-->
<bean id="elasticsearchTemplate" class="org.springframework.data.elasticsearch.core.ElasticsearchTemplate">
<constructor-arg name="client" ref="esClient"/>
</bean>
</beans>13-SpringDataES工程配置
14-SpringDataES创建索引
java.lang.IllegalStateException: Failed to load ApplicationContext 解决办法
import com.itheima.es.entity.Article;
import com.itheima.es.repositories.ArticleRepository;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext.xml")//加载配置文件初始化spring容器
public class SpringDataElasticSearchTest {
@Autowired
private ArticleRepository articleRepository;
@Autowired
private ElasticsearchTemplate template;
@Test
public void createIndex() throws Exception {
//创建索引并配置映射关系
template.createIndex(Article.class);
//配置映射关系
//template.putMapping(Article.class);
}
}15-SpringDataES添加文档
16-SpringDataES删除文档
17-SpringDataES更新文档
ES的底层是Lucene，Lucene更新原理是先添加再删除。
18-SpringDataES简单查询
19-自定义查询方法查询
20-使用NativeSearchQuery查询
21-ElasticSearch课程总结
一、使用Java客户端管理ES
1、创建索引库
步骤：
1）创建一个Java工程
2）添加jar包，添加maven的坐标
3）编写测试方法实现创建索引库
1、创建一个Settings对象，相当于是一个配置信息，主要用于配置集群的名称
2、创建一个客户端Client对象
3、使用client对象创建一个索引库
4、关闭client对象
2、使用Java客户端设置Mappings
步骤：
1）创建一个Settings对象
2）创建一个Client对象
3）创建一个mapping信息，应该是一个json数据，可以是字符串也可以是XContextBuilder对象
4）使用client向es服务器发送mapping信息
5）关闭client对象
3、添加文档(一行数据)
步骤：
1）创建一个Settings对象
2）创建一个Client对象
3）创建一个文档对象，创建一个json格式的字符串或者使用XContentBuilder
4）使用Client对象把文档添加到索引库中
5）关闭client
4、添加文档的第二种方式
创建一个pojo类
使用工具类把pojo转换成json字符串
把文档写入索引库二、使用ES客户端实现搜索
1、根据id搜索
QueryBuilder queryBuilder = QueryBuilders.idsQuery().addIds("1", "2");
2、根据Term查询（关键词）
QueryBuilder queryBuilder = QueryBuilders.termQuery("title", "北方");
3、QueryString查询方式（带分析的查询）
QueryBuilder queryBuilder = QueryBuilders.queryStringQuery("速度与激情").defaultField("title");
查询步骤：
1）创建一个Client对象
2）创建一个查询对象，可以使用QueryBuilders工具类创建QueryBuilder对象
3）使用client执行查询
4）得到查询的结果
5）取查询结果的总记录数
6）取查询结果列表
7）关闭client
4、分页的处理
在client对象执行查询之前，设置分页信息。
然后再执行查询
//执行查询
SearchResponse searchResponse = client.prepareSearch("index_hello")
.setTypes("article")
.setQuery(queryBuilder)
//设置分页信息
.setFrom(0)
//每页显示的行数
.setSize(5)
.get();
分页需要设置两个值：from、size
from：起始的行号，从0开始。
size：每页显示的记录数
5、查询结果高亮显示
（1）高亮的配置
1）设置高亮显示的字段
2）设置高亮显示的前缀
3）设置高亮显示的后缀
（2）在client对象执行查询之前，设置高亮显示的信息
（3）遍历结果列表时可以从结果中取高亮结果三、SpringDataElasticSearch
1、工程搭建
1）创建一个java工程。
2）把相关jar包添加到工程中，如果maven工程就添加坐标。
3）创建一个spring的配置文件
1、配置elasticsearch:transport-client
2、配置elasticsearch:repositories，包扫描器，扫描dao
3、配置elasticsearchTemplate对象，就是一个bean
2、管理索引库
1、创建一个Entity类，其实就是一个JavaBean（pojo）映射到一个Document上
需要添加一些注解进行标注。
2、创建一个Dao，是一个接口，需要继承ElasticSearchRepository接口。
3、编写测试代码。
3、创建索引
直接使用ElasticsearchTemplate对象的createIndex方法创建索引，并配置映射关系。
4、添加与更新文档
1）创建一个Article对象
2）使用ArticleRepository对象向索引库中添加文档。
5、删除文档
直接使用ArticleRepository对象的deleteById方法直接删除。
6、查询索引库
直接使用ArticleRepository对象的查询方法
7、自定义查询方法
需要根据SpringDataES的命名规则来命名
如果不设置分页信息，默认带分页，每页显示10条数据。
如果设置分页信息，应该在方法中添加一个参数Pageable
Pageable pageable = PageRequest.of(0, 15);
注意：设置分页信息，默认是从0页开始。
可以对搜索的内容先分词然后再进行查询，每个词之间都是and的关系。
8、使用原生的查询条件查询
NativeSearchQuery对象。
使用方法：
1）创建一个NativeSearchQuery对象
设置查询条件，QueryBuilder对象
2）使用ElasticSearchTemplate对象执行查询
3）取查询结果
01、项目文件一览图
02、工程详细代码
01、Article.java
package com.itheima.es.entity;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;
@Document(indexName = "sdes_blog", type = "article")//文档，springdata-es
public class Article {
@Id
@Field(type = FieldType.Long, store = true)
private long id;
@Field(type = FieldType.text, store = true, analyzer = "ik_smart")
private String title;
@Field(type = FieldType.text, store = true, analyzer = "ik_smart")
private String content;
public long getId() {
return id;
}
public void setId(long id) {
this.id = id;
}
public String getTitle() {
return title;
}
public void setTitle(String title) {
this.title = title;
}
public String getContent() {
return content;
}
public void setContent(String content) {
this.content = content;
}
@Override
public String toString() {
return "Article{" +
"id=" + id +
", title='" + title + '\'' +
", content='" + content + '\'' +
'}';
}
}02、ArticleRepository.java
package com.itheima.es.repositories;
import com.itheima.es.entity.Article;
import org.springframework.data.domain.Pageable;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
//import java.awt.print.Pageable;
import java.util.List;
public interface ArticleRepository extends ElasticsearchRepository<Article, Long> {//对Article进行操作，主键是Long
List<Article> findByTitle(String title);
List<Article> findByTitleOrContent(String title, String content);
List<Article> findByTitleOrContent(String title, String content, Pageable pageable);//pageable设置分页信息
}03、SpringDataElasticSearchTest.java
import com.itheima.es.entity.Article;
import com.itheima.es.repositories.ArticleRepository;
import jdk.nashorn.internal.runtime.ECMAException;
import org.elasticsearch.index.query.QueryBuilders;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
import org.springframework.data.elasticsearch.core.query.NativeSearchQuery;
import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.util.List;
import java.util.Optional;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext.xml")//加载配置文件初始化spring容器
public class SpringDataElasticSearchTest {
@Autowired
private ArticleRepository articleRepository;//在运行中不会有啥问题！
@Autowired
private ElasticsearchTemplate template;
@Test
public void createIndex() throws Exception {
//创建索引并配置映射关系
template.createIndex(Article.class);
//配置映射关系
//template.putMapping(Article.class);
}
@Test
public void addDocument() throws Exception {
for (int i = 11; i <= 20; i++) {
//创建一个Article对象
Article article = new Article();
article.setId(i);
article.setTitle("我的脑海每分每秒只为你一人沉醉~");//小黑子 我应该拿你怎样 我应该拿你怎样~~~
article.setContent("最迷人让我神魂颠倒是你身上香水~");//哎嗨呦，你干嘛~~~ uh~ 所有人都在看着你~
//把文档写入索引库
articleRepository.save(article);
}
}
@Test
public void deleteDocumentById() throws Exception {//根据id删除文档信息
articleRepository.deleteById(1l);
//articleRepository.deleteAll();//全部删除
}
@Test
public void findAll() throws Exception {
Iterable<Article> articles = articleRepository.findAll();
articles.forEach(a -> System.out.println(a));
}
@Test
public void testFindById() throws Exception {
Optional<Article> optional = articleRepository.findById(1l);
Article article = optional.get();
System.out.println(article);
}
@Test
public void testFindByTitle() throws Exception {
List<Article> list = articleRepository.findByTitle("爆炸and沉醉");
list.stream().forEach(a -> System.out.println(a));
}
@Test
public void testFindByTitleOrContent1() throws Exception {
articleRepository.findByTitleOrContent("沉醉", "香水").forEach(a -> System.out.println(a));
}
@Test
public void testFindByTitleOrContent2() throws Exception {//pageable分页查询
Pageable pageable = PageRequest.of(1, 15);
articleRepository.findByTitleOrContent("沉醉", "香水", pageable).forEach(a -> System.out.println(a));
}
@Test
public void testNativeSearchQuery() throws Exception {
//创建一个查询对象
NativeSearchQuery query = new NativeSearchQueryBuilder().withQuery(QueryBuilders.queryStringQuery("脑海爆炸").defaultField("title"))
.withPageable(PageRequest.of(0, 15))
.build();
//执行查询
List<Article> articleList = template.queryForList(query, Article.class);
articleList.forEach(a -> System.out.println(a));
}
}bye~
