mirror of
https://github.com/ckaczor/sqltoolsservice.git
synced 2026-01-14 01:25:40 -05:00
839acf67cd
* Remove xunit dependency from testdriver * swap expected/actual as needed * Convert Test.Common to nunit * port hosting unit tests to nunit * port batchparser integration tests to nunit * port testdriver.tests to nunit * fix target to copy dependency * port servicelayer unittests to nunit * more unit test fixes * port integration tests to nunit * fix test method type * try using latest windows build for PRs * reduce test memory use
1269 lines
66 KiB
C#
1269 lines
66 KiB
C#
//
|
|
// Copyright (c) Microsoft. All rights reserved.
|
|
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
|
|
//
|
|
using Microsoft.SqlServer.Dac.Compare;
|
|
using Microsoft.SqlServer.Dac.Model;
|
|
using Microsoft.SqlTools.Hosting.Protocol;
|
|
using Microsoft.SqlTools.ServiceLayer.SchemaCompare;
|
|
using Microsoft.SqlTools.ServiceLayer.SchemaCompare.Contracts;
|
|
using Microsoft.SqlTools.ServiceLayer.TaskServices;
|
|
using Microsoft.SqlTools.ServiceLayer.Test.Common;
|
|
using Microsoft.SqlTools.ServiceLayer.Utility;
|
|
using Moq;
|
|
using System;
|
|
using Microsoft.Data.SqlClient;
|
|
using System.IO;
|
|
using System.Linq;
|
|
using System.Threading.Tasks;
|
|
using NUnit.Framework;
|
|
using System.Diagnostics;
|
|
|
|
namespace Microsoft.SqlTools.ServiceLayer.IntegrationTests.SchemaCompare
|
|
{
|
|
public class SchemaCompareServiceTests
|
|
{
|
|
private const string SourceScript = @"CREATE TABLE [dbo].[table1]
|
|
(
|
|
[ID] INT NOT NULL PRIMARY KEY,
|
|
[Date] DATE NOT NULL
|
|
)
|
|
CREATE TABLE [dbo].[table2]
|
|
(
|
|
[ID] INT NOT NULL PRIMARY KEY,
|
|
[col1] NCHAR(10) NULL
|
|
)";
|
|
|
|
private const string TargetScript = @"CREATE TABLE [dbo].[table2]
|
|
(
|
|
[ID] INT NOT NULL PRIMARY KEY,
|
|
[col1] NCHAR(10) NULL,
|
|
[col2] NCHAR(10) NULL
|
|
)
|
|
CREATE TABLE [dbo].[table3]
|
|
(
|
|
[ID] INT NOT NULL PRIMARY KEY,
|
|
[col1] INT NULL,
|
|
)";
|
|
|
|
private const string SourceIncludeExcludeScript = @"CREATE TABLE t1(c1 INT PRIMARY KEY, c2 INT)
|
|
GO
|
|
CREATE TABLE t2(c1 INT PRIMARY KEY, c2 INT)
|
|
GO
|
|
cREATE VIEW v1 as SELECT c1 FROM t2";
|
|
|
|
private const string TargetIncludeExcludeScript = @"CREATE TABLE t1 (c1 INT PRIMARY KEY)
|
|
GO
|
|
CREATE TABLE t3 (c3 INT PRIMARY KEY, c2 INT)
|
|
GO
|
|
CREATE VIEW v2 as SELECT t1.c1, t3.c3 FROM t1, t3
|
|
GO";
|
|
|
|
private const string CreateKey = @"CREATE COLUMN MASTER KEY [CMK_Auto1]
|
|
WITH (
|
|
KEY_STORE_PROVIDER_NAME = N'MSSQL_CERTIFICATE_STORE',
|
|
KEY_PATH = N'CurrentUser/my/1234'
|
|
);
|
|
CREATE COLUMN ENCRYPTION KEY [CEK_Auto1]
|
|
WITH VALUES
|
|
(
|
|
COLUMN_MASTER_KEY = [CMK_Auto1],
|
|
ALGORITHM = N'RSA_OAEP',
|
|
ENCRYPTED_VALUE = 0x0000
|
|
);";
|
|
|
|
private const string CreateFileGroup = @"ALTER DATABASE {0}
|
|
ADD FILEGROUP [MyFileGroup] CONTAINS MEMORY_OPTIMIZED_DATA;
|
|
GO";
|
|
|
|
/// <summary>
|
|
/// Verify the schema compare request comparing two dacpacs
|
|
/// </summary>
|
|
[Test]
|
|
public async Task SchemaCompareDacpacToDacpac()
|
|
{
|
|
var result = SchemaCompareTestUtils.GetLiveAutoCompleteTestObjects();
|
|
|
|
// create dacpacs from databases
|
|
SqlTestDb sourceDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, SourceScript, "SchemaCompareSource");
|
|
SqlTestDb targetDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, TargetScript, "SchemaCompareTarget");
|
|
try
|
|
{
|
|
string sourceDacpacFilePath = SchemaCompareTestUtils.CreateDacpac(sourceDb);
|
|
string targetDacpacFilePath = SchemaCompareTestUtils.CreateDacpac(targetDb);
|
|
|
|
SchemaCompareEndpointInfo sourceInfo = new SchemaCompareEndpointInfo();
|
|
SchemaCompareEndpointInfo targetInfo = new SchemaCompareEndpointInfo();
|
|
|
|
sourceInfo.EndpointType = SchemaCompareEndpointType.Dacpac;
|
|
sourceInfo.PackageFilePath = sourceDacpacFilePath;
|
|
targetInfo.EndpointType = SchemaCompareEndpointType.Dacpac;
|
|
targetInfo.PackageFilePath = targetDacpacFilePath;
|
|
|
|
var schemaCompareParams = new SchemaCompareParams
|
|
{
|
|
SourceEndpointInfo = sourceInfo,
|
|
TargetEndpointInfo = targetInfo
|
|
};
|
|
|
|
SchemaCompareOperation schemaCompareOperation = new SchemaCompareOperation(schemaCompareParams, null, null);
|
|
ValidateSchemaCompareWithExcludeIncludeResults(schemaCompareOperation);
|
|
|
|
// cleanup
|
|
SchemaCompareTestUtils.VerifyAndCleanup(sourceDacpacFilePath);
|
|
SchemaCompareTestUtils.VerifyAndCleanup(targetDacpacFilePath);
|
|
}
|
|
finally
|
|
{
|
|
sourceDb.Cleanup();
|
|
targetDb.Cleanup();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Verify the schema compare request comparing a two databases
|
|
/// </summary>
|
|
[Test]
|
|
public async Task SchemaCompareDatabaseToDatabase()
|
|
{
|
|
var result = SchemaCompareTestUtils.GetLiveAutoCompleteTestObjects();
|
|
SqlTestDb sourceDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, SourceScript, "SchemaCompareSource");
|
|
SqlTestDb targetDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, TargetScript, "SchemaCompareTarget");
|
|
string folderPath = Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.LocalApplicationData), "SchemaCompareTest");
|
|
Directory.CreateDirectory(folderPath);
|
|
|
|
try
|
|
{
|
|
SchemaCompareEndpointInfo sourceInfo = new SchemaCompareEndpointInfo();
|
|
SchemaCompareEndpointInfo targetInfo = new SchemaCompareEndpointInfo();
|
|
|
|
sourceInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
sourceInfo.DatabaseName = sourceDb.DatabaseName;
|
|
targetInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
targetInfo.DatabaseName = targetDb.DatabaseName;
|
|
|
|
var schemaCompareParams = new SchemaCompareParams
|
|
{
|
|
SourceEndpointInfo = sourceInfo,
|
|
TargetEndpointInfo = targetInfo
|
|
};
|
|
|
|
SchemaCompareOperation schemaCompareOperation = new SchemaCompareOperation(schemaCompareParams, result.ConnectionInfo, result.ConnectionInfo);
|
|
ValidateSchemaCompareWithExcludeIncludeResults(schemaCompareOperation);
|
|
}
|
|
finally
|
|
{
|
|
// cleanup
|
|
sourceDb.Cleanup();
|
|
targetDb.Cleanup();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Verify the schema compare request comparing a database to a dacpac
|
|
/// </summary>
|
|
[Test]
|
|
public async Task SchemaCompareDatabaseToDacpac()
|
|
{
|
|
var result = SchemaCompareTestUtils.GetLiveAutoCompleteTestObjects();
|
|
SqlTestDb sourceDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, SourceScript, "SchemaCompareSource");
|
|
SqlTestDb targetDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, TargetScript, "SchemaCompareTarget");
|
|
|
|
try
|
|
{
|
|
string targetDacpacFilePath = SchemaCompareTestUtils.CreateDacpac(targetDb);
|
|
|
|
SchemaCompareEndpointInfo sourceInfo = new SchemaCompareEndpointInfo();
|
|
SchemaCompareEndpointInfo targetInfo = new SchemaCompareEndpointInfo();
|
|
|
|
sourceInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
sourceInfo.DatabaseName = sourceDb.DatabaseName;
|
|
targetInfo.EndpointType = SchemaCompareEndpointType.Dacpac;
|
|
targetInfo.PackageFilePath = targetDacpacFilePath;
|
|
|
|
var schemaCompareParams = new SchemaCompareParams
|
|
{
|
|
SourceEndpointInfo = sourceInfo,
|
|
TargetEndpointInfo = targetInfo
|
|
};
|
|
|
|
SchemaCompareOperation schemaCompareOperation = new SchemaCompareOperation(schemaCompareParams, result.ConnectionInfo, null);
|
|
ValidateSchemaCompareWithExcludeIncludeResults(schemaCompareOperation);
|
|
|
|
// cleanup
|
|
SchemaCompareTestUtils.VerifyAndCleanup(targetDacpacFilePath);
|
|
}
|
|
finally
|
|
{
|
|
sourceDb.Cleanup();
|
|
targetDb.Cleanup();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Verify the schema compare generate script request comparing a database to a database
|
|
/// </summary>
|
|
[Test]
|
|
public async Task SchemaCompareGenerateScriptDatabaseToDatabase()
|
|
{
|
|
var result = SchemaCompareTestUtils.GetLiveAutoCompleteTestObjects();
|
|
var schemaCompareRequestContext = new Mock<RequestContext<SchemaCompareResult>>();
|
|
schemaCompareRequestContext.Setup(x => x.SendResult(It.IsAny<SchemaCompareResult>())).Returns(Task.FromResult(new object()));
|
|
|
|
SqlTestDb sourceDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, SourceScript, "SchemaCompareSource");
|
|
SqlTestDb targetDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, TargetScript, "SchemaCompareTarget");
|
|
|
|
try
|
|
{
|
|
SchemaCompareEndpointInfo sourceInfo = new SchemaCompareEndpointInfo();
|
|
SchemaCompareEndpointInfo targetInfo = new SchemaCompareEndpointInfo();
|
|
|
|
sourceInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
sourceInfo.DatabaseName = sourceDb.DatabaseName;
|
|
targetInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
targetInfo.DatabaseName = targetDb.DatabaseName;
|
|
|
|
var schemaCompareParams = new SchemaCompareParams
|
|
{
|
|
SourceEndpointInfo = sourceInfo,
|
|
TargetEndpointInfo = targetInfo
|
|
};
|
|
|
|
SchemaCompareOperation schemaCompareOperation = new SchemaCompareOperation(schemaCompareParams, result.ConnectionInfo, result.ConnectionInfo);
|
|
|
|
// generate script params
|
|
var generateScriptParams = new SchemaCompareGenerateScriptParams
|
|
{
|
|
TargetDatabaseName = targetDb.DatabaseName,
|
|
OperationId = schemaCompareOperation.OperationId,
|
|
};
|
|
|
|
ValidateSchemaCompareScriptGenerationWithExcludeIncludeResults(schemaCompareOperation, generateScriptParams);
|
|
}
|
|
finally
|
|
{
|
|
sourceDb.Cleanup();
|
|
targetDb.Cleanup();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Verify the schema compare generate script request comparing a dacpac to a database
|
|
/// </summary>
|
|
[Test]
|
|
public async Task SchemaCompareGenerateScriptDacpacToDatabase()
|
|
{
|
|
var result = SchemaCompareTestUtils.GetLiveAutoCompleteTestObjects();
|
|
SqlTestDb sourceDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, SourceScript, "SchemaCompareSource");
|
|
SqlTestDb targetDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, TargetScript, "SchemaCompareTarget");
|
|
string folderPath = Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.LocalApplicationData), "SchemaCompareTest");
|
|
Directory.CreateDirectory(folderPath);
|
|
|
|
try
|
|
{
|
|
string sourceDacpacFilePath = SchemaCompareTestUtils.CreateDacpac(sourceDb);
|
|
|
|
SchemaCompareEndpointInfo sourceInfo = new SchemaCompareEndpointInfo();
|
|
SchemaCompareEndpointInfo targetInfo = new SchemaCompareEndpointInfo();
|
|
|
|
sourceInfo.EndpointType = SchemaCompareEndpointType.Dacpac;
|
|
sourceInfo.PackageFilePath = sourceDacpacFilePath;
|
|
targetInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
targetInfo.DatabaseName = targetDb.DatabaseName;
|
|
|
|
var schemaCompareParams = new SchemaCompareParams
|
|
{
|
|
SourceEndpointInfo = sourceInfo,
|
|
TargetEndpointInfo = targetInfo
|
|
};
|
|
|
|
SchemaCompareOperation schemaCompareOperation = new SchemaCompareOperation(schemaCompareParams, result.ConnectionInfo, result.ConnectionInfo);
|
|
|
|
// generate script
|
|
var generateScriptParams = new SchemaCompareGenerateScriptParams
|
|
{
|
|
TargetDatabaseName = targetDb.DatabaseName,
|
|
OperationId = schemaCompareOperation.OperationId,
|
|
};
|
|
|
|
ValidateSchemaCompareScriptGenerationWithExcludeIncludeResults(schemaCompareOperation, generateScriptParams);
|
|
|
|
// cleanup
|
|
SchemaCompareTestUtils.VerifyAndCleanup(sourceDacpacFilePath);
|
|
}
|
|
finally
|
|
{
|
|
sourceDb.Cleanup();
|
|
targetDb.Cleanup();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Verify the schema compare publish changes request comparing a dacpac to a database
|
|
/// </summary>
|
|
[Test]
|
|
public async Task SchemaComparePublishChangesDacpacToDatabase()
|
|
{
|
|
var result = SchemaCompareTestUtils.GetLiveAutoCompleteTestObjects();
|
|
SqlTestDb sourceDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, SourceScript, "SchemaCompareSource");
|
|
SqlTestDb targetDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, null, "SchemaCompareTarget");
|
|
string folderPath = Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.LocalApplicationData), "SchemaCompareTest");
|
|
Directory.CreateDirectory(folderPath);
|
|
|
|
try
|
|
{
|
|
string sourceDacpacFilePath = SchemaCompareTestUtils.CreateDacpac(sourceDb);
|
|
|
|
SchemaCompareEndpointInfo sourceInfo = new SchemaCompareEndpointInfo();
|
|
SchemaCompareEndpointInfo targetInfo = new SchemaCompareEndpointInfo();
|
|
|
|
sourceInfo.EndpointType = SchemaCompareEndpointType.Dacpac;
|
|
sourceInfo.PackageFilePath = sourceDacpacFilePath;
|
|
targetInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
targetInfo.DatabaseName = targetDb.DatabaseName;
|
|
|
|
var schemaCompareParams = new SchemaCompareParams
|
|
{
|
|
SourceEndpointInfo = sourceInfo,
|
|
TargetEndpointInfo = targetInfo
|
|
};
|
|
|
|
SchemaCompareOperation schemaCompareOperation = new SchemaCompareOperation(schemaCompareParams, result.ConnectionInfo, result.ConnectionInfo);
|
|
schemaCompareOperation.Execute(TaskExecutionMode.Execute);
|
|
|
|
Assert.True(schemaCompareOperation.ComparisonResult.IsValid);
|
|
Assert.False(schemaCompareOperation.ComparisonResult.IsEqual);
|
|
Assert.NotNull(schemaCompareOperation.ComparisonResult.Differences);
|
|
var enumerator = schemaCompareOperation.ComparisonResult.Differences.GetEnumerator();
|
|
enumerator.MoveNext();
|
|
Assert.True(enumerator.Current.SourceObject.Name.ToString().Equals("[dbo].[table1]"));
|
|
enumerator.MoveNext();
|
|
Assert.True(enumerator.Current.SourceObject.Name.ToString().Equals("[dbo].[table2]"));
|
|
|
|
// update target
|
|
var publishChangesParams = new SchemaComparePublishChangesParams
|
|
{
|
|
TargetDatabaseName = targetDb.DatabaseName,
|
|
OperationId = schemaCompareOperation.OperationId,
|
|
};
|
|
|
|
SchemaComparePublishChangesOperation publishChangesOperation = new SchemaComparePublishChangesOperation(publishChangesParams, schemaCompareOperation.ComparisonResult);
|
|
publishChangesOperation.Execute(TaskExecutionMode.Execute);
|
|
Assert.True(publishChangesOperation.PublishResult.Success);
|
|
Assert.That(publishChangesOperation.PublishResult.Errors, Is.Empty);
|
|
|
|
// Verify that there are no differences after the publish by running the comparison again
|
|
schemaCompareOperation.Execute(TaskExecutionMode.Execute);
|
|
|
|
Assert.True(schemaCompareOperation.ComparisonResult.IsValid);
|
|
Assert.True(schemaCompareOperation.ComparisonResult.IsEqual);
|
|
Assert.That(schemaCompareOperation.ComparisonResult.Differences, Is.Empty);
|
|
|
|
// cleanup
|
|
SchemaCompareTestUtils.VerifyAndCleanup(sourceDacpacFilePath);
|
|
}
|
|
finally
|
|
{
|
|
sourceDb.Cleanup();
|
|
targetDb.Cleanup();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Verify the schema compare publish changes request comparing a database to a database
|
|
/// </summary>
|
|
[Test]
|
|
public async Task SchemaComparePublishChangesDatabaseToDatabase()
|
|
{
|
|
var result = SchemaCompareTestUtils.GetLiveAutoCompleteTestObjects();
|
|
SqlTestDb sourceDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, SourceScript, "SchemaCompareSource");
|
|
SqlTestDb targetDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, null, "SchemaCompareTarget");
|
|
|
|
try
|
|
{
|
|
SchemaCompareEndpointInfo sourceInfo = new SchemaCompareEndpointInfo();
|
|
SchemaCompareEndpointInfo targetInfo = new SchemaCompareEndpointInfo();
|
|
|
|
sourceInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
sourceInfo.DatabaseName = sourceDb.DatabaseName;
|
|
targetInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
targetInfo.DatabaseName = targetDb.DatabaseName;
|
|
|
|
var schemaCompareParams = new SchemaCompareParams
|
|
{
|
|
SourceEndpointInfo = sourceInfo,
|
|
TargetEndpointInfo = targetInfo
|
|
};
|
|
|
|
SchemaCompareOperation schemaCompareOperation = new SchemaCompareOperation(schemaCompareParams, result.ConnectionInfo, result.ConnectionInfo);
|
|
schemaCompareOperation.Execute(TaskExecutionMode.Execute);
|
|
|
|
Assert.True(schemaCompareOperation.ComparisonResult.IsValid);
|
|
Assert.False(schemaCompareOperation.ComparisonResult.IsEqual);
|
|
Assert.NotNull(schemaCompareOperation.ComparisonResult.Differences);
|
|
var enumerator = schemaCompareOperation.ComparisonResult.Differences.GetEnumerator();
|
|
enumerator.MoveNext();
|
|
Assert.True(enumerator.Current.SourceObject.Name.ToString().Equals("[dbo].[table1]"));
|
|
enumerator.MoveNext();
|
|
Assert.True(enumerator.Current.SourceObject.Name.ToString().Equals("[dbo].[table2]"));
|
|
|
|
// update target
|
|
var publishChangesParams = new SchemaComparePublishChangesParams
|
|
{
|
|
TargetDatabaseName = targetDb.DatabaseName,
|
|
OperationId = schemaCompareOperation.OperationId,
|
|
};
|
|
|
|
SchemaComparePublishChangesOperation publishChangesOperation = new SchemaComparePublishChangesOperation(publishChangesParams, schemaCompareOperation.ComparisonResult);
|
|
publishChangesOperation.Execute(TaskExecutionMode.Execute);
|
|
Assert.True(publishChangesOperation.PublishResult.Success);
|
|
Assert.That(publishChangesOperation.PublishResult.Errors, Is.Empty);
|
|
|
|
// Verify that there are no differences after the publish by running the comparison again
|
|
schemaCompareOperation.Execute(TaskExecutionMode.Execute);
|
|
|
|
Assert.True(schemaCompareOperation.ComparisonResult.IsValid);
|
|
Assert.True(schemaCompareOperation.ComparisonResult.IsEqual);
|
|
Assert.That(schemaCompareOperation.ComparisonResult.Differences, Is.Empty);
|
|
}
|
|
finally
|
|
{
|
|
sourceDb.Cleanup();
|
|
targetDb.Cleanup();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Verify the schema compare Scmp File Save for database endpoints
|
|
/// </summary>
|
|
[Test]
|
|
public async Task SchemaCompareSaveScmpFileForDatabases()
|
|
{
|
|
var result = SchemaCompareTestUtils.GetLiveAutoCompleteTestObjects();
|
|
|
|
SqlTestDb sourceDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, SourceScript, "SchemaCompareSource");
|
|
SqlTestDb targetDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, TargetScript, "SchemaCompareTarget");
|
|
|
|
try
|
|
{
|
|
SchemaCompareEndpointInfo sourceInfo = new SchemaCompareEndpointInfo();
|
|
SchemaCompareEndpointInfo targetInfo = new SchemaCompareEndpointInfo();
|
|
|
|
sourceInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
sourceInfo.DatabaseName = sourceDb.DatabaseName;
|
|
targetInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
targetInfo.DatabaseName = targetDb.DatabaseName;
|
|
|
|
CreateAndValidateScmpFile(sourceInfo, targetInfo, true, true);
|
|
}
|
|
finally
|
|
{
|
|
sourceDb.Cleanup();
|
|
targetDb.Cleanup();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Verify the schema compare Scmp File Save for dacpac endpoints
|
|
/// </summary>
|
|
[Test]
|
|
public async Task SchemaCompareSaveScmpFileForDacpacs()
|
|
{
|
|
SqlTestDb sourceDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, SourceScript, "SchemaCompareSource");
|
|
SqlTestDb targetDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, TargetScript, "SchemaCompareTarget");
|
|
|
|
try
|
|
{
|
|
string sourceDacpac = SchemaCompareTestUtils.CreateDacpac(sourceDb);
|
|
string targetDacpac = SchemaCompareTestUtils.CreateDacpac(targetDb);
|
|
string filePath = SchemaCompareTestUtils.CreateScmpPath();
|
|
|
|
SchemaCompareEndpointInfo sourceInfo = new SchemaCompareEndpointInfo();
|
|
SchemaCompareEndpointInfo targetInfo = new SchemaCompareEndpointInfo();
|
|
|
|
sourceInfo.EndpointType = SchemaCompareEndpointType.Dacpac;
|
|
sourceInfo.PackageFilePath = sourceDacpac;
|
|
targetInfo.EndpointType = SchemaCompareEndpointType.Dacpac;
|
|
targetInfo.PackageFilePath = targetDacpac;
|
|
|
|
CreateAndValidateScmpFile(sourceInfo, targetInfo, false, false);
|
|
}
|
|
finally
|
|
{
|
|
sourceDb.Cleanup();
|
|
targetDb.Cleanup();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Verify the schema compare Scmp File Save for dacpac and db endpoints combination
|
|
/// </summary>
|
|
[Test]
|
|
public async Task SchemaCompareSaveScmpFileForDacpacToDB()
|
|
{
|
|
SqlTestDb sourceDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, SourceScript, "SchemaCompareSource");
|
|
SqlTestDb targetDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, TargetScript, "SchemaCompareTarget");
|
|
|
|
try
|
|
{
|
|
string sourceDacpac = SchemaCompareTestUtils.CreateDacpac(sourceDb);
|
|
string filePath = SchemaCompareTestUtils.CreateScmpPath();
|
|
|
|
SchemaCompareEndpointInfo sourceInfo = new SchemaCompareEndpointInfo();
|
|
SchemaCompareEndpointInfo targetInfo = new SchemaCompareEndpointInfo();
|
|
|
|
sourceInfo.EndpointType = SchemaCompareEndpointType.Dacpac;
|
|
sourceInfo.PackageFilePath = sourceDacpac;
|
|
targetInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
targetInfo.DatabaseName = targetDb.DatabaseName;
|
|
|
|
CreateAndValidateScmpFile(sourceInfo, targetInfo, false, true);
|
|
}
|
|
finally
|
|
{
|
|
sourceDb.Cleanup();
|
|
targetDb.Cleanup();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Verify opening an scmp comparing two databases
|
|
/// </summary>
|
|
[Test]
|
|
public async Task SchemaCompareOpenScmpDatabaseToDatabaseRequest()
|
|
{
|
|
await CreateAndOpenScmp(SchemaCompareEndpointType.Database, SchemaCompareEndpointType.Database);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Verify opening an scmp comparing a dacpac and database
|
|
/// </summary>
|
|
[Test]
|
|
public async Task SchemaCompareOpenScmpDacpacToDatabaseRequest()
|
|
{
|
|
await CreateAndOpenScmp(SchemaCompareEndpointType.Dacpac, SchemaCompareEndpointType.Database);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Verify opening an scmp comparing two dacpacs
|
|
/// </summary>
|
|
[Test]
|
|
public async Task SchemaCompareOpenScmpDacpacToDacpacRequest()
|
|
{
|
|
await CreateAndOpenScmp(SchemaCompareEndpointType.Dacpac, SchemaCompareEndpointType.Dacpac);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Verify the schema compare Service Calls ends to end
|
|
/// </summary>
|
|
[Test]
|
|
public async Task VerifySchemaCompareServiceCalls()
|
|
{
|
|
string operationId = Guid.NewGuid().ToString();
|
|
DiffEntry diffEntry = null;
|
|
bool cancelled = false;
|
|
var connectionObject = SchemaCompareTestUtils.GetLiveAutoCompleteTestObjects();
|
|
|
|
SqlTestDb sourceDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, SourceScript, "SchemaCompareSource");
|
|
SqlTestDb targetDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, TargetScript, "SchemaCompareTarget");
|
|
|
|
try
|
|
{
|
|
SchemaCompareEndpointInfo sourceInfo = new SchemaCompareEndpointInfo();
|
|
SchemaCompareEndpointInfo targetInfo = new SchemaCompareEndpointInfo();
|
|
|
|
sourceInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
sourceInfo.DatabaseName = sourceDb.DatabaseName;
|
|
sourceInfo.OwnerUri = connectionObject.ConnectionInfo.OwnerUri;
|
|
targetInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
targetInfo.DatabaseName = targetDb.DatabaseName;
|
|
targetInfo.OwnerUri = connectionObject.ConnectionInfo.OwnerUri;
|
|
TaskService.Instance.TaskManager.Reset();
|
|
|
|
// Schema compare service call
|
|
var schemaCompareRequestContext = new Mock<RequestContext<SchemaCompareResult>>();
|
|
schemaCompareRequestContext.Setup((RequestContext<SchemaCompareResult> x) => x.SendResult(It.Is<SchemaCompareResult>((diffResult) =>
|
|
ValidateScResult(diffResult, out diffEntry, operationId, ref cancelled)))).Returns(Task.FromResult(new object()));
|
|
|
|
var schemaCompareParams = new SchemaCompareParams
|
|
{
|
|
OperationId = operationId,
|
|
SourceEndpointInfo = sourceInfo,
|
|
TargetEndpointInfo = targetInfo,
|
|
DeploymentOptions = new DeploymentOptions()
|
|
};
|
|
|
|
await SchemaCompareService.Instance.HandleSchemaCompareRequest(schemaCompareParams, schemaCompareRequestContext.Object);
|
|
|
|
// Schema compare Cancel call
|
|
var schemaCompareCancelRequestContext = new Mock<RequestContext<ResultStatus>>();
|
|
schemaCompareCancelRequestContext.Setup((RequestContext<ResultStatus> x) => x.SendResult(It.Is<ResultStatus>((result) =>
|
|
result.Success == true))).Returns(Task.FromResult(new object()));
|
|
|
|
var schemaCompareCancelParams = new SchemaCompareCancelParams
|
|
{
|
|
OperationId = operationId
|
|
};
|
|
|
|
cancelled = true;
|
|
await SchemaCompareService.Instance.HandleSchemaCompareCancelRequest(schemaCompareCancelParams, schemaCompareCancelRequestContext.Object);
|
|
await SchemaCompareService.Instance.CurrentSchemaCompareTask;
|
|
|
|
|
|
// complete schema compare call for further testing
|
|
cancelled = false;
|
|
await SchemaCompareService.Instance.HandleSchemaCompareRequest(schemaCompareParams, schemaCompareRequestContext.Object);
|
|
await SchemaCompareService.Instance.CurrentSchemaCompareTask;
|
|
|
|
// Generate script Service call
|
|
var generateScriptRequestContext = new Mock<RequestContext<ResultStatus>>();
|
|
generateScriptRequestContext.Setup((RequestContext<ResultStatus> x) => x.SendResult(It.Is<ResultStatus>((result) => result.Success == true))).Returns(Task.FromResult(new object()));
|
|
|
|
var generateScriptParams = new SchemaCompareGenerateScriptParams
|
|
{
|
|
OperationId = operationId,
|
|
TargetDatabaseName = targetDb.DatabaseName,
|
|
TargetServerName = "My server"
|
|
};
|
|
|
|
await SchemaCompareService.Instance.HandleSchemaCompareGenerateScriptRequest(generateScriptParams, generateScriptRequestContext.Object);
|
|
ValidateTask(SR.GenerateScriptTaskName);
|
|
|
|
// Publish service call
|
|
var publishRequestContext = new Mock<RequestContext<ResultStatus>>();
|
|
publishRequestContext.Setup((RequestContext<ResultStatus> x) => x.SendResult(It.Is<ResultStatus>((result) => result.Success == true))).Returns(Task.FromResult(new object()));
|
|
|
|
|
|
SqlConnectionStringBuilder builder = new SqlConnectionStringBuilder(targetDb.ConnectionString);
|
|
var publishParams = new SchemaComparePublishChangesParams
|
|
{
|
|
OperationId = operationId,
|
|
TargetDatabaseName = targetDb.DatabaseName,
|
|
TargetServerName = builder.DataSource,
|
|
};
|
|
|
|
await SchemaCompareService.Instance.HandleSchemaComparePublishChangesRequest(publishParams, publishRequestContext.Object);
|
|
ValidateTask(SR.PublishChangesTaskName);
|
|
|
|
// Include/Exclude service call
|
|
var excludeRequestContext = new Mock<RequestContext<ResultStatus>>();
|
|
excludeRequestContext.Setup((RequestContext<ResultStatus> x) => x.SendResult(It.Is<ResultStatus>((result) => result.Success == true))).Returns(Task.FromResult(new object()));
|
|
|
|
var excludeParams = new SchemaCompareNodeParams
|
|
{
|
|
OperationId = operationId,
|
|
DiffEntry = diffEntry
|
|
};
|
|
|
|
await SchemaCompareService.Instance.HandleSchemaCompareIncludeExcludeNodeRequest(excludeParams, publishRequestContext.Object);
|
|
|
|
// Save Scmp service call
|
|
var saveScmpRequestContext = new Mock<RequestContext<ResultStatus>>();
|
|
saveScmpRequestContext.Setup((RequestContext<ResultStatus> x) => x.SendResult(It.Is<ResultStatus>((result) => result.Success == true))).Returns(Task.FromResult(new object()));
|
|
var scmpFilePath = SchemaCompareTestUtils.CreateScmpPath();
|
|
|
|
var saveScmpParams = new SchemaCompareSaveScmpParams
|
|
{
|
|
SourceEndpointInfo = sourceInfo,
|
|
TargetEndpointInfo = targetInfo,
|
|
DeploymentOptions = new DeploymentOptions(),
|
|
ScmpFilePath = scmpFilePath
|
|
};
|
|
|
|
await SchemaCompareService.Instance.HandleSchemaCompareSaveScmpRequest(saveScmpParams, saveScmpRequestContext.Object);
|
|
await SchemaCompareService.Instance.CurrentSchemaCompareTask;
|
|
|
|
// Open Scmp service call
|
|
var openScmpRequestContext = new Mock<RequestContext<SchemaCompareOpenScmpResult>>();
|
|
openScmpRequestContext.Setup((RequestContext<SchemaCompareOpenScmpResult> x) => x.SendResult(It.Is<SchemaCompareOpenScmpResult>((result) => ValidateScmpRoundtrip(result, sourceDb.DatabaseName, targetDb.DatabaseName)))).Returns(Task.FromResult(new object()));
|
|
|
|
var openScmpParams = new SchemaCompareOpenScmpParams
|
|
{
|
|
FilePath = scmpFilePath
|
|
};
|
|
|
|
await SchemaCompareService.Instance.HandleSchemaCompareOpenScmpRequest(openScmpParams, openScmpRequestContext.Object);
|
|
await SchemaCompareService.Instance.CurrentSchemaCompareTask;
|
|
SchemaCompareTestUtils.VerifyAndCleanup(scmpFilePath);
|
|
}
|
|
finally
|
|
{
|
|
sourceDb.Cleanup();
|
|
targetDb.Cleanup();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Verify the schema compare cancel
|
|
/// </summary>
|
|
[Test]
|
|
public async Task SchemaCompareCancelCompareOperation()
|
|
{
|
|
var result = SchemaCompareTestUtils.GetLiveAutoCompleteTestObjects();
|
|
SqlTestDb sourceDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, SourceScript, "SchemaCompareSource");
|
|
SqlTestDb targetDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, TargetScript, "SchemaCompareTarget");
|
|
|
|
try
|
|
{
|
|
SchemaCompareEndpointInfo sourceInfo = new SchemaCompareEndpointInfo();
|
|
SchemaCompareEndpointInfo targetInfo = new SchemaCompareEndpointInfo();
|
|
|
|
sourceInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
sourceInfo.DatabaseName = sourceDb.DatabaseName;
|
|
targetInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
targetInfo.DatabaseName = targetDb.DatabaseName;
|
|
|
|
var schemaCompareParams = new SchemaCompareParams
|
|
{
|
|
SourceEndpointInfo = sourceInfo,
|
|
TargetEndpointInfo = targetInfo
|
|
};
|
|
|
|
SchemaCompareOperation schemaCompareOperation = new SchemaCompareOperation(schemaCompareParams, result.ConnectionInfo, result.ConnectionInfo);
|
|
schemaCompareOperation.schemaCompareStarted += (sender, e) => { schemaCompareOperation.Cancel(); };
|
|
|
|
try
|
|
{
|
|
Task cTask = Task.Factory.StartNew(() => schemaCompareOperation.Execute(TaskExecutionMode.Execute));
|
|
cTask.Wait();
|
|
Assert.False(cTask.IsCompletedSuccessfully, "schema compare task should not complete after cancel");
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Assert.NotNull(ex.InnerException);
|
|
Assert.True(ex.InnerException is OperationCanceledException, $"Exception is expected to be Operation cancelled but actually is {ex.InnerException}");
|
|
}
|
|
|
|
Assert.Null(schemaCompareOperation.ComparisonResult.Differences);
|
|
}
|
|
finally
|
|
{
|
|
sourceDb.Cleanup();
|
|
targetDb.Cleanup();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// test to verify recent dacfx bugs
|
|
/// does not need all combinations of db and dacpacs
|
|
/// </summary>
|
|
//[Test] disabling the failing test is failing now.
|
|
public async Task SchemaCompareCEKAndFilegoupTest()
|
|
{
|
|
var result = SchemaCompareTestUtils.GetLiveAutoCompleteTestObjects();
|
|
SqlTestDb sourceDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, CreateKey, "SchemaCompareSource");
|
|
sourceDb.RunQuery(string.Format(CreateFileGroup, sourceDb.DatabaseName));
|
|
SqlTestDb targetDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, TargetScript, "SchemaCompareTarget");
|
|
|
|
try
|
|
{
|
|
SchemaCompareEndpointInfo sourceInfo = new SchemaCompareEndpointInfo();
|
|
SchemaCompareEndpointInfo targetInfo = new SchemaCompareEndpointInfo();
|
|
|
|
sourceInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
sourceInfo.DatabaseName = sourceDb.DatabaseName;
|
|
targetInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
targetInfo.DatabaseName = targetDb.DatabaseName;
|
|
DeploymentOptions options = new DeploymentOptions();
|
|
|
|
// ensure that files are excluded seperate from filegroups
|
|
Assert.True(options.ExcludeObjectTypes.Contains(SqlServer.Dac.ObjectType.Files));
|
|
Assert.False(options.ExcludeObjectTypes.Contains(SqlServer.Dac.ObjectType.Filegroups));
|
|
|
|
var schemaCompareParams = new SchemaCompareParams
|
|
{
|
|
SourceEndpointInfo = sourceInfo,
|
|
TargetEndpointInfo = targetInfo,
|
|
DeploymentOptions = options
|
|
};
|
|
|
|
SchemaCompareOperation schemaCompareOperation = new SchemaCompareOperation(schemaCompareParams, result.ConnectionInfo, result.ConnectionInfo);
|
|
schemaCompareOperation.Execute(TaskExecutionMode.Execute);
|
|
|
|
Assert.True(schemaCompareOperation.ComparisonResult.IsValid);
|
|
Assert.False(schemaCompareOperation.ComparisonResult.IsEqual);
|
|
Assert.NotNull(schemaCompareOperation.ComparisonResult.Differences);
|
|
|
|
// validate CEK script
|
|
var cek = schemaCompareOperation.ComparisonResult.Differences.First(x => x.Name == "SqlColumnEncryptionKey");
|
|
Assert.NotNull(cek);
|
|
Assert.True(cek.SourceObject != null, "CEK obect is null");
|
|
Assert.True(cek.SourceObject.Name.ToString() == "[CEK_Auto1]", string.Format("CEK object name incorrect. Expected {0}, Actual {1}", "CEK_Auto1", cek.SourceObject.Name.ToString()));
|
|
Assert.True(CreateKey.Contains(cek.SourceObject.GetScript().Trim()), string.Format("Expected script : {0}, Actual Script {1}", cek.SourceObject.GetScript(), CreateKey));
|
|
|
|
// validate CMK script
|
|
var cmk = schemaCompareOperation.ComparisonResult.Differences.First(x => x.Name == "SqlColumnMasterKey");
|
|
Assert.NotNull(cmk);
|
|
Assert.True(cmk.SourceObject != null, "CMK obect is null");
|
|
Assert.True(cmk.SourceObject.Name.ToString() == "[CMK_Auto1]", string.Format("CMK object name incorrect. Expected {0}, Actual {1}", "CEK_Auto1", cmk.SourceObject.Name.ToString()));
|
|
Assert.True(CreateKey.Contains(cmk.SourceObject.GetScript().Trim()), string.Format("Expected script : {0}, Actual Script {1}", cmk.SourceObject.GetScript(), CreateKey));
|
|
|
|
// validate filegroup's presence
|
|
var filegroup = schemaCompareOperation.ComparisonResult.Differences.First(x => x.Name == "SqlFilegroup");
|
|
Assert.NotNull(filegroup);
|
|
Assert.True(filegroup.SourceObject != null, "File group obect is null");
|
|
|
|
// validate file's absense
|
|
bool filepresent = schemaCompareOperation.ComparisonResult.Differences.Any(x => x.Name == "SqlFile");
|
|
Assert.False(filepresent, "SqlFile should not be present");
|
|
var objectsWithFileInName = schemaCompareOperation.ComparisonResult.Differences.Where(x => x.Name.Contains("File"));
|
|
Assert.True(1 == objectsWithFileInName.Count(), string.Format("Only one File/Filegroup object was to be found, but found {0}", objectsWithFileInName.Count()));
|
|
}
|
|
finally
|
|
{
|
|
// cleanup
|
|
sourceDb.Cleanup();
|
|
targetDb.Cleanup();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Verify the schema compare request with failing exclude request because of dependencies and that include will include dependencies
|
|
/// </summary>
|
|
[Test]
|
|
public async Task SchemaCompareIncludeExcludeWithDependencies()
|
|
{
|
|
var result = SchemaCompareTestUtils.GetLiveAutoCompleteTestObjects();
|
|
SqlTestDb sourceDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, SourceIncludeExcludeScript, "SchemaCompareSource");
|
|
SqlTestDb targetDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, TargetIncludeExcludeScript, "SchemaCompareTarget");
|
|
|
|
try
|
|
{
|
|
string targetDacpacFilePath = SchemaCompareTestUtils.CreateDacpac(targetDb);
|
|
|
|
SchemaCompareEndpointInfo sourceInfo = new SchemaCompareEndpointInfo();
|
|
SchemaCompareEndpointInfo targetInfo = new SchemaCompareEndpointInfo();
|
|
|
|
sourceInfo.EndpointType = SchemaCompareEndpointType.Database;
|
|
sourceInfo.DatabaseName = sourceDb.DatabaseName;
|
|
targetInfo.EndpointType = SchemaCompareEndpointType.Dacpac;
|
|
targetInfo.PackageFilePath = targetDacpacFilePath;
|
|
|
|
var schemaCompareParams = new SchemaCompareParams
|
|
{
|
|
SourceEndpointInfo = sourceInfo,
|
|
TargetEndpointInfo = targetInfo
|
|
};
|
|
|
|
SchemaCompareOperation schemaCompareOperation = new SchemaCompareOperation(schemaCompareParams, result.ConnectionInfo, null);
|
|
schemaCompareOperation.Execute(TaskExecutionMode.Execute);
|
|
Assert.True(schemaCompareOperation.ComparisonResult.IsValid);
|
|
Assert.False(schemaCompareOperation.ComparisonResult.IsEqual);
|
|
Assert.NotNull(schemaCompareOperation.ComparisonResult.Differences);
|
|
|
|
// try to exclude
|
|
DiffEntry t2Diff = SchemaCompareUtils.CreateDiffEntry(schemaCompareOperation.ComparisonResult.Differences.Where(x => x.SourceObject != null && x.SourceObject.Name.Parts[1] == "t2").First(), null);
|
|
SchemaCompareNodeParams t2ExcludeParams = new SchemaCompareNodeParams()
|
|
{
|
|
OperationId = schemaCompareOperation.OperationId,
|
|
DiffEntry = t2Diff,
|
|
IncludeRequest = false,
|
|
TaskExecutionMode = TaskExecutionMode.Execute
|
|
};
|
|
|
|
SchemaCompareIncludeExcludeNodeOperation t2ExcludeOperation = new SchemaCompareIncludeExcludeNodeOperation(t2ExcludeParams, schemaCompareOperation.ComparisonResult);
|
|
t2ExcludeOperation.Execute(TaskExecutionMode.Execute);
|
|
Assert.False(t2ExcludeOperation.Success, "Excluding Table t2 should fail because view v1 depends on it");
|
|
Assert.True(t2ExcludeOperation.ComparisonResult.Differences.Where(x => x.SourceObject != null && x.SourceObject.Name.Parts[1] == "t2").First().Included, "Difference Table t2 should still be included because the exclude request failed");
|
|
Assert.True(t2ExcludeOperation.BlockingDependencies.Count == 1, "There should be one dependency");
|
|
Assert.True(t2ExcludeOperation.BlockingDependencies[0].SourceValue[1] == "v1", "Dependency should be View v1");
|
|
|
|
// exclude view v1, then t2 should also get excluded by this
|
|
DiffEntry v1Diff = SchemaCompareUtils.CreateDiffEntry(schemaCompareOperation.ComparisonResult.Differences.Where(x => x.SourceObject != null && x.SourceObject.Name.Parts[1] == "v1").First(), null);
|
|
SchemaCompareNodeParams v1ExcludeParams = new SchemaCompareNodeParams()
|
|
{
|
|
OperationId = schemaCompareOperation.OperationId,
|
|
DiffEntry = v1Diff,
|
|
IncludeRequest = false,
|
|
TaskExecutionMode = TaskExecutionMode.Execute
|
|
};
|
|
|
|
SchemaCompareIncludeExcludeNodeOperation v1ExcludeOperation = new SchemaCompareIncludeExcludeNodeOperation(v1ExcludeParams, schemaCompareOperation.ComparisonResult);
|
|
v1ExcludeOperation.Execute(TaskExecutionMode.Execute);
|
|
Assert.True(v1ExcludeOperation.Success, "Excluding View v1 should succeed");
|
|
Assert.False(v1ExcludeOperation.ComparisonResult.Differences.Where(x => x.SourceObject != null && x.SourceObject.Name.Parts[1] == "v1").First().Included, "Difference View v1 should be excluded");
|
|
Assert.False(v1ExcludeOperation.ComparisonResult.Differences.Where(x => x.SourceObject != null && x.SourceObject.Name.Parts[1] == "t2").First().Included, "Difference Table t2 should be excluded");
|
|
Assert.True(v1ExcludeOperation.AffectedDependencies.Count == 1, "There should be one dependency");
|
|
Assert.False(v1ExcludeOperation.AffectedDependencies[0].Included, "The dependency Table t2 should be excluded");
|
|
|
|
// including v1 should also include t2
|
|
SchemaCompareNodeParams v1IncludeParams = new SchemaCompareNodeParams()
|
|
{
|
|
OperationId = schemaCompareOperation.OperationId,
|
|
DiffEntry = v1Diff,
|
|
IncludeRequest = true,
|
|
TaskExecutionMode = TaskExecutionMode.Execute
|
|
};
|
|
|
|
SchemaCompareIncludeExcludeNodeOperation v1IncludeOperation = new SchemaCompareIncludeExcludeNodeOperation(v1IncludeParams, t2ExcludeOperation.ComparisonResult);
|
|
v1IncludeOperation.Execute(TaskExecutionMode.Execute);
|
|
Assert.True(v1IncludeOperation.Success, "Including v1 should succeed");
|
|
Assert.True(v1IncludeOperation.ComparisonResult.Differences.Where(x => x.SourceObject != null && x.SourceObject.Name.Parts[1] == "v1").First().Included, "Difference View v1 should be included");
|
|
Assert.True(v1IncludeOperation.ComparisonResult.Differences.Where(x => x.SourceObject != null && x.SourceObject.Name.Parts[1] == "t2").First().Included, "Difference Table t2 should still be included");
|
|
Assert.True(v1IncludeOperation.AffectedDependencies != null && v1IncludeOperation.AffectedDependencies.Count == 1, "There should be one difference");
|
|
Assert.True(v1IncludeOperation.AffectedDependencies.First().SourceValue[1] == "t2", "The affected difference of including v1 should be t2");
|
|
|
|
// cleanup
|
|
SchemaCompareTestUtils.VerifyAndCleanup(targetDacpacFilePath);
|
|
}
|
|
finally
|
|
{
|
|
sourceDb.Cleanup();
|
|
targetDb.Cleanup();
|
|
}
|
|
}
|
|
|
|
private void ValidateSchemaCompareWithExcludeIncludeResults(SchemaCompareOperation schemaCompareOperation)
|
|
{
|
|
schemaCompareOperation.Execute(TaskExecutionMode.Execute);
|
|
|
|
Assert.True(schemaCompareOperation.ComparisonResult.IsValid);
|
|
Assert.False(schemaCompareOperation.ComparisonResult.IsEqual);
|
|
Assert.NotNull(schemaCompareOperation.ComparisonResult.Differences);
|
|
|
|
// create Diff Entry from Difference
|
|
DiffEntry diff = SchemaCompareUtils.CreateDiffEntry(schemaCompareOperation.ComparisonResult.Differences.First(), null);
|
|
|
|
int initial = schemaCompareOperation.ComparisonResult.Differences.Count();
|
|
SchemaCompareNodeParams schemaCompareExcludeNodeParams = new SchemaCompareNodeParams()
|
|
{
|
|
OperationId = schemaCompareOperation.OperationId,
|
|
DiffEntry = diff,
|
|
IncludeRequest = false,
|
|
TaskExecutionMode = TaskExecutionMode.Execute
|
|
};
|
|
SchemaCompareIncludeExcludeNodeOperation nodeExcludeOperation = new SchemaCompareIncludeExcludeNodeOperation(schemaCompareExcludeNodeParams, schemaCompareOperation.ComparisonResult);
|
|
nodeExcludeOperation.Execute(TaskExecutionMode.Execute);
|
|
|
|
int afterExclude = schemaCompareOperation.ComparisonResult.Differences.Count();
|
|
|
|
Assert.True(initial == afterExclude, $"Changes should be same again after excluding/including, before {initial}, now {afterExclude}");
|
|
|
|
SchemaCompareNodeParams schemaCompareincludeNodeParams = new SchemaCompareNodeParams()
|
|
{
|
|
OperationId = schemaCompareOperation.OperationId,
|
|
DiffEntry = diff,
|
|
IncludeRequest = true,
|
|
TaskExecutionMode = TaskExecutionMode.Execute
|
|
};
|
|
|
|
SchemaCompareIncludeExcludeNodeOperation nodeIncludeOperation = new SchemaCompareIncludeExcludeNodeOperation(schemaCompareincludeNodeParams, schemaCompareOperation.ComparisonResult);
|
|
nodeIncludeOperation.Execute(TaskExecutionMode.Execute);
|
|
int afterInclude = schemaCompareOperation.ComparisonResult.Differences.Count();
|
|
|
|
|
|
Assert.True(initial == afterInclude, $"Changes should be same again after excluding/including, before:{initial}, now {afterInclude}");
|
|
}
|
|
|
|
private void ValidateSchemaCompareScriptGenerationWithExcludeIncludeResults(SchemaCompareOperation schemaCompareOperation, SchemaCompareGenerateScriptParams generateScriptParams)
|
|
{
|
|
schemaCompareOperation.Execute(TaskExecutionMode.Execute);
|
|
|
|
Assert.True(schemaCompareOperation.ComparisonResult.IsValid);
|
|
Assert.False(schemaCompareOperation.ComparisonResult.IsEqual);
|
|
Assert.NotNull(schemaCompareOperation.ComparisonResult.Differences);
|
|
|
|
SchemaCompareGenerateScriptOperation generateScriptOperation = new SchemaCompareGenerateScriptOperation(generateScriptParams, schemaCompareOperation.ComparisonResult);
|
|
generateScriptOperation.Execute(TaskExecutionMode.Script);
|
|
|
|
Assert.True(generateScriptOperation.ScriptGenerationResult.Success);
|
|
string initialScript = generateScriptOperation.ScriptGenerationResult.Script;
|
|
|
|
// create Diff Entry from on Difference
|
|
DiffEntry diff = SchemaCompareUtils.CreateDiffEntry(schemaCompareOperation.ComparisonResult.Differences.First(), null);
|
|
|
|
//Validate Diff Entry creation for object type
|
|
ValidateDiffEntryCreation(diff, schemaCompareOperation.ComparisonResult.Differences.First());
|
|
|
|
int initial = schemaCompareOperation.ComparisonResult.Differences.Count();
|
|
SchemaCompareNodeParams schemaCompareExcludeNodeParams = new SchemaCompareNodeParams()
|
|
{
|
|
OperationId = schemaCompareOperation.OperationId,
|
|
DiffEntry = diff,
|
|
IncludeRequest = false,
|
|
TaskExecutionMode = TaskExecutionMode.Execute
|
|
};
|
|
SchemaCompareIncludeExcludeNodeOperation nodeExcludeOperation = new SchemaCompareIncludeExcludeNodeOperation(schemaCompareExcludeNodeParams, schemaCompareOperation.ComparisonResult);
|
|
nodeExcludeOperation.Execute(TaskExecutionMode.Execute);
|
|
|
|
int afterExclude = schemaCompareOperation.ComparisonResult.Differences.Count();
|
|
|
|
Assert.True(initial == afterExclude, $"Changes should be same again after excluding/including, before {initial}, now {afterExclude}");
|
|
|
|
generateScriptOperation = new SchemaCompareGenerateScriptOperation(generateScriptParams, schemaCompareOperation.ComparisonResult);
|
|
generateScriptOperation.Execute(TaskExecutionMode.Script);
|
|
|
|
Assert.True(generateScriptOperation.ScriptGenerationResult.Success);
|
|
string afterExcludeScript = generateScriptOperation.ScriptGenerationResult.Script;
|
|
Assert.True(initialScript.Length > afterExcludeScript.Length, $"Script should be affected (less statements) exclude operation, before {initialScript}, now {afterExcludeScript}");
|
|
|
|
SchemaCompareNodeParams schemaCompareincludeNodeParams = new SchemaCompareNodeParams()
|
|
{
|
|
OperationId = schemaCompareOperation.OperationId,
|
|
DiffEntry = diff,
|
|
IncludeRequest = true,
|
|
TaskExecutionMode = TaskExecutionMode.Execute
|
|
};
|
|
|
|
SchemaCompareIncludeExcludeNodeOperation nodeIncludeOperation = new SchemaCompareIncludeExcludeNodeOperation(schemaCompareincludeNodeParams, schemaCompareOperation.ComparisonResult);
|
|
nodeIncludeOperation.Execute(TaskExecutionMode.Execute);
|
|
int afterInclude = schemaCompareOperation.ComparisonResult.Differences.Count();
|
|
|
|
Assert.True(initial == afterInclude, $"Changes should be same again after excluding/including:{initial}, now {afterInclude}");
|
|
|
|
generateScriptOperation = new SchemaCompareGenerateScriptOperation(generateScriptParams, schemaCompareOperation.ComparisonResult);
|
|
generateScriptOperation.Execute(TaskExecutionMode.Script);
|
|
|
|
Assert.True(generateScriptOperation.ScriptGenerationResult.Success);
|
|
string afterIncludeScript = generateScriptOperation.ScriptGenerationResult.Script;
|
|
Assert.True(initialScript.Length == afterIncludeScript.Length, $"Changes should be same as inital since we included what we excluded, before {initialScript}, now {afterIncludeScript}");
|
|
}
|
|
|
|
private async Task CreateAndOpenScmp(SchemaCompareEndpointType sourceEndpointType, SchemaCompareEndpointType targetEndpointType)
|
|
{
|
|
SqlTestDb sourceDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, SourceScript, "SchemaCompareOpenScmpSource");
|
|
SqlTestDb targetDb = await SqlTestDb.CreateNewAsync(TestServerType.OnPrem, false, null, TargetScript, "SchemaCompareOpenScmpTarget");
|
|
|
|
try
|
|
{
|
|
SchemaCompareEndpoint sourceEndpoint = CreateSchemaCompareEndpoint(sourceDb, sourceEndpointType);
|
|
SchemaCompareEndpoint targetEndpoint = CreateSchemaCompareEndpoint(targetDb, targetEndpointType);
|
|
|
|
// create a comparison and exclude the first difference
|
|
SchemaComparison compare = new SchemaComparison(sourceEndpoint, targetEndpoint);
|
|
SchemaComparisonResult result = compare.Compare();
|
|
Assert.That(result.Differences, Is.Not.Empty);
|
|
SchemaDifference difference = result.Differences.First();
|
|
if (difference.SourceObject != null)
|
|
{
|
|
compare.ExcludedSourceObjects.Add(new SchemaComparisonExcludedObjectId(difference.SourceObject.ObjectType, difference.SourceObject.Name));
|
|
}
|
|
else
|
|
{
|
|
compare.ExcludedSourceObjects.Add(new SchemaComparisonExcludedObjectId(difference.TargetObject.ObjectType, difference.TargetObject.Name));
|
|
}
|
|
|
|
// save to scmp
|
|
string folderPath = Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.LocalApplicationData), "SchemaCompareTest");
|
|
Directory.CreateDirectory(folderPath);
|
|
string filePath = Path.Combine(folderPath, string.Format("SchemaCompareOpenScmpTest{0}.scmp", DateTime.Now.ToFileTime()));
|
|
compare.SaveToFile(filePath);
|
|
Assert.True(File.Exists(filePath));
|
|
|
|
var schemaCompareOpenScmpParams = new SchemaCompareOpenScmpParams
|
|
{
|
|
FilePath = filePath
|
|
};
|
|
|
|
SchemaCompareOpenScmpOperation schemaCompareOpenScmpOperation = new SchemaCompareOpenScmpOperation(schemaCompareOpenScmpParams);
|
|
schemaCompareOpenScmpOperation.Execute(TaskExecutionMode.Execute);
|
|
|
|
Assert.NotNull(schemaCompareOpenScmpOperation.Result);
|
|
Assert.True(schemaCompareOpenScmpOperation.Result.Success);
|
|
Assert.That(schemaCompareOpenScmpOperation.Result.ExcludedSourceElements, Is.Not.Empty);
|
|
Assert.AreEqual(1, schemaCompareOpenScmpOperation.Result.ExcludedSourceElements.Count());
|
|
Assert.That(schemaCompareOpenScmpOperation.Result.ExcludedTargetElements, Is.Empty);
|
|
Assert.AreEqual(targetDb.DatabaseName, schemaCompareOpenScmpOperation.Result.OriginalTargetName);
|
|
ValidateResultEndpointInfo(sourceEndpoint, schemaCompareOpenScmpOperation.Result.SourceEndpointInfo, sourceDb.ConnectionString);
|
|
ValidateResultEndpointInfo(targetEndpoint, schemaCompareOpenScmpOperation.Result.TargetEndpointInfo, targetDb.ConnectionString);
|
|
|
|
SchemaCompareTestUtils.VerifyAndCleanup(filePath);
|
|
}
|
|
finally
|
|
{
|
|
sourceDb.Cleanup();
|
|
targetDb.Cleanup();
|
|
}
|
|
}
|
|
|
|
private SchemaCompareEndpoint CreateSchemaCompareEndpoint(SqlTestDb db, SchemaCompareEndpointType endpointType)
|
|
{
|
|
if (endpointType == SchemaCompareEndpointType.Dacpac)
|
|
{
|
|
string dacpacFilePath = SchemaCompareTestUtils.CreateDacpac(db);
|
|
return new SchemaCompareDacpacEndpoint(dacpacFilePath);
|
|
}
|
|
else
|
|
{
|
|
return new SchemaCompareDatabaseEndpoint(db.ConnectionString);
|
|
}
|
|
}
|
|
|
|
private void ValidateResultEndpointInfo(SchemaCompareEndpoint originalEndpoint, SchemaCompareEndpointInfo resultEndpoint, string connectionString)
|
|
{
|
|
if (resultEndpoint.EndpointType == SchemaCompareEndpointType.Dacpac)
|
|
{
|
|
SchemaCompareDacpacEndpoint dacpacEndpoint = originalEndpoint as SchemaCompareDacpacEndpoint;
|
|
Assert.AreEqual(dacpacEndpoint.FilePath, resultEndpoint.PackageFilePath);
|
|
}
|
|
else
|
|
{
|
|
SchemaCompareDatabaseEndpoint databaseEndpoint = originalEndpoint as SchemaCompareDatabaseEndpoint;
|
|
Assert.AreEqual(databaseEndpoint.DatabaseName, resultEndpoint.DatabaseName);
|
|
Assert.That(connectionString, Does.Contain(resultEndpoint.ConnectionDetails.ConnectionString), "connectionString has password but resultEndpoint doesn't");
|
|
}
|
|
}
|
|
|
|
private void ValidateDiffEntryCreation(DiffEntry diff, SchemaDifference schemaDifference)
|
|
{
|
|
if (schemaDifference.SourceObject != null)
|
|
{
|
|
ValidateDiffEntryObjects(diff.SourceValue, diff.SourceObjectType, schemaDifference.SourceObject);
|
|
}
|
|
if (schemaDifference.TargetObject != null)
|
|
{
|
|
ValidateDiffEntryObjects(diff.TargetValue, diff.TargetObjectType, schemaDifference.TargetObject);
|
|
}
|
|
}
|
|
|
|
private void ValidateDiffEntryObjects(string[] diffObjectName, string diffObjectTypeType, TSqlObject dacfxObject)
|
|
{
|
|
Assert.AreEqual(dacfxObject.Name.Parts.Count, diffObjectName.Length);
|
|
for (int i = 0; i < diffObjectName.Length; i++)
|
|
{
|
|
Assert.AreEqual(dacfxObject.Name.Parts[i], diffObjectName[i]);
|
|
}
|
|
|
|
var dacFxExcludedObject = new SchemaComparisonExcludedObjectId(dacfxObject.ObjectType, dacfxObject.Name);
|
|
var excludedObject = new SchemaComparisonExcludedObjectId(diffObjectTypeType, new ObjectIdentifier(diffObjectName));
|
|
|
|
Assert.AreEqual(dacFxExcludedObject.Identifier.ToString(), excludedObject.Identifier.ToString());
|
|
Assert.AreEqual(dacFxExcludedObject.TypeName, excludedObject.TypeName);
|
|
|
|
string dacFxType = dacFxExcludedObject.TypeName;
|
|
Assert.AreEqual(dacFxType, diffObjectTypeType);
|
|
}
|
|
|
|
private void CreateAndValidateScmpFile(SchemaCompareEndpointInfo sourceInfo, SchemaCompareEndpointInfo targetInfo, bool isSourceDb, bool isTargetDb)
|
|
{
|
|
string filePath = SchemaCompareTestUtils.CreateScmpPath();
|
|
var result = SchemaCompareTestUtils.GetLiveAutoCompleteTestObjects();
|
|
|
|
SchemaCompareObjectId[] schemaCompareObjectIds = new SchemaCompareObjectId[]{
|
|
new SchemaCompareObjectId()
|
|
{
|
|
NameParts = new string[] {"dbo", "Table1" },
|
|
SqlObjectType = "Microsoft.Data.Tools.Schema.Sql.SchemaModel.SqlTable",
|
|
}
|
|
};
|
|
|
|
var schemaCompareParams = new SchemaCompareSaveScmpParams
|
|
{
|
|
SourceEndpointInfo = sourceInfo,
|
|
TargetEndpointInfo = targetInfo,
|
|
DeploymentOptions = new DeploymentOptions()
|
|
{
|
|
// change some random ones explicitly
|
|
AllowDropBlockingAssemblies = true,
|
|
DropConstraintsNotInSource = true,
|
|
IgnoreAnsiNulls = true,
|
|
NoAlterStatementsToChangeClrTypes = false,
|
|
PopulateFilesOnFileGroups = false,
|
|
VerifyDeployment = false,
|
|
},
|
|
ScmpFilePath = filePath,
|
|
ExcludedSourceObjects = schemaCompareObjectIds,
|
|
ExcludedTargetObjects = null,
|
|
};
|
|
|
|
SchemaCompareSaveScmpOperation schemaCompareOperation = new SchemaCompareSaveScmpOperation(schemaCompareParams, result.ConnectionInfo, result.ConnectionInfo);
|
|
schemaCompareOperation.Execute(TaskExecutionMode.Execute);
|
|
|
|
Assert.True(File.Exists(filePath), "SCMP file should be present");
|
|
|
|
string text = File.ReadAllText(filePath);
|
|
Assert.True(!string.IsNullOrEmpty(text), "SCMP File should not be empty");
|
|
|
|
// Validate with DacFx SchemaComparison object
|
|
SchemaComparison sc = new SchemaComparison(filePath);
|
|
|
|
if (isSourceDb)
|
|
{
|
|
Assert.True(sc.Source is SchemaCompareDatabaseEndpoint, "Source should be SchemaCompareDatabaseEndpoint");
|
|
Assert.True((sc.Source as SchemaCompareDatabaseEndpoint).DatabaseName == sourceInfo.DatabaseName, $"Source Database {(sc.Source as SchemaCompareDatabaseEndpoint).DatabaseName} name does not match the params passed {sourceInfo.DatabaseName}");
|
|
}
|
|
else
|
|
{
|
|
Assert.True(sc.Source is SchemaCompareDacpacEndpoint, "Source should be SchemaCompareDacpacEndpoint");
|
|
Assert.True((sc.Source as SchemaCompareDacpacEndpoint).FilePath == sourceInfo.PackageFilePath, $"Source dacpac {(sc.Source as SchemaCompareDacpacEndpoint).FilePath} name does not match the params passed {sourceInfo.PackageFilePath}");
|
|
SchemaCompareTestUtils.VerifyAndCleanup(sourceInfo.PackageFilePath);
|
|
}
|
|
|
|
if (isTargetDb)
|
|
{
|
|
Assert.True(sc.Target is SchemaCompareDatabaseEndpoint, "Source should be SchemaCompareDatabaseEndpoint");
|
|
Assert.True((sc.Target as SchemaCompareDatabaseEndpoint).DatabaseName == targetInfo.DatabaseName, $"Source Database {(sc.Target as SchemaCompareDatabaseEndpoint).DatabaseName} name does not match the params passed {targetInfo.DatabaseName}");
|
|
}
|
|
else
|
|
{
|
|
Assert.True(sc.Target is SchemaCompareDacpacEndpoint, "Source should be SchemaCompareDacpacEndpoint");
|
|
Assert.True((sc.Target as SchemaCompareDacpacEndpoint).FilePath == targetInfo.PackageFilePath, $"Source dacpac {(sc.Target as SchemaCompareDacpacEndpoint).FilePath} name does not match the params passed {targetInfo.PackageFilePath}");
|
|
SchemaCompareTestUtils.VerifyAndCleanup(targetInfo.PackageFilePath);
|
|
}
|
|
|
|
Assert.True(!sc.ExcludedTargetObjects.Any(), "Target Excluded Objects are expected to be Empty");
|
|
Assert.True(sc.ExcludedSourceObjects.Count == 1, $"Exactly {1} Source Excluded Object Should be present but {sc.ExcludedSourceObjects.Count} found");
|
|
SchemaCompareTestUtils.CompareOptions(schemaCompareParams.DeploymentOptions, sc.Options);
|
|
SchemaCompareTestUtils.VerifyAndCleanup(filePath);
|
|
}
|
|
|
|
private bool ValidateScResult(SchemaCompareResult diffResult, out DiffEntry diffEntry, string operationId, ref bool cancelled)
|
|
{
|
|
if (cancelled)
|
|
{
|
|
Assert.True(diffResult.Differences == null, "Differences should be null after cancel");
|
|
Assert.True(diffResult.Success == false, "Result success for schema compare should be false after cancel");
|
|
diffEntry = null;
|
|
return true;
|
|
}
|
|
|
|
diffEntry = diffResult.Differences.ElementAt(0);
|
|
Assert.True(diffResult.Success == true, "Result success is false for schema compare");
|
|
Assert.True(diffResult.Differences != null, "Schema compare Differences should not be null");
|
|
Assert.True(diffResult.Differences.Count > 0, "Schema compare difference count should be greater than 0");
|
|
Assert.True(diffResult.OperationId == operationId, $"Expected Operation id {operationId}. Actual {diffResult.OperationId}");
|
|
return true;
|
|
}
|
|
|
|
private bool ValidateScmpRoundtrip(SchemaCompareOpenScmpResult result, string sourceName, string targetName)
|
|
{
|
|
Assert.True(true == result.Success, "Result Success is false");
|
|
Assert.True(SchemaCompareEndpointType.Database == result.SourceEndpointInfo.EndpointType, $"Source Endpoint type does not match. Expected {SchemaCompareEndpointType.Database}. Actual {result.SourceEndpointInfo.EndpointType}");
|
|
Assert.True(SchemaCompareEndpointType.Database == result.TargetEndpointInfo.EndpointType, $"Target Endpoint type does not match. Expected {SchemaCompareEndpointType.Database}. Actual {result.TargetEndpointInfo.EndpointType}");
|
|
Assert.True(sourceName == result.SourceEndpointInfo.DatabaseName, $"Source Endpoint name does not match. Expected {sourceName}, Actual {result.SourceEndpointInfo.DatabaseName}");
|
|
Assert.True(targetName == result.TargetEndpointInfo.DatabaseName, $"Source Endpoint name does not match. Expected {targetName}, Actual {result.TargetEndpointInfo.DatabaseName}");
|
|
return true;
|
|
}
|
|
|
|
private void ValidateTask(string expectedTaskName)
|
|
{
|
|
// upped the retry count to 20 so tests pass against remote servers more readily
|
|
int retry = 20;
|
|
Assert.True(TaskService.Instance.TaskManager.Tasks.Count == 1, $"Expected 1 task but found {TaskService.Instance.TaskManager.Tasks.Count} tasks");
|
|
while (TaskService.Instance.TaskManager.Tasks.Any() && retry > 0)
|
|
{
|
|
if (!TaskService.Instance.TaskManager.HasCompletedTasks())
|
|
{
|
|
System.Threading.Thread.Sleep(2000);
|
|
}
|
|
else
|
|
{
|
|
foreach (SqlTask sqlTask in TaskService.Instance.TaskManager.Tasks)
|
|
{
|
|
if (sqlTask.IsCompleted)
|
|
{
|
|
Assert.True(sqlTask.TaskStatus == SqlTaskStatus.Succeeded, $"Task {sqlTask.TaskMetadata.Name} expected to succeed but failed with {sqlTask.TaskStatus.ToString()}");
|
|
Assert.True(sqlTask.TaskMetadata.Name.Equals(expectedTaskName), $"Unexpected Schema compare task name. Expected : {expectedTaskName}, Actual : {sqlTask.TaskMetadata.Name}");
|
|
TaskService.Instance.TaskManager.RemoveCompletedTask(sqlTask);
|
|
}
|
|
}
|
|
}
|
|
retry--;
|
|
}
|
|
Assert.False(TaskService.Instance.TaskManager.Tasks.Any(), $"No tasks were expected to exist but had {TaskService.Instance.TaskManager.Tasks.Count} [{string.Join(",", TaskService.Instance.TaskManager.Tasks.Select(t => t.TaskId))}]");
|
|
Console.WriteLine($"ValidateTask{expectedTaskName} completed at retry = {retry}");
|
|
TaskService.Instance.TaskManager.Reset();
|
|
}
|
|
}
|
|
}
|