垂直分库:根据业务将数据库进行拆分,比如用户表在用户数据库中,订单表在订单数据库中

服务器:容器名server-user,端口3301
服务器:容器名server-order,端口3302
还是通过docker容器来进行创建(创建之前一定要先开放端口然后重启服务器使端口生效)

第一步:创建server-user容器
step1:创建容器:

docker run -d \
-p 3301:3306 \
-v /atguigu/server/user/conf:/etc/mysql/conf.d \
-v /atguigu/server/user/data:/var/lib/mysql \
-e MYSQL_ROOT_PASSWORD=123456 \
–name server-user \
mysql:8.0.29
step2:登录mysql服务器

#进入容器:
docker exec -it server-user env LANG=C.UTF-8 /bin/bash

#进入容器内的mysql命令行
mysql -uroot -p

#修改默认密码插件
ALTER USER ‘root’@’%’ IDENTIFIED WITH mysql_native_password BY ‘123456’;
step3:创建数据库

CREATE DATABASE db_user;
USE db_user;
CREATE TABLE t_user (
id BIGINT AUTO_INCREMENT,
uname VARCHAR(30),
PRIMARY KEY (id)
);
第二步:创建server-order容器
step1:创建容器:

docker run -d \
-p 3302:3306 \
-v /atguigu/server/order/conf:/etc/mysql/conf.d \
-v /atguigu/server/order/data:/var/lib/mysql \
-e MYSQL_ROOT_PASSWORD=123456 \
–name server-order \
mysql:8.0.29
step2:登录mysql服务器

#进入容器:
docker exec -it server-order env LANG=C.UTF-8 /bin/bash

#进入容器内的mysql命令行
mysql -uroot -p

#修改默认密码插件
ALTER USER ‘root’@’%’ IDENTIFIED WITH mysql_native_password BY ‘123456’;
step3:创建数据库

CREATE DATABASE db_order;
USE db_order;
CREATE TABLE t_order (
id BIGINT AUTO_INCREMENT,
order_no VARCHAR(30),
user_id BIGINT,
amount DECIMAL(10,2),
PRIMARY KEY(id)
);
第三步:编写程序
1、新建实体类Order(User实体类在上一篇文章已经创建)

 

 

 

2.新建OrderMapper

 

 

 

3.数据分片配置,官方配置文档:数据分片 :: ShardingSphere

# 内存模式–实际项目中请配置集群模式
spring.shardingsphere.mode.type=Memory

# 配置真实数据源-名字自己起
spring.shardingsphere.datasource.names=server-order,server-user

# 配置第 1 个数据源
spring.shardingsphere.datasource.server-order.type=com.zaxxer.hikari.HikariDataSource
spring.shardingsphere.datasource.server-order.driver-class-name=com.mysql.jdbc.Driver
spring.shardingsphere.datasource.server-order.jdbc-url=jdbc:mysql://ip:3302/db_order
spring.shardingsphere.datasource.server-order.username=root
spring.shardingsphere.datasource.server-order.password=123456

# 配置第 2 个数据源
spring.shardingsphere.datasource.server-user.type=com.zaxxer.hikari.HikariDataSource
spring.shardingsphere.datasource.server-user.driver-class-name=com.mysql.jdbc.Driver
spring.shardingsphere.datasource.server-user.jdbc-url=jdbc:mysql://ip:3301/db_user
spring.shardingsphere.datasource.server-user.username=root
spring.shardingsphere.datasource.server-user.password=123456

# 标准分片表配置
spring.shardingsphere.rules.sharding.tables.t_user.actual-data-nodes= server-user.t_user
spring.shardingsphere.rules.sharding.tables.t_order.actual-data-nodes= server-order.t_order

# 打印SQl
spring.shardingsphere.props.sql-show=true
 

4.写代码插入t_user表和t_order表数据

 

 

 

然后启动服务浏览器访问:http://localhost:8080/sharding/jdbc/testInsertUserAndOrder

这个时候看日志输出:可以看到t_user表是对server-user数据源操作,t_order是对server-order数据源进行操作

 

 

 源代码已上传码云:https://gitee.com/vancl/sharding-jdbc/tree/master

 

 
 

————————————————
版权声明:本文为CSDN博主「知守观天下行走叶青」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/royal1235/article/details/127343034