Merge pull request #400 from plusmancn/add_changed_rows

feat: issue#288

Author: sidorares

lib/packets/resultset_header.js

@@ -18,6 +18,15 @@ function ResultSetHeader (packet, bigNumberStrings, encoding)
     this.infileName = packet.readString(undefined, encoding);
   }
 
+  // issue#288: Add changedRow if exists, reference to https://github.com/sidorares/node-mysql2/issues/288
+  if (encoding) {
+    var message = packet.readString(undefined, encoding);
+    var m = message.match(/\schanged:\s*(\d+)/i);
+    if (m !== null) {
+      this.changedRows = parseInt(m[1], 10);
+    }
+  }
+
   // snippet from mysql-native:
   // res.affected_rows = this.lcnum();
   // res.insert_id = this.lcnum();

test/integration/connection/test-update-changed-rows.js

@@ -0,0 +1,47 @@
+/**
+ * <[email protected]> created at 2016.09.17 15:24:34
+ *
+ * issue#288: https://github.com/sidorares/node-mysql2/issues/288
+ */
+var common = require('../../common');
+var connection = common.createConnection();
+var assert = require('assert');
+
+var result1 = undefined;
+var result2 = undefined;
+
+// connection.
+connection.query([
+  'CREATE TEMPORARY TABLE `changed_rows` (',
+  '`id` int(11) unsigned NOT NULL AUTO_INCREMENT,',
+  '`value` int(5) NOT NULL,',
+  'PRIMARY KEY (`id`)',
+  ') ENGINE=InnoDB DEFAULT CHARSET=utf8'
+].join('\n'));
+connection.query('insert into changed_rows(value) values(1)');
+connection.query('insert into changed_rows(value) values(1)');
+connection.query('insert into changed_rows(value) values(2)');
+connection.query('insert into changed_rows(value) values(3)');
+
+connection.execute('update changed_rows set value=1', [], function (err, _result) {
+  if (err) {
+    throw err;
+  }
+
+  result1 = _result;
+  connection.execute('update changed_rows set value=1', [], function (err, _result) {
+    if (err) {
+      throw err;
+    }
+
+    result2 = _result;
+    connection.end();
+  });
+});
+
+process.on('exit', function () {
+  assert.equal(result1.affectedRows, 4);
+  assert.equal(result1.changedRows, 2);
+  assert.equal(result2.affectedRows, 4);
+  assert.equal(result2.changedRows, 0);
+});