LEVIATHAN v962456e · 962456eee1

atlantis-mysql · MySql

class Connection

since 0.1.0-alpha.1linux

bases
IDbConnection

Constructors

new

new(DbConfig cfg, Options opts)

Fields

asm

authPlugin

string authPlugin

awaitingPubKey

bool awaitingPubKey

broken

bool broken

busy

bool busy

cfg

DbConfig cfg

closed

bool closed

cmd

CommandState | None cmd

connecting

bool connecting

deprecateEof

bool deprecateEof

hs

HandshakeV10 | None hs

inTrans

bool inTrans

opts

Options opts

phase

int phase

queue

Array<() => void> queue

ready

bool ready

scrambleNonce

string scrambleNonce

seq

int seq

sock

startPromise

Promise<ConnOutcome> startPromise

stmtCache

Map<string, PreparedStmt> stmtCache

tlsActive

bool tlsActive

Methods

afterPrepParams

afterPrepParams(CommandState c) -> void

attach

attach(int fd) -> void

begin

begin() -> Promise<ITransaction>

beginExecute

beginExecute(PreparedStmt st, Array<string | int | float | bool | None> params, Promise<CommandResult> p) -> void

beginPing

beginPing(Promise<CommandResult> p) -> void

beginPrepare

beginPrepare(string sql, Promise<CommandResult> p) -> void

beginText

beginText(string sql, Promise<CommandResult> p) -> void

beginWith

beginWith(string isolation) -> Promise<ITransaction>

buildClientCaps

buildClientCaps(HandshakeV10 h) -> int

buildHandshakeResponse

buildHandshakeResponse(int clientCaps, string authResp, string plugin) -> string

buildResultSet

buildResultSet(CommandResult cr) -> ResultSet

classifyErr

classifyErr(string p) -> MySqlException

close

close() -> void

completeCmd

completeCmd(CommandResult r) -> void

completePrepare

completePrepare(CommandState c) -> void

dispatchCommand

dispatchCommand(CommandState c, string p) -> void

enqueue

enqueue(() => void starter) -> void

execPrepared

execPrepared(PreparedStmt st, Array<string | int | float | bool | None> params, string sql, Promise<CommandResult> out, bool allowReprepare) -> void

execute

execute(string sql, Array<string | int | float | bool | None> params) -> Promise<ExecResult>

fatal

fatal(MySqlException e) -> void

fatalErr

fatalErr(string p) -> void

finishConnect

finishConnect(MySqlException | None err) -> void

isBroken

isBroken() -> bool

isInTrans

isInTrans() -> bool

onAuth

onAuth(string p) -> void

onClose

onClose() -> void

onCommandPacket

onCommandPacket(string p) -> void

onHandshake

onHandshake(string p) -> void

onPacket

onPacket(int s, string payload) -> void

onPreparePacket

onPreparePacket(CommandState c, string p) -> void

ping

ping() -> Promise<bool>

postAuth

postAuth() -> void

pump

pump() -> void

query

query(string sql, Array<string | int | float | bool | None> params) -> Promise<ResultSet>

requireServerCaps

requireServerCaps(HandshakeV10 h) -> void

runCommand

runCommand(string sql, Array<string | int | float | bool | None> params) -> Promise<CommandResult>

runExecute

runExecute(PreparedStmt st, Array<string | int | float | bool | None> params) -> Promise<CommandResult>

runPing

runPing() -> Promise<CommandResult>

runPrepare

runPrepare(string sql) -> Promise<CommandResult>

runPreparedFlow

runPreparedFlow(string sql, Array<string | int | float | bool | None> params) -> Promise<CommandResult>

runText

runText(string sql) -> Promise<CommandResult>

sendPacket

sendPacket(string payload) -> void

sendRsaPassword

sendRsaPassword(string pem) -> void

start

start() -> Promise<ConnOutcome>

startCommand

startCommand() -> void

trackTrans

trackTrans(int status) -> void