读写分离

不使用Spring

引入Maven依赖

  1. <dependency>
  2.     <groupId>io.shardingsphere</groupId>
  3.     <artifactId>sharding-jdbc-core</artifactId>
  4.     <version>${sharding-sphere.version}</version>
  5. </dependency>

基于Java编码的规则配置

  1.     // 配置真实数据源
  2.     Map<String, DataSource> dataSourceMap = new HashMap<>();
  4.     // 配置主库
  5.     BasicDataSource masterDataSource = new BasicDataSource();
  6.     masterDataSource.setDriverClassName("com.mysql.jdbc.Driver");
  7.     masterDataSource.setUrl("jdbc:mysql://localhost:3306/ds_master");
  8.     masterDataSource.setUsername("root");
  9.     masterDataSource.setPassword("");
  10.     dataSourceMap.put("ds_master", masterDataSource);
  12.     // 配置第一个从库
  13.     BasicDataSource slaveDataSource1 = new BasicDataSource();
  14.     slaveDataSource1.setDriverClassName("com.mysql.jdbc.Driver");
  15.     slaveDataSource1.setUrl("jdbc:mysql://localhost:3306/ds_slave0");
  16.     slaveDataSource1.setUsername("root");
  17.     slaveDataSource1.setPassword("");
  18.     dataSourceMap.put("ds_slave0", slaveDataSource1);
  20.     // 配置第二个从库
  21.     BasicDataSource slaveDataSource2 = new BasicDataSource();
  22.     slaveDataSource2.setDriverClassName("com.mysql.jdbc.Driver");
  23.     slaveDataSource2.setUrl("jdbc:mysql://localhost:3306/ds_slave1");
  24.     slaveDataSource2.setUsername("root");
  25.     slaveDataSource2.setPassword("");
  26.     dataSourceMap.put("ds_slave1", slaveDataSource2);
  28.     // 配置读写分离规则
  29.     MasterSlaveRuleConfiguration masterSlaveRuleConfig = new MasterSlaveRuleConfiguration("ds_master_slave", "ds_master", Arrays.asList("ds_slave0", "ds_slave1"));
  31.     // 获取数据源对象
  32.     DataSource dataSource = MasterSlaveDataSourceFactory.createDataSource(createDataSourceMap(), masterSlaveRuleConfig, new HashMap<String, Object>(), new Properties());

基于Yaml的规则配置

或通过Yaml方式配置，与以上配置等价：

  1. dataSources:
  2.   ds_master: !!org.apache.commons.dbcp.BasicDataSource
  3.     driverClassName: com.mysql.jdbc.Driver
  4.     url: jdbc:mysql://localhost:3306/ds_master
  5.     username: root
  6.     password: 
  7.   ds_slave0: !!org.apache.commons.dbcp.BasicDataSource
  8.     driverClassName: com.mysql.jdbc.Driver
  9.     url: jdbc:mysql://localhost:3306/ds_slave0
  10.     username: root
  11.     password:
  12.   ds_slave1: !!org.apache.commons.dbcp.BasicDataSource
  13.     driverClassName: com.mysql.jdbc.Driver
  14.     url: jdbc:mysql://localhost:3306/ds_slave1
  15.     username: root
  16.     password: 
  18. masterSlaveRule:
  19.   name: ds_ms
  20.   masterDataSourceName: ds_master
  21.   slaveDataSourceNames: [ds_slave0, ds_slave1]
  23.   props:
  24.       sql.show: true
  25.   configMap:
  26.       key1: value1
  1.     DataSource dataSource = MasterSlaveDataSourceFactory.createDataSource(yamlFile);

使用原生JDBC

通过MasterSlaveDataSourceFactory工厂和规则配置对象获取MasterSlaveDataSource，MasterSlaveDataSource实现自JDBC的标准接口DataSource。然后可通过DataSource选择使用原生JDBC开发，或者使用JPA, MyBatis等ORM工具。以JDBC原生实现为例：

  1. DataSource dataSource = MasterSlaveDataSourceFactory.createDataSource(yamlFile);
  2. String sql = "SELECT i.* FROM t_order o JOIN t_order_item i ON o.order_id=i.order_id WHERE o.user_id=? AND o.order_id=?";
  3. try (
  4.         Connection conn = dataSource.getConnection();
  5.         PreparedStatement preparedStatement = conn.prepareStatement(sql)) {
  6.     preparedStatement.setInt(1, 10);
  7.     preparedStatement.setInt(2, 1001);
  8.     try (ResultSet rs = preparedStatement.executeQuery()) {
  9.         while(rs.next()) {
  10.             System.out.println(rs.getInt(1));
  11.             System.out.println(rs.getInt(2));
  12.         }
  13.     }
  14. }

