public interface EntityCanalMap<T extends java.io.Serializable>
限定符和类型 | 接口和说明 |
---|---|
static class |
EntityCanalMap.ActionHolder<T extends java.io.Serializable>
动作事件包装
|
static class |
EntityCanalMap.ActionType
操作动作
|
static class |
EntityCanalMap.UpdateEntry<T extends java.io.Serializable>
缓存更新对象
|
限定符和类型 | 方法和说明 |
---|---|
default void |
add(T data)
添加数据,实现类不需要实现
|
default void |
addAll(java.util.List<T> datas)
批量添加数据,实现类不需要实现
|
CanalMap.Define |
getCacheDefine()
缓存分类名称
|
default java.util.List<java.lang.String> |
interceptorMethods()
获取获取数据方法名【默认拦截get开头和find开头的方法】
|
java.lang.Object |
mergeLocalData(java.lang.Object result,
java.util.List<EntityCanalMap.ActionHolder<T>> updateEntry,
java.lang.String methodName,
java.lang.Object[] args)
合并ThreadLocal,尚未提交的数据,存在当前线程事务还没提交,又要获取数据场景
|
void |
reloadAllData()
从数据库加载全量数据
|
default void |
remove(T data)
删除数据,实现类不需要实现
|
default void |
removeAll(java.util.List<T> datas)
删除全部数据
|
default void |
update(T newObj,
T oldObj)
删除数据,实现类不需要实现
|
default void |
updateAll(java.util.List<org.apache.commons.lang3.tuple.MutablePair<T,T>> updatas)
需要更新的数据
|
void |
updateChange(java.util.List<EntityCanalMap.ActionHolder<T>> updateEntry)
更新变更数据[缓存组织内部使用,应用不要调用]
|
CanalMap.Define getCacheDefine()
void reloadAllData()
void updateChange(java.util.List<EntityCanalMap.ActionHolder<T>> updateEntry)
updateEntry
- 变更数据java.lang.Object mergeLocalData(java.lang.Object result, java.util.List<EntityCanalMap.ActionHolder<T>> updateEntry, java.lang.String methodName, java.lang.Object[] args)
result
- 返回的数据updateEntry
- 需要合并的数据methodName
- 方法args
- 方法参数default void add(T data)
data
- 数据default void addAll(java.util.List<T> datas)
datas
- 数据default void remove(T data)
data
- 数据default void removeAll(java.util.List<T> datas)
datas
- 删除多条数据default void update(T newObj, T oldObj)
newObj
- 新数据oldObj
- 旧数据default void updateAll(java.util.List<org.apache.commons.lang3.tuple.MutablePair<T,T>> updatas)
updatas
- 需要更新的数据,MutablePair对应的是新数据、旧数据default java.util.List<java.lang.String> interceptorMethods()