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