test/jdbc/Threads/hashIndexTest.java

   1 /*
   2  * To change this template, choose Tools | Templates
   3  * and open the template in the editor.
   4  */
   5
   6 import java.sql.*;
   7 /**
   8  *
   9  * @author bijaya
  10  */
  11
  12 public class  hashIndexTest{
  13
  14     public static void main(String[] args) {
  15      try
  16        {
  17
  18
  19            int noOfThreads=5;
  20            int noOfRecords=1000;
  21            Class.forName("csql.jdbc.JdbcSqlDriver");
  22            Connection con = DriverManager.getConnection("jdbc:csql:", "root", "manager");
  23            Statement cStmt = con.createStatement();
  24            cStmt.execute("CREATE TABLE emp (f1 int, f2 char (20));");
  25            cStmt.execute("create index ind on emp(f1) hash unique;");
  26            connect[] conth= new connect[10];
  27            System.out.println("Table Insert");
  28            for(int i=0;i<noOfThreads;i++)
  29            {
  30                conth[i] = new connect(i,0,noOfRecords);
  31            }
  32            for(int i=0;i<noOfThreads;i++)
  33            {
  34               conth[i].th.join();
  35            }
  36            System.out.println("Table Select");
  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            System.out.println("Table Update");
  47            for(int i=0;i<noOfThreads;i++)
  48            {
  49                conth[i] = new connect(i,2,noOfRecords);
  50            }
  51            for(int i=0;i<noOfThreads;i++)
  52            {
  53               conth[i].th.join();
  54            }
  55            System.out.println("Table delete");
  56            for(int i=0;i<noOfThreads;i++)
  57            {
  58                conth[i] = new connect(i,3,noOfRecords);
  59            }
  60            for(int i=0;i<noOfThreads;i++)
  61            {
  62               conth[i].th.join();
  63            }
  64
  65            System.out.println("Drop Table ");
  66
  67            cStmt.execute("DROP TABLE emp ;");
  68            con.close();
  69         }catch(Exception e) {
  70             System.out.println("Exception in Test: "+e);
  71             e.printStackTrace();
  72         }
  73     }
  74  }
  75
  76