org.apache.shardingsphere.shardingjdbc.jdbc.adapter

Class AbstractConnectionAdapter

java.lang.Object

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

org.apache.shardingsphere.shardingjdbc.jdbc.unsupported.AbstractUnsupportedOperationConnection

org.apache.shardingsphere.shardingjdbc.jdbc.adapter.AbstractConnectionAdapter

All Implemented Interfaces:

AutoCloseable, Connection, Wrapper

Direct Known Subclasses:

MasterSlaveConnection, ShardingConnection

public abstract class AbstractConnectionAdapter
extends AbstractUnsupportedOperationConnection

Adapter for Connection.

Author:

zhangliang, panjuan, zhaojun, maxiaoguang

Field Summary

Fields inherited from interface java.sql.Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractConnectionAdapter(ShardingTransactionManagerEngine shardingTransactionManagerEngine, TransactionType transactionType)

Method Summary

Modifier and Type	Method and Description
void	clearWarnings()
void	close()
void	commit()
boolean	getAutoCommit()
Connection	getConnection(String dataSourceName) Get database connection.
List<Connection>	getConnections(org.apache.shardingsphere.core.constant.ConnectionMode connectionMode, String dataSourceName, int connectionSize) Get database connections.
protected abstract Map<String,DataSource>	getDataSourceMap()
int	getHoldability()
int	getTransactionIsolation()
SQLWarning	getWarnings()
boolean	isClosed()
protected abstract boolean	isOnlyLocalTransactionValid()
boolean	isReadOnly()
boolean	isSerialExecute() Whether execute SQL serial or not.
void	rollback()
void	setAutoCommit(boolean autoCommit)
void	setHoldability(int holdability)
void	setReadOnly(boolean readOnly)
void	setTransactionIsolation(int level)

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

abort, createArrayOf, createBlob, createClob, createNClob, createSQLXML, createStruct, getCatalog, getClientInfo, getClientInfo, getNetworkTimeout, getSchema, getTypeMap, isValid, nativeSQL, prepareCall, prepareCall, prepareCall, releaseSavepoint, rollback, setCatalog, setClientInfo, setClientInfo, setNetworkTimeout, setSavepoint, setSavepoint, setSchema, setTypeMap

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 java.sql.Connection

createStatement, createStatement, createStatement, getMetaData, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement

Methods inherited from interface java.sql.Wrapper

isWrapperFor, unwrap

Constructor Detail

AbstractConnectionAdapter

protected AbstractConnectionAdapter(ShardingTransactionManagerEngine shardingTransactionManagerEngine,
                                    TransactionType transactionType)

Method Detail

getConnection

public final Connection getConnection(String dataSourceName)
                               throws SQLException

Get database connection.

Parameters:

dataSourceName - data source name

Returns:

database connection

Throws:

SQLException - SQL exception

getConnections

public final List<Connection> getConnections(org.apache.shardingsphere.core.constant.ConnectionMode connectionMode,
                                             String dataSourceName,
                                             int connectionSize)
                                      throws SQLException

Get database connections.

Parameters:

connectionMode - connection mode

dataSourceName - data source name

connectionSize - size of connection list to be get

Returns:

database connections

Throws:

SQLException - SQL exception

isSerialExecute

public boolean isSerialExecute()

Whether execute SQL serial or not.

Returns:

true or false

getDataSourceMap

protected abstract Map<String,DataSource> getDataSourceMap()

getAutoCommit

public final boolean getAutoCommit()

setAutoCommit

public final void setAutoCommit(boolean autoCommit)
                         throws SQLException

Throws:

SQLException

isOnlyLocalTransactionValid

protected abstract boolean isOnlyLocalTransactionValid()

commit

public final void commit()
                  throws SQLException

Throws:

SQLException

rollback

public final void rollback()
                    throws SQLException

Throws:

SQLException

close

public final void close()
                 throws SQLException

Throws:

SQLException

isClosed

public final boolean isClosed()

isReadOnly

public final boolean isReadOnly()

setReadOnly

public final void setReadOnly(boolean readOnly)
                       throws SQLException

Throws:

SQLException

getTransactionIsolation

public final int getTransactionIsolation()
                                  throws SQLException

Throws:

SQLException

setTransactionIsolation

public final void setTransactionIsolation(int level)
                                   throws SQLException

Throws:

SQLException

getWarnings

public final SQLWarning getWarnings()

clearWarnings

public void clearWarnings()

getHoldability

public final int getHoldability()

setHoldability

public final void setHoldability(int holdability)