导包
<!--导入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: elasticsearchcluster-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不分词哈。
开始操作
@Autowiredprivate ElasticsearchTemplate elasticsearchTemplate;创建索引库
@Testpublic void test05(){
// boolean index = elasticsearchTemplate.createIndex("spring-demo");
// System.out.println(index);elasticsearchTemplate.createIndex(EmpDoc.class);elasticsearchTemplate.putMapping(EmpDoc.class);} @Testpublic void test06(){EmpDoc empDoc = new EmpDoc();empDoc.setAge(12);empDoc.setIntro("zzzz");empDoc.setId(1l);empDoc.setName("zs");userDocRepository.save(empDoc);} @Testpublic void test07(){System.out.println(userDocRepository.findById(1l).get());}其余操作就很简单了,简单的增删改查没意思，直接快进到聚合查询，我就是为了回忆聚合查询，才开始又慢慢看es的
@Testpublic 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是范围查询
反正一切都在代码中了哈
@Testpublic 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);}
