Skip to content

Commit 4bb0542

Browse files
add additional methods to parse
1 parent 513a40c commit 4bb0542

File tree

1 file changed

+18
-0
lines changed

1 file changed

+18
-0
lines changed

machines/parse-native-query-result.js

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,7 @@ module.exports = {
5858

5959

6060
fn: function parseNativeQueryResult(inputs, exits) {
61+
var _ = require('lodash');
6162
var normalizedResult;
6263

6364
switch (inputs.queryType) {
@@ -83,6 +84,23 @@ module.exports = {
8384
};
8485
break;
8586

87+
case 'avg':
88+
var avg = _.first(inputs.nativeQueryResult.rows).avg;
89+
normalizedResult = Number(avg);
90+
break;
91+
92+
case 'sum':
93+
var sum = _.first(inputs.nativeQueryResult.rows).sum;
94+
normalizedResult = Number(sum);
95+
break;
96+
97+
case 'count':
98+
var countResult = _.first(inputs.nativeQueryResult.rows);
99+
var countResultKey = _.first(_.keys(countResult));
100+
var count = inputs.nativeQueryResult.rows[0][countResultKey];
101+
normalizedResult = Number(count);
102+
break;
103+
86104
default:
87105

88106
}

0 commit comments

Comments
 (0)