fr.ifremer.adagio.synchro.meta

Class SynchroDatabaseMetadata

Object

SynchroDatabaseMetadata

public class SynchroDatabaseMetadata
extends Object

Created on 1/14/14.

Since:

3.5

Author:

Tony Chemit

Field Summary

Fields

Modifier and Type	Field and Description
protected Configuration	configuration
protected SynchroContext	context
protected DatabaseMetadata	delegate
protected Dialect	dialect
protected List<SynchroInterceptor>	interceptors
protected DatabaseMetaData	meta
protected Set<String>	sequences
protected Map<String,SynchroTableMetadata>	tables
protected String[]	types

Constructor Summary

Constructors

Constructor and Description
SynchroDatabaseMetadata(Connection connection, Dialect dialect, Configuration configuration, SynchroContext context)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	fireOnTableLoad(SynchroTableMetadata table)
SynchroContext	getContext()
Dialect	getDialect()
ResultSet	getExportedKeys(String catalog, String schema, String table)
ResultSet	getImportedKeys(String catalog, String schema, String table)
int	getInExpressionCountLimit()
protected List<SynchroInterceptor>	getInterceptors(TableMetadata table)
Set<String>	getLoadedRootTableNames() Return all root tables (top level tables).
SynchroTableMetadata	getLoadedTable(String name)
SynchroTableMetadata	getLoadedTable(String name, String schema, String catalog)
Set<String>	getLoadedTableNames() Return all tables (already loaded).
ResultSet	getPrimaryKeys(String catalog, String schema, String table)
protected SynchroTableMetadata	getTable(Dialect dialect, String name, String schema, String catalog, boolean isQuoted, Predicate<SynchroColumnMetadata> columnFilter, boolean withJoinedTables)
SynchroTableMetadata	getTable(String name)
int	getTableCount()
Set<String>	getTableNames(Predicate<String> tableFilter) Load tables names from database schema, using the given table filter.
Set<String>	getTableNames(Set<String> tablePatterns, Predicate<String> tableFilter) Load tables names from database schema, using the given table patterns list, and a optional filter.
protected Set<String>	initSequences(Connection connection, Dialect dialect)
boolean	isSequence(String tableName)
static SynchroDatabaseMetadata	loadDatabaseMetadata(Connection connection, Dialect dialect, Configuration configuration, SynchroContext context, Set<String> tableNames, boolean enableJoinMetadataLoading) Load the datasource schema for the given connection and dialect.
static SynchroDatabaseMetadata	loadDatabaseMetadata(Connection connection, Dialect dialect, Configuration configuration, SynchroContext context, Set<String> tableNames, Predicate<String> tableFilter, Predicate<SynchroColumnMetadata> columnFilter, boolean enableJoinMetadataLoading) Load the datasource schema for the given connection and dialect.
void	prepare(Dialect dialect, Configuration configuration, Set<String> tableNames, Predicate<String> tableFilter, Predicate<SynchroColumnMetadata> columnFilter, boolean enableJoinMetadataLoading)

Methods inherited from class Object

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

Field Detail

delegate

protected final DatabaseMetadata delegate

tables

protected final Map<String,SynchroTableMetadata> tables

meta

protected final DatabaseMetaData meta

configuration

protected final Configuration configuration

dialect

protected final Dialect dialect

sequences

protected final Set<String> sequences

types

protected final String[] types

interceptors

protected List<SynchroInterceptor> interceptors

context

protected SynchroContext context

Constructor Detail

SynchroDatabaseMetadata

public SynchroDatabaseMetadata(Connection connection,
                       Dialect dialect,
                       Configuration configuration,
                       SynchroContext context)

Method Detail

loadDatabaseMetadata

public static SynchroDatabaseMetadata loadDatabaseMetadata(Connection connection,
                                           Dialect dialect,
                                           Configuration configuration,
                                           SynchroContext context,
                                           Set<String> tableNames,
                                           boolean enableJoinMetadataLoading)

Load the datasource schema for the given connection and dialect.

Parameters:

connection - connection of the data source

dialect - dialect to use

configuration -

tableNames - table names to includes (table patterns are accepted)

Returns:

the database schema metadata

loadDatabaseMetadata

public static SynchroDatabaseMetadata loadDatabaseMetadata(Connection connection,
                                           Dialect dialect,
                                           Configuration configuration,
                                           SynchroContext context,
                                           Set<String> tableNames,
                                           Predicate<String> tableFilter,
                                           Predicate<SynchroColumnMetadata> columnFilter,
                                           boolean enableJoinMetadataLoading)

