Class NoSqlDatabaseCreator<T>

java.lang.Object

org.jobrunr.storage.nosql.common.NoSqlDatabaseCreator<T>

Direct Known Subclasses:

MongoDBCreator

public abstract class NoSqlDatabaseCreator<T>
extends Object

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	NoSqlDatabaseCreator(Class<? extends NoSqlStorageProvider> noSqlStorageProviderClass)
protected	NoSqlDatabaseCreator(List<Class<? extends NoSqlStorageProvider>> noSqlStorageProviderClasses)
protected	NoSqlDatabaseCreator(NoSqlStorageProvider noSqlStorageProvider)

Method Summary

Modifier and Type	Method	Description
protected Stream<NoSqlMigration>	getMigrations()
protected abstract boolean	isNewMigration(NoSqlMigration noSqlMigration)
protected boolean	isValidMigration(NoSqlMigration noSqlMigration)
protected abstract boolean	markMigrationAsDone(NoSqlMigration noSqlMigration)
protected abstract void	runMigration(T noSqlMigration)
protected void	runMigrationIfNecessary(NoSqlMigration noSqlMigration)
void	runMigrations()

Methods inherited from class Object

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

Constructor Details

NoSqlDatabaseCreator

protected NoSqlDatabaseCreator(NoSqlStorageProvider noSqlStorageProvider)

NoSqlDatabaseCreator

protected NoSqlDatabaseCreator(Class<? extends NoSqlStorageProvider> noSqlStorageProviderClass)

NoSqlDatabaseCreator

protected NoSqlDatabaseCreator(List<Class<? extends NoSqlStorageProvider>> noSqlStorageProviderClasses)

Method Details

runMigrations

public void runMigrations()

isValidMigration

protected boolean isValidMigration(NoSqlMigration noSqlMigration)

isNewMigration

protected abstract boolean isNewMigration(NoSqlMigration noSqlMigration)

runMigration

protected abstract void runMigration(T noSqlMigration)
                              throws Exception

Throws:

Exception

markMigrationAsDone

protected abstract boolean markMigrationAsDone(NoSqlMigration noSqlMigration)

runMigrationIfNecessary

protected void runMigrationIfNecessary(NoSqlMigration noSqlMigration)

getMigrations

protected Stream<NoSqlMigration> getMigrations()