Skip to content

Commit 5521d41

Browse files
dplewisflovilmart
authored andcommitted
PG: Support for multiple projection in aggregate (#4469)
1 parent c9ab790 commit 5521d41

File tree

2 files changed

+22
-2
lines changed

2 files changed

+22
-2
lines changed

spec/ParseQuery.Aggregate.spec.js

Lines changed: 21 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -254,7 +254,8 @@ describe('Parse.Query Aggregate testing', () => {
254254
rp.get(Parse.serverURL + '/aggregate/TestObject', options)
255255
.then((resp) => {
256256
resp.results.forEach((result) => {
257-
expect(result.name !== undefined).toBe(true);
257+
expect(result.objectId).not.toBe(undefined);
258+
expect(result.name).not.toBe(undefined);
258259
expect(result.sender).toBe(undefined);
259260
expect(result.size).toBe(undefined);
260261
expect(result.score).toBe(undefined);
@@ -263,6 +264,25 @@ describe('Parse.Query Aggregate testing', () => {
263264
}).catch(done.fail);
264265
});
265266

267+
it('multiple project query', (done) => {
268+
const options = Object.assign({}, masterKeyOptions, {
269+
body: {
270+
project: { name: 1, score: 1, sender: 1 },
271+
}
272+
});
273+
rp.get(Parse.serverURL + '/aggregate/TestObject', options)
274+
.then((resp) => {
275+
resp.results.forEach((result) => {
276+
expect(result.objectId).not.toBe(undefined);
277+
expect(result.name).not.toBe(undefined);
278+
expect(result.score).not.toBe(undefined);
279+
expect(result.sender).not.toBe(undefined);
280+
expect(result.size).toBe(undefined);
281+
});
282+
done();
283+
}).catch(done.fail);
284+
});
285+
266286
it('project with group query', (done) => {
267287
const options = Object.assign({}, masterKeyOptions, {
268288
body: {

src/Adapters/Storage/Postgres/PostgresStorageAdapter.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1552,7 +1552,7 @@ export class PostgresStorageAdapter implements StorageAdapter {
15521552
}
15531553
}
15541554

1555-
const qs = `SELECT ${columns.join(',')} FROM $1:name ${wherePattern} ${sortPattern} ${limitPattern} ${skipPattern} ${groupPattern}`;
1555+
const qs = `SELECT ${columns.join()} FROM $1:name ${wherePattern} ${sortPattern} ${limitPattern} ${skipPattern} ${groupPattern}`;
15561556
debug(qs, values);
15571557
return this._client.map(qs, values, a => this.postgresObjectToParseObject(className, a, schema))
15581558
.then(results => {

0 commit comments

Comments
 (0)