fixup

Author: w41ter

fe/fe-core/src/test/java/org/apache/doris/journal/bdbje/BDBEnvironmentTest.java

@@ -153,7 +153,7 @@ public void testSetup() throws Exception {
         Assertions.assertEquals(OperationStatus.SUCCESS, db.put(null, key, value));
 
         DatabaseEntry readValue = new DatabaseEntry();
-        Assertions.assertEquals(OperationStatus.SUCCESS, db.get(null, key, readValue, LockMode.READ_COMMITTED));
+        Assertions.assertEquals(OperationStatus.SUCCESS, db.get(null, key, readValue, LockMode.DEFAULT));
         Assertions.assertEquals(new String(value.getData()), new String(readValue.getData()));
 
         // Remove database
@@ -174,7 +174,7 @@ public void testSetup() throws Exception {
         Database epochDb = bdbEnvironment.getEpochDB();
         Assertions.assertEquals(OperationStatus.SUCCESS, epochDb.put(null, key, value));
         DatabaseEntry readValue2 = new DatabaseEntry();
-        Assertions.assertEquals(OperationStatus.SUCCESS, epochDb.get(null, key, readValue2, LockMode.READ_COMMITTED));
+        Assertions.assertEquals(OperationStatus.SUCCESS, epochDb.get(null, key, readValue2, LockMode.DEFAULT));
         Assertions.assertEquals(new String(value.getData()), new String(readValue2.getData()));
 
         new MockUp<Env>() {
@@ -244,7 +244,7 @@ public void testMetadataRecovery() throws Exception {
         Assertions.assertEquals(OperationStatus.SUCCESS, db.put(null, key, value));
 
         DatabaseEntry readValue = new DatabaseEntry();
-        Assertions.assertEquals(OperationStatus.SUCCESS, db.get(null, key, readValue, LockMode.READ_COMMITTED));
+        Assertions.assertEquals(OperationStatus.SUCCESS, db.get(null, key, readValue, LockMode.DEFAULT));
         Assertions.assertEquals(new String(value.getData()), new String(readValue.getData()));
         bdbEnvironment.close();
 
@@ -254,7 +254,7 @@ public void testMetadataRecovery() throws Exception {
         Database db2 = bdbEnvironment2.openDatabase(dbName);
 
         DatabaseEntry readValue2 = new DatabaseEntry();
-        Assertions.assertEquals(OperationStatus.SUCCESS, db2.get(null, key, readValue2, LockMode.READ_COMMITTED));
+        Assertions.assertEquals(OperationStatus.SUCCESS, db2.get(null, key, readValue2, LockMode.DEFAULT));
         Assertions.assertEquals(new String(value.getData()), new String(readValue2.getData()));
         bdbEnvironment2.close();
     }
@@ -278,15 +278,15 @@ public void testOpenReplicatedEnvironmentTwice() throws Exception {
         Assertions.assertEquals(OperationStatus.SUCCESS, db.put(null, key, value));
 
         DatabaseEntry readValue = new DatabaseEntry();
-        Assertions.assertEquals(OperationStatus.SUCCESS, db.get(null, key, readValue, LockMode.READ_COMMITTED));
+        Assertions.assertEquals(OperationStatus.SUCCESS, db.get(null, key, readValue, LockMode.DEFAULT));
         Assertions.assertEquals(new String(value.getData()), new String(readValue.getData()));
         bdbEnvironment.close();
 
         bdbEnvironment.openReplicatedEnvironment(homeFile);
         bdbEnvironment.openReplicatedEnvironment(homeFile);
         Database db2 = bdbEnvironment.openDatabase(dbName);
         DatabaseEntry readValue2 = new DatabaseEntry();
-        Assertions.assertEquals(OperationStatus.SUCCESS, db2.get(null, key, readValue2, LockMode.READ_COMMITTED));
+        Assertions.assertEquals(OperationStatus.SUCCESS, db2.get(null, key, readValue2, LockMode.DEFAULT));
         Assertions.assertEquals(new String(value.getData()), new String(readValue2.getData()));
         bdbEnvironment.close();
     }
@@ -324,9 +324,9 @@ public void testTruncateJournalsGreaterThan() throws Exception {
         Database db11AfterTruncate = bdbEnvironment.openDatabase("11");
         Assertions.assertEquals(7, db11AfterTruncate.count());
         Assertions.assertEquals(OperationStatus.NOTFOUND,
-                db11AfterTruncate.get(null, longToEntry(18), new DatabaseEntry(), LockMode.READ_COMMITTED));
+                db11AfterTruncate.get(null, longToEntry(18), new DatabaseEntry(), LockMode.DEFAULT));
         Assertions.assertEquals(OperationStatus.SUCCESS,
-                db11AfterTruncate.get(null, longToEntry(17), new DatabaseEntry(), LockMode.READ_COMMITTED));
+                db11AfterTruncate.get(null, longToEntry(17), new DatabaseEntry(), LockMode.DEFAULT));
         bdbEnvironment.close();
     }
 
@@ -405,14 +405,14 @@ public void testCluster() throws Exception {
             Assertions.assertEquals(1, followerEnvironment.getDatabaseNames().size());
             Database followerDb = followerEnvironment.openDatabase(dbName);
             DatabaseEntry readValue = new DatabaseEntry();
-            Assertions.assertEquals(OperationStatus.SUCCESS, followerDb.get(null, key, readValue, LockMode.READ_COMMITTED));
+            Assertions.assertEquals(OperationStatus.SUCCESS, followerDb.get(null, key, readValue, LockMode.DEFAULT));
             Assertions.assertEquals(new String(value.getData()), new String(readValue.getData()));
         }
 
         Assertions.assertEquals(1, observerEnvironment.getDatabaseNames().size());
         Database observerDb = observerEnvironment.openDatabase(dbName);
         DatabaseEntry readValue = new DatabaseEntry();
-        Assertions.assertEquals(OperationStatus.SUCCESS, observerDb.get(null, key, readValue, LockMode.READ_COMMITTED));
+        Assertions.assertEquals(OperationStatus.SUCCESS, observerDb.get(null, key, readValue, LockMode.DEFAULT));
         Assertions.assertEquals(new String(value.getData()), new String(readValue.getData()));
 
         observerEnvironment.close();
@@ -519,7 +519,7 @@ public void testRollbackException() throws Exception {
             Assertions.assertEquals(1, entryPair.first.getDatabaseNames().size());
             Database followerDb = entryPair.first.openDatabase(beginDbName);
             DatabaseEntry readValue = new DatabaseEntry();
-            Assertions.assertEquals(OperationStatus.SUCCESS, followerDb.get(null, key, readValue, LockMode.READ_COMMITTED));
+            Assertions.assertEquals(OperationStatus.SUCCESS, followerDb.get(null, key, readValue, LockMode.DEFAULT));
             Assertions.assertEquals(new String(value.getData()), new String(readValue.getData()));
             followerDb.close();
         }
@@ -688,7 +688,7 @@ public void testReadTxnIsNotMatched() throws Exception {
             Assertions.assertEquals(1, entryPair.first.getDatabaseNames().size());
             Database followerDb = entryPair.first.openDatabase(beginDbName);
             DatabaseEntry readValue = new DatabaseEntry();
-            Assertions.assertEquals(OperationStatus.SUCCESS, followerDb.get(null, key, readValue, LockMode.READ_COMMITTED));
+            Assertions.assertEquals(OperationStatus.SUCCESS, followerDb.get(null, key, readValue, LockMode.DEFAULT));
             Assertions.assertEquals(new String(value.getData()), new String(readValue.getData()));
         }
 
@@ -737,6 +737,6 @@ public void testReadTxnIsNotMatched() throws Exception {
 
         key = new DatabaseEntry(new byte[]{1, 2, 3});
         DatabaseEntry readValue = new DatabaseEntry();
-        Assertions.assertEquals(OperationStatus.SUCCESS, masterDb.get(null, key, readValue, LockMode.READ_COMMITTED));
+        Assertions.assertEquals(OperationStatus.SUCCESS, masterDb.get(null, key, readValue, LockMode.DEFAULT));
     }
 }