com.mysql.cj.xdevapi

public Class ClientImpl

Class Inheritance

extends Object
implements Client, ProtocolEventListener

java.lang.Object
com.mysql.cj.xdevapi.ClientImpl

All Implemented Interfaces

com.mysql.cj.protocol.Protocol.ProtocolEventListener, com.mysql.cj.xdevapi.Client, java.lang.AutoCloseable

Imports

java.io.IOException, java.lang.ref.WeakReference, java.util.ArrayList, .List, .Objects, .Properties, .Set, java.util.concurrent.BlockingQueue, .ConcurrentHashMap, .ConcurrentMap, .CopyOnWriteArraySet, .LinkedBlockingQueue, .Semaphore, .TimeUnit, java.util.concurrent.locks.ReadWriteLock, .ReentrantReadWriteLock, java.util.stream.Collectors, .Stream, com.mysql.cj.Messages, com.mysql.cj.conf.BooleanPropertyDefinition, .ConnectionUrl, .DefaultPropertySet, .HostInfo, .IntegerPropertyDefinition, .PropertySet, com.mysql.cj.exceptions.CJCommunicationsException, .CJException, .ExceptionFactory, .WrongArgumentException, com.mysql.cj.protocol.Protocol.ProtocolEventListener, com.mysql.cj.protocol.x.XProtocol, .XProtocolError, com.mysql.cj.util.StringUtils

Nested and Inner Type Summary

Modifier and Type	Class and Description
public class	ClientImpl.PooledXProtocol

Field Summary

Modifier and Type	Field and Description
private Set<WeakReference<ClientImpl.PooledXProtocol>>	activeProtocols
private Semaphore	availableProtocols
private ReadWriteLock	clientShutdownLock
private ConnectionUrl	connUrl
private ConcurrentMap<HostInfo, Long>	demotedHosts
private int	demotedTimeout
private BlockingQueue<ClientImpl.PooledXProtocol>	idleProtocols
private boolean	isClosed
private int	maxIdleTime
private int	maxSize
private Set<WeakReference<Session>>	nonPooledSessions
private final ClientImpl.PooledXProtocol	poisonProtocolMarker
private boolean	poolingEnabled
private int	queueTimeout
private SessionFactory	sessionFactory

Constructor Summary

Access	Constructor and Description
public	ClientImpl(String url, String clientPropsJson)
public	ClientImpl(String url, Properties clientProps)

Method Summary

Modifier and Type	Method and Description
private Properties	clientPropsFromJson(String clientPropsJson)
public void	close() Implements com.mysql.cj.xdevapi.Client.close. Close `Client`.
private Session	getNonPooledSession()
private Session	getPooledSession()
public Session	getSession() Implements com.mysql.cj.xdevapi.Client.getSession. Get `Session` from pool or the new one.
public void	handleEvent(Protocol.ProtocolEventListener.EventType type, Object info, Throwable reason) Implements com.mysql.cj.protocol.Protocol.ProtocolEventListener.handleEvent.
pack-priv void	idleProtocol(ClientImpl.PooledXProtocol protocol)
private void	init(String url, Properties clientProps)
private ClientImpl.PooledXProtocol	newPooledXProtocol(List<HostInfo> hostsList)
private ClientImpl.PooledXProtocol	newPooledXProtocol(HostInfo hi)
private void	removeActivePooledXProtocol(ClientImpl.PooledXProtocol protocol)
private void	validateAndInitializeClientProps(Properties clientProps)
private ClientImpl.PooledXProtocol	validateAndResetPooledXProtocol(ClientImpl.PooledXProtocol protocol, List<HostInfo> hostsList)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

activeProtocols	back to summary
private Set<WeakReference<ClientImpl.PooledXProtocol>> activeProtocols

availableProtocols	back to summary
private Semaphore availableProtocols

clientShutdownLock	back to summary
private ReadWriteLock clientShutdownLock

connUrl	back to summary
private ConnectionUrl connUrl

demotedHosts	back to summary
private ConcurrentMap<HostInfo, Long> demotedHosts

demotedTimeout	back to summary
private int demotedTimeout

idleProtocols	back to summary
private BlockingQueue<ClientImpl.PooledXProtocol> idleProtocols

isClosed	back to summary
private boolean isClosed

maxIdleTime	back to summary
private int maxIdleTime

maxSize	back to summary
private int maxSize

nonPooledSessions	back to summary
private Set<WeakReference<Session>> nonPooledSessions

poisonProtocolMarker	back to summary
private final ClientImpl.PooledXProtocol poisonProtocolMarker

poolingEnabled	back to summary
private boolean poolingEnabled

queueTimeout	back to summary
private int queueTimeout

sessionFactory	back to summary
private SessionFactory sessionFactory

Constructor Detail

