Sharding-JDBC：数据库分库分表界的王者

后端

2023-03-21 19:07:19

Sharding-JDBC：轻松实现数据库分库分表的利器

分库分表的必要性

随着互联网的蓬勃发展，数据量正以前所未有的速度增长。传统的单机数据库难以承载海量数据的存储和处理需求。数据库分库分表技术 应运而生，它通过将数据分布在多个数据库实例上，有效提升数据库的性能和可扩展性。

Sharding-JDBC 简介

Sharding-JDBC 是一款开源的数据库中间件，它可以轻松实现数据库的分库分表。Sharding-JDBC 具有以下特点：

高性能： 采用异步非阻塞的方式进行数据分片，性能极佳。
数据一致性： 通过两阶段提交协议保证数据的一致性。
高可用： 支持主从复制，具有很高的可用性。

Sharding-JDBC 使用入门

添加 Sharding-JDBC 依赖

<dependency>
    <groupId>org.apache.shardingsphere</groupId>
    <artifactId>sharding-jdbc-core</artifactId>
    <version>5.1.0</version>
</dependency>

配置 Sharding-JDBC

# 数据源配置
spring.shardingsphere.datasource.names=ds0,ds1
spring.shardingsphere.datasource.ds0.type=com.zaxxer.hikari.HikariDataSource
spring.shardingsphere.datasource.ds0.driver-class-name=com.mysql.jdbc.Driver
spring.shardingsphere.datasource.ds0.url=jdbc:mysql://localhost:3306/ds0
spring.shardingsphere.datasource.ds0.username=root
spring.shardingsphere.datasource.ds0.password=123456
spring.shardingsphere.datasource.ds1.type=com.zaxxer.hikari.HikariDataSource
spring.shardingsphere.datasource.ds1.driver-class-name=com.mysql.jdbc.Driver
spring.shardingsphere.datasource.ds1.url=jdbc:mysql://localhost:3306/ds1
spring.shardingsphere.datasource.ds1.username=root
spring.shardingsphere.datasource.ds1.password=123456

# 分库分表规则配置
spring.shardingsphere.sharding.default-database-strategy.inline.sharding-column=user_id
spring.shardingsphere.sharding.default-database-strategy.inline.algorithm-expression=ds$->{user_id % 2}
spring.shardingsphere.sharding.default-table-strategy.inline.sharding-column=order_id
spring.shardingsphere.sharding.default-table-strategy.inline.algorithm-expression=t_order_$->{order_id % 2}

使用 Sharding-JDBC

@Autowired
private JdbcTemplate jdbcTemplate;

public void test() {
    // 插入数据
    String sql = "INSERT INTO t_order (order_id, user_id, order_amount) VALUES (1, 1, 100)";
    jdbcTemplate.execute(sql);

    // 查询数据
    sql = "SELECT * FROM t_order WHERE order_id = 1";
    List<Map<String, Object>> result = jdbcTemplate.queryForList(sql);
    System.out.println(result);
}