systems.dmx.core.impl

Class PersistenceLayer

Show UML class diagram

java.lang.Object

systems.dmx.core.impl.StorageDecorator

systems.dmx.core.impl.PersistenceLayer

public final class PersistenceLayer
extends StorageDecorator

Storage vendor agnostic access control on top of vendor specific storage. 2 kinds of methods: - access controlled: get/create/update - direct DB access: fetch/store (as derived from storage impl) ### TODO: no instatiations here ### TODO: hold storage object in instance variable (instead deriving) to make direct DB access more explicit

Field Summary

Fields

Modifier and Type	Field and Description
(package private) EventManager	em
private Logger	logger
(package private) ModelFactoryImpl	mf
(package private) TypeStorage	typeStorage
private static String	URI_PREFIX_ASSOCIATION_TYPE
private static String	URI_PREFIX_ROLE_TYPE
private static String	URI_PREFIX_TOPIC_TYPE

Constructor Summary

Constructors

Constructor and Description
PersistenceLayer(DMXStorage storage)

Method Summary

Modifier and Type	Method and Description
(package private) TopicImpl	_createTopic(TopicModelImpl model)
private TopicImpl	_createTopic(TopicModelImpl model, String uriPrefix) Creates a new topic in the DB.
(package private) Iterable<AssociationModelImpl>	_getAssociations(String assocTypeUri, long topic1Id, long topic2Id, String roleTypeUri1, String roleTypeUri2) Fetches from DB and filters READables.
(package private) AssociationTypeModelImpl	_getAssociationType(String uri) Type cache direct access.
(package private) TopicTypeModelImpl	_getTopicType(String uri) Type cache direct access.
private void	bootstrapTypeCache()
(package private) void	checkAssociationReadAccess(long assocId)
(package private) void	checkAssociationWriteAccess(long assocId)
(package private) <M extends DMXObjectModelImpl> M	checkReadAccess(M model)
(package private) <O> O	checkReadAccessAndInstantiate(DMXObjectModelImpl model)
(package private) <O> List<O>	checkReadAccessAndInstantiate(List<? extends DMXObjectModelImpl> models)
(package private) void	checkTopicReadAccess(long topicId)
(package private) void	checkTopicWriteAccess(long topicId)
(package private) AssociationImpl	createAssociation(AssociationModelImpl model) Creates a new association in the DB.
(package private) AssociationImpl	createAssociation(String typeUri, RoleModel roleModel1, RoleModel roleModel2) Convenience.
(package private) void	createAssociationInstantiation(long assocId, String assocTypeUri)
(package private) AssociationTypeImpl	createAssociationType(AssociationTypeModelImpl model)
(package private) Topic	createRoleType(TopicModelImpl model)
(package private) TopicImpl	createTopic(TopicModelImpl model)
(package private) void	createTopicInstantiation(long topicId, String topicTypeUri)
(package private) TopicTypeImpl	createTopicType(TopicTypeModelImpl model)
private void	createType(TypeModelImpl model, String uriPrefix)
(package private) void	deleteAssociation(AssociationModelImpl assoc)
(package private) void	deleteAssociation(long assocId) Convenience.
(package private) void	deleteAssociationType(String assocTypeUri)
(package private) void	deleteTopic(long topicId) Convenience.
(package private) void	deleteTopic(TopicModelImpl topic)
(package private) void	deleteTopicType(String topicTypeUri)
private <M extends DMXObjectModelImpl> List<M>	filterReadables(List<M> models)
(package private) Iterable<Association>	getAllAssociations()
(package private) List<AssociationType>	getAllAssociationTypes()
(package private) Iterable<Topic>	getAllTopics()
(package private) List<TopicType>	getAllTopicTypes()
(package private) Association	getAssociation(long assocId)
(package private) Association	getAssociation(String assocTypeUri, long topic1Id, long topic2Id, String roleTypeUri1, String roleTypeUri2)
(package private) List<AssociationModelImpl>	getAssociationAssociations(long assocId)
(package private) Association	getAssociationBetweenTopicAndAssociation(String assocTypeUri, long topicId, long assocId, String topicRoleTypeUri, String assocRoleTypeUri)
(package private) Association	getAssociationByValue(String key, SimpleValue value)
(package private) RelatedAssociationModelImpl	getAssociationRelatedAssociation(long assocId, String assocTypeUri, String myRoleTypeUri, String othersRoleTypeUri, String othersAssocTypeUri)
(package private) List<RelatedAssociationModelImpl>	getAssociationRelatedAssociations(long assocId, String assocTypeUri, String myRoleTypeUri, String othersRoleTypeUri, String othersAssocTypeUri)
(package private) List<RelatedTopicModelImpl>	getAssociationRelatedTopics(long assocId, List<String> assocTypeUris, String myRoleTypeUri, String othersRoleTypeUri, String othersTopicTypeUri)
(package private) List<RelatedTopicModelImpl>	getAssociationRelatedTopics(long assocId, String assocTypeUri, String myRoleTypeUri, String othersRoleTypeUri, String othersTopicTypeUri)
(package private) List<Association>	getAssociations(long topic1Id, long topic2Id)
(package private) List<Association>	getAssociations(String assocTypeUri, long topic1Id, long topic2Id)
(package private) List<Association>	getAssociations(String assocTypeUri, long topic1Id, long topic2Id, String roleTypeUri1, String roleTypeUri2)
(package private) List<Association>	getAssociationsByProperty(String propUri, Object propValue)
(package private) List<Association>	getAssociationsByPropertyRange(String propUri, Number from, Number to)
(package private) List<Association>	getAssociationsByType(String assocTypeUri)
(package private) List<Association>	getAssociationsByValue(String key, SimpleValue value)
(package private) AssociationTypeImpl	getAssociationType(String uri)
(package private) AssociationTypeImpl	getAssociationTypeImplicitly(long assocId)
private List<String>	getAssociationTypeUris()
(package private) DMXObject	getObject(long id)
(package private) long[]	getPlayerIds(long assocId)
(package private) RelatedTopicModelImpl	getRelatedTopic(long objectId, String assocTypeUri, String myRoleTypeUri, String othersRoleTypeUri, String othersTopicTypeUri)
(package private) List<RelatedTopicModelImpl>	getRelatedTopics(long objectId, String assocTypeUri, String myRoleTypeUri, String othersRoleTypeUri, String othersTopicTypeUri)
(package private) Topic	getTopic(long topicId)
(package private) List<AssociationModelImpl>	getTopicAssociations(long topicId)
(package private) TopicImpl	getTopicByUri(String uri)
(package private) TopicImpl	getTopicByValue(String key, SimpleValue value)
(package private) RelatedAssociationModelImpl	getTopicRelatedAssociation(long topicId, String assocTypeUri, String myRoleTypeUri, String othersRoleTypeUri, String othersAssocTypeUri)
(package private) List<RelatedAssociationModelImpl>	getTopicRelatedAssociations(long topicId, String assocTypeUri, String myRoleTypeUri, String othersRoleTypeUri, String othersAssocTypeUri)
(package private) List<RelatedTopicModelImpl>	getTopicRelatedTopics(long topicId, List<String> assocTypeUris, String myRoleTypeUri, String othersRoleTypeUri, String othersTopicTypeUri)
(package private) List<RelatedTopicModelImpl>	getTopicRelatedTopics(long topicId, String assocTypeUri, String myRoleTypeUri, String othersRoleTypeUri, String othersTopicTypeUri)
(package private) List<Topic>	getTopicsByProperty(String propUri, Object propValue)
(package private) List<Topic>	getTopicsByPropertyRange(String propUri, Number from, Number to)
(package private) List<Topic>	getTopicsByType(String topicTypeUri)
(package private) List<Topic>	getTopicsByValue(String key, SimpleValue value)
(package private) TopicTypeImpl	getTopicType(String uri)
(package private) TopicTypeImpl	getTopicTypeImplicitly(long topicId)
private List<String>	getTopicTypeUris()
(package private) boolean	hasReadAccess(DMXObjectModelImpl model)
(package private) <O> List<O>	instantiate(Iterable<? extends DMXObjectModelImpl> models)
(package private) List<Topic>	searchTopics(String searchTerm, String fieldUri)
private String	typeUri(long objectId)
(package private) void	updateAssociation(AssociationModelImpl updateModel)
(package private) void	updateAssociation(AssociationModelImpl assoc, AssociationModelImpl updateModel)
(package private) void	updateAssociationType(AssociationTypeModelImpl updateModel)
(package private) void	updateTopic(TopicModelImpl updateModel)
(package private) void	updateTopic(TopicModelImpl topic, TopicModelImpl updateModel)
(package private) void	updateTopicType(TopicTypeModelImpl updateModel)
private <M extends DMXObjectModelImpl> M	updateValues(M updateModel, M targetObject)

