realstartbean.java

eclipse java/jsp 航空管理系统

/*
 * Copyright Neusoft Dalian Center,All Rights Reserved
 *
 * WEB Application Apply Struts Platform
 * 
 * PackageName shengjb.model
 * ClassName RealStartBean.java
 *
 * @author shengjb  | [e-mail]
 *
 * Created on 2005-4-13
 *
 */
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 zhangchunliang.model.AppMode;
import kangyi.ConnectionPool.DbConnection;

import shengjb.form.RealStartForm;

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

    /** 系统调试日志记录器 */
    static Logger systemDebug = Logger.getLogger(RealStartBean.class);
	
	/**
	 * load MySQL database driver
	 */
	//public RealSuspendBean(){
	//	  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 startdisplayall(RealStartForm realStartForm){
	     
		 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 buffer=new StringBuffer();
	    
		try{
			if(realStartForm.getSid()!= null){
			    /*获取数据库连接*/
			    db = new DbConnection();
			    con = db.getCon();
			    sql = con.createStatement();
			    String update = "UPDATE stuff SET stopflag = "+1+" WHERE sid = "+"'"+ realStartForm.getSid()+ "'";
			    sql.executeUpdate(update);
			    /* 记录用户操作日志：修改用户姓名*/
		        userOperation.info("userID:"+ realStartForm.getSid()+",操作：修改用户ID为：" + realStartForm.getSid() 
        			    + "的停用标志(stopflag)，结果:成功");
			    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("<TH width=50>" + "select");
		        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>");
		    	    String s = "<input type=\"radio\" name=\"sid\" value=\""
					    +rs.getString("sid")+ "\">";
    		        buffer.append("<TD>" + s + "</TD>");
		    	    buffer.append("<TR>");
		        }
		        buffer.append("</Table>");
		        return buffer;
			}else {
		    	return new StringBuffer().append("nochooseuser");
		    }
		}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){}
        }
	}
}