Javaweb的Demo.zip

package com.looeywei.UserCRDUDemo.dao.impl; import com.looeywei.UserCRDUDemo.dao.UserDao; import com.looeywei.UserCRDUDemo.domain.User; import com.looeywei.UserCRDUDemo.util.JDBCUtils; import org.springframework.jdbc.core.BeanPropertyRowMapper; import org.springframework.jdbc.core.JdbcTemplate; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.Set; public class UserDaoImpl implements UserDao { private JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource()); @Override public List<User> findAll() { // 使用JDBC操作数据库 String sql = "select * from user"; List<User> users = template.query(sql, new BeanPropertyRowMapper<User>(User.class)); return users; } @Override public User findUserByUsernameAndPassword(String username, String password) { try { String sql = "select * from user where username = ? and password = ?"; User user = template.queryForObject(sql, new BeanPropertyRowMapper<User>(User.class), username, password); return user; }catch (Exception e){ e.printStackTrace(); return null; } } @Override public void addUser(User user) { String sql = "insert into user values(NULL, ?, ?, ?, ? ,?, ? , null, null)"; template.update(sql, user.getName(), user.getGender(), user.getAge(), user.getAddress(), user.getQq(), user.getEmail()); } @Override public void delUser(int id) { String sql = "delete from user where id = ?"; template.update(sql, id); } @Override public User findUserById(int id) { String sql = "select * from user where id = ?"; return template.queryForObject(sql, new BeanPropertyRowMapper<>(User.class), id); } @Override public void updateUser(User user) { String sql = "update user set name=?, gender=?, age=?, address=?, qq=?, email=? where id=?"; template.update(sql, user.getName(), user.getGender(), user.getAge(), user.getAddress(), user.getQq(), user.getEmail(), user.getId()); } /** * 查询总数量 * @return * @param map */ @Override public int findTotalCount(Map<String, String[]> map) { // 定义初始sql String sql = "select count(*) from user where 1 = 1 "; StringBuilder sb = new StringBuilder(sql); // 遍历map Set<String> keySet = map.keySet(); // 参数集合 List<Object> params = new ArrayList<>(); for (String key : keySet) { // 排除分页条件参数 if("currentPage".equals(key) || "rows".equals(key)){ continue; } // 获取value, 明确只有一个值 String value = map.get(key)[0]; if(value != null && !"".equals(value)){ sb.append(" and " + key + " like ? "); params.add("%" + value + "%"); } } System.out.println(sb); System.out.println(params); int totalCount = template.queryForObject(sb.toString(), Integer.class, params.toArray()); return totalCount; } /** * 分页查询 * @param start * @param rows * @param map * @return */ @Override public List<User> findByPage(int start, int rows, Map<String, String[]> map) { String sql = "select * from user where 1 = 1 "; StringBuilder sb = new StringBuilder(sql); // 遍历map Set<String> keySet = map.keySet(); // 参数集合 List<Object> params = new ArrayList<>(); for (String key : keySet) { // 排除分页条件参数 if("currentPage".equals(key) || "rows".equals(key)){ continue; } // 获取value, 明确只有一个值 String value = map.get(key)[0]; if(value != null && !"".equals(value)){ sb.append(" and " + key + " like ? "); params.add("%" + value + "%"); } } // 添加分页查询 sb.append(" limit ?, ? "); params.add(start); params.add(rows); List<User> list = template.query(sb.toString(), new BeanPropertyRowMapper<>(User.class), params.toArray()); return list; } }