采用jsp的通讯录系统

package com.address.dao; import java.sql.*; import java.util.Vector; import com.address.po.Address; public class AddressDAO { private Connection conn=null; private Statement stmt=null; private PreparedStatement pstmt=null; private ResultSet rs=null; public AddressDAO() { conn=DBConn.getConn("sa", ""); } public Vector<Address> query(int userId) { Vector<Address> v=new Vector<Address>(); Address ad=null; String sql="select * from Info where user_Id="+userId; try { stmt=conn.createStatement(); rs=stmt.executeQuery(sql); while(rs.next()) { ad=new Address(); ad.setFriId(rs.getInt(1)); ad.setFriName(rs.getString(2)); ad.setFriPhone(rs.getString(3)); ad.setFriOicq(rs.getString(4)); ad.setFriAddress(rs.getString(5)); v.add(ad); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return v; } public Vector<Address> query(String userName,String userPhone,int userId) { Vector<Address> v=new Vector<Address>(); Address ad=null; String sql="select * from Info where user_Id="+userId; if(!userName.equals("")) { sql+=" and fri_Name like '%"+userName+"%'"; } if(!userPhone.equals("")) { sql+=" and fri_Phone like '%"+userPhone+"%'"; } try { stmt=conn.createStatement(); rs=stmt.executeQuery(sql); while(rs.next()) { ad=new Address(); ad.setFriId(rs.getInt(1)); ad.setFriName(rs.getString(2)); ad.setFriPhone(rs.getString(3)); ad.setFriOicq(rs.getString(4)); ad.setFriAddress(rs.getString(5)); v.add(ad); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return v; } public int delDB(String id) { int flag=0; try { stmt=conn.createStatement(); flag=stmt.executeUpdate("delete from Info where fri_Id="+id); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return flag; } public int updateDB(Address address) { int flag=0; try { pstmt=conn.prepareStatement("update Info set fri_Name=?,fri_Phone=?,fri_Oicq=?,fri_Address=? where fri_Id=?"); pstmt.setString(1, address.getFriName()); pstmt.setString(2, address.getFriPhone()); pstmt.setString(3, address.getFriOicq()); pstmt.setString(4, address.getFriAddress()); pstmt.setInt(5, address.getFriId()); flag=pstmt.executeUpdate(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return flag; } public int insertDB(Address address) { int flag=0; try { pstmt=conn.prepareStatement("insert Info(fri_Name,fri_Phone,fri_Oicq,fri_Address,user_Id) values(?,?,?,?,?)"); pstmt.setString(1, address.getFriName()); pstmt.setString(2, address.getFriPhone()); pstmt.setString(3, address.getFriOicq()); pstmt.setString(4, address.getFriAddress()); pstmt.setInt(5, address.getUserId()); flag=pstmt.executeUpdate(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return flag; } public void closeRs() { try { if(rs!=null) { rs.close(); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public void closeStmt() { try { if(stmt!=null) { stmt.close(); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public void closeConn() { try { if(conn!=null) { conn.close(); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }