Class MongoDbRepository<TMongoDbContext, TEntity>

Inheritance
System.Object
BasicRepositoryBase<TEntity>
RepositoryBase<TEntity>
MongoDbRepository<TMongoDbContext, TEntity>
MongoDbRepository<TMongoDbContext, TEntity, TKey>
Implements
IServiceProviderAccessor
ITransientDependency
IRepository<TEntity>
IQueryable<TEntity>
IMongoQueryable<TEntity>
Inherited Members
Volo.Abp.Domain.Repositories.RepositoryBase<TEntity>.WithDetails(Expression<>[])
Volo.Abp.Domain.Repositories.RepositoryBase<TEntity>.FindAsync(Expression<>, System.Boolean, CancellationToken)
Volo.Abp.Domain.Repositories.RepositoryBase<TEntity>.GetAsync(Expression<>, System.Boolean, CancellationToken)
Volo.Abp.Domain.Repositories.RepositoryBase<TEntity>.DeleteAsync(Expression<>, System.Boolean, CancellationToken)
Namespace: Volo.Abp.Domain.Repositories.MongoDB
Assembly: Volo.Abp.MongoDB.dll
Syntax
public class MongoDbRepository<TMongoDbContext, TEntity> : RepositoryBase<TEntity>, IServiceProviderAccessor, IUnitOfWorkEnabled, ITransientDependency, IUnitOfWorkManagerAccessor, IMongoDbRepository<TEntity>, IRepository<TEntity>, IReadOnlyRepository<TEntity>, IQueryable<TEntity>, IBasicRepository<TEntity>, IReadOnlyBasicRepository<TEntity>, IRepository, IMongoQueryable<TEntity> where TMongoDbContext : IAbpMongoDbContext where TEntity : class, IEntity
Type Parameters
Name Description
TMongoDbContext
TEntity

Constructors

MongoDbRepository(IMongoDbContextProvider<TMongoDbContext>)

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

Properties

AuditPropertySetter

Declaration
public IAuditPropertySetter AuditPropertySetter { get; set; }
Property Value
Type Description
IAuditPropertySetter

Collection

Declaration
public virtual IMongoCollection<TEntity> Collection { get; }
Property Value
Type Description
IMongoCollection<TEntity>

Database

Declaration
public virtual IMongoDatabase Database { get; }
Property Value
Type Description
IMongoDatabase

DbContext

Declaration
public virtual TMongoDbContext DbContext { get; }
Property Value
Type Description
TMongoDbContext

DbContextProvider

Declaration
protected IMongoDbContextProvider<TMongoDbContext> DbContextProvider { get; }
Property Value
Type Description
IMongoDbContextProvider<TMongoDbContext>

DistributedEventBus

Declaration
public IDistributedEventBus DistributedEventBus { get; set; }
Property Value
Type Description
IDistributedEventBus

EntityChangeEventHelper

Declaration
public IEntityChangeEventHelper EntityChangeEventHelper { get; set; }
Property Value
Type Description
IEntityChangeEventHelper

GuidGenerator

Declaration
public IGuidGenerator GuidGenerator { get; set; }
Property Value
Type Description
IGuidGenerator

LocalEventBus

Declaration
public ILocalEventBus LocalEventBus { get; set; }
Property Value
Type Description
ILocalEventBus

Methods

ApplyAbpConceptsForAddedEntityAsync(TEntity)

Declaration
protected virtual Task ApplyAbpConceptsForAddedEntityAsync(TEntity entity)
Parameters
Type Name Description
TEntity entity
Returns
Type Description
Task

ApplyAbpConceptsForDeletedEntityAsync(TEntity)

Declaration
protected virtual Task ApplyAbpConceptsForDeletedEntityAsync(TEntity entity)
Parameters
Type Name Description
TEntity entity
Returns
Type Description
Task

CheckAndSetId(TEntity)

Declaration
protected virtual void CheckAndSetId(TEntity entity)
Parameters
Type Name Description
TEntity entity

CreateEntityFilter(TEntity, Boolean, String)

Declaration
protected virtual FilterDefinition<TEntity> CreateEntityFilter(TEntity entity, bool withConcurrencyStamp = false, string concurrencyStamp = null)
Parameters
Type Name Description
TEntity entity
System.Boolean withConcurrencyStamp
System.String concurrencyStamp
Returns
Type Description
FilterDefinition<TEntity>

DeleteAsync(TEntity, Boolean, CancellationToken)

Declaration
public override Task DeleteAsync(TEntity entity, bool autoSave = false, CancellationToken cancellationToken = null)
Parameters
Type Name Description
TEntity entity
System.Boolean autoSave
CancellationToken cancellationToken
Returns
Type Description
Task

DeleteAsync(Expression<Func<TEntity, Boolean>>, Boolean, CancellationToken)

Declaration
public override Task DeleteAsync(Expression<Func<TEntity, bool>> predicate, bool autoSave = false, CancellationToken cancellationToken = null)
Parameters
Type Name Description
Expression<Func<TEntity, System.Boolean>> predicate
System.Boolean autoSave
CancellationToken cancellationToken
Returns
Type Description
Task

FindAsync(Expression<Func<TEntity, Boolean>>, Boolean, CancellationToken)

