diff --git a/lib/query.js b/lib/query.js
index 3d5dfc08f..c7fadeec9 100644
--- a/lib/query.js
+++ b/lib/query.js
@@ -61,7 +61,7 @@ p.handleDataRow = function(msg) {
       row[self._fieldNames[i]] = self._fieldConverters[i](rawValue);
     }
   }
-  self.emit('row', row);
+  self.emit('row', row, self._result);
 
   //if there is a callback collect rows
   if(self.callback) {