Class OdbcConnectionContext
- java.lang.Object
-
- org.apache.ignite.internal.processors.odbc.ClientListenerAbstractConnectionContext
-
- org.apache.ignite.internal.processors.odbc.odbc.OdbcConnectionContext
-
- All Implemented Interfaces:
ClientListenerConnectionContext
public class OdbcConnectionContext extends ClientListenerAbstractConnectionContext
ODBC Connection Context.
-
-
Field Summary
Fields Modifier and Type Field Description static ClientListenerProtocolVersionVER_2_1_0Version 2.1.0.static ClientListenerProtocolVersionVER_2_1_5Version 2.1.5: added "lazy" flag.static ClientListenerProtocolVersionVER_2_13_0Version 2.13.0: added ability to choose of query engine support.static ClientListenerProtocolVersionVER_2_3_0Version 2.3.0: added "skipReducerOnUpdate" flag.static ClientListenerProtocolVersionVER_2_3_2Version 2.3.2: added multiple statements support.static ClientListenerProtocolVersionVER_2_5_0Version 2.5.0: added authentication.static ClientListenerProtocolVersionVER_2_7_0Version 2.7.0: added precision and scale.static ClientListenerProtocolVersionVER_2_8_0Version 2.8.0: added column nullability info.-
Fields inherited from class org.apache.ignite.internal.processors.odbc.ClientListenerAbstractConnectionContext
ctx, NONE_TX, ses, userAttrs
-
-
Constructor Summary
Constructors Constructor Description OdbcConnectionContext(GridKernalContext ctx, GridNioSession ses, GridSpinBusyLock busyLock, long connId, int maxCursors)Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddTxContext(ClientTxContext txCtx)Add new transaction context to connection.protected voidcleanupTxs()byteclientType()ClientListenerProtocolVersiondefaultVersion()ClientListenerRequestHandlerhandler()Handler getter.voidinitializeFromHandshake(GridNioSession ses, ClientListenerProtocolVersion ver, BinaryReaderExImpl reader)Initialize from handshake message.booleanisVersionSupported(ClientListenerProtocolVersion ver)voidonDisconnected()Called whenever client is disconnected due to correct connection close or due toIOExceptionduring network operations.ClientListenerMessageParserparser()Parser gettervoidremoveTxContext(int txId)Remove transaction context from connection.ClientTxContexttxContext(int txId)Transaction context by transaction id.-
Methods inherited from class org.apache.ignite.internal.processors.odbc.ClientListenerAbstractConnectionContext
attributes, authenticate, clientDescriptor, connectionId, initClientDescriptor, kernalContext, nextTxId, securityContext
-
-
-
-
Field Detail
-
VER_2_1_0
public static final ClientListenerProtocolVersion VER_2_1_0
Version 2.1.0.
-
VER_2_1_5
public static final ClientListenerProtocolVersion VER_2_1_5
Version 2.1.5: added "lazy" flag.
-
VER_2_3_0
public static final ClientListenerProtocolVersion VER_2_3_0
Version 2.3.0: added "skipReducerOnUpdate" flag.
-
VER_2_3_2
public static final ClientListenerProtocolVersion VER_2_3_2
Version 2.3.2: added multiple statements support.
-
VER_2_5_0
public static final ClientListenerProtocolVersion VER_2_5_0
Version 2.5.0: added authentication.
-
VER_2_7_0
public static final ClientListenerProtocolVersion VER_2_7_0
Version 2.7.0: added precision and scale.
-
VER_2_8_0
public static final ClientListenerProtocolVersion VER_2_8_0
Version 2.8.0: added column nullability info.
-
VER_2_13_0
public static final ClientListenerProtocolVersion VER_2_13_0
Version 2.13.0: added ability to choose of query engine support.
-
-
Constructor Detail
-
OdbcConnectionContext
public OdbcConnectionContext(GridKernalContext ctx, GridNioSession ses, GridSpinBusyLock busyLock, long connId, int maxCursors)
Constructor.- Parameters:
ctx- Kernal Context.ses- Client's NIO session.busyLock- Shutdown busy lock.connId- Connection ID.maxCursors- Maximum allowed cursors.
-
-
Method Detail
-
clientType
public byte clientType()
- Returns:
- Client type.
-
isVersionSupported
public boolean isVersionSupported(ClientListenerProtocolVersion ver)
- Parameters:
ver- Version to check.- Returns:
trueif version is supported.
-
defaultVersion
public ClientListenerProtocolVersion defaultVersion()
- Returns:
- Current context version.
-
initializeFromHandshake
public void initializeFromHandshake(GridNioSession ses, ClientListenerProtocolVersion ver, BinaryReaderExImpl reader) throws IgniteCheckedException
Initialize from handshake message.- Parameters:
ses- NIO session.ver- Protocol version.reader- Reader set to the configuration part of the handshake message.- Throws:
IgniteCheckedException- On error.
-
handler
public ClientListenerRequestHandler handler()
Handler getter.- Returns:
- Request handler for the connection.
-
parser
public ClientListenerMessageParser parser()
Parser getter- Returns:
- Message parser for the connection.
-
onDisconnected
public void onDisconnected()
Called whenever client is disconnected due to correct connection close or due toIOExceptionduring network operations.- Specified by:
onDisconnectedin interfaceClientListenerConnectionContext- Overrides:
onDisconnectedin classClientListenerAbstractConnectionContext
-
txContext
public ClientTxContext txContext(int txId)
Transaction context by transaction id.- Specified by:
txContextin classClientListenerAbstractConnectionContext- Parameters:
txId- Tx ID.
-
addTxContext
public void addTxContext(ClientTxContext txCtx)
Add new transaction context to connection.- Specified by:
addTxContextin classClientListenerAbstractConnectionContext- Parameters:
txCtx- Tx context.
-
removeTxContext
public void removeTxContext(int txId)
Remove transaction context from connection.- Specified by:
removeTxContextin classClientListenerAbstractConnectionContext- Parameters:
txId- Tx ID.
-
cleanupTxs
protected void cleanupTxs()
- Specified by:
cleanupTxsin classClientListenerAbstractConnectionContext
-
-