alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-5944 Toasted varchar array is not correctly processed

Browse Source
This commit is contained in:
Praveen Burgu 2022-12-15 15:16:12 -08:00 committed by Jiri Pechanec
parent c9fe6d5ef7
commit 0b4769c793
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/UnchangedToastedReplicationMessageColumn.java
View File

@ -25,12 +25,13 @@ public class UnchangedToastedReplicationMessageColumn extends AbstractReplicatio
*/
public static final Object UNCHANGED_TOAST_VALUE = new Object();
private boolean isArrayColumn = false;
private boolean isStringArrayColumn = false;
public UnchangedToastedReplicationMessageColumn(String columnName, PostgresType type, String typeWithModifiers, boolean optional) {
super(columnName, type, typeWithModifiers, optional);
if (typeWithModifiers.equals("text[]") || typeWithModifiers.equals("_text")) {
isArrayColumn = true;
if (typeWithModifiers.equals("text[]") || typeWithModifiers.equals("_text") ||
typeWithModifiers.equals("character varying[]") || typeWithModifiers.equals("_varchar")) {
isStringArrayColumn = true;
}
}
@ -41,7 +42,7 @@ public boolean isToastedColumn() {
@Override
public Object getValue(PostgresStreamingChangeEventSource.PgConnectionSupplier connection, boolean includeUnknownDatatypes) {
if (isArrayColumn) {
if (isStringArrayColumn) {
return Arrays.asList(UNCHANGED_TOAST_VALUE);
}
return UNCHANGED_TOAST_VALUE;