org.apache.shardingsphere.dbdiscovery.spi

Interface DatabaseDiscoveryType

All Superinterfaces:

ShardingSphereAlgorithm, TypedSPI

public interface DatabaseDiscoveryType
extends ShardingSphereAlgorithm

Database discovery type.

Method Summary

Modifier and Type	Method and Description
void	checkDatabaseDiscoveryConfig(Map<String,DataSource> dataSourceMap, String schemaName) Check database discovery config.
String	getPrimaryDataSource() Get primary data source.
void	startPeriodicalUpdate(Map<String,DataSource> dataSourceMap, String schemaName, Collection<String> disabledDataSourceNames, String groupName, String primaryDataSourceName) Start periodical update.
void	updateMemberState(Map<String,DataSource> dataSourceMap, String schemaName, Collection<String> disabledDataSourceNames) Update member state.
void	updatePrimaryDataSource(Map<String,DataSource> dataSourceMap, String schemaName, Collection<String> disabledDataSourceNames, String groupName, String primaryDataSourceName) Update primary data source.

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

getProps, getType, setProps

Method Detail

checkDatabaseDiscoveryConfig

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

Check database discovery config.

Parameters:

dataSourceMap - data source map

schemaName - schema name

Throws:

SQLException - SQL Exception

updatePrimaryDataSource

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

Update primary data source.

Parameters:

dataSourceMap - data source map

schemaName - schema name

disabledDataSourceNames - disabled data source names

primaryDataSourceName - primary data source name

groupName - group name

updateMemberState

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

Update member state.

Parameters:

dataSourceMap - data source map

schemaName - schema name

disabledDataSourceNames - disabled data source names

startPeriodicalUpdate

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

Start periodical update.

Parameters:

dataSourceMap - data source map

schemaName - schema name

disabledDataSourceNames - disabled data source names

primaryDataSourceName - primary data source name

groupName - group name

getPrimaryDataSource

String getPrimaryDataSource()

Get primary data source.

Returns:

primary data source