Skip to main content

Version: 5.9

abstractDatabaseDriver <C>

Hierarchy

DatabaseDriver
- AbstractSqlDriver
- MongoDriver

Implements

IDatabaseDriver<C>

Properties

[EntityManagerType]

[EntityManagerType]: EntityManager<DatabaseDriver<C>>

readonlyconfig

config: Configuration<IDatabaseDriver<Connection>>

Methods

aggregate

aggregate(entityName: string, pipeline: any[]): Promise<any[]>

Implementation of IDatabaseDriver.aggregate
Parameters
- entityName: string
- pipeline: any[]
Returns Promise<any[]>

close

close(force?: boolean): Promise<void>

Implementation of IDatabaseDriver.close
Parameters
- optionalforce: boolean
Returns Promise<void>

connect

connect(): Promise<C>

Implementation of IDatabaseDriver.connect
Returns Promise<C>

convertException

convertException(exception: Error): DriverException

Implementation of IDatabaseDriver.convertException
Converts native db errors to standardized driver exceptions
Parameters
- exception: Error
Returns DriverException

abstractcount

count<T, P>(entityName: string, where: FilterQuery<T>, options?: CountOptions<T, P>): Promise<number>

Implementation of IDatabaseDriver.count
Type parameters
- T: object
- P: string = never
Parameters
- entityName: string
- where: FilterQuery<T>
- optionaloptions: CountOptions<T, P>
Returns Promise<number>

countVirtual

countVirtual<T>(entityName: string, where: FilterQuery<T>, options: CountOptions<T, any>): Promise<number>

Type parameters
- T: object
Parameters
- entityName: string
- where: FilterQuery<T>
- options: CountOptions<T, any>
Returns Promise<number>

createEntityManager

createEntityManager<D>(useContext?: boolean): D[typeof EntityManagerType]

Implementation of IDatabaseDriver.createEntityManager
Type parameters
- D: IDatabaseDriver<Connection, D> = IDatabaseDriver<Connection>
Parameters
- optionaluseContext: boolean
Returns D[typeof EntityManagerType]

ensureIndexes

ensureIndexes(): Promise<void>

Implementation of IDatabaseDriver.ensureIndexes
Returns Promise<void>

abstractfind

find<T, P>(entityName: string, where: FilterQuery<T>, options?: FindOptions<T, P>): Promise<EntityData<T>[]>

Implementation of IDatabaseDriver.find
Finds selection of entities
Type parameters
- T: object
- P: string = never
Parameters
- entityName: string
- where: FilterQuery<T>
- optionaloptions: FindOptions<T, P>
Returns Promise<EntityData<T>[]>

abstractfindOne

findOne<T, P>(entityName: string, where: FilterQuery<T>, options?: FindOneOptions<T, P>): Promise<null | EntityData<T>>

Implementation of IDatabaseDriver.findOne
Finds single entity (table row, document)
Type parameters
- T: object
- P: string = never
Parameters
- entityName: string
- where: FilterQuery<T>
- optionaloptions: FindOneOptions<T, P>
Returns Promise<null | EntityData<T>>

findVirtual

findVirtual<T>(entityName: string, where: FilterQuery<T>, options: FindOptions<T, any>): Promise<EntityData<T>[]>

Implementation of IDatabaseDriver.findVirtual
Type parameters
- T: object
Parameters
- entityName: string
- where: FilterQuery<T>
- options: FindOptions<T, any>
Returns Promise<EntityData<T>[]>

getConnection

getConnection(type?: ConnectionType): C

Implementation of IDatabaseDriver.getConnection
Parameters
- type: ConnectionType = 'write'
Returns C

getDependencies

getDependencies(): string[]

Implementation of IDatabaseDriver.getDependencies
Returns name of the underlying database dependencies (e.g. mongodb or mysql2) for SQL drivers it also returns knex in the array as connectors are not used directly there
Returns string[]

getMetadata

getMetadata(): MetadataStorage

Implementation of IDatabaseDriver.getMetadata
Returns MetadataStorage

getPlatform

getPlatform(): Platform

Implementation of IDatabaseDriver.getPlatform
Returns Platform

init

init(): Promise<void>

Implementation of IDatabaseDriver.init
Returns Promise<void>

loadFromPivotTable

