Sharding-JDBC介紹及應(yīng)用總結(jié)

IT那活兒發(fā)布于2023-01-11 13:20 / 1800人閱讀

初識Sharding-JDBC

Sharding Sphere是一套開源的分布式數(shù)據(jù)庫中間件解決方案。而 sharding-jdbc是ShardingSphere的其中一個模塊，它定位為輕量級Java框架，在Java的JDBC層提供的額外服務(wù)。它使用客戶端直連數(shù)據(jù)庫，以jar包形式提供服務(wù)，無需額外部署和依賴，可理解為增強(qiáng)版的JDBC驅(qū)動，完全兼容JDBC和各種ORM框架。
Sharding-JDBC 主要作用：簡化對分庫分表之后數(shù)據(jù)相關(guān)操作

Sharding-JDBC 分庫分表操作

Sharding-JDBC水平分表

搭建環(huán)境

（1）技術(shù)：SpringBoot 2.2.1+ MyBatisPlus + Sharding-JDBC + Druid 連接池

（2）創(chuàng)建 SpringBoot 工程

（3）引入需要的依賴

 ▼▼▼<dependencies> 
<dependency> 
<groupId>org.springframework.bootgroupId> 
<artifactId>spring-boot-starterartifactId> 
dependency> 
<dependency> 
<groupId>org.springframework.bootgroupId> 
<artifactId>spring-boot-starter-testartifactId> 
dependency> 
<dependency> 
<groupId>com.alibabagroupId> 
<artifactId>druid-spring-boot-starterartifactId> 
<version>1.1.20version> 
dependency> 
<dependency> 
<groupId>mysqlgroupId> 
<artifactId>mysql-connector-javaartifactId> 
dependency> 
<dependency> 
<groupId>org.apache.shardingspheregroupId> 
<artifactId>sharding-jdbc-spring-boot-starterartifactId> 
<version>4.0.0-RC1version> 
dependency> 
<dependency> 
<groupId>com.baomidougroupId> 
<artifactId>mybatis-plus-boot-starterartifactId> 
<version>3.0.5version> 
dependency> 
<dependency> 
<groupId>org.projectlombokgroupId> 
<artifactId>lombokartifactId> 
dependency> 
dependencies>

按照水平分表的方式，創(chuàng)建數(shù)據(jù)庫和數(shù)據(jù)庫表

（1）創(chuàng)建數(shù)據(jù)庫 course_db

（2）在數(shù)據(jù)庫創(chuàng)建兩張表 course_1 和 course_2

（3）約定規(guī)則：如果添加課程 id 是偶數(shù)把數(shù)據(jù)添加 course_1，如果奇數(shù)添加到 course_2

配置Sharding-JDBC分片策略

在項目 application.properties 配置文件中進(jìn)行配置

# shardingjdbc 分片策略

# 配置數(shù)據(jù)源，給數(shù)據(jù)源起名稱

▼▼▼spring.shardingsphere.datasource.names=m1

# 一個實(shí)體類對應(yīng)兩張表，覆蓋

▼▼▼spring.main.allow-bean-definition-overriding=true

#配置數(shù)據(jù)源具體內(nèi)容，包含連接池，驅(qū)動，地址，用戶名和密碼

▼▼▼spring.shardingsphere.datasource.m1.type=com.alibaba.druid.pool.DruidDataSourc 
e 
spring.shardingsphere.datasource.m1.driver-class-name=com.mysql.cj.jdbc.Driver 
spring.shardingsphere.datasource.m1.url=jdbc:mysql://localhost:3306/course_db? 
serverTimezone=GMT%2B8 
spring.shardingsphere.datasource.m1.username=root 
spring.shardingsphere.datasource.m1.password=root

#指定 course 表分布情況，配置表在哪個數(shù)據(jù)庫里面，表名稱都是什么 m1.course_1 ,m1.course_2

▼▼▼spring.shardingsphere.sharding.tables.course.actual-data-nodes=m1.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 值偶數(shù)添加到 course_1 表，如果 cid 是奇數(shù)添加到 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}

# 打開 sql 輸出日志

▼▼▼
spring.shardingsphere.props.sql.show=true

編寫測試代碼

▼▼▼
@RunWith(SpringRunner.class)
@SpringBootTest
public classShardingjdbcdemoApplicationTests {
//注入 mapper
@Autowired
privateCourseMappercourseMapper;
//添加課程的方法
@Test
public voidaddCourse() {
for(inti=1;i<=10;i++) {
Course course =newCourse();
course.setCname("java"+i);
course.setUserId(100L);
course.setCstatus("Normal"+i);
courseMapper.insert(course);
}
}
//查詢課程的方法
@Test
public voidfindCourse() {
QueryWrapper wrapper =newQueryWrapper<>();
wrapper.eq("cid",465114665106538497L);
Course course =courseMapper.selectOne(wrapper);
System.out.println(course);
}
}