Methods inherited from class systems.dmx.core.impl.StorageDecorator

_deleteAssociation, _deleteTopic, beginTx, fetchAllAssociations, fetchAllTopics, fetchAssociation, fetchAssociation, fetchAssociation, fetchAssociationAssociations, fetchAssociationBetweenTopicAndAssociation, fetchAssociationRelatedAssociation, fetchAssociationRelatedAssociations, fetchAssociationRelatedTopic, fetchAssociationRelatedTopics, fetchAssociationRelatedTopics, fetchAssociations, fetchAssociations, fetchAssociationsBetweenTopicAndAssociation, fetchAssociationsByProperty, fetchAssociationsByPropertyRange, fetchMigrationNr, fetchObject, fetchPlayerIds, fetchProperty, fetchRelatedTopic, fetchRelatedTopics, fetchTopic, fetchTopic, fetchTopicAssociations, fetchTopicRelatedAssociation, fetchTopicRelatedAssociations, fetchTopicRelatedTopic, fetchTopicRelatedTopics, fetchTopicRelatedTopics, fetchTopics, fetchTopicsByProperty, fetchTopicsByPropertyRange, getDatabaseVendorObject, getDatabaseVendorObject, hasProperty, indexAssociationProperty, indexAssociationValue, indexTopicProperty, indexTopicValue, init, queryTopics, removeAssociationProperty, removeTopicProperty, shutdown, storeAssociation, storeAssociationProperty, storeAssociationTypeUri, storeAssociationUri, storeAssociationValue, storeAssociationValue, storeMigrationNr, storeRoleTypeUri, storeTopic, storeTopicProperty, storeTopicTypeUri, storeTopicUri, storeTopicValue, storeTopicValue