loadFromPivotTable<T, O>(prop: EntityProperty<any>, owners: Primary<O>[][], where?: FilterQuery<any>, orderBy?: QueryOrderMap<T>[], ctx?: any, options?: FindOptions<T, any>): Promise<Dictionary<T[]>>

Implementation of IDatabaseDriver.loadFromPivotTable
When driver uses pivot tables for M:N, this method will load identifiers for given collections from them
Type parameters
- T: object
- O: object
Parameters
- prop: EntityProperty<any>
- owners: Primary<O>[][]
- optionalwhere: FilterQuery<any>
- optionalorderBy: QueryOrderMap<T>[]
- optionalctx: any
- optionaloptions: FindOptions<T, any>
Returns Promise<Dictionary<T[]>>

lockPessimistic

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

Implementation of IDatabaseDriver.lockPessimistic
Type parameters
- T
Parameters
- entity: T
- options: LockOptions
Returns Promise<void>

mapResult

mapResult<T>(result: EntityDictionary<T>, meta?: EntityMetadata<T>, populate?: PopulateOptions<T>[]): null | EntityData<T>

Implementation of IDatabaseDriver.mapResult
Type parameters
- T: object
Parameters
- result: EntityDictionary<T>
- optionalmeta: EntityMetadata<T>
- populate: PopulateOptions<T>[] = []
Returns null | EntityData<T>

abstractnativeDelete

nativeDelete<T>(entityName: string, where: FilterQuery<T>, options?: DeleteOptions<T>): Promise<QueryResult<T>>

Implementation of IDatabaseDriver.nativeDelete
Type parameters
- T: object
Parameters
- entityName: string
- where: FilterQuery<T>
- optionaloptions: DeleteOptions<T>
Returns Promise<QueryResult<T>>

abstractnativeInsert

nativeInsert<T>(entityName: string, data: EntityDictionary<T>, options?: NativeInsertUpdateOptions<T>): Promise<QueryResult<T>>

Implementation of IDatabaseDriver.nativeInsert
Type parameters
- T: object
Parameters
- entityName: string
- data: EntityDictionary<T>
- optionaloptions: NativeInsertUpdateOptions<T>
Returns Promise<QueryResult<T>>

abstractnativeInsertMany

nativeInsertMany<T>(entityName: string, data: EntityDictionary<T>[], options?: NativeInsertUpdateManyOptions<T>): Promise<QueryResult<T>>

Implementation of IDatabaseDriver.nativeInsertMany
Type parameters
- T: object
Parameters
- entityName: string
- data: EntityDictionary<T>[]
- optionaloptions: NativeInsertUpdateManyOptions<T>
Returns Promise<QueryResult<T>>

abstractnativeUpdate

nativeUpdate<T>(entityName: string, where: FilterQuery<T>, data: EntityDictionary<T>, options?: NativeInsertUpdateOptions<T>): Promise<QueryResult<T>>

Implementation of IDatabaseDriver.nativeUpdate
Type parameters
- T: object
Parameters
- entityName: string
- where: FilterQuery<T>
- data: EntityDictionary<T>
- optionaloptions: NativeInsertUpdateOptions<T>
Returns Promise<QueryResult<T>>

nativeUpdateMany

nativeUpdateMany<T>(entityName: string, where: FilterQuery<T>[], data: EntityDictionary<T>[], options?: NativeInsertUpdateManyOptions<T>): Promise<QueryResult<T>>

Implementation of IDatabaseDriver.nativeUpdateMany
Type parameters
- T: object
Parameters
- entityName: string
- where: FilterQuery<T>[]
- data: EntityDictionary<T>[]
- optionaloptions: NativeInsertUpdateManyOptions<T>
Returns Promise<QueryResult<T>>

reconnect

reconnect(): Promise<C>

Implementation of IDatabaseDriver.reconnect
Returns Promise<C>

setMetadata

setMetadata(metadata: MetadataStorage): void

Implementation of IDatabaseDriver.setMetadata
Parameters
- metadata: MetadataStorage
Returns void

syncCollection

syncCollection<T, O>(coll: Collection<T, O>, options?: DriverMethodOptions): Promise<void>

Implementation of IDatabaseDriver.syncCollection
Type parameters
- T: object
- O: object
Parameters
- coll: Collection<T, O>
- optionaloptions: DriverMethodOptions
Returns Promise<void>