SpringBoot与shardingsphere分库分表实战_springboot集成shardingsphere 实战

---

• 修改pom.xml,引入相关组件

<java.version>1.8</java.version>

<mybatis-plus.version>3.1.1</mybatis-plus.version>

<sharding-sphere.version>4.0.0-RC2</sharding-sphere.version>

org.springframework.boot

spring-boot-starter-web

org.mybatis.spring.boot

mybatis-spring-boot-starter

2.0.1

mysql

mysql-connector-java

8.0.15

com.baomidou

mybatis-plus-boot-starter

${mybatis-plus.version}

org.apache.shardingsphere

sharding-jdbc-spring-boot-starter

${sharding-sphere.version}

org.apache.shardingsphere

sharding-jdbc-spring-namespace

${sharding-sphere.version}

org.projectlombok

lombok

true

org.springframework.boot

spring-boot-starter-test

test

org.springframework.boot

spring-boot-maven-plugin

• 配置mysql-plus

@Configuration

@MapperScan(“com.github.jianzh5.blog.mapper”)

public class MybatisPlusConfig {

/**

• 攻击 SQL 阻断解析器

*/

@Bean

public PaginationInterceptor paginationInterceptor(){

PaginationInterceptor paginationInterceptor = new PaginationInterceptor();

List sqlParserList = new ArrayList<>();

sqlParserList.add(new BlockAttackSqlParser());

paginationInterceptor.setSqlParserList(sqlParserList);

return new PaginationInterceptor();

}

/**

• SQL执行效率插件

*/

@Bean

// @Profile({“dev”,“test”})

public PerformanceInterceptor performanceInterceptor() {

return new PerformanceInterceptor();

}

}

• 编写实体类Order

@Data

@TableName(“t_order”)

public class Order {

private Long id;

private String name;

private String type;

private Date gmtCreate;

}

• 编写DAO层,OrderMapper

/**

• 订单Dao层

*/

public interface OrderMapper extends BaseMapper {

}

• 编写接口及接口实现

public interface OrderService extends IService {

}

/**

• 订单实现层

• @author jianzh5

• @date 2019/10/15 17:05

*/

@Service

public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements OrderService {

}

• 配置文件（配置说明见备注）

server.port=8080

配置ds0 和ds1两个数据源

spring.shardingsphere.datasource.names = ds0,ds1

#ds0 配置

spring.shardingsphere.datasource.ds0.type = com.zaxxer.hikari.HikariDataSource

spring.shardingsphere.datasource.ds0.driver-class-name = com.mysql.cj.jdbc.Driver

spring.shardingsphere.datasource.ds0.jdbc-url = jdbc:mysql://192.168.249.129:3306/blog?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false

spring.shardingsphere.datasource.ds0.username = root

spring.shardingsphere.datasource.ds0.password = 000000

#ds1 配置

spring.shardingsphere.datasource.ds1.type = com.zaxxer.hikari.HikariDataSource

spring.shardingsphere.datasource.ds1.driver-class-name = com.mysql.cj.jdbc.Driver

spring.shardingsphere.datasource.ds1.jdbc-url = jdbc:mysql://192.168.249.131:3306/blog?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false

spring.shardingsphere.datasource.ds1.username = root

spring.shardingsphere.datasource.ds1.password = 000000

分库策略 根据id取模确定数据进哪个数据库

spring.shardingsphere.sharding.default-database-strategy.inline.sharding-column = id

spring.shardingsphere.sharding.default-database-strategy.inline.algorithm-expression = ds$->{id % 2}

具体分表策略

节点 ds0.t_order_0,ds0.t_order_1,ds1.t_order_0,ds1.t_order_1

spring.shardingsphere.sharding.tables.t_order.actual-data-nodes = dsKaTeX parse error: Expected group after '_' at position 17: …>{0..1}.t_order_̲->{0…2}

分表字段id

spring.shardingsphere.sharding.tables.t_order.table-strategy.inline.sharding-column = id

分表策略 根据id取模,确定数据最终落在那个表中

spring.shardingsphere.sharding.tables.t_order.table-strategy.inline.algorithm-expression = t_order_$->{id % 3}

使用SNOWFLAKE算法生成主键

spring.shardingsphere.sharding.tables.t_order.key-generator.column = id

spring.shardingsphere.sharding.tables.t_order.key-generator.type = SNOWFLAKE

#spring.shardingsphere.sharding.binding-tables=t_order

spring.shardingsphere.props.sql.show = true

自我介绍一下，小编13年上海交大毕业，曾经在小公司待过，也去过华为、OPPO等大厂，18年进入阿里一直到现在。

深知大多数Java工程师，想要提升技能，往往是自己摸索成长或者是报班学习，但对于培训机构动则几千的学费，着实压力不小。自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！

因此收集整理了一份《2024年Java开发全套学习资料》，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友，同时减轻大家的负担。

既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，基本涵盖了95%以上Java开发知识点，真正体系化！

由于文件比较大，这里只是将部分目录截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频，并且会持续更新！

如果你觉得这些内容对你有帮助，可以扫码获取！！（备注Java获取）

最后

一次偶然，从朋友那里得到一份“java高分面试指南”，里面涵盖了25个分类的面试题以及详细的解析：JavaOOP、Java集合/泛型、Java中的IO与NIO、Java反射、Java序列化、Java注解、多线程&并发、JVM、Mysql、Redis、Memcached、MongoDB、Spring、Spring Boot、Spring Cloud、RabbitMQ、Dubbo 、MyBatis 、ZooKeeper 、数据结构、算法、Elasticsearch 、Kafka 、微服务、Linux。

这不，马上就要到招聘季了，很多朋友又开始准备“金三银四”的春招啦，那我想这份“java高分面试指南”应该起到不小的作用，所以今天想给大家分享一下。

请注意：关于这份“java高分面试指南”，每一个方向专题（25个）的题目这里几乎都会列举，在不看答案的情况下，大家可以自行测试一下水平 且由于篇幅原因，这边无法展示所有完整的答案解析
《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取！
oud、RabbitMQ、Dubbo 、MyBatis 、ZooKeeper 、数据结构、算法、Elasticsearch 、Kafka 、微服务、Linux。

这不，马上就要到招聘季了，很多朋友又开始准备“金三银四”的春招啦，那我想这份“java高分面试指南”应该起到不小的作用，所以今天想给大家分享一下。

[外链图片转存中…(img-SeAXKSe4-1713404370515)]

请注意：关于这份“java高分面试指南”，每一个方向专题（25个）的题目这里几乎都会列举，在不看答案的情况下，大家可以自行测试一下水平 且由于篇幅原因，这边无法展示所有完整的答案解析
《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取！