Commit 9c3912ff authored by tristaZero's avatar tristaZero
Browse files

modify ShardingOnlyWithDatabasesAndTables.java

parent 17790a3a

sharding-jdbc-example/raw-jdbc-orche-example/src/main/java/io/shardingsphere/example/jdbc/main/orche/java/etcd/ShardingOnlyWithDatabasesAndTables.java

+2 −3
Original line number Diff line number Diff line
@@ -27,7 +27,6 @@ import io.shardingsphere.example.repository.jdbc.repository.RawOrderItemReposito 
import io.shardingsphere.example.repository.jdbc.repository.RawOrderRepository;

import io.shardingsphere.example.repository.jdbc.service.RawDemoService;

import io.shardingsphere.orchestration.config.OrchestrationConfiguration;

import io.shardingsphere.orchestration.config.OrchestrationType;

import io.shardingsphere.orchestration.reg.api.RegistryCenterConfiguration;

import io.shardingsphere.orchestration.reg.etcd.EtcdConfiguration;

import io.shardingsphere.shardingjdbc.orchestration.api.OrchestrationShardingDataSourceFactory;
@@ -57,7 +56,7 @@ public class ShardingOnlyWithDatabasesAndTables { 
    

    private static DataSource getDataSourceFromRegCenter() throws SQLException {

        return OrchestrationShardingDataSourceFactory.createDataSource(

                new OrchestrationConfiguration("orchestration-sharding-dbtbl-data-source", getRegistryCenterConfiguration(), false, OrchestrationType.SHARDING));

                new OrchestrationConfiguration("orchestration-sharding-dbtbl-data-source", getRegistryCenterConfiguration(), false));

    }

    

    private static DataSource getDataSourceFromLocalConfiguration() throws SQLException {
@@ -68,7 +67,7 @@ public class ShardingOnlyWithDatabasesAndTables { 
        shardingRuleConfig.setDefaultDatabaseShardingStrategyConfig(new InlineShardingStrategyConfiguration("user_id", "demo_ds_${user_id % 2}"));

        shardingRuleConfig.setDefaultTableShardingStrategyConfig(new StandardShardingStrategyConfiguration("order_id", new ModuloShardingTableAlgorithm()));

        OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration(

                "orchestration-sharding-dbtbl-data-source", getRegistryCenterConfiguration(), false, OrchestrationType.SHARDING);

                "orchestration-sharding-dbtbl-data-source", getRegistryCenterConfiguration(), false);

        return OrchestrationShardingDataSourceFactory.createDataSource(createDataSourceMap(), shardingRuleConfig, new HashMap<String, Object>(), new Properties(), orchestrationConfig);

    }

sharding-jdbc-example/raw-jdbc-orche-example/src/main/java/io/shardingsphere/example/jdbc/main/orche/java/etcd/ShardingOnlyWithTables.java

+2 −3
Original line number Diff line number Diff line
@@ -24,7 +24,6 @@ import io.shardingsphere.example.repository.jdbc.repository.RawOrderItemReposito 
import io.shardingsphere.example.repository.jdbc.repository.RawOrderRepository;

import io.shardingsphere.example.repository.jdbc.service.RawDemoService;

import io.shardingsphere.orchestration.config.OrchestrationConfiguration;

import io.shardingsphere.orchestration.config.OrchestrationType;

import io.shardingsphere.orchestration.reg.api.RegistryCenterConfiguration;

import io.shardingsphere.orchestration.reg.etcd.EtcdConfiguration;

