189 8069 5689
spring boot+mybatis-plus怎样使用shardingsphere分库分表，相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。
创新互联是一家集网站建设,锡林浩特企业网站建设,锡林浩特品牌网站建设,网站定制,锡林浩特网站建设报价,网络营销,网络优化,锡林浩特网站推广为一体的创新建站企业，帮助传统企业提升企业形象加强企业竞争力。可充分满足这一群体相比中小企业更为丰富、高端、多元的互联网需求。同时我们时刻保持专业、时尚、前沿，时刻以成就客户成长自我，坚持不断学习、思考、沉淀、净化自己，让我们为更多的企业打造出实用型网站。
一.关于
效果预览：
ShardingSphere是一个数据库中间件，可以实现分库分表、读写分离等，详见官网： https://shardingsphere.apache.org/
这里使用spring boot+mybatis-plus的方式来搭建demo。
二.项目搭建
使用vscode(java开发环境可以百度一下)新建一个spring boot项目，引入lombok、mybatis-plus等：
11 4.1.1 org.springframework.boot spring-boot-starter-web org.mybatis.spring.boot mybatis-spring-boot-starter 2.1.3 org.springframework.boot spring-boot-devtools runtime true MySQL mysql-connector-java runtime com.baomidou mybatis-plus-boot-starter 3.3.1 org.projectlombok lombok org.apache.shardingsphere sharding-jdbc-spring-boot-starter ${sharding-sphere.version} org.apache.shardingsphere sharding-jdbc-spring-namespace ${sharding-sphere.version} com.alibaba druid 1.1.22 org.antlr antlr4-runtime 4.7.2
项目结构：
application.yml配置：
spring:
shardingsphere:
datasource:
names: ds0,ds1
ds0:
type: com.alibaba.druid.pool.DruidDataSource
driverClassName: com.mysql.jdbc.Driver
url: jdbc:mysql://localhost:3306/ds0?useUnicode=true&characterEncoding=utf8&tinyInt1isBit=false&useSSL=false&serverTimezone=GMT
username: root
password: 123456
ds1:
type: com.alibaba.druid.pool.DruidDataSource
driverClassName: com.mysql.jdbc.Driver
url: jdbc:mysql://localhost:3306/ds1?useUnicode=true&characterEncoding=utf8&tinyInt1isBit=false&useSSL=false&serverTimezone=GMT
username: root
password: 123456
sharding:
tables:
t_order:
actualDataNodes: ds${0..1}.t_order_${0..1}
databaseStrategy:
inline:
shardingColumn: user_id
algorithmExpression: ds${user_id % 2}
tableStrategy:
inline:
shardingColumn: order_id
algorithmExpression: t_order_${order_id % 2}
keyGenerator:
type: SNOWFLAKE
column: order_id
t_order_item:
actualDataNodes: ds${0..1}.t_order_item_${0..1}
databaseStrategy:
inline:
shardingColumn: user_id
algorithmExpression: ds${user_id % 2}
tableStrategy:
inline:
shardingColumn: order_id
algorithmExpression: t_order_item_${order_id % 2}
binding-tables: t_order,t_order_item
broadcast-tables: t_config
defaultDataSourceName: ds0
defaultTableStrategy:
none:
defaultKeyGenerator:
type: SNOWFLAKE
column: order_id
props:
sql.shwo: truedb：分别建ds0和ds1库，并分别建t_order_0、t_order_1和t_order_item_0、t_order_item_1
# Host: localhost (Version 5.7.17) # Date: 2020-08-23 12:31:22 # Generator: MySQL-Front 6.0 (Build 2.29) # # Structure for table "t_order_0" # CREATE TABLE `t_order_0` ( `order_id` bigint(11) NOT NULL DEFAULT '0', `user_id` bigint(1) DEFAULT NULL, `amount` decimal(18,2) DEFAULT NULL, `discount` decimal(10,2) DEFAULT NULL, `create_time` datetime DEFAULT NULL, PRIMARY KEY (`order_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; # # Structure for table "t_order_item_0" # CREATE TABLE `t_order_item_0` ( `order_id` bigint(11) NOT NULL DEFAULT '0', `product_id` bigint(11) DEFAULT NULL, `product_name` varchar(255) DEFAULT NULL, `price` decimal(10,2) DEFAULT NULL, `discount` decimal(10,2) DEFAULT NULL, `count` int(11) DEFAULT NULL, PRIMARY KEY (`order_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
entity：
Order.java
@Data
@TableName("t_order")
public class Order extends Model {
/**
*
*/
private static final long serialVersionUID = 1L;
private Long orderId;
private Long userId;
private BigDecimal amount;
private BigDecimal discount;
private LocalDateTime createTime;
public Order(){}
public Order(Long orderId,Long userId,BigDecimal amount,BigDecimal discount,LocalDateTime createTime){
this.orderId=orderId;
this.userId=userId;
this.amount=amount;
this.discount=discount;
this.createTime=createTime;
}
} OrderItem.java
@Data
@TableName("t_order_item")
public class OrderItem extends Model {
private Long orderId;
private Long productId;
private String productName;
private BigDecimal price;
private BigDecimal discount;
@TableField("`count`")
private int count;
public OrderItem(){}
public OrderItem(Long orderId,Long productId,String productName,BigDecimal price,BigDecimal discount,int count){
this.orderId=orderId;
this.productId=productId;
this.productName=productName;
this.price=price;
this.discount=discount;
this.count=count;
}
} mapper:
OrderMapper.java
public interface OrderMapper extends BaseMapper{ }
OrderItemMapper.java
public interface OrderItemMapper extends BaseMapper{ }
service:
OrderService.java
public interface OrderService extends IService{ boolean save(Order order,List items); }
OrderServiceImpl.java
