當前位置：首頁 > 编程资源 > 编程问答 >内容正文

编程问答

server sql 水平分表_springboot集成Shardingsphere进行分库分表

發布時間：2025/3/12 编程问答 27 豆豆

生活随笔收集整理的這篇文章主要介紹了 server sql 水平分表_springboot集成Shardingsphere进行分库分表小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

當公司業務量上去之后，單表支撐不了的時候，分庫分表就是一個繞不開的話題，小弟最近新入職一家公司，發現這邊公司在用ShardingSphere來進行分庫分表，之前沒接觸過這方面，所以就寫了個demo學習一下，下面文章就記錄一下如何用ShardingSphere來進行分庫分表！(能力有限，本章不會講原理奧，只是記錄如何分庫分表，原理方面后面我學習了再寫，現在先會用先0.0，)

1、官網文檔地址

這是ShardingSphere官網文檔的地址，有需要的可以點進去看一下。

2、技術及環境

數據庫項目用到的技術

mysql5.6

springboot、mybatis、shardingsphere

3、建庫建表

1、新建兩個數據庫：一個user0，一個user1。2、在user0數據庫新建兩個表：一個us_admin0，一個us_admin1，新建語句如下：

CREATE?TABLE?`us_admin0`?(
??`id`?bigint(20)?NOT?NULL?AUTO_INCREMENT?COMMENT?'主鍵ID',
??`user_id`?int(11)?NOT?NULL?COMMENT?'用戶id',
?`addr_id`?int(11)?NOT?NULL?COMMENT?'地址id',
??`user_name`?varchar(64)?NOT?NULL?COMMENT?'用戶編號',
??PRIMARY?KEY?(`id`)
)?ENGINE=InnoDB?DEFAULT?CHARSET=utf8mb4?COMMENT='后臺用戶表';

CREATE?TABLE?`us_admin1`?(
??`id`?bigint(20)?NOT?NULL?AUTO_INCREMENT?COMMENT?'主鍵ID',
??`user_id`?int(11)?NOT?NULL?COMMENT?'用戶id',
?`addr_id`?int(11)?NOT?NULL?COMMENT?'地址id',
??`user_name`?varchar(64)?NOT?NULL?COMMENT?'用戶編號',
??PRIMARY?KEY?(`id`)
)?ENGINE=InnoDB?DEFAULT?CHARSET=utf8mb4?COMMENT='后臺用戶表';

3、在user1數據庫新建兩個表：一個us_admin0，一個us_admin1，新建語句如下：

4、搭建springboot項目

這部分就idea自己創建一下就好了，pom文件及配置文件內容如下：

pom文件：

<?xml ?version="1.0"?encoding="UTF-8"?>
"http://maven.apache.org/POM/4.0.0"?xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
?????????xsi:schemaLocation="http://maven.apache.org/POM/4.0.0?https://maven.apache.org/xsd/maven-4.0.0.xsd">4.0.0org.springframework.bootspring-boot-starter-parent2.0.7.RELEASE?com.shardingsphere1.0.0-SNAPSHOTsphereDemo?project?for?Spring?Boot1.8Hoxton.SR33.8.28.0.12junitjunit4.12testorg.springframework.bootspring-boot-starter-web-servicesorg.springframework.bootspring-boot-starter-testtestorg.junit.vintagejunit-vintage-engineorg.apache.shardingspheresharding-jdbc-spring-boot-starter4.0.0-RC1com.alibabadruid-spring-boot-starter1.1.14mysqlmysql-connector-javaorg.springframework.bootspring-boot-starter-actuatororg.mybatis.spring.bootmybatis-spring-boot-starter2.1.2org.springframework.bootspring-boot-maven-plugin

application.yml配置：

#?服務端口
server:
??port:?8888

