[#5281] Add owner support to Gravitino CLI

clients/cli/src/main/java/org/apache/gravitino/cli/CommandActions.java

@@ -31,6 +31,9 @@ public class CommandActions {
   public static final String UPDATE = "update";
   public static final String CREATE = "create";
   public static final String DELETE = "delete";
+  public static final String SET = "set";
+  public static final String REMOVE = "remove";
+  public static final String PROPERTIES = "properties";
 
   private static final HashSet<String> VALID_COMMANDS = new HashSet<>();
 
@@ -40,6 +43,9 @@ public class CommandActions {
     VALID_COMMANDS.add(UPDATE);
     VALID_COMMANDS.add(CREATE);
     VALID_COMMANDS.add(DELETE);
+    VALID_COMMANDS.add(SET);
+    VALID_COMMANDS.add(REMOVE);
+    VALID_COMMANDS.add(PROPERTIES);
   }
 
   /**

clients/cli/src/main/java/org/apache/gravitino/cli/CommandEntities.java

@@ -31,6 +31,10 @@ public class CommandEntities {
   public static final String SCHEMA = "schema";
   public static final String TABLE = "table";
   public static final String COLUMN = "column";
+  public static final String USER = "user";
+  public static final String GROUP = "group";
+  public static final String TAG = "tag";
+  public static final String OWNER = "owner";
 
   private static final HashSet<String> VALID_ENTITIES = new HashSet<>();
 
@@ -40,6 +44,10 @@ public class CommandEntities {
     VALID_ENTITIES.add(SCHEMA);
     VALID_ENTITIES.add(TABLE);
     VALID_ENTITIES.add(COLUMN);
+    VALID_ENTITIES.add(USER);
+    VALID_ENTITIES.add(GROUP);
+    VALID_ENTITIES.add(TAG);
+    VALID_ENTITIES.add(OWNER);
   }
 
   /**

clients/cli/src/main/java/org/apache/gravitino/cli/ErrorMessages.java

@@ -23,10 +23,21 @@
 public class ErrorMessages {
   public static final String UNSUPPORTED_COMMAND = "Unsupported or unknown command.";
   public static final String UNKNOWN_ENTITY = "Unknown entity.";
+  public static final String TOO_MANY_ARGUMENTS = "Too many arguments.";
   public static final String UNKNOWN_METALAKE = "Unknown metalake name.";
   public static final String UNKNOWN_CATALOG = "Unknown catalog name.";
   public static final String UNKNOWN_SCHEMA = "Unknown schema name.";
   public static final String UNKNOWN_TABLE = "Unknown table name.";
   public static final String MALFORMED_NAME = "Malformed entity name.";
   public static final String MISSING_NAME = "Missing name.";
+  public static final String METALAKE_EXISTS = "Metalake already exists.";
+  public static final String CATALOG_EXISTS = "Catalog already exists.";
+  public static final String SCHEMA_EXISTS = "Schema already exists.";
+  public static final String UNKNOWN_USER = "Unknown user.";
+  public static final String USER_EXISTS = "User already exists.";
+  public static final String UNKNOWN_GROUP = "Unknown group.";
+  public static final String GROUP_EXISTS = "Group already exists.";
+  public static final String UNKNOWN_TAG = "Unknown tag.";
+  public static final String TAG_EXISTS = "Tag already exists.";
+  public static final String UNKNOWN_ROLE = "Unknown role.";
 }

clients/cli/src/main/java/org/apache/gravitino/cli/FullName.java

@@ -41,11 +41,13 @@ public FullName(CommandLine line) {
 
   /**
    * Retrieves the metalake name from the command line options, the GRAVITINO_METALAKE environment
-   * variable.
+   * variable or the Gravitino config file.
    *
    * @return The metalake name, or null if not found.
    */
   public String getMetalakeName() {
+    GravitinoConfig config = new GravitinoConfig(null);
+
     // If specified on the command line use that
     if (line.hasOption(GravitinoOptions.METALAKE)) {
       return line.getOptionValue(GravitinoOptions.METALAKE);
@@ -60,6 +62,18 @@ public String getMetalakeName() {
     // Check if the metalake name is set as an environment variable
     if (metalakeEnv != null) {
       return metalakeEnv;
+      // Check if the metalake name is specified in the configuration file
+    } else if (config.fileExists()) {
+      config.read();
+      String configName = config.getMetalakeName();
+      if (configName != null) {
+        return configName;
+      }
+    }
+
+    // Extract the metalake name from the full name option
+    if (line.hasOption(GravitinoOptions.NAME)) {
+      return line.getOptionValue(GravitinoOptions.NAME).split("\\.")[0];
     }
 
     return null;
@@ -115,4 +129,59 @@ public String getNamePart(int position) {
     System.err.println(ErrorMessages.MISSING_NAME);
     return null;
   }
+
+  /**
+   * Helper method to determine a specific part of the full name exits.
+   *
+   * @param partNo The part of the name to obtain.
+   * @return True if the part exitsts.
+   */
+  public boolean hasNamePart(int partNo) {
+    /* Extract the name part from the full name if available. */
+    if (line.hasOption(GravitinoOptions.NAME)) {
+      String[] names = line.getOptionValue(GravitinoOptions.NAME).split("\\.");
+      int length = names.length;
+      int position = partNo;
+
+      return position <= length;
+    }
+
+    return false;
+  }
+
+  /**
+   * Does the metalake name exist?
+   *
+   * @return True if the catalog name exists, or false if it does not.
+   */
+  public boolean hasMetalakeName() {
+    return hasNamePart(1);
+  }
+
+  /**
+   * Does the catalog name exist?
+   *
+   * @return True if the catalog name exists, or false if it does not.
+   */
+  public boolean hasCatalogName() {
+    return hasNamePart(2);
+  }
+
+  /**
+   * Does the schema name exist?
+   *
+   * @return True if the schema name exists, or false if it does not.
+   */
+  public boolean hasSchemaName() {
+    return hasNamePart(3);
+  }
+
+  /**
+   * Does the table name exist?
+   *
+   * @return True if the table name exists, or false if it does not.
+   */
+  public boolean hasTableName() {
+    return hasNamePart(4);
+  }
 }