Declaration
public override Task<TEntity> FindAsync(Expression<Func<TEntity, bool>> predicate, bool includeDetails = true, CancellationToken cancellationToken = null)
Parameters
Type Name Description
Expression<Func<TEntity, System.Boolean>> predicate
System.Boolean includeDetails
CancellationToken cancellationToken
Returns
Type Description
Task<TEntity>

GetCountAsync(CancellationToken)

Declaration
public override Task<long> GetCountAsync(CancellationToken cancellationToken = null)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task<System.Int64>

GetExecutionModel()

Declaration
public QueryableExecutionModel GetExecutionModel()
Returns
Type Description
QueryableExecutionModel

GetListAsync(Boolean, CancellationToken)

Declaration
public override Task<List<TEntity>> GetListAsync(bool includeDetails = false, CancellationToken cancellationToken = null)
Parameters
Type Name Description
System.Boolean includeDetails
CancellationToken cancellationToken
Returns
Type Description
Task<List<TEntity>>

GetMongoQueryable()

Declaration
public virtual IMongoQueryable<TEntity> GetMongoQueryable()
Returns
Type Description
IMongoQueryable<TEntity>

GetPagedListAsync(Int32, Int32, String, Boolean, CancellationToken)

Declaration
public override Task<List<TEntity>> GetPagedListAsync(int skipCount, int maxResultCount, string sorting, bool includeDetails = false, CancellationToken cancellationToken = null)
Parameters
Type Name Description
System.Int32 skipCount
System.Int32 maxResultCount
System.String sorting
System.Boolean includeDetails
CancellationToken cancellationToken
Returns
Type Description
Task<List<TEntity>>

GetQueryable()

Declaration
protected override IQueryable<TEntity> GetQueryable()
Returns
Type Description
IQueryable<TEntity>
Overrides
Volo.Abp.Domain.Repositories.RepositoryBase<TEntity>.GetQueryable()

InsertAsync(TEntity, Boolean, CancellationToken)

Declaration
public override Task<TEntity> InsertAsync(TEntity entity, bool autoSave = false, CancellationToken cancellationToken = null)
Parameters
Type Name Description
TEntity entity
System.Boolean autoSave
CancellationToken cancellationToken
Returns
Type Description
Task<TEntity>

IsHardDeleted(TEntity)

Declaration
protected virtual bool IsHardDeleted(TEntity entity)
Parameters
Type Name Description
TEntity entity
Returns
Type Description
System.Boolean

SetCreationAuditProperties(TEntity)

Declaration
protected virtual void SetCreationAuditProperties(TEntity entity)
Parameters
Type Name Description
TEntity entity

SetDeletionAuditProperties(TEntity)

Declaration
protected virtual void SetDeletionAuditProperties(TEntity entity)
Parameters
Type Name Description
TEntity entity

SetModificationAuditProperties(TEntity)

Declaration
protected virtual void SetModificationAuditProperties(TEntity entity)
Parameters
Type Name Description
TEntity entity

SetNewConcurrencyStamp(TEntity)

Sets a new ConcurrencyStamp value if given entity implements IHasConcurrencyStamp interface. Returns the old ConcurrencyStamp value.

Declaration
protected virtual string SetNewConcurrencyStamp(TEntity entity)
Parameters
Type Name Description
TEntity entity
Returns
Type Description
System.String

ThrowOptimisticConcurrencyException()

Declaration
protected virtual void ThrowOptimisticConcurrencyException()

ToCursor(CancellationToken)

Declaration
public IAsyncCursor<TEntity> ToCursor(CancellationToken cancellationToken = null)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
IAsyncCursor<TEntity>

ToCursorAsync(CancellationToken)

Declaration
public Task<IAsyncCursor<TEntity>> ToCursorAsync(CancellationToken cancellationToken = null)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
Task<IAsyncCursor<TEntity>>

TriggerDomainEventsAsync(Object)

Declaration
protected virtual Task TriggerDomainEventsAsync(object entity)
Parameters
Type Name Description
System.Object entity
Returns
Type Description
Task

TriggerEntityDeleteEventsAsync(TEntity)

Declaration
protected virtual Task TriggerEntityDeleteEventsAsync(TEntity entity)
Parameters
Type Name Description
TEntity entity
Returns
Type Description
Task

TriggerEntityUpdateEventsAsync(TEntity)

Declaration
protected virtual Task TriggerEntityUpdateEventsAsync(TEntity entity)
Parameters
Type Name Description
TEntity entity
Returns
Type Description
Task

TrySetGuidId(IEntity<Guid>)

Declaration
protected virtual void TrySetGuidId(IEntity<Guid> entity)
Parameters
Type Name Description
IEntity<Guid> entity

UpdateAsync(TEntity, Boolean, CancellationToken)

Declaration
public override Task<TEntity> UpdateAsync(TEntity entity, bool autoSave = false, CancellationToken cancellationToken = null)
Parameters
Type Name Description
TEntity entity
System.Boolean autoSave
CancellationToken cancellationToken
Returns
Type Description
Task<TEntity>

Implements

IServiceProviderAccessor
ITransientDependency
IQueryable<>
IMongoQueryable<>

Extension Methods