目录

• 主从库搭建
  
• Compose File
  
• Master 配置
  
• Slave 配置
  
• 主从配置
• 创建分库分表
  
• Order 1 库
  
• Order 2 库
  
• User 库
  
• Sharding-JDBC 引入
  
• Sharding-JDBC 配置
  
• 可选配置
• 数据源配置
  
• 主从复制配置
  
• 数据节点配置
  
• Demo 程序
  

Sharding-JDBC 是无侵入式的 MySQL 分库分表操作工具，所有库表设置仅需要在配置文件中配置即可，无须修改任何代码。
本文写了一个 Demo，使用的是 SpringBoot 框架，通过 Docker 进行 MySQL 实例管理，分库分表结构如下图，同时所有的库都进行了主从复制：

文章图片


主从库搭建
Docker 项目结构：

docker├── docker-compose.yml├── master│├── data│├── log││└── error.log│├── my.cnf│└── mysql-files# Win 需要，Linux 不需要├── README.md└── slave├── data├── log│└── error.log├── my.cnf└── mysql-files

Compose File

version: '3'networks:sharding-jdbc-demo:driver: bridgeipam:config:- subnet: 172.25.0.0/24services:master:image: mysqlcontainer_name: sharding-jdbc-demo-masterports:- "3307:3306"volumes:- "./master/data:/var/lib/mysql"- "./master/mysql-files:/var/lib/mysql-files"# win 下的 MySQL8 需要，Linux 不需要- "./master/log/error.log:/var/log/mysql/error.log"- "./master/my.cnf:/etc/mysql/my.cnf"environment:MYSQL_ROOT_PASSWORD: 123456entrypoint: bash -c "chown -R mysql:mysql /var/log/mysql && chmod 644 /etc/mysql/my.cnf && exec /entrypoint.sh mysqld"restart: unless-stoppednetworks:sharding-jdbc-demo:ipv4_address: 172.25.0.101slave:image: mysqlcontainer_name: sharding-jdbc-demo-slaveports:- "3308:3306"volumes:- "./slave/data:/var/lib/mysql"- "./slave/mysql-files:/var/lib/mysql-files"- "./slave/log/error.log:/var/log/mysql/error.log"- "./slave/my.cnf:/etc/mysql/my.cnf"environment:MYSQL_ROOT_PASSWORD: 123456entrypoint: bash -c "chown -R mysql:mysql /var/log/mysql && chmod 644 /etc/mysql/my.cnf&& exec /entrypoint.sh mysqld"restart: unless-stoppednetworks:sharding-jdbc-demo:ipv4_address: 172.25.0.102

Master 配置

[mysqld]pid-file= /var/run/mysqld/mysqld.pidsocket= /var/run/mysqld/mysqld.sockdatadir= /var/lib/mysqllog-error= /var/log/mysql/error.logbind-address= 0.0.0.0secure-file-priv = NULLmax_connections= 16384character-set-server = utf8mb4collation-server= utf8mb4_general_ciinit_connect='SET NAMES utf8mb4'skip-name-resolveserver_id = 1log-bin = mysql-binbinlog-do-db = db_order_1 # 复制 db_order_1binlog-do-db = db_order_2 # 复制 db_order_2binlog-do-db = db_user# 复制 db_userlog-slave-updatessync_binlog = 1auto_increment_offset = 1auto_increment_increment = 1expire_logs_days = 7log_bin_trust_function_creators = 1# Custom config should go here!includedir /etc/mysql/conf.d/

Slave 配置

[mysqld]pid-file= /var/run/mysqld/mysqld.pidsocket= /var/run/mysqld/mysqld.sockdatadir= /var/lib/mysqllog-error= /var/log/mysql/error.logbind-address= 0.0.0.0secure-file-priv = NULLmax_connections= 16384character-set-server = utf8mb4collation-server= utf8mb4_general_ciinit_connect='SET NAMES utf8mb4'skip-name-resolveskip-host-cacheserver_id = 2log-bin = mysql-binlog-slave-updatessync_binlog = 0innodb_flush_log_at_trx_commit = 0# 提交策略replicate-do-db = db_order_1# 复制 db_order_1replicate-do-db = db_order_2# 复制 db_order_2replicate-do-db = db_user# 复制 db_userslave-net-timeout = 60# 重连时间log_bin_trust_function_creators = 1# Custom config should go here!includedir /etc/mysql/conf.d/

主从配置
启动容器 docker compose up -d;
登录 Master mysql -uroot -h 127.0.0.1 -P 3307 -p ;
查看 master 状态。