（1）上面測試代碼執(zhí)行，報錯了

（2）解決方案，在配置文件中添加一行配置

# 一個實(shí)體類對應(yīng)兩張表，覆蓋

▼▼▼
spring.main.allow-bean-definition-overriding=true

Sharding-JDBC實(shí)現(xiàn)水平分庫

數(shù)據(jù)庫搭建

創(chuàng)建兩個數(shù)據(jù)庫db1和db2，每個數(shù)據(jù)庫創(chuàng)建兩張表tab1和tab2，每個表中包括兩個字段cid和userId。

數(shù)據(jù)庫規(guī)則：userId為偶數(shù)則添加到db1數(shù)據(jù)庫，為奇數(shù)列則添加到db2數(shù)據(jù)庫。

表規(guī)則：cid為偶數(shù)列則添加到tab1，為奇數(shù)則添加到表tab2。

在Spring boot配置文件配置數(shù)據(jù)庫分片規(guī)則

# shardingjdbc 分片策略# 配置數(shù)據(jù)源，給數(shù)據(jù)源起名稱,

# 水平分庫，配置兩個數(shù)據(jù)源

▼▼▼
spring.shardingsphere.datasource.names=m1,m2

# 一個實(shí)體類對應(yīng)兩張表，覆蓋

▼▼▼
spring.main.allow-bean-definition-overriding=true

#配置第一個數(shù)據(jù)源具體內(nèi)容，包含連接池，驅(qū)動，地址，用戶名和密碼

▼▼▼
spring.shardingsphere.datasource.m1.type=com.alibaba.druid.pool.DruidDataSourc
e
spring.shardingsphere.datasource.m1.driver-class-name=com.mysql.cj.jdbc.Driver
spring.shardingsphere.datasource.m1.url=jdbc:mysql://localhost:3306/edu_db_1?s
erverTimezone=GMT%2B8
spring.shardingsphere.datasource.m1.username=root
spring.shardingsphere.datasource.m1.password=root

#配置第二個數(shù)據(jù)源具體內(nèi)容，包含連接池，驅(qū)動，地址，用戶名和密碼

▼▼▼
spring.shardingsphere.datasource.m2.type=com.alibaba.druid.pool.DruidDataSourc
e
spring.shardingsphere.datasource.m2.driver-class-name=com.mysql.cj.jdbc.Driver
spring.shardingsphere.datasource.m2.url=jdbc:mysql://localhost:3306/edu_db_2?s
erverTimezone=GMT%2B8
spring.shardingsphere.datasource.m2.username=root
spring.shardingsphere.datasource.m2.password=root

#指定數(shù)據(jù)庫分布情況，數(shù)據(jù)庫里面表分布情況

# m1 m2 course_1 course_2

▼▼▼
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 值偶數(shù)添加到 course_1 表，如果 cid 是奇數(shù)添加到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}

# 指定數(shù)據(jù)庫分片策略約定 user_id 是偶數(shù)添加 m1，是奇數(shù)添加 m2

▼▼▼
#spring.shardingsphere.sharding.default-database-strategy.inline.sharding
column=user_id
#spring.shardingsphere.sharding.default-database-strategy.inline.algorithm-
expression=m$->{user_id % 2 + 1}
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

編寫測試方法

▼▼▼
//======================測試水平分庫=====================
//添加操作
@Test
public voidaddCourseDb() {
Course course =newCourse();
course.setCname("javademo1");
//分庫根據(jù) user_id
course.setUserId(111L);
course.setCstatus("Normal1");
courseMapper.insert(course);
}
//查詢操作
@Test
public voidfindCourseDb() {
QueryWrapper wrapper =newQueryWrapper<>();
//設(shè)置 userid 值
wrapper.eq("user_id",100L);
//設(shè)置 cid 值
wrapper.eq("cid",465162909769531393L);
Course course =courseMapper.selectOne(wrapper);
System.out.println(course);
}

Sharding-JDBC實(shí)現(xiàn)讀寫分離

Sharding-JDBC 通過 sql 語句語義分析，實(shí)現(xiàn)讀寫分離過程，不會做數(shù)據(jù)同步

Sharding-JDBC 操作

配置讀寫分離策略

# user_db 從服務(wù)器

▼▼▼
spring.shardingsphere.datasource.s0.type=com.alibaba.druid.pool.DruidDataSourc 
e 
spring.shardingsphere.datasource.s0.driver-class-name=com.mysql.cj.jdbc.Driver 
spring.shardingsphere.datasource.s0.url=jdbc:mysql://localhost:3307/user_db?se 
rverTimezone=GMT%2B8 
spring.shardingsphere.datasource.s0.username=root spring.shardingsphere.datasource.s0.password=root

