springboot mysql 分库分表

Spring Boot是一个基于Spring框架的快速开发Web应用程序的框架，而MySQL分库分表是一种常见的数据库架构设计方式，可以提高数据库的性能和扩展性。在Spring Boot中，可以使用ShardingSphere-JDBC来实现MySQL分库分表。 具体实现步骤如下： 1. 在pom.xml文件中添加ShardingSphere-JDBC的依赖。 2. 配置数据源和分片规则，可以使用YAML或Properties文件进行配置。 3. 在代码中使用JdbcTemplate或MyBatis等ORM框架进行数据库操作。 在上述引用中，可以看到一个基于Spring Boot和ShardingSphere-JDBC的MySQL分库分表项目的pom.xml文件和表结构示例。通过这些示例，可以更好地理解如何在Spring Boot中实现MySQL分库分表。

### Spring Boot 中使用 Sharding JDBC 实现分库分表的配置教程 #### 1. Maven依赖引入 为了在Spring Boot项目中集成Sharding JDBC，首先需要在`pom.xml`文件中添加相应的Maven依赖。 ```xml <dependency> <groupId>org.apache.shardingsphere</groupId> <artifactId>sharding-jdbc-spring-boot-starter</artifactId> <version>4.1.1</version> </dependency> <!-- 数据源连接池 --> <dependency> <groupId>com.zaxxer</groupId> <artifactId>HikariCP</artifactId> </dependency> <!-- MySQL驱动 --> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> ``` 以上代码片段展示了如何通过Maven引入Sharding JDBC及其相关组件[^1]。 --- #### 2. 配置数据源 在`application.yml`或`application.properties`文件中定义多个数据源，并指定分片策略。以下是基于YAML格式的一个示例： ```yaml spring: shardingsphere: datasource: names: ds_0,ds_1 ds_0: type: com.zaxxer.hikari.HikariDataSource driver-class-name: com.mysql.cj.jdbc.Driver jdbc-url: jdbc:mysql://localhost:3306/db_0?useSSL=false&serverTimezone=UTC username: root password: root ds_1: type: com.zaxxer.hikari.HikariDataSource driver-class-name: com.mysql.cj.jdbc.Driver jdbc-url: jdbc:mysql://localhost:3306/db_1?useSSL=false&serverTimezone=UTC username: root password: root rules: sharding: tables: t_order: actual-data-nodes: ds_${0..1}.t_order${0..1} table-strategy: standard: sharding-column: order_id precise-algorithm-class-name: com.example.demo.algorithm.ModuloDatabaseShardingAlgorithm key-generate-strategy: column: order_id key-generator-class-name: org.apache.shardingsphere.core.keygen.DefaultKeyGenerator ``` 此配置说明了如何设置两个物理数据库（`db_0` 和 `db_1`），并为订单表`t_order`分配实际存储节点[^5]。 --- #### 3. 自定义分片算法 Sharding JDBC支持多种内置分片算法，也可以自定义分片逻辑。以下是一个简单的模运算分片算法实现： ```java public class ModuloDatabaseShardingAlgorithm implements PreciseShardingAlgorithm<Long> { @Override public String doSharding(Collection<String> availableTargetNames, PreciseShardingValue<Long> shardingValue) { long value = shardingValue.getValue(); int dbIndex = (int)(value % 2); return "ds_" + dbIndex; } } ``` 该算法根据`order_id`字段值对2取模来决定具体的数据源[^2]。 --- #### 4. 测试分库分表示例 完成上述配置后，可以通过单元测试验证功能是否正常工作。下面展示了一个插入和查询操作的例子： ```java @SpringBootTest @RunWith(SpringRunner.class) public class OrderTest { @Resource private OrderMapper orderMapper; @Test public void testInsertOrder() { for (int i = 0; i < 10; i++) { Order order = new Order(); order.setOrderId((long)i); order.setUserId(1001L); order.setStatus("NEW"); orderMapper.insert(order); } } @Test public void testQueryOrders() { QueryWrapper<Order> wrapper = new QueryWrapper<>(); wrapper.eq("user_id", 1001L); List<Order> orders = orderMapper.selectList(wrapper); orders.forEach(System.out::println); } } ``` 这段代码实现了向分布式环境中插入订单记录以及按条件检索的功能[^3]。 --- #### 5. 进阶功能：读写分离 如果希望进一步提升性能，可以结合Sharding JDBC实现读写分离。只需扩展配置如下所示即可： ```yaml spring: shardingsphere: masterslave: load-balance-algorithm-type: round_robin name: ms_ds master-data-source-name: write_ds slave-data-source-names: read_ds_0,read_ds_1 ``` 这里设置了主从复制模式下的负载均衡策略[^1]。 --- ### 总结 本文介绍了如何利用Sharding JDBC框架，在Spring Boot应用里快速搭建起一套具备分库分表能力的基础架构体系。同时提供了关于自定义分片规则、基本CRUD接口开发等方面的指导建议。