diff --git a/lib/packets/resultset_header.js b/lib/packets/resultset_header.js index e6a8cd492f..35f72e9e87 100644 --- a/lib/packets/resultset_header.js +++ b/lib/packets/resultset_header.js @@ -50,6 +50,7 @@ class ResultSetHeader { stateChanges = { systemVariables: {}, schema: null, + gtids: [], trackStateChange: null }; } @@ -72,6 +73,12 @@ class ResultSetHeader { stateChanges.trackStateChange = packet.readLengthCodedString( encoding ); + } else if (type === sessionInfoTypes.STATE_GTIDS) { + // TODO: find if the first length coded string means anything. Usually comes as empty + // eslint-disable-next-line no-unused-vars + const _unknownString = packet.readLengthCodedString(encoding); + const gtid = packet.readLengthCodedString(encoding); + stateChanges.gtids = gtid.split(','); } else { // unsupported session track type. For now just ignore }