Class: UnitOfWork#
core.UnitOfWork
Constructors#
constructor#
+ new UnitOfWork(em: EntityManager<IDatabaseDriver<Connection>>): UnitOfWork
Parameters:#
| Name | Type |
|---|---|
em | EntityManager<IDatabaseDriver<Connection>> |
Returns: UnitOfWork
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:32
Properties#
changeSetComputer#
• Private Readonly changeSetComputer: ChangeSetComputer
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:30
changeSetPersister#
• Private Readonly changeSetPersister: ChangeSetPersister
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:31
changeSets#
• Private Readonly changeSets: Map<AnyEntity<any>, ChangeSet<AnyEntity<any>>>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:23
collectionUpdates#
• Private Readonly collectionUpdates: Set<Collection<AnyEntity<any>, unknown>>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:24
comparator#
• Private Readonly comparator: EntityComparator
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:29
eventManager#
• Private Readonly eventManager: EventManager
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:28
extraUpdates#
• Private Readonly extraUpdates: Set<[AnyEntity<any>, string, Reference<any> | AnyEntity<any> | Collection<any, unknown>]>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:25
identityMap#
• Private Readonly identityMap: IdentityMap
map of references to managed entities
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:18
metadata#
• Private Readonly metadata: MetadataStorage
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:26
orphanRemoveStack#
• Private Readonly orphanRemoveStack: Set<AnyEntity<any>>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:22
persistStack#
• Private Readonly persistStack: Set<AnyEntity<any>>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:20
platform#
• Private Readonly platform: Platform
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:27
removeStack#
• Private Readonly removeStack: Set<AnyEntity<any>>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:21
working#
• Private working: boolean= false
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:32
Methods#
cancelOrphanRemoval#
â–¸ cancelOrphanRemoval(entity: AnyEntity<any>): void
Parameters:#
| Name | Type |
|---|---|
entity | AnyEntity<any> |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:323
cascade#
â–¸ Privatecascade<T>(entity: T, type: Cascade, visited: WeakSet<AnyEntity<any>>, options?: { checkRemoveStack?: boolean }): void
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
entity | T |
type | Cascade |
visited | WeakSet<AnyEntity<any>> |
options | object |
options.checkRemoveStack? | boolean |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:459
cascadeReference#
â–¸ PrivatecascadeReference<T>(entity: T, prop: EntityProperty<T>, type: Cascade, visited: WeakSet<AnyEntity<any>>, options: { checkRemoveStack?: boolean }): void
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
entity | T |
prop | EntityProperty<T> |
type | Cascade |
visited | WeakSet<AnyEntity<any>> |
options | object |
options.checkRemoveStack? | boolean |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:477
checkOrphanRemoval#
â–¸ PrivatecheckOrphanRemoval<T>(changeSet: ChangeSet<T>): void
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
changeSet | ChangeSet<T> |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:370
checkUniqueProps#
â–¸ PrivatecheckUniqueProps<T>(changeSet: ChangeSet<T>): boolean
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
changeSet | ChangeSet<T> |
Returns: boolean
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:355
clear#
â–¸ clear(): void
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:270
commit#
â–¸ commit(): Promise<void>
Returns: Promise<void>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:216
commitCreateChangeSets#
â–¸ PrivatecommitCreateChangeSets<T>(changeSets: ChangeSet<T>[], ctx?: any): Promise<void>
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
changeSets | ChangeSet<T>[] |
ctx? | any |
Returns: Promise<void>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:613
commitDeleteChangeSets#
â–¸ PrivatecommitDeleteChangeSets<T>(changeSets: ChangeSet<T>[], ctx?: any): Promise<void>
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
changeSets | ChangeSet<T>[] |
ctx? | any |
Returns: Promise<void>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:668
commitUpdateChangeSets#
â–¸ PrivatecommitUpdateChangeSets<T>(changeSets: ChangeSet<T>[], ctx?: any, batched?: boolean): Promise<void>
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type | Default value |
|---|---|---|
changeSets | ChangeSet<T>[] | - |
ctx? | any | - |
batched | boolean | true |
Returns: Promise<void>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:651
computeChangeSet#
â–¸ computeChangeSet<T>(entity: T): void
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
entity | T |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:158
computeChangeSets#
â–¸ computeChangeSets(): void
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:287
findExtraUpdates#
â–¸ PrivatefindExtraUpdates<T>(changeSet: ChangeSet<T>, props: EntityProperty<T>[]): void
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
changeSet | ChangeSet<T> |
props | EntityProperty<T>[] |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:636
findNewEntities#
â–¸ PrivatefindNewEntities<T>(entity: T, visited?: WeakSet<AnyEntity<any>>): void
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
entity | T |
visited | WeakSet<AnyEntity<any>> |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:327
fixMissingReference#
â–¸ PrivatefixMissingReference<T>(entity: T, prop: EntityProperty<T>): void
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
entity | T |
prop | EntityProperty<T> |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:553
getById#
â–¸ getById<T>(entityName: string, id: Primary<T> | Primary<T>[]): 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:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
entityName | string |
id | Primary<T> | Primary<T>[] |
Returns: undefined | T
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:87
getChangeSetGroups#
â–¸ PrivategetChangeSetGroups(): object
Orders change sets so FK constrains are maintained, ensures stable order (needed for node < 11)
Returns: object
| Name | Type |
|---|---|
create | |
delete | |
update |
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:688
getChangeSets#
â–¸ getChangeSets(): ChangeSet<AnyEntity<any>>[]
Returns: ChangeSet<AnyEntity<any>>[]
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:146
getCollectionUpdates#
â–¸ getCollectionUpdates(): Collection<AnyEntity<any>, unknown>[]
Returns: Collection<AnyEntity<any>, unknown>[]
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:150
getCommitOrder#
â–¸ PrivategetCommitOrder(): string[]
Returns: string[]
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:704
getExtraUpdates#
â–¸ getExtraUpdates(): Set<[AnyEntity<any>, string, Reference<any> | AnyEntity<any> | Collection<any, unknown>]>
Returns: Set<[AnyEntity<any>, string, Reference<any> | AnyEntity<any> | Collection<any, unknown>]>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:154
getIdentityMap#
â–¸ getIdentityMap(): IdentityMap
Returns map of all managed entities.
Returns: IdentityMap
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:111
getOriginalEntityData#
â–¸ getOriginalEntityData<T>(): AnyEntity<any>[]
deprecated use uow.getOriginalEntityData(entity)
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Returns: AnyEntity<any>[]
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:118
â–¸ getOriginalEntityData<T>(entity: T): undefined | EntityData<T>
Returns stored snapshot of entity state that is used for change set computation.
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
entity | T |
Returns: undefined | EntityData<T>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:123
getPersistStack#
â–¸ getPersistStack(): Set<AnyEntity<any>>
Returns: Set<AnyEntity<any>>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:138
getRemoveStack#
â–¸ getRemoveStack(): Set<AnyEntity<any>>
Returns: Set<AnyEntity<any>>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:142
initIdentifier#
â–¸ PrivateinitIdentifier<T>(entity: T): void
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
entity | T |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:385
isCollectionSelfReferenced#
â–¸ PrivateisCollectionSelfReferenced(collection: Collection<AnyEntity<any>, unknown>, visited: WeakSet<AnyEntity<any>>): boolean
Parameters:#
| Name | Type |
|---|---|
collection | Collection<AnyEntity<any>, unknown> |
visited | WeakSet<AnyEntity<any>> |
Returns: boolean
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:505
lock#
â–¸ lock<T>(entity: T, mode: LockMode, version?: number | Date): Promise<void>
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
entity | T |
mode | LockMode |
version? | number | Date |
Returns: Promise<void>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:256
lockOptimistic#
â–¸ PrivatelockOptimistic<T>(entity: T, meta: EntityMetadata<T>, version: number | Date): Promise<void>
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
entity | T |
meta | EntityMetadata<T> |
version | number | Date |
Returns: Promise<void>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:531
lockPessimistic#
â–¸ PrivatelockPessimistic<T>(entity: T, mode: LockMode): Promise<void>
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
entity | T |
mode | LockMode |
Returns: Promise<void>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:523
merge#
â–¸ merge<T>(entity: T, visited?: WeakSet<AnyEntity<any>>): void
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
entity | T |
visited? | WeakSet<AnyEntity<any>> |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:36
persist#
â–¸ persist<T>(entity: T, visited?: WeakSet<AnyEntity<any>>, checkRemoveStack?: boolean): void
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type | Default value |
|---|---|---|
entity | T | - |
visited | WeakSet<AnyEntity<any>> | - |
checkRemoveStack | boolean | false |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:189
persistToDatabase#
â–¸ PrivatepersistToDatabase(groups: { create: ; delete: ; update: }, tx?: any): Promise<void>
Parameters:#
| Name | Type |
|---|---|
groups | object |
groups.create | - |
groups.delete | - |
groups.update | - |
tx? | any |
Returns: Promise<void>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:569
postCommitCleanup#
â–¸ PrivatepostCommitCleanup(): void
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:449
processReference#
â–¸ PrivateprocessReference<T>(parent: T, prop: EntityProperty<T>, reference: any, visited: WeakSet<AnyEntity<any>>): void
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
parent | T |
prop | EntityProperty<T> |
reference | any |
visited | WeakSet<AnyEntity<any>> |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:395
processToManyReference#
â–¸ PrivateprocessToManyReference<T>(reference: Collection<AnyEntity<any>, unknown>, visited: WeakSet<AnyEntity<any>>, parent: T, prop: EntityProperty<T>): void
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
reference | Collection<AnyEntity<any>, unknown> |
visited | WeakSet<AnyEntity<any>> |
parent | T |
prop | EntityProperty<T> |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:413
processToOneReference#
â–¸ PrivateprocessToOneReference<T>(reference: any, visited: WeakSet<AnyEntity<any>>): void
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
reference | any |
visited | WeakSet<AnyEntity<any>> |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:407
recomputeSingleChangeSet#
â–¸ recomputeSingleChangeSet<T>(entity: T): void
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
entity | T |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:172
registerManaged#
â–¸ registerManaged<T>(entity: T, data?: EntityData<T>, refresh?: boolean, newEntity?: boolean): T
internal
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type |
|---|---|
entity | T |
data? | EntityData<T> |
refresh? | boolean |
newEntity? | boolean |
Returns: T
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:66
remove#
â–¸ remove(entity: AnyEntity<any>, visited?: WeakSet<AnyEntity<any>>): void
Parameters:#
| Name | Type |
|---|---|
entity | AnyEntity<any> |
visited | WeakSet<AnyEntity<any>> |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:203
runHooks#
â–¸ PrivaterunHooks<T>(type: EventType, changeSet: ChangeSet<T>, sync?: boolean): Promise<unknown>
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type | Default value |
|---|---|---|
type | EventType | - |
changeSet | ChangeSet<T> | - |
sync | boolean | false |
Returns: Promise<unknown>
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:426
scheduleExtraUpdate#
â–¸ scheduleExtraUpdate<T>(changeSet: ChangeSet<T>, prop: EntityProperty<T>): void
Type parameters:#
| Name |
|---|
T |
Parameters:#
| Name | Type |
|---|---|
changeSet | ChangeSet<T> |
prop | EntityProperty<T> |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:311
scheduleOrphanRemoval#
â–¸ scheduleOrphanRemoval(entity?: AnyEntity<any>): void
Parameters:#
| Name | Type |
|---|---|
entity? | AnyEntity<any> |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:317
shouldCascade#
â–¸ PrivateshouldCascade(prop: EntityProperty<any>, type: Cascade): boolean
Parameters:#
| Name | Type |
|---|---|
prop | EntityProperty<any> |
type | Cascade |
Returns: boolean
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:510
tryGetById#
â–¸ tryGetById<T>(entityName: string, where: FilterQuery<T>, strict?: boolean): null | T
Type parameters:#
| Name | Type |
|---|---|
T | AnyEntity<T> |
Parameters:#
| Name | Type | Default value |
|---|---|---|
entityName | string | - |
where | FilterQuery<T> | - |
strict | boolean | true |
Returns: null | T
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:98
unsetIdentity#
â–¸ unsetIdentity(entity: AnyEntity<any>): void
Parameters:#
| Name | Type |
|---|---|
entity | AnyEntity<any> |
Returns: void
Defined in: packages/core/src/unit-of-work/UnitOfWork.ts:275