提交 55510da7 authored 作者: Thomas Mueller's avatar Thomas Mueller

MVStore: deal with the case that data was moved to a new chunk (work in progress)

上级 8497c759
...@@ -81,10 +81,10 @@ public class TestMVTableEngine extends TestBase { ...@@ -81,10 +81,10 @@ public class TestMVTableEngine extends TestBase {
} }
private void testLowRetentionTime() throws SQLException { private void testLowRetentionTime() throws SQLException {
deleteDb("mvstore"); deleteDb("testLowRetentionTime");
Connection conn = getConnection("mvstore;RETENTION_TIME=10;WRITE_DELAY=10"); Connection conn = getConnection("testLowRetentionTime;RETENTION_TIME=10;WRITE_DELAY=10");
Statement stat = conn.createStatement(); Statement stat = conn.createStatement();
Connection conn2 = getConnection("mvstore"); Connection conn2 = getConnection("testLowRetentionTime");
Statement stat2 = conn2.createStatement(); Statement stat2 = conn2.createStatement();
stat.execute("create alias sleep as $$void sleep(int ms) throws Exception { Thread.sleep(ms); }$$"); stat.execute("create alias sleep as $$void sleep(int ms) throws Exception { Thread.sleep(ms); }$$");
stat.execute("create table test(id identity, name varchar) as select x, 'Init' from system_range(0, 1999)"); stat.execute("create table test(id identity, name varchar) as select x, 'Init' from system_range(0, 1999)");
...@@ -102,6 +102,7 @@ public class TestMVTableEngine extends TestBase { ...@@ -102,6 +102,7 @@ public class TestMVTableEngine extends TestBase {
assertEquals(i, rs.getInt(1)); assertEquals(i, rs.getInt(1));
} }
assertFalse(rs.next()); assertFalse(rs.next());
conn2.close();
conn.close(); conn.close();
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论