ShardingSphere简单实现 shardingjdbc分页查询

一：pom.xml相关引用

 org.springframework.boot spring-boot-starter-parent 2.1.3.RELEASE  4.0.0 lab-18-sharding-datasource-01  org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-thymeleaf org.webjars jquery 3.4.1  org.springframework.boot spring-boot-starter-jdbc  mysql mysql-connector-java 5.1.48  org.mybatis.spring.boot mybatis-spring-boot-starter 2.1.1  org.apache.shardingsphere sharding-jdbc-spring-boot-starter 4.0.0-RC2  org.springframework spring-aspects  org.springframework.boot spring-boot-starter-test test 

二:启动类Application

@SpringBootApplication@MapperScan(basePackages = "cn.iocoder.springboot.lab18.shardingdatasource.mapper")public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); }}

三：yaml配置

server: port: 8126spring: # ShardingSphere 配置项 shardingsphere: datasource: # 所有数据源的名字 names: ds-orders-0, ds-orders-1 # 订单 orders 数据源配置 00 ds-orders-0: type: com.zaxxer.hikari.HikariDataSource # 使用 Hikari 数据库连接池 driver-class-name: com.mysql.jdbc.Driver jdbc-url: jdbc:mysql://127.0.0.1:3310/lab18_orders_0?useSSL=false&useUnicode=true&characterEncoding=UTF-8 username: root password: root # 订单 orders 数据源配置 01 ds-orders-1: type: com.zaxxer.hikari.HikariDataSource # 使用 Hikari 数据库连接池 driver-class-name: com.mysql.jdbc.Driver jdbc-url: jdbc:mysql://127.0.0.1:3310/lab18_orders_1?useSSL=false&useUnicode=true&characterEncoding=UTF-8 username: root password: root # 分片规则 sharding: tables: # orders 表配置 orders:# actualDataNodes: ds-orders-$->{0..1}.orders_$->{0..4} # 映射到 ds-orders 数据源的 orders 表# actualDataNodes: ds-orders-0.orders_0, ds-orders-0.orders_2, ds-orders-0.orders_4, ds-orders-0.orders_6, ds-orders-1.orders_1, ds-orders-1.orders_3, ds-orders-1.orders_5, ds-orders-1.orders_7 actualDataNodes: ds-orders-0.orders_$->{[0,2,4,6]}, ds-orders-1.orders_$->{[1,3,5,7]} # 映射到 ds-orders-0 和 ds-orders-1 数据源的 orders 表们 key-generator: # 主键生成策略 column: id type: SNOWFLAKE database-strategy: inline: algorithm-expression: ds-orders-$->{user_id % 2} sharding-column: user_id table-strategy: inline: algorithm-expression: orders_$->{user_id % 8} sharding-column: user_id # order_config 表配置 order_config: actualDataNodes: ds-orders-0.order_config # 仅映射到 ds-orders-0 数据源的 order_config 表 # 拓展属性配置 props: sql: show: true # 打印 SQL# mybatis 配置内容mybatis: config-location: classpath:mybatis-config.xml # 配置 MyBatis 配置文件路径 mapper-locations: classpath:mapperpublic class OrderDO { private Long id; private Integer userId; public Long getId() { return id; } public OrderDO setId(Long id) { this.id = id; return this; } public Integer getUserId() { return userId; } public OrderDO setUserId(Integer userId) { this.userId = userId; return this; } @Override public String toString() { return "OrderDO{" + "id=" + id + ", userId=" + userId + '}'; }}

在 lab18_orders_0 数据库下，创建 orders_0、orders_2、orders_4、orders_6 数据表。SQL 如下：