Methods inherited from class java.lang.Object

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

Field Detail

URI_PREFIX_TOPIC_TYPE

private static final String URI_PREFIX_TOPIC_TYPE

See Also:

Constant Field Values

URI_PREFIX_ASSOCIATION_TYPE

private static final String URI_PREFIX_ASSOCIATION_TYPE

See Also:

Constant Field Values

URI_PREFIX_ROLE_TYPE

private static final String URI_PREFIX_ROLE_TYPE

See Also:

Constant Field Values

typeStorage

TypeStorage typeStorage

em

EventManager em

mf

ModelFactoryImpl mf

logger

private final Logger logger

Constructor Detail

PersistenceLayer

public PersistenceLayer(DMXStorage storage)

Method Detail

getTopic

Topic getTopic(long topicId)

getTopicByUri

TopicImpl getTopicByUri(String uri)

getTopicByValue

TopicImpl getTopicByValue(String key,
                          SimpleValue value)

getTopicsByValue

List<Topic> getTopicsByValue(String key,
                             SimpleValue value)

getTopicsByType

List<Topic> getTopicsByType(String topicTypeUri)

searchTopics

List<Topic> searchTopics(String searchTerm,
                         String fieldUri)

getAllTopics

Iterable<Topic> getAllTopics()

createTopic

TopicImpl createTopic(TopicModelImpl model)

_createTopic

TopicImpl _createTopic(TopicModelImpl model)

_createTopic

private TopicImpl _createTopic(TopicModelImpl model,
                               String uriPrefix)

Creates a new topic in the DB. No child topics are created.

updateTopic

void updateTopic(TopicModelImpl updateModel)

updateTopic

void updateTopic(TopicModelImpl topic,
                 TopicModelImpl updateModel)

deleteTopic

void deleteTopic(long topicId)

Convenience.

deleteTopic

void deleteTopic(TopicModelImpl topic)

getAssociation

Association getAssociation(long assocId)

getAssociationByValue

Association getAssociationByValue(String key,
                                  SimpleValue value)

getAssociationsByValue

