— 步骤2：创建Maven项目
# 创建项目结构
mkdir -p shardingsphere-jdbc-demo/src/main/java/com/fgedu
mkdir -p shardingsphere-jdbc-demo/src/main/resources

— 步骤3：配置pom.xml

4.0.0
com.fgedu
shardingsphere-jdbc-demo
1.0-SNAPSHOT


org.apache.shardingsphere
shardingsphere-jdbc-core
5.4.0


com.yashandb
yashandb-jdbc
8.0.0


com.zaxxer
HikariCP
3.4.5

— 步骤4：配置分片规则
# 创建application.yml
# src/main/resources/application.yml
spring:
shardingsphere:
datasource:
names: ds0, ds1
ds0:
type: com.zaxxer.hikari.HikariDataSource
driver-class-name: com.yashandb.jdbc.Driver
jdbc-url: jdbc:yashandb://fgedu.net.cn:1521/fgedudb01
username: fgedu
password: fgedu
ds1:
type: com.zaxxer.hikari.HikariDataSource
driver-class-name: com.yashandb.jdbc.Driver
jdbc-url: jdbc:yashandb://fgedu.net.cn:1521/fgedudb02
username: fgedu
password: fgedu
rules:
sharding:
tables:
fgedu_order:
actual-data-nodes: ds${0..1}.fgedu_order_${0..1}
table-strategy:
inline:
sharding-column: order_id
algorithm-expression: fgedu_order_${order_id % 2}
database-strategy:
inline:
sharding-column: user_id
algorithm-expression: ds${user_id % 2}

— 步骤5：编写测试代码
// src/main/java/com/fgedu/ShardingSphereDemo.java
import org.apache.shardingsphere.driver.api.ShardingSphereDataSourceFactory;
import org.apache.shardingsphere.infra.config.algorithm.ShardingSphereAlgorithmConfiguration;
import org.apache.shardingsphere.sharding.api.config.ShardingRuleConfiguration;
import org.apache.shardingsphere.sharding.api.config.rule.ShardingTableRuleConfiguration;
import org.apache.shardingsphere.sharding.api.config.strategy.sharding.InlineShardingStrategyConfiguration;

import javax.sql.DataSource;
import java.io.File;
import java.io.IOException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import java.util.Properties;

