software.amazon.jdbc.targetdriverdialect

Class PgTargetDriverDialect

java.lang.Object

software.amazon.jdbc.targetdriverdialect.GenericTargetDriverDialect

software.amazon.jdbc.targetdriverdialect.PgTargetDriverDialect

All Implemented Interfaces:

TargetDriverDialect

public class PgTargetDriverDialect
extends GenericTargetDriverDialect

Field Summary

Fields inherited from class software.amazon.jdbc.targetdriverdialect.GenericTargetDriverDialect

ALLOWED_ON_CLOSED_METHODS, NETWORK_BOUND_METHODS_FOR_ENTIRE_RESULTSET

Constructor Summary

Constructors

Constructor and Description
PgTargetDriverDialect()

Method Summary

Modifier and Type	Method and Description
void	abortConnection(@NonNull java.sql.Connection connectionToAbort, @NonNull java.util.concurrent.Executor abortExecutor)
java.util.Set<java.lang.String>	getAllowedOnConnectionMethodNames()
byte[]	getEncryptedBytes(@NonNull java.sql.ResultSet rs, java.lang.Object columnRef)
java.lang.String	getSQLQueryString(java.sql.PreparedStatement ps)
boolean	isDialect(java.sql.Driver driver)
boolean	isDialect(java.lang.String dataSourceClass)
boolean	isDriverRegistered()
ConnectInfo	prepareConnectInfo(@NonNull java.lang.String protocol, @NonNull HostSpec hostSpec, @NonNull java.util.Properties props)
void	prepareDataSource(@NonNull javax.sql.DataSource dataSource, @NonNull java.lang.String protocol, @NonNull HostSpec hostSpec, @NonNull java.util.Properties props)
void	registerDataType(@NonNull java.sql.Connection connection, @NonNull java.lang.String typeName, @NonNull java.lang.String className)
void	registerDriver()
void	setEncryptedParameter(@NonNull java.sql.PreparedStatement ps, int paramIndex, byte[] encrypted)

Methods inherited from class software.amazon.jdbc.targetdriverdialect.GenericTargetDriverDialect

findSQLQueryString, getNetworkBoundMethodNames, getSQLState, ping

Methods inherited from class java.lang.Object

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

Constructor Detail

PgTargetDriverDialect

public PgTargetDriverDialect()

Method Detail

isDialect

public boolean isDialect(java.sql.Driver driver)

Specified by:

isDialect in interface TargetDriverDialect

Overrides:

isDialect in class GenericTargetDriverDialect

isDialect

public boolean isDialect(java.lang.String dataSourceClass)

Specified by:

isDialect in interface TargetDriverDialect

Overrides:

isDialect in class GenericTargetDriverDialect

prepareConnectInfo

public ConnectInfo prepareConnectInfo(@NonNull java.lang.String protocol,
                                      @NonNull HostSpec hostSpec,
                                      @NonNull java.util.Properties props)

Specified by:

prepareConnectInfo in interface TargetDriverDialect

Overrides:

prepareConnectInfo in class GenericTargetDriverDialect

prepareDataSource

public void prepareDataSource(@NonNull javax.sql.DataSource dataSource,
                              @NonNull java.lang.String protocol,
                              @NonNull HostSpec hostSpec,
                              @NonNull java.util.Properties props)
                       throws java.sql.SQLException

Specified by:

prepareDataSource in interface TargetDriverDialect

Overrides:

prepareDataSource in class GenericTargetDriverDialect

Throws:

java.sql.SQLException

isDriverRegistered

public boolean isDriverRegistered()
                           throws java.sql.SQLException

Specified by:

isDriverRegistered in interface TargetDriverDialect

Overrides:

isDriverRegistered in class GenericTargetDriverDialect

Throws:

java.sql.SQLException

registerDriver

public void registerDriver()
                    throws java.sql.SQLException

Specified by:

registerDriver in interface TargetDriverDialect

Overrides:

registerDriver in class GenericTargetDriverDialect

Throws:

java.sql.SQLException

getAllowedOnConnectionMethodNames

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

Specified by:

getAllowedOnConnectionMethodNames in interface TargetDriverDialect

Overrides:

getAllowedOnConnectionMethodNames in class GenericTargetDriverDialect

abortConnection

public void abortConnection(@NonNull java.sql.Connection connectionToAbort,
                            @NonNull java.util.concurrent.Executor abortExecutor)
                     throws java.sql.SQLException

Specified by:

abortConnection in interface TargetDriverDialect

Overrides:

abortConnection in class GenericTargetDriverDialect

Throws:

java.sql.SQLException

getSQLQueryString

public java.lang.String getSQLQueryString(java.sql.PreparedStatement ps)

Specified by:

getSQLQueryString in interface TargetDriverDialect

Overrides:

getSQLQueryString in class GenericTargetDriverDialect

registerDataType

public void registerDataType(@NonNull java.sql.Connection connection,
                             @NonNull java.lang.String typeName,
                             @NonNull java.lang.String className)
                      throws java.sql.SQLException

Specified by:

registerDataType in interface TargetDriverDialect

Overrides:

registerDataType in class GenericTargetDriverDialect

Throws:

java.sql.SQLException

setEncryptedParameter

public void setEncryptedParameter(@NonNull java.sql.PreparedStatement ps,
                                  int paramIndex,
                                  byte[] encrypted)
                           throws java.sql.SQLException

Specified by:

setEncryptedParameter in interface TargetDriverDialect

Overrides:

setEncryptedParameter in class GenericTargetDriverDialect

Throws:

java.sql.SQLException

getEncryptedBytes

public byte[] getEncryptedBytes(@NonNull java.sql.ResultSet rs,
                                java.lang.Object columnRef)
                         throws java.sql.SQLException

Specified by:

getEncryptedBytes in interface TargetDriverDialect

Overrides:

getEncryptedBytes in class GenericTargetDriverDialect

Throws:

java.sql.SQLException