查询全部
//查询所有用户 public List<User> findUser(){ List<User> list = new ArrayList<User>(); try { DataCon dc = new DataCon(); //数据库对象 Connection con = dc.getConnction();//连接数据库 String sql = "select * from user";//sql语句 PreparedStatement ps = con.prepareStatement(sql);//处理sql语句 ResultSet rs = ps.executeQuery();//执行查询 while(rs.next()){ User us = new User();//创建用户对象 us.setUserName(rs.getString("userName"));//得到数据库中列传入用户名到User对象 us.setPassWord(rs.getString("passWord"));//得到数据库中列传入密码到User对象 list.add(us); } dc.closeAll(rs,ps,con);//关闭数据库 } catch (Exception e) { e.printStackTrace(); } return list; }
//测试类中的所有用户查询测试 UserDao userDao = new UserDao(); User user = new User(); @Test public void testUser(){ List<User> list = userDao.findUser();//调用方法 for(User u:list) System.out.println(u.getUserName()); }
判断用户名,密码
//查询单个用户 public int selectUser(User user){ try { DataCon dc = new DataCon();//数据库对象 Connection con = dc.getConnction();//连接数据库 String sql ="select * from user where userName=? and passWord=?";//查询用户名,密码的sql语句 PreparedStatement ps = con.prepareStatement(sql); ps.setString(1, user.getUserName());//得到用户名 ps.setString(2, user.getPassWord());//得到密码 ResultSet rs = ps.executeQuery();//执行查询 if(rs.next()){ return rs.getInt("id"); } } catch (Exception e) { e.printStackTrace(); } return -1; }
//测试类中判断用户的代码
@Test public void testselect(){ user.setUserName("嘎嘎");//传入值 user.setPassWord("123");//传入值 userDao.selectUser(user);//调用方法 }
数据插入
//插入用户 public void insertUser(User user){ try { DataCon dc = new DataCon();//数据库对象 Connection con = dc.getConnction();//连接数据库 String sql ="insert into user(userName,passWord) values(?,?)";//插入语句 PreparedStatement ps = con.prepareStatement(sql);//执行sql ps.setString(1, user.getUserName());//传入要传入的用户名 ps.setString(2, user.getPassWord());//传入要传入的密码 ps.executeUpdate();//执行插入 } catch (Exception e) { e.printStackTrace(); } }
//测试类中插入信息测试
@Test public void testInsert(){ user.setUserName("哈哈");//传入值 user.setPassWord("123");//传入值 userDao.insertUser(user);//调用方法 }
//更新用户密码
public void updateUser(User user){ try { DataCon dc = new DataCon();//数据库对象 Connection con = dc.getConnction();//连接数据库 String sql ="update user set passWord=? where id=?";//更新语句 PreparedStatement ps = con.prepareStatement(sql);//执行sql ps.setString(1, user.getPassWord());//传入要传入的密码 ps.setInt(2, user.getId());//传入要传入的密码 ps.executeUpdate();//执行插入 } catch (Exception e) { e.printStackTrace(); } }
//测试用户更新
public void testUpdate(){ User user = new User(); user.setPassWord("123"); user.setId(5); userDao.updateUser(user); }
//删除
public void deleteUser(int id){ try { DataCon dc = new DataCon();//数据库对象 Connection con = dc.getConnction();//连接数据库 String sql = "delete from user where id=?";//删除语句 PreparedStatement ps = con.prepareStatement(sql); ps.setInt(1, id);//删除的id ps.executeUpdate(); } catch (Exception e) { e.printStackTrace(); } }
//测试删除
public void testDelete(){ userDao.deleteUser(11); userDao.deleteUser(12); }