DBZ-7752 Small change in naming

debezium · May 2, 2024 · 994c861 · 994c861
1 parent 3b3c89f
commit 994c861
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 10 deletions.
diff --git a/src/main/java/io/debezium/connector/jdbc/PreparedStatementQueryBinder.java b/src/main/java/io/debezium/connector/jdbc/PreparedStatementQueryBinder.java
@@ -26,7 +26,7 @@ public void bind(ValueBindDescriptor valueBindDescriptor) {
             if (valueBindDescriptor.getTargetSqlType() != null) {
                 if (valueBindDescriptor.getTargetSqlType() == Types.ARRAY) {
                     Collection<Object> collection = (Collection<Object>) valueBindDescriptor.getValue();
-                    Array array = binder.getConnection().createArrayOf(valueBindDescriptor.getSubTypeName(), collection.toArray());
+                    Array array = binder.getConnection().createArrayOf(valueBindDescriptor.getElementTypeName(), collection.toArray());
                     binder.setArray(valueBindDescriptor.getIndex(), array);
                 }
                 else {

diff --git a/src/main/java/io/debezium/connector/jdbc/ValueBindDescriptor.java b/src/main/java/io/debezium/connector/jdbc/ValueBindDescriptor.java
@@ -12,27 +12,27 @@ public class ValueBindDescriptor {
 
     private final Integer targetSqlType;
 
-    private final String subTypeName;
+    private final String elementTypeName;
 
     public ValueBindDescriptor(int index, Object value) {
         this.index = index;
         this.value = value;
         this.targetSqlType = null;
-        this.subTypeName = null;
+        this.elementTypeName = null;
     }
 
     public ValueBindDescriptor(int index, Object value, Integer targetSqlType) {
         this.index = index;
         this.value = value;
         this.targetSqlType = targetSqlType;
-        this.subTypeName = null;
+        this.elementTypeName = null;
     }
 
-    public ValueBindDescriptor(int index, Object value, Integer targetSqlType, String subTypeName) {
+    public ValueBindDescriptor(int index, Object value, Integer targetSqlType, String elementTypeName) {
         this.index = index;
         this.value = value;
         this.targetSqlType = targetSqlType;
-        this.subTypeName = subTypeName;
+        this.elementTypeName = elementTypeName;
     }
 
     public int getIndex() {
@@ -47,7 +47,7 @@ public Integer getTargetSqlType() {
         return targetSqlType;
     }
 
-    public String getSubTypeName() {
-        return subTypeName;
+    public String getElementTypeName() {
+        return elementTypeName;
     }
 }
diff --git a/src/main/java/io/debezium/connector/jdbc/dialect/postgres/ArrayType.java b/src/main/java/io/debezium/connector/jdbc/dialect/postgres/ArrayType.java
@@ -34,8 +34,8 @@ public String[] getRegistrationKeys() {
 
     @Override
     public String getTypeName(DatabaseDialect dialect, Schema schema, boolean key) {
-        Type subType = dialect.getSchemaType(schema.valueSchema());
-        typeName = subType.getTypeName(dialect, schema.valueSchema(), key);
+        Type elementType = dialect.getSchemaType(schema.valueSchema());
+        typeName = elementType.getTypeName(dialect, schema.valueSchema(), key);
         return typeName + "[]";
     }