Merge pull request #888 from Algunenano/support_1368

Aggregation count: Do not return null categories
This commit is contained in:
Raúl Marín 2018-03-09 11:06:40 +01:00 committed by GitHub
commit 06604cd738
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 85 additions and 17 deletions

View File

@ -5,6 +5,7 @@ Released yyyy-mm-dd
- Upgrades Windshaft to 4.5.3 - Upgrades Windshaft to 4.5.3
- Implemented middleware to authorize users via new Api Key system - Implemented middleware to authorize users via new Api Key system
- Keep the old authorization system as fallback - Keep the old authorization system as fallback
- Aggregation widget: Remove NULL categories in 'count' aggregations too
## 5.3.1 ## 5.3.1
Released 2018-02-13 Released 2018-02-13

View File

@ -42,7 +42,7 @@ const rankedCategoriesQueryTpl = ctx => `
${ctx.aggregationFn} AS value, ${ctx.aggregationFn} AS value,
row_number() OVER (ORDER BY ${ctx.aggregationFn} desc) as rank row_number() OVER (ORDER BY ${ctx.aggregationFn} desc) as rank
FROM (${filteredQueryTpl(ctx)}) filtered_source FROM (${filteredQueryTpl(ctx)}) filtered_source
${ctx.aggregationColumn !== null ? `WHERE ${ctx.aggregationColumn} IS NOT NULL` : ''} WHERE ${ctx.aggregation === "count" ? `${ctx.column}` : `${ctx.aggregationColumn}`} IS NOT NULL
GROUP BY ${ctx.column} GROUP BY ${ctx.column}
ORDER BY 2 DESC ORDER BY 2 DESC
) )
@ -279,7 +279,7 @@ module.exports = class Aggregation extends BaseDataview {
max_val = 0, max_val = 0,
categories_count = 0 categories_count = 0
} = result.rows[0] || {}; } = result.rows[0] || {};
return { return {
aggregation: this.aggregation, aggregation: this.aggregation,
count: count, count: count,
@ -290,10 +290,10 @@ module.exports = class Aggregation extends BaseDataview {
max: max_val, max: max_val,
categoriesCount: categories_count, categoriesCount: categories_count,
categories: result.rows.map(({ category, value, agg }) => { categories: result.rows.map(({ category, value, agg }) => {
return { return {
category: agg ? 'Other' : category, category: agg ? 'Other' : category,
value, value,
agg agg
}; };
}) })
}; };

View File

@ -70,12 +70,8 @@ describe('aggregations happy cases', function() {
].join(' UNION ALL '); ].join(' UNION ALL ');
operations.forEach(function (operation) { operations.forEach(function (operation) {
var not = operation === 'count' ? ' not ' : ' '; var description = 'should handle NULL values in category and aggregation columns using "' +
var description = 'should' + operation + '" as aggregation operation';
not +
'handle NULL values in category and aggregation columns using "' +
operation +
'" as aggregation operation';
it(description, function (done) { it(description, function (done) {
this.testClient = new TestClient(aggregationOperationMapConfig(operation, query, 'cat', 'val')); this.testClient = new TestClient(aggregationOperationMapConfig(operation, query, 'cat', 'val'));
@ -96,12 +92,7 @@ describe('aggregations happy cases', function() {
} }
}); });
if (operation === 'count') { assert.ok(!hasNullCategory, 'aggregation has category NULL');
assert.ok(hasNullCategory, 'aggregation has not a category NULL');
} else {
assert.ok(!hasNullCategory, 'aggregation has category NULL');
}
done(); done();
}); });
}); });
@ -425,3 +416,79 @@ describe('aggregation dataview tuned by categories query param', function () {
}); });
}); });
}); });
describe('Count aggregation', function () {
const mapConfig = {
version: '1.5.0',
layers: [
{
type: "cartodb",
options: {
source: {
"id": "a0"
},
cartocss: "#points { marker-width: 10; marker-fill: red; }",
cartocss_version: "2.3.0"
}
}
],
dataviews: {
categories: {
source: {
id: 'a0'
},
type: 'aggregation',
options: {
column: 'cat',
aggregation: 'count'
}
}
},
analyses: [
{
id: "a0",
type: "source",
params: {
query: `
SELECT
null::geometry the_geom_webmercator,
CASE
WHEN x % 4 = 0 THEN 1
WHEN x % 4 = 1 THEN 2
WHEN x % 4 = 2 THEN 3
ELSE null
END AS val,
CASE
WHEN x % 4 = 0 THEN 'category_1'
WHEN x % 4 = 1 THEN 'category_2'
WHEN x % 4 = 2 THEN 'category_3'
ELSE null
END AS cat
FROM generate_series(1, 1000) x
`
}
}
]
};
it(`should handle null values correctly when aggregationColumn isn't provided`, function (done) {
this.testClient = new TestClient(mapConfig, 1234);
this.testClient.getDataview('categories', { own_filter: 0, categories: 0 }, (err, dataview) => {
assert.ifError(err);
assert.equal(dataview.categories.length, 3);
this.testClient.drain(done);
});
});
it(`should handle null values correctly when aggregationColumn is provided`, function (done) {
mapConfig.dataviews.categories.options.aggregationColumn = 'val';
this.testClient = new TestClient(mapConfig, 1234);
this.testClient.getDataview('categories', { own_filter: 0, categories: 0 }, (err, dataview) => {
assert.ifError(err);
assert.equal(dataview.categories.length, 3);
this.testClient.drain(done);
});
});
});