提交 e5ac2ada authored 作者: Thomas Mueller's avatar Thomas Mueller

--no commit message

--no commit message
上级 a67837cb
...@@ -222,6 +222,7 @@ class PageBtreeLeaf extends PageBtree { ...@@ -222,6 +222,7 @@ class PageBtreeLeaf extends PageBtree {
} }
void remapChildren() { void remapChildren() {
// nothing to do
} }
/** /**
......
...@@ -46,12 +46,12 @@ public class PageDataLeafOverflow extends Record { ...@@ -46,12 +46,12 @@ public class PageDataLeafOverflow extends Record {
/** /**
* The previous page (overflow or leaf). * The previous page (overflow or leaf).
*/ */
private final int previous; private final int previousPage;
/** /**
* The next overflow page, or 0. * The next overflow page, or 0.
*/ */
private final int next; private final int nextPage;
/** /**
* The number of content bytes. * The number of content bytes.
...@@ -70,8 +70,8 @@ public class PageDataLeafOverflow extends Record { ...@@ -70,8 +70,8 @@ public class PageDataLeafOverflow extends Record {
this.leaf = leaf; this.leaf = leaf;
setPos(pageId); setPos(pageId);
this.type = type; this.type = type;
this.previous = previous; this.previousPage = previous;
this.next = next; this.nextPage = next;
this.offset = offset; this.offset = offset;
this.size = size; this.size = size;
} }
...@@ -81,14 +81,14 @@ public class PageDataLeafOverflow extends Record { ...@@ -81,14 +81,14 @@ public class PageDataLeafOverflow extends Record {
setPos(pageId); setPos(pageId);
this.data = data; this.data = data;
this.offset = offset; this.offset = offset;
previous = data.readInt(); previousPage = data.readInt();
type = data.readByte(); type = data.readByte();
if (type == (Page.TYPE_DATA_OVERFLOW | Page.FLAG_LAST)) { if (type == (Page.TYPE_DATA_OVERFLOW | Page.FLAG_LAST)) {
size = data.readShortInt(); size = data.readShortInt();
next = 0; nextPage = 0;
} else if (type == Page.TYPE_DATA_OVERFLOW) { } else if (type == Page.TYPE_DATA_OVERFLOW) {
size = leaf.getPageStore().getPageSize() - START_MORE; size = leaf.getPageStore().getPageSize() - START_MORE;
next = data.readInt(); nextPage = data.readInt();
} else { } else {
throw Message.getSQLException(ErrorCode.FILE_CORRUPTED_1, "page:" + getPos() + " type:" + type); throw Message.getSQLException(ErrorCode.FILE_CORRUPTED_1, "page:" + getPos() + " type:" + type);
} }
...@@ -106,7 +106,7 @@ public class PageDataLeafOverflow extends Record { ...@@ -106,7 +106,7 @@ public class PageDataLeafOverflow extends Record {
return 0; return 0;
} }
target.write(data.getBytes(), START_MORE, size); target.write(data.getBytes(), START_MORE, size);
return next; return nextPage;
} }
public int getByteCount(DataPage dummy) { public int getByteCount(DataPage dummy) {
...@@ -117,10 +117,10 @@ public class PageDataLeafOverflow extends Record { ...@@ -117,10 +117,10 @@ public class PageDataLeafOverflow extends Record {
PageStore store = leaf.getPageStore(); PageStore store = leaf.getPageStore();
DataPage overflow = store.createDataPage(); DataPage overflow = store.createDataPage();
DataPage data = leaf.getDataPage(); DataPage data = leaf.getDataPage();
overflow.writeInt(previous); overflow.writeInt(previousPage);
overflow.writeByte((byte) type); overflow.writeByte((byte) type);
if (type == Page.TYPE_DATA_OVERFLOW) { if (type == Page.TYPE_DATA_OVERFLOW) {
overflow.writeInt(next); overflow.writeInt(nextPage);
} else { } else {
overflow.writeShortInt(size); overflow.writeShortInt(size);
} }
...@@ -129,7 +129,7 @@ public class PageDataLeafOverflow extends Record { ...@@ -129,7 +129,7 @@ public class PageDataLeafOverflow extends Record {
} }
public String toString() { public String toString() {
return "page[" + getPos() + "] data leaf overflow prev:" + previous + " next:" + next; return "page[" + getPos() + "] data leaf overflow prev:" + previousPage + " next:" + nextPage;
} }
/** /**
......
...@@ -22,7 +22,6 @@ import java.sql.Statement; ...@@ -22,7 +22,6 @@ import java.sql.Statement;
import java.util.Map; import java.util.Map;
import java.util.Properties; import java.util.Properties;
import org.h2.command.CommandInterface; import org.h2.command.CommandInterface;
import org.h2.constant.ErrorCode; import org.h2.constant.ErrorCode;
import org.h2.constant.SysProperties; import org.h2.constant.SysProperties;
......
...@@ -83,10 +83,6 @@ public class PageFreeList extends Record { ...@@ -83,10 +83,6 @@ public class PageFreeList extends Record {
*/ */
void free(int pageId) throws SQLException { void free(int pageId) throws SQLException {
full = false; full = false;
int test;
if (pageId - getPos() <= 0) {
System.out.println("stop!");
}
used.clear(pageId - getPos()); used.clear(pageId - getPos());
store.updateRecord(this, true, data); store.updateRecord(this, true, data);
} }
......
...@@ -22,12 +22,10 @@ import org.h2.index.PageBtreeIndex; ...@@ -22,12 +22,10 @@ import org.h2.index.PageBtreeIndex;
import org.h2.index.PageScanIndex; import org.h2.index.PageScanIndex;
import org.h2.log.InDoubtTransaction; import org.h2.log.InDoubtTransaction;
import org.h2.log.LogSystem; import org.h2.log.LogSystem;
import org.h2.log.SessionState;
import org.h2.message.Message; import org.h2.message.Message;
import org.h2.message.Trace; import org.h2.message.Trace;
import org.h2.message.TraceSystem; import org.h2.message.TraceSystem;
import org.h2.result.Row; import org.h2.result.Row;
import org.h2.result.SortOrder;
import org.h2.schema.Schema; import org.h2.schema.Schema;
import org.h2.table.Column; import org.h2.table.Column;
import org.h2.table.IndexColumn; import org.h2.table.IndexColumn;
...@@ -968,8 +966,8 @@ public class PageStore implements CacheWriter { ...@@ -968,8 +966,8 @@ public class PageStore implements CacheWriter {
} }
/** /**
* Commit or rollback a prepared transaction after opening a database with in-doubt * Commit or rollback a prepared transaction after opening a database with
* transactions. * in-doubt transactions.
* *
* @param sessionId the session id * @param sessionId the session id
* @param pageId the page where the transaction was prepared * @param pageId the page where the transaction was prepared
......
...@@ -807,13 +807,13 @@ public class Recover extends Tool implements DataHandler { ...@@ -807,13 +807,13 @@ public class Recover extends Tool implements DataHandler {
case Page.TYPE_BTREE_NODE: case Page.TYPE_BTREE_NODE:
writer.println("-- page " + page + ": btree node" + (last ? "(last)" : "")); writer.println("-- page " + page + ": btree node" + (last ? "(last)" : ""));
if (trace) { if (trace) {
dumpPageBtreeNode(store, pageSize, writer, s, last, page); dumpPageBtreeNode(writer, s);
} }
break; break;
case Page.TYPE_BTREE_LEAF: case Page.TYPE_BTREE_LEAF:
writer.println("-- page " + page + ": btree leaf " + (last ? "(last)" : "")); writer.println("-- page " + page + ": btree leaf " + (last ? "(last)" : ""));
if (trace) { if (trace) {
dumpPageBtreeLeaf(store, pageSize, writer, s, last, page); dumpPageBtreeLeaf(writer, s);
} }
break; break;
case Page.TYPE_FREE_LIST: case Page.TYPE_FREE_LIST:
...@@ -1012,7 +1012,7 @@ public class Recover extends Tool implements DataHandler { ...@@ -1012,7 +1012,7 @@ public class Recover extends Tool implements DataHandler {
} }
} }
private void dumpPageBtreeNode(FileStore store, int pageSize, PrintWriter writer, DataPage s, boolean last, long pageId) { private void dumpPageBtreeNode(PrintWriter writer, DataPage s) {
int entryCount = s.readShortInt(); int entryCount = s.readShortInt();
int rowCount = s.readInt(); int rowCount = s.readInt();
int[] children = new int[entryCount + 1]; int[] children = new int[entryCount + 1];
...@@ -1038,7 +1038,7 @@ public class Recover extends Tool implements DataHandler { ...@@ -1038,7 +1038,7 @@ public class Recover extends Tool implements DataHandler {
writer.println("-- [" + entryCount + "] child: " + children[entryCount] + " rowCount: " + rowCount); writer.println("-- [" + entryCount + "] child: " + children[entryCount] + " rowCount: " + rowCount);
} }
private void dumpPageBtreeLeaf(FileStore store, int pageSize, PrintWriter writer, DataPage s, boolean last, long pageId) { private void dumpPageBtreeLeaf(PrintWriter writer, DataPage s) {
s.readInt(); s.readInt();
int entryCount = s.readShortInt(); int entryCount = s.readShortInt();
int[] offsets = new int[entryCount]; int[] offsets = new int[entryCount];
......
...@@ -21,8 +21,8 @@ import org.h2.constant.SysProperties; ...@@ -21,8 +21,8 @@ import org.h2.constant.SysProperties;
public class ObjectArray<T> implements Iterable<T> { public class ObjectArray<T> implements Iterable<T> {
private static final int CAPACITY_INIT = 4, CAPACITY_SHRINK = 256; private static final int CAPACITY_INIT = 4, CAPACITY_SHRINK = 256;
int size;
private T[] data; private T[] data;
private int size;
private ObjectArray(int capacity) { private ObjectArray(int capacity) {
data = createArray(capacity); data = createArray(capacity);
...@@ -323,7 +323,7 @@ public class ObjectArray<T> implements Iterable<T> { ...@@ -323,7 +323,7 @@ public class ObjectArray<T> implements Iterable<T> {
/** /**
* The iterator for this list. * The iterator for this list.
*/ */
private class ObjectArrayIterator implements Iterator<T> { class ObjectArrayIterator implements Iterator<T> {
private int index; private int index;
public boolean hasNext() { public boolean hasNext() {
......
...@@ -29,13 +29,15 @@ package org.h2.util; ...@@ -29,13 +29,15 @@ package org.h2.util;
*</pre> *</pre>
*/ */
public class StatementBuilder { public class StatementBuilder {
private StringBuilder builder = new StringBuilder();
private final StringBuilder builder = new StringBuilder();
private int index; private int index;
/** /**
* Create a new builder. * Create a new builder.
*/ */
public StatementBuilder() { public StatementBuilder() {
// nothing to do
} }
/** /**
......
...@@ -13,8 +13,6 @@ import java.sql.Statement; ...@@ -13,8 +13,6 @@ import java.sql.Statement;
import java.util.Random; import java.util.Random;
import java.util.Set; import java.util.Set;
import java.util.TreeSet; import java.util.TreeSet;
import org.h2.engine.ConnectionInfo;
import org.h2.engine.Database;
import org.h2.test.TestBase; import org.h2.test.TestBase;
/** /**
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论