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

spring:
  application:
    name: cloud-elasticsearch
  elasticsearch:
    uris: http://127.0.0.1:9200 #  這里還要注意是https還是http協(xié)議
#    username: elastic #如果有賬號(hào)密碼就要配置賬號(hào)密碼，否則可以不配置
#    password: 123456
server:
  port: 20000

@Data
@Document(indexName = "news")
public class EsNews {
    @Id
    private String id;
    @Field(type = FieldType.Text, analyzer = "ik_max_word",searchAnalyzer = "ik_smart")
    private String title;//標(biāo)題
    @Field(type = FieldType.Text, analyzer = "ik_max_word",searchAnalyzer = "ik_smart")
    private String content;//內(nèi)容
    @Field(type = FieldType.Keyword)
    private String author;//作者
    @Field(type = FieldType.Keyword)
    private List<String> tags;//標(biāo)簽
    @Field(type = FieldType.Date,pattern = "yyyy-MM-dd HH:mm:ss||yyyy-MM-dd")
    @JsonProperty("publish_date")
    private Date publishDate;//發(fā)布時(shí)間
    @Field(type = FieldType.Date,pattern = "yyyy-MM-dd HH:mm:ss||yyyy-MM-dd")
    @JsonProperty("create_time")
    private Date createTime;//創(chuàng)建時(shí)間
    @Field(type = FieldType.Long)
    @JsonProperty("view_count")
    private Long viewCount;//閱讀量
}

public interface EsNewsRepository extends ElasticsearchRepository<EsNews,String> {
}

    @Test
    @DisplayName("新增單個(gè)文檔")
    void saveDoc(){
        EsNews news = new EsNews();
        news.setId("1");//如果不設(shè)置ID,Spring則會(huì)幫你生成一個(gè)ES風(fēng)格的隨機(jī)ID
        news.setTitle("電影《不能說(shuō)的秘密》熱映");
        news.setContent("內(nèi)容：不能說(shuō)的秘密............牛X..");
        news.setAuthor("周杰倫");
        news.setTags(Arrays.asList("電影", "國(guó)產(chǎn)"));
        news.setPublishDate(new Date());
        news.setCreateTime(new Date());
        news.setViewCount(100L);
        esNewsRepository.save(news);
    }

    @Test
    @DisplayName("批量新增文檔")
    void saveBatchDoc(){
        List<EsNews> newsList = new ArrayList<>();
        for (int i = 1; i <= 11; i++) {
            EsNews news = new EsNews();
            news.setId(String.valueOf(i));
            news.setTitle("電影《CPW的奇幻世界 " + i + "》");
            news.setContent("內(nèi)容 " + i);
            news.setAuthor("作者" + i);
            news.setTags(Arrays.asList("電影", "奇幻"));
            news.setPublishDate(new Date());
            news.setCreateTime(new Date());
            news.setViewCount(100L + i);
            newsList.add(news);
        }
        esNewsRepository.saveAll(newsList);
    }

    @Test
    @DisplayName("新增單個(gè)文檔")
    void saveDoc(){
        EsNews news = new EsNews();
        news.setId("1");//ES會(huì)先找文檔庫(kù)里是否存在改ID，先刪除再覆蓋
        news.setTitle("電影《不能說(shuō)的秘密》熱映");
        news.setContent("內(nèi)容：不能說(shuō)的秘密........牛X..更新覆蓋操作");
        news.setAuthor("周杰倫");
        news.setTags(Arrays.asList("電影", "國(guó)產(chǎn)"));
        news.setPublishDate(new Date());
        news.setCreateTime(new Date());
        news.setViewCount(100L);
        esNewsRepository.save(news);
    }

    @Test
    @DisplayName("根據(jù)ID查詢文檔")
    void searchByID(){
        Optional<EsNews> news = esNewsRepository.findById("999");
        System.out.println(news);
    }

public interface EsNewsRepository extends ElasticsearchRepository<EsNews,String> {
    Page<EsNews> findByTitleContainingOrAuthor(String Title, String Author,Pageable pageable);
}

    @Test
    @DisplayName("分頁(yè)查詢條件")
    void searchAll(){
        Pageable pageable = PageRequest.of(0, 10);
        Page<EsNews> pageList = esNewsRepository.findByTitleContainingOrAuthor("奇幻世界","作者1",pageable);
        for (EsNews news : pageList) {
            System.out.println(news);
        }
    }

    @Test
    @DisplayName("根據(jù)ID刪除文檔")
    void deleteDocById(){
        esNewsRepository.deleteById("1");
        System.out.println("ID為1的文檔刪除成功");
    }
    @Test
    @DisplayName("批量刪除文檔")
    void deleteBatchDoc(){
        esNewsRepository.deleteAll();
        System.out.println("文檔批量刪除成功");
    }
    @Test
    @DisplayName("根據(jù)ID批量刪除文檔")
    void deleteBatchDocByIds(){
        List<String> idList = Arrays.asList("1", "2");
        esNewsRepository.deleteAllById(idList);
        System.out.println("根據(jù)ID批量刪除文檔刪除成功");
    }