Show / Hide Table of Contents

Class MongoDbRepository<TMongoDbContext, TEntity, TKey>

Inheritance
object
BasicRepositoryBase<TEntity>
RepositoryBase<TEntity>
MongoDbRepository<TMongoDbContext, TEntity>
MongoDbRepository<TMongoDbContext, TEntity, TKey>
Implements
IServiceProviderAccessor
IUnitOfWorkEnabled
IUnitOfWorkManagerAccessor
IMongoDbRepository<TEntity, TKey>
IMongoDbRepository<TEntity>
IRepository<TEntity, TKey>
IRepository<TEntity>
IReadOnlyRepository<TEntity, TKey>
IReadOnlyRepository<TEntity>
IBasicRepository<TEntity, TKey>
IBasicRepository<TEntity>
IReadOnlyBasicRepository<TEntity, TKey>
IReadOnlyBasicRepository<TEntity>
IRepository
Inherited Members
MongoDbRepository<TMongoDbContext, TEntity>.GetCollectionAsync(CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.GetDatabaseAsync(CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.GetSessionHandleAsync(CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.GetDbContextAsync(CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.InsertAsync(TEntity, bool, CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.InsertManyAsync(IEnumerable<TEntity>, bool, CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.UpdateAsync(TEntity, bool, CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.UpdateManyAsync(IEnumerable<TEntity>, bool, CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.DeleteAsync(TEntity, bool, CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.DeleteManyAsync(IEnumerable<TEntity>, bool, CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.GetListAsync(bool, CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.GetListAsync(Expression<Func<TEntity, bool>>, bool, CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.GetCountAsync(CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.GetPagedListAsync(int, int, string, bool, CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.DeleteAsync(Expression<Func<TEntity, bool>>, bool, CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.DeleteDirectAsync(Expression<Func<TEntity, bool>>, CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.GetQueryable()
MongoDbRepository<TMongoDbContext, TEntity>.GetQueryableAsync()
MongoDbRepository<TMongoDbContext, TEntity>.FindAsync(Expression<Func<TEntity, bool>>, bool, CancellationToken)
MongoDbRepository<TMongoDbContext, TEntity>.GetMongoQueryable()
MongoDbRepository<TMongoDbContext, TEntity>.GetMongoQueryableAsync(CancellationToken, AggregateOptions)
MongoDbRepository<TMongoDbContext, TEntity>.GetMongoQueryableAsync<TOtherEntity>(CancellationToken, AggregateOptions)
MongoDbRepository<TMongoDbContext, TEntity>.GetAggregateAsync(CancellationToken, AggregateOptions)
MongoDbRepository<TMongoDbContext, TEntity>.IsHardDeleted(TEntity)
MongoDbRepository<TMongoDbContext, TEntity>.CreateEntityFilterAsync(TEntity, bool, string)
MongoDbRepository<TMongoDbContext, TEntity>.CreateEntitiesFilterAsync(IEnumerable<TEntity>, bool)
MongoDbRepository<TMongoDbContext, TEntity>.ApplyAbpConceptsForAddedEntityAsync(TEntity)
MongoDbRepository<TMongoDbContext, TEntity>.TriggerEntityCreateEvents(TEntity)
MongoDbRepository<TMongoDbContext, TEntity>.TriggerEntityUpdateEvents(TEntity)
MongoDbRepository<TMongoDbContext, TEntity>.ApplyAbpConceptsForDeletedEntity(TEntity)
MongoDbRepository<TMongoDbContext, TEntity>.TriggerEntityDeleteEvents(TEntity)
MongoDbRepository<TMongoDbContext, TEntity>.CheckAndSetId(TEntity)
MongoDbRepository<TMongoDbContext, TEntity>.TrySetGuidId(IEntity<Guid>)
MongoDbRepository<TMongoDbContext, TEntity>.SetCreationAuditProperties(TEntity)
MongoDbRepository<TMongoDbContext, TEntity>.SetModificationAuditProperties(TEntity)
MongoDbRepository<TMongoDbContext, TEntity>.SetDeletionAuditProperties(TEntity)
MongoDbRepository<TMongoDbContext, TEntity>.IncrementEntityVersionProperty(TEntity)
MongoDbRepository<TMongoDbContext, TEntity>.TriggerDomainEvents(object)
MongoDbRepository<TMongoDbContext, TEntity>.SetNewConcurrencyStamp(TEntity)
MongoDbRepository<TMongoDbContext, TEntity>.ThrowOptimisticConcurrencyException()
MongoDbRepository<TMongoDbContext, TEntity>.ApplyDataFilters<TQueryable, TOtherEntity>(TQueryable)
MongoDbRepository<TMongoDbContext, TEntity>.Collection
MongoDbRepository<TMongoDbContext, TEntity>.Database
MongoDbRepository<TMongoDbContext, TEntity>.SessionHandle
MongoDbRepository<TMongoDbContext, TEntity>.DbContext
MongoDbRepository<TMongoDbContext, TEntity>.DbContextProvider
MongoDbRepository<TMongoDbContext, TEntity>.LocalEventBus
MongoDbRepository<TMongoDbContext, TEntity>.DistributedEventBus
MongoDbRepository<TMongoDbContext, TEntity>.EntityChangeEventHelper
MongoDbRepository<TMongoDbContext, TEntity>.GuidGenerator
MongoDbRepository<TMongoDbContext, TEntity>.AuditPropertySetter
MongoDbRepository<TMongoDbContext, TEntity>.BulkOperationProvider
MongoDbRepository<TMongoDbContext, TEntity>.RepositoryFilterer
RepositoryBase<TEntity>.WithDetails()
RepositoryBase<TEntity>.WithDetails(params Expression<Func<TEntity, object>>[])
RepositoryBase<TEntity>.WithDetailsAsync()
RepositoryBase<TEntity>.WithDetailsAsync(params Expression<Func<TEntity, object>>[])
RepositoryBase<TEntity>.GetQueryable()
RepositoryBase<TEntity>.GetQueryableAsync()
RepositoryBase<TEntity>.FindAsync(Expression<Func<TEntity, bool>>, bool, CancellationToken)
RepositoryBase<TEntity>.GetAsync(Expression<Func<TEntity, bool>>, bool, CancellationToken)
RepositoryBase<TEntity>.DeleteAsync(Expression<Func<TEntity, bool>>, bool, CancellationToken)
RepositoryBase<TEntity>.DeleteDirectAsync(Expression<Func<TEntity, bool>>, CancellationToken)
RepositoryBase<TEntity>.ApplyDataFilters<TQueryable>(TQueryable)
BasicRepositoryBase<TEntity>.InsertAsync(TEntity, bool, CancellationToken)
BasicRepositoryBase<TEntity>.InsertManyAsync(IEnumerable<TEntity>, bool, CancellationToken)
BasicRepositoryBase<TEntity>.SaveChangesAsync(CancellationToken)
BasicRepositoryBase<TEntity>.UpdateAsync(TEntity, bool, CancellationToken)
BasicRepositoryBase<TEntity>.UpdateManyAsync(IEnumerable<TEntity>, bool, CancellationToken)
BasicRepositoryBase<TEntity>.DeleteAsync(TEntity, bool, CancellationToken)
BasicRepositoryBase<TEntity>.DeleteManyAsync(IEnumerable<TEntity>, bool, CancellationToken)
BasicRepositoryBase<TEntity>.GetListAsync(bool, CancellationToken)
BasicRepositoryBase<TEntity>.GetListAsync(Expression<Func<TEntity, bool>>, bool, CancellationToken)
BasicRepositoryBase<TEntity>.GetCountAsync(CancellationToken)
BasicRepositoryBase<TEntity>.GetPagedListAsync(int, int, string, bool, CancellationToken)
BasicRepositoryBase<TEntity>.GetCancellationToken(CancellationToken)
BasicRepositoryBase<TEntity>.ShouldTrackingEntityChange()
BasicRepositoryBase<TEntity>.LazyServiceProvider
BasicRepositoryBase<TEntity>.ServiceProvider
BasicRepositoryBase<TEntity>.DataFilter
BasicRepositoryBase<TEntity>.CurrentTenant
BasicRepositoryBase<TEntity>.AsyncExecuter
BasicRepositoryBase<TEntity>.UnitOfWorkManager
BasicRepositoryBase<TEntity>.CancellationTokenProvider
BasicRepositoryBase<TEntity>.LoggerFactory
BasicRepositoryBase<TEntity>.Logger
BasicRepositoryBase<TEntity>.EntityChangeTrackingProvider
BasicRepositoryBase<TEntity>.IsChangeTrackingEnabled
object.GetType()
object.MemberwiseClone()
object.ToString()
object.Equals(object)
object.Equals(object, object)
object.ReferenceEquals(object, object)
object.GetHashCode()
Namespace: Volo.Abp.Domain.Repositories.MongoDB
Assembly: Volo.Abp.MongoDB.dll
Syntax
public class MongoDbRepository<TMongoDbContext, TEntity, TKey> : MongoDbRepository<TMongoDbContext, TEntity>, IServiceProviderAccessor, IUnitOfWorkEnabled, IUnitOfWorkManagerAccessor, IMongoDbRepository<TEntity, TKey>, IMongoDbRepository<TEntity>, IRepository<TEntity, TKey>, IRepository<TEntity>, IReadOnlyRepository<TEntity, TKey>, IReadOnlyRepository<TEntity>, IBasicRepository<TEntity, TKey>, IBasicRepository<TEntity>, IReadOnlyBasicRepository<TEntity, TKey>, IReadOnlyBasicRepository<TEntity>, IRepository where TMongoDbContext : IAbpMongoDbContext where TEntity : class, IEntity<TKey>
Type Parameters
Name Description
TMongoDbContext
TEntity
TKey

Constructors

MongoDbRepository(IMongoDbContextProvider<TMongoDbContext>)

Declaration
public MongoDbRepository(IMongoDbContextProvider<TMongoDbContext> dbContextProvider)
Parameters
Type Name Description
IMongoDbContextProvider<TMongoDbContext> dbContextProvider

Properties

RepositoryFiltererWithKey

Declaration
public IMongoDbRepositoryFilterer<TEntity, TKey> RepositoryFiltererWithKey { get; }
Property Value
Type Description
IMongoDbRepositoryFilterer<TEntity, TKey>

Methods

ApplyDataFilters<TQueryable, TOtherEntity>(TQueryable)

Declaration
protected override TQueryable ApplyDataFilters<TQueryable, TOtherEntity>(TQueryable query) where TQueryable : IQueryable<TOtherEntity>
Parameters
Type Name Description
TQueryable query
Returns
Type Description
TQueryable
Type Parameters
Name Description
TQueryable
TOtherEntity
Overrides
MongoDbRepository<TMongoDbContext, TEntity>.ApplyDataFilters<TQueryable, TOtherEntity>(TQueryable)

CreateEntitiesFilterAsync(IEnumerable<TEntity>, bool)

Declaration
protected override Task<FilterDefinition<TEntity>> CreateEntitiesFilterAsync(IEnumerable<TEntity> entities, bool withConcurrencyStamp = false)
Parameters
Type Name Description
IEnumerable<TEntity> entities
bool withConcurrencyStamp
Returns
Type Description
Task<FilterDefinition<TEntity>>
Overrides
MongoDbRepository<TMongoDbContext, TEntity>.CreateEntitiesFilterAsync(IEnumerable<TEntity>, bool)

CreateEntityFilterAsync(TEntity, bool, string?)

Declaration
protected override Task<FilterDefinition<TEntity>> CreateEntityFilterAsync(TEntity entity, bool withConcurrencyStamp = false, string? concurrencyStamp = null)
Parameters
Type Name Description
TEntity entity
bool withConcurrencyStamp
string concurrencyStamp
Returns
Type Description
Task<FilterDefinition<TEntity>>
Overrides
MongoDbRepository<TMongoDbContext, TEntity>.CreateEntityFilterAsync(TEntity, bool, string)

DeleteAsync(TKey, bool, CancellationToken)

Declaration
public virtual Task DeleteAsync(TKey id, bool autoSave = false, CancellationToken cancellationToken = default)
Parameters
Type Name Description
TKey id
bool autoSave
CancellationToken cancellationToken
Returns
Type Description
Task

DeleteManyAsync(IEnumerable<TKey>, bool, CancellationToken)

Declaration
public virtual Task DeleteManyAsync(IEnumerable<TKey> ids, bool autoSave = false, CancellationToken cancellationToken = default)
Parameters
Type Name Description
IEnumerable<TKey> ids
bool autoSave
CancellationToken cancellationToken
Returns
Type Description
Task

FindAsync(TKey, bool, CancellationToken)

Declaration
public virtual Task<TEntity?> FindAsync(TKey id, bool includeDetails = true, CancellationToken cancellationToken = default)
Parameters
Type Name Description
TKey id
bool includeDetails
CancellationToken cancellationToken
Returns
Type Description
Task<TEntity>

GetAsync(TKey, bool, CancellationToken)

Declaration
public virtual Task<TEntity> GetAsync(TKey id, bool includeDetails = true, CancellationToken cancellationToken = default)
Parameters
Type Name Description
TKey id
bool includeDetails
CancellationToken cancellationToken
Returns
Type Description
Task<TEntity>

Implements

IServiceProviderAccessor
IUnitOfWorkEnabled
IUnitOfWorkManagerAccessor
IMongoDbRepository<TEntity, TKey>
IMongoDbRepository<TEntity>
IRepository<TEntity, TKey>
IRepository<TEntity>
IReadOnlyRepository<TEntity, TKey>
IReadOnlyRepository<TEntity>
IBasicRepository<TEntity, TKey>
IBasicRepository<TEntity>
IReadOnlyBasicRepository<TEntity, TKey>
IReadOnlyBasicRepository<TEntity>
IRepository

Extension Methods

AbpObjectExtensions.As<T>(object)
AbpObjectExtensions.To<T>(object)
LockExtensions.Locking(object, Action)
LockExtensions.Locking<TResult>(object, Func<TResult>)
MongoDbCoreRepositoryExtensions.GetAggregateAsync<TEntity>(IReadOnlyBasicRepository<TEntity>, CancellationToken, AggregateOptions?)
MongoDbCoreRepositoryExtensions.GetCollectionAsync<TEntity>(IReadOnlyBasicRepository<TEntity>, CancellationToken)
MongoDbCoreRepositoryExtensions.GetCollection<TEntity>(IReadOnlyBasicRepository<TEntity>)
MongoDbCoreRepositoryExtensions.GetDatabaseAsync<TEntity>(IReadOnlyBasicRepository<TEntity>, CancellationToken)
MongoDbCoreRepositoryExtensions.GetDatabase<TEntity>(IReadOnlyBasicRepository<TEntity>)
MongoDbCoreRepositoryExtensions.GetMongoQueryableAsync<TEntity>(IReadOnlyBasicRepository<TEntity>, CancellationToken, AggregateOptions?)
MongoDbCoreRepositoryExtensions.GetMongoQueryable<TEntity>(IReadOnlyBasicRepository<TEntity>)
MongoDbCoreRepositoryExtensions.ToMongoDbRepository<TEntity>(IReadOnlyBasicRepository<TEntity>)
AbpObjectExtensions.If<T>(T, bool, Action<T>)
AbpObjectExtensions.If<T>(T, bool, Func<T, T>)
AbpObjectExtensions.IsIn<T>(T, IEnumerable<T>)
AbpObjectExtensions.IsIn<T>(T, params T[])
AbpQueryableExtensions.OrderByIf<T, TQueryable>(TQueryable, bool, string)
AbpQueryableExtensions.PageBy<T, TQueryable>(TQueryable, int, int)
AbpQueryableExtensions.WhereIf<T, TQueryable>(TQueryable, bool, Expression<Func<T, bool>>)
AbpQueryableExtensions.WhereIf<T, TQueryable>(TQueryable, bool, Expression<Func<T, int, bool>>)
LockExtensions.Locking<T>(T, Action<T>)
LockExtensions.Locking<T, TResult>(T, Func<T, TResult>)
In this article
Back to top Powered by Volosoft