test/jdbc/network/Gateway/GwTest10.java

   1
   2 //1. Donot run csqlserver
   3 //Then do (INSERT/UPDATE/DELETE/SELECT) with params statement using gateway statement
   4
   5 import java.sql.Connection;
   6 import java.sql.DriverManager;
   7 import java.sql.PreparedStatement;
   8 import java.sql.ResultSet;
   9 import java.sql.Statement;
  10
  11
  12 /**
  13  *
  14  * @Author : Nihar
  15  */
  16 public class GwTest10 {
  17      public static void main(String[] args)
  18     {
  19        try
  20        {
  21            Class.forName("csql.jdbc.JdbcSqlDriver");
  22            Connection con = DriverManager.getConnection("jdbc:gateway://localhost:5678", "root", "manager");
  23            Statement cStmt = con.createStatement();
  24            PreparedStatement stmt = null, selStmt= null;
  25            stmt = con.prepareStatement("INSERT INTO t1 VALUES (?, ?);");
  26            for (int i =0 ; i< 10 ; i++) {
  27              stmt.setInt(1, i);
  28              stmt.setString(2, String.valueOf(i+100));
  29              stmt.executeUpdate();
  30            }
  31            stmt.close();
  32            con.commit();
  33            selStmt = con.prepareStatement("SELECT * from t1 where f1 = ?;");
  34            ResultSet rs = null;
  35            for (int i =0 ; i< 10 ; i++) {
  36              selStmt.setInt(1, i);
  37              rs = selStmt.executeQuery();
  38              while (rs.next())
  39              {
  40                  System.out.println("Tuple value is " + rs.getInt(1)+ " "+ rs.getString(2));
  41              }
  42              rs.close();
  43            }
  44            int ret=0;
  45            stmt = con.prepareStatement("UPDATE t1 SET f2 = ? WHERE f1 = ?;");
  46            for (int i =0 ; i< 10 ; i +=2) {
  47              stmt.setString(1, String.valueOf(i+200));
  48              stmt.setInt(2, i);
  49              ret = stmt.executeUpdate();
  50              if (ret != 1) break;
  51            }
  52            stmt.close();
  53            con.commit();
  54            System.out.println("After update, listing tuples:");
  55            for (int i =0 ; i< 10 ; i++) {
  56              selStmt.setInt(1, i);
  57              rs = selStmt.executeQuery();
  58              while (rs.next())
  59              {
  60                  System.out.println("Tuple value is " + rs.getInt(1)+ " "+ rs.getString(2));
  61              }
  62              rs.close();
  63            }
  64            con.commit();
  65            stmt = con.prepareStatement("DELETE FROM t1 WHERE f1 = ?;");
  66            for (int i =0 ; i< 10 ; i +=3) {
  67              stmt.setInt(1, i);
  68              ret = stmt.executeUpdate();
  69              if (ret !=1) break;
  70            }
  71            stmt.close();
  72            con.commit();
  73
  74            System.out.println("After delete, listing tuples:");
  75            for (int i =0 ; i< 10 ; i++) {
  76              selStmt.setInt(1, i);
  77              rs = selStmt.executeQuery();
  78              while (rs.next())
  79              {
  80                  System.out.println("Tuple value is " + rs.getInt(1)+ " "+ rs.getString(2));
  81              }
  82              rs.close();
  83            }
  84            con.commit();
  85            con.close();
  86         }catch(Exception e) {
  87              System.out.println("Exception in Test: "+e);
  88              e.printStackTrace();
  89         }
  90     }
  91
  92 }