com.atlassian.dbexporter.jdbc

Class JdbcUtils

java.lang.Object

com.atlassian.dbexporter.jdbc.JdbcUtils

public final class JdbcUtils
extends Object

Convenience methods for dealing with JDBC resources.

Author:

Erik van Zijst

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	JdbcUtils.JdbcCallable<T>

Constructor Summary

Constructors

Constructor and Description
JdbcUtils()

Method Summary

Modifier and Type	Method and Description
static void	closeQuietly(Connection connection) Closes the specified Connection, swallowing any SQLException.
static void	closeQuietly(ResultSet resultSet) Closes the specified ResultSet, swallowing any SQLException.
static void	closeQuietly(ResultSet resultSet, Statement statement) Closes the specified ResultSet and Statement, swallowing any SQLException.
static void	closeQuietly(Statement... statements) Closes the specified Statement, swallowing any SQLException.
static Statement	createStatement(ImportExportErrorService errorService, String table, Connection connection)
static DatabaseMetaData	metadata(ImportExportErrorService errorService, Connection connection)
static PreparedStatement	preparedStatement(ImportExportErrorService errorService, String table, Connection connection, String sql)
static String	quote(ImportExportErrorService errorService, String table, Connection connection, String identifier) Quotes the database identifier if needed.
static <T> T	withConnection(ImportExportErrorService errorService, ConnectionProvider provider, JdbcUtils.JdbcCallable<T> callable)
static <T> T	withNoAutoCommit(ImportExportErrorService errorService, Connection connection, JdbcUtils.JdbcCallable<T> callable) Executes callable with no autoCommit.

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcUtils

public JdbcUtils()

Method Detail

withConnection

public static <T> T withConnection(ImportExportErrorService errorService,
                                   ConnectionProvider provider,
                                   JdbcUtils.JdbcCallable<T> callable)

withNoAutoCommit

public static <T> T withNoAutoCommit(ImportExportErrorService errorService,
                                     Connection connection,
                                     JdbcUtils.JdbcCallable<T> callable)

Executes callable with no autoCommit.

E.g. PostgreSQL requires autoCommit to be off for batchSize to take effect.

closeQuietly

public static void closeQuietly(ResultSet resultSet)

Closes the specified ResultSet, swallowing any SQLException.

Parameters:

resultSet -

closeQuietly

public static void closeQuietly(Statement... statements)

Closes the specified Statement, swallowing any SQLException.

Parameters:

statements - the list of statements to close

closeQuietly

public static void closeQuietly(Connection connection)

Closes the specified Connection, swallowing any SQLException.

Parameters:

connection -

closeQuietly

public static void closeQuietly(ResultSet resultSet,
                                Statement statement)

Closes the specified ResultSet and Statement, swallowing any SQLException.

Parameters:

resultSet -

statement -

quote

public static String quote(ImportExportErrorService errorService,
                           String table,
                           Connection connection,
                           String identifier)

Quotes the database identifier if needed.

Parameters:

errorService -

table -

connection - the current connection being used

identifier - the database identifier to quote @return the quoted database identifier

Throws:

ImportExportException - if anything wrong happens getting information from the database connection.

metadata

public static DatabaseMetaData metadata(ImportExportErrorService errorService,
                                        Connection connection)

createStatement

public static Statement createStatement(ImportExportErrorService errorService,
                                        String table,
                                        Connection connection)

preparedStatement

public static PreparedStatement preparedStatement(ImportExportErrorService errorService,
                                                  String table,
                                                  Connection connection,
                                                  String sql)