diff --git a/packages/cubejs-schema-compiler/src/adapter/BaseTimeDimension.ts b/packages/cubejs-schema-compiler/src/adapter/BaseTimeDimension.ts index c5305250c0fa7..12dee4693e5f6 100644 --- a/packages/cubejs-schema-compiler/src/adapter/BaseTimeDimension.ts +++ b/packages/cubejs-schema-compiler/src/adapter/BaseTimeDimension.ts @@ -39,7 +39,7 @@ export class BaseTimeDimension extends BaseFilter { } // TODO: find and fix all hidden references to granularity to rely on granularityObj instead? - public get granularity(): string | undefined { + public get granularity(): string | null | undefined { return this.granularityObj?.granularity; } @@ -217,7 +217,7 @@ export class BaseTimeDimension extends BaseFilter { return this.query.dateTimeCast(this.query.paramAllocator.allocateParam(this.dateRange ? this.dateToFormatted() : BUILD_RANGE_END_LOCAL)); } - public dateRangeGranularity() { + public dateRangeGranularity(): string | null { if (!this.dateRange) { return null; } @@ -262,7 +262,7 @@ export class BaseTimeDimension extends BaseFilter { } public resolvedGranularity() { - return this.granularityObj?.resolvedGranularity(); + return this.granularityObj ? this.granularityObj.resolvedGranularity() : this.dateRangeGranularity(); } public isPredefinedGranularity(): boolean { diff --git a/packages/cubejs-schema-compiler/src/adapter/PreAggregations.js b/packages/cubejs-schema-compiler/src/adapter/PreAggregations.js index efc642af9d727..b060b2922e9f2 100644 --- a/packages/cubejs-schema-compiler/src/adapter/PreAggregations.js +++ b/packages/cubejs-schema-compiler/src/adapter/PreAggregations.js @@ -450,7 +450,7 @@ export class PreAggregations { static timeDimensionsAsIs(timeDimensions) { return timeDimensions && R.sortBy( R.prop(0), - timeDimensions.map(d => [d.expressionPath(), d.granularity]), + timeDimensions.map(d => [d.expressionPath(), d.resolvedGranularity()]), ) || []; } diff --git a/packages/cubejs-schema-compiler/test/integration/postgres/pre-aggregations.test.ts b/packages/cubejs-schema-compiler/test/integration/postgres/pre-aggregations.test.ts index eb24efc8ff4b3..67334caa87a1f 100644 --- a/packages/cubejs-schema-compiler/test/integration/postgres/pre-aggregations.test.ts +++ b/packages/cubejs-schema-compiler/test/integration/postgres/pre-aggregations.test.ts @@ -229,6 +229,7 @@ describe('PreAggregations', () => { dimensions: [sourceAndId, source], timeDimension: createdAt, granularity: 'hour', + allowNonStrictDateRangeMatch: true }, visitorsMultiplied: { measures: [count], @@ -546,6 +547,33 @@ describe('PreAggregations', () => { }); })); + it('simple pre-aggregation (with no granularity in query)', () => compiler.compile().then(() => { + const query = new PostgresQuery({ joinGraph, cubeEvaluator, compiler }, { + measures: [ + 'visitors.count' + ], + timeDimensions: [{ + dimension: 'visitors.createdAt', + dateRange: ['2017-01-01 00:00:00.000', '2017-01-29 22:59:59.999'] + }], + timezone: 'America/Los_Angeles', + preAggregationsSchema: '' + }); + + const queryAndParams = query.buildSqlAndParams(); + console.log(queryAndParams); + expect(query.preAggregations?.preAggregationForQuery?.canUsePreAggregation).toEqual(true); + expect(queryAndParams[0]).toMatch(/visitors_source_and_id_rollup/); + + return dbRunner.evaluateQueryWithPreAggregations(query).then(res => { + expect(res).toEqual( + [{ + visitors__count: '5' + }] + ); + }); + })); + it('leaf measure pre-aggregation', () => compiler.compile().then(() => { const query = new PostgresQuery({ joinGraph, cubeEvaluator, compiler }, { measures: [