insert components one by one to prevent database memory overflow

app/sda-workflow/src/3_components/ConnectedComponentsTask.h

@@ -30,7 +30,7 @@ public:
         this->desc["cfg-file"]=this->cfgFile.string();
     }
 
-    std::unordered_map<uint64_t,std::vector<std::string>> queryPathsForComponent(const std::vector<ComponentReference> & componentIds, const MemgraphConnection & memgraphConnection){
+    std::unordered_map<uint64_t,std::vector<std::string>> queryPathsForComponent(fishnet::util::forward_range_of<ComponentReference> auto & componentIds, const MemgraphConnection & memgraphConnection){
         std::unordered_map<uint64_t,std::vector<std::string>> componentToFilesMap;
         std::vector<mg::Value> componentValues;
         for(auto componentRef : componentIds)
@@ -84,17 +84,10 @@ public:
         }
         auto components = fishnet::graph::BFS::connectedComponents(graph).get();
         this->desc["Connected Components"]=components.size();
-        auto componentIds = memgraphClient.createComponents(components);
-    /**
-     * WITH $data as components UNWIND range(0,size(components)-1) as index
-CREATE (c:Component) WITH components[index] as nodes,c
-UNWIND nodes as nodeId
-MATCH (n:Settlement) WHERE n.id=nodeId MERGE (n)-[:part_of]->(c) 
-Nodes: 6922201
-UNWIND $data as component_id
-MATCH (c:Component)<-[:part_of]-(:Settlement)-[:stored]->(f:File)WHERE ID(c)=component_id 
-     */
-        // Out of memory error seems to appear here:
+        auto componentIds = components
+                            | std::views::transform([&memgraphClient](const auto & nodesOfComponent){return memgraphClient.createComponent(nodesOfComponent);})
+                            | std::views::filter([](const std::optional<ComponentReference> & opt){return opt.has_value();})
+                            | std::views::transform([](const std::optional<ComponentReference> & opt){return opt.value();});
         std::unordered_map<uint64_t,std::vector<std::string>> componentToFilesMap = queryPathsForComponent(componentIds,memgraphClient.getMemgraphConnection());
         std::unordered_map<std::string,std::vector<uint64_t>> fileToComponentsMap;
         std::vector<ComponentFileJob> contractionJobs;