test/jdbc/Connection/ConnTest2.java

   1 //Test 5000 connections
   2 import java.sql.*;
   3
   4 public class ConnTest2
   5 {
   6     public static void main(String[] args)
   7     {
   8        try
   9        {
  10            Class.forName("csql.jdbc.JdbcSqlDriver");
  11            Connection con = DriverManager.getConnection("jdbc:csql", "root", "manager");
  12            Statement cStmt = con.createStatement();
  13            int ret =0;
  14            cStmt.execute("CREATE TABLE T1 (f1 integer, f2 char (20));");
  15            con.close();
  16            int count =0;
  17            PreparedStatement stmt = null;
  18            for (int i=0; i <5000 ; i++)
  19            {
  20                con = DriverManager.getConnection("jdbc:csql", "root", "manager");
  21                stmt = con.prepareStatement("INSERT INTO T1 VALUES (?, ?);");
  22                stmt.setInt(1, i);
  23                stmt.setString(2, String.valueOf(i+100));
  24                ret = stmt.executeUpdate();
  25                if (ret != 1) break;
  26                count++;
  27                stmt.close();
  28                con.commit();
  29                con.close();
  30                if (i%100 ==0)  {System.out.println("Total Connections made "+ i); System.gc(); Thread.sleep(500);}
  31            }
  32            System.out.println("Total Rows inserted "+ count);
  33
  34
  35            con = DriverManager.getConnection("jdbc:csql", "root", "manager");
  36            cStmt = con.createStatement();
  37            System.out.println("Listing tuples:");
  38            ResultSet rs = cStmt.executeQuery("SELECT * from T1;");
  39            count =0;
  40            while (rs.next())
  41            {
  42                System.out.println("Tuple value is " + rs.getInt(1)+ " "+ rs.getString(2));
  43                count++;
  44            }
  45            rs.close();
  46            con.commit();
  47            System.out.println("Total rows selected " + count);
  48            cStmt.execute("DROP TABLE T1;");
  49            con.close();
  50            }catch(Exception e) {
  51                System.out.println("Exception in Test: "+e);
  52                 e.printStackTrace();
  53            }
  54     }
  55 }