com.cosylab.cdb.jdal

Class HibernateWDALImpl

java.lang.Object

WJDALPOA

com.cosylab.cdb.jdal.HibernateWDALImpl

All Implemented Interfaces:

Recoverer

public class HibernateWDALImpl
extends WJDALPOA
implements Recoverer

WDAL implementation for hibernate w/ DOMJavaClassInspector.

Author:

msekoranja

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String[]	args
protected Configuration	config
protected int	configId
protected java.lang.String	configName
protected boolean	createTables
protected org.w3c.dom.ls.DOMImplementationLS	domImplementationLS
protected boolean	forceInMemory
protected HibernateDBUtil	hibernateDBUtil
protected HibernateUtil	hibernateUtil
protected org.w3c.dom.ls.LSInput	input
protected boolean	loadXMLCDB
protected java.util.logging.Logger	m_logger
protected Session	mainSession
protected org.omg.CORBA.ORB	orb
protected org.w3c.dom.ls.LSOutput	output
protected org.w3c.dom.ls.LSParser	parser
protected HibernateWDALPlugin	plugin
protected org.omg.PortableServer.POA	poa
protected java.lang.Object	rootNode
protected javax.xml.parsers.SAXParser	saxParser
protected com.cosylab.cdb.jdal.HibernateWDALImpl.SchemaResourceResolverLoader	schemaResourceResolverLoader

Constructor Summary

Constructors

Constructor and Description
HibernateWDALImpl(java.lang.String[] args, org.omg.CORBA.ORB orb, org.omg.PortableServer.POA poa, java.util.logging.Logger logger) ctor that takes all command line args given to OracleServer

Method Summary

Modifier and Type	Method and Description
int	add_change_listener(DALChangeListener listener)
void	add_node(java.lang.String curl, java.lang.String xml)
void	bindNonExpandedComponentXMLToAlmaBranch(Session session, java.util.Map<java.lang.String,java.lang.Object> parentMap, Component component)
protected void	bindToAlmaBranch(java.util.Map<java.lang.String,java.lang.Object> parentMap, java.lang.String name, java.lang.String path, java.lang.Object objectToBind)
protected void	cleanListenedCurls() Cleans listened curls from invalid listeners to avoid repeatedly calling invalid listeners
void	clear_cache_all()
void	clear_cache(java.lang.String curl)
protected void	clearCache(java.lang.String curl)
java.lang.String	configuration_name()
DAO	get_DAO_Servant(java.lang.String curl)
java.lang.String	get_DAO(java.lang.String curl)
LogLevels	get_default_logLevels() Gets the log levels of the default logging configuration.
java.lang.String[]	get_logger_names() Gets the names of all loggers, to allow configuring their levels individually.
LogLevels	get_logLevels(java.lang.String logger_name) Gets log levels for a particular named logger.
WDAO	get_WDAO_Servant(java.lang.String curl)
protected java.util.Map<java.lang.String,java.lang.Object>	getAlmaBranch()
java.lang.Object	getChannelsTableMap()
java.util.Map<java.lang.String,java.lang.Object>	getComponentsTableMap()
java.util.Map<java.lang.String,java.lang.Object>	getContainersTableMap()
java.util.List	getListForConfiguration(Session session, java.lang.Class type)
java.util.List	getListForConfiguration(Session session, java.lang.Class type, Criterion cr)
java.util.Map<java.lang.String,java.lang.Object>	getManagersTableMap()
protected Criterion	getRegularExpressionRestriction(java.lang.String columnName, java.lang.String re)
protected java.io.File	getStorageFile()
java.lang.String[]	getSubNodes(DAL dal, java.lang.String subnode)
java.util.Map<java.lang.String,java.lang.Object>	getTableMap(Session session, java.lang.String keyField, java.lang.Class type)
protected void	initializeRootNode()
java.lang.String	list_daos(java.lang.String name)
java.lang.String	list_nodes(java.lang.String curl)
void	listen_for_changes(java.lang.String curl, int listenerID)
protected java.lang.String	listNodes(java.lang.String curl, boolean daosOnly)
protected void	loadChannels(java.lang.String curl, boolean reload)
protected void	loadComponents(java.lang.String curl, boolean reload)
protected void	loadComponentsTree(java.lang.String curl, boolean reload)
protected void	loadContainers(java.lang.String curl, boolean reload)
void	loadListeners()
protected void	loadMACI(java.lang.String curl, boolean reload)
protected void	loadManagers(java.lang.String curl, boolean reload)
protected boolean	loadXMLCDB(java.lang.String[] args, org.omg.CORBA.ORB orb, org.omg.PortableServer.POA poa, java.lang.String configName)
protected void	object_changed(java.lang.String curl)
void	recoverClients() Recovery related implementation.
void	refresh_logging_config() Commands the container or manager to read in again the logging configuration from the CDB and to reconfigure the loggers accordingly.
void	remove_change_listener(int listenerID)
void	remove_node(java.lang.String curl)
void	saveChanges(java.lang.String curl, java.util.Map propertyMap) Save changes given by map to the node identified by curl
boolean	saveListeners()
void	set_DAO(java.lang.String curl, java.lang.String xml)
void	set_default_logLevels(LogLevels levels) Sets the log levels of the default logging configuration.
void	set_logLevels(java.lang.String logger_name, LogLevels levels) Sets log levels for a particular named logger.
void	shutdown()
protected void	updateAlmaBranch(java.lang.String curl)
void	updateChannelsTableMap(java.lang.String curl)
protected void	updateComponentsTableMap(java.lang.String curl)
void	updateContainersTableMap(java.lang.String curl)
protected void	updateManagersTableMap(java.lang.String curl)

