org.n52.sos.ds.datasource

Class AbstractHibernateDatasource

java.lang.Object

org.n52.sos.ds.datasource.AbstractHibernateCoreDatasource

org.n52.sos.ds.datasource.AbstractHibernateDatasource

All Implemented Interfaces:

ConnectionProviderIdentificator, Datasource, DatasourceDaoIdentifier, HibernateDatasourceConstants, Constants, SQLConstants

Direct Known Subclasses:

AbstractH2Datasource, AbstractHibernateFullDBDatasource

public abstract class AbstractHibernateDatasource
extends AbstractHibernateCoreDatasource
implements SQLConstants

Since:

4.0.0

Author:

Christian Autermann

Nested Class Summary

Nested classes/interfaces inherited from interface org.n52.sos.ds.HibernateDatasourceConstants

HibernateDatasourceConstants.DatabaseConcept

Field Summary

Fields

Modifier and Type	Field and Description
protected static Integer	BATCH_SIZE_DEFAULT_VALUE
protected static String	BATCH_SIZE_DESCRIPTION
protected static String	BATCH_SIZE_KEY
protected static String	BATCH_SIZE_TITLE
protected static String	DATABASE_CONCEPT_DEFAULT_VALUE
protected static String	DATABASE_CONCEPT_DESCRIPTION
protected static String	DATABASE_CONCEPT_KEY
protected static String	DATABASE_CONCEPT_TITLE
private ChoiceSettingDefinition	databaseConceptDefinition
private org.hibernate.dialect.Dialect	dialect
private static org.slf4j.Logger	LOG
protected static boolean	MULTILINGUALISM_DEFAULT_VALUE
protected static String	MULTILINGUALISM_DESCRIPTION
protected static String	MULTILINGUALISM_KEY
protected static String	MULTILINGUALISM_TITLE
private boolean	multilingualismDatasource
private BooleanSettingDefinition	multilingualismDefinition
protected static Boolean	PROVIDED_JDBC_DRIVER_DEFAULT_VALUE
protected static String	PROVIDED_JDBC_DRIVER_DESCRIPTION
protected static String	PROVIDED_JDBC_DRIVER_KEY
protected static String	PROVIDED_JDBC_DRIVER_TITLE
protected static String	SCHEMA_DESCRIPTION
protected static String	SCHEMA_KEY
protected static String	SCHEMA_TITLE
protected static String	SCHMEA_DEFAULT_VALUE
protected static boolean	TRANSACTIONAL_DEFAULT_VALUE
protected static String	TRANSACTIONAL_DESCRIPTION
protected static String	TRANSACTIONAL_KEY
protected static String	TRANSACTIONAL_TITLE
private boolean	transactionalDatasource
private BooleanSettingDefinition	transactionalDefiniton
protected static String	USERNAME_KEY

Fields inherited from class org.n52.sos.ds.datasource.AbstractHibernateCoreDatasource

C3P0_CONNECTION_POOL, DATABASE_DEFAULT_VALUE, DATABASE_DESCRIPTION, DATABASE_KEY, DATABASE_TITLE, HOST_DEFAULT_VALUE, HOST_DESCRIPTION, HOST_KEY, HOST_TITLE, MAX_POOL_SIZE_DEFAULT_VALUE, MAX_POOL_SIZE_DESCRIPTION, MAX_POOL_SIZE_KEY, MAX_POOL_SIZE_TITLE, MIN_POOL_SIZE_DEFAULT_VALUE, MIN_POOL_SIZE_DESCRIPTION, MIN_POOL_SIZE_KEY, MIN_POOL_SIZE_TITLE, PASSWORD_KEY, PASSWORD_TITLE, PORT_KEY, PORT_TITLE, USERNAME_TITLE

Fields inherited from interface org.n52.sos.util.SQLConstants

DEFAULT_COUNT, FROM, SELECT

Fields inherited from interface org.n52.sos.util.Constants

