Class Connection

constructor

• new Connection(
      websocket: ExaWebsocket,
      logger: ILogger,
      name: string,
      onClose?: (event: unknown) => void,
  ): Connection

  Parameters

  • websocket: ExaWebsocket
  • logger: ILogger
  • name: string
  • OptionalonClose: (event: unknown) => void

  Returns Connection

name

active

• get active(): boolean

  Returns boolean

broken

• get broken(): boolean

  Returns boolean

connection

• get connection(): ExaWebsocket

  Returns ExaWebsocket

breakConnection

• breakConnection(error: Error, closeSocket?: boolean): void

  Parameters

  • error: Error
  • closeSocket: boolean = true

  Returns void

close

• close(): Promise<void>

  Returns Promise<void>

sendCommand

• sendCommand<T>(
      cmd: Commands,
      getCancel?: (cancel?: Cancelable) => void,
  ): Promise<SQLResponse<T>>

  Type Parameters

  • T

  Parameters

  • cmd: Commands
  • OptionalgetCancel: (cancel?: Cancelable) => void

  Returns Promise<SQLResponse<T>>

sendCommandWithNoResult

• sendCommandWithNoResult(cmd: AbortQueryCommand): Promise<undefined>

  Parameters

  • cmd: AbortQueryCommand

  Returns Promise<undefined>

setCompression

• setCompression(compression: boolean): void

  Parameters

  • compression: boolean

  Returns void