public class ShardingSphereDemo {
public static void main(String[] args) throws IOException, SQLException {
// 加载配置文件
File yamlFile = new File(“src/main/resources/application.yml”);
DataSource dataSource = ShardingSphereDataSourceFactory.createDataSource(yamlFile);

// 测试插入
try (Connection conn = dataSource.getConnection();
PreparedStatement ps = conn.prepareStatement(“INSERT INTO fgedu_order (order_id, user_id, amount) VALUES (?, ?, ?)”);
ResultSet rs = ps.executeQuery()) {
for (int i = 1; i <= 10; i++) { ps.setLong(1, i); ps.setLong(2, i % 2 + 1); ps.setBigDecimal(3, new java.math.BigDecimal(i * 100)); ps.executeUpdate(); } } // 测试查询 try (Connection conn = dataSource.getConnection(); PreparedStatement ps = conn.prepareStatement("SELECT * FROM fgedu_order"); ResultSet rs = ps.executeQuery()) { while (rs.next()) { System.out.println("order_id: " + rs.getLong("order_id") + ", user_id: " + rs.getLong("user_id") + ", amount: " + rs.getBigDecimal("amount")); } } dataSource.close(); } } -- 步骤6：编译和运行 # 编译项目 mvn clean package # 运行项目 java -jar target/shardingsphere-jdbc-demo-1.0-SNAPSHOT.jar -- 输出结果 order_id: 1, user_id: 1, amount: 100 order_id: 2, user_id: 2, amount: 200 order_id: 3, user_id: 1, amount: 300 order_id: 4, user_id: 2, amount: 400 order_id: 5, user_id: 1, amount: 500 order_id: 6, user_id: 2, amount: 600 order_id: 7, user_id: 1, amount: 700 order_id: 8, user_id: 2, amount: 800 order_id: 9, user_id: 1, amount: 900 order_id: 10, user_id: 2, amount: 1000

— 步骤2：配置ShardingSphere-Proxy
# 解压ShardingSphere-Proxy
tar -zxvf apache-shardingsphere-5.4.0-shardingsphere-proxy-bin.tar.gz
cd apache-shardingsphere-5.4.0-shardingsphere-proxy-bin

# 复制YashanDB驱动到lib目录
cp /path/to/yashandb-jdbc-8.0.0.jar lib/

# 配置config-sharding.yaml
# vi conf/config-sharding.yaml
dataSources:
ds0:
dataSourceClassName: com.zaxxer.hikari.HikariDataSource
driverClassName: com.yashandb.jdbc.Driver
jdbcUrl: jdbc:yashandb://fgedu.net.cn:1521/fgedudb01
username: fgedu
password: fgedu
ds1:
dataSourceClassName: com.zaxxer.hikari.HikariDataSource
driverClassName: com.yashandb.jdbc.Driver
jdbcUrl: jdbc:yashandb://fgedu.net.cn:1521/fgedudb02
username: fgedu
password: fgedu

rules:
– !SHARDING
tables:
fgedu_order:
actualDataNodes: ds${0..1}.fgedu_order_${0..1}
tableStrategy:
inline:
shardingColumn: order_id
algorithmExpression: fgedu_order_${order_id % 2}
databaseStrategy:
inline:
shardingColumn: user_id
algorithmExpression: ds${user_id % 2}
bindingTables:
– fgedu_order

— 步骤3：启动ShardingSphere-Proxy
# 启动服务
./bin/start.sh

— 步骤4：连接ShardingSphere-Proxy
# 使用MySQL客户端连接
mysql -h localhost -P 3307 -u root -p

— 步骤5：创建数据库和表
mysql> CREATE DATABASE sharding_db;
mysql> USE sharding_db;
mysql> CREATE TABLE fgedu_order (
-> order_id BIGINT PRIMARY KEY,
-> user_id BIGINT,
-> amount DECIMAL(10, 2)
-> );

— 步骤6：插入数据
mysql> INSERT INTO fgedu_order (order_id, user_id, amount) VALUES (1, 1, 100);
mysql> INSERT INTO fgedu_order (order_id, user_id, amount) VALUES (2, 2, 200);
mysql> INSERT INTO fgedu_order (order_id, user_id, amount) VALUES (3, 1, 300);
mysql> INSERT INTO fgedu_order (order_id, user_id, amount) VALUES (4, 2, 400);

— 步骤7：查询数据
mysql> SELECT * FROM fgedu_order;

— 输出结果
+———+———+——–+
| order_id | user_id | amount |
+———+———+——–+
| 1 | 1 | 100.00 |
| 2 | 2 | 200.00 |
| 3 | 1 | 300.00 |
| 4 | 2 | 400.00 |
+———+———+——–+

— 步骤8：验证分片效果
# 连接到实际的YashanDB实例
# 连接ds0 (fgedudb01)
sqlplus fgedu/fgedu@fgedu.net.cn:1521/fgedudb01

SQL> SELECT * FROM fgedu_order_1;

— 输出结果
ORDER_ID USER_ID AMOUNT
———- ———- ———-
1 1 100
3 1 300

# 连接ds1 (fgedudb02)
sqlplus fgedu/fgedu@fgedu.net.cn:1521/fgedudb02

SQL> SELECT * FROM fgedu_order_0;

— 输出结果
ORDER_ID USER_ID AMOUNT
———- ———- ———-
2 2 200
4 2 400

— 步骤2：安装ShardingSphere-Operator
# 添加Helm仓库
helm repo add shardingsphere https://shardingsphere.apache.org/charts
helm repo update

# 安装ShardingSphere-Operator
helm install shardingsphere-operator shardingsphere/shardingsphere-operator

— 步骤3：创建ShardingSphereProxy资源
# 创建shardingsphere-proxy.yaml
# vi shardingsphere-proxy.yaml
apiVersion: shardingsphere.apache.org/v1alpha1
kind: ShardingSphereProxy
metadata:
name: shardingsphere-proxy
namespace: default
spec:
replicas: 2
image: apache/shardingsphere-proxy:5.4.0
port:
mysql: 3307
postgresql: 5432
config:
server:
authentication:
users:
root:
password: root
sharding:
password: sharding
authorizedSchemas: sharding_db
storage:
type: memory
rules:
– name: sharding
config:
tables:
fgedu_order:
actualDataNodes: ds${0..1}.fgedu_order_${0..1}
tableStrategy:
inline:
shardingColumn: order_id
algorithmExpression: fgedu_order_${order_id % 2}
databaseStrategy:
inline:
shardingColumn: user_id
algorithmExpression: ds${user_id % 2}
dataSources:
ds0:
dataSourceClassName: com.zaxxer.hikari.HikariDataSource
driverClassName: com.yashandb.jdbc.Driver
jdbcUrl: jdbc:yashandb://fgedu.net.cn:1521/fgedudb01
username: fgedu
password: fgedu
ds1:
dataSourceClassName: com.zaxxer.hikari.HikariDataSource
driverClassName: com.yashandb.jdbc.Driver
jdbcUrl: jdbc:yashandb://fgedu.net.cn:1521/fgedudb02
username: fgedu
password: fgedu

— 步骤4：应用配置
# 应用ShardingSphereProxy资源
kubectl apply -f shardingsphere-proxy.yaml

— 步骤5：查看部署状态
# 查看Pod状态
kubectl get pods

— 输出结果
NAME READY STATUS RESTARTS AGE
shardingsphere-proxy-7f9d5f7c9d-4k2x6 1/1 Running 0 5m
shardingsphere-proxy-7f9d5f7c9d-8x7z9 1/1 Running 0 5m

— 步骤6：连接ShardingSphere-Proxy
# 端口转发
kubectl port-forward service/shardingsphere-proxy 3307:3307

# 连接ShardingSphere-Proxy
mysql -h localhost -P 3307 -u root -p

— 步骤7：测试功能
# 参考4.2节的测试步骤