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

DBZ-347 Formatting

Browse Source
This commit is contained in:
Gunnar Morling 2017-09-18 17:04:14 +02:00
parent 38f8364647
commit 99f39038bb
2 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlSchemaTest.java
View File

@ -5,6 +5,7 @@
*/
package io.debezium.connector.mysql;
import static org.fest.assertions.Assertions.assertThat;
import static org.junit.Assert.fail;
import java.io.IOException;
@ -15,8 +16,6 @@
import org.junit.Before;
import org.junit.Test;
import static org.fest.assertions.Assertions.assertThat;
import io.debezium.relational.Table;
import io.debezium.relational.TableId;
import io.debezium.relational.TableSchema;
@ -65,7 +64,7 @@ public void shouldApplyDdlStatementsAndRecover() throws InterruptedException {
// Testing.Print.enable();
// Set up the server ...
source.setBinlogStartPoint("binlog-001",400);
source.setBinlogStartPoint("binlog-001", 400);
mysql.applyDdl(source, "db1", "SET " + MySqlSystemVariables.CHARSET_NAME_SERVER + "=utf8mb4", this::printStatements);
mysql.applyDdl(source, "db1", readFile("ddl/mysql-products.ddl"), this::printStatements);
@ -184,7 +183,7 @@ protected void assertTableExcluded(String fullyQualifiedTableName) {
assertThat(mysql.tables().forTable(tableId)).isNull();
assertThat(mysql.schemaFor(tableId)).isNull();
}
protected void assertNoTablesExistForDatabase(String dbName) {
assertThat(mysql.tables().tableIds().stream().filter(id->id.catalog().equals(dbName)).count()).isEqualTo(0);
}

2
debezium-core/src/main/java/io/debezium/relational/history/HistoryRecord.java
View File

@ -83,4 +83,4 @@ public String toString() {
public boolean isValid() {
return source() != null && position() != null;
}
}
}