提交 e2035ba4 authored 作者: Evgenij Ryazanov's avatar Evgenij Ryazanov

Remove Table.commit() that was needed only by PageStore+MVCC

上级 2cdee129
...@@ -698,7 +698,6 @@ public class Session extends SessionWithState implements TransactionStore.Rollba ...@@ -698,7 +698,6 @@ public class Session extends SessionWithState implements TransactionStore.Rollba
ArrayList<Row> rows = new ArrayList<>(undoLog.size()); ArrayList<Row> rows = new ArrayList<>(undoLog.size());
while (undoLog.size() > 0) { while (undoLog.size() > 0) {
UndoLogRecord entry = undoLog.getLast(); UndoLogRecord entry = undoLog.getLast();
entry.commit();
rows.add(entry.getRow()); rows.add(entry.getRow());
undoLog.removeLast(false); undoLog.removeLast(false);
} }
......
...@@ -243,14 +243,6 @@ public class UndoLogRecord { ...@@ -243,14 +243,6 @@ public class UndoLogRecord {
return filePos; return filePos;
} }
/**
* This method is called after the operation was committed.
* It commits the change to the indexes.
*/
void commit() {
table.commit(operation, row);
}
/** /**
* Get the row that was deleted or inserted. * Get the row that was deleted or inserted.
* *
......
...@@ -142,11 +142,6 @@ public class RegularTable extends TableBase { ...@@ -142,11 +142,6 @@ public class RegularTable extends TableBase {
analyzeIfRequired(session); analyzeIfRequired(session);
} }
@Override
public void commit(short operation, Row row) {
lastModificationId = database.getNextModificationDataId();
}
private void checkRowCount(Session session, Index index, int offset) { private void checkRowCount(Session session, Index index, int offset) {
if (SysProperties.CHECK) { if (SysProperties.CHECK) {
if (!(index instanceof PageDelegateIndex)) { if (!(index instanceof PageDelegateIndex)) {
......
...@@ -224,17 +224,6 @@ public abstract class Table extends SchemaObjectBase { ...@@ -224,17 +224,6 @@ public abstract class Table extends SchemaObjectBase {
addRow(session, newRow); addRow(session, newRow);
} }
/**
* Commit an operation (when using multi-version concurrency).
*
* @param operation the operation
* @param row the row
*/
@SuppressWarnings("unused")
public void commit(short operation, Row row) {
// nothing to do
}
/** /**
* Check if this table supports ALTER TABLE. * Check if this table supports ALTER TABLE.
* *
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论