Add Control file module files and validation

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

@@ -719,6 +719,50 @@ public enum CoreError implements ScalarDbError {
       "",
       ""),
 
+  DATA_LOADER_DUPLICATE_DATA_MAPPINGS(
+      Category.USER_ERROR,
+      "0158",
+      "Duplicate data mappings found for table '%s' in the control file",
+      "",
+      ""),
+  DATA_LOADER_MISSING_COLUMN_MAPPING(
+      Category.USER_ERROR,
+      "0159",
+      "No mapping found for column '%s' in table '%s' in the control file. \\nControl file validation set at 'FULL'. All columns need to be mapped.",
+      "",
+      ""),
+  DATA_LOADER_CONTROL_FILE_MISSING_DATA_MAPPINGS(
+      Category.USER_ERROR, "0160", "The control file is missing data mappings", "", ""),
+  DATA_LOADER__MISSING_NAMESPACE_OR_TABLE(
+      Category.USER_ERROR,
+      "0161",
+      "The provided namespace '%s' and/or table name '%s' is incorrect and could not be found",
+      "",
+      ""),
+  DATA_LOADER_TARGET_COLUMN_NOT_FOUND(
+      Category.USER_ERROR,
+      "0162",
+      "The target column '%s' for source field '%s' could not be found in table '%s'",
+      "",
+      ""),
+  DATA_LOADER_MISSING_PARTITION_KEY(
+      Category.USER_ERROR,
+      "0163",
+      "The required partition key '%s' is missing in the control file mapping for table '%s'",
+      "",
+      ""),
+  DATA_LOADER_MISSING_CLUSTERING_KEY(
+      Category.USER_ERROR,
+      "0164",
+      "The required clustering key '%s' is missing in the control file mapping for table '%s'",
+      "",
+      ""),
+  DATA_LOADER_MULTIPLE_MAPPINGS_FOR_COLUMN_FOUND(
+      Category.USER_ERROR,
+      "0165",
+      "Multiple data mappings found for column '%s' in table '%s'",
+      "",
+      ""),
   //
   // Errors for the concurrency error category
   //
@@ -969,6 +1013,18 @@ public enum CoreError implements ScalarDbError {
       "Handling the before-preparation snapshot hook failed. Details: %s",
       "",
       ""),
+  DATA_LOADER_ERROR_CRUD_EXCEPTION(
+      Category.INTERNAL_ERROR,
+      "0047",
+      "Something went wrong while trying to save the data. Details %s",
+      "",
+      ""),
+  DATA_LOADER_ERROR_SCAN(
+      Category.INTERNAL_ERROR,
+      "0048",
+      "Something went wrong while scanning. Are you sure you are running in the correct transaction mode? Details %s",
+      "",
+      ""),
 
   //
   // Errors for the unknown transaction status error category

data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/controlfile/ControlFile.java

@@ -0,0 +1,27 @@
+package com.scalar.db.dataloader.core.dataimport.controlfile;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import java.util.ArrayList;
+import java.util.List;
+import lombok.Getter;
+import lombok.Setter;
+
+/** Represents the control file */
+@Getter
+@Setter
+public class ControlFile {
+
+  @JsonProperty("tables")
+  private final List<ControlFileTable> tables;
+
+  /** Class constructor */
+  public ControlFile() {
+    this.tables = new ArrayList<>();
+  }
+
+  @JsonCreator
+  public ControlFile(@JsonProperty("tables") List<ControlFileTable> tables) {
+    this.tables = tables;
+  }
+}

data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/controlfile/ControlFileTable.java

@@ -0,0 +1,64 @@
+package com.scalar.db.dataloader.core.dataimport.controlfile;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import java.util.ArrayList;
+import java.util.List;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * Represents the configuration for a single table in the control file, including its namespace,
+ * table name, and field mappings. This class is used to define how data from a control file maps to
+ * a specific table in ScalarDB.
+ */
+@Getter
+@Setter
+public class ControlFileTable {
+
+  /** The namespace of the table in ScalarDB. */
+  @JsonProperty("namespace")
+  private String namespace;
+
+  /** The name of the table in ScalarDB. */
+  @JsonProperty("table_name")
+  private String tableName;
+
+  /**
+   * A list of mappings defining the correspondence between control file fields and table columns.
+   */
+  @JsonProperty("mappings")
+  private final List<ControlFileTableFieldMapping> mappings;
+
+  /**
+   * Creates a new {@code ControlFileTable} instance with the specified namespace and table name.
+   * The mappings list is initialized as an empty list.
+   *
+   * @param namespace The namespace of the table in ScalarDB.
+   * @param tableName The name of the table in ScalarDB.
+   */
+  public ControlFileTable(String namespace, String tableName) {
+    this.namespace = namespace;
+    this.tableName = tableName;
+    this.mappings = new ArrayList<>();
+  }
+
+  /**
+   * Constructs a {@code ControlFileTable} instance using data from a serialized JSON object. This
+   * constructor is used for deserialization of API requests or control files.
+   *
+   * @param namespace The namespace of the table in ScalarDB.
+   * @param tableName The name of the table in ScalarDB.
+   * @param mappings A list of mappings that define the relationship between control file fields and
+   *     table columns.
+   */
+  @JsonCreator
+  public ControlFileTable(
+      @JsonProperty("namespace") String namespace,
+      @JsonProperty("table_name") String tableName,
+      @JsonProperty("mappings") List<ControlFileTableFieldMapping> mappings) {
+    this.namespace = namespace;
+    this.tableName = tableName;
+    this.mappings = mappings;
+  }
+}

data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/controlfile/ControlFileTableFieldMapping.java

@@ -0,0 +1,39 @@
+package com.scalar.db.dataloader.core.dataimport.controlfile;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * Represents the mapping of a single field in the control file to a column in a ScalarDB table.
+ * This class defines how data from a specific field in the input source should be mapped to the
+ * corresponding column in the database.
+ */
+@Getter
+@Setter
+public class ControlFileTableFieldMapping {
+
+  /** The name of the field in the input source (e.g., JSON or CSV). */
+  @JsonProperty("source_field")
+  private String sourceField;
+
+  /** The name of the column in the ScalarDB table that the field maps to. */
+  @JsonProperty("target_column")
+  private String targetColumn;
+
+  /**
+   * Constructs a {@code ControlFileTableFieldMapping} instance using data from a serialized JSON
+   * object. This constructor is primarily used for deserialization of control file mappings.
+   *
+   * @param sourceField The name of the field in the input source (e.g., JSON or CSV).
+   * @param targetColumn The name of the corresponding column in the ScalarDB table.
+   */
+  @JsonCreator
+  public ControlFileTableFieldMapping(
+      @JsonProperty("source_field") String sourceField,
+      @JsonProperty("target_column") String targetColumn) {
+    this.sourceField = sourceField;
+    this.targetColumn = targetColumn;
+  }
+}

data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/controlfile/ControlFileValidationException.java

@@ -0,0 +1,14 @@
+package com.scalar.db.dataloader.core.dataimport.controlfile;
+
+/** Represents the control file */
+public class ControlFileValidationException extends Exception {
+
+  /**
+   * Class constructor
+   *
+   * @param message error message
+   */
+  public ControlFileValidationException(String message) {
+    super(message);
+  }
+}