List tables command

src/main/java/io/stargate/sgv2/jsonapi/api/model/command/Command.java

@@ -64,6 +64,7 @@ enum CommandName {
     FIND_ONE("findOne"),
     INSERT_MANY("insertMany"),
     INSERT_ONE("insertOne"),
+    LIST_TABLES("listTables"),
     UPDATE_MANY("updateMany"),
     UPDATE_ONE("updateOne"),
     BEGIN_OFFLINE_SESSION("beginOfflineSession"),

src/main/java/io/stargate/sgv2/jsonapi/api/model/command/CommandStatus.java

@@ -26,6 +26,10 @@ public enum CommandStatus {
   /** Status for reporting existing collections. */
   @JsonProperty("collections")
   EXISTING_COLLECTIONS,
+  /** Status for reporting existing collections. */
+  @JsonProperty("tables")
+  EXISTING_TABLES,
+
   /**
    * List of response entries, one for each document we tried to insert with {@code insertMany}
    * command. Each entry has 2 mandatory fields: {@code _id} (document id), and {@code status} (one

src/main/java/io/stargate/sgv2/jsonapi/api/model/command/TableOnlyCommand.java

@@ -4,11 +4,13 @@
 import com.fasterxml.jackson.annotation.JsonTypeInfo;
 import io.stargate.sgv2.jsonapi.api.model.command.impl.CreateTableCommand;
 import io.stargate.sgv2.jsonapi.api.model.command.impl.DropTableCommand;
+import io.stargate.sgv2.jsonapi.api.model.command.impl.ListTablesCommand;
 
 /** Interface for all commands executed against a keyspace. */
 @JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.WRAPPER_OBJECT)
 @JsonSubTypes({
   @JsonSubTypes.Type(value = CreateTableCommand.class),
-  @JsonSubTypes.Type(value = DropTableCommand.class)
+  @JsonSubTypes.Type(value = DropTableCommand.class),
+  @JsonSubTypes.Type(value = ListTablesCommand.class),
 })
 public interface TableOnlyCommand extends KeyspaceCommand {}

src/main/java/io/stargate/sgv2/jsonapi/api/model/command/impl/ListTablesCommand.java

@@ -0,0 +1,23 @@
+package io.stargate.sgv2.jsonapi.api.model.command.impl;
+
+import com.fasterxml.jackson.annotation.JsonTypeName;
+import io.stargate.sgv2.jsonapi.api.model.command.TableOnlyCommand;
+import org.eclipse.microprofile.openapi.annotations.enums.SchemaType;
+import org.eclipse.microprofile.openapi.annotations.media.Schema;
+
+@Schema(description = "Command that lists all available tables in a namespace.")
+@JsonTypeName("listTables")
+public record ListTablesCommand(Options options) implements TableOnlyCommand {
+  public record Options(
+      @Schema(
+              description = "include table properties.",
+              type = SchemaType.BOOLEAN,
+              implementation = Boolean.class)
+          boolean explain) {}
+
+  /** {@inheritDoc} */
+  @Override
+  public CommandName commandName() {
+    return CommandName.LIST_TABLES;
+  }
+}

src/main/java/io/stargate/sgv2/jsonapi/api/model/command/serializer/ColumnDefinitionSerializer.java

@@ -0,0 +1,42 @@
+package io.stargate.sgv2.jsonapi.api.model.command.serializer;
+
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.databind.JsonSerializer;
+import com.fasterxml.jackson.databind.SerializerProvider;
+import io.stargate.sgv2.jsonapi.api.model.command.table.definition.datatype.ColumnType;
+import io.stargate.sgv2.jsonapi.api.model.command.table.definition.datatype.ComplexTypes;
+import java.io.IOException;
+
+/**
+ * Custom serializer to encode the column type to the JSON payload This is required because
+ * composite and custom column types may need additional properties to be serialized
+ */
+public class ColumnDefinitionSerializer extends JsonSerializer<ColumnType> {
+
+  @Override
+  public void serialize(
+      ColumnType columnType, JsonGenerator jsonGenerator, SerializerProvider serializerProvider)
+      throws IOException {
+    jsonGenerator.writeStartObject();
+    jsonGenerator.writeStringField("type", columnType.getApiName());
+    if (columnType instanceof ComplexTypes.MapType mt) {
+      jsonGenerator.writeStringField("keyType", mt.keyTypeName());
+      jsonGenerator.writeStringField("valueType", mt.valueTypeName());
+    } else if (columnType instanceof ComplexTypes.ListType lt) {
+      jsonGenerator.writeStringField("valueType", lt.valueTypeName());
+    } else if (columnType instanceof ComplexTypes.SetType st) {
+      jsonGenerator.writeStringField("valueType", st.valueTypeName());
+    } else if (columnType instanceof ComplexTypes.VectorType vt) {
+      jsonGenerator.writeNumberField("dimension", vt.getDimension());
+      if (vt.getVectorConfig() != null)
+        jsonGenerator.writeObjectField("service", vt.getVectorConfig());
+    } else if (columnType instanceof ComplexTypes.UnsupportedType ut) {
+      jsonGenerator.writeObjectField(
+          "apiSupport", new ApiSupport(false, false, false, ut.cqlFormat()));
+    }
+    jsonGenerator.writeEndObject();
+  }
+
+  public record ApiSupport(
+      boolean createTable, boolean insert, boolean read, String cqlDefinition) {}
+}

src/main/java/io/stargate/sgv2/jsonapi/api/model/command/serializer/OrderingKeysSerializer.java

@@ -0,0 +1,42 @@
+package io.stargate.sgv2.jsonapi.api.model.command.serializer;
+
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.databind.JsonSerializer;
+import com.fasterxml.jackson.databind.SerializerProvider;
+import io.stargate.sgv2.jsonapi.api.model.command.table.definition.PrimaryKey;
+import java.io.IOException;
+
+/**
+ * Custom serializer to encode the column type to the JSON payload This is required because
+ * composite and custom column types may need additional properties to be serialized
+ */
+public class OrderingKeysSerializer extends JsonSerializer<PrimaryKey.OrderingKey[]> {
+
+  @Override
+  public void serialize(
+      PrimaryKey.OrderingKey[] orderingKeys,
+      JsonGenerator jsonGenerator,
+      SerializerProvider serializerProvider)
+      throws IOException {
+    jsonGenerator.writeStartObject();
+    if (orderingKeys != null) {
+      for (PrimaryKey.OrderingKey orderingKey : orderingKeys) {
+        jsonGenerator.writeNumberField(
+            orderingKey.column(), orderingKey.order() == PrimaryKey.OrderingKey.Order.ASC ? 1 : -1);
+      }
+    }
+    jsonGenerator.writeEndObject();
+  }
+
+  /**
+   * This is used when a unsupported type column is present in a table. How to use this class will
+   * evolve as different unsupported types are analyzed.
+   *
+   * @param createTable
+   * @param insert
+   * @param read
+   * @param cqlDefinition
+   */
+  private record ApiSupport(
+      boolean createTable, boolean insert, boolean read, String cqlDefinition) {}
+}

src/main/java/io/stargate/sgv2/jsonapi/api/model/command/table/definition/PrimaryKey.java

@@ -1,8 +1,11 @@
 package io.stargate.sgv2.jsonapi.api.model.command.table.definition;
 
+import com.fasterxml.jackson.annotation.JsonInclude;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
 import io.stargate.sgv2.jsonapi.api.model.command.deserializers.PrimaryKeyDeserializer;
+import io.stargate.sgv2.jsonapi.api.model.command.serializer.OrderingKeysSerializer;
 import jakarta.annotation.Nullable;
 import jakarta.validation.constraints.NotNull;
 import org.eclipse.microprofile.openapi.annotations.enums.SchemaType;
@@ -16,9 +19,15 @@
 //    implementation = Object.class,
 //    description = "Represents the table primary key")
 public record PrimaryKey(
-    @NotNull @Schema(description = "Columns that make the partition keys", type = SchemaType.ARRAY)
+    @NotNull
+        @Schema(description = "Columns that make the partition keys", type = SchemaType.ARRAY)
+        @JsonProperty("partitionBy")
+        @JsonInclude(JsonInclude.Include.NON_NULL)
         String[] keys,
-    @Nullable @Schema(description = "Columns that make the ordering keys", type = SchemaType.ARRAY)
+    @Nullable
+        @Schema(description = "Columns that make the ordering keys", type = SchemaType.ARRAY)
+        @JsonProperty("partitionSort")
+        @JsonSerialize(using = OrderingKeysSerializer.class)
         OrderingKey[] orderingKeys) {
 
   public record OrderingKey(String column, Order order) {

src/main/java/io/stargate/sgv2/jsonapi/api/model/command/table/definition/datatype/ColumnType.java

@@ -1,19 +1,29 @@
 package io.stargate.sgv2.jsonapi.api.model.command.table.definition.datatype;
 
 import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
 import io.stargate.sgv2.jsonapi.api.model.command.deserializers.ColumnDefinitionDeserializer;
 import io.stargate.sgv2.jsonapi.api.model.command.impl.VectorizeConfig;
+import io.stargate.sgv2.jsonapi.api.model.command.serializer.ColumnDefinitionSerializer;
 import io.stargate.sgv2.jsonapi.exception.SchemaException;
 import io.stargate.sgv2.jsonapi.service.schema.tables.ApiDataType;
 import java.util.List;
 import java.util.Map;
 
 /** Interface for column types. This is used to define the type of a column in a table. */
 @JsonDeserialize(using = ColumnDefinitionDeserializer.class)
+@JsonSerialize(using = ColumnDefinitionSerializer.class)
 public interface ColumnType {
   // Returns api data type.
   ApiDataType getApiDataType();
 
+  /*
+  Returns the name of the column type to be used in the API request.
+   */
+  default String getApiName() {
+    return getApiDataType().getApiName();
+  }
+
   static List<String> getSupportedTypes() {
     return List.of(
         "ascii",
@@ -46,42 +56,6 @@ static ColumnType fromString(
     // TODO: the name of the type should be a part of the ColumnType interface, and use a map for
     // the lookup
     switch (type) {
-      case "ascii":
-        return PrimitiveTypes.ASCII;
-      case "bigint":
-        return PrimitiveTypes.BIGINT;
-      case "blob":
-        return PrimitiveTypes.BINARY;
-      case "boolean":
-        return PrimitiveTypes.BOOLEAN;
-      case "date":
-        return PrimitiveTypes.DATE;
-      case "decimal":
-        return PrimitiveTypes.DECIMAL;
-      case "double":
-        return PrimitiveTypes.DOUBLE;
-      case "duration":
-        return PrimitiveTypes.DURATION;
-      case "float":
-        return PrimitiveTypes.FLOAT;
-      case "inet":
-        return PrimitiveTypes.INET;
-      case "int":
-        return PrimitiveTypes.INT;
-      case "smallint":
-        return PrimitiveTypes.SMALLINT;
-      case "text":
-        return PrimitiveTypes.TEXT;
-      case "time":
-        return PrimitiveTypes.TIME;
-      case "timestamp":
-        return PrimitiveTypes.TIMESTAMP;
-      case "tinyint":
-        return PrimitiveTypes.TINYINT;
-      case "uuid":
-        return PrimitiveTypes.UUID;
-      case "varint":
-        return PrimitiveTypes.VARINT;
       case "map":
         {
           if (keyType == null || valueType == null) {
@@ -134,6 +108,10 @@ static ColumnType fromString(
         }
       default:
         {
+          ColumnType columnType = PrimitiveTypes.fromString(type);
+          if (columnType != null) {
+            return columnType;
+          }
           Map<String, String> errorMessageFormattingValues =
               Map.of(
                   "type",

src/main/java/io/stargate/sgv2/jsonapi/api/model/command/table/definition/datatype/ComplexTypes.java

@@ -24,6 +24,14 @@ public ApiDataType getApiDataType() {
           (PrimitiveApiDataType) keyType.getApiDataType(),
           (PrimitiveApiDataType) valueType.getApiDataType());
     }
+
+    public String keyTypeName() {
+      return keyType.getApiDataType().getApiName();
+    }
+
+    public String valueTypeName() {
+      return valueType.getApiDataType().getApiName();
+    }
   }
 
   /** A list type implementation */
@@ -38,6 +46,10 @@ public ListType(ColumnType valueType) {
     public ApiDataType getApiDataType() {
       return new ComplexApiDataType.ListType((PrimitiveApiDataType) valueType.getApiDataType());
     }
+
+    public String valueTypeName() {
+      return valueType.getApiDataType().getApiName();
+    }
   }
 
   /** A set type implementation */
@@ -52,6 +64,10 @@ public SetType(ColumnType valueType) {
     public ApiDataType getApiDataType() {
       return new ComplexApiDataType.SetType((PrimitiveApiDataType) valueType.getApiDataType());
     }
+
+    public String valueTypeName() {
+      return valueType.getApiDataType().getApiName();
+    }
   }
 
   /* Vector type */
@@ -81,4 +97,30 @@ public int getDimension() {
       return vectorSize;
     }
   }
+
+  /**
+   * Unsupported type implementation, returned in response when cql table has unsupported format
+   * column
+   */
+  public static class UnsupportedType implements ColumnType {
+    private final String cqlFormat;
+
+    public UnsupportedType(String cqlFormat) {
+      this.cqlFormat = cqlFormat;
+    }
+
+    @Override
+    public ApiDataType getApiDataType() {
+      throw new UnsupportedOperationException("Unsupported type");
+    }
+
+    @Override
+    public String getApiName() {
+      return "UNSUPPORTED";
+    }
+
+    public String cqlFormat() {
+      return cqlFormat;
+    }
+  }
 }