Show / Hide Table of Contents

Class BulkUpdateCommand

Base class for bulk update commands.

Inheritance
System.Object
Loggable
DataCommandBase<IBulkUpdateContext, IBulkDataOperationResult>
BulkOperationCommandBase<IBulkUpdateContext, IBulkDataOperationResult>
BulkUpdateCommand
InMemoryBulkUpdateCommand
MongoBulkUpdateCommand
Implements
ILoggable
IBulkUpdateCommand
IDataCommand<IBulkUpdateContext, IBulkDataOperationResult>
IDataCommand
IAsyncOperation
Inherited Members
BulkOperationCommandBase<IBulkUpdateContext, IBulkDataOperationResult>.GetMatchingCriteria<T>(IBulkUpdateContext)
BulkOperationCommandBase<IBulkUpdateContext, IBulkDataOperationResult>.GetBulkOperationResult<T>(IBulkUpdateContext, Int64, Int64, Expression<Func<T, Boolean>>)
BulkOperationCommandBase<IBulkUpdateContext, IBulkDataOperationResult>.CreateBulkOperationResult<T>(IBulkUpdateContext, Int64, Exception)
BulkOperationCommandBase<IBulkUpdateContext, IBulkDataOperationResult>.GetCriteriaString<T>(IBulkDataOperationContext, Expression<Func<T, Boolean>>)
DataCommandBase<IBulkUpdateContext, IBulkDataOperationResult>.ExecuteAsync(IBulkUpdateContext, CancellationToken)
DataCommandBase<IBulkUpdateContext, IBulkDataOperationResult>.IDataCommand.ExecuteAsync(IDataOperationContext, CancellationToken)
DataCommandBase<IBulkUpdateContext, IBulkDataOperationResult>.IAsyncOperation.ExecuteAsync(IContext, CancellationToken)
DataCommandBase<IBulkUpdateContext, IBulkDataOperationResult>.GetIdEqualityExpression<T>(IDataContext, Object)
DataCommandBase<IBulkUpdateContext, IBulkDataOperationResult>.TryGetLocalCache(IDataContext)
DataCommandBase<IBulkUpdateContext, IBulkDataOperationResult>.TryGetEntityActivator(IDataContext)
Loggable.Logger
Loggable.GetLogger()
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Kephas.Data.Commands
Assembly: Kephas.Data.dll
Syntax
[DataContextType(typeof(DataContextBase))]
public class BulkUpdateCommand : BulkOperationCommandBase<IBulkUpdateContext, IBulkDataOperationResult>, ILoggable, IBulkUpdateCommand, IDataCommand<IBulkUpdateContext, IBulkDataOperationResult>, IDataCommand, IAsyncOperation

Methods

| Improve this Doc View Source

BulkUpdateAsync<T>(IBulkUpdateContext, CancellationToken)

Updates the entities matching the provided criteria and returns the number of affected entities.

Declaration
protected virtual Task<IBulkDataOperationResult> BulkUpdateAsync<T>(IBulkUpdateContext bulkUpdateContext, CancellationToken cancellationToken)

    where T : class
Parameters
Type Name Description
IBulkUpdateContext bulkUpdateContext

The bulk update context.

System.Threading.CancellationToken cancellationToken

Optional. The cancellation token.

Returns
Type Description
System.Threading.Tasks.Task<IBulkDataOperationResult>

A promise of the number of updated entities.

Type Parameters
Name Description
T

The type of the entity.

| Improve this Doc View Source

BulkUpdateCoreAsync<T>(IBulkUpdateContext, Expression<Func<T, Boolean>>, IDictionary<String, Object>, CancellationToken)

Updates the entities matching the provided criteria and returns the number of affected entities.

Declaration
protected virtual Task<long> BulkUpdateCoreAsync<T>(IBulkUpdateContext bulkDeleteContext, Expression<Func<T, bool>> criteria, IDictionary<string, object> values, CancellationToken cancellationToken)

    where T : class
Parameters
Type Name Description
IBulkUpdateContext bulkDeleteContext

The bulk delete context.

System.Linq.Expressions.Expression<System.Func<T, System.Boolean>> criteria

The criteria for finding the entities to operate on.

System.Collections.Generic.IDictionary<System.String, System.Object> values

The values.

System.Threading.CancellationToken cancellationToken

The cancellation token.

Returns
Type Description
System.Threading.Tasks.Task<System.Int64>

A promise of the number of updated entities.

Type Parameters
Name Description
T

The type of the entity.

| Improve this Doc View Source

ExecuteAsync(IBulkUpdateContext, CancellationToken)

Executes the data command asynchronously.

Declaration
public override Task<IBulkDataOperationResult> ExecuteAsync(IBulkUpdateContext operationContext, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
IBulkUpdateContext operationContext

The operation context.

System.Threading.CancellationToken cancellationToken

The cancellation token (optional).

Returns
Type Description
System.Threading.Tasks.Task<IBulkDataOperationResult>

A promise of a IDataCommandResult.

Overrides
Kephas.Data.Commands.DataCommandBase<Kephas.Data.Commands.IBulkUpdateContext, Kephas.Data.Commands.IBulkDataOperationResult>.ExecuteAsync(Kephas.Data.Commands.IBulkUpdateContext, System.Threading.CancellationToken)
| Improve this Doc View Source

UpdateEntity<T>(T, IDictionary<String, Object>)

Updates the entity with the values in the dictionary.

Declaration
protected virtual void UpdateEntity<T>(T entity, IDictionary<string, object> values)
Parameters
Type Name Description
T entity

The entity.

System.Collections.Generic.IDictionary<System.String, System.Object> values

The values.

Type Parameters
Name Description
T

The entity type.

Implements

ILoggable
IBulkUpdateCommand
IDataCommand<TOperationContext, TResult>
IDataCommand
IAsyncOperation

Extension Methods

DynamicObjectExtensions.SetPropertyValue(Object, String, Object)
DynamicObjectExtensions.TrySetPropertyValue(Object, String, Object)
DynamicObjectExtensions.GetPropertyValue(Object, String)
DynamicObjectExtensions.TryGetPropertyValue(Object, String, out Object)
DynamicObjectExtensions.GetRuntimeTypeInfo(Object)
DynamicObjectExtensions.ToDynamic(Object)
DynamicObjectExtensions.ToExpando(Object)
BehaviorValue.ToBehaviorValue<TValue>(TValue)
CollectionExtensions.AddRange<T, TItem>(T, IEnumerable<TItem>)
LoggingExtensions.GetLogger(Object, IContext)
TypeExtensions.GetAbstractType(Object)
TypeExtensions.GetAbstractTypeInfo(Object)
ReflectionHelper.GetTypeInfo(Object)
EntityEntryExtensions.TryGetAttachedEntityEntry(Object)
  • Improve this Doc
  • View Source
Back to top Generated by DocFX