software.amazon.jdbc.plugin.cache

Class DataLocalCacheConnectionPlugin

java.lang.Object

software.amazon.jdbc.plugin.AbstractConnectionPlugin

software.amazon.jdbc.plugin.cache.DataLocalCacheConnectionPlugin

All Implemented Interfaces:

ConnectionPlugin, StateSnapshotProvider

public class DataLocalCacheConnectionPlugin
extends AbstractConnectionPlugin

Field Summary

Fields

Modifier and Type	Field and Description
static AwsWrapperProperty	DATA_CACHE_TRIGGER_CONDITION
protected static java.util.Map<java.lang.String,java.sql.ResultSet>	dataCache
protected @Nullable java.lang.String	dataCacheTriggerCondition

Constructor Summary

Constructors

Constructor and Description
DataLocalCacheConnectionPlugin(PluginService pluginService, java.util.Properties props)

Method Summary

Modifier and Type	Method and Description
static void	clearCache()
<T,E extends java.lang.Exception> T	execute(java.lang.Class<T> resultClass, java.lang.Class<E> exceptionClass, java.lang.Object methodInvokeOn, java.lang.String methodName, JdbcCallable<T,E> jdbcMethodFunc, @Nullable java.lang.Object[] jdbcMethodArgs)
protected @Nullable java.lang.String	getQuery(@Nullable java.lang.Object[] jdbcMethodArgs)
java.util.Set<java.lang.String>	getSubscribedMethods()

Methods inherited from class software.amazon.jdbc.plugin.AbstractConnectionPlugin

acceptsStrategy, connect, forceConnect, getHostSpecByStrategy, getHostSpecByStrategy, getSnapshotState, initHostProvider, notifyConnectionChanged, notifyNodeListChanged

Methods inherited from class java.lang.Object

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

Field Detail

DATA_CACHE_TRIGGER_CONDITION

public static final AwsWrapperProperty DATA_CACHE_TRIGGER_CONDITION

dataCache

protected static final java.util.Map<java.lang.String,java.sql.ResultSet> dataCache

dataCacheTriggerCondition

protected final @Nullable java.lang.String dataCacheTriggerCondition

Constructor Detail

DataLocalCacheConnectionPlugin

public DataLocalCacheConnectionPlugin(PluginService pluginService,
                                      java.util.Properties props)

Method Detail

clearCache

public static void clearCache()

getSubscribedMethods

public java.util.Set<java.lang.String> getSubscribedMethods()

Specified by:

getSubscribedMethods in interface ConnectionPlugin

Specified by:

getSubscribedMethods in class AbstractConnectionPlugin

execute

public <T,E extends java.lang.Exception> T execute(java.lang.Class<T> resultClass,
                                                   java.lang.Class<E> exceptionClass,
                                                   java.lang.Object methodInvokeOn,
                                                   java.lang.String methodName,
                                                   JdbcCallable<T,E> jdbcMethodFunc,
                                                   @Nullable java.lang.Object[] jdbcMethodArgs)
                                            throws E extends java.lang.Exception

Specified by:

execute in interface ConnectionPlugin

Overrides:

execute in class AbstractConnectionPlugin

Throws:

E extends java.lang.Exception

getQuery

protected @Nullable java.lang.String getQuery(@Nullable java.lang.Object[] jdbcMethodArgs)