test/jdbc/network/Statement/TestScript3.java

   1 //ExecuteUpdate Should return no of records updated
   2
   3 import java.sql.Connection;
   4 import java.sql.DriverManager;
   5 import java.sql.PreparedStatement;
   6 import java.sql.ResultSet;
   7 import java.sql.Statement;
   8
   9 /**
  10  *
  11  * @author bijaya
  12  */
  13 public class TestScript3 {
  14  public static void main(String[] args)
  15     {
  16        try
  17        {
  18            Class.forName("csql.jdbc.JdbcSqlDriver");
  19            Connection con = DriverManager.getConnection("jdbc:csql://localhost:5678", "root", "manager");
  20            Statement cStmt = con.createStatement();
  21            cStmt.execute("CREATE TABLE T1 (f1 integer, f2 char (20));");
  22            cStmt.execute("CREATE INDEX IDX ON T1 ( f1);");
  23            con.commit();
  24            PreparedStatement stmt = null, selStmt= null;
  25            stmt = con.prepareStatement("INSERT INTO T1 VALUES (?, ?);");
  26            int ret=0;
  27            for (int i =0 ; i< 10 ; i++) {
  28              stmt.setInt(1, i);
  29              stmt.setString(2, String.valueOf(i+100));
  30              ret=stmt.executeUpdate();
  31              if (ret != 1){
  32                  System.out.println("ExecuteUpdate doesnot return proper values in Insert "+ret);
  33                  break;
  34              }
  35               System.out.println("ExecuteUpdate return proper values in Insert ");
  36            }
  37            stmt.close();
  38            con.commit();
  39            selStmt = con.prepareStatement("SELECT * from T1 where f1 = ?;");
  40            ResultSet rs = null;
  41            for (int i =0 ; i< 10 ; i++) {
  42              selStmt.setInt(1, i);
  43              rs = selStmt.executeQuery();
  44              while (rs.next())
  45              {
  46                  System.out.println("Tuple value is " + rs.getInt(1)+ " "+ rs.getString(2));
  47              }
  48              rs.close();
  49            }
  50            int a=5;
  51            stmt = con.prepareStatement("UPDATE T1 SET f2 = ? WHERE f1 >5;");
  52
  53              stmt.setString(1, String.valueOf(a+200));
  54
  55              ret = stmt.executeUpdate();
  56              if (ret != 4){
  57                  System.out.println("ExecuteUpdate doesnot return proper values for Update "+ret);
  58              }
  59              System.out.println("ExecuteUpdate return proper values fro Update "+ret);
  60
  61            stmt.close();
  62            con.commit();
  63
  64            System.out.println("After update, listing tuples:");
  65            for (int i =0 ; i< 10 ; i++) {
  66              selStmt.setInt(1, i);
  67              rs = selStmt.executeQuery();
  68              while (rs.next())
  69              {
  70                  System.out.println("Tuple value is " + rs.getInt(1)+ " "+ rs.getString(2));
  71              }
  72              rs.close();
  73            }
  74            con.commit();
  75
  76            stmt = con.prepareStatement("DELETE FROM T1 ;");
  77
  78
  79              ret = stmt.executeUpdate();
  80              if (ret !=10)
  81              {
  82                  System.out.println("ExecuteUpdate doesnot return proper vslues for Delete "+ret);
  83              }
  84              System.out.println("ExecuteUpdate returns proper vslues for delete "+ret);
  85
  86            stmt.close();
  87            con.commit();
  88
  89
  90            cStmt.execute("DROP TABLE T1 ;");
  91            con.close();
  92         }catch(Exception e) {
  93
  94              System.out.println("Exception in Test: "+e);
  95              e.printStackTrace();
  96         }
  97     }
  98 }
  99