employeedata.java

一个简单的基于struts基于人员的管理

package com.yourcompany;
import java.sql.SQLException;
import java.util.ArrayList;

import  com.yourcompany.DatasourceDB;
import  com.yourcompany.Employee;
public class EmployeeData 
//生成现实的对象集合
{
	  
	 //构造函数
     public EmployeeData()
     {
    	 //15919837832
     }
     
     //返回一个员工对象
     public static Employee getEmployee(String username,java.sql.Connection conn) throws Exception
     {
    	 java.sql.Statement st = null;
    	 java.sql.ResultSet rs = null;
    	 Employee em = null;
    	 try
    	 {
    		  st = conn.createStatement();
    	
    		  rs = st.executeQuery("select * from employees where username='"+username+"'");
    		 if( rs.next())
    		 {
    			 em = new Employee();
    			 em.setUsername(rs.getString("username"));
    			 em.setPassword(rs.getString("password"));
    			 em.setDepid(rs.getInt("depid"));
    			 em.setRoleid(rs.getInt("roleid"));
    		 	 em.setName(rs.getString("name"));
    		 	 em.setPhone(rs.getString("phone"));
    		 	 em.setEmail(rs.getString("email"));
    		 } 
    		 else
    		 {
    			 throw new Exception("Employee " + username + " not found!");
    		 }
    	 }
    	 catch(Exception e)
    	 {
    		 
    	 }
    	 finally
    	 {
    		 st.close();
    		 rs.close();
    	 }
    	 return em;
     }

     //返回对象集合
     public static  ArrayList getEmployees(java.sql.Connection conn)
     {
    	 Employee  employee = null;
    	 ArrayList<Employee> employees = new ArrayList<Employee>();
    	 java.sql.Statement st = null;
    	 java.sql.ResultSet rs  = null;
    	 
    	 try
    	 {
    		 st = conn.createStatement();
    		 rs = st.executeQuery("select * from employees inner join roles on employees.roleid = roles.roleid inner join departments on departments.depid = employees.depid");
    		 //得到对象集合
    		 
    		 while(rs.next())
    		 {
    			 employee = new Employee();
    			 employee.setUsername(rs.getString("username"));
    			 employee.setName(rs.getString("name"));
    			 employee.setRolename(rs.getString("rolename"));
    			 employee.setPhone(rs.getString("phone"));
    			 employee.setEmail(rs.getString("email"));
    			 employee.setRoleid(rs.getInt("roleid"));
    			 employee.setDepid(rs.getInt("depid"));
    			 employee.setDepartment(rs.getString("depname"));
    			 employees.add(employee);
    		 }
    	 }
    	 catch( Exception e )
    	 {
    		 
    	 }
    	 finally
    	 {
    		 try
    		 {
    			 st.close();
    			 rs.close();
    		 }
    		 catch(Exception e1)
    		 {
    			 
    		 }
    	 }
    	 return employees;
     }
   
     public static boolean addEmployee(Employee employee,java.sql.Connection conn)
     {
    	 java.sql.Statement st = null;
 
    	 String sqlstr = null;
 
    	 try
    	 {
    		  sqlstr = " insert into employees(username,password,roleid,name,phone,email,depid) ";
    		  sqlstr += "values("+"'"+employee.getUsername()+"'"+","
    		  +"'"+employee.getPassword()+"'"+","
    		  +new Integer(employee.getRoleid()).toString()+","
    		  +"'"+employee.getName()+"'"+","
    		  +"'"+employee.getPhone()+"'"+"," 
    		  +"'"+employee.getEmail()+"'"+"," 
    		  + (new Integer(employee.getDepid())).toString()
    		  +")";
    		  
    		  st = conn.createStatement();
    		  st.execute(sqlstr);
    		 
    		  
    	 }
    	 catch(Exception e)
    	 {
    		 return false;
    	 }
    	 finally
    	 {
    		 try
    		 {
    			 st.close();
    		 }
    		 catch(Exception e1)
    		 {
    			 
    		 }
    	 }
    	 return true;
     }
     
     public static void removeEmployee(String username,java.sql.Connection conn)
     {
    	 java.sql.Statement st = null;
    	 String sqlstr = null;
    	 try
    	 {
    		 sqlstr = "delete from employees where username = "+"'"+username+"'";
    		 st = conn.createStatement();
    		 st.execute(sqlstr);
    		 
    	 }
    	 catch(Exception e)
    	 {
    		 
    	 }
    	 finally
    	 {
    		 try
    		 {
    			 st.close();
    		 }
    		 catch(Exception e1)
    		 {
    			 
    		 }
    	 }
     }
     
     public static void updateEmployee(Employee employee,java.sql.Connection conn) throws SQLException
     {
    	 java.sql.Statement st = null;
    	 String sqlstr = null;
    	 try
    	 {
    		 sqlstr = "update employees "
    			 +"set password ="+"'"+employee.getPassword()+"'"+","
    			 +" password ="+"'"+employee.getPassword()+"'"+","
    			 +" roleid = "+ new Integer(employee.getRoleid()).toString()+","
    			 +" name ="+"'"+employee.getName()+"'"+","
    			 +" phone ="+"'"+employee.getPhone()+"'"+"," 
    			 +" email ="+"'"+employee.getEmail()+"'"+","  
    			 +" depid = "+ new Integer(employee.getDepid()).toString()
    			 +" where username = "+"'"+employee.getUsername()+"'";
    		 st = conn.createStatement();
    		 st.execute(sqlstr);
    			 
    			 
    	 }
    	 catch(Exception e)
    	 {
    		 try
    		 {
    			 
    		 }
    		 catch(Exception e1)
    		 {
    			st.close(); 
    		 }
    	 }
     }
}