1 5 package org.h2.test.db; 6 7 import java.sql.*; 8 9 import org.h2.test.TestBase; 10 11 public class TestCheckpoint extends TestBase { 12 13 public void test() throws Exception { 14 deleteDb("checkpoint"); 16 Connection c0 = getConnection("checkpoint"); 17 Statement s0 = c0.createStatement(); 18 Connection c1 = getConnection("checkpoint"); 19 Statement s1 = c1.createStatement(); 20 s1.execute("CREATE TABLE TEST(ID INT PRIMARY KEY, NAME VARCHAR(255))"); 21 s1.execute("INSERT INTO TEST VALUES(1, 'Hello')"); 22 s0.execute("CHECKPOINT"); 23 24 s1.execute("INSERT INTO TEST VALUES(2, 'World')"); 25 c1.setAutoCommit(false); 26 s1.execute("INSERT INTO TEST VALUES(3, 'Maybe')"); 27 s0.execute("CHECKPOINT"); 28 29 s1.execute("INSERT INTO TEST VALUES(4, 'Or not')"); 30 s0.execute("CHECKPOINT"); 31 32 s1.execute("INSERT INTO TEST VALUES(5, 'ok yes')"); 33 s1.execute("COMMIT"); 34 s0.execute("CHECKPOINT"); 35 36 c0.close(); 37 c1.close(); 38 } 39 40 } 41 | Popular Tags |