当前位置:网站首页>The level of ShardingSphere depots in actual combat (4)
The level of ShardingSphere depots in actual combat (4)
2022-07-31 00:50:00 【Melting polar】
概述
场景
创建两个数据库
环境搭建
建库、建表
CREATE TABLE `course_1` (
`cid` bigint(20) NOT NULL,
`cname` varchar(50) NOT NULL,
`user_id` bigint(20) NOT NULL,
`cstatus` varchar(10) NOT NULL,
PRIMARY KEY (`cid`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
springboot环境搭建
配置分片规则
# 配置分片策略
# 配置数据源
spring.shardingsphere.datasource.names=m1,m2
spring.shardingsphere.datasource.m1.type=com.alibaba.druid.pool.DruidDataSource
spring.shardingsphere.datasource.m1.driver-class-name=com.mysql.cj.jdbc.Driver
spring.shardingsphere.datasource.m1.url=jdbc:mysql://localhost:3306/edu_db_1?serverTimezone=GMT%2B8
spring.shardingsphere.datasource.m1.username=root
spring.shardingsphere.datasource.m1.password=123456
spring.shardingsphere.datasource.m2.type=com.alibaba.druid.pool.DruidDataSource
spring.shardingsphere.datasource.m2.driver-class-name=com.mysql.cj.jdbc.Driver
spring.shardingsphere.datasource.m2.url=jdbc:mysql://localhost:3306/edu_db_2?serverTimezone=GMT%2B8
spring.shardingsphere.datasource.m2.username=root
spring.shardingsphere.datasource.m2.password=123456
# 指定course表分布情况,配置表在哪个数据库中,表名称都是什么
spring.shardingsphere.sharding.tables.course.actual-data-nodes=m$->{
1..2}.course_$->{
1..2}
# 指定course主键cid生成策略SNOWFLAKE
spring.shardingsphere.sharding.tables.course.key-generator.column=cid
spring.shardingsphere.sharding.tables.course.key-generator.type=SNOWFLAKE
# 指定表分片策略, cid是偶数添加到course_1表中,cid是奇数添加到course_2
spring.shardingsphere.sharding.tables.course.table-strategy.inline.sharding-column=cid
spring.shardingsphere.sharding.tables.course.table-strategy.inline.algorithm-expression=course_$->{
cid % 2 + 1}
# 指定库的中course表的分片策略
spring.shardingsphere.sharding.tables.course.database-strategy.inline.sharding-column=user_id
spring.shardingsphere.sharding.tables.course.database-strategy.inline.algorithm-expression=m$->{
user_id % 2 + 1}
# 打开sql输出日志
spring.shardingsphere.props.sql.show=true
# 解决一个Course实体类不能对应两张表的问题
spring.main.allow-bean-definition-overriding=true
编写测试代码
@Test
void addFk() {
for (int i = 0; i < 10; i++) {
Course course = new Course();
course.setCname("java");
course.setUserId(101L);
course.setCstatus("normal");
courseMapper.insertSelective(course);
}
}
@Test
public void findCourseDb() {
Example example = new Example(Course.class);
Example.Criteria criteria = example.createCriteria();
criteria.andEqualTo("userId", 100L);
criteria.andEqualTo("cid", 760185728628948993L);
Course course = courseMapper.selectOneByExample(example);
System.out.println(course);
}
边栏推荐
- Why use high-defense CDN when financial, government and enterprises are attacked?
- The difference between h264 and h265 decoding
- IOT cross-platform component design scheme
- typescript17-函数可选参数
- typescript15- (specify both parameter and return value types)
- Jmeter parameter transfer method (token transfer, interface association, etc.)
- ES6中 async 函数、await表达式 的基本用法
- MySQL table design for message queue to store message data
- MySQL数据库面试题总结(2022最新版)
- [Yugong Series] July 2022 Go Teaching Course 015-Assignment Operators and Relational Operators of Operators
猜你喜欢
随机推荐
typescript16-void
BOM系列之history对象
Gabor filter study notes
SereTOD2022 Track2代码剖析-面向半监督和强化学习的任务型对话系统挑战赛
typescript14-(单独指定参数和返回值的类型)
Meeting OA project pending meeting, all meeting functions
Summary of MySQL database interview questions (2022 latest version)
typescript10-commonly used basic types
ELK部署脚本---亲测可用
ShardingSphere之垂直分库分表实战(五)
BOM系列之Navigator对象
Xss target drone training [success when pop-up window is realized]
MySQL系列一:账号管理与引擎
The difference between truncate and delete in MySQL database
【愚公系列】2022年07月 Go教学课程 019-循环结构之for
【ABAP】MFBF过账到质量检验库存类型Demo
The difference between substring and substr in MySQL
GO GOPROXY代理设置
Detailed explanation of 9 common reasons for MySQL index failure
typescript13-类型别名