test/soakTest/jdbcSelect1.java

   1 import java.sql.*;
   2 import java.io.*;
   3 import java.util.Calendar;
   4 import java.text.SimpleDateFormat;
   5
   6 public class jdbcSelect1
   7 {
   8     public static final String DATE_FORMAT_NOW = "yyyy-MM-dd HH:mm:ss";
   9
  10     public static String now() {
  11         Calendar cal = Calendar.getInstance();
  12         SimpleDateFormat sdf = new SimpleDateFormat(DATE_FORMAT_NOW);
  13         return sdf.format(cal.getTime());
  14     }
  15
  16     public static void main(String[] args)
  17     {
  18         try {
  19             if (args.length != 1) {
  20                 System.out.println("Usage: java jdbcSelect1 <opfile>\n");
  21                 return;
  22             }
  23
  24             Class.forName("csql.jdbc.JdbcSqlDriver");
  25             Connection con = DriverManager.getConnection("jdbc:csql", "root", "manager");
  26             Connection adCon = DriverManager.getConnection("jdbc:Adapter", "root", "manager");
  27             PreparedStatement stmt = null, selStmt= null;
  28             PreparedStatement adStmt = null, adSelStmt= null;
  29             selStmt=con.prepareStatement("select count(f1) from soakTable;");
  30             adSelStmt=adCon.prepareStatement("select count(f1) from soakTable;");
  31             ResultSet rs = null, adrs =null; int f1var=0, f2var=0, f3var=0;
  32             FileWriter fstream = new FileWriter(args[0], true);
  33             BufferedWriter out = new BufferedWriter(fstream);
  34
  35             while(true){
  36                 try {
  37                 rs= selStmt.executeQuery();
  38                 if(rs.next()){
  39                     f1var=rs.getInt(1);
  40                 }
  41                 rs.close();
  42                 adrs=adSelStmt.executeQuery();
  43                 if(adrs.next()){
  44                     f2var=adrs.getInt(1);
  45                 }
  46                 adrs.close();
  47                 con.commit();
  48                 adCon.commit();
  49                 out.write("Total Records in CSQL: " +f1var+" "+jdbcDelete.now()+"\n");
  50                 out.write("Total Records in DRDB: " +f2var+" "+jdbcDelete.now()+"\n");
  51                 out.flush();
  52                 Thread.sleep(60000);
  53               } catch(Exception ex) {
  54               System.out.println("Exception: "+ ex);
  55                System.out.println("jdbcSelect1 failed at "+jdbcDelete.now());
  56             }
  57         }
  58     } catch (Exception e) {
  59             System.out.println("Exception: "+ e);
  60         }
  61    }
  62 }
  63
  64
  65
  66