List<Association> getAssociationsByValue(String key,
                                         SimpleValue value)

getAssociation

Association getAssociation(String assocTypeUri,
                           long topic1Id,
                           long topic2Id,
                           String roleTypeUri1,
                           String roleTypeUri2)

getAssociationBetweenTopicAndAssociation

Association getAssociationBetweenTopicAndAssociation(String assocTypeUri,
                                                     long topicId,
                                                     long assocId,
                                                     String topicRoleTypeUri,
                                                     String assocRoleTypeUri)

getAssociationsByType

List<Association> getAssociationsByType(String assocTypeUri)

getAssociations

List<Association> getAssociations(long topic1Id,
                                  long topic2Id)

getAssociations

List<Association> getAssociations(String assocTypeUri,
                                  long topic1Id,
                                  long topic2Id)

getAssociations

List<Association> getAssociations(String assocTypeUri,
                                  long topic1Id,
                                  long topic2Id,
                                  String roleTypeUri1,
                                  String roleTypeUri2)

_getAssociations

Iterable<AssociationModelImpl> _getAssociations(String assocTypeUri,
                                                long topic1Id,
                                                long topic2Id,
                                                String roleTypeUri1,
                                                String roleTypeUri2)

Fetches from DB and filters READables. No instantiation. ### TODO: drop this. Use the new traversal methods instead.

getAllAssociations

Iterable<Association> getAllAssociations()

getPlayerIds

long[] getPlayerIds(long assocId)

createAssociation

AssociationImpl createAssociation(String typeUri,
                                  RoleModel roleModel1,
                                  RoleModel roleModel2)

Convenience.

createAssociation

AssociationImpl createAssociation(AssociationModelImpl model)

Creates a new association in the DB.

updateAssociation

void updateAssociation(AssociationModelImpl updateModel)

updateAssociation

void updateAssociation(AssociationModelImpl assoc,
                       AssociationModelImpl updateModel)

deleteAssociation

void deleteAssociation(long assocId)

Convenience.

deleteAssociation

void deleteAssociation(AssociationModelImpl assoc)

createTopicInstantiation

void createTopicInstantiation(long topicId,
                              String topicTypeUri)

createAssociationInstantiation

void createAssociationInstantiation(long assocId,
                                    String assocTypeUri)

getTopicType

TopicTypeImpl getTopicType(String uri)

getTopicTypeImplicitly

TopicTypeImpl getTopicTypeImplicitly(long topicId)

getAssociationType

AssociationTypeImpl getAssociationType(String uri)

getAssociationTypeImplicitly

AssociationTypeImpl getAssociationTypeImplicitly(long assocId)

getAllTopicTypes

List<TopicType> getAllTopicTypes()

getAllAssociationTypes

List<AssociationType> getAllAssociationTypes()

createTopicType

TopicTypeImpl createTopicType(TopicTypeModelImpl model)

createAssociationType

AssociationTypeImpl createAssociationType(AssociationTypeModelImpl model)

updateTopicType

void updateTopicType(TopicTypeModelImpl updateModel)

updateAssociationType

void updateAssociationType(AssociationTypeModelImpl updateModel)

deleteTopicType

void deleteTopicType(String topicTypeUri)

deleteAssociationType

void deleteAssociationType(String assocTypeUri)

createRoleType

Topic createRoleType(TopicModelImpl model)

_getTopicType

TopicTypeModelImpl _getTopicType(String uri)

Type cache direct access. No permission check.

_getAssociationType

AssociationTypeModelImpl _getAssociationType(String uri)

Type cache direct access. No permission check.

getObject

DMXObject getObject(long id)

getTopicRelatedTopics

List<RelatedTopicModelImpl> getTopicRelatedTopics(long topicId,
                                                  String assocTypeUri,
                                                  String myRoleTypeUri,
                                                  String othersRoleTypeUri,
                                                  String othersTopicTypeUri)

getTopicRelatedTopics

List<RelatedTopicModelImpl> getTopicRelatedTopics(long topicId,
                                                  List<String> assocTypeUris,
                                                  String myRoleTypeUri,
                                                  String othersRoleTypeUri,
                                                  String othersTopicTypeUri)

getTopicRelatedAssociation

