change version and add update

build.gradle

@@ -5,7 +5,7 @@ plugins {
 }
 
 group 'ru.di9'
-version '1.9'
+version '1.9.1'
 
 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);
 }

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

@@ -56,7 +56,7 @@ public class JdbcTemplateImpl implements JdbcTemplate {
              PreparedStatement preparedStatement = connection.prepareStatement(sql)) {
             psp.process(preparedStatement);
             try (ResultSet resultSet = preparedStatement.executeQuery()) {
-                return rse.extractData(resultSet);
+                return resultSet.next() ? rse.extractData(resultSet) : null;
             }
         } catch (SQLException e) {
             throw throwDataAccessException(sql, e);
@@ -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;

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) {
+        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;