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

Remove MVCC setting from some connection URLs in tests

上级 2a2a7b13
...@@ -529,7 +529,7 @@ public class TestGeneralCommonTableQueries extends AbstractBaseForCommonTableExp ...@@ -529,7 +529,7 @@ public class TestGeneralCommonTableQueries extends AbstractBaseForCommonTableExp
try { try {
// Test with settings: lazy mvStore memory mvcc multiThreaded // Test with settings: lazy mvStore memory mvcc multiThreaded
// connection url is // connection url is
// mem:script;MV_STORE=true;LOG=1;LOCK_TIMEOUT=50;MVCC=TRUE; // mem:script;MV_STORE=true;LOG=1;LOCK_TIMEOUT=50;
// MULTI_THREADED=TRUE;LAZY_QUERY_EXECUTION=1 // MULTI_THREADED=TRUE;LAZY_QUERY_EXECUTION=1
config.lazy = true; config.lazy = true;
config.mvStore = true; config.mvStore = true;
......
...@@ -76,9 +76,9 @@ public class TestMvcc1 extends TestBase { ...@@ -76,9 +76,9 @@ public class TestMvcc1 extends TestBase {
// selects new data (select * from test where id > ?) and deletes // selects new data (select * from test where id > ?) and deletes
deleteDb("mvcc1"); deleteDb("mvcc1");
c1 = getConnection("mvcc1;MVCC=TRUE;LOCK_TIMEOUT=10"); c1 = getConnection("mvcc1;LOCK_TIMEOUT=10");
s1 = c1.createStatement(); s1 = c1.createStatement();
c2 = getConnection("mvcc1;MVCC=TRUE;LOCK_TIMEOUT=10"); c2 = getConnection("mvcc1;LOCK_TIMEOUT=10");
s2 = c2.createStatement(); s2 = c2.createStatement();
c1.setAutoCommit(false); c1.setAutoCommit(false);
c2.setAutoCommit(false); c2.setAutoCommit(false);
......
...@@ -92,7 +92,7 @@ public class TestMvccMultiThreaded extends TestBase { ...@@ -92,7 +92,7 @@ public class TestMvccMultiThreaded extends TestBase {
final Connection[] connList = new Connection[len]; final Connection[] connList = new Connection[len];
for (int i = 0; i < len; i++) { for (int i = 0; i < len; i++) {
Connection conn = getConnection( Connection conn = getConnection(
getTestName() + ";MVCC=TRUE;LOCK_TIMEOUT=500"); getTestName() + ";LOCK_TIMEOUT=500");
connList[i] = conn; connList[i] = conn;
} }
Connection conn = connList[0]; Connection conn = connList[0];
...@@ -129,8 +129,7 @@ public class TestMvccMultiThreaded extends TestBase { ...@@ -129,8 +129,7 @@ public class TestMvccMultiThreaded extends TestBase {
int len = 2; int len = 2;
final Connection[] connList = new Connection[len]; final Connection[] connList = new Connection[len];
for (int i = 0; i < len; i++) { for (int i = 0; i < len; i++) {
connList[i] = getConnection( connList[i] = getConnection(getTestName());
getTestName() + ";MVCC=TRUE");
} }
Connection conn = connList[0]; Connection conn = connList[0];
conn.createStatement().execute( conn.createStatement().execute(
......
...@@ -24,7 +24,7 @@ public class TestMvccMultiThreaded2 extends TestBase { ...@@ -24,7 +24,7 @@ public class TestMvccMultiThreaded2 extends TestBase {
private static final int TEST_TIME_SECONDS = 60; private static final int TEST_TIME_SECONDS = 60;
private static final boolean DISPLAY_STATS = false; private static final boolean DISPLAY_STATS = false;
private static final String URL = ";MVCC=TRUE;LOCK_TIMEOUT=120000;MULTI_THREADED=TRUE"; private static final String URL = ";LOCK_TIMEOUT=120000;MULTI_THREADED=TRUE";
/** /**
* Run just this test. * Run just this test.
......
...@@ -38,7 +38,9 @@ public class TestRowLocks extends TestBase { ...@@ -38,7 +38,9 @@ public class TestRowLocks extends TestBase {
@Override @Override
public void test() throws Exception { public void test() throws Exception {
testSetMode(); testSetMode();
testCases(); if (config.mvStore) {
testCases();
}
deleteDb(getTestName()); deleteDb(getTestName());
} }
...@@ -55,7 +57,7 @@ public class TestRowLocks extends TestBase { ...@@ -55,7 +57,7 @@ public class TestRowLocks extends TestBase {
private void testCases() throws Exception { private void testCases() throws Exception {
deleteDb(getTestName()); deleteDb(getTestName());
c1 = getConnection(getTestName() + ";MVCC=TRUE"); c1 = getConnection(getTestName());
s1 = c1.createStatement(); s1 = c1.createStatement();
s1.execute("SET LOCK_TIMEOUT 10000"); s1.execute("SET LOCK_TIMEOUT 10000");
s1.execute("CREATE TABLE TEST AS " + s1.execute("CREATE TABLE TEST AS " +
......
...@@ -506,7 +506,7 @@ public class TestMVTableEngine extends TestBase { ...@@ -506,7 +506,7 @@ public class TestMVTableEngine extends TestBase {
Statement stat; Statement stat;
Statement stat2; Statement stat2;
deleteDb(getTestName()); deleteDb(getTestName());
String url = getTestName() + ";MV_STORE=TRUE;MVCC=TRUE"; String url = getTestName() + ";MV_STORE=TRUE";
url = getURL(url, true); url = getURL(url, true);
conn = getConnection(url); conn = getConnection(url);
stat = conn.createStatement(); stat = conn.createStatement();
...@@ -563,7 +563,7 @@ public class TestMVTableEngine extends TestBase { ...@@ -563,7 +563,7 @@ public class TestMVTableEngine extends TestBase {
Statement stat; Statement stat;
Statement stat2; Statement stat2;
deleteDb(getTestName()); deleteDb(getTestName());
String url = getTestName() + ";MV_STORE=TRUE;MVCC=TRUE"; String url = getTestName() + ";MV_STORE=TRUE";
url = getURL(url, true); url = getURL(url, true);
conn = getConnection(url); conn = getConnection(url);
stat = conn.createStatement(); stat = conn.createStatement();
...@@ -593,7 +593,7 @@ public class TestMVTableEngine extends TestBase { ...@@ -593,7 +593,7 @@ public class TestMVTableEngine extends TestBase {
Statement stat; Statement stat;
Statement stat2; Statement stat2;
deleteDb(getTestName()); deleteDb(getTestName());
String url = getTestName() + ";MV_STORE=TRUE;MVCC=TRUE"; String url = getTestName() + ";MV_STORE=TRUE";
url = getURL(url, true); url = getURL(url, true);
conn = getConnection(url); conn = getConnection(url);
stat = conn.createStatement(); stat = conn.createStatement();
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论