io.shardingsphere.jdbc.orchestration.internal

Class OrchestrationMasterSlaveDataSource

java.lang.Object

io.shardingsphere.core.jdbc.adapter.WrapperAdapter

io.shardingsphere.core.jdbc.unsupported.AbstractUnsupportedOperationDataSource

io.shardingsphere.core.jdbc.adapter.AbstractDataSourceAdapter

io.shardingsphere.core.jdbc.core.datasource.MasterSlaveDataSource

io.shardingsphere.jdbc.orchestration.internal.OrchestrationMasterSlaveDataSource

All Implemented Interfaces:

AutoCloseable, Wrapper, CommonDataSource, DataSource

public class OrchestrationMasterSlaveDataSource
extends MasterSlaveDataSource
implements AutoCloseable

Orchestration master-slave datasource.

Author:

caohao

Constructor Summary

Constructors

Constructor and Description
OrchestrationMasterSlaveDataSource(Map<String,DataSource> dataSourceMap, MasterSlaveRuleConfiguration masterSlaveRuleConfig, Map<String,Object> configMap, OrchestrationFacade orchestrationFacade)

Method Summary

Modifier and Type	Method and Description
void	close()
void	init() Initialize for master-slave orchestration.

Methods inherited from class io.shardingsphere.core.jdbc.core.datasource.MasterSlaveDataSource

getAllDataSources, getConnection, renew

Methods inherited from class io.shardingsphere.core.jdbc.adapter.AbstractDataSourceAdapter

getConnection, getDatabaseType, getLogWriter, getParentLogger, setLogWriter

Methods inherited from class io.shardingsphere.core.jdbc.unsupported.AbstractUnsupportedOperationDataSource

getLoginTimeout, setLoginTimeout

Methods inherited from class io.shardingsphere.core.jdbc.adapter.WrapperAdapter

isWrapperFor, recordMethodInvocation, replayMethodsInvocation, throwSQLExceptionIfNecessary, unwrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.sql.Wrapper

isWrapperFor, unwrap

Constructor Detail

OrchestrationMasterSlaveDataSource

public OrchestrationMasterSlaveDataSource(Map<String,DataSource> dataSourceMap,
                                          MasterSlaveRuleConfiguration masterSlaveRuleConfig,
                                          Map<String,Object> configMap,
                                          OrchestrationFacade orchestrationFacade)
                                   throws SQLException

Throws:

SQLException

Method Detail

init

public void init()

Initialize for master-slave orchestration.

close

public void close()

Specified by:

close in interface AutoCloseable