AMPERSAND_CHAR, AMPERSAND_STRING, BACKSLASH_CHAR, BACKSLASH_STRING, BLANK_CHAR, BLANK_STRING, CLOSE_BRACE_CHAR, CLOSE_BRACE_STRING, COLON_CHAR, COLON_STRING, COMMA_CHAR, COMMA_SPACE_STRING, COMMA_STRING, CSV_BLOCK_SEPARATOR, CSV_TOKEN_SEPARATOR, DASH_CHAR, DASH_STRING, DEFAULT_ENCODING, DOLLAR_CHAR, DOLLAR_STRING, DOT_CHAR, DOT_STRING, DOUBLE_COLON_STRING, EMPTY_STRING, EPSG_WGS84, EPSG_WGS84_3D, EQUAL_SIGN_CHAR, EQUAL_SIGN_STRING, GREATER_THAN_SIGN_STRING, HASH_CODE_13, HASH_CODE_17, HASH_CODE_19, HASH_CODE_23, HASH_CODE_29, HASH_CODE_3, HASH_CODE_31, HASH_CODE_37, HASH_CODE_41, HASH_CODE_43, HASH_CODE_47, HASH_CODE_5, HASH_CODE_7, HTTP, INT_0, INT_1, INT_2, INT_3, INT_4, INVERTED_COMMA_CHAR, INVERTED_COMMA_STRING, LESS_THAN_SIGN_STRING, LINE_SEPARATOR_CHAR, LINE_SEPARATOR_STRING, MINUS_CHAR, MINUS_STRING, NUMBER_SIGN_CHAR, NUMBER_SIGN_STRING, OPEN_BRACE_CHAR, OPEN_BRACE_STRING, PERCENT_CHAR, PERCENT_STRING, PLUS_CHAR, PLUS_STRING, QUERSTIONMARK_CHAR, QUERSTIONMARK_STRING, SEMICOLON_CHAR, SEMICOLON_STRING, SLASH_CHAR, SLASH_STRING, SPACE_CHAR, SPACE_STRING, UNDERSCORE_CHAR, UNDERSCORE_STRING, URN

Fields inherited from interface org.n52.sos.ds.Datasource

ADVANCED_GROUP, BASE_GROUP

Fields inherited from interface org.n52.sos.ds.ConnectionProviderIdentificator

CONNECTION_PROVIDER_IDENTIFIER

Fields inherited from interface org.n52.sos.ds.DatasourceDaoIdentifier

DATASOURCE_DAO_IDENTIFIER, IDEPENDET_IDENTIFIER

Fields inherited from interface org.n52.sos.ds.HibernateDatasourceConstants

HIBERNATE_ANNOTADED_CLASSES, HIBERNATE_DEFAULT_OGM_PACKAGE, HIBERNATE_DIRECTORY, HIBERNATE_DRIVER_CLASS, HIBERNATE_MAPPING_CORE_PATH, HIBERNATE_MAPPING_EREPORTING_CONCEPT_OBSERVATION_PATH, HIBERNATE_MAPPING_EXTENSION, HIBERNATE_MAPPING_EXTENSION_READONLY, HIBERNATE_MAPPING_I18N_PATH, HIBERNATE_MAPPING_OLD_CONCEPT_OBSERVATION_PATH, HIBERNATE_MAPPING_PATH, HIBERNATE_MAPPING_SERIES_CONCEPT_OBSERVATION_PATH, HIBERNATE_MAPPING_SERIES_CONCEPT_PATH, HIBERNATE_MAPPING_TRANSACTIONAL_PATH, HIBERNATE_RESOURCES, HIBERNATPE_MAPPING_OLD_CONCEPT_PATH, OGM_CONNECTION_PROVIDER_IDENTIFIER, OGM_DATASOURCE_DAO_IDENTIFIER, ORM_CONNECTION_PROVIDER_IDENTIFIER, ORM_DATASOURCE_DAO_IDENTIFIER, PATH_SEPERATOR, PROVIDED_JDBC

Constructor Summary

Constructors

Constructor and Description
AbstractHibernateDatasource()

Method Summary

