Name	Size	Mode	Actions
auth_switch_request.js	1055	0644	editdlrm
auth_switch_request_more_data.js	793	0644	editdlrm
auth_switch_response.js	707	0644	editdlrm
binary_row.js	2087	0644	editdlrm
binlog_dump.js	984	0644	editdlrm
binlog_query_statusvars.js	3515	0644	editdlrm
change_user.js	3306	0644	editdlrm
close_statement.js	454	0644	editdlrm
column_definition.js	4499	0644	editdlrm
execute.js	4669	0644	editdlrm
handshake.js	3914	0644	editdlrm
handshake_response.js	5053	0644	editdlrm
index.js	4398	0644	editdlrm
packet.js	24810	0644	editdlrm
prepared_statement_header.js	375	0644	editdlrm
prepare_statement.js	800	0644	editdlrm
query.js	775	0644	editdlrm
register_slave.js	1629	0644	editdlrm
resultset_header.js	4105	0644	editdlrm
ssl_request.js	633	0644	editdlrm
text_row.js	1196	0644	editdlrm

'use strict'; // http://dev.mysql.com/doc/internals/en/query-event.html const keys = { FLAGS2: 0, SQL_MODE: 1, CATALOG: 2, AUTO_INCREMENT: 3, CHARSET: 4, TIME_ZONE: 5, CATALOG_NZ: 6, LC_TIME_NAMES: 7, CHARSET_DATABASE: 8, TABLE_MAP_FOR_UPDATE: 9, MASTER_DATA_WRITTEN: 10, INVOKERS: 11, UPDATED_DB_NAMES: 12, MICROSECONDS: 3 }; module.exports = function parseStatusVars(buffer) { const result = {}; let offset = 0; let key, length, prevOffset; while (offset < buffer.length) { key = buffer[offset++]; switch (key) { case keys.FLAGS2: result.flags = buffer.readUInt32LE(offset); offset += 4; break; case keys.SQL_MODE: // value is 8 bytes, but all dcumented flags are in first 4 bytes result.sqlMode = buffer.readUInt32LE(offset); offset += 8; break; case keys.CATALOG: length = buffer[offset++]; result.catalog = buffer.toString('utf8', offset, offset + length); offset += length + 1; // null byte after string break; case keys.CHARSET: result.clientCharset = buffer.readUInt16LE(offset); result.connectionCollation = buffer.readUInt16LE(offset + 2); result.serverCharset = buffer.readUInt16LE(offset + 4); offset += 6; break; case keys.TIME_ZONE: length = buffer[offset++]; result.timeZone = buffer.toString('utf8', offset, offset + length); offset += length; // no null byte break; case keys.CATALOG_NZ: length = buffer[offset++]; result.catalogNz = buffer.toString('utf8', offset, offset + length); offset += length; // no null byte break; case keys.LC_TIME_NAMES: result.lcTimeNames = buffer.readUInt16LE(offset); offset += 2; break; case keys.CHARSET_DATABASE: result.schemaCharset = buffer.readUInt16LE(offset); offset += 2; break; case keys.TABLE_MAP_FOR_UPDATE: result.mapForUpdate1 = buffer.readUInt32LE(offset); result.mapForUpdate2 = buffer.readUInt32LE(offset + 4); offset += 8; break; case keys.MASTER_DATA_WRITTEN: result.masterDataWritten = buffer.readUInt32LE(offset); offset += 4; break; case keys.INVOKERS: length = buffer[offset++]; result.invokerUsername = buffer.toString( 'utf8', offset, offset + length ); offset += length; length = buffer[offset++]; result.invokerHostname = buffer.toString( 'utf8', offset, offset + length ); offset += length; break; case keys.UPDATED_DB_NAMES: length = buffer[offset++]; // length - number of null-terminated strings result.updatedDBs = []; // we'll store them as array here for (; length; --length) { prevOffset = offset; // fast forward to null terminating byte while (buffer[offset++] && offset < buffer.length) { // empty body, everything inside while condition } result.updatedDBs.push( buffer.toString('utf8', prevOffset, offset - 1) ); } break; case keys.MICROSECONDS: result.microseconds = // REVIEW: INVALID UNKNOWN VARIABLE! buffer.readInt16LE(offset) + (buffer[offset + 2] << 16); offset += 3; } } return result; };