test/soakTest/jdbcUpdate.java

   1 import java.sql.*;
   2 import java.io.*;
   3 import java.util.Calendar;
   4 import java.text.SimpleDateFormat;
   5
   6 public class jdbcUpdate
   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
  17     public static void main(String[] args)
  18     {
  19
  20         try{
  21             if (args.length != 1) {
  22                 System.out.println("Usage: java jdbcDelete <opfile>\n");
  23                 return;
  24             }
  25
  26             Class.forName("csql.jdbc.JdbcSqlDriver");
  27             Connection con = DriverManager.getConnection("jdbc:csql", "root", "manager");
  28             Connection adCon = DriverManager.getConnection("jdbc:Adapter", "root", "manager");
  29
  30             PreparedStatement selStmt = null, updStmt = null;
  31             PreparedStatement adSelStmt = null, adUpdStmt = null;
  32
  33             selStmt = con.prepareStatement("select f2 from soakTable limit 1 offset 50;");
  34             updStmt = con.prepareStatement("update soakTable set f1=? where f2=?;");
  35 //            adSelStmt = adCon.prepareStatement("select f2 from soakTable limit 1 offset 50;");
  36             adUpdStmt = adCon.prepareStatement("update soakTable set f1=? where f2=?;");
  37             ResultSet rs = null, adrs=null; int f1var=111, f2var=0, adf2var=0;
  38             FileWriter fstream = new FileWriter(args[0], true);
  39             BufferedWriter out = new BufferedWriter(fstream);
  40
  41             while(true){
  42               try {
  43                 rs = selStmt.executeQuery();
  44                 if(rs.next()) f2var=rs.getInt(1);
  45                 rs.close();
  46 //                adrs = adSelStmt.executeQuery();
  47   //              if(adrs.next()) adf2var=adrs.getInt(1);
  48     //            adrs.close();
  49                 updStmt.setInt(1,f1var);
  50                 updStmt.setInt(2,adf2var);
  51                 updStmt.executeUpdate();
  52                 con.commit();
  53                 adUpdStmt.setInt(1,f1var);
  54                 adUpdStmt.setInt(2,adf2var);
  55                 adUpdStmt.executeUpdate();
  56             //    System.out.println("Updated value: " +f1var);
  57                 adCon.commit();
  58                 out.write("Updated PK: " + adf2var + " "+jdbcDelete.now()+"\n");
  59                 out.flush();
  60                 Thread.sleep(5000);
  61
  62               } catch (Exception ex) {
  63                 System.out.println("Exception: "+ ex);
  64                 System.out.println("jdbcUpdate fail f2 = "+f2var+" "+jdbcDelete.now());
  65               }
  66         }
  67         }
  68         catch (Exception e) {
  69            System.out.println("Exception: "+ e);
  70         }
  71    }
  72 }
  73