works for file

Author: zvonand

src/Storages/ObjectStorage/Utils.cpp

@@ -12,6 +12,7 @@
 #include <Disks/ObjectStorages/ObjectStorageFactory.h>
 #include <Poco/Util/MapConfiguration.h>
 #include <IO/S3/URI.h>
+#include <filesystem>
 #if USE_AWS_S3
 #include <Disks/ObjectStorages/S3/S3ObjectStorage.h>
 #endif
@@ -454,7 +455,39 @@ std::pair<DB::ObjectStoragePtr, std::string> resolveObjectStorageForPath(
             endpoint.push_back('/');
         cfg->setString(config_prefix + ".endpoint", endpoint);
     }
-    // No extra config needed for local storage (file://)
+    else if (target_norm == "file")
+    {
+        // For file:// URIs, extract the directory path
+        // file:///absolute/path/to/file -> path = /absolute/path/to/, key = /absolute/path/to/file (full path)
+        std::string full_path = "/" + target.key;  // Reconstruct full path
+        std::filesystem::path fs_path(full_path);
+        std::filesystem::path parent = fs_path.parent_path();
+        std::string dir_path = parent.string();
+        
+        // Ensure directory path ends with /
+        if (dir_path.empty() || dir_path == "/")
+        {
+            // Root directory
+            dir_path = "/";
+        }
+        else if (dir_path.back() != '/')
+        {
+            dir_path += '/';
+        }
+        
+        cfg->setString(config_prefix + ".path", dir_path);
+        
+        auto & factory = DB::ObjectStorageFactory::instance();
+
+        // Also use the cache key as a (unique) storage name
+        DB::ObjectStoragePtr storage = factory.create(cache_key, *cfg, config_prefix, context, /*skip_access_check*/ true);
+
+        secondary_storages.emplace(cache_key, storage);
+
+        // For local storage, getObjectMetadata expects the full path, not just the filename
+        // Return the full absolute path as the key
+        return {storage, full_path};
+    }
 
     auto & factory = DB::ObjectStorageFactory::instance();