software.amazon.jdbc

Class PluginServiceImpl

java.lang.Object

software.amazon.jdbc.PluginServiceImpl

All Implemented Interfaces:

CanReleaseResources, HostListProviderService, PluginManagerService, PluginService

public class PluginServiceImpl
extends java.lang.Object
implements PluginService, CanReleaseResources, HostListProviderService, PluginManagerService

Field Summary

Fields

Modifier and Type	Field and Description
protected java.sql.Connection	currentConnection
protected HostSpec	currentHostSpec
protected HostListProvider	hostListProvider
protected java.util.List<HostSpec>	hosts
protected HostSpec	initialConnectionHostSpec
protected ConnectionPluginManager	pluginManager

Constructor Summary

Constructors

Constructor and Description
PluginServiceImpl(@NonNull ConnectionPluginManager pluginManager, @NonNull java.util.Properties props, @NonNull java.lang.String originalUrl, java.lang.String targetDriverProtocol)

Method Summary

Modifier and Type	Method and Description
protected java.util.EnumSet<NodeChangeOptions>	compare(@NonNull java.sql.Connection connA, @NonNull HostSpec hostSpecA, @NonNull java.sql.Connection connB, @NonNull HostSpec hostSpecB)
protected java.util.EnumSet<NodeChangeOptions>	compare(@NonNull HostSpec hostSpecA, @NonNull HostSpec hostSpecB)
java.sql.Connection	connect(HostSpec hostSpec, java.util.Properties props)
void	forceRefreshHostList()
void	forceRefreshHostList(java.sql.Connection connection)
java.sql.Connection	getCurrentConnection()
HostSpec	getCurrentHostSpec()
HostListProvider	getHostListProvider()
java.util.List<HostSpec>	getHosts()
HostSpec	getInitialConnectionHostSpec()
boolean	isExplicitReadOnly()
boolean	isInTransaction()
boolean	isReadOnly()
boolean	isStaticHostListProvider()
void	refreshHostList()
void	refreshHostList(java.sql.Connection connection)
void	releaseResources() An object that implements this interface should release all acquired resources assuming it may be disposed at any time.
void	setAvailability(@NonNull java.util.Set<java.lang.String> hostAliases, @NonNull HostAvailability availability)
void	setCurrentConnection(@NonNull java.sql.Connection connection, @NonNull HostSpec hostSpec)
java.util.EnumSet<NodeChangeOptions>	setCurrentConnection(@NonNull java.sql.Connection connection, @NonNull HostSpec hostSpec, @Nullable ConnectionPlugin skipNotificationForThisPlugin)
void	setHostListProvider(HostListProvider hostListProvider)
void	setInitialConnectionHostSpec(@NonNull HostSpec initialConnectionHostSpec)
void	setInTransaction(boolean inTransaction)
void	setReadOnly(boolean readOnly)

Methods inherited from class java.lang.Object

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

Field Detail

pluginManager

protected final ConnectionPluginManager pluginManager

hostListProvider

protected volatile HostListProvider hostListProvider

hosts

protected java.util.List<HostSpec> hosts

currentConnection

protected java.sql.Connection currentConnection

currentHostSpec

protected HostSpec currentHostSpec

initialConnectionHostSpec

protected HostSpec initialConnectionHostSpec

Constructor Detail

PluginServiceImpl

public PluginServiceImpl(@NonNull ConnectionPluginManager pluginManager,
                         @NonNull java.util.Properties props,
                         @NonNull java.lang.String originalUrl,
                         java.lang.String targetDriverProtocol)

Method Detail

getCurrentConnection

public java.sql.Connection getCurrentConnection()

Specified by:

getCurrentConnection in interface HostListProviderService

Specified by:

getCurrentConnection in interface PluginService

getCurrentHostSpec

public HostSpec getCurrentHostSpec()

Specified by:

getCurrentHostSpec in interface HostListProviderService

Specified by:

getCurrentHostSpec in interface PluginService

setInitialConnectionHostSpec

public void setInitialConnectionHostSpec(@NonNull HostSpec initialConnectionHostSpec)

