格式化代码

kaaass · kaaass · Jan 13, 2021 · Jan 1, 2021 · Jan 1, 2021 · Jan 1, 2021
commit 795ecef0d0ca184402782c96d86af34dd01d14e3
diff --git a/src/main/java/net/kaaass/rumbase/dataitem/IItemStorage.java b/src/main/java/net/kaaass/rumbase/dataitem/IItemStorage.java
@@ -23,14 +23,14 @@ public interface IItemStorage {
      * <p>
      * 如果数据项已经存在，就将数据更新在已存在的数据项所在空间上；
      * 如果数据项不存在，则以此UUID插入数据项
-     *</p>
+     * </p>
+     *
      * @param item 数据项
      * @param uuid 编号
      */
     void insertItemWithUuid(byte[] item, long uuid);
 
     /**
-     *
      * 通过UUID查询数据项
      *
      * @param uuid 编号
@@ -40,7 +40,6 @@ public interface IItemStorage {
     byte[] queryItemByUuid(long uuid) throws UUIDException;
 
 
-
     /**
      * 列出页中所有的记录
      *
@@ -51,6 +50,7 @@ public interface IItemStorage {
 
     /**
      * 根据UUID更新数据项
+     *
      * @param uuid 编号
      * @param item 数据项
      * @throws UUIDException 没有找到对应UUID的异常

diff --git a/src/main/java/net/kaaass/rumbase/dataitem/exception/FileException.java b/src/main/java/net/kaaass/rumbase/dataitem/exception/FileException.java
@@ -6,7 +6,8 @@
 import java.util.Map;
 
 /**
- *  在创建、打开数据库时
+ * 在创建、打开数据库时
+ *
  * @author kaito
  */
 public class FileException extends RumbaseException {

diff --git a/src/main/java/net/kaaass/rumbase/dataitem/exception/UUIDException.java b/src/main/java/net/kaaass/rumbase/dataitem/exception/UUIDException.java
@@ -6,8 +6,9 @@
 import java.util.Map;
 
 /**
- *  关于Uuid的相关错误
- * @author  kaito
+ * 关于Uuid的相关错误
+ *
+ * @author kaito
  */
 public class UUIDException extends RumbaseException {
 

diff --git a/src/main/java/net/kaaass/rumbase/dataitem/mock/MockItemStorage.java b/src/main/java/net/kaaass/rumbase/dataitem/mock/MockItemStorage.java
@@ -30,16 +30,16 @@ public class MockItemStorage implements IItemStorage {
      */
     private Map<Long, byte[]> maps;
     /**
-     *  模拟的文件头信息
+     * 模拟的文件头信息
      */
     private byte[] meta;
 
     /**
      * 模拟的构造函数
      *
-     * @param fileName 文件名
+     * @param fileName     文件名
      * @param tempFreePage 当前第一个空闲页号
-     * @param headerUuid 头信息对应UUID
+     * @param headerUuid   头信息对应UUID
      */
     public MockItemStorage(String fileName, int tempFreePage, long headerUuid) {
         this.fileName = fileName;
@@ -68,7 +68,7 @@ public static IItemStorage ofFile(String fileName) {
     /**
      * 新建数据库，并写入表头
      *
-     * @param fileName 文件名
+     * @param fileName    文件名
      * @param tableHeader 表头信息
      * @return 返回数据项管理器
      */
@@ -87,15 +87,15 @@ public long insertItem(byte[] item) {
     }
 
     @Override
-    public void insertItemWithUuid(byte[] item, long uuid){
-        maps.put(uuid,item);
+    public void insertItemWithUuid(byte[] item, long uuid) {
+        maps.put(uuid, item);
     }
 
     @Override
     public byte[] queryItemByUuid(long uuid) throws UUIDException {
-        if (maps.containsKey(uuid)){
+        if (maps.containsKey(uuid)) {
             return maps.get(uuid);
-        }else {
+        } else {
             throw new UUIDException(2);
         }
     }

diff --git a/src/main/java/net/kaaass/rumbase/page/PageStorage.java b/src/main/java/net/kaaass/rumbase/page/PageStorage.java
@@ -1,7 +1,5 @@
 package net.kaaass.rumbase.page;
 
-import net.kaaass.rumbase.page.exception.FileException;
-
 /**
  * 用于管理一系列连续页的存储对象，隐藏任何关于存储的物理细节
  *
@@ -11,6 +9,7 @@ public interface PageStorage {
 
     /**
      * 获取该页存储中的某一页
+     *
      * @param pageId 页号
      * @return 该页页对象
      */

diff --git a/src/main/java/net/kaaass/rumbase/page/mock/MockBuffer.java b/src/main/java/net/kaaass/rumbase/page/mock/MockBuffer.java
@@ -35,34 +35,34 @@ public void put(int offset, byte[] bytes) throws BufferExeception {
         try {
             System.arraycopy(bytes, 0, this.byteBuffer, offset, bytes.length);
             this.size--;
-        }catch (Exception e) {
+        } catch (Exception e) {
             e.printStackTrace();
-        }finally {
+        } finally {
             lock.unlock();
         }
     }
 
     public byte[] get(int offset) {
         lock.lock();
-        try{
+        try {
             byte[] temp = new byte[PageManager.PAGE_SIZE];
             System.arraycopy(this.byteBuffer, offset, temp, offset, PageManager.PAGE_SIZE);
             return temp;
-        }catch (Exception e) {
+        } catch (Exception e) {
             e.printStackTrace();
-        }finally {
+        } finally {
             lock.unlock();
         }
         return null;
     }
 
     public void free(int offset) {
         lock.lock();
-        try{
+        try {
             System.arraycopy(this.byteBuffer, offset, new byte[PageManager.PAGE_SIZE], 0, PageManager.PAGE_SIZE);
-        }catch (Exception e) {
+        } catch (Exception e) {
             e.printStackTrace();
-        }finally{
+        } finally {
             lock.unlock();
         }
     }

diff --git a/src/main/java/net/kaaass/rumbase/page/mock/MockPage.java b/src/main/java/net/kaaass/rumbase/page/mock/MockPage.java
@@ -5,11 +5,6 @@
 import net.kaaass.rumbase.page.exception.FileException;
 import net.kaaass.rumbase.page.exception.PageException;
 
-import java.io.File;
-import java.io.RandomAccessFile;
-import java.util.concurrent.locks.ReentrantLock;
-import java.util.concurrent.locks.ReentrantReadWriteLock;
-
 public class MockPage implements Page {
     private byte[] data;
     long pageId;
@@ -40,7 +35,8 @@ public void patchData(int offset, byte[] data) throws PageException {
     }
 
     @Override
-    public void flush() throws FileException { }
+    public void flush() throws FileException {
+    }
 
     @Override
     public void pin() {

diff --git a/src/main/java/net/kaaass/rumbase/page/mock/MockPageStorage.java b/src/main/java/net/kaaass/rumbase/page/mock/MockPageStorage.java
@@ -1,15 +1,10 @@
 package net.kaaass.rumbase.page.mock;
 
 import net.kaaass.rumbase.page.Page;
-import net.kaaass.rumbase.page.PageStorage;
 import net.kaaass.rumbase.page.PageManager;
+import net.kaaass.rumbase.page.PageStorage;
 import net.kaaass.rumbase.page.exception.FileException;
 
-import java.io.File;
-import java.io.FileInputStream;
-import java.io.FileOutputStream;
-import java.io.OutputStream;
-import java.io.*;
 import java.util.HashMap;
 import java.util.Map;
 
@@ -25,7 +20,7 @@ public MockPageStorage(String filepath) throws FileException {
         this.fakeFile = new byte[1024 * 4 * 20];
         for (int i = 0; i < 20; i++) {
             for (int j = 0; j < 1024 * 4; j++) {
-                this.fakeFile[1024 * 4 * i + j] = (byte)i;
+                this.fakeFile[1024 * 4 * i + j] = (byte) i;
             }
         }
     }
@@ -35,7 +30,7 @@ public Page get(long pageId) {
         //文件会预留5页作为文件头
         try {
             byte[] data = new byte[PageManager.PAGE_SIZE];
-            System.arraycopy(fakeFile, (int) (pageId + PageManager.FILE_HEAD_SIZE)*PageManager.PAGE_SIZE, data, 0, data.length);
+            System.arraycopy(fakeFile, (int) (pageId + PageManager.FILE_HEAD_SIZE) * PageManager.PAGE_SIZE, data, 0, data.length);
             Integer tmpId = (int) pageId;
             if (pageMap.containsKey(tmpId)) {
                 return pageMap.get(tmpId);

diff --git a/src/main/java/net/kaaass/rumbase/record/IRecordStorage.java b/src/main/java/net/kaaass/rumbase/record/IRecordStorage.java
@@ -4,7 +4,6 @@
 import net.kaaass.rumbase.transaction.TransactionContext;
 
 import java.util.Optional;
-import java.util.UUID;
 
 /**
  * 记录存储接口，提供由记录ID存取数据的容器

diff --git a/src/main/java/net/kaaass/rumbase/record/exception/RecordNotFoundException.java b/src/main/java/net/kaaass/rumbase/record/exception/RecordNotFoundException.java
@@ -14,13 +14,14 @@
  */
 public class RecordNotFoundException extends RumbaseException {
 
-    public static final Map<Integer, String> REASONS = new HashMap<>(){{
+    public static final Map<Integer, String> REASONS = new HashMap<>() {{
         put(1, "物理记录不存在");
     }};
 
     /**
      * 记录不存在异常
-     * @param subId  子错误号
+     *
+     * @param subId 子错误号
      */
     public RecordNotFoundException(int subId) {
         super(5001, subId, REASONS.get(subId));

diff --git a/src/main/java/net/kaaass/rumbase/transaction/TransactionContext.java b/src/main/java/net/kaaass/rumbase/transaction/TransactionContext.java
@@ -60,15 +60,15 @@ static TransactionContext empty() {
     /**
      * 对记录加共享锁
      *
-     * @param uuid 记录id
+     * @param uuid      记录id
      * @param tableName 表字段
      */
     void sharedLock(long uuid, String tableName);
 
     /**
      * 对记录加排他锁
      *
-     * @param uuid 记录id
+     * @param uuid      记录id
      * @param tableName 表字段
      */
     void exclusiveLock(long uuid, String tableName);