CqEngine添加联合索引和复合唯一索引

一.实体类

@Data
public class CategoryT {private Integer id;private String oneCategory;private String twoCategory;private String createTime;private String updateTime;public String uniKey() {return oneCategory + "/" + twoCategory;}
}

二.集合

@SuppressWarnings("unchecked")
@NoArgsConstructor(access = AccessLevel.PRIVATE)
public class CategoryDb {private static final IndexedCollection<CategoryT> CACHE;static {//堆内持久化CACHE = new TransactionalIndexedCollection<>(CategoryT.class);//添加索引CACHE.addIndex(UniqueIndex.onAttribute(Index.ID));CACHE.addIndex(HashIndex.onAttribute(Index.ONE_CATEGORY));CACHE.addIndex(HashIndex.onAttribute(Index.TWO_CATEGORY));//联合索引CACHE.addIndex(CompoundIndex.onAttributes(Index.ONE_CATEGORY, Index.TWO_CATEGORY));//复合唯一索引CACHE.addIndex(CompoundIndex.onAttributes(Index.ONE_CATEGORY, Index.TWO_CATEGORY));}private static final class Index {//创建属性的访问者对象private static final Attribute<CategoryT, Integer> ID = QueryFactory.attribute("ID", CategoryT::getId);private static final Attribute<CategoryT, String> ONE_CATEGORY = QueryFactory.attribute("ONE_CATEGORY", CategoryT::getOneCategory);private static final Attribute<CategoryT, String> TWO_CATEGORY = QueryFactory.attribute("TWO_CATEGORY", CategoryT::getTwoCategory);private static final Attribute<CategoryT, String> UNI_KEY = QueryFactory.attribute("UNI_KEY", CategoryT::uniKey);private static final Attribute<CategoryT, String> CREATE_TIME = QueryFactory.attribute("CREATE_TIME", CategoryT::getCreateTime);private static final Attribute<CategoryT, String> UPDATE_TIME = QueryFactory.attribute("UPDATE_TIME", CategoryT::getUpdateTime);}
}