分库分表(4) ---SpringBoot + ShardingSphere 实现分表
分库分表(4)--- ShardingSphere实现分表
有关分库分表前面写了三篇博客:
1、 分库分表(1) --- 理论
2、 分库分表(2) --- ShardingSphere(理论)
3、 分库分表(3) ---SpringBoot + ShardingSphere实现读写分离
这篇博客通过ShardingSphere 实现分表不分库 ，并在文章最下方附上项目 Github地址 。
一、项目概述
1、技术架构
项目总体技术选型
SpringBoot2.0.6 + shardingsphere4.0.0-RC1 + Maven3.5.4 + MySQL + lombok(插件)
2、项目说明
场景 在实际开发中，如果表的数据过大，我们可能需要把一张表拆分成多张表，这里就是通过ShardingSphere实现分表功能，但不分库。
3、数据库设计
这里有个member库，里面的 tab_user 表由一张拆分成3张，分别是 tab_user0 、 tab_user1 、 tab_user2 。
如图
具体的创建表SQL也会放到GitHub项目里
二、核心代码
说明 完整的代码会放到GitHub上，这里只放一些核心代码。
1、application.properties
server.port=8086
#指定mybatis信息
mybatis.config-location=classpath:mybatis-config.xml
spring.shardingsphere.datasource.names=master
# 数据源 主库
spring.shardingsphere.datasource.master.type=com.alibaba.druid.pool.DruidDataSource
spring.shardingsphere.datasource.master.driver-class-name=com.mysql.jdbc.Driver
spring.shardingsphere.datasource.master.url=jdbc:mysql://localhost:3306/member?characterEncoding=utf-8
spring.shardingsphere.datasource.master.username=root
spring.shardingsphere.datasource.master.password=123456
#数据分表规则
#指定所需分的表
spring.shardingsphere.sharding.tables.tab_user.actual-data-nodes=master.tab_user$->{0..2}
#指定主键
spring.shardingsphere.sharding.tables.tab_user.table-strategy.inline.sharding-column=id
#分表规则为主键除以3取模
spring.shardingsphere.sharding.tables.tab_user.table-strategy.inline.algorithm-expression=tab_user$->{id % 3}
#打印sql
spring.shardingsphere.props.sql.show=true
Sharding-JDBC可以通过 Java ， YAML ， Spring命名空间 和 Spring Boot Starter 四种方式配置，开发者可根据场景选择适合的配置方式。具体可以看官网。
2、UserController
@RestController
public class UserController {
@Autowired
private UserService userService;
/**
* 模拟插入数据
*/
List<User> userList = Lists.newArrayList();
/**
* 初始化插入数据
*/
@PostConstruct
private void getData() {
userList.add(new User(1L,"小小", "女", 3));
userList.add(new User(2L,"爸爸", "男", 30));
userList.add(new User(3L,"妈妈", "女", 28));
userList.add(new User(4L,"爷爷", "男", 64));
userList.add(new User(5L,"奶奶", "女", 62));
}
/**
* @Description: 批量保存用户
*/
@PostMapping("save-user")
public Object saveUser() {
return userService.insertForeach(userList);
}
/**
* @Description: 获取用户列表
*/
@GetMapping("list-user")
public Object listUser() {
return userService.list();
}
三、测试验证
1、批量插入数据
请求接口
localhost:8086/save-user
我们可以从商品接口代码中可以看出，它会批量插入5条数据。我们先看控制台输出SQL语句
我们可以从SQL语句可以看出 tab_user1 和 tab_user2 表插入了 两条数据 ，而 tab_user0 表中插入 一条数据 。
我们再来看数据库
tab_user0
tab_user1
tab_user2
完成分表插入数据。
2、获取数据
我们来获取列表的SQL，这里对SQL做了order排序操作，具体ShardingSphere分表实现order操作的原理可以看上面一篇博客。
select * from tab_user order by id
请求接口结果
我们可以看出虽然已经分表，但依然可以将多表数据聚合在一起并可以排序。
注意 ShardingSphere并不支持 CASE WHEN 、 HAVING 、 UNION (ALL) ， 有限支持子查询 。这个官网有详细说明。
Github地址 ： https://github.com/yudiandemingzi/spring-boot-sharding-sphere
参考
1、 ShardingSphere中文文档
2、 ShardingSphere官网
3、 Shardingsphere Github库
我相信，无论今后的道路多么坎坷，只要抓住今天，迟早会在奋斗中尝到人生的甘甜。抓住人生中的一分一秒，胜过虚度中的一月一年！(19）
正文到此结束
- 本文标签： classpath git 配置 HTML 开发 虚度 springboot 测试 struct map App 打印sql 文章 Spring Boot root ip sql 空间 mybatis Word id java cat 代码 REST 博客 Master spring maven 数据库 GitHub 插件 http MQ druid mysql db description 数据 list src IO JDBC node tar 开发者 XML lib NIO ArrayList tab https UI Select dataSource Service sharding
- 版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
- 本文海报： 生成海报一 生成海报二
热门推荐
相关文章
近期评论
-
文章和留言都翻到11页了 没有OOM
-
-
朋友，翻页到11页，及以后，会出现OOM，无法访问
-
-
搞个gitee的项目
-
-
版本号是多少，你可以下载哪个代码仓库，jdk选1.8 直接跑就行
-
-
-
Loading...
![[HBLOG]公众号](https://www.liuhaihua.cn/img/qrcode_gzh.jpg)
