<dependency>
    <groupId>io.shardingsphere</groupId>
    <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
    <version>xxx</version>
</dependency>

spring:
  shardingsphere:
    datasource:
      # 數(shù)據(jù)源配置，定義兩個數(shù)據(jù)源
      names: ds0， ds1
      ds0:
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://localhost:3306/database0
        username: root
        password: root
      ds1:
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://localhost:3306/database1
        username: root
        password: root
    sharding:
      tables:
        # 訂單表的配置
        order:
          actualDataNodes: ds${0..1}.order_${0..3}
          # 表路由策略，根據(jù)用戶ID進行分表
          tableStrategy:
            standard:
              shardingColumn: user_id
              preciseAlgorithmClassName: com.example.algorithm.PreciseModuloTableShardingAlgorithm
          # 數(shù)據(jù)庫路由策略，根據(jù)用戶ID進行分庫
          databaseStrategy:
            standard:
              shardingColumn: user_id
              preciseAlgorithmClassName: com.example.algorithm.PreciseModuloDatabaseShardingAlgorithm

public class PreciseModuloTableShardingAlgorithm implements PreciseShardingAlgorithm<Long> {
    @Override
    public String doSharding(Collection<String> tableNames， PreciseShardingValue<Long> shardingValue) {
        for (String tableName : tableNames) {
            if (tableName.endsWith(String.valueOf(shardingValue.getValue() % 4))) {
                return tableName;
            }
        }
        throw new IllegalArgumentException("Unsupported table name: " + shardingValue.getLogicTableName());
    }
}

public class PreciseModuloDatabaseShardingAlgorithm implements PreciseShardingAlgorithm<Long> {
    @Override
    public String doSharding(Collection<String> databaseNames， PreciseShardingValue<Long> shardingValue) {
        for (String databaseName : databaseNames) {
            if (databaseName.endsWith(String.valueOf(shardingValue.getValue() % 2))) {
                return databaseName;
            }
        }
        throw new IllegalArgumentException("Unsupported database name: " + shardingValue.getLogicTableName());
    }
}

@Repository
public class OrderRepository {
    @Autowired
    private JdbcTemplate jdbcTemplate;
    
    public List<Order> findOrdersByUserId(Long userId) {
        String sql = "SELECT * FROM `order` WHERE user_id = ?";
        return jdbcTemplate.query(sql， new Object[]{userId}， new BeanPropertyRowMapper<>(Order.class));
    }
    
    public void saveOrder(Order order) {
        String sql = "INSERT INTO `order` (id， user_id， amount) VALUES (?， ?， ?)";
        jdbcTemplate.update(sql， order.getId()， order.getUserId()， order.getAmount());
    }
}

@Service
public class OrderService {
    @Autowired
    private OrderRepository orderRepository;
    
    public List<Order> getOrdersByUserId(Long userId) {
        return orderRepository.findOrdersByUserId(userId);
    }
    
    public void saveOrder(Order order) {
        orderRepository.saveOrder(order);
    }
}