org.apache.ignite.internal.jdbc.thin

Class JdbcThinTcpIo

java.lang.Object

org.apache.ignite.internal.jdbc.thin.JdbcThinTcpIo

public class JdbcThinTcpIo
extends Object

JDBC IO layer implementation based on blocking IPC streams.

Constructor Summary

Constructors

Constructor and Description
JdbcThinTcpIo(ConnectionProperties connProps, InetSocketAddress sockAddr, int timeout) Start connection and perform handshake.

Method Summary

Modifier and Type	Method and Description
void	close() Close the client IO.
ConnectionProperties	connectionProperties()
UUID	nodeId()
int	timeout() Returns socket timeout.
void	timeout(int ms) Enable/disable socket timeout with specified timeout.

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcThinTcpIo

public JdbcThinTcpIo(ConnectionProperties connProps,
                     InetSocketAddress sockAddr,
                     int timeout)
              throws SQLException,
                     IOException

Start connection and perform handshake.

Parameters:

connProps - Connection properties.

sockAddr - Socket address.

timeout - Socket connection timeout in ms.

Throws:

SQLException - On connection error or reject.

IOException - On IO error in handshake.

Method Detail

close

public void close()

Close the client IO.

connectionProperties

public ConnectionProperties connectionProperties()

Returns:

Connection properties.

timeout

public void timeout(int ms)
             throws SQLException

Enable/disable socket timeout with specified timeout.

Parameters:

ms - the specified timeout, in milliseconds.

Throws:

SQLException - if there is an error in the underlying protocol.

timeout

public int timeout()
            throws SQLException

Returns socket timeout.

Throws:

SQLException - if there is an error in the underlying protocol.

nodeId

public UUID nodeId()

Returns:

Node Id.