querybean.java

eclipse java/jsp 航空管理系统

/*
 * Copyright Neusoft Dalian Center,All Rights Reserved
 *
 * WEB Application Apply Struts Platform
 * 
 * PackageName shengjb.model
 * ClassName QueryBean.java
 *
 * @author shengjb  | [e-mail]
 *
 * Created on 2005-4-15
 *
 */
package shengjb.model;

import java.sql.Connection; 
//import java.sql.DriverManager; 
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.ResultSet;

import org.apache.log4j.Logger;

import zhangchunliang.model.AppMode;
import kangyi.ConnectionPool.DbConnection;

/**
 * QueryBean BeanClass
 * 
 * @author shengjb ver.0.7
 */
public class QueryBean {
	
	/** 用户操作日志记录器 */
    static Logger userOperation = Logger.getLogger("userOperation");
    
    /** 用户异常日志记录器 */
    static Logger userError = Logger.getLogger("userError");

    /** 系统调试日志记录器 */
    static Logger systemDebug = Logger.getLogger(QueryBean.class);
	
	/**
	 * load MySQL database driver
	 */
    //public DisplayAllBean(){
	//	try{
    //        Class.forName("com.mysql.jdbc.Driver");   
    //    }
    //    catch(ClassNotFoundException e){
    //        e.getMessage();
    //        userError.error("数据库驱动没有配置");
    //    }
	//}
	
	/**
	 * Display all the records of database table stuff
	 * and a page have ten records
	 */
	public StringBuffer querydisplayall(){
		
		AppMode.registerUser();
	    
		/*connect database*/
		//StringBuffer conSql = new StringBuffer(500);
        //conSql.append("jdbc:mysql://192.168.219.148/ciqms?user=");
        //conSql.append("shengjb");
        //conSql.append("&password=");
        //conSql.append("sunny");
        //conSql.append("&useUnicode=true&characterEncoding=GBK");
        //String conmysql=conSql.toString();
        DbConnection db = null;
        Connection con = null;
        Statement sql = null;
        ResultSet rs = null;
        /*定义StringBuffer变量，在jsp页上显示*/
	    StringBuffer buffer=new StringBuffer();
	    
		try{
			/*获取数据库连接*/
			db = new DbConnection();
			con = db.getCon();
			sql = con.createStatement();
			/*返回可滚动的结果集*/
		    rs = sql.executeQuery("SELECT * FROM stuff");
		    /* 记录用户操作日志：查询所有用户 */
            userOperation.info("操作：查询出所有用户，结果:成功");
			
		    buffer.append("<Table Border>");
		    buffer.append("<TR>");
		    buffer.append("<TH with=100>"+"sid");
		    buffer.append("<TH with=100>"+"sname");
		    buffer.append("<TH with=100>"+"password");
		    buffer.append("<TH with=100>"+"mail");
		    buffer.append("<TH with=100>"+"groupstring");
		    buffer.append("<TH with=100>"+"depno");
		    buffer.append("<TH with=100>"+"stopflag");
		    buffer.append("</TR>");
		    
		    while(rs.next()){
		    	buffer.append("<TR>");
		    	buffer.append("<TD>" + rs.getString("sid")+ "</TD>");
		    	buffer.append("<TD>" + rs.getString("sname")+ "</TD>");
		    	buffer.append("<TD>" + rs.getString("password")+ "</TD>");
		    	//buffer.append("<TD>" + rs.getString("mail")+ "</TD>");
		    	if(rs.getString("mail").length() != 0){
		    		buffer.append("<TD>" + rs.getString("mail")+ "</TD>");
		    	}else{
		    		buffer.append("<TD>" +"&nbsp;"+ "</TD>");
		        }
		    	buffer.append("<TD>" + rs.getString("groupstring")+ "</TD>");
		    	buffer.append("<TD>" + rs.getInt("depno")+ "</TD>");
		    	buffer.append("<TD>" + rs.getInt("stopflag")+ "</TD>");
		    	buffer.append("<TR>");
		    }
		    buffer.append("</Table>");
		    /*返回StringBuffer变量*/
		    return buffer;
		    }catch(SQLException se){
		    System.out.println(se.getMessage());
		    userError.error("查询所有用户错误：SQL语句执行错误");
		  	return new StringBuffer("无法建立连接");
		}finally{
			
			AppMode.loginoutUser();
			
        	try{
        		rs.close();
        		sql.close();
        		con.close();
        	}catch(Exception e){}
        }
	}
}