HA

    Class name: org.apache.shardingsphere.dbdiscovery.api.config.DatabaseDiscoveryRuleConfiguration Attributes:

    Class name: org.apache.shardingsphere.dbdiscovery.api.config.rule.DatabaseDiscoveryDataSourceRuleConfiguration

    Class name: org.apache.shardingsphere.dbdiscovery.api.config.rule.DatabaseDiscoveryHeartBeatConfiguration

    Attributes:

    Attributes：

    1. Import Maven dependency.
    2. // Build data source ds_0, ds_1, ds_2
    3. Map<String, DataSource> dataSourceMap = new HashMap<>(3, 1);
    4. dataSourceMap.put("ds_0", createDataSource1("primary_demo_ds"));
    5. dataSourceMap.put("ds_2", createDataSource3("primary_demo_ds"));
    7. DataSource dataSource = ShardingSphereDataSourceFactory.createDataSource("database_discovery_db", dataSourceMap, Arrays.asList(createDatabaseDiscoveryConfiguration(), createReadwriteSplittingConfiguration()), null);
    10.     DatabaseDiscoveryDataSourceRuleConfiguration dataSourceRuleConfiguration = new DatabaseDiscoveryDataSourceRuleConfiguration("readwrite_ds", Arrays.asList("ds_0, ds_1, ds_2"), "mgr-heartbeat", "mgr");
    11.     return new DatabaseDiscoveryRuleConfiguration(Collections.singleton(dataSourceRuleConfiguration), createDiscoveryHeartbeats(), createDiscoveryTypes());
    12. }
    14. private static ReadwriteSplittingRuleConfiguration createReadwriteSplittingConfiguration() {
    15.     ReadwriteSplittingDataSourceRuleConfiguration dataSourceConfiguration1 = new ReadwriteSplittingDataSourceRuleConfiguration("replica_ds", new DynamicReadwriteSplittingStrategyConfiguration("readwrite_ds", true), "");
    16.     return new ReadwriteSplittingRuleConfiguration(Arrays.asList(dataSourceConfiguration1), Collections.emptyMap());
    17. }
    19.     Map<String, AlgorithmConfiguration> discoveryTypes = new HashMap<>(1， 1);
    21.     props.put("group-name", "558edd3c-02ec-11ea-9bb3-080027e39bd2");
    22.     discoveryTypes.put("mgr", new AlgorithmConfiguration("MGR", props));
    23.     return discoveryTypes;
    24. }
    26. private static Map<String, DatabaseDiscoveryHeartBeatConfiguration> createDiscoveryHeartbeats() {
    27.     Map<String, DatabaseDiscoveryHeartBeatConfiguration> discoveryHeartBeatConfiguration = new HashMap<>(1， 1);
    28.     Properties props = new Properties();
    29.     props.put("keep-alive-cron", "0/5 * * * * ?");
    30.     discoveryHeartBeatConfiguration.put("mgr-heartbeat", new DatabaseDiscoveryHeartBeatConfiguration(props));
    31.     return discoveryHeartBeatConfiguration;