systems.dmx.core.impl

Class CoreServiceImpl

java.lang.Object

systems.dmx.core.impl.CoreServiceImpl

All Implemented Interfaces:

CoreService

public class CoreServiceImpl
extends Object
implements CoreService

Implementation of the DMX core service. Embeddable into Java applications.

Constructor Summary

Constructors

Constructor and Description
CoreServiceImpl(AccessLayer al, org.osgi.framework.BundleContext bundleContext)

Method Summary

Modifier and Type	Method and Description
void	addAssocPropertyIndex(String propUri)
void	addTopicPropertyIndex(String propUri)
DMXTransaction	beginTx()
systems.dmx.core.impl.AssocImpl	createAssoc(AssocModel model)
systems.dmx.core.impl.AssocTypeImpl	createAssocType(AssocTypeModel model)
RoleType	createRoleType(RoleTypeModel model)
systems.dmx.core.impl.TopicImpl	createTopic(TopicModel model)
systems.dmx.core.impl.TopicTypeImpl	createTopicType(TopicTypeModel model)
void	deleteAssoc(long assocId)
void	deleteAssocType(String assocTypeUri)
void	deleteTopic(long topicId)
void	deleteTopicType(String topicTypeUri)
void	dispatchEvent(String pluginUri, DMXEvent event, Object... params)
void	fireEvent(DMXEvent event, Object... params)
Iterable<Assoc>	getAllAssocs()
List<AssocType>	getAllAssocTypes()
List<RoleType>	getAllRoleTypes()
Iterable<Topic>	getAllTopics()
List<TopicType>	getAllTopicTypes()
Assoc	getAssoc(long assocId)
Assoc	getAssocBetweenTopicAndAssoc(String assocTypeUri, long topicId, long assocId, String topicRoleTypeUri, String assocRoleTypeUri)
Assoc	getAssocBetweenTopicAndTopic(String assocTypeUri, long topic1Id, long topic2Id, String roleTypeUri1, String roleTypeUri2) Returns the association between two topics, qualified by association type and both role types.
Assoc	getAssocByValue(String typeUri, SimpleValue value) Retrieves a single association by type and exact value.
List<Assoc>	getAssocs(long topic1Id, long topic2Id) Returns all associations between two topics.
List<Assoc>	getAssocs(long topic1Id, long topic2Id, String assocTypeUri) Returns the associations between two topics.
List<Assoc>	getAssocsByProperty(String propUri, Object propValue)
List<Assoc>	getAssocsByPropertyRange(String propUri, Number from, Number to)
List<Assoc>	getAssocsByRoleType(String roleTypeUri)
List<Assoc>	getAssocsByType(String assocTypeUri)
systems.dmx.core.impl.AssocTypeImpl	getAssocType(String uri)
systems.dmx.core.impl.AssocTypeImpl	getAssocTypeImplicitly(long assocId) Acccesses an association type while enforcing the implicit READ permission.
Object	getDatabaseVendorObject()
ModelFactory	getModelFactory()
DMXObject	getObject(long id)
List<PlayerModel>	getPlayerModels(long assocId)
PluginImpl	getPlugin(String pluginUri)
List<PluginInfo>	getPluginInfo()
PrivilegedAccess	getPrivilegedAccess()
Object	getProperty(long id, String propUri) Returns a topic's or association's property value associated with the given property URI.
RoleType	getRoleType(String roleTypeUri)
RoleType	getRoleTypeImplicitly(long assocId, String roleTypeUri)
Topic	getTopic(long topicId) Retrieves a topic by ID.
Topic	getTopicByUri(String uri) Retrieves a topic by URI.
Topic	getTopicByValue(String typeUri, SimpleValue value) Retrieves a single topic by type and exact value.
List<Topic>	getTopicsByProperty(String propUri, Object propValue)
List<Topic>	getTopicsByPropertyRange(String propUri, Number from, Number to)
List<Topic>	getTopicsByType(String topicTypeUri)
List<Topic>	getTopicsByValue(String typeUri, SimpleValue value) Retrieves topics by type and exact value.
systems.dmx.core.impl.TopicTypeImpl	getTopicType(String uri)
systems.dmx.core.impl.TopicTypeImpl	getTopicTypeImplicitly(long topicId) Acccesses a topic type while enforcing the implicit READ permission.
WebSocketServiceImpl	getWebSocketService()
boolean	hasProperty(long id, String propUri) Checks whether for a given topic or association a property value is associated with a given property URI.
QueryResult	query(String topicQuery, String topicTypeUri, boolean searchTopicChildren, String assocQuery, String assocTypeUri, boolean searchAssocChildren)
List<Assoc>	queryAssocs(String typeUri, String query) Retrieves associations by type and value.
List<Topic>	queryTopics(String typeUri, String query) Retrieves topics by type and value.
TopicResult	queryTopicsFulltext(String query, String typeUri, boolean searchChildTopics) Performs a fulltext search in topic values and in entire topic trees.
void	shutdown()
void	updateAssoc(AssocModel updateModel)
void	updateAssocType(AssocTypeModel updateModel)
systems.dmx.core.impl.TopicImpl	updateTopic(TopicModel updateModel)
void	updateTopicType(TopicTypeModel updateModel)

