http://blog.chinaunix.net/uid-10018502-id-2972078.html

1. 實現一、在內部建立內聯類實現RowMapper介面   
2. package hysteria.contact.dao.impl;   
3. import java.sql.ResultSet;   
4. import java.sql.SQLException;   
5. import java.sql.Types;   
6. import java.util.List;   
7. import org.springframework.jdbc.core.JdbcTemplate;   
8. import org.springframework.jdbc
   .core.RowMapper;   
9. import hysteria.contact.dao.ItemDAO;   
10. import hysteria.contact.domain.Item;   
11. publicclass ItemDAOImpl implements ItemDAO {   
12. private JdbcTemplate jdbcTemplate;   
13. publicvoid setJdbcTemplate(JdbcTemplate jdbcTemplate) {   
14. this.jdbcTemplate = jdbcTemplate;   
15. }   
16. public Item insert(Item item) {   
17.    String sql = "INSERT INTO items(user_id,name,phone,email) VALUES(?,?,?,?)";   
18.    Object[] params = new Object[]{item.getUserId(),item.getName(),item.getPhone(),item.getEmail()};   
19. int[] types = newint[]{Types.INTEGER,Types.VARCHAR,Types.CHAR,Types.VARCHAR};   
20.    jdbcTemplate.update(sql,params,types);   
21. return item;   
22. }   
23. public Item update(Item item) {   
24.    String sql = "UPDATE items SET name = ?, phone = ?, email = ? WHERE id = ?";   
25.    Object[] params = new Object[] {item.getName(),item.getPhone(),item.getEmail(),item.getId()};   
26. int[] types = newint[] {Types.VARCHAR,Types.CHAR,Types.VARCHAR,Types.VARCHAR,Types.INTEGER};   
27.    jdbcTemplate.update(sql,params,types);   
28. return item;   
29. }   
30. publicvoid delete(Item item) {   
31.    String sql = "DELETE FROM items WHERE id = ?";   
32.    Object[] params = new Object[] {item.getId()};   
33. int[] types = newint[]{Types.INTEGER};   
34.    jdbcTemplate.update(sql,params,types);   
35. }   
36. public Item findById(int id) {   
37.    String sql = "SELECT * FROM items WHERE id = ?";   
38.    Object[] params = new Object[] {id};   
39. int[] types = newint[] {Types.INTEGER};   
40.    List items = jdbcTemplate.query(sql,params,types,new ItemMapper());   
41. if(items.isEmpty()){   
42. returnnull;   
43.    }   
44. return (Item)items.get(0);   
45. }   
46. public List findAll() {   
47.    String sql = "SELECT * FROM items";   
48. return jdbcTemplate.query(sql,new ItemMapper());   
49. }   
50. public List findAllByUser(int user_id) {   
51.    String sql = "SELECT * FROM items WHERE user_id = ?";   
52.    Object[] params = new Object[]{user_id};   
53. int[] types = newint[]{Types.INTEGER};   
54.    List items = jdbcTemplate.query(sql,params,types,new ItemMapper());   
55. return items;   
56. }   
57. protectedclass ItemMapper implements RowMapper {   
58. public Object mapRow(ResultSet rs, int rowNum) throws SQLException {   
59.     Item item = new Item();   
60.     item.setId(rs.getInt("id"));   
61.     item.setUserId(rs.getInt("user_id"));   
62.     item.setName(rs.getString("name"));   
63.     item.setPhone(rs.getString("phone"));   
64.     item.setEmail(rs.getString("email"));   
65. return item;   
66.    }   
67. }   
68. }