Methods inherited from class java.lang.Object

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

Field Detail

configName

protected java.lang.String configName

configId

protected int configId

config

protected Configuration config

hibernateUtil

protected final HibernateUtil hibernateUtil

hibernateDBUtil

protected final HibernateDBUtil hibernateDBUtil

mainSession

protected volatile Session mainSession

loadXMLCDB

protected boolean loadXMLCDB

createTables

protected boolean createTables

forceInMemory

protected boolean forceInMemory

args

protected java.lang.String[] args

orb

protected org.omg.CORBA.ORB orb

poa

protected org.omg.PortableServer.POA poa

m_logger

protected final java.util.logging.Logger m_logger

rootNode

protected volatile java.lang.Object rootNode

saxParser

protected javax.xml.parsers.SAXParser saxParser

parser

protected org.w3c.dom.ls.LSParser parser

input

protected org.w3c.dom.ls.LSInput input

output

protected org.w3c.dom.ls.LSOutput output

domImplementationLS

protected org.w3c.dom.ls.DOMImplementationLS domImplementationLS

schemaResourceResolverLoader

protected com.cosylab.cdb.jdal.HibernateWDALImpl.SchemaResourceResolverLoader schemaResourceResolverLoader

plugin

protected HibernateWDALPlugin plugin

Constructor Detail

HibernateWDALImpl

public HibernateWDALImpl(java.lang.String[] args,
                         org.omg.CORBA.ORB orb,
                         org.omg.PortableServer.POA poa,
                         java.util.logging.Logger logger)

ctor that takes all command line args given to OracleServer

Parameters:

args -

orb_val -

poa_val -

Method Detail

getSubNodes

public java.lang.String[] getSubNodes(DAL dal,
                                      java.lang.String subnode)
                               throws java.lang.Throwable

Throws:

java.lang.Throwable

loadXMLCDB

protected boolean loadXMLCDB(java.lang.String[] args,
                             org.omg.CORBA.ORB orb,
                             org.omg.PortableServer.POA poa,
                             java.lang.String configName)

getAlmaBranch

protected java.util.Map<java.lang.String,java.lang.Object> getAlmaBranch()

bindNonExpandedComponentXMLToAlmaBranch

public void bindNonExpandedComponentXMLToAlmaBranch(Session session,
                                                    java.util.Map<java.lang.String,java.lang.Object> parentMap,
                                                    Component component)

