test/jdbc/Connection/IsoTest2.java

   1 //Open two connections and call setTransactionIsolation(TRANSACTION_UNCOMMITTED ).
   2 //From 1st connection insert tuple and then sleep, from 2nd connection try to select the inserted tuple.
   3 //Tuple should be seen.
   4 //Author: XieLiang
   5 import java.sql.*;
   6 public class IsoTest2
   7 {
   8     public static void main(String[] args)
   9     {
  10        try
  11        {
  12            Class.forName("csql.jdbc.JdbcSqlDriver");
  13            Connection con1 = DriverManager.getConnection("jdbc:csql", "root", "manager");
  14            Connection con2 = DriverManager.getConnection("jdbc:csql", "root", "manager");
  15            if ( (con1 == null) || (con2 == null) )
  16                    System.out.println("test failed!");
  17            con1.setTransactionIsolation(Connection.TRANSACTION_READ_UNCOMMITTED);
  18            con2.setTransactionIsolation(Connection.TRANSACTION_READ_UNCOMMITTED);
  19            con1.setAutoCommit(false);
  20            con2.setAutoCommit(false);
  21            Statement cStmt = con1.createStatement();
  22            cStmt.execute("CREATE TABLE T1(f1 integer,f2 char(20));");
  23            PreparedStatement stmt = null;
  24            stmt = con1.prepareStatement("INSERT INTO T1 VALUES(?,?);");
  25            stmt.setInt(1,1);
  26            stmt.setString(2,"test");
  27            int ret = 0;
  28            ret = stmt.executeUpdate();
  29            if (ret != 1) {
  30                con1.close();
  31                con2.close();
  32                System.exit(1);
  33            }
  34
  35            cStmt = con2.createStatement();
  36            ResultSet rs = cStmt.executeQuery("SELECT * FROM T1;");
  37            int count =0;
  38            while(rs.next())
  39            {
  40                count++;
  41            }
  42            rs.close();
  43            cStmt.execute("DROP TABLE T1;");
  44            con1.close();
  45            con2.close();
  46            if (count !=1) System.exit(1); else System.exit(0);
  47         }catch(Exception e) {
  48             System.out.println(e.getMessage());
  49             e.getStackTrace();
  50             System.exit(1);
  51        }
  52     }
  53 }