Moved other yql/essentials libs YQL-19206

init
commit_hash:7d4c435602078407bbf20dd3c32f9c90d2bbcbc0

1 files changed, 34 insertions, 0 deletions

diff --git a/yql/essentials/sql/cluster_mapping.cpp b/yql/essentials/sql/cluster_mapping.cpp
new file mode 100644
index 0000000000..7a6ab64ecd
--- /dev/null
+++ b/yql/essentials/sql/cluster_mapping.cpp
@@ -0,0 +1,34 @@
+#include "cluster_mapping.h"
+#include <yql/essentials/providers/common/provider/yql_provider_names.h>
+
+using namespace NYql;
+
+namespace NSQLTranslation {
+TClusterMapping::TClusterMapping(const THashMap<TString, TString>& mapping) {
+    for (const auto& p : mapping) {
+        if (p.second == KikimrProviderName) {
+            CaseSensitiveClusters.emplace(p);
+            continue;
+        }
+
+        TString clusterLowerCase = to_lower(p.first);
+        CaseInsensitiveClusters.emplace(clusterLowerCase, p.second);
+    }
+}
+
+TMaybe<TString> TClusterMapping::GetClusterProvider(const TString& cluster, TString& normalizedClusterName) const {
+    auto providerPtr1 = CaseSensitiveClusters.FindPtr(cluster);
+    if (providerPtr1) {
+        normalizedClusterName = cluster;
+        return *providerPtr1;
+    }
+
+    TString clusterLowerCase = to_lower(cluster);
+    auto providerPtr2 = CaseInsensitiveClusters.FindPtr(clusterLowerCase);
+    if (providerPtr2) {
+        normalizedClusterName = clusterLowerCase;
+        return *providerPtr2;
+    }
+    return Nothing();
+}
+}