Skip to content

Commit 3327a31

Browse files
authored
Task/rdmp 328 extraction archive triggers (#2254)
* add extraction db triggers * fix test * add tests * add missing test * update tests * move checks
1 parent 1464eea commit 3327a31

File tree

6 files changed

+889
-72
lines changed

6 files changed

+889
-72
lines changed

CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
1111
- Require all deletes to enter a commit message when using the commit system
1212
- Introduce ability to view Catalogues in a flat view
1313
- Fix bug where Internal catalogues were still able to be added to a CIC
14+
- Add ability to use archive trigger when re-releasing to a database
1415

1516
## [9.0.3] - 2025-11-03
1617
- Improve checking for default pipelines

Rdmp.Core.Tests/DataExport/DataExtraction/ExecuteFullExtractionToDatabaseMSSqlDestinationReExtractionTest.cs

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -533,7 +533,7 @@ public void ReExtractToADatabaseWithNewDataAndNoPKs()
533533

534534
dt = destinationTable.GetDataTable();
535535

536-
Assert.That(dt.Rows, Has.Count.EqualTo(2));
536+
Assert.That(dt.Rows, Has.Count.EqualTo(3));
537537
}
538538

539539
[Test]
@@ -802,7 +802,7 @@ public void ReExtractToADatabaseWithNewDataAndSinglePK()
802802

803803
dt = destinationTable.GetDataTable();
804804

805-
Assert.That(dt.Rows, Has.Count.EqualTo(2));
805+
Assert.That(dt.Rows, Has.Count.EqualTo(3));
806806
}
807807

808808
[Test]
@@ -1061,7 +1061,7 @@ public void ReExtractToADatabaseWithNewDataAndExtractionIdentifierIsPK()
10611061

10621062
dt = destinationTable.GetDataTable();
10631063

1064-
Assert.That(dt.Rows, Has.Count.EqualTo(2));
1064+
Assert.That(dt.Rows, Has.Count.EqualTo(3));
10651065
}
10661066

10671067
[Test]
@@ -1209,6 +1209,8 @@ public void ExtractToDatabaseUseTriggers()
12091209
var argumentDbNamePattern = destinationArguments.Single(static a => a.Name == "DatabaseNamingPattern");
12101210
var argumentTblNamePattern = destinationArguments.Single(static a => a.Name == "TableNamingPattern");
12111211
var reExtract = destinationArguments.Single(static a => a.Name == "AppendDataIfTableExists");
1212+
var argUseArchiveTrigger = destinationArguments.Single(static a => a.Name == "UseArchiveTrigger");
1213+
12121214
Assert.That(argumentServer.Name, Is.EqualTo("TargetDatabaseServer"));
12131215
var extractionServer = new ExternalDatabaseServer(CatalogueRepository, "myserver", null)
12141216
{
@@ -1224,6 +1226,8 @@ public void ExtractToDatabaseUseTriggers()
12241226
argumentDbNamePattern.SaveToDatabase();
12251227
argumentTblNamePattern.SetValue("$c_$d");
12261228
argumentTblNamePattern.SaveToDatabase();
1229+
argUseArchiveTrigger.SetValue(true);
1230+
argUseArchiveTrigger.SaveToDatabase();
12271231
reExtract.SetValue(true);
12281232
reExtract.SaveToDatabase();
12291233

0 commit comments

Comments
 (0)