spring的jdbcTemplate小案例

package edu.kmust.user.dao; import java.sql.ResultSet; import java.sql.SQLException; import java.util.List; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.RowMapper; import edu.kmust.user.entity.User; public class UserDao { /* * 通过ioc的方式获取jdbcTemplate对象(该对象已经在配置文件中注入了数据库和c3p0的信息) */ private JdbcTemplate jdbcTemplate ; public void setJdbcTemplate(JdbcTemplate jdbcTemplate) { this.jdbcTemplate = jdbcTemplate; } /** * 添加用户 * @param user */ public void add(User user) { String sql = "insert into tb_user values(?,?)" ; //使用update(String sql,Object...args):int - JdbcTemplate System.out.println(user.getUsername()); int rows = jdbcTemplate.update(sql, user.getUsername(),user.getPassword()); System.out.println("添加成功,影响记录数="+rows); } /** * 根据用户名修改其密码 * @param user */ public void update(User user) { String sql = "update tb_user set user_password=? where user_name=?" ; //使用update(String sql,Object...args) int rows = jdbcTemplate.update(sql,user.getPassword(),user.getUsername()); System.out.println("修改成功,影响记录数="+rows); } /** * 根据用户名删除该用户 * @param user */ public void delete(User user) { String sql="delete from tb_user where user_name=?"; //使用update(String sql,Object...args) int rows = jdbcTemplate.update(sql, user.getUsername()); System.out.println("删除成功,影响记录数="+rows); } /** * 查询所有记录的行数 */ public void queryCount() { String sql = "select count(*) from tb_user"; //使用的是queryForObject(String sql,Class<T> requiredType) int count = jdbcTemplate.queryForObject(sql,Integer.class); System.out.println("查询成功,所有累计行数="+count); } /** * 根据用户名查询该用户 * @param user */ public void queryObject(User user) { String sql = "select * from tb_user where user_name=?" ; /* * 使用queryForObject(String sql,RowMapper<T> rowMapper,Object...args) * 第二参数是接口RowMapper,需要自己写类实现接口，自己做数据封装 */ User user1 = jdbcTemplate.queryForObject(sql, new MyRowMapper(), user.getUsername()); System.out.println("查询成功："+user1); } /** * 返回所有用户的集合 */ public void queryList() { String sql = "select * from tb_user" ; //使用query(String sql,RowMapper<T> rowMapper,Object...args) List<User> userList = jdbcTemplate.query(sql, new MyRowMapper()); System.out.println("查询成功："+userList); } } /** * 自己写的接口封装 * @author zhaoyuqiang * */ class MyRowMapper implements RowMapper<User>{ @Override public User mapRow(ResultSet rs, int num) throws SQLException { //1. 从结果集里面得到数据,注意：user_name是数据库中的字段名称 String username = rs.getString("user_name"); String userpassword = rs.getString("user_password"); //2.把得到的数据封装到对象里面 User user = new User(); user.setUsername(username); user.setUsername(userpassword); return user; } }