org.usergrid.persistence.cassandra
Class RelationManagerImpl

java.lang.Object
  extended by org.usergrid.persistence.cassandra.RelationManagerImpl
All Implemented Interfaces:
RelationManager

public class RelationManagerImpl
extends Object
implements RelationManager


Field Summary
static me.prettyprint.cassandra.serializers.ByteBufferSerializer be
           
static me.prettyprint.cassandra.serializers.LongSerializer le
           
static me.prettyprint.cassandra.serializers.StringSerializer se
           
static me.prettyprint.cassandra.serializers.UUIDSerializer ue
           
 
Constructor Summary
RelationManagerImpl()
           
 
Method Summary
 Entity addToCollection(String collectionName, EntityRef itemRef)
           
 Entity addToCollections(List<EntityRef> owners, String collectionName)
           
 me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batchAddConnectionIndexEntries(IndexUpdate indexUpdate, IndexUpdate.IndexEntry entry, ConnectionRefImpl connection, UUID[] index_keys)
           
 me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batchAddToCollection(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch, String collectionName, Entity entity, UUID timestampUuid)
          Batch add to collection.
 me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batchAddToCollections(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch, String ownerType, List<UUID> ownerIds, String collectionName, Entity entity, UUID timestampUuid)
           
 void batchCreateCollectionMembership(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch, EntityRef ownerRef, String collectionName, EntityRef itemRef, EntityRef membershipRef, UUID timestampUuid)
           
 me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batchDeleteConnectionIndexEntries(IndexUpdate indexUpdate, IndexUpdate.IndexEntry entry, ConnectionRefImpl connection, UUID[] index_keys)
           
 void batchDisconnect(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch, UUID timestampUuid)
           
 me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batchRemoveFromCollection(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch, String collectionName, Entity entity, boolean force, UUID timestampUuid)
           
 me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batchRemoveFromCollection(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch, String collectionName, Entity entity, UUID timestampUuid)
          Batch remove from collection.
 void batchRemoveFromContainers(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> m, UUID timestampUuid)
           
 IndexUpdate batchStartIndexUpdate(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch, Entity entity, String entryName, Object entryValue, UUID timestampUuid, boolean schemaHasProperty, boolean isMultiValue, boolean removeListEntry, boolean fulltextIndexed)
           
 IndexUpdate batchStartIndexUpdate(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch, Entity entity, String entryName, Object entryValue, UUID timestampUuid, boolean schemaHasProperty, boolean isMultiValue, boolean removeListEntry, boolean fulltextIndexed, boolean skipRead)
           
 IndexUpdate batchUpdateBackwardConnectionsDictionaryIndexes(IndexUpdate indexUpdate)
          Batch update backword connections set indexes.
 IndexUpdate batchUpdateBackwardConnectionsPropertyIndexes(IndexUpdate indexUpdate)
          Batch update backword connections property indexes.
 IndexUpdate batchUpdateCollectionIndex(IndexUpdate indexUpdate, EntityRef owner, String collectionName)
          Batch update collection index.
 IndexUpdate batchUpdateConnectionIndex(IndexUpdate indexUpdate, ConnectionRefImpl connection)
          Batch update connection index.
 me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batchUpdateEntityConnection(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch, boolean disconnect, ConnectionRefImpl connection, UUID timestampUuid)
           
 void batchUpdatePropertyIndexes(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch, String propertyName, Object propertyValue, boolean entitySchemaHasProperty, boolean noRead, UUID timestampUuid)
           
 void batchUpdateSetIndexes(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch, String setName, Object elementValue, boolean removeFromSet, UUID timestampUuid)
           
 boolean connectionExists(ConnectionRef connectionRef)
           
 ConnectionRef connectionRef(ConnectedEntityRef... connections)
           
 ConnectionRef connectionRef(String connectionType, EntityRef connectedEntityRef)
           
 ConnectionRef connectionRef(String pairedConnectionType, EntityRef pairedEntity, String connectionType, EntityRef connectedEntityRef)
           
 void copyRelationships(String srcRelationName, EntityRef dstEntityRef, String dstRelationName)
           
 ConnectionRef createConnection(ConnectedEntityRef... connections)
           
 ConnectionRef createConnection(ConnectionRef connection)
           
 ConnectionRef createConnection(String connectionType, EntityRef connectedEntityRef)
           
 ConnectionRef createConnection(String pairedConnectionType, EntityRef pairedEntity, String connectionType, EntityRef connectedEntityRef)
           
 Entity createItemInCollection(String collectionName, String itemType, Map<String,Object> properties)
           
 void deleteConnection(ConnectionRef connectionRef)
           
 org.springframework.context.ApplicationContext getApplicationContext()
           
 Map<String,Object> getAssociatedProperties(AssociatedEntityRef associatedEntityRef)
           
 Object getAssociatedProperty(AssociatedEntityRef associatedEntityRef, String propertyName)
           
 Object getCFKeyForSubkey(CollectionInfo collection, SliceNode node)
          Gets the cF key for subkey.
 Results getCollection(String collectionName, Query query, Results.Level resultsLevel)
           
 Results getCollection(String collectionName, UUID startResult, int count, Results.Level resultsLevel, boolean reversed)
           
 Set<String> getCollectionIndexes(String collectionName)
           
 Set<String> getCollections()
           
 long getCollectionSize(String collectionName)
           
 Results getConnectedEntities(String connectionType, String connectedEntityType, Results.Level resultsLevel)
           
 Results getConnectingEntities(String connectionType, String connectedEntityType, Results.Level resultsLevel)
           
 Set<String> getConnectionIndexes(ConnectionRefImpl connection)
           
 Set<String> getConnectionIndexes(String connectionType)
           
 List<ConnectionRefImpl> getConnections(ConnectionRefImpl connection, boolean includeConnectionEntities)
          Gets the connections.
 List<ConnectionRefImpl> getConnections(List<UUID> connectionIds)
           
 List<ConnectedEntityRef> getConnections(Query query)
           
 List<ConnectionRefImpl> getConnectionsWithEntity(UUID participatingEntityId)
           
 Set<String> getConnectionTypes()
           
 Set<String> getConnectionTypes(boolean filterConnection)
           
 Set<String> getConnectionTypes(UUID connectedEntityId)
           
 Map<EntityRef,Set<String>> getContainingCollections()
           
 Results getIndexResults(List<me.prettyprint.hector.api.beans.HColumn<ByteBuffer,ByteBuffer>> results, boolean compositeResults, String connectionType, String entityType, Results.Level level)
          Process index results.
 Map<String,Map<UUID,Set<String>>> getOwners()
           
 RelationManagerImpl init(EntityManagerImpl em, CassandraService cass, UUID applicationId, EntityRef headEntity, IndexBucketLocator indexBucketLocator)
           
 void removeFromCollection(String collectionName, EntityRef itemRef)
           
 Results searchCollection(String collectionName, Query query)
           
 Results searchConnectedEntities(Query query)
           
 List<ConnectionRef> searchConnections(Query query)
           
 List<me.prettyprint.hector.api.beans.HColumn<ByteBuffer,ByteBuffer>> searchIndex(Object indexKey, String searchName, Object searchStartValue, Object searchFinishValue, UUID startResult, String cursor, int count, boolean reversed)
          Search index.
 void setAssociatedProperty(AssociatedEntityRef associatedEntityRef, String propertyName, Object propertyValue)
           
 void updateEntityConnection(boolean disconnect, ConnectionRefImpl connection)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

