software.amazon.jdbc.ds

Class AwsWrapperXADataSource

java.lang.Object

software.amazon.jdbc.ds.AwsWrapperXADataSource

All Implemented Interfaces:

java.io.Serializable, javax.sql.CommonDataSource, javax.sql.XADataSource

public class AwsWrapperXADataSource
extends java.lang.Object
implements javax.sql.XADataSource, java.io.Serializable

An XADataSource entry point for the AWS Advanced JDBC Wrapper. It wraps a target driver-specific XADataSource (for example org.postgresql.xa.PGXADataSource or com.mysql.cj.jdbc.MysqlXADataSource) so the wrapper's plugin pipeline applies to the application-facing Connection, while the XA control surface is delegated to the target's XAResource.

Connection-switching plugins (read/write splitting, failover) are not supported on the XA path; see the XA documentation for the recommended two-datasource pattern. The wrapper's internal connection pool is also not applicable to the XA path (the transaction manager / application server provides XA connection pooling).

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected @Nullable java.lang.String	database
protected @Nullable java.lang.String	jdbcProtocol
protected @Nullable java.lang.String	jdbcUrl
protected @Nullable java.io.PrintWriter	logWriter
protected @Nullable java.lang.String	password
protected @Nullable java.lang.String	serverName
protected @Nullable java.lang.String	serverPort
protected @Nullable java.lang.String	targetDataSourceClassName
protected @Nullable java.util.Properties	targetDataSourceProperties
protected @Nullable java.lang.String	user

Constructor Summary

Constructors

Constructor and Description
AwsWrapperXADataSource()
AwsWrapperXADataSource(CoreServicesContainer coreServicesContainer)

Method Summary

Modifier and Type	Method and Description
@Nullable java.lang.String	getDatabase()
@Nullable java.lang.String	getJdbcProtocol()
@Nullable java.lang.String	getJdbcUrl()
int	getLoginTimeout()
@Nullable java.io.PrintWriter	getLogWriter()
java.util.logging.Logger	getParentLogger()
@Nullable java.lang.String	getPassword()
@Nullable java.lang.String	getServerName()
@Nullable java.lang.String	getServerPort()
@Nullable java.lang.String	getTargetDataSourceClassName()
@Nullable java.util.Properties	getTargetDataSourceProperties()
@Nullable java.lang.String	getUser()
javax.sql.XAConnection	getXAConnection()
javax.sql.XAConnection	getXAConnection(@Nullable java.lang.String username, @Nullable java.lang.String password)
void	setDatabase(@NonNull java.lang.String database)
void	setJdbcProtocol(@NonNull java.lang.String jdbcProtocol)
void	setJdbcUrl(@Nullable java.lang.String url)
void	setLoginTimeout(int seconds)
void	setLogWriter(java.io.PrintWriter out)
void	setPassword(@Nullable java.lang.String password)
void	setServerName(@NonNull java.lang.String serverName)
void	setServerPort(@NonNull java.lang.String serverPort)
void	setTargetDataSourceClassName(@Nullable java.lang.String className)
void	setTargetDataSourceProperties(@Nullable java.util.Properties props)
void	setUser(@Nullable java.lang.String user)

Methods inherited from class java.lang.Object

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

Field Detail

logWriter

protected transient @Nullable java.io.PrintWriter logWriter

user

protected @Nullable java.lang.String user

password

protected @Nullable java.lang.String password

jdbcUrl

protected @Nullable java.lang.String jdbcUrl

targetDataSourceClassName

protected @Nullable java.lang.String targetDataSourceClassName

targetDataSourceProperties

protected @Nullable java.util.Properties targetDataSourceProperties

jdbcProtocol

protected @Nullable java.lang.String jdbcProtocol

serverName

protected @Nullable java.lang.String serverName

serverPort

protected @Nullable java.lang.String serverPort

database

protected @Nullable java.lang.String database

Constructor Detail

AwsWrapperXADataSource

public AwsWrapperXADataSource()

AwsWrapperXADataSource

public AwsWrapperXADataSource(CoreServicesContainer coreServicesContainer)

Method Detail

setTargetDataSourceClassName

public void setTargetDataSourceClassName(@Nullable java.lang.String className)

getTargetDataSourceClassName

public @Nullable java.lang.String getTargetDataSourceClassName()

setServerName

public void setServerName(@NonNull java.lang.String serverName)

getServerName

public @Nullable java.lang.String getServerName()

setServerPort

public void setServerPort(@NonNull java.lang.String serverPort)

getServerPort

public @Nullable java.lang.String getServerPort()

setDatabase

public void setDatabase(@NonNull java.lang.String database)

getDatabase

public @Nullable java.lang.String getDatabase()

setJdbcUrl

public void setJdbcUrl(@Nullable java.lang.String url)

getJdbcUrl

public @Nullable java.lang.String getJdbcUrl()

setJdbcProtocol

public void setJdbcProtocol(@NonNull java.lang.String jdbcProtocol)

getJdbcProtocol

public @Nullable java.lang.String getJdbcProtocol()

setTargetDataSourceProperties

public void setTargetDataSourceProperties(@Nullable java.util.Properties props)

getTargetDataSourceProperties

public @Nullable java.util.Properties getTargetDataSourceProperties()

setUser

public void setUser(@Nullable java.lang.String user)

getUser

public @Nullable java.lang.String getUser()

setPassword

public void setPassword(@Nullable java.lang.String password)

getPassword

public @Nullable java.lang.String getPassword()

getXAConnection

public javax.sql.XAConnection getXAConnection()
                                       throws java.sql.SQLException

Specified by:

getXAConnection in interface javax.sql.XADataSource

Throws:

java.sql.SQLException

getXAConnection

public javax.sql.XAConnection getXAConnection(@Nullable java.lang.String username,
                                              @Nullable java.lang.String password)
                                       throws java.sql.SQLException

Specified by:

getXAConnection in interface javax.sql.XADataSource

Throws:

java.sql.SQLException

getLogWriter

public @Nullable java.io.PrintWriter getLogWriter()
                                           throws java.sql.SQLException

Specified by:

getLogWriter in interface javax.sql.CommonDataSource

Throws:

java.sql.SQLException

setLogWriter

public void setLogWriter(java.io.PrintWriter out)
                  throws java.sql.SQLException

Specified by:

setLogWriter in interface javax.sql.CommonDataSource

Throws:

java.sql.SQLException

setLoginTimeout

public void setLoginTimeout(int seconds)
                     throws java.sql.SQLException

Specified by:

setLoginTimeout in interface javax.sql.CommonDataSource

Throws:

java.sql.SQLException

getLoginTimeout

public int getLoginTimeout()
                    throws java.sql.SQLException

Specified by:

getLoginTimeout in interface javax.sql.CommonDataSource

Throws:

java.sql.SQLException

getParentLogger

public java.util.logging.Logger getParentLogger()
                                         throws java.sql.SQLFeatureNotSupportedException

Specified by:

getParentLogger in interface javax.sql.CommonDataSource

Throws:

java.sql.SQLFeatureNotSupportedException