public class MongoSession extends AbstractMongoSession
A Session implementation for the Mongo document store.
Constructor and description |
---|
MongoSession
(MongoDatastore datastore, MappingContext mappingContext, org.springframework.context.ApplicationEventPublisher publisher) |
MongoSession
(MongoDatastore datastore, MappingContext mappingContext, org.springframework.context.ApplicationEventPublisher publisher, boolean stateless) |
Type Params | Return Type | Name and description |
---|---|---|
|
protected Transaction<com.mongodb.client.MongoClient> |
beginTransactionInternal() |
|
private org.bson.Document |
buildNativeDocumentQueryFromCriteria(QueryableCriteria criteria, PersistentEntity entity) |
|
protected void |
cacheEntry(java.io.Serializable key, java.lang.Object entry, java.util.Map<java.io.Serializable, java.lang.Object> entryCache, boolean forDirtyCheck) |
|
protected Persister |
createPersister(java.lang.Class cls, MappingContext mappingContext) |
|
public Query |
createQuery(java.lang.Class type) |
|
protected org.bson.Document |
createSetAndUnsetDoc(org.bson.Document updateDoc) |
|
public java.lang.Object |
decode(java.lang.Class type, java.lang.Object nativeObject) |
|
public void |
delete(java.lang.Iterable objects) |
|
public long |
deleteAll(QueryableCriteria criteria) |
|
public void |
disconnect() |
|
public void |
flush(com.mongodb.WriteConcern writeConcern) |
|
protected void |
flushPendingUpdates(java.util.Map<PersistentEntity, java.util.Collection<PendingUpdate>> updates) |
|
protected java.util.Map<PersistentEntity, java.util.List> |
getDeleteMap(java.lang.Iterable objects) |
|
protected java.util.List<com.mongodb.client.model.WriteModel<org.bson.Document>> |
getWriteModelsForEntity(PersistentEntity persistentEntity, java.util.Map<PersistentEntity, java.util.List<com.mongodb.client.model.WriteModel<org.bson.Document>>> writeModels) |
|
public void |
run() |
|
public long |
updateAll(QueryableCriteria criteria, java.util.Map<java.lang.String, java.lang.Object> properties) |