se

public static final me.prettyprint.cassandra.serializers.StringSerializer se

be

public static final me.prettyprint.cassandra.serializers.ByteBufferSerializer be

ue

public static final me.prettyprint.cassandra.serializers.UUIDSerializer ue

le

public static final me.prettyprint.cassandra.serializers.LongSerializer le
Constructor Detail

RelationManagerImpl

public RelationManagerImpl()
Method Detail

init

public RelationManagerImpl init(EntityManagerImpl em,
                                CassandraService cass,
                                UUID applicationId,
                                EntityRef headEntity,
                                IndexBucketLocator indexBucketLocator)

getApplicationContext

public org.springframework.context.ApplicationContext getApplicationContext()

getConnections

public List<ConnectionRefImpl> getConnections(ConnectionRefImpl connection,
                                              boolean includeConnectionEntities)
                                       throws Exception
Gets the connections.

Parameters:
applicationId - the application id
connection - the connection
Returns:
list of connections
Throws:
Exception - the exception

getConnectionsWithEntity

public List<ConnectionRefImpl> getConnectionsWithEntity(UUID participatingEntityId)
                                                 throws Exception
Throws:
Exception

getConnections

public List<ConnectionRefImpl> getConnections(List<UUID> connectionIds)
                                       throws Exception
Throws:
Exception

