java超市账单管理系统

package com.wen.supermarketbill.dao.impl; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import com.wen.supermarketbill.dao.BaseDao; import com.wen.supermarketbill.dao.UserDao; import com.wen.supermarketbill.entity.User; /** * * @author wenxinrui * */ public class UserDaoImpl implements UserDao { protected Connection conn = null; protected PreparedStatement pst = null; protected ResultSet rs = null; BaseDao bd = new BaseDao(); String sql; User user; int updateRows = 0; // 释放资源 public void close() { if (rs != null) { try { rs.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } if (pst != null) { try { pst.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } if (conn != null) { try { conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } // 查询 public List<User> getUsersListByName(String userName) { List<User> userList = new ArrayList<User>(); if (userName != null) { sql = "select * from userInfo where userName=?"; } else { sql = "select * from userInfo"; } Object[] params = { userName }; rs = bd.executeSQL(sql, params); try { while (rs.next()) { user = new User(); user.setId(rs.getInt("id")); user.setUserId(rs.getString("userId")); user.setUserName(rs.getString("userName")); user.setUserPassword(rs.getString("userPassword")); user.setUserAddress(rs.getString("userAddress")); user.setUserAge(rs.getString("userAge")); user.setUserGender(rs.getString("userGender")); user.setUserPhoneNumber(rs.getString("userPhoneNumber")); user.setUserPower(rs.getString("userPower")); userList.add(user); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { close(); } return userList; } // 根据用户名获取密码 public String getPassword(String userName) { sql = "select * from userInfo where userName=?"; Object[] params = { userName }; rs = bd.executeSQL(sql, params); try { while (rs.next()) { return rs.getString("userPassword"); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { close(); } return null; } // 根据用户名获取用户身份 public String getPower(String userName) { sql = "select * from userInfo where userName=?"; Object[] params = { userName }; ResultSet rs = bd.executeSQL(sql, params); try { while (rs.next()) { return rs.getString("userPower"); } } catch (SQLException e) { e.printStackTrace(); } finally { close(); } return null; } // 增加用户信息 public boolean add(User user) { sql = "insert into userInfo(userId,userName,userPassword,userGender,userAge,userPhoneNumber,userAddress,userPower) values (?,?,?,?,?,?,?,?)"; Object[] params = { user.getUserId(), user.getUserName(), user.getUserPassword(), user.getUserGender(), user.getUserAge(), user.getUserPhoneNumber(),user.getUserAddress(), user.getUserPower() }; updateRows = bd.executeUpdate(sql, params); close(); if (updateRows != 1) { return false; } else { return true; } } // 删除删除信息 public boolean delete(int id) { sql="delete from userInfo where Id=?"; Object[] params ={id}; updateRows=bd.executeUpdate(sql, params); close(); if (updateRows != 1) { return false; } else { return true; } } // 根据id获得user对象 public User getUserById(int id) { user=new User(); sql="select *from userInfo where Id=?"; Object[] params ={id}; rs=bd.executeSQL(sql, params); try { while (rs.next()) { user = new User(); user.setId(rs.getInt("id")); user.setUserId(rs.getString("userId")); user.setUserName(rs.getString("userName")); user.setUserPassword(rs.getString("userPassword")); user.setUserAddress(rs.getString("userAddress")); user.setUserAge(rs.getString("userAge")); user.setUserGender(rs.getString("userGender")); user.setUserPhoneNumber(rs.getString("userPhoneNumber")); user.setUserPower(rs.getString("userPower")); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ close(); } return user; } // 获得user列表 public List<User> getUsersList() { List<User> userList = new ArrayList<User>(); sql = "select * from userInfo"; Object[] params = {}; rs = bd.executeSQL(sql, params); try { while (rs.next()) { user = new User(); user.setId(rs.getInt("id")); user.setUserId(rs.getString("userId")); user.setUserName(rs.getString("userName")); user.setUserPassword(rs.getString("userPassword")); user.setUserAddress(rs.getString("userAddress")); user.setUserAge(rs.getString("userAge")); user.setUserGender(rs.getString("userGender")); user.setUserPhoneNumber(rs.getString("userPhoneNumber")); user.setUserPower(rs.getString("userPower")); userList.add(user); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ close(); } return userList; } // 修改用户信息 public boolean update(User user) { sql="update userInfo set userId=?,userName=?,userGender=?,userAge=?,userPhoneNumber=?,userAddress=? where Id=?"; Object[] params = {user.getUserId(),user.getUserName(),user.getUserGender(),user.getUserAge(),user.getUserPhoneNumber(),user.getUserAddress(),user.getId()}; updateRows = bd.executeUpdate(sql, params); close(); if (updateRows != 1) { return false; } else { return true; } } // 修改密码 public boolean updateUserPassWord(int id,String newPassword) { sql="update userInfo set userPassword=? where Id=?"; Object[] params = {newPassword,id}; updateRows = bd.executeUpdate(sql, params); close(); if (updateRows != 1) { return false; } else { return true; } } }