SNOW-1846830 allow triple slash file prefix (file:///) (#2033)

Author: sfc-gh-mkubik

src/main/java/net/snowflake/client/jdbc/SnowflakeFileTransferAgent.java

@@ -1881,7 +1881,7 @@ private void uploadFiles(Set<String> fileList, int parallel) throws SnowflakeSQL
             threadExecutor.submit(
                 getUploadFileCallable(
                     stageInfo,
-                    srcFile,
+                    srcFileObj.getPath(),
                     fileMetadata,
                     (stageInfo.getStageType() == StageInfo.StageType.LOCAL_FS)
                         ? null

src/test/java/net/snowflake/client/jdbc/FileUploaderLatestIT.java

@@ -49,6 +49,7 @@
 import org.apache.commons.io.FileUtils;
 import org.junit.jupiter.api.Tag;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.io.TempDir;
 
 /** Tests for SnowflakeFileTransferAgent that require an active connection */
 @Tag(TestTags.OTHERS)
@@ -885,4 +886,32 @@ public void testUploadWithTildeInPath() throws SQLException, IOException {
       FileUtils.deleteDirectory(subDir.toFile());
     }
   }
+
+  @Test
+  public void testUploadWithTripleSlashFilePrefix(@TempDir File tempDir)
+      throws SQLException, IOException {
+    String stageName = "testStage" + SnowflakeUtil.randomAlphaNumeric(10);
+    try (Connection connection = getConnection();
+        Statement statement = connection.createStatement()) {
+      try {
+        statement.execute("CREATE OR REPLACE STAGE " + stageName);
+        SFSession sfSession = connection.unwrap(SnowflakeConnectionV1.class).getSfSession();
+
+        String command =
+            "PUT file:///" + getFullPathFileInResource(TEST_DATA_FILE) + " @" + stageName;
+        SnowflakeFileTransferAgent sfAgent =
+            new SnowflakeFileTransferAgent(command, sfSession, new SFStatement(sfSession));
+        assertTrue(sfAgent.execute());
+
+        String tempDirPath = tempDir.getCanonicalPath().replace("\\", "/");
+        String getCommand = "GET @" + stageName + " file:///" + tempDirPath;
+        SnowflakeFileTransferAgent sfAgent1 =
+            new SnowflakeFileTransferAgent(getCommand, sfSession, new SFStatement(sfSession));
+        assertTrue(sfAgent1.execute());
+        assertEquals(1, sfAgent1.statusRows.size());
+      } finally {
+        statement.execute("DROP STAGE if exists " + stageName);
+      }
+    }
+  }
 }