@Override
    public Job save(Job jobToSave) {
        try (final Connection conn = dataSource.getConnection(); final Transaction transaction = new Transaction(conn)) {
            final Job savedJob = jobTable(conn).save(jobToSave);
            transaction.commit();
            notifyJobStatsOnChangeListeners();
            return savedJob;
        } catch (SQLException e) {
            throw new StorageException(e);
        }
    }
@Test
    void saveJobs_NotAllJobsAreSavedThenThrowConcurrentSqlModificationException() throws SQLException {
        when(preparedStatement.executeBatch()).thenReturn(new int[]{});

        assertThatThrownBy(() -> jobStorageProvider.save(singletonList(anEnqueuedJob().build()))).isInstanceOf(JobRunrException.class);
    }