| Modifiers | Name | Description |
|---|---|---|
protected class |
CassandraEntityPersister.CassandraEntityAccess |
| Fields inherited from class | Fields |
|---|---|
class org.grails.datastore.mapping.engine.NativeEntryEntityPersister |
EMBEDDED_PREFIX, DEFAULT_TIMEOUT |
class org.grails.datastore.mapping.engine.LockableEntityPersister |
DEFAULT_TIMEOUT |
| Constructor and description |
|---|
CassandraEntityPersister
(org.grails.datastore.mapping.model.MappingContext context, org.grails.datastore.mapping.model.PersistentEntity entity, CassandraSession cassandraSession, org.springframework.context.ApplicationEventPublisher applicationEventPublisher) |
| Type | Name and description |
|---|---|
protected void |
addPendingUpdate(java.io.Serializable id, com.datastax.driver.core.Statement statement) |
void |
append(java.lang.Object obj, java.lang.String propertyName, java.lang.Object element, org.springframework.cassandra.core.WriteOptions writeOptions) |
void |
append(java.io.Serializable id, java.lang.String propertyName, java.lang.Object element, org.springframework.cassandra.core.WriteOptions writeOptions) |
java.lang.Object |
convertObject(org.grails.datastore.mapping.model.PersistentEntity persistentEntity, java.io.Serializable nativeKey, java.lang.Object object) |
static java.lang.Object |
convertPrimitiveToNative(java.lang.Object item, org.springframework.data.cassandra.mapping.CassandraPersistentProperty cassandraPersistentProperty, org.springframework.core.convert.ConversionService conversionService) |
protected org.grails.datastore.mapping.engine.EntityAccess |
createEntityAccess(org.grails.datastore.mapping.model.PersistentEntity persistentEntity, java.lang.Object obj) |
protected org.grails.datastore.mapping.engine.EntityAccess |
createEntityAccess(org.grails.datastore.mapping.model.PersistentEntity persistentEntity, java.lang.Object obj, org.grails.datastore.mapping.engine.EntityAccess nativeEntry) |
protected java.util.Map<java.lang.String, java.io.Serializable> |
createIdMap(java.io.Serializable nativeKey, boolean withColumnName) |
protected org.grails.datastore.mapping.engine.EntityAccess |
createNewEntry(java.lang.String family) |
protected org.grails.datastore.mapping.engine.EntityAccess |
createNewEntry(java.lang.String family, java.lang.Object instance) |
java.lang.Object |
createObjectFromNativeEntry(org.grails.datastore.mapping.model.PersistentEntity persistentEntity, java.io.Serializable nativeKey, org.grails.datastore.mapping.engine.EntityAccess nativeEntry) |
org.grails.datastore.mapping.query.Query |
createQuery() |
protected com.datastax.driver.core.querybuilder.Update |
createUpdate() |
protected void |
deleteEntries(java.lang.String family, java.util.List<java.lang.Object> keys) |
protected void |
deleteEntry(java.lang.String family, java.lang.Object key, java.lang.Object entry) |
void |
deleteFrom(java.lang.Object obj, java.lang.String propertyName, java.lang.Object item, boolean isIndex, org.springframework.cassandra.core.WriteOptions writeOptions) |
void |
deleteFrom(java.io.Serializable id, java.lang.String propertyName, java.lang.Object item, boolean isIndex, org.springframework.cassandra.core.WriteOptions writeOptions) |
protected boolean |
doesRequirePropertyIndexing() |
protected java.lang.Object |
generateIdentifier(org.grails.datastore.mapping.model.PersistentEntity persistentEntity, org.grails.datastore.mapping.engine.EntityAccess entityAccess) |
org.grails.datastore.mapping.engine.AssociationIndexer |
getAssociationIndexer(org.grails.datastore.mapping.engine.EntityAccess nativeEntry, org.grails.datastore.mapping.model.types.Association association) |
protected CassandraSession |
getCassandraSession() |
protected org.springframework.data.cassandra.core.CassandraTemplate |
getCassandraTemplate() |
protected java.lang.Object |
getCurrentVersion(org.grails.datastore.mapping.engine.EntityAccess ea) |
java.lang.String |
getEntityFamily() |
protected java.lang.Object |
getEntryValue(org.grails.datastore.mapping.engine.EntityAccess nativeEntry, java.lang.String property) |
java.io.Serializable |
getObjectIdentifier(java.lang.Object object) |
static org.springframework.data.cassandra.mapping.CassandraPersistentProperty |
getPersistentProperty(org.springframework.data.cassandra.mapping.CassandraPersistentEntity<?> cassandraPersistentEntity, java.lang.String propertyName) |
org.grails.datastore.mapping.engine.PropertyValueIndexer |
getPropertyIndexer(org.grails.datastore.mapping.model.PersistentProperty property) |
static java.lang.String |
getPropertyName(org.springframework.data.cassandra.mapping.CassandraPersistentEntity<?> cassandraPersistentEntity, java.lang.String propertyName) |
static java.lang.String |
getPropertyName(org.springframework.data.cassandra.mapping.CassandraPersistentProperty property) |
protected java.lang.String |
getTableName() |
protected org.springframework.cassandra.core.WriteOptions |
getWriteOptions(java.lang.Object entity) |
com.datastax.driver.core.Statement |
prepareAppend(java.io.Serializable id, java.lang.String propertyName, java.lang.Object element, org.springframework.cassandra.core.WriteOptions writeOptions) |
protected com.datastax.driver.core.querybuilder.Delete |
prepareDelete(java.io.Serializable id, com.datastax.driver.core.querybuilder.Delete delete) |
com.datastax.driver.core.Statement |
prepareDeleteFrom(java.io.Serializable id, java.lang.String propertyName, java.lang.Object item, boolean isIndex, org.springframework.cassandra.core.WriteOptions writeOptions) |
com.datastax.driver.core.Statement |
preparePrepend(java.io.Serializable id, java.lang.String propertyName, java.lang.Object element, org.springframework.cassandra.core.WriteOptions writeOptions) |
com.datastax.driver.core.Statement |
prepareReplaceAt(java.io.Serializable id, java.lang.String propertyName, int index, java.lang.Object element, org.springframework.cassandra.core.WriteOptions writeOptions) |
protected com.datastax.driver.core.querybuilder.Update |
prepareUpdate(java.io.Serializable id, com.datastax.driver.core.querybuilder.Update update, org.springframework.cassandra.core.WriteOptions writeOptions) |
com.datastax.driver.core.Statement |
prepareUpdateProperties(java.io.Serializable id, java.util.Map<java.lang.String, java.lang.Object> properties, org.springframework.cassandra.core.WriteOptions writeOptions) |
com.datastax.driver.core.Statement |
prepareUpdateProperty(java.io.Serializable id, java.lang.String propertyName, java.lang.Object item, org.springframework.cassandra.core.WriteOptions writeOptions) |
void |
prepend(java.lang.Object obj, java.lang.String propertyName, java.lang.Object element, org.springframework.cassandra.core.WriteOptions writeOptions) |
void |
prepend(java.io.Serializable id, java.lang.String propertyName, java.lang.Object element, org.springframework.cassandra.core.WriteOptions writeOptions) |
protected java.lang.Object |
readIdentifierFromObject(java.lang.Object object) |
protected java.lang.Object |
readObjectIdentifier(org.grails.datastore.mapping.engine.EntityAccess entityAccess, org.grails.datastore.mapping.model.ClassMapping cm) |
void |
replaceAt(java.lang.Object obj, java.lang.String propertyName, int index, java.lang.Object element, org.springframework.cassandra.core.WriteOptions writeOptions) |
void |
replaceAt(java.io.Serializable id, java.lang.String propertyName, int index, java.lang.Object element, org.springframework.cassandra.core.WriteOptions writeOptions) |
protected org.grails.datastore.mapping.engine.EntityAccess |
retrieveEntry(org.grails.datastore.mapping.model.PersistentEntity persistentEntity, java.lang.String family, java.io.Serializable nativeKey) |
protected void |
setEntryValue(org.grails.datastore.mapping.engine.EntityAccess nativeEntry, java.lang.String key, java.lang.Object value) |
void |
setObjectIdentifier(java.lang.Object obj, java.io.Serializable id) |
protected java.lang.Object |
storeEntry(org.grails.datastore.mapping.model.PersistentEntity persistentEntity, org.grails.datastore.mapping.engine.EntityAccess entityAccess, java.lang.Object storeId, org.grails.datastore.mapping.engine.EntityAccess entry) |
java.lang.Object |
update(java.lang.Object obj) |
java.lang.Object |
update(java.lang.Object obj, boolean simpleTypesOnly) |
protected void |
updateEntry(org.grails.datastore.mapping.model.PersistentEntity persistentEntity, org.grails.datastore.mapping.engine.EntityAccess entityAccess, java.lang.Object key, org.grails.datastore.mapping.engine.EntityAccess entry) |
protected void |
updateEntry(org.grails.datastore.mapping.model.PersistentEntity persistentEntity, org.grails.datastore.mapping.engine.EntityAccess entityAccess, java.lang.Object key, org.grails.datastore.mapping.engine.EntityAccess entry, boolean simpleTypesOnly) |
void |
updateProperties(java.io.Serializable id, java.util.Map<java.lang.String, java.lang.Object> properties, org.springframework.cassandra.core.WriteOptions writeOptions) |
void |
updateProperty(java.io.Serializable id, java.lang.String propertyName, java.lang.Object item, org.springframework.cassandra.core.WriteOptions writeOptions) |
java.lang.Object |
updateSingleTypes(java.lang.Object obj) |
| Methods inherited from class | Name |
|---|---|
class org.grails.datastore.mapping.engine.NativeEntryEntityPersister |
org.grails.datastore.mapping.engine.NativeEntryEntityPersister#getClassMapping(), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#getPropertyIndexer(org.grails.datastore.mapping.model.PersistentProperty), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#getAssociationIndexer(java.lang.Object, org.grails.datastore.mapping.model.types.Association), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#createObjectFromNativeEntry(org.grails.datastore.mapping.model.PersistentEntity, java.io.Serializable, java.lang.Object), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#createObjectFromEmbeddedNativeEntry(org.grails.datastore.mapping.model.PersistentEntity, java.lang.Object), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#createEmbeddedCacheEntryKey(java.lang.Object), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#getEntityFamily(), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#createNativeObjectForEmbedded(org.grails.datastore.mapping.model.types.Association, java.lang.Object), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#refresh(java.lang.Object), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#isDirty(java.lang.Object, java.lang.Object), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#lock(java.io.Serializable, int), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#lock(java.io.Serializable), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#unlock(java.lang.Object), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#isLocked(java.lang.Object), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#proxy(java.io.Serializable), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#getSession(), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#retrieveAll(java.lang.Iterable), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#retrieveAll([Ljava.io.Serializable;), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#persist(java.lang.Object), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#persist(java.lang.Iterable), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#getMappingContext(), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#getProxyFactory(), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#getPersistentEntity(), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#setObjectIdentifier(java.lang.Object, java.io.Serializable), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#cancelInsert(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#firePostInsertEvent(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#cancelUpdate(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#cancelDelete(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#cancelLoad(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#firePostUpdateEvent(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#firePostDeleteEvent(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#firePreLoadEvent(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#firePostLoadEvent(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#retrieve(java.io.Serializable), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#getObjectIdentifier(java.lang.Object), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#getType(), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#delete(java.lang.Object), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#delete(java.lang.Iterable), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#insert(java.lang.Object), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#wait(long, int), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#wait(long), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#wait(), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#equals(java.lang.Object), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#toString(), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#hashCode(), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#getClass(), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#notify(), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#notifyAll(), org.grails.datastore.mapping.engine.NativeEntryEntityPersister#createQuery() |
class org.grails.datastore.mapping.engine.LockableEntityPersister |
org.grails.datastore.mapping.engine.LockableEntityPersister#proxy(java.io.Serializable), org.grails.datastore.mapping.engine.LockableEntityPersister#lock(java.io.Serializable), org.grails.datastore.mapping.engine.LockableEntityPersister#lock(java.io.Serializable, int), org.grails.datastore.mapping.engine.LockableEntityPersister#unlock(java.lang.Object), org.grails.datastore.mapping.engine.LockableEntityPersister#isLocked(java.lang.Object), org.grails.datastore.mapping.engine.LockableEntityPersister#getSession(), org.grails.datastore.mapping.engine.LockableEntityPersister#retrieveAll(java.lang.Iterable), org.grails.datastore.mapping.engine.LockableEntityPersister#retrieveAll([Ljava.io.Serializable;), org.grails.datastore.mapping.engine.LockableEntityPersister#persist(java.lang.Object), org.grails.datastore.mapping.engine.LockableEntityPersister#persist(java.lang.Iterable), org.grails.datastore.mapping.engine.LockableEntityPersister#getMappingContext(), org.grails.datastore.mapping.engine.LockableEntityPersister#getProxyFactory(), org.grails.datastore.mapping.engine.LockableEntityPersister#getPersistentEntity(), org.grails.datastore.mapping.engine.LockableEntityPersister#setObjectIdentifier(java.lang.Object, java.io.Serializable), org.grails.datastore.mapping.engine.LockableEntityPersister#cancelInsert(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.LockableEntityPersister#firePostInsertEvent(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.LockableEntityPersister#cancelUpdate(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.LockableEntityPersister#cancelDelete(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.LockableEntityPersister#cancelLoad(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.LockableEntityPersister#firePostUpdateEvent(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.LockableEntityPersister#firePostDeleteEvent(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.LockableEntityPersister#firePreLoadEvent(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.LockableEntityPersister#firePostLoadEvent(org.grails.datastore.mapping.model.PersistentEntity, org.grails.datastore.mapping.engine.EntityAccess), org.grails.datastore.mapping.engine.LockableEntityPersister#retrieve(java.io.Serializable), org.grails.datastore.mapping.engine.LockableEntityPersister#getObjectIdentifier(java.lang.Object), org.grails.datastore.mapping.engine.LockableEntityPersister#getType(), org.grails.datastore.mapping.engine.LockableEntityPersister#delete(java.lang.Object), org.grails.datastore.mapping.engine.LockableEntityPersister#delete(java.lang.Iterable), org.grails.datastore.mapping.engine.LockableEntityPersister#insert(java.lang.Object), org.grails.datastore.mapping.engine.LockableEntityPersister#wait(long, int), org.grails.datastore.mapping.engine.LockableEntityPersister#wait(long), org.grails.datastore.mapping.engine.LockableEntityPersister#wait(), org.grails.datastore.mapping.engine.LockableEntityPersister#equals(java.lang.Object), org.grails.datastore.mapping.engine.LockableEntityPersister#toString(), org.grails.datastore.mapping.engine.LockableEntityPersister#hashCode(), org.grails.datastore.mapping.engine.LockableEntityPersister#getClass(), org.grails.datastore.mapping.engine.LockableEntityPersister#notify(), org.grails.datastore.mapping.engine.LockableEntityPersister#notifyAll(), org.grails.datastore.mapping.engine.LockableEntityPersister#createQuery(), org.grails.datastore.mapping.engine.LockableEntityPersister#refresh(java.lang.Object) |