Skip to main content
Module

x/mysql2/mod.ts>Connection

MySQL client for Deno with focus on performance. Supports prepared statements, non-utf8 encodings, binary log protocol, compression much more
sail-sail/mysql2
Latest
class Connection
extends EventEmitter
Re-export
import { Connection } from "https://deno.land/x/mysql2@v1.0.6/mod.ts";

Constructors

new
Connection(opts: { config: ConnectionConfig; })

Properties

_authPlugin: any
_closing: boolean
_fatalError: Error | null
_handshakePacket: Packet | null
_outOfOrderPackets: Packet[]
_pool: Pool | undefined | null
_protocolError: Error | null
_statements: LRU<any, any>
authorized: boolean | undefined
clientEncoding: string
clientHelloReply: any
compressedSequenceId: number
optional
connectionId: number
connectTimeout: number | undefined
packetParser: PacketParser
sequenceId: number
serverCapabilityFlags: number
serverConfig: any
serverEncoding: string
stream: Socket
threadId: number | undefined | null

Methods

_bumpCompressedSequenceId(numPackets: number)
_handleNetworkError(err: Error)
_handleTimeoutError()
_resetSequenceId()
addCommand(cmd: Command)
commit(cb: any)
connect(cb: any)
end(callback?: any): any
escape(value: string)
escapeId(value: string)
execute(
sql: string,
values?: any,
cb?: any,
)
format(sql: string, values?: any)
handlePacket(packet?: Packet)
ping(cb: any)
prepare(options: any, cb: Function)
protocolError(message?: string, code?: string | number)
query(
sql?: any,
values?: any,
cb?: any,
)
raw(sql: string)
rollback(cb: any)
serverHandshake(args?: any)
startTLS(_onSecure: () => void)
unprepare(sql: string)
write(buffer: Buffer)
writeColumns(columns: any)
writeEof(warnings?: any, statusFlags?: any)
writeError(args?: any)
writeOk(args?: any)
writePacket(packet: Packet)
writeTextResult(rows: any, columns: any)
writeTextRow(column: any)

Static Methods

createQuery(
sql: any,
values: any,
cb: any,
config: any,
)
statementKey(options: any)
interface Connection
implements EventEmitter
Re-export
import { type Connection } from "https://deno.land/x/mysql2@v1.0.6/mod.ts";

Properties

threadId: number

Methods

connect(): Promise<void>
ping(): Promise<void>
beginTransaction(): Promise<void>
commit(): Promise<void>
rollback(): Promise<void>
changeUser(options: ConnectionOptions): Promise<void>
query<T extends
>(sql: string): Promise<[T, FieldPacket[]]>
query<T extends
>(sql: string, values: any | any[] | { [param: string]: any; }): Promise<[T, FieldPacket[]]>
query<T extends
>(options: QueryOptions): Promise<[T, FieldPacket[]]>
query<T extends
>(options: QueryOptions, values: any | any[] | { [param: string]: any; }): Promise<[T, FieldPacket[]]>
execute<T extends
>(sql: string): Promise<[T, FieldPacket[]]>
execute<T extends
>(sql: string, values: any | any[] | { [param: string]: any; }): Promise<[T, FieldPacket[]]>
execute<T extends
>(options: QueryOptions): Promise<[T, FieldPacket[]]>
execute<T extends
>(options: QueryOptions, values: any | any[] | { [param: string]: any; }): Promise<[T, FieldPacket[]]>
unprepare(sql: string): void
end(options?: any): Promise<void>
destroy(): void
pause(): void
resume(): void
escape(value: any): string
escapeId(value: string): string
escapeId(values: string[]): string
format(sql: string, values?: any | any[] | { [param: string]: any; }): string