VPF::Connection Pool - Форум программистов

Firex

Дата 28.1.2012, 18:18 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 58
Регистрация: 20.10.2010

Репутация: нет
Всего: нет

Класс ConnectionPool:

Код


final public class ConnectionPool {
    public static final String DRIVER_CLASS = "com.mysql.jdbc.Driver";
    public static final String DB_URL = "jdbc:mysql://localhost:3306/vhotel?encoding=UTF-8&useUnicode=true&characterEncoding=UTF-8";
    public static final String DB_USER = "vhotel";
    public static final String DB_PASSWORD = "root";

    private BlockingQueue<Connection> connections = new LinkedBlockingQueue<Connection>();

    private ConnectionPool() {}

    synchronized public Connection getConnection() throws SQLException {
        Connection connection = null;
        while(connection == null) {
            try {
                if(connections.isEmpty()) {
                    System.out.println("point 1");
                    connection = DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD);
                    
                    System.out.println("point 2");
                    if(connection == null){
                        System.out.println("point 3");
                    }
                    //connection.setAutoCommit(false);
                    System.out.println("point 4");
                } else {
                    connection = connections.take();
                    if(!connection.isValid(0)) {
                        connection = null;
                    }
                    System.out.println("point 5");
                }
            } catch(InterruptedException e) {
                
            } catch(SQLException e) {
                
            }
        }
        return connection;

    }

    public void freeConnection(Connection connection) {
        try {
            connections.put(connection);
        } catch(InterruptedException e) {
        }
    }

    public void init() throws Exception {
        try {
            Class.forName(DRIVER_CLASS);
        } catch(ClassNotFoundException e) {
            throw new Exception(e);
        }
    }

    private static ConnectionPool instance = new ConnectionPool();

    public static ConnectionPool getInstance() {
        return instance;
        
    }
}

Зацикливается в точке (Point 1), т.е. происходит множественный вывод этого сообщения(ака бесконечный цикл), причём до точки (Point 2) даже не доходит, не могу врубиться, с чем связано. Подскажите, кто видит, в чём беда.
Заодно, может кто-то скажет, на каком уровне должен создаваться ДАО-менеджер, который в последствии создаёт другие ДАО? Т.е. на уровне(во время) получения запроса от пользователя(сервлетом), или где-то ещё раньше?(где?)

jk1

Дата 28.1.2012, 18:34 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Участник
Сообщений: 1168
Регистрация: 17.10.2008
Где: Санкт-Петербург

Репутация: 40
Всего: 75

Вот тут бросается исключение

Код


connection = DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD);

но из-за пустых блоков обработки исключений Вы ничего не видите. Добавьте хотя бы e.printStackTrace() для целей отладки и поймете, в чем причина.
А зациклили Вы его сами при помощи while(connection == null)

--------------------

Opinions are like assholes — everybody has one

Firex

Дата 29.1.2012, 10:52 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 58
Регистрация: 20.10.2010

Репутация: нет
Всего: нет

Спс, поковыряв эксепшены, выяснилось, что эклипс некорректно ставит classpath...

1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Общие вопросы \| Следующая тема »