MongoDatastore (Grails 8.0.0-SNAPSHOT)

org.grails.datastore.mapping.mongo.MongoDatastore

All Implemented Interfaces and Traits:

MappingContextListener, java.io.Closeable, MultiTenantCapableDatastore, MultipleConnectionSourceCapableDatastore, SmartLifecycle, StatelessDatastore, TransactionCapableDatastore
```
public class MongoDatastore
extends AbstractDatastore
implements MappingContextListener, java.io.Closeable, MultiTenantCapableDatastore, MultipleConnectionSourceCapableDatastore, SmartLifecycle, StatelessDatastore, TransactionCapableDatastore
```
A Datastore implementation for the Mongo document store.
Authors:
Graeme Rocher
Since:
1.0

Field Summary

Fields
Modifiers	Name	Description
`static java.lang.String`	`CODEC_ENGINE`
`static java.lang.String`	`INDEX_ATTRIBUTES`
`static java.lang.String`	`INDEX_EXPIRE_AFTER_SECONDS`	TTL index attribute.
`static java.lang.String`	`INDEX_RECREATE_ON_CONFLICT`	Opt-in index attribute: when an index already exists on the same keys with conflicting options that cannot be reconciled in place (i.e. anything other than a TTL change), drop the existing index and recreate it with the declared options instead of just logging the conflict.
`static int`	`LIFECYCLE_PHASE`	Below the web server's phase so the client outlives the requests using it, and above `EmbeddedMongoLifecycle.PHASE` so an embedded server outlives this client: Spring starts in ascending phase order and stops in descending.
`static java.lang.String`	`SETTING_CONNECTION_STRING`
`static java.lang.String`	`SETTING_DATABASE_NAME`
`static java.lang.String`	`SETTING_DEFAULT_MAPPING`
`static java.lang.String`	`SETTING_ENGINE`
`static java.lang.String`	`SETTING_HOST`
`static java.lang.String`	`SETTING_OPTIONS`
`static java.lang.String`	`SETTING_PASSWORD`
`static java.lang.String`	`SETTING_PORT`
`static java.lang.String`	`SETTING_STATELESS`
`static java.lang.String`	`SETTING_URL`
`static java.lang.String`	`SETTING_USERNAME`
`protected AutoTimestampEventListener`	`autoTimestampEventListener`
`protected boolean`	`codecEngine`
`protected CodecRegistry`	`codecRegistry`
`protected ConnectionSources<MongoClient, MongoConnectionSourceSettings>`	`connectionSources`
`protected java.util.Map<java.lang.String, MongoDatastore>`	`datastoresByConnectionSource`
`protected java.lang.String`	`defaultDatabase`
`protected FlushModeType`	`defaultFlushMode`
`protected ConfigurableApplicationEventPublisher`	`eventPublisher`
`protected GormEnhancer`	`gormEnhancer`
`protected MongoClient`	`mongo`	Not final because start() replaces it after a CRaC restore.
`protected java.util.Map<PersistentEntity, java.lang.String>`	`mongoCollections`
`protected java.util.Map<PersistentEntity, java.lang.String>`	`mongoDatabases`
`protected MultiTenancyMode`	`multiTenancyMode`
`protected boolean`	`stateless`
`protected TenantResolver`	`tenantResolver`
`protected PlatformTransactionManager`	`transactionManager`
`protected boolean`	`transactionsEnabled`

Inherited fields
Fields inherited from class	Fields
`class AbstractDatastore`	`LOG, applicationEventPublisher, cacheAdapterRepository, connectionDetails, mappingContext, serviceRegistry`

Constructor Summary

