io.shardingsphere.core.jdbc.core.connection

Class MasterSlaveConnection

java.lang.Object

io.shardingsphere.core.jdbc.adapter.WrapperAdapter

io.shardingsphere.core.jdbc.unsupported.AbstractUnsupportedOperationConnection

io.shardingsphere.core.jdbc.adapter.AbstractConnectionAdapter

io.shardingsphere.core.jdbc.core.connection.MasterSlaveConnection

All Implemented Interfaces:

AutoCloseable, Connection, Wrapper

public final class MasterSlaveConnection
extends AbstractConnectionAdapter

Connection that support master-slave.

Author:

zhangliang

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
MasterSlaveConnection()

Method Summary

Modifier and Type	Method and Description
Statement	createStatement()
Statement	createStatement(int resultSetType, int resultSetConcurrency)
Statement	createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)
protected Map<String,DataSource>	getDataSourceMap()
DatabaseMetaData	getMetaData()
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)

Methods inherited from class io.shardingsphere.core.jdbc.adapter.AbstractConnectionAdapter

clearWarnings, close, commit, getAutoCommit, getConnection, getHoldability, getTransactionIsolation, getWarnings, isClosed, isReadOnly, removeCache, rollback, setAutoCommit, setHoldability, setReadOnly, setTransactionIsolation

Methods inherited from class io.shardingsphere.core.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 io.shardingsphere.core.jdbc.adapter.WrapperAdapter

isWrapperFor, recordMethodInvocation, replayMethodsInvocation, throwSQLExceptionIfNecessary, 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

MasterSlaveConnection

public MasterSlaveConnection()

Method Detail

getDataSourceMap

protected Map<String,DataSource> getDataSourceMap()

Specified by:

getDataSourceMap in class AbstractConnectionAdapter

getMetaData

public DatabaseMetaData getMetaData()
                             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)

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