该文件是一种基于JavaWeb的社交系统

package dao; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import entity.User; import util.DBUtil; public class UserDaoJDBCImp implements UserDao { //获取用户对象 public User getUser(String username,String pwd){ Connection con = DBUtil.getConnection(); try { PreparedStatement pst = con.prepareStatement("select * from friend_user where username=? and password=?"); pst.setString(1, username); pst.setString(2, pwd); ResultSet rs = pst.executeQuery(); if(rs.next()){ System.out.println("查到用户"); User p = new User(username, pwd); p.setUserId(rs.getInt(1)); p.setAge(rs.getInt(5));//年龄 p.setPhone(rs.getString(7));//电话 p.setSex(rs.getString(6));//性别 p.setName(rs.getString(4));//名字 return p; } } catch (SQLException e) { e.printStackTrace(); }finally{ DBUtil.close(con); } return null; } //添加用户 public boolean addUser(User user){ Connection con = DBUtil.getConnection(); try { PreparedStatement pst = con.prepareStatement("insert into friend_user(username,password,name,age,gendar,phone) values(?,?,?,?,?,?)"); pst.setString(1, user.getUsername()); pst.setString(2, user.getPwd()); pst.setString(3, user.getName()); pst.setInt(4, user.getAge()); pst.setString(5, user.getSex()); pst.setString(6, user.getPhone()); pst.execute(); } catch (SQLException e) { System.out.println("用户已存在"); return false; }finally{ DBUtil.close(con); } return true; } //得到所有用户 public ArrayList<User> getUsers(){ Connection con = DBUtil.getConnection(); ArrayList<User> users = new ArrayList<User>(); try { PreparedStatement pst = con.prepareStatement("select * from friend_user"); ResultSet rs = pst.executeQuery(); while(rs.next()){ User user = new User(rs.getString(2),rs.getString(3)); user.setUserId(rs.getInt(1)); user.setName(rs.getString(4)); user.setAge(rs.getInt(5)); user.setSex(rs.getString(6)); user.setPhone(rs.getString(7)); users.add(user); } } catch (SQLException e) { System.out.println("获取对象异常"); e.printStackTrace(); }finally{ DBUtil.close(con); } return users; } public ArrayList<String> getUserPic(int userId){ //获得用户的图片地址 Connection con = DBUtil.getConnection(); ArrayList<String> pics = new ArrayList<String>(); try { PreparedStatement pst = con.prepareStatement("select * from friend_pic where userId=?"); pst.setInt(1,userId); ResultSet rs = pst.executeQuery(); while(rs.next()){ pics.add(rs.getString(2)); } } catch (SQLException e) { System.out.println("图片获取异常"); e.printStackTrace(); }finally{ DBUtil.close(con); } return pics; } public void savePic(String picAddress,int user_id){ Connection con = DBUtil.getConnection(); try { PreparedStatement pst = con.prepareStatement("insert into friend_pic(picName,userId) values(?,?)"); pst.setString(1, picAddress); pst.setInt(2, user_id); pst.execute(); } catch (SQLException e) { System.out.println("图片存入异常"); e.printStackTrace(); }finally{ DBUtil.close(con); } } }