bindToAlmaBranch

protected void bindToAlmaBranch(java.util.Map<java.lang.String,java.lang.Object> parentMap,
                                java.lang.String name,
                                java.lang.String path,
                                java.lang.Object objectToBind)

getListForConfiguration

public java.util.List getListForConfiguration(Session session,
                                              java.lang.Class type)
                                       throws java.lang.Throwable

Throws:

java.lang.Throwable

getListForConfiguration

public java.util.List getListForConfiguration(Session session,
                                              java.lang.Class type,
                                              Criterion cr)
                                       throws java.lang.Throwable

Throws:

java.lang.Throwable

initializeRootNode

protected void initializeRootNode()

getTableMap

public java.util.Map<java.lang.String,java.lang.Object> getTableMap(Session session,
                                                                    java.lang.String keyField,
                                                                    java.lang.Class type)

getComponentsTableMap

public java.util.Map<java.lang.String,java.lang.Object> getComponentsTableMap()

getContainersTableMap

public java.util.Map<java.lang.String,java.lang.Object> getContainersTableMap()

getChannelsTableMap

public java.lang.Object getChannelsTableMap()

get_DAO_Servant

public DAO get_DAO_Servant(java.lang.String curl)
                    throws CDBXMLErrorEx,
                           CDBRecordDoesNotExistEx

Throws:

CDBXMLErrorEx

CDBRecordDoesNotExistEx

get_DAO

public java.lang.String get_DAO(java.lang.String curl)
                         throws CDBXMLErrorEx,
                                CDBRecordDoesNotExistEx

Throws:

CDBXMLErrorEx

CDBRecordDoesNotExistEx

listNodes

protected java.lang.String listNodes(java.lang.String curl,
                                     boolean daosOnly)

list_nodes

public java.lang.String list_nodes(java.lang.String curl)

list_daos

public java.lang.String list_daos(java.lang.String name)

configuration_name

public java.lang.String configuration_name()

add_node

public void add_node(java.lang.String curl,
                     java.lang.String xml)
              throws CDBExceptionEx,
                     CDBXMLErrorEx,
                     CDBRecordAlreadyExistsEx

Throws:

CDBExceptionEx

CDBXMLErrorEx

CDBRecordAlreadyExistsEx

remove_node

public void remove_node(java.lang.String curl)
                 throws CDBRecordIsReadOnlyEx,
                        CDBRecordDoesNotExistEx

Throws:

CDBRecordIsReadOnlyEx

CDBRecordDoesNotExistEx

get_WDAO_Servant

public WDAO get_WDAO_Servant(java.lang.String curl)
                      throws CDBRecordIsReadOnlyEx,
                             CDBXMLErrorEx,
                             CDBRecordDoesNotExistEx

Throws:

CDBRecordIsReadOnlyEx

CDBXMLErrorEx

CDBRecordDoesNotExistEx

set_DAO

public void set_DAO(java.lang.String curl,
                    java.lang.String xml)
             throws CDBFieldDoesNotExistEx,
                    CDBRecordIsReadOnlyEx,
                    CDBExceptionEx,
                    CDBXMLErrorEx,
                    CDBRecordDoesNotExistEx

Throws:

CDBFieldDoesNotExistEx

CDBRecordIsReadOnlyEx

CDBExceptionEx

CDBXMLErrorEx

CDBRecordDoesNotExistEx

saveChanges

public void saveChanges(java.lang.String curl,
                        java.util.Map propertyMap)
                 throws CDBXMLErrorEx,
                        CDBExceptionEx,
                        CDBFieldDoesNotExistEx,
                        CDBRecordDoesNotExistEx

Save changes given by map to the node identified by curl

Parameters:

curl -

propertyMap -

Throws:

CDBXMLErrorEx

CDBExceptionEx

CDBFieldDoesNotExistEx

CDBRecordDoesNotExistEx

recoverClients

public void recoverClients()

Recovery related implementation. Load list of listeners from the recovery file and notifies them to clear cache. NOTICE: This method should be called when DAL POA is alrady initialized and active. NOTE: Method execution depends on recoveryRead variable.

