混合规则

背景信息

ShardingSphere 涵盖了很多功能，例如，分库分片、读写分离、高可用、数据加密等。这些功能用户可以单独进行使用，也可以配合一起使用，下面是基于 JAVA API 的配置示例。

配置示例

  1. // 分片配置
  2. private ShardingRuleConfiguration createShardingRuleConfiguration() {
  3.     ShardingRuleConfiguration result = new ShardingRuleConfiguration();
  4.     result.getTables().add(getOrderTableRuleConfiguration());
  5.     result.setDefaultDatabaseShardingStrategy(new StandardShardingStrategyConfiguration("user_id", "inline"));
  6.     result.setDefaultTableShardingStrategy(new StandardShardingStrategyConfiguration("order_id", "standard_test_tbl"));
  7.     Properties props = new Properties();
  8.     props.setProperty("algorithm-expression", "demo_ds_${user_id % 2}");
  9.     result.getShardingAlgorithms().put("inline", new AlgorithmConfiguration("INLINE", props));
  10.     result.getShardingAlgorithms().put("standard_test_tbl", new AlgorithmConfiguration("STANDARD_TEST_TBL", new Properties()));
  11.     result.getKeyGenerators().put("snowflake", new AlgorithmConfiguration("SNOWFLAKE", new Properties()));
  12.     return result;
  13. }
  15. private ShardingTableRuleConfiguration getOrderTableRuleConfiguration() {
  16.     ShardingTableRuleConfiguration result = new ShardingTableRuleConfiguration("t_order", "demo_ds_${0..1}.t_order_${[0, 1]}");
  17.     result.setKeyGenerateStrategy(new KeyGenerateStrategyConfiguration("order_id", "snowflake"));
  18.     return result;
  19. }
  21. // 动态读写分离配置
  22. private static ReadwriteSplittingRuleConfiguration createReadwriteSplittingConfiguration() {
  23.     ReadwriteSplittingDataSourceRuleConfiguration dataSourceConfiguration1 = new ReadwriteSplittingDataSourceRuleConfiguration("replica_ds_0", new DynamicReadwriteSplittingStrategyConfiguration("readwrite_ds_0", true), "");
  24.     ReadwriteSplittingDataSourceRuleConfiguration dataSourceConfiguration2 = new ReadwriteSplittingDataSourceRuleConfiguration("replica_ds_1", new DynamicReadwriteSplittingStrategyConfiguration("readwrite_ds_1", true), "");
  25.     Collection<ReadwriteSplittingDataSourceRuleConfiguration> dataSources = new LinkedList<>();
  26.     dataSources.add(dataSourceRuleConfiguration1);
  27.     dataSources.add(dataSourceRuleConfiguration2);
  28.     return new ReadwriteSplittingRuleConfiguration(dataSources, Collections.emptyMap());
  29. }
  31. // 数据库发现配置
  32. private static DatabaseDiscoveryRuleConfiguration createDatabaseDiscoveryConfiguration() {
  33.     DatabaseDiscoveryDataSourceRuleConfiguration dataSourceRuleConfiguration1 = new DatabaseDiscoveryDataSourceRuleConfiguration("readwrite_ds_0", Arrays.asList("ds_0, ds_1, ds_2"), "mgr-heartbeat", "mgr");
  34.     DatabaseDiscoveryDataSourceRuleConfiguration dataSourceRuleConfiguration2 = new DatabaseDiscoveryDataSourceRuleConfiguration("readwrite_ds_1", Arrays.asList("ds_3, ds_4, ds_5"), "mgr-heartbeat", "mgr");
  35.     Collection<DatabaseDiscoveryDataSourceRuleConfiguration> dataSources = new LinkedList<>();    
  36.     dataSources.add(dataSourceRuleConfiguration1);
  37.     dataSources.add(dataSourceRuleConfiguration2);
  38.     return new DatabaseDiscoveryRuleConfiguration(configs, createDiscoveryHeartbeats(), createDiscoveryTypes());
  39. }
  41. private static DatabaseDiscoveryRuleConfiguration createDatabaseDiscoveryConfiguration() {
  42.     DatabaseDiscoveryDataSourceRuleConfiguration dataSourceRuleConfiguration = new DatabaseDiscoveryDataSourceRuleConfiguration("readwrite_ds_1", Arrays.asList("ds_3, ds_4, ds_5"), "mgr-heartbeat", "mgr");
  43.     return new DatabaseDiscoveryRuleConfiguration(Collections.singleton(dataSourceRuleConfiguration), createDiscoveryHeartbeats(), createDiscoveryTypes());
  44. }
  46. private static Map<String, AlgorithmConfiguration> createDiscoveryTypes() {
  47.     Map<String, AlgorithmConfiguration> result = new HashMap<>(1， 1);
  48.     Properties props = new Properties();
  49.     props.put("group-name", "558edd3c-02ec-11ea-9bb3-080027e39bd2");
  50.     discoveryTypes.put("mgr", new AlgorithmConfiguration("MGR", props));
  51.     return result;
  52. }
  54. private static Map<String, DatabaseDiscoveryHeartBeatConfiguration> createDiscoveryHeartbeats() {
  55.     Map<String, DatabaseDiscoveryHeartBeatConfiguration> result = new HashMap<>(1， 1);
  56.     Properties props = new Properties();
  57.     props.put("keep-alive-cron", "0/5 * * * * ?");
  58.     discoveryHeartBeatConfiguration.put("mgr-heartbeat", new DatabaseDiscoveryHeartBeatConfiguration(props));
  59.     return result;
  60. }
  62. // 数据加密配置
  63. public EncryptRuleConfiguration createEncryptRuleConfiguration() {
  64.     Properties props = new Properties();
  65.     props.setProperty("aes-key-value", "123456");
  66.     EncryptColumnRuleConfiguration columnConfigAes = new EncryptColumnRuleConfiguration("username", "username", "", "", "username_plain", "name_encryptor", null);
  67.     EncryptColumnRuleConfiguration columnConfigTest = new EncryptColumnRuleConfiguration("pwd", "pwd", "assisted_query_pwd", "like_pwd", "", "pwd_encryptor", null);
  68.     EncryptTableRuleConfiguration encryptTableRuleConfig = new EncryptTableRuleConfiguration("t_user", Arrays.asList(columnConfigAes, columnConfigTest), null);
  69.     Map<String, AlgorithmConfiguration> encryptAlgorithmConfigs = new LinkedHashMap<>(2, 1);
  70.     encryptAlgorithmConfigs.put("name_encryptor", new AlgorithmConfiguration("AES", props));
  71.     encryptAlgorithmConfigs.put("pwd_encryptor", new AlgorithmConfiguration("assistedTest", props));
  72.     encryptAlgorithmConfigs.put("like_encryptor", new AlgorithmConfiguration("CHAR_DIGEST_LIKE", new Properties()));
  73.     EncryptRuleConfiguration result = new EncryptRuleConfiguration(Collections.singleton(encryptTableRuleConfig), encryptAlgorithmConfigs);
  74.     return result;
  75. }