Modifier and Type	Method and Description
protected void	addMappingFileDirectories(Map<String,Object> settings, Properties p) Add mapping files directories to properties
private String	checkCatalog(Connection conn)
protected String[]	checkCreateSchema(String[] script) Remove duplicated foreign key definition for table observationHasOffering otherwise database model creation fails in Oracle
protected String[]	checkDropSchema(String[] dropSchema) Check if drop schema contains alter table ... drop constraint ... .
private boolean	checkIfExtensionDirectoryExists()
boolean	checkIfSchemaExists(Map<String,Object> settings) Check if the schema exists.
boolean	checkIfSchemaExists(Properties current, Map<String,Object> changed) Check if the schema exists.
void	checkPostCreation(Properties properties)
protected String	checkSchema(String schema, String catalog, Connection conn)
protected String[]	checkScriptForGeneratedAndDuplicatedEntries(String[] script) Remove generated foreign key definition and duplicated entries.
protected void	close(Connection conn) Close SQL connection
protected void	close(Statement stmt) Close SQL statement
private <T> T[]	concat(T[] first, T[]... rest) Concatenate two arrays
protected IntegerSettingDefinition	createBatchSizeDefinition() Create settings definition for JDBC batch size
protected ChoiceSettingDefinition	createDatabaseConceptDefinition()
protected abstract org.hibernate.dialect.Dialect	createDialect() Create a new Hibernate dialect
protected BooleanSettingDefinition	createMultilingualismDefinition()
protected BooleanSettingDefinition	createProvidedJdbcDriverDefinition() Create settings definition for JDBC driver
String[]	createSchema(Map<String,Object> settings) Create the schema for the supplied settings.
protected StringSettingDefinition	createSchemaDefinition() Create settings definition for database schema
protected BooleanSettingDefinition	createTransactionalDefinition() Create settings definition for transactional support
protected StringSettingDefinition	createUsernameDefinition() Create settings definition for username
String[]	dropSchema(Map<String,Object> settings) Drop the present schema (or parts of it).
protected void	execute(String[] sql, Connection conn) Execute SQL script
void	execute(String[] sql, Map<String,Object> settings)
void	executePostCreateSchema(Map<String,Object> databaseSettings)
protected Set<SettingDefinition<?,?>>	filter(Set<SettingDefinition<?,?>> definitions, Set<String> keysToExclude)
DatasourceCallback	getCallback()
CustomConfiguration	getConfig(Map<String,Object> settings) Get custom configuration from datasource settings
String	getConnectionProviderIdentifier()
protected ChoiceSettingDefinition	getDatabaseConceptDefinition()
protected String	getDatabaseConceptMappingDirectory(Map<String,Object> settings)
protected org.hibernate.tool.hbm2ddl.DatabaseMetadata	getDatabaseMetadata(Connection conn, CustomConfiguration customConfiguration)
String	getDatasourceDaoIdentifier()
protected org.hibernate.dialect.Dialect	getDialectInternal() Get internal Hibernate dialect
protected abstract String	getDriverClass() Gets the qualified name of the driver class.
private String	getGeneratedForeignKeyFor(String tableName) Create the beginning character of a generated foreign key from a table name hasCode()
protected BooleanSettingDefinition	getMulitLanguageDefiniton()
protected String[]	getPostSchemaScript() Get the schema script after the database schema is created
protected String[]	getPreSchemaScript() Get the schema script before the database schema is created
protected String	getSchema(Map<String,Object> settings)
protected BooleanSettingDefinition	getTransactionalDefiniton() Get transactional setting definition
protected boolean	isMultiLanguage(Properties properties)
boolean	isMultiLanguageDatasource()
boolean	isPostCreateSchema()
protected boolean	isSetSchema(Map<String,Object> settings)
protected boolean	isTransactional(Properties properties) Check if properties contains transactional mapping path
boolean	isTransactionalDatasource() Check if the datasource is transactional
boolean	needsSchema()
protected abstract Connection	openConnection(Map<String,Object> settings) Open a new SQL connection
void	prepare(Map<String,Object> settings) Called right before a schema is created.
protected File	resource(String resource) Get File from resource String
void	setMultiLangugage(boolean multiLanguageDatasource)
void	setTransactional(boolean transactionalDatasource) Set transactional datasource flag
String[]	updateSchema(Map<String,Object> settings) Creates an update schema for the supplied settings.
void	validateConnection(Map<String,Object> settings) Check if a connection is possible.
void	validateConnection(Properties current, Map<String,Object> changed) Check if a connection is still possible with the newSettings settings.
protected abstract void	validatePrerequisites(Connection con, org.hibernate.tool.hbm2ddl.DatabaseMetadata metadata, Map<String,Object> settings) Check if the required extensions are available
void	validatePrerequisites(Map<String,Object> settings) Validate if all prerequisites (e.g. datasource version) are met.
void	validatePrerequisites(Properties current, Map<String,Object> changed) Used to validate prerequisites after the connections settings newSettings in the admin interface.
void	validateSchema(Map<String,Object> settings) Validate the existing schema.
void	validateSchema(Properties current, Map<String,Object> changed) Validate the existing schema.

