setreader.java

个人办公平台,用JAVA开发的TOMCAT的服务器

/*
 * Created on 2006-9-23
 *
 * To change the template for this generated file go to
 * Window>Preferences>Java>Code Generation>Code and Comments
 */
package com.skyhawk.richeng.setreader;

import java.io.IOException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import com.skyhawk.db.ConnectionFactory;
import com.skyhawk.db.DatabaseUtils;

/**
 * @author Administrator
 *
 * To change the template for this generated type comment go to
 * Window>Preferences>Java>Code Generation>Code and Comments
 */
public class SetReader {

	
	public ArrayList viewReader(HttpServletRequest request,HttpServletResponse response,String empid) {
	    Statement stmt = null;
		ResultSet rs1 = null;
			HttpSession sess=request.getSession();
			String empid1=(String) sess.getAttribute("empid1");
			System.out.println("++++++reader"+empid1);
			
			ArrayList arraylist = new ArrayList();
			 Connection conn =  ConnectionFactory.getConnection();
			 try {
				stmt=conn.createStatement();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			 String datequery ="select readerid,empname from o_reader,o_employee where o_reader.empid='"+empid+"' and o_reader.readerid=o_employee.empid";
			 
			 try {
			 	
			 	System.out.println("==datequery=="+datequery);
			 	
				rs1=stmt.executeQuery(datequery);
			} 
			catch (SQLException e1) {
				e1.printStackTrace();
			}
			  try {
			  
				while(rs1.next()){
				 Reader reader=new Reader();
				    reader.setEmpid(Integer.parseInt(empid));
				 	reader.setName(rs1.getString("empname"));
				 	reader.setReaderId(Integer.parseInt(rs1.getString("readerid")));
				 	arraylist.add(reader);
				}
			    } catch (SQLException e2) {
				e2.printStackTrace();
				
			}
			finally{
			DatabaseUtils coldat =new DatabaseUtils();
			DatabaseUtils.closeObject(rs1,stmt,conn);
			System.out.println("+++++close+++++");
		}
		     return arraylist;
		}
	public void addReader(HttpServletRequest request,HttpServletResponse response) throws SQLException{
		 Statement stmt = null;
			ResultSet rs1 = null;
			 Connection conn =  ConnectionFactory.getConnection();
				HttpSession sess=request.getSession();
				String empid1=(String) sess.getAttribute("empid1");
		stmt=conn.createStatement();
		String emp=request.getParameter("right");
		String insert="insert into o_reader values('"+empid1+"','"+emp+"')";
		System.out.println("readerinsert===="+insert);
		System.out.println("readerright"+emp);
		try {
			stmt.executeUpdate(insert);
			//stmt.execute(insert);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		try {
			request.getRequestDispatcher("/duzheshezhi.jsp").forward(request,response);
		}
		catch (Exception e) {
				e.printStackTrace();
				try {
					try {
						request.getRequestDispatcher("/fail.jsp").forward(request,response);
					} catch (ServletException e2) {
						e2.printStackTrace();
					}
				} catch (IOException e1) {
					e1.printStackTrace();
				}
				
			  }
			  finally{
				DatabaseUtils coldat =new DatabaseUtils();
				DatabaseUtils.closeObject(rs1,stmt,conn);
				System.out.println("+++++close+++++");
			  }
			}
	
	public void deletereader(HttpServletRequest request,HttpServletResponse response){
		Statement stmt = null;
		ResultSet rs1 = null;
		Connection conn =  ConnectionFactory.getConnection();
		
		try {

			stmt=conn.createStatement();
				HttpSession sess=request.getSession();
				String empid1=(String) sess.getAttribute("empid1");
				String readerid=request.getParameter("left");
		
		//String readerid=request.getParameter("l");
		String del="delete from o_reader where empid='"+empid1+"' and readerid='"+readerid+"'";
		
	    System.out.println("del==="+del);
	    int amount = stmt.executeUpdate(del);
	    System.out.println("del==="+amount);
	    
	    request.getRequestDispatcher("/duzheshezhi.jsp").forward(request,response);
	 }
	  catch (Exception e) {
		e.printStackTrace();
		try {
			try {
				request.getRequestDispatcher("/fail.jsp").forward(request,response);
			} catch (ServletException e2) {

				e2.printStackTrace();
			}
		} catch (IOException e1) {
			e1.printStackTrace();
		}
		
	  }
	  finally{
		DatabaseUtils coldat =new DatabaseUtils();
		DatabaseUtils.closeObject(rs1,stmt,conn);
		System.out.println("+++++close+++++");
	  }
	}
}