jdbc — два запроса в одном соединении

Question

[dndred]

Здравствуйте!
Начал изучать Java и уперся в проблему работы с базой данных — не могу выполнить второй sql запрос в одном соединении, имея открытый первый. В документации по JDBC написано, что для этого следует использовать другой экземпляр объекта PreparedStatement, но мне это не помогает — при выполнении второго запроса, недочитанный ResultSet первого закрывается.

                conn = DriverManager.getConnection(
                                strURL + "?lc_ctype=WIN1251",properties);
                PreparedStatement q1 = conn.prepareStatement("select * from params");
                ResultSet r1 = q1.executeQuery();
                PreparedStatement q2 = conn.prepareStatement("select * from clients");
                ResultSet r2 = q2.executeQuery();
                r1.next();//Тут программа вываливается с ошибкой org.firebirdsql.jdbc.FBSQLException: The result set is closed
                r1.getObject(1); 
                r2.next();
                r2.getObject(1);

Полный текст на http://pastebin.com/
Неужели нужно открывать новое соединение на каждый запрос? Или я что-то не так делаю?
Заранее спасибо!

Comments

[dndred]

В итоге, пршёл к решению забирать весь результат сразу.

import javax.sql.rowset.CachedRowSet;
PreparedStatement q1 = conn.prepareStatement("select * from Params");
CachedRowSet r1 = new CachedRowSetImpl();
r1.populate(q1.executeQuery());

PreparedStatement q2 = conn.prepareStatement("select * from Clients");
CachedRowSet r2 = new CachedRowSetImpl();

Answer 1

[sergei-grigorev]

Нет, не нужно поднимать новое соединение на каждый запрос. Нужно закрывать имеющиеся statements перед вызовом новых. Просто в данном случае, у тебя одновременно открыто два разных запроса, один из которых в пакетном режиме подтягивает данные из одной таблицы, а второй — подтягивает совершенно другие данные из второй таблицы. Одновременно это быть не может. В данном случае вам действительно потребуется два коннекта (используйте пул соединений для более эффективной работы). Либо вы можете подтянуть данные сначала из одного запроса, закрыть PrepareStatement и ResultSet, и только затем уже подтягивать данные из второй таблицы.

Comments

[dndred]

JDBC не позволяет это из принципиальных соображений? В Delphi я свободно держал нужное мне число открытых запросов в одном соединении.

Answer 2

[Snowindy]

Скорее всего, вам нужно будет получить другое соединение для второго запроса. Но я бы так не делал.
Если вам надо одновременно читать из двух мест в одной базе, значит проблема в дизайне. Вероятно, стоит применить одно из:
1) написать один JOIN для двух таблиц и вернуть его
2) Начитать первый результат в память и работать с этими данными во время итераций по второму
3) Использовать хранимую процедуру в БД, которая сделает всю логику и вернет результат.

Comments

[dndred]

JDBC точно не позволяет сделать это? Далеко не все задачи уместно сводить к одному запросу, хранимые процедуры не лучшее место для бизнес логики, а результаты запроса могут и поместиться целиком в память. Хорошо знакомые мне PHP и Delphi позволяют работать с двумя (и более) запросами одновременно.

[Snowindy]

Отвечая на вопрос:
Попробуйте conn.createStatement() вместо conn.prepareStatement().
По крайней мере таким примеры есть на stackoverflow

Также, если вы все-таки хотите докопаться до сути вопроса, stackoverflow предложит гораздо больше ответов. Но и по имеющимся там топикам генеральная линия ответов примерно такая — «так просто не надо делать, это плохой дизайн»
хранимые процедуры не лучшее место для бизнес логики — а для чего они, по вашему, хорошее место?
Вы хотите гонять данные от двух резалтсетов по сети и процессить их, в том числе из-за того, что "результаты запроса могут и поместиться целиком в память". Это будет медленно и глючно, гарантирую.

[dndred]

conn.createStatement() просто создаёт Statement для не параметризированного запроса. Результат тот же.

Statement q1 = conn.createStatement();
ResultSet r1 = q1.executeQuery("select * from params");
Statement q2 = conn.createStatement();
ResultSet r2 = q2.executeQuery("select * from clients");
r1.next();//org.firebirdsql.jdbc.FBSQLException: The result set is closed
r1.getObject(1);
r2.next();
r2.getObject(1);

