本站内容均来自兴趣收集,如不慎侵害的您的相关权益,请留言告知,我们将尽快删除.谢谢.
一 Spring Data Elasticsearch 项目环境搭建
1.1 修改pom文件添加依赖
目前使用spring-boot-starter-parent版本为2.6.8
对应spring-data-elasticsearch版本为4.3.4
<!-- springDateElasticsearch依赖--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-elasticsearch</artifactId> </dependency>
1.2 修改application.yml配置文件
spring:
elasticsearch:
rest:
uris: http://192.168.8.128:9200
二 ElasticsearchTemplate的使用
2.1 创建实体类
@Document指定实体类和索引对应关系
indexName：索引名称
type: 索引类型（从ES 7.0 开始已经过时了）
shards: 主分片数量。从ES 7开始默认1
replicas：复制分片数量。从ES 7开始默认1
@Id 指定主键
@Field指定普通属性
type： 对应Elasticsearch中属性类型。使用FiledType枚举可以快速获取。
text类型能被分词
keywords不能被分词
index： 是否创建索引。作为搜索条件时index必须为true
analyzer：指定分词器类型。
@Data
@Document(indexName = "student_index",shards = 1,replicas = 1)
public class Student {
@Id
private String id;
@Field(type = FieldType.Keyword)
private String name;
@Field(type = FieldType.Text,analyzer = "ik_max_word")
private String desc;
@Field(type = FieldType.Text,analyzer = "ik_max_word")
private String data;
@Field(type = FieldType.Integer)
private Integer age;
}
2.2 初始化索引
@Autowired
private ElasticsearchRestTemplate elasticsearchRestTemplate;
@Test
void createIndex() {
// 从 spring data es 4.0开始所有索引操作都在这个接口
IndexOperations indexOperations = elasticsearchRestTemplate.indexOps(Student.class);
// 是否存在，存在则删除
if(indexOperations.exists()){
indexOperations.delete();
}
// 创建索引
indexOperations.create();
// createMapping 根据实体类获取映射关系
// putMapping 把映射关系添加到索引中
Document mapping = indexOperations.createMapping(Student.class);
indexOperations.putMapping(mapping);
}
2.3 删除索引
/**
* 删除索引
*/ @Test
void deleteIndex() {
IndexOperations indexOperations = elasticsearchRestTemplate.indexOps(Student.class);
boolean delete = indexOperations.delete();
System.out.println(delete);
}
2.4 新增文档
新增单个文档
/**
* 新增单个文档
*/ @Test
void insert(){
Student student = new Student();
student.setAge(23);
student.setData("123");
student.setDesc("华为手机");
student.setId("1");
student.setName("张三");
Student save = elasticsearchRestTemplate.save(student);
System.out.println(save);
}批量新增
/**
* 批量新增
*/ @Test
void batchInsert(){
List<Student> list = new ArrayList<>();
list.add(new Student("2","李四","苹果手机","1",22));
list.add(new Student("3","王五","oppo手机","2",24));
list.add(new Student("4","赵六","voio手机","3",25));
list.add(new Student("5","田七","小米手机","4",26));
Iterable<Student> result = elasticsearchRestTemplate.save(list);
System.out.println(result);
}
2.5 删除操作
根据主键删除
/**
* 根据主键删除
*/ @Test
void deleteById() {
// 根据id删除
String delete = elasticsearchRestTemplate.delete("5", Student.class);
System.out.println(delete);
}根据条件删除
/**
* 根据查询条件删除
*/ @Test
void delete() {
QueryStringQueryBuilder queryBuilder = QueryBuilders.queryStringQuery("张三");
Query query = new NativeSearchQuery(queryBuilder);
ByQueryResponse QueryDelete = elasticsearchRestTemplate.delete(query, Student.class);
System.out.println(QueryDelete);
}
2.6 修改操作
全量替换
/**
* 批量修改
*/ @Test
void update(){
Student student = new Student();
student.setId("1");
student.setAge(23);
student.setData("99");
student.setDesc("华为手机AND苹果手机");
student.setName("张三");
Student save = elasticsearchRestTemplate.save(student);
System.out.println(save);
}部分修改
/**
* 部分修改
*/ @Test
void update2(){
// ctx._source 固定写法
String script = "ctx._source.age = 27;ctx._source.desc = 'oppo手机and苹果电脑'";
UpdateQuery build = UpdateQuery.builder("3").withScript(script).build();
IndexCoordinates indexCoordinates = IndexCoordinates.of("student_index");
UpdateResponse update = elasticsearchRestTemplate.update(build, indexCoordinates);
System.out.println(update.getResult());
}
2.7 查询操作
根据主键查询
/**
* 根据主键查查询
*/ @Test
void searchById(){
Student student = elasticsearchRestTemplate.get("3", Student.class);
System.out.println(student);
}模糊查询
/**
* 模糊查询
*/ @Test
void LikeSearch(){
QueryStringQueryBuilder queryBuilder = QueryBuilders.queryStringQuery("手机");
Query query = new NativeSearchQuery(queryBuilder);
SearchHits<Student> search = elasticsearchRestTemplate.search(query, Student.class);
List<SearchHit<Student>> searchHits = search.getSearchHits();
List<Student> list = new ArrayList<>();
searchHits.forEach(sh->{
list.add(sh.getContent());
});
System.out.println(list);
}使用match_all查询所有文档
/**
* 使用match_all查询所有文档
*/ @Test
void matchAllSearch(){
MatchAllQueryBuilder queryBuilder = QueryBuilders.matchAllQuery();
Query query = new NativeSearchQuery(queryBuilder);
SearchHits<Student> search = elasticsearchRestTemplate.search(query, Student.class);
List<SearchHit<Student>> searchHits = search.getSearchHits();
List<Student> list = new ArrayList<>();
searchHits.forEach(sh->{
list.add(sh.getContent());
});
System.out.println(list);
}使用match查询文档
/**
* 使用match查询文档
*/ @Test
void matchSearch(){
Query query = new NativeSearchQuery( QueryBuilders.matchQuery("name","张三"));
SearchHits<Student> search = elasticsearchRestTemplate.search(query, Student.class);
List<SearchHit<Student>> searchHits = search.getSearchHits();
System.out.println(search.getTotalHits());
List<Student> list = new ArrayList<>();
searchHits.forEach(sh->{
list.add(sh.getContent());
});
System.out.println(list);
}使用match_phrase查询文档
/**
* 使用match_phrase查询文档
* 短语搜索是对条件不分词，但是文档中属性根据配置实体类时指定的分词类型进行分词。
* 如果属性使用ik分词器，从分词后的索引数据中进行匹配。
*/ @Test
void matchPhraseSearch(){
Query query = new NativeSearchQuery( QueryBuilders.matchPhraseQuery("desc","电脑"));
SearchHits<Student> search = elasticsearchRestTemplate.search(query, Student.class);
List<SearchHit<Student>> searchHits = search.getSearchHits();
System.out.println(search.getTotalHits());
List<Student> list = new ArrayList<>();
searchHits.forEach(sh->{
list.add(sh.getContent());
});
System.out.println(list);
}使用range查询文档
/**
* 使用range查询文档
*/ @Test
void rangeSearch(){
Query query = new NativeSearchQuery( QueryBuilders.rangeQuery("age").gte("24").lte(29));
SearchHits<Student> search = elasticsearchRestTemplate.search(query, Student.class);
List<SearchHit<Student>> searchHits = search.getSearchHits();
System.out.println(search.getTotalHits());
List<Student> list = new ArrayList<>();
searchHits.forEach(sh->{
list.add(sh.getContent());
});
System.out.println(list);
}多条件查询
/**
* 多条件查询
*/ @Test
void querysSearch(){
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
List<QueryBuilder> listQuery = new ArrayList<>();
listQuery.add(QueryBuilders.matchQuery("name","张三"));
listQuery.add(QueryBuilders.matchQuery("age","23"));
boolQueryBuilder.must().addAll(listQuery);// 逻辑 与
// boolQueryBuilder.should().addAll(listQuery);// 逻辑 或
BoolQueryBuilder boolQueryBuilder2 = QueryBuilders.boolQuery();
List<QueryBuilder> listQuery2 = new ArrayList<>();
listQuery2.add(QueryBuilders.matchQuery("name","李四"));
listQuery2.add(QueryBuilders.matchQuery("age","22"));
boolQueryBuilder2.must().addAll(listQuery2);// 逻辑 与
BoolQueryBuilder boolQueryBuilder3 = QueryBuilders.boolQuery();
List<QueryBuilder> listQuery3 = new ArrayList<>();
listQuery3.add(boolQueryBuilder);
listQuery3.add(boolQueryBuilder2);
boolQueryBuilder3.should().addAll(listQuery3);// 逻辑 或
boolQueryBuilder3.must().addAll(listQuery3);// 逻辑 与
NativeSearchQuery nativeSearchQuery = new NativeSearchQuery(boolQueryBuilder3);
SearchHits<Student> search = elasticsearchRestTemplate.search(nativeSearchQuery, Student.class);
List<SearchHit<Student>> searchHits = search.getSearchHits();
System.out.println(search.getTotalHits());
List<Student> list = new ArrayList<>();
searchHits.forEach(sh->{
list.add(sh.getContent());
});
System.out.println(list);
}分页与排序
/**
* 分页查询
*/ @Test
void pageSearch(){
Query query = new NativeSearchQuery(QueryBuilders.matchAllQuery());
// 排序
query.addSort(Sort.by(Sort.Direction.DESC,"age"));
// 分页
query.setPageable(PageRequest.of(1,2));
SearchHits<Student> searchHits = elasticsearchRestTemplate.search(query, Student.class);
System.out.println(searchHits.getTotalHits());
List<SearchHit<Student>> hitList = searchHits.getSearchHits();
List<Student> listResult = new ArrayList<>();
hitList.forEach(list->{
listResult.add(list.getContent());
});
System.out.println(listResult);
}
Be First to Comment