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()