change version and add update

This commit is contained in:
lCarLyl
2022-09-25 01:40:41 +03:00
parent 8512b8ffe4
commit 3676b24d0f
4 changed files with 25 additions and 1 deletions

View File

@@ -33,4 +33,6 @@ public interface JdbcTemplate {
ResultSetExtractor<T> processGeneratedKey) throws DataAccessException;
void transaction(Consumer<JdbcTemplate> consumer);
void update(@Language("GenericSQL") String sql, PreparedStatementProcessor psp);
}

View File

@@ -145,6 +145,17 @@ public class JdbcTemplateImpl implements JdbcTemplate {
}
}
@Override
public void update(String sql, PreparedStatementProcessor psp) {
try (PreparedStatement statement = dataSource.getConnection().prepareStatement(sql)){
psp.process(statement);
statement.executeUpdate();
}catch (SQLException e){
throw throwDataAccessException(sql, e);
}
}
private <T> ResultSetExtractor<List<T>> createResultSetExtractorList(final RowMapper<T> rowMapper) {
return rs -> {
List<T> resultList;

View File

@@ -112,6 +112,17 @@ public class JdbcTemplateTransactional implements JdbcTemplate, AutoCloseable {
consumer.accept(this);
}
@Override
public void update(String sql, PreparedStatementProcessor psp) {
try (PreparedStatement statement = connection.prepareStatement(sql)) {
psp.process(statement);
statement.executeUpdate();
} catch (SQLException e) {
throw throwDataAccessException(sql, e);
}
}
private <T> ResultSetExtractor<List<T>> createResultSetExtractorList(final RowMapper<T> rowMapper) {
return rs -> {
List<T> resultList;