mysql读写分离，分库分表-MysqlSample.zip

package com.trj.shading.config; import org.apache.commons.dbcp.BasicDataSource; import org.apache.shardingsphere.api.config.sharding.ShardingRuleConfiguration; import org.apache.shardingsphere.api.config.sharding.TableRuleConfiguration; import org.apache.shardingsphere.api.config.sharding.strategy.InlineShardingStrategyConfiguration; import org.apache.shardingsphere.shardingjdbc.api.ShardingDataSourceFactory; import org.apache.shardingsphere.shardingjdbc.api.yaml.YamlMasterSlaveDataSourceFactory; import org.apache.shardingsphere.shardingjdbc.api.yaml.YamlShardingDataSourceFactory; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.util.ResourceUtils; import javax.sql.DataSource; import java.io.File; import java.io.IOException; import java.sql.SQLException; import java.util.HashMap; import java.util.Map; import java.util.Properties; /** * @author TRJ * @date 2019/10/11 * Description: */ @Configuration public class ShadingConfig { @Bean public DataSource dataSource() throws IOException, SQLException { File yamlFile = ResourceUtils.getFile("classpath:sharding-jdbc.yaml"); return YamlShardingDataSourceFactory.createDataSource(yamlFile); } // @Bean public DataSource dataSourceByCode() throws SQLException { // 配置真实数据源 Map<String, DataSource> dataSourceMap = new HashMap<>(5); // 配置第一个数据源 BasicDataSource dataSource1 = new BasicDataSource(); dataSource1.setDriverClassName("com.mysql.jdbc.Driver"); dataSource1.setUrl("jdbc:mysql://192.168.1.60:3306/shading0"); dataSource1.setUsername("root"); dataSource1.setPassword("19931213jie@JIE"); dataSourceMap.put("shading0", dataSource1); // 配置第二个数据源 BasicDataSource dataSource2 = new BasicDataSource(); dataSource2.setDriverClassName("com.mysql.jdbc.Driver"); dataSource2.setUrl("jdbc:mysql://192.168.1.60:3306/shading1"); dataSource2.setUsername("root"); dataSource2.setPassword("19931213jie@JIE"); dataSourceMap.put("shading1", dataSource2); // 配置Order表规则 TableRuleConfiguration orderTableRuleConfig = new TableRuleConfiguration("t_order","shading${0..1}.t_order${0..1}"); // 配置分库 + 分表策略 orderTableRuleConfig.setDatabaseShardingStrategyConfig(new InlineShardingStrategyConfiguration("user_id", "shading${user_id % 2}")); orderTableRuleConfig.setTableShardingStrategyConfig(new InlineShardingStrategyConfiguration("order_id", "t_order${order_id % 2}")); // 配置分片规则 ShardingRuleConfiguration shardingRuleConfig = new ShardingRuleConfiguration(); shardingRuleConfig.getTableRuleConfigs().add(orderTableRuleConfig); // 省略配置order_item表规则... // ... // 获取数据源对象 DataSource dataSource = ShardingDataSourceFactory.createDataSource(dataSourceMap, shardingRuleConfig, new Properties()); return dataSource; } }