Class MongoDbRepository<TMongoDbContext, TEntity>
Inheritance
System.Object
MongoDbRepository<TMongoDbContext, TEntity>
Implements
IServiceProviderAccessor
ITransientDependency
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)
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
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
DistributedEventBus
Declaration
public IDistributedEventBus DistributedEventBus { get; set; }
Property Value
Type |
Description |
IDistributedEventBus |
|
EntityChangeEventHelper
Declaration
public IEntityChangeEventHelper EntityChangeEventHelper { get; set; }
Property Value
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
ApplyAbpConceptsForDeletedEntityAsync(TEntity)
Declaration
protected virtual Task ApplyAbpConceptsForDeletedEntityAsync(TEntity entity)
Parameters
Type |
Name |
Description |
TEntity |
entity |
|
Returns
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
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
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)
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
TriggerEntityDeleteEventsAsync(TEntity)
Declaration
protected virtual Task TriggerEntityDeleteEventsAsync(TEntity entity)
Parameters
Type |
Name |
Description |
TEntity |
entity |
|
Returns
TriggerEntityUpdateEventsAsync(TEntity)
Declaration
protected virtual Task TriggerEntityUpdateEventsAsync(TEntity entity)
Parameters
Type |
Name |
Description |
TEntity |
entity |
|
Returns
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