elasticsearch

/**
 * @author zhouchj
 * @date 2023/7/18
 */
@Data
@Document(indexName = "test-document-item")
public class Item implements Serializable {

    /**
     * id
     */
    @Id
    @Field(name = "title", type = FieldType.Keyword)
    private Long id;

    /**
     * 标题
     */
    @Field(name = "title", type = FieldType.Keyword)
    private String title;

    /**
     * 分类
     */
    @Field(name = "category", type = FieldType.Keyword)
    private String category;

    /**
     * 品牌
     */
    @Field(name = "brand", type = FieldType.Keyword)
    private String brand;

    /**
     * 价格
     */
    @Field(name = "price", type = FieldType.Double)
    private Double price;

    /**
     * 图片地址
     */
    @Field(name = "images", type = FieldType.Keyword)
    private String images;

    /**
     * 更新时间
     */
    @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
    @Field(name = "update_time", type = FieldType.Date)
    private Date updateTime = new Date();

}

    QueryPageEntity<Item> page = esToolkitFactory.lambdaQuery(Item.class)
                .term(Item::getId, Arrays.asList(1, 2))
                .agg(Item::getPrice)
                .withSort(Sort.Direction.DESC, Item::getPrice)
                .withPage(new PageForm())
                .page();

Item item = new Item();
item.setId(2L);
item.setTitle("怡宝");
item.setCategory("矿泉水");
item.setBrand("农夫山泉饮料有限公司");
item.setPrice(2.0D);
item.setImages("假装这个是个图片");
item.setUpdateTime(new Date());

esToolkitFactory.lambdaUpdate(Item.class)
    .save(item);

esToolkitFactory.lambdaUpdate(Item.class)
                .term(Item::getId, 2)
                .set(Item::getTitle, "大宝")
                .update();

// 按照id删除
esToolkitFactory.lambdaUpdate(Item.class)
                .id(1L)
                .id(2L)
                .delete();

//按照查询删除
esToolkitFactory.lambdaUpdate(Item.class)
                .term(Item::getPrice,2)
                .delete();

// 创建索引
esToolkitFactory.indexOperate(Item.class)
                .createIndexIfExists();
// 删除索引
esToolkitFactory.indexOperate(Item.class)
                .deleteIndex();

// 创建新索引
EsIndexOperate<ItemNew> newIndexOperate=esToolkitFactory.indexOperate("test-document-item-v1",ItemNew.class);
newIndexOperate.createIfExists();

// 查询老索引中的数据
List<Item> list=esToolkitFactory.lambdaQuery("test-document-item",Item.class)
    .list();

// 老索引数据实体转换成新索引数据实体
List<ItemNew> newList=list.stream().map(r->{
    ItemNew itemNew=new ItemNew();
    itemNew.setId(r.getId());
    itemNew.setTitle(r.getTitle());
    itemNew.setCategory(r.getCategory());
    itemNew.setBrand(r.getBrand());
    itemNew.setPrice(r.getPrice());
    itemNew.setImages(r.getImages());
    itemNew.setUpdateTime(r.getUpdateTime());
    return itemNew;
}).collect(Collectors.toList());

// 保存数据到新索引
esToolkitFactory.lambdaUpdate("test-document-item-v1",ItemNew.class)
    .saveBatch(newList);

// 删除老索引
esToolkitFactory.indexOperate("test-document-item",Item.class)
    .deleteIndex();

// 新索引别名设置为老索引名称
newIndexOperate.addAlias("test-document-item");

/**
 * @author zhouchj
 * @date 2023/9/4
 */
@Service
public class ItemServiceImpl extends EsServiceImpl<Item> implements ItemService {

    @Override
    public List<Item> list() {
        return this.lambdaQuery()
                .list();
    }
}

/**
 * @author zhouchj
 * @date 2023/9/4
 */
@Service
public class ItemServiceImpl extends EsServiceImpl<Item> implements ItemService {

    public ItemServiceImpl() {
        index("test-document-item");
    }

    @Override
    public List<Item> list() {
        return this.lambdaQuery()
                .list();
    }
}

/**
 * @author zhouchj
 * @date 2023/9/4
 */
@Service
public class ItemServiceImpl extends EsServiceImpl<Item> implements ItemService {


    @Override
    public List<Item> list() {
        return this.lambdaQuery(getIndexName())
                .list();
    }

    private String getIndexName() {
        return "test-document-item-" + 1L;
    }
}