diff --git a/azure_storage_client.go b/azure_storage_client.go
index f5c270a63..0db3a4cb3 100644
--- a/azure_storage_client.go
+++ b/azure_storage_client.go
@@ -204,7 +204,7 @@ func (util *snowflakeAzureClient) uploadFile(
 		})
 	} else {
 		var f *os.File
-		f, err = os.OpenFile(dataFile, os.O_RDONLY, readWriteFileMode)
+		f, err = os.Open(dataFile)
 		if err != nil {
 			return err
 		}
diff --git a/doc.go b/doc.go
index f8fe39bb4..d6ab5a8c0 100644
--- a/doc.go
+++ b/doc.go
@@ -889,7 +889,7 @@ both an escape character and as a separator in path names.
 To send information from a stream (rather than a file) use code similar to the code below.
 (The ReplaceAll() function is needed on Windows to handle backslashes in the path to the file.)
 
-	fileStream, _ := os.OpenFile(fname, os.O_RDONLY, 0666)
+	fileStream, _ := os.Open(fname)
 	defer func() {
 		if fileStream != nil {
 			fileStream.Close()
diff --git a/encrypt_util.go b/encrypt_util.go
index b6cedcdff..435ecbafc 100644
--- a/encrypt_util.go
+++ b/encrypt_util.go
@@ -232,7 +232,7 @@ func decryptFile(
 		return "", err
 	}
 	defer tmpOutputFile.Close()
-	infile, err := os.OpenFile(filename, os.O_RDONLY, readWriteFileMode)
+	infile, err := os.Open(filename)
 	if err != nil {
 		return "", err
 	}
diff --git a/encrypt_util_test.go b/encrypt_util_test.go
index 8ed977f90..1480a3ab9 100644
--- a/encrypt_util_test.go
+++ b/encrypt_util_test.go
@@ -54,7 +54,7 @@ func TestEncryptDecryptFile(t *testing.T) {
 	}
 	defer os.Remove(decryptedFile)
 
-	fd, err = os.OpenFile(decryptedFile, os.O_RDONLY, readWriteFileMode)
+	fd, err = os.Open(decryptedFile)
 	if err != nil {
 		t.Error(err)
 	}
@@ -144,7 +144,7 @@ func encryptDecryptFile(t *testing.T, encMat snowflakeFileEncryption, expected i
 	defer os.Remove(decryptedFile)
 
 	cnt := 0
-	fd, err := os.OpenFile(decryptedFile, os.O_RDONLY, readWriteFileMode)
+	fd, err := os.Open(decryptedFile)
 	if err != nil {
 		t.Error(err)
 	}
@@ -238,7 +238,7 @@ func generateKLinesOfNFiles(k int, n int, compress bool, tmpDir string) (string,
 					return "", err
 				}
 				w := gzip.NewWriter(fOut)
-				fIn, err := os.OpenFile(fname, os.O_RDONLY, readWriteFileMode)
+				fIn, err := os.Open(fname)
 				if err != nil {
 					return "", err
 				}
diff --git a/file_util.go b/file_util.go
index cf32fdc97..13740bb89 100644
--- a/file_util.go
+++ b/file_util.go
@@ -40,7 +40,7 @@ func (util *snowflakeFileUtil) compressFileWithGzip(fileName string, tmpDir stri
 	basename := baseName(fileName)
 	gzipFileName := filepath.Join(tmpDir, basename+"_c.gz")
 
-	fr, err := os.OpenFile(fileName, os.O_RDONLY, readWriteFileMode)
+	fr, err := os.Open(fileName)
 	if err != nil {
 		return "", -1, err
 	}
diff --git a/gcs_storage_client.go b/gcs_storage_client.go
index 078091b25..5d9dac9a8 100644
--- a/gcs_storage_client.go
+++ b/gcs_storage_client.go
@@ -196,7 +196,7 @@ func (util *snowflakeGcsClient) uploadFile(
 			uploadSrc = meta.realSrcStream
 		}
 	} else {
-		uploadSrc, err = os.OpenFile(dataFile, os.O_RDONLY, readWriteFileMode)
+		uploadSrc, err = os.Open(dataFile)
 		if err != nil {
 			return err
 		}
diff --git a/local_storage_client_test.go b/local_storage_client_test.go
index 114f49982..6b0c87f7c 100644
--- a/local_storage_client_test.go
+++ b/local_storage_client_test.go
@@ -73,7 +73,7 @@ func TestLocalUpload(t *testing.T) {
 	if uploadMeta.resStatus != skipped {
 		t.Fatal("overwrite is false. should have skipped")
 	}
-	fileStream, _ := os.OpenFile(fname, os.O_RDONLY, readWriteFileMode)
+	fileStream, _ := os.Open(fname)
 	ctx := WithFileStream(context.Background(), fileStream)
 	uploadMeta.srcStream = getFileStream(ctx)
 
diff --git a/put_get_test.go b/put_get_test.go
index 259abe178..93f2a9fa8 100644
--- a/put_get_test.go
+++ b/put_get_test.go
@@ -399,7 +399,7 @@ func testPutGet(t *testing.T, isStream bool) {
 	runTests(t, dsn, func(dbt *DBTest) {
 		dbt.mustExec("create or replace table " + tableName +
 			" (a int, b string)")
-		fileStream, err := os.OpenFile(fname, os.O_RDONLY, readWriteFileMode)
+		fileStream, err := os.Open(fname)
 		if err != nil {
 			t.Error(err)
 		}
@@ -525,7 +525,7 @@ func TestPutGetGcsDownscopedCredential(t *testing.T) {
 	runTests(t, dsn, func(dbt *DBTest) {
 		dbt.mustExec("create or replace table " + tableName +
 			" (a int, b string)")
-		fileStream, err := os.OpenFile(fname, os.O_RDONLY, readWriteFileMode)
+		fileStream, err := os.Open(fname)
 		if err != nil {
 			t.Error(err)
 		}
diff --git a/put_get_user_stage_test.go b/put_get_user_stage_test.go
index d8f6a0c88..69c9a1142 100644
--- a/put_get_user_stage_test.go
+++ b/put_get_user_stage_test.go
@@ -69,7 +69,7 @@ func putGetUserStage(t *testing.T, tmpDir string, numberOfFiles int, numberOfLin
 		dbt.mustExec("rm @" + stageName)
 		var fs *os.File
 		if isStream {
-			fs, _ = os.OpenFile(files, os.O_RDONLY, readWriteFileMode)
+			fs, _ = os.Open(files)
 			dbt.mustExecContext(WithFileStream(context.Background(), fs),
 				fmt.Sprintf("put 'file://%v' @%v", strings.ReplaceAll(
 					files, "\\", "\\\\"), stageName))