Constructors
Constructor and description
`MongoDatastore(ConnectionSources<MongoClient, MongoConnectionSourceSettings> connectionSources, MongoMappingContext mappingContext, ConfigurableApplicationEventPublisher eventPublisher)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(ConnectionSources<MongoClient, MongoConnectionSourceSettings> connectionSources, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, MongoMappingContext mappingContext, ConfigurableApplicationEventPublisher eventPublisher)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Package packages)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, java.lang.Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, java.lang.Package packages)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(MongoClient mongoClient, java.lang.Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(Builder clientOptions, PropertyResolver configuration, MongoMappingContext mappingContext, ConfigurableApplicationEventPublisher eventPublisher)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(Builder clientOptions, PropertyResolver configuration, MongoMappingContext mappingContext)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(PropertyResolver configuration, MongoMappingContext mappingContext, ConfigurableApplicationEventPublisher eventPublisher)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(PropertyResolver configuration, MongoConnectionSourceFactory connectionSourceFactory, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(PropertyResolver configuration, MongoMappingContext mappingContext)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(PropertyResolver configuration, java.lang.Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(java.util.Map<java.lang.String, java.lang.Object> configuration, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(java.util.Map<java.lang.String, java.lang.Object> configuration, java.lang.Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(java.util.Map<java.lang.String, java.lang.Object> configuration)` Creates a MongoDatastore with the given configuration
`MongoDatastore(java.util.Map<java.lang.String, java.lang.Object> configuration, MongoMappingContext mappingContext)`
`MongoDatastore(MongoMappingContext mappingContext)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(java.lang.Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(java.lang.Package packagesToScan)` Construct a Mongo datastore scanning the given packages
`MongoDatastore(java.lang.Package packageToScan)` Construct a Mongo datastore scanning the given package
`MongoDatastore(PropertyResolver configuration, java.lang.Package packagesToScan)` Construct a Mongo datastore scanning the given packages
`MongoDatastore(java.util.Map<java.lang.String, java.lang.Object> configuration, java.lang.Package packagesToScan)` Construct a Mongo datastore scanning the given packages
`MongoDatastore(PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Package packagesToScan)` Construct a Mongo datastore scanning the given packages

Methods Summary

Methods
Type Params	Return Type	Name and description
	`public void`	`buildIndex()` Builds the MongoDB index for this datastore
	`public void`	`close()`
	`protected static ConnectionSources<MongoClient, MongoConnectionSourceSettings>`	`createDefaultConnectionSources(MongoClient mongoClient, PropertyResolver configuration, MongoMappingContext mappingContext, boolean closeable)` Creates the connection sources for a MongoClient.
	`protected static MongoMappingContext`	`createMappingContext(ConnectionSources<MongoClient, MongoConnectionSourceSettings> connectionSources, java.lang.Class classes)`
	`protected static MongoMappingContext`	`createMappingContext(PropertyResolver configuration, java.lang.Class classes)`
	`protected static MongoClient`	`createMongoClient(PropertyResolver configuration, Builder mongoOptions, MongoMappingContext mappingContext)`
	`protected Session`	`createSession(PropertyResolver connDetails)`
	`protected Session`	`createStatelessSession(PropertyResolver connectionDetails)`
	`public ConfigurableApplicationEventPublisher`	`getApplicationEventPublisher()` Returns: The ConfigurableApplicationEventPublisher instance used by this datastore
	`public AutoTimestampEventListener`	`getAutoTimestampEventListener()`
	`public CodecRegistry`	`getCodecRegistry()` Returns: The CodecRegistry
	`public com.mongodb.client.MongoCollection<Document>`	`getCollection(PersistentEntity entity)` Obtain the raw com.mongodb.client.MongoCollection for the given entity
	`public java.lang.String`	`getCollectionName(PersistentEntity entity)` Gets the default collection name for the given entity
	`public ConnectionSources<MongoClient, MongoConnectionSourceSettings>`	`getConnectionSources()` Returns: The ConnectionSources for this datastore
	`public java.lang.String`	`getDatabaseName(PersistentEntity entity)`
	`public MongoDatastore`	`getDatastoreForConnection(java.lang.String connectionName)`
	`public Datastore`	`getDatastoreForConnection(java.lang.String connectionName)`
	`public MongoDatastore`	`getDatastoreForTenantId(java.io.Serializable tenantId)`
	`public java.lang.String`	`getDefaultDatabase()` Returns: The default database name
	`public FlushModeType`	`getDefaultFlushMode()` Returns: The default flush mode
`<D>`	`protected GormInstanceApi<D>`	`getInstanceApi(java.lang.Class<D> cls, java.lang.String qualifier)`
	`public MongoMappingContext`	`getMappingContext()` Returns: The mapping context
	`public MongoClient`	`getMongoClient()` Returns: The MongoClient instance
	`public MultiTenancyMode`	`getMultiTenancyMode()`
	`public PersistentEntityCodec`	`getPersistentEntityCodec(PersistentEntity entity)` Obtains a PersistentEntityCodec for the given entity
	`public PersistentEntityCodec`	`getPersistentEntityCodec(java.lang.Class entityClass)` Obtains a PersistentEntityCodec for the given entity
	`public int`	`getPhase()`
