混合规则

混合配置的规则项之间的叠加使用是通过数据源名称和表名称关联的。

如果前一个规则是面向数据源聚合的，下一个规则在配置数据源时，则需要使用前一个规则配置的聚合后的逻辑数据源名称； 同理，如果前一个规则是面向表聚合的，下一个规则在配置表时，则需要使用前一个规则配置的聚合后的逻辑表名称。

配置项说明

  1. /* 数据源配置 */
  2. HikariDataSource writeDataSource0 = new HikariDataSource();
  3. writeDataSource0.setDriverClassName("com.mysql.jdbc.Driver");
  4. writeDataSource0.setJdbcUrl("jdbc:mysql://localhost:3306/db0?serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=UTF-8");
  5. writeDataSource0.setUsername("root");
  6. writeDataSource0.setPassword("");
  8. HikariDataSource writeDataSource1 = new HikariDataSource();
  9. // ...忽略其他数据库配置项
  11. HikariDataSource read0OfwriteDataSource0 = new HikariDataSource();
  12. // ...忽略其他数据库配置项
  14. HikariDataSource read1OfwriteDataSource0 = new HikariDataSource();
  15. // ...忽略其他数据库配置项
  17. HikariDataSource read0OfwriteDataSource1 = new HikariDataSource();
  18. // ...忽略其他数据库配置项
  20. HikariDataSource read1OfwriteDataSource1 = new HikariDataSource();
  21. // ...忽略其他数据库配置项
  23. Map<String, DataSource> datasourceMaps = new HashMap<>(6);
  25. datasourceMaps.put("write_ds0", writeDataSource0);
  26. datasourceMaps.put("write_ds0_read0", read0OfwriteDataSource0);
  27. datasourceMaps.put("write_ds0_read1", read1OfwriteDataSource0);
  29. datasourceMaps.put("write_ds1", writeDataSource1);
  30. datasourceMaps.put("write_ds1_read0", read0OfwriteDataSource1);
  31. datasourceMaps.put("write_ds1_read1", read1OfwriteDataSource1);
  33. /* 分片规则配置 */
  34. // 表达式 ds_${0..1} 枚举值表示的是主从配置的逻辑数据源名称列表
  35. ShardingTableRuleConfiguration tOrderRuleConfiguration = new ShardingTableRuleConfiguration("t_order", "ds_${0..1}.t_order_${[0, 1]}");
  36. tOrderRuleConfiguration.setKeyGenerateStrategy(new KeyGenerateStrategyConfiguration("order_id", "snowflake"));
  37. tOrderRuleConfiguration.setTableShardingStrategy(new StandardShardingStrategyConfiguration("order_id", "tOrderInlineShardingAlgorithm"));
  38. Properties tOrderShardingInlineProps = new Properties();
  39. tOrderShardingInlineProps.setProperty("algorithm-expression", "t_order_${order_id % 2}");
  40. tOrderRuleConfiguration.getShardingAlgorithms().putIfAbsent("tOrderInlineShardingAlgorithm", new ShardingSphereAlgorithmConfiguration("INLINE",tOrderShardingInlineProps));
  42. ShardingTableRuleConfiguration tOrderItemRuleConfiguration = new ShardingTableRuleConfiguration("t_order_item", "ds_${0..1}.t_order_item_${[0, 1]}");
  43. tOrderItemRuleConfiguration.setKeyGenerateStrategy(new KeyGenerateStrategyConfiguration("order_item_id", "snowflake"));
  44. tOrderRuleConfiguration.setTableShardingStrategy(new StandardShardingStrategyConfiguration("order_item_id", "tOrderItemInlineShardingAlgorithm"));
  45. Properties tOrderItemShardingInlineProps = new Properties();
  46. tOrderItemShardingInlineProps.setProperty("algorithm-expression", "t_order_item_${order_item_id % 2}");
  47. tOrderRuleConfiguration.getShardingAlgorithms().putIfAbsent("tOrderItemInlineShardingAlgorithm", new ShardingSphereAlgorithmConfiguration("INLINE",tOrderItemShardingInlineProps));
  49. ShardingRuleConfiguration shardingRuleConfiguration = new ShardingRuleConfiguration();
  50. shardingRuleConfiguration.getTables().add(tOrderRuleConfiguration);
  51. shardingRuleConfiguration.getTables().add(tOrderItemRuleConfiguration);
  52. shardingRuleConfiguration.getBindingTableGroups().add("t_order, t_order_item");
  53. shardingRuleConfiguration.getBroadcastTables().add("t_bank");
  54. // 默认分库策略
  55. shardingRuleConfiguration.setDefaultDatabaseShardingStrategy(new StandardShardingStrategyConfiguration("user_id", "default_db_strategy_inline"));
  56. Properties defaultDatabaseStrategyInlineProps = new Properties();
  57. defaultDatabaseStrategyInlineProps.setProperty("algorithm-expression", "ds_${user_id % 2}");
  58. shardingRuleConfiguration.getShardingAlgorithms().put("default_db_strategy_inline", new ShardingSphereAlgorithmConfiguration("INLINE", defaultDatabaseStrategyInlineProps));
  59. // 分布式序列算法配置
  60. Properties snowflakeProperties = new Properties();
  61. snowflakeProperties.setProperty("worker-id", "123");
  62. shardingRuleConfiguration.getKeyGenerators().put("snowflake", new ShardingSphereAlgorithmConfiguration("SNOWFLAKE", snowflakeProperties));
  64. /* 数据加密规则配置 */
  65. Properties encryptProperties = new Properties();
  66. encryptProperties.setProperty("aes-key-value", "123456");
  67. EncryptColumnRuleConfiguration columnConfigAes = new EncryptColumnRuleConfiguration("user_name", "user_name", "", "user_name_plain", "name_encryptor");
  68. EncryptColumnRuleConfiguration columnConfigTest = new EncryptColumnRuleConfiguration("pwd", "pwd", "assisted_query_pwd", "", "pwd_encryptor");
  69. EncryptTableRuleConfiguration encryptTableRuleConfig = new EncryptTableRuleConfiguration("t_user", Arrays.asList(columnConfigAes, columnConfigTest));
  71. Map<String, ShardingSphereAlgorithmConfiguration> encryptAlgorithmConfigs = new LinkedHashMap<>(2, 1);
  72. encryptAlgorithmConfigs.put("name_encryptor", new ShardingSphereAlgorithmConfiguration("AES", encryptProperties));
  73. encryptAlgorithmConfigs.put("pwd_encryptor", new ShardingSphereAlgorithmConfiguration("assistedTest", encryptProperties));
  74. EncryptRuleConfiguration encryptRuleConfiguration = new EncryptRuleConfiguration(Collections.singleton(encryptTableRuleConfig), encryptAlgorithmConfigs);
  76. /* 读写分离规则配置 */
  77. ReadwriteSplittingDataSourceRuleConfiguration dataSourceConfiguration1 = new ReadwriteSplittingDataSourceRuleConfiguration("ds_0", "write_ds0", Arrays.asList("write_ds0_read0", "write_ds0_read1"), "roundRobin");
  78. ReadwriteSplittingDataSourceRuleConfiguration dataSourceConfiguration2 = new ReadwriteSplittingDataSourceRuleConfiguration("ds_1", "write_ds0", Arrays.asList("write_ds1_read0", "write_ds1_read0"), "roundRobin");
  80. //负载均衡算法
  81. Map<String, ShardingSphereAlgorithmConfiguration> loadBalanceMaps = new HashMap<>(1);
  82. loadBalanceMaps.put("roundRobin", new ShardingSphereAlgorithmConfiguration("ROUND_ROBIN", new Properties()));
  84. ReadwriteSplittingRuleConfiguration readWriteSplittingyRuleConfiguration = new ReadwriteSplittingRuleConfiguration(Arrays.asList(dataSourceConfiguration1, dataSourceConfiguration2), loadBalanceMaps);
  86. /* 其他配置 */
  87. Properties otherProperties = new Properties();
  88. otherProperties.setProperty("sql-show", "true");
  90. /* shardingDataSource 就是最终被ORM框架或其他jdbc框架引用的数据源名称 */
  91. DataSource shardingDataSource = ShardingSphereDataSourceFactory.createDataSource(datasourceMaps, Arrays.asList(shardingRuleConfiguration, readWriteSplittingyRuleConfiguration, encryptRuleConfiguration), otherProperties);