test/performance/throughput/treeIndexTest.java

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