From c0046634183167499ceb61a1a2a1c2b766506323 Mon Sep 17 00:00:00 2001
From: Yilong Chang <yilong@confluent.io>
Date: Wed, 10 Feb 2021 10:45:47 -0800
Subject: [PATCH] DBZ-3056 Fix format.

---
 .../sqlserver/SqlServerConnector.java         | 23 ++++++++++---------
 .../sqlserver/SqlServerConnectorTest.java     |  1 +
 2 files changed, 13 insertions(+), 11 deletions(-)

diff --git a/debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerConnector.java b/debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerConnector.java
index 5cfa8f4ba..a6cf25a9c 100644
--- a/debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerConnector.java
+++ b/debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerConnector.java
@@ -5,9 +5,6 @@
  */
 package io.debezium.connector.sqlserver;
 
-import io.debezium.config.Configuration;
-import io.debezium.util.Clock;
-import io.debezium.util.Strings;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.HashMap;
@@ -22,6 +19,10 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import io.debezium.config.Configuration;
+import io.debezium.util.Clock;
+import io.debezium.util.Strings;
+
 /**
  * The main connector class used to instantiate configuration and execution classes
  *
@@ -70,7 +71,7 @@ public ConfigDef config() {
     @Override
     public Config validate(Map<String, String> connectorConfigs) {
         Configuration config = Configuration.from(connectorConfigs);
-        SqlServerConnectorConfig sqlServerConfig  = new SqlServerConnectorConfig(config);
+        SqlServerConnectorConfig sqlServerConfig = new SqlServerConnectorConfig(config);
         // First, validate all of the individual fields, which is easy since don't make any of the fields invisible ...
         Map<String, ConfigValue> results = config.validate(SqlServerConnectorConfig.ALL_FIELDS);
 
@@ -88,20 +89,20 @@ public Config validate(Map<String, String> connectorConfigs) {
 
         // If there are no errors on any of these ...
         if (hostnameValue.errorMessages().isEmpty()
-            && portValue.errorMessages().isEmpty()
-            && userValue.errorMessages().isEmpty()
-            && passwordValue.errorMessages().isEmpty()
-            && databaseValue.errorMessages().isEmpty()) {
+                && portValue.errorMessages().isEmpty()
+                && userValue.errorMessages().isEmpty()
+                && passwordValue.errorMessages().isEmpty()
+                && databaseValue.errorMessages().isEmpty()) {
             // Try to connect to the database ...
             try (SqlServerConnection connection = new SqlServerConnection(sqlServerConfig.jdbcConfig(), Clock.system(),
-                sqlServerConfig.getSourceTimestampMode(), null)) {
+                    sqlServerConfig.getSourceTimestampMode(), null)) {
                 // SqlServerConnection will try retrieving database, no need to run another query.
                 logger.info("Successfully tested connection for {} with user '{}'", connection.connectionString(),
-                    connection.username());
+                        connection.username());
             }
             catch (Throwable e) {
                 logger.info("Failed testing connection for {} with user '{}'", sqlServerConfig.jdbcConfig(),
-                    userValue);
+                        userValue);
                 hostnameValue.addErrorMessage("Unable to connect: " + e.getMessage());
                 portValue.addErrorMessage("Unable to connect: " + e.getMessage());
                 databaseValue.addErrorMessage("Unable to connect: " + e.getMessage());
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorTest.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorTest.java
index 18f1815d8..ca28322a2 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorTest.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorTest.java
@@ -9,6 +9,7 @@
 
 import java.util.HashMap;
 import java.util.Map;
+
 import org.apache.kafka.common.config.Config;
 import org.apache.kafka.common.config.ConfigDef;
 import org.apache.kafka.common.config.ConfigDef.ConfigKey;