test/performance/throughput/hashIndexTest.java

   1 import java.sql.*;
   2 /**
   3  *
   4  * @author bijaya
   5  */
   6
   7 public class  hashIndexTest{
   8
   9     public static void main(String[] args) {
  10      try
  11        {
  12            int noOfThreads=3;
  13            int noOfRecords=10000;
  14            //Class.forName("csql.jdbc.JdbcSqlDriver");
  15            //Connection con = DriverManager.getConnection("jdbc:csql:", "root", "manager");
  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) hash unique;");
  20            connect[] conth= new connect[noOfThreads];
  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            for(int i=0;i<noOfThreads;i++)
  37            {
  38                conth[i] = new connect(i,1,noOfRecords);
  39            }
  40            for(int i=0;i<noOfThreads;i++)
  41            {
  42               conth[i].th.join();
  43            }
  44            totalTimeTaken=0;
  45            for(int i=0;i<noOfThreads;i++)
  46            {
  47               totalTimeTaken = totalTimeTaken + conth[i].timeTaken;
  48            }
  49            System.out.println("Table Select " + totalTimeTaken);
  50            /*System.out.println("Table Update");
  51            for(int i=0;i<noOfThreads;i++)
  52            {
  53                conth[i] = new connect(i,2,noOfRecords);
  54            }
  55            for(int i=0;i<noOfThreads;i++)
  56            {
  57               conth[i].th.join();
  58            }
  59            System.out.println("Table delete");
  60            for(int i=0;i<noOfThreads;i++)
  61            {
  62                conth[i] = new connect(i,3,noOfRecords);
  63            }
  64            for(int i=0;i<noOfThreads;i++)
  65            {
  66               conth[i].th.join();
  67            }
  68            System.out.println("Drop Table ");
  69            */
  70
  71            cStmt.execute("DROP TABLE emp ;");
  72            con.close();
  73         }catch(Exception e) {
  74             System.out.println("Exception in Test: "+e);
  75             e.printStackTrace();
  76         }
  77     }
  78  }
  79
  80