realquerybean.java

eclipse java/jsp 航空管理系统

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

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

import org.apache.log4j.Logger;

import shengjb.form.RealQueryForm;
import zhangchunliang.model.AppMode;
import kangyi.ConnectionPool.DbConnection;

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

    /** 系统调试日志记录器 */
    static Logger systemDebug = Logger.getLogger(RealQueryBean.class);
	
	/**
	 * load MySQL database driver
	 */
	//public RealQueryBean(){
	//	  try{
    //        Class.forName("com.mysql.jdbc.Driver");   
    //    }
    //    catch(ClassNotFoundException e){
    //        System.out.println(e.getMessage());
    //        userError.error("数据库驱动没有配置");
    //    }
	//}

	/**
     * name:         转换字符串方法
     * Description:  把屏幕上获取的中文字符串正确的传入MODEL中
     * @return       Str 转换完的字符串 
     */
    public String convert(String s){
        String str=s;
        try{
            byte b[]=str.getBytes("ISO-8859-1");
            str=new String(b);
            return str;
        }
        catch(Exception e){
            return str;
        }
    }
  
	/**
	 * 查出满足条件的记录，并显示到JSP中
	 */
	public StringBuffer querydisplayall(RealQueryForm realQueryForm){
		
		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;
        
        /*获得RealQueryForm里的queryName并转换成字符串*/
        String queryName = realQueryForm.getQueryName();
        queryName = convert(queryName);	
        
        StringBuffer buffer=new  StringBuffer();
        
		try{
			/*获取数据库连接*/
            db = new DbConnection();
            con = db.getCon();
            sql=con.createStatement();
           	String condition = "SELECT * FROM stuff WHERE sname LIKE '%"+ queryName +"%'";
           	rs = sql.executeQuery(condition);
           	/* 记录用户操作日志：查询满足条件的用户 */
            userOperation.info("操作：查询出用户名中含有"+ queryName + "的所有用户，结果:成功");
           	
           	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>");
            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){}
        }
	}
}