提交 25e1e0da authored 作者: Thomas Mueller's avatar Thomas Mueller

Open to not log binary values.

上级 b3bd3a5b
...@@ -245,6 +245,11 @@ public class Set extends Prepared { ...@@ -245,6 +245,11 @@ public class Set extends Prepared {
session.setQueryTimeout(value); session.setQueryTimeout(value);
break; break;
} }
case SetTypes.REDO_LOG_BINARY: {
int value = getIntValue();
session.setRedoLogBinary(value == 1);
break;
}
case SetTypes.REFERENTIAL_INTEGRITY: { case SetTypes.REFERENTIAL_INTEGRITY: {
session.getUser().checkAdmin(); session.getUser().checkAdmin();
int value = getIntValue(); int value = getIntValue();
......
...@@ -194,6 +194,11 @@ public class SetTypes { ...@@ -194,6 +194,11 @@ public class SetTypes {
*/ */
public static final int QUERY_TIMEOUT = 36; public static final int QUERY_TIMEOUT = 36;
/**
* The type of a SET REDO_LOG_BINARY statement.
*/
public static final int REDO_LOG_BINARY = 37;
private static final ArrayList<String> TYPES = New.arrayList(); private static final ArrayList<String> TYPES = New.arrayList();
private SetTypes() { private SetTypes() {
...@@ -239,6 +244,7 @@ public class SetTypes { ...@@ -239,6 +244,7 @@ public class SetTypes {
list.add(CREATE_BUILD, "CREATE_BUILD"); list.add(CREATE_BUILD, "CREATE_BUILD");
list.add(VARIABLE, "@"); list.add(VARIABLE, "@");
list.add(QUERY_TIMEOUT, "QUERY_TIMEOUT"); list.add(QUERY_TIMEOUT, "QUERY_TIMEOUT");
list.add(REDO_LOG_BINARY, "REDO_LOG_BINARY");
} }
/** /**
......
...@@ -86,6 +86,7 @@ public class Session extends SessionWithState { ...@@ -86,6 +86,7 @@ public class Session extends SessionWithState {
private int systemIdentifier; private int systemIdentifier;
private HashMap<String, Procedure> procedures; private HashMap<String, Procedure> procedures;
private boolean undoLogEnabled = true; private boolean undoLogEnabled = true;
private boolean redoLogBinary = true;
private boolean autoCommitAtTransactionEnd; private boolean autoCommitAtTransactionEnd;
private String currentTransactionName; private String currentTransactionName;
private volatile long cancelAt; private volatile long cancelAt;
...@@ -1010,6 +1011,10 @@ public class Session extends SessionWithState { ...@@ -1010,6 +1011,10 @@ public class Session extends SessionWithState {
this.undoLogEnabled = b; this.undoLogEnabled = b;
} }
public void setRedoLogBinary(boolean b) {
this.redoLogBinary = b;
}
public boolean isUndoLogEnabled() { public boolean isUndoLogEnabled() {
return undoLogEnabled; return undoLogEnabled;
} }
...@@ -1175,4 +1180,8 @@ public class Session extends SessionWithState { ...@@ -1175,4 +1180,8 @@ public class Session extends SessionWithState {
return scopeIdentity; return scopeIdentity;
} }
public boolean isRedoLogBinaryEnabled() {
return redoLogBinary;
}
} }
...@@ -41,7 +41,7 @@ public class ByteUtils { ...@@ -41,7 +41,7 @@ public class ByteUtils {
/** /**
* Write a long value to the byte array. * Write a long value to the byte array.
* *
* @param buffthe byte array * @param buff the byte array
* @param pos the position * @param pos the position
* @param x the value * @param x the value
*/ */
......
...@@ -299,6 +299,8 @@ java org.h2.test.TestAll timer ...@@ -299,6 +299,8 @@ java org.h2.test.TestAll timer
/* /*
increment storage read version
update copyright to 2010 update copyright to 2010
outer join bug outer join bug
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论