org.apache.shardingsphere.dbdiscovery.mgr

Class MGRDatabaseDiscoveryType

java.lang.Object

org.apache.shardingsphere.dbdiscovery.mgr.MGRDatabaseDiscoveryType

All Implemented Interfaces:

DatabaseDiscoveryType, org.apache.shardingsphere.infra.config.algorithm.ShardingSphereAlgorithm, org.apache.shardingsphere.infra.spi.typed.TypedSPI

public final class MGRDatabaseDiscoveryType
extends Object
implements DatabaseDiscoveryType

MGR data base discovery type.

Constructor Summary

Constructors

Constructor and Description
MGRDatabaseDiscoveryType()

Method Summary

Modifier and Type	Method and Description
void	checkDatabaseDiscoveryConfig(Map<String,DataSource> dataSourceMap, String schemaName)
String	getPrimaryDataSource()
String	getType()
void	startPeriodicalUpdate(Map<String,DataSource> dataSourceMap, String schemaName, Collection<String> disabledDataSourceNames, String groupName, String primaryDataSourceName)
void	updateMemberState(Map<String,DataSource> dataSourceMap, String schemaName, Collection<String> disabledDataSourceNames)
void	updatePrimaryDataSource(Map<String,DataSource> dataSourceMap, String schemaName, Collection<String> disabledDataSourceNames, String groupName, String primaryDataSourceName)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.shardingsphere.infra.spi.typed.TypedSPI

getProps, setProps

Constructor Detail

MGRDatabaseDiscoveryType

public MGRDatabaseDiscoveryType()

Method Detail

checkDatabaseDiscoveryConfig

public void checkDatabaseDiscoveryConfig(Map<String,DataSource> dataSourceMap,
                                         String schemaName)
                                  throws SQLException

Specified by:

checkDatabaseDiscoveryConfig in interface DatabaseDiscoveryType

Throws:

SQLException

updatePrimaryDataSource

public void updatePrimaryDataSource(Map<String,DataSource> dataSourceMap,
                                    String schemaName,
                                    Collection<String> disabledDataSourceNames,
                                    String groupName,
                                    String primaryDataSourceName)

Specified by:

updatePrimaryDataSource in interface DatabaseDiscoveryType

updateMemberState

public void updateMemberState(Map<String,DataSource> dataSourceMap,
                              String schemaName,
                              Collection<String> disabledDataSourceNames)

Specified by:

updateMemberState in interface DatabaseDiscoveryType

startPeriodicalUpdate

public void startPeriodicalUpdate(Map<String,DataSource> dataSourceMap,
                                  String schemaName,
                                  Collection<String> disabledDataSourceNames,
                                  String groupName,
                                  String primaryDataSourceName)

Specified by:

startPeriodicalUpdate in interface DatabaseDiscoveryType

getPrimaryDataSource

public String getPrimaryDataSource()

Specified by:

getPrimaryDataSource in interface DatabaseDiscoveryType

getType

public String getType()

Specified by:

getType in interface org.apache.shardingsphere.infra.spi.typed.TypedSPI