Loading sharding-jdbc-example/raw-jdbc-orche-example/src/main/java/io/shardingsphere/example/jdbc/main/orche/java/etcd/MasterSlaveOnly.java +2 −3 Original line number Diff line number Diff line Loading @@ -23,7 +23,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.OrchestrationMasterSlaveDataSourceFactory; Loading Loading @@ -57,13 +56,13 @@ public class MasterSlaveOnly { private static DataSource getDataSourceFromRegCenter() throws SQLException { return OrchestrationMasterSlaveDataSourceFactory.createDataSource( new OrchestrationConfiguration("orchestration-master-slave-data-source", getRegistryCenterConfiguration(), false, OrchestrationType.MASTER_SLAVE)); new OrchestrationConfiguration("orchestration-master-slave-data-source", getRegistryCenterConfiguration(), false)); } private static DataSource getDataSourceFromLocalConfiguration() throws SQLException { MasterSlaveRuleConfiguration masterSlaveRuleConfig = new MasterSlaveRuleConfiguration("demo_ds_master_slave", "demo_ds_master", Arrays.asList("demo_ds_slave_0", "demo_ds_slave_1")); OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration( "orchestration-master-slave-data-source", getRegistryCenterConfiguration(), true, OrchestrationType.MASTER_SLAVE); "orchestration-master-slave-data-source", getRegistryCenterConfiguration(), true); return OrchestrationMasterSlaveDataSourceFactory.createDataSource(createDataSourceMap(), masterSlaveRuleConfig, new HashMap<String, Object>(), new Properties(), orchestrationConfig); } Loading sharding-jdbc-example/raw-jdbc-orche-example/src/main/java/io/shardingsphere/example/jdbc/main/orche/java/zookeeper/MasterSlaveOnly.java +2 −2 Original line number Diff line number Diff line Loading @@ -59,13 +59,13 @@ public class MasterSlaveOnly { private static DataSource getDataSourceFromRegCenter() throws SQLException { return OrchestrationMasterSlaveDataSourceFactory.createDataSource( new OrchestrationConfiguration("orchestration-master-slave-data-source", getRegistryCenterConfiguration(), false, OrchestrationType.MASTER_SLAVE)); new OrchestrationConfiguration("orchestration-master-slave-data-source", getRegistryCenterConfiguration(), false)); } private static DataSource getDataSourceFromLocalConfiguration() throws SQLException { MasterSlaveRuleConfiguration masterSlaveRuleConfig = new MasterSlaveRuleConfiguration("demo_ds_master_slave", "demo_ds_master", Arrays.asList("demo_ds_slave_0", "demo_ds_slave_1")); OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration( "orchestration-master-slave-data-source", getRegistryCenterConfiguration(), true, OrchestrationType.MASTER_SLAVE); "orchestration-master-slave-data-source", getRegistryCenterConfiguration(), true); return OrchestrationMasterSlaveDataSourceFactory.createDataSource(createDataSourceMap(), masterSlaveRuleConfig, new HashMap<String, Object>(), new Properties(), orchestrationConfig); } Loading Loading
sharding-jdbc-example/raw-jdbc-orche-example/src/main/java/io/shardingsphere/example/jdbc/main/orche/java/etcd/MasterSlaveOnly.java +2 −3 Original line number Diff line number Diff line Loading @@ -23,7 +23,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.OrchestrationMasterSlaveDataSourceFactory; Loading Loading @@ -57,13 +56,13 @@ public class MasterSlaveOnly { private static DataSource getDataSourceFromRegCenter() throws SQLException { return OrchestrationMasterSlaveDataSourceFactory.createDataSource( new OrchestrationConfiguration("orchestration-master-slave-data-source", getRegistryCenterConfiguration(), false, OrchestrationType.MASTER_SLAVE)); new OrchestrationConfiguration("orchestration-master-slave-data-source", getRegistryCenterConfiguration(), false)); } private static DataSource getDataSourceFromLocalConfiguration() throws SQLException { MasterSlaveRuleConfiguration masterSlaveRuleConfig = new MasterSlaveRuleConfiguration("demo_ds_master_slave", "demo_ds_master", Arrays.asList("demo_ds_slave_0", "demo_ds_slave_1")); OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration( "orchestration-master-slave-data-source", getRegistryCenterConfiguration(), true, OrchestrationType.MASTER_SLAVE); "orchestration-master-slave-data-source", getRegistryCenterConfiguration(), true); return OrchestrationMasterSlaveDataSourceFactory.createDataSource(createDataSourceMap(), masterSlaveRuleConfig, new HashMap<String, Object>(), new Properties(), orchestrationConfig); } Loading
sharding-jdbc-example/raw-jdbc-orche-example/src/main/java/io/shardingsphere/example/jdbc/main/orche/java/zookeeper/MasterSlaveOnly.java +2 −2 Original line number Diff line number Diff line Loading @@ -59,13 +59,13 @@ public class MasterSlaveOnly { private static DataSource getDataSourceFromRegCenter() throws SQLException { return OrchestrationMasterSlaveDataSourceFactory.createDataSource( new OrchestrationConfiguration("orchestration-master-slave-data-source", getRegistryCenterConfiguration(), false, OrchestrationType.MASTER_SLAVE)); new OrchestrationConfiguration("orchestration-master-slave-data-source", getRegistryCenterConfiguration(), false)); } private static DataSource getDataSourceFromLocalConfiguration() throws SQLException { MasterSlaveRuleConfiguration masterSlaveRuleConfig = new MasterSlaveRuleConfiguration("demo_ds_master_slave", "demo_ds_master", Arrays.asList("demo_ds_slave_0", "demo_ds_slave_1")); OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration( "orchestration-master-slave-data-source", getRegistryCenterConfiguration(), true, OrchestrationType.MASTER_SLAVE); "orchestration-master-slave-data-source", getRegistryCenterConfiguration(), true); return OrchestrationMasterSlaveDataSourceFactory.createDataSource(createDataSourceMap(), masterSlaveRuleConfig, new HashMap<String, Object>(), new Properties(), orchestrationConfig); } Loading