Class OdbcRequestHandler
- java.lang.Object
-
- org.apache.ignite.internal.processors.odbc.odbc.OdbcRequestHandler
-
- All Implemented Interfaces:
ClientListenerRequestHandler
public class OdbcRequestHandler extends Object implements ClientListenerRequestHandler
SQL query handler.
-
-
Constructor Summary
Constructors Constructor Description OdbcRequestHandler(GridKernalContext ctx, GridSpinBusyLock busyLock, ClientListenerResponseSender sender, int maxCursors, boolean distributedJoins, boolean enforceJoinOrder, boolean replicatedOnly, boolean collocated, boolean lazy, boolean skipReducerOnUpdate, @Nullable String qryEngine, ClientListenerProtocolVersion ver, OdbcConnectionContext connCtx)Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ClientListenerResponsedoHandle(OdbcRequest req)Handle ODBC request.ClientListenerResponsehandle(ClientListenerRequest req)Handle request.ClientListenerResponsehandleException(Throwable e, ClientListenerRequest req)Handle exception.booleanisCancellationCommand(int cmdId)Detect whether given command is a cancellation command.booleanisCancellationSupported()Checks whether query cancellation is supported within given version of protocol.voidonDisconnect()Called whenever client is disconnected due to correct connection close or due toIOExceptionduring network operations.ClientListenerProtocolVersionprotocolVersion()voidregisterRequest(long reqId, int cmdType)Registers request for futher cancellation if any.voidunregisterRequest(long reqId)Try to unregister request.voidwriteHandshake(BinaryWriterExImpl writer)Write successful handshake response.
-
-
-
Constructor Detail
-
OdbcRequestHandler
public OdbcRequestHandler(GridKernalContext ctx, GridSpinBusyLock busyLock, ClientListenerResponseSender sender, int maxCursors, boolean distributedJoins, boolean enforceJoinOrder, boolean replicatedOnly, boolean collocated, boolean lazy, boolean skipReducerOnUpdate, @Nullable @Nullable String qryEngine, ClientListenerProtocolVersion ver, OdbcConnectionContext connCtx)
Constructor.- Parameters:
ctx- Context.busyLock- Shutdown latch.sender- Results sender.maxCursors- Maximum allowed cursors.distributedJoins- Distributed joins flag.enforceJoinOrder- Enforce join order flag.replicatedOnly- Replicated only flag.collocated- Collocated flag.lazy- Lazy flag.skipReducerOnUpdate- Skip reducer on update flag.qryEngine- Name of SQL query engine to use.ver- Client protocol version.
-
-
Method Detail
-
handle
public ClientListenerResponse handle(ClientListenerRequest req)
Handle request.- Specified by:
handlein interfaceClientListenerRequestHandler- Parameters:
req- Request.- Returns:
- Response.
-
doHandle
public ClientListenerResponse doHandle(OdbcRequest req)
Handle ODBC request.- Parameters:
req- ODBC request.- Returns:
- Response.
-
handleException
public ClientListenerResponse handleException(Throwable e, ClientListenerRequest req)
Handle exception.- Specified by:
handleExceptionin interfaceClientListenerRequestHandler- Parameters:
e- Exception.req- Request.- Returns:
- Error response.
-
writeHandshake
public void writeHandshake(BinaryWriterExImpl writer)
Write successful handshake response.- Specified by:
writeHandshakein interfaceClientListenerRequestHandler- Parameters:
writer- Binary writer.
-
onDisconnect
public void onDisconnect()
Called whenever client is disconnected due to correct connection close or due toIOExceptionduring network operations.
-
isCancellationCommand
public boolean isCancellationCommand(int cmdId)
Detect whether given command is a cancellation command.- Specified by:
isCancellationCommandin interfaceClientListenerRequestHandler- Parameters:
cmdId- Command Id- Returns:
- true if given command is cancellation one, false otherwise;
-
isCancellationSupported
public boolean isCancellationSupported()
Checks whether query cancellation is supported within given version of protocol.- Specified by:
isCancellationSupportedin interfaceClientListenerRequestHandler- Returns:
trueif supported,falseotherwise.
-
registerRequest
public void registerRequest(long reqId, int cmdType)Registers request for futher cancellation if any.- Specified by:
registerRequestin interfaceClientListenerRequestHandler- Parameters:
reqId- Request Id.cmdType- Command Type.
-
unregisterRequest
public void unregisterRequest(long reqId)
Try to unregister request.- Specified by:
unregisterRequestin interfaceClientListenerRequestHandler- Parameters:
reqId- Request Id.
-
protocolVersion
public ClientListenerProtocolVersion protocolVersion()
- Specified by:
protocolVersionin interfaceClientListenerRequestHandler- Returns:
- Protocol version.
-
-