FM / packets

/var/www/myprog.com.ua/server/node/node_modules/mysql/lib/protocol/packets/

/var/www/myprog.com.ua/server/node/node_modules/mysql/lib/protocol/packets

Name	Size	Mode	Actions
AuthSwitchRequestPacket.js	707	0644	edit dl rm
AuthSwitchResponsePacket.js	375	0644	edit dl rm
ClientAuthenticationPacket.js	2080	0644	edit dl rm
ComChangeUserPacket.js	960	0644	edit dl rm
ComPingPacket.js	289	0644	edit dl rm
ComQueryPacket.js	405	0644	edit dl rm
ComQuitPacket.js	301	0644	edit dl rm
ComStatisticsPacket.js	313	0644	edit dl rm
EmptyPacket.js	163	0644	edit dl rm
EofPacket.js	721	0644	edit dl rm
ErrorPacket.js	1007	0644	edit dl rm
Field.js	649	0644	edit dl rm
FieldPacket.js	3264	0644	edit dl rm
HandshakeInitializationPacket.js	3958	0644	edit dl rm
index.js	1360	0644	edit dl rm
LocalDataFilePacket.js	319	0644	edit dl rm
LocalInfileRequestPacket.js	609	0644	edit dl rm
OkPacket.js	1414	0644	edit dl rm
OldPasswordPacket.js	367	0644	edit dl rm
ResultSetHeaderPacket.js	381	0644	edit dl rm
RowDataPacket.js	4088	0644	edit dl rm
SSLRequestPacket.js	983	0644	edit dl rm
StatisticsPacket.js	544	0644	edit dl rm
UseOldPasswordPacket.js	379	0644	edit dl rm

Edit: /var/www/myprog.com.ua/server/node/node_modules/mysql/lib/protocol/packets/OkPacket.js (1414B)

// Language-neutral expression to match ER_UPDATE_INFO
var ER_UPDATE_INFO_REGEXP = /^[^:0-9]+: [0-9]+[^:0-9]+: ([0-9]+)[^:0-9]+: [0-9]+[^:0-9]*$/;

module.exports = OkPacket;
function OkPacket(options) {
  options = options || {};

this.fieldCount   = undefined;
  this.affectedRows = undefined;
  this.insertId     = undefined;
  this.serverStatus = undefined;
  this.warningCount = undefined;
  this.message      = undefined;
  this.protocol41   = options.protocol41;
}

OkPacket.prototype.parse = function(parser) {
  this.fieldCount   = parser.parseUnsignedNumber(1);
  this.affectedRows = parser.parseLengthCodedNumber();
  this.insertId     = parser.parseLengthCodedNumber();
  if (this.protocol41) {
    this.serverStatus = parser.parseUnsignedNumber(2);
    this.warningCount = parser.parseUnsignedNumber(2);
  }
  this.message      = parser.parsePacketTerminatedString();
  this.changedRows  = 0;

var m = ER_UPDATE_INFO_REGEXP.exec(this.message);
  if (m !== null) {
    this.changedRows = parseInt(m[1], 10);
  }
};

OkPacket.prototype.write = function(writer) {
  writer.writeUnsignedNumber(1, 0x00);
  writer.writeLengthCodedNumber(this.affectedRows || 0);
  writer.writeLengthCodedNumber(this.insertId || 0);
  if (this.protocol41) {
    writer.writeUnsignedNumber(2, this.serverStatus || 0);
    writer.writeUnsignedNumber(2, this.warningCount || 0);
  }
  writer.writeString(this.message);
};

// Language-neutral expression to match ER_UPDATE_INFO var ER_UPDATE_INFO_REGEXP = /^[^:0-9]+: [0-9]+[^:0-9]+: ([0-9]+)[^:0-9]+: [0-9]+[^:0-9]*$/; module.exports = OkPacket; function OkPacket(options) { options = options || {}; this.fieldCount = undefined; this.affectedRows = undefined; this.insertId = undefined; this.serverStatus = undefined; this.warningCount = undefined; this.message = undefined; this.protocol41 = options.protocol41; } OkPacket.prototype.parse = function(parser) { this.fieldCount = parser.parseUnsignedNumber(1); this.affectedRows = parser.parseLengthCodedNumber(); this.insertId = parser.parseLengthCodedNumber(); if (this.protocol41) { this.serverStatus = parser.parseUnsignedNumber(2); this.warningCount = parser.parseUnsignedNumber(2); } this.message = parser.parsePacketTerminatedString(); this.changedRows = 0; var m = ER_UPDATE_INFO_REGEXP.exec(this.message); if (m !== null) { this.changedRows = parseInt(m[1], 10); } }; OkPacket.prototype.write = function(writer) { writer.writeUnsignedNumber(1, 0x00); writer.writeLengthCodedNumber(this.affectedRows || 0); writer.writeLengthCodedNumber(this.insertId || 0); if (this.protocol41) { writer.writeUnsignedNumber(2, this.serverStatus || 0); writer.writeUnsignedNumber(2, this.warningCount || 0); } writer.writeString(this.message); };