1.简介

ShardingSphere-JDBC目前是5.0.0-alpha版本了，我这里以4.x版本演示其入门级的使用方法。此篇文章演示一个纯Java Api方式的使用Demo和整合SpringBoot的使用Demo。Demo是参考官方文档编写的。

2.基于Java Api方式的使用

ShardingSphere-JDBC的jar包版本很多，考虑到官方文档在写的时候也是基于 4.0.x版本写的文档，所以，我这里使用 4.0.1 版本（4.0版本的最后一个小升级版本）

1.依赖引入

  1.     <sharding-sphere.version>4.0.1</sharding-sphere.version>
  3.     <dependency>
  4.       <groupId>org.apache.shardingsphere</groupId>
  5.       <artifactId>sharding-jdbc-core</artifactId>
  6.       <version>${sharding-sphere.version}</version>
  7.     </dependency>
  9.     <dependency>
  10.       <groupId>mysql</groupId>
  11.       <artifactId>mysql-connector-java</artifactId>
  12.       <version>5.1.39</version>
  13.     </dependency>
  15.     <dependency>
  16.       <groupId>com.zaxxer</groupId>
  17.       <artifactId>HikariCP</artifactId>
  18.       <version>3.4.5</version>
  19.     </dependency>

2.数据库与表的准备
创建2个数据库ds0，ds1。在数据库中各创建2张表，创表语句如下：

  1. create table t_order(
  2.       user_id int(11),
  3.       order_id int(11) PRIMARY KEY    
  4. );

最后创建的结果是这样：
image.png

3.编写代码

  1. package org.example;
  3. import com.zaxxer.hikari.HikariDataSource;
  4. import org.apache.shardingsphere.api.config.sharding.ShardingRuleConfiguration;
  5. import org.apache.shardingsphere.api.config.sharding.TableRuleConfiguration;
  6. import org.apache.shardingsphere.api.config.sharding.strategy.InlineShardingStrategyConfiguration;
  7. import org.apache.shardingsphere.shardingjdbc.api.ShardingDataSourceFactory;
  9. import javax.sql.DataSource;
  10. import java.sql.Connection;
  11. import java.sql.PreparedStatement;
  12. import java.sql.SQLException;
  13. import java.util.HashMap;
  14. import java.util.Map;
  15. import java.util.Properties;
  17. /**
  18.  * Hello world!
  19.  */
  20. public class App {
  22.     public static void main(String[] args) throws SQLException {
  23.         // 配置真实数据源
  24.         Map<String, DataSource> dataSourceMap = new HashMap<>();
  26.         // 配置第一个数据源
  27.         HikariDataSource dataSource1= new HikariDataSource();
  28.         dataSource1.setDriverClassName("com.mysql.jdbc.Driver");
  29.         dataSource1.setJdbcUrl("jdbc:mysql://localhost:3306/ds0");
  30.         dataSource1.setUsername("root");
  31.         dataSource1.setPassword("888888");
  32.         dataSourceMap.put("ds0", dataSource1);
  34.         // 配置第二个数据源
  35.         HikariDataSource dataSource2 = new HikariDataSource();
  36.         dataSource2.setDriverClassName("com.mysql.jdbc.Driver");
  37.         dataSource2.setJdbcUrl("jdbc:mysql://localhost:3306/ds1");
  38.         dataSource2.setUsername("root");
  39.         dataSource2.setPassword("888888");
  40.         dataSourceMap.put("ds1", dataSource2);
  42.         // 配置Order表规则
  43.         TableRuleConfiguration orderTableRuleConfig = new TableRuleConfiguration("t_order","ds${0..1}.t_order${0..1}");
  45.         // 配置分库 + 分表策略
  46.         orderTableRuleConfig.setDatabaseShardingStrategyConfig(new InlineShardingStrategyConfiguration("user_id", "ds${user_id % 2}"));
  47.         orderTableRuleConfig.setTableShardingStrategyConfig(new InlineShardingStrategyConfiguration("order_id", "t_order${order_id % 2}"));
  49.         // 配置分片规则
  50.         ShardingRuleConfiguration shardingRuleConfig = new ShardingRuleConfiguration();
  51.         shardingRuleConfig.getTableRuleConfigs().add(orderTableRuleConfig);
  53.         // 省略配置order_item表规则...
  54.         // ...
  56.         // 获取数据源对象
  57.         DataSource dataSource = ShardingDataSourceFactory.createDataSource(dataSourceMap, shardingRuleConfig, new Properties());
  59.         Connection connection = dataSource.getConnection();
  60.         PreparedStatement preparedStatement = connection.prepareStatement("insert into t_order values(1,1),(1,2),(2,1),(2,2)");
  61.         int result = preparedStatement.executeUpdate();
  62.         System.out.println(result);
  63.     }
  64. }

4.执行结果
上面的配置是：按照userId进行分库，orderId分表。
userId%2 ==0则数据进入ds0，否则进入ds1
之后，orderId%2==0则进入t_order0,否则进入t_order1

3.