Package tigase.db.util

Class SchemaLoader<P extends SchemaLoader.Parameters>

java.lang.Object

tigase.db.util.SchemaLoader<P>

Direct Known Subclasses:

DBSchemaLoader

public abstract class SchemaLoader<P extends SchemaLoader.Parameters>
extends Object

Author:

andrzej

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	SchemaLoader.Parameters
static enum	SchemaLoader.Result
static class	SchemaLoader.TypeInfo

Field Summary

Fields

Modifier and Type	Field	Description
protected static final Logger	log

Constructor Summary

Constructors

Constructor	Description
SchemaLoader()

Method Summary

Modifier and Type	Method	Description
protected <T extends DataSource> SchemaLoader.Result	addUsersToRepository(SchemaManager.SchemaInfo schemaInfo, T dataSource, Class<T> dataSourceClass, List<BareJID> jids, String password, Logger log)
protected Function<AuthRepository,SchemaLoader.Result>	addUsersToRepositoryFunction(List<BareJID> jids, String pwd, Logger log)
abstract SchemaLoader.Result	addXmppAdminAccount(SchemaManager.SchemaInfo schemaInfo)	Method attempts to add XMPP admin user account to the database using AuthRepository.
abstract P	createParameters()
abstract SchemaLoader.Result	destroyDataSource()
abstract void	execute(SchemaLoader.Parameters params)
static List<SchemaLoader.TypeInfo>	getAllSupportedTypes()
static Stream<SchemaLoader.TypeInfo>	getAllSupportedTypesStream()
abstract List<CommandlineParameter>	getCommandlineParameters()
abstract Optional<Version>	getComponentVersionFromDb(String component)
protected String	getConfigString()
protected <DS extends DataSource> Stream<Class<DataSourceAware<DS>>>	getDataSourceAwareClassesForSchemaInfo(SchemaManager.SchemaInfo schema, Class<DS> dataSourceIfc)
abstract String	getDBUri()
protected <DSIFC extends DataSource, DS extends DSIFC> Stream<DataSourceAware>	getInitializedDataSourceAwareForSchemaInfo(SchemaManager.SchemaInfo schema, Class<DSIFC> dataSourceIfc, DS dataSource, Logger log)
static List<CommandlineParameter>	getMainCommandlineParameters(boolean forceNotRequired)
abstract Optional<Version>	getMinimalRequiredComponentVersionForUpgrade(SchemaManager.SchemaInfo schema)
abstract List<CommandlineParameter>	getSetupOptions()
abstract List<SchemaLoader.TypeInfo>	getSupportedTypes()
protected String	getType()
void	init(P props)
abstract void	init(P props, Optional<SchemaManager.RootCredentialsCache> rootCredentialsCache)
protected AuthRepository	initializeAuthRepository(AuthRepository authRepository)
protected <T extends DataSource> Function<DataSourceAware<T>,DataSourceAware<T>>	initializeDataSourceAwareFunction(T dataSource, Logger log)
protected <T> T	instantiateClass(Class<T> clazz)
boolean	isSupported(String dbType)
SchemaLoader.Result	loadCommonSchema()
abstract SchemaLoader.Result	loadSchema(SchemaManager.SchemaInfo schemaInfo, String version)
abstract SchemaLoader.Result	loadSchemaFile(String fileName)	Method checks whether the connection to the database is possible and that database of specified name exists.
static void	main(String[] args)	Main method allowing pass arguments to the class and setting all logging to be printed to console.
static SchemaLoader	newInstance(String type)
static SchemaLoader	newInstanceForURI(String uri)
abstract SchemaLoader.Result	postInstallation()
SchemaLoader.Result	printInfo()
abstract SchemaLoader.Result	setComponentVersion(String component, String version)	Methods attempt to write to database loaded schema version for particular component
abstract SchemaLoader.Result	shutdown()
abstract SchemaLoader.Result	validateDBConnection()	Method validates whether the connection can at least be eI stablished.
abstract SchemaLoader.Result	validateDBExists()	Method, if the connection is validated by validateDBConnection, checks whether desired database exists.

Methods inherited from class java.lang.Object

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

Field Details

log

protected static final Logger log

Constructor Details

SchemaLoader

public SchemaLoader()

Method Details

getMainCommandlineParameters

public static List<CommandlineParameter> getMainCommandlineParameters(boolean forceNotRequired)

getAllSupportedTypesStream

public static Stream<SchemaLoader.TypeInfo> getAllSupportedTypesStream()

getAllSupportedTypes

