Support for setting rowsAsArray per query.

Author: ifsnow

lib/protocol/Parser.js

@@ -21,7 +21,7 @@ function Parser(options) {
   this._nextPacketNumber  = 0;
   this._encoding          = 'utf-8';
   this._paused            = false;
-  this._rowsAsArray        = options.config && options.config.rowsAsArray;
+  this._rowsAsArray       = options.config && options.config.rowsAsArray;
 }
 
 Parser.prototype.write = function write(chunk) {
@@ -411,8 +411,12 @@ Parser.prototype.packetLength = function packetLength() {
   return this._packetHeader.length + this._longPacketBuffers.size;
 };
 
+Parser.prototype.setArrayRowMode = function(isArrayRowMode) {
+  this._isArrayRowMode = typeof isArrayRowMode === 'undefined' ? this._rowsAsArray : isArrayRowMode;
+};
+
 Parser.prototype.isArrayRowMode = function() {
-  return this._rowsAsArray;
+  return this._isArrayRowMode;
 };
 
 Parser.prototype._combineNextBuffers = function _combineNextBuffers(bytes) {

lib/protocol/sequences/Query.js

@@ -17,6 +17,7 @@ function Query(options, callback) {
     ? true
     : options.typeCast;
   this.nestTables = options.nestTables || false;
+  this.isArrayRowMode = options.rowsAsArray;
 
   this._resultSet = null;
   this._results   = [];
@@ -138,6 +139,8 @@ Query.prototype._handleFinalResultPacket = function(packet) {
 };
 
 Query.prototype['RowDataPacket'] = function(packet, parser, connection) {
+  parser.setArrayRowMode(this.isArrayRowMode);
+
   packet.parse(parser, this._resultSet.fieldPackets, this.typeCast, this.nestTables, connection);
 
   var row = packet.isArray() ? packet.getArrayValue() : packet;

test/integration/connection/test-query-rows-as-array.js

@@ -14,5 +14,13 @@ common.getTestConnection({ rowsAsArray: true }, function (err, connection) {
     assert.deepEqual(rows, [[1]]);
   });
 
+  connection.query({
+    sql: 'SELECT ?',
+    rowsAsArray: false
+  }, [ 1 ], function (err, rows) {
+    assert.ifError(err);
+    assert.deepEqual(rows, [{1: 1}]);
+  });
+
   connection.end(assert.ifError);
 });