Хранимые процедуры хорошее место для инкапсуляции некоторой логики БД, которая не касается приложения напрямую.
> «результаты запроса могут и поместиться целиком в память». Это будет медленно и глючно, гарантирую
Я имел ввиду «могут и НЕ поместиться в память». Опечатка, извините.
Впрочем, большинство запросов в память помещаются. Подскажите тогда удобную реализацию fetchall для результатов запроса.

[Snowindy]

Насчет «НЕ» я сразу понял, что опечатка :) поэтому и говорю: большие объемы лучше бы делать в базе, если хотим сохранить нормальную производительность.

fetchall в php… никогда не пользовал, извините
JDBC-интерфейс CallbleStatement позволяет доставать резалт-сет, с ним работаем как обычно. Обертку под свои нужды придумать несложно.

[Snowindy]

JdbcTemplate от Spring — весьма удобная штука.

Answer 3

[1nd1go]

В документации написано, что Statement

By default, only one ResultSet object per Statement object can be open at the same time.

Therefore, if the reading of one ResultSet object is interleaved with the reading of another, each must have been generated by different Statement objects.

All execution methods in the Statement interface implicitly close a statment's current ResultSet object if an open one exists

Comments

[dndred]

Я читал это. У меня как раз «been generated by different Statement objects» — два разных PreparedStatement. Потому и спрашиваю, что не работает.

[Snowindy]

В примере автора используются разные Statement. Я думаю, это ограничение конкретного драйвера.

[1nd1go]

Т.е. попробуйте: Statement.getResultSet() вместо Statement.executeQuery()

Answer 4

[1nd1go]

Непонятно как комментарий к моему же ответу так глубоко упал…

Попробуйте: Statement.getResultSet() вместо Statement.executeQuery()

Comments

[dndred]

Насколько я понял, getResultSet() предназначен для обработки запроса в ответ на который может придти несколько объектов ResultSet и обычно он используется в паре с getMoreResults().
Попытка применить его в моём случае дала новую ошибку:

PreparedStatement q1 = conn.prepareStatement("select * from params");
PreparedStatement q2 = conn.prepareStatement("select * from Clients");
ResultSet r1 = q2.getResultSet();
ResultSet r2 = q2.getResultSet();
r1.next();//Exception in thread "main" java.lang.NullPointerException
r1.getObject(1);
r2.next();
r2.getObject(1);

[Snowindy]

в коде ошибка
ResultSet r1 = q2.getResultSet();
ResultSet r2 = q2.getResultSet();

[dndred]

Спасибо, но результат не меняется.

PreparedStatement q1 = conn.prepareStatement("select * from params");
PreparedStatement q2 = conn.prepareStatement("select * from Clients");
ResultSet r1 = q1.getResultSet();
ResultSet r2 = q2.getResultSet();
r1.next();//Exception in thread "main" java.lang.NullPointerException
r1.getObject(1);
r2.next();
r2.getObject(1);

[1nd1go]

Это потому что еще запрос не выполнился.
Вызовите

if (q1.execute()) {
  q1.getResultSet();
}

и для 2 соответственно.

[dndred]

Тогда мы возвращаемся к началу: The result set is closed

PreparedStatement q1 = conn.prepareStatement("select * from Params");
PreparedStatement q2 = conn.prepareStatement("select * from Clients");
q1.execute();
ResultSet r1 = q1.getResultSet();
q2.execute();
ResultSet r2 = q2.getResultSet();
r1.next();//org.firebirdsql.jdbc.FBSQLException: The result set is closed
r1.getObject(1);
r2.next();
r2.getObject(1);

Answer 5

[ComodoHacker]

Эту возможность прежде всего должна поддерживать используемая СУБД. Ну и драйвер соответственно. Например в MSSQL она появилась не так давно, с 2005 версии. Насчет вашего Firebird определенно сказать не могу, копайте доки.

Comments

[ComodoHacker]

Беглый гуглинг не дает ничего по jdbc, но в дотнетовском IBProvider эта фича упоминается как раз в контексте Firebird. Так что надежда есть.

[dndred]

В Delphi я так делал лет 10 назад, ещё в InterBase 6. Драйвер JDBC для Firebird`да родной, как я понял. От авторов.

[ComodoHacker]

Вот и напишите авторам.

Answer 6

[Beholder]

Всё сильно зависит от типа базы данных и JDBC-драйвера, но обычно такие фокусы не дозволяются. Ну подумайте — передавать по одному TCP-соединению одновременно сразу два разных набора данных — это хоть и реализуемо в принципе, но обычно авторы этим не заморачиваются.

Answer 7

[dkurilenko]

использовать пул соединений и доставать соединения из пула для каждого запроса. Затем класть обратно.