org.apache.shardingsphere.dbdiscovery.rule

Class DatabaseDiscoveryRule

java.lang.Object

org.apache.shardingsphere.dbdiscovery.rule.DatabaseDiscoveryRule

All Implemented Interfaces:

org.apache.shardingsphere.infra.rule.level.FeatureRule, org.apache.shardingsphere.infra.rule.scope.SchemaRule, org.apache.shardingsphere.infra.rule.ShardingSphereRule, org.apache.shardingsphere.infra.rule.type.DataSourceContainedRule, org.apache.shardingsphere.infra.rule.type.StatusContainedRule

public final class DatabaseDiscoveryRule
extends Object
implements org.apache.shardingsphere.infra.rule.level.FeatureRule, org.apache.shardingsphere.infra.rule.scope.SchemaRule, org.apache.shardingsphere.infra.rule.type.DataSourceContainedRule, org.apache.shardingsphere.infra.rule.type.StatusContainedRule

Database discovery rule.

Constructor Summary

Constructors

Constructor and Description
DatabaseDiscoveryRule(AlgorithmProvidedDatabaseDiscoveryRuleConfiguration config, org.apache.shardingsphere.infra.database.type.DatabaseType databaseType, Map<String,DataSource> dataSourceMap, String schemaName)
DatabaseDiscoveryRule(DatabaseDiscoveryRuleConfiguration config, org.apache.shardingsphere.infra.database.type.DatabaseType databaseType, Map<String,DataSource> dataSourceMap, String schemaName)

Method Summary

Modifier and Type	Method and Description
Optional<DatabaseDiscoveryDataSourceRule>	findDataSourceRule(String dataSourceName) Find data source rule.
Collection<String>	getAllLogicDataSourceNames() Get all logic data source names.
Map<String,Collection<String>>	getDataSourceMapper()
DatabaseDiscoveryDataSourceRule	getSingleDataSourceRule() Get single data source rule.
void	updateRuleStatus(org.apache.shardingsphere.infra.rule.event.RuleChangedEvent event)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DatabaseDiscoveryRule

public DatabaseDiscoveryRule(DatabaseDiscoveryRuleConfiguration config,
                             org.apache.shardingsphere.infra.database.type.DatabaseType databaseType,
                             Map<String,DataSource> dataSourceMap,
                             String schemaName)

DatabaseDiscoveryRule

public DatabaseDiscoveryRule(AlgorithmProvidedDatabaseDiscoveryRuleConfiguration config,
                             org.apache.shardingsphere.infra.database.type.DatabaseType databaseType,
                             Map<String,DataSource> dataSourceMap,
                             String schemaName)

Method Detail

getAllLogicDataSourceNames

public Collection<String> getAllLogicDataSourceNames()

Get all logic data source names.

Returns:

all logic data source names

getSingleDataSourceRule

public DatabaseDiscoveryDataSourceRule getSingleDataSourceRule()

Get single data source rule.

Returns:

HA data source rule

findDataSourceRule

public Optional<DatabaseDiscoveryDataSourceRule> findDataSourceRule(String dataSourceName)

Find data source rule.

Parameters:

dataSourceName - data source name

Returns:

HA data source rule

getDataSourceMapper

public Map<String,Collection<String>> getDataSourceMapper()

Specified by:

getDataSourceMapper in interface org.apache.shardingsphere.infra.rule.type.DataSourceContainedRule

updateRuleStatus

public void updateRuleStatus(org.apache.shardingsphere.infra.rule.event.RuleChangedEvent event)

Specified by:

updateRuleStatus in interface org.apache.shardingsphere.infra.rule.type.StatusContainedRule