Skip to content

Commit e21828e

Browse files
committed
fix: other ts
1 parent 9166ce8 commit e21828e

File tree

1 file changed

+25
-5
lines changed

1 file changed

+25
-5
lines changed

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

Lines changed: 25 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,13 @@ class MySqlSourceCdcTemporalConverter : RelationalColumnCustomConverter {
5555

5656
override val partialConverters: List<PartialConverter> =
5757
listOf(
58-
NullFallThrough,
58+
PartialConverter {
59+
if (it == null || it == 0) {
60+
Converted("1970-01-01T00:00:00.000000")
61+
} else {
62+
NoConversion
63+
}
64+
},
5965
PartialConverter {
6066
if (it is LocalDateTime) {
6167
Converted(it.format(LocalDateTimeCodec.formatter))
@@ -87,7 +93,13 @@ class MySqlSourceCdcTemporalConverter : RelationalColumnCustomConverter {
8793

8894
override val partialConverters: List<PartialConverter> =
8995
listOf(
90-
NullFallThrough,
96+
PartialConverter {
97+
if (it == null || it == 0) {
98+
Converted("1970-01-01T00:00:00.000000")
99+
}else {
100+
NoConversion
101+
}
102+
},
91103
PartialConverter {
92104
if (it is LocalDateTime) {
93105
Converted(it.format(LocalDateTimeCodec.formatter))
@@ -121,8 +133,10 @@ class MySqlSourceCdcTemporalConverter : RelationalColumnCustomConverter {
121133
listOf(
122134
PartialConverter {
123135
if (it == null || it == 0) {
124-
Converted("")
125-
} else NoConversion
136+
Converted("1970-01-01")
137+
} else {
138+
NoConversion
139+
}
126140
},
127141
PartialConverter {
128142
if (it is LocalDate) {
@@ -182,7 +196,13 @@ class MySqlSourceCdcTemporalConverter : RelationalColumnCustomConverter {
182196

183197
override val partialConverters: List<PartialConverter> =
184198
listOf(
185-
NullFallThrough,
199+
PartialConverter {
200+
if (it == null || it == 0) {
201+
Converted("1970-01-01T00:00:00.000000")
202+
} else {
203+
NoConversion
204+
}
205+
},
186206
PartialConverter {
187207
if (it is ZonedDateTime) {
188208
if (serverTimezone != "UTC") {

0 commit comments

Comments
 (0)