1.有关Sharding-JDBC
本文还是基于当当网Sharding-Jdbc的依赖
这里需要特殊介绍的是,使用Sharding-JDBC进行读写分离的时候,只允许设置一个主库,从库的话可以设置多个,访问策略的话从源码上看只有两种轮询(ROUND_ROBIN)和随机(RANDOM)。
源码代码如下:
2.本文场景
由于本地环境并没有使用Mysql主从复制,只是创建了三个库,其中database0作为主库,database1和database2作为从库。主库进行增删改操作,从库进行查询操作,如下图为本文数据库的三个表。
如上图分别是三个数据库中的user表,其中master-user为database0数据库中的user表,salve-user1为database1中的user表,salve-user2为database2中的user表。
3.代码实现
本文使用SpringBoot2.0.3,SpringData-JPA,Druid连接池,和当当的sharding-jdbc。
3.1 建表SQL
创建表和数据库的SQL如下所示,这里默认在从库内分别插入了一条数据,name值分别存放dalaoyang1和dalaoyang2便于区分。
3.2 依赖文件
新建项目,依赖文件还是当当的sharding-jdbc-core依赖和druid连接池,完整pom文件代码如下所示。
3.3 配置信息
在配置信息中配置了三个数据库的信息和JPA的简单配置。
3.4 启动类
上一篇文章说到在启动类加入了@EnableAutoConfiguration去除数据库自动配置,当时也没太注意,其实可以直接在@SpringBootApplication注解上去除数据库自动配置,剩下的和上一篇一样,使用@EnableTransactionManagement开启事务,使用@EnableConfigurationProperties注解加入配置实体,启动类完整代码如下所示。
3.5 实体类和数据库操作层
User实体类。
UserRepository类。
3.6 数据库参数类
数据库配置类,Database0Config。
数据库配置类,Database1Config。
数据库配置类,Database2Config。
3.7 读写分离配置
创建一个DataSourceConfig类来设置读写分离,这里其实也与分库分表类似,也可以在分库分表的基础上进行读写分离,需要创建一个Map集合来接收从库。在创建数据源时需要传入五个参数,分别是:
•name:数据源名称
•masterDataSourceName:主库数据源名称
•masterDataSource:主数据源
•slaveDataSourceMap:从数据源集合
•strategyType:访问策略 当然,也可以使用其他方法创建数据源,本文代码如下:
3.8 Controller Controller
做为测试类,创建两个方法,save方法和getAll方法,其中:
•save方法用于测试主库的插入和修改
•getAll方法用于测试读数据 UserController类如下所示。
4.测试
4.1 测试主库
使用postman访问,控制台如图所示。
再次访问,如图。
主键冲突了,其实这是由于插入的时候使用的database0,但是查询使用的是database1和database2,但是我在从库内并没有ID是100的数据,所以JPA判定我为插入,但是数据库内缺有这样的数据。 我们接下来测试一下查询。访问
再次访问,如图。
证明从库的读取是正常的,接下来修改从库的ID为100。然后访问,查看控制台如图。
因为存在了ID为100的数据,所以SQL为修改语句。
5.源码
源码地址:https://gitee.com/dalaoyang/springboot_learn/tree/master/springboot2_shardingjdbc_dxfl