jprdonnelly/airbyte
1
0
Fork 0
mirror of synced 2025-12-22 03:21:25 -05:00
Code Issues Packages Projects Releases Wiki Activity

[cdk, source-postgres, source-mysql, source-mongodb-v2] Fixing vulnerabilities in dependencies (#58132)

Browse Source 
Co-authored-by: Octavia Squidington III <octavia-squidington-iii@users.noreply.github.com>
This commit is contained in:
Yue Li
2025-04-24 08:28:30 -07:00
committed by GitHub
parent 01cd16654e
commit ad7aa7af4b
15 changed files with 112 additions and 109 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
airbyte-integrations/connectors/source-postgres/build.gradle
View File

@@ -12,7 +12,7 @@ java {
}
airbyteJavaConnector {
cdkVersionRequired = '0.48.4'
cdkVersionRequired = '0.48.9'
features = ['db-sources', 'datastore-postgres']
useLocalCdk = false
}
@@ -23,6 +23,7 @@ application {
}
dependencies {
api "com.google.protobuf:protobuf-java:3.25.5" // for fixing vulnerability of protobuf-java used by Debezium
implementation 'commons-codec:commons-codec:1.16.0'
implementation 'io.debezium:debezium-embedded:3.0.1.Final'
implementation 'io.debezium:debezium-connector-postgres:3.0.1.Final'

2
airbyte-integrations/connectors/source-postgres/metadata.yaml
View File

@@ -9,7 +9,7 @@ data:
connectorSubtype: database
connectorType: source
definitionId: decd338e-5647-4c0b-adf4-da0e75f5a750
dockerImageTag: 3.6.30
dockerImageTag: 3.6.31
dockerRepository: airbyte/source-postgres
documentationUrl: https://docs.airbyte.com/integrations/sources/postgres
githubIssueLabel: source-postgres

9
airbyte-integrations/connectors/source-postgres/src/test/java/io/airbyte/integrations/source/postgres/PostgresSourceTest.java
View File

@@ -293,13 +293,8 @@ class PostgresSourceTest {
return null;
});
final JsonNode anotherUserConfig = getConfig("test_user_3", "132");
final Set<AirbyteMessage> actualMessages =
MoreIterators.toSet(source().read(anotherUserConfig, CONFIGURED_CATALOG, null));
setEmittedAtToNull(actualMessages);
// expect 6 records, 4 state messages and 4 stream status messages.
assertEquals(14, actualMessages.size());
final var actualRecordMessages = filterRecords(actualMessages);
assertEquals(PRIVILEGE_TEST_CASE_EXPECTED_MESSAGES, actualRecordMessages);
final Throwable thrown = assertThrows(Exception.class, () -> MoreIterators.toSet(source().read(anotherUserConfig, CONFIGURED_CATALOG, null)));
assertNotNull(thrown.getMessage());
}
@Test