添加文件元数据对象

src/main/java/cn/reghao/dfs/store/oss/db/mapper/DataBlockMapper.java

@@ -0,0 +1,16 @@
+package cn.reghao.dfs.store.oss.db.mapper;
+
+import cn.reghao.dfs.store.oss.model.DataBlock;
+import cn.reghao.jutil.jdk.db.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+import java.util.List;
+
+/**
+ * @author reghao
+ * @date 2022-11-24 11:11:24
+ */
+@Mapper
+public interface DataBlockMapper extends BaseMapper<DataBlock> {
+    List<DataBlock> findByObjectId(String objectId);
+}

src/main/java/cn/reghao/dfs/store/oss/db/mapper/FileMetaMapper.java

@@ -0,0 +1,14 @@
+package cn.reghao.dfs.store.oss.db.mapper;
+
+import cn.reghao.dfs.store.oss.model.FileMeta;
+import cn.reghao.jutil.jdk.db.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @author reghao
+ * @date 2022-11-24 11:11:06
+ */
+@Mapper
+public interface FileMetaMapper extends BaseMapper<FileMeta> {
+    FileMeta findByObjectName(String objectName);
+}

src/main/java/cn/reghao/dfs/store/oss/model/DataBlock.java

@@ -0,0 +1,20 @@
+package cn.reghao.dfs.store.oss.model;
+
+import cn.reghao.jutil.jdk.db.BaseObject;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+/**
+ * @author reghao
+ * @date 2022-11-24 10:25:18
+ */
+@NoArgsConstructor
+@AllArgsConstructor
+@Getter
+public class DataBlock extends BaseObject<Integer> {
+    private String objectId;
+    private int index;
+    private String blockId;
+    //private long size;
+}

src/main/java/cn/reghao/dfs/store/oss/model/FileBlock.java

@@ -0,0 +1,17 @@
+package cn.reghao.dfs.store.oss.model;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+import java.util.List;
+
+/**
+ * @author reghao
+ * @date 2022-11-24 10:25:52
+ */
+@AllArgsConstructor
+@Getter
+public class FileBlock {
+    private String objectId;
+    private List<DataBlock> dataBlocks;
+}

src/main/java/cn/reghao/dfs/store/oss/model/FileMeta.java

@@ -1,9 +1,9 @@
 package cn.reghao.dfs.store.oss.model;
 
+import cn.reghao.jutil.jdk.db.BaseObject;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
-
-import java.io.Serializable;
+import lombok.NoArgsConstructor;
 
 /**
  * 文件元数据
@@ -11,13 +11,13 @@ import java.io.Serializable;
  * @author reghao
  * @date 2022-11-21 10:53:10
  */
+@NoArgsConstructor
 @AllArgsConstructor
 @Getter
-public class FileMeta implements Serializable {
-    private static final long serialVersionUID = 1L;
-
+public class FileMeta extends BaseObject<Integer> {
     private String objectName;
+    private String objectId;
     private long size;
-    private String absolutePath;
     private String contentType;
+    private String sha256sum;
 }

src/main/resources/mapper/oss/DataBlockMapper.xml

@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="cn.reghao.dfs.store.oss.db.mapper.DataBlockMapper">
+    <insert id="save" useGeneratedKeys="true" keyProperty="id">
+        insert into data_block
+        (`id`,`deleted`,`create_time`,`update_time`,`object_id`,`index`,`block_id`)
+        values 
+        (#{id},#{deleted},#{createTime},#{updateTime},#{objectId},#{index},#{blockId})
+    </insert>
+    <insert id="saveAll" useGeneratedKeys="true" keyProperty="id">
+        insert into data_block
+        (`id`,`deleted`,`create_time`,`update_time`,`object_id`,`index`,`block_id`)
+        values
+        <foreach collection="list" item="item" index="index" separator=",">
+            (#{item.id},#{item.deleted},#{item.createTime},#{item.updateTime},#{item.objectId},#{item.index},#{item.blockId})
+        </foreach>
+    </insert>
+
+    <select id="findByObjectId" resultType="cn.reghao.dfs.store.oss.model.DataBlock">
+        select * from data_block
+        where object_id=#{objectId}
+    </select>
+</mapper>

src/main/resources/mapper/oss/FileMetaMapper.xml

@@ -0,0 +1,16 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="cn.reghao.dfs.store.oss.db.mapper.FileMetaMapper">
+    <insert id="save" useGeneratedKeys="true" keyProperty="id">
+        insert into file_meta
+        (`id`,`deleted`,`create_time`,`update_time`,`object_name`,`object_id`,`size`,`content_type`,`sha256sum`)
+        values 
+        (#{id},#{deleted},#{createTime},#{updateTime},#{objectName},#{objectId},#{size},#{contentType},#{sha256sum})
+    </insert>
+
+    <select id="findByObjectName" resultType="cn.reghao.dfs.store.oss.model.FileMeta">
+        select * from file_meta
+        where object_name=#{objectName}
+    </select>
+</mapper>