前言
此博文是学习吕一明老师《90天Java进阶训练营二期》的笔记总结，接上一篇博文。我们接着来介绍和分析MyBatis
本次分析中涉及到的代码和数据库表均放在GitHub上，地址：源码地址
目录
本篇博文将按照如下顺序来介绍MyBatis的相关知识。
- MyBatis 如何获取数据库中的表、字段
- MyBatis 的多数据源处理
- MyBatis 的读写分离
- MyBatis plus的简单运用
MyBatis如何获取数据库中的表、字段
原理
information_schema数据库是MySQL自带的，它提供了访问数据库元数据的方式。什么是元数据呢？元数据是关于数据的数据，如数据库名或表名，列的数据类型，或访问权限等。有些时候用于表述该信息的其他术语包括“数据词典”和“系统目录”。
在MySQL中，把 information_schema 看作是一个数据库，确切说是信息数据库。其中保存着关于MySQL服务器所维护的所有其他数据库的信息。如数据库名，数据库的表，表栏的数据类型与访问权 限等。在INFORMATION_SCHEMA中，有数个只读表。它们实际上是视图，而不是基本表，因此，你将无法看到与之相关的任何文件。
information_schema表说明
SCHEMATA表：提供了当前mysql实例中所有数据库的信息。是show databases的结果取之此表。
TABLES表：提供了关于数据库中的表的信息（包括视图）。详细表述了某个表属于哪个schema，表类型，表引擎，创建时间等信息。是show tables from schemaname的结果取之此表。
COLUMNS表：提供了表中的列信息。详细表述了某张表的所有列以及每个列的信息。是show columns from schemaname.tablename的结果取之此表。
STATISTICS表：提供了关于表索引的信息。是show index from schemaname.tablename的结果取之此表。
USER_PRIVILEGES（用户权限）表：给出了关于全程权限的信息。该信息源自mysql.user授权表。是非标准表。
SCHEMA_PRIVILEGES（方案权限）表：给出了关于方案（数据库）权限的信息。该信息来自mysql.db授权表。是非标准表。
TABLE_PRIVILEGES（表权限）表：给出了关于表权限的信息。该信息源自mysql.tables_priv授权表。是非标准表。
COLUMN_PRIVILEGES（列权限）表：给出了关于列权限的信息。该信息源自mysql.columns_priv授权表。是非标准表。
CHARACTER_SETS（字符集）表：提供了mysql实例可用字符集的信息。是SHOW CHARACTER SET结果集取之此表。
COLLATIONS表：提供了关于各字符集的对照信息。
COLLATION_CHARACTER_SET_APPLICABILITY表：指明了可用于校对的字符集。这些列等效于SHOW COLLATION的前两个显示字段。
TABLE_CONSTRAINTS表：描述了存在约束的表。以及表的约束类型。
KEY_COLUMN_USAGE表：描述了具有约束的键列。
ROUTINES表：提供了关于存储子程序（存储程序和函数）的信息。此时，ROUTINES表不包含自定义函数（UDF）。名为“mysql.proc name”的列指明了对应于INFORMATION_SCHEMA.ROUTINES表的mysql.proc表列。
VIEWS表：给出了关于数据库中的视图的信息。需要有show views权限，否则无法查看视图信息。
TRIGGERS表：提供了关于触发程序的信息。必须有super权限才能查看该表
查找当前数据库的表信息：
第一种方法：
select * from information_schema.TABLES where TABLE_SCHEMA=(select database())
第二种方法：
#获取表信息 show table status
查找当前表的所有字段信息：
第一种方法：
select * from information_schema.COLUMNS where TABLE_SCHEMA = (select database()) and TABLE_NAME=#{tableName}
第二种方式
show full fields from `student`;
MyBatis 的多数据源处理
单独使用MyBatis ，只需要在xml文件中配置多个environment,生产SqlSessionFactory的时候指定environment即可实现多数据源。
<!-- 设置一个默认的连接环境信息 --> <environments default="development"> <!--连接环境信息，取一个任意唯一的名字 --> <environment id="development"> <!-- mybatis使用jdbc事务管理方式 --> <transactionManager type="JDBC"/> <!-- mybatis使用连接池方式来获取连接 --> <dataSource type="POOLED"> <!-- 配置与数据库交互的4个必要属性 --> <property name="driver" value="${jdbc.driver}"/> <property name="url" value="${jdbc.url}"/> <property name="username" value="${jdbc.username}"/> <property name="password" value="${jdbc.password}"/> </dataSource> </environment> <environment id="development2"> <transactionManager type="JDBC"/> <dataSource type="POOLED"> <property name="driver" value="${jdbc.driver}"/> <property name="url" value="${jdbc.url2}"/> <property name="username" value="${jdbc.username2}"/> <property name="password" value="${jdbc.password2}"/> </dataSource> </environment> </environments>
集成Spring的多数据源处理
1.通过扫描包区分
参考源码：
项目结构：
关键代码如下：
@Configuration //扫描包 @MapperScan(basePackages = "com.neo.mapper.test1", sqlSessionTemplateRef = "test1SqlSessionTemplate") public class DataSource1Config { @Bean(name = "test1DataSource") // 注入数据源 @ConfigurationProperties(prefix = "spring.datasource.test1") @Primary public DataSource testDataSource() { return DataSourceBuilder.create().build(); } // 创建SqlSessionFactory @Bean(name = "test1SqlSessionFactory") @Primary public SqlSessionFactory testSqlSessionFactory(@Qualifier("test1DataSource") DataSource dataSource) throws Exception { SqlSessionFactoryBean bean = new SqlSessionFactoryBean(); bean.setDataSource(dataSource); bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mybatis/mapper/test1/*.xml")); return bean.getObject(); } // 事务的初始化 @Bean(name = "test1TransactionManager") @Primary public DataSourceTransactionManager testTransactionManager(@Qualifier("test1DataSource") DataSource dataSource) { return new DataSourceTransactionManager(dataSource); } @Bean(name = "test1SqlSessionTemplate") @Primary public SqlSessionTemplate testSqlSessionTemplate(@Qualifier("test1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception { return new SqlSessionTemplate(sqlSessionFactory); } }
2.通过动态数据源区分
MyBatis 的读写分离
原理跟多数据源类似，MyBatis做读写分离的方式有多种，通过拦截发起请求的方法或执行的sql来自动判断需要的数据源!
1.拦截发起操作的方法名
需要自己约定增删改查的前缀，然后根据前缀选择数据源！
git demo： https://github.com/XWxiaowei/90-Java-demo-2/tree/master/course-3-mybatis/bounterMybatis
spring-mybatis.xml 中的配置配置了主库和从库（主写从读），在配置文件中配置默认的数据源是masterDataSource。
<!-- Master数据源 --> <bean id="masterDataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"> .... </bean> <!-- Slave数据源 --> <bean id="slaveDataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"> ... </bean> <!-- 自定义动态数据源 --> <bean id="dataSource" class="com.bounter.mybatis.extension.DynamicDataSource"> <property name="targetDataSources"> <map key-type="java.lang.String"> <!-- 配置读写数据源 --> <entry value-ref="masterDataSource" key="write"></entry> <entry value-ref="slaveDataSource" key="read"></entry> </map> </property> <property name="defaultTargetDataSource" ref="masterDataSource"></property> </bean>
代码解释：
首先定义了一个方法名的拦截器DataSourceAspect，在方法执行之前获取方法名，然后跟定义的方法清单（读库的）比较，如果方法名的前缀再方法清单中，则将数据源的key切换成读库的key。该key放在了DynamicDataSourceHolder类中的内部对象ThreadLocal中。保证了线程安全。
@Component @Aspect @EnableAspectJAutoProxy(proxyTargetClass = true) public class DataSourceAspect { //读库数据源key private static final String DATASOURCE_KEY_READ = "read"; //查询方法清单 String[] queryMethods = {"find","get","query","count","select"}; /** * dao层方法执行前选择数据源 * @param point */ @Before("execution(* com.bounter.mybatis.dao..*.*(..))") public void before(JoinPoint point) { // 获取到当前执行的方法名 String methodName = point.getSignature().getName(); //匹配查询方法 for(String queryMethod : queryMethods) { if(methodName.startsWith(queryMethod)) { //查询方法设置数据源为读库 DynamicDataSourceHolder.setDataSource(DATASOURCE_KEY_READ); System.out.println("methodName-->" + methodName + " 当前数据库-->" + DATASOURCE_KEY_READ.toString()); break; } } } /** * dao层方法执行完后清空数据源选择 * @param point */ @After("execution(* com.bounter.mybatis.dao..*.*(..))") public void after(JoinPoint point) { DynamicDataSourceHolder.clearDataSource(); } }
设置数据源的key
private static final ThreadLocal<String> dataSourceHolder = new ThreadLocal<>(); public static void setDataSource(String dataSourceKey) { dataSourceHolder.set(dataSourceKey); }
然后，就是调用到AbstractRoutingDataSource类的getConnection方法获取Connection对象。
public Connection getConnection() throws SQLException { return this.determineTargetDataSource().getConnection(); }
在getConnection() 方法内部首先调用determineTargetDataSource()获取DataSource（数据源）。
protected DataSource determineTargetDataSource() { Assert.notNull(this.resolvedDataSources, "DataSource router not initialized"); Object lookupKey = this.determineCurrentLookupKey(); DataSource dataSource = (DataSource)this.resolvedDataSources.get(lookupKey); if (dataSource == null && (this.lenientFallback || lookupKey == null)) { dataSource = this.resolvedDefaultDataSource; } if (dataSource == null) { throw new IllegalStateException("Cannot determine target DataSource for lookup key [" + lookupKey + "]"); } else { return dataSource; }
而数据源的获取则是根据子类实现determineCurrentLookupKey()方法返回的key来对应取。
public class DynamicDataSource extends AbstractRoutingDataSource { @Override protected Object determineCurrentLookupKey() { //使用DynamicDataSourceHolder保证线程安全 return DynamicDataSourceHolder.getDataSource(); }
2.截发起操作的sql
git demo:https://github.com/shawntime/shawn-rwdb
MyBatis plus的简单运用
MyBatis plus官网地址
