О API JDBC достаточно много информации и гайдов, но к сожалению почти все как под копирку. Сам достаточно долгое время осваивал это чудо, переводя ресурсы умных.
Привет!
Не так давно узнал о некоторых приемах создания соединения и дальнейшей работы с ним.
На 100% уникальность не претендую, лавры не собираю.
В общем, типичная задача, подключится к БД и запросить данные из таблицы. Что мы делаем для этого:
- Создаем (получаем) Connection
- Создаем Statement
- Выполняем запрос и складываем все в ResulSet
- Ну а далее, прокручиваем ResulSet получая из него данные
Connection conn = ConnectionPool.init().getConnection();
Statement stmt = conn.createStatement();
ResultSet rset = stmt.executeQuery("SELECT t.* FROM warehouses t");
while(rset.next()) {
...
}
rset.close();
stmt.close();
ConnectionPool.init().comebackConnection(conn);
Прокручиваемый ResultSet
Начиная с версии JDBC 2.0 появилась возможность направленной прокрутки набора результата.
Для этого, при создании Statement необходимо указать параметр желаемой прокрутки.
Connection conn = ConnectionPool.init().getConnection();
Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
ResultSet rset = stmt.executeQuery("SELECT t.* FROM warehouses t");
...
rset.close();
stmt.close();
ConnectionPool.init().comebackConnection(conn);
- ResultSet.TYPE_FORWARD_ONLY: значение по умолчанию, прокрутка в одном направлении;
- ResultSet.TYPE_SCROLL_INSENSITIVE: прокрутка назад и вперед. При изменении данных в БД, ResultSet не отразит этого.
- ResultSet.TYPE_SCROLL_SENSITIVE: тоже самое что и 2, плюс отражает реальное представление данных в базе данных по мере их изменения.
Для перемещения курсора вперед, традиционно вызываем next(), для перемещения назад — previous(). Также можем вызвать first() или last() для перемещения в начало или конец курсора. Можно перейти на конкретную строку указав ее индекс — absolute(5) или переместиться относительно текущего на порядок — relative(3).
Редактируемый ResultSet
Возможно, в коде выше вы заметили второй параметр — ResultSet.CONCUR_READ_ONLY, он означает, что выбранный результат доступен только для чтения.
Вместо создания привычных стейтментов для обновления (вставка, редактирование, удаление) мы можем воспользоваться ранее созданным ResultSet`ом. Но для этого во второй параметр метода по созданию Statement необходимо указать ResultSet.CONCUR_UPDATABLE.
В таком ResultSet вы сможете не только обновлять выбранные записи, но и создавать новые, а также производить удаление.
Connection conn = ConnectionPool.init().getConnection();
Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE);
ResultSet rset = stmt.executeQuery("SELECT t.* FROM warehouses t"); //Псевдоним тут не случайно
// Обновим строку
rset.absolute(5); //Переходим на 5 строку
rset.updateObject("active_date", new java.sql.Date(new Date().getTime())); //Устанавливаем значение в поле
rset.updateRow(); //Фиксируем данные
//Вставим новую строку
rset.moveToInsertRow(); //Добавляем новую строку и переходим на нее
rset.updateObject("id", 123);
rset.updateObject("name", "Склад №4");
rset.updateObject("active_date", new java.sql.Date(new Date().getTime()));
rset.insertRow(); //Фиксируем данные
//Удалим строку
rset.last(); // Идем на последнюю строку
rset.deleteRow(); // Удаляем ее из БД
rset.close();
stmt.close();
ConnectionPool.init().comebackConnection(conn);
- Вызов метода cancelRowUpdates() отменит все ожидающие изменения.
- Перед вызовом методов updateRow() или insertRow() необходимо проверять, что текущая строка находится в состоянии обновления или создания соответственно. Иначе возникнет исключение.
Пакетные обновления
Для большей скорости, операций по обновлению данных БД рекомендуется делать в пакетах.
Т.е. это когда вы например добавляете строки в таблицу и не отправляете их каждую по отдельности на сервер, а делаете это в конце.
Сразу скажу, что в этих случаях необходимо выключит AutoCommit у соединения, т.к. отправлять изменения на сервер мы будем принудительно.
А также, нужно проверить, поддерживает ли версия драйвера пакетные обновления — DatabaseMetaData.supportsBatchUpdates().
Connection conn = ConnectionPool.init().getConnection();
conn.setAutoCommit(false);
Statement stmt = conn.createStatement();
stmt.addBatch("INSERT INTO warehouses(id, name, active_date) VALUES(1,'Склад №1', sysdate)"); //Добавляем строку в пакет
stmt.addBatch("INSERT INTO warehouses(id, name, active_date) VALUES(2,'Склад №2', sysdate)");//Еще одну
stmt.addBatch("INSERT INTO warehouses(id, name, active_date) VALUES(3,'Склад №3', sysdate)");//Еще одну
stmt.executeBatch(); //Выполняем пакет
conn.commit(); //Фиксируем данные
conn.setAutoCommit(true);
stmt.close();
ConnectionPool.init().comebackConnection(conn);
Заключение
Данная статья не является гайдом о том как нужно делать. Большинство примеров представлено в тезисном варианте, цель которого — передать коротко и лаконично основную мысль. В следующей статье напишу про RowSet`ы и что нибудь еще, непопулярное!
Спасибо!
Автор: мистер Олимпия
