Package org.apache.ignite.internal.processors.odbc

Class ClientListenerAbstractConnectionContext

java.lang.Object

org.apache.ignite.internal.processors.odbc.ClientListenerAbstractConnectionContext

All Implemented Interfaces:

ClientListenerConnectionContext

Direct Known Subclasses:

ClientConnectionContext, JdbcConnectionContext, OdbcConnectionContext

public abstract class ClientListenerAbstractConnectionContext
extends Object
implements ClientListenerConnectionContext

Base connection context.

Field Summary

Fields

Modifier and Type	Field	Description
protected GridKernalContext	ctx	Kernal context.
static int	NONE_TX	Transaciton id that mean no transaction.
protected GridNioSession	ses	Nio session.
protected Map<String,String>	userAttrs	User attributes.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ClientListenerAbstractConnectionContext(GridKernalContext ctx, GridNioSession ses, long connId)	Constructor.

Method Summary

Modifier and Type	Method	Description
abstract void	addTxContext(ClientTxContext txCtx)	Add new transaction context to connection.
Map<String,String>	attributes()	Connection attributes.
protected void	authenticate(GridNioSession ses, String user, String pwd)	Perform authentication.
protected abstract void	cleanupTxs()
String	clientDescriptor()	Describes the client connection: - thin cli: "cli:host:port@user_name" - thin JDBC: "jdbc-thin:host:port@user_name" - ODBC: "odbc:host:port@user_name" Used by the running query view to display query initiator.
long	connectionId()
protected void	initClientDescriptor(String prefix)
GridKernalContext	kernalContext()
int	nextTxId()	Next transaction id for this connection.
void	onDisconnected()	Called whenever client is disconnected due to correct connection close or due to IOException during network operations.
abstract void	removeTxContext(int txId)	Remove transaction context from connection.
@Nullable SecurityContext	securityContext()
abstract @Nullable ClientTxContext	txContext(int txId)	Transaction context by transaction id.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.odbc.ClientListenerConnectionContext

clientType, defaultVersion, handler, initializeFromHandshake, isVersionSupported, parser

Field Detail

NONE_TX

public static final int NONE_TX

Transaciton id that mean no transaction.

See Also:

Constant Field Values

ctx

protected final GridKernalContext ctx

Kernal context.

ses

protected final GridNioSession ses

Nio session.

userAttrs

protected Map<String,String> userAttrs

User attributes.

Constructor Detail

ClientListenerAbstractConnectionContext

protected ClientListenerAbstractConnectionContext(GridKernalContext ctx,
                                                  GridNioSession ses,
                                                  long connId)

Constructor.

Parameters:

ctx - Kernal context.

ses - Client's NIO session.

connId - Connection ID.

Method Detail

kernalContext

public GridKernalContext kernalContext()

Returns:

Kernal context.

securityContext

@Nullable
public @Nullable SecurityContext securityContext()

Specified by:

securityContext in interface ClientListenerConnectionContext

Returns:

Security context.

connectionId

public long connectionId()

Specified by:

connectionId in interface ClientListenerConnectionContext

Returns:

Current connection id.

authenticate

protected void authenticate(GridNioSession ses,
                            String user,
                            String pwd)
                     throws IgniteCheckedException

Perform authentication.

Throws:

IgniteCheckedException - If failed.

onDisconnected

public void onDisconnected()

Called whenever client is disconnected due to correct connection close or due to IOException during network operations.

Specified by:

onDisconnected in interface ClientListenerConnectionContext

initClientDescriptor

protected void initClientDescriptor(String prefix)

clientDescriptor

public String clientDescriptor()

Describes the client connection: - thin cli: "cli:host:port@user_name" - thin JDBC: "jdbc-thin:host:port@user_name" - ODBC: "odbc:host:port@user_name" Used by the running query view to display query initiator.

Returns:

Client descriptor string.

nextTxId

public int nextTxId()

Next transaction id for this connection.

txContext

@Nullable
public abstract @Nullable ClientTxContext txContext(int txId)

Transaction context by transaction id.

Parameters:

txId - Tx ID.

addTxContext

public abstract void addTxContext(ClientTxContext txCtx)

Add new transaction context to connection.

Parameters:

txCtx - Tx context.

removeTxContext

public abstract void removeTxContext(int txId)

Remove transaction context from connection.

Parameters:

txId - Tx ID.

cleanupTxs

protected abstract void cleanupTxs()

attributes

public Map<String,String> attributes()

Connection attributes.

Specified by:

attributes in interface ClientListenerConnectionContext