SET NAMES utf8mb4;SET FOREIGN_KEY_CHECKS = 0;-- ------------------------------ Table structure for orders_0-- ----------------------------DROp TABLE IF EXISTS `orders_0`;CREATE TABLE `orders_0` ( `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '订单编号', `user_id` int(16) DEFAULT NULL COMMENT '用户编号', PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单表';-- ------------------------------ Table structure for orders_2-- ----------------------------DROP TABLE IF EXISTS `orders_2`;CREATE TABLE `orders_2` ( `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '订单编号', `user_id` int(16) DEFAULT NULL COMMENT '用户编号', PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单表';-- ------------------------------ Table structure for orders_4-- ----------------------------DROP TABLE IF EXISTS `orders_4`;CREATE TABLE `orders_4` ( `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '订单编号', `user_id` int(16) DEFAULT NULL COMMENT '用户编号', PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单表';-- ------------------------------ Table structure for orders_6-- ----------------------------DROP TABLE IF EXISTS `orders_6`;CREATE TABLE `orders_6` ( `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '订单编号', `user_id` int(16) DEFAULT NULL COMMENT '用户编号', PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单表';SET FOREIGN_KEY_CHECKS = 1;

在 lab18_orders_1 数据库下，创建 orders_1、orders_3、orders_5、orders_7 数据表。SQL 如下：

SET NAMES utf8mb4;SET FOREIGN_KEY_CHECKS = 0;-- ------------------------------ Table structure for orders_1-- ----------------------------DROP TABLE IF EXISTS `orders_1`;CREATE TABLE `orders_1` ( `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '订单编号', `user_id` int(16) DEFAULT NULL COMMENT '用户编号', PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=400675304294580226 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单表';-- ------------------------------ Table structure for orders_3-- ----------------------------DROP TABLE IF EXISTS `orders_3`;CREATE TABLE `orders_3` ( `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '订单编号', `user_id` int(16) DEFAULT NULL COMMENT '用户编号', PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单表';-- ------------------------------ Table structure for orders_5-- ----------------------------DROP TABLE IF EXISTS `orders_5`;CREATE TABLE `orders_5` ( `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '订单编号', `user_id` int(16) DEFAULT NULL COMMENT '用户编号', PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单表';-- ------------------------------ Table structure for orders_7-- ----------------------------DROP TABLE IF EXISTS `orders_7`;CREATE TABLE `orders_7` ( `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '订单编号', `user_id` int(16) DEFAULT NULL COMMENT '用户编号', PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单表';SET FOREIGN_KEY_CHECKS = 1;

五.二：OrderConfigDO

// OrderConfigDO.javapublic class OrderConfigDO { private Integer id; private Integer payTimeout; // ... 省略 setting/getting 方法}

在 lab18_orders_0 数据库下，创建 orders_0 数据表。SQL 如下：

-- ------------------------------ Table structure for order_config-- ----------------------------DROP TABLE IF EXISTS `order_config`;CREATE TABLE `order_config` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '编号', `pay_timeout` int(11) DEFAULT NULL COMMENT '支付超时时间;单位：分钟', PRIMARY KEY (`id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单配置表';

六：Mapper
六.一:OrderMapper

// OrderMapper.java@Repositorypublic interface OrderMapper { OrderDO selectById(@Param("id") Integer id); List selectListByUserId(@Param("userId") Integer userId); void insert(OrderDO order);}

六.二:OrderMapper.xml

 id, user_id SELECT FROM orders WHERe id = #{id} SELECT FROM orders WHERe user_id = #{userId} INSERT INTO orders ( user_id ) VALUES ( #{userId} ) 

六.三：OrderConfigMapper

// OrderConfigMapper.java@Repositorypublic interface OrderConfigMapper { OrderConfigDO selectById(@Param("id") Integer id);}

六.四OrderConfigMapper.xml

 id, pay_timeout SELECT FROM order_config WHERe id = #{id} 

总结：

• 在 mybatis 配置项下，设置 mybatis-spring-boot-starter 自动化配置 MyBatis 需要的参数。
• 在 spring.shardingsphere 配置项下，设置 sharding-jdbc-spring-boot-starter 自动化配置 Sharding-JDBC 需要的参数。比较复杂，我们一个一个来看。

spring.shardingsphere.datasource 配置项，我们配置了 ds-orders-0 和 ds-orders-1 两个数据源，分别对应 lab18_orders_0 和 lab18_orders_1 两个数据库。

spring.shardingsphere.sharding 配置项，我们配置了 orders 和 order_config 逻辑表 。

逻辑表 ：水平拆分的数据库（表）的相同逻辑和数据结构表的总称。例：订单数据根据主键尾数拆分为 10 张表，分别是 t_order_0 到 t_order_9 ，他们的逻辑表名为 t_order 。

真实表 ：在分片的数据库中真实存在的物理表。即上个示例中的 t_order_0 到 t_order_9 。

数据节点 ：数据分片的最小单元。由数据源名称和数据表组成，例：ds_0.t_order_0 。

• orders 配置项，设置 orders 逻辑表，使用分库分表的规则。
  • actualDataNodes ：对应的数据节点，使用的是行表达式 。这里的意思是，ds-orders-0.orders_0, ds-orders-0.orders_2, ds-orders-0.orders_4, ds-orders-0.orders_6, ds-orders-1.orders_1, ds-orders-1.orders_3, ds-orders-1.orders_5, ds-orders-1.orders_7 。
  • key-generator ：主键生成策略。这里采用分布式主键 SNOWFLAKE 方案。更多可以看  概念 & 功能 > 数据分片 > 其他功能 > 分布式主键》”>《 ShardingSphere > 概念 & 功能 > 数据分片 > 其他功能 > 分布式主键》 文档。
  • database-strategy ：按照 index = user_id % 2 分库，路由到 ds-orders-${index} 数据源（库）。
  • table-strategy ：index = user_id % 8 分表，路由到 orders_${index} 数据表。
• order_config 配置项，设置 order_config 逻辑表，不使用分库分表。
  • actualDataNodes ：对应的数据节点，只对应数据源（库）为 ds-orders-0 的 order_config 表。

spring.shardingsphere.props 配置项，设置拓展属性配置。

• sql.show ：设置打印 SQL 。因为我们编写的 SQL 会被 Sharding-JDBC 进行处理，实际执行的可能不是我们编写的，通过打印，方便我们观察和理解。

整体结构：