Package org.spincast.plugins.flywayutils

Class SpincastFlywayMigrationBase

java.lang.Object

org.spincast.plugins.flywayutils.SpincastFlywayMigrationBase

All Implemented Interfaces:

SpincastFlywayMigration

public abstract class SpincastFlywayMigrationBase
extends Object
implements SpincastFlywayMigration

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor	Description
SpincastFlywayMigrationBase(DataSource dataSource, JdbcUtils jdbcUtils)

Method Summary

Modifier and Type	Method	Description
protected DataSource	getDataSource()
protected JdbcUtils	getJdbcUtils()
final void	migrate(Connection connection)	Override {runMigration(Connection)} instead of this method.
protected abstract void	runMigration(Connection connection)	Runs the migrations inside a scope where the proper connection will used, even by indirect components (ex: a service is called that uses a repository which gets a connection using JdbcScope.transactional(org.spincast.plugins.jdbc.TransactionalScope) transactional()).

Methods inherited from class java.lang.Object

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

Field Details

logger

protected static final org.slf4j.Logger logger

Constructor Details

SpincastFlywayMigrationBase

@Inject
public SpincastFlywayMigrationBase(DataSource dataSource,
 JdbcUtils jdbcUtils)

Method Details

getDataSource

protected DataSource getDataSource()

getJdbcUtils

protected JdbcUtils getJdbcUtils()

migrate

public final void migrate(Connection connection)
                   throws Exception

Override {runMigration(Connection)} instead of this method.

Specified by:

migrate in interface SpincastFlywayMigration

Throws:

Exception

runMigration

protected abstract void runMigration(Connection connection)

Runs the migrations inside a scope where the proper connection will used, even by indirect components (ex: a service is called that uses a repository which gets a connection using JdbcScope.transactional(org.spincast.plugins.jdbc.TransactionalScope) transactional()).