Specified by:

recoverClients in interface Recoverer

shutdown

public void shutdown()

object_changed

protected void object_changed(java.lang.String curl)

Parameters:

curl -

getStorageFile

protected java.io.File getStorageFile()

Returns:

File

loadListeners

public void loadListeners()

saveListeners

public boolean saveListeners()

Returns:

boolean

add_change_listener

public int add_change_listener(DALChangeListener listener)

listen_for_changes

public void listen_for_changes(java.lang.String curl,
                               int listenerID)

remove_change_listener

public void remove_change_listener(int listenerID)

cleanListenedCurls

protected void cleanListenedCurls()

Cleans listened curls from invalid listeners to avoid repeatedly calling invalid listeners

clearCache

protected void clearCache(java.lang.String curl)

clear_cache

public void clear_cache(java.lang.String curl)

loadMACI

protected void loadMACI(java.lang.String curl,
                        boolean reload)

loadComponents

protected void loadComponents(java.lang.String curl,
                              boolean reload)

loadContainers

protected void loadContainers(java.lang.String curl,
                              boolean reload)

loadManagers

protected void loadManagers(java.lang.String curl,
                            boolean reload)

loadChannels

protected void loadChannels(java.lang.String curl,
                            boolean reload)

loadComponentsTree

protected void loadComponentsTree(java.lang.String curl,
                                  boolean reload)

getManagersTableMap

public java.util.Map<java.lang.String,java.lang.Object> getManagersTableMap()

getRegularExpressionRestriction

protected Criterion getRegularExpressionRestriction(java.lang.String columnName,
                                                    java.lang.String re)

updateComponentsTableMap

protected void updateComponentsTableMap(java.lang.String curl)

updateContainersTableMap

public void updateContainersTableMap(java.lang.String curl)

updateManagersTableMap

protected void updateManagersTableMap(java.lang.String curl)

updateChannelsTableMap

public void updateChannelsTableMap(java.lang.String curl)

updateAlmaBranch

protected void updateAlmaBranch(java.lang.String curl)

clear_cache_all

public void clear_cache_all()

get_default_logLevels

public LogLevels get_default_logLevels()

Gets the log levels of the default logging configuration. These levels are used by all loggers that have not been configured individually.

set_default_logLevels

public void set_default_logLevels(LogLevels levels)
                           throws IllegalLogLevelsEx

Sets the log levels of the default logging configuration. These levels are used by all loggers that have not been configured individually.

Throws:

IllegalLogLevelsEx

get_logger_names

public java.lang.String[] get_logger_names()

Gets the names of all loggers, to allow configuring their levels individually. The names are those that appear in the log records in the field "SourceObject". This includes the container logger, ORB logger, component loggers, and (only C++) GlobalLogger.

The returned logger names are randomly ordered.

get_logLevels

public LogLevels get_logLevels(java.lang.String logger_name)
                        throws LoggerDoesNotExistEx

Gets log levels for a particular named logger. If the returned field LogLevels.useDefault is true, then the logger uses the default levels, see get_default_logLevels(); otherwise the returned local and remote levels apply.

For possible convenience, the default levels are returned in addition to setting LogLevels#useDefault to true.

Throws:

LoggerDoesNotExistEx

set_logLevels

public void set_logLevels(java.lang.String logger_name,
                          LogLevels levels)
                   throws LoggerDoesNotExistEx,
                          IllegalLogLevelsEx

Sets log levels for a particular named logger. If levels.useDefault is true, then the logger will be reset to using default levels; otherwise it will use the supplied local and remote levels.

Throws:

LoggerDoesNotExistEx

IllegalLogLevelsEx

refresh_logging_config

public void refresh_logging_config()

Commands the container or manager to read in again the logging configuration from the CDB and to reconfigure the loggers accordingly. This allows for persistent changes in the logging configuration to become effective, and also for changes of more advanced parameters.

Note that unlike for the logging initialization in #initialize(), now we give precedence to the CDB values over any previous settings.