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 java.sql.ResultSet;
20 import java.sql.SQLException;
21
22 import org.springframework.batch.sample.domain.trade.CustomerCredit;
23 import org.springframework.jdbc.core.RowMapper;
24
25 public class CustomerCreditRowMapper implements RowMapper {
26
27 public static final String ID_COLUMN = "id";
28 public static final String NAME_COLUMN = "name";
29 public static final String CREDIT_COLUMN = "credit";
30
31 public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
32 CustomerCredit customerCredit = new CustomerCredit();
33
34 customerCredit.setId(rs.getInt(ID_COLUMN));
35 customerCredit.setName(rs.getString(NAME_COLUMN));
36 customerCredit.setCredit(rs.getBigDecimal(CREDIT_COLUMN));
37
38 return customerCredit;
39 }
40
41 }