文档章节

SpringCloud集成 Mybatis分表插件shardbatis 踩坑日志及其原理分析

L墨龙
 L墨龙
发布于 01/22 20:21
字数 693
阅读 40
收藏 4

公司新开发的系统数据量过大,需要进行分表处理,我在网上浏览一圈,选中了Shardbatis,原因有二:

1.公司项目本身集成了Mybatis,而Shardbatis是其插件,引入方便;

2.Sharbatis十分轻便,只要稍微配置一下即可使用;

如何引入,百度一大堆,这里不再赘述,下面分析一下其原理:

Shardbatis说白了就是一个interceptor(拦截器),它的原理跟Mybatis的分页插件(PageHelper)差不多,PageHelper其实也是依赖interceptor(拦截器)进行拦截将要发送到数据库执行的sql,做进一步处理的插件。

研究源码可以看到,PageHelper实现了Interceptor(拦截器)接口:


@Intercepts({@Signature(
    type = Executor.class,
    method = "query",
    args = {MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class}
)})
public class PageHelper implements Interceptor {
    private SqlUtil sqlUtil;
    private Properties properties;
    private SqlUtilConfig sqlUtilConfig;
    private boolean autoDialect = true;
    private boolean autoRuntimeDialect;
    private boolean closeConn = true;
    private Map<String, SqlUtil> urlSqlUtilMap = new ConcurrentHashMap();

    public PageHelper() {
    }
...省略

Shardbatis也实现了Interceptor(拦截器)接口:

@Intercepts({@Signature(
        type = StatementHandler.class,
        method = "prepare",
        args = {Connection.class}
)})
public class ShardPlugin implements Interceptor {
    private static final Log log = LogFactory.getLog(com.google.code.shardbatis.plugin.ShardPlugin.class);
    public static final String SHARDING_CONFIG = "shardingConfig";
    private static final ConcurrentHashMap<String, Boolean> cache = new ConcurrentHashMap();

    public ShardPlugin() {
    }
...省略

我们在初始化SqlSessionFactory的时候,可以配置对应的拦截器,代码如下:

    @Bean
    public SqlSessionFactoryBean sqlSessionFactoryBean(DataSource dataSource) {
        SqlSessionFactoryBean bean = MybatisKit.newMybatisSessionFactory(dataSource, this.mybatisProperties);
        //初始化分表插件
        ShardPlugin shardPlugin = new ShardPlugin();
        //..省略
        
        //初始化分页插件
        PageHelper pageHelper = new PageHelper();
        //..省略 
        

        //根据自己需要拦截的顺序,组装数组
        Interceptor[] plugins = new Interceptor[]{shardPlugin,pageHelper};
        //将插件引入SqlSessionFactory
        bean.setPlugins(plugins);
        return bean;
    }

这样,就可以拦截Mybatis即将执行的Sql做进一步处理。

接下来,来分享一下,我集成Shardbatis时踩到的坑:

我依赖的是Shardbatis版本如下:

<dependency>
    <groupId>org.shardbatis</groupId>
    <artifactId>shardbatis</artifactId>
    <version>2.0.0B</version>
</dependency>

当运行的时候报了如下错误:

这个错误让我重复检查了代码N次,以及调试了N次仍然没找到错误。在网上疯狂百度搜索,最后在官网issue看到这个:

然后我翻一下我集成的ShardBatis插件源码,发现:

这确实够坑的,没办法,使用开源的东西,就得踩它的坑。最后,我重写了ShardPlugin类,加上Integer.class ,完美解决问题:如下:

@Intercepts({@Signature(
        type = StatementHandler.class,
        method = "prepare",
        args = {Connection.class,Integer.class}
)})
public class ShardPlugin implements Interceptor {
    private static final Log log = LogFactory.getLog(com.google.code.shardbatis.plugin.ShardPlugin.class);
    public static final String SHARDING_CONFIG = "shardingConfig";
    private static final ConcurrentHashMap<String, Boolean> cache = new ConcurrentHashMap();

    public ShardPlugin() {
    }
...省略

好了,本博客分享到此结束,谢谢。

© 著作权归作者所有

共有 人打赏支持
L墨龙
粉丝 7
博文 44
码字总数 17069
作品 0
广州
私信 提问
SpringBlade 2.0 正式版发布,集成Nacos与Sentinel

大家新年好!经过一个半月的持续迭代,SpringBlade2.0的正式版终于发布了,同时全新官网上线。下面我们来看一下正式版有哪些惊喜。 SpringBlade简介: SpringBlade 2.0 是一个基于 Spring B...

smallchill
02/10
0
0
2、为什么是SpringCloud?

我很想明白为什么微服务架构会选择SpringCloud,为啥就是它? 在网上逛了一圈之后总结下: 一、SpringCloud是有Spring社区做支持的,所以这个社区的活跃度和质量完全可以保证SpringCloud在微...

小钢钉
2018/11/13
0
0
Spring Blade 2.0 双版齐发,基于 AVue 的前端以及单工程版发布

SpringBlade 2.0 正式版发布后,大家对于 vue 版本的前端和 springboot 单工程版本呼声较高,所以榨干了自己的时间刚了两个版本出来!下面我们来看一下详细更新内容。 简介: SpringBlade 是...

smallchill
今天
0
0
迁移微服务框架-SpringCloud-事后总结

什么是微服务? 什么是 springcloud? 引用维基百科: 微服务是一种架构风格,一个大型复杂软件应用由一个或多个微服务组成。系统中的各个微服务可被独立部署,各个微服务之间是松耦合的。每个微...

我是你大哥
2018/09/10
0
0
SpringCloud服务的平滑上下线

吐槽: 以前都是手撸RPC,最近接触 SpringCloud ,深感痛心。主要有以下几点: 1)代码量巨大,找BUG时间长,超级复杂的设计 2)版本管理混乱,经常出现莫名其妙的配置错误(所以2.0是打死不...

Java干货分享
2018/09/29
0
0

没有更多内容

加载失败,请刷新页面

加载更多

“好”接口的设计与实现

一、好接口的特性 易读 易用,难于误用 功能独立 容易扩展 二、好接口设计的基本原则 只做并做好一件事 函数名自解释 不恰当的函数名,往往是不恰当设计的征兆 如果没做到上一点,就将函数分...

mskk
17分钟前
0
0
zabbix安装配置

环境 系统:centos7.5软件版本: mysql: 5.7 zabbix: 3.4.15内网: Port: 10051 IP: 192.168.2.71外网: Port: 34521 Domain: freefrp.cnAgent被动模式(默认) ...

亦漩
35分钟前
2
0
一看就能学会的H5视频推流方案

本文由云+社区发表 作者:周超 导语 随着直播平台爆发式增长,直播平台从 PC 端转战移动端,紧跟着直播的潮流,自己学习实现了一套简单的 H5 视频推流的解决方案,下面就给小伙伴们分享一下自...

腾讯云加社区
38分钟前
3
0
Spring Boot 2.X优雅停止

本文章介绍了正常关闭Spring Boot 应用程序的过程。许多开发人员和架构师总是讨论SpringBoot的应用设计、流量负载、框架和应用模式,但很少有人讨论关闭阶段。生命周期意识可以说一个真正资深...

WUBAOQUAN
48分钟前
4
0
Linux Redis 高可用之主从复制

Redis主从复制简介 和MySQL主从复制的原因一样,Redis虽然读取写入的速度都特别快,但是也会产生读压力特别大的情况。为了分担读压力,Redis支持主从复制,Redis的主从结构可以采用一主多从或...

我最喜欢三大框架
55分钟前
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部