При использовании конструкции try-catch-finally возможна ситуация, когда происходит подавление одного исключения другим.
Метод close() может сгенерировать исключение. В этот же момент, основной код работы с ресурсом, тоже может выбросить исключение, но его исключение будет утеряно, так как оно будет перезаписано исключением, которое может возникнуть уже в самом блоке finally и может возникнуть уже от метода close(), при попытке закрытия ресурса, которого нет.
Таким образом , Информация об исходной ошибке пропадёт: мы никогда не узнаем, что было причиной исходного исключения.
Поэтому я решил использовать оператор try-with-resourse. Ниже приведен класс который создает пул коннекторов из которого и берутся коннекторы. Следующий кусок кода показывает первоначальный вариант, а за ним вариант, в котором я попытался использовать оператор try-with-resourse.
Остаются вопросы:
Как закрывать resulSet, в данном случае он может быть помещен в оператор try-with-resourse и компилятор это пропустит, но код не выполнится, потому что объект PrepareStatement не получит данные.
Как отменить для конткретного объекта connection (для коннектора,который в данный момент используется) транзакцию, так как если я использую открытие ресурса Connection в операторе try-with-resourse, соответственно я не могу его уже указать в блоке catch.
Вот получение Connection из пула коннекторов:
public class ConnectionPool extends Constants {
private static final ConnectionPool pool = new ConnectionPool();
public static ConnectionPool getPool() {
return pool;
}
private DataSource dataSource;
private ConnectionPool() {
Properties properties;
String nameJndiResource;
try {
if (isBlank(PATH_TO_PROPERTIES_JNDI)) {
throw new ValidateException(MESSAGE_NOT_EMPTY_STR);
}
properties = new ClassPathPropertiesReader().getProperties(PATH_TO_PROPERTIES_JNDI);
} catch (IOException e) {
throw new ConnectionException(MESSAGE_EXCEPTION_FILE_JNDI, e);
}
isNullObjects(properties);
try {
nameJndiResource = properties.getProperty(JNDI_LINK);
Context initContext = new InitialContext();
Context rootContext = (Context) initContext.lookup("java:comp/env");
dataSource = (DataSource) rootContext.lookup(nameJndiResource);
} catch (NamingException e) {
throw new ConnectionException(MESSAGE_LOOKUP_JNDI, e);
}
}
public Connection getConnection() {
try {
dataSource.getConnection().setAutoCommit(false);
return dataSource.getConnection();
} catch (SQLException e) {
throw new ConnectionException(MESSAGE_CONNECTION, e);
}
}
private void closeDbResources(Connection connection) {
closeDbResources(connection, null, null);
}
private void closeDbResources(ResultSet resultSet) {
closeDbResources(null, null, resultSet);
}
public void closeDbResources(Connection connection, Statement statement) {
closeDbResources(connection, statement, null);
}
private void closeDbResources(Connection connection, Statement statement, ResultSet resultSet) {
closeResultSet(resultSet);
closeStatement(statement);
closeConnection(connection);
}
private void closeConnection(Connection connection) {
if (connection != null) {
try {
connection.close();
} catch (SQLException e) {
System.out.println("Error: Connection has not been closed!");
}
}
}
private void closeStatement(Statement statement) {
if (statement != null) {
try {
statement.close();
} catch (SQLException e) {
System.out.println("Error: Statement has not been closed!");
}
}
}
private void closeResultSet(ResultSet resultSet) {
if (resultSet != null) {
try {
resultSet.close();
} catch (SQLException e) {
System.out.println("Error: ResultSet has not been closed!");
}
}
}
public static void rollback(Connection conn) {
try {
conn.rollback();
} catch (Exception e) {
System.out.println("Rollback changes as a result of a transaction that failed to undo.");
}
}
}
Вот кусок кода (пример метода) из dao-класса, здесь используется конструкция try-catch-finally, а также отмена транзакции
@Override
public List<TranslitEntity> loadAllUserTranslits(Integer userId) {
Connection connection = null;
PreparedStatement statement = null;
ResultSet set = null;
List<TranslitEntity> result = new ArrayList<TranslitEntity>();
try {
connection = ConnectionPool.getPool().getConnection();
statement = connection.prepareStatement("SELECT * from translits WHERE user_id = ?");
statement.setInt(1, userId);
set = statement.executeQuery();
while (set.next()) {
TranslitEntity entity = ResultSetConverter.createTranslitEntity(set);
result.add(entity);
}
} catch (SQLException e) {
rollback(connection);
throw new DaoException(e);
} finally {
ConnectionPool.getPool().closeDbResources(connection, statement, set);
}
return result;
}
А вот пример попытки использования оператора try-with-resourse, но здесь пришлось отказаться от применения отката транзакции в случае возникновения исключения и нет возможности закрыть объект ResultSet.
@Override
public List<TranslitEntity> loadAllUserTranslits(Integer userId) {
Connection connection = null;
PreparedStatement statement = null;
ResultSet set = null;
List<TranslitEntity> result = new ArrayList<TranslitEntity>();
try {
connection = ConnectionPool.getPool().getConnection();
statement = connection.prepareStatement("SELECT * from translits WHERE user_id = ?");
statement.setInt(1, userId);
set = statement.executeQuery();
while (set.next()) {
TranslitEntity entity = ResultSetConverter.createTranslitEntity(set);
result.add(entity);
}
} catch (SQLException e) {
rollback(connection);
throw new DaoException(e);
} finally {
ConnectionPool.getPool().closeDbResources(connection, statement, set);
}
return result;
}
Например, я использовал конструкцию try-with-resources
для connection
и prepareStatement
, а как быть с откатом транзакции если получилось исключение, куда ее деть?
rollback(connection);
В блоке catch
я не могу его использовать.
Кстати если возникнет вопрос почему я должен закрыть все три объекта : connection, statement, resutset, - недостаточно закрыть connection, хотя по документации если закрыть connection, то все остальные каналы закроются, на практике бывает не так... Поэтому я закрываю все каналы, используемые при работе в рамках одного запроса.