ShardingSphere 是一款由阿里巴巴开源的强大的分布式数据库中间件。它提供了数据分片、分布式事务和数据库治理等功能。
以下是一个简单的示例，展示如何使用 ShardingSphere 进行数据分片。
- 添加 Maven 依赖：
<dependency>
<groupId>org.apache.shardingsphere</groupId>
<artifactId>shardingsphere-jdbc-core-spring-boot-starter</artifactId>
<version>您的ShardingSphere版本</version>
</dependency>- 配置
application.yml：
spring:
shardingsphere:
datasource:
names: ds0,ds1
ds0:
url: jdbc:mysql://localhost:3306/ds0
username: root
password:
type: com.zaxxer.hikari.HikariDataSource
ds1:
url: jdbc:mysql://localhost:3306/ds1
username: root
password:
type: com.zaxxer.hikari.HikariDataSource
sharding:
tables:
t_order:
actualDataNodes: ds${0..1}.t_order_${0..1}
databaseStrategy:
standard:
shardingColumn: user_id
shardingAlgorithmName: table-inline
tableStrategy:
inline:
sharding-algorithm-name: table-inline
shardingAlgorithms:
table-inline:
type: INLINE
props:
algorithm-expression: t_order_${user_id % 2}
props:
sql:
show: true在这个配置中，我们定义了两个数据源 ds0 和 ds1，并且配置了 t_order 表进行分片，分片键为 user_id，采用了 inline 表达式来决定数据节点。
- 使用 ShardingSphere 进行数据库操作：
@Autowired
private DataSource dataSource;
public void insertOrder() throws SQLException {
try (
Connection connection = dataSource.getConnection();
PreparedStatement preparedStatement = connection.prepareStatement("INSERT INTO t_order (user_id, order_id) VALUES (?, ?)")
) {
preparedStatement.setInt(1, 1);
preparedStatement.setInt(2, 1001);
preparedStatement.executeUpdate();
}
}在这个 Java 示例中，我们通过自动装配的 DataSource 对象获取数据库连接，并执行插入操作。ShardingSphere 会根据 user_id 的值来决定将数据插入到 ds0 还是 ds1 中的 t_order_0 或 t_order_1 表。