Interface IDiskRepositoryCollection<TEntity, TKey>

Namespace

Tharga.MongoDB

Assembly

Tharga.MongoDB.dll

public interface IDiskRepositoryCollection<TEntity, TKey> : IRepositoryCollection<TEntity, TKey>, IReadOnlyRepositoryCollection<TEntity, TKey>, IRepositoryCollection, IReadOnlyRepositoryCollection where TEntity : EntityBase<TKey>

Type Parameters

TEntity

TKey

Inherited Members

IRepositoryCollection<TEntity, TKey>.AddAsync(TEntity, IClientSessionHandle)

IRepositoryCollection<TEntity, TKey>.TryAddAsync(TEntity, IClientSessionHandle)

IRepositoryCollection<TEntity, TKey>.AddManyAsync(IEnumerable<TEntity>, IClientSessionHandle)

IRepositoryCollection<TEntity, TKey>.DeleteOneAsync(TKey, IClientSessionHandle)

IRepositoryCollection<TEntity, TKey>.ExecuteAsync<T>(Func<IMongoCollection<TEntity>, Task<T>>, Operation)

IRepositoryCollection<TEntity, TKey>.ExecuteAsync<T>(Func<IMongoCollection<TEntity>, CancellationToken, Task<T>>, Operation, CancellationToken)

IRepositoryCollection<TEntity, TKey>.ExecuteManyAsync<T>(Func<IMongoCollection<TEntity>, CancellationToken, Task<IAsyncCursor<T>>>, CancellationToken)

IRepositoryCollection<TEntity, TKey>.GetPageAsync(int, PagePosition, Expression<Func<TEntity, bool>>, Expression<Func<TEntity, object>>, bool, CancellationToken)