`<D>`	`protected MongoStaticApi<D>`	`getStaticApi(java.lang.Class<D> cls, java.lang.String qualifier)`
	`public TenantResolver`	`getTenantResolver()`
	`public PlatformTransactionManager`	`getTransactionManager()` Returns: The transaction manager
`<D>`	`protected GormValidationApi<D>`	`getValidationApi(java.lang.Class<D> cls, java.lang.String qualifier)`
	`protected MongoGormEnhancer`	`initialize(MongoConnectionSourceSettings settings)`
	`protected MongoGormEnhancer`	`initialize(MongoConnectionSourceSettings settings)` Runs the initialization sequence
	`protected void`	`initializeIndices(PersistentEntity entity)` Indexes any properties that are mapped with index:true
	`public boolean`	`isRunning()`
	`public boolean`	`isSchemaless()`
	`public boolean`	`isTransactionsEnabled()` Whether GORM should use real MongoDB multi-document transactions (a server-side `ClientSession`) for transactional operations.
	`public void`	`newConnectionSource(ConnectionSource<MongoClient, MongoConnectionSourceSettings> connectionSource)`
	`public void`	`persistentEntityAdded(PersistentEntity entity)`
	`public void`	`persistentEntityAdded(PersistentEntity entity)`
	`protected void`	`registerAllEntitiesWithEnhancer()`
	`protected void`	`registerEntity(PersistentEntity entity)`
	`protected void`	`registerEventListeners(ConfigurableApplicationEventPublisher eventPublisher)`
	`public java.io.Serializable`	`resolveTenantIdentifier()`
	`public java.lang.Iterable<java.io.Serializable>`	`resolveTenantIds()`
	`public void`	`setCodecProviders(java.util.List<CodecProvider> codecProviders)` Sets any additional codec providers
	`public void`	`setCodecRegistries(java.util.List<CodecRegistry> codecRegistries)` Sets any additional codec registries
	`public void`	`setCodecs(java.util.List<Codec<?>> codecs)` Sets any additional codecs
	`public void`	`setMessageSource(java.util.List<MessageSource> messageSources)` The message source used for validation messages
	`public void`	`setMessageSource(MessageSource messageSource)`
	`public void`	`start()` Builds a replacement MongoClient after a restore, using the same factory and configuration the original was built from, so settings applied at startup still apply.
	`public void`	`stop()` Closes the MongoClient so the process can be checkpointed.
