public interface CanalMap<T extends java.io.Serializable>
组织机构关系缓存接口
| 限定符和类型 | 接口和说明 |
|---|---|
static class |
CanalMap.Define
缓存定义
|
static class |
CanalMap.UpdateEntry<T extends java.io.Serializable>
缓存更新对象
|
static class |
CanalMap.UpdateEntryUnmodifiable<O extends java.io.Serializable>
不可变得对象
|
| 限定符和类型 | 方法和说明 |
|---|---|
default void |
add(java.util.List<T> data)
添加数据,实现类不需要实现
|
CanalMap.Define |
getCacheDefine()
缓存分类名称
|
default java.util.List<java.lang.String> |
interceptorMethods()
获取获取数据方法名【默认拦截get开头和find开头的方法】
|
java.lang.Object |
mergeLocalData(java.lang.Object result,
CanalMap.UpdateEntry<T> updateEntry,
java.lang.String methodName,
java.lang.Object[] args)
合并ThreadLocal,尚未提交的数据,存在当前线程事务还没提交,又要获取数据场景
|
void |
reloadAllData()
从数据库加载全量数据
|
default void |
remove(java.util.List<T> data)
删除数据,实现类不需要实现
|
void |
updateChange(CanalMap.UpdateEntry<T> updateEntry)
更新变更数据[缓存组织内部使用,应用不要调用]
|
CanalMap.Define getCacheDefine()
void reloadAllData()
void updateChange(CanalMap.UpdateEntry<T> updateEntry)
updateEntry - 变更数据java.lang.Object mergeLocalData(java.lang.Object result,
CanalMap.UpdateEntry<T> updateEntry,
java.lang.String methodName,
java.lang.Object[] args)
result - 返回的数据updateEntry - 需要合并的数据methodName - 方法args - 方法参数default void add(java.util.List<T> data)
data - 数据default void remove(java.util.List<T> data)
data - 数据default java.util.List<java.lang.String> interceptorMethods()