Methods inherited from class java.lang.Object

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

Constructor Detail

CoreServiceImpl

public CoreServiceImpl(AccessLayer al,
                       org.osgi.framework.BundleContext bundleContext)

Parameters:

bundleContext - The context of the DMX Core bundle.

Method Detail

getTopic

public Topic getTopic(long topicId)

Description copied from interface: CoreService

Retrieves a topic by ID.

Specified by:

getTopic in interface CoreService

Returns:

the topic.

getTopicByUri

public Topic getTopicByUri(String uri)

Description copied from interface: CoreService

Retrieves a topic by URI.

Specified by:

getTopicByUri in interface CoreService

Returns:

the topic, or null if no topic is found.

getTopicsByType

public List<Topic> getTopicsByType(String topicTypeUri)

Specified by:

getTopicsByType in interface CoreService

getAllTopics

public Iterable<Topic> getAllTopics()

Specified by:

getAllTopics in interface CoreService

getTopicByValue

public Topic getTopicByValue(String typeUri,
                             SimpleValue value)

Description copied from interface: CoreService

Retrieves a single topic by type and exact value. Throws if more than one topic is found. Lucene query syntax (wildcards, phrase search, ...) is not supported. A text search is case-sensitive.

Specified by:

getTopicByValue in interface CoreService

Parameters:

typeUri - a topic type URI; only topics of this type are searched; mandatory

value - the value to search for

Returns:

the found topic, or null if no topic is found.

getTopicsByValue

public List<Topic> getTopicsByValue(String typeUri,
                                    SimpleValue value)

Description copied from interface: CoreService

Retrieves topics by type and exact value. Lucene query syntax (wildcards, phrase search, ...) is not supported. A text search is case-sensitive.

Specified by:

getTopicsByValue in interface CoreService

Parameters:

typeUri - a topic type URI; only topics of this type are searched; mandatory

value - the value to search for

Returns:

a list of found topics, may be empty.

queryTopics

public List<Topic> queryTopics(String typeUri,
                               String query)

Description copied from interface: CoreService

Retrieves topics by type and value. Lucene query syntax is supported. A topic is regarded a hit if the search term matches the topic's entire value (in contrast to a fulltext search). Spaces must be escaped though. Search is case-sensitive.

Specified by:

queryTopics in interface CoreService

Parameters:

typeUri - a topic type URI; only topics of this type are searched; mandatory

query - The query. Must be non-empty. Lucene query syntax is supported:

