public class PersistenceLayer extends StorageDecorator
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 |
(package private) ValueStorage |
valueStorage |
Constructor and Description |
---|
PersistenceLayer(DeepaMehtaStorage storage) |
Modifier and Type | Method and Description |
---|---|
(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) |
(package private) TopicTypeModelImpl |
_getTopicType(String uri) |
private void |
bootstrapTypeCache() |
private void |
checkAssociationReadAccess(long assocId) |
private void |
checkAssociationWriteAccess(long assocId) |
private void |
checkReadAccess(DeepaMehtaObjectModelImpl model) |
(package private) <O> O |
checkReadAccessAndInstantiate(DeepaMehtaObjectModelImpl model) |
(package private) <O> List<O> |
checkReadAccessAndInstantiate(Iterable<? extends DeepaMehtaObjectModelImpl> models) |
private void |
checkTopicReadAccess(long topicId) |
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) AssociationType |
createAssociationType(AssociationTypeModelImpl model) |
(package private) Topic |
createRoleType(TopicModelImpl model) |
(package private) TopicImpl |
createTopic(TopicModelImpl model)
Convenience.
|
(package private) TopicImpl |
createTopic(TopicModelImpl model,
String uriPrefix)
Creates a new topic in the DB.
|
(package private) void |
createTopicInstantiation(long topicId,
String topicTypeUri) |
(package private) TopicType |
createTopicType(TopicTypeModelImpl model) |
private void |
createTypeTopic(TypeModelImpl model,
String uriPrefix) |
(package private) void |
deleteAssociation(long assocId) |
(package private) void |
deleteAssociationType(String assocTypeUri) |
(package private) void |
deleteTopic(long topicId) |
(package private) void |
deleteTopicType(String topicTypeUri) |
private <M extends DeepaMehtaObjectModelImpl> |
filterReadables(Iterable<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) Association |
getAssociationBetweenTopicAndAssociation(String assocTypeUri,
long topicId,
long assocId,
String topicRoleTypeUri,
String assocRoleTypeUri) |
(package private) Association |
getAssociationByValue(String key,
SimpleValue value) |
(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) AssociationType |
getAssociationType(String uri) |
(package private) AssociationType |
getAssociationTypeImplicitly(long assocId) |
private List<String> |
getAssociationTypeUris() |
(package private) DeepaMehtaObject |
getObject(long id) |
(package private) long[] |
getPlayerIds(long assocId) |
(package private) Topic |
getTopic(long topicId) |
(package private) TopicImpl |
getTopicByUri(String uri) |
(package private) TopicImpl |
getTopicByValue(String key,
SimpleValue value) |
(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) TopicType |
getTopicType(String uri) |
(package private) TopicType |
getTopicTypeImplicitly(long topicId) |
private List<String> |
getTopicTypeUris() |
(package private) boolean |
hasReadAccess(DeepaMehtaObjectModelImpl model) |
(package private) <O> List<O> |
instantiate(Iterable<? extends DeepaMehtaObjectModelImpl> models) |
(package private) List<Topic> |
searchTopics(String searchTerm,
String fieldUri) |
private String |
typeUri(long objectId) |
(package private) void |
updateAssociation(AssociationModelImpl newModel) |
(package private) void |
updateAssociationType(AssociationTypeModelImpl newModel) |
(package private) void |
updateTopic(TopicModelImpl newModel) |
(package private) void |
updateTopicType(TopicTypeModelImpl newModel) |
_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
private static final String URI_PREFIX_TOPIC_TYPE
private static final String URI_PREFIX_ASSOCIATION_TYPE
private static final String URI_PREFIX_ROLE_TYPE
TypeStorage typeStorage
ValueStorage valueStorage
EventManager em
public PersistenceLayer(DeepaMehtaStorage storage)
TopicImpl getTopicByUri(String uri)
TopicImpl getTopicByValue(String key, SimpleValue value)
List<Topic> getTopicsByValue(String key, SimpleValue value)
List<Topic> getTopicsByType(String topicTypeUri)
List<Topic> searchTopics(String searchTerm, String fieldUri)
Iterable<Topic> getAllTopics()
TopicImpl createTopic(TopicModelImpl model)
TopicImpl createTopic(TopicModelImpl model, String uriPrefix)
void updateTopic(TopicModelImpl newModel)
void deleteTopic(long topicId)
Association getAssociation(long assocId)
Association getAssociationByValue(String key, SimpleValue value)
List<Association> getAssociationsByValue(String key, SimpleValue value)
Association getAssociation(String assocTypeUri, long topic1Id, long topic2Id, String roleTypeUri1, String roleTypeUri2)
Association getAssociationBetweenTopicAndAssociation(String assocTypeUri, long topicId, long assocId, String topicRoleTypeUri, String assocRoleTypeUri)
List<Association> getAssociationsByType(String assocTypeUri)
List<Association> getAssociations(long topic1Id, long topic2Id)
List<Association> getAssociations(String assocTypeUri, long topic1Id, long topic2Id)
List<Association> getAssociations(String assocTypeUri, long topic1Id, long topic2Id, String roleTypeUri1, String roleTypeUri2)
Iterable<AssociationModelImpl> _getAssociations(String assocTypeUri, long topic1Id, long topic2Id, String roleTypeUri1, String roleTypeUri2)
Iterable<Association> getAllAssociations()
long[] getPlayerIds(long assocId)
AssociationImpl createAssociation(String typeUri, RoleModel roleModel1, RoleModel roleModel2)
AssociationImpl createAssociation(AssociationModelImpl model)
void updateAssociation(AssociationModelImpl newModel)
void deleteAssociation(long assocId)
void createTopicInstantiation(long topicId, String topicTypeUri)
void createAssociationInstantiation(long assocId, String assocTypeUri)
TopicType getTopicType(String uri)
TopicType getTopicTypeImplicitly(long topicId)
AssociationType getAssociationType(String uri)
AssociationType getAssociationTypeImplicitly(long assocId)
List<TopicType> getAllTopicTypes()
List<AssociationType> getAllAssociationTypes()
TopicType createTopicType(TopicTypeModelImpl model)
AssociationType createAssociationType(AssociationTypeModelImpl model)
void updateTopicType(TopicTypeModelImpl newModel)
void updateAssociationType(AssociationTypeModelImpl newModel)
void deleteTopicType(String topicTypeUri)
void deleteAssociationType(String assocTypeUri)
Topic createRoleType(TopicModelImpl model)
TopicTypeModelImpl _getTopicType(String uri)
AssociationTypeModelImpl _getAssociationType(String uri)
DeepaMehtaObject getObject(long id)
List<Topic> getTopicsByProperty(String propUri, Object propValue)
List<Topic> getTopicsByPropertyRange(String propUri, Number from, Number to)
List<Association> getAssociationsByProperty(String propUri, Object propValue)
List<Association> getAssociationsByPropertyRange(String propUri, Number from, Number to)
<O> O checkReadAccessAndInstantiate(DeepaMehtaObjectModelImpl model)
<O> List<O> checkReadAccessAndInstantiate(Iterable<? extends DeepaMehtaObjectModelImpl> models)
private <M extends DeepaMehtaObjectModelImpl> Iterable<M> filterReadables(Iterable<M> models)
boolean hasReadAccess(DeepaMehtaObjectModelImpl model)
private void checkReadAccess(DeepaMehtaObjectModelImpl model)
AccessControlException
private void checkTopicReadAccess(long topicId)
private void checkAssociationReadAccess(long assocId)
private void checkTopicWriteAccess(long topicId)
private void checkAssociationWriteAccess(long assocId)
<O> List<O> instantiate(Iterable<? extends DeepaMehtaObjectModelImpl> models)
private List<String> getTopicTypeUris()
private List<String> getAssociationTypeUris()
private void createTypeTopic(TypeModelImpl model, String uriPrefix)
private void bootstrapTypeCache()
Copyright © 2017. All Rights Reserved.