test/jdbc/network/Adapter/AdStmt1.java

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