icsearch集成Spring

介绍一、环境初始化二、实战入门1、定义数据实体类2、定义Dao层3、框架集成-SpringData-集成测试-索引操作4、框架集成-SpringData-集成测试-文档操作5、框架集成-SpringData-集成测试-文档搜索

Spring

POJO的关键功能区域为中心的模型与Elastichsearch交互文档和轻松地编写一个存储索引库数据访问层简单的来说是类似于Mybatis-Plus操作。

一、环境初始化

elasticsearch--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-elasticsearch/artifactId/dependency2、增加配置文件配置

http://localhost:9200#设置有用户和密码可以取消注释

username:

hrefhttps://github.com/xuyuan-upward许苑向上/a*/

public

ElasticsearchRestTemplateAutowiredprivate

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

void

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

void

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

flg

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

flg);}

Product();product.setId(2L);product.setTitle(华为手机);product.setCategory(手机);product.setPrice(2999.0);product.setImages(http://www.atguigu/hw.jpg);productDao.save(product);}//POSTMAN,

GET

http://localhost:9200/product/_doc/2//修改Testpublic

void

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

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

GET

http://localhost:9200/product/_doc/2//根据

查询Testpublic

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

void

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

void

Product();product.setId(2L);productDao.delete(product);}//POSTMAN,

GET

http://localhost:9200/product/_doc/2//批量新增Testpublic

void

Product();product.setId(Long.valueOf(i));product.setTitle([i]小米手机);product.setCategory(手机);product.setPrice(1999.0

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

void

findByPageable(){//设置排序(排序方式正序还是倒序排序的

id)Sort

Sort.by(Sort.Direction.DESC,id);int

表示第二页int

pageSize,sort);//分页查询PageProduct

productPage

productDao.findAll(pageRequest);for

(Product

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

SpringBootTest

productDao.search(termQueryBuilder);for

(Product

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

term

productDao.search(termQueryBuilder,pageRequest);for

(Product

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