[+]add table mock and unit test

kaaass · kaaass · Jan 13, 2021 · Jan 1, 2021 · Jan 1, 2021 · Jan 1, 2021
commit eb3d19c928d751f8a8da4d1ba642e743560f9b59
diff --git a/README.md b/README.md
@@ -9,8 +9,8 @@ Java构建的高性能SQL关系型数据库。
 | **模块**                | **内容**             | **负责人** | **包**       |
 | ----------------------- | -------------------- | ---------- | ------------ |
 | Query Parse Module      | SQL 语句解析         | @KAAAsS    | parse       |
-| Query Execution Module  | 查询执行、优化       |            | query       |
-| Table Management Module | 系统内数据库、表管理 |            | table       |
+| Query Execution Module  | 查询执行、优化       | @KveinAxel  | query       |
+| Table Management Module | 系统内数据库、表管理 |  @KveinAxel  | table       |
 | Indexing Module         | 索引结构，使用 B+ 树 |            | index       |
 | Record Module           | 记录管理，实现 MVCC  | @KAAAsS    | record      |
 | Transaction Module      | 实现事务的管理与 2PL |            | transaction |

diff --git a/src/main/java/net/kaaass/rumbase/table/Entry.java b/src/main/java/net/kaaass/rumbase/table/Entry.java
@@ -0,0 +1,13 @@
+package net.kaaass.rumbase.table;
+
+import java.util.*;
+
+/**
+ * 一行记录数据
+ * <p>
+ * 代表表中的一行数据
+ *
+ * @author @KveinAxel
+ */
+public class Entry extends HashMap<String, FieldValue> {
+}
diff --git a/src/main/java/net/kaaass/rumbase/table/FieldType.java b/src/main/java/net/kaaass/rumbase/table/FieldType.java
@@ -0,0 +1,13 @@
+package net.kaaass.rumbase.table;
+
+public enum FieldType {
+    INT,
+    FLOAT;
+
+    public int getSize() {
+        return switch (this) {
+            case INT -> 4;
+            case FLOAT -> 4;
+        };
+    }
+}
diff --git a/src/main/java/net/kaaass/rumbase/table/FieldValue.java b/src/main/java/net/kaaass/rumbase/table/FieldValue.java
@@ -0,0 +1,57 @@
+package net.kaaass.rumbase.table;
+
+public class FieldValue<T> implements Comparable {
+    private T value;
+    private FieldType type;
+
+    public T getValue() {
+        return value;
+    }
+
+    public void setValue(T value) {
+        this.value = value;
+    }
+
+    public FieldType getType() {
+        return type;
+    }
+
+    public void setType(FieldType type) {
+        this.type = type;
+    }
+
+    public FieldValue(FieldType type) {
+        this.type = type;
+    }
+
+    public FieldValue(T value, FieldType type) {
+        this.value = value;
+        this.type = type;
+    }
+
+
+    @Override
+    public int compareTo(Object o) {
+        if (o instanceof FieldValue) {
+            var another = (FieldValue) o;
+            if (this.type != another.type) {
+                return 0;
+            } else {
+                return switch (this.type) {
+                    case INT -> (int) this.getValue() - (int) another.getValue();
+                    case FLOAT -> {
+                        var res = (float) this.getValue() - (float) another.getValue();
+                        if (res < 0)
+                            yield -1;
+                        else if (res == 0)
+                            yield 0;
+                        else
+                            yield 1;
+                    }
+                };
+            }
+        } else {
+            return 0;
+        }
+    }
+}
diff --git a/src/main/java/net/kaaass/rumbase/table/IField.java b/src/main/java/net/kaaass/rumbase/table/IField.java
@@ -0,0 +1,100 @@
+package net.kaaass.rumbase.table;
+
+import java.util.List;
+import java.util.Optional;
+import java.util.UUID;
+
+/**
+ * 字段结构
+ * <p>
+ * 提供字段解析服务
+ * <p>
+ * 提供字段的索引处理
+ *
+ * @author @KveinAxel
+ */
+public interface IField {
+
+    /**
+     * 从配置信息的字节数组获取字段的属性
+     *
+     * @param raw 配置信息
+     */
+    void parseSelf(byte[] raw);
+
+    /**
+     * 将自身的配置信息持久化成字节数组
+     *
+     * @return 配置信息
+     */
+    byte[] persistSelf();
+
+    /**
+     * 是否已经被建立引用
+     * @return true则已经建立引用，反之没建立
+     */
+    Boolean isIndexed();
+
+    /**
+     * 获取字段的类型
+     *
+     * @return 字段类型
+     */
+    FieldType getType();
+
+    /**
+     * 字段所占用的字节数
+     *
+     * @return 字节数
+     */
+    int getSize();
+
+    /**
+     * 在该字段的索引上进行范围搜索
+     *
+     * @param left 查询左端点
+     * @param right 查询右端点
+     * @return 查询到的uuid
+     */
+    List<UUID> searchRange(FieldValue left, FieldValue right);
+
+    /**
+     * 在该字段的索引上进行单点搜索
+     *
+     * @param value 字段的值
+     * @return 字段的uuid的Optional
+     */
+    Optional<UUID> search(FieldValue value);
+
+    /**
+     * 将字符串转换成字段值
+     *
+     * @param valStr 字符串
+     * @return 字段值的Optional
+     */
+    Optional<FieldValue> strToValue(String valStr);
+
+    /**
+     * 将字段值转成字节数组
+     *
+     * @param value 字段值
+     * @return 字节数组
+     */
+    Optional<byte[]> valueToRaw(FieldValue value);
+
+    /**
+     * 将字节数组转成字段值
+     *
+     * @param raw 字节数组
+     * @return 字段值
+     */
+    Optional<FieldValue> rawToValue(byte[] raw) ;
+
+    /**
+     * 获取字段名
+     *
+     * @return 字段名
+     */
+    String getFieldName();
+
+}
diff --git a/src/main/java/net/kaaass/rumbase/table/ITable.java b/src/main/java/net/kaaass/rumbase/table/ITable.java
@@ -0,0 +1,115 @@
+package net.kaaass.rumbase.table;
+
+import net.kaaass.rumbase.record.IRecordStorage;
+import net.kaaass.rumbase.table.exception.TableNotFoundException;
+import net.kaaass.rumbase.table.exception.TypeIncompatibleException;
+import net.kaaass.rumbase.transaction.TransactionContext;
+
+import java.util.List;
+import java.util.Optional;
+import java.util.UUID;
+
+/**
+ * 表结构
+ * <p>
+ * 验证数据是否满足表约束
+ * <p>
+ * 提供行数据解析服务
+ *
+ * @author @KveinAxel
+ */
+public interface ITable {
+
+    /**
+     * 根据配置信息解析获取表属性
+     * @param raw 配置信息
+     */
+    void parseSelf(byte[] raw);
+
+    /**
+     * 将自己持久化成字节数组
+     */
+    byte[] persistSelf();
+
+    /**
+     * 删除元组
+     *
+     * @param context 事务context
+     * @param fieldName 字段名
+     * @param uuid 元组的uuid
+     * @param recordStorage record层访问接口
+     * @return 被删除的元组数
+     */
+    int delete(TransactionContext context, String fieldName, UUID uuid, IRecordStorage recordStorage);
+
+    /**
+     * 更新元组
+     *
+     * @param context 事务context
+     * @param fieldName 字段名
+     * @param uuid 元组的uuid
+     * @param newEntry 新的元组
+     * @return 被更新的元组数
+     */
+    int update(TransactionContext context, String fieldName, UUID uuid, Entry newEntry);
+
+    /**
+     * 获取元组内容
+     *
+     * @param context 事务context
+     * @param fieldName 字段名
+     * @param uuids 元组的uuid列表
+     * @param recordStorage record层访问接口
+     * @return 元组entry列表
+     * @throws TableNotFoundException 要查询的表不存在
+     */
+    List<Entry> read(TransactionContext context, String fieldName, List<UUID> uuids, IRecordStorage recordStorage) throws TableNotFoundException;
+
+    /**
+     * 向表插入元组
+     *
+     * @param context 事务context
+     * @param fieldName 字段名
+     * @param newEntry 新的元组
+     * @param recordStorage record层访问接口
+     * @throws TableNotFoundException 要查询的表不存在
+     * @throws TypeIncompatibleException 插入的元组不满足表约束
+     */
+    void insert(TransactionContext context, String fieldName, Entry newEntry, IRecordStorage recordStorage) throws TableNotFoundException, TypeIncompatibleException;
+
+    /**
+     *
+     *
+     * @param fieldName 字段名
+     * @param left 查询区间左端点
+     * @param right 查询区间右端点
+     * @return 查询到的uuid列表
+     * @throws TableNotFoundException 要查询的表不存在
+     */
+    List<UUID> search(String fieldName, FieldValue left, FieldValue right) throws TableNotFoundException;
+
+    /**
+     * 将字符串列表转换成一个元组
+     *
+     * @param values 字符串列表
+     * @return 元组的Optional
+     */
+    Optional<Entry> strToEntry(List<String> values);
+
+    /**
+     * 将entry转换成字节数组
+     *
+     * @param entry 元组
+     * @return 字节数组
+     */
+    Optional<byte[]> entryToRaw(Entry entry);
+
+    /**
+     * 将字节数组转换成entry
+     *
+     * @param raw 字节数组
+     * @return 元组
+     */
+    Optional<Entry> parseEntry(byte[] raw);
+
+}