【ShardingSphere】ShardingSphere-JDBC 读写分离

　　ShardingSphere-JDBC基本使用参考：【ShardingSphere】ShardingSphere-JDBC 快速入门

　　主从数据库搭建参考：【Mysql】主从同步配置

读写分离

　　参考官方文档：https://shardingsphere.apache.org/document/current/cn/user-manual/shardingsphere-jdbc/configuration/java-api/readwrite-splitting/

　　具体实现，代码如下：

/**
 * 主从配置
 */
public class ShardingMasterSlaveTest {

    public static void main(String[] args) throws SQLException {
        ShardingMasterSlaveTest.insert();
        ShardingMasterSlaveTest.select();
    }

    public static void insert() throws SQLException {
        // 获取数据源
        DataSource dataSource = getDataSource();

        String insertSql1 = "INSERT INTO user VALUES(1, '小白');";
        String insertSql2 = "INSERT INTO user VALUES(2, '小黑');";
        String insertSql3 = "INSERT INTO user VALUES(3, '小黄');";
        String insertSql4 = "INSERT INTO user VALUES(4, '小蓝');";

        try (
                Connection conn = dataSource.getConnection();
                PreparedStatement ps = conn.prepareStatement(insertSql2)) {
            int num = ps.executeUpdate();
            System.out.println("num = " + num);
        }

    }


    public static void select() throws SQLException {
        // 获取数据源
        DataSource dataSource = getDataSource();

        String sql = "select * from user";

        try (
                Connection conn = dataSource.getConnection();
                PreparedStatement ps = conn.prepareStatement(sql)) {
            try (ResultSet rs = ps.executeQuery()) {
                while(rs.next()) {
                    int order_id = rs.getInt(1);
                    String name = rs.getString(2);
                    System.out.println(order_id + "	" + name);
                }
            }
        }
    }

    public static DataSource getDataSource() throws SQLException {
        // 配置真实数据源
        Map<String, DataSource> dataSourceMap = new HashMap<>();

        // 配置第 1 个数据源
        HikariDataSource dataSource1 = new HikariDataSource();
        dataSource1.setDriverClassName("com.mysql.cj.jdbc.Driver");
        dataSource1.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/test_master_slave?allowPublicKeyRetrieval=true&useSSL=true");
        dataSource1.setUsername("root");
        dataSource1.setPassword("123");
        dataSourceMap.put("ds0", dataSource1);

        // 配置第 2 个数据源
        HikariDataSource dataSource2 = new HikariDataSource();
        dataSource2.setDriverClassName("com.mysql.cj.jdbc.Driver");
        dataSource2.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/test_master_slave?allowPublicKeyRetrieval=true&useSSL=true");
        dataSource2.setUsername("root");
        dataSource2.setPassword("123");
        dataSourceMap.put("ds1", dataSource2);


        // 读写数据源配置
        ReadwriteSplittingDataSourceRuleConfiguration dataSourceRuleConfiguration = new ReadwriteSplittingDataSourceRuleConfiguration(
                "master_slave_db", null, "ds0", Arrays.asList("ds1"), "ROUND_ROBIN");

        // 读写分离配置
        ReadwriteSplittingRuleConfiguration readwriteSplittingRuleConfiguration = new ReadwriteSplittingRuleConfiguration(
                Collections.singleton(dataSourceRuleConfiguration), new HashMap<>());

        // 创建 ShardingSphereDataSource
        DataSource dataSource = ShardingSphereDataSourceFactory.createDataSource(dataSourceMap, Collections.singleton(readwriteSplittingRuleConfiguration), new Properties());

        return dataSource;
    }