mydb：TM实现

一、说明

TM就是事务管理：实现对于事务的新增（active）、事务的状态修改（commit、abort）、事务的状态判断

二、事务管理

2.1创建xid文件/打开xid文件

创建xid、写一个空的 XID 文件头并创建TM

    public static TransactionManagerImpl create(String path) {
        //创建文件.xid
        File f = new File(path+TransactionManagerImpl.XID_SUFFIX);
        try {
            if(!f.createNewFile()) {
                Panic.panic(Error.FileExistsException);
            }
        } catch (Exception e) {
            Panic.panic(e);
        }
        if(!f.canRead() || !f.canWrite()) {
            Panic.panic(Error.FileCannotRWException);
        }

        //用于高效地处理文件的读取和写入操作
        FileChannel fc = null;
        //任意读文件
        RandomAccessFile raf = null;
        try {
            raf = new RandomAccessFile(f, "rw");
            fc = raf.getChannel();
        } catch (FileNotFoundException e) {
           Panic.panic(e);
        }

        // 写空XID文件头
        ByteBuffer buf = ByteBuffer.wrap(new byte[TransactionManagerImpl.LEN_XID_HEADER_LENGTH]);
        try {
            //定位到指定位置
            fc.position(0);
            //进行写入
            fc.write(buf);
        } catch (IOException e) {
            Panic.panic(e);
        }
        
        return new TransactionManagerImpl(raf, fc);
    }

2.2 打开xid文件并创建TM

public static TransactionManagerImpl open(String path) {
        File f = new File(path+TransactionManagerImpl.XID_SUFFIX);
        if(!f.exists()) {
            Panic.panic(Error.FileNotExistsException);
        }
        if(!f.canRead() || !f.canWrite()) {
            Panic.panic(Error.FileCannotRWException);
        }

        FileChannel fc = null;
        RandomAccessFile raf = null;
        try {
            raf = new RandomAccessFile(f, "rw");
            fc = raf.getChannel();
        } catch (FileNotFoundException e) {
           Panic.panic(e);
        }

        return new TransactionManagerImpl(raf, fc);
    }

2.2 基于TM进行相关的事务处理

0. 检查文件是否合法 :利用 RandomAccessFile 文件长度 和  new io 的一个类 FileChannel

1、新增事务

新增字节、修改事务总数

2、修改事务状态

通过 updateXID()实现 updateXid是对指定位置写 如果没有直接写 如果有会覆盖

3、事务的状态判断

2.3 注意事项

这里的所有文件操作，在执行后都需要立刻刷入文件中，防止在崩溃后文件丢失数据，fileChannel 的 force() 方法，强制同步缓存内容到文件中，类似于 BIO 中的 flush() 方法。force 方法的参数是一个布尔，表示是否同步文件的元数据（例如最后修改时间等）。

每次写完会try  force() 方法。