Snow 715504 mfa token cache

.github/workflows/jira_issue.yml

@@ -37,7 +37,7 @@ jobs:
           summary: '${{ github.event.issue.title }}'
           description: |
             ${{ github.event.issue.body }} \\ \\ _Created from GitHub Action_ for ${{ github.event.issue.html_url }}
-          fields: '{ "customfield_11401": {"id": "14723"}, "assignee": {"id": "712020:3c0352b5-63f7-4e26-9afe-38f6f9f0f4c5"}, "components":[{"id":"19287"}] }'
+          fields: '{ "customfield_11401": {"id": "14723"}, "assignee": {"id": "712020:e1f41916-da57-4fe8-b317-116d5229aa51"}, "components":[{"id":"19287"}], "labels": ["oss"], "priority": {"id": "10001"} }'
 
       - name: Update GitHub Issue
         uses: ./jira/gajira-issue-update

.github/workflows/main.yml

@@ -41,6 +41,7 @@ jobs:
         with:
           dotnet-version: |
             6.0.x
+            7.0.x
             8.0.x
             9.0.x
           dotnet-quality: 'ga'
@@ -103,6 +104,7 @@ jobs:
         with:
           dotnet-version: |
             6.0.x
+            7.0.x
             8.0.x
             9.0.x
           dotnet-quality: 'ga'
@@ -163,6 +165,7 @@ jobs:
         with:
           dotnet-version: |
             6.0.x
+            7.0.x
             8.0.x
             9.0.x
           dotnet-quality: 'ga'

Jenkinsfile

@@ -24,7 +24,7 @@ timestamps {
       }
     }
     params = [
-      string(name: 'svn_revision', value: 'main'),
+      string(name: 'svn_revision', value: 'bptp-built'),
       string(name: 'branch', value: 'main'),
       string(name: 'client_git_commit', value: scmInfo.GIT_COMMIT),
       string(name: 'client_git_branch', value: scmInfo.GIT_BRANCH),

Snowflake.Data.Tests/IntegrationTests/FileUploadDownloadLargeFilesIT.cs

@@ -23,33 +23,33 @@ public class FileUploadDownloadLargeFilesIT : SFBaseTest
         private static readonly string s_fullFileName = Path.Combine(s_localFolderName, FileName);
         private static readonly string s_fullDownloadedFileName = Path.Combine(s_downloadFolderName, FileName);
         private static readonly MD5 s_md5 = MD5.Create();
-        
+
         [OneTimeSetUp]
         public static void GenerateLargeFileForTests()
         {
             CreateLocalDirectory(s_localFolderName);
             GenerateLargeFile(s_fullFileName);
         }
-        
+
         [OneTimeTearDown]
         public static void DeleteGeneratedLargeFile()
         {
             RemoveLocalFile(s_fullFileName);
             RemoveDirectory(s_localFolderName);
         }
-        
+
         [Test]
         public void TestThatUploadsAndDownloadsTheSameFile()
         {
             // act
             UploadFile(s_fullFileName, s_remoteFolderName);
             DownloadFile(s_remoteFolderName, s_downloadFolderName, FileName);
-            
+
             // assert
             Assert.AreEqual(
                 CalcualteMD5(s_fullFileName),
                 CalcualteMD5(s_fullDownloadedFileName));
-            
+
             // cleanup
             RemoveFilesFromServer(s_remoteFolderName);
             RemoveLocalFile(s_fullDownloadedFileName);
@@ -85,7 +85,7 @@ private void DownloadFile(string remoteFolderName, string downloadFolderName, st
                 command.ExecuteNonQuery();
             }
         }
-        
+
         private void RemoveFilesFromServer(string remoteFolderName)
         {
             using (var conn = new SnowflakeDbConnection())
@@ -108,7 +108,7 @@ private static string CalcualteMD5(string fullFileName)
         }
 
         private static void RemoveLocalFile(string fullFileName) => File.Delete(fullFileName);
-        
+
         private static void CreateLocalDirectory(string path) => Directory.CreateDirectory(path);
 
         private static void RemoveDirectory(string path) => Directory.Delete(path, true);

Snowflake.Data.Tests/IntegrationTests/SFPutGetTest.cs

@@ -1,4 +1,4 @@
-/*
+/*
  * Copyright (c) 2012-2023 Snowflake Computing Inc. All rights reserved.
  */
 
@@ -560,16 +560,36 @@
             }
         }
 
