org.apache.shardingsphere.driver.jdbc.core.connection

Class ShardingSphereConnection

java.lang.Object

org.apache.shardingsphere.driver.jdbc.adapter.WrapperAdapter

org.apache.shardingsphere.driver.jdbc.unsupported.AbstractUnsupportedOperationConnection

org.apache.shardingsphere.driver.jdbc.adapter.AbstractConnectionAdapter

org.apache.shardingsphere.driver.jdbc.core.connection.ShardingSphereConnection

All Implemented Interfaces:

AutoCloseable, Connection, Wrapper, org.apache.shardingsphere.infra.executor.sql.prepare.driver.ExecutorDriverManager<Connection,Statement,org.apache.shardingsphere.infra.executor.sql.prepare.driver.jdbc.StatementOption>, org.apache.shardingsphere.infra.executor.sql.prepare.driver.jdbc.ExecutorJDBCManager

public final class ShardingSphereConnection
extends AbstractConnectionAdapter
implements org.apache.shardingsphere.infra.executor.sql.prepare.driver.jdbc.ExecutorJDBCManager

ShardingSphere Connection.

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
ShardingSphereConnection(Map<String,DataSource> dataSourceMap, MetaDataContexts metaDataContexts, TransactionContexts transactionContexts, TransactionType transactionType)

Method Summary

Modifier and Type	Method and Description
void	commit()
Array	createArrayOf(String typeName, Object[] elements)
Statement	createStatement()
Statement	createStatement(int resultSetType, int resultSetConcurrency)
Statement	createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)
Statement	createStorageResource(Connection connection, org.apache.shardingsphere.infra.executor.sql.execute.engine.ConnectionMode connectionMode, org.apache.shardingsphere.infra.executor.sql.prepare.driver.jdbc.StatementOption option)
PreparedStatement	createStorageResource(String sql, List<Object> parameters, Connection connection, org.apache.shardingsphere.infra.executor.sql.execute.engine.ConnectionMode connectionMode, org.apache.shardingsphere.infra.executor.sql.prepare.driver.jdbc.StatementOption option)
boolean	getAutoCommit()
Connection	getConnection(String dataSourceName) Get database connection.
List<Connection>	getConnections(String dataSourceName, int connectionSize, org.apache.shardingsphere.infra.executor.sql.execute.engine.ConnectionMode connectionMode)
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.driver.jdbc.adapter.AbstractConnectionAdapter

clearWarnings, close, getCatalog, getHoldability, getSchema, getTransactionIsolation, getWarnings, isClosed, isReadOnly, isValid, setCatalog, setHoldability, setReadOnly, setSchema, setTransactionIsolation

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

abort, createBlob, createClob, createNClob, createSQLXML, createStruct, getClientInfo, getClientInfo, getNetworkTimeout, getTypeMap, nativeSQL, prepareCall, prepareCall, prepareCall, releaseSavepoint, rollback, setClientInfo, setClientInfo, setNetworkTimeout, setSavepoint, setSavepoint, setTypeMap

Methods inherited from class org.apache.shardingsphere.driver.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

ShardingSphereConnection

public ShardingSphereConnection(Map<String,DataSource> dataSourceMap,
                                MetaDataContexts metaDataContexts,
                                TransactionContexts transactionContexts,
                                TransactionType transactionType)

Method Detail

getConnection

public Connection getConnection(String dataSourceName)
                         throws SQLException

Get database connection.

Parameters:

dataSourceName - data source name

Returns:

database connection

Throws:

SQLException - SQL exception

getConnections

public List<Connection> getConnections(String dataSourceName,
                                       int connectionSize,
                                       org.apache.shardingsphere.infra.executor.sql.execute.engine.ConnectionMode connectionMode)
                                throws SQLException

Specified by:

getConnections in interface org.apache.shardingsphere.infra.executor.sql.prepare.driver.ExecutorDriverManager<Connection,Statement,org.apache.shardingsphere.infra.executor.sql.prepare.driver.jdbc.StatementOption>

Throws:

SQLException

isHoldTransaction

public boolean isHoldTransaction()

Whether hold transaction or not.

Returns:

true or false

createStorageResource

public Statement createStorageResource(Connection connection,
                                       org.apache.shardingsphere.infra.executor.sql.execute.engine.ConnectionMode connectionMode,
                                       org.apache.shardingsphere.infra.executor.sql.prepare.driver.jdbc.StatementOption option)
                                throws SQLException

Specified by:

createStorageResource in interface org.apache.shardingsphere.infra.executor.sql.prepare.driver.ExecutorDriverManager<Connection,Statement,org.apache.shardingsphere.infra.executor.sql.prepare.driver.jdbc.StatementOption>

Throws:

SQLException

createStorageResource

public PreparedStatement createStorageResource(String sql,
                                               List<Object> parameters,
                                               Connection connection,
                                               org.apache.shardingsphere.infra.executor.sql.execute.engine.ConnectionMode connectionMode,
                                               org.apache.shardingsphere.infra.executor.sql.prepare.driver.jdbc.StatementOption option)
                                        throws SQLException

Specified by:

createStorageResource in interface org.apache.shardingsphere.infra.executor.sql.prepare.driver.ExecutorDriverManager<Connection,Statement,org.apache.shardingsphere.infra.executor.sql.prepare.driver.jdbc.StatementOption>

Throws:

SQLException

getMetaData

public DatabaseMetaData getMetaData()

Specified by:

getMetaData in interface Connection

prepareStatement

public PreparedStatement prepareStatement(String sql)
                                   throws SQLException

Specified by:

prepareStatement in interface Connection

Throws:

SQLException

prepareStatement

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

Specified by:

prepareStatement in interface Connection

Throws:

SQLException

prepareStatement

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

Specified by:

prepareStatement in interface Connection

Throws:

SQLException

prepareStatement

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

Specified by:

prepareStatement in interface Connection

Throws:

SQLException

prepareStatement

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

Specified by:

prepareStatement in interface Connection

Throws:

SQLException

prepareStatement

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

Specified by:

prepareStatement in interface Connection

Throws:

SQLException

createStatement

public Statement createStatement()

Specified by:

createStatement in interface Connection

createStatement

public Statement createStatement(int resultSetType,
                                 int resultSetConcurrency)

Specified by:

createStatement in interface Connection

createStatement

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

Specified by:

createStatement in interface Connection

getAutoCommit

public boolean getAutoCommit()

Specified by:

getAutoCommit in interface Connection

setAutoCommit

public void setAutoCommit(boolean autoCommit)
                   throws SQLException

Specified by:

setAutoCommit in interface Connection

Throws:

SQLException

commit

public void commit()
            throws SQLException

Specified by:

commit in interface Connection

Throws:

SQLException

rollback

public void rollback()
              throws SQLException

Specified by:

rollback in interface Connection

Throws:

SQLException

createArrayOf

public Array createArrayOf(String typeName,
                           Object[] elements)
                    throws SQLException

Specified by:

createArrayOf in interface Connection

Throws:

SQLException