1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 package org.springframework.batch.sample.domain.trade.internal;
18
19 import javax.sql.DataSource;
20
21 import org.springframework.batch.sample.domain.trade.CustomerDebit;
22 import org.springframework.batch.sample.domain.trade.CustomerDebitDao;
23 import org.springframework.beans.factory.annotation.Autowired;
24 import org.springframework.jdbc.core.JdbcOperations;
25 import org.springframework.jdbc.core.JdbcTemplate;
26
27
28
29
30
31
32
33 public class JdbcCustomerDebitDao implements CustomerDebitDao {
34
35 private static final String UPDATE_CREDIT = "UPDATE CUSTOMER SET credit= credit-? WHERE name=?";
36
37 private JdbcOperations jdbcTemplate;
38
39 public void write(CustomerDebit customerDebit) {
40 jdbcTemplate.update(UPDATE_CREDIT, customerDebit.getDebit(), customerDebit.getName());
41 }
42
43 @Autowired
44 public void setDataSource(DataSource dataSource) {
45 this.jdbcTemplate = new JdbcTemplate(dataSource);
46 }
47
48 }