|
17 | 17 | */
|
18 | 18 | package ru.mystamps.web.feature.series.importing;
|
19 | 19 |
|
20 |
| -import lombok.RequiredArgsConstructor; |
21 | 20 | import org.apache.commons.lang3.Validate;
|
22 |
| -import org.springframework.beans.factory.annotation.Value; |
| 21 | +import org.springframework.core.env.Environment; |
23 | 22 | import org.springframework.dao.EmptyResultDataAccessException;
|
24 | 23 | import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
|
25 | 24 | import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
|
|
35 | 34 |
|
36 | 35 | // it complains that "request_id" is present many times
|
37 | 36 | @SuppressWarnings("PMD.AvoidDuplicateLiterals")
|
38 |
| -@RequiredArgsConstructor |
39 | 37 | public class JdbcSeriesImportDao implements SeriesImportDao {
|
40 | 38 |
|
41 | 39 | private final NamedParameterJdbcTemplate jdbcTemplate;
|
42 |
| - |
43 |
| - @Value("${series_import_requests.create}") |
44 |
| - private String createSeriesImportRequestSql; |
45 |
| - |
46 |
| - @Value("${series_import_requests.set_series_id_and_change_status}") |
47 |
| - private String setSeriesIdAndChangeStatusSql; |
48 |
| - |
49 |
| - @Value("${series_import_requests.change_status}") |
50 |
| - private String changeStatusSql; |
51 |
| - |
52 |
| - @Value("${series_import_requests.find_by_id}") |
53 |
| - private String findImportRequestByIdSql; |
54 |
| - |
55 |
| - @Value("${series_import_requests.add_raw_content}") |
56 |
| - private String addRawContentSql; |
57 |
| - |
58 |
| - @Value("${series_import_requests.find_raw_content_by_request_id}") |
59 |
| - private String findRawContentSql; |
60 |
| - |
61 |
| - @Value("${series_import_requests.add_series_parsed_data}") |
62 |
| - private String addParsedDataSql; |
63 |
| - |
64 |
| - @Value("${series_import_requests.find_series_parsed_data_by_request_id}") |
65 |
| - private String findParsedDataSql; |
66 |
| - |
67 |
| - @Value("${series_import_requests.find_request_info_by_series_id}") |
68 |
| - private String findRequestInfoSql; |
69 |
| - |
70 |
| - @Value("${series_import_requests.find_all}") |
71 |
| - private String findAllSql; |
| 40 | + private final String createSeriesImportRequestSql; |
| 41 | + private final String setSeriesIdAndChangeStatusSql; |
| 42 | + private final String changeStatusSql; |
| 43 | + private final String findImportRequestByIdSql; |
| 44 | + private final String addRawContentSql; |
| 45 | + private final String findRawContentSql; |
| 46 | + private final String addParsedDataSql; |
| 47 | + private final String findParsedDataSql; |
| 48 | + private final String findRequestInfoSql; |
| 49 | + private final String findAllSql; |
| 50 | + |
| 51 | + @SuppressWarnings("checkstyle:linelength") |
| 52 | + public JdbcSeriesImportDao(Environment env, NamedParameterJdbcTemplate jdbcTemplate) { |
| 53 | + this.jdbcTemplate = jdbcTemplate; |
| 54 | + this.createSeriesImportRequestSql = env.getRequiredProperty("series_import_requests.create"); |
| 55 | + this.setSeriesIdAndChangeStatusSql = env.getRequiredProperty("series_import_requests.set_series_id_and_change_status"); |
| 56 | + this.changeStatusSql = env.getRequiredProperty("series_import_requests.change_status"); |
| 57 | + this.findImportRequestByIdSql = env.getRequiredProperty("series_import_requests.find_by_id"); |
| 58 | + this.addRawContentSql = env.getRequiredProperty("series_import_requests.add_raw_content"); |
| 59 | + this.findRawContentSql = env.getRequiredProperty("series_import_requests.find_raw_content_by_request_id"); |
| 60 | + this.addParsedDataSql = env.getRequiredProperty("series_import_requests.add_series_parsed_data"); |
| 61 | + this.findParsedDataSql = env.getRequiredProperty("series_import_requests.find_series_parsed_data_by_request_id"); |
| 62 | + this.findRequestInfoSql = env.getRequiredProperty("series_import_requests.find_request_info_by_series_id"); |
| 63 | + this.findAllSql = env.getRequiredProperty("series_import_requests.find_all"); |
| 64 | + } |
72 | 65 |
|
73 | 66 | @Override
|
74 | 67 | public Integer add(ImportSeriesDbDto importRequest) {
|
|
0 commit comments