Mixed Rules

Background

ShardingSphere provides a variety of features, such as data sharding, read/write splitting, high availability, and data encryption. These features can be used independently or in combination. Below, you will find the configuration samples based on JAVA API.

Samples

  1. // Sharding configuration
  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. // Read/write splitting configuration
  22. private static ReadwriteSplittingRuleConfiguration createReadwriteSplittingConfiguration() {
  23.     ReadwriteSplittingDataSourceRuleConfiguration dataSourceConfiguration1 = new ReadwriteSplittingDataSourceRuleConfiguration("replica_ds_0", Arrays.asList("readwrite_ds_0"), true), "");
  24.     ReadwriteSplittingDataSourceRuleConfiguration dataSourceConfiguration2 = new ReadwriteSplittingDataSourceRuleConfiguration("replica_ds_1", Arrays.asList("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. // Data encryption configuration
  32. private static EncryptRuleConfiguration createEncryptRuleConfiguration() {
  33.     Properties props = new Properties();
  34.     props.setProperty("aes-key-value", "123456");
  35.     EncryptColumnRuleConfiguration columnConfigAes = new EncryptColumnRuleConfiguration("username", new EncryptColumnItemRuleConfiguration("username", "name_encryptor"));
  36.     EncryptColumnRuleConfiguration columnConfigTest = new EncryptColumnRuleConfiguration("pwd", new EncryptColumnItemRuleConfiguration("pwd", "pwd_encryptor"));
  37.     columnConfigTest.setAssistedQuery(new EncryptColumnItemRuleConfiguration("assisted_query_pwd", "pwd_encryptor"));
  38.     columnConfigTest.setLikeQuery(new EncryptColumnItemRuleConfiguration("like_pwd", "like_encryptor"));
  39.     EncryptTableRuleConfiguration encryptTableRuleConfig = new EncryptTableRuleConfiguration("t_user", Arrays.asList(columnConfigAes, columnConfigTest));
  40.     Map<String, AlgorithmConfiguration> encryptAlgorithmConfigs = new HashMap<>();
  41.     encryptAlgorithmConfigs.put("name_encryptor", new AlgorithmConfiguration("AES", props));
  42.     encryptAlgorithmConfigs.put("pwd_encryptor", new AlgorithmConfiguration("assistedTest", props));
  43.     encryptAlgorithmConfigs.put("like_encryptor", new AlgorithmConfiguration("CHAR_DIGEST_LIKE", new Properties()));
  44.     return new EncryptRuleConfiguration(Collections.singleton(encryptTableRuleConfig), encryptAlgorithmConfigs);
  45. }