Fix

Author: brfrn169

core/src/test/java/com/scalar/db/transaction/consensuscommit/CoordinatorTest.java

@@ -68,7 +68,7 @@ public void getState_TransactionIdGiven_ShouldReturnState()
     // Arrange
     Result result = mock(Result.class);
     when(result.getText(Attribute.ID)).thenReturn(ANY_ID_1);
-    when(result.getText(Attribute.CHILD_IDS)).thenReturn(EMPTY_CHILD_IDS);
+    when(result.contains(Attribute.CHILD_IDS)).thenReturn(false);
     when(result.getInt(Attribute.STATE)).thenReturn(TransactionState.COMMITTED.get());
     when(result.getBigInt(Attribute.CREATED_AT)).thenReturn(ANY_TIME_1);
     when(storage.get(any(Get.class))).thenReturn(Optional.of(result));
@@ -112,6 +112,7 @@ public void getStateByParentId_GroupCommitParentIdGiven_ShouldReturnStateUsingIt
 
     Result result = mock(Result.class);
     when(result.getText(Attribute.ID)).thenReturn(parentId);
+    when(result.contains(Attribute.CHILD_IDS)).thenReturn(true);
     when(result.getText(Attribute.CHILD_IDS)).thenReturn(childIdsStr);
     when(result.getInt(Attribute.STATE)).thenReturn(TransactionState.ABORTED.get());
     when(result.getBigInt(Attribute.CREATED_AT)).thenReturn(ANY_TIME_1);
@@ -139,6 +140,7 @@ public void getStateByFullId_GroupCommitFullIdGiven_ShouldReturnStateUsingItPare
 
     Result result = mock(Result.class);
     when(result.getText(Attribute.ID)).thenReturn(fullId);
+    when(result.contains(Attribute.CHILD_IDS)).thenReturn(true);
     when(result.getText(Attribute.CHILD_IDS)).thenReturn(EMPTY_CHILD_IDS);
     when(result.getInt(Attribute.STATE)).thenReturn(TransactionState.ABORTED.get());
     when(result.getBigInt(Attribute.CREATED_AT)).thenReturn(ANY_TIME_1);
@@ -220,6 +222,7 @@ public void getState_WithCoordinatorNamespaceChanged_ShouldGetWithChangedNamespa
 
     Result result = mock(Result.class);
     when(result.getText(Attribute.ID)).thenReturn(ANY_ID_1);
+    when(result.contains(Attribute.CHILD_IDS)).thenReturn(true);
     when(result.getText(Attribute.CHILD_IDS)).thenReturn(EMPTY_CHILD_IDS);
     when(result.getInt(Attribute.STATE)).thenReturn(TransactionState.COMMITTED.get());
     when(result.getBigInt(Attribute.CREATED_AT)).thenReturn(ANY_TIME_1);
@@ -297,6 +300,7 @@ public void getState_TransactionIdForGroupCommitGivenAndParentIdAndChildIdMatch_
 
     Result resultForGroupCommitState = mock(Result.class);
     when(resultForGroupCommitState.getText(Attribute.ID)).thenReturn(parentId);
+    when(resultForGroupCommitState.contains(Attribute.CHILD_IDS)).thenReturn(true);
     when(resultForGroupCommitState.getText(Attribute.CHILD_IDS))
         .thenReturn(Joiner.on(',').join(childIds));
     when(resultForGroupCommitState.getInt(Attribute.STATE)).thenReturn(transactionState.get());
@@ -353,13 +357,15 @@ public void getState_TransactionIdForSingleCommitGivenAndFullIdMatches_ShouldRet
 
     Result resultForGroupCommitState = mock(Result.class);
     when(resultForGroupCommitState.getText(Attribute.ID)).thenReturn(parentId);
+    when(resultForGroupCommitState.contains(Attribute.CHILD_IDS)).thenReturn(true);
     when(resultForGroupCommitState.getText(Attribute.CHILD_IDS))
         .thenReturn(Joiner.on(',').join(dummyChildIds));
     when(resultForGroupCommitState.getInt(Attribute.STATE)).thenReturn(transactionState.get());
     when(resultForGroupCommitState.getBigInt(Attribute.CREATED_AT)).thenReturn(ANY_TIME_1);
 
     Result resultForSingleCommitState = mock(Result.class);
     when(resultForSingleCommitState.getText(Attribute.ID)).thenReturn(fullId);
+    when(resultForSingleCommitState.contains(Attribute.CHILD_IDS)).thenReturn(true);
     when(resultForSingleCommitState.getText(Attribute.CHILD_IDS)).thenReturn(EMPTY_CHILD_IDS);
     when(resultForSingleCommitState.getInt(Attribute.STATE)).thenReturn(transactionState.get());
     when(resultForSingleCommitState.getBigInt(Attribute.CREATED_AT)).thenReturn(ANY_TIME_1);
@@ -410,6 +416,7 @@ public void getState_TransactionIdForGroupCommitGivenAndOnlyParentIdMatches_Shou
 
     Result resultForGroupCommitState = mock(Result.class);
     when(resultForGroupCommitState.getText(Attribute.ID)).thenReturn(parentId);
+    when(resultForGroupCommitState.contains(Attribute.CHILD_IDS)).thenReturn(true);
     when(resultForGroupCommitState.getText(Attribute.CHILD_IDS))
         .thenReturn(Joiner.on(',').join(childIds));
     when(resultForGroupCommitState.getInt(Attribute.STATE)).thenReturn(transactionState.get());
@@ -464,13 +471,15 @@ public void getState_TransactionIdForGroupCommitGivenAndOnlyParentIdMatches_Shou
 
     Result resultForGroupCommitState = mock(Result.class);
     when(resultForGroupCommitState.getText(Attribute.ID)).thenReturn(parentId);
+    when(resultForGroupCommitState.contains(Attribute.CHILD_IDS)).thenReturn(true);
     when(resultForGroupCommitState.getText(Attribute.CHILD_IDS))
         .thenReturn(Joiner.on(',').join(childIds));
     when(resultForGroupCommitState.getInt(Attribute.STATE)).thenReturn(transactionState.get());
     when(resultForGroupCommitState.getBigInt(Attribute.CREATED_AT)).thenReturn(ANY_TIME_1);
 
     Result resultForSingleCommitState = mock(Result.class);
     when(resultForSingleCommitState.getText(Attribute.ID)).thenReturn(targetFullId);
+    when(resultForSingleCommitState.contains(Attribute.CHILD_IDS)).thenReturn(true);
     when(resultForSingleCommitState.getText(Attribute.CHILD_IDS)).thenReturn(EMPTY_CHILD_IDS);
     when(resultForSingleCommitState.getInt(Attribute.STATE)).thenReturn(transactionState.get());
     when(resultForSingleCommitState.getBigInt(Attribute.CREATED_AT)).thenReturn(ANY_TIME_1);
@@ -522,6 +531,7 @@ public void getState_TransactionIdGivenButNoIdMatches_ShouldReturnEmpty(
 
     Result resultForGroupCommitState = mock(Result.class);
     when(resultForGroupCommitState.getText(Attribute.ID)).thenReturn(parentId);
+    when(resultForGroupCommitState.contains(Attribute.CHILD_IDS)).thenReturn(true);
     when(resultForGroupCommitState.getText(Attribute.CHILD_IDS))
         .thenReturn(Joiner.on(',').join(childIds));
     when(resultForGroupCommitState.getInt(Attribute.STATE)).thenReturn(transactionState.get());