abstractConnection

Hierarchy

• Connection
  • AbstractSqlConnection
  • MongoConnection

Index

Constructors

• constructor

Methods

• begin
• close
• commit
• connect
• execute
• getClientUrl
• getConnectionOptions
• getDefaultClientUrl
• getPlatform
• isConnected
• rollback
• setMetadata
• setPlatform
• transactional

Constructors

constructor

• new Connection(config: Configuration<IDatabaseDriver<Connection>>, options?: ConnectionOptions, type?: ConnectionType): Connection

• Parameters

  • config: Configuration<IDatabaseDriver<Connection>>

  • optionaloptions: ConnectionOptions

  • type: ConnectionType = 'write'

  Returns Connection

Methods

begin

• begin(options?: { ctx?: any; eventBroadcaster?: TransactionEventBroadcaster; isolationLevel?: IsolationLevel }): Promise<any>

• Parameters

  • optionaloptions: { ctx?: any; eventBroadcaster?: TransactionEventBroadcaster; isolationLevel?: IsolationLevel }

  Returns Promise<any>

close

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

• Closes the database connection (aka disconnect)

  ---

  Parameters

  • optionalforce: boolean

  Returns Promise<void>

commit

• commit(ctx: any, eventBroadcaster?: TransactionEventBroadcaster): Promise<void>

• Parameters

  • ctx: any

  • optionaleventBroadcaster: TransactionEventBroadcaster

  Returns Promise<void>

abstractconnect

• connect(): Promise<void>

• Establishes connection to database

  ---

  Returns Promise<void>

abstractexecute

• execute<T>(query: string, params?: any[], method?: get | all | run, ctx?: any): Promise<any>

• Type parameters

  • T

  Parameters

  • query: string

  • optionalparams: any[]

  • optionalmethod: get | all | run

  • optionalctx: any

  Returns Promise<any>

getClientUrl

• getClientUrl(): string

• Returns string

getConnectionOptions

• getConnectionOptions(): ConnectionConfig

• Returns ConnectionConfig

abstractgetDefaultClientUrl

• getDefaultClientUrl(): string

• Returns default client url for given driver (e.g. mongodb://127.0.0.1:27017 for mongodb)

  ---

  Returns string

getPlatform

• getPlatform(): Platform

• Returns Platform

abstractisConnected

• isConnected(): Promise<boolean>

• Are we connected to the database

  ---

  Returns Promise<boolean>

rollback

• rollback(ctx: any, eventBroadcaster?: TransactionEventBroadcaster): Promise<void>

• Parameters

  • ctx: any

  • optionaleventBroadcaster: TransactionEventBroadcaster

  Returns Promise<void>

setMetadata

• setMetadata(metadata: MetadataStorage): void

• Parameters

  • metadata: MetadataStorage

  Returns void

setPlatform

• setPlatform(platform: Platform): void

• Parameters

  • platform: Platform

  Returns void

transactional

• transactional<T>(cb: (trx: any) => Promise<T>, options?: { ctx?: any; eventBroadcaster?: TransactionEventBroadcaster; isolationLevel?: IsolationLevel }): Promise<T>

• Type parameters

  • T

  Parameters

  • cb: (trx: any) => Promise<T>

  • optionaloptions: { ctx?: any; eventBroadcaster?: TransactionEventBroadcaster; isolationLevel?: IsolationLevel }

  Returns Promise<T>