Примечание: мы снова используем единственное соединение.
************************************************
public Connection connection() {
try {
if ((connection == null) || (connection.isClosed()))
{
if (connection!=null)
log.severe("Connection was closed !");
connection = DriverManager.getConnection(jdbcURL, username, password);
}
} catch (SQLException e) {
log.severe("can't connect: " + e.getMessage());
}
return connection;
}
**************************************************
public IngisObject[] select(String query, String idColumnName, String[] columns) {
Connection con = connection();
Vector<IngisObject> objects = new Vector<IngisObject>();
try {
Statement stmt = con.createStatement();
String sql = query;
ResultSet rs =stmt.executeQuery(sql);//oracle increases cursors count here
while(rs.next()) {
IngisObject o = new IngisObject("New Result");
o.setIdColumnName(idColumnName);
o.setDatabase(this);
for(String column: columns)
o.attrs().put(column, rs.getObject(column));
objects.add(o);
}
rs.close();// oracle don't decrease cursor count here, while it's expected
stmt.close();
}
catch (SQLException ex) {
System.out.println(query);
ex.printStackTrace();
}
Параметр init.ora open_cursors
определяет максимальное количество открытых курсоров, которое может быть одновременно у сессии. По умолчанию он имеет значение 50. Если приложение превысит это число, возникнет ошибка "ORA-01000: превышено максимальное количество открытых курсоров".
Поэтому обязательно нужно закрывать ресурсы JDBC, когда они больше не нужны, в частности java.sql.ResultSet и java.sql.Statement. Если они не закрыты, в приложении происходит утечка ресурсов.
В случае повторного использования объекта Connection необходимо учитывать тот факт, что открытые курсоры oracle остаются открытыми и используются до тех пор, пока существует соединение и не завершилась транзакция. Когда приложение фиксирует транзакцию, открытые курсоры освобождаются.
Поэтому, как разработчик приложения, вы должны знать приблизительную оценку необходимого количества открытых курсоров для вашей самой сложной транзакции.
Сложность заключается в неспособности внутренних представлений параметров oracle (v$open_cursor, v$sesstat и т.д.) показать разницу между открытыми курсорами, которые можно использовать повторно, и открытыми курсорами, которые все еще блокируются (не используются повторно!) незакрытым ResulSet или Statement. Если вы закроете все объекты Statement и ResultSet в блоке finally, ваше приложение будет в полном порядке.
Настройка параметра init.ora работает следующим образом (нашему приложению требуется 800 курсоров максимум)
ALTER SYSTEM SET open_cursors = 800 SCOPE=BOTH;
Обычно вы помещаете операторы закрытия для ResultSet и Statement в блок finally
, чтобы гарантировать, что они будут вызваны, даже если произойдет исключение (возможно, именно с этим связана ваша проблема). В вашем текущем коде, если произойдет SQLException, то два вызова метода close( ) никогда не произойдут, и курсоры останутся открытыми.
Также какой запрос вы используете в Oracle, чтобы увидеть количество открытых курсоров?
Edit:
Этот код должен закрывать курсор. Если это не так, то вы должны увидеть корреляцию 1 к 1 между вызовом вашего метода и увеличением количества курсоров на 1. Убедитесь, что нет какого-то неожиданного процесса, который вызывает увеличение количества курсоров.
Если у вас есть привилегии, вы можете выполнить этот запрос к базе данных, чтобы посмотреть количество открытых курсоров по сторонам, чтобы выяснить, не увеличивает ли количество курсоров какой-то другой процесс, а не конкретно ваш. Он вернет все, у кого открыто более 10 курсоров, вы можете поднять этот параметр, чтобы отфильтровать шум или сузить его по имени пользователя или osuser:
select oc.sid,
count(*) numCur,
s.username username,
s.osuser osuser,
oc.sql_text,
s.program
from v$open_cursor oc,
v$session s
where s.sid = oc.sid
group by oc.sid,
oc.sql_text,
s.username,
s.osuser,
s.program
having count(*) > 10
order by oc.sid;
Другой запрос, который может быть полезен, в случае, если несколько sid'ов используют одну и ту же строку запроса, так что вышеприведенный запрос не выявляет преступника:
select oc.sql_text, count(*)
from v$open_cursor oc
group by oc.sql_text
having count(*) > 10
order by count(*) desc;
Правильный способ сделать это - закрыть каждый ресурс в блоке finally в его собственном блоке try / catch. Обычно я использую такой статический служебный класс:
public class DatabaseUtils
{
public static void close(Connection connection)
{
try
{
if (connection != null)
{
connection.close();
}
}
catch (SQLException e)
{
// log exception here.
}
}
// similar methods for ResultSet and Statement
}
Поэтому я бы написал ваш код следующим образом:
public IngisObject[] select(String query, String idColumnName, String[] columns) {
Vector<IngisObject> objects = new Vector<IngisObject>();
Connection con = null;
Statement stmt = null;
ResultSet rs = null;
try
{
connection = connection();
stmt = con.createStatement();
// This is a SQL injection attack waiting to happen; I'd recommend PreparedStatemen
String sql = query;
rs =stmt.executeQuery(sql);//oracle increases cursors count here
while(rs.next())
{
IngisObject o = new IngisObject("New Result");
o.setIdColumnName(idColumnName);
o.setDatabase(this);
for(String column: columns) o.attrs().put(column, rs.getObject(column));
objects.add(o);
}
}
catch (SQLException ex)
{
System.out.println(query);
ex.printStackTrace();
}
finally
{
DatabaseUtils.close(rs);
DatabaseUtils.close(stmt);
DatabaseUtils.close(con);
}