mysql> show master status\G*************************** 1. row ***************************File: mysql-bin.000004# 记住 Bin log 当前文件名称Position: 156# 记住 Bin log 当前偏移量Binlog_Do_DB: db_order_1,db_order_2,db_user# 确认复制数据库是否正确Binlog_Ignore_DB:Executed_Gtid_Set:

登录 Slave mysql -uroot -h 127.0.0.1 -P 3308 -p
设置 Master 连接，注意 host 与 port 是内网的地址和端口。

mysql> change master to master_host='172.25.0.101',master_user='root',master_password='123456',master_port=3306,master_log_file='mysql-bin.000004',master_log_pos=156;

启动同步

mysql> start slave;

查看 Slave 状态，若 Slave_IO 与 Slave_SQL 都在运行为 YES 即成功。

mysql> show slave status\G*************************** 1. row ***************************Slave_IO_State: Waiting for source to send eventMaster_Host: 172.25.0.101Master_User: rootMaster_Port: 3306Connect_Retry: 60Master_Log_File: mysql-bin.000004Read_Master_Log_Pos: 156Relay_Log_File: d2a706a02933-relay-bin.000002Relay_Log_Pos: 324Relay_Master_Log_File: mysql-bin.000004Slave_IO_Running: YesSlave_SQL_Running: YesReplicate_Do_DB: db_order_1,db_order_2,db_user

创建分库分表
登录 Master，创建数据库：

CREATE DATABASE db_order_1; CREATE DATABASE db_order_2; CREATE DATABASE db_user;

此时从库也会创建数据库，若没有，则是主从配置失败了。
此时已完成垂直分库和水平分库。接下来创建数据表：


Order 1 库

先 USE db_order_1; ，再分别创建 t_dict 全局表、t_order_1 和 t_order_2 水平分表。

