setintrecord.java

用java语言简单实现数据库的初步功能

package simpledb.tx.recovery;

import simpledb.server.SimpleDB;
import simpledb.buffer.*;
import simpledb.file.Block;
import simpledb.log.BasicLogRecord;

class SetIntRecord implements LogRecord {
	private int txnum, offset, val;
	private Block blk;

	/**
	 * Creates a new setint log record.
	 * @param txnum the ID of the specified transaction
	 * @param blk the block containing the value
	 * @param offset the offset of the value in the block
	 * @param val the new value
	 */
	public SetIntRecord(int txnum, Block blk, int offset, int val) {
		this.txnum = txnum;
		this.blk = blk;
		this.offset = offset;
		this.val = val;
	}
	
	/**
	 * Creates a log record by reading five other values from the log.
	 * @param rec the basic log record
	 */
	public SetIntRecord(BasicLogRecord rec) {
		txnum = rec.nextInt();
		String filename = rec.nextString();
		int blknum = rec.nextInt();
		blk = new Block(filename, blknum);
		offset = rec.nextInt();
		val = rec.nextInt();
	}

	/** 
	 * Writes a setInt record to the log.
	 * This log record contains the SETINT operator,
	 * followed by the transaction id, the filename, number,
	 * and offset of the modified block, and the previous
	 * integer value at that offset.
	 * @return the LSN of the last log value
	 */
	public int writeToLog() {
		Object[] rec = new Object[] {SETINT, txnum, blk.fileName(), 
									 blk.number(), offset, val};
		return logMgr.append(rec);
	}

	public int op() {
		return LogRecord.SETINT;
	}

	public int txNumber() {
		return txnum;
	}

	public String toString() {
		return "<SETINT " + txnum + " " + blk + " " + offset + " " + val + ">";
	}

	/** 
	 * Replaces the specified data value with the value saved in the log record.
	 * The method pins a buffer to the specified block,
	 * calls setString to restore the saved value, 
	 * and unpins the buffer.
	 * @see simpledb.tx.recovery.LogRecord#undo(int)
	 */
	public void undo(int txnum) {
		BufferMgr buffMgr = SimpleDB.bufferMgr();
		Buffer buff = buffMgr.pin(blk);
		buff.setInt(offset, val, txnum, -1);
		buffMgr.unpin(buff);
	}
}