`<T1>`	`public T1`	`withNewSession(java.io.Serializable tenantId, groovy.lang.Closure<T1> callable)`

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class AbstractDatastore`	`connect, connect, connectStateless, createSession, createStatelessSession, destroy, doInSession, getApplicationContext, getApplicationEventPublisher, getCurrentSession, getMappingContext, getService, getServices, getSessionResolver, hasCurrentSession, initializeConverters, isIndexed, isSchemaless, mapToPropertyResolver, retrieveSession, retrieveSession, setApplicationContext, withSession`

- Field Detail
  - public static final java.lang.String CODEC_ENGINE
  - public static final java.lang.String INDEX_ATTRIBUTES
  - public static final java.lang.String INDEX_EXPIRE_AFTER_SECONDS
    
    TTL index attribute. MongoDB's IndexOptions#expireAfter(Long, TimeUnit)#expireAfter(Long, TimeUnit) is the only way to set a TTL, but it is a two-argument setter that MongoConstants.mapToObject cannot reach (that helper only invokes single-argument setters). So expireAfterSeconds is pulled out of the index attributes and applied explicitly. TTL indexes are single-field only — MongoDB silently ignores the option on a compound index.
  - public static final java.lang.String INDEX_RECREATE_ON_CONFLICT
    
    Opt-in index attribute: when an index already exists on the same keys with conflicting options that cannot be reconciled in place (i.e. anything other than a TTL change), drop the existing index and recreate it with the declared options instead of just logging the conflict.
  - public static final int LIFECYCLE_PHASE
    
    Below the web server's phase so the client outlives the requests using it, and above EmbeddedMongoLifecycle.PHASE so an embedded server outlives this client: Spring starts in ascending phase order and stops in descending.
  - public static final java.lang.String SETTING_CONNECTION_STRING
  - public static final java.lang.String SETTING_DATABASE_NAME
  - public static final java.lang.String SETTING_DEFAULT_MAPPING
  - public static final java.lang.String SETTING_ENGINE
  - public static final java.lang.String SETTING_HOST
  - public static final java.lang.String SETTING_OPTIONS
  - public static final java.lang.String SETTING_PASSWORD
  - public static final java.lang.String SETTING_PORT
  - public static final java.lang.String SETTING_STATELESS
  - public static final java.lang.String SETTING_URL
  - public static final java.lang.String SETTING_USERNAME
  - protected final AutoTimestampEventListener autoTimestampEventListener
  - protected final boolean codecEngine
  - protected CodecRegistry codecRegistry
  - protected final ConnectionSources<MongoClient, MongoConnectionSourceSettings> connectionSources
  - protected final java.util.Map<java.lang.String, MongoDatastore> datastoresByConnectionSource
  - protected final java.lang.String defaultDatabase
  - protected final FlushModeType defaultFlushMode
  - protected final ConfigurableApplicationEventPublisher eventPublisher
  - protected final GormEnhancer gormEnhancer
  - protected MongoClient mongo
    
    Not final because start() replaces it after a CRaC restore. Everything other than construction reaches it through getMongoClient(), so a replacement is picked up without anything else having to be told.
  - protected final java.util.Map<PersistentEntity, java.lang.String> mongoCollections
  - protected final java.util.Map<PersistentEntity, java.lang.String> mongoDatabases
  - protected final MultiTenancyMode multiTenancyMode
  - protected final boolean stateless
  - protected final TenantResolver tenantResolver
  - protected final PlatformTransactionManager transactionManager
  - protected final boolean transactionsEnabled
- Constructor Detail
  - public MongoDatastore(ConnectionSources<MongoClient, MongoConnectionSourceSettings> connectionSources, MongoMappingContext mappingContext, ConfigurableApplicationEventPublisher eventPublisher)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    connectionSources - The ConnectionSources to use
    eventPublisher - The Spring ApplicationContext
    mappingContext - The mapping context
  - public MongoDatastore(ConnectionSources<MongoClient, MongoConnectionSourceSettings> connectionSources, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Class classes)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    connectionSources - The ConnectionSources to use
    eventPublisher - The Spring ApplicationContext
    classes - The persistent classes
  - public MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, MongoMappingContext mappingContext, ConfigurableApplicationEventPublisher eventPublisher)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    mongoClient - The MongoClient instance
    eventPublisher - The Spring ApplicationContext
    mappingContext - The mapping context
  - public MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Class classes)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    mongoClient - The MongoClient instance
    eventPublisher - The Spring ApplicationContext
    classes - The persistent classes
  - public MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Package packages)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    mongoClient - The MongoClient instance
    eventPublisher - The Spring ApplicationContext
    packages - The packages to scan
  - public MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, java.lang.Class classes)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    mongoClient - The MongoClient instance
    classes - The persistent classes
  - public MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, java.lang.Package packages)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    mongoClient - The MongoClient instance
    packages - The packages to scan
  - public MongoDatastore(MongoClient mongoClient, java.lang.Class classes)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    mongoClient - The MongoClient instance
    classes - The persistent classes
  - public MongoDatastore(Builder clientOptions, PropertyResolver configuration, MongoMappingContext mappingContext, ConfigurableApplicationEventPublisher eventPublisher)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    clientOptions - The MongoClientSettings instance
    configuration - The configuration
    eventPublisher - The Spring ApplicationContext
    mappingContext - The mapping context
  - public MongoDatastore(Builder clientOptions, PropertyResolver configuration, MongoMappingContext mappingContext)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    clientOptions - The MongoClientSettings instance
    configuration - The configuration
    mappingContext - The mapping context
  - public MongoDatastore(PropertyResolver configuration, MongoMappingContext mappingContext, ConfigurableApplicationEventPublisher eventPublisher)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    configuration - The configuration for the datastore
    eventPublisher - The Spring ApplicationContext
    mappingContext - The mapping context
  - public MongoDatastore(PropertyResolver configuration, MongoConnectionSourceFactory connectionSourceFactory, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Class classes)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    configuration - The configuration for the datastore
    eventPublisher - The Spring ApplicationContext
    connectionSourceFactory - The connection source factory to use
    classes - The persistent classes
  - public MongoDatastore(PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Class classes)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    configuration - The configuration for the datastore
    eventPublisher - The Spring ApplicationContext
    classes - The persistent classes
  - public MongoDatastore(PropertyResolver configuration, MongoMappingContext mappingContext)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    configuration - The configuration for the datastore
    mappingContext - The mapping context
  - public MongoDatastore(PropertyResolver configuration, java.lang.Class classes)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    configuration - The configuration for the datastore
    classes - The persistent classes
  - public MongoDatastore(java.util.Map<java.lang.String, java.lang.Object> configuration, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Class classes)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    configuration - The configuration
    eventPublisher - The event publisher
    classes - The persistent classes
  - public MongoDatastore(java.util.Map<java.lang.String, java.lang.Object> configuration, java.lang.Class classes)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    configuration - The configuration
    classes - The persistent classes
  - public MongoDatastore(java.util.Map<java.lang.String, java.lang.Object> configuration)
    
    Creates a MongoDatastore with the given configuration
    Parameters:
    configuration - The configuration
  - public MongoDatastore(java.util.Map<java.lang.String, java.lang.Object> configuration, MongoMappingContext mappingContext)
  - public MongoDatastore(MongoMappingContext mappingContext)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    mappingContext - The MongoMappingContext
  - public MongoDatastore(java.lang.Class classes)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    classes - The persistent classes
  - public MongoDatastore(java.lang.Package packagesToScan)
    
    Construct a Mongo datastore scanning the given packages
    Parameters:
    packagesToScan - The packages to scan
  - public MongoDatastore(java.lang.Package packageToScan)
    
    Construct a Mongo datastore scanning the given package
    Parameters:
    packageToScan - The packages to scan
  - public MongoDatastore(PropertyResolver configuration, java.lang.Package packagesToScan)
    
    Construct a Mongo datastore scanning the given packages
    Parameters:
    configuration - The configuration
    packagesToScan - The packages to scan
  - public MongoDatastore(java.util.Map<java.lang.String, java.lang.Object> configuration, java.lang.Package packagesToScan)
    
    Construct a Mongo datastore scanning the given packages
    Parameters:
    configuration - The configuration
    packagesToScan - The packages to scan
  - public MongoDatastore(PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Package packagesToScan)
    
    Construct a Mongo datastore scanning the given packages
    Parameters:
    configuration - The configuration
    eventPublisher - The event publisher
    packagesToScan - The packages to scan
- Method Detail
  - public void buildIndex()
    
    Builds the MongoDB index for this datastore
  - @java.lang.Override
    @jakarta.annotation.PreDestroy
    public void close()
  - protected static ConnectionSources<MongoClient, MongoConnectionSourceSettings> createDefaultConnectionSources(MongoClient mongoClient, PropertyResolver configuration, MongoMappingContext mappingContext, boolean closeable)
    
    Creates the connection sources for a MongoClient.
    Parameters:
    mongoClient - The MongoClient
    configuration - The configuration
    mappingContext - The MongoMappingContext
    closeable - whether GORM owns the client and should close it on shutdown. Pass false for an externally-supplied client (its lifecycle is owned by the caller, e.g. a Spring-managed bean) and true for a client GORM created itself, so it is not leaked.
    Returns:
    The ConnectionSources
  - protected static MongoMappingContext createMappingContext(ConnectionSources<MongoClient, MongoConnectionSourceSettings> connectionSources, java.lang.Class classes)
  - protected static MongoMappingContext createMappingContext(PropertyResolver configuration, java.lang.Class classes)
  - protected static MongoClient createMongoClient(PropertyResolver configuration, Builder mongoOptions, MongoMappingContext mappingContext)
  - @java.lang.Override
    protected Session createSession(PropertyResolver connDetails)
  - @java.lang.Override
    protected Session createStatelessSession(PropertyResolver connectionDetails)
  - @java.lang.Override
    public ConfigurableApplicationEventPublisher getApplicationEventPublisher()
    
    Returns:
    The ConfigurableApplicationEventPublisher instance used by this datastore
  - public AutoTimestampEventListener getAutoTimestampEventListener()
  - public CodecRegistry getCodecRegistry()
    
    Returns:
    The CodecRegistry
  - public com.mongodb.client.MongoCollection<Document> getCollection(PersistentEntity entity)
    
    Obtain the raw com.mongodb.client.MongoCollection for the given entity
    Parameters:
    entity - The entity
    Returns:
    The Mongo collection
  - public java.lang.String getCollectionName(PersistentEntity entity)
    
    Gets the default collection name for the given entity
    Parameters:
    entity - The entity
    Returns:
    The collection name
  - public ConnectionSources<MongoClient, MongoConnectionSourceSettings> getConnectionSources()
    
    Returns:
    The ConnectionSources for this datastore
  - public java.lang.String getDatabaseName(PersistentEntity entity)
  - @java.lang.Override
    public MongoDatastore getDatastoreForConnection(java.lang.String connectionName)
  - @java.lang.Override
    public Datastore getDatastoreForConnection(java.lang.String connectionName)
  - @java.lang.Override
    public MongoDatastore getDatastoreForTenantId(java.io.Serializable tenantId)
  - public java.lang.String getDefaultDatabase()
    
    Returns:
    The default database name
  - public FlushModeType getDefaultFlushMode()
    
    Returns:
    The default flush mode
  - <D> @java.lang.Override
    protected GormInstanceApi<D> getInstanceApi(java.lang.Class<D> cls, java.lang.String qualifier)
  - @java.lang.Override
    public MongoMappingContext getMappingContext()
    
    Returns:
    The mapping context
  - public MongoClient getMongoClient()
    
    Returns:
    The MongoClient instance
  - @java.lang.Override
    public MultiTenancyMode getMultiTenancyMode()
  - public PersistentEntityCodec getPersistentEntityCodec(PersistentEntity entity)
    
    Obtains a PersistentEntityCodec for the given entity
    Parameters:
    entity - The entity
    Returns:
    The PersistentEntityCodec
  - public PersistentEntityCodec getPersistentEntityCodec(java.lang.Class entityClass)
    
    Obtains a PersistentEntityCodec for the given entity
    Parameters:
    entityClass - The entity class
    Returns:
    The PersistentEntityCodec
  - @java.lang.Override
    public int getPhase()
  - <D> @java.lang.Override
    protected MongoStaticApi<D> getStaticApi(java.lang.Class<D> cls, java.lang.String qualifier)
  - @java.lang.Override
    public TenantResolver getTenantResolver()
  - public PlatformTransactionManager getTransactionManager()
    
    Returns:
    The transaction manager
  - <D> @java.lang.Override
    protected GormValidationApi<D> getValidationApi(java.lang.Class<D> cls, java.lang.String qualifier)
  - @java.lang.Override
    protected MongoGormEnhancer initialize(MongoConnectionSourceSettings settings)
  - protected MongoGormEnhancer initialize(MongoConnectionSourceSettings settings)
    
    Runs the initialization sequence
    Parameters:
    settings
  - protected void initializeIndices(PersistentEntity entity)
    
    Indexes any properties that are mapped with index:true
    Parameters:
    entity - The entity
  - @java.lang.Override
    public boolean isRunning()
  - @java.lang.Override
    public boolean isSchemaless()
  - public boolean isTransactionsEnabled()
    
    Whether GORM should use real MongoDB multi-document transactions (a server-side ClientSession) for transactional operations. This is opt-in via grails.mongodb.transactional and additionally requires a replica set or sharded cluster; if a standalone topology is positively detected the feature is disabled (with a one-time warning) and GORM falls back to the legacy client-side flush behavior.
    Returns:
    true if server-side transactions should be used
    Since:
    8.0
  - public void newConnectionSource(ConnectionSource<MongoClient, MongoConnectionSourceSettings> connectionSource)
  - @java.lang.Override
    public void persistentEntityAdded(PersistentEntity entity)
  - public void persistentEntityAdded(PersistentEntity entity)
  - protected void registerAllEntitiesWithEnhancer()
  - protected void registerEntity(PersistentEntity entity)
  - protected void registerEventListeners(ConfigurableApplicationEventPublisher eventPublisher)
  - @java.lang.Override
    public java.io.Serializable resolveTenantIdentifier()
  - @java.lang.Override
    public java.lang.Iterable<java.io.Serializable> resolveTenantIds()
  - @org.springframework.beans.factory.annotation.Autowired(required = false)
    public void setCodecProviders(java.util.List<CodecProvider> codecProviders)
    
    Sets any additional codec providers
    Parameters:
    codecProviders - The CodecProvider instances
  - @org.springframework.beans.factory.annotation.Autowired(required = false)
    public void setCodecRegistries(java.util.List<CodecRegistry> codecRegistries)
    
    Sets any additional codec registries
    Parameters:
    codecRegistries - The CodecRegistry instances
  - @org.springframework.beans.factory.annotation.Autowired(required = false)
    public void setCodecs(java.util.List<Codec<?>> codecs)
    
    Sets any additional codecs
    Parameters:
    codecs - The Codec instances
  - @org.springframework.beans.factory.annotation.Autowired(required = false)
    public void setMessageSource(java.util.List<MessageSource> messageSources)
    
    The message source used for validation messages
    Parameters:
    messageSources - The message source
  - public void setMessageSource(MessageSource messageSource)
  - @java.lang.Override
    public void start()
    
    Builds a replacement MongoClient after a restore, using the same factory and configuration the original was built from, so settings applied at startup still apply.
  - @java.lang.Override
    public void stop()
    
    Closes the MongoClient so the process can be checkpointed.
    CRaC refuses to checkpoint a process holding open sockets, and a connected driver holds one per pooled connection plus its server monitors. Closing the client shuts the monitor threads down and releases every socket, which nothing else in the driver offers: draining the pool leaves the monitors connected.
    A client the application supplied is left alone. Its lifecycle belongs to whoever created it, and this datastore stays running so that start() does not later replace something it does not own.
  - <T1> @java.lang.Override
    public T1 withNewSession(java.io.Serializable tenantId, groovy.lang.Closure<T1> callable)

Summary:
Field
Constructor
Method

| Detail:
Field
Constructor
Method

[Java] Class MongoDatastore

Field Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

public static final java.lang.String CODEC_ENGINE

public static final java.lang.String INDEX_ATTRIBUTES

public static final java.lang.String INDEX_EXPIRE_AFTER_SECONDS

public static final java.lang.String INDEX_RECREATE_ON_CONFLICT

public static final int LIFECYCLE_PHASE

public static final java.lang.String SETTING_CONNECTION_STRING

public static final java.lang.String SETTING_DATABASE_NAME

public static final java.lang.String SETTING_DEFAULT_MAPPING

public static final java.lang.String SETTING_ENGINE

public static final java.lang.String SETTING_HOST

public static final java.lang.String SETTING_OPTIONS

public static final java.lang.String SETTING_PASSWORD

public static final java.lang.String SETTING_PORT

public static final java.lang.String SETTING_STATELESS

public static final java.lang.String SETTING_URL

public static final java.lang.String SETTING_USERNAME

protected final AutoTimestampEventListener autoTimestampEventListener

protected final boolean codecEngine

protected CodecRegistry codecRegistry

protected final ConnectionSources<MongoClient, MongoConnectionSourceSettings> connectionSources

protected final java.util.Map<java.lang.String, MongoDatastore> datastoresByConnectionSource

protected final java.lang.String defaultDatabase

protected final FlushModeType defaultFlushMode

protected final ConfigurableApplicationEventPublisher eventPublisher

protected final GormEnhancer gormEnhancer

protected MongoClient mongo

protected final java.util.Map<PersistentEntity, java.lang.String> mongoCollections

protected final java.util.Map<PersistentEntity, java.lang.String> mongoDatabases

protected final MultiTenancyMode multiTenancyMode

protected final boolean stateless

protected final TenantResolver tenantResolver

protected final PlatformTransactionManager transactionManager

protected final boolean transactionsEnabled

Constructor Detail

public MongoDatastore(ConnectionSources<MongoClient, MongoConnectionSourceSettings> connectionSources, MongoMappingContext mappingContext, ConfigurableApplicationEventPublisher eventPublisher)

public MongoDatastore(ConnectionSources<MongoClient, MongoConnectionSourceSettings> connectionSources, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Class classes)

public MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, MongoMappingContext mappingContext, ConfigurableApplicationEventPublisher eventPublisher)

public MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Class classes)

public MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Package packages)

public MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, java.lang.Class classes)

public MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, java.lang.Package packages)

public MongoDatastore(MongoClient mongoClient, java.lang.Class classes)

public MongoDatastore(Builder clientOptions, PropertyResolver configuration, MongoMappingContext mappingContext, ConfigurableApplicationEventPublisher eventPublisher)

public MongoDatastore(Builder clientOptions, PropertyResolver configuration, MongoMappingContext mappingContext)

public MongoDatastore(PropertyResolver configuration, MongoMappingContext mappingContext, ConfigurableApplicationEventPublisher eventPublisher)

public MongoDatastore(PropertyResolver configuration, MongoConnectionSourceFactory connectionSourceFactory, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Class classes)

public MongoDatastore(PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Class classes)

public MongoDatastore(PropertyResolver configuration, MongoMappingContext mappingContext)

public MongoDatastore(PropertyResolver configuration, java.lang.Class classes)

public MongoDatastore(java.util.Map<java.lang.String, java.lang.Object> configuration, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Class classes)

public MongoDatastore(java.util.Map<java.lang.String, java.lang.Object> configuration, java.lang.Class classes)

public MongoDatastore(java.util.Map<java.lang.String, java.lang.Object> configuration)

public MongoDatastore(java.util.Map<java.lang.String, java.lang.Object> configuration, MongoMappingContext mappingContext)

public MongoDatastore(MongoMappingContext mappingContext)

public MongoDatastore(java.lang.Class classes)

public MongoDatastore(java.lang.Package packagesToScan)

public MongoDatastore(java.lang.Package packageToScan)

public MongoDatastore(PropertyResolver configuration, java.lang.Package packagesToScan)

public MongoDatastore(java.util.Map<java.lang.String, java.lang.Object> configuration, java.lang.Package packagesToScan)

public MongoDatastore(PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, java.lang.Package packagesToScan)

Method Detail

public void buildIndex()

@java.lang.Override@jakarta.annotation.PreDestroypublic void close()

protected static ConnectionSources<MongoClient, MongoConnectionSourceSettings> createDefaultConnectionSources(MongoClient mongoClient, PropertyResolver configuration, MongoMappingContext mappingContext, boolean closeable)

protected static MongoMappingContext createMappingContext(ConnectionSources<MongoClient, MongoConnectionSourceSettings> connectionSources, java.lang.Class classes)

protected static MongoMappingContext createMappingContext(PropertyResolver configuration, java.lang.Class classes)

protected static MongoClient createMongoClient(PropertyResolver configuration, Builder mongoOptions, MongoMappingContext mappingContext)

@java.lang.Overrideprotected Session createSession(PropertyResolver connDetails)

@java.lang.Overrideprotected Session createStatelessSession(PropertyResolver connectionDetails)

@java.lang.Overridepublic ConfigurableApplicationEventPublisher getApplicationEventPublisher()

public AutoTimestampEventListener getAutoTimestampEventListener()

public CodecRegistry getCodecRegistry()

public com.mongodb.client.MongoCollection<Document> getCollection(PersistentEntity entity)

public java.lang.String getCollectionName(PersistentEntity entity)

@java.lang.Override
@jakarta.annotation.PreDestroy
public void close()

@java.lang.Override
protected Session createSession(PropertyResolver connDetails)

@java.lang.Override
protected Session createStatelessSession(PropertyResolver connectionDetails)

@java.lang.Override
public ConfigurableApplicationEventPublisher getApplicationEventPublisher()

@java.lang.Override
public MongoDatastore getDatastoreForConnection(java.lang.String connectionName)

@java.lang.Override
public Datastore getDatastoreForConnection(java.lang.String connectionName)

@java.lang.Override
public MongoDatastore getDatastoreForTenantId(java.io.Serializable tenantId)

<D> @java.lang.Override
protected GormInstanceApi<D> getInstanceApi(java.lang.Class<D> cls, java.lang.String qualifier)

@java.lang.Override
public MongoMappingContext getMappingContext()

@java.lang.Override
public MultiTenancyMode getMultiTenancyMode()

@java.lang.Override
public int getPhase()

<D> @java.lang.Override
protected MongoStaticApi<D> getStaticApi(java.lang.Class<D> cls, java.lang.String qualifier)

@java.lang.Override
public TenantResolver getTenantResolver()

<D> @java.lang.Override
protected GormValidationApi<D> getValidationApi(java.lang.Class<D> cls, java.lang.String qualifier)

@java.lang.Override
protected MongoGormEnhancer initialize(MongoConnectionSourceSettings settings)

@java.lang.Override
public boolean isRunning()

@java.lang.Override
public boolean isSchemaless()

@java.lang.Override
public void persistentEntityAdded(PersistentEntity entity)

@java.lang.Override
public java.io.Serializable resolveTenantIdentifier()

@java.lang.Override
public java.lang.Iterable<java.io.Serializable> resolveTenantIds()

@org.springframework.beans.factory.annotation.Autowired(required = false)
public void setCodecProviders(java.util.List<CodecProvider> codecProviders)

@org.springframework.beans.factory.annotation.Autowired(required = false)
public void setCodecRegistries(java.util.List<CodecRegistry> codecRegistries)

@org.springframework.beans.factory.annotation.Autowired(required = false)
public void setCodecs(java.util.List<Codec<?>> codecs)

@org.springframework.beans.factory.annotation.Autowired(required = false)
public void setMessageSource(java.util.List<MessageSource> messageSources)

@java.lang.Override
public void start()

@java.lang.Override
public void stop()

<T1> @java.lang.Override
public T1 withNewSession(java.io.Serializable tenantId, groovy.lang.Closure<T1> callable)