org.apache.shardingsphere.shardingjdbc.jdbc.core.connection

Class ShardingConnection

java.lang.Object

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

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

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

org.apache.shardingsphere.shardingjdbc.jdbc.core.connection.ShardingConnection

All Implemented Interfaces:

AutoCloseable, Connection, Wrapper

public final class ShardingConnection
extends AbstractConnectionAdapter

Connection that support sharding.

Author:

zhangliang, caohao, gaohongtao, zhaojun

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

Constructor and Description
ShardingConnection(Map<String,DataSource> dataSourceMap, ShardingRuntimeContext runtimeContext, TransactionType transactionType)

Method Summary

Modifier and Type	Method and Description
void	commit()
protected Connection	createConnection(String dataSourceName, DataSource dataSource)
Statement	createStatement()
Statement	createStatement(int resultSetType, int resultSetConcurrency)
Statement	createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)
DatabaseMetaData	getMetaData()
boolean	isHoldTransaction() Whether hold transaction or not.
PreparedStatement	prepareStatement(String sql)
PreparedStatement	prepareStatement(String sql, int autoGeneratedKeys)
PreparedStatement	prepareStatement(String sql, int[] columnIndexes)
PreparedStatement	prepareStatement(String sql, int resultSetType, int resultSetConcurrency)
PreparedStatement	prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)
PreparedStatement	prepareStatement(String sql, String[] columnNames)
void	rollback()
void	setAutoCommit(boolean autoCommit)

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

clearWarnings, close, getAutoCommit, getConnection, getConnections, getDataSourceMap, getHoldability, getTransactionIsolation, getWarnings, isClosed, isReadOnly, setHoldability, setReadOnly, setTransactionIsolation

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.Wrapper

isWrapperFor, unwrap

Constructor Detail

ShardingConnection

public ShardingConnection(Map<String,DataSource> dataSourceMap,
                          ShardingRuntimeContext runtimeContext,
                          TransactionType transactionType)

Method Detail

isHoldTransaction

public boolean isHoldTransaction()

Whether hold transaction or not.

Returns:

true or false

createConnection

protected Connection createConnection(String dataSourceName,
                                      DataSource dataSource)
                               throws SQLException

Specified by:

createConnection in class AbstractConnectionAdapter

Throws:

SQLException

getMetaData

public DatabaseMetaData getMetaData()
                             throws SQLException

Throws:

SQLException

prepareStatement

public PreparedStatement prepareStatement(String sql)
                                   throws SQLException

Throws:

SQLException

prepareStatement

public PreparedStatement prepareStatement(String sql,
                                          int resultSetType,
                                          int resultSetConcurrency)
                                   throws SQLException

Throws:

SQLException

prepareStatement

public PreparedStatement prepareStatement(String sql,
                                          int resultSetType,
                                          int resultSetConcurrency,
                                          int resultSetHoldability)
                                   throws SQLException

Throws:

SQLException

prepareStatement

public PreparedStatement prepareStatement(String sql,
                                          int autoGeneratedKeys)
                                   throws SQLException

Throws:

SQLException

prepareStatement

public PreparedStatement prepareStatement(String sql,
                                          int[] columnIndexes)
                                   throws SQLException

Throws:

SQLException

prepareStatement

public PreparedStatement prepareStatement(String sql,
                                          String[] columnNames)
                                   throws SQLException

Throws:

SQLException

createStatement

public Statement createStatement()

createStatement

public Statement createStatement(int resultSetType,
                                 int resultSetConcurrency)

createStatement

public Statement createStatement(int resultSetType,
                                 int resultSetConcurrency,
                                 int resultSetHoldability)

setAutoCommit

public void setAutoCommit(boolean autoCommit)
                   throws SQLException

Specified by:

setAutoCommit in interface Connection

Overrides:

setAutoCommit in class AbstractConnectionAdapter

Throws:

SQLException

commit

public void commit()
            throws SQLException

Specified by:

commit in interface Connection

Overrides:

commit in class AbstractConnectionAdapter

Throws:

SQLException

rollback

public void rollback()
              throws SQLException

Specified by:

rollback in interface Connection

Overrides:

rollback in class AbstractConnectionAdapter

Throws:

SQLException