Цитата(Lamer @ 20.2.2005, 13:09)

"Коммонс" - это библиотеки common-net и еще несколько common-что-то, да?

Ага.

Один раз в жизни написать свой connection pool надо.
Таким образом ты сталкиваешься с проблемами, которые возникают
по ходу решения и понимаешь идею.
Легче дальше программировать будет.
Главное - думать в правильном направлении.

Можно, например, так реализовать.
Правда за ошибками снаружи придется следить.

Код

import java.sql.Connection; import java.sql.Statement; import java.sql.DriverManager; import java.sql.SQLException; /** * Название говорит само за себя. */ final class ConnectionPool {    private Connection[] c;//массив подключений    private Statement[] s;//массив утверждений    private boolean[] b;//флаги занятости утверждений    private int size;//размер масиивов    //переменные чтоб в методах не создавать    private int i;//индекс массивов //----Конструктор-------------------------------------------------------    private ConnectionPool(String driver, String url, String user,                           String password, int _size)            throws ClassNotFoundException, SQLException {        size=_size;        c=new Connection[size];        s=new Statement[size];        b=new boolean[size];        Class.forName(driver);        int i;        for(i=0;i<size;i++){            c[i]=DriverManager.getConnection(url,user,password);            s[i]=c[i].createStatement();            b[i]=false;        }    } //----Метод создания объекта--------------------------------------------    final static ConnectionPool getInstance(String driver, String url,                                     String user, String password,                                     int size){        try{            Class.forName(driver);        }catch(ClassNotFoundException e1){            return null;        }        try{            Connection c=DriverManager.getConnection(url,user,password);            Statement s=c.createStatement();            s.close();            c.close();        }catch(SQLException e2){            return null;        }        try{            ConnectionPool cp=new ConnectionPool(driver, url, user,                    password, size);            return cp;        }catch(ClassNotFoundException e1){            return null;        }catch(SQLException e2){            return null;        }    } //----Метод захвата утверждения-----------------------------------------    final synchronized Statement getStatement(){        for(i=0;i<size;i++){            if(!b[i]){                b[i]=true;                return s[i];            }        }        return null;    } //----Метод освобождения утверждения------------------------------------    final synchronized boolean getBack(Statement _s){        for(i=0;i<size;i++){            if(s[i]==_s){                b[i]=false;                return true;            }        }        return false;    } //----Метод для закрытия пула-------------------------------------------    final synchronized boolean close(){        //если ресурс занят - то не заканчиваем работу        for(i=0;i<size;i++){            if(b[i]){                return false;            }        }        boolean error=false;        //закрываем подключения и утверждения        for(i=0;i<size;i++){            try{                s[i].close();            }catch(SQLException e1){                error=true;            }            try{                c[i].close();            }catch(SQLException e2){                error=true;            }        }        return !error;    } }

Извиняюсь. getInstance, естественно, должен быть static

Это сообщение отредактировал(а) Slavca - 23.2.2005, 10:29

Slavca
Большое спасибо за пример, посмотрю на досуге.

у resin-a тоже есть pool, можешь использовать

ZAVS
Спасибо
Мне пока не для реального использования, просто пощупать в свободное время.

Цитата(Slavca @ 21.2.2005, 09:27)

Один раз в жизни написать свой connection pool надо.

Написать надо, а на вот использовать на production не надо. Чтобы написать хороший пул надо очень хорошо разбираться в этом деле. Например в твоем сразу видно критический недостаток - все соеденения открывается сразу и к тому же сразу создается множество statements. Это сразу выделяет кучу ресурсов, которые чаще всего не будут использованны. Если у тебя, к примеру, три Tomcat'a на каждом по три сайта и каждый из них создает пул из 50 коннектов - то у тебя сразу создается 450 подключений, что уже может привести к тому, что все это дело рухнет. Говорят, что даже для того, чтобы поддерживать открытое соеденение MS SQL сервер выделяет около мегабайта памяти. Заодно скажу, что у нас общее количество сайтов работающих с одной и той же БД в три-четыре раза больше как минимум.

Не могу не согласиться с тем, что для серьезных дел нужен серьезный подход.

Поскольку тред достаточно старый (я на Винграде появился спустя два месяца), то на глаза он мне раньше не попадался, а сегодня Lamer George дал на него ссылку в другом топике, ну и вот я значить из интереса зашел и глянул, о чем тут пишут.

Самое главный вывод: ТОВАРИЩИ, НЕ ПОЛЬЗУЙТЕСЬ ПРИМЕРОМ, который дал Slavca. Ни для каких целей: ни для продакшена, ни в качестве отправной точки при разработке собственного пула, ни как образец программного дизайна. Пример - просто из рук вон.

Slavca, не обижайся. Молодец, что проявил инициативу и запостил код. Далее, ты совершенно справедливо говоришь, что "один раз в жизни написать свой connection pool надо". Действительно, надо. Дальше потом жить будет проще. Но надо также, чтобы нашелся человек, который прошелся бы по твоему коду с красным карандашом в руке и указал, чем плоха твоя самодельная реализация.

Так вот, единственно с целью предостеречь возможных последователей от повторения твоих ошибок, беру в руки красный карандаш и начинаю править. Итак:

1. Зачем раздавать статементы вместо соединений???

Любой человек, который сталкивался с мало-мальски слоожными датабазными приложениями, знаком с понятием транзакции. Так вот, транзакция в теминах JDBC имеет область действия в пределах соединения, а не команды SQL! Из статемента, конечно, соединение тоже можно вытащить: statement.getConnection(), но зачем так делать, когда логически гораздо естественнее выдавать его прямо из пула?

Кроме того, не все всегда делается статементом. Иногда полезнее использовать PreparedStatement, а иногда бывает нужен CallableStatement.

2. Привязка к приприеторному API

Если ты в своей программе станешь использовать пул в таком виде, как ты его написал, то в каждом месте кода, где требуется доступ к БД, тебе придется писать примерно такое:

Код

ConnectionPool pool = ConnectionPool.getInstance("connection params..."); Statement stm = pool.getStatement(stm); int n = stm.executeQuery("update some_table set some_field=10 where some_id="25""); stm.close(); // важно! stm.getConnection().close(); pool.getBack(stm);

Если программист, который использует твой пул, забудет последнюю строчку, то рано или поздно массив забъется невозвращенными статементами, и больше никто никаких соединений получить не сможет. Причем это может произойти не только по причине забывчивости, но и в результате небрежного оформления кода доступа к данным, потому что по-грамотному строчка pool.getBack(stm) должна быть заключена в секции finally блока try/catch/finally.

Но это касается датабазного кода вообще, и с этой точки зрения действия connection.close() и pool.getBack() предъявляют одинаковые требования к программистской дисциплине. А вот что действительно плохо, это что если ты на каком-то этапе решишь использовать другую реализацию пула, то тебе придется в куче мест убирать вызов pool.getBack(). Кстати, getBack - неудачное имя (get back - это возвращаться). Лучше было бы putBack или releaseStatement. Но это детали.

Если ты спросишь, есть ли лучшие альтенрнативы, то ответ будет "Есть!". Для того чтобы сделать пул по возможности более прозрачным для программиста, можно, например, написать свою обертку (wrapper) вокруг объекта типа Connection, которая знает. что делать по close():

Код

public class ConnectionWrapper implements Connection {   private ConnectionPool pool;   private Connection con;   public ConnectionWrapper(Connection con, Connection Pool pool)   {     this.pool = pool;     this.con = con;   }   // delegate all methods on the Connection interface   //  to the underlyong Connection object   public Statement createStatement() throws SQLException   {     return con.createStatement();   } // ...and so on   public void close() throws SQLException   {     con.close();     pool.releaseConnection(con);   } }

При таком подходе использование пула не накладывает никаких дополнительных требований на код доступа к данным, то есть можно использовать объекты типа Connection как обычное JDBC соединение.

3. Ранняя инициализация

Как совершенно справедливо заметил Fantasist, во многих случаях это может завалить сервер - причем совершенно безо всяких на то оснований. С другой стороны, если разработчик уверен, что ранняя инициализация не будет проблемой в его приложении, он должен иметь возможность указать это при создании пула.

4. Отсутствие цикла ожидания

А теперь - о самом главном недостатке. Как мы видим из кода, если свободных соединений нет, то пул просто и без затей возвращает нам значение null. Вот это зашибись! Нет бы чуток подождать, да попробовать еще разок, а он хоба - и null.

Так вот, код по синхронизированию доступа к списку соединений - это и есть самая соль пула. Это именно то, ради чего как раз и было бы полезно попытаться написать пул самому. Потому что там вылезает куча нюансов взаимодействия тредов, которые просто необходимо знать всякому уважающему себя Java программеру.

В данном случае код мог бы выглядеть примерно так (несущественные детали опускаем):

Код

public synchronized Connection getConnection() throws SQLException {   try   {     while(true)     {       ConnectionWrapper con = getAvailableConnection();       if (con != null)       {         return con;       }       // all connections are busy       if (list.size() < MAX_CONNECTIONS)       {         return createNewConnection();       }       // otherwise wait till one gets available       wait();     }   }   catch (InterruptedException e)   {     // not much else to do here     logger.error(e.getMessage(), e);     throw new RuntimeException("Could not allocate an SQL connection");   } } public synchronized Connection releaseConnection(ConnectionWrapper con) {   con.setAvailable();   notifyAll(); // Это самая важная часть: разблокировать все ждущие треды                //  и позволить им конкурировать за захват objectMonitor'а } private ConnectionWrapper getAvailableConnection() {     Iterator iter = list.iterator();     while (iter.hasNext())     {       ConnectionWrapper con = iter.next();       if (con.isAvailable())       {         con.setBusy();         return con;       }     }     return null; }

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

Поэтому. После того как вы напишите свою реализацию пула (можно взять за основу мои правки) и убедитесь, что она худо-бедно работает, нужно будет взять и все нафиг грохнуть, а потом пойти и взять нормальный готовый продукт. Например, такой как Proxool. И увидеть разницу.

И настанет вам нирвана

Ya posmotrel na Proxool, vrode klasnoya shtyka, vse prosto. No kak etim polzovatsya v realnom prilozenii???

Esli y mne nado vupolnit SQL zapros kakoj kod mne nado napisat'????

Sejchas v moej programe odin Connection katoruj sozdaetsya pri starte programu. Potim kogda ya hocy zapystit' Statemement, PreparedStatement ya dostau Connection(y menya on tolko odin), delau
connection.createStatement(....) i poehali.

Chto mne pomenyat???
Mozhet est eshe primeru ili mozhet est svoii primeru??

Spasibo.

Lamer George, если нужно, вот я недавно разбирался с проблемой доступа к пулу: http://forum.vingrad.ru/index.php?showtopi...=0&#entry502629

A chto naschet Apache DBCP? Kto-to polzovalsya???
I she est c3p0.

Цитата(DEMOVERSION @ 18.10.2005, 12:43)

A chto naschet Apache DBCP? Kto-to polzovalsya???

Пользуюсь постоянно. Хорошая штука.

А можно пример?

и если можно пример для простого приложения, а то я только примеры для веб-програм видел.
у меня простое консольное приложение.

спасибо!