Skip to content

Commit 94ec658

Browse files
committed
refactor
1 parent 312e955 commit 94ec658

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

0 commit comments

Comments
 (0)