mydb：TM实现

一、说明

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

二、事务管理

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

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

    public static TransactionManagerImpl create(String path) {//创建文件.xidFile 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() 方法。