使用Spring

引入Maven依赖

  1. <!-- for spring boot -->
  2. <dependency>
  3.     <groupId>io.shardingsphere</groupId>
  4.     <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
  5.     <version>${sharding-sphere.version}</version>
  6. </dependency>
  8. <!-- for spring namespace -->
  9. <dependency>
  10.     <groupId>io.shardingsphere</groupId>
  11.     <artifactId>sharding-jdbc-spring-namespace</artifactId>
  12.     <version>${sharding-sphere.version}</version>
  13. </dependency>

基于Spring boot的规则配置

  1. sharding.jdbc.datasource.names=master,slave0,slave1
  3. sharding.jdbc.datasource.master.type=org.apache.commons.dbcp.BasicDataSource
  4. sharding.jdbc.datasource.master.driver-class-name=com.mysql.jdbc.Driver
  5. sharding.jdbc.datasource.master.url=jdbc:mysql://localhost:3306/master
  6. sharding.jdbc.datasource.master.username=root
  7. sharding.jdbc.datasource.master.password=
  9. sharding.jdbc.datasource.slave0.type=org.apache.commons.dbcp.BasicDataSource
  10. sharding.jdbc.datasource.slave0.driver-class-name=com.mysql.jdbc.Driver
  11. sharding.jdbc.datasource.slave0.url=jdbc:mysql://localhost:3306/slave0
  12. sharding.jdbc.datasource.slave0.username=root
  13. sharding.jdbc.datasource.slave0.password=
  15. sharding.jdbc.datasource.slave1.type=org.apache.commons.dbcp.BasicDataSource
  16. sharding.jdbc.datasource.slave1.driver-class-name=com.mysql.jdbc.Driver
  17. sharding.jdbc.datasource.slave1.url=jdbc:mysql://localhost:3306/slave1
  18. sharding.jdbc.datasource.slave1.username=root
  19. sharding.jdbc.datasource.slave1.password=
  21. sharding.jdbc.config.masterslave.name=ms
  22. sharding.jdbc.config.masterslave.master-data-source-name=master
  23. sharding.jdbc.config.masterslave.slave-data-source-names=slave0,slave1
  25. sharding.jdbc.config.props.sql.show=true

基于Spring命名空间的规则配置

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
  4.     xmlns:master-slave="http://shardingsphere.io/schema/shardingsphere/masterslave" 
  5.     xsi:schemaLocation="http://www.springframework.org/schema/beans 
  6.                         http://www.springframework.org/schema/beans/spring-beans.xsd
  7.                         http://shardingsphere.io/schema/shardingsphere/masterslave 
  8.                         http://shardingsphere.io/schema/shardingsphere/masterslave/master-slave.xsd 
  9.                         ">
  10.     <bean id="ds_master" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
  11.         <property name="driverClassName" value="com.mysql.jdbc.Driver" />
  12.         <property name="url" value="jdbc:mysql://localhost:3306/ds_master" />
  13.         <property name="username" value="root" />
  14.         <property name="password" value="" />
  15.     </bean>
  16.     <bean id="ds_slave0" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
  17.         <property name="driverClassName" value="com.mysql.jdbc.Driver" />
  18.         <property name="url" value="jdbc:mysql://localhost:3306/ds_slave0" />
  19.         <property name="username" value="root" />
  20.         <property name="password" value="" />
  21.     </bean>
  22.     <bean id="ds_slave1" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
  23.         <property name="driverClassName" value="com.mysql.jdbc.Driver" />
  24.         <property name="url" value="jdbc:mysql://localhost:3306/ds_slave1" />
  25.         <property name="username" value="root" />
  26.         <property name="password" value="" />
  27.     </bean>
  29.     <master-slave:data-source id="masterSlaveDataSource" master-data-source-name="ds_master" slave-data-source-names="ds_slave0, ds_slave1" >
  30.         <master-slave:props>
  31.                 <prop key="sql.show">${sql_show}</prop>
  32.                 <prop key="executor.size">10</prop>
  33.                 <prop key="foo">bar</prop>
  34.             </master-slave:props>
  35.     </master-slave:data-source>
  36. </beans>

在Spring中使用DataSource

直接通过注入的方式即可使用DataSource，或者将DataSource配置在JPA、Hibernate或MyBatis中使用。

  1. @Resource
  2. private DataSource dataSource;

更多的详细配置请参考配置手册。