springboot~对应sharding-jdbc实现分库分表

原因

当mysql数据库单表大于1千万以后，查询的性能就不能保证了，我们必须考虑分库，分表的方案了，还好，sharding-jdbc可以很优雅的与springboot对接，完成对mysql的分库和分表。
依赖整理

为了不影响其它小容量的表，所有添加了动态数据源，只对需要分库分表的进行配置即可

• com.baomidou:dynamic-datasource-spring-boot-starter:3.3.1
  
• org.apache.shardingsphere:sharding-jdbc-spring-boot-starter:4.1.1
  
• com.baomidou:dynamic-datasource-spring-boot-starter:3.3.1
  
• com.baomidou:mybatis-plus-boot-starter:3.4.1
  

1.     <dependency>
2.         <groupId>org.apache.shardingsphere</groupId>
3.         <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
4.     </dependency>
5.     <dependency>
6.         <groupId>com.baomidou</groupId>
7.         <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
8.     </dependency>
9.     <dependency>
10.         <groupId>com.alibaba</groupId>
11.         <artifactId>druid-spring-boot-starter</artifactId>
12.     </dependency>
13.     <dependency>
14.         <groupId>com.baomidou</groupId>
15.         <artifactId>mybatis-plus-boot-starter</artifactId>
16.     </dependency>
17.     <dependency>
18.         <groupId>mysql</groupId>
19.         <artifactId>mysql-connector-java</artifactId>
20.     </dependency>

复制代码

配置整理

1. spring:
2.   application.name: sharding-jdbc
3.   datasource:
4.     dynamic:
5.       primary: master0
6.       datasource:
7.         master0:
8.           url: jdbc:mysql://192.168.4.xx:3306/sharding0?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false
9.           username: root
10.           password: xxx
11.           driver-class-name: com.mysql.jdbc.Driver
12.         master1:
13.           url: jdbc:mysql://192.168.4.xx:3306/sharding1?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false
14.           username: root
15.           password: xxx
16.           driver-class-name: com.mysql.jdbc.Driver
18.   shardingsphere:
19.     datasource:
20.       names: ds0,ds1
21.       ds0:
22.         driver-class-name: com.mysql.cj.jdbc.Driver
23.         jdbc-url: jdbc:mysql://192.168.4.xx:3306/sharding0?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false
24.         username: root
25.         password: xxx
26.         type: com.zaxxer.hikari.HikariDataSource
27.       ds1:
28.         driver-class-name: com.mysql.cj.jdbc.Driver
29.         jdbc-url: jdbc:mysql://192.168.4.xx:3306/sharding1?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false
30.         username: root
31.         password: xxx
32.         type: com.zaxxer.hikari.HikariDataSource #必须个type，否则报错
33.     sharding:
34.       tables:
35.         t_order:
36.           #key-generator:
37.           #  column: id
38.           #  type: SNOWFLAKE
39.           actual-data-nodes: ds$->{0..1}.t_order_$->{0..1} #需要开发人员手动按规则建立数据表
40.           database-strategy:
41.             inline:
42.               sharding-column: id
43.               algorithm‐expression: ds$->{id % 2}
44.           table-strategy:
45.             inline:
46.               sharding-column: id
47.               algorithm‐expression: t_order_$->{id % 2}
48.     props:
49.       sql:
50.         show: true   # 日志显示SQL
52. mybatis:
53.   mapperLocations: classpath:mapper/*.xml
54.   typeAliasesPackage: com.lind.shardingjdbc.entity
55.   configuration:
56.     mapUnderscoreToCamelCase: true

复制代码

提前建立表分库和分表


测试代码整理

• 配置类
  

1. @Configuration
2. @AutoConfigureBefore({ DynamicDataSourceAutoConfiguration.class, SpringBootConfiguration.class })
3. public class DataSourceConfiguration {
5.         // 分表数据源名称
6.         private static final String SHARDING_DATA_SOURCE_NAME = "sharding";
7.         /**
8.          * shardingjdbc有四种数据源，需要根据业务注入不同的数据源
9.          *
10.          * <p>
11.          * 1. 未使用分片, 脱敏的名称(默认): shardingDataSource;
12.          * <p>
13.          * 2. 主从数据源: masterSlaveDataSource;
14.          * <p>
15.          * 3. 脱敏数据源：encryptDataSource;
16.          * <p>
17.          * 4. 影子数据源：shadowDataSource
18.          */
19.         @Lazy
20.         @Resource(name = "shardingDataSource")
21.         AbstractDataSourceAdapter shardingDataSource;
22.         // 动态数据源配置项
23.         @Autowired
24.         private DynamicDataSourceProperties properties;
26.         @Bean
27.         public DynamicDataSourceProvider dynamicDataSourceProvider() {
28.                 Map<String, DataSourceProperty> datasourceMap = properties.getDatasource();
29.                 return new AbstractDataSourceProvider() {
30.                         @Override
31.                         public Map<String, DataSource> loadDataSources() {
32.                                 Map<String, DataSource> dataSourceMap = createDataSourceMap(datasourceMap);
33.                                 // 将 shardingjdbc 管理的数据源也交给动态数据源管理
34.                                 dataSourceMap.put(SHARDING_DATA_SOURCE_NAME, shardingDataSource);
35.                                 return dataSourceMap;
36.                         }
37.                 };
38.         }
40.         /**
41.          * 将动态数据源设置为首选的 当spring存在多个数据源时, 自动注入的是首选的对象 设置为主要的数据源之后，就可以支持shardingjdbc原生的配置方式了
42.          */
43.         @Primary
44.         @Bean
45.         public DataSource dataSource(DynamicDataSourceProvider dynamicDataSourceProvider) {
46.                 DynamicRoutingDataSource dataSource = new DynamicRoutingDataSource();
47.                 dataSource.setPrimary(properties.getPrimary());
48.                 dataSource.setStrict(properties.getStrict());
49.                 dataSource.setStrategy(properties.getStrategy());
50.                 dataSource.setProvider(dynamicDataSourceProvider);
51.                 dataSource.setP6spy(properties.getP6spy());
52.                 dataSource.setSeata(properties.getSeata());
53.                 return dataSource;
54.         }
56. }

复制代码

• 实体类和mapper类
  

1. @Data
2. @TableName("t_order")
3. public class Order {
5.         @TableId(type = IdType.ASSIGN_ID)
6.         Long orderId;
8.         double amount;
10.         Integer userId;
12. }
13. @Mapper
14. public interface OrderMapper extends BaseMapper<Order> {
16. }

复制代码

• 分表的测试
  

1.     @GetMapping("insert")
2.         @DS("sharding")
3.         public ResponseEntity test() {
4.                 Order order = new Order();
5.                 order.setAmount(100);
6.                 order.setUserId(1);
7.                 orderMapper.insert(order);
8.                 return ResponseEntity.ok("success");
9.         }

复制代码

• 不进行分表的测试
  

1.     @GetMapping("insert-not-sharding")
2.         public ResponseEntity testNotSharding() {
3.                 Order order = new Order();
4.                 order.setAmount(101);
5.                 order.setUserId(2);
6.                 orderMapper.insert(order);
7.                 return ResponseEntity.ok("success");
8.         }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！