Backport to branch(3) : Add --replication-tables option to the Schema Loader (#2753)

Co-authored-by: Mitsunori Komatsu <[email protected]>

Author: feeblefakie

core/src/main/java/com/scalar/db/api/ReplicationAdmin.java

@@ -2,7 +2,6 @@
 
 import com.scalar.db.common.error.CoreError;
 import com.scalar.db.exception.storage.ExecutionException;
-import java.util.Collections;
 import java.util.Map;
 
 /** An administrative interface for the replication feature. */
@@ -31,10 +30,7 @@ default void createReplicationTables(Map<String, String> options) throws Executi
    */
   default void createReplicationTables(boolean ifNotExist, Map<String, String> options)
       throws ExecutionException {
-    if (ifNotExist && replicationTablesExist()) {
-      return;
-    }
-    createReplicationTables(options);
+    throw new UnsupportedOperationException(CoreError.REPLICATION_NOT_ENABLED.buildMessage());
   }
 
   /**
@@ -48,10 +44,7 @@ default void createReplicationTables(boolean ifNotExist, Map<String, String> opt
    * @throws ExecutionException if the operation fails
    */
   default void createReplicationTables(boolean ifNotExist) throws ExecutionException {
-    if (ifNotExist && replicationTablesExist()) {
-      return;
-    }
-    createReplicationTables(Collections.emptyMap());
+    throw new UnsupportedOperationException(CoreError.REPLICATION_NOT_ENABLED.buildMessage());
   }
 
   /**
@@ -60,7 +53,7 @@ default void createReplicationTables(boolean ifNotExist) throws ExecutionExcepti
    * @throws ExecutionException if the operation fails
    */
   default void createReplicationTables() throws ExecutionException {
-    createReplicationTables(Collections.emptyMap());
+    throw new UnsupportedOperationException(CoreError.REPLICATION_NOT_ENABLED.buildMessage());
   }
 
   /**
@@ -83,10 +76,7 @@ default void dropReplicationTables() throws ExecutionException {
    * @throws ExecutionException if the operation fails
    */
   default void dropReplicationTables(boolean ifExist) throws ExecutionException {
-    if (ifExist && !replicationTablesExist()) {
-      return;
-    }
-    dropReplicationTables();
+    throw new UnsupportedOperationException(CoreError.REPLICATION_NOT_ENABLED.buildMessage());
   }
 
   /**

core/src/main/java/com/scalar/db/common/error/CoreError.java

@@ -861,8 +861,7 @@ public enum CoreError implements ScalarDbError {
   REPLICATION_NOT_ENABLED(
       Category.USER_ERROR,
       "0188",
-      // TODO: Update the message once the licence type is determined.
-      "The replication feature is not enabled. To use this feature, you must enable it",
+      "The replication feature is not enabled. To use this feature, you must enable it. Note that this feature is supported only in the ScalarDB Enterprise edition",
       "",
       ""),
   DATA_LOADER_IMPORT_TARGET_MISSING(

schema-loader/build.gradle

@@ -19,6 +19,7 @@ dependencies {
     implementation "com.google.code.gson:gson:${gsonVersion}"
     implementation "info.picocli:picocli:${picocliVersion}"
     testImplementation "org.junit.jupiter:junit-jupiter-api:${junitVersion}"
+    testImplementation "org.junit.jupiter:junit-jupiter-params:${junitVersion}"
     testRuntimeOnly "org.junit.jupiter:junit-jupiter-engine:${junitVersion}"
     testImplementation "org.assertj:assertj-core:${assertjVersion}"
     testImplementation "org.mockito:mockito-core:${mockitoVersion}"