ClientImpl	back to summary
public ClientImpl(String url, String clientPropsJson)

ClientImpl	back to summary
public ClientImpl(String url, Properties clientProps)

Method Detail

clientPropsFromJson	back to summary
private Properties clientPropsFromJson(String clientPropsJson)

close back to summary

close	back to summary
public void close() Implements com.mysql.cj.xdevapi.Client.close. Doc from com.mysql.cj.xdevapi.Client.close. 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. Annotations @Override

public void close()

Implements com.mysql.cj.xdevapi.Client.close.

Doc from com.mysql.cj.xdevapi.Client.close.

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.

Annotations

@Override

getNonPooledSession	back to summary
private Session getNonPooledSession()

getPooledSession	back to summary
private Session getPooledSession()

getSession back to summary

getSession	back to summary
public Session getSession() Implements com.mysql.cj.xdevapi.Client.getSession. Doc from com.mysql.cj.xdevapi.Client.getSession. Get `Session` from pool or the new one. Returns:Session `Session` Annotations @Override

public Session getSession()

Implements com.mysql.cj.xdevapi.Client.getSession.

Doc from com.mysql.cj.xdevapi.Client.getSession.

Get Session from pool or the new one.

Returns:Session

Session

Annotations

@Override

handleEvent	back to summary
public void handleEvent(Protocol.ProtocolEventListener.EventType type, Object info, Throwable reason) Implements com.mysql.cj.protocol.Protocol.ProtocolEventListener.handleEvent. Annotations @Override

handleEvent

back to summary

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

Implements com.mysql.cj.protocol.Protocol.ProtocolEventListener.handleEvent.

Annotations

@Override

idleProtocol	back to summary
pack-priv void idleProtocol(ClientImpl.PooledXProtocol protocol)

init	back to summary
private void init(String url, Properties clientProps)

newPooledXProtocol	back to summary
private ClientImpl.PooledXProtocol newPooledXProtocol(List<HostInfo> hostsList)

newPooledXProtocol	back to summary
private ClientImpl.PooledXProtocol newPooledXProtocol(HostInfo hi)

removeActivePooledXProtocol	back to summary
private void removeActivePooledXProtocol(ClientImpl.PooledXProtocol protocol)

validateAndInitializeClientProps	back to summary
private void validateAndInitializeClientProps(Properties clientProps)

validateAndResetPooledXProtocol	back to summary
private ClientImpl.PooledXProtocol validateAndResetPooledXProtocol(ClientImpl.PooledXProtocol protocol, List<HostInfo> hostsList)

com.mysql.cj.xdevapi back to summary

public Class ClientImpl.PooledXProtocol

Class Inheritance

extends XProtocol

java.lang.Object
com.mysql.cj.protocol.AbstractProtocol
com.mysql.cj.protocol.x.XProtocol
com.mysql.cj.xdevapi.ClientImpl.PooledXProtocol

Field Summary

Modifier and Type	Field and Description
private HostInfo	hostInfo
private long	idleSince
private int	maxIdleTime

Inherited from com.mysql.cj.protocol.x.XProtocol:: defaultSchemaName

Constructor Summary

Access	Constructor and Description
pack-priv	PooledXProtocol()
pack-priv	PooledXProtocol(HostInfo hostInfo, PropertySet propertySet, int maxIdleTime)

Method Summary

Modifier and Type	Method and Description
public void	close() Overrides com.mysql.cj.protocol.x.XProtocol.close. Implements com.mysql.cj.protocol.Protocol.close.
pack-priv HostInfo	getHostInfo()
pack-priv boolean	isHostInfoValid(List<HostInfo> hostsList)
pack-priv boolean	isIdleTimeoutReached()
pack-priv void	realClose()

Field Detail

hostInfo	back to summary
private HostInfo hostInfo

idleSince	back to summary
private long idleSince

maxIdleTime	back to summary
private int maxIdleTime

Constructor Detail

PooledXProtocol	back to summary
pack-priv PooledXProtocol()

PooledXProtocol	back to summary
pack-priv PooledXProtocol(HostInfo hostInfo, PropertySet propertySet, int maxIdleTime)

Method Detail

close	back to summary
public void close() Overrides com.mysql.cj.protocol.x.XProtocol.close. Implements com.mysql.cj.protocol.Protocol.close. Annotations @Override

back to summary

public void close()

Overrides com.mysql.cj.protocol.x.XProtocol.close.

Implements com.mysql.cj.protocol.Protocol.close.

Annotations

@Override

getHostInfo	back to summary
pack-priv HostInfo getHostInfo()

isHostInfoValid	back to summary
pack-priv boolean isHostInfoValid(List<HostInfo> hostsList)

isIdleTimeoutReached	back to summary
pack-priv boolean isIdleTimeoutReached()

realClose	back to summary
pack-priv void realClose()