package test_java; public class TestDao { private JdbcTemplate jt; public void setJt(JdbcTemplate jt) { this.jt = jt; } public List<TNpc> getAll() { String sql = "select * from t_npc"; // 使用 List list = jt.query(sql, new NpcRowMapper()); return list; } /** * 定义内部类实现RowMapper接口 */ public class NpcRowMapper implements RowMapper { // 实现mapRow方法 public Object mapRow(ResultSet rs, int num) throws SQLException { // 对类进行封装 TNpc npc = new TNpc(); npc.setId(rs.getLong("id")); npc.setName(rs.getString("name")); return npc; } } }
package test_java; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Types; import java.util.List; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.RowMapper; import hysteria.contact.dao.ItemDAO; import hysteria.contact.domain.Item; public class ItemDAOImpl implements ItemDAO { private JdbcTemplate jdbcTemplate; public void setJdbcTemplate(JdbcTemplate jdbcTemplate) { this.jdbcTemplate = jdbcTemplate; } public Item insert(Item item) { String sql = "INSERT INTO items(user_id,name,phone,email) VALUES(?,?,?,?)"; Object[] params = new Object[] { item.getUserId(), item.getName(), item.getPhone(), item.getEmail() }; int[] types = new int[] { Types.INTEGER, Types.VARCHAR, Types.CHAR, Types.VARCHAR }; jdbcTemplate.update(sql, params, types); return item; } public Item update(Item item) { String sql = "UPDATE items SET name = ?, phone = ?, email = ? WHERE id = ?"; Object[] params = new Object[] { item.getName(), item.getPhone(), item.getEmail(), item.getId() }; int[] types = new int[] { Types.VARCHAR, Types.CHAR, Types.VARCHAR, Types.VARCHAR, Types.INTEGER }; jdbcTemplate.update(sql, params, types); return item; } public void delete(Item item) { String sql = "DELETE FROM items WHERE id = ?"; Object[] params = new Object[] { item.getId() }; int[] types = new int[] { Types.INTEGER }; jdbcTemplate.update(sql, params, types); } public Item findById(int id) { String sql = "SELECT * FROM items WHERE id = ?"; Object[] params = new Object[] { id }; int[] types = new int[] { Types.INTEGER }; List items = jdbcTemplate.query(sql, params, types, new ItemMapper()); if (items.isEmpty()) { return null; } return (Item) items.get(0); } public List<Item> findAll() { String sql = "SELECT * FROM items"; return jdbcTemplate.query(sql, new ItemMapper()); } public List<Item> findAllByUser(int user_id) { String sql = "SELECT * FROM items WHERE user_id = ?"; Object[] params = new Object[] { user_id }; int[] types = new int[] { Types.INTEGER }; List items = jdbcTemplate.query(sql, params, types, new ItemMapper()); return items; } protected class ItemMapper implements RowMapper { public Object mapRow(ResultSet rs, int rowNum) throws SQLException { Item item = new Item(); item.setId(rs.getInt("id")); item.setUserId(rs.getInt("user_id")); item.setName(rs.getString("name")); item.setPhone(rs.getString("phone")); item.setEmail(rs.getString("email")); return item; } } }
发布时间:2010-11-18
发布时间:2010-11-07
发布时间:2015-09-11
发布时间:2011-02-04
发布时间:2010-11-08
发布时间:2010-10-30
发布时间:2011-01-14
发布时间:2011-01-01
发布时间:2011-02-27
发布时间:2011-01-16
发布时间:2011-03-08
发布时间:2011-01-12