github/directus
1
0
Fork 0
mirror of https://github.com/directus/directus.git synced 2026-01-30 21:28:08 -05:00
Code Issues Packages Projects Releases Wiki Activity

Apply aggregation query to dbQuery

Browse Source
This commit is contained in:
rijkvanzanten
2021-05-25 14:31:01 -04:00
parent 2f6a90ee14
commit b80bdb7146
1 changed files with 38 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
api/src/utils/apply-query.ts
View File

@@ -2,8 +2,8 @@ import { Knex } from 'knex';
import { clone, get, isPlainObject, set } from 'lodash';
import { customAlphabet } from 'nanoid';
import validate from 'uuid-validate';
import { InvalidQueryException } from '../exceptions';
import { Filter, Query, Relation, SchemaOverview } from '../types';
import { ForbiddenException, InvalidQueryException } from '../exceptions';
import { Aggregate, Filter, Query, Relation, SchemaOverview } from '../types';
import { getRelationType } from './get-relation-type';
const generateAlias = customAlphabet('abcdefghijklmnopqrstuvwxyz', 5);
@@ -46,6 +46,14 @@ export default function applyQuery(
if (query.search) {
applySearch(schema, dbQuery, query.search, collection);
}
if (query.group) {
dbQuery.groupBy(query.group);
}
if (query.aggregate) {
applyAggregate(dbQuery, query.aggregate);
}
}
/**
@@ -471,6 +479,34 @@ export async function applySearch(
});
}
export function applyAggregate(dbQuery: Knex.QueryBuilder, aggregate: Aggregate) {
for (const [operation, aliasMap] of Object.entries(aggregate)) {
if (!aliasMap) continue;
for (const [column, alias] of Object.entries(aliasMap)) {
if (operation === 'avg') {
dbQuery.avg(column, { as: alias });
}
if (operation === 'min') {
dbQuery.min(column, { as: alias });
}
if (operation === 'max') {
dbQuery.max(column, { as: alias });
}
if (operation === 'count') {
dbQuery.count(column, { as: alias });
}
if (operation === 'sum') {
dbQuery.sum(column, { as: alias });
}
}
}
}
function getFilterPath(key: string, value: Record<string, any>) {
const path = [key];