SqlClient/src/Microsoft.Data.SqlClient/tests/FunctionalTests/SqlBulkCopyCacheMetadataTest.cs at 855e63ca28d0c34e8372ca43cb5a2b09e3d568af · dotnet/SqlClient · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT license.
// See the LICENSE file in the project root for more information.

using Xunit;

namespace Microsoft.Data.SqlClient.Tests
{
    public class SqlBulkCopyCacheMetadataTest
    {
        [Fact]
        public void CacheMetadata_FlagValue_IsCorrect()
        {
            Assert.Equal(1 << 7, (int)SqlBulkCopyOptions.CacheMetadata);
        }

        [Fact]
        public void CacheMetadata_CanBeCombinedWithOtherOptions()
        {
            SqlBulkCopyOptions combined =
                SqlBulkCopyOptions.CacheMetadata |
                SqlBulkCopyOptions.KeepIdentity |
                SqlBulkCopyOptions.TableLock;

            Assert.True((combined & SqlBulkCopyOptions.CacheMetadata) == SqlBulkCopyOptions.CacheMetadata);
            Assert.True((combined & SqlBulkCopyOptions.KeepIdentity) == SqlBulkCopyOptions.KeepIdentity);
            Assert.True((combined & SqlBulkCopyOptions.TableLock) == SqlBulkCopyOptions.TableLock);
        }

        [Fact]
        public void CacheMetadata_DoesNotOverlapExistingFlags()
        {
            int cacheMetadataValue = (int)SqlBulkCopyOptions.CacheMetadata;
            Assert.NotEqual((int)SqlBulkCopyOptions.Default, cacheMetadataValue);
            Assert.NotEqual((int)SqlBulkCopyOptions.KeepIdentity, cacheMetadataValue);
            Assert.NotEqual((int)SqlBulkCopyOptions.CheckConstraints, cacheMetadataValue);
            Assert.NotEqual((int)SqlBulkCopyOptions.TableLock, cacheMetadataValue);
            Assert.NotEqual((int)SqlBulkCopyOptions.KeepNulls, cacheMetadataValue);
            Assert.NotEqual((int)SqlBulkCopyOptions.FireTriggers, cacheMetadataValue);
            Assert.NotEqual((int)SqlBulkCopyOptions.UseInternalTransaction, cacheMetadataValue);
            Assert.NotEqual((int)SqlBulkCopyOptions.AllowEncryptedValueModifications, cacheMetadataValue);
        }

        [Fact]
        public void InvalidateMetadataCache_CanBeCalledWithoutError()
        {
            using SqlBulkCopy bulkCopy = new(new SqlConnection());
            bulkCopy.InvalidateMetadataCache();
        }

        [Fact]
        public void InvalidateMetadataCache_CanBeCalledMultipleTimes()
        {
            using SqlBulkCopy bulkCopy = new(new SqlConnection());
            bulkCopy.InvalidateMetadataCache();
            bulkCopy.InvalidateMetadataCache();
            bulkCopy.InvalidateMetadataCache();
        }

        [Fact]
        public void InvalidateMetadataCache_WithCacheMetadataOption()
        {
            using SqlBulkCopy bulkCopy = new(new SqlConnection(), SqlBulkCopyOptions.CacheMetadata, null);
            bulkCopy.InvalidateMetadataCache();
        }

        [Fact]
        public void InvalidateMetadataCache_WithoutCacheMetadataOption()
        {
            using SqlBulkCopy bulkCopy = new(new SqlConnection(), SqlBulkCopyOptions.Default, null);
            bulkCopy.InvalidateMetadataCache();
        }

        [Fact]
        public void DestinationTableName_Change_DoesNotThrowWithCacheMetadata()
        {
            using SqlBulkCopy bulkCopy = new(new SqlConnection(), SqlBulkCopyOptions.CacheMetadata, null);
            bulkCopy.DestinationTableName = "Table1";
            bulkCopy.DestinationTableName = "Table2";
            bulkCopy.DestinationTableName = "Table1";
        }

        [Fact]
        public void Constructor_WithCacheMetadataOption_Succeeds()
        {
            using SqlBulkCopy bulkCopy = new(new SqlConnection(), SqlBulkCopyOptions.CacheMetadata, null);
            Assert.NotNull(bulkCopy);
        }

        [Fact]
        public void Constructor_WithCacheMetadataAndConnectionString_Succeeds()
        {
            using SqlBulkCopy bulkCopy = new("Server=localhost", SqlBulkCopyOptions.CacheMetadata);
            Assert.NotNull(bulkCopy);
        }
    }
}