Specified by:

setInitialConnectionHostSpec in interface HostListProviderService

getInitialConnectionHostSpec

public HostSpec getInitialConnectionHostSpec()

Specified by:

getInitialConnectionHostSpec in interface HostListProviderService

Specified by:

getInitialConnectionHostSpec in interface PluginService

setCurrentConnection

public void setCurrentConnection(@NonNull java.sql.Connection connection,
                                 @NonNull HostSpec hostSpec)
                          throws java.sql.SQLException

Specified by:

setCurrentConnection in interface PluginService

Throws:

java.sql.SQLException

setCurrentConnection

public java.util.EnumSet<NodeChangeOptions> setCurrentConnection(@NonNull java.sql.Connection connection,
                                                                 @NonNull HostSpec hostSpec,
                                                                 @Nullable ConnectionPlugin skipNotificationForThisPlugin)
                                                          throws java.sql.SQLException

Specified by:

setCurrentConnection in interface PluginService

Throws:

java.sql.SQLException

compare

protected java.util.EnumSet<NodeChangeOptions> compare(@NonNull java.sql.Connection connA,
                                                       @NonNull HostSpec hostSpecA,
                                                       @NonNull java.sql.Connection connB,
                                                       @NonNull HostSpec hostSpecB)

compare

protected java.util.EnumSet<NodeChangeOptions> compare(@NonNull HostSpec hostSpecA,
                                                       @NonNull HostSpec hostSpecB)

getHosts

public java.util.List<HostSpec> getHosts()

Specified by:

getHosts in interface PluginService

setAvailability

public void setAvailability(@NonNull java.util.Set<java.lang.String> hostAliases,
                            @NonNull HostAvailability availability)

Specified by:

setAvailability in interface PluginService

isExplicitReadOnly

public boolean isExplicitReadOnly()

Specified by:

isExplicitReadOnly in interface PluginService

isReadOnly

public boolean isReadOnly()

Specified by:

isReadOnly in interface PluginService

isInTransaction

public boolean isInTransaction()

Specified by:

isInTransaction in interface PluginService

setReadOnly

public void setReadOnly(boolean readOnly)

Specified by:

setReadOnly in interface PluginManagerService

setInTransaction

public void setInTransaction(boolean inTransaction)

Specified by:

setInTransaction in interface PluginManagerService

getHostListProvider

public HostListProvider getHostListProvider()

Specified by:

getHostListProvider in interface HostListProviderService

Specified by:

getHostListProvider in interface PluginService

refreshHostList

public void refreshHostList()
                     throws java.sql.SQLException

Specified by:

refreshHostList in interface PluginService

Throws:

java.sql.SQLException

refreshHostList

public void refreshHostList(java.sql.Connection connection)
                     throws java.sql.SQLException

Specified by:

refreshHostList in interface PluginService

Throws:

java.sql.SQLException

forceRefreshHostList

public void forceRefreshHostList()
                          throws java.sql.SQLException

Specified by:

forceRefreshHostList in interface PluginService

Throws:

java.sql.SQLException

forceRefreshHostList

public void forceRefreshHostList(java.sql.Connection connection)
                          throws java.sql.SQLException

Specified by:

forceRefreshHostList in interface PluginService

Throws:

java.sql.SQLException

isStaticHostListProvider

public boolean isStaticHostListProvider()

Specified by:

isStaticHostListProvider in interface HostListProviderService

setHostListProvider

public void setHostListProvider(HostListProvider hostListProvider)

Specified by:

setHostListProvider in interface HostListProviderService

connect

public java.sql.Connection connect(HostSpec hostSpec,
                                   java.util.Properties props)
                            throws java.sql.SQLException

Specified by:

connect in interface PluginService

Throws:

java.sql.SQLException

releaseResources

public void releaseResources()

Description copied from interface: CanReleaseResources

An object that implements this interface should release all acquired resources assuming it may be disposed at any time. This method may be called more than once.

Calling this method does NOT mean that an object is disposing and there won't be any further calls. An object should keep its functional state after calling this method.

Specified by:

releaseResources in interface CanReleaseResources