Use CoreError for messages of RuntimeExceptions in DynamoAdmin (#3007)

Co-authored-by: Josh Wong <[email protected]>

Author: brfrn169

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

@@ -712,6 +712,30 @@ public enum CoreError implements ScalarDbError {
       "Db2 does not support renaming primary key or index key columns",
       "",
       ""),
+  DYNAMO_IMPORT_NOT_SUPPORTED(
+      Category.USER_ERROR,
+      "0223",
+      "Import-related functionality is not supported in DynamoDB",
+      "",
+      ""),
+  DYNAMO_PARTITION_KEY_BLOB_TYPE_NOT_SUPPORTED(
+      Category.USER_ERROR,
+      "0224",
+      "The BLOB type is supported only for the last column in the partition key in DynamoDB. Column: %s",
+      "",
+      ""),
+  DYNAMO_CLUSTERING_KEY_BLOB_TYPE_NOT_SUPPORTED(
+      Category.USER_ERROR,
+      "0225",
+      "The BLOB type is not supported for clustering keys in DynamoDB. Column: %s",
+      "",
+      ""),
+  DYNAMO_INDEX_COLUMN_BOOLEAN_TYPE_NOT_SUPPORTED(
+      Category.USER_ERROR,
+      "0226",
+      "The BOOLEAN type is not supported for index columns in DynamoDB. Column: %s",
+      "",
+      ""),
 
   //
   // Errors for the concurrency error category

core/src/main/java/com/scalar/db/storage/dynamo/DynamoAdmin.java

@@ -336,24 +336,23 @@ private void checkMetadata(TableMetadata metadata) {
       }
       if (metadata.getColumnDataType(partitionKeyName) == DataType.BLOB) {
         throw new IllegalArgumentException(
-            "BLOB type is supported only for the last column in partition key in DynamoDB: "
-                + partitionKeyName);
+            CoreError.DYNAMO_PARTITION_KEY_BLOB_TYPE_NOT_SUPPORTED.buildMessage(partitionKeyName));
       }
     }
 
     for (String clusteringKeyName : metadata.getClusteringKeyNames()) {
       if (metadata.getColumnDataType(clusteringKeyName) == DataType.BLOB) {
         throw new IllegalArgumentException(
-            "Currently, BLOB type is not supported for clustering keys in DynamoDB: "
-                + clusteringKeyName);
+            CoreError.DYNAMO_CLUSTERING_KEY_BLOB_TYPE_NOT_SUPPORTED.buildMessage(
+                clusteringKeyName));
       }
     }
 
     for (String secondaryIndexName : metadata.getSecondaryIndexNames()) {
       if (metadata.getColumnDataType(secondaryIndexName) == DataType.BOOLEAN) {
         throw new IllegalArgumentException(
-            "Currently, BOOLEAN type is not supported for a secondary index in DynamoDB: "
-                + secondaryIndexName);
+            CoreError.DYNAMO_INDEX_COLUMN_BOOLEAN_TYPE_NOT_SUPPORTED.buildMessage(
+                secondaryIndexName));
       }
     }
   }
@@ -951,16 +950,11 @@ public void createIndex(
       throws ExecutionException {
     Namespace namespace = Namespace.of(namespacePrefix, nonPrefixedNamespace);
     TableMetadata metadata = getTableMetadata(nonPrefixedNamespace, table);
-
-    if (metadata == null) {
-      throw new IllegalArgumentException(
-          "The " + getFullTableName(namespace, table) + " table does not exist");
-    }
+    assert metadata != null;
 
     if (metadata.getColumnDataType(columnName) == DataType.BOOLEAN) {
       throw new IllegalArgumentException(
-          "Currently, BOOLEAN type is not supported for a secondary index in DynamoDB: "
-              + columnName);
+          CoreError.DYNAMO_INDEX_COLUMN_BOOLEAN_TYPE_NOT_SUPPORTED.buildMessage(columnName));
     }
 
     long ru = Long.parseLong(options.getOrDefault(REQUEST_UNIT, DEFAULT_REQUEST_UNIT));
@@ -1033,7 +1027,8 @@ columnName, getFullTableName(namespace, table)),
         TableMetadata.newBuilder(tableMetadata).addSecondaryIndex(columnName).build());
   }
 
-  private boolean rawIndexExists(String nonPrefixedNamespace, String table, String indexName) {
+  private boolean rawIndexExists(String nonPrefixedNamespace, String table, String indexName)
+      throws ExecutionException {
     Namespace namespace = Namespace.of(namespacePrefix, nonPrefixedNamespace);
     String globalIndexName =
         String.join(
@@ -1061,7 +1056,7 @@ private boolean rawIndexExists(String nonPrefixedNamespace, String table, String
           return true;
         }
         if (retryCount++ >= MAX_RETRY_COUNT) {
-          throw new IllegalStateException(
+          throw new ExecutionException(
               String.format(
                   "Waiting for the secondary index %s on the %s table to be active failed",
                   indexName, getFullTableName(namespace, table)));
@@ -1459,15 +1454,13 @@ public void renameColumn(
   @Override
   public TableMetadata getImportTableMetadata(
       String namespace, String table, Map<String, DataType> overrideColumnsType) {
-    throw new UnsupportedOperationException(
-        "Import-related functionality is not supported in DynamoDB");
+    throw new UnsupportedOperationException(CoreError.DYNAMO_IMPORT_NOT_SUPPORTED.buildMessage());
   }
 
   @Override
   public void addRawColumnToTable(
       String namespace, String table, String columnName, DataType columnType) {
-    throw new UnsupportedOperationException(
-        "Import-related functionality is not supported in DynamoDB");
+    throw new UnsupportedOperationException(CoreError.DYNAMO_IMPORT_NOT_SUPPORTED.buildMessage());
   }
 
   @Override
@@ -1476,8 +1469,7 @@ public void importTable(
       String table,
       Map<String, String> options,
       Map<String, DataType> overrideColumnsType) {
-    throw new UnsupportedOperationException(
-        "Import-related functionality is not supported in DynamoDB");
+    throw new UnsupportedOperationException(CoreError.DYNAMO_IMPORT_NOT_SUPPORTED.buildMessage());
   }
 
   @Override