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

DBZ-2859 Fix formatting

Browse Source
This commit is contained in:
Chris Cranford 2021-01-04 14:00:11 -05:00
parent 90e41c6fa2
commit d0bce38efb
1 changed files with 43 additions and 43 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

86
debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorConfigTest.java
View File

@ -7,12 +7,12 @@
import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue; import static org.junit.Assert.assertTrue;
import org.junit.Test; import org.junit.Test;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import io.debezium.config.Configuration; import io.debezium.config.Configuration;
import io.debezium.connector.oracle.util.TestHelper;
public class OracleConnectorConfigTest { public class OracleConnectorConfigTest {
@ -23,12 +23,12 @@ public void validXtreamNoUrl() throws Exception {
final OracleConnectorConfig connectorConfig = new OracleConnectorConfig( final OracleConnectorConfig connectorConfig = new OracleConnectorConfig(
Configuration.create() Configuration.create()
.with(OracleConnectorConfig.SERVER_NAME, "myserver") .with(OracleConnectorConfig.SERVER_NAME, "myserver")
.with(OracleConnectorConfig.HOSTNAME, "MyHostname") .with(OracleConnectorConfig.HOSTNAME, "MyHostname")
.with(OracleConnectorConfig.DATABASE_NAME, "mydb") .with(OracleConnectorConfig.DATABASE_NAME, "mydb")
.with(OracleConnectorConfig.XSTREAM_SERVER_NAME, "myserver") .with(OracleConnectorConfig.XSTREAM_SERVER_NAME, "myserver")
.with(OracleConnectorConfig.USER, "debezium") .with(OracleConnectorConfig.USER, "debezium")
.build()); .build());
assertTrue(connectorConfig.getConfig().validateAndRecord(connectorConfig.ALL_FIELDS, LOGGER::error)); assertTrue(connectorConfig.getConfig().validateAndRecord(connectorConfig.ALL_FIELDS, LOGGER::error));
} }
@ -37,13 +37,13 @@ public void validLogminerNoUrl() throws Exception {
final OracleConnectorConfig connectorConfig = new OracleConnectorConfig( final OracleConnectorConfig connectorConfig = new OracleConnectorConfig(
Configuration.create() Configuration.create()
.with(OracleConnectorConfig.CONNECTOR_ADAPTER, "logminer") .with(OracleConnectorConfig.CONNECTOR_ADAPTER, "logminer")
.with(OracleConnectorConfig.SERVER_NAME, "myserver") .with(OracleConnectorConfig.SERVER_NAME, "myserver")
.with(OracleConnectorConfig.HOSTNAME, "MyHostname") .with(OracleConnectorConfig.HOSTNAME, "MyHostname")
.with(OracleConnectorConfig.DATABASE_NAME, "mydb") .with(OracleConnectorConfig.DATABASE_NAME, "mydb")
.with(OracleConnectorConfig.SCHEMA_NAME, "myschema") .with(OracleConnectorConfig.SCHEMA_NAME, "myschema")
.with(OracleConnectorConfig.USER, "debezium") .with(OracleConnectorConfig.USER, "debezium")
.build()); .build());
assertTrue(connectorConfig.getConfig().validateAndRecord(connectorConfig.ALL_FIELDS, LOGGER::error)); assertTrue(connectorConfig.getConfig().validateAndRecord(connectorConfig.ALL_FIELDS, LOGGER::error));
} }
@ -52,12 +52,12 @@ public void validXtreamWithUrl() throws Exception {
final OracleConnectorConfig connectorConfig = new OracleConnectorConfig( final OracleConnectorConfig connectorConfig = new OracleConnectorConfig(
Configuration.create() Configuration.create()
.with(OracleConnectorConfig.SERVER_NAME, "myserver") .with(OracleConnectorConfig.SERVER_NAME, "myserver")
.with(OracleConnectorConfig.URL, "jdbc:oci:thin:@myserver/mydatabase") .with(OracleConnectorConfig.URL, "jdbc:oci:thin:@myserver/mydatabase")
.with(OracleConnectorConfig.DATABASE_NAME, "mydb") .with(OracleConnectorConfig.DATABASE_NAME, "mydb")
.with(OracleConnectorConfig.XSTREAM_SERVER_NAME, "myserver") .with(OracleConnectorConfig.XSTREAM_SERVER_NAME, "myserver")
.with(OracleConnectorConfig.USER, "debezium") .with(OracleConnectorConfig.USER, "debezium")
.build()); .build());
assertTrue(connectorConfig.getConfig().validateAndRecord(connectorConfig.ALL_FIELDS, LOGGER::error)); assertTrue(connectorConfig.getConfig().validateAndRecord(connectorConfig.ALL_FIELDS, LOGGER::error));
} }
@ -66,43 +66,43 @@ public void validLogminerWithUrl() throws Exception {
final OracleConnectorConfig connectorConfig = new OracleConnectorConfig( final OracleConnectorConfig connectorConfig = new OracleConnectorConfig(
Configuration.create() Configuration.create()
.with(OracleConnectorConfig.CONNECTOR_ADAPTER, "logminer") .with(OracleConnectorConfig.CONNECTOR_ADAPTER, "logminer")
.with(OracleConnectorConfig.SERVER_NAME, "myserver") .with(OracleConnectorConfig.SERVER_NAME, "myserver")
.with(OracleConnectorConfig.URL, "MyHostname") .with(OracleConnectorConfig.URL, "MyHostname")
.with(OracleConnectorConfig.DATABASE_NAME, "mydb") .with(OracleConnectorConfig.DATABASE_NAME, "mydb")
.with(OracleConnectorConfig.SCHEMA_NAME, "myschema") .with(OracleConnectorConfig.SCHEMA_NAME, "myschema")
.with(OracleConnectorConfig.USER, "debezium") .with(OracleConnectorConfig.USER, "debezium")
.build()); .build());
assertTrue(connectorConfig.getConfig().validateAndRecord(connectorConfig.ALL_FIELDS, LOGGER::error)); assertTrue(connectorConfig.getConfig().validateAndRecord(connectorConfig.ALL_FIELDS, LOGGER::error));
} }
@Test @Test
public void validUrlTNS() throws Exception { public void validUrlTNS() throws Exception {
final OracleConnectorConfig connectorConfig = new OracleConnectorConfig( final OracleConnectorConfig connectorConfig = new OracleConnectorConfig(
Configuration.create() Configuration.create()
.with(OracleConnectorConfig.CONNECTOR_ADAPTER, "logminer") .with(OracleConnectorConfig.CONNECTOR_ADAPTER, "logminer")
.with(OracleConnectorConfig.SERVER_NAME, "myserver") .with(OracleConnectorConfig.SERVER_NAME, "myserver")
.with(OracleConnectorConfig.URL, "jdbc:oracle:thin:@(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=192.68.1.11)(PORT=1701))(ADDRESS=(PROTOCOL=TCP)(HOST=192.68.1.12)(PORT=1701))(ADDRESS=(PROTOCOL=TCP)(HOST=192.68.1.13)(PORT=1701))(LOAD_BALANCE = yes)(FAILOVER = on)(CONNECT_DATA =(SERVER = DEDICATED)(SERVICE_NAME = myserver.mydomain.com)(FAILOVER_MODE =(TYPE = SELECT)(METHOD = BASIC)(RETRIES = 3)(DELAY = 5))))") .with(OracleConnectorConfig.URL,
.with(OracleConnectorConfig.DATABASE_NAME, "mydb") "jdbc:oracle:thin:@(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=192.68.1.11)(PORT=1701))(ADDRESS=(PROTOCOL=TCP)(HOST=192.68.1.12)(PORT=1701))(ADDRESS=(PROTOCOL=TCP)(HOST=192.68.1.13)(PORT=1701))(LOAD_BALANCE = yes)(FAILOVER = on)(CONNECT_DATA =(SERVER = DEDICATED)(SERVICE_NAME = myserver.mydomain.com)(FAILOVER_MODE =(TYPE = SELECT)(METHOD = BASIC)(RETRIES = 3)(DELAY = 5))))")
.with(OracleConnectorConfig.SCHEMA_NAME, "myschema") .with(OracleConnectorConfig.DATABASE_NAME, "mydb")
.with(OracleConnectorConfig.USER, "debezium") .with(OracleConnectorConfig.SCHEMA_NAME, "myschema")
.build()); .with(OracleConnectorConfig.USER, "debezium")
.build());
assertTrue(connectorConfig.getConfig().validateAndRecord(connectorConfig.ALL_FIELDS, LOGGER::error)); assertTrue(connectorConfig.getConfig().validateAndRecord(connectorConfig.ALL_FIELDS, LOGGER::error));
} }
@Test @Test
public void invalidNoHostnameNoUri() throws Exception { public void invalidNoHostnameNoUri() throws Exception {
final OracleConnectorConfig connectorConfig = new OracleConnectorConfig( final OracleConnectorConfig connectorConfig = new OracleConnectorConfig(
Configuration.create() Configuration.create()
.with(OracleConnectorConfig.CONNECTOR_ADAPTER, "logminer") .with(OracleConnectorConfig.CONNECTOR_ADAPTER, "logminer")
.with(OracleConnectorConfig.SERVER_NAME, "myserver") .with(OracleConnectorConfig.SERVER_NAME, "myserver")
.with(OracleConnectorConfig.DATABASE_NAME, "mydb") .with(OracleConnectorConfig.DATABASE_NAME, "mydb")
.with(OracleConnectorConfig.SCHEMA_NAME, "myschema") .with(OracleConnectorConfig.SCHEMA_NAME, "myschema")
.with(OracleConnectorConfig.USER, "debezium") .with(OracleConnectorConfig.USER, "debezium")
.build()); .build());
assertFalse(connectorConfig.getConfig().validateAndRecord(connectorConfig.ALL_FIELDS, LOGGER::error)); assertFalse(connectorConfig.getConfig().validateAndRecord(connectorConfig.ALL_FIELDS, LOGGER::error));
} }
} }