test/sqlnetwork/Jdbcnetwork/StmtTest2.java

   1 //Create a table and index for that table. Then do (INSERT/UPDATE/DELETE/SELECT) with no params statement.
   2 import java.sql.*;
   3 public class StmtTest2
   4 {
   5     public static void main(String[] args)
   6     {
   7        try
   8        {
   9            Class.forName("csql.jdbc.JdbcSqlDriver");
  10            Connection con = DriverManager.getConnection("jdbc:csql://localhost:5678/csql", "root", "manager");
  11            Statement cStmt = con.createStatement();
  12            cStmt.execute("CREATE TABLE T1 (f1 integer, f2 char (20));");
  13            cStmt.execute("CREATE INDEX IDX ON T1 ( f1);");
  14            con.commit();
  15
  16            cStmt.execute("INSERT INTO T1 VALUES (1, 'FIRST');");
  17            cStmt.executeUpdate("INSERT INTO T1 VALUES (2, 'SECOND');");
  18            con.commit();
  19
  20            ResultSet rs = null;
  21            rs = cStmt.executeQuery("SELECT * from T1 where f1 = 1;");
  22            while (rs.next())
  23            {
  24                System.out.println("Tuple value is " + rs.getInt(1)+ " "+ rs.getString(2));
  25            }
  26            rs.close();
  27
  28
  29            cStmt.execute("SELECT * from T1 where f1 = 2;");
  30            rs = cStmt.getResultSet();
  31            while (rs.next())
  32            {
  33                System.out.println("Tuple value is " + rs.getInt(1)+ " "+ rs.getString(2));
  34            }
  35            rs.close();
  36            con.commit();
  37
  38            cStmt.executeUpdate("UPDATE T1 SET f2 = 'CHANGED' WHERE f1 = 1;");
  39            con.commit();
  40
  41
  42
  43            cStmt.executeUpdate("DELETE FROM T1 WHERE f1 = 2;");
  44            con.commit();
  45
  46            System.out.println("After delete, listing tuples:");
  47            rs = cStmt.executeQuery("SELECT * from T1 ;");
  48            while (rs.next())
  49            {
  50                System.out.println("Tuple value is " + rs.getInt(1)+ " "+ rs.getString(2));
  51            }
  52            rs.close();
  53            con.commit();
  54            cStmt.execute("DROP TABLE T1 ;");
  55            con.close();
  56         }catch(Exception e) {
  57             System.out.println("Exception in Test: "+e);
  58             e.printStackTrace();
  59         }
  60     }
  61 }