Resolve leaking error message

Gemfile

@@ -10,3 +10,7 @@ gem "rake"
 gem "rspec"
 gem "pry"
 gem "dotenv"
+
+group :development do
+  gem "parallel"
+end

Gemfile.lock

@@ -1,7 +1,7 @@
 PATH
   remote: .
   specs:
-    ruby_snowflake_client (1.1.0)
+    ruby_snowflake_client (1.3.0)
 
 GEM
   remote: https://rubygems.org/
@@ -10,6 +10,7 @@ GEM
     diff-lcs (1.5.0)
     dotenv (2.8.1)
     method_source (1.0.0)
+    parallel (1.23.0)
     pry (0.14.2)
       coderay (~> 1.1)
       method_source (~> 1.0)
@@ -34,6 +35,7 @@ PLATFORMS
 DEPENDENCIES
   bundler
   dotenv
+  parallel
   pry
   rake
   rspec

lib/ruby_snowflake_client/version.rb

@@ -1,3 +1,3 @@
 module RubySnowflakeClient
-  VERSION = '1.2.1'
+  VERSION = '1.3.0'
 end

spec/snowflake/client_spec.rb

@@ -62,7 +62,50 @@
             sql: query
           )
         end
+      end
+
+      context "for unauthorized database" do
+        before do
+          client.connect(
+            account: ENV["SNOWFLAKE_ACCOUNT"],
+            warehouse: ENV["SNOWFLAKE_WAREHOUSE"],
+            user: ENV["SNOWFLAKE_USER"],
+            password: ENV["SNOWFLAKE_PASSWORD"],
+          )
+        end
+        let(:query) { "SELECT * FROM TEST_DATABASE.RINSED_WEB_APP.EMAILS LIMIT 1;" }
+        it "should raise an exception" do
+          expect { result }.to raise_error do |error|
+            expect(error).to be_a Snowflake::Error
+            expect(error.message).to include "TEST_DATABASE"
+            expect(error.sentry_context).to include(
+              sql: query
+            )
+          end
+        end
 
+        it "should raise the correct exception for threaded work" do
+          require "parallel"
+
+          Parallel.map((1..3).collect { _1 }, in_threads: 2) do |idx|
+            c = described_class.new
+            c.connect(
+              account: ENV["SNOWFLAKE_ACCOUNT"],
+              warehouse: ENV["SNOWFLAKE_WAREHOUSE"],
+              user: ENV["SNOWFLAKE_USER"],
+              password: ENV["SNOWFLAKE_PASSWORD"],
+            )
+            query = "SELECT * FROM TEST_DATABASE#{idx}.RINSED_WEB_APP.EMAILS LIMIT 1;"
+
+            expect { c.fetch(query) }.to raise_error do |error|
+              expect(error).to be_a Snowflake::Error
+              expect(error.sentry_context).to include(
+                sql: query
+              )
+              expect(error.message).to include "TEST_DATABASE#{idx}"
+            end
+          end
+        end
       end
     end