DROP TABLE IF EXISTS `t_dict`; CREATE TABLE `t_dict`(`id`intNOT NULL AUTO_INCREMENT,`type`intNOT NULL,`enum_value` intNOT NULL,`name`varchar(64) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',PRIMARY KEY (`id`)) ENGINE = InnoDBAUTO_INCREMENT = 7DEFAULT CHARSET = utf8mb4COLLATE = utf8mb4_general_ci; LOCK TABLES `t_dict` WRITE; INSERT INTO `t_dict` VALUES (1,1,0,'未定义'),(2,1,1,'未付款'),(3,1,2,'已付款'),(4,1,3,'退款中'),(5,1,4,'已退款'),(6,1,5,'已完成'),(7,2,0,'未定义'),(8,2,1,'已创建'),(9,2,2,'已验证'),(10,2,3,'已冻结'),(11,2,4,'已注销'),(12,2,5,'已删除'); UNLOCK TABLES; DROP TABLE IF EXISTS `t_order_1`; CREATE TABLE `t_order_1`(`id`bigintNOT NULL,`user_id` bigintNOT NULL,`price`decimal(10, 2) NOT NULL,`status`intNOT NULL DEFAULT '1',PRIMARY KEY (`id`)) ENGINE = InnoDBDEFAULT CHARSET = utf8mb4COLLATE = utf8mb4_general_ci; DROP TABLE IF EXISTS `t_order_2`; CREATE TABLE `t_order_2`(`id`bigintNOT NULL,`user_id` bigintNOT NULL,`price`decimal(10, 2) NOT NULL,`status`intNOT NULL DEFAULT '1',PRIMARY KEY (`id`)) ENGINE = InnoDBDEFAULT CHARSET = utf8mb4COLLATE = utf8mb4_general_ci;

Order 2 库

先 USE db_order_2; ，再分别创建 t_dict 全局表、t_order_1 和 t_order_2 水平分表。所执行 SQL 与 db_order_1 一致。


User 库

先 USE db_user; ，再分别创建 t_dict 全局表和 t_user 表，此处就不进行水平或垂直分表了。垂直分表 sharding-jdbc 不会去处理，因为垂直分表之后就是异表异构了，执行 Join 操作就可以了，或者代码进行多次查询实现。

DROP TABLE IF EXISTS `t_dict`; CREATE TABLE `t_dict`(`id`intNOT NULL AUTO_INCREMENT,`type`intNOT NULL,`enum_value` intNOT NULL,`name`varchar(64) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',PRIMARY KEY (`id`)) ENGINE = InnoDBAUTO_INCREMENT = 7DEFAULT CHARSET = utf8mb4COLLATE = utf8mb4_general_ci; LOCK TABLES `t_dict` WRITE; INSERT INTO `t_dict` VALUES (1,1,0,'未定义'),(2,1,1,'未付款'),(3,1,2,'已付款'),(4,1,3,'退款中'),(5,1,4,'已退款'),(6,1,5,'已完成'),(7,2,0,'未定义'),(8,2,1,'已创建'),(9,2,2,'已验证'),(10,2,3,'已冻结'),(11,2,4,'已注销'),(12,2,5,'已删除'); UNLOCK TABLES; DROP TABLE IF EXISTS `t_user`; CREATE TABLE `t_user`(`id`bigintNOT NULL AUTO_INCREMENT,`name` varchar(128) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',`type` intNOT NULL DEFAULT '1',PRIMARY KEY (`id`)) ENGINE = InnoDBAUTO_INCREMENT = 1426999086541635586DEFAULT CHARSET = utf8mb4COLLATE = utf8mb4_general_ci;

Sharding-JDBC 引入
Sharding-JDBC maven 包：

org.apache.shardingspheresharding-jdbc-spring-boot-starter4.1.1

本 Demo 其他用到的依赖，分别是 Junit 测试、Lombok、MyBatis Plus、Druid 连接池、MySQL 驱动、Java Faker 数据生成器：

org.springframework.bootspring-boot-starter-testtestjunitjunit4.13.2testorg.projectlomboklomboktruecom.baomidoumybatis-plus-boot-starter3.4.3.1com.alibabadruid1.2.6mysqlmysql-connector-javaorg.apache.shardingspheresharding-jdbc-spring-boot-starter4.1.1com.github.javafakerjavafaker1.0.2

Sharding-JDBC 配置

可选配置
启用 SQL 打印：

spring.shardingsphere.props.sql.show = true

数据源配置

总共有 t_order_1、t_order_2 和 t_user 三个库，加上单主单从的复制，因此有 6 个数据库，需要配置六个数据源：

# Datasource Definespring.shardingsphere.datasource.names = o1-master,o2-master,o1-slave,o2-slave,u-master,u-slave# datasource o1-masterspring.shardingsphere.datasource.o1-master.type = com.alibaba.druid.pool.DruidDataSourcespring.shardingsphere.datasource.o1-master.driver-class-name = com.mysql.cj.jdbc.Driverspring.shardingsphere.datasource.o1-master.url = jdbc:mysql://localhost:3307/db_order_1?useUnicode=truespring.shardingsphere.datasource.o1-master.username = rootspring.shardingsphere.datasource.o1-master.password = 123456# datasource o1-slavespring.shardingsphere.datasource.o1-slave.type = com.alibaba.druid.pool.DruidDataSourcespring.shardingsphere.datasource.o1-slave.driver-class-name = com.mysql.cj.jdbc.Driverspring.shardingsphere.datasource.o1-slave.url = jdbc:mysql://localhost:3308/db_order_1?useUnicode=truespring.shardingsphere.datasource.o1-slave.username = rootspring.shardingsphere.datasource.o1-slave.password = 123456# datasource o2-masterspring.shardingsphere.datasource.o2-master.type = com.alibaba.druid.pool.DruidDataSourcespring.shardingsphere.datasource.o2-master.driver-class-name = com.mysql.cj.jdbc.Driverspring.shardingsphere.datasource.o2-master.url = jdbc:mysql://localhost:3307/db_order_2?useUnicode=truespring.shardingsphere.datasource.o2-master.username = rootspring.shardingsphere.datasource.o2-master.password = 123456# datasource o2-slavespring.shardingsphere.datasource.o2-slave.type = com.alibaba.druid.pool.DruidDataSourcespring.shardingsphere.datasource.o2-slave.driver-class-name = com.mysql.cj.jdbc.Driverspring.shardingsphere.datasource.o2-slave.url = jdbc:mysql://localhost:3308/db_order_2?useUnicode=truespring.shardingsphere.datasource.o2-slave.username = rootspring.shardingsphere.datasource.o2-slave.password = 123456# datasource u-masterspring.shardingsphere.datasource.u-master.type = com.alibaba.druid.pool.DruidDataSourcespring.shardingsphere.datasource.u-master.driver-class-name = com.mysql.cj.jdbc.Driverspring.shardingsphere.datasource.u-master.url = jdbc:mysql://localhost:3307/db_user?useUnicode=truespring.shardingsphere.datasource.u-master.username = rootspring.shardingsphere.datasource.u-master.password = 123456# datasource u-slavespring.shardingsphere.datasource.u-slave.type = com.alibaba.druid.pool.DruidDataSourcespring.shardingsphere.datasource.u-slave.driver-class-name = com.mysql.cj.jdbc.Driverspring.shardingsphere.datasource.u-slave.url = jdbc:mysql://localhost:3308/db_user?useUnicode=truespring.shardingsphere.datasource.u-slave.username = rootspring.shardingsphere.datasource.u-slave.password = 123456

主从复制配置

主从配置不需要声明，在定义时会自动读取 key 中的主从配置库作为逻辑库，如下面的 db-order-1。

# Replication Definespring.shardingsphere.sharding.master-slave-rules.db-order-1.master-data-source-name=o1-masterspring.shardingsphere.sharding.master-slave-rules.db-order-1.slave-data-source-names=o1-slavespring.shardingsphere.sharding.master-slave-rules.db-order-2.master-data-source-name=o2-masterspring.shardingsphere.sharding.master-slave-rules.db-order-2.slave-data-source-names=o2-slavespring.shardingsphere.sharding.master-slave-rules.db-user.master-data-source-name=u-masterspring.shardingsphere.sharding.master-slave-rules.db-user.slave-data-source-names=u-slave

数据节点配置

数据节点，指的是每张数据表，由于存在分库、分表、全局的不同类型，因此数据节点也有不同类型。注意，由于我们进行了主从复制，因此这里的数据库不能直接填数据源的名称，应该填在主从复制配置的 Key 中定义的名称，如 db-user 而不是 u-master 或 u-slave。
全局表：

# BroadCast Tablespring.shardingsphere.sharding.broadcast-tables = t_dict

单库单表：
key-generator.column 设置主键列。
key-generator.type 设置主键生成类型，这里使用雪花算法，其实没必要因为不是分表的，但是不填也会默认使用这个。

# Data Node t_userspring.shardingsphere.sharding.tables.t_user.actual-data-nodes = db-user.t_userspring.shardingsphere.sharding.tables.t_user.key-generator.column = idspring.shardingsphere.sharding.tables.t_user.key-generator.type = SNOWFLAKE

分库分表：
在 actual-data-nodes 中使用 groovy 表达式进行设置。
在 database-strategy 中设置切分方式，具体自查，暂没时间写。

# Data Node t_order, If there is not master-salve-replication, use datasource name like "o$-master->{1..2}.t_order_$->{1..2}"spring.shardingsphere.sharding.tables.t_order.actual-data-nodes = db-order-$->{1..2}.t_order_$->{1..2}spring.shardingsphere.sharding.tables.t_order.key-generator.column = idspring.shardingsphere.sharding.tables.t_order.key-generator.type = SNOWFLAKE# database sharding strategyspring.shardingsphere.sharding.tables.t_order.database-strategy.inline.sharding-column = user_idspring.shardingsphere.sharding.tables.t_order.database-strategy.inline.algorithm-expression = db-order-$->{user_id % 2 + 1}# table sharding strategyspring.shardingsphere.sharding.tables.t_order.table-strategy.inline.sharding-column = idspring.shardingsphere.sharding.tables.t_order.table-strategy.inline.algorithm-expression = t_order_$->{id % 2 + 1}

Demo 程序
参见：zoharyips/sharding-jdbc-demo (github.com)
【Java使用Sharding-JDBC分库分表进行操作】到此这篇关于Java使用Sharding-JDBC分库分表进行操作的文章就介绍到这了,更多相关Java Sharding-JDBC分库分表内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

推荐阅读

• 

  攀枝花酒店最好排名榜攀枝花酒店价格
• 

  5和4的最小公倍数是多少 5和4的最小公倍数是几
• 

  晶体中为什么会产生缺陷
• 

  西裤怎么洗
• 

  我国跨境电商以什么模式为主营业务 我国跨境电商以什么模式为主，我国跨境电商以什么模式为主体
• 

  冰箱显示屏出现e1怎么解决,实际上与普通无异
• 

  用UG制作的电极模型
• 

  保险行业创新案例分析,经典保险案例分析100例pdf
• 

  三星s22ultra拍照评测
• 

  冷冻胚胎技术|宝宝一出生就“27岁”，冷冻胚胎技术是如何做到的
• 

  密接没有感染次密接会感染吗
• 

  什么是HDR摄影
• 

  尼康105 1.4人像 尼康105-1.4人像作品
• 

  Linux数据类型大小
• 

  林肯车售价 深入了解车价
• 

  lol德莱文打盖伦怎么打？
• 

  创造营2021选手名单所有人 创造营成团名单
• 

  梯形体的体积计算公式是什么
• 

  将十进制215转换成八进制数是
• 

  箭牌洁具的价格表 箭牌单功能卫浴单价

• JAVA（抽象类与接口的区别&重载与重写&内存泄漏）
• 由浅入深理解AOP
• 【译】20个更有效地使用谷歌搜索的技巧
• mybatisplus如何在xml的连表查询中使用queryWrapper
• MybatisPlus|MybatisPlus LambdaQueryWrapper使用int默认值的坑及解决
• MybatisPlus使用queryWrapper如何实现复杂查询
• 事件代理
• Java|Java OpenCV图像处理之SIFT角点检测详解
• java中如何实现重建二叉树
• iOS中的Block