<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
        </dependency>

spring:
  elasticsearch:
    rest:
      uris: localhost:19200
      # 賬號密碼配置，如果沒有則不需要
      password: elastic
      username: elastic

package com.walker.es.entity;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.annotation.Transient;
import org.springframework.data.annotation.TypeAlias;
import org.springframework.data.elasticsearch.annotations.DateFormat;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
@Data
//索引
// boolean createIndex() default true;  默認(rèn)會創(chuàng)建索引
@Document(indexName = "alarm_record", shards = 2, replicas = 2,createIndex = true)
public class AlarmRecordEntity {
    //    配置使用的id
    @Id
    private Long id;
    //    事件
//  配置屬性，分詞器
    @Field(type = FieldType.Text, analyzer = "ik_max_word")
    private String title;
    //    設(shè)備
    @Field(type = FieldType.Keyword)
    private String deviceCode;
    //    時(shí)間  需要使用keyword，否則無法實(shí)現(xiàn)范圍查詢 
    @Field(type = FieldType.Keyword)
    private String time;
    //    在es中進(jìn)行忽略的
    @Transient
    private String msg;
}

package com.walker.es.repository;
import com.walker.es.entity.AlarmRecordEntity;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.stereotype.Repository;
// 添加注解
@Repository
// 繼承類 ElasticsearchRepository
public interface AlarmRecordRepository extends ElasticsearchRepository<AlarmRecordEntity, Long> {
    // 你可以在這里添加自定義查詢方法
}

    @Autowired
    private AlarmRecordRepository alarmRecordRepository;

    // 創(chuàng)建新警報(bào)記錄
    @PostMapping
    public ResponseEntity<AlarmRecordEntity> createAlarmRecord(@RequestBody AlarmRecordEntity alarmRecord) {
//      自動生成雪花id
        alarmRecord.setId(IdUtil.getSnowflakeNextId());
        AlarmRecordEntity savedRecord = alarmRecordRepository.save(alarmRecord);
        return ResponseEntity.ok(savedRecord);
    }

{
  "title": "打架告警",
  "deviceCode": "A001",
  "time": "2024-11-10 10:10:00",
  "msg": "消息描述"
}

    @Autowired
    private DocumentOperations documentOperations;
    @Autowired
    private ElasticsearchConverter elasticsearchConverter;
// 更新警報(bào)記錄
    @PutMapping("/{id}")
    public ResponseEntity<AlarmRecordEntity> updateAlarmRecord(@PathVariable Long id, @RequestBody AlarmRecordEntity alarmRecord) {
        //使用ElasticsearchConverter 將對象轉(zhuǎn)成Document對象
        Document document = elasticsearchConverter.mapObject(alarmRecord);
       // 修改方法
        UpdateQuery updateQuery = UpdateQuery.builder(String.valueOf(id)).withDocument(document).build();
        UpdateResponse updateResponse = documentOperations.update(updateQuery, IndexCoordinates.of("alarm_record"));
        log.info("修改數(shù)據(jù)結(jié)果：{}", JSONUtil.toJsonStr(updateResponse));
        return ResponseEntity.ok(alarmRecord);
    }

    // 刪除警報(bào)記錄
    @DeleteMapping("/{id}")
    public ResponseEntity<Void> deleteAlarmRecord(@PathVariable Long id) {
        if (!alarmRecordRepository.existsById(id)) {
            return ResponseEntity.notFound().build();
        }
        alarmRecordRepository.deleteById(id);
        return ResponseEntity.noContent().build();
    }

    // 獲取所有警報(bào)記錄
    @GetMapping("/findByDeviceCode")
    public List<AlarmRecordEntity> findByDeviceCode(String deviceCode) {
        return  alarmRecordRepository.findAlarmRecordEntitiesByDeviceCodeEquals(deviceCode);
    }

