org.apache.shardingsphere.readwritesplitting.rule

Class ReadwriteSplittingRule

java.lang.Object

org.apache.shardingsphere.readwritesplitting.rule.ReadwriteSplittingRule

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 ReadwriteSplittingRule
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

Readwrite-splitting rule.

Constructor Summary

Constructors

Constructor and Description
ReadwriteSplittingRule(AlgorithmProvidedReadwriteSplittingRuleConfiguration ruleConfig)
ReadwriteSplittingRule(ReadwriteSplittingRuleConfiguration ruleConfig)

Method Summary

Modifier and Type	Method and Description
Optional<ReadwriteSplittingDataSourceRule>	findDataSourceRule(String dataSourceName) Find data source rule.
Collection<String>	getAllLogicDataSourceNames() Get all logic data source names.
Map<String,Collection<String>>	getDataSourceMapper()
ReadwriteSplittingDataSourceRule	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

ReadwriteSplittingRule

public ReadwriteSplittingRule(ReadwriteSplittingRuleConfiguration ruleConfig)

ReadwriteSplittingRule

public ReadwriteSplittingRule(AlgorithmProvidedReadwriteSplittingRuleConfiguration ruleConfig)

Method Detail

getAllLogicDataSourceNames

public Collection<String> getAllLogicDataSourceNames()

Get all logic data source names.

Returns:

all logic data source names

getSingleDataSourceRule

public ReadwriteSplittingDataSourceRule getSingleDataSourceRule()

Get single data source rule.

Returns:

replica query data source rule

findDataSourceRule

public Optional<ReadwriteSplittingDataSourceRule> findDataSourceRule(String dataSourceName)

Find data source rule.

Parameters:

dataSourceName - data source name

Returns:

replica query 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