Field Summary

Fields 

Modifiers	Name	Description
static java.lang.String	MONGO_SET_OPERATOR
static java.lang.String	MONGO_UNSET_OPERATOR
protected com.mongodb.client.ClientSession	clientSession
protected static java.util.Map<org.grails.datastore.mapping.model.PersistentEntity, com.mongodb.WriteConcern>	declaredWriteConcerns
protected java.lang.String	defaultDatabase
protected boolean	errorOccured
protected java.util.Map<org.grails.datastore.mapping.model.PersistentEntity, java.lang.String>	mongoCollections
protected java.util.Map<org.grails.datastore.mapping.model.PersistentEntity, java.lang.String>	mongoDatabases
protected MongoDatastore	mongoDatastore
protected com.mongodb.WriteConcern	writeConcern

Inherited fields 

Fields inherited from class	Fields
class org.grails.datastore.mapping.core.AbstractSession	ENTITY_ACCESS

Constructor Summary

Constructors 

Constructor and description
AbstractMongoSession(MongoDatastore datastore, org.grails.datastore.mapping.model.MappingContext mappingContext, org.springframework.context.ApplicationEventPublisher publisher)
AbstractMongoSession(MongoDatastore datastore, org.grails.datastore.mapping.model.MappingContext mappingContext, org.springframework.context.ApplicationEventPublisher publisher, boolean stateless)

Methods Summary

Methods 

Type Params	Return Type	Name and description
	protected void	addPostFlushOperations(java.util.List<org.grails.datastore.mapping.core.impl.PendingOperation> cascadeOperations)
<T>	public com.mongodb.client.AggregateIterable<T>	aggregate(com.mongodb.client.MongoCollection<T> collection, java.util.List<? extends org.bson.conversions.Bson> pipeline)
	protected org.grails.datastore.mapping.transactions.Transaction	beginTransactionInternal()
	public com.mongodb.bulk.BulkWriteResult	bulkWrite(com.mongodb.client.MongoCollection collection, java.util.List<? extends com.mongodb.client.model.WriteModel> writes)
	protected void	closeClientSessionQuietly() Closes and detaches the com.mongodb.client.ClientSession if one is still attached.
	public long	countDocuments(com.mongodb.client.MongoCollection<?> collection, org.bson.conversions.Bson filter)
<T>	public abstract T	decode(java.lang.Class<T> type, java.lang.Object nativeObject) Decodes the given entity type from the given native object type
	public com.mongodb.client.result.DeleteResult	deleteMany(com.mongodb.client.MongoCollection collection, org.bson.conversions.Bson filter)
	public void	disconnect()
<T>	public com.mongodb.client.FindIterable<T>	find(com.mongodb.client.MongoCollection<T> collection, org.bson.conversions.Bson filter)
<R>	public com.mongodb.client.FindIterable<R>	find(com.mongodb.client.MongoCollection<?> collection, org.bson.conversions.Bson filter, java.lang.Class<R> resultClass)
<T>	public T	findOneAndDelete(com.mongodb.client.MongoCollection<T> collection, org.bson.conversions.Bson filter)
<T>	public T	findOneAndDelete(com.mongodb.client.MongoCollection<T> collection, org.bson.conversions.Bson filter, com.mongodb.client.model.FindOneAndDeleteOptions options)
	public void	flush()
	public abstract void	flush(com.mongodb.WriteConcern writeConcern)
	public com.mongodb.client.ClientSession	getClientSession() Returns: the active com.mongodb.client.ClientSession for the current MongoDB transaction, or null if no server-side transaction is in progress
	public com.mongodb.client.MongoCollection<org.bson.Document>	getCollection(org.grails.datastore.mapping.model.PersistentEntity entity)
	public java.lang.String	getCollectionName(org.grails.datastore.mapping.model.PersistentEntity entity)
	public java.lang.String	getDatabase(org.grails.datastore.mapping.model.PersistentEntity entity) Returns: The name of the default database
	public MongoDatastore	getDatastore()
	public com.mongodb.WriteConcern	getDeclaredWriteConcern(org.grails.datastore.mapping.model.PersistentEntity entity)
	public java.lang.String	getDefaultDatabase() Returns: The name of the default database
	public org.grails.datastore.mapping.document.config.DocumentMappingContext	getDocumentMappingContext()
	public MongoMappingContext	getMappingContext()
	public com.mongodb.client.MongoClient	getNativeInterface()
	public com.mongodb.WriteConcern	getWriteConcern() Obtains the WriteConcern to use for the session
	public boolean	hasActiveTransaction() Returns: true if a server-side MongoDB transaction is currently active on this session
	public boolean	hasTransaction()
	public void	setWriteConcern(com.mongodb.WriteConcern writeConcern) Sets the WriteConcern to use for the session
	public com.mongodb.client.result.UpdateResult	updateMany(com.mongodb.client.MongoCollection collection, org.bson.conversions.Bson filter, org.bson.conversions.Bson update, com.mongodb.client.model.UpdateOptions options)
	public java.lang.String	useCollection(org.grails.datastore.mapping.model.PersistentEntity entity, java.lang.String collectionName) Use the given collection for the given entity
	public java.lang.String	useDatabase(org.grails.datastore.mapping.model.PersistentEntity entity, java.lang.String databaseName) Use the given database name for the given entity

Inherited Methods Summary

Inherited Methods 

Methods inherited from class

Name

class org.grails.datastore.mapping.core.AbstractSession

