joe/kami-parse-server
Public Access
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Group aggregation supports multiple columns for postgres (#6483)

Browse Source 
* Group aggregation supports multiple columns for postgres

* Group aggregation supports multiple columns for postgres

* Group aggregation supports multiple columns for postgres

* Group aggregation supports multiple columns for postgres
This commit is contained in:
Siddharth Ramesh
2020-03-09 21:48:39 +05:30
committed by GitHub
parent f69545939b
commit ef17dc4382
2 changed files with 61 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
src/Adapters/Storage/Postgres/PostgresStorageAdapter.js
View File

@@ -2219,20 +2219,30 @@ export class PostgresStorageAdapter implements StorageAdapter {
groupValues = value;
const groupByFields = [];
for (const alias in value) {
const operation = Object.keys(value[alias])[0];
const source = transformAggregateField(value[alias][operation]);
if (mongoAggregateToPostgres[operation]) {
if (typeof value[alias] === 'string' && value[alias]) {
const source = transformAggregateField(value[alias]);
if (!groupByFields.includes(`"${source}"`)) {
groupByFields.push(`"${source}"`);
}
columns.push(
`EXTRACT(${
mongoAggregateToPostgres[operation]
} FROM $${index}:name AT TIME ZONE 'UTC') AS $${index +
1}:name`
);
values.push(source, alias);
columns.push(`$${index}:name AS $${index + 1}:name`);
index += 2;
} else {
const operation = Object.keys(value[alias])[0];
const source = transformAggregateField(value[alias][operation]);
if (mongoAggregateToPostgres[operation]) {
if (!groupByFields.includes(`"${source}"`)) {
groupByFields.push(`"${source}"`);
}
columns.push(
`EXTRACT(${
mongoAggregateToPostgres[operation]
} FROM $${index}:name AT TIME ZONE 'UTC') AS $${index +
1}:name`
);
values.push(source, alias);
index += 2;
}
}
}
groupPattern = `GROUP BY $${index}:raw`;