Add IT for repairCoordinatorTables Coordinator schema upgrade

Verifies that calling repairCoordinatorTables with scalar.db.consensus_commit.coordinator.group_commit.enabled toggled from false to true against an existing pre-group-commit Coordinator table issues ALTER TABLE ADD COLUMN to add the child_ids column.

Author: brfrn169

integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitAdminRepairTableIntegrationTestBase.java

@@ -1,7 +1,14 @@
 package com.scalar.db.transaction.consensuscommit;
 
+import static org.assertj.core.api.Assertions.assertThat;
+
+import com.scalar.db.api.DistributedTransactionAdmin;
 import com.scalar.db.api.DistributedTransactionAdminRepairTableIntegrationTestBase;
+import com.scalar.db.api.TableMetadata;
+import com.scalar.db.config.DatabaseConfig;
+import com.scalar.db.service.TransactionFactory;
 import java.util.Properties;
+import org.junit.jupiter.api.Test;
 
 public abstract class ConsensusCommitAdminRepairTableIntegrationTestBase
     extends DistributedTransactionAdminRepairTableIntegrationTestBase {
@@ -18,4 +25,47 @@ protected final Properties getProperties(String testName) {
   }
 
   protected abstract Properties getProps(String testName);
+
+  @Test
+  public void
+      repairCoordinatorTables_WithExistingCoordinatorMissingChildIdsColumn_ShouldAddChildIdsColumn()
+          throws Exception {
+    // Arrange: drop the Coordinator created in setUp and recreate it via a separate admin
+    // instance that has group commit explicitly disabled, so the Coordinator table has no
+    // CHILD_IDS column.
+    admin.dropCoordinatorTables();
+
+    Properties propertiesWithGroupCommitDisabled = new Properties();
+    propertiesWithGroupCommitDisabled.putAll(getProperties(TEST_NAME));
+    propertiesWithGroupCommitDisabled.setProperty(
+        ConsensusCommitConfig.COORDINATOR_GROUP_COMMIT_ENABLED, "false");
+    try (DistributedTransactionAdmin adminWithGroupCommitDisabled =
+        TransactionFactory.create(propertiesWithGroupCommitDisabled).getTransactionAdmin()) {
+      waitForDifferentSessionDdl();
+      adminWithGroupCommitDisabled.createCoordinatorTables(getCreationOptions());
+    }
+
+    // Act: repair with group commit enabled. The existing Coordinator has no CHILD_IDS column,
+    // so this should add the column via ALTER TABLE ADD COLUMN.
+    Properties propertiesWithGroupCommitEnabled = new Properties();
+    propertiesWithGroupCommitEnabled.putAll(getProperties(TEST_NAME));
+    propertiesWithGroupCommitEnabled.setProperty(
+        ConsensusCommitConfig.COORDINATOR_GROUP_COMMIT_ENABLED, "true");
+    try (DistributedTransactionAdmin adminWithGroupCommitEnabled =
+        TransactionFactory.create(propertiesWithGroupCommitEnabled).getTransactionAdmin()) {
+      waitForDifferentSessionDdl();
+      adminWithGroupCommitEnabled.repairCoordinatorTables(getCreationOptions());
+
+      // Assert: the column now exists in the post-repair Coordinator metadata.
+      waitForDifferentSessionDdl();
+      String coordinatorNamespace =
+          new ConsensusCommitConfig(new DatabaseConfig(propertiesWithGroupCommitEnabled))
+              .getCoordinatorNamespace()
+              .orElse(Coordinator.NAMESPACE);
+      TableMetadata metadata =
+          adminWithGroupCommitEnabled.getTableMetadata(coordinatorNamespace, Coordinator.TABLE);
+      assertThat(metadata).isNotNull();
+      assertThat(metadata.getColumnNames()).contains(Attribute.CHILD_IDS);
+    }
+  }
 }