Skip to content

Commit 8d7b191

Browse files
authored
[Source-mysql-v2] : Support to add CDC option (#45366)
1 parent 5761f46 commit 8d7b191

File tree

3 files changed

+17
-2
lines changed

3 files changed

+17
-2
lines changed

airbyte-integrations/connectors/source-mysql-v2/metadata.yaml

+1-1
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ data:
99
connectorSubtype: database
1010
connectorType: source
1111
definitionId: 561393ed-7e3a-4d0d-8b8b-90ded371754c
12-
dockerImageTag: 0.0.2
12+
dockerImageTag: 0.0.3
1313
dockerRepository: airbyte/source-mysql-v2
1414
documentationUrl: https://docs.airbyte.com/integrations/sources/mysql
1515
githubIssueLabel: source-mysql-v2

airbyte-integrations/connectors/source-mysql-v2/src/main/kotlin/io/airbyte/integrations/source/mysql/MysqlSourceConfigurationJsonObject.kt

+2-1
Original file line numberDiff line numberDiff line change
@@ -277,7 +277,8 @@ class MicronautPropertiesFriendlyEncryption {
277277
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "cursor_method")
278278
@JsonSubTypes(
279279
JsonSubTypes.Type(value = UserDefinedCursor::class, name = "user_defined"),
280-
// TODO: add CDC support
280+
JsonSubTypes.Type(value = CdcCursor::class, name = "cdc")
281+
// TODO: port over additional Cdc options
281282
)
282283
@JsonSchemaTitle("Update Method")
283284
@JsonSchemaDescription("Configures how data is extracted from the database.")

airbyte-integrations/connectors/source-mysql-v2/src/test/resources/expected-spec.json

+14
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,20 @@
4444
},
4545
"description": "Incrementally detects new inserts and updates using the <a href=\"https://docs.airbyte.com/understanding-airbyte/connections/incremental-append/#user-defined-cursor\">cursor column</a> chosen when configuring a connection (e.g. created_at, updated_at).",
4646
"additionalProperties": true
47+
},
48+
{
49+
"type": "object",
50+
"title": "Read Changes using Change Data Capture (CDC)",
51+
"required": ["cursor_method"],
52+
"properties": {
53+
"cursor_method": {
54+
"enum": ["cdc"],
55+
"type": "string",
56+
"default": "cdc"
57+
}
58+
},
59+
"description": "<i>Recommended</i> - Incrementally reads new inserts, updates, and deletes using Mysql's <a href=\"https://docs.airbyte.com/integrations/sources/mssql/#change-data-capture-cdc\"> change data capture feature</a>. This must be enabled on your database.",
60+
"additionalProperties": true
4761
}
4862
],
4963
"order": 10,

0 commit comments

Comments
 (0)