Простейший Connection pool без DataSource в Java

[nomit]

1) Название методов жестокое.
2) метод getAvailableConnsCnt — может врать
3) Чем обусловлено использование Vector?
4) Что если мы попытаемся положить Connection созданный вне нашего пула?

Непонятно на кого рассчитана статья, такое любой начинающий программист(изучивший базовые вещи по синхронизации в java)может сам написать.

[maratvildan]

Для начинающих и растерявшихся и предназначена)

[btd]

Для не начинающих, используйте готовые пуллы: bonecp, c3p0, apache и тд.

[romario13]

Я бы даже рекомендовал прямо наоборот:
> для начинающих, используйте готовые пуллы: bonecp, c3p0, apache и тд.

[maratvildan]

Api у Vector удобней в данном случае Api ArrayList своим lastElement()

[megaserg]

Тогда, может быть, лучше какой-нибудь Set? У вас сейчас в putback поиск при удалении за линейное время происходит.

[maratvildan]

Java SE, предполагается что приложение небольшое. Соединений не тысячами, даже не сотнями, сколько потоков создается столько и соединений, возможно чуть больше. Здесь разница в скорости не столько важна

[nomit]

А если таких не оптимальных мест в приложении +1000? В разных местах не только в пуле. Там где оптимальней было бы использовать связанный список вместо массива.

[maratvildan]

Чем плох Vector в данном контексте по-вашему?

[nomit]

Можно 2 раза один и тот же Conection положить в него.

[maratvildan]

Нет, не будет такого. Каждый раз создается новое соединение, как в

for (int i = 0; i < initConnCnt; i++) 
{
	availableConns.addElement(getConnection());
}

так и в

if (availableConns.size() == 0) {
			newConn = getConnection();
}

А в putback выпадает с ошибкой, если коннекшна нет в usedConns

[nomit]

А вы насчет ошибки уверены? Если взглянуть реализацию Вектора, то при удалении он просто вернет false

[maratvildan]

да, виноват, putback нужно доработать

[maratvildan]

как-нибудь так:

public synchronized void checkin(Connection c) throws NullPointerException {
	if (c != null) {
		if (usedConns.removeElement(c)) {
			availableConns.addElement(c);
		} else {
			throw new NullPointerException("Connection not in the usedConns");
		}			
	}
}

[nomit]

Да можно так, ну проще использовать Set который по определению своему нужен для хранения уникальных объектов

[orionll]

Вообще, это даже никакой не ConnectionPool. Т.е. он не выполняет свой основной функции — переиспользование соединений после их закрытия. Правильный ConnectionPool должен возвращать не реальное физическое соединение, а обертку над ним, которая слушает событие onClose, в случае которого ничего на самом деле не закрывает, а кладет соединение обратно в pool для последующего переиспользования.

[Vlad_IT]

del

[megaserg]

Только уже есть версия 2.2: commons.apache.org/proper/commons-pool/

[onk]

подключаем к проекту myBatis (iBatis) и получаем пул из коробки
плюс не нужно напрямую с чистым jdbc иметь дело

ну или воспользоваться c3p0

[romario13]

А главное — зачем? (с)

Посмотрите плз исходный код популярных пулов соединений. Уверен, что там вы подчерпнете для себя очень много полезной информации.

[apangin]

Если бы было всё так просто! Первый же Exception сломает весь пул.
Чтобы всё работало правильно, придётся делать обёртки над Connection и Statement, которые ловят исключения и инвалидируют (закрывают) Connection, не кладя его обратно в пул. Вдобавок нужно ограничивать размер пула, а новые соединения открывать вне synchronized, чтобы избежать нежелательных задержек в многопоточном приложении.

[edolganov]

Рекомендую всем желающим хороший пример реализации Connection Pool от MyBatis.

Довольно понятный код и учитываются все аспекты данного вопроса:
— ограничение сверху на макс.количество соединений
— обработка ошибок соединения
— обновление пула соединений новыми, при обрыве старых

Я даже брал когда-то этот код для реализации пула сокетов.

[maratvildan]

Подход серьезный, спору нет. Спасибо за ссылку

[fogone]

Похоже, ошибка закралась изначально в предпосылке:

Ведь сервера приложений у нас в данном случае нет, следовательно, использовать Data Source мы не можем

Ну и так вот, конечно, не делается:
try { conn = DriverManager.getConnection(url); } catch (Exception e) { e.printStackTrace(); }

велосипед не нужен [x]

[dougrinch]

Какая вообще связь между пулом и аппсервером?

[AN3O]

Да в самом деле реализаций на просторах интернета тьма тьмущая.
Например: svn.l2jserver.com/trunk/L2J_Server/java/com/l2jserver/L2DatabaseFactory.java
Пример использования: svn.l2jserver.com/trunk/L2J_Server/java/com/l2jserver/gameserver/datatables/ClanTable.java

Естественно, вместо c3p0 пула можно юзать стандартный пул Java.

[sergey-b]

Возвращать надо не java.sql.Connection, а обертку, у которой метод close() возвращает соединение в пул. Ведь Connection у нас реализует интерфейс AutoCloseable.