Class BulkTransactionLoader

When importing lots (10k+) of transactions (to bulk delete, change status/etc) loading them all individually can take hours. This bulk loader is designed to pre-load as much of each of them in bulk at once, so when they individually load there is less to do - typically this can reduce 30k transactions from 3 hours to 5 mins

Inheritance

object

BulkProcessorLoader

BulkProcessorLoader<ITransactionProcessor>

BulkTransactionLoader

Implements

IDisposable

Inherited Members

BulkProcessorLoader<ITransactionProcessor>.ThreadSafeAttachToOtherProcessors(IEntityUpdater)

BulkProcessorLoader<ITransactionProcessor>.InternalLoad(IEntityUpdater)

BulkProcessorLoader.Load(IEntityUpdater)

BulkProcessorLoader.Dispose(bool)

BulkProcessorLoader.Dispose()

BulkProcessorLoader.Loaded

BulkProcessorLoader.Source

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: LemonEdge.API.Core.FinancialServices.Processors.Transactional

Assembly: LemonEdge.API.Core.FinancialServices.dll

Syntax

public class BulkTransactionLoader : BulkProcessorLoader<ITransactionProcessor>, IDisposable

Constructors

BulkTransactionLoader(ITransactionProcessor)

Declaration

public BulkTransactionLoader(ITransactionProcessor source)

Parameters

Type	Name	Description
ITransactionProcessor	source

Methods

InternalLoad(IEnumerable<ITransactionProcessor>, IEntityUpdater, IReadOnlyCache, UserInfo)

Declaration

protected override Task InternalLoad(IEnumerable<ITransactionProcessor> otherProcessors, IEntityUpdater context, IReadOnlyCache cache, UserInfo user)

Parameters

Type	Name	Description
IEnumerable<ITransactionProcessor>	otherProcessors
IEntityUpdater	context
IReadOnlyCache	cache
UserInfo	user

Returns

Type	Description
Task

Overrides

BulkProcessorLoader<ITransactionProcessor>.InternalLoad(IEnumerable<ITransactionProcessor>, IEntityUpdater, IReadOnlyCache, UserInfo)

TryGetBulkLoadedPostingAllocations(Guid, out ConcurrentDictionary<Guid, List<GLPostingAllocated>>)

Declaration

public bool TryGetBulkLoadedPostingAllocations(Guid transactionId, out ConcurrentDictionary<Guid, List<GLPostingAllocated>> allocations)

Parameters

Type	Name	Description
Guid	transactionId
ConcurrentDictionary<Guid, List<GLPostingAllocated>>	allocations

Returns

Type	Description
bool

TryGetBulkLoadedPostings(Guid, out ConcurrentDictionary<Guid, List<GLPosting>>)

Declaration

public bool TryGetBulkLoadedPostings(Guid transactionId, out ConcurrentDictionary<Guid, List<GLPosting>> postings)

Parameters

Type	Name	Description
Guid	transactionId
ConcurrentDictionary<Guid, List<GLPosting>>	postings

Returns

Type	Description
bool

TryGetBulkLoadedSubTransactions(Guid, out List<ITransaction>)

Declaration

public bool TryGetBulkLoadedSubTransactions(Guid transactionId, out List<ITransaction> subTransactions)

Parameters

Type	Name	Description
Guid	transactionId
List<ITransaction>	subTransactions

Returns

Type	Description
bool

TryGetBulkLoadedTransactionAllocations(Guid, out ConcurrentDictionary<Guid, List<TransactionAllocated>>)

Declaration

public bool TryGetBulkLoadedTransactionAllocations(Guid transactionId, out ConcurrentDictionary<Guid, List<TransactionAllocated>> allocations)

Parameters

Type	Name	Description
Guid	transactionId
ConcurrentDictionary<Guid, List<TransactionAllocated>>	allocations

Returns

Type	Description
bool

TryGetBulkLoadedTransactionLinks(Guid, out List<ITransactionLink>)

Declaration

public bool TryGetBulkLoadedTransactionLinks(Guid transactionId, out List<ITransactionLink> links)

Parameters

Type	Name	Description
Guid	transactionId
List<ITransactionLink>	links

Returns

Type	Description
bool

Implements

IDisposable

Extension Methods

LinqExtensions.AsArray<T>(T)

LinqExtensions.ToArrayOfOne<T>(T)

LinqExtensions.ToListOfOne<T>(T)

MiscExtensions.SetIfNotEqual<T, TP>(T, Expression<Func<T, TP>>, TP)

WeakReferenceExtensions.WeakReference(object)

SQLExtensions.ToSQLValue(object, bool)

ReflectionExtensions.ClearEventInvocations(object, string)

StringExtensions.ToCSVFormatString(object, Type)