IRepositoryCollection<TEntity, TKey>.GetPageProjectionAsync<T>(int, PagePosition, Expression<Func<TEntity, T>>, Expression<Func<TEntity, bool>>, Expression<Func<TEntity, object>>, bool, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.GetAsync(Expression<Func<TEntity, bool>>, Options<TEntity>, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.GetAsync(FilterDefinition<TEntity>, Options<TEntity>, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.GetProjectionAsync<T>(Expression<Func<TEntity, bool>>, Options<TEntity>, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.GetProjectionAsync<T>(FilterDefinition<TEntity>, Options<TEntity>, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.GetManyAsync(Expression<Func<TEntity, bool>>, Options<TEntity>, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.GetManyAsync(FilterDefinition<TEntity>, Options<TEntity>, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.GetManyProjectionAsync<T>(Expression<Func<TEntity, bool>>, Options<TEntity>, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.GetManyProjectionAsync<T>(FilterDefinition<TEntity>, Options<TEntity>, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.GetOneAsync(TKey, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.GetOneAsync(Expression<Func<TEntity, bool>>, OneOption<TEntity>, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.GetOneAsync(FilterDefinition<TEntity>, OneOption<TEntity>, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.CountAsync(Expression<Func<TEntity, bool>>, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.CountAsync(FilterDefinition<TEntity>, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.EstimatedCountAsync(CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.SumAsync(Expression<Func<TEntity, decimal>>, Expression<Func<TEntity, bool>>, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.AvgAsync(Expression<Func<TEntity, decimal>>, Expression<Func<TEntity, bool>>, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.MinAsync<TField>(Expression<Func<TEntity, TField>>, Expression<Func<TEntity, bool>>, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.MaxAsync<TField>(Expression<Func<TEntity, TField>>, Expression<Func<TEntity, bool>>, CancellationToken)

IReadOnlyRepositoryCollection<TEntity, TKey>.GetDirtyAsync()

IReadOnlyRepositoryCollection<TEntity, TKey>.GetFailedIndices()

IRepositoryCollection.DropCollectionAsync()

IReadOnlyRepositoryCollection.GetSizeAsync(CancellationToken)

Methods

AddOrReplaceAsync(TEntity, IClientSessionHandle)

Task<EntityChangeResult<TEntity>> AddOrReplaceAsync(TEntity entity, IClientSessionHandle session = null)

Parameters

entity TEntity

session IClientSessionHandle

Returns

Task<EntityChangeResult<TEntity>>

DeleteManyAsync(FilterDefinition<TEntity>, IClientSessionHandle)

Task<long> DeleteManyAsync(FilterDefinition<TEntity> filter, IClientSessionHandle session = null)

Parameters

filter FilterDefinition<TEntity>

session IClientSessionHandle

Returns

Task<long>

DeleteManyAsync(Expression<Func<TEntity, bool>>, IClientSessionHandle)

Task<long> DeleteManyAsync(Expression<Func<TEntity, bool>> predicate = null, IClientSessionHandle session = null)

Parameters

predicate Expression<Func<TEntity, bool>>

session IClientSessionHandle

Returns

Task<long>

DeleteOneAsync(FilterDefinition<TEntity>, OneOption<TEntity>, IClientSessionHandle)

Task<TEntity> DeleteOneAsync(FilterDefinition<TEntity> filter, OneOption<TEntity> options = null, IClientSessionHandle session = null)

Parameters

filter FilterDefinition<TEntity>

options OneOption<TEntity>

session IClientSessionHandle

Returns

Task<TEntity>

DeleteOneAsync(Expression<Func<TEntity, bool>>, OneOption<TEntity>, IClientSessionHandle)

Task<TEntity> DeleteOneAsync(Expression<Func<TEntity, bool>> predicate, OneOption<TEntity> options = null, IClientSessionHandle session = null)

Parameters

predicate Expression<Func<TEntity, bool>>

options OneOption<TEntity>

session IClientSessionHandle

Returns

Task<TEntity>

GetCollection()

[Obsolete("Use ExecuteAsync instead. This method will be deprecated.")]
IMongoCollection<TEntity> GetCollection()

Returns

IMongoCollection<TEntity>

ReplaceOneAsync(TEntity, OneOption<TEntity>, IClientSessionHandle)

Task<EntityChangeResult<TEntity>> ReplaceOneAsync(TEntity entity, OneOption<TEntity> options = null, IClientSessionHandle session = null)

Parameters

entity TEntity

options OneOption<TEntity>

session IClientSessionHandle

Returns

Task<EntityChangeResult<TEntity>>

UpdateManyAsync(FilterDefinition<TEntity>, UpdateDefinition<TEntity>, IClientSessionHandle)

Task<long> UpdateManyAsync(FilterDefinition<TEntity> filter, UpdateDefinition<TEntity> update, IClientSessionHandle session = null)

Parameters

filter FilterDefinition<TEntity>

update UpdateDefinition<TEntity>

session IClientSessionHandle

Returns

Task<long>

UpdateManyAsync(Expression<Func<TEntity, bool>>, UpdateDefinition<TEntity>, IClientSessionHandle)

Task<long> UpdateManyAsync(Expression<Func<TEntity, bool>> predicate, UpdateDefinition<TEntity> update, IClientSessionHandle session = null)

Parameters

predicate Expression<Func<TEntity, bool>>

update UpdateDefinition<TEntity>

session IClientSessionHandle

Returns

Task<long>

UpdateOneAsync(FilterDefinition<TEntity>, UpdateDefinition<TEntity>, OneOption<TEntity>, IClientSessionHandle)

Task<EntityChangeResult<TEntity>> UpdateOneAsync(FilterDefinition<TEntity> filter, UpdateDefinition<TEntity> update, OneOption<TEntity> options = null, IClientSessionHandle session = null)

Parameters

filter FilterDefinition<TEntity>

update UpdateDefinition<TEntity>

options OneOption<TEntity>

session IClientSessionHandle

Returns

Task<EntityChangeResult<TEntity>>

UpdateOneAsync(Expression<Func<TEntity, bool>>, UpdateDefinition<TEntity>, OneOption<TEntity>, IClientSessionHandle)

Task<EntityChangeResult<TEntity>> UpdateOneAsync(Expression<Func<TEntity, bool>> predicate, UpdateDefinition<TEntity> update, OneOption<TEntity> options = null, IClientSessionHandle session = null)

Parameters

predicate Expression<Func<TEntity, bool>>

update UpdateDefinition<TEntity>

options OneOption<TEntity>

session IClientSessionHandle

Returns

Task<EntityChangeResult<TEntity>>

UpdateOneAsync(TKey, UpdateDefinition<TEntity>, IClientSessionHandle)

Task<EntityChangeResult<TEntity>> UpdateOneAsync(TKey id, UpdateDefinition<TEntity> update, IClientSessionHandle session = null)

Parameters

id TKey

update UpdateDefinition<TEntity>

session IClientSessionHandle

Returns

Task<EntityChangeResult<TEntity>>