getCFKeyForSubkey

public Object getCFKeyForSubkey(CollectionInfo collection,
                                SliceNode node)
Gets the cF key for subkey.

Parameters:
collection - the collection
properties - the properties
Returns:
row key

batchUpdateCollectionIndex

public IndexUpdate batchUpdateCollectionIndex(IndexUpdate indexUpdate,
                                              EntityRef owner,
                                              String collectionName)
                                       throws Exception
Batch update collection index.

Parameters:
batch - the batch
applicationId - the application id
ownerType - the owner type
ownerId - the owner id
jointOwnerId - the joint owner id
collectionName - the collection name
entityType - the entity type
entityId - the entity id
entityProperties - the entity properties
entryName - the entry name
entryValue - the entry value
isSet - the is set
removeSetEntry - the remove set entry
timestamp - the timestamp
Returns:
batch
Throws:
Exception - the exception

getCollectionIndexes

public Set<String> getCollectionIndexes(String collectionName)
                                 throws Exception
Specified by:
getCollectionIndexes in interface RelationManager
Throws:
Exception

getContainingCollections

public Map<EntityRef,Set<String>> getContainingCollections()
                                                    throws Exception
Throws:
Exception

batchCreateCollectionMembership

public void batchCreateCollectionMembership(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
                                            EntityRef ownerRef,
                                            String collectionName,
                                            EntityRef itemRef,
                                            EntityRef membershipRef,
                                            UUID timestampUuid)
                                     throws Exception
Throws:
Exception

batchAddToCollection

public me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batchAddToCollection(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
                                                                                   String collectionName,
                                                                                   Entity entity,
                                                                                   UUID timestampUuid)
                                                                            throws Exception
Batch add to collection.

Parameters:
batch - the batch
applicationId - the application id
ownerType - the owner type
ownerId - the owner id
jointOwnerId - the joint owner id
collectionName - the collection name
entityType - the entity type
entityId - the entity id
entityProperties - the entity properties
timestamp - the timestamp
Returns:
batch
Throws:
Exception - the exception

batchAddToCollections

public me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batchAddToCollections(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
                                                                                    String ownerType,
                                                                                    List<UUID> ownerIds,
                                                                                    String collectionName,
                                                                                    Entity entity,
                                                                                    UUID timestampUuid)
                                                                             throws Exception
Throws:
Exception

batchRemoveFromCollection

public me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batchRemoveFromCollection(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
                                                                                        String collectionName,
                                                                                        Entity entity,
                                                                                        UUID timestampUuid)
                                                                                 throws Exception
Batch remove from collection.

Parameters:
batch - the batch
applicationId - the application id
ownerType - the owner type
ownerId - the owner id
collectionName - the collection name
entityType - the entity type
entityId - the entity id
entityProperties - the entity properties
timestamp - the timestamp
Returns:
batch
Throws:
Exception - the exception

batchRemoveFromCollection

public me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batchRemoveFromCollection(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
                                                                                        String collectionName,
                                                                                        Entity entity,
                                                                                        boolean force,
                                                                                        UUID timestampUuid)
                                                                                 throws Exception
