dohertj2/jdescopingtool
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(datasync): add GIW connection type to DbQuerySource

Browse Source 
Add support for "giw" connection type in DbQuerySource to enable
the StatusCode pipeline to query from the GIW Oracle database.
This commit is contained in:
Joseph Doherty
2026-01-07 00:58:56 -05:00
parent c59a3160d0
commit 4b3c900d52
2 changed files with 14 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
NEW/src/JdeScoping.DataSync/Etl/Sources/DbQuerySource.cs
+3 -2
View File
@@ -12,7 +12,7 @@ public class DbQuerySource : IImportSource
{
private static readonly HashSet<string> ValidConnectionTypes = new(StringComparer.OrdinalIgnoreCase)
{
"jde", "cms", "lotfinder"
"jde", "cms", "lotfinder", "giw"
};
private readonly IDbConnectionFactory _connectionFactory;
@@ -48,7 +48,7 @@ public class DbQuerySource : IImportSource
if (!ValidConnectionTypes.Contains(connectionType))
{
throw new ArgumentException($"Unknown connection type: {connectionType}. Valid types are: jde, cms, lotfinder.", nameof(connectionType));
throw new ArgumentException($"Unknown connection type: {connectionType}. Valid types are: jde, cms, lotfinder, giw.", nameof(connectionType));
}
_connectionFactory = connectionFactory;
@@ -77,6 +77,7 @@ public class DbQuerySource : IImportSource
{
"jde" => await _connectionFactory.CreateJdeConnectionAsync(cancellationToken),
"cms" => await _connectionFactory.CreateCmsConnectionAsync(cancellationToken),
"giw" => await _connectionFactory.CreateGiwConnectionAsync(cancellationToken),
"lotfinder" => await _connectionFactory.CreateLotFinderConnectionAsync(cancellationToken),
_ => throw new InvalidOperationException($"Unknown connection type: {_connectionType}")
};
NEW/tests/JdeScoping.DataSync.Tests/Etl/Sources/DbQuerySourceTests.cs
+11
View File
@@ -81,4 +81,15 @@ public class DbQuerySourceTests
var source = new DbQuerySource(factory, "jde", "SELECT 1", commandTimeout: 7200);
source.SourceName.ShouldBe("DbQuery:jde");
}
[Fact]
public void Constructor_WithGiwConnectionType_DoesNotThrow()
{
// Arrange
var connectionFactory = Substitute.For<IDbConnectionFactory>();
// Act & Assert - should not throw
var source = new DbQuerySource(connectionFactory, "giw", "SELECT 1", null);
source.SourceName.ShouldBe("DbQuery:giw");
}
}