Skip to content

Commit f307685

Browse files
committed
refactor
1 parent ceda12b commit f307685

File tree

2 files changed

+418
-46
lines changed

2 files changed

+418
-46
lines changed

packages/cubejs-query-orchestrator/src/orchestrator/QueryOrchestrator.ts

Lines changed: 0 additions & 46 deletions
Original file line numberDiff line numberDiff line change
@@ -599,50 +599,4 @@ export class QueryOrchestrator {
599599
options
600600
);
601601
}
602-
603-
/**
604-
* Clear cached schema information for a data source.
605-
*/
606-
public async clearDataSourceSchemaCache(dataSource: string = 'default'): Promise<void> {
607-
const cacheKey: CacheKey = [`METADATA:${MetadataOperationType.GET_SCHEMAS}`, 'empty', dataSource];
608-
const redisKey = this.queryCache.queryRedisKey(cacheKey);
609-
await this.queryCache.getCacheDriver().remove(redisKey);
610-
this.logger('Cleared datasource schema cache', { dataSource });
611-
}
612-
613-
/**
614-
* Clear cached table information for specific schemas.
615-
*/
616-
public async clearTablesForSchemasCache(
617-
schemas: QuerySchemasResult[],
618-
dataSource: string = 'default'
619-
): Promise<void> {
620-
const paramsHash = this.createMetadataHash(MetadataOperationType.GET_TABLES_FOR_SCHEMAS, { schemas });
621-
const cacheKey: CacheKey = [`METADATA:${MetadataOperationType.GET_TABLES_FOR_SCHEMAS}`, paramsHash, dataSource];
622-
const redisKey = this.queryCache.queryRedisKey(cacheKey);
623-
await this.queryCache.getCacheDriver().remove(redisKey);
624-
this.logger('Cleared tables for schemas cache', {
625-
dataSource,
626-
schemaCount: schemas.length,
627-
cacheHash: paramsHash
628-
});
629-
}
630-
631-
/**
632-
* Clear cached column information for specific tables.
633-
*/
634-
public async clearColumnsForTablesCache(
635-
tables: QueryTablesResult[],
636-
dataSource: string = 'default'
637-
): Promise<void> {
638-
const paramsHash = this.createMetadataHash(MetadataOperationType.GET_COLUMNS_FOR_TABLES, { tables });
639-
const cacheKey: CacheKey = [`METADATA:${MetadataOperationType.GET_COLUMNS_FOR_TABLES}`, paramsHash, dataSource];
640-
const redisKey = this.queryCache.queryRedisKey(cacheKey);
641-
await this.queryCache.getCacheDriver().remove(redisKey);
642-
this.logger('Cleared columns for tables cache', {
643-
dataSource,
644-
tableCount: tables.length,
645-
cacheHash: paramsHash
646-
});
647-
}
648602
}

0 commit comments

Comments
 (0)