test/soakTest/jdbcDelete.java

   1 import java.sql.*;
   2 import java.io.*;
   3 import java.util.Calendar;
   4 import java.text.SimpleDateFormat;
   5
   6 public class jdbcDelete
   7 {
   8     public static final String DATE_FORMAT_NOW = "yyyy-MM-dd HH:mm:ss";
   9     public static final int TS = 1;
  10
  11     public static String now() {
  12         Calendar cal = Calendar.getInstance();
  13         SimpleDateFormat sdf = new SimpleDateFormat(DATE_FORMAT_NOW);
  14         return sdf.format(cal.getTime());
  15     }
  16
  17     public static void main(String[] args)
  18     {
  19         try {
  20             if (args.length != 1) {
  21                 System.out.println("Usage: java jdbcDelete <opfile>\n");
  22                 return;
  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, delStmt = null, adSelStmt=null, adDelStmt=null;
  28             selStmt = con.prepareStatement("select f2 from soakTable limit 1;");
  29             delStmt = con.prepareStatement("delete from soakTable where f2 = ?;");
  30 //            adSelStmt = adCon.prepareStatement("select f2 from soakTable limit 1;");
  31             adDelStmt = adCon.prepareStatement("delete from soakTable where f2 = ?;");
  32             ResultSet rs = null, adrs = null; int f2var = 0;
  33             FileWriter fstream = new FileWriter(args[0], true);
  34             BufferedWriter out = new BufferedWriter(fstream);
  35             while (true) {
  36                 try {
  37                 Thread.sleep(jdbcDelete.TS);
  38                 rs = selStmt.executeQuery();
  39                 if(rs.next()) { f2var = rs.getInt(1); }
  40                 rs.close();
  41      //           adrs = adSelStmt.executeQuery();
  42   //              if(adrs.next()) { f2var = adrs.getInt(1); }
  43   //              adrs.close();
  44                 delStmt.setInt(1,f2var);
  45                 delStmt.execute();
  46                 con.commit();
  47                 adDelStmt.setInt(1,f2var);
  48                 adDelStmt.execute();
  49                 adCon.commit();
  50                 //System.out.println("f2var = "+f2var+" "+jdbcDelete.now());
  51                 out.write("deleted PK: " +f2var + " "+jdbcDelete.now()+"\n");
  52                 out.flush();
  53               } catch(Exception ex) {
  54                   System.out.println("Exception: "+ ex);
  55                   System.out.println("jdbcDelete fail f2 = "+f2var+" "+jdbcDelete.now());
  56               }
  57             }
  58         } catch (Exception e) {
  59             System.out.println("Exception: "+ e);
  60         }
  61     }
  62 }
  63