From 215ccf70ac35b15549c9a5d8a7f26a07fba65336 Mon Sep 17 00:00:00 2001
From: mfvitale <mvitale@redhat.com>
Date: Wed, 26 Jul 2023 15:47:43 +0200
Subject: [PATCH] DBZ-6637 use the right column name when checking for
 columnQueryBindingFromField

---
 .../connector/jdbc/dialect/GeneralDatabaseDialect.java         | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/dialect/GeneralDatabaseDialect.java b/debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/dialect/GeneralDatabaseDialect.java
index ce563b89c..6ec393c6b 100644
--- a/debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/dialect/GeneralDatabaseDialect.java
+++ b/debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/dialect/GeneralDatabaseDialect.java
@@ -621,7 +621,8 @@ protected void addColumnDefaultValue(FieldDescriptor field, StringBuilder column
     }
 
     protected String columnQueryBindingFromField(String fieldName, TableDescriptor table, SinkRecordDescriptor record) {
-        final String columnName = columnNameFromField(fieldName, record);
+
+        final String columnName = getColumnNamingStrategy().resolveColumnName(fieldName);
 
         if (record.getNonKeyFieldNames().contains(columnName)) {
             Struct source = record.getAfterStruct();