信息发布→ 登录 注册 退出

Mybatis实现分包定义数据库的原理与过程

发布时间:2026-01-11

点击量:
目录
  • 前言
  • 原理
    • 前提:
    • 猜想
  • 实现
    • 1:定义两个数据源
    • 2:定义两个SqlSessionFactory
    • 3:不同包实现绑定不同的sqlSessionFactory
    • 4:测试
    • 拓展:
  • 总结

    前言

    业务需求中需要连接两个数据库处理数据,需要用动态数据源。通过了解mybatis的框架,计划 使用分包的方式进行数据源的区分。

    原理

    前提:

    我们使用mybatis都会有四个步骤

    1:构建SqlSessionFactory

    2:通过SqlSessionFactory 获取到sqlSession 对象

    3:通过sqlSession对象获取Mapper的动态代理对象

    4:通过执行动态代理对象获取返回值

    其实点开sqlSessionFactory就的Configuration对象中的Environment对象绑定了我们的dataSource对象

    同样,我们通过debug发现,动态代理后的mapper对象是同样持有Configuration对象,绑定我们的连接信息。

    猜想

    需要分包实现不同数据源的话,需要对不同的mapper指定不同的sqlSessionFactroy,查看mapperScan的注解源码,

    通过理解注释,我们是可以指定maper动态代理对象的sqlSessionFactory对象的。然后结果basePackages就可以对不同的包使用不同的sqlSessionFactory从而实现不同包使用不同的数据源。

    实现

    1:定义两个数据源

    两个数据源分别命名位ds01,ds02,这里采用都是德鲁伊的数据库连接池。为了简介,详细配置没有展示了。

    2:定义两个SqlSessionFactory

    定义两个sqlSessionFactory,分别绑定两个数据源。

    3:不同包实现绑定不同的sqlSessionFactory

    通过@MapperScan指定扫描的包,通知指定SqlSessionFactory

    @MapperScan(basePackages = "com.lenven.demo.dao.ds02",sqlSessionFactoryRef = "salveSqlSessionFactory")
    @MapperScan(basePackages = "com.lenven.demo.dao.ds01",sqlSessionFactoryRef = "masterSqlSessionFactory")
    

    4:测试

    对两个不同的包的mapper测试,都可以正确查询出数据

    拓展:

    通过实现

    AbstractRoutingDataSource也可以实现动态数据源。

    该类实现DataSource的接口,可以配置对各数据源在

     @Nullable
        private Map<Object, DataSource> resolvedDataSources;
    

    这个属性里面。

    让后通过暴露一个determineCurrentLookupKey 获取需要使用的数据源的key。但是需要注意事务的问题。

    总结

    在线客服
    服务热线

    服务热线

    4008888355

    微信咨询
    二维码
    返回顶部
    ×二维码

    截屏,微信识别二维码

    打开微信

    微信号已复制,请打开微信添加咨询详情!