org.apache.shardingsphere.shardingjdbc.jdbc.core.datasource

Class ShardingDataSource

java.lang.Object

org.apache.shardingsphere.shardingjdbc.jdbc.adapter.WrapperAdapter

org.apache.shardingsphere.shardingjdbc.jdbc.unsupported.AbstractUnsupportedOperationDataSource

org.apache.shardingsphere.shardingjdbc.jdbc.adapter.AbstractDataSourceAdapter

org.apache.shardingsphere.shardingjdbc.jdbc.core.datasource.ShardingDataSource

All Implemented Interfaces:

AutoCloseable, Wrapper, CommonDataSource, DataSource

public class ShardingDataSource
extends AbstractDataSourceAdapter

Sharding data source.

Author:

zhangliang, zhaojun, panjuan

Constructor Summary

Constructors

Constructor and Description
ShardingDataSource(Map<String,DataSource> dataSourceMap, org.apache.shardingsphere.core.rule.ShardingRule shardingRule, Properties props)

Method Summary

Modifier and Type	Method and Description
ShardingConnection	getConnection()

Methods inherited from class org.apache.shardingsphere.shardingjdbc.jdbc.adapter.AbstractDataSourceAdapter

close, close, getConnection, getParentLogger, getRuntimeContext

Methods inherited from class org.apache.shardingsphere.shardingjdbc.jdbc.unsupported.AbstractUnsupportedOperationDataSource

getLoginTimeout, setLoginTimeout

Methods inherited from class org.apache.shardingsphere.shardingjdbc.jdbc.adapter.WrapperAdapter

isWrapperFor, recordMethodInvocation, replayMethodsInvocation, unwrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.sql.CommonDataSource

getLogWriter, setLogWriter

Methods inherited from interface java.sql.Wrapper

isWrapperFor, unwrap

Constructor Detail

ShardingDataSource

public ShardingDataSource(Map<String,DataSource> dataSourceMap,
                          org.apache.shardingsphere.core.rule.ShardingRule shardingRule,
                          Properties props)
                   throws SQLException

Throws:

SQLException

Method Detail

getConnection

public final ShardingConnection getConnection()