software.amazon.jdbc.plugin.sqlparser

Class SqlParserConnectionPlugin

java.lang.Object

software.amazon.jdbc.plugin.AbstractConnectionPlugin

software.amazon.jdbc.plugin.sqlparser.SqlParserConnectionPlugin

All Implemented Interfaces:

ConnectionPlugin, StateSnapshotProvider

public class SqlParserConnectionPlugin
extends AbstractConnectionPlugin

Plugin that parses SQL statements and populates the PluginCallContext with analysis results for downstream plugins to consume.

This plugin must be placed before any plugin that needs SQL analysis (e.g., kmsEncryption, autoReadWriteSplitting).

Constructor Summary

Constructors

Constructor and Description
SqlParserConnectionPlugin(PluginService pluginService, java.util.Properties properties)

Method Summary

Modifier and Type	Method and Description
<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)
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

Constructor Detail

SqlParserConnectionPlugin

public SqlParserConnectionPlugin(PluginService pluginService,
                                 java.util.Properties properties)

Method Detail

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