com.mysql.cj.protocol.a

Class SimplePacketReaderTest.MockSocketConnection

java.lang.Object

com.mysql.cj.protocol.a.SimplePacketReaderTest.MockSocketConnection

All Implemented Interfaces:

SocketConnection

Direct Known Subclasses:

SimplePacketReaderTest.FixedBufferSocketConnection

Enclosing class:

SimplePacketReaderTest

public static class SimplePacketReaderTest.MockSocketConnection
extends java.lang.Object
implements SocketConnection

Field Summary

Fields

Modifier and Type	Field and Description
boolean	forceClosed

Constructor Summary

Constructors

Constructor and Description
MockSocketConnection()

Method Summary

Modifier and Type	Method and Description
void	connect(java.lang.String host, int port, PropertySet propertySet, ExceptionInterceptor exceptionInterceptor, Log log, int loginTimeout) Connect to the MySQL server and setup a stream connection.
void	forceClose()
ExceptionInterceptor	getExceptionInterceptor()
java.lang.String	getHost() Returns the host this IO is connected to
FullReadInputStream	getMysqlInput()
java.io.BufferedOutputStream	getMysqlOutput()
java.net.Socket	getMysqlSocket()
NetworkResources	getNetworkResources()
int	getPort()
PropertySet	getPropertySet()
SocketFactory	getSocketFactory()
boolean	isSSLEstablished()
void	performTlsHandshake(ServerSession serverSession)
int	readFully(byte[] b, int off, int len) Mock method to override getMysqlInput().readFully().
void	setMysqlInput(FullReadInputStream mysqlInput)
void	setSocketFactory(SocketFactory socketFactory)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.mysql.cj.protocol.SocketConnection

performTlsHandshake

Field Detail

forceClosed

public boolean forceClosed

Constructor Detail

MockSocketConnection

public MockSocketConnection()

Method Detail

connect

public void connect(java.lang.String host,
                    int port,
                    PropertySet propertySet,
                    ExceptionInterceptor exceptionInterceptor,
                    Log log,
                    int loginTimeout)

Description copied from interface: SocketConnection

Connect to the MySQL server and setup a stream connection.

Specified by:

connect in interface SocketConnection

Parameters:

host - the hostname to connect to

port - the port number that the server is listening on

propertySet - the PropertySet with required connection options

exceptionInterceptor - exception interceptor

log - logger

loginTimeout - the driver login time limit in milliseconds

performTlsHandshake

public void performTlsHandshake(ServerSession serverSession)
                         throws SSLParamsException,
                                FeatureNotAvailableException,
                                java.io.IOException

Specified by:

performTlsHandshake in interface SocketConnection

Throws:

SSLParamsException

FeatureNotAvailableException

java.io.IOException

forceClose

public void forceClose()

Specified by:

forceClose in interface SocketConnection

getNetworkResources

public NetworkResources getNetworkResources()

Specified by:

getNetworkResources in interface SocketConnection

getHost

public java.lang.String getHost()

Description copied from interface: SocketConnection

Returns the host this IO is connected to

Specified by:

getHost in interface SocketConnection

Returns:

host name

getPort

public int getPort()

Specified by:

getPort in interface SocketConnection

getMysqlSocket

public java.net.Socket getMysqlSocket()

Specified by:

getMysqlSocket in interface SocketConnection

getMysqlInput

public FullReadInputStream getMysqlInput()

Specified by:

getMysqlInput in interface SocketConnection

readFully

public int readFully(byte[] b,
                     int off,
                     int len)
              throws java.io.IOException

Mock method to override getMysqlInput().readFully().

Parameters:

b -

off -

len -

Returns:

an integer

Throws:

java.io.IOException

setMysqlInput

public void setMysqlInput(FullReadInputStream mysqlInput)

Specified by:

setMysqlInput in interface SocketConnection

getMysqlOutput

public java.io.BufferedOutputStream getMysqlOutput()

Specified by:

getMysqlOutput in interface SocketConnection

isSSLEstablished

public boolean isSSLEstablished()

Specified by:

isSSLEstablished in interface SocketConnection

getSocketFactory

public SocketFactory getSocketFactory()

Specified by:

getSocketFactory in interface SocketConnection

setSocketFactory

public void setSocketFactory(SocketFactory socketFactory)

Specified by:

setSocketFactory in interface SocketConnection

getExceptionInterceptor

public ExceptionInterceptor getExceptionInterceptor()

Specified by:

getExceptionInterceptor in interface SocketConnection

getPropertySet

public PropertySet getPropertySet()

Specified by:

getPropertySet in interface SocketConnection