UnitOfWork

Index

Constructors

• constructor

Methods

• cancelOrphanRemoval
• clear
• clearActionsQueue
• commit
• computeChangeSet
• computeChangeSets
• getById
• getChangeSets
• getCollectionUpdates
• getExtraUpdates
• getIdentityMap
• getOriginalEntityData
• getPersistStack
• getRemoveStack
• lock
• merge
• persist
• recomputeSingleChangeSet
• remove
• scheduleExtraUpdate
• scheduleOrphanRemoval
• shouldAutoFlush
• tryGetById
• unsetIdentity

Constructors

constructor

• new UnitOfWork(em: EntityManager<IDatabaseDriver<Connection>>): UnitOfWork

• Parameters

  • em: EntityManager<IDatabaseDriver<Connection>>

  Returns UnitOfWork

Methods

cancelOrphanRemoval

• cancelOrphanRemoval(entity: AnyEntity<any>, visited?: Set<AnyEntity<any>>): void

• Parameters

  • entity: AnyEntity<any>

  • optionalvisited: Set<AnyEntity<any>>

  Returns void

clear

• clear(): void

• Returns void

clearActionsQueue

• clearActionsQueue(): void

• Returns void

commit

• commit(): Promise<void>

• Returns Promise<void>

computeChangeSet

• computeChangeSet<T>(entity: T): void

• Type parameters

  • T: AnyEntity<T>

  Parameters

  • entity: T

  Returns void

computeChangeSets

• computeChangeSets(): void

• Returns void

getById

• getById<T>(entityName: string, id: Primary<T> | Primary<T>[], schema?: string): undefined | T

• Returns entity from the identity map. For composite keys, you need to pass an array of PKs in the same order as they are defined in meta.primaryKeys.

  ---

  Type parameters

  • T: AnyEntity<T>

  Parameters

  • entityName: string

  • id: Primary<T> | Primary<T>[]

  • optionalschema: string

  Returns undefined | T

getChangeSets

• getChangeSets(): ChangeSet<AnyEntity<any>>[]

• Returns ChangeSet<AnyEntity<any>>[]

getCollectionUpdates

• getCollectionUpdates(): Collection<AnyEntity<any>, unknown>[]

• Returns Collection<AnyEntity<any>, unknown>[]

getExtraUpdates

• getExtraUpdates(): Set<[AnyEntity<any>, string | string[], AnyEntity<any> | Reference<any> | AnyEntity<any>[] | Collection<any, unknown>]>

• Returns Set<[AnyEntity<any>, string | string[], AnyEntity<any> | Reference<any> | AnyEntity<any>[] | Collection<any, unknown>]>

getIdentityMap

• getIdentityMap(): IdentityMap

• Returns map of all managed entities.

  ---

  Returns IdentityMap

getOriginalEntityData

• getOriginalEntityData<T>(): AnyEntity<any>[]
• getOriginalEntityData<T>(entity: T): undefined | EntityData<T>

• Returns stored snapshot of entity state that is used for change set computation.

  @deprecated

  use uow.getOriginalEntityData(entity)

  ---

  Type parameters

  • T: AnyEntity<T>

  Returns AnyEntity<any>[]

getPersistStack

• getPersistStack(): Set<AnyEntity<any>>

• Returns Set<AnyEntity<any>>

getRemoveStack

• getRemoveStack(): Set<AnyEntity<any>>

• Returns Set<AnyEntity<any>>

lock

• lock<T>(entity: T, options: LockOptions): Promise<void>

• Type parameters

  • T: AnyEntity<T>

  Parameters

  • entity: T

  • options: LockOptions

  Returns Promise<void>

merge

• merge<T>(entity: T, visited?: Set<AnyEntity<any>>): void

• Type parameters

  • T: AnyEntity<T>

  Parameters

  • entity: T

  • optionalvisited: Set<AnyEntity<any>>

  Returns void

persist

• persist<T>(entity: T, visited?: Set<AnyEntity<any>>, options?: { cascade?: boolean; checkRemoveStack?: boolean }): void

• Type parameters

  • T: AnyEntity<T>

  Parameters

  • entity: T

  • optionalvisited: Set<AnyEntity<any>>

  • options: { cascade?: boolean; checkRemoveStack?: boolean } = {}

  Returns void

recomputeSingleChangeSet

• recomputeSingleChangeSet<T>(entity: T): void

• Type parameters

  • T: AnyEntity<T>

  Parameters

  • entity: T

  Returns void

remove

• remove<T>(entity: T, visited?: Set<AnyEntity<any>>, options?: { cascade?: boolean }): void

• Type parameters

  • T: AnyEntity<T>

  Parameters

  • entity: T

  • optionalvisited: Set<AnyEntity<any>>

  • options: { cascade?: boolean } = {}

  Returns void

scheduleExtraUpdate

• scheduleExtraUpdate<T>(changeSet: ChangeSet<T>, props: EntityProperty<T>[]): void

• Type parameters

  • T

  Parameters

  • changeSet: ChangeSet<T>

  • props: EntityProperty<T>[]

  Returns void

scheduleOrphanRemoval

• scheduleOrphanRemoval(entity?: AnyEntity<any>, visited?: Set<AnyEntity<any>>): void

• Parameters

  • optionalentity: AnyEntity<any>

  • optionalvisited: Set<AnyEntity<any>>

  Returns void

shouldAutoFlush

• shouldAutoFlush<T>(meta: EntityMetadata<T>): boolean

• Type parameters

  • T: AnyEntity<T>

  Parameters

  • meta: EntityMetadata<T>

  Returns boolean

tryGetById

• tryGetById<T>(entityName: string, where: FilterQuery<T>, schema?: string, strict?: boolean): null | T

• Type parameters

  • T: AnyEntity<T>

  Parameters

  • entityName: string

  • where: FilterQuery<T>

  • optionalschema: string

  • strict: boolean = true

  Returns null | T

unsetIdentity

• unsetIdentity(entity: AnyEntity<any>): void

• Parameters

  • entity: AnyEntity<any>

  Returns void