Throws:
Exception

batchDeleteConnectionIndexEntries

public me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batchDeleteConnectionIndexEntries(IndexUpdate indexUpdate,
                                                                                                IndexUpdate.IndexEntry entry,
                                                                                                ConnectionRefImpl connection,
                                                                                                UUID[] index_keys)
                                                                                         throws Exception
Throws:
Exception

batchAddConnectionIndexEntries

public me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batchAddConnectionIndexEntries(IndexUpdate indexUpdate,
                                                                                             IndexUpdate.IndexEntry entry,
                                                                                             ConnectionRefImpl connection,
                                                                                             UUID[] index_keys)

batchUpdateConnectionIndex

public IndexUpdate batchUpdateConnectionIndex(IndexUpdate indexUpdate,
                                              ConnectionRefImpl connection)
                                       throws Exception
Batch update connection index.

Parameters:
batch - the batch
applicationId - the application id
connection - the connection
entryName - the entry name
entryValue - the entry value
isSet - the is set
removeListEntry - the remove set entry
timestamp - the timestamp
Returns:
batch
Throws:
Exception - the exception

getConnectionIndexes

public Set<String> getConnectionIndexes(ConnectionRefImpl connection)
                                 throws Exception
Throws:
Exception

batchUpdateBackwardConnectionsPropertyIndexes

public IndexUpdate batchUpdateBackwardConnectionsPropertyIndexes(IndexUpdate indexUpdate)
                                                          throws Exception
Batch update backword connections property indexes.

Parameters:
batch - the batch
applicationId - the application id
itemType - the item type
itemId - the item id
propertyName - the property name
propertyValue - the property value
timestamp - the timestamp
Returns:
batch
Throws:
Exception - the exception

batchUpdateBackwardConnectionsDictionaryIndexes

public IndexUpdate batchUpdateBackwardConnectionsDictionaryIndexes(IndexUpdate indexUpdate)
                                                            throws Exception
Batch update backword connections set indexes.

Parameters:
batch - the batch
applicationId - the application id
itemType - the item type
itemId - the item id
setName - the set name
property - the property
elementValue - the set value
removeFromSet - the remove from set
timestamp - the timestamp
Returns:
batch
Throws:
Exception - the exception

batchUpdateEntityConnection

public me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batchUpdateEntityConnection(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
                                                                                          boolean disconnect,
                                                                                          ConnectionRefImpl connection,
                                                                                          UUID timestampUuid)
                                                                                   throws Exception
Throws:
Exception

updateEntityConnection

public void updateEntityConnection(boolean disconnect,
                                   ConnectionRefImpl connection)
                            throws Exception
Throws:
Exception

batchDisconnect

public void batchDisconnect(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
                            UUID timestampUuid)
                     throws Exception
Throws:
Exception

batchStartIndexUpdate

public IndexUpdate batchStartIndexUpdate(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
                                         Entity entity,
                                         String entryName,
                                         Object entryValue,
                                         UUID timestampUuid,
                                         boolean schemaHasProperty,
                                         boolean isMultiValue,
                                         boolean removeListEntry,
                                         boolean fulltextIndexed)
                                  throws Exception
Throws:
Exception

batchStartIndexUpdate

public IndexUpdate batchStartIndexUpdate(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
                                         Entity entity,
                                         String entryName,
                                         Object entryValue,
                                         UUID timestampUuid,
                                         boolean schemaHasProperty,
                                         boolean isMultiValue,
                                         boolean removeListEntry,
                                         boolean fulltextIndexed,
                                         boolean skipRead)
                                  throws Exception
Throws:
Exception

batchUpdatePropertyIndexes

public void batchUpdatePropertyIndexes(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
                                       String propertyName,
                                       Object propertyValue,
                                       boolean entitySchemaHasProperty,
                                       boolean noRead,
                                       UUID timestampUuid)
                                throws Exception
Throws:
Exception

