qidao123.com技术社区-IT企服评测·应用市场

标题: springboot~对应sharding-jdbc实现分库分表 [打印本页]
作者: 雁过留声    时间: 2023-5-24 11:52
标题: springboot~对应sharding-jdbc实现分库分表
原因

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

为了不影响其它小容量的表，所有添加了动态数据源，只对需要分库分表的进行配置即可
  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. }
复制代码
  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.         }
复制代码
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！



欢迎光临 qidao123.com技术社区-IT企服评测·应用市场 (https://dis.qidao123.com/) Powered by Discuz! X3.4