Skip to content

Commit 7470fc4

Browse files
yuxiqianyuxiqian
committed
Migrate to JUnit 5 & AssertJ
1 parent 97c1c36 commit 7470fc4

File tree

2 files changed

+325
-310
lines changed

2 files changed

+325
-310
lines changed

‎flink-cdc-common/src/test/java/org/apache/flink/cdc/common/utils/ChangeEventUtilsTest.java

Lines changed: 78 additions & 79 deletions
Original file line numberDiff line numberDiff line change
@@ -17,9 +17,9 @@
1717

1818
package org.apache.flink.cdc.common.utils;
1919

20+
import org.assertj.core.api.Assertions;
2021
import org.assertj.core.util.Sets;
21-
import org.junit.Assert;
22-
import org.junit.Test;
22+
import org.junit.jupiter.api.Test;
2323

2424
import java.util.Arrays;
2525
import java.util.Collections;
@@ -34,86 +34,85 @@
3434
public class ChangeEventUtilsTest {
3535
@Test
3636
public void testResolveSchemaEvolutionOptions() {
37-
Assert.assertEquals(
38-
ChangeEventUtils.resolveSchemaEvolutionOptions(
39-
Collections.emptyList(), Collections.emptyList()),
40-
Sets.set(CREATE_TABLE, ADD_COLUMN, ALTER_COLUMN_TYPE, DROP_COLUMN, RENAME_COLUMN));
41-
42-
Assert.assertEquals(
43-
ChangeEventUtils.resolveSchemaEvolutionOptions(
44-
Collections.emptyList(), Collections.singletonList("drop")),
45-
Sets.set(CREATE_TABLE, ADD_COLUMN, ALTER_COLUMN_TYPE, RENAME_COLUMN));
46-
47-
Assert.assertEquals(
48-
ChangeEventUtils.resolveSchemaEvolutionOptions(
49-
Arrays.asList("create", "add"), Collections.emptyList()),
50-
Sets.set(CREATE_TABLE, ADD_COLUMN));
51-
52-
Assert.assertEquals(
53-
ChangeEventUtils.resolveSchemaEvolutionOptions(
54-
Collections.singletonList("column"),
55-
Collections.singletonList("drop.column")),
56-
Sets.set(ADD_COLUMN, ALTER_COLUMN_TYPE, RENAME_COLUMN));
57-
58-
Assert.assertEquals(
59-
ChangeEventUtils.resolveSchemaEvolutionOptions(
60-
Collections.emptyList(), Collections.singletonList("drop.column")),
61-
Sets.set(CREATE_TABLE, ADD_COLUMN, ALTER_COLUMN_TYPE, RENAME_COLUMN));
37+
Assertions.assertThat(
38+
ChangeEventUtils.resolveSchemaEvolutionOptions(
39+
Collections.emptyList(), Collections.emptyList()))
40+
.isEqualTo(
41+
Sets.set(
42+
CREATE_TABLE,
43+
ADD_COLUMN,
44+
ALTER_COLUMN_TYPE,
45+
DROP_COLUMN,
46+
RENAME_COLUMN));
47+
48+
Assertions.assertThat(
49+
ChangeEventUtils.resolveSchemaEvolutionOptions(
50+
Collections.emptyList(), Collections.singletonList("drop")))
51+
.isEqualTo(Sets.set(CREATE_TABLE, ADD_COLUMN, ALTER_COLUMN_TYPE, RENAME_COLUMN));
52+
53+
Assertions.assertThat(
54+
ChangeEventUtils.resolveSchemaEvolutionOptions(
55+
Arrays.asList("create", "add"), Collections.emptyList()))
56+
.isEqualTo(Sets.set(CREATE_TABLE, ADD_COLUMN));
57+
58+
Assertions.assertThat(
59+
ChangeEventUtils.resolveSchemaEvolutionOptions(
60+
Collections.singletonList("column"),
61+
Collections.singletonList("drop.column")))
62+
.isEqualTo(Sets.set(ADD_COLUMN, ALTER_COLUMN_TYPE, RENAME_COLUMN));
63+
64+
Assertions.assertThat(
65+
ChangeEventUtils.resolveSchemaEvolutionOptions(
66+
Collections.emptyList(), Collections.singletonList("drop.column")))
67+
.isEqualTo(Sets.set(CREATE_TABLE, ADD_COLUMN, ALTER_COLUMN_TYPE, RENAME_COLUMN));
6268
}
6369

6470
@Test
6571
public void testResolveSchemaEvolutionTag() {
66-
Assert.assertEquals(
67-
ChangeEventUtils.resolveSchemaEvolutionTag("all"),
68-
Arrays.asList(
69-
ADD_COLUMN, CREATE_TABLE, ALTER_COLUMN_TYPE, DROP_COLUMN, RENAME_COLUMN));
70-
71-
Assert.assertEquals(
72-
ChangeEventUtils.resolveSchemaEvolutionTag("column"),
73-
Arrays.asList(ADD_COLUMN, ALTER_COLUMN_TYPE, DROP_COLUMN, RENAME_COLUMN));
74-
75-
Assert.assertEquals(
76-
ChangeEventUtils.resolveSchemaEvolutionTag("table"),
77-
Collections.singletonList(CREATE_TABLE));
78-
79-
Assert.assertEquals(
80-
ChangeEventUtils.resolveSchemaEvolutionTag("rename"),
81-
Collections.singletonList(RENAME_COLUMN));
82-
83-
Assert.assertEquals(
84-
ChangeEventUtils.resolveSchemaEvolutionTag("rename.column"),
85-
Collections.singletonList(RENAME_COLUMN));
86-
87-
Assert.assertEquals(
88-
ChangeEventUtils.resolveSchemaEvolutionTag("drop"),
89-
Collections.singletonList(DROP_COLUMN));
90-
91-
Assert.assertEquals(
92-
ChangeEventUtils.resolveSchemaEvolutionTag("drop.column"),
93-
Collections.singletonList(DROP_COLUMN));
94-
95-
Assert.assertEquals(
96-
ChangeEventUtils.resolveSchemaEvolutionTag("create"),
97-
Collections.singletonList(CREATE_TABLE));
98-
99-
Assert.assertEquals(
100-
ChangeEventUtils.resolveSchemaEvolutionTag("create.table"),
101-
Collections.singletonList(CREATE_TABLE));
102-
103-
Assert.assertEquals(
104-
ChangeEventUtils.resolveSchemaEvolutionTag("alter"),
105-
Collections.singletonList(ALTER_COLUMN_TYPE));
106-
107-
Assert.assertEquals(
108-
ChangeEventUtils.resolveSchemaEvolutionTag("alter.column.type"),
109-
Collections.singletonList(ALTER_COLUMN_TYPE));
110-
111-
Assert.assertEquals(
112-
ChangeEventUtils.resolveSchemaEvolutionTag("add"),
113-
Collections.singletonList(ADD_COLUMN));
114-
115-
Assert.assertEquals(
116-
ChangeEventUtils.resolveSchemaEvolutionTag("add.column"),
117-
Collections.singletonList(ADD_COLUMN));
72+
Assertions.assertThat(ChangeEventUtils.resolveSchemaEvolutionTag("all"))
73+
.isEqualTo(
74+
Arrays.asList(
75+
ADD_COLUMN,
76+
CREATE_TABLE,
77+
ALTER_COLUMN_TYPE,
78+
DROP_COLUMN,
79+
RENAME_COLUMN));
80+
81+
Assertions.assertThat(ChangeEventUtils.resolveSchemaEvolutionTag("column"))
82+
.isEqualTo(
83+
Arrays.asList(ADD_COLUMN, ALTER_COLUMN_TYPE, DROP_COLUMN, RENAME_COLUMN));
84+
85+
Assertions.assertThat(ChangeEventUtils.resolveSchemaEvolutionTag("table"))
86+
.isEqualTo(Collections.singletonList(CREATE_TABLE));
87+
88+
Assertions.assertThat(ChangeEventUtils.resolveSchemaEvolutionTag("rename"))
89+
.isEqualTo(Collections.singletonList(RENAME_COLUMN));
90+
91+
Assertions.assertThat(ChangeEventUtils.resolveSchemaEvolutionTag("rename.column"))
92+
.isEqualTo(Collections.singletonList(RENAME_COLUMN));
93+
94+
Assertions.assertThat(ChangeEventUtils.resolveSchemaEvolutionTag("drop"))
95+
.isEqualTo(Collections.singletonList(DROP_COLUMN));
96+
97+
Assertions.assertThat(ChangeEventUtils.resolveSchemaEvolutionTag("drop.column"))
98+
.isEqualTo(Collections.singletonList(DROP_COLUMN));
99+
100+
Assertions.assertThat(ChangeEventUtils.resolveSchemaEvolutionTag("create"))
101+
.isEqualTo(Collections.singletonList(CREATE_TABLE));
102+
103+
Assertions.assertThat(ChangeEventUtils.resolveSchemaEvolutionTag("create.table"))
104+
.isEqualTo(Collections.singletonList(CREATE_TABLE));
105+
106+
Assertions.assertThat(ChangeEventUtils.resolveSchemaEvolutionTag("alter"))
107+
.isEqualTo(Collections.singletonList(ALTER_COLUMN_TYPE));
108+
109+
Assertions.assertThat(ChangeEventUtils.resolveSchemaEvolutionTag("alter.column.type"))
110+
.isEqualTo(Collections.singletonList(ALTER_COLUMN_TYPE));
111+
112+
Assertions.assertThat(ChangeEventUtils.resolveSchemaEvolutionTag("add"))
113+
.isEqualTo(Collections.singletonList(ADD_COLUMN));
114+
115+
Assertions.assertThat(ChangeEventUtils.resolveSchemaEvolutionTag("add.column"))
116+
.isEqualTo(Collections.singletonList(ADD_COLUMN));
118117
}
119118
}

0 commit comments

Comments
 (0)