+        [Test]
+        public void TestPutGetFileWithSpaceAndSingleQuote(
+            [Values] StageType stageType,
+            [Values("/STAGE PATH WITH SPACE")] string stagePath)
+        {
+            PrepareTest(null, stageType, stagePath, false, true, true);
+            using (var conn = new SnowflakeDbConnection(ConnectionString))
+            {
+                conn.Open();
+                PutFile(conn, "", ResultStatus.UPLOADED, true);
+                CopyIntoTable(conn, true);
+                GetFile(conn, true);
+            }
+        }
+
         private void PrepareTest(string sourceFileCompressionType, StageType stageType, string stagePath,
-            bool autoCompress, bool clientEncryption = true)
+            bool autoCompress, bool clientEncryption = true, bool makeFilePathWithSpace = false)
         {
             t_stageType = stageType;
             t_sourceCompressionType = sourceFileCompressionType;
             t_autoCompress = autoCompress;
             // Prepare temp file name with specified file extension
             t_fileName = Guid.NewGuid() + ".csv" +
-                        (t_autoCompress? SFFileCompressionTypes.LookUpByName(t_sourceCompressionType).FileExtension: "");
-            t_inputFilePath = Path.GetTempPath() + t_fileName;
+                        (t_autoCompress ? SFFileCompressionTypes.LookUpByName(t_sourceCompressionType).FileExtension : "");
+            var sourceFolderWithSpace = $"{Guid.NewGuid()} source file path with space";
+            var inputPathBase = makeFilePathWithSpace ?
+                Path.Combine(s_outputDirectory, sourceFolderWithSpace) :
+                Path.GetTempPath();
+            t_inputFilePath = Path.Combine(inputPathBase, t_fileName);
+
             if (IsCompressedByTheDriver())
             {
                 t_destCompressionType = "gzip";
@@ -580,7 +600,16 @@
                 t_destCompressionType = t_sourceCompressionType;
                 t_outputFileName = t_fileName;
             }
-            t_outputFilePath = $@"{s_outputDirectory}/{t_outputFileName}";
+            var destinationFolderWithSpace = $"{Guid.NewGuid()} destination file path with space";
+            var outputPathBase = makeFilePathWithSpace ?
+                Path.Combine(s_outputDirectory, destinationFolderWithSpace) :
+                s_outputDirectory;
+            t_outputFilePath = Path.Combine(outputPathBase, t_outputFileName);
+            if (makeFilePathWithSpace)
+            {
+                Directory.CreateDirectory(inputPathBase);
+                Directory.CreateDirectory(outputPathBase);
+            }
             t_filesToDelete.Add(t_outputFilePath);
             PrepareFileData(t_inputFilePath);
 
@@ -610,16 +639,17 @@
         string PutFile(
             SnowflakeDbConnection conn,
             String additionalAttribute = "",
-            ResultStatus expectedStatus = ResultStatus.UPLOADED)
+            ResultStatus expectedStatus = ResultStatus.UPLOADED,
+            bool encloseInSingleQuotes = false)
         {
             string queryId;
             using (var command = conn.CreateCommand())
             {
                 // Prepare PUT query
-                string putQuery =
-                    $"PUT file://{t_inputFilePath} {t_internalStagePath}" +
-                    $" AUTO_COMPRESS={(t_autoCompress ? "TRUE" : "FALSE")}" +
-                    $" {additionalAttribute}";
+                var putQuery = encloseInSingleQuotes ?
+                    $"PUT 'file://{t_inputFilePath.Replace("\\", "/")}' '{t_internalStagePath}'" :
+                    $"PUT file://{t_inputFilePath} {t_internalStagePath}";
+                putQuery += $" AUTO_COMPRESS={(t_autoCompress ? "TRUE" : "FALSE")}" + $" {additionalAttribute}";
                 // Upload file
                 command.CommandText = putQuery;
                 var reader = command.ExecuteReader();
@@ -661,7 +691,7 @@
         }
 
         // COPY INTO - Copy data from the stage into temp table
-        private void CopyIntoTable(SnowflakeDbConnection conn)
+        private void CopyIntoTable(SnowflakeDbConnection conn, bool encloseInSingleQuotes = false)
         {
             using (var command = conn.CreateCommand())
             {
@@ -671,7 +701,8 @@
                         command.CommandText = $"COPY INTO {t_schemaName}.{t_tableName}";
                         break;
                     default:
-                        command.CommandText =
+                        command.CommandText = encloseInSingleQuotes ?
+                            $"COPY INTO {t_schemaName}.{t_tableName} FROM '{t_internalStagePath}/{t_fileName}'" :
                             $"COPY INTO {t_schemaName}.{t_tableName} FROM {t_internalStagePath}/{t_fileName}";
                         break;
                 }
@@ -696,12 +727,14 @@
         }
 
         // GET - Download from the stage into local directory
-        private void GetFile(DbConnection conn)
+        private void GetFile(DbConnection conn, bool encloseInSingleQuotes = false)
         {
             using (var command = conn.CreateCommand())
             {
                 // Prepare GET query
-                var getQuery = $"GET {t_internalStagePath}/{t_fileName} file://{s_outputDirectory}";
+                var getQuery = encloseInSingleQuotes ?
+                    $"GET '{t_internalStagePath}/{t_fileName}' 'file://{Path.GetDirectoryName(t_outputFilePath).Replace("\\", "/")}'" :
+                    $"GET {t_internalStagePath}/{t_fileName} file://{s_outputDirectory}";
 
                 // Download file
                 command.CommandText = getQuery;
@@ -764,7 +797,7 @@
         {
             var bytes = new byte[stream.Length];
             stream.Position = 0;
             stream.Read(bytes, 0, (int) stream.Length);
             return Encoding.UTF8.GetString(bytes).Split('\n');
         }