[CBO] Improve transitive closure algorithm, add cycles processing

Author: pashandor789

ydb/core/kqp/ut/common/kqp_ut_common.cpp

@@ -1468,6 +1468,24 @@ NJson::TJsonValue GetJoinOrder(const TString& deserializedPlan) {
     return GetJoinOrderImpl(optRoot);
 }
 
+NJson::TJsonValue GetJoinOrderFromDetailedJoinOrderImpl(const NJson::TJsonValue& opt) {
+    if (!opt.GetMapSafe().contains("table")) {
+        NJson::TJsonValue res;
+        auto args = opt.GetMapSafe().at("args").GetArraySafe();
+        for (size_t i = 0; i < args.size(); ++i) {
+            res.AppendValue(GetJoinOrderFromDetailedJoinOrderImpl(args[i]));
+        }
+        return res;
+    }
+
+    return opt.GetMapSafe().at("table");
+}
+
+NJson::TJsonValue GetJoinOrderFromDetailedJoinOrder(const TString& deserializedDetailedJoinOrder) {
+    NJson::TJsonValue optRoot;
+    NJson::ReadJsonTree(deserializedDetailedJoinOrder, &optRoot, true);
+    return GetJoinOrderFromDetailedJoinOrderImpl(optRoot);
+}
 
 } // namspace NKqp
 } // namespace NKikimr

ydb/core/kqp/ut/common/kqp_ut_common.h

@@ -381,5 +381,7 @@ NJson::TJsonValue GetDetailedJoinOrder(const TString& deserializedPlan, const TG
 /* Gets tables join order without details : only tables. */
 NJson::TJsonValue GetJoinOrder(const TString& deserializedPlan);
 
+NJson::TJsonValue GetJoinOrderFromDetailedJoinOrder(const TString& deserializedDetailedJoinOrder);
+
 } // namespace NKqp
 } // namespace NKikimr

ydb/core/kqp/ut/join/data/join_order/lookupbug.json

@@ -32,3 +32,4 @@
       }
     ]
 }
+

ydb/core/kqp/ut/join/data/join_order/tpcc.json

@@ -12,3 +12,4 @@
       }
     ]
 }
+

ydb/core/kqp/ut/join/data/join_order/tpcds64_1000s.json

@@ -52,3 +52,4 @@
       }
     ]
 }
+

ydb/core/kqp/ut/join/data/join_order/tpcds64_1000s_column_store.json

@@ -52,3 +52,4 @@
       }
     ]
 }
+

ydb/core/kqp/ut/join/data/join_order/tpcds64_small_1000s.json

@@ -82,3 +82,4 @@
       }
     ]
 }
+

ydb/core/kqp/ut/join/data/join_order/tpcds64_small_1000s_column_store.json

@@ -82,3 +82,4 @@
       }
     ]
 }
+