lanbeancl.java

MVC模式 jsp + servlet + bean 实现简单的用户管理系统

//这是一个处理类,有些人把它叫做bo,主要是封装对users表的各种
//操作,(主要是增，删，修，查...)
package com.djj.model;

import java.sql.*;
import java.util.*;
public class lanBeanCl {

	private Statement sm=null;//PreparedStatement
	private ResultSet rs=null;
	private Connection ct=null;
	private int  pageSize=3;
	private int  rowCount=0;//该值从数据库查询
	private int  pageCount=0;//该值是通过pageSize和rowCount
	
	//添加栏目
	public boolean addLan(String lanName,String lanAbout,String lanSort,String lanTemplate,int lanLever){
		
		boolean b=false;
		
		try {
			
			//得到连接
			ct=new ConnDB().getConn();
			
			sm=ct.createStatement();
			//执行
			int a=sm.executeUpdate("insert into lanmu values('"+lanName+"','"+lanAbout+"','"+lanSort+"','"+lanTemplate+"','"+lanLever+"')");
			if(a==1){
				
				//添加成功
				b=true;
			}
		} catch (Exception e) {
			
			e.printStackTrace();
			// TODO: handle exception
		}finally{
			
			this.close();
		}
		
		return b;
	}
	
	//删除栏目
	public boolean delLanByName(String lanName){
		
		boolean b=false;
		
		try {
			//得到连接
			ct=new ConnDB().getConn();
			
			sm=ct.createStatement();
			//执行
			int a=sm.executeUpdate("delete from lanmu where lanName='"+lanName+"'");
			
			if(a==1){
				
				//删除成功
				b=true;
			}
						
			
		} catch (Exception e) {
			
			e.printStackTrace();
			// TODO: handle exception
		}finally{
			
			this.close();
		}
		
		return b;
	}
	
	//更新用户
	public boolean updateLan(lanBean lan){
		
		boolean b=false;
		
		try {
			
			//得到连接
			ct=new ConnDB().getConn();
			
			sm=ct.createStatement();
			//执行
			
			String lanName = lan.getLanName();
			String lanAbout = lan.getLanAbout();
			String lanSort = lan.getLanSort();
			String lanTemplate = lan.getLanTemplate();
			int lanLever = lan.getLanLever();
			
			int a=sm.executeUpdate(
"update lanmu set lanName='"+lanName+"',lanAbout='"+lanAbout+"',lanSort='"+lanSort+"',lanTemplate='"+lanTemplate+"',lanLever='"+lanLever+"' where lanName='"+lanName+"'");
			
			if(a==1){
				System.out.println("update success");
				//更新成功
				b=true;
			}
						
			
		} catch (Exception e) {
			
			e.printStackTrace();
			// TODO: handle exception
		}finally{
			
			this.close();
		}
		
		return b;
	}
	
	//返回，分页的总页数
	public int getPageCount(){
		
		try {
			
			//得到连接
			ct=new ConnDB().getConn();
			
			sm=ct.createStatement();
//			4. 查询
  			rs=sm.executeQuery("select count(*) from users ");
   
   			//请注意，一定要rs.next()
   			
   			if(rs.next()){	
   				rowCount=rs.getInt(1);//得出一共有多少条数据
   				//System.out.println("----------------"+rowCount);
   			}
   			
   			//计算pageCount,这里算法很多，可以自己设计
   			if(rowCount%pageSize==0){
   				
   				pageCount=rowCount/pageSize;
   			}else{
   				
   				pageCount=rowCount/pageSize+1;
   			}
			//pageCount为分多少条页面
			
		} catch (Exception e) {
			e.printStackTrace();
			// TODO: handle exception
		}finally{
			
			this.close();
		}
		
		return pageCount;
	}
	
	//得到用户需要显示的用户信息(分页)
	
	public ArrayList getLanmuByPage(int pageNow){
		
		ArrayList al=new ArrayList();
		try {
			//创建连接
			ct=new ConnDB().getConn();
			
//			3.创建Statement 
  			sm=ct.createStatement();
   			
   			//查询出需要显示的记录
   			
   			rs=sm.executeQuery("select top "+pageSize
   			+" * from lanmu where lanName not in (select top "
   			+pageSize*(pageNow-1)+" lanName from lanmu) ");
   			
			//开始将rs封装到ArrayList
   			while(rs.next()){
   				lanBean lb = new lanBean();
   				lb.setLanName(rs.getString(1));
   				lb.setLanAbout(rs.getString(2));
   				lb.setLanSort(rs.getString(3));
   				lb.setLanTemplate(rs.getString(4));
   				lb.setLanLever(rs.getInt(5));
   				//将ub放入到arryalist中
   				al.add(lb);
   			}
			
		} catch (Exception e) {
			e.printStackTrace();
			// TODO: handle exception
		}finally{
			//关闭资源
			this.close();
		}
		
		return al;
	}
	//根据用户名搜索用户信息
   public ArrayList selectUser(String u){
		
	   ArrayList al=new ArrayList();
		try {
			
//			到数据库中去验证用户
	    	ct=new ConnDB().getConn();
		    
	  		//3.创建Statement 
	  		sm=ct.createStatement();
	  		
	  		//4. 查询
	  		rs=sm.executeQuery("select * from users where username='"+u+"'");
	  		
	  		//根据结果判断
	  		if(rs.next()){
	  			System.out.println("rs.next() have values");
	  			UserBean ub=new UserBean();
   				ub.setUserId(rs.getInt(1));
   				ub.setUsername(rs.getString(2));
   				ub.setPasswd(rs.getString(3));
   				ub.setRepasswd(rs.getString(4));
   				ub.setGrade(rs.getString(5));
   				al.add(ub);
	  		}
			
		} catch (Exception e) {
		   
			e.printStackTrace();    // TODO: handle exception
		
		}finally{
			
			this.close();
		}
		return al;
	}
	
   //关闭资源
	public void close(){
		
		try {
			
			if(rs!=null){
				
				rs.close();
				rs=null;
			}
			if(sm!=null){
				
				sm.close();
				sm=null;
			}
			if(ct!=null){
				
				ct.close();
				ct=null;
				
			}
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
	}
	
	
//	//验证用户是否存在
//	
//	public boolean checkUser(String u,String p ){
//		
//		boolean b=false;
//		
//		//...
//		try {
//			
////			到数据库中去验证用户
//	    	ct=new ConnDB().getConn();
//		    
//	  		//3.创建Statement 
//	  		sm=ct.createStatement();
//	  		
//	  		//4. 查询
//	  		rs=sm.executeQuery("select passwd from users where username='"+u+"'");
//	  		
//	  		//根据结果判断
//	  		if(rs.next()){
//	  			
//	  			//说明用户名存在
//	  			if(rs.getString(1).equals(p)){
//	  				
//	  				//一定合法
//	  				b=true;
//	  			}
//	  		}
//			
//		} catch (Exception e) {
//			e.printStackTrace();
//			// TODO: handle exception
//		}finally{
//			
//			//关闭打开的各种资源，这个很重要的!!!!
//			
//			//函数 ！！
//			this.close();
//		}
//		
//		return b;
//		
//	}
//public static void main(String args[]){
//	UserBeanCl ub = new UserBeanCl();
//	//ub.selectUser("端建军");
////	//String grade = "站点管理员";
//	UserBean user = new UserBean();
//	user.setUsername("龙龙");
//	user.setPasswd("111");
//	user.setRepasswd("111");
//	user.setGrade("模块管理员");
//	ub.updateUser(user);
////	//ub.addUser("端丽萍", "1010", "1010", "栏目管理员");
//}
}