#?服務名
spring:
??application:
????name:?test-user
??#?配置sharding?jdbc分片規則
??shardingsphere:
????datasource:
??????#?連接名稱(下面要用這個名稱來區分庫)
??????names:?ds0,ds1
??????ds0:
????????type:?com.alibaba.druid.pool.DruidDataSource
????????driver-class-name:?com.mysql.jdbc.Driver
????????url:?jdbc:mysql://192.168.1.19:3306/user0?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
????????username:?root
????????password:?123
????????initialSize:?5??????#初始化大小
????????maxActive:?200???????#最大值
????????maxWait:?2000??????#最大等待時間，配置獲取連接等待超時，時間單位都是毫秒ms
????????timeBetweenEvictionRunsMillis:?60000????#配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接
??????ds1:
????????type:?com.alibaba.druid.pool.DruidDataSource
????????driver-class-name:?com.mysql.jdbc.Driver
????????url:?jdbc:mysql://192.168.1.19:3306/user1?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
????????username:?root
????????password:?123
????????initialSize:?5??????#初始化大小
????????maxActive:?200???????#最大值
????????maxWait:?2000??????#最大等待時間，配置獲取連接等待超時，時間單位都是毫秒ms
????????timeBetweenEvictionRunsMillis:?60000????#配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接
????#?配置分片規則
????sharding:
??????#?按表來區分
??????tables:
????????us_admin:
??????????#?配置數據節點
??????????actualDataNodes:?ds${0..1}.us_admin${0..1}
??????????#?分庫策略
??????????databaseStrategy:
????????????inline:
??????????????#?分庫的規則?用user_id這個字段來分庫?總共有兩個庫?及ds0(user0)與ds1(user1)
??????????????shardingColumn:?user_id
??????????????algorithmExpression:?ds${user_id?%?2}
??????????#?分表策略
??????????tableStrategy:
????????????inline:
??????????????shardingColumn:?addr_id
??????????????algorithmExpression:?us_admin${addr_id?%?2}
??????????keyGenerator:
????????????column:?id
????????????type:?SNOWFLAKE
??????bindingTables:
????????us_admin
??????broadcastTables:
????????t_config
??????defaultDataSourceName:?ds0

????props:
??????sql.show:?true

#?配置xml?的掃描路徑
mybatis:
??mapper-locations:?classpath:mapper/*.xml
??check-config-location:?true
??type-aliases-package:?com.sharding.sphere.model
??configuration:
????cacheEnabled:?true
????mapUnderscoreToCamelCase:?true

5、接口測試

編寫增刪改接口進行測試，分庫根據user_id來切片，分表根據addr_id來切片，分別插入一些數據，結果如下：

@RestController
public?class?UserController?{

????@Resource
????UserService?userService;

????@RequestMapping("add")
????public?Integer?add(@RequestBody?UsAdmin?usAdmin){
????????Integer?add?=?userService.add(usAdmin);
????????return?add;
????}

????@RequestMapping("select")
????public?List?select(){
????????List?select?=?userService.select();return?select;
????}@RequestMapping("delect")public?Integer?delect(Long?id){
????????Integer?delect?=?userService.delect(id);return?delect;
????}
}

查詢sql語句：

<select?id="selectAll"?resultMap="BaseResultMap">
????select
??????id,?addr_id,?user_id,?user_name
????from?us_admin
??select>

新增sql語句：

<insert?id="insertSelective"?parameterType="com.sharding.sphere.model.UsAdmin">
????insert?into?us_admin
????<trim?prefix="("?suffix=")"?suffixOverrides=",">
??????<if?test="id?!=?null">
????????id,
??????if>
??????<if?test="userId?!=?null">
????????user_id,
??????if>
??????<if?test="addrId?!=?null">
????????addr_id,
??????if>
??????<if?test="userName?!=?null">
????????user_name,
??????if>
????trim>
????<trim?prefix="values?("?suffix=")"?suffixOverrides=",">
??????<if?test="id?!=?null">
????????#{id,jdbcType=BIGINT},
??????if>
??????<if?test="userId?!=?null">
????????#{userId,jdbcType=INTEGER},
??????if>
??????<if?test="addrId?!=?null">
????????#{addrId,jdbcType=INTEGER},
??????if>
??????<if?test="userName?!=?null">
????????#{userName,jdbcType=VARCHAR},
??????if>
????trim>
??insert>

刪除sql語句：

?delete?from?us_admin
????where?id?=?#{id,jdbcType=BIGINT}

數據新增分表分庫結果：

image

查詢結果：

image

可以看到，新增數據的時候以user_id%2來計算分庫，雙數在user0庫，單數在user1庫，addr_id作為分表id，雙數在us_admin0表，單數在us_admin1表，先確定庫然后確定表，而查詢一條語句可以查詢到所有，不過ShardingSphere好像有些sql語句是不支持的，比如關聯自己這種操作(us_admin left join us_admin這種)，還有一些不支持的sql，具體的可以百度看看。

講道理來看，ShardingSphere其實對代碼的侵入量并不算多，只是有一些配置，配置好之后該寫的sql跟原來一樣的，可能是還沒有踩到該踩的坑吧，等周末研究一下原理之后再寫一篇文章分析分析。

6、公眾號

如果你覺得我的文章對你有幫助話，歡迎關注我的微信公眾號:"一個快樂又痛苦的程序員"(無廣告，單純分享原創文章、已pj的實用工具、各種Java學習資源，期待與你共同進步)

總結

以上是生活随笔為你收集整理的server sql 水平分表_springboot集成Shardingsphere进行分库分表的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。

上一篇：（二分+区间搜索）Mountain W
下一篇：（DFS or BFS）Find The