com.atlassian.confluence.impl.hibernate

Class DataAccessUtils

java.lang.Object

com.atlassian.confluence.impl.hibernate.DataAccessUtils

@ParametersAreNonnullByDefault
 @ReturnValuesAreNonnullByDefault
public abstract class DataAccessUtils
extends Object

Provides access to several underlying Hibernate and JDBC data access objects, which are commonly used in database-related upgrade tasks.

Method Summary

Modifier and Type	Method and Description
static org.hibernate.query.NativeQuery	createSqlQuery(org.hibernate.Session session, String sql) A convenience wrapper around QueryProducer.createNativeQuery(String) which conditionally sets the query flush mode depending on the current transaction state.
static net.sf.hibernate.Session	downgrade(org.hibernate.Session session) Get the hibernate Session object with the v5 interface and hibernate implementation.
static net.sf.hibernate.SessionFactory	downgrade(org.hibernate.SessionFactory sessionFactory) Get a reference to the v5 SessionFactory interface.
static Set<String>	filterToExistingTables(Set<String> tableNames, org.springframework.transaction.PlatformTransactionManager transactionManager, org.hibernate.SessionFactory sessionFactory) Within a new transaction (for DB metadata retrieval), return the supplied Set of tables names filtered such that all the tables that don't exist are removed.
static void	flush(org.hibernate.Session session) Flushes the session.
static Connection	getConnection(org.hibernate.Session session) Returns the JDBC connection for the session.
static org.hibernate.dialect.Dialect	getDialect()
static org.hibernate.dialect.Dialect	getDialect(ConfluenceHibernateConfig hibernateConfig)
static org.springframework.jdbc.core.JdbcTemplate	getJdbcTemplate(org.hibernate.Session session) Returns a JDBC template for the provided Hibernate session.
static org.springframework.jdbc.core.JdbcTemplate	getJdbcTemplate(org.hibernate.SessionFactory sessionFactory) Returns a JDBC template for the active Hibernate session.
static String	getPrimaryKeyColumnName(org.springframework.transaction.PlatformTransactionManager transactionManager, org.hibernate.SessionFactory sessionFactory, String tableName) Locates the name of the column used as the primary key on the given table.
static org.hibernate.Session	getSession(org.hibernate.SessionFactory sessionFactory) Returns the current session or creates one if one does not exist.
static boolean	isColumnPresent(String tableName, String columnName, org.springframework.transaction.PlatformTransactionManager transactionManager, org.hibernate.SessionFactory sessionFactory, BootstrapManager bootstrapManager)
static boolean	isTablePresent(String tableName, org.springframework.transaction.PlatformTransactionManager transactionManager, org.hibernate.SessionFactory sessionFactory) Within a new transaction (for the database metadata lookup) check if the named table exists in the database.
static <T> T	withNewConnection(org.springframework.transaction.PlatformTransactionManager transactionManager, org.hibernate.SessionFactory sessionFactory, Function<Connection,T> callback)

Methods inherited from class java.lang.Object

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

Method Detail

getSession

public static org.hibernate.Session getSession(org.hibernate.SessionFactory sessionFactory)

Returns the current session or creates one if one does not exist.

See Also:

SessionFactoryUtils.getSession(net.sf.hibernate.SessionFactory, boolean)

flush

public static void flush(org.hibernate.Session session)
                  throws org.springframework.dao.DataAccessException

Flushes the session. That is, checks for any updates on attached Hibernate objects and issues the required SQL to the database server. All the objects attached to the session remain attached and in memory.

This does not commit anything by itself, but relies on the surrounding transaction to commit the changes.

Throws:

org.springframework.dao.DataAccessException - if the connection cannot be retrieved

getJdbcTemplate

public static org.springframework.jdbc.core.JdbcTemplate getJdbcTemplate(org.hibernate.Session session)

Returns a JDBC template for the provided Hibernate session. The JDBC template participates in the same transaction as the session.

getJdbcTemplate

public static org.springframework.jdbc.core.JdbcTemplate getJdbcTemplate(org.hibernate.SessionFactory sessionFactory)

Returns a JDBC template for the active Hibernate session. Creates a new session if one does not exist.

See Also:

getSession(SessionFactory), getJdbcTemplate(Session)

getConnection

public static Connection getConnection(org.hibernate.Session session)
                                throws org.springframework.dao.DataAccessException

Returns the JDBC connection for the session. Statements created and executed on this connection will typically share the same transaction as the session.

Throws:

org.springframework.dao.DataAccessException - if the connection cannot be retrieved

getDialect

public static org.hibernate.dialect.Dialect getDialect()
                                                throws org.springframework.dao.DataAccessException

Throws:

org.springframework.dao.DataAccessException

getDialect

public static org.hibernate.dialect.Dialect getDialect(ConfluenceHibernateConfig hibernateConfig)
                                                throws org.springframework.dao.DataAccessException

Throws:

org.springframework.dao.DataAccessException

filterToExistingTables

public static Set<String> filterToExistingTables(Set<String> tableNames,
                                                 org.springframework.transaction.PlatformTransactionManager transactionManager,
                                                 org.hibernate.SessionFactory sessionFactory)

Within a new transaction (for DB metadata retrieval), return the supplied Set of tables names filtered such that all the tables that don't exist are removed.

Returns:

a Set of table names which are found in the database.

isTablePresent

public static boolean isTablePresent(String tableName,
                                     org.springframework.transaction.PlatformTransactionManager transactionManager,
                                     org.hibernate.SessionFactory sessionFactory)

Within a new transaction (for the database metadata lookup) check if the named table exists in the database.

Returns:

true if it exists, otherwise false.

getPrimaryKeyColumnName

public static String getPrimaryKeyColumnName(org.springframework.transaction.PlatformTransactionManager transactionManager,
                                             org.hibernate.SessionFactory sessionFactory,
                                             String tableName)

Locates the name of the column used as the primary key on the given table.

Returns:

The name of the pri9mary key column

Throws:

IllegalStateException - if there is no primary key on the given table, or if the primary is constructed from more than one column

isColumnPresent

public static boolean isColumnPresent(String tableName,
                                      String columnName,
                                      org.springframework.transaction.PlatformTransactionManager transactionManager,
                                      org.hibernate.SessionFactory sessionFactory,
                                      BootstrapManager bootstrapManager)
                               throws InfrastructureException

Throws:

InfrastructureException

withNewConnection

public static <T> T withNewConnection(org.springframework.transaction.PlatformTransactionManager transactionManager,
                                      org.hibernate.SessionFactory sessionFactory,
                                      Function<Connection,T> callback)

downgrade

@Nullable
public static net.sf.hibernate.SessionFactory downgrade(@Nullable
                                                                  org.hibernate.SessionFactory sessionFactory)

Get a reference to the v5 SessionFactory interface.

downgrade

@Nullable
public static net.sf.hibernate.Session downgrade(@Nullable
                                                           org.hibernate.Session session)

Get the hibernate Session object with the v5 interface and hibernate implementation.

createSqlQuery

public static org.hibernate.query.NativeQuery createSqlQuery(org.hibernate.Session session,
                                                             String sql)

A convenience wrapper around QueryProducer.createNativeQuery(String) which conditionally sets the query flush mode depending on the current transaction state.