以下是一个使用ShardingSphere的ShardingJDBC实现分表的简单示例。
- 在pom.xml中添加ShardingSphere的依赖：
<dependency>
<groupId>org.apache.shardingsphere</groupId>
<artifactId>sharding-jdbc-core</artifactId>
<version>您的版本号</version>
</dependency>
- 配置分片规则。在src/main/resources下创建配置文件
sharding-jdbc.yaml：
shardingRule:
tables:
t_order:
actualDataNodes: ds${0..1}.t_order_${0..1}
tableStrategy:
inline:
shardingColumn: order_id
algorithmExpression: t_order_${order_id % 2}
keyGenerator:
type: SNOWFLAKE
column: order_id
bindingTables:
- t_order,t_order_item
defaultDatabaseStrategy:
inline:
shardingColumn: user_id
algorithmExpression: ds${user_id % 2}
defaultTableStrategy:
none:
- 使用ShardingJDBC进行数据库操作：
public class ShardingJdbcExample {
public static void main(String[] args) throws SQLException {
// 配置数据源
DataSource dataSource = ShardingJdbcFactory.createDataSource("sharding-jdbc.yaml");
// 获取连接
Connection conn = dataSource.getConnection();
// 执行SQL
PreparedStatement preparedStatement = conn.prepareStatement("INSERT INTO t_order (user_id, order_id) VALUES (?, ?)");
preparedStatement.setInt(1, 10);
preparedStatement.setInt(2, 1000);
preparedStatement.executeUpdate();
// 关闭连接
preparedStatement.close();
conn.close();
}
}
在这个例子中，我们配置了基于order_id的分表策略和基于user_id的数据库分片策略。当插入一条t_order记录时，系统会根据order_id计算该记录应该存放在哪个分表中，同时会根据user_id决定该操作应该连接到哪个数据库。
这只是一个简单的示例，实际项目中可能需要更复杂的配置和逻辑。