Methods inherited from class org.n52.sos.ds.datasource.AbstractHibernateCoreDatasource

createDatabaseDefinition, createDatabaseDefinition, createHostDefinition, createHostDefinition, createMaxPoolSizeDefinition, createMaxPoolSizeDefinition, createMinPoolSizeDefinition, createMinPoolSizeDefinition, createPasswordDefinition, createPasswordDefinition, createPortDefinition, createPortDefinition, createUsernameDefinition, getChangableSettingDefinitions, getDatasourceProperties, getSettingDefinitions, mergeProperties, parseDatasourceProperties, parseURL, setDatabaseDefault, setDatabaseDescription, setHostDefault, setHostDescription, setMaxPoolSizeDefault, setMinPoolSizeDefault, setPasswordDefault, setPasswordDescription, setPortDefault, setPortDescription, setUsernameDefault, setUsernameDescription, toURL

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.n52.sos.ds.Datasource

checkSchemaCreation, clear, getDatasourceProperties, getDialectName, supportsClear

Field Detail

LOG

private static final org.slf4j.Logger LOG

SCHEMA_KEY

protected static final String SCHEMA_KEY

See Also:

Constant Field Values

SCHEMA_TITLE

protected static final String SCHEMA_TITLE

See Also:

Constant Field Values

SCHEMA_DESCRIPTION

protected static final String SCHEMA_DESCRIPTION

See Also:

Constant Field Values

SCHMEA_DEFAULT_VALUE

protected static final String SCHMEA_DEFAULT_VALUE

See Also:

Constant Field Values

DATABASE_CONCEPT_TITLE

protected static final String DATABASE_CONCEPT_TITLE

See Also:

Constant Field Values

DATABASE_CONCEPT_DESCRIPTION

protected static final String DATABASE_CONCEPT_DESCRIPTION

See Also:

Constant Field Values

DATABASE_CONCEPT_KEY

protected static final String DATABASE_CONCEPT_KEY

See Also:

Constant Field Values

DATABASE_CONCEPT_DEFAULT_VALUE

protected static final String DATABASE_CONCEPT_DEFAULT_VALUE

TRANSACTIONAL_TITLE

protected static final String TRANSACTIONAL_TITLE

See Also:

Constant Field Values

TRANSACTIONAL_DESCRIPTION

protected static final String TRANSACTIONAL_DESCRIPTION

See Also:

Constant Field Values

TRANSACTIONAL_KEY

protected static final String TRANSACTIONAL_KEY

See Also:

Constant Field Values

TRANSACTIONAL_DEFAULT_VALUE

protected static final boolean TRANSACTIONAL_DEFAULT_VALUE

See Also:

Constant Field Values

MULTILINGUALISM_TITLE

protected static final String MULTILINGUALISM_TITLE

See Also:

Constant Field Values

MULTILINGUALISM_DESCRIPTION

protected static final String MULTILINGUALISM_DESCRIPTION

See Also:

Constant Field Values

MULTILINGUALISM_KEY

protected static final String MULTILINGUALISM_KEY

See Also:

Constant Field Values

MULTILINGUALISM_DEFAULT_VALUE

protected static final boolean MULTILINGUALISM_DEFAULT_VALUE

See Also:

Constant Field Values

USERNAME_KEY

protected static final String USERNAME_KEY

See Also:

Constant Field Values

PROVIDED_JDBC_DRIVER_DEFAULT_VALUE

protected static final Boolean PROVIDED_JDBC_DRIVER_DEFAULT_VALUE

PROVIDED_JDBC_DRIVER_TITLE

protected static final String PROVIDED_JDBC_DRIVER_TITLE

See Also:

Constant Field Values

PROVIDED_JDBC_DRIVER_DESCRIPTION

protected static final String PROVIDED_JDBC_DRIVER_DESCRIPTION

See Also:

Constant Field Values

PROVIDED_JDBC_DRIVER_KEY

protected static final String PROVIDED_JDBC_DRIVER_KEY

See Also:

Constant Field Values

