test/performance/throughput/noIndexTest.java

   1 import java.sql.*;
   2 /**
   3  *
   4  * @author bijaya
   5  */
   6
   7 public class  noIndexTest{
   8
   9     public static void main(String[] args) {
  10      try
  11        {
  12
  13
  14            int noOfThreads=5;
  15            int noOfRecords=10000;
  16            Connection con = connect.getDBConn();
  17            Statement cStmt = con.createStatement();
  18            cStmt.execute("CREATE TABLE emp (f1 int, f2 char (20));");
  19            connect[] conth= new connect[10];
  20            System.out.println("Table Insert");
  21            for(int i=0;i<noOfThreads;i++)
  22            {
  23                conth[i] = new connect(i,0,noOfRecords);
  24            }
  25            for(int i=0;i<noOfThreads;i++)
  26            {
  27               conth[i].th.join();
  28            }
  29            long totalTimeTaken=0;
  30            for(int i=0;i<noOfThreads;i++)
  31            {
  32               totalTimeTaken = totalTimeTaken + conth[i].timeTaken;
  33            }
  34            System.out.println("Table Insert " + totalTimeTaken);
  35
  36
  37            for(int i=0;i<noOfThreads;i++)
  38            {
  39                conth[i] = new connect(i,1,noOfRecords);
  40            }
  41            for(int i=0;i<noOfThreads;i++)
  42            {
  43               conth[i].th.join();
  44            }
  45            totalTimeTaken=0;
  46            for(int i=0;i<noOfThreads;i++)
  47            {
  48               totalTimeTaken = totalTimeTaken + conth[i].timeTaken;
  49            }
  50            System.out.println("Table Select " + totalTimeTaken);
  51
  52            /*System.out.println("Table Update");
  53            for(int i=0;i<noOfThreads;i++)
  54            {
  55                conth[i] = new connect(i,2,noOfRecords);
  56            }
  57            for(int i=0;i<noOfThreads;i++)
  58            {
  59               conth[i].th.join();
  60            }
  61            System.out.println("Table delete");
  62            for(int i=0;i<noOfThreads;i++)
  63            {
  64                conth[i] = new connect(i,3,noOfRecords);
  65            }
  66            for(int i=0;i<noOfThreads;i++)
  67            {
  68               conth[i].th.join();
  69            }*/
  70
  71            System.out.println("Drop Table ");
  72
  73            cStmt.execute("DROP TABLE emp ;");
  74            con.close();
  75         }catch(Exception e) {
  76             System.out.println("Exception in Test: "+e);
  77             e.printStackTrace();
  78         }
  79     }
  80  }
  81
  82