chore(query-orchestrator): Replaced queryKey with queryKeyMd5 (#10312)

Author: RusovDmitriy

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

@@ -1,4 +1,5 @@
 import R from 'ramda';
+import crypto from 'crypto';
 import { getEnv, MaybeCancelablePromise } from '@cubejs-backend/shared';
 import {
   cancelCombinator,
@@ -33,7 +34,7 @@ type IndexesSql = { sql: [string, unknown[]], indexName: string }[];
 type QueryKey = [QueryWithParams, IndexesSql, InvalidationKeys] | [QueryWithParams, InvalidationKeys];
 
 type QueryOptions = {
-  queryKey: QueryKey;
+  queryKeyMd5: QueryKey | string;
   newVersionEntry: VersionEntry;
   query: string;
   values: unknown[];
@@ -47,6 +48,29 @@ function nowTimestamp(client: DriverInterface) {
   return client.nowTimestamp?.() ?? new Date().getTime();
 }
 
+/**
+ * Computes MD5 hash of the query key.
+ * Special handling for FETCH_TABLES_FOR queries - returns the original string instead of hash.
+ */
+function queryKeyMd5(queryKey: QueryKey): string {
+  const jsonStr = JSON.stringify(queryKey);
+
+  // Special case: if query contains FETCH_TABLES_FOR, return the string representation
+  if (jsonStr.includes('FETCH_TABLES_FOR')) {
+    // Extract the SQL string from the query key if it's a string
+    if (Array.isArray(queryKey) && queryKey.length > 0) {
+      const firstElement = queryKey[0];
+      if (Array.isArray(firstElement) && typeof firstElement[0] === 'string') {
+        return firstElement[0];
+      }
+    }
+    return jsonStr;
+  }
+
+  // Otherwise, return MD5 hash
+  return crypto.createHash('md5').update(jsonStr).digest('hex');
+}
+
 export class PreAggregationLoader {
   private preAggregations: PreAggregations;
 
@@ -482,7 +506,7 @@ export class PreAggregationLoader {
 
   protected queryOptions(invalidationKeys: InvalidationKeys, query: string, params: unknown[], targetTableName: string, newVersionEntry: VersionEntry) {
     return {
-      queryKey: this.preAggregationQueryKey(invalidationKeys),
+      queryKeyMd5: queryKeyMd5(this.preAggregationQueryKey(invalidationKeys)),
       query,
       values: params,
       targetTableName,