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

Execute TestSessionLocks only with config.multiThreaded

上级 e139ecde
...@@ -27,6 +27,9 @@ public class TestSessionsLocks extends TestBase { ...@@ -27,6 +27,9 @@ public class TestSessionsLocks extends TestBase {
@Override @Override
public void test() throws Exception { public void test() throws Exception {
if (!config.multiThreaded) {
return;
}
testCancelStatement(); testCancelStatement();
if (!config.mvcc) { if (!config.mvcc) {
testLocks(); testLocks();
...@@ -36,7 +39,7 @@ public class TestSessionsLocks extends TestBase { ...@@ -36,7 +39,7 @@ public class TestSessionsLocks extends TestBase {
private void testLocks() throws SQLException { private void testLocks() throws SQLException {
deleteDb("sessionsLocks"); deleteDb("sessionsLocks");
Connection conn = getConnection("sessionsLocks;MULTI_THREADED=1"); Connection conn = getConnection("sessionsLocks");
Statement stat = conn.createStatement(); Statement stat = conn.createStatement();
ResultSet rs; ResultSet rs;
rs = stat.executeQuery("select * from information_schema.locks " + rs = stat.executeQuery("select * from information_schema.locks " +
...@@ -82,7 +85,7 @@ public class TestSessionsLocks extends TestBase { ...@@ -82,7 +85,7 @@ public class TestSessionsLocks extends TestBase {
private void testCancelStatement() throws Exception { private void testCancelStatement() throws Exception {
deleteDb("sessionsLocks"); deleteDb("sessionsLocks");
Connection conn = getConnection("sessionsLocks;MULTI_THREADED=1"); Connection conn = getConnection("sessionsLocks");
Statement stat = conn.createStatement(); Statement stat = conn.createStatement();
ResultSet rs; ResultSet rs;
rs = stat.executeQuery("select * from information_schema.sessions " + rs = stat.executeQuery("select * from information_schema.sessions " +
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论