导包
<!--导入es-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
</dependency>配置
data:
elasticsearch:
cluster-name: elasticsearch
cluster-nodes: 127.0.0.1:93009200,可以查看es信息
9300 内部用
9300是TCP协议端口号，ES集群之间通讯端口号
9200端口号，暴露ES RESTful接口端口号
searchAnalyzer 查的时候分词器
analyzer 存入的时候分词器
GET _cat/indices 相当于查询所有库
导入工具类
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.TransportAddress;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import org.springframework.stereotype.Component;
import java.net.InetAddress;
import java.net.UnknownHostException;
@Component
public class ESClientUtil {
public TransportClient getClient(){
TransportClient client = null;
Settings settings = Settings.builder()
.put("cluster.name", "elasticsearch").build();
try {
client = new PreBuiltTransportClient(settings).addTransportAddress(new TransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
} catch (UnknownHostException e) {
e.printStackTrace();
}
return client;
}
}创建实现增删改查的ES工厂，这个接口估计是模仿mybatis那个mapper，东施效颦罢了。
package org.example.utils;
import org.example.domain.EmpDoc;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.stereotype.Repository;
//要穿一个类，然后文档对象id的类型,我们需要自己写一个接口类，并在接口类上打一个注解，注入到spring容器
/**
* 这个Repository 类似与mybatis中的mapper接口
* 这个接口不需要实现类，我们到时候如果想对文档crud，只需要注入这个接口类就可以了。
* 反正就是动态代理嘛，自动生成动态代理类，自动将代理实现类交给spring管理，所以我们注入这个接口类
* 就可以使用这个接口类的方法，实现文档的crud
*/
@Repository
public interface UserDocRepository extends ElasticsearchRepository<EmpDoc,Long> {
}
我们创建索引库的话，可以通过注解实体类来创建es库
package org.example.domain;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
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;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.stereotype.Repository;
@Data
@AllArgsConstructor
@NoArgsConstructor
//这里指明了
@Document(indexName = "test",type = "emp")
public class EmpDoc{
@Id //文档id字段
private Long id;
@Field(type = FieldType.Keyword) //不分词
private String name;
@Field(type = FieldType.Integer)
private Integer age;
@Field(type = FieldType.Text,analyzer = "ik_smart"
,searchAnalyzer = "ik_smart")
private String intro;
}
@Document(indexName = "test",type = "emp")
指明了在es中的位置和地址，text分词查询，keyword不分词哈。
开始操作
@Autowired
private ElasticsearchTemplate elasticsearchTemplate;创建索引库
@Test
public void test05(){
// boolean index = elasticsearchTemplate.createIndex("spring-demo");
// System.out.println(index);
elasticsearchTemplate.createIndex(EmpDoc.class);
elasticsearchTemplate.putMapping(EmpDoc.class);
} @Test
public void test06(){
EmpDoc empDoc = new EmpDoc();
empDoc.setAge(12);
empDoc.setIntro("zzzz");
empDoc.setId(1l);
empDoc.setName("zs");
userDocRepository.save(empDoc);
} @Test
public void test07(){
System.out.println(userDocRepository.findById(1l).get());
}其余操作就很简单了,简单的增删改查没意思，直接快进到聚合查询，我就是为了回忆聚合查询，才开始又慢慢看es的
@Test
public void test08(){
// 创建一个查询构建器对象
NativeSearchQueryBuilder builder = new NativeSearchQueryBuilder();
// Page<EmpDoc> search = userDocRepository.search(builder.build());
NativeSearchQuery build = builder.build();
Page<EmpDoc> search = userDocRepository.search(build);
// 添加查询条件，添加排序条件，添加分页条件,将es的分页对象转换为自己的对象
PageList<EmpDoc> empDocPageList = new PageList<>(search.getTotalElements(), search.getContent());
System.out.println(empDocPageList);
}build去拿searquery对象，为什么要去拿searchquery对象呢？因为search方法要searchquery，才会返回值。
然后这个返回的值里面有很多方法，就可以拿到totals啥的。
分页
queryBuilder.withPageable(PageRequest.of(0,10));
对了，这个方法要的是接口，所以我们要找接口的实现类。是这个方法是要接口吗，我有点记不清了。
成功哈
关键字查询，范围查询，条件查询
我们要先搞清楚
query -> bool -> must(match)/filter(term/range)的顺序
然后
queryBuilder.withQuery(boolQuery);
这个方法可以放入一个boolQuery，这个boolQuery我们可以弄很多的聚合查询在其中
bool中有must关键查询和filter范围查询和过滤查询
must 多个属性都可以关键字查询
mutiMatchQuery 匹配多个字段，多字段分词查询
must——》match关键字查询
filter-》term 是条件查询
filter-》range是范围查询
反正一切都在代码中了哈
@Test
public void test08(){
// 创建一个查询构建器对象
NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();
// Page<EmpDoc> search = userDocRepository.search(builder.build());
//条件查询
FieldSortBuilder age = SortBuilders.fieldSort("age").order(SortOrder.DESC);
queryBuilder.withSort(age);
// 分页查询
queryBuilder.withPageable(PageRequest.of(0,10));
// 关键字，分词查询还是不分词查询，是分词查询，包含关键字会查询出来。
// dsl结构，要记得住，不然理解不到
// query -> bool -> must(match)/filter(term/range)
// mutiMatchQuery 多字段
// 直接先到bool层
BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
// List<QueryBuilder> must = boolQuery.must();
// must.add(QueryBuilders.matchQuery("age","15"));
// queryBuilder.withQuery()
List<QueryBuilder> filter = boolQuery.filter();
// filter.add(QueryBuilders.termQuery("id",3));
// 词元查询
// 年龄
filter.add(QueryBuilders.rangeQuery("age").gte(15).lte(20));
queryBuilder.withQuery(boolQuery);
NativeSearchQuery build = queryBuilder.build();
Page<EmpDoc> search = userDocRepository.search(build);
// 添加查询条件，添加排序条件，添加分页条件,将es的分页对象转换为自己的对象
PageList<EmpDoc> empDocPageList = new PageList<>(search.getTotalElements(), search.getContent());
System.out.println(empDocPageList);
}
