com.adaptris.core.util

Class JdbcUtil

java.lang.Object

com.adaptris.core.util.JdbcUtil

public abstract class JdbcUtil
extends java.lang.Object

Helper methods used internally to support JDBC operations within the framework.

Constructor Summary

Constructors

Constructor and Description
JdbcUtil()

Method Summary

Modifier and Type	Method and Description
static void	closeQuietly(java.lang.AutoCloseable... closeables)
static void	commit(java.sql.Connection sqlConnection) Commit any pending transactions on the Connection.
static void	commit(java.sql.Connection sqlConnection, AdaptrisMessage msg) Commit the connection
static java.sql.Savepoint	createSavepoint(java.sql.Connection sqlConnection) Create a Savepoint on the connection
static java.sql.Connection	getConnection(AdaptrisMessage msg, AdaptrisConnection adpCon) Convenience method to get the Connection either from the AdaptrisMessage object or from configuration.
static java.util.Properties	mergeConnectionProperties(java.util.Properties p, java.lang.String username, java.lang.String password)
static void	rollback(java.sql.Connection sqlConnection) Rollback the connection.
static void	rollback(java.sql.Connection sqlConnection, AdaptrisMessage msg) Rollback to the stored savepoint.
static void	rollback(java.sql.Savepoint svp, java.sql.Connection sqlConnection) Rollback to the stored savepoint.
static java.sql.Connection	testConnection(java.sql.Connection sqlConnection, java.lang.String testStatement, boolean debugMode)

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcUtil

public JdbcUtil()

Method Detail

closeQuietly

public static void closeQuietly(java.lang.AutoCloseable... closeables)

rollback

public static void rollback(java.sql.Savepoint svp,
                            java.sql.Connection sqlConnection)

Rollback to the stored savepoint.

If Connection.getAutoCommit() is true, then this operation does nothing.

Parameters:

svp - the savepoint (if null, no rollback occurs).

sqlConnection - the database connection.

rollback

public static void rollback(java.sql.Connection sqlConnection)

Rollback the connection.

If Connection.getAutoCommit() is true, then this operation does nothing.

Parameters:

sqlConnection - the database connection.

commit

public static void commit(java.sql.Connection sqlConnection)
                   throws java.sql.SQLException

Commit any pending transactions on the Connection.

If Connection.getAutoCommit() is true, then this operation does nothing.

Parameters:

sqlConnection - the SQL Connection

Throws:

java.sql.SQLException - if the commit fails.

createSavepoint

public static java.sql.Savepoint createSavepoint(java.sql.Connection sqlConnection)
                                          throws java.sql.SQLException

Create a Savepoint on the connection

If Connection.getAutoCommit() is true, then this operation returns null.

Parameters:

sqlConnection - the SQL Connection

Returns:

a created Savepoint or null if the connection does not require it.

Throws:

java.sql.SQLException - if the operation fails.

testConnection

public static java.sql.Connection testConnection(java.sql.Connection sqlConnection,
                                                 java.lang.String testStatement,
                                                 boolean debugMode)
                                          throws java.sql.SQLException

Throws:

java.sql.SQLException

mergeConnectionProperties

public static java.util.Properties mergeConnectionProperties(java.util.Properties p,
                                                             java.lang.String username,
                                                             java.lang.String password)
                                                      throws PasswordException

Throws:

PasswordException

getConnection

public static java.sql.Connection getConnection(AdaptrisMessage msg,
                                                AdaptrisConnection adpCon)
                                         throws java.sql.SQLException

Convenience method to get the Connection either from the AdaptrisMessage object or from configuration.

Parameters:

msg - the adaptrisMessage object

adpCon - the configured AdaptrisConnection

Returns:

the connection either from the adaptris message or from configuration.

Throws:

java.sql.SQLException

rollback

public static void rollback(java.sql.Connection sqlConnection,
                            AdaptrisMessage msg)

Rollback to the stored savepoint.

If a database connection exists in the AdaptrisMessage object metadata then you don't want to rollback, you want to let the parent (presumably a JdbcServiceList) to do it for you.

Parameters:

sqlConnection - the database connection.

msg - the AdaptrisMessage

commit

public static void commit(java.sql.Connection sqlConnection,
                          AdaptrisMessage msg)
                   throws java.sql.SQLException

Commit the connection

If a database connection exists in the AdaptrisMessage object metadata then you don't want to rollback, you want to let the parent (presumably a JdbcServiceList) to do it for you.

Parameters:

sqlConnection - the SQL Connection

msg - the AdaptrisMessage currently being processed.

Throws:

java.sql.SQLException - if the commit fails.