Add integration tests for Azure MySQL.

These run against Azure Database for MySQL - Flexible Server in Central US.

Signed-off-by: Bradley Grainger <bgrainger@gmail.com>

Author: bgrainger

azure-pipelines.yml

@@ -110,6 +110,35 @@ jobs:
       image: 'mysql:8.0'
       connectionString: 'server=localhost;port=3306;user id=mysqltest;password=test;database=conformance;ssl mode=none;DefaultCommandTimeout=3600;AllowPublicKeyRetrieval=True'
 
+- job: azure_mysql_integration_tests
+  displayName: 'Azure MySQL Integration Tests'
+  pool:
+    vmimage: 'windows-latest'
+  steps:
+  - task: UseDotNet@2
+    displayName: 'Install .NET Core'
+    inputs:
+      version: $(DotNetCoreSdkVersion)
+  - task: PowerShell@2
+    displayName: 'Copy Azure config'
+    inputs:
+      targetType: inline
+      script: Copy-Item -Path ".\.ci\config\config.ssl.json" -Destination ".\tests\SideBySide\config.json"
+  - task: DotNetCoreCLI@2
+    displayName: 'Restore packages'
+    inputs:
+      command: 'restore'
+  - task: DotNetCoreCLI@2
+    displayName: 'Side by Side tests (net6.0)'
+    inputs:
+      command: 'test'
+      projects: 'tests/SideBySide/SideBySide.csproj'
+      arguments: '-c Release -f net6.0 --no-restore'
+      testRunTitle: ${{ format('{0}, $(Agent.OS), {1}, {2}', 'Azure', 'net6.0', 'SSL') }}
+    env:
+      DATA__UNSUPPORTEDFEATURES: 'BulkCopyDataTable,CachingSha2Password,Ed25519,GlobalLog,KnownCertificateAuthority,QueryAttributes,RsaEncryption,Sha256Password,Timeout,Tls11,Tls13,UnixDomainSocket'
+      DATA__CONNECTIONSTRING: "$(AzureConnectionString);database=mysqltest;ssl mode=Required;DefaultCommandTimeout=3600;AllowPublicKeyRetrieval=True"
+
 - job: windows_integration_tests_1
   displayName: 'Windows Integration Tests (Part 1)'
   pool:

tests/SideBySide/BulkLoaderAsync.cs

@@ -433,7 +433,7 @@ public void BulkCopyNullDataTable()
 		Assert.ThrowsAsync<ArgumentNullException>(async () => await bulkCopy.WriteToServerAsync(default(DataTable)));
 	}
 
-	[Fact]
+	[SkippableFact(ServerFeatures.BulkCopyDataTable)]
 	public async Task BulkCopyDataTableWithLongData()
 	{
 		var dataTable = new DataTable()
@@ -557,7 +557,7 @@ public async Task BulkCopyAbort(int notifyAfter, int rowCount, int abortAfter, i
 			Assert.Equal(expectedCount, await cmd.ExecuteScalarAsync());
 	}
 
-	[Fact]
+	[SkippableFact(ServerFeatures.BulkCopyDataTable)]
 	public async Task BulkCopyDataTableWithWarnings()
 	{
 		var dataTable = new DataTable()

tests/SideBySide/BulkLoaderSync.cs

@@ -515,7 +515,7 @@ public void BulkCopyNullDataTable()
 		Assert.Throws<ArgumentNullException>(() => bulkCopy.WriteToServer(default(DataTable)));
 	}
 
-	[Fact]
+	[SkippableFact(ServerFeatures.BulkCopyDataTable)]
 	public void BulkCopyDataTableWithLongBlob()
 	{
 		var dataTable = new DataTable()
@@ -554,7 +554,7 @@ public void BulkCopyDataTableWithLongBlob()
 		}
 	}
 
-	[SkippableTheory(ServerFeatures.LargePackets)]
+	[SkippableTheory(ServerFeatures.LargePackets | ServerFeatures.BulkCopyDataTable)]
 	[InlineData(6)]
 	[InlineData(12)]
 	[InlineData(21)]
@@ -620,7 +620,7 @@ public void BulkCopyDataTableWithLongData(int rows)
 		}
 	}
 
-	[Fact]
+	[SkippableFact(ServerFeatures.BulkCopyDataTable)]
 	public void BulkCopyDataTableWithSpecialCharacters()
 	{
 		var dataTable = new DataTable()
@@ -922,7 +922,7 @@ public void BulkCopyDoesNotInsertAllRows()
 		Assert.Equal(MySqlErrorCode.BulkCopyFailed, ex.ErrorCode);
 	}
 
-	[Fact]
+	[SkippableFact(ServerFeatures.BulkCopyDataTable)]
 	public void BulkCopyDataTableWithWarnings()
 	{
 		var dataTable = new DataTable()

tests/SideBySide/ServerFeatures.cs

@@ -24,4 +24,6 @@ public enum ServerFeatures
 	ResetConnection = 0x2_0000,
 	ZeroDateTime = 0x4_0000,
 	QueryAttributes = 0x8_0000,
+	GlobalLog = 0x10_0000,
+	BulkCopyDataTable = 0x20_0000,
 }

tests/SideBySide/Transaction.cs

@@ -43,7 +43,7 @@ public void DbConnectionCommit()
 		Assert.Equal(new[] { 1, 2 }, results);
 	}
 
-	[Theory]
+	[SkippableTheory(ServerFeatures.GlobalLog)]
 	[InlineData(IsolationLevel.ReadUncommitted, "read uncommitted")]
 	[InlineData(IsolationLevel.ReadCommitted, "read committed")]
 	[InlineData(IsolationLevel.RepeatableRead, "repeatable read")]
@@ -70,7 +70,7 @@ public void DbConnectionIsolationLevel(IsolationLevel inputIsolationLevel, strin
 	}
 
 #if !BASELINE
-	[Theory]
+	[SkippableTheory(ServerFeatures.GlobalLog)]
 	[InlineData(IsolationLevel.ReadUncommitted, "start transaction")]
 	[InlineData(IsolationLevel.ReadCommitted, "start transaction")]
 	[InlineData(IsolationLevel.RepeatableRead, "start transaction")]