Merge remote-tracking branch 'origin/master'

Reviewed-on: https://dev.di9.ru/gitea/dmitriymx/jdbc-template/pulls/1

build.gradle

@@ -5,7 +5,7 @@ plugins {
 }
 
 group 'ru.di9'
-version '1.9'
+version '1.9.2'
 
 repositories {
     mavenCentral()

src/main/java/ru/di9/jdbc/JdbcTemplate.java

@@ -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) throws DataAccessException;
 }

src/main/java/ru/di9/jdbc/JdbcTemplateImpl.java

@@ -1,6 +1,7 @@
 package ru.di9.jdbc;
 
 import org.intellij.lang.annotations.Language;
+import org.jetbrains.annotations.Nullable;
 
 import javax.sql.DataSource;
 import java.sql.*;
@@ -50,6 +51,7 @@ public class JdbcTemplateImpl implements JdbcTemplate {
     }
 
     @Override
+    @Nullable
     public <T> T query(@Language("GenericSQL") String sql, PreparedStatementProcessor psp,
                        ResultSetExtractor<T> rse) throws DataAccessException {
         try (Connection connection = dataSource.getConnection();
@@ -145,6 +147,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) {
         return rs -> {
             List<T> resultList;

src/main/java/ru/di9/jdbc/JdbcTemplateTransactional.java

@@ -112,6 +112,17 @@ public class JdbcTemplateTransactional implements JdbcTemplate, AutoCloseable {
         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) {
         return rs -> {
             List<T> resultList;