@@ -271,7 +271,7 @@ public class TestLob extends TestBase {
...
@@ -271,7 +271,7 @@ public class TestLob extends TestBase {
};
};
task.execute();
task.execute();
stat.execute("create table test2(id int primary key, name clob)");
stat.execute("create table test2(id int primary key, name clob)");
for(inti=0;i<1000;i++){
for(inti=0;i<100;i++){
stat.execute("delete from test2");
stat.execute("delete from test2");
stat.execute("insert into test2 values(1, space(10000 + "+i+"))");
stat.execute("insert into test2 values(1, space(10000 + "+i+"))");
}
}
...
@@ -366,34 +366,18 @@ public class TestLob extends TestBase {
...
@@ -366,34 +366,18 @@ public class TestLob extends TestBase {
Connectionconn=getDeadlock2Connection();
Connectionconn=getDeadlock2Connection();
Statementstat=conn.createStatement();
Statementstat=conn.createStatement();
stat.execute("create cached table test(id int not null identity, name clob, counter int)");
stat.execute("create cached table test(id int not null identity, name clob, counter int)");
stat.execute("insert into test(id, name) select x, space(100000) from system_range(1, 1000)");
stat.execute("insert into test(id, name) select x, space(100000) from system_range(1, 100)");
Deadlock2Task1task1=newDeadlock2Task1();
Deadlock2Task1task1=newDeadlock2Task1();
Deadlock2Task1task2=newDeadlock2Task1();
Deadlock2Task2task2=newDeadlock2Task2();
Deadlock2Task1task3=newDeadlock2Task1();
Deadlock2Task1task4=newDeadlock2Task1();
Deadlock2Task2task5=newDeadlock2Task2();
Deadlock2Task2task6=newDeadlock2Task2();
task1.execute("task1");
task1.execute("task1");
task2.execute("task2");
task2.execute("task2");
task3.execute("task3");
for(inti=0;i<100;i++){
task4.execute("task4");
task5.execute("task5");
task6.execute("task6");
for(inti=0;i<1000;i++){
stat.execute("insert into test values(null, space(10000 + "+i+"), 1)");
stat.execute("insert into test values(null, space(10000 + "+i+"), 1)");
}
}
task1.get();
task1.get();
task1.conn.close();
task1.conn.close();
task2.get();
task2.get();
task2.conn.close();
task2.conn.close();
task3.get();
task3.conn.close();
task4.get();
task4.conn.close();
task5.get();
task5.conn.close();
task6.get();
task6.conn.close();
conn.close();
conn.close();
}
}
...
@@ -694,25 +678,25 @@ public class TestLob extends TestBase {
...
@@ -694,25 +678,25 @@ public class TestLob extends TestBase {
Connectionconn=getConnection("lob");
Connectionconn=getConnection("lob");
Statementstat=conn.createStatement();
Statementstat=conn.createStatement();
stat.execute("create table test(data clob)");
stat.execute("create table test(data clob)");
ResultSetrs=stat.executeQuery("select count(*) from INFORMATION_SCHEMA.LOBS");
ResultSetrs=stat.executeQuery("select count(*) from INFORMATION_SCHEMA.LOBS");
assertTrue(rs.next());
assertTrue(rs.next());
assertEquals(0,rs.getInt(1));
assertEquals(0,rs.getInt(1));
rs.close();
rs.close();
PreparedStatementprep=conn.prepareStatement("INSERT INTO test(data) VALUES(?)");
PreparedStatementprep=conn.prepareStatement("INSERT INTO test(data) VALUES(?)");
finalStringname="A veeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeery long string generated only to insert enough data to reproduce the increasing db size PITA ";