MongoDatastore (Grace Data MongoDB

org.grails.datastore.mapping.mongo.MongoDatastore

All Implemented Interfaces and Traits:

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

Field Summary

Fields
Modifiers	Name	Description
`static String`	`CODEC_ENGINE`
`static String`	`INDEX_ATTRIBUTES`
`static String`	`SETTING_CONNECTION_STRING`
`static String`	`SETTING_DATABASE_NAME`
`static String`	`SETTING_DEFAULT_MAPPING`
`static String`	`SETTING_ENGINE`
`static String`	`SETTING_HOST`
`static String`	`SETTING_OPTIONS`
`static String`	`SETTING_PASSWORD`
`static String`	`SETTING_PORT`
`static String`	`SETTING_STATELESS`
`static String`	`SETTING_URL`
`static String`	`SETTING_USERNAME`
`protected AutoTimestampEventListener`	`autoTimestampEventListener`
`protected boolean`	`codecEngine`
`protected CodecRegistry`	`codecRegistry`
`protected ConnectionSources<MongoClient, MongoConnectionSourceSettings>`	`connectionSources`
`protected Map<String, MongoDatastore>`	`datastoresByConnectionSource`
`protected String`	`defaultDatabase`
`protected FlushModeType`	`defaultFlushMode`
`protected ConfigurableApplicationEventPublisher`	`eventPublisher`
`protected GormEnhancer`	`gormEnhancer`
`protected MongoClient`	`mongo`
`protected Map<PersistentEntity, String>`	`mongoCollections`
`protected Map<PersistentEntity, String>`	`mongoDatabases`
`protected MultiTenancySettings.MultiTenancyMode`	`multiTenancyMode`
`protected boolean`	`stateless`
`protected TenantResolver`	`tenantResolver`
`protected PlatformTransactionManager`	`transactionManager`

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, 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, Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, Package packages)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, Package packages)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(MongoClient mongoClient, Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(MongoClientSettings.Builder clientOptions, PropertyResolver configuration, MongoMappingContext mappingContext, ConfigurableApplicationEventPublisher eventPublisher)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(MongoClientSettings.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, Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, 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, Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(Map<String, Object> configuration, ConfigurableApplicationEventPublisher eventPublisher, Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(Map<String, Object> configuration, Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(Map<String, Object> configuration)` Creates a MongoDatastore with the given configuration
`MongoDatastore(Map<String, Object> configuration, MongoMappingContext mappingContext)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(MongoMappingContext mappingContext)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(Class classes)` Configures a new MongoDatastore for the given arguments
`MongoDatastore(Package packagesToScan)` Construct a Mongo datastore scanning the given packages
`MongoDatastore(Package packageToScan)` Construct a Mongo datastore scanning the given package
`MongoDatastore(PropertyResolver configuration, Package packagesToScan)` Construct a Mongo datastore scanning the given packages
`MongoDatastore(Map<String, Object> configuration, Package packagesToScan)` Construct a Mongo datastore scanning the given packages
`MongoDatastore(PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, 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)` Creates the connection sources for an existing MongoClient
	`protected static MongoMappingContext`	`createMappingContext(ConnectionSources<MongoClient, MongoConnectionSourceSettings> connectionSources, Class classes)`
	`protected static MongoMappingContext`	`createMappingContext(PropertyResolver configuration, Class classes)`
	`protected static MongoClient`	`createMongoClient(PropertyResolver configuration, MongoClientSettings.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 MongoCollection<Document>`	`getCollection(PersistentEntity entity)` Obtain the raw MongoCollection for the given entity
	`public 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 String`	`getDatabaseName(PersistentEntity entity)`
	`public MongoDatastore`	`getDatastoreForConnection(String connectionName)`
	`public Datastore`	`getDatastoreForConnection(String connectionName)`
	`public MongoDatastore`	`getDatastoreForTenantId(Serializable tenantId)`
	`public String`	`getDefaultDatabase()` Returns: The default database name
	`public FlushModeType`	`getDefaultFlushMode()` Returns: The default flush mode
`<D>`	`protected GormInstanceApi<D>`	`getInstanceApi(Class<D> cls, String qualifier)`
	`public MongoMappingContext`	`getMappingContext()` Returns: The mapping context
	`public MongoClient`	`getMongoClient()` Returns: The MongoClient instance
	`public MultiTenancySettings.MultiTenancyMode`	`getMultiTenancyMode()`
	`public PersistentEntityCodec`	`getPersistentEntityCodec(PersistentEntity entity)` Obtains a PersistentEntityCodec for the given entity
	`public PersistentEntityCodec`	`getPersistentEntityCodec(Class entityClass)` Obtains a PersistentEntityCodec for the given entity
`<D>`	`protected MongoStaticApi<D>`	`getStaticApi(Class<D> cls, String qualifier)`
	`public TenantResolver`	`getTenantResolver()`
	`public PlatformTransactionManager`	`getTransactionManager()` Returns: The transaction manager
`<D>`	`protected GormValidationApi<D>`	`getValidationApi(Class<D> cls, 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`	`isSchemaless()`
	`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 Serializable`	`resolveTenantIdentifier()`
	`public Iterable<Serializable>`	`resolveTenantIds()`
	`public void`	`setCodecProviders(List<CodecProvider> codecProviders)` Sets any additional codec providers
	`public void`	`setCodecRegistries(List<CodecRegistry> codecRegistries)` Sets any additional codec registries
	`public void`	`setCodecs(List<Codec<?>> codecs)` Sets any additional codecs
	`public void`	`setMessageSource(MessageSource messageSource)` The message source used for validation messages
`<T1>`	`public T1`	`withNewSession(Serializable tenantId, Closure<T1> callable)`

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class AbstractDatastore`	`connect, connect, connectStateless, destroy, equals, getApplicationContext, getApplicationEventPublisher, getClass, getCurrentSession, getMappingContext, getService, getServices, hasCurrentSession, hashCode, isSchemaless, notify, notifyAll, retrieveSession, retrieveSession, setApplicationContext, toString, wait, wait, wait, withSession`

- Field Detail
  - public static final String CODEC_ENGINE
  - public static final String INDEX_ATTRIBUTES
  - public static final String SETTING_CONNECTION_STRING
  - public static final String SETTING_DATABASE_NAME
  - public static final String SETTING_DEFAULT_MAPPING
  - public static final String SETTING_ENGINE
  - public static final String SETTING_HOST
  - public static final String SETTING_OPTIONS
  - public static final String SETTING_PASSWORD
  - public static final String SETTING_PORT
  - public static final String SETTING_STATELESS
  - public static final String SETTING_URL
  - public static final String SETTING_USERNAME
  - protected final AutoTimestampEventListener autoTimestampEventListener
  - protected final boolean codecEngine
  - protected CodecRegistry codecRegistry
  - protected final ConnectionSources<MongoClient, MongoConnectionSourceSettings> connectionSources
  - protected final Map<String, MongoDatastore> datastoresByConnectionSource
  - protected final String defaultDatabase
  - protected final FlushModeType defaultFlushMode
  - protected final ConfigurableApplicationEventPublisher eventPublisher
  - protected final GormEnhancer gormEnhancer
  - protected final MongoClient mongo
  - protected final Map<PersistentEntity, String> mongoCollections
  - protected final Map<PersistentEntity, String> mongoDatabases
  - protected final MultiTenancySettings.MultiTenancyMode multiTenancyMode
  - protected final boolean stateless
  - protected final TenantResolver tenantResolver
  - protected final PlatformTransactionManager transactionManager
- 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, 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, 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, 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, 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, Package packages)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    mongoClient - The MongoClient instance
    packages - The packages to scan
  - public MongoDatastore(MongoClient mongoClient, Class classes)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    mongoClient - The MongoClient instance
    classes - The persistent classes
  - public MongoDatastore(MongoClientSettings.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(MongoClientSettings.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, 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, 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, Class classes)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    configuration - The configuration for the datastore
    classes - The persistent classes
  - public MongoDatastore(Map<String, Object> configuration, ConfigurableApplicationEventPublisher eventPublisher, Class classes)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    configuration - The configuration
    eventPublisher - The event publisher
    classes - The persistent classes
  - public MongoDatastore(Map<String, Object> configuration, Class classes)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    configuration - The configuration
    classes - The persistent classes
  - public MongoDatastore(Map<String, Object> configuration)
    
    Creates a MongoDatastore with the given configuration
    Parameters:
    configuration - The configuration
  - public MongoDatastore(Map<String, Object> configuration, MongoMappingContext mappingContext)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    configuration - The configuration
    mappingContext - The MongoMappingContext
  - public MongoDatastore(MongoMappingContext mappingContext)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    mappingContext - The MongoMappingContext
  - public MongoDatastore(Class classes)
    
    Configures a new MongoDatastore for the given arguments
    Parameters:
    classes - The persistent classes
  - public MongoDatastore(Package packagesToScan)
    
    Construct a Mongo datastore scanning the given packages
    Parameters:
    packagesToScan - The packages to scan
  - public MongoDatastore(Package packageToScan)
    
    Construct a Mongo datastore scanning the given package
    Parameters:
    packageToScan - The packages to scan
  - public MongoDatastore(PropertyResolver configuration, Package packagesToScan)
    
    Construct a Mongo datastore scanning the given packages
    Parameters:
    configuration - The configuration
    packagesToScan - The packages to scan
  - public MongoDatastore(Map<String, Object> configuration, 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, 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
  - @Override
    @PreDestroy
    public void close()
  - protected static ConnectionSources<MongoClient, MongoConnectionSourceSettings> createDefaultConnectionSources(MongoClient mongoClient, PropertyResolver configuration, MongoMappingContext mappingContext)
    
    Creates the connection sources for an existing MongoClient
    Parameters:
    mongoClient - The MongoClient
    configuration - The configuration
    mappingContext - The MongoMappingContext
    Returns:
    The ConnectionSources
  - protected static MongoMappingContext createMappingContext(ConnectionSources<MongoClient, MongoConnectionSourceSettings> connectionSources, Class classes)
  - protected static MongoMappingContext createMappingContext(PropertyResolver configuration, Class classes)
  - protected static MongoClient createMongoClient(PropertyResolver configuration, MongoClientSettings.Builder mongoOptions, MongoMappingContext mappingContext)
  - @Override
    protected Session createSession(PropertyResolver connDetails)
  - @Override
    protected Session createStatelessSession(PropertyResolver connectionDetails)
  - @Override
    public ConfigurableApplicationEventPublisher getApplicationEventPublisher()
    
    Returns:
    The ConfigurableApplicationEventPublisher instance used by this datastore
  - public AutoTimestampEventListener getAutoTimestampEventListener()
  - public CodecRegistry getCodecRegistry()
    
    Returns:
    The CodecRegistry
  - public MongoCollection<Document> getCollection(PersistentEntity entity)
    
    Obtain the raw MongoCollection for the given entity
    Parameters:
    entity - The entity
    Returns:
    The Mongo collection
  - public 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 String getDatabaseName(PersistentEntity entity)
  - @Override
    public MongoDatastore getDatastoreForConnection(String connectionName)
  - @Override
    public Datastore getDatastoreForConnection(String connectionName)
  - @Override
    public MongoDatastore getDatastoreForTenantId(Serializable tenantId)
  - public String getDefaultDatabase()
    
    Returns:
    The default database name
  - public FlushModeType getDefaultFlushMode()
    
    Returns:
    The default flush mode
  - <D> @Override
    protected GormInstanceApi<D> getInstanceApi(Class<D> cls, String qualifier)
  - @Override
    public MongoMappingContext getMappingContext()
    
    Returns:
    The mapping context
  - public MongoClient getMongoClient()
    
    Returns:
    The MongoClient instance
  - @Override
    public MultiTenancySettings.MultiTenancyMode getMultiTenancyMode()
  - public PersistentEntityCodec getPersistentEntityCodec(PersistentEntity entity)
    
    Obtains a PersistentEntityCodec for the given entity
    Parameters:
    entity - The entity
    Returns:
    The PersistentEntityCodec
  - public PersistentEntityCodec getPersistentEntityCodec(Class entityClass)
    
    Obtains a PersistentEntityCodec for the given entity
    Parameters:
    entityClass - The entity class
    Returns:
    The PersistentEntityCodec
  - <D> @Override
    protected MongoStaticApi<D> getStaticApi(Class<D> cls, String qualifier)
  - @Override
    public TenantResolver getTenantResolver()
  - @Override
    public PlatformTransactionManager getTransactionManager()
    
    Returns:
    The transaction manager
  - <D> @Override
    protected GormValidationApi<D> getValidationApi(Class<D> cls, String qualifier)
  - @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
  - @Override
    public boolean isSchemaless()
  - @Override
    public void newConnectionSource(ConnectionSource<MongoClient, MongoConnectionSourceSettings> connectionSource)
  - @Override
    public void persistentEntityAdded(PersistentEntity entity)
  - @Override
    public void persistentEntityAdded(PersistentEntity entity)
  - protected void registerAllEntitiesWithEnhancer()
  - protected void registerEntity(PersistentEntity entity)
  - protected void registerEventListeners(ConfigurableApplicationEventPublisher eventPublisher)
  - @Override
    public Serializable resolveTenantIdentifier()
  - @Override
    public Iterable<Serializable> resolveTenantIds()
  - @Autowired(required = false)
    public void setCodecProviders(List<CodecProvider> codecProviders)
    
    Sets any additional codec providers
    Parameters:
    codecProviders - The CodecProvider instances
  - @Autowired(required = false)
    public void setCodecRegistries(List<CodecRegistry> codecRegistries)
    
    Sets any additional codec registries
    Parameters:
    codecRegistries - The CodecRegistry instances
  - @Autowired(required = false)
    public void setCodecs(List<Codec<?>> codecs)
    
    Sets any additional codecs
    Parameters:
    codecs - The Codec instances
  - @Autowired(required = false)
    public void setMessageSource(MessageSource messageSource)
    
    The message source used for validation messages
    Parameters:
    messageSource - The message source
  - <T1> @Override
    public T1 withNewSession(Serializable tenantId, Closure<T1> callable)

Summary:
Field
Constructor
Method

| Detail:
Field
Constructor
Method

Groovy Documentation

[Java] Class MongoDatastore

Field Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

public static final String CODEC_ENGINE

public static final String INDEX_ATTRIBUTES

public static final String SETTING_CONNECTION_STRING

public static final String SETTING_DATABASE_NAME

public static final String SETTING_DEFAULT_MAPPING

public static final String SETTING_ENGINE

public static final String SETTING_HOST

public static final String SETTING_OPTIONS

public static final String SETTING_PASSWORD

public static final String SETTING_PORT

public static final String SETTING_STATELESS

public static final String SETTING_URL

public static final String SETTING_USERNAME

protected final AutoTimestampEventListener autoTimestampEventListener

protected final boolean codecEngine

protected CodecRegistry codecRegistry

protected final ConnectionSources<MongoClient, MongoConnectionSourceSettings> connectionSources

protected final Map<String, MongoDatastore> datastoresByConnectionSource

protected final String defaultDatabase

protected final FlushModeType defaultFlushMode

protected final ConfigurableApplicationEventPublisher eventPublisher

protected final GormEnhancer gormEnhancer

protected final MongoClient mongo

protected final Map<PersistentEntity, String> mongoCollections

protected final Map<PersistentEntity, String> mongoDatabases

protected final MultiTenancySettings.MultiTenancyMode multiTenancyMode

protected final boolean stateless

protected final TenantResolver tenantResolver

protected final PlatformTransactionManager transactionManager

Constructor Detail

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

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

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

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

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

public MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, Class classes)

public MongoDatastore(MongoClient mongoClient, PropertyResolver configuration, Package packages)

public MongoDatastore(MongoClient mongoClient, Class classes)

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

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

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

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

public MongoDatastore(PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, Class classes)

public MongoDatastore(PropertyResolver configuration, MongoMappingContext mappingContext)

public MongoDatastore(PropertyResolver configuration, Class classes)

public MongoDatastore(Map<String, Object> configuration, ConfigurableApplicationEventPublisher eventPublisher, Class classes)

public MongoDatastore(Map<String, Object> configuration, Class classes)

public MongoDatastore(Map<String, Object> configuration)

public MongoDatastore(Map<String, Object> configuration, MongoMappingContext mappingContext)

public MongoDatastore(MongoMappingContext mappingContext)

public MongoDatastore(Class classes)

public MongoDatastore(Package packagesToScan)

public MongoDatastore(Package packageToScan)

public MongoDatastore(PropertyResolver configuration, Package packagesToScan)

public MongoDatastore(Map<String, Object> configuration, Package packagesToScan)

public MongoDatastore(PropertyResolver configuration, ConfigurableApplicationEventPublisher eventPublisher, Package packagesToScan)

Method Detail

public void buildIndex()

@Override@PreDestroypublic void close()

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

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

protected static MongoMappingContext createMappingContext(PropertyResolver configuration, Class classes)

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

@Overrideprotected Session createSession(PropertyResolver connDetails)

@Overrideprotected Session createStatelessSession(PropertyResolver connectionDetails)

@Overridepublic ConfigurableApplicationEventPublisher getApplicationEventPublisher()

public AutoTimestampEventListener getAutoTimestampEventListener()

public CodecRegistry getCodecRegistry()

public MongoCollection<Document> getCollection(PersistentEntity entity)

public String getCollectionName(PersistentEntity entity)

public ConnectionSources<MongoClient, MongoConnectionSourceSettings> getConnectionSources()

public String getDatabaseName(PersistentEntity entity)

@Overridepublic MongoDatastore getDatastoreForConnection(String connectionName)

@Overridepublic Datastore getDatastoreForConnection(String connectionName)

@Override
@PreDestroy
public void close()

@Override
protected Session createSession(PropertyResolver connDetails)

@Override
protected Session createStatelessSession(PropertyResolver connectionDetails)

@Override
public ConfigurableApplicationEventPublisher getApplicationEventPublisher()

@Override
public MongoDatastore getDatastoreForConnection(String connectionName)

@Override
public Datastore getDatastoreForConnection(String connectionName)

@Override
public MongoDatastore getDatastoreForTenantId(Serializable tenantId)

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

@Override
public MongoMappingContext getMappingContext()

@Override
public MultiTenancySettings.MultiTenancyMode getMultiTenancyMode()

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

@Override
public TenantResolver getTenantResolver()

@Override
public PlatformTransactionManager getTransactionManager()

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

@Override
protected MongoGormEnhancer initialize(MongoConnectionSourceSettings settings)

@Override
public boolean isSchemaless()

@Override
public void newConnectionSource(ConnectionSource<MongoClient, MongoConnectionSourceSettings> connectionSource)

@Override
public void persistentEntityAdded(PersistentEntity entity)

@Override
public void persistentEntityAdded(PersistentEntity entity)

@Override
public Serializable resolveTenantIdentifier()

@Override
public Iterable<Serializable> resolveTenantIds()

@Autowired(required = false)
public void setCodecProviders(List<CodecProvider> codecProviders)

@Autowired(required = false)
public void setCodecRegistries(List<CodecRegistry> codecRegistries)

@Autowired(required = false)
public void setCodecs(List<Codec<?>> codecs)

@Autowired(required = false)
public void setMessageSource(MessageSource messageSource)

<T1> @Override
public T1 withNewSession(Serializable tenantId, Closure<T1> callable)