DBZ-6589 Reformat code

debezium · Aug 7, 2023 · 2dcd033 · 2dcd033
1 parent 12be592
commit 2dcd033
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/main/java/io/debezium/connector/jdbc/dialect/db2/Db2DatabaseDialect.java b/src/main/java/io/debezium/connector/jdbc/dialect/db2/Db2DatabaseDialect.java
@@ -93,7 +93,7 @@ public String getUpsertStatement(TableDescriptor table, SinkRecordDescriptor rec
         builder.append("merge into ");
         builder.append(getQualifiedTableName(table.getId()));
         builder.append(" using (values(");
-        builder.appendLists(record.getKeyFieldNames(), record.getNonKeyFieldNames(), (name) -> columnQueryBindingFromField(name, table , record));
+        builder.appendLists(record.getKeyFieldNames(), record.getNonKeyFieldNames(), (name) -> columnQueryBindingFromField(name, table, record));
         builder.append(")) as DAT(");
         builder.appendLists(record.getKeyFieldNames(), record.getNonKeyFieldNames(), (name) -> columnNameFromField(name, record));
         builder.append(") on ");

diff --git a/...est/java/io/debezium/connector/jdbc/integration/postgres/JdbcSinkColumnTypeMappingIT.java b/...est/java/io/debezium/connector/jdbc/integration/postgres/JdbcSinkColumnTypeMappingIT.java
@@ -58,9 +58,9 @@ public void testShouldCoerceStringTypeToJsonbColumnType(SinkRecordFactory factor
         shouldCoerceStringTypeToColumnType(factory, "jsonb", "{\"id\": 12345}", "{\"id\": 67890}");
     }
 
-
     private void shouldCoerceStringTypeToColumnType(SinkRecordFactory factory, String columnType, String insertValue,
-                                                    String updateValue) throws Exception {
+                                                    String updateValue)
+            throws Exception {
         final Map<String, String> properties = getDefaultSinkConfig();
         properties.put(JdbcSinkConnectorConfig.SCHEMA_EVOLUTION, JdbcSinkConnectorConfig.SchemaEvolutionMode.BASIC.getValue());
         properties.put(JdbcSinkConnectorConfig.PRIMARY_KEY_MODE, JdbcSinkConnectorConfig.PrimaryKeyMode.RECORD_KEY.getValue());