atlantis-mysql · MySql
class Connection
since 0.1.0-alpha.1linux
- bases
IDbConnection
Constructors
new
new(DbConfig cfg, Options opts)Fields
asm
PacketAssembler asmauthPlugin
string authPluginawaitingPubKey
bool awaitingPubKeybroken
bool brokenbusy
bool busycfg
DbConfig cfgclosed
bool closedcmd
CommandState | None cmdconnecting
bool connectingdeprecateEof
bool deprecateEofhs
HandshakeV10 | None hsinTrans
bool inTransopts
Options optsphase
int phasequeue
Array<() => void> queueready
bool readyscrambleNonce
string scrambleNonceseq
int seqsock
TcpStream sockstartPromise
Promise<ConnOutcome> startPromisestmtCache
Map<string, PreparedStmt> stmtCachetlsActive
bool tlsActiveMethods
afterPrepParams
afterPrepParams(CommandState c) -> voidattach
attach(int fd) -> voidbegin
begin() -> Promise<ITransaction>beginExecute
beginExecute(PreparedStmt st, Array<string | int | float | bool | None> params, Promise<CommandResult> p) -> voidbeginPing
beginPing(Promise<CommandResult> p) -> voidbeginPrepare
beginPrepare(string sql, Promise<CommandResult> p) -> voidbeginText
beginText(string sql, Promise<CommandResult> p) -> voidbeginWith
beginWith(string isolation) -> Promise<ITransaction>buildClientCaps
buildClientCaps(HandshakeV10 h) -> intbuildHandshakeResponse
buildHandshakeResponse(int clientCaps, string authResp, string plugin) -> stringbuildResultSet
buildResultSet(CommandResult cr) -> ResultSetclassifyErr
classifyErr(string p) -> MySqlExceptionclose
close() -> voidcompleteCmd
completeCmd(CommandResult r) -> voidcompletePrepare
completePrepare(CommandState c) -> voiddispatchCommand
dispatchCommand(CommandState c, string p) -> voidenqueue
enqueue(() => void starter) -> voidexecPrepared
execPrepared(PreparedStmt st, Array<string | int | float | bool | None> params, string sql, Promise<CommandResult> out, bool allowReprepare) -> voidexecute
fatal
fatal(MySqlException e) -> voidfatalErr
fatalErr(string p) -> voidfinishConnect
finishConnect(MySqlException | None err) -> voidisBroken
isBroken() -> boolisInTrans
isInTrans() -> boolonAuth
onAuth(string p) -> voidonClose
onClose() -> voidonCommandPacket
onCommandPacket(string p) -> voidonHandshake
onHandshake(string p) -> voidonPacket
onPacket(int s, string payload) -> voidonPreparePacket
onPreparePacket(CommandState c, string p) -> voidping
ping() -> Promise<bool>postAuth
postAuth() -> voidpump
pump() -> voidquery
requireServerCaps
requireServerCaps(HandshakeV10 h) -> voidrunCommand
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) -> voidsendRsaPassword
sendRsaPassword(string pem) -> voidstart
start() -> Promise<ConnOutcome>startCommand
startCommand() -> voidtrackTrans
trackTrans(int status) -> void