Interface IRepositoryCollection<TEntity, TKey>

Namespace

Tharga.MongoDB

Assembly

Tharga.MongoDB.dll

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

Type Parameters

TEntity

TKey

Inherited Members

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

AddAsync(TEntity, IClientSessionHandle)

Task AddAsync(TEntity entity, IClientSessionHandle session = null)

Parameters

entity TEntity

session IClientSessionHandle

Returns

Task

AddManyAsync(IEnumerable<TEntity>, IClientSessionHandle)

Task AddManyAsync(IEnumerable<TEntity> entities, IClientSessionHandle session = null)

Parameters

entities IEnumerable<TEntity>

session IClientSessionHandle

Returns

Task

DeleteOneAsync(TKey, IClientSessionHandle)

Task<TEntity> DeleteOneAsync(TKey id, IClientSessionHandle session = null)

Parameters

id TKey

session IClientSessionHandle

Returns

Task<TEntity>

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

Task<T> ExecuteAsync<T>(Func<IMongoCollection<TEntity>, CancellationToken, Task<T>> execute, Operation operation, CancellationToken cancellationToken)

Parameters

execute Func<IMongoCollection<TEntity>, CancellationToken, Task<T>>

operation Operation

cancellationToken CancellationToken

Returns

Task<T>

Type Parameters

T

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

Task<T> ExecuteAsync<T>(Func<IMongoCollection<TEntity>, Task<T>> execute, Operation operation)

Parameters

execute Func<IMongoCollection<TEntity>, Task<T>>

operation Operation

Returns

Task<T>

Type Parameters

T

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

IAsyncEnumerable<T> ExecuteManyAsync<T>(Func<IMongoCollection<TEntity>, CancellationToken, Task<IAsyncCursor<T>>> queryFactory, CancellationToken cancellationToken = default)

Parameters

queryFactory Func<IMongoCollection<TEntity>, CancellationToken, Task<IAsyncCursor<T>>>

cancellationToken CancellationToken

Returns

IAsyncEnumerable<T>

Type Parameters

T

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

Keyset (seek-based) pagination. Cost is O(log N) per page regardless of how deep the page sits — no skip penalty on deep pages or "jump to last." Single-column sort only; total count is intentionally not part of the result and should be obtained via CountAsync(predicate) separately.

Task<CursorPage<TEntity>> GetPageAsync(int pageSize, PagePosition position, Expression<Func<TEntity, bool>> predicate = null, Expression<Func<TEntity, object>> sortBy = null, bool ascending = true, CancellationToken cancellationToken = default)

Parameters

pageSize int

position PagePosition

predicate Expression<Func<TEntity, bool>>

sortBy Expression<Func<TEntity, object>>

ascending bool

cancellationToken CancellationToken

Returns

Task<CursorPage<TEntity>>

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

Projection variant of GetPageAsync(int, PagePosition, Expression<Func<TEntity, bool>>, Expression<Func<TEntity, object>>, bool, CancellationToken) — returns the projected shape T instead of the entity.

Task<CursorPage<T>> GetPageProjectionAsync<T>(int pageSize, PagePosition position, Expression<Func<TEntity, T>> projection, Expression<Func<TEntity, bool>> predicate = null, Expression<Func<TEntity, object>> sortBy = null, bool ascending = true, CancellationToken cancellationToken = default)

Parameters

pageSize int

position PagePosition

projection Expression<Func<TEntity, T>>

predicate Expression<Func<TEntity, bool>>

sortBy Expression<Func<TEntity, object>>

ascending bool

cancellationToken CancellationToken

Returns

Task<CursorPage<T>>

Type Parameters

T

TryAddAsync(TEntity, IClientSessionHandle)

Task<bool> TryAddAsync(TEntity entity, IClientSessionHandle session = null)

Parameters

entity TEntity

session IClientSessionHandle

Returns

Task<bool>