BATCH_SIZE_KEY

protected static final String BATCH_SIZE_KEY

See Also:

Constant Field Values

BATCH_SIZE_TITLE

protected static final String BATCH_SIZE_TITLE

See Also:

Constant Field Values

BATCH_SIZE_DESCRIPTION

protected static final String BATCH_SIZE_DESCRIPTION

See Also:

Constant Field Values

BATCH_SIZE_DEFAULT_VALUE

protected static final Integer BATCH_SIZE_DEFAULT_VALUE

dialect

private org.hibernate.dialect.Dialect dialect

databaseConceptDefinition

private final ChoiceSettingDefinition databaseConceptDefinition

transactionalDefiniton

private final BooleanSettingDefinition transactionalDefiniton

transactionalDatasource

private boolean transactionalDatasource

multilingualismDefinition

private final BooleanSettingDefinition multilingualismDefinition

multilingualismDatasource

private boolean multilingualismDatasource

Constructor Detail

AbstractHibernateDatasource

public AbstractHibernateDatasource()

Method Detail

createUsernameDefinition

protected StringSettingDefinition createUsernameDefinition()

Create settings definition for username

Overrides:

createUsernameDefinition in class AbstractHibernateCoreDatasource

Returns:

Username settings definition

createSchemaDefinition

protected StringSettingDefinition createSchemaDefinition()

Create settings definition for database schema

Returns:

Database schema settings definition

createDatabaseConceptDefinition

protected ChoiceSettingDefinition createDatabaseConceptDefinition()

createTransactionalDefinition

protected BooleanSettingDefinition createTransactionalDefinition()

Create settings definition for transactional support

Returns:

Transactional support settings definition

createMultilingualismDefinition

protected BooleanSettingDefinition createMultilingualismDefinition()

createProvidedJdbcDriverDefinition

protected BooleanSettingDefinition createProvidedJdbcDriverDefinition()

Create settings definition for JDBC driver

Returns:

JDBC driver settings definition

createBatchSizeDefinition

protected IntegerSettingDefinition createBatchSizeDefinition()

Create settings definition for JDBC batch size

Returns:

JDBC batch size settings definition

getConfig

public CustomConfiguration getConfig(Map<String,Object> settings)

Get custom configuration from datasource settings

Parameters:

settings - Datasource settings to create custom configuration from

Returns:

Custom configuration from datasource settings

getDatabaseConceptMappingDirectory

protected String getDatabaseConceptMappingDirectory(Map<String,Object> settings)

resource

protected File resource(String resource)

Get File from resource String

Parameters:

resource - Resource String

Returns:

File from resource String

createSchema

public String[] createSchema(Map<String,Object> settings)

Description copied from interface: Datasource

Create the schema for the supplied settings. Will only be called if needsSchema() and checkSchemaCreation() return true. If checkIfSchemaExists() returned true, dropSchema() will be called first.

Specified by:

createSchema in interface Datasource

Parameters:

settings - the settings to connect

dropSchema

public String[] dropSchema(Map<String,Object> settings)

Description copied from interface: Datasource

Drop the present schema (or parts of it). Will only be called if needsSchema() and checkIfSchemaExists() return true.

Specified by:

dropSchema in interface Datasource

Parameters:

settings - the settings to connect

updateSchema

public String[] updateSchema(Map<String,Object> settings)

Description copied from interface: Datasource

Creates an update schema for the supplied settings. Will only be called if needsSchema() and checkSchemaCreation() return true. If checkIfSchemaExists() returned true, dropSchema() will be called first.

Specified by:

updateSchema in interface Datasource

Parameters:

settings - the settings to connect

Returns:

validateSchema

public void validateSchema(Map<String,Object> settings)

Description copied from interface: Datasource

Validate the existing schema. Will only be called if needsSchema() and checkIfSchemaExists() return true.

Specified by:

validateSchema in interface Datasource

Parameters:

settings - the settings to connect

getDatabaseMetadata

protected org.hibernate.tool.hbm2ddl.DatabaseMetadata getDatabaseMetadata(Connection conn,
                                                                          CustomConfiguration customConfiguration)
                                                                   throws SQLException

Throws:

SQLException

checkIfSchemaExists

public boolean checkIfSchemaExists(Map<String,Object> settings)

Description copied from interface: Datasource

