分库分表-写
2023-06-08 13:54:17 0 举报AI智能生成
简单思维导图
作者其他创作
大纲/内容
流程
编写mybatis-interceptor
解析sql执行的type
拦截INSERT、UPDATE、DELETE
支持开关切换
按照分库规则，写sql执行在新的数据库
shutdown旧库至新库的flink-cdc任务
add新库到旧库flink-cdc任务
支持自定义日期同步
支持开关切换
服务
globalcenter-sso
编写mybatis拦截器，拦截sql，写入和修改删除类型的sql执行到新库
globalcenter-web
编写mybatis拦截器，拦截sql，写入和修改删除类型的sql执行到新库
globalcenter-rest
编写mybatis拦截器，拦截sql，写入和修改删除类型的sql执行到新库
globalcenter-dubbosvc
编写mybatis拦截器，拦截sql，写入和修改删除类型的sql执行到新库
flink-cdc
新库数据到旧库同步
异常
mybatis拦截器-写入到新库sql执行失败
打印异常信息，执行的sql输出到日志，后续可用于手动执行
flink-cdc新库同步到旧库任务写入失败
输出日志，排查和解决错误
可以根据日期重新回缩时间内数据进行重新同步
检查
新库总数检查
同步延迟时间检查，提取平均延迟时间、最大延迟时间
数据一致性检查
检查数据行日期信息、自增信息等是否和同步的数据一致
随机抽查部分数据是否和原数据一致
读业务梳理
梳理常用的读场景，观察切换到新库后读场景是否正常运行
计划
调研sharding-jdbc在globalcenter服务可行性
调用mybatis拦截器中动态替换数据源支持sharding-jdbc可行性
抽象mybatis拦截器，适用多个服务，支持开关
修改flink-cdc服务，适配旧到新/新到旧切换及开关支持
数据检查
0 条评论
下一页