package com.walker.es.repository;
import com.walker.es.entity.AlarmRecordEntity;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository
public interface AlarmRecordRepository extends ElasticsearchRepository<AlarmRecordEntity, Long> {
// 根據(jù)deviceCode=xx進(jìn)行查詢，不需要去重寫方法等，相對簡便
    List<AlarmRecordEntity> findAlarmRecordEntitiesByDeviceCodeEquals(String deviceCode);
}

@Data
public class AlarmSearchDTO {
//    注意，頁碼需要從0開始，否則會跳過
    private Integer pageIndex=0;
    private Integer pageSize=10;
    private String title;
    private String deviceCode;
    private String startTime;
    private String endTime;
}

 @PostMapping("/page")
    public PageVo<AlarmRecordEntity> getAlarmRecords(@RequestBody AlarmSearchDTO dto) {
     // 分頁類  將頁碼和頁數(shù)參數(shù)填入
        Pageable pageable = PageRequest.of(dto.getPageIndex(),dto.getPageSize());
        // 構(gòu)建查詢 在spring-data-elastic中有三種查詢方式，具體可以查看后面的查詢方式
        NativeSearchQueryBuilder  query = new NativeSearchQueryBuilder()
                .withPageable(pageable);
//        如果設(shè)備編碼非空
        if(StrUtil.isNotEmpty(dto.getDeviceCode())){
//            精確查詢 termQuery
            query.withQuery(QueryBuilders.termQuery("deviceCode",dto.getDeviceCode() ));
        }
        if(StrUtil.isNotEmpty(dto.getTitle())){
//            模糊查詢 fuzzyQuery   如果是要根據(jù)分詞拆分查詢的話，得使用matchQuery
            query.withQuery(QueryBuilders.fuzzyQuery("title",dto.getTitle() ));
        }
//        范圍查詢
        if (StrUtil.isNotEmpty(dto.getStartTime())) {
//            range范圍查詢需要keyword才能生效，如果使用text則會不生效
            query.withQuery(QueryBuilders.rangeQuery("time").gte(dto.getStartTime()).lte(dto.getEndTime()));
        }
        NativeSearchQuery searchQuery = query.build();
//        排序：根據(jù)id倒敘
        searchQuery.addSort(Sort.sort(AlarmRecordEntity.class).by(AlarmRecordEntity::getId).descending());
        // 執(zhí)行查詢
        SearchHits<AlarmRecordEntity> search = elasticsearchTemplate.search(searchQuery, AlarmRecordEntity.class);
        PageVo<AlarmRecordEntity> pageVo = new PageVo<>();
        if(search!=null){
            //設(shè)置總數(shù)
            pageVo.setTotal(search.getTotalHits());
            // 返回的行數(shù)
            List<SearchHit<AlarmRecordEntity>> searchHits = search.getSearchHits();
            if(CollUtil.isNotEmpty(searchHits)){
                ArrayList<AlarmRecordEntity> rows = new ArrayList<>();
                for (SearchHit<AlarmRecordEntity> searchHit : searchHits) {
                    AlarmRecordEntity content = searchHit.getContent();
                    rows.add(content);
                }
                pageVo.setList(rows);
            }
        }
        return pageVo;
    }

 CodeCriteriaQuery criteriaQuery = new CriteriaQuery();
criteriaQuery.addCriteria(Criteria.where("fieldName").is("value"));
List<MyEntity> results = elasticsearchOperations.queryForList(criteriaQuery, MyEntity.class);

CodeStringQuery stringQuery = new StringQuery("{\"match\":{\"fieldName\":\"value\"}}");
List<MyEntity> results = elasticsearchOperations.queryForList(stringQuery, MyEntity.class);

CodeNativeSearchQueryBuilder searchQueryBuilder = new NativeSearchQueryBuilder();
searchQueryBuilder.withQuery(QueryBuilders.matchQuery("fieldName", "value"));
NativeSearchQuery searchQuery = searchQueryBuilder.build();
List<MyEntity> results = elasticsearchOperations.queryForList(searchQuery, MyEntity.class);