org.grails.datastore.mapping.core.AbstractSession#addPendingDelete(org.grails.datastore.mapping.core.impl.PendingDelete), org.grails.datastore.mapping.core.AbstractSession#addPendingInsert(org.grails.datastore.mapping.core.impl.PendingInsert), org.grails.datastore.mapping.core.AbstractSession#addPendingUpdate(org.grails.datastore.mapping.core.impl.PendingUpdate), org.grails.datastore.mapping.core.AbstractSession#addPostFlushOperation(java.lang.Runnable), org.grails.datastore.mapping.core.AbstractSession#attach(java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#beginTransaction(), org.grails.datastore.mapping.core.AbstractSession#beginTransaction(org.springframework.transaction.TransactionDefinition), org.grails.datastore.mapping.core.AbstractSession#cacheCollection(org.grails.datastore.mapping.model.PersistentEntity, java.io.Serializable, java.util.Collection, java.lang.String), org.grails.datastore.mapping.core.AbstractSession#cacheEntry(org.grails.datastore.mapping.model.PersistentEntity, java.io.Serializable, java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#cacheInstance(java.lang.Class, java.io.Serializable, java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#clear(), org.grails.datastore.mapping.core.AbstractSession#clear(java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#clearSessionProperty(java.lang.String), org.grails.datastore.mapping.core.AbstractSession#contains(java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#createEntityAccess(org.grails.datastore.mapping.model.PersistentEntity, java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#createQuery(java.lang.Class), org.grails.datastore.mapping.core.AbstractSession#delete(java.lang.Iterable), org.grails.datastore.mapping.core.AbstractSession#delete(java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#deleteAll(org.grails.datastore.mapping.query.api.QueryableCriteria), org.grails.datastore.mapping.core.AbstractSession#disconnect(), org.grails.datastore.mapping.core.AbstractSession#equals(java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#flush(), org.grails.datastore.mapping.core.AbstractSession#getAttribute(java.lang.Object, java.lang.String), org.grails.datastore.mapping.core.AbstractSession#getCachedCollection(org.grails.datastore.mapping.model.PersistentEntity, java.io.Serializable, java.lang.String), org.grails.datastore.mapping.core.AbstractSession#getCachedEntry(org.grails.datastore.mapping.model.PersistentEntity, java.io.Serializable), org.grails.datastore.mapping.core.AbstractSession#getCachedEntry(org.grails.datastore.mapping.model.PersistentEntity, java.io.Serializable, boolean), org.grails.datastore.mapping.core.AbstractSession#getCachedInstance(java.lang.Class, java.io.Serializable), org.grails.datastore.mapping.core.AbstractSession#getClass(), org.grails.datastore.mapping.core.AbstractSession#getDatastore(), org.grails.datastore.mapping.core.AbstractSession#getFlushMode(), org.grails.datastore.mapping.core.AbstractSession#getMappingContext(), org.grails.datastore.mapping.core.AbstractSession#getNativeInterface(), org.grails.datastore.mapping.core.AbstractSession#getObjectIdentifier(java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#getPendingDeletes(), org.grails.datastore.mapping.core.AbstractSession#getPendingInserts(), org.grails.datastore.mapping.core.AbstractSession#getPendingUpdates(), org.grails.datastore.mapping.core.AbstractSession#getPersister(java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#getSessionProperty(java.lang.String), org.grails.datastore.mapping.core.AbstractSession#getTransaction(), org.grails.datastore.mapping.core.AbstractSession#hasTransaction(), org.grails.datastore.mapping.core.AbstractSession#hashCode(), org.grails.datastore.mapping.core.AbstractSession#insert(java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#isCached(java.lang.Class, java.io.Serializable), org.grails.datastore.mapping.core.AbstractSession#isConnected(), org.grails.datastore.mapping.core.AbstractSession#isDirty(java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#isPendingAlready(java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#isSchemaless(), org.grails.datastore.mapping.core.AbstractSession#isStateless(), org.grails.datastore.mapping.core.AbstractSession#isStateless(org.grails.datastore.mapping.model.PersistentEntity), org.grails.datastore.mapping.core.AbstractSession#lock(java.lang.Class, java.io.Serializable), org.grails.datastore.mapping.core.AbstractSession#lock(java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#merge(java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#notify(), org.grails.datastore.mapping.core.AbstractSession#notifyAll(), org.grails.datastore.mapping.core.AbstractSession#persist(java.lang.Iterable), org.grails.datastore.mapping.core.AbstractSession#persist(java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#proxy(java.lang.Class, java.io.Serializable), org.grails.datastore.mapping.core.AbstractSession#refresh(java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#registerPending(java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#retrieve(java.lang.Class, java.io.Serializable), org.grails.datastore.mapping.core.AbstractSession#retrieveAll(java.lang.Class, [Ljava.io.Serializable;), org.grails.datastore.mapping.core.AbstractSession#retrieveAll(java.lang.Class, java.lang.Iterable), org.grails.datastore.mapping.core.AbstractSession#setAttribute(java.lang.Object, java.lang.String, java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#setFlushMode(jakarta.persistence.FlushModeType), org.grails.datastore.mapping.core.AbstractSession#setSessionProperty(java.lang.String, java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#setSynchronizedWithTransaction(boolean), org.grails.datastore.mapping.core.AbstractSession#toString(), org.grails.datastore.mapping.core.AbstractSession#unlock(java.lang.Object), org.grails.datastore.mapping.core.AbstractSession#updateAll(org.grails.datastore.mapping.query.api.QueryableCriteria, java.util.Map), org.grails.datastore.mapping.core.AbstractSession#wait(), org.grails.datastore.mapping.core.AbstractSession#wait(long), org.grails.datastore.mapping.core.AbstractSession#wait(long, int)