# 主庫從庫邏輯數(shù)據(jù)源定義 ds0 為 user_db

▼▼▼
spring.shardingsphere.sharding.master-slave-rules.ds0.master-data-source
name=m0
spring.shardingsphere.sharding.master-slave-rules.ds0.slave-data-source
names=s0

# 配置 user_db 數(shù)據(jù)庫里面 t_user 專庫專表

#spring.shardingsphere.sharding.tables.t_user.actual-data-nodes=m$->{0}.t_user

# t_user 分表策略，固定分配至 ds0 的 t_user 真實(shí)表

▼▼▼
spring.shardingsphere.sharding.tables.t_user.actual-data-nodes=ds0.t_user

編寫測試代碼

//添加操作
@Test
public voidaddUserDb() {
User user =newUser();
user.setUsername("lucymary");
user.setUstatus("a");
userMapper.insert(user);
}
//查詢操作
@Test
public voidfindUserDb() {
QueryWrapper wrapper =newQueryWrapper<>();
//設(shè)置 userid 值
wrapper.eq("user_id",465508031619137537L);
User user =userMapper.selectOne(wrapper);
System.out.println(user);
}

END

更多精彩干貨分享

點(diǎn)擊下方名片關(guān)注

IT那活兒

GPU云服務(wù)器云服務(wù)器 webrtc介紹及簡單應(yīng)用華為云服務(wù)器銷售介紹術(shù)語總結(jié) 應(yīng)用技巧總結(jié) 云計算及應(yīng)用

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/129943.html

發(fā)表評論

登陸后可評論

0條評論

IT那活兒

男|高級講師

我要關(guān)注我要私信

TA的文章

消息中間件故障分析一例

閱讀 1356·2023-01-11 13:20
RAC雙節(jié)點(diǎn)crash回復(fù)一例

閱讀 1707·2023-01-11 13:20
ORA-600處理一例

閱讀 1215·2023-01-11 13:20
雙節(jié)點(diǎn)RAC實(shí)例2 HANG 故障分析一例

閱讀 1906·2023-01-11 13:20
RAC集群節(jié)點(diǎn)1重啟分析一例

閱讀 4165·2023-01-11 13:20
CRS啟動報錯CRS-1656處理分享

閱讀 2757·2023-01-11 13:20
oracle 12CR2打補(bǔ)丁報錯處理一例

閱讀 1402·2023-01-11 13:20
分布式緩存組件故障分析及監(jiān)控優(yōu)化

閱讀 3671·2023-01-11 13:20

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

Sharding-JDBC介紹及應(yīng)用總結(jié)

搭建環(huán)境

按照水平分表的方式，創(chuàng)建數(shù)據(jù)庫和數(shù)據(jù)庫表

配置Sharding-JDBC分片策略

編寫測試代碼

數(shù)據(jù)庫搭建

在Spring boot配置文件配置數(shù)據(jù)庫分片規(guī)則

編寫測試方法

Sharding-JDBC 操作

配置讀寫分離策略

編寫測試代碼

相關(guān)文章

database

當(dāng)當(dāng)彈性化中間件及云化之路（據(jù)說讀完可以少踩坑）

java篇

Sharding-Jdbc實(shí)現(xiàn)mysql分庫分表

**springboot實(shí)踐筆記之一：springboot+sharding-jdbc+mybatis全**

發(fā)表評論

0條評論

IT那活兒

男|高級講師

TA的文章

消息中間件故障分析一例

RAC雙節(jié)點(diǎn)crash回復(fù)一例

ORA-600處理一例

雙節(jié)點(diǎn)RAC實(shí)例2 HANG 故障分析一例

RAC集群節(jié)點(diǎn)1重啟分析一例

CRS啟動報錯CRS-1656處理分享

oracle 12CR2打補(bǔ)丁報錯處理一例

分布式緩存組件故障分析及監(jiān)控優(yōu)化

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

Sharding-JDBC介紹及應(yīng)用總結(jié)

搭建環(huán)境

按照水平分表的方式，創(chuàng)建數(shù)據(jù)庫和數(shù)據(jù)庫表

配置Sharding-JDBC分片策略

編寫測試代碼

數(shù)據(jù)庫搭建

在Spring boot配置文件配置數(shù)據(jù)庫分片規(guī)則

編寫測試方法

Sharding-JDBC 操作

配置讀寫分離策略

編寫測試代碼

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

按照水平分表的方式，創(chuàng)建數(shù)據(jù)庫和數(shù)據(jù)庫表