batchUpdateSetIndexes

public void batchUpdateSetIndexes(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
                                  String setName,
                                  Object elementValue,
                                  boolean removeFromSet,
                                  UUID timestampUuid)
                           throws Exception
Throws:
Exception

getIndexResults

public Results getIndexResults(List<me.prettyprint.hector.api.beans.HColumn<ByteBuffer,ByteBuffer>> results,
                               boolean compositeResults,
                               String connectionType,
                               String entityType,
                               Results.Level level)
                        throws Exception
Process index results.

Parameters:
results - the results
compositeResults - the composite results
compositeOffset - the composite offset
connectionType - the connection type
entityType - the entity type
outputList - the output list
outputDetails - the output details
Throws:
Exception - the exception

searchIndex

public List<me.prettyprint.hector.api.beans.HColumn<ByteBuffer,ByteBuffer>> searchIndex(Object indexKey,
                                                                                        String searchName,
                                                                                        Object searchStartValue,
                                                                                        Object searchFinishValue,
                                                                                        UUID startResult,
                                                                                        String cursor,
                                                                                        int count,
                                                                                        boolean reversed)
                                                                                 throws Exception
Search index.

Parameters:
applicationId - the application id
indexKey - the index key
searchName - the search name
searchStartValue - the search start value
searchFinishValue - the search finish value
startResult - the start result
count - the count
Returns:
the list
Throws:
Exception - the exception

getOwners

public Map<String,Map<UUID,Set<String>>> getOwners()
                                            throws Exception
Specified by:
getOwners in interface RelationManager
Throws:
Exception

getCollections

public Set<String> getCollections()
                           throws Exception
Specified by:
getCollections in interface RelationManager
Throws:
Exception

getCollection

public Results getCollection(String collectionName,
                             UUID startResult,
                             int count,
                             Results.Level resultsLevel,
                             boolean reversed)
                      throws Exception
Specified by:
getCollection in interface RelationManager
Throws:
Exception

getCollectionSize

public long getCollectionSize(String collectionName)
                       throws Exception
Specified by:
getCollectionSize in interface RelationManager
Throws:
Exception

getCollection

public Results getCollection(String collectionName,
                             Query query,
                             Results.Level resultsLevel)
                      throws Exception
Specified by:
getCollection in interface RelationManager
Throws:
Exception

addToCollection

public Entity addToCollection(String collectionName,
                              EntityRef itemRef)
                       throws Exception
Specified by:
addToCollection in interface RelationManager
Throws:
Exception

addToCollections

public Entity addToCollections(List<EntityRef> owners,
                               String collectionName)
                        throws Exception
Specified by:
addToCollections in interface RelationManager
Throws:
Exception

createItemInCollection

public Entity createItemInCollection(String collectionName,
                                     String itemType,
                                     Map<String,Object> properties)
                              throws Exception
Specified by:
createItemInCollection in interface RelationManager
Throws:
Exception

removeFromCollection

public void removeFromCollection(String collectionName,
                                 EntityRef itemRef)
                          throws Exception
Specified by:
removeFromCollection in interface RelationManager
Throws:
Exception

batchRemoveFromContainers

public void batchRemoveFromContainers(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> m,
                                      UUID timestampUuid)
                               throws Exception
Throws:
Exception

copyRelationships

public void copyRelationships(String srcRelationName,
                              EntityRef dstEntityRef,
                              String dstRelationName)
                       throws Exception
Specified by:
copyRelationships in interface RelationManager
Throws:
Exception

searchCollection

public Results searchCollection(String collectionName,
                                Query query)
                         throws Exception
Specified by:
searchCollection in interface RelationManager
Throws:
Exception

createConnection

public ConnectionRef createConnection(ConnectionRef connection)
                               throws Exception
Specified by:
createConnection in interface RelationManager
Throws:
Exception

createConnection

public ConnectionRef createConnection(String connectionType,
                                      EntityRef connectedEntityRef)
                               throws Exception
