package test.jdbc.access;



import java.io.*;

import java.sql.*;

import java.util.Vector;

import java.util.Properties;



public class testAccess4Ralf {



    public static void main(String argv[]) {

        try {

            String jdbcUrl = "jdbc:access:/D:/test/access/issue3/database1.mdb?";



            Class.forName("com.hxtt.sql.access.AccessDriver").newInstance();



            testAccess4Ralf test = new testAccess4Ralf(jdbcUrl);

            for (int i = 0; i < 50; i++) {

                test.test();

                try {

                    Thread.sleep(5000);

//                    Thread.sleep(1000);

                } catch (java.lang.InterruptedException e) {

                }

            }

        } catch (Exception e) {

            System.err.println(e.getMessage());

            e.printStackTrace();

        }

    }



    private String jdbcUrl;



    Connection con = null;

    Statement stmt;



    private testAccess4Ralf(String jdbcUrl) throws SQLException {

        this.jdbcUrl = jdbcUrl;



        Properties properties = new Properties();

//            properties.setProperty("lockTimeout","100");

        con = DriverManager.getConnection(jdbcUrl, properties);



        stmt = con.createStatement();



    }



    public void test() {



        String querySQL = "select * from setup where test>" + ((int) (java.lang.Math.random() * 1000));



        int queryCount = 0;

        try {



//            con.setAutoCommit(false);

//                con.setTransactionIsolation(Connection.TRANSACTION_READ_UNCOMMITTED);

//                con.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);

//                con.setTransactionIsolation(Connection.TRANSACTION_REPEATABLE_READ);

//            con.setTransactionIsolation(Connection.TRANSACTION_SERIALIZABLE);

//            Statement stmt = con.createStatement();

//            Statement stmt = con.createStatement(ResultSet.TYPE_FORWARD_ONLY,ResultSet.CONCUR_READ_ONLY);

//            Statement stmt = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);

            //Statement stmt = con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);

            ResultSet rs;

            rs = stmt.executeQuery(querySQL);

            queryCount++;



            ResultSetMetaData resultSetMetaData = rs.getMetaData();

            int iNumCols = resultSetMetaData.getColumnCount();

            for (int j = 1; j <= iNumCols; j++) {

                //              System.out.println(resultSetMetaData.getColumnName(j));

            }

            Object colval;



            long ncount = 0;

            rs.beforeFirst();

            while (rs.next()) {

                ncount++;

                for (int j = 1; j <= iNumCols; j++) {

                    colval = rs.getObject(j);

//                                System.out.print(colval+"  ");

                }

//                            System.out.println();

            }

            rs.close();//Let the CONCUR_UPDATABLE resultSet release its open files at once.

            rs = null;

            System.out.println("The total row number of resultset: " + ncount);

//                        System.out.println();                        



            //          stmt.close();

        } catch (SQLException sqle) {

            do {

                System.err.println(sqle.getMessage());

                System.err.println("Error Code:" + sqle.getErrorCode());

                System.err.println("SQL State:" + sqle.getSQLState());

                sqle.printStackTrace();

            } while ((sqle = sqle.getNextException()) != null);

        } finally {

            System.out.println(querySQL);

            System.out.println("Select Query Count = " + queryCount);

            /*try {

                if (con != null) {

                    con.close();

                    con = null;

                }

            } catch (Exception e) {

                System.err.println(e.getMessage());

                e.printStackTrace();

            }*/

        }

    }

}



/*

(ns evil-hongxin.core

  (:gen-class)

  (require [clojure.java.jdbc :as jdbc]))



(def connection-uri "jdbc:Access:///riskDB.mdb")

(def query ["select * from rep_Kovarianz where kov>0.2"])





(defn run-query

  []

  (count (jdbc/query {:connection-uri connection-uri} query)))



(defn doit

  []

  (dotimes [x 50]

    (print x "..")

    (run-query)

    (println "ok")

    (Thread/sleep 5000)))



(defn -main

  [& args]

  (doit))

*/

package test.jdbc.access;



import java.io.*;

import java.sql.*;

import java.util.Vector;

import java.util.Properties;



public class testAccess4Ralf2 implements Runnable {

    public static void main(String argv[]) {

        try {

            String jdbcUrl = "jdbc:access:/D:/test/access/issue3/database1.mdb?lockTimeout=5000";



            Class.forName("com.hxtt.sql.access.AccessDriver").newInstance();





           for(int i=0;i<50;i++){

                testAccess4Ralf2 test = new testAccess4Ralf2(jdbcUrl);

                Thread t = new Thread(test);

                t.start();

                try{

                    Thread.sleep(5000);

                }catch(java.lang.InterruptedException e){

                }

            }

        } catch (Exception e) {

            System.err.println(e.getMessage());

            e.printStackTrace();

        }

    }



    private String jdbcUrl;



    private testAccess4Ralf2(String jdbcUrl) {

        this.jdbcUrl = jdbcUrl;

    }



    public void run() {





        

        Connection con = null;

        int queryCount = 0;

        String querySQL = "select * from setup where test>" + ((int) (java.lang.Math.random() * 1000));        try {



            Properties properties = new Properties();

            con = DriverManager.getConnection( jdbcUrl, properties);

//            con.setAutoCommit(false);

//                con.setTransactionIsolation(Connection.TRANSACTION_READ_UNCOMMITTED);

//                con.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);

//                con.setTransactionIsolation(Connection.TRANSACTION_REPEATABLE_READ);

//            con.setTransactionIsolation(Connection.TRANSACTION_SERIALIZABLE);



//            Statement stmt = con.createStatement();

//            Statement stmt = con.createStatement(ResultSet.TYPE_FORWARD_ONLY,ResultSet.CONCUR_READ_ONLY);

            Statement stmt = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);

            //Statement stmt = con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);





                        ResultSet rs;

                        rs = stmt.executeQuery(querySQL);

                        queryCount++;



                        ResultSetMetaData resultSetMetaData = rs.getMetaData();

                        int iNumCols = resultSetMetaData.getColumnCount();

                        for (int j = 1; j <= iNumCols; j++) {

                        //              System.out.println(resultSetMetaData.getColumnName(j));

                        }

                        Object colval;



                        long ncount = 0;

                        rs.beforeFirst();

                        while (rs.next()) {

                            ncount++;

                            for (int j = 1; j <= iNumCols; j++) {

                                colval = rs.getObject(j);

//                                System.out.print(colval+"  ");

                            }

//                            System.out.println();

                        }

                        rs.close();//Let the CONCUR_UPDATABLE resultSet release its open files at once.

                        rs = null;

                        System.out.println("The total row number of resultset: "+ncount);

//                        System.out.println();                        



            stmt.close();

        } catch (SQLException sqle) {

            do {

                System.err.println(sqle.getMessage());

                System.err.println("Error Code:" + sqle.getErrorCode());

                System.err.println("SQL State:" + sqle.getSQLState());

                sqle.printStackTrace();

            } while ((sqle = sqle.getNextException()) != null);

        } finally {

            System.out.println(querySQL);

            System.out.println("Select Query Count = " + queryCount);

            try {

                if (con != null) {

                    con.close();

                    con = null;

                }

            } catch (Exception e) {

                System.err.println(e.getMessage());

                e.printStackTrace();

            }

        }

    }

}