DBZ-7698 Improve test naming

debezium · Mar 29, 2024 · 5a02b29 · 5a02b29
1 parent 5d10208
commit 5a02b29
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/src/test/java/io/debezium/connector/vitess/VitessOffsetContextTest.java b/src/test/java/io/debezium/connector/vitess/VitessOffsetContextTest.java
@@ -100,7 +100,7 @@ public void shouldResetToNewVGgtid() {
     }
 
     @Test
-    public void shouldGetOrderedTransactionContext() {
+    public void shouldGetVitessTransactionContext() {
         VitessConnectorConfig config = new VitessConnectorConfig(
                 TestHelper.defaultConfig()
                         .with(VitessConnectorConfig.TRANSACTION_CONTEXT, VitessTransactionContext.class)
@@ -113,7 +113,7 @@ public void shouldGetOrderedTransactionContext() {
     }
 
     @Test
-    public void shouldGetInitialOrderedTransactionContext() {
+    public void shouldGetInitialVitessTransactionContext() {
         VitessConnectorConfig config = new VitessConnectorConfig(
                 TestHelper.defaultConfig()
                         .with(VitessConnectorConfig.TRANSACTION_CONTEXT, VitessTransactionContext.class)

diff --git a/src/test/java/io/debezium/connector/vitess/pipeline/txmetadata/VitessEpochProviderTest.java b/src/test/java/io/debezium/connector/vitess/pipeline/txmetadata/VitessEpochProviderTest.java
@@ -21,7 +21,8 @@ public class VitessEpochProviderTest {
     private String txId = prefix + String.join(",", host1Tx2, host2Tx1);
     private String txIdShrunk = prefix + String.join(",", host1Tx2);
 
-    private String txIdUpgrade = "MySQL82/" + String.join(",", host1Tx2);
+    private String txIdVersion5 = "MySQL57/" + String.join(",", host1Tx2);
+    private String txIdVersion8 = "MySQL82/" + String.join(",", host1Tx2);
 
     @Test
     public void testGetEpochSameHostSet() {
@@ -53,9 +54,9 @@ public void testGetEpochDisjointThrowsException() {
     }
 
     @Test
-    public void testGetEpochVersionUpgrade() {
+    public void testVersionUpgradeDoesNotAffectEpoch() {
         VitessEpochProvider provider = new VitessEpochProvider();
-        Long epoch = provider.getEpoch(0L, previousTxId, txIdUpgrade);
-        assertThat(epoch).isEqualTo(1);
+        Long epoch = provider.getEpoch(0L, txIdVersion5, txIdVersion8);
+        assertThat(epoch).isEqualTo(0L);
     }
 }