import io.shardingsphere.shardingjdbc.orchestration.api.OrchestrationShardingDataSourceFactory;
@@ -54,7 +53,7 @@ public class ShardingOnlyWithTables { 
    

    private static DataSource getDataSourceFromRegCenter() throws SQLException {

        return OrchestrationShardingDataSourceFactory.createDataSource(

                new OrchestrationConfiguration("orchestration-sharding-tbl-data-source", getRegistryCenterConfiguration(), false, OrchestrationType.SHARDING));

                new OrchestrationConfiguration("orchestration-sharding-tbl-data-source", getRegistryCenterConfiguration(), false));

    }

    

    private static DataSource getDataSourceFromLocalConfiguration() throws SQLException {
@@ -63,7 +62,7 @@ public class ShardingOnlyWithTables { 
        shardingRuleConfig.getTableRuleConfigs().add(getOrderItemTableRuleConfiguration());

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

        OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration(

                "orchestration-sharding-tbl-data-source", getRegistryCenterConfiguration(), false, OrchestrationType.SHARDING);

                "orchestration-sharding-tbl-data-source", getRegistryCenterConfiguration(), false);

        return OrchestrationShardingDataSourceFactory.createDataSource(createDataSourceMap(), shardingRuleConfig, new HashMap<String, Object>(), new Properties(), orchestrationConfig);

    }

sharding-jdbc-example/raw-jdbc-orche-example/src/main/java/io/shardingsphere/example/jdbc/main/orche/java/zookeeper/ShardingOnlyWithDatabasesAndTables.java

+2 −2
Original line number Diff line number Diff line
@@ -59,7 +59,7 @@ public class ShardingOnlyWithDatabasesAndTables { 
    

    private static DataSource getDataSourceFromRegCenter() throws SQLException {

        return OrchestrationShardingDataSourceFactory.createDataSource(

                new OrchestrationConfiguration("orchestration-sharding-dbtbl-data-source", getRegistryCenterConfiguration(), false, OrchestrationType.SHARDING));

                new OrchestrationConfiguration("orchestration-sharding-dbtbl-data-source", getRegistryCenterConfiguration(), false));

    }

    

    private static DataSource getDataSourceFromLocalConfiguration() throws SQLException {
@@ -70,7 +70,7 @@ public class ShardingOnlyWithDatabasesAndTables { 
        shardingRuleConfig.setDefaultDatabaseShardingStrategyConfig(new InlineShardingStrategyConfiguration("user_id", "demo_ds_${user_id % 2}"));

        shardingRuleConfig.setDefaultTableShardingStrategyConfig(new StandardShardingStrategyConfiguration("order_id", new ModuloShardingTableAlgorithm()));

        OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration(

                "orchestration-sharding-dbtbl-data-source", getRegistryCenterConfiguration(), false, OrchestrationType.SHARDING);

                "orchestration-sharding-dbtbl-data-source", getRegistryCenterConfiguration(), false);

        return OrchestrationShardingDataSourceFactory.createDataSource(createDataSourceMap(), shardingRuleConfig, new HashMap<String, Object>(), new Properties(), orchestrationConfig);

    }

sharding-jdbc-example/raw-jdbc-orche-example/src/main/java/io/shardingsphere/example/jdbc/main/orche/java/zookeeper/ShardingOnlyWithTables.java

+2 −2
Original line number Diff line number Diff line
@@ -56,7 +56,7 @@ public class ShardingOnlyWithTables { 
    

    private static DataSource getDataSourceFromRegCenter() throws SQLException {

        return OrchestrationShardingDataSourceFactory.createDataSource(

                new OrchestrationConfiguration("orchestration-sharding-tbl-data-source", getRegistryCenterConfiguration(), false, OrchestrationType.SHARDING));

                new OrchestrationConfiguration("orchestration-sharding-tbl-data-source", getRegistryCenterConfiguration(), false));

    }

    

    private static DataSource getDataSourceFromLocalConfiguration() throws SQLException {
@@ -65,7 +65,7 @@ public class ShardingOnlyWithTables { 
        shardingRuleConfig.getTableRuleConfigs().add(getOrderItemTableRuleConfiguration());

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

        OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration(

                "orchestration-sharding-tbl-data-source", getRegistryCenterConfiguration(), false, OrchestrationType.SHARDING);

                "orchestration-sharding-tbl-data-source", getRegistryCenterConfiguration(), false);

        return OrchestrationShardingDataSourceFactory.createDataSource(createDataSourceMap(), shardingRuleConfig, new HashMap<String, Object>(), new Properties(), orchestrationConfig);

    }