java实现在线通讯录

package com.dao; import com.db.*; import com.endity.*; import java.sql.*; import java.util.*; public class BookDao { public Connection conn; public PreparedStatement ps; public ResultSet rs; public BookDao() { conn=DBManager.getConnection(); } //查询当前用户的通讯录 public ArrayList findBookById(int i) { ArrayList list=new ArrayList(); String sql="select * from Book where userId=?"; try { ps=conn.prepareStatement(sql); ps.setInt(1,i); rs=ps.executeQuery(); while(rs.next()) { BookBean book=new BookBean(); book.setId(rs.getInt(1)); book.setName(rs.getString(2)); book.setSex(rs.getString(3)); book.setPhone(rs.getString(4)); book.setAddress(rs.getString(5)); book.setMobilePhone(rs.getString(6)); book.setCompany(rs.getString(7)); book.setComPhone(rs.getString(8)); book.setComAddress(rs.getString(9)); book.setRelation(rs.getInt(10)); book.setUserId(rs.getInt(11)); list.add(book); } } catch (SQLException e) { e.printStackTrace(); } return list; } //查询当前用户的通讯录 public ArrayList findBookRelationById(int i,int j) { ArrayList list=new ArrayList(); String sql="select * from Book where userId=? and relation=?"; try { ps=conn.prepareStatement(sql); ps.setInt(1,i); ps.setInt(2,j); rs=ps.executeQuery(); while(rs.next()) { BookBean book=new BookBean(); book.setId(rs.getInt(1)); book.setName(rs.getString(2)); book.setSex(rs.getString(3)); book.setPhone(rs.getString(4)); book.setAddress(rs.getString(5)); book.setMobilePhone(rs.getString(6)); book.setCompany(rs.getString(7)); book.setComPhone(rs.getString(8)); book.setComAddress(rs.getString(9)); book.setRelation(rs.getInt(10)); book.setUserId(rs.getInt(11)); list.add(book); } } catch (SQLException e) { e.printStackTrace(); } return list; } //添加联系人 public int addBook(BookBean book) { int count=0; String sql="insert into Book values(?,?,?,?,?,?,?,?,?,?) "; try { ps=conn.prepareStatement(sql); ps.setString(1,book.getName()); ps.setString(2,book.getSex()); ps.setString(3,book.getPhone()); ps.setString(4,book.getAddress()); ps.setString(5,book.getMobilePhone()); ps.setString(6,book.getCompany()); ps.setString(7,book.getComPhone()); ps.setString(8,book.getComAddress()); ps.setInt(9,book.getRelation()); ps.setInt(10,book.getUserId()); count=ps.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); } return count; } //删除联系人 public int delBookByBookId(int bookId) { int count=0; String sql="delete from Book where id=?"; try { ps=conn.prepareStatement(sql); ps.setInt(1,bookId); count=ps.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); } return count; } }