未验证 提交 a2ededd6 编写于 作者: M menghaoranss 提交者: GitHub

For issue4736 fix example errors (#4796)

上级 cb2c4942
......@@ -30,8 +30,8 @@ import org.apache.shardingsphere.example.orchestration.raw.jdbc.config.local.Loc
import org.apache.shardingsphere.example.orchestration.raw.jdbc.config.local.LocalShardingDatabasesAndTablesConfiguration;
import org.apache.shardingsphere.example.type.RegistryCenterType;
import org.apache.shardingsphere.example.type.ShardingType;
import org.apache.shardingsphere.orchestration.center.configuration.InstanceConfiguration;
import org.apache.shardingsphere.shardingjdbc.jdbc.adapter.AbstractDataSourceAdapter;
import org.apache.shardingsphere.underlying.common.config.orchestration.CenterConfiguration;
import javax.sql.DataSource;
import java.sql.SQLException;
......@@ -64,18 +64,18 @@ public class JavaConfigurationExampleMain {
}
private static DataSource getDataSource(final ShardingType shardingType, final boolean loadConfigFromRegCenter) throws SQLException {
Map<String, InstanceConfiguration> instanceConfigurationMap = getRegistryCenterConfiguration(registryCenterType, shardingType);
Map<String, CenterConfiguration> centerConfigurationMap = getRegistryCenterConfiguration(registryCenterType, shardingType);
ExampleConfiguration configuration;
switch (shardingType) {
case SHARDING_DATABASES_AND_TABLES:
configuration = loadConfigFromRegCenter
? new CloudShardingDatabasesAndTablesConfiguration(instanceConfigurationMap) : new LocalShardingDatabasesAndTablesConfiguration(instanceConfigurationMap);
? new CloudShardingDatabasesAndTablesConfiguration(centerConfigurationMap) : new LocalShardingDatabasesAndTablesConfiguration(centerConfigurationMap);
break;
case MASTER_SLAVE:
configuration = loadConfigFromRegCenter ? new CloudMasterSlaveConfiguration(instanceConfigurationMap) : new LocalMasterSlaveConfiguration(instanceConfigurationMap);
configuration = loadConfigFromRegCenter ? new CloudMasterSlaveConfiguration(centerConfigurationMap) : new LocalMasterSlaveConfiguration(centerConfigurationMap);
break;
case ENCRYPT:
configuration = loadConfigFromRegCenter ? new CloudEncryptConfiguration(instanceConfigurationMap) : new LocalEncryptConfiguration(instanceConfigurationMap);
configuration = loadConfigFromRegCenter ? new CloudEncryptConfiguration(centerConfigurationMap) : new LocalEncryptConfiguration(centerConfigurationMap);
break;
default:
throw new UnsupportedOperationException(shardingType.name());
......@@ -83,7 +83,7 @@ public class JavaConfigurationExampleMain {
return configuration.getDataSource();
}
private static Map<String, InstanceConfiguration> getRegistryCenterConfiguration(final RegistryCenterType registryCenterType, ShardingType shardingType) {
private static Map<String, CenterConfiguration> getRegistryCenterConfiguration(final RegistryCenterType registryCenterType, ShardingType shardingType) {
return RegistryCenterType.ZOOKEEPER == registryCenterType ? RegistryCenterConfigurationUtil.getZooKeeperConfiguration(String.valueOf(!loadConfigFromRegCenter), shardingType) :
RegistryCenterConfigurationUtil.getNacosConfiguration(String.valueOf(!loadConfigFromRegCenter), shardingType);
}
......
......@@ -18,7 +18,7 @@
package org.apache.shardingsphere.example.orchestration.raw.jdbc.config;
import org.apache.shardingsphere.example.type.ShardingType;
import org.apache.shardingsphere.orchestration.center.configuration.InstanceConfiguration;
import org.apache.shardingsphere.underlying.common.config.orchestration.CenterConfiguration;
import java.util.HashMap;
import java.util.Map;
......@@ -34,11 +34,11 @@ public class RegistryCenterConfigurationUtil {
private static final String NACOS_NAMESPACE = "";
public static Map<String, InstanceConfiguration> getZooKeeperConfiguration(String overwrite, ShardingType shardingType) {
Map<String, InstanceConfiguration> instanceConfigurationMap = new HashMap<String, InstanceConfiguration>();
public static Map<String, CenterConfiguration> getZooKeeperConfiguration(String overwrite, ShardingType shardingType) {
Map<String, CenterConfiguration> instanceConfigurationMap = new HashMap<String, CenterConfiguration>();
Properties properties = new Properties();
properties.setProperty("overwrite", overwrite);
InstanceConfiguration result = new InstanceConfiguration("zookeeper", properties);
CenterConfiguration result = new CenterConfiguration("zookeeper", properties);
result.setServerLists(ZOOKEEPER_CONNECTION_STRING);
result.setNamespace(NAMESPACE);
result.setOrchestrationType("registry_center,config_center");
......@@ -56,19 +56,19 @@ public class RegistryCenterConfigurationUtil {
return instanceConfigurationMap;
}
public static Map<String, InstanceConfiguration> getNacosConfiguration(String overwrite, ShardingType shardingType) {
Map<String, InstanceConfiguration> instanceConfigurationMap = new HashMap<String, InstanceConfiguration>();
public static Map<String, CenterConfiguration> getNacosConfiguration(String overwrite, ShardingType shardingType) {
Map<String, CenterConfiguration> instanceConfigurationMap = new HashMap<String, CenterConfiguration>();
Properties nacosProperties = new Properties();
nacosProperties.setProperty("group", "SHARDING_SPHERE_DEFAULT_GROUP");
nacosProperties.setProperty("timeout", "3000");
nacosProperties.setProperty("overwrite", overwrite);
InstanceConfiguration nacosResult = new InstanceConfiguration("nacos", nacosProperties);
CenterConfiguration nacosResult = new CenterConfiguration("nacos", nacosProperties);
nacosResult.setServerLists(NACOS_CONNECTION_STRING);
nacosResult.setNamespace(NACOS_NAMESPACE);
nacosResult.setOrchestrationType("config_center");
Properties zookeeperProperties = new Properties();
zookeeperProperties.setProperty("overwrite", overwrite);
InstanceConfiguration zookeeperResult = new InstanceConfiguration("zookeeper", zookeeperProperties);
CenterConfiguration zookeeperResult = new CenterConfiguration("zookeeper", zookeeperProperties);
zookeeperResult.setServerLists(ZOOKEEPER_CONNECTION_STRING);
zookeeperResult.setNamespace(NAMESPACE);
zookeeperResult.setOrchestrationType("registry_center");
......
......@@ -18,9 +18,9 @@
package org.apache.shardingsphere.example.orchestration.raw.jdbc.config.cloud;
import org.apache.shardingsphere.example.config.ExampleConfiguration;
import org.apache.shardingsphere.orchestration.center.configuration.InstanceConfiguration;
import org.apache.shardingsphere.orchestration.center.configuration.OrchestrationConfiguration;
import org.apache.shardingsphere.shardingjdbc.orchestration.api.OrchestrationEncryptDataSourceFactory;
import org.apache.shardingsphere.underlying.common.config.orchestration.CenterConfiguration;
import org.apache.shardingsphere.underlying.common.config.orchestration.OrchestrationConfiguration;
import javax.sql.DataSource;
import java.sql.SQLException;
......@@ -28,14 +28,14 @@ import java.util.Map;
public class CloudEncryptConfiguration implements ExampleConfiguration {
private final Map<String, InstanceConfiguration> instanceConfigurationMap;
private final Map<String, CenterConfiguration> centerConfigurationMap;
public CloudEncryptConfiguration(final Map<String, InstanceConfiguration> instanceConfigurationMap) {
this.instanceConfigurationMap = instanceConfigurationMap;
public CloudEncryptConfiguration(final Map<String, CenterConfiguration> centerConfigurationMap) {
this.centerConfigurationMap = centerConfigurationMap;
}
@Override
public DataSource getDataSource() throws SQLException {
return OrchestrationEncryptDataSourceFactory.createDataSource(new OrchestrationConfiguration(instanceConfigurationMap));
return OrchestrationEncryptDataSourceFactory.createDataSource(new OrchestrationConfiguration(centerConfigurationMap));
}
}
......@@ -18,9 +18,9 @@
package org.apache.shardingsphere.example.orchestration.raw.jdbc.config.cloud;
import org.apache.shardingsphere.example.config.ExampleConfiguration;
import org.apache.shardingsphere.orchestration.center.configuration.InstanceConfiguration;
import org.apache.shardingsphere.orchestration.center.configuration.OrchestrationConfiguration;
import org.apache.shardingsphere.shardingjdbc.orchestration.api.OrchestrationMasterSlaveDataSourceFactory;
import org.apache.shardingsphere.underlying.common.config.orchestration.CenterConfiguration;
import org.apache.shardingsphere.underlying.common.config.orchestration.OrchestrationConfiguration;
import javax.sql.DataSource;
import java.sql.SQLException;
......@@ -28,15 +28,15 @@ import java.util.Map;
public final class CloudMasterSlaveConfiguration implements ExampleConfiguration {
private final Map<String, InstanceConfiguration> instanceConfigurationMap;
private final Map<String, CenterConfiguration> centerConfigurationMap;
public CloudMasterSlaveConfiguration(final Map<String, InstanceConfiguration> instanceConfigurationMap) {
this.instanceConfigurationMap = instanceConfigurationMap;
public CloudMasterSlaveConfiguration(final Map<String, CenterConfiguration> centerConfigurationMap) {
this.centerConfigurationMap = centerConfigurationMap;
}
@Override
public DataSource getDataSource() throws SQLException {
return OrchestrationMasterSlaveDataSourceFactory.createDataSource(new OrchestrationConfiguration(instanceConfigurationMap));
return OrchestrationMasterSlaveDataSourceFactory.createDataSource(new OrchestrationConfiguration(centerConfigurationMap));
}
}
......@@ -18,9 +18,9 @@
package org.apache.shardingsphere.example.orchestration.raw.jdbc.config.cloud;
import org.apache.shardingsphere.example.config.ExampleConfiguration;
import org.apache.shardingsphere.orchestration.center.configuration.InstanceConfiguration;
import org.apache.shardingsphere.orchestration.center.configuration.OrchestrationConfiguration;
import org.apache.shardingsphere.shardingjdbc.orchestration.api.OrchestrationShardingDataSourceFactory;
import org.apache.shardingsphere.underlying.common.config.orchestration.CenterConfiguration;
import org.apache.shardingsphere.underlying.common.config.orchestration.OrchestrationConfiguration;
import javax.sql.DataSource;
import java.sql.SQLException;
......@@ -28,14 +28,14 @@ import java.util.Map;
public final class CloudShardingDatabasesAndTablesConfiguration implements ExampleConfiguration {
private final Map<String, InstanceConfiguration> instanceConfigurationMap;
private final Map<String, CenterConfiguration> centerConfigurationMap;
public CloudShardingDatabasesAndTablesConfiguration(final Map<String, InstanceConfiguration> instanceConfigurationMap) {
this.instanceConfigurationMap = instanceConfigurationMap;
public CloudShardingDatabasesAndTablesConfiguration(final Map<String, CenterConfiguration> centerConfigurationMap) {
this.centerConfigurationMap = centerConfigurationMap;
}
@Override
public DataSource getDataSource() throws SQLException {
return OrchestrationShardingDataSourceFactory.createDataSource(new OrchestrationConfiguration(instanceConfigurationMap));
return OrchestrationShardingDataSourceFactory.createDataSource(new OrchestrationConfiguration(centerConfigurationMap));
}
}
......@@ -23,9 +23,9 @@ import org.apache.shardingsphere.encrypt.api.EncryptTableRuleConfiguration;
import org.apache.shardingsphere.encrypt.api.EncryptorRuleConfiguration;
import org.apache.shardingsphere.example.config.ExampleConfiguration;
import org.apache.shardingsphere.example.core.api.DataSourceUtil;
import org.apache.shardingsphere.orchestration.center.configuration.InstanceConfiguration;
import org.apache.shardingsphere.orchestration.center.configuration.OrchestrationConfiguration;
import org.apache.shardingsphere.shardingjdbc.orchestration.api.OrchestrationEncryptDataSourceFactory;
import org.apache.shardingsphere.underlying.common.config.orchestration.CenterConfiguration;
import org.apache.shardingsphere.underlying.common.config.orchestration.OrchestrationConfiguration;
import javax.sql.DataSource;
import java.sql.SQLException;
......@@ -35,10 +35,10 @@ import java.util.Properties;
public class LocalEncryptConfiguration implements ExampleConfiguration {
private final Map<String, InstanceConfiguration> instanceConfigurationMap;
private final Map<String, CenterConfiguration> centerConfigurationMap;
public LocalEncryptConfiguration(final Map<String, InstanceConfiguration> instanceConfigurationMap) {
this.instanceConfigurationMap = instanceConfigurationMap;
public LocalEncryptConfiguration(final Map<String, CenterConfiguration> centerConfigurationMap) {
this.centerConfigurationMap = centerConfigurationMap;
}
@Override
......@@ -47,7 +47,7 @@ public class LocalEncryptConfiguration implements ExampleConfiguration {
}
private OrchestrationConfiguration getOrchestrationConfiguration() {
return new OrchestrationConfiguration(instanceConfigurationMap);
return new OrchestrationConfiguration(centerConfigurationMap);
}
private EncryptRuleConfiguration getEncryptRuleConfiguration() {
......
......@@ -20,9 +20,9 @@ package org.apache.shardingsphere.example.orchestration.raw.jdbc.config.local;
import org.apache.shardingsphere.api.config.masterslave.MasterSlaveRuleConfiguration;
import org.apache.shardingsphere.example.config.ExampleConfiguration;
import org.apache.shardingsphere.example.core.api.DataSourceUtil;
import org.apache.shardingsphere.orchestration.center.configuration.InstanceConfiguration;
import org.apache.shardingsphere.orchestration.center.configuration.OrchestrationConfiguration;
import org.apache.shardingsphere.shardingjdbc.orchestration.api.OrchestrationMasterSlaveDataSourceFactory;
import org.apache.shardingsphere.underlying.common.config.orchestration.CenterConfiguration;
import org.apache.shardingsphere.underlying.common.config.orchestration.OrchestrationConfiguration;
import javax.sql.DataSource;
import java.sql.SQLException;
......@@ -33,16 +33,16 @@ import java.util.Properties;
public final class LocalMasterSlaveConfiguration implements ExampleConfiguration {
private final Map<String, InstanceConfiguration> instanceConfigurationMap;
private final Map<String, CenterConfiguration> centerConfigurationMap;
public LocalMasterSlaveConfiguration(final Map<String, InstanceConfiguration> instanceConfigurationMap) {
this.instanceConfigurationMap = instanceConfigurationMap;
public LocalMasterSlaveConfiguration(final Map<String, CenterConfiguration> centerConfigurationMap) {
this.centerConfigurationMap = centerConfigurationMap;
}
@Override
public DataSource getDataSource() 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(instanceConfigurationMap);
OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration(centerConfigurationMap);
return OrchestrationMasterSlaveDataSourceFactory.createDataSource(createDataSourceMap(), masterSlaveRuleConfig, new Properties(), orchestrationConfig);
}
......
......@@ -25,9 +25,9 @@ import org.apache.shardingsphere.api.config.sharding.strategy.StandardShardingSt
import org.apache.shardingsphere.example.algorithm.PreciseModuloShardingTableAlgorithm;
import org.apache.shardingsphere.example.config.ExampleConfiguration;
import org.apache.shardingsphere.example.core.api.DataSourceUtil;
import org.apache.shardingsphere.orchestration.center.configuration.InstanceConfiguration;
import org.apache.shardingsphere.orchestration.center.configuration.OrchestrationConfiguration;
import org.apache.shardingsphere.shardingjdbc.orchestration.api.OrchestrationShardingDataSourceFactory;
import org.apache.shardingsphere.underlying.common.config.orchestration.CenterConfiguration;
import org.apache.shardingsphere.underlying.common.config.orchestration.OrchestrationConfiguration;
import javax.sql.DataSource;
import java.sql.SQLException;
......@@ -37,10 +37,10 @@ import java.util.Properties;
public final class LocalShardingDatabasesAndTablesConfiguration implements ExampleConfiguration {
private final Map<String, InstanceConfiguration> instanceConfigurationMap;
private final Map<String, CenterConfiguration> centerConfigurationMap;
public LocalShardingDatabasesAndTablesConfiguration(final Map<String, InstanceConfiguration> instanceConfigurationMap) {
this.instanceConfigurationMap = instanceConfigurationMap;
public LocalShardingDatabasesAndTablesConfiguration(final Map<String, CenterConfiguration> centerConfigurationMap) {
this.centerConfigurationMap = centerConfigurationMap;
}
private static KeyGeneratorConfiguration getKeyGeneratorConfiguration() {
......@@ -58,7 +58,7 @@ public final class LocalShardingDatabasesAndTablesConfiguration implements Examp
shardingRuleConfig.getBroadcastTables().add("t_address");
shardingRuleConfig.setDefaultDatabaseShardingStrategyConfig(new InlineShardingStrategyConfiguration("user_id", "demo_ds_${user_id % 2}"));
shardingRuleConfig.setDefaultTableShardingStrategyConfig(new StandardShardingStrategyConfiguration("order_id", new PreciseModuloShardingTableAlgorithm()));
OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration(instanceConfigurationMap);
OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration(centerConfigurationMap);
return OrchestrationShardingDataSourceFactory.createDataSource(createDataSourceMap(), shardingRuleConfig, new Properties(), orchestrationConfig);
}
......
......@@ -23,9 +23,9 @@ import org.apache.shardingsphere.api.config.sharding.TableRuleConfiguration;
import org.apache.shardingsphere.api.config.sharding.strategy.InlineShardingStrategyConfiguration;
import org.apache.shardingsphere.example.config.ExampleConfiguration;
import org.apache.shardingsphere.example.core.api.DataSourceUtil;
import org.apache.shardingsphere.orchestration.center.configuration.InstanceConfiguration;
import org.apache.shardingsphere.orchestration.center.configuration.OrchestrationConfiguration;
import org.apache.shardingsphere.shardingjdbc.orchestration.api.OrchestrationShardingDataSourceFactory;
import org.apache.shardingsphere.underlying.common.config.orchestration.CenterConfiguration;
import org.apache.shardingsphere.underlying.common.config.orchestration.OrchestrationConfiguration;
import javax.sql.DataSource;
import java.sql.SQLException;
......@@ -35,10 +35,10 @@ import java.util.Properties;
public final class LocalShardingDatabasesConfiguration implements ExampleConfiguration {
private final Map<String, InstanceConfiguration> instanceConfigurationMap;
private final Map<String, CenterConfiguration> centerConfigurationMap;
public LocalShardingDatabasesConfiguration(final Map<String, InstanceConfiguration> instanceConfigurationMap) {
this.instanceConfigurationMap = instanceConfigurationMap;
public LocalShardingDatabasesConfiguration(final Map<String, CenterConfiguration> centerConfigurationMap) {
this.centerConfigurationMap = centerConfigurationMap;
}
private static KeyGeneratorConfiguration getKeyGeneratorConfiguration() {
......@@ -55,7 +55,7 @@ public final class LocalShardingDatabasesConfiguration implements ExampleConfigu
shardingRuleConfig.getBindingTableGroups().add("t_order, t_order_item");
shardingRuleConfig.getBroadcastTables().add("t_address");
shardingRuleConfig.setDefaultDatabaseShardingStrategyConfig(new InlineShardingStrategyConfiguration("user_id", "demo_ds_${user_id % 2}"));
OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration(instanceConfigurationMap);
OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration(centerConfigurationMap);
return OrchestrationShardingDataSourceFactory.createDataSource(createDataSourceMap(), shardingRuleConfig, new Properties(), orchestrationConfig);
}
......
......@@ -27,9 +27,9 @@ import org.apache.shardingsphere.api.config.sharding.KeyGeneratorConfiguration;
import org.apache.shardingsphere.api.config.sharding.ShardingRuleConfiguration;
import org.apache.shardingsphere.api.config.sharding.TableRuleConfiguration;
import org.apache.shardingsphere.api.config.sharding.strategy.StandardShardingStrategyConfiguration;
import org.apache.shardingsphere.orchestration.center.configuration.InstanceConfiguration;
import org.apache.shardingsphere.orchestration.center.configuration.OrchestrationConfiguration;
import org.apache.shardingsphere.shardingjdbc.orchestration.api.OrchestrationShardingDataSourceFactory;
import org.apache.shardingsphere.underlying.common.config.orchestration.CenterConfiguration;
import org.apache.shardingsphere.underlying.common.config.orchestration.OrchestrationConfiguration;
import javax.sql.DataSource;
import java.sql.SQLException;
......@@ -41,10 +41,10 @@ import java.util.Properties;
public final class LocalShardingMasterSlaveConfiguration implements ExampleConfiguration {
private final Map<String, InstanceConfiguration> instanceConfigurationMap;
private final Map<String, CenterConfiguration> centerConfigurationMap;
public LocalShardingMasterSlaveConfiguration(final Map<String, InstanceConfiguration> instanceConfigurationMap) {
this.instanceConfigurationMap = instanceConfigurationMap;
public LocalShardingMasterSlaveConfiguration(final Map<String, CenterConfiguration> centerConfigurationMap) {
this.centerConfigurationMap = centerConfigurationMap;
}
@Override
......@@ -57,7 +57,7 @@ public final class LocalShardingMasterSlaveConfiguration implements ExampleConfi
shardingRuleConfig.setDefaultDatabaseShardingStrategyConfig(new StandardShardingStrategyConfiguration("user_id", new PreciseModuloShardingDatabaseAlgorithm()));
shardingRuleConfig.setDefaultTableShardingStrategyConfig(new StandardShardingStrategyConfiguration("order_id", new PreciseModuloShardingTableAlgorithm()));
shardingRuleConfig.setMasterSlaveRuleConfigs(getMasterSlaveRuleConfigurations());
OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration(instanceConfigurationMap);
OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration(centerConfigurationMap);
return OrchestrationShardingDataSourceFactory.createDataSource(createDataSourceMap(), shardingRuleConfig, new Properties(), orchestrationConfig);
}
......
......@@ -24,9 +24,9 @@ import org.apache.shardingsphere.api.config.sharding.strategy.StandardShardingSt
import org.apache.shardingsphere.example.algorithm.PreciseModuloShardingTableAlgorithm;
import org.apache.shardingsphere.example.config.ExampleConfiguration;
import org.apache.shardingsphere.example.core.api.DataSourceUtil;
import org.apache.shardingsphere.orchestration.center.configuration.InstanceConfiguration;
import org.apache.shardingsphere.orchestration.center.configuration.OrchestrationConfiguration;
import org.apache.shardingsphere.shardingjdbc.orchestration.api.OrchestrationShardingDataSourceFactory;
import org.apache.shardingsphere.underlying.common.config.orchestration.CenterConfiguration;
import org.apache.shardingsphere.underlying.common.config.orchestration.OrchestrationConfiguration;
import javax.sql.DataSource;
import java.sql.SQLException;
......@@ -36,10 +36,10 @@ import java.util.Properties;
public final class LocalShardingTablesConfiguration implements ExampleConfiguration {
private final Map<String, InstanceConfiguration> instanceConfigurationMap;
private final Map<String, CenterConfiguration> centerConfigurationMap;
public LocalShardingTablesConfiguration(final Map<String, InstanceConfiguration> instanceConfigurationMap) {
this.instanceConfigurationMap = instanceConfigurationMap;
public LocalShardingTablesConfiguration(final Map<String, CenterConfiguration> centerConfigurationMap) {
this.centerConfigurationMap = centerConfigurationMap;
}
@Override
......@@ -50,7 +50,7 @@ public final class LocalShardingTablesConfiguration implements ExampleConfigurat
shardingRuleConfig.getBindingTableGroups().add("t_order, t_order_item");
shardingRuleConfig.getBroadcastTables().add("t_address");
shardingRuleConfig.setDefaultTableShardingStrategyConfig(new StandardShardingStrategyConfiguration("order_id", new PreciseModuloShardingTableAlgorithm()));
OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration(instanceConfigurationMap);
OrchestrationConfiguration orchestrationConfig = new OrchestrationConfiguration(centerConfigurationMap);
return OrchestrationShardingDataSourceFactory.createDataSource(createDataSourceMap(), shardingRuleConfig, new Properties(), orchestrationConfig);
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册