Load the datasource schema for the given connection and dialect.

Parameters:

connection - connection of the data source

dialect - dialect to use

configuration -

tableNames - table names to includes (table patterns are accepted) (optional if tabkleFilter not null)

tableFilter - filter tables (optional)

columnFilter - filter columns (optional)

Returns:

the database schema metadata

getTableCount

public int getTableCount()

getContext

public SynchroContext getContext()

getDialect

public Dialect getDialect()

getInExpressionCountLimit

public int getInExpressionCountLimit()

isSequence

public boolean isSequence(String tableName)

prepare

public void prepare(Dialect dialect,
           Configuration configuration,
           Set<String> tableNames,
           Predicate<String> tableFilter,
           Predicate<SynchroColumnMetadata> columnFilter,
           boolean enableJoinMetadataLoading)

getTable

public SynchroTableMetadata getTable(String name)
                              throws HibernateException

Throws:

HibernateException

getLoadedTable

public SynchroTableMetadata getLoadedTable(String name)
                                    throws HibernateException

Throws:

HibernateException

getLoadedTable

public SynchroTableMetadata getLoadedTable(String name,
                                  String schema,
                                  String catalog)
                                    throws HibernateException

Throws:

HibernateException

getTableNames

public Set<String> getTableNames(Predicate<String> tableFilter)

Load tables names from database schema, using the given table filter.
This method call #getTableNames(Set,Predicate) with the table pattern "%".

Parameters:

tableFilter - A filter predicate, to filter tables to retrieve. If null: process all tables found.

Returns:

All tables names found in database, filtered using the given tableFilter

See Also:

#getTableNames(Set,Predicate)

getTableNames

public Set<String> getTableNames(Set<String> tablePatterns,
                        Predicate<String> tableFilter)

Load tables names from database schema, using the given table patterns list, and a optional filter. This use the JDBC metadata API.
This will include Tables and View objects. Synonyms ar includes only if enable in connection properties org.hibernate.cfg.AvailableSettings.ENABLE_SYNONYMS.

Parameters:

tablePatterns - A list of table pattern. Use the pattern '%' to get all tables.

tableFilter - Optional. A filter predicate, to filter tables to retrieve. If null: process tables found from pattern will be return.

Returns:

All tables names found in database

See Also:

org.hibernate.cfg.AvailableSettings.ENABLE_SYNONYMS, DatabaseMetaData.getTables(String,String,String,String[])

getLoadedRootTableNames

public Set<String> getLoadedRootTableNames()

Return all root tables (top level tables).
Return only tables previously loaded using methods getTable() or loadDatabaseMetadata()

Returns:

All loaded tables metadata

getLoadedTableNames

public Set<String> getLoadedTableNames()

Return all tables (already loaded).
Return only tables previously loaded using methods getTable() or loadDatabaseMetadata()

Returns:

All loaded tables names

getExportedKeys

public ResultSet getExportedKeys(String catalog,
                        String schema,
                        String table)
                          throws SQLException

Throws:

SQLException

See Also:

java.sql.DatabaseMetaData.getExportedKeys(String,String,String)

getImportedKeys

public ResultSet getImportedKeys(String catalog,
                        String schema,
                        String table)
                          throws SQLException

Throws:

SQLException

See Also:

java.sql.DatabaseMetaData.getImportedKeys(String,String,String)

getPrimaryKeys

public ResultSet getPrimaryKeys(String catalog,
                       String schema,
                       String table)
                         throws SQLException

Throws:

SQLException

See Also:

java.sql.DatabaseMetaData.getPrimaryKeys(String,String,String)

getTable

protected SynchroTableMetadata getTable(Dialect dialect,
                            String name,
                            String schema,
                            String catalog,
                            boolean isQuoted,
                            Predicate<SynchroColumnMetadata> columnFilter,
                            boolean withJoinedTables)
                                 throws HibernateException

Throws:

HibernateException

initSequences

protected Set<String> initSequences(Connection connection,
                        Dialect dialect)
                             throws SQLException

Throws:

SQLException

getInterceptors

protected List<SynchroInterceptor> getInterceptors(TableMetadata table)

fireOnTableLoad

protected void fireOnTableLoad(SynchroTableMetadata table)