提交 2a2a7b13 authored 作者: Evgenij Ryazanov's avatar Evgenij Ryazanov

Remove TestAll.mvcc

上级 a9f52ea6
...@@ -308,11 +308,6 @@ java org.h2.test.TestAll timer ...@@ -308,11 +308,6 @@ java org.h2.test.TestAll timer
*/ */
public boolean codeCoverage; public boolean codeCoverage;
/**
* If the multi version concurrency control mode should be used.
*/
public boolean mvcc = mvStore;
/** /**
* If the multi-threaded mode should be used. * If the multi-threaded mode should be used.
*/ */
...@@ -644,12 +639,10 @@ kill -9 `jps -l | grep "org.h2.test." | cut -d " " -f 1` ...@@ -644,12 +639,10 @@ kill -9 `jps -l | grep "org.h2.test." | cut -d " " -f 1`
memory = false; memory = false;
multiThreaded = false; multiThreaded = false;
mvStore = false; mvStore = false;
mvcc = false;
test(); test();
testUnit(); testUnit();
mvStore = true; mvStore = true;
mvcc = true;
memory = true; memory = true;
multiThreaded = false; multiThreaded = false;
networked = true; networked = true;
...@@ -713,7 +706,6 @@ kill -9 `jps -l | grep "org.h2.test." | cut -d " " -f 1` ...@@ -713,7 +706,6 @@ kill -9 `jps -l | grep "org.h2.test." | cut -d " " -f 1`
multiThreaded = false; multiThreaded = false;
mvStore = false; mvStore = false;
mvcc = false;
test(); test();
// testUnit(); // testUnit();
} }
...@@ -1130,7 +1122,6 @@ kill -9 `jps -l | grep "org.h2.test." | cut -d " " -f 1` ...@@ -1130,7 +1122,6 @@ kill -9 `jps -l | grep "org.h2.test." | cut -d " " -f 1`
appendIf(buff, networked, "net"); appendIf(buff, networked, "net");
appendIf(buff, memory, "memory"); appendIf(buff, memory, "memory");
appendIf(buff, codeCoverage, "codeCoverage"); appendIf(buff, codeCoverage, "codeCoverage");
appendIf(buff, mvcc, "mvcc");
appendIf(buff, multiThreaded, "multiThreaded"); appendIf(buff, multiThreaded, "multiThreaded");
appendIf(buff, cipher != null, cipher); appendIf(buff, cipher != null, cipher);
appendIf(buff, cacheType != null, cacheType); appendIf(buff, cacheType != null, cacheType);
......
...@@ -314,9 +314,6 @@ public abstract class TestBase { ...@@ -314,9 +314,6 @@ public abstract class TestBase {
// force operations to disk // force operations to disk
url = addOption(url, "MAX_OPERATION_MEMORY", "1"); url = addOption(url, "MAX_OPERATION_MEMORY", "1");
} }
if (config.mvcc) {
url = addOption(url, "MVCC", "TRUE");
}
url = addOption(url, "MULTI_THREADED", config.multiThreaded ? "TRUE" : "FALSE"); url = addOption(url, "MULTI_THREADED", config.multiThreaded ? "TRUE" : "FALSE");
if (config.lazy) { if (config.lazy) {
url = addOption(url, "LAZY_QUERY_EXECUTION", "1"); url = addOption(url, "LAZY_QUERY_EXECUTION", "1");
......
...@@ -235,7 +235,7 @@ public class TestDeadlock extends TestBase { ...@@ -235,7 +235,7 @@ public class TestDeadlock extends TestBase {
} }
private void testThreePhilosophers() throws Exception { private void testThreePhilosophers() throws Exception {
if (config.mvcc || config.mvStore) { if (config.mvStore) {
return; return;
} }
initTest(); initTest();
...@@ -281,7 +281,7 @@ public class TestDeadlock extends TestBase { ...@@ -281,7 +281,7 @@ public class TestDeadlock extends TestBase {
// test case for issue # 61 // test case for issue # 61
// http://code.google.com/p/h2database/issues/detail?id=61) // http://code.google.com/p/h2database/issues/detail?id=61)
private void testThreeSome() throws Exception { private void testThreeSome() throws Exception {
if (config.mvcc || config.mvStore) { if (config.mvStore) {
return; return;
} }
initTest(); initTest();
...@@ -326,7 +326,7 @@ public class TestDeadlock extends TestBase { ...@@ -326,7 +326,7 @@ public class TestDeadlock extends TestBase {
} }
private void testLockUpgrade() throws Exception { private void testLockUpgrade() throws Exception {
if (config.mvcc || config.mvStore) { if (config.mvStore) {
return; return;
} }
initTest(); initTest();
...@@ -360,7 +360,7 @@ public class TestDeadlock extends TestBase { ...@@ -360,7 +360,7 @@ public class TestDeadlock extends TestBase {
} }
private void testDiningPhilosophers() throws Exception { private void testDiningPhilosophers() throws Exception {
if (config.mvcc || config.mvStore) { if (config.mvStore) {
return; return;
} }
initTest(); initTest();
......
...@@ -534,7 +534,6 @@ public class TestGeneralCommonTableQueries extends AbstractBaseForCommonTableExp ...@@ -534,7 +534,6 @@ public class TestGeneralCommonTableQueries extends AbstractBaseForCommonTableExp
config.lazy = true; config.lazy = true;
config.mvStore = true; config.mvStore = true;
config.memory = true; config.memory = true;
config.mvcc = true;
config.multiThreaded = true; config.multiThreaded = true;
String setupSQL = "--no config set"; String setupSQL = "--no config set";
......
...@@ -28,7 +28,7 @@ public class TestLargeBlob extends TestBase { ...@@ -28,7 +28,7 @@ public class TestLargeBlob extends TestBase {
@Override @Override
public void test() throws Exception { public void test() throws Exception {
if (!config.big || config.memory || config.mvcc || config.networked) { if (!config.big || config.memory || config.mvStore || config.networked) {
return; return;
} }
......
...@@ -693,10 +693,7 @@ public class TestLinkedTable extends TestBase { ...@@ -693,10 +693,7 @@ public class TestLinkedTable extends TestBase {
} }
private void testGeometry() throws SQLException { private void testGeometry() throws SQLException {
if (!config.mvStore && config.mvcc) { if (config.memory && config.mvStore) {
return;
}
if (config.memory && config.mvcc) {
return; return;
} }
if (DataType.GEOMETRY_CLASS == null) { if (DataType.GEOMETRY_CLASS == null) {
......
...@@ -510,7 +510,7 @@ public class TestLob extends TestBase { ...@@ -510,7 +510,7 @@ public class TestLob extends TestBase {
} }
private void testDeadlock2() throws Exception { private void testDeadlock2() throws Exception {
if (config.mvcc || config.memory) { if (config.mvStore || config.memory) {
return; return;
} }
deleteDb("lob"); deleteDb("lob");
......
...@@ -142,7 +142,7 @@ public class TestMultiThread extends TestBase implements Runnable { ...@@ -142,7 +142,7 @@ public class TestMultiThread extends TestBase implements Runnable {
} }
private void testConcurrentView() throws Exception { private void testConcurrentView() throws Exception {
if (config.mvcc || config.mvStore) { if (config.mvStore) {
return; return;
} }
String db = getTestName(); String db = getTestName();
...@@ -206,7 +206,7 @@ public class TestMultiThread extends TestBase implements Runnable { ...@@ -206,7 +206,7 @@ public class TestMultiThread extends TestBase implements Runnable {
} }
private void testConcurrentAnalyze() throws Exception { private void testConcurrentAnalyze() throws Exception {
if (config.mvcc) { if (config.mvStore) {
return; return;
} }
deleteDb(getTestName()); deleteDb(getTestName());
......
...@@ -43,9 +43,6 @@ public class TestMultiThreadedKernel extends TestBase { ...@@ -43,9 +43,6 @@ public class TestMultiThreadedKernel extends TestBase {
@Override @Override
public void test() throws Exception { public void test() throws Exception {
if (config.mvcc) {
return;
}
if (config.mvStore) { // FIXME can't see why test should not work in MVStore mode if (config.mvStore) { // FIXME can't see why test should not work in MVStore mode
return; return;
} }
......
...@@ -659,7 +659,7 @@ public class TestOptimizations extends TestBase { ...@@ -659,7 +659,7 @@ public class TestOptimizations extends TestBase {
ResultSet rs = stat.executeQuery( ResultSet rs = stat.executeQuery(
"explain select min(x), max(x) from test"); "explain select min(x), max(x) from test");
rs.next(); rs.next();
if (!config.mvcc) { if (!config.mvStore) {
String plan = rs.getString(1); String plan = rs.getString(1);
assertContains(plan, "direct"); assertContains(plan, "direct");
} }
......
...@@ -31,7 +31,7 @@ public class TestSessionsLocks extends TestBase { ...@@ -31,7 +31,7 @@ public class TestSessionsLocks extends TestBase {
return; return;
} }
testCancelStatement(); testCancelStatement();
if (!config.mvcc) { if (!config.mvStore) {
testLocks(); testLocks();
} }
deleteDb("sessionsLocks"); deleteDb("sessionsLocks");
...@@ -56,7 +56,7 @@ public class TestSessionsLocks extends TestBase { ...@@ -56,7 +56,7 @@ public class TestSessionsLocks extends TestBase {
assertEquals("PUBLIC", rs.getString("TABLE_SCHEMA")); assertEquals("PUBLIC", rs.getString("TABLE_SCHEMA"));
assertEquals("TEST", rs.getString("TABLE_NAME")); assertEquals("TEST", rs.getString("TABLE_NAME"));
rs.getString("SESSION_ID"); rs.getString("SESSION_ID");
if (config.mvcc || config.mvStore) { if (config.mvStore) {
assertEquals("READ", rs.getString("LOCK_TYPE")); assertEquals("READ", rs.getString("LOCK_TYPE"));
} else { } else {
assertEquals("WRITE", rs.getString("LOCK_TYPE")); assertEquals("WRITE", rs.getString("LOCK_TYPE"));
...@@ -67,7 +67,7 @@ public class TestSessionsLocks extends TestBase { ...@@ -67,7 +67,7 @@ public class TestSessionsLocks extends TestBase {
stat2.execute("SELECT * FROM TEST"); stat2.execute("SELECT * FROM TEST");
rs = stat.executeQuery("select * from information_schema.locks " + rs = stat.executeQuery("select * from information_schema.locks " +
"order by session_id"); "order by session_id");
if (!config.mvcc && !config.mvStore) { if (!config.mvStore) {
rs.next(); rs.next();
assertEquals("PUBLIC", rs.getString("TABLE_SCHEMA")); assertEquals("PUBLIC", rs.getString("TABLE_SCHEMA"));
assertEquals("TEST", rs.getString("TABLE_NAME")); assertEquals("TEST", rs.getString("TABLE_NAME"));
......
...@@ -53,10 +53,7 @@ public class TestSpatial extends TestBase { ...@@ -53,10 +53,7 @@ public class TestSpatial extends TestBase {
@Override @Override
public void test() throws SQLException { public void test() throws SQLException {
if (!config.mvStore && config.mvcc) { if (config.memory && config.mvStore) {
return;
}
if (config.memory && config.mvcc) {
return; return;
} }
if (DataType.GEOMETRY_CLASS != null) { if (DataType.GEOMETRY_CLASS != null) {
......
...@@ -85,7 +85,7 @@ public class TestTransaction extends TestBase { ...@@ -85,7 +85,7 @@ public class TestTransaction extends TestBase {
conn.setAutoCommit(false); conn.setAutoCommit(false);
ResultSet rs; ResultSet rs;
if (config.mvcc || config.mvStore) { if (config.mvStore) {
rs = stat2.executeQuery("select count(*) from test"); rs = stat2.executeQuery("select count(*) from test");
rs.next(); rs.next();
assertEquals(0, rs.getInt(1)); assertEquals(0, rs.getInt(1));
...@@ -187,7 +187,7 @@ public class TestTransaction extends TestBase { ...@@ -187,7 +187,7 @@ public class TestTransaction extends TestBase {
Connection conn2 = getConnection("transaction"); Connection conn2 = getConnection("transaction");
conn2.setAutoCommit(false); conn2.setAutoCommit(false);
Statement stat2 = conn2.createStatement(); Statement stat2 = conn2.createStatement();
if (config.mvcc) { if (config.mvStore) {
stat2.execute("update test set name = 'Welt' where id = 2"); stat2.execute("update test set name = 'Welt' where id = 2");
} }
assertThrows(ErrorCode.LOCK_TIMEOUT_1, stat2). assertThrows(ErrorCode.LOCK_TIMEOUT_1, stat2).
...@@ -321,7 +321,7 @@ public class TestTransaction extends TestBase { ...@@ -321,7 +321,7 @@ public class TestTransaction extends TestBase {
c2.setAutoCommit(false); c2.setAutoCommit(false);
s1.executeUpdate("insert into A(code) values('one')"); s1.executeUpdate("insert into A(code) values('one')");
Statement s2 = c2.createStatement(); Statement s2 = c2.createStatement();
if (config.mvcc || config.mvStore) { if (config.mvStore) {
assertThrows( assertThrows(
ErrorCode.REFERENTIAL_INTEGRITY_VIOLATED_PARENT_MISSING_1, s2). ErrorCode.REFERENTIAL_INTEGRITY_VIOLATED_PARENT_MISSING_1, s2).
executeUpdate("insert into B values('two', 1)"); executeUpdate("insert into B values('two', 1)");
......
...@@ -111,7 +111,7 @@ public class TestTriggersConstraints extends TestBase implements Trigger { ...@@ -111,7 +111,7 @@ public class TestTriggersConstraints extends TestBase implements Trigger {
} }
private void testDeleteInTrigger() throws SQLException { private void testDeleteInTrigger() throws SQLException {
if (config.mvcc || config.mvStore) { if (config.mvStore) {
return; return;
} }
Connection conn; Connection conn;
......
...@@ -29,7 +29,6 @@ public class TestUpgrade extends TestBase { ...@@ -29,7 +29,6 @@ public class TestUpgrade extends TestBase {
*/ */
public static void main(String... a) throws Exception { public static void main(String... a) throws Exception {
TestBase base = TestBase.createCaller().init(); TestBase base = TestBase.createCaller().init();
base.config.mvcc = false;
base.config.mvStore = false; base.config.mvStore = false;
base.test(); base.test();
} }
......
...@@ -111,10 +111,7 @@ public class TestUsingIndex extends TestBase { ...@@ -111,10 +111,7 @@ public class TestUsingIndex extends TestBase {
} }
private void testSpatialIndex() throws SQLException { private void testSpatialIndex() throws SQLException {
if (!config.mvStore && config.mvcc) { if (config.memory && config.mvStore) {
return;
}
if (config.memory && config.mvcc) {
return; return;
} }
if (DataType.GEOMETRY_CLASS == null) { if (DataType.GEOMETRY_CLASS == null) {
...@@ -147,10 +144,7 @@ public class TestUsingIndex extends TestBase { ...@@ -147,10 +144,7 @@ public class TestUsingIndex extends TestBase {
} }
private void testBadSpatialSyntax() throws SQLException { private void testBadSpatialSyntax() throws SQLException {
if (!config.mvStore && config.mvcc) { if (config.memory && config.mvStore) {
return;
}
if (config.memory && config.mvcc) {
return; return;
} }
if (DataType.GEOMETRY_CLASS == null) { if (DataType.GEOMETRY_CLASS == null) {
......
...@@ -1271,7 +1271,7 @@ public class TestMetaData extends TestBase { ...@@ -1271,7 +1271,7 @@ public class TestMetaData extends TestBase {
} }
private void testSessionsUncommitted() throws SQLException { private void testSessionsUncommitted() throws SQLException {
if (config.mvcc || config.memory) { if (config.mvStore || config.memory) {
return; return;
} }
Connection conn = getConnection("metaData"); Connection conn = getConnection("metaData");
......
...@@ -28,7 +28,7 @@ public class TestTransactionIsolation extends TestBase { ...@@ -28,7 +28,7 @@ public class TestTransactionIsolation extends TestBase {
@Override @Override
public void test() throws SQLException { public void test() throws SQLException {
if (config.mvcc || config.mvStore) { if (config.mvStore) {
// no tests yet // no tests yet
} else { } else {
testTableLevelLocking(); testTableLevelLocking();
......
...@@ -30,7 +30,6 @@ public class TestMvcc1 extends TestBase { ...@@ -30,7 +30,6 @@ public class TestMvcc1 extends TestBase {
*/ */
public static void main(String... a) throws Exception { public static void main(String... a) throws Exception {
TestBase test = TestBase.createCaller().init(); TestBase test = TestBase.createCaller().init();
test.config.mvcc = true;
test.test(); test.test();
} }
...@@ -59,7 +58,7 @@ public class TestMvcc1 extends TestBase { ...@@ -59,7 +58,7 @@ public class TestMvcc1 extends TestBase {
} }
private void testCases() throws SQLException { private void testCases() throws SQLException {
if (!config.mvcc) { if (!config.mvStore) {
return; return;
} }
ResultSet rs; ResultSet rs;
......
...@@ -34,13 +34,12 @@ public class TestMvcc2 extends TestBase { ...@@ -34,13 +34,12 @@ public class TestMvcc2 extends TestBase {
*/ */
public static void main(String... a) throws Exception { public static void main(String... a) throws Exception {
TestBase test = TestBase.createCaller().init(); TestBase test = TestBase.createCaller().init();
test.config.mvcc = true;
test.test(); test.test();
} }
@Override @Override
public void test() throws Exception { public void test() throws Exception {
if (!config.mvcc) { if (!config.mvStore) {
return; return;
} }
deleteDb("mvcc2"); deleteDb("mvcc2");
......
...@@ -26,7 +26,6 @@ public class TestMvcc3 extends TestBase { ...@@ -26,7 +26,6 @@ public class TestMvcc3 extends TestBase {
*/ */
public static void main(String... a) throws Exception { public static void main(String... a) throws Exception {
TestBase test = TestBase.createCaller().init(); TestBase test = TestBase.createCaller().init();
test.config.mvcc = true;
test.test(); test.test();
} }
...@@ -63,7 +62,7 @@ public class TestMvcc3 extends TestBase { ...@@ -63,7 +62,7 @@ public class TestMvcc3 extends TestBase {
} }
private void testConcurrentUpdate() throws SQLException { private void testConcurrentUpdate() throws SQLException {
if (!config.mvcc) { if (!config.mvStore) {
return; return;
} }
deleteDb("mvcc3"); deleteDb("mvcc3");
...@@ -102,7 +101,7 @@ public class TestMvcc3 extends TestBase { ...@@ -102,7 +101,7 @@ public class TestMvcc3 extends TestBase {
} }
private void testInsertUpdateRollback() throws SQLException { private void testInsertUpdateRollback() throws SQLException {
if (!config.mvcc) { if (!config.mvStore) {
return; return;
} }
...@@ -147,7 +146,7 @@ public class TestMvcc3 extends TestBase { ...@@ -147,7 +146,7 @@ public class TestMvcc3 extends TestBase {
} }
private void testCreateTableAsSelect() throws SQLException { private void testCreateTableAsSelect() throws SQLException {
if (!config.mvcc) { if (!config.mvStore) {
return; return;
} }
deleteDb("mvcc3"); deleteDb("mvcc3");
...@@ -165,7 +164,7 @@ public class TestMvcc3 extends TestBase { ...@@ -165,7 +164,7 @@ public class TestMvcc3 extends TestBase {
} }
private void testRollback() throws SQLException { private void testRollback() throws SQLException {
if (!config.mvcc) { if (!config.mvStore) {
return; return;
} }
...@@ -218,7 +217,7 @@ public class TestMvcc3 extends TestBase { ...@@ -218,7 +217,7 @@ public class TestMvcc3 extends TestBase {
} }
private void testDisableAutoCommit() throws SQLException { private void testDisableAutoCommit() throws SQLException {
if (!config.mvcc) { if (!config.mvStore) {
return; return;
} }
deleteDb("mvcc3"); deleteDb("mvcc3");
......
...@@ -26,7 +26,6 @@ public class TestMvcc4 extends TestBase { ...@@ -26,7 +26,6 @@ public class TestMvcc4 extends TestBase {
*/ */
public static void main(String... a) throws Exception { public static void main(String... a) throws Exception {
TestBase test = TestBase.createCaller().init(); TestBase test = TestBase.createCaller().init();
test.config.mvcc = true;
test.config.lockTimeout = 20000; test.config.lockTimeout = 20000;
test.config.memory = true; test.config.memory = true;
test.test(); test.test();
...@@ -34,7 +33,7 @@ public class TestMvcc4 extends TestBase { ...@@ -34,7 +33,7 @@ public class TestMvcc4 extends TestBase {
@Override @Override
public void test() throws SQLException { public void test() throws SQLException {
if (config.networked || !config.mvcc) { if (config.networked || !config.mvStore) {
return; return;
} }
testSelectForUpdateAndUpdateConcurrency(); testSelectForUpdateAndUpdateConcurrency();
......
...@@ -30,7 +30,7 @@ public class TestMvccMultiThreaded extends TestBase { ...@@ -30,7 +30,7 @@ public class TestMvccMultiThreaded extends TestBase {
@Override @Override
public void test() throws Exception { public void test() throws Exception {
if (!config.mvcc) { if (!config.mvStore) {
return; return;
} }
testConcurrentSelectForUpdate(); testConcurrentSelectForUpdate();
......
...@@ -33,7 +33,6 @@ public class TestMvccMultiThreaded2 extends TestBase { ...@@ -33,7 +33,6 @@ public class TestMvccMultiThreaded2 extends TestBase {
*/ */
public static void main(String... a) throws Exception { public static void main(String... a) throws Exception {
TestBase test = TestBase.createCaller().init(); TestBase test = TestBase.createCaller().init();
test.config.mvcc = true;
test.config.lockTimeout = 120000; test.config.lockTimeout = 120000;
test.config.memory = true; test.config.memory = true;
test.config.multiThreaded = true; test.config.multiThreaded = true;
...@@ -47,7 +46,7 @@ public class TestMvccMultiThreaded2 extends TestBase { ...@@ -47,7 +46,7 @@ public class TestMvccMultiThreaded2 extends TestBase {
@Override @Override
public void test() throws SQLException, InterruptedException { public void test() throws SQLException, InterruptedException {
if (!config.mvcc) { if (!config.mvStore) {
return; return;
} }
testSelectForUpdateConcurrency(); testSelectForUpdateConcurrency();
......
...@@ -154,7 +154,7 @@ public class TestCrashAPI extends TestBase implements Runnable { ...@@ -154,7 +154,7 @@ public class TestCrashAPI extends TestBase implements Runnable {
recoverAll(); recoverAll();
return; return;
} }
if (config.mvcc || config.networked) { if (config.mvStore || config.networked) {
return; return;
} }
int len = getSize(2, 6); int len = getSize(2, 6);
...@@ -531,7 +531,7 @@ public class TestCrashAPI extends TestBase implements Runnable { ...@@ -531,7 +531,7 @@ public class TestCrashAPI extends TestBase implements Runnable {
@Override @Override
public TestBase init(TestAll conf) throws Exception { public TestBase init(TestAll conf) throws Exception {
super.init(conf); super.init(conf);
if (config.mvcc || config.networked) { if (config.mvStore || config.networked) {
return this; return this;
} }
startServerIfRequired(); startServerIfRequired();
......
...@@ -123,7 +123,7 @@ public class TestMultiThreaded extends TestBase { ...@@ -123,7 +123,7 @@ public class TestMultiThreaded extends TestBase {
@Override @Override
public void test() throws Exception { public void test() throws Exception {
if (config.mvcc) { if (config.mvStore) {
return; return;
} }
deleteDb("multiThreaded"); deleteDb("multiThreaded");
......
...@@ -27,7 +27,6 @@ public class TestReleaseSelectLock extends TestBase { ...@@ -27,7 +27,6 @@ public class TestReleaseSelectLock extends TestBase {
public static void main(String... a) throws Exception { public static void main(String... a) throws Exception {
TestBase test = TestBase.createCaller().init(); TestBase test = TestBase.createCaller().init();
test.config.mvStore = false; test.config.mvStore = false;
test.config.mvcc = false;
test.config.multiThreaded = true; test.config.multiThreaded = true;
test.test(); test.test();
} }
......
...@@ -33,7 +33,6 @@ public class TestJmx extends TestBase { ...@@ -33,7 +33,6 @@ public class TestJmx extends TestBase {
public static void main(String... a) throws Exception { public static void main(String... a) throws Exception {
TestBase base = TestBase.createCaller().init(); TestBase base = TestBase.createCaller().init();
base.config.mvStore = false; base.config.mvStore = false;
base.config.mvcc = false;
base.test(); base.test();
} }
...@@ -114,7 +113,7 @@ public class TestJmx extends TestBase { ...@@ -114,7 +113,7 @@ public class TestJmx extends TestBase {
result = mbeanServer.invoke(name, "listSessions", null, null).toString(); result = mbeanServer.invoke(name, "listSessions", null, null).toString();
assertContains(result, "session id"); assertContains(result, "session id");
if (config.mvcc || config.mvStore) { if (config.mvStore) {
assertContains(result, "read lock"); assertContains(result, "read lock");
} else { } else {
assertContains(result, "write lock"); assertContains(result, "write lock");
......
...@@ -33,7 +33,7 @@ public class TestMultiThreadedKernel extends TestBase implements Runnable { ...@@ -33,7 +33,7 @@ public class TestMultiThreadedKernel extends TestBase implements Runnable {
@Override @Override
public void test() throws Exception { public void test() throws Exception {
if (config.networked || config.mvcc) { if (config.networked || config.mvStore) {
return; return;
} }
deleteDb("multiThreadedKernel"); deleteDb("multiThreadedKernel");
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论