首页 > 代码库 > TSharding源码阅读

TSharding源码阅读

1 读取解析数据库配置文件

DataSourceScanner实现了Spring的BeanDefinitionRegistryPostProcessor和ApplicationContextAware接口。

BeanDefinitionRegistryPostProcessor 允许定义bean

ApplicationContextAware 可以获取Spring上下文。

代码流程:getDataSources解析读取数据库配置文件,registerDataSources 生成DataSourceFactoryBean(名字格式trade0005SlaveDataSource)并注入到SpringBean工厂。继续遍历解析数据源,封装成Map<String, ReadWriteSplittingDataSource> ,如果有可写数据源则创建事务管理器(名字格式trade0005TransactionManager),注册到SpringBean工厂。如果可写数据源不存在,注册一个空transactionManager。如果只有一个可写数据源,则添加别名,兼容默认情况。解析完数据源后,向Spring注册dataSourceLookup,其实就是把数据源map保存起来。

2 MapperScannerWithSharding 

  Tsharding MybatisMapper的扫描类,负责将Mapper接口与对应的xml配置文件整合,绑定设定的数据源,注入到Spring Context中。

  实现了BeanFactoryPostProcessor, InitializingBean 接口  。BeanFactoryPostProcessor可以修改BEAN的配置信息

  代码流程:

      获取1步中注册的dataSourceLookup。

    initSqlSessionFactories。第一次SqlSessionFactoryBean.setMapperLocations.setDataSource.setTypeAliasesPackage(mapper位置,数据源,实体类),实例化SqlSessionFactoryBean,单例注册到bean工厂(名字格式为trade0001)。后续,从第一次的sessionFactoryBean.getObject()获取一个SqlSessionFactory

TSharding源码阅读