ShardingSphere简单实现(shardingsphere seata)()

花匠人从多个角度为你分享ShardingSphere简单实现(shardingsphere seata)()，让你更加了解ShardingSphere简单实现(shardingsphere seata)()，包含生活百科相关的生活技巧、生活小窍门、生活小妙招等生活百科知识。

　　本篇文章为你整理了ShardingSphere简单实现(shardingsphere seata)()的详细内容，包含有ShardingSphere简单实现(shardingsphere seata) 等，让你从多个方面了解ShardingSphere简单实现(shardingsphere seata)()，希望对你有帮助。

　　一：pom.xml相关引用

<?xml version="1.0" encoding="UTF-8"?>org.springframework.boot spring-boot-starter-parent2.1.3.RELEASE4.0.0 lab-18-sharding-datasource-01org.springframework.boot spring-boot-starter-weborg.springframework.boot spring-boot-starter-thymeleaforg.webjars jquery3.4.1org.springframework.boot spring-boot-starter-jdbcmysql mysql-connector-java5.1.48org.mybatis.spring.boot mybatis-spring-boot-starter2.1.1org.apache.shardingsphere sharding-jdbc-spring-boot-starter4.0.0-RC2org.springframework spring-aspectsorg.springframework.boot spring-boot-starter-testtest

二:启动类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

<?xml version="1.0" encoding="UTF-8"?> id, user_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

<?xml version="1.0" encoding="UTF-8"?> id, pay_timeout

总结：在 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 进行处理，实际执行的可能不是我们编写的，通过打印，方便我们观察和理解。整体结构：

　　以上就是ShardingSphere简单实现(shardingsphere seata)()的全部内容，想要了解更多ShardingSphere简单实现(shardingsphere seata)()相关的内容，请持续关注我们。

以上就是花匠人为你整理的ShardingSphere简单实现(shardingsphere seata)()，如果你还想了解更多生活百科知识，请持续关注花匠人。

郑重声明：本文版权归原作者所有，转载文章仅为传播更多信息之目的，如作者信息标记有误，请第一时间联系我们修改或删除，多谢。

相关文章阅读