背景信息

ShardingSphere-JDBC 支持所有的数据库 JDBC 驱动和连接池。

本节将介绍,通过 JAVA API 的方式配置数据源。

操作步骤

1. 引入 Maven 依赖

  1. <dependency>
  2. <groupId>org.apache.shardingsphere</groupId>
  3. <artifactId>shardingsphere-jdbc-core</artifactId>
  4. <version>${latest.release.version}</version>
  5. </dependency>

注意:请将 ${latest.release.version} 更改为实际的版本号。

配置示例

  1. ModeConfiguration modeConfig = // 构建运行模式
  2. Map<String, DataSource> dataSourceMap = createDataSources();
  3. Collection<RuleConfiguration> ruleConfigs = ... // 构建具体规则
  4. Properties props = ... // 构建属性配置
  5. DataSource dataSource = ShardingSphereDataSourceFactory.createDataSource(databaseName, modeConfig, dataSourceMap, ruleConfigs, props);
  6. private Map<String, DataSource> createDataSources() {
  7. Map<String, DataSource> dataSourceMap = new HashMap<>();
  8. // 配置第 1 个数据源
  9. HikariDataSource dataSource1 = new HikariDataSource();
  10. dataSource1.setDriverClassName("com.mysql.jdbc.Driver");
  11. dataSource1.setJdbcUrl("jdbc:mysql://localhost:3306/ds_1");
  12. dataSource1.setUsername("root");
  13. dataSource1.setPassword("");
  14. dataSourceMap.put("ds_1", dataSource1);
  15. // 配置第 2 个数据源
  16. HikariDataSource dataSource2 = new HikariDataSource();
  17. dataSource2.setDriverClassName("com.mysql.jdbc.Driver");
  18. dataSource2.setJdbcUrl("jdbc:mysql://localhost:3306/ds_2");
  19. dataSource2.setUsername("root");
  20. dataSource2.setPassword("");
  21. dataSourceMap.put("ds_2", dataSource2);
  22. }