ckaczor/azuredatastudio
1
0
Fork 0
mirror of https://github.com/ckaczor/azuredatastudio.git synced 2026-01-13 17:22:15 -05:00
Code Issues Packages Projects Releases Wiki Activity

Revalidate failed IR Validation steps (#24237)

Browse Source
This commit is contained in:
Ram Uday Kumar
2023-09-01 10:34:36 +05:30
committed by GitHub
parent f8cd52f70a
commit 6556eaa1ed
4 changed files with 109 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
extensions/sql-migration/images/redo.svg Normal file
View File

@@ -0,0 +1,3 @@
<svg width="16" height="16" viewBox="0 0 16 16" fill="none" xmlns="http://www.w3.org/2000/svg">
<path d="M9,4.05h3.3l-1.1-1.1a4.811,4.811,0,0,0-1.1-.9A4.079,4.079,0,0,0,9,1.35a4,4,0,0,0-1.5-.3,3.909,3.909,0,0,0-1.8.4,3.3,3.3,0,0,0-1.4,1,3.4,3.4,0,0,0-.9,1.4A3.293,3.293,0,0,0,3,5.55a5.105,5.105,0,0,0,.3,1.7,7.082,7.082,0,0,0,1,1.4l6.5,6.5-.7.8L3.6,9.35a6.617,6.617,0,0,1-1.2-1.7A5.2,5.2,0,0,1,2,5.55a5.863,5.863,0,0,1,.2-1.4,3.1,3.1,0,0,1,.6-1.3,4.986,4.986,0,0,1,.8-1.2L4.7.85A7.5,7.5,0,0,1,6,.25L7.5.05l1.2.2a1.907,1.907,0,0,1,1,.3l.9.5.8.7.7.7.9.9V.05h1v5H9Z" fill="#0078D4"/>
</svg>
Side by Side

After

Width:  |  Height:  |  Size: 590 B

5
extensions/sql-migration/src/constants/iconPathHelper.ts
View File

@@ -40,6 +40,7 @@ export class IconPathHelper {
public static emptyTable: IconPath;
public static addAzureAccount: IconPath;
public static retry: IconPath;
public static redo: IconPath;
public static edit: IconPath;
public static restartDataCollection: IconPath;
public static stop: IconPath;
@@ -167,6 +168,10 @@ export class IconPathHelper {
light: context.asAbsolutePath('images/retry.svg'),
dark: context.asAbsolutePath('images/retry.svg')
};
IconPathHelper.redo = {
light: context.asAbsolutePath('images/redo.svg'),
dark: context.asAbsolutePath('images/redo.svg')
};
IconPathHelper.edit = {
light: context.asAbsolutePath('images/edit.svg'),
dark: context.asAbsolutePath('images/edit.svg')

1
extensions/sql-migration/src/constants/strings.ts
View File

@@ -802,6 +802,7 @@ export const VALIDATION_STATE_FAILED = localize('sql.migration.validation.state.
export const VALIDATE_IR_DONE_BUTTON = localize('sql.migration.validate.ir.done.button', "Done");
export const VALIDATE_IR_HEADING = localize('sql.migration.validate.ir.heading', "We are validating the following:");
export const VALIDATE_IR_START_VALIDATION = localize('sql.migration.validate.ir.start.validation', "Start validation");
export const VALIDATE_IR_FAILED_REVALIDATION = localize('sql.migration.validate.ir.failed.revalidation', "Revalidate failed steps");
export const VALIDATE_IR_STOP_VALIDATION = localize('sql.migration.validate.ir.stop.validation', "Stop validation");
export const VALIDATE_IR_COPY_RESULTS = localize('sql.migration.validate.ir.copy.results', "Copy validation results");
export const VALIDATE_IR_RESULTS_HEADING = localize('sql.migration.validate.ir.results.heading', "Validation step details");

117
extensions/sql-migration/src/dialog/validationResults/validateIrDialog.ts
View File

@@ -50,6 +50,7 @@ export class ValidateIrDialog {
private _resultsTable!: azdata.TableComponent;
private _startLoader!: azdata.LoadingComponent;
private _startButton!: azdata.ButtonComponent;
private _revalidationButton!: azdata.ButtonComponent;
private _cancelButton!: azdata.ButtonComponent;
private _copyButton!: azdata.ButtonComponent;
private _validationResult: any[][] = [];
@@ -144,6 +145,17 @@ export class ValidateIrDialog {
label: constants.VALIDATE_IR_STOP_VALIDATION,
enabled: false,
}).component();
this._revalidationButton = view.modelBuilder.button()
.withProps({
iconPath: IconPathHelper.redo,
iconHeight: 18,
iconWidth: 18,
width: 150,
label: constants.VALIDATE_IR_FAILED_REVALIDATION,
enabled: false,
}).component();
this._copyButton = view.modelBuilder.button()
.withProps({
iconPath: IconPathHelper.copy,
@@ -157,6 +169,10 @@ export class ValidateIrDialog {
this._disposables.push(
this._startButton.onDidClick(
async (e) => await this._runValidation()));
this._disposables.push(
this._revalidationButton.onDidClick(
async (e) => await this._runFailedRevalidation()));
this._disposables.push(
this._cancelButton.onDidClick(
e => {
@@ -172,6 +188,7 @@ export class ValidateIrDialog {
.withToolbarItems([
{ component: this._startButton },
{ component: this._cancelButton },
{ component: this._revalidationButton },
{ component: this._copyButton }])
.component();
@@ -262,6 +279,7 @@ export class ValidateIrDialog {
try {
this._startLoader.loading = true;
this._startButton.enabled = false;
this._revalidationButton.enabled = false;
this._cancelButton.enabled = true;
this._copyButton.enabled = false;
this._dialog!.okButton.enabled = false;
@@ -274,6 +292,30 @@ export class ValidateIrDialog {
} finally {
this._startLoader.loading = false;
this._startButton.enabled = true;
this._revalidationButton.enabled = !this._model.isIrTargetValidated;
this._cancelButton.enabled = false;
this._copyButton.enabled = true;
this._dialog!.okButton.enabled = this._model.isIrTargetValidated;
this._dialog!.cancelButton.enabled = !this._model.isIrTargetValidated;
}
}
private async _runFailedRevalidation(results?: ValidationResult[]): Promise<void> {
try {
this._startLoader.loading = true;
this._startButton.enabled = false;
this._revalidationButton.enabled = false;
this._cancelButton.enabled = true;
this._copyButton.enabled = false;
this._dialog!.okButton.enabled = false;
this._dialog!.cancelButton.enabled = true;
if (!this._model.isIrTargetValidated) {
await this._revalidate();
}
} finally {
this._startLoader.loading = false;
this._startButton.enabled = true;
this._revalidationButton.enabled = !this._model.isIrTargetValidated;
this._cancelButton.enabled = false;
this._copyButton.enabled = true;
this._dialog!.okButton.enabled = this._model.isIrTargetValidated;
@@ -373,7 +415,19 @@ export class ValidateIrDialog {
this._saveResults();
}
private async _validateDatabaseMigration(): Promise<void> {
private async _revalidate(): Promise<void> {
await this._initIrResultsForRevalidation();
if (this._model.isSqlDbTarget) {
await this._validateSqlDbMigration(true);
} else {
await this._validateDatabaseMigration(true);
}
this._saveResults();
}
private async _validateDatabaseMigration(skipSuccessfulSteps: boolean = false): Promise<void> {
const currentConnection = await getSourceConnectionProfile();
const sourceServerName = currentConnection?.serverName!;
const encryptConnection = getEncryptConnectionValue(currentConnection);
@@ -426,17 +480,21 @@ export class ValidateIrDialog {
};
// validate integration runtime (IR) is online
if (!await validate(sourceDatabaseName, networkShare, true, false, false, false)) {
this._canceled = true;
await this._updateValidateIrResults(testNumber + 1, ValidateIrState.Canceled, [constants.VALIDATE_IR_VALIDATION_CANCELED])
return;
if (!skipSuccessfulSteps || this._validationResult[testNumber][ValidationResultIndex.state] !== ValidateIrState.Succeeded) {
if (!await validate(sourceDatabaseName, networkShare, true, false, false, false)) {
this._canceled = true;
await this._updateValidateIrResults(testNumber + 1, ValidateIrState.Canceled, [constants.VALIDATE_IR_VALIDATION_CANCELED])
return;
}
}
testNumber++;
// validate blob container connectivity
if (!await validate(sourceDatabaseName, networkShare, false, false, false, true)) {
await this._updateValidateIrResults(testNumber + 1, ValidateIrState.Canceled, [constants.VALIDATE_IR_VALIDATION_CANCELED])
return;
if (!skipSuccessfulSteps || this._validationResult[testNumber][ValidationResultIndex.state] !== ValidateIrState.Succeeded) {
if (!await validate(sourceDatabaseName, networkShare, false, false, false, true)) {
await this._updateValidateIrResults(testNumber + 1, ValidateIrState.Canceled, [constants.VALIDATE_IR_VALIDATION_CANCELED])
return;
}
}
for (let i = 0; i < databaseCount; i++) {
@@ -448,14 +506,18 @@ export class ValidateIrDialog {
break;
}
// validate source connectivity
await validate(sourceDatabaseName, networkShare, false, false, true, false);
if (!skipSuccessfulSteps || this._validationResult[testNumber][ValidationResultIndex.state] !== ValidateIrState.Succeeded) {
await validate(sourceDatabaseName, networkShare, false, false, true, false);
}
testNumber++;
if (this._canceled) {
await this._updateValidateIrResults(testNumber, ValidateIrState.Canceled, [constants.VALIDATE_IR_VALIDATION_CANCELED])
break;
}
// valdiate source location / network share connectivity
await validate(sourceDatabaseName, networkShare, false, true, false, false);
if (!skipSuccessfulSteps || this._validationResult[testNumber][ValidationResultIndex.state] !== ValidateIrState.Succeeded) {
await validate(sourceDatabaseName, networkShare, false, true, false, false);
}
}
}
@@ -469,7 +531,7 @@ export class ValidateIrDialog {
return error;
}
private async _validateSqlDbMigration(): Promise<void> {
private async _validateSqlDbMigration(skipSuccessfulSteps: boolean = false): Promise<void> {
const currentConnection = await getSourceConnectionProfile();
const sourceServerName = currentConnection?.serverName!;
const encryptConnection = getEncryptConnectionValue(currentConnection);
@@ -521,10 +583,12 @@ export class ValidateIrDialog {
};
// validate IR is online
if (!await validate(sourceDatabaseName, targetDatabaseName, true, false, false)) {
this._canceled = true;
await this._updateValidateIrResults(testNumber + 1, ValidateIrState.Canceled, [constants.VALIDATE_IR_VALIDATION_CANCELED]);
return;
if (!skipSuccessfulSteps || this._validationResult[testNumber][ValidationResultIndex.state] !== ValidateIrState.Succeeded) {
if (!await validate(sourceDatabaseName, targetDatabaseName, true, false, false)) {
this._canceled = true;
await this._updateValidateIrResults(testNumber + 1, ValidateIrState.Canceled, [constants.VALIDATE_IR_VALIDATION_CANCELED]);
return;
}
}
for (let i = 0; i < databaseCount; i++) {
@@ -537,7 +601,9 @@ export class ValidateIrDialog {
break;
}
// validate source connectivity
await validate(sourceDatabaseName, targetDatabaseName, false, true, false);
if (!skipSuccessfulSteps || this._validationResult[testNumber][ValidationResultIndex.state] !== ValidateIrState.Succeeded) {
await validate(sourceDatabaseName, targetDatabaseName, false, true, false);
}
testNumber++;
if (this._canceled) {
@@ -545,7 +611,9 @@ export class ValidateIrDialog {
break;
}
// validate target connectivity
await validate(sourceDatabaseName, targetDatabaseName, false, false, true);
if (!skipSuccessfulSteps || this._validationResult[testNumber][ValidationResultIndex.state] !== ValidateIrState.Succeeded) {
await validate(sourceDatabaseName, targetDatabaseName, false, false, true);
}
}
}
@@ -584,6 +652,21 @@ export class ValidateIrDialog {
await this._resultsTable.updateProperty('data', data);
}
private async _initIrResultsForRevalidation(results?: ValidationResult[]): Promise<void> {
this._valdiationErrors = [];
this._canceled = false;
let testNumber: number = 0;
this._validationResult.forEach(async element => {
if (element[ValidationResultIndex.state] !== ValidateIrState.Succeeded) {
await this._updateValidateIrResults(testNumber++, ValidateIrState.Pending);
}
else {
testNumber++;
}
});
}
private async _initSqlDbIrResults(results?: ValidationResult[]): Promise<void> {
this._validationResult = [];
this._addValidationResult(constants.VALIDATE_IR_VALIDATION_RESULT_LABEL_SHIR);