realdeletebean.java

eclipse java/jsp 航空管理系统

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

import shengjb.form.RealDeleteForm;
import zhangchunliang.model.AppMode;

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

    /** 系统调试日志记录器 */
    static Logger systemDebug = Logger.getLogger(RealDeleteBean.class);
	
	/**
	 * load MySQL database driver
	 */
	//public RealDeleteBean(){
	//	  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 deletedisplayall(RealDeleteForm realDeleteForm){
		
		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(realDeleteForm.getSid()!= null){
			    /*获取数据库连接*/ 
			    db = new DbConnection();
			    con = db.getCon();
			    sql = con.createStatement();
			    String delete = "DELETE FROM stuff WHERE sid"+"="+"'"+ realDeleteForm.getSid()+ "'";
			    /* 记录用户操作日志：查询所有用户 */
                userOperation.info("操作：删除sid为："+ realDeleteForm.getSid()+"的用户，结果:成功");
			    sql.executeUpdate(delete);
			    /* 记录用户操作日志：查询所有用户 */
                userOperation.info("操作：查询出删除后的所有用户，结果:成功");
			    rs = sql.executeQuery("SELECT * FROM stuff");
		        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>");
		        //con.close();
		        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){}
        }
	}
}