Class Transaction

Namespace

MongoDB.Entities

Assembly

MongoDB.Entities.dll

Represents a DB instance that has a transaction started, which can be used to carry out inter-related write operations atomically.

TIP: Remember to always call .Dispose() after use or enclose in a 'Using' statement.

public class Transaction : DB, IDisposable

Inheritance

object

DB

Transaction

Implements

IDisposable

Inherited Members

DB.Collection<T>()

DB.CollectionName<T>()

DB.CreateCollectionAsync<T>(Action<CreateCollectionOptions<T>>, CancellationToken, IClientSessionHandle)

DB.DropCollectionAsync<T>(IClientSessionHandle)

DB.CountEstimatedAsync<T>(CancellationToken)

DB.CountAsync<T>(Expression<Func<T, bool>>, CancellationToken, CountOptions, bool)

DB.CountAsync<T>(FilterDefinition<T>, CancellationToken, CountOptions, bool)

DB.CountAsync<T>(Func<FilterDefinitionBuilder<T>, FilterDefinition<T>>, CancellationToken, CountOptions, bool)

DB.CountAsync<T>(CancellationToken)

DB.ModifiedBy

DB.WithModifiedBy(ModifiedBy)

DB.InitAsync(string, MongoClientSettings, MongoDatabaseSettings, bool)

DB.AllDatabaseNamesAsync(string, int)

DB.AllDatabaseNamesAsync(MongoClientSettings)

DB.Database()

DB.Default

DB.Instance(string, MongoClientSettings)

DB.DatabaseName()

DB.ChangeDefaultDatabase(string, MongoClientSettings)

DB.Filter<T>()

DB.Sort<T>()

DB.Projection<T>()

DB.Entity<T>()

DB.Entity<T>(object)

DB.SetServiceProvider(IServiceProvider)

DB.OnBeforeSave<T>()

DB.OnBeforeUpdate<T>()

DB.DeleteAsync<T>(T, CancellationToken)

DB.DeleteAsync<T>(object, CancellationToken)

DB.DeleteAsync<T>(IEnumerable<T>, CancellationToken)

DB.DeleteAsync<T>(IEnumerable<object>, CancellationToken)

DB.DeleteAsync<T>(Expression<Func<T, bool>>, CancellationToken, Collation)

DB.DeleteAsync<T>(Func<FilterDefinitionBuilder<T>, FilterDefinition<T>>, CancellationToken, Collation)

DB.DeleteAsync<T>(FilterDefinition<T>, CancellationToken, Collation)

DB.Distinct<T, TProperty>()

DB.File<T>(string)

DB.Find<T>()

DB.Find<T, TProjection>()

DB.Fluent<T>(AggregateOptions)

DB.FluentTextSearch<T>(Search, string, bool, bool, string, AggregateOptions)

DB.GeoNear<T>(Coordinates2D, Expression<Func<T, object>>, bool, int?, int?, int?, BsonDocument, int?, Expression<Func<T, object>>, string, AggregateOptions)

DB.IgnoreGlobalFilters

DB.SetGlobalFilter<T>(Expression<Func<T, bool>>, bool)

DB.SetGlobalFilter<T>(Func<FilterDefinitionBuilder<T>, FilterDefinition<T>>, bool)

DB.SetGlobalFilter<T>(FilterDefinition<T>, bool)

DB.SetGlobalFilter(Type, string, bool)

DB.SetGlobalFilterForBaseClass<TBase>(Expression<Func<TBase, bool>>, bool)

DB.SetGlobalFilterForBaseClass<TBase>(Func<FilterDefinitionBuilder<TBase>, FilterDefinition<TBase>>, bool)

DB.SetGlobalFilterForBaseClass<TBase>(FilterDefinition<TBase>, bool)

DB.SetGlobalFilterForInterface<TInterface>(string, bool)

DB.Index<T>()

DB.InsertAsync<T>(T, CancellationToken)

DB.InsertAsync<T>(IEnumerable<T>, CancellationToken)

DB.MigrateAsync<T>()

DB.MigrateAsync()

DB.MigrationsAsync(IEnumerable<IMigration>)

DB.PagedSearch<T>()

DB.PagedSearch<T, TProjection>()

DB.PipelineCursorAsync<T, TResult>(Template<T, TResult>, CancellationToken, AggregateOptions)

DB.PipelineAsync<T, TResult>(Template<T, TResult>, CancellationToken, AggregateOptions)

DB.PipelineSingleAsync<T, TResult>(Template<T, TResult>, CancellationToken, AggregateOptions)

DB.PipelineFirstAsync<T, TResult>(Template<T, TResult>, CancellationToken, AggregateOptions)

DB.Queryable<T>(AggregateOptions)

DB.Replace<T>()

DB.SaveAsync<T>(T, CancellationToken)

DB.SaveAsync<T>(IEnumerable<T>, CancellationToken)

DB.SaveOnlyAsync<T>(T, Expression<Func<T, object>>, CancellationToken)

DB.SaveOnlyAsync<T>(T, IEnumerable<string>, CancellationToken)

DB.SaveOnlyAsync<T>(IEnumerable<T>, Expression<Func<T, object>>, CancellationToken)

DB.SaveOnlyAsync<T>(IEnumerable<T>, IEnumerable<string>, CancellationToken)

DB.SaveExceptAsync<T>(T, Expression<Func<T, object>>, CancellationToken)

DB.SaveExceptAsync<T>(T, IEnumerable<string>, CancellationToken)

DB.SaveExceptAsync<T>(IEnumerable<T>, Expression<Func<T, object>>, CancellationToken)

DB.SaveExceptAsync<T>(IEnumerable<T>, IEnumerable<string>, CancellationToken)

DB.SavePreservingAsync<T>(T, CancellationToken)

DB.NextSequentialNumberAsync<T>(CancellationToken)

DB.NextSequentialNumberAsync(string, CancellationToken)

DB.SessionHandle

DB.Transaction(ClientSessionOptions, TransactionOptions)

DB.Update<T>()

DB.UpdateAndGet<T>()

DB.UpdateAndGet<T, TProjection>()

DB.Watcher<T>(string)

DB.Watchers<T>()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Properties

Session

The client session handle for this transaction instance.

public IClientSessionHandle Session { get; }

Property Value

IClientSessionHandle

Methods

AbortAsync(CancellationToken)

Aborts and rolls back a transaction

public Task AbortAsync(CancellationToken cancellation = default)

Parameters

cancellation CancellationToken

An optional cancellation token

Returns

Task

CommitAsync(CancellationToken)

Commits a transaction to MongoDB

public Task CommitAsync(CancellationToken cancellation = default)

Parameters

cancellation CancellationToken

An optional cancellation token

Returns

Task

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public void Dispose()