Commit 91e4a359 authored by terrymanu's avatar terrymanu
Browse files

update example fpr java config

parent 32beaebe

sharding-jdbc-orchestration-example/sharding-jdbc-orchestration-etcd-java-example/src/main/java/io/shardingjdbc/example/orchestration/OrchestrationEtcdMasterSlaveMain.java

+2 −6
Original line number Diff line number Diff line
@@ -80,12 +80,8 @@ public final class OrchestrationEtcdMasterSlaveMain { 
        return result;

    }

    

    private static MasterSlaveRuleConfiguration crateMasterSlaveRuleConfig() throws SQLException {

        MasterSlaveRuleConfiguration result = new MasterSlaveRuleConfiguration();

        result.setName("demo_master_slave");

        result.setMasterDataSourceName("demo_ds_master");

        result.setSlaveDataSourceNames(Lists.newArrayList("demo_ds_slave_0", "demo_ds_slave_1"));

        return result;

    private static MasterSlaveRuleConfiguration crateMasterSlaveRuleConfig() {

        return new MasterSlaveRuleConfiguration("demo_master_slave", "demo_ds_master", Lists.newArrayList("demo_ds_slave_0", "demo_ds_slave_1"));

    }

    

    private static void createTable(final DataSource dataSource) throws SQLException {

sharding-jdbc-orchestration-example/sharding-jdbc-orchestration-etcd-java-example/src/main/java/io/shardingjdbc/example/orchestration/OrchestrationEtcdShardingMain.java

+1 −1
Original line number Diff line number Diff line
@@ -95,7 +95,7 @@ public final class OrchestrationEtcdShardingMain { 
        result.getTableRuleConfigs().add(orderItemTableRuleConfig);

        result.getBindingTableGroups().add("t_order, t_order_item");

        result.setDefaultDatabaseShardingStrategyConfig(new InlineShardingStrategyConfiguration("user_id", "demo_ds_${user_id % 2}"));

        result.setDefaultTableShardingStrategyConfig(new StandardShardingStrategyConfiguration("order_id", ModuloTableShardingAlgorithm.class.getName()));

        result.setDefaultTableShardingStrategyConfig(new StandardShardingStrategyConfiguration("order_id", new ModuloTableShardingAlgorithm()));

        return result;

    }

sharding-jdbc-orchestration-example/sharding-jdbc-orchestration-etcd-java-example/src/main/java/io/shardingjdbc/example/orchestration/OrchestrationEtcdShardingMasterSlaveMain.java

+5 −13
Original line number Diff line number Diff line
@@ -103,23 +103,15 @@ public final class OrchestrationEtcdShardingMasterSlaveMain { 
        result.getTableRuleConfigs().add(orderItemTableRuleConfig);

        result.getBindingTableGroups().add("t_order, t_order_item");

        result.setDefaultDatabaseShardingStrategyConfig(new InlineShardingStrategyConfiguration("user_id", "demo_ds_${user_id % 2}"));

        result.setDefaultTableShardingStrategyConfig(new StandardShardingStrategyConfiguration("order_id", ModuloTableShardingAlgorithm.class.getName()));

        result.setDefaultTableShardingStrategyConfig(new StandardShardingStrategyConfiguration("order_id", new ModuloTableShardingAlgorithm()));

        result.setMasterSlaveRuleConfigs(crateMasterSlaveRuleConfigs());

        return result;

    }

    

    private static List<MasterSlaveRuleConfiguration> crateMasterSlaveRuleConfigs() throws SQLException {

        final MasterSlaveRuleConfiguration config1 = new MasterSlaveRuleConfiguration();

        config1.setName("demo_ds_0");

        config1.setMasterDataSourceName("demo_ds_master_0");

        config1.setSlaveDataSourceNames(Lists.newArrayList("demo_ds_master_0_slave_0", "demo_ds_master_0_slave_1"));

        List<MasterSlaveRuleConfiguration> result = new ArrayList<>();

        result.add(config1);

        final MasterSlaveRuleConfiguration config2 = new MasterSlaveRuleConfiguration();

        config2.setName("demo_ds_1");

        config2.setMasterDataSourceName("demo_ds_master_1");

        config2.setSlaveDataSourceNames(Lists.newArrayList("demo_ds_master_1_slave_0", "demo_ds_master_1_slave_1"));

        result.add(config2);

    private static List<MasterSlaveRuleConfiguration> crateMasterSlaveRuleConfigs() {

        List<MasterSlaveRuleConfiguration> result = new ArrayList<>(2);

        result.add(new MasterSlaveRuleConfiguration("demo_ds_0", "demo_ds_master_0", Lists.newArrayList("demo_ds_master_0_slave_0", "demo_ds_master_0_slave_1")));

        result.add(new MasterSlaveRuleConfiguration("demo_ds_1", "demo_ds_master_1", Lists.newArrayList("demo_ds_master_1_slave_0", "demo_ds_master_1_slave_1")));

        return result;

    }

sharding-jdbc-orchestration-example/sharding-jdbc-orchestration-zookeeper-java-example/src/main/java/io/shardingjdbc/example/orchestration/OrchestrationMasterSlaveMain.java

+2 −6
Original line number Diff line number Diff line
@@ -82,12 +82,8 @@ public final class OrchestrationMasterSlaveMain { 
        return result;

    }

    

    private static MasterSlaveRuleConfiguration crateMasterSlaveRuleConfig() throws SQLException {

        MasterSlaveRuleConfiguration result = new MasterSlaveRuleConfiguration();

        result.setName("demo_master_slave");

        result.setMasterDataSourceName("demo_ds_master");

        result.setSlaveDataSourceNames(Lists.newArrayList("demo_ds_slave_0", "demo_ds_slave_1"));

        return result;

    private static MasterSlaveRuleConfiguration crateMasterSlaveRuleConfig() {

        return new MasterSlaveRuleConfiguration("demo_master_slave", "demo_ds_master", Lists.newArrayList("demo_ds_slave_0", "demo_ds_slave_1"));

    }

    

    private static void createTable(final DataSource dataSource) throws SQLException {

sharding-jdbc-orchestration-example/sharding-jdbc-orchestration-zookeeper-java-example/src/main/java/io/shardingjdbc/example/orchestration/OrchestrationShardingMain.java

+1 −1
Original line number Diff line number Diff line
@@ -99,7 +99,7 @@ public final class OrchestrationShardingMain { 
        result.getTableRuleConfigs().add(orderItemTableRuleConfig);

        result.getBindingTableGroups().add("t_order, t_order_item");

        result.setDefaultDatabaseShardingStrategyConfig(new InlineShardingStrategyConfiguration("user_id", "demo_ds_${user_id % 2}"));

        result.setDefaultTableShardingStrategyConfig(new StandardShardingStrategyConfiguration("order_id", ModuloTableShardingAlgorithm.class.getName()));

        result.setDefaultTableShardingStrategyConfig(new StandardShardingStrategyConfiguration("order_id", new ModuloTableShardingAlgorithm()));

        return result;

    }