• "*" matches arbitrary characters
• "?" matches a single character
• phrases enclosed in double quotes (")
• escape special character by preceding with back slash (\)
• combining search terms by "AND"/"OR" (uppercase required). Default is "OR". "&&" and "||" are respective synonyms.

Returns:

a list of found topics, may be empty.

queryTopicsFulltext

public TopicResult queryTopicsFulltext(String query,
                                       String typeUri,
                                       boolean searchChildTopics)

Description copied from interface: CoreService

Performs a fulltext search in topic values and in entire topic trees. Single words are found in entire text-value. Lucene query syntax is supported. Search is case-insensitive.

Specified by:

queryTopicsFulltext in interface CoreService

Parameters:

query - The search query. Must be non-empty. Lucene query syntax is supported:

• "*" matches arbitrary characters
• "?" matches a single character
• phrases enclosed in double quotes (")
• escape special character by preceding with back slash (\)
• combining search terms by "AND"/"OR" (uppercase required). Default is "OR". "&&" and "||" are respective synonyms.

typeUri - Optional: a topic type URI; only topics of this type are searched. If null all topics are searched.
If given, all returned topics are of this type (regardless of the "searchChildTopics" setting).

searchChildTopics - Applicable only if "topicTypeUri" is given (ignored otherwise): if true the topic's child topics are searched as well.
Example: to search for Persons where "Berlin" appears in *any* child topic pass "dmx.contacts.person" for "topicTypeUri", and set "searchChildTopics" to true.

Returns:

a TopicResult object that wraps both the original query parameters and the resulting topic list (may be empty).

createTopic

public systems.dmx.core.impl.TopicImpl createTopic(TopicModel model)

Specified by:

createTopic in interface CoreService

updateTopic

public systems.dmx.core.impl.TopicImpl updateTopic(TopicModel updateModel)

Specified by:

updateTopic in interface CoreService

deleteTopic

public void deleteTopic(long topicId)

Specified by:

deleteTopic in interface CoreService

getAssoc

public Assoc getAssoc(long assocId)

Specified by:

getAssoc in interface CoreService

getPlayerModels

public List<PlayerModel> getPlayerModels(long assocId)

Specified by:

getPlayerModels in interface CoreService

getAssocsByType

public List<Assoc> getAssocsByType(String assocTypeUri)

Specified by:

getAssocsByType in interface CoreService

getAssocsByRoleType

public List<Assoc> getAssocsByRoleType(String roleTypeUri)

Specified by:

getAssocsByRoleType in interface CoreService

getAssocs

public List<Assoc> getAssocs(long topic1Id,
                             long topic2Id)

Description copied from interface: CoreService

Returns all associations between two topics. If no such association exists an empty list is returned.

Specified by:

getAssocs in interface CoreService

getAssocs

public List<Assoc> getAssocs(long topic1Id,
                             long topic2Id,
                             String assocTypeUri)

Description copied from interface: CoreService

Returns the associations between two topics. If no such association exists an empty list is returned.

Specified by:

getAssocs in interface CoreService

assocTypeUri - Assoc type filter. Pass null to switch filter off.

getAssocBetweenTopicAndTopic

public Assoc getAssocBetweenTopicAndTopic(String assocTypeUri,
                                          long topic1Id,
                                          long topic2Id,
                                          String roleTypeUri1,
                                          String roleTypeUri2)

Description copied from interface: CoreService

Returns the association between two topics, qualified by association type and both role types. If no such association exists null is returned. If more than one association exist, a runtime exception is thrown.

Specified by:

getAssocBetweenTopicAndTopic in interface CoreService

Parameters:

assocTypeUri - Assoc type filter. Pass null to switch filter off.

getAssocBetweenTopicAndAssoc

public Assoc getAssocBetweenTopicAndAssoc(String assocTypeUri,
                                          long topicId,
                                          long assocId,
                                          String topicRoleTypeUri,
                                          String assocRoleTypeUri)

Specified by:

getAssocBetweenTopicAndAssoc in interface CoreService

getAllAssocs

public Iterable<Assoc> getAllAssocs()

Specified by:

getAllAssocs in interface CoreService

getAssocByValue

public Assoc getAssocByValue(String typeUri,
                             SimpleValue value)

Description copied from interface: CoreService

Retrieves a single association by type and exact value. Throws if more than one association is found. Lucene query syntax (wildcards, phrase search, ...) is not supported. A text search is case-sensitive.

Specified by:

getAssocByValue in interface CoreService

Parameters:

typeUri - an association type URI; only associations of this type are searched; mandatory

value - the value to search for

Returns:

the found association, or null if no association is found.

queryAssocs

public List<Assoc> queryAssocs(String typeUri,
                               String query)

Description copied from interface: CoreService

Retrieves associations by type and value. Lucene query syntax is supported. An association is regarded a hit if the search term matches the association's entire value (in contrast to a fulltext search). Spaces must be escaped though. Search is case-sensitive.

Specified by:

queryAssocs in interface CoreService

Parameters:

typeUri - an association type URI; only associations of this type are searched; mandatory

query - The query. Must be non-empty. Lucene query syntax is supported:

• "*" matches arbitrary characters
• "?" matches a single character
• phrases enclosed in double quotes (")
• escape special character by preceding with back slash (\)
• combining search terms by "AND"/"OR" (uppercase required). Default is "OR". "&&" and "||" are respective synonyms.

Returns:

a list of found associations, may be empty.

createAssoc

public systems.dmx.core.impl.AssocImpl createAssoc(AssocModel model)

Specified by:

createAssoc in interface CoreService

updateAssoc

public void updateAssoc(AssocModel updateModel)

Specified by:

updateAssoc in interface CoreService

deleteAssoc

public void deleteAssoc(long assocId)

Specified by:

deleteAssoc in interface CoreService

getTopicType

public systems.dmx.core.impl.TopicTypeImpl getTopicType(String uri)

Specified by:

getTopicType in interface CoreService

getTopicTypeImplicitly

public systems.dmx.core.impl.TopicTypeImpl getTopicTypeImplicitly(long topicId)

Description copied from interface: CoreService

Acccesses a topic type while enforcing the implicit READ permission. A user has implicit READ permission for the topic type if she has READ permission for the given topic.

Specified by:

getTopicTypeImplicitly in interface CoreService

getAllTopicTypes

public List<TopicType> getAllTopicTypes()

Specified by:

getAllTopicTypes in interface CoreService

createTopicType

public systems.dmx.core.impl.TopicTypeImpl createTopicType(TopicTypeModel model)

Specified by:

createTopicType in interface CoreService

updateTopicType

public void updateTopicType(TopicTypeModel updateModel)

Specified by:

updateTopicType in interface CoreService

deleteTopicType

public void deleteTopicType(String topicTypeUri)

Specified by:

deleteTopicType in interface CoreService

getAssocType

public systems.dmx.core.impl.AssocTypeImpl getAssocType(String uri)

Specified by:

getAssocType in interface CoreService

getAssocTypeImplicitly

public systems.dmx.core.impl.AssocTypeImpl getAssocTypeImplicitly(long assocId)

Description copied from interface: CoreService

Acccesses an association type while enforcing the implicit READ permission. A user has implicit READ permission for the association type if she has READ permission for the given association.

Specified by:

getAssocTypeImplicitly in interface CoreService

getAllAssocTypes

public List<AssocType> getAllAssocTypes()

Specified by:

getAllAssocTypes in interface CoreService

createAssocType

public systems.dmx.core.impl.AssocTypeImpl createAssocType(AssocTypeModel model)

Specified by:

createAssocType in interface CoreService

updateAssocType

public void updateAssocType(AssocTypeModel updateModel)

Specified by:

updateAssocType in interface CoreService

deleteAssocType

public void deleteAssocType(String assocTypeUri)

Specified by:

deleteAssocType in interface CoreService

getRoleType

public RoleType getRoleType(String roleTypeUri)

Specified by:

getRoleType in interface CoreService

getRoleTypeImplicitly

public RoleType getRoleTypeImplicitly(long assocId,
                                      String roleTypeUri)

Specified by:

getRoleTypeImplicitly in interface CoreService

getAllRoleTypes

public List<RoleType> getAllRoleTypes()

Specified by:

getAllRoleTypes in interface CoreService

createRoleType

public RoleType createRoleType(RoleTypeModel model)

Specified by:

createRoleType in interface CoreService

getObject

public DMXObject getObject(long id)

Specified by:

getObject in interface CoreService

query

public QueryResult query(String topicQuery,
                         String topicTypeUri,
                         boolean searchTopicChildren,
                         String assocQuery,
                         String assocTypeUri,
                         boolean searchAssocChildren)

Specified by:

query in interface CoreService

getPlugin

public PluginImpl getPlugin(String pluginUri)

Specified by:

getPlugin in interface CoreService

getPluginInfo

public List<PluginInfo> getPluginInfo()

Specified by:

getPluginInfo in interface CoreService

fireEvent

public void fireEvent(DMXEvent event,
                      Object... params)

Specified by:

fireEvent in interface CoreService

dispatchEvent

public void dispatchEvent(String pluginUri,
                          DMXEvent event,
                          Object... params)

Specified by:

dispatchEvent in interface CoreService

getProperty

public Object getProperty(long id,
                          String propUri)

Description copied from interface: CoreService

Returns a topic's or association's property value associated with the given property URI. If there's no property value associated with the property URI an exception is thrown.

Specified by:

getProperty in interface CoreService

Parameters:

id - a topic ID, or an association ID

hasProperty

public boolean hasProperty(long id,
                           String propUri)

Description copied from interface: CoreService

Checks whether for a given topic or association a property value is associated with a given property URI.

Specified by:

hasProperty in interface CoreService

Parameters:

id - a topic ID, or an association ID

getTopicsByProperty

public List<Topic> getTopicsByProperty(String propUri,
                                       Object propValue)

Specified by:

getTopicsByProperty in interface CoreService

getTopicsByPropertyRange

public List<Topic> getTopicsByPropertyRange(String propUri,
                                            Number from,
                                            Number to)

Specified by:

getTopicsByPropertyRange in interface CoreService

getAssocsByProperty

public List<Assoc> getAssocsByProperty(String propUri,
                                       Object propValue)

Specified by:

getAssocsByProperty in interface CoreService

getAssocsByPropertyRange

public List<Assoc> getAssocsByPropertyRange(String propUri,
                                            Number from,
                                            Number to)

Specified by:

getAssocsByPropertyRange in interface CoreService

addTopicPropertyIndex

public void addTopicPropertyIndex(String propUri)

Specified by:

addTopicPropertyIndex in interface CoreService

addAssocPropertyIndex

public void addAssocPropertyIndex(String propUri)

Specified by:

addAssocPropertyIndex in interface CoreService

beginTx

public DMXTransaction beginTx()

Specified by:

beginTx in interface CoreService

getModelFactory

public ModelFactory getModelFactory()

Specified by:

getModelFactory in interface CoreService

getPrivilegedAccess

public PrivilegedAccess getPrivilegedAccess()

Specified by:

getPrivilegedAccess in interface CoreService

getWebSocketService

public WebSocketServiceImpl getWebSocketService()

Specified by:

getWebSocketService in interface CoreService

getDatabaseVendorObject

public Object getDatabaseVendorObject()

Specified by:

getDatabaseVendorObject in interface CoreService

shutdown

public void shutdown()