Mixed Rules

Configuration Item Explanation

  1. /* Data source configuration */
  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. // ...Omit specific configuration.
  11. HikariDataSource read0OfwriteDataSource0 = new HikariDataSource();
  12. // ...Omit specific configuration.
  14. HikariDataSource read1OfwriteDataSource0 = new HikariDataSource();
  15. // ...Omit specific configuration.
  17. HikariDataSource read0OfwriteDataSource1 = new HikariDataSource();
  18. // ...Omit specific configuration.
  20. HikariDataSource read1OfwriteDataSource1 = new HikariDataSource();
  21. // ...Omit specific configuration.
  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. /* Sharding rule configuration */
  34. // The enumeration value of `ds_$->{0..1}` is the name of the logical data source configured with read-query
  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. ruleConfiguration.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. ruleConfiguration.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. // Default database strategy configuration
  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));
  60. // Key generate algorithm configuration
  61. Properties snowflakeProperties = new Properties();
  62. snowflakeProperties.setProperty("worker-id", "123");
  63. shardingRuleConfiguration.getKeyGenerators().put("snowflake", new ShardingSphereAlgorithmConfiguration("SNOWFLAKE", snowflakeProperties));
  65. /* Data encrypt rule configuration */
  66. Properties encryptProperties = new Properties();
  67. encryptProperties.setProperty("aes-key-value", "123456");
  68. EncryptColumnRuleConfiguration columnConfigAes = new EncryptColumnRuleConfiguration("user_name", "user_name", "", "user_name_plain", "name_encryptor");
  69. EncryptColumnRuleConfiguration columnConfigTest = new EncryptColumnRuleConfiguration("pwd", "pwd", "assisted_query_pwd", "", "pwd_encryptor");
  70. EncryptTableRuleConfiguration encryptTableRuleConfig = new EncryptTableRuleConfiguration("t_user", Arrays.asList(columnConfigAes, columnConfigTest));
  71. // Data encrypt algorithm configuration
  72. Map<String, ShardingSphereAlgorithmConfiguration> encryptAlgorithmConfigs = new LinkedHashMap<>(2, 1);
  73. encryptAlgorithmConfigs.put("name_encryptor", new ShardingSphereAlgorithmConfiguration("AES", encryptProperties));
  74. encryptAlgorithmConfigs.put("pwd_encryptor", new ShardingSphereAlgorithmConfiguration("assistedTest", encryptProperties));
  75. EncryptRuleConfiguration encryptRuleConfiguration = new EncryptRuleConfiguration(Collections.singleton(encryptTableRuleConfig), encryptAlgorithmConfigs);
  77. /* Readwrite-splitting rule configuration */
  78. ReadwriteSplittingDataSourceRuleConfiguration dataSourceConfiguration1 = new ReadwriteSplittingDataSourceRuleConfiguration("ds_0", "write_ds0", Arrays.asList("write_ds0_read0", "write_ds0_read1"), "roundRobin");
  79. ReadwriteSplittingDataSourceRuleConfiguration dataSourceConfiguration2 = new ReadwriteSplittingDataSourceRuleConfiguration("ds_1", "write_ds0", Arrays.asList("write_ds1_read0", "write_ds1_read0"), "roundRobin");
  81. // Load balance algorithm configuration
  82. Map<String, ShardingSphereAlgorithmConfiguration> loadBalanceMaps = new HashMap<>(1);
  83. loadBalanceMaps.put("roundRobin", new ShardingSphereAlgorithmConfiguration("ROUND_ROBIN", new Properties()));
  85. ReadwriteSplittingRuleConfiguration readWriteSplittingRuleConfiguration = new ReadwriteSplittingRuleConfiguration(Arrays.asList(dataSourceConfiguration1, dataSourceConfiguration2), loadBalanceMaps);
  87. /* Other Properties configuration */
  88. Properties otherProperties = new Properties();
  89. otherProperties.setProperty("sql-show", "true");
  91. /* The variable `shardingDataSource` is the logic data source referenced by other frameworks(such as ORM, JPA, etc.) */
  92. DataSource shardingDataSource = ShardingSphereDataSourceFactory.createDataSource(datasourceMaps, Arrays.asList(shardingRuleConfiguration, readWriteSplittingRuleConfiguration, encryptRuleConfiguration), otherProperties);