public static List<SchemaLoader.TypeInfo> getAllSupportedTypes()

main

public static void main(String[] args)

Main method allowing pass arguments to the class and setting all logging to be printed to console.

Parameters:

args - key-value (in the form of "-<variable> value") parameters.

newInstance

public static SchemaLoader newInstance(String type)

newInstanceForURI

public static SchemaLoader newInstanceForURI(String uri)

createParameters

public abstract P createParameters()

execute

public abstract void execute(SchemaLoader.Parameters params)

init

public abstract void init(P props,
 Optional<SchemaManager.RootCredentialsCache> rootCredentialsCache)

init

public void init(P props)

getSupportedTypes

public abstract List<SchemaLoader.TypeInfo> getSupportedTypes()

isSupported

public boolean isSupported(String dbType)

getDBUri

public abstract String getDBUri()

getSetupOptions

public abstract List<CommandlineParameter> getSetupOptions()

getCommandlineParameters

public abstract List<CommandlineParameter> getCommandlineParameters()

validateDBConnection

public abstract SchemaLoader.Result validateDBConnection()

Method validates whether the connection can at least be eI stablished. If yes then appropriate flag is set.

validateDBExists

public abstract SchemaLoader.Result validateDBExists()

Method, if the connection is validated by validateDBConnection, checks whether desired database exists. If not it creates such database using *-installer-create-db.sql schema file substituting it's variables with ones provided.

postInstallation

public abstract SchemaLoader.Result postInstallation()

getConfigString

protected String getConfigString()
                          throws IOException

Throws:

IOException

printInfo

public SchemaLoader.Result printInfo()

addXmppAdminAccount

public abstract SchemaLoader.Result addXmppAdminAccount(SchemaManager.SchemaInfo schemaInfo)

Method attempts to add XMPP admin user account to the database using AuthRepository.

setComponentVersion

public abstract SchemaLoader.Result setComponentVersion(String component,
 String version)

Methods attempt to write to database loaded schema version for particular component

Parameters:

component - name of the component for which version should be set

version - value which should be associated with the component

Returns:

a SchemaLoader.Result object indicating whether the call was successful

getComponentVersionFromDb

public abstract Optional<Version> getComponentVersionFromDb(String component)

loadSchemaFile

public abstract SchemaLoader.Result loadSchemaFile(String fileName)

Method checks whether the connection to the database is possible and that database of specified name exists. If yes then a schema file from properties is loaded.

Parameters:

fileName - set of String with path to file

shutdown

public abstract SchemaLoader.Result shutdown()

loadCommonSchema

public SchemaLoader.Result loadCommonSchema()

loadSchema

public abstract SchemaLoader.Result loadSchema(SchemaManager.SchemaInfo schemaInfo,
 String version)

getMinimalRequiredComponentVersionForUpgrade

public abstract Optional<Version> getMinimalRequiredComponentVersionForUpgrade(SchemaManager.SchemaInfo schema)

destroyDataSource

public abstract SchemaLoader.Result destroyDataSource()

addUsersToRepository

protected <T extends DataSource>
SchemaLoader.Result addUsersToRepository(SchemaManager.SchemaInfo schemaInfo,
 T dataSource,
 Class<T> dataSourceClass,
 List<BareJID> jids,
 String password,
 Logger log)

getDataSourceAwareClassesForSchemaInfo

protected <DS extends DataSource>
Stream<Class<DataSourceAware<DS>>> getDataSourceAwareClassesForSchemaInfo(SchemaManager.SchemaInfo schema,
 Class<DS> dataSourceIfc)

getInitializedDataSourceAwareForSchemaInfo

protected <DSIFC extends DataSource,
DS extends DSIFC>
Stream<DataSourceAware> getInitializedDataSourceAwareForSchemaInfo(SchemaManager.SchemaInfo schema,
 Class<DSIFC> dataSourceIfc,
 DS dataSource,
 Logger log)

initializeAuthRepository

protected AuthRepository initializeAuthRepository(AuthRepository authRepository)

initializeDataSourceAwareFunction

protected <T extends DataSource>
Function<DataSourceAware<T>,DataSourceAware<T>> initializeDataSourceAwareFunction(T dataSource,
 Logger log)

addUsersToRepositoryFunction

protected Function<AuthRepository,SchemaLoader.Result> addUsersToRepositoryFunction(List<BareJID> jids,
 String pwd,
 Logger log)

instantiateClass

protected <T> T instantiateClass(Class<T> clazz)

getType

protected String getType()