使用sharding-jdbc實現水平分庫+水平分表的示例代碼
前面的文章使用sharding-jdbc實現水平分表中詳細記錄瞭如何使用sharding-jdbc實現水平分表,即根據相應的策略,將一部分數據存入到表1中,一部分數據存入到表2中,邏輯上為同一張表,分表操作全部交由sharding-jdbc進行處理。
可能根據需要,還需要將一張表的數據拆分存入到多個數據庫中,甚至多個數據庫的多個表中,使用sharding-jdbc同樣可以實現。
重復的篇幅則不再贅述,下面重點記錄升級的過程。
分庫分表策略:將id為偶數的存入到庫1中,奇數存入到庫2中,在每個庫中,再根據學生的性別分別存到到表1和表2中。
新建兩個數據庫sharding_db1和sharding_db2,在兩個數據庫中在分別創建結構相同的兩張表,student_1和student_2。
CREATE TABLE `NewTable` ( `ID` bigint(20) NOT NULL , `NAME` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NOT NULL , `AGE` int(11) NOT NULL , `GENDER` int(1) NOT NULL , PRIMARY KEY (`ID`) );
相比前面文章中,將gender性別字段設置成瞭int類型,方便根據性別再進行分表。
修改配置文件
spring.main.allow-bean-definition-overriding=true # 配置Sharding-JDBC的分片策略 # 配置數據源,給數據源起名g1,g2...此處可配置多數據源 spring.shardingsphere.datasource.names=g1,g2 # 配置數據源具體內容:連接池,驅動,地址,用戶名,密碼 spring.shardingsphere.datasource.g1.type=com.alibaba.druid.pool.DruidDataSource spring.shardingsphere.datasource.g1.driver-class-name=com.mysql.cj.jdbc.Driver spring.shardingsphere.datasource.g1.url=jdbc:mysql://localhost:3306/sharding_db1?characterEncoding=utf-8&useUnicode=true&useSSL=false&serverTimezone=UTC spring.shardingsphere.datasource.g1.username=root spring.shardingsphere.datasource.g1.password=123456 spring.shardingsphere.datasource.g2.type=com.alibaba.druid.pool.DruidDataSource spring.shardingsphere.datasource.g2.driver-class-name=com.mysql.cj.jdbc.Driver spring.shardingsphere.datasource.g2.url=jdbc:mysql://localhost:3306/sharding_db2?characterEncoding=utf-8&useUnicode=true&useSSL=false&serverTimezone=UTC spring.shardingsphere.datasource.g2.username=root spring.shardingsphere.datasource.g2.password=123456 # 配置數據庫的分佈,表的分佈 spring.shardingsphere.sharding.tables.student.actual-data-nodes=g$->{1..2}.student_$->{1..2} # 指定student表 主鍵gid 生成策略為 SNOWFLAKE spring.shardingsphere.sharding.tables.student.key-generator.column=id spring.shardingsphere.sharding.tables.student.key-generator.type=SNOWFLAKE # 指定數據庫分片策略 約定id值是偶數添加到sharding_db1中,奇數添加到sharding_db2中 spring.shardingsphere.sharding.tables.student.database-strategy.inline.sharding-column=id spring.shardingsphere.sharding.tables.student.database-strategy.inline.algorithm-expression=g$->{id % 2 + 1} # 指定表分片策略 約定gender值是0添加到student_1表,如果gender是1添加到student_2表 spring.shardingsphere.sharding.tables.student.table-strategy.inline.sharding-column=gender spring.shardingsphere.sharding.tables.student.table-strategy.inline.algorithm-expression=student_$->{gender % 2 + 1} # 打開sql輸出日志 spring.shardingsphere.props.sql.show=true
配置多個數據源時,使用逗號隔開,分別配置其屬性。除瞭配置表分片策略,還需配置庫分配策略。
測試類
@SpringBootTest class ShardingJdbcDemoApplicationTests { @Autowired private StudentMapper studentMapper; @Test public void test01() { for (int i = 0; i < 15; i++) { Student student = new Student(); student.setName("wuwl"); student.setAge(27); student.setGender(i%2); studentMapper.insert(student); } } }
運行效果:
看樣子是成功瞭,查看數據庫數據。
sharding_db1.student_1:
sharding_db1.student_2:
sharding_db2.student_1:
sharding_db2.student_2:
到此這篇關於使用sharding-jdbc實現水平分庫+水平分表的示例代碼的文章就介紹到這瞭,更多相關sharding-jdbc水平分庫水平分表內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!
推薦閱讀:
- 使用sharding-jdbc實現水平分表的示例代碼
- 利用Sharding-Jdbc進行分庫分表的操作代碼
- 透明化Sharding-JDBC數據庫字段加解密方案
- Java ShardingJDBC實戰演練
- SpringBoot+MybatisPlus+Mysql+Sharding-JDBC分庫分表