test/jdbc/network/Gateway/GwStmt9.java

   1 //Null statement test in Gateway for parameteraze statement on cache table
   2 import java.sql.*;
   3 /**
   4  *
   5  * @Author : Nihar
   6  */
   7 public class GwStmt9 {
   8 public static void main(String[] args) {
   9
  10          try
  11         {
  12             Class.forName("csql.jdbc.JdbcSqlDriver");
  13             Connection con=DriverManager.getConnection("jdbc:gateway://localhost:5678","root","manager");
  14             Statement cStmt=con.createStatement();
  15             PreparedStatement stmt=null,selStmt=null;
  16             stmt=con.prepareStatement("INSERT INTO t1 VALUES(?,?,?,?,?,?,?,?);");
  17             int ret=0;
  18             for(int i=0;i<10;i++)
  19             {
  20                 if(i==2 ) {
  21                     stmt.setNull(1,java.sql.Types.INTEGER);
  22                     stmt.setNull(2,java.sql.Types.SMALLINT);
  23 //                    stmt.setNull(3,java.sql.Types.TINYINT);
  24                     stmt.setNull(3,java.sql.Types.BIGINT);
  25                     stmt.setNull(4,java.sql.Types.FLOAT);
  26                     stmt.setNull(5,java.sql.Types.CHAR);
  27                     stmt.setNull(6,java.sql.Types.DATE);
  28                     stmt.setNull(7,java.sql.Types.TIME);
  29                     stmt.setNull(8,java.sql.Types.TIMESTAMP);
  30                 }else{
  31                 stmt.setInt(1,i);
  32                 stmt.setShort(2,(short)(i+1));
  33 //                stmt.setByte(3,(byte)(i+2));
  34                 stmt.setLong(3,(long)i);
  35                 stmt.setFloat(4,(float)1000+i);
  36                 stmt.setString(5, String.valueOf("India"+i));
  37                 stmt.setDate(6,Date.valueOf("2008-03-21"));
  38                 stmt.setTime(7,Time.valueOf("18:00:00"));
  39                 stmt.setTimestamp(8,Timestamp.valueOf("2008-03-21 18:00:00"));
  40                 }
  41                 ret=stmt.executeUpdate();
  42                 if(ret!=1) break;
  43             }
  44             stmt.close();
  45             con.commit();
  46             selStmt=con.prepareStatement("SELECT * FROM t1 ;");
  47             ResultSet rs=null;
  48             rs=selStmt.executeQuery();
  49             while(rs.next())
  50             {
  51
  52                 System.out.print("Tuple value is " + rs.getInt(1)+ " ");
  53                 if(rs.wasNull()) System.out.print(" NULL");
  54                 System.out.print(rs.getShort(2) + " ");
  55                 if(rs.wasNull()) System.out.print(" NULL");
  56   //              System.out.print(rs.getByte(3)  + " ");
  57   //              if(rs.wasNull()) System.out.print(" NULL");
  58                 System.out.print(rs.getLong(3)  + " ");
  59                 if(rs.wasNull()) System.out.print(" NULL");
  60                 System.out.print(rs.getFloat(4) + " ");
  61                 if(rs.wasNull()) System.out.print(" NULL");
  62                 System.out.print(rs.getString(5) + " ");
  63                 if(rs.wasNull()) System.out.print(" NULL");
  64                 System.out.print(rs.getDate(6) + " ");
  65                 if(rs.wasNull()) System.out.print(" NULL");
  66                 System.out.print(rs.getTime(7)  + " ");
  67                 if(rs.wasNull()) System.out.print(" NULL");
  68                 System.out.println(rs.getTimestamp(8) + " ");
  69                 if(rs.wasNull()) System.out.println(" NULL");
  70
  71             }
  72             rs.close();
  73             con.commit();
  74             con.close();
  75         }catch(Exception e) {
  76             System.out.println("Exception in Test: "+e);
  77             e.printStackTrace();
  78         }
  79
  80     }
  81 }