甘肃省住房建设厅网站企业网站
- 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/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/data/elasticsearchhttp://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 {@Autowiredprivate ArticleRepository articleRepository;@Autowiredprivate ElasticsearchTemplate template;@Testpublic 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;}@Overridepublic 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进行操作，主键是LongList<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 {@Autowiredprivate ArticleRepository articleRepository;//在运行中不会有啥问题！@Autowiredprivate ElasticsearchTemplate template;@Testpublic void createIndex() throws Exception {//创建索引并配置映射关系template.createIndex(Article.class);//配置映射关系//template.putMapping(Article.class);}@Testpublic 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);}}@Testpublic void deleteDocumentById() throws Exception {//根据id删除文档信息articleRepository.deleteById(1l);//articleRepository.deleteAll();//全部删除}@Testpublic void findAll() throws Exception {Iterable<Article> articles = articleRepository.findAll();articles.forEach(a -> System.out.println(a));}@Testpublic void testFindById() throws Exception {Optional<Article> optional = articleRepository.findById(1l);Article article = optional.get();System.out.println(article);}@Testpublic void testFindByTitle() throws Exception {List<Article> list = articleRepository.findByTitle("爆炸and沉醉");list.stream().forEach(a -> System.out.println(a));}@Testpublic void testFindByTitleOrContent1() throws Exception {articleRepository.findByTitleOrContent("沉醉", "香水").forEach(a -> System.out.println(a));}@Testpublic void testFindByTitleOrContent2() throws Exception {//pageable分页查询Pageable pageable = PageRequest.of(1, 15);articleRepository.findByTitleOrContent("沉醉", "香水", pageable).forEach(a -> System.out.println(a));}@Testpublic 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~