test/performance/throughput/connect.java

   1 /*
   2  * To change this template, choose Tools | Templates
   3  * and open the template in the editor.
   4  */
   5
   6
   7 /**
   8  *
   9  * @author bijaya
  10  */
  11
  12 import java.sql.*;
  13
  14 public class connect implements Runnable
  15 {
  16     Connection con;
  17     PreparedStatement stmt;
  18     ResultSet rs;
  19     Thread th;
  20     int thid;
  21     int totalrecord;
  22     int type;
  23     long timeTaken;
  24     connect(int i,int ty ,int record)
  25     {
  26         System.out.println("thread "+ i);
  27         thid=i;
  28         totalrecord=record;
  29         type=ty;
  30         timeTaken=0;
  31         th=new Thread(this);
  32         th.start();
  33     }
  34     public static Connection getDBConn() throws Exception
  35     {
  36         Class.forName("csql.jdbc.JdbcSqlDriver");
  37         Connection con = DriverManager.getConnection("jdbc:csql:", "root", "manager");
  38         return con;
  39     }
  40     public void run()
  41     {
  42         if(0==type)  insertTest();
  43         else if(1==type) selectTest();
  44         else if(2==type) updateTest();
  45         else if(3==type) deleteTest();
  46         else selectTest1();
  47     }
  48
  49     public void insertTest()
  50     {
  51         try{
  52         //Class.forName("csql.jdbc.JdbcSqlDriver");
  53         //con = DriverManager.getConnection("jdbc:csql:","root","manager");
  54         con = getDBConn();
  55         stmt = con.prepareStatement("insert into emp values (?, 'SECOND');");
  56         long count = 0, recordCount=0;
  57         int ret = 0;
  58         long start = 0,end = 0,curr = 0;
  59         long tot = 0;
  60         for(int i=0; i<totalrecord; i++){
  61                stmt.setInt(1, totalrecord*thid+i);
  62                start = System.nanoTime();
  63                 try{
  64                 ret = stmt.executeUpdate();
  65                 }catch(Exception e1)
  66                 {
  67                     try{
  68                         System.out.println("Retry -1 Exception in Test=1: "+e1);
  69                         ret = stmt.executeUpdate();
  70                     }catch(Exception e)
  71                     {
  72                         System.out.println("Retry -2 Exception in Test=2: "+e);
  73                         ret = stmt.executeUpdate();
  74                     }
  75
  76                 }
  77                 if(ret!=1) break;
  78                 end = System.nanoTime();
  79                 curr = end - start;
  80                 tot = tot + curr;
  81                 count++;
  82         }
  83         stmt.close();
  84         timeTaken = tot;
  85         long val = tot/totalrecord;
  86         System.out.println("Thread id "+this.thid+"  Total rec: "+count+" Avgtime  :"+val);
  87         System.out.println("Total Record Insert: "+count);
  88         Thread.sleep(1000);
  89         con.close();
  90         }catch(Exception e) {
  91             System.out.println("Exception in Test: "+e+"Thread NO"+thid);
  92             e.printStackTrace();
  93         }
  94     }
  95
  96 public void selectTest()
  97 {
  98         try{
  99         //Class.forName("csql.jdbc.JdbcSqlDriver");
 100         //con = DriverManager.getConnection("jdbc:csql:","root","manager");
 101         con = getDBConn();
 102         stmt = con.prepareStatement("select * from emp where f1=?");
 103         Thread.sleep(1000);
 104         long count = 0, recordCount=0;
 105         int ret = 0;
 106         long start = 0,end = 0,curr = 0;
 107         long tot = 0;
 108         for(int i=0; i<totalrecord; i++){
 109             stmt.setInt(1, totalrecord*thid +i);
 110             start = System.nanoTime();
 111                 try{
 112                 rs = stmt.executeQuery();
 113                 }catch(Exception e1)
 114                 {
 115                     try{
 116                         System.out.println("Retry-1"+ e1);
 117                         rs = stmt.executeQuery();
 118                     }catch(Exception e)
 119                     {
 120                         System.out.println("Retry-2"+ e1);
 121                         rs = stmt.executeQuery();
 122                     }
 123                 }
 124                 if(rs.next())
 125                 {
 126                     recordCount++;
 127                 }
 128
 129                 end = System.nanoTime();
 130                 curr = end - start;
 131                 tot = tot + curr;
 132                 count++;
 133         }
 134         stmt.close();
 135         timeTaken = tot;
 136         long val = tot/totalrecord;
 137         System.out.println("Thread id "+this.thid+"Total select "+recordCount+" Avgtime  :"+val);
 138         System.out.println("Total Record select "+recordCount + " " + tot + " "+ totalrecord);
 139         con.close();
 140         }catch(Exception e) {
 141             System.out.println("Exception in Test: "+e+"Thread NO"+thid);
 142             e.printStackTrace();
 143         }
 144     }
 145
 146 public void deleteTest()
 147 {
 148
 149         try{
 150         //Class.forName("csql.jdbc.JdbcSqlDriver");
 151         //con = DriverManager.getConnection("jdbc:csql:","root","manager");
 152         con = getDBConn();
 153         stmt = con.prepareStatement("delete from emp where f1=?");
 154         long count = 0, recordCount=0;
 155         int ret = 0;
 156
 157         Thread.sleep(2000);
 158         long start = 0,end = 0,curr = 0;
 159         long tot = 0;
 160         for(int i=0; i<totalrecord; i++){
 161             stmt.setInt(1, totalrecord*thid+i);
 162             start = System.nanoTime();
 163                 try{
 164                 ret = stmt.executeUpdate();
 165                 }catch(Exception e1)
 166                 {
 167                     try{
 168                         ret = stmt.executeUpdate();
 169                     }catch(Exception e)
 170                     {
 171                    //     System.out.println("Exception in Test=2: "+e);
 172                         ret = stmt.executeUpdate();
 173                     }
 174                 }
 175                 if(ret!=1) break;
 176                 end = System.nanoTime();
 177                 curr = end - start;
 178                 tot = tot + curr;
 179                 count++;
 180         }
 181         stmt.close();
 182         long val = tot/totalrecord;
 183         System.out.println("Total Record Delete: "+count);
 184         con.close();
 185         }catch(Exception e) {
 186             System.out.println("Exception in Test: "+e+"Thread NO"+thid);
 187             e.printStackTrace();
 188         }
 189     }
 190 public void updateTest()
 191    {
 192         try{
 193         //Class.forName("csql.jdbc.JdbcSqlDriver");
 194         //con = DriverManager.getConnection("jdbc:csql:","root","manager");
 195         con = getDBConn();
 196         stmt = con.prepareStatement("update emp set f2='india' where f1=?");
 197         long count = 0, recordCount=0;
 198         int ret = 0;
 199
 200         Thread.sleep(1000);
 201         long start = 0,end = 0,curr = 0;
 202         long tot = 0;
 203         for(int i=0; i<totalrecord; i++){
 204             stmt.setInt(1, totalrecord*thid+i);
 205             start = System.nanoTime();
 206                 try{
 207                 ret = stmt.executeUpdate();
 208                 }catch(Exception e1)
 209                 {
 210                     try{
 211                         ret = stmt.executeUpdate();
 212                     }catch(Exception e)
 213                     {
 214                         //System.out.println("Exception in Test=2: "+e);
 215                         ret = stmt.executeUpdate();
 216                     }
 217                 }
 218                 if(ret!=1) break;
 219                 end = System.nanoTime();
 220                 curr = end - start;
 221                 tot = tot + curr;
 222                 count++;
 223         }
 224         stmt.close();
 225         long val = tot/totalrecord;
 226         System.out.println("Thread id "+this.thid+"  Total rec Update: "+count+" Avgtime  :"+val);
 227         System.out.println("Total Record Update: "+count);
 228         con.close();
 229         }catch(Exception e) {
 230             System.out.println("Exception in Test: "+e+"Thread NO"+thid);
 231             e.printStackTrace();
 232         }
 233     }
 234
 235 public void selectTest1()
 236 {
 237         try{
 238         //Class.forName("csql.jdbc.JdbcSqlDriver");
 239         //con = DriverManager.getConnection("jdbc:csql:","root","manager");
 240         con = getDBConn();
 241         stmt = con.prepareStatement("select * from emp where f1>=? and f1<?");
 242         Thread.sleep(1000);
 243         long count = 0, recordCount=0;
 244         int ret = 0;
 245         long start = 0,end = 0,curr = 0;
 246         long tot = 0;
 247         for(int i=0; i<totalrecord/100; i++){
 248             stmt.setInt(1, totalrecord*thid +i);
 249             stmt.setInt(2, totalrecord*thid +i+100);
 250             start = System.nanoTime();
 251                 try{
 252                 rs = stmt.executeQuery();
 253                 }catch(Exception e1)
 254                 {
 255                     try{
 256                         rs = stmt.executeQuery();
 257                     }catch(Exception e)
 258                     {
 259                         rs = stmt.executeQuery();
 260                     }
 261                 }
 262                 while(rs.next())
 263                 {
 264                     recordCount++;
 265                 }
 266
 267                 end = System.nanoTime();
 268                 curr = end - start;
 269                 tot = tot + curr;
 270                 count++;
 271         }
 272         stmt.close();
 273         long val = tot/totalrecord;
 274         System.out.println("Thread id "+this.thid+"Total select "+recordCount+" Avgtime  :"+val);
 275         System.out.println("Total Record select "+recordCount);
 276         con.close();
 277         }catch(Exception e) {
 278               System.out.println("Exception in Test: "+e+"Thread NO"+thid);
 279               e.printStackTrace();
 280         }
 281      }
 282
 283
 284 }