PreparedStatement ps2 = connection.prepareStatement(sql2);
    public void _testPreparedStatements() throws Exception {        Connection connection = getConnectionViaDriverManager();        connection.setAutoCommit(false);        try {                    String sql1 = MessageFormat.format(                    SELECT_TABLE_1, new Object[]{"?"});                        PreparedStatement ps1 = connection.prepareStatement(sql1);                        String sql2 = MessageFormat.format(                    SELECT_TABLE_2, new Object[]{"?"});                        PreparedStatement ps2 = connection.prepareStatement(sql2);                        RandomSelector selector1 =                 new RandomPreparedSelector(ps1, RECORD_COUNT);                        RandomSelector selector2 =                 new RandomPreparedSelector(ps2, RECORD_COUNT);                        Thread thread1 = new Thread(selector1, "Selector 1");            Thread thread2 = new Thread(selector2, "Selector 2");                        thread1.start();            thread2.start();                        Thread.sleep(TEST_TIME_SECONDS * 1000);                        selector1.stop();            selector2.stop();                        thread1.join();            thread2.join();            ps1.close();            ps2.close();                    } finally {            connection.close();        }    }