。

其主要目标是使得对数据的访问变得方便快捷#xff0c;并支持

map-reduce

是一个用于简化数据库、非关系型数据库、索引库访问并支持云服务的开源框架。

其主要目标是使得对数据的访问变得方便快捷并支持

map-reduce

JPA的写法可以在几乎不用写实现的情况下实现对数据的访问和操作。

除了

CRUD

的官网https://spring.io/projects/spring-data/

Spring

https://spring.io/projects/spring-data-elasticsearch

,进入到Spring

Boot版本https://docs.spring.io/spring-data/elasticsearch/docs/4.3.0/reference/html/#preface.requirements

Spring

xmlnshttp://maven.apache.org/POM/4.0.0xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0

http://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersionparentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion2.3.6.RELEASE/versionrelativePath//parentgroupIdorg.example/groupIdartifactIdspringdata-elasticsearch/artifactIdversion1.0-SNAPSHOT/versionpropertiesmaven.compiler.source8/maven.compiler.sourcemaven.compiler.target8/maven.compiler.targetproject.build.sourceEncodingUTF-8/project.build.sourceEncoding/propertiesdependenciesdependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-elasticsearch/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-devtools/artifactIdscoperuntime/scopeoptionaltrue/optional/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-test/artifactId/dependencydependencygroupIdjunit/groupIdartifactIdjunit/artifactId/dependencydependencygroupIdorg.springframework/groupIdartifactIdspring-test/artifactId/dependency/dependencies

/project4

增加配置文件application.properties添加以下配置

服务地址

logging.level.com.atguigu.esdebug5

SpringBoot

启动类SpringDataElasticSearchMainApplication

public

SpringDataElasticSearchMainApplication

{public

{SpringApplication.run(SpringDataElasticSearchMainApplication.class,args);}

创建数据实体类

客户端的。

需要自定义配置类继承AbstractElasticsearchConfiguration并实现elasticsearchClient()抽象方法创建

RestHighLevelClient

AbstractElasticsearchConfiguration

{private

newRestHighLevelClient(builder);return

DAO

ElasticsearchRepositoryProduct,Long

实体类映射操作

ElasticsearchRestTemplateAutowiredprivate

elasticsearchRestTemplate;//创建索引并增加映射配置Testpublic

void

createIndex(){//创建索引系统初始化会自动创建索引System.out.println(创建索引);}Testpublic

void

deleteIndex(){//创建索引系统初始化会自动创建索引boolean

***

elasticsearchRestTemplate.deleteIndex(Product.class);System.out.println(删除索引

***);}

Product();product.setId(1L);product.setTitle(华为手机);product.setCategory(手机);product.setPrice(2999.0);product.setImages(http://www.atguigu/hw.jpg);productDao.save(product);}//修改Testpublic

void

Product();product.setId(1L);product.setTitle(小米

手机);product.setCategory(手机);product.setPrice(9999.0);product.setImages(http://www.atguigu/xm.jpg);productDao.save(product);}//根据

查询Testpublic

productDao.findById(1L).get();System.out.println(product);}Testpublic

void

{System.out.println(product);}}//删除Testpublic

void

Product();product.setId(1L);productDao.delete(product);}//批量新增Testpublic

void

Product();product.setId(Long.valueOf(i));product.setTitle([

]小米手机);product.setCategory(手机);product.setPrice(1999.0

i);product.setImages(http://www.atguigu/xm.jpg);productList.add(product);}productDao.saveAll(productList);}//分页查询Testpublic

void

productDao.findAll(pageRequest);for

(Product

{System.out.println(Product);}}

执行delete()删除id为1的数据后再执行findAll()方法查找索引的所有文档查看程序执行结果

执行saveAll()方法批量新增后执行findByPageable方法分页查询数据查看程序执行结果

配置分词器

在测试文档查询之前需要先配置中文分词器ElasticSearch默认的内置分词器standard是针对英文等拉丁语系设计的是不支持中文分词的。

IK分词器是一个开源的中文分词器插件丰富和优化了Elasticsearch

环境ES7.8安装ik分词器为例对应下载ik分词器7.8版本下载链接https://release.infinilabs.com/analysis-ik/stable/elasticsearch-analysis-ik-7.8.0.zip

ik分词器各个版本的下载链接https://release.infinilabs.com/analysis-ik/stable/

GitHub仓库链接https://github.com/infinilabs/analysis-ik

1、下载ik分词器压缩包并解压

从上面的分词结果可以看到查询“小米手机”就查不到了。

这时候就需要我们自定义拆分文本

5、自定义拆分脚本

首先在plugins\ik\config目录下新建一个文本文件命名为.dic后缀的文件例如我命名为myWord.dic

。

开自定义的dic文件在其中编写你需要的词语这里要将文件的编码选择为UTF-8否则无法正确识别

打开plugins\ik\config目录下的IKAnalyzer.cfg.xml文件将自定义的dic文件写入

文档搜索

productDao.search(termQueryBuilder);for

(Product

{System.out.println(product);}}/***

term

productDao.search(termQueryBuilder,

pageRequest);for

{System.out.println(product);}}

}term查询结果