Merge pull request #350 from snowflakedb/prep-1.2.5

Merge Changes for release 1.2.5
snowflakedb · Jul 22, 2021 · 79bd89c · 79bd89c
2 parents bfc6570 + 1db22ca
commit 79bd89c
Show file tree

Hide file tree

Showing 13 changed files with 824 additions and 46 deletions.
diff --git a/Snowflake.Data.Tests/Mock/MockSecretDetector.cs b/Snowflake.Data.Tests/Mock/MockSecretDetector.cs
@@ -0,0 +1,31 @@
+/*
+ * Copyright (c) 2021 Snowflake Computing Inc. All rights reserved.
+ */
+
+using System;
+using Snowflake.Data.Log;
+
+namespace Snowflake.Data.Tests.Mock
+{
+    class MockSecretDetector
+    {        
+        public static SecretDetector.Mask MaskSecrets(string text)
+        {
+            SecretDetector.Mask result = new SecretDetector.Mask();
+            try
+            {
+                throw new Exception("Test exception");
+            }
+            catch (Exception ex)
+            {
+                //We'll assume that the exception was raised during masking
+                //to be safe consider that the log has sensitive information
+                //and do not raise an exception.
+                result.isMasked = true;
+                result.maskedText = ex.Message;
+                result.errStr = ex.Message;
+            }
+            return result;
+        }
+    }
+}
diff --git a/Snowflake.Data.Tests/SFBaseTest.cs b/Snowflake.Data.Tests/SFBaseTest.cs
@@ -89,7 +89,6 @@ public void SFTestSetup()
             Assert.IsTrue(cloud == null || cloud == "AWS" || cloud == "AZURE" || cloud == "GCP", "{0} is not supported. Specify AWS, AZURE or GCP as cloud environment", cloud);
 
             StreamReader reader = new StreamReader("parameters.json");
-
             var testConfigString = reader.ReadToEnd();
 
             Dictionary<string, TestConfig> testConfigs = JsonConvert.DeserializeObject<Dictionary<string, TestConfig>>(testConfigString);

diff --git a/Snowflake.Data.Tests/SFConnectionIT.cs b/Snowflake.Data.Tests/SFConnectionIT.cs
@@ -20,6 +20,48 @@ class SFConnectionIT : SFBaseTest
     {
         private static SFLogger logger = SFLoggerFactory.GetLogger<SFConnectionIT>();
 
+
+        [Test]
+        public void testMulitpleConnectionInParallel()
+        {
+            Task[] tasks = new Task[450];
+            for (int i = 0; i < 450; i++)
+            {
+                tasks[i] = Task.Run(() =>
+                {
+                    using (IDbConnection conn = new SnowflakeDbConnection())
+                    {
+
+                        conn.ConnectionString = ConnectionString + ";CONNECTION_TIMEOUT=30;INSECUREMODE=false";
+                        Console.WriteLine($"{conn.ConnectionString}");
+
+                        try
+                        {
+                            conn.Open();
+                        }
+                        catch (Exception e)
+                        {
+                            Console.WriteLine(e);
+                            Console.WriteLine("--------------------------");
+                            Console.WriteLine(e.InnerException);
+                        }
+                    }
+                });
+            }
+            try
+            {
+                Task.WaitAll(tasks);
+            }
+            catch (AggregateException ae)
+            {
+                Console.WriteLine("One or more exceptions occurred: ");
+                foreach (var ex in ae.Flatten().InnerExceptions)
+                    Console.WriteLine("   {0}", ex.Message);
+
+            }
+
+        }
+
         [Test]
         public void TestBasicConnection()
         {