Check if the schema exists. Should return true even if parts are missing. Will only be called if needsSchema() returns true.

Specified by:

checkIfSchemaExists in interface Datasource

Parameters:

settings - the settings to connect

Returns:

if the schema (or parts of it) exists

checkSchema

protected String checkSchema(String schema,
                             String catalog,
                             Connection conn)
                      throws SQLException

Throws:

SQLException

checkCatalog

private String checkCatalog(Connection conn)
                     throws SQLException

Throws:

SQLException

execute

public void execute(String[] sql,
                    Map<String,Object> settings)
             throws org.hibernate.HibernateException

Specified by:

execute in interface Datasource

Throws:

org.hibernate.HibernateException

validateConnection

public void validateConnection(Map<String,Object> settings)

Description copied from interface: Datasource

Check if a connection is possible.

Specified by:

validateConnection in interface Datasource

Parameters:

settings - the settings to connect

needsSchema

public boolean needsSchema()

Specified by:

needsSchema in interface Datasource

Returns:

if this datasource needs some kind of schema

validatePrerequisites

public void validatePrerequisites(Map<String,Object> settings)

Description copied from interface: Datasource

Validate if all prerequisites (e.g. datasource version) are met. Will only be called if validateConnection() succeeded.

Specified by:

validatePrerequisites in interface Datasource

Parameters:

settings - the settings to connect

validateConnection

public void validateConnection(Properties current,
                               Map<String,Object> changed)

Description copied from interface: Datasource

Check if a connection is still possible with the newSettings settings.

Specified by:

validateConnection in interface Datasource

Parameters:

current - the current datasource settings

changed - the newSettings settings

validatePrerequisites

public void validatePrerequisites(Properties current,
                                  Map<String,Object> changed)

Description copied from interface: Datasource

Used to validate prerequisites after the connections settings newSettings in the admin interface.

Specified by:

validatePrerequisites in interface Datasource

Parameters:

current - the current datasource settings

changed - the newSettings settings

validateSchema

public void validateSchema(Properties current,
                           Map<String,Object> changed)

Description copied from interface: Datasource

Validate the existing schema. Will only be called if needsSchema() and checkIfSchemaExists() return true.

Specified by:

validateSchema in interface Datasource

Parameters:

current - the current datasource settings

changed - the newSettings settings

checkIfSchemaExists

public boolean checkIfSchemaExists(Properties current,
                                   Map<String,Object> changed)

Description copied from interface: Datasource

Check if the schema exists. Should return true even if parts are missing. Will only be called if needsSchema() returns true.

Specified by:

checkIfSchemaExists in interface Datasource

Parameters:

current - the current datasource settings

changed - the newSettings settings

Returns:

if the schema (or parts of it) exists

checkPostCreation

public void checkPostCreation(Properties properties)

Specified by:

checkPostCreation in interface Datasource

checkIfExtensionDirectoryExists

private boolean checkIfExtensionDirectoryExists()

filter

protected Set<SettingDefinition<?,?>> filter(Set<SettingDefinition<?,?>> definitions,
                                             Set<String> keysToExclude)

getDialectInternal

protected org.hibernate.dialect.Dialect getDialectInternal()

Get internal Hibernate dialect

Returns:

Hibernate dialect

execute

protected void execute(String[] sql,
                       Connection conn)
                throws org.hibernate.HibernateException

Execute SQL script

Parameters:

sql - SQL script to execute

conn - SQL connection

Throws:

org.hibernate.HibernateException - If an error occurs

close

protected void close(Connection conn)

Close SQL connection

Parameters:

conn - SQL connection to close

close

protected void close(Statement stmt)

Close SQL statement

Parameters:

stmt - SQL statement to close

addMappingFileDirectories

protected void addMappingFileDirectories(Map<String,Object> settings,
                                         Properties p)

Add mapping files directories to properties

Parameters:

settings - Datasource settings

p - Datasource properties

getDatabaseConceptDefinition

protected ChoiceSettingDefinition getDatabaseConceptDefinition()

isTransactional

protected boolean isTransactional(Properties properties)

Check if properties contains transactional mapping path

Parameters:

properties - Datasource properties

Returns:

true, if properties contains transactional mapping path

getTransactionalDefiniton

protected BooleanSettingDefinition getTransactionalDefiniton()

Get transactional setting definition

