美文网首页
User的Dao类

User的Dao类

作者: Joy_yang17 | 来源:发表于2018-05-22 19:55 被阅读6次

    /**对数据库中的表进行增,删,改,查
    */
    package com.nsu.dao;

    import java.net.PasswordAuthentication;
    import java.sql.Connection;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.util.ArrayList;

    import org.omg.CORBA.WCharSeqHelper;

    import com.mysql.jdbc.PreparedStatement;
    import com.nsu.bean.User;
    import com.nsu.util.DButil;

    public class UserDao {
    private Connection conn;
    private java.sql.PreparedStatement pst;//pst预处理
    private ResultSet rs;
    DButil db = new DButil();

    //添加用户,传递参数user
    public boolean addUser(User user){
        boolean b=false;
        try {
            //获得数据库的链接
            conn=db.getConn();
            String sql = "insert into users(name,sex,pwd ) values('"+user.getName()+"','"+user.getSex()+"','"+user.getPwd()+"')";
            //private java.sql.PreparedStatement pst;编译
            pst = conn.prepareStatement(sql);
            int a =pst.executeUpdate();
            if(a==1){
                b=true;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return b;
    }
    
    //删除用户
    public boolean delUser(int id) {
        boolean b= false;
        try {
            conn = db.getConn();//1.获得链接
             String sql="delete from users where id="+id;//2.输入sql语句
             pst=conn.prepareStatement(sql);//3.预编译
             int a=pst.executeUpdate();//4.执行
             if(a==1){
                 b=true;
             }
             
        } catch (Exception e) {
            
            e.printStackTrace();
        }
     
        return b; 
        
    }
    
    
    //修改用户
    public boolean updUser(User user){
        //判断是否修改
        boolean b = false;
        try {
            conn=db.getConn();//1.获得链接
            String sql="update users set name='"+user.getName()+"',sex='"+user.getSex()+"',pwd='"+user.getPwd()+"' where id="+user.getId();//2.输入sql语句
            System.out.println(sql);
            pst=conn.prepareStatement(sql);
            int a =pst.executeUpdate();
            if (a==1){
                b=true;
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return b;
    }
    //查寻
    public User selectUserbyId(int id){
        User user=new User();
        try {
            conn=db.getConn();
            String sql="select*from users where id="+id;
            pst=conn.prepareStatement(sql);
            rs=pst.executeQuery();
            while (rs.next()){   //判断是否为空
                user.setId(rs.getInt(1)); 
                user.setName(rs.getString(2));
                user.setPwd(rs.getString(3));
                user.setSex(rs.getString(4));
            
            
            }
        }
            catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } 
    
    
           catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return user;
    
    
        
    }
    //多项查寻
    public ArrayList<User> selectUserAll(){
        ArrayList<User> al = new ArrayList<User>();
        try {
            conn=db.getConn();//获取链接
            String sql = "select * from users";
            pst=conn.prepareStatement(sql);//编译
            rs=pst.executeQuery();
            while(rs.next()){
                User user = new User();
                //rs.getint(1)
                user.setId(rs.getInt(1));
                user.setName(rs.getString(2));
                user.setSex(rs.getString(3));
                user.setPwd(rs.getString(4));
                //将user对象添加到al中
                al.add(user);
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return al;
    }
    //查寻用户名密码与数据库密码是否一致
    public boolean loginUser(String username,String pwd){
        boolean b = false;
        String password="";
        try {
            conn = db.getConn();
            String sql = "select pwd from users where usersname";
                    pst=conn.prepareStatement(sql);
            rs=pst.executeQuery();
            if(rs.next()){
                password=rs.getString(1);
                
            }
            if(password.equals(pwd))
                b=true;
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return false;
        
    }
    
    public static void main(String[] args) {
        UserDao ud = new UserDao();
        boolean b =ud.loginUser("admin", "admin");
        System.out.println(b);
        //ud.delUser(1);//(删除)
        
        //添加数据
        //User user = new User();
        //user.setId(8);
        //user.setSex("女");
        //user.setName("zhangsan");
        //user.setPwd("123456");
        //System.out.println(ud.addUser(user));
        
        //User user = ud.selectUserbyId(6);
        //ArrayList<User> al = new ArrayList<User>();
        //al = ud.selectUserAll();//调用ud方法
        //for(int i=0;i<al.size();i++){
        //  System.out.println("第"+i+"个的名字"+al.get(i).getName());
        }
        //System.out.println("id为6 的用户:"+user.getId()+","+user.getName()+","+user.getPwd()+","+user.getSex());
        
    
    
    }
    

    相关文章

      网友评论

          本文标题:User的Dao类

          本文链接:https://www.haomeiwen.com/subject/gkmkjftx.html