com.mysql.cj.xdevapi

Class ClientImpl

java.lang.Object

com.mysql.cj.xdevapi.ClientImpl

All Implemented Interfaces:

Protocol.ProtocolEventListener, Client

public class ClientImpl
extends java.lang.Object
implements Client, Protocol.ProtocolEventListener

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ClientImpl.PooledXProtocol

Nested classes/interfaces inherited from interface com.mysql.cj.xdevapi.Client

Client.ClientProperty

Nested classes/interfaces inherited from interface com.mysql.cj.protocol.Protocol.ProtocolEventListener

Protocol.ProtocolEventListener.EventType

Field Summary

Fields

Modifier and Type	Field and Description
(package private) java.util.Set<java.lang.ref.WeakReference<ClientImpl.PooledXProtocol>>	activeProtocols
private ConnectionUrl	connUrl
(package private) java.util.Map<HostInfo,java.lang.Long>	demotedHosts
private int	demotedTimeout
(package private) java.util.concurrent.BlockingQueue<ClientImpl.PooledXProtocol>	idleProtocols
(package private) boolean	isClosed
(package private) int	maxIdleTime
private int	maxSize
(package private) java.util.Set<java.lang.ref.WeakReference<Session>>	nonPooledSessions
private boolean	poolingEnabled
private int	queueTimeout
(package private) SessionFactory	sessionFactory

Constructor Summary

Constructors

Constructor and Description
ClientImpl(java.lang.String url, java.util.Properties clientProps)
ClientImpl(java.lang.String url, java.lang.String clientPropsJson)

Method Summary

Modifier and Type	Method and Description
private java.util.Properties	clientPropsFromJson(java.lang.String clientPropsJson)
void	close() Close Client.
Session	getSession() Get Session from pool or the new one.
void	handleEvent(Protocol.ProtocolEventListener.EventType type, java.lang.Object info, java.lang.Throwable reason)
(package private) void	idleProtocol(ClientImpl.PooledXProtocol prot)
private void	init(java.lang.String url, java.util.Properties clientProps)
private ClientImpl.PooledXProtocol	newPooledXProtocol(HostInfo hi)
private void	removeActivePooledXProtocol(ClientImpl.PooledXProtocol prot)
private void	validateAndInitializeClientProps(java.util.Properties clientProps)

Methods inherited from class java.lang.Object

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

Field Detail

isClosed

boolean isClosed

connUrl

private ConnectionUrl connUrl

poolingEnabled

private boolean poolingEnabled

maxSize

private int maxSize

maxIdleTime

int maxIdleTime

queueTimeout

private int queueTimeout

demotedTimeout

private int demotedTimeout

demotedHosts

java.util.Map<HostInfo,java.lang.Long> demotedHosts

idleProtocols

java.util.concurrent.BlockingQueue<ClientImpl.PooledXProtocol> idleProtocols

activeProtocols

java.util.Set<java.lang.ref.WeakReference<ClientImpl.PooledXProtocol>> activeProtocols

nonPooledSessions

java.util.Set<java.lang.ref.WeakReference<Session>> nonPooledSessions

sessionFactory

SessionFactory sessionFactory

Constructor Detail

ClientImpl

public ClientImpl(java.lang.String url,
                  java.lang.String clientPropsJson)

ClientImpl

public ClientImpl(java.lang.String url,
                  java.util.Properties clientProps)

Method Detail

clientPropsFromJson

private java.util.Properties clientPropsFromJson(java.lang.String clientPropsJson)

validateAndInitializeClientProps

private void validateAndInitializeClientProps(java.util.Properties clientProps)

init

private void init(java.lang.String url,
                  java.util.Properties clientProps)

getSession

public Session getSession()

Description copied from interface: Client

Get Session from pool or the new one.

Specified by:

getSession in interface Client

Returns:

Session

newPooledXProtocol

private ClientImpl.PooledXProtocol newPooledXProtocol(HostInfo hi)

close

public void close()

Description copied from interface: Client

Close Client. Closes all Sessions it has created, and destroys the managed pool.

Calling the method close on a Client object that is already closed is a no-op.

Specified by:

close in interface Client

idleProtocol

void idleProtocol(ClientImpl.PooledXProtocol prot)

handleEvent

public void handleEvent(Protocol.ProtocolEventListener.EventType type,
                        java.lang.Object info,
                        java.lang.Throwable reason)

Specified by:

handleEvent in interface Protocol.ProtocolEventListener

removeActivePooledXProtocol

private void removeActivePooledXProtocol(ClientImpl.PooledXProtocol prot)