Returns:

Transactional setting definition

isMultiLanguage

protected boolean isMultiLanguage(Properties properties)

getMulitLanguageDefiniton

protected BooleanSettingDefinition getMulitLanguageDefiniton()

concat

private <T> T[] concat(T[] first,
                       T[]... rest)

Concatenate two arrays

Parameters:

first - First array

rest - The other array

Returns:

Concatenated array

getPreSchemaScript

protected String[] getPreSchemaScript()

Get the schema script before the database schema is created

Returns:

script to run before the schema creation

getPostSchemaScript

protected String[] getPostSchemaScript()

Get the schema script after the database schema is created

Returns:

script to run after the schema creation

isSetSchema

protected boolean isSetSchema(Map<String,Object> settings)

getSchema

protected String getSchema(Map<String,Object> settings)

isTransactionalDatasource

public boolean isTransactionalDatasource()

Check if the datasource is transactional

Returns:

true, if it is a transactionalDatasource

setTransactional

public void setTransactional(boolean transactionalDatasource)

Set transactional datasource flag

Parameters:

transactionalDatasource - the transactionalDatasource flag to set

isMultiLanguageDatasource

public boolean isMultiLanguageDatasource()

Returns:

the multi language

setMultiLangugage

public void setMultiLangugage(boolean multiLanguageDatasource)

Parameters:

multi - language the multi language to set

checkCreateSchema

protected String[] checkCreateSchema(String[] script)

Remove duplicated foreign key definition for table observationHasOffering otherwise database model creation fails in Oracle

Parameters:

script - Create and not checked script.

Returns:

Checked script without duplicate foreign key for observationHasOffering

checkScriptForGeneratedAndDuplicatedEntries

protected String[] checkScriptForGeneratedAndDuplicatedEntries(String[] script)

Remove generated foreign key definition and duplicated entries.

Parameters:

script - Not checked script.

Returns:

Checked script without duplicate foreign key

getGeneratedForeignKeyFor

private String getGeneratedForeignKeyFor(String tableName)

Create the beginning character of a generated foreign key from a table name hasCode()

Parameters:

string - Table name

Returns:

Beginning characters of a generated foreign key like "FK + table name hasCode()"

checkDropSchema

protected String[] checkDropSchema(String[] dropSchema)

Check if drop schema contains alter table ... drop constraint ... . Due to dynamic generation some constraints are generated and differ.

Parameters:

dropSchema - Schema to check

Returns:

Checked schema

getCallback

public DatasourceCallback getCallback()

Specified by:

getCallback in interface Datasource

Returns:

the callback used at instantiation time of the connection provider

prepare

public void prepare(Map<String,Object> settings)

Description copied from interface: Datasource

Called right before a schema is created.

Specified by:

prepare in interface Datasource

Parameters:

settings - the settings to connect

isPostCreateSchema

public boolean isPostCreateSchema()

Specified by:

isPostCreateSchema in interface Datasource

executePostCreateSchema

public void executePostCreateSchema(Map<String,Object> databaseSettings)

Specified by:

executePostCreateSchema in interface Datasource

getConnectionProviderIdentifier

public String getConnectionProviderIdentifier()

Specified by:

getConnectionProviderIdentifier in interface ConnectionProviderIdentificator

getDatasourceDaoIdentifier

public String getDatasourceDaoIdentifier()

Specified by:

getDatasourceDaoIdentifier in interface DatasourceDaoIdentifier

getDriverClass

protected abstract String getDriverClass()

Gets the qualified name of the driver class.

Returns:

the driver class.

validatePrerequisites

protected abstract void validatePrerequisites(Connection con,
                                              org.hibernate.tool.hbm2ddl.DatabaseMetadata metadata,
                                              Map<String,Object> settings)

Check if the required extensions are available

Parameters:

con - SQL connection

metadata - Current database metadata

settings - Datasource settings

createDialect

protected abstract org.hibernate.dialect.Dialect createDialect()

Create a new Hibernate dialect

Returns:

Hibernate dialect

openConnection

protected abstract Connection openConnection(Map<String,Object> settings)
                                      throws SQLException

Open a new SQL connection

Parameters:

settings - Datasource setting: URL, username, passsword, database, ...

Returns:

New SQL connection

Throws:

SQLException - If the SQL connection creation fails