com.cosylab.cdb.jdal

Class DALImpl

java.lang.Object

JDALPOA

com.cosylab.cdb.jdal.DALImpl

All Implemented Interfaces:

Recoverer

public class DALImpl
extends JDALPOA
implements Recoverer

A note about the inheritance structure used in this module: The writable variant of the DAL interface delegates to an instance of DALImpl for all JDALOperations, see WDALBaseImpl. It only adds the implementation of the WDALOperations methods.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DALImpl.Filter Filter which selects all xsd files in the root/schemas directory.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	EXTERNAL_SCHEMA_LOCATION_PROPERTY_ID Property for setting the mapping of URIs to XML schemas.
static java.lang.String	SCHEMA_VALIDATION_FEATURE_ID Schema validation feature id (http://apache.org/xml/features/validation/schema).
protected java.util.concurrent.atomic.AtomicLong	totalDALInvocationCounter
static java.lang.String	USE_XSD_CACHE_PROPERTYNAME The XSD cache may have additional bad side effects (one was a failure with xinclude which has been fixed), so we only use it if this property is set to true to switch it off easily in case of problems.
boolean	useXsdCache

Method Summary

Modifier and Type	Method and Description
int	add_change_listener(DALChangeListener listener)
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)
java.lang.String	configuration_name()
DAO	get_DAO_Servant(java.lang.String curl) create DAO servant with requested XML
java.lang.String	get_DAO(java.lang.String curl) returns full expanded XML string
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.
static void	getFiles(java.lang.String filePath, java.util.LinkedHashMap<java.lang.String,java.lang.String> map) Adds all *.xsd files from filePath directory if file already exists in map it is skipped
java.lang.String	getRecordPath(java.lang.String curl)
javax.xml.parsers.SAXParser	getSaxParser()
static java.lang.String	getSchemas(java.lang.String root, java.util.logging.Logger logger) returns string of URIs separated by ' ' for all schema files in root/schemas and directories list given by ACS.cdbpath environment variable This method is public static to be used more easily in the HibernateDAL (com.cosylab.cdb.jdal.XSDElementTypeResolver#initializeParser())
protected java.io.File	getStorageFile()
java.lang.String	internal_get_DAO(java.lang.String curl, boolean precacheStage) returns full expanded XML string
boolean	isShutdown()
java.lang.String	list_daos(java.lang.String name)
java.lang.String	list_nodes(java.lang.String name)
void	listen_for_changes(java.lang.String curl, int listenerID)
void	loadFactory()
void	loadListeners()
XMLHandler	loadRecords(java.lang.String curl, boolean toString) Returns a xml constructed of all records below given curl
protected void	object_changed(java.lang.String curl)
void	parseNode(DALNode node, XMLHandler xmlSolver, java.lang.String path)
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)
boolean	saveListeners()
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()
void	shutdownEmbeddedDALImpl()
boolean	wasCacheLimitReached()

Methods inherited from class java.lang.Object

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

Field Detail

SCHEMA_VALIDATION_FEATURE_ID

public static final java.lang.String SCHEMA_VALIDATION_FEATURE_ID

Schema validation feature id (http://apache.org/xml/features/validation/schema). See http://xerces.apache.org/xerces2-j/features.html

See Also:

Constant Field Values

EXTERNAL_SCHEMA_LOCATION_PROPERTY_ID

public static final java.lang.String EXTERNAL_SCHEMA_LOCATION_PROPERTY_ID

Property for setting the mapping of URIs to XML schemas. See http://xerces.apache.org/xerces2-j/properties.html

See Also:

Constant Field Values

USE_XSD_CACHE_PROPERTYNAME

public static final java.lang.String USE_XSD_CACHE_PROPERTYNAME

The XSD cache may have additional bad side effects (one was a failure with xinclude which has been fixed), so we only use it if this property is set to true to switch it off easily in case of problems.

See Also:

Constant Field Values

useXsdCache

public final boolean useXsdCache

totalDALInvocationCounter

protected final java.util.concurrent.atomic.AtomicLong totalDALInvocationCounter

Method Detail

loadFactory

public void loadFactory()

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

getSchemas

public static java.lang.String getSchemas(java.lang.String root,
                                          java.util.logging.Logger logger)

returns string of URIs separated by ' ' for all schema files in root/schemas and directories list given by ACS.cdbpath environment variable This method is public static to be used more easily in the HibernateDAL (com.cosylab.cdb.jdal.XSDElementTypeResolver#initializeParser())

getFiles

public static void getFiles(java.lang.String filePath,
                            java.util.LinkedHashMap<java.lang.String,java.lang.String> map)

Adds all *.xsd files from filePath directory if file already exists in map it is skipped

getRecordPath

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

parseNode

public void parseNode(DALNode node,
                      XMLHandler xmlSolver,
                      java.lang.String path)
               throws org.xml.sax.SAXException,
                      java.io.IOException,
                      AcsJCDBXMLErrorEx

Throws:

org.xml.sax.SAXException

java.io.IOException

AcsJCDBXMLErrorEx

loadRecords

public XMLHandler loadRecords(java.lang.String curl,
                              boolean toString)
                       throws AcsJCDBRecordDoesNotExistEx,
                              AcsJCDBXMLErrorEx

Returns a xml constructed of all records below given curl

Parameters:

curl -

toString -

Returns:

Throws:

AcsJCDBRecordDoesNotExistEx

AcsJCDBXMLErrorEx

wasCacheLimitReached

public boolean wasCacheLimitReached()

get_DAO

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

returns full expanded XML string

Throws:

CDBRecordDoesNotExistEx

CDBXMLErrorEx

internal_get_DAO

public java.lang.String internal_get_DAO(java.lang.String curl,
                                         boolean precacheStage)
                                  throws CDBRecordDoesNotExistEx,
                                         CDBXMLErrorEx

returns full expanded XML string

Throws:

CDBRecordDoesNotExistEx

CDBXMLErrorEx

get_DAO_Servant

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

create DAO servant with requested XML

Throws:

CDBRecordDoesNotExistEx

CDBXMLErrorEx

shutdown

public void shutdown()

shutdownEmbeddedDALImpl

public void shutdownEmbeddedDALImpl()

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

clear_cache

public void clear_cache(java.lang.String curl)

clear_cache_all

public void clear_cache_all()

list_nodes

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

list_daos

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

configuration_name

public java.lang.String configuration_name()

getSaxParser

public javax.xml.parsers.SAXParser getSaxParser()

Returns:

isShutdown

public boolean isShutdown()

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.