信息的增删查改

//查询所有信息
    public List<Info> findAllInfo(){
        List<Info> list = new ArrayList<Info>();
        try {
            DataCon dc = new DataCon(); //数据库对象
            Connection con = dc.getConnction();//连接数据库
            String sql = "select i.*,u.* from info i,user u where i.userid=u.id";//查询所有的用户，用户留言信息，密码的sql语句
            PreparedStatement ps = con.prepareStatement(sql);//处理sql语句
            
            ResultSet rs = ps.executeQuery();//执行查询
            while(rs.next()){
                Info in = new Info();//创建用户留言对象
                in.setId(rs.getInt("i.id"));//得到数据库中列传入信息ID到Info对象 
                in.setInfoTitle(rs.getString("i.InfoTitle"));
                in.setinformation(rs.getString("i.Information"));
                in.setUserid(rs.getInt("u.id"));
                in.setUsername(rs.getString("u.username"));
                list.add(in);
            }
        
            dc.closeAll(rs,ps,con);//关闭数据库
        } catch (Exception e) {
            e.printStackTrace();
        }    
        return list;
    }

 

//查询单个用户对应的所有留言

//查询单个用户对应的所有留言
    public List<Info> selectUserInfo(int id){
        List<Info> list = new ArrayList<Info>();
        DataCon dc = new DataCon();//数据库对象
        Connection con = dc.getConnction();//连接数据库
        String sql ="select i.*,u.* from info i,user u where i.userid=u.id and u.id=?";//查询用户名，密码的sql语句
        try {
            
            PreparedStatement ps = con.prepareStatement(sql);
            ps.setInt(1, id);//得到用户名
        
            ResultSet rs = ps.executeQuery();//执行查询
            while(rs.next()){
                Info in = new Info();//创建用户留言对象
                in.setId(rs.getInt("i.id"));//得到数据库中列传入信息ID到Info对象 
                in.setInfoTitle(rs.getString("i.InfoTitle"));
                in.setinformation(rs.getString("i.Information"));
                in.setUserid(rs.getInt("u.id"));
                in.setUsername(rs.getString("u.username"));
                list.add(in);
            }    
        } catch (Exception e) {
            e.printStackTrace();
        }
        return list;
    }

//查询单个留言对应的信息  
  public Info selectInfo(int infoid){
        Info in = new Info();//创建用户留言对象
        DataCon dc = new DataCon();//数据库对象
        Connection con = dc.getConnction();//连接数据库
        String sql ="select i.*,u.* from info i,user u where i.userid=u.id and i.id=?";//查询单个留言对应的信息，密码的sql语句
        try {
            
            PreparedStatement ps = con.prepareStatement(sql);
            ps.setInt(1, infoid);//得到用户名
        
            ResultSet rs = ps.executeQuery();//执行查询
            while(rs.next()){
                
                in.setId(rs.getInt("i.id"));//得到数据库中列传入信息ID到Info对象 
                in.setInfoTitle(rs.getString("i.InfoTitle"));
                in.setinformation(rs.getString("i.Information"));
                in.setUserid(rs.getInt("u.id"));
                in.setUsername(rs.getString("u.username"));
                
            }    
        } catch (Exception e) {
            e.printStackTrace();
        }
        return in;
    }

//插入用户
    public void insertUser(Info info){
        DataCon dc = new DataCon();//数据库对象
        Connection con = dc.getConnction();//连接数据库
        String sql ="insert into info(infoTitle,information,userid) values(?,?,?)";//插入语句
        try {
            PreparedStatement ps = con.prepareStatement(sql);//执行sql
            ps.setString(1, info.getInfoTitle());//传入要传入的用户名
            ps.setString(2, info.getinformation());//传入要传入的密码
            ps.setInt(3, info.getUserid());//传入要传入的密码
            ps.executeUpdate();//执行插入
        } catch (Exception e) {
            e.printStackTrace();
        }
            
    }
    //更新用户信息
    public void updateUser(Info info){
        DataCon dc = new DataCon();//数据库对象
        Connection con = dc.getConnction();//连接数据库
        String sql ="update info set infoTitle=?,information=? where id=?";//更新语句
        try {
            PreparedStatement ps = con.prepareStatement(sql);//执行sql
            ps.setString(1, info.getInfoTitle());//传入要传入的用户名
            ps.setString(2, info.getinformation());
            ps.setInt(3, info.getId());//传入要传入的密码
            
            ps.executeUpdate();//执行插入
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    //删除用户留言信息
    public void deleteInfo(int id){
        DataCon dc = new DataCon();//数据库对象
        Connection con = dc.getConnction();//连接数据库
        String sql = "delete from info where id=?";//删除语句
        try {
            PreparedStatement ps = con.prepareStatement(sql);
            ps.setInt(1, id);//删除的id
        
            ps.executeUpdate();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }