test/jdbc/network/Connection/ConnTest29.java

   1 //Create Connection, insert 1 tuple, call rollback. Repeat the steps(connec,insert,rollback) for 10K times.
   2 //Then connect and check whether 0 tuples are present.
   3 import java.sql.*;
   4 public class ConnTest29
   5 {
   6     public static void main(String[] args)
   7     {
   8        try
   9        {
  10            Class.forName("csql.jdbc.JdbcSqlDriver");
  11            Connection con = DriverManager.getConnection("jdbc:csql://localhost:5678", "root", "manager");
  12            con.setAutoCommit(false);
  13            Statement cStmt = con.createStatement();
  14            PreparedStatement stmt = null;
  15            int ret = 0;
  16            cStmt.execute("CREATE TABLE T1 (f1 integer, f2 char (20));");
  17            con.commit();
  18            con.close();
  19            for (int i=0; i <10000; i++)
  20            {
  21                 con = DriverManager.getConnection("jdbc:csql","root","manager");
  22                 con.setAutoCommit(false);
  23                 stmt = con.prepareStatement("INSERT INTO T1 VALUES(?,?);");
  24                 stmt.setInt(1,1);
  25                 stmt.setString(2,"xieliangkingsoft");
  26                 ret = stmt.executeUpdate();
  27                 if(ret != 1)
  28                 {
  29                    System.out.println("test failed");
  30                    break;
  31                 }
  32                 stmt.close();
  33                 con.rollback();
  34                 con.close();
  35            }
  36            con = DriverManager.getConnection("jdbc:csql","root","manager");
  37            int count = 0;
  38            cStmt = con.createStatement();
  39            ResultSet rs = cStmt.executeQuery("SELECT * from T1;");
  40            while(rs.next())
  41            {
  42                     count++;
  43            }
  44            rs.close();
  45            System.out.println("Total rows selected " + count);
  46            cStmt.execute("DROP TABLE T1;");
  47            con.commit();
  48            con.close();
  49            if (count == 0) System.exit(0); else System.exit(1);
  50         }catch(Exception e) {
  51            System.out.println("Exception in Test: "+e);
  52            e.printStackTrace();
  53            System.exit(1);
  54         }
  55     }
  56 }