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

类 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

所有已实现的接口:

AutoCloseable, Connection, Wrapper

public final class ShardingConnection
extends AbstractConnectionAdapter

Connection that support sharding.

字段概要

从接口继承的字段 java.sql.Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

构造器概要

构造器

构造器和说明
ShardingConnection(Map<String,DataSource> dataSourceMap, ShardingRuntimeContext runtimeContext, TransactionType transactionType)

方法概要

限定符和类型	方法和说明
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)

从类继承的方法 org.apache.shardingsphere.shardingjdbc.jdbc.adapter.AbstractConnectionAdapter

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

从类继承的方法 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

从类继承的方法 org.apache.shardingsphere.shardingjdbc.jdbc.adapter.WrapperAdapter

isWrapperFor, recordMethodInvocation, replayMethodsInvocation, unwrap

从类继承的方法 java.lang.Object

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

从接口继承的方法 java.sql.Wrapper

isWrapperFor, unwrap

构造器详细资料

ShardingConnection

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

方法详细资料

isHoldTransaction

public boolean isHoldTransaction()

Whether hold transaction or not.

返回:

true or false

createConnection

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

指定者:

createConnection 在类中 AbstractConnectionAdapter

抛出:

SQLException

getMetaData

public DatabaseMetaData getMetaData()

prepareStatement

public PreparedStatement prepareStatement(String sql)
                                   throws SQLException

抛出:

SQLException

prepareStatement

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

抛出:

SQLException

prepareStatement

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

抛出:

SQLException

prepareStatement

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

抛出:

SQLException

prepareStatement

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

抛出:

SQLException

prepareStatement

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

抛出:

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

指定者:

setAutoCommit 在接口中 Connection

覆盖:

setAutoCommit 在类中 AbstractConnectionAdapter

抛出:

SQLException

commit

public void commit()
            throws SQLException

指定者:

commit 在接口中 Connection

覆盖:

commit 在类中 AbstractConnectionAdapter

抛出:

SQLException

rollback

public void rollback()
              throws SQLException

指定者:

rollback 在接口中 Connection

覆盖:

rollback 在类中 AbstractConnectionAdapter

抛出:

SQLException