Package com.nuodb.jdbc
Class RemConnection
- java.lang.Object
-
- com.nuodb.jdbc.RemConnection
-
- All Implemented Interfaces:
Connection,AutoCloseable,Connection,Wrapper
public class RemConnection extends Object implements Connection
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interfaceRemConnection.ErrorHandler
-
Field Summary
Fields Modifier and Type Field Description static intBROKER_PORTstatic StringCLIENT_INFOstatic StringDEFAULT_CIPHERstatic StringJKS_KEYSTORE_TYPEstatic StringLOB_CHUNK_SIZEstatic intLOB_CHUNK_SIZE_DEFAULTstatic StringLOB_CHUNKING_ENABLEDstatic booleanLOB_CHUNKING_ENABLED_DEFAULTstatic longMAX_MESSAGE_LENGTHstatic StringPKCS12_KEYSTORE_TYPEstatic StringTIMEZONE_NAMEstatic intTRANSACTION_ENGINE_PORT-
Fields inherited from interface java.sql.Connection
TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE
-
-
Method Summary
-
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface java.sql.Connection
beginRequest, endRequest, setShardingKey, setShardingKey, setShardingKeyIfValid, setShardingKeyIfValid
-
-
-
-
Field Detail
-
TIMEZONE_NAME
public static final String TIMEZONE_NAME
- See Also:
- Constant Field Values
-
BROKER_PORT
public static final int BROKER_PORT
- See Also:
- Constant Field Values
-
TRANSACTION_ENGINE_PORT
public static final int TRANSACTION_ENGINE_PORT
- See Also:
- Constant Field Values
-
MAX_MESSAGE_LENGTH
public static final long MAX_MESSAGE_LENGTH
-
DEFAULT_CIPHER
public static final String DEFAULT_CIPHER
- See Also:
- Constant Field Values
-
LOB_CHUNK_SIZE
public static final String LOB_CHUNK_SIZE
- See Also:
- Constant Field Values
-
LOB_CHUNKING_ENABLED
public static final String LOB_CHUNKING_ENABLED
- See Also:
- Constant Field Values
-
CLIENT_INFO
public static final String CLIENT_INFO
- See Also:
- Constant Field Values
-
LOB_CHUNKING_ENABLED_DEFAULT
public static final boolean LOB_CHUNKING_ENABLED_DEFAULT
- See Also:
- Constant Field Values
-
LOB_CHUNK_SIZE_DEFAULT
public static final int LOB_CHUNK_SIZE_DEFAULT
- See Also:
- Constant Field Values
-
JKS_KEYSTORE_TYPE
public static final String JKS_KEYSTORE_TYPE
- See Also:
- Constant Field Values
-
PKCS12_KEYSTORE_TYPE
public static final String PKCS12_KEYSTORE_TYPE
- See Also:
- Constant Field Values
-
-
Method Detail
-
getSQLContext
public SQLContext getSQLContext()
- Specified by:
getSQLContextin interfaceConnection
-
getServerSideConnectionId
public int getServerSideConnectionId()
- Specified by:
getServerSideConnectionIdin interfaceConnection
-
getEffectivePlatformVersion
public int getEffectivePlatformVersion()
- Specified by:
getEffectivePlatformVersionin interfaceConnection
-
getConnectedNodeId
public int getConnectedNodeId()
- Specified by:
getConnectedNodeIdin interfaceConnection
-
getGlobalConnectionId
public long getGlobalConnectionId()
- Specified by:
getGlobalConnectionIdin interfaceConnection
-
getErrorHandler
public RemConnection.ErrorHandler getErrorHandler()
-
clearWarnings
public void clearWarnings() throws SQLException- Specified by:
clearWarningsin interfaceConnection- Throws:
SQLException
-
close
public void close() throws SQLException- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceConnection- Throws:
SQLException
-
getLogger
public Logger getLogger()
-
commit
public void commit() throws SQLException- Specified by:
commitin interfaceConnection- Throws:
SQLException
-
prepare
public int prepare(NuoXid nXid) throws SQLException
- Throws:
SQLException
-
recover
public NuoXid[] recover() throws SQLException
- Throws:
SQLException
-
recoverByCommit
public void recoverByCommit(long nuodbTransId) throws SQLException- Throws:
SQLException
-
recoverByRollback
public void recoverByRollback(long nuodbTransId) throws SQLException- Throws:
SQLException
-
createArrayOf
public com.nuodb.jdbc.Array createArrayOf(String typeName, Object[] elements) throws SQLException
- Specified by:
createArrayOfin interfaceConnection- Throws:
SQLException
-
createBlob
public Blob createBlob() throws SQLException
- Specified by:
createBlobin interfaceConnection- Throws:
SQLException
-
createClob
public Clob createClob() throws SQLException
- Specified by:
createClobin interfaceConnection- Throws:
SQLException
-
createNClob
public NClob createNClob() throws SQLException
- Specified by:
createNClobin interfaceConnection- Throws:
SQLException
-
createSQLXML
public SQLXML createSQLXML() throws SQLException
- Specified by:
createSQLXMLin interfaceConnection- Throws:
SQLException
-
createStatement
public Statement createStatement() throws SQLException
- Specified by:
createStatementin interfaceConnection- Throws:
SQLException
-
createStatement
public Statement createStatement(int resultSetType, int resultSetConcurrency) throws SQLException
- Specified by:
createStatementin interfaceConnection- Throws:
SQLException
-
createStatement
public Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
- Specified by:
createStatementin interfaceConnection- Throws:
SQLException
-
createStruct
public com.nuodb.jdbc.Struct createStruct(String typeName, Object[] attributes) throws SQLException
- Specified by:
createStructin interfaceConnection- Throws:
SQLException
-
getAutoCommit
public boolean getAutoCommit() throws SQLException- Specified by:
getAutoCommitin interfaceConnection- Throws:
SQLException
-
getCatalog
public String getCatalog() throws SQLException
- Specified by:
getCatalogin interfaceConnection- Throws:
SQLException
-
getClientInfo
public Properties getClientInfo() throws SQLException
- Specified by:
getClientInfoin interfaceConnection- Throws:
SQLException
-
getClientInfo
public String getClientInfo(String name) throws SQLException
- Specified by:
getClientInfoin interfaceConnection- Throws:
SQLException
-
getHoldability
public int getHoldability() throws SQLException- Specified by:
getHoldabilityin interfaceConnection- Throws:
SQLException
-
getMetaData
public DatabaseMetaData getMetaData() throws SQLException
- Specified by:
getMetaDatain interfaceConnection- Throws:
SQLException
-
getTransactionIsolation
public int getTransactionIsolation() throws SQLException- Specified by:
getTransactionIsolationin interfaceConnection- Throws:
SQLException
-
getTypeMap
public Map<String,Class<?>> getTypeMap() throws SQLException
- Specified by:
getTypeMapin interfaceConnection- Throws:
SQLException
-
getWarnings
public SQLWarning getWarnings() throws SQLException
- Specified by:
getWarningsin interfaceConnection- Throws:
SQLException
-
isClosed
public boolean isClosed() throws SQLException- Specified by:
isClosedin interfaceConnection- Throws:
SQLException
-
isReadOnly
public boolean isReadOnly() throws SQLException- Specified by:
isReadOnlyin interfaceConnection- Throws:
SQLException
-
isValid
public boolean isValid(int timeout) throws SQLException- Specified by:
isValidin interfaceConnection- Throws:
SQLException
-
nativeSQL
public String nativeSQL(String sql) throws SQLException
- Specified by:
nativeSQLin interfaceConnection- Throws:
SQLException
-
prepareCall
public CallableStatement prepareCall(String sql) throws SQLException
- Specified by:
prepareCallin interfaceConnection- Throws:
SQLException
-
prepareCall
public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency) throws SQLException
- Specified by:
prepareCallin interfaceConnection- Throws:
SQLException
-
prepareCall
public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
- Specified by:
prepareCallin interfaceConnection- Throws:
SQLException
-
prepareStatement
public PreparedStatement prepareStatement(String sql) throws SQLException
- Specified by:
prepareStatementin interfaceConnection- Throws:
SQLException
-
prepareStatement
public PreparedStatement prepareStatement(String sql, int autoGeneratedKeys) throws SQLException
- Specified by:
prepareStatementin interfaceConnection- Throws:
SQLException
-
prepareStatement
public PreparedStatement prepareStatement(String sql, int[] columnIndexes) throws SQLException
- Specified by:
prepareStatementin interfaceConnection- Throws:
SQLException
-
prepareStatement
public PreparedStatement prepareStatement(String sql, String[] columnNames) throws SQLException
- Specified by:
prepareStatementin interfaceConnection- Throws:
SQLException
-
prepareStatement
public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency) throws SQLException
- Specified by:
prepareStatementin interfaceConnection- Throws:
SQLException
-
prepareStatement
public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
- Specified by:
prepareStatementin interfaceConnection- Throws:
SQLException
-
releaseSavepoint
public void releaseSavepoint(Savepoint savepoint) throws SQLException
- Specified by:
releaseSavepointin interfaceConnection- Throws:
SQLException
-
rollback
public void rollback() throws SQLException- Specified by:
rollbackin interfaceConnection- Throws:
SQLException
-
rollback
public void rollback(Savepoint savepoint) throws SQLException
- Specified by:
rollbackin interfaceConnection- Throws:
SQLException
-
setAutoCommit
public void setAutoCommit(boolean autoCommit) throws SQLException- Specified by:
setAutoCommitin interfaceConnection- Throws:
SQLException
-
setCatalog
public void setCatalog(String catalog) throws SQLException
- Specified by:
setCatalogin interfaceConnection- Throws:
SQLException
-
setClientInfo
public void setClientInfo(Properties properties) throws SQLClientInfoException
- Specified by:
setClientInfoin interfaceConnection- Throws:
SQLClientInfoException
-
setClientInfo
public void setClientInfo(String name, String value) throws SQLClientInfoException
- Specified by:
setClientInfoin interfaceConnection- Throws:
SQLClientInfoException
-
setHoldability
public void setHoldability(int holdability) throws SQLException- Specified by:
setHoldabilityin interfaceConnection- Throws:
SQLException
-
setReadOnly
public void setReadOnly(boolean readOnly) throws SQLException- Specified by:
setReadOnlyin interfaceConnection- Throws:
SQLException
-
setSavepoint
public Savepoint setSavepoint() throws SQLException
- Specified by:
setSavepointin interfaceConnection- Throws:
SQLException
-
setSavepoint
public Savepoint setSavepoint(String name) throws SQLException
- Specified by:
setSavepointin interfaceConnection- Throws:
SQLException
-
setTransactionIsolation
public void setTransactionIsolation(int level) throws SQLException- Specified by:
setTransactionIsolationin interfaceConnection- Throws:
SQLException
-
setTypeMap
public void setTypeMap(Map<String,Class<?>> map) throws SQLException
- Specified by:
setTypeMapin interfaceConnection- Throws:
SQLException
-
isWrapperFor
public boolean isWrapperFor(Class<?> iface) throws SQLException
- Specified by:
isWrapperForin interfaceWrapper- Throws:
SQLException
-
unwrap
public <T> T unwrap(Class<T> iface) throws SQLException
- Specified by:
unwrapin interfaceWrapper- Throws:
SQLException
-
getDriverName
public static String getDriverName() throws SQLException
- Throws:
SQLException
-
getDriverVersion
public static String getDriverVersion() throws SQLException
- Throws:
SQLException
-
describeClientInfo
public static String describeClientInfo()
-
createSSLSocket
public void createSSLSocket(SSLContext sslContext, String host, int port) throws IOException
- Throws:
IOException
-
openDatabase
public void openDatabase(String host, int port, String databaseName, Properties properties, String url) throws SQLException
- Throws:
SQLException
-
setSocketTimeout
public void setSocketTimeout(int timeout)
-
sendAndReceive
public void sendAndReceive(EncodedDataStream stream) throws SQLException
- Throws:
SQLException
-
raiseStateException
public static void raiseStateException(String message, String state, int code) throws SQLException
- Throws:
SQLException
-
sendAndReceive
public void sendAndReceive(EncodedDataStream stream, Long maxLength) throws SQLException
- Throws:
SQLException
-
sendAsync
public void sendAsync(EncodedDataStream stream) throws SQLException
- Throws:
SQLException
-
getTimeout
public int getTimeout() throws SQLException- Throws:
SQLException
-
abort
public void abort(Executor executor) throws SQLException
- Specified by:
abortin interfaceConnection- Throws:
SQLException
-
getNetworkTimeout
public int getNetworkTimeout() throws SQLException- Specified by:
getNetworkTimeoutin interfaceConnection- Throws:
SQLException
-
getSchema
public String getSchema() throws SQLException
- Specified by:
getSchemain interfaceConnection- Throws:
SQLException
-
setNetworkTimeout
public void setNetworkTimeout(Executor executor, int milliseconds) throws SQLException
- Specified by:
setNetworkTimeoutin interfaceConnection- Throws:
SQLException
-
setSchema
public void setSchema(String schema) throws SQLException
- Specified by:
setSchemain interfaceConnection- Throws:
SQLException
-
isInGlobalTx
public boolean isInGlobalTx()
-
setInGlobalTx
public void setInGlobalTx(boolean flag) throws SQLException- Throws:
SQLException
-
getXaTransState
public int getXaTransState()
-
setXaTransState
public void setXaTransState(int state)
-
closeSocket
public void closeSocket()
-
getCryptoInputStream
public com.nuodb.impl.net.CryptoInputStream getCryptoInputStream()
-
getCryptoOutputStream
public com.nuodb.impl.net.CryptoOutputStream getCryptoOutputStream()
-
getSocket
public Socket getSocket()
-
-