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

DBZ-3056 Fix format.

Browse Source
This commit is contained in:
Yilong Chang 2021-02-10 10:45:47 -08:00 committed by Gunnar Morling
parent d98488b376
commit c004663418
2 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerConnector.java
View File

@ -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());

1
debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorTest.java
View File

@ -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;