Merge pull request 'change version and add update' (#1) from feature/update into master
Reviewed-on: https://dev.di9.ru/gitea/dmitriymx/jdbc-template/pulls/1
This commit is contained in:
@@ -5,7 +5,7 @@ plugins {
|
|||||||
}
|
}
|
||||||
|
|
||||||
group 'ru.di9'
|
group 'ru.di9'
|
||||||
version '1.9'
|
version '1.9.1'
|
||||||
|
|
||||||
repositories {
|
repositories {
|
||||||
mavenCentral()
|
mavenCentral()
|
||||||
|
|||||||
@@ -33,4 +33,6 @@ public interface JdbcTemplate {
|
|||||||
ResultSetExtractor<T> processGeneratedKey) throws DataAccessException;
|
ResultSetExtractor<T> processGeneratedKey) throws DataAccessException;
|
||||||
|
|
||||||
void transaction(Consumer<JdbcTemplate> consumer);
|
void transaction(Consumer<JdbcTemplate> consumer);
|
||||||
|
|
||||||
|
void update(@Language("GenericSQL") String sql, PreparedStatementProcessor psp) throws DataAccessException;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -145,6 +145,17 @@ public class JdbcTemplateImpl implements JdbcTemplate {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void update(String sql, PreparedStatementProcessor psp) throws DataAccessException {
|
||||||
|
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) {
|
private <T> ResultSetExtractor<List<T>> createResultSetExtractorList(final RowMapper<T> rowMapper) {
|
||||||
return rs -> {
|
return rs -> {
|
||||||
List<T> resultList;
|
List<T> resultList;
|
||||||
|
|||||||
@@ -112,6 +112,17 @@ public class JdbcTemplateTransactional implements JdbcTemplate, AutoCloseable {
|
|||||||
consumer.accept(this);
|
consumer.accept(this);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void update(String sql, PreparedStatementProcessor psp) throws DataAccessException {
|
||||||
|
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) {
|
private <T> ResultSetExtractor<List<T>> createResultSetExtractorList(final RowMapper<T> rowMapper) {
|
||||||
return rs -> {
|
return rs -> {
|
||||||
List<T> resultList;
|
List<T> resultList;
|
||||||
|
|||||||
Reference in New Issue
Block a user