@groovy.transform.CompileStatic class MongoCodecEntityPersister extends ThirdPartyCacheEntityPersister<java.lang.Object>
An {@org.grails.datastore.mapping.engine.EntityPersister} that uses the MongoDB 3.0 org.bson.codecs.configuration.CodecRegistry infrastructure
Modifiers | Name | Description |
---|---|---|
class |
MongoCodecEntityPersister.1 |
|
class |
MongoCodecEntityPersister.2 |
|
class |
MongoCodecEntityPersister.3 |
Modifiers | Name | Description |
---|---|---|
static java.lang.String |
ASSIGNED_IDENTIFIER_MAPPING |
|
static java.lang.String |
INC_OPERATOR |
|
static java.lang.String |
INSTANCE_PREFIX |
|
static java.lang.String |
MONGO_CLASS_FIELD |
|
static java.lang.String |
MONGO_ID_FIELD |
|
protected static java.lang.String |
NEXT_ID |
|
protected static java.lang.String |
NEXT_ID_SUFFIX |
|
protected EntityReflector |
fastClassData |
|
protected boolean |
hasNumericalIdentifier |
|
protected boolean |
hasStringIdentifier |
|
protected MongoDatastore |
mongoDatastore |
|
protected MongoCodecSession |
mongoSession |
Constructor and description |
---|
MongoCodecEntityPersister
(MappingContext mappingContext, PersistentEntity entity, MongoCodecSession session, org.springframework.context.ApplicationEventPublisher publisher, TPCacheAdapterRepository<java.lang.Object> cacheAdapterRepository) |
Type Params | Return Type | Name and description |
---|---|---|
|
protected EntityAccess |
createEntityAccess(PersistentEntity pe, java.lang.Object obj) |
|
protected org.bson.Document |
createIdQuery(java.lang.Object key) |
|
Query |
createQuery() |
|
protected void |
deleteEntities(PersistentEntity pe, java.lang.Iterable objects) |
|
protected void |
deleteEntity(PersistentEntity pe, java.lang.Object obj) |
|
java.io.Serializable |
generateIdentifier(PersistentEntity persistentEntity) |
|
protected java.lang.String |
getCollectionName(PersistentEntity pe) |
|
protected java.lang.String |
getIdentifierName(ClassMapping cm) |
|
protected com.mongodb.client.MongoCollection |
getMongoCollection(PersistentEntity pe) |
|
MongoCodecSession |
getSession() |
|
protected boolean |
isAssignedId(PersistentEntity persistentEntity) |
|
boolean |
isLocked(java.lang.Object o) |
|
private boolean |
isNotUpdateForAssignedId(PersistentEntity persistentEntity, java.lang.Object obj, boolean update, boolean assignedId, SessionImplementor<java.lang.Object> si) |
|
java.lang.Object |
lock(java.io.Serializable id) |
|
java.lang.Object |
lock(java.io.Serializable id, int timeout) |
|
protected java.util.List<java.io.Serializable> |
persistEntities(PersistentEntity pe, java.lang.Iterable objs) |
|
protected java.io.Serializable |
persistEntity(PersistentEntity entity, java.lang.Object obj, boolean isInsert) |
|
protected java.io.Serializable |
persistEntity(PersistentEntity pe, java.lang.Object obj) |
|
protected void |
processAssociations(MongoCodecSession mongoCodecSession, PersistentEntity entity, EntityAccess entityAccess, java.lang.Object obj, ProxyFactory proxyFactory, boolean isUpdate) |
|
java.io.Serializable |
refresh(java.lang.Object o) |
|
protected java.util.List<java.lang.Object> |
retrieveAllEntities(PersistentEntity pe, java.io.Serializable[] keys) |
|
protected java.util.List<java.lang.Object> |
retrieveAllEntities(PersistentEntity pe, java.lang.Iterable<java.io.Serializable> keys) |
|
protected java.lang.Object |
retrieveEntity(PersistentEntity pe, java.io.Serializable key) |
|
void |
unlock(java.lang.Object o) |
|
protected void |
updateCaches(PersistentEntity persistentEntity, java.lang.Object e, java.io.Serializable id) |