RelatedAssociationModelImpl getTopicRelatedAssociation(long topicId,
                                                       String assocTypeUri,
                                                       String myRoleTypeUri,
                                                       String othersRoleTypeUri,
                                                       String othersAssocTypeUri)

getTopicRelatedAssociations

List<RelatedAssociationModelImpl> getTopicRelatedAssociations(long topicId,
                                                              String assocTypeUri,
                                                              String myRoleTypeUri,
                                                              String othersRoleTypeUri,
                                                              String othersAssocTypeUri)

getTopicAssociations

List<AssociationModelImpl> getTopicAssociations(long topicId)

getAssociationRelatedTopics

List<RelatedTopicModelImpl> getAssociationRelatedTopics(long assocId,
                                                        String assocTypeUri,
                                                        String myRoleTypeUri,
                                                        String othersRoleTypeUri,
                                                        String othersTopicTypeUri)

getAssociationRelatedTopics

List<RelatedTopicModelImpl> getAssociationRelatedTopics(long assocId,
                                                        List<String> assocTypeUris,
                                                        String myRoleTypeUri,
                                                        String othersRoleTypeUri,
                                                        String othersTopicTypeUri)

getAssociationRelatedAssociation

RelatedAssociationModelImpl getAssociationRelatedAssociation(long assocId,
                                                             String assocTypeUri,
                                                             String myRoleTypeUri,
                                                             String othersRoleTypeUri,
                                                             String othersAssocTypeUri)

getAssociationRelatedAssociations

List<RelatedAssociationModelImpl> getAssociationRelatedAssociations(long assocId,
                                                                    String assocTypeUri,
                                                                    String myRoleTypeUri,
                                                                    String othersRoleTypeUri,
                                                                    String othersAssocTypeUri)

getAssociationAssociations

List<AssociationModelImpl> getAssociationAssociations(long assocId)

getRelatedTopic

RelatedTopicModelImpl getRelatedTopic(long objectId,
                                      String assocTypeUri,
                                      String myRoleTypeUri,
                                      String othersRoleTypeUri,
                                      String othersTopicTypeUri)

getRelatedTopics

List<RelatedTopicModelImpl> getRelatedTopics(long objectId,
                                             String assocTypeUri,
                                             String myRoleTypeUri,
                                             String othersRoleTypeUri,
                                             String othersTopicTypeUri)

getTopicsByProperty

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

getTopicsByPropertyRange

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

getAssociationsByProperty

List<Association> getAssociationsByProperty(String propUri,
                                            Object propValue)

getAssociationsByPropertyRange

List<Association> getAssociationsByPropertyRange(String propUri,
                                                 Number from,
                                                 Number to)

checkReadAccessAndInstantiate

<O> O checkReadAccessAndInstantiate(DMXObjectModelImpl model)

checkReadAccessAndInstantiate

<O> List<O> checkReadAccessAndInstantiate(List<? extends DMXObjectModelImpl> models)

filterReadables

private <M extends DMXObjectModelImpl> List<M> filterReadables(List<M> models)

hasReadAccess

boolean hasReadAccess(DMXObjectModelImpl model)

checkReadAccess

<M extends DMXObjectModelImpl> M checkReadAccess(M model)

checkTopicReadAccess

void checkTopicReadAccess(long topicId)

Throws:

AccessControlException - if the current user has no permission.

checkAssociationReadAccess

void checkAssociationReadAccess(long assocId)

Throws:

AccessControlException - if the current user has no permission.

checkTopicWriteAccess

void checkTopicWriteAccess(long topicId)

Throws:

AccessControlException - if the current user has no permission.

checkAssociationWriteAccess

void checkAssociationWriteAccess(long assocId)

Throws:

AccessControlException - if the current user has no permission.

instantiate

<O> List<O> instantiate(Iterable<? extends DMXObjectModelImpl> models)

getTopicTypeUris

private List<String> getTopicTypeUris()

getAssociationTypeUris

private List<String> getAssociationTypeUris()

createType

private void createType(TypeModelImpl model,
                        String uriPrefix)

typeUri

private String typeUri(long objectId)

bootstrapTypeCache

private void bootstrapTypeCache()

updateValues

private <M extends DMXObjectModelImpl> M updateValues(M updateModel,
                                                      M targetObject)