首页 > 代码库 > 信息的增删查改

信息的增删查改

//查询所有信息    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();        }    }

 

 

 

 

信息的增删查改