Specified by:
createConnection in interface RelationManager
Throws:
Exception

createConnection

public ConnectionRef createConnection(String pairedConnectionType,
                                      EntityRef pairedEntity,
                                      String connectionType,
                                      EntityRef connectedEntityRef)
                               throws Exception
Specified by:
createConnection in interface RelationManager
Throws:
Exception

createConnection

public ConnectionRef createConnection(ConnectedEntityRef... connections)
                               throws Exception
Specified by:
createConnection in interface RelationManager
Throws:
Exception

connectionRef

public ConnectionRef connectionRef(String connectionType,
                                   EntityRef connectedEntityRef)
                            throws Exception
Specified by:
connectionRef in interface RelationManager
Throws:
Exception

connectionRef

public ConnectionRef connectionRef(String pairedConnectionType,
                                   EntityRef pairedEntity,
                                   String connectionType,
                                   EntityRef connectedEntityRef)
                            throws Exception
Specified by:
connectionRef in interface RelationManager
Throws:
Exception

connectionRef

public ConnectionRef connectionRef(ConnectedEntityRef... connections)
Specified by:
connectionRef in interface RelationManager

deleteConnection

public void deleteConnection(ConnectionRef connectionRef)
                      throws Exception
Specified by:
deleteConnection in interface RelationManager
Throws:
Exception

connectionExists

public boolean connectionExists(ConnectionRef connectionRef)
                         throws Exception
Specified by:
connectionExists in interface RelationManager
Throws:
Exception

getConnectionTypes

public Set<String> getConnectionTypes(UUID connectedEntityId)
                               throws Exception
Specified by:
getConnectionTypes in interface RelationManager
Throws:
Exception

getConnectionTypes

public Set<String> getConnectionTypes()
                               throws Exception
Specified by:
getConnectionTypes in interface RelationManager
Throws:
Exception

getConnectionTypes

public Set<String> getConnectionTypes(boolean filterConnection)
                               throws Exception
Specified by:
getConnectionTypes in interface RelationManager
Throws:
Exception

getConnectedEntities

public Results getConnectedEntities(String connectionType,
                                    String connectedEntityType,
                                    Results.Level resultsLevel)
                             throws Exception
Specified by:
getConnectedEntities in interface RelationManager
Throws:
Exception

getConnectingEntities

public Results getConnectingEntities(String connectionType,
                                     String connectedEntityType,
                                     Results.Level resultsLevel)
                              throws Exception
Specified by:
getConnectingEntities in interface RelationManager
Throws:
Exception

getConnections

public List<ConnectedEntityRef> getConnections(Query query)
                                        throws Exception
Specified by:
getConnections in interface RelationManager
Throws:
Exception

searchConnectedEntities

public Results searchConnectedEntities(Query query)
                                throws Exception
Specified by:
searchConnectedEntities in interface RelationManager
Throws:
Exception

searchConnections

public List<ConnectionRef> searchConnections(Query query)
                                      throws Exception
Specified by:
searchConnections in interface RelationManager
Throws:
Exception

getConnectionIndexes

public Set<String> getConnectionIndexes(String connectionType)
                                 throws Exception
Specified by:
getConnectionIndexes in interface RelationManager
Throws:
Exception

getAssociatedProperty

public Object getAssociatedProperty(AssociatedEntityRef associatedEntityRef,
                                    String propertyName)
                             throws Exception
Specified by:
getAssociatedProperty in interface RelationManager
Throws:
Exception

getAssociatedProperties

public Map<String,Object> getAssociatedProperties(AssociatedEntityRef associatedEntityRef)
                                           throws Exception
Specified by:
getAssociatedProperties in interface RelationManager
Throws:
Exception

setAssociatedProperty

public void setAssociatedProperty(AssociatedEntityRef associatedEntityRef,
                                  String propertyName,
                                  Object propertyValue)
                           throws Exception
Specified by:
setAssociatedProperty in interface RelationManager
Throws:
Exception


Copyright © 2013. All Rights Reserved.