searchdao.java

一个管理系统 用java作的

/*
 *  僔僗僥儉丂丂丗 嶳廏HR僔僗僥儉奐敪
 *  僒僽僔僗僥儉丗 WEB僔僗僥儉
 *
 *   VER    丂曄峏擔     丂晹壽      扴摉幰  丂曄峏撪梕
 *  -----------------------------------------------------------------
 *  V1.00 丂丂${date} (ShanXiu丂Soft)  Tuwenjie   弶斉
 *
 *       (C) Copyright SHANXIU CORPORATION 2006
 *                     All Rights Reserved.
 *
 */


package net.shanxiu.HR.dao;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;

import javax.naming.InitialContext;
import javax.sql.DataSource;

import net.shanxiu.HR.entity.Constants;
import net.shanxiu.HR.vo.DepVo;
import net.shanxiu.HR.vo.DetailVo;
import net.shanxiu.HR.vo.M_DetailVo;
import net.shanxiu.HR.vo.PartVo;
import net.shanxiu.HR.vo.ResultDepVo;
import net.shanxiu.HR.vo.ResultVo;
import net.shanxiu.HR.vo.Worker;

/**
 * SearchDao
 */

/*******************************************************************************
 * 僋儔僗偺奣梫丗姰惉崯宯?庡梫揑??岟擻
 * 
 * @author  嶌惉幰 tuwenjie
 * @version 1.0
*******************************************************************************
 */
public class SearchDao extends DbUtil {
    
    
    public SearchDao(){
    }
    
    /*******************************************************************************
     * 張棟撪梕偺奣梫:崻悩梡??擖揑ID榓枾???悢悩?丆敾抐惀斲崌朄梡?
     * 
     * @param   堷悢:梡??擖ID榓枾?
     * @return  栠傝抣:worker,懚?梡??尷榓惄柤埲媦ID 
     * @exception  ?忢丗Exception
     *******************************************************************************
     */
    public Worker search(String userId,String userPsw) throws Exception{
    	
       Worker worker = new Worker();
        
/*      this makes guard three sorts 
 *      such as manager employer and the other
        number, two is the other
 */     							
        worker.setGuard(Constants.OTHER);	
        
        
        
        DataSource dataSource;
		Connection connection = null;
		Statement stm         = null;
		ResultSet rs          = null;
        try {
			InitialContext ctx = new InitialContext();
			
			String jndiName="java:comp/env/jdbc/test";
			
			dataSource = (DataSource)ctx.lookup(jndiName);
			
			connection = dataSource.getConnection();
			
			String sql    = "SELECT * FROM emp";
			stm = connection.createStatement();
			rs  = stm.executeQuery(sql);
			
			
      //  Connection con = connectToDb();
      //  String sql     = "select * from emp as e";
        
     //   try{
            
       //   stm=con.createStatement();
       //   rs=stm.executeQuery(sql);
          
          while(rs.next()){
            if(rs.getString(2).equalsIgnoreCase(userId)&&rs.getString(15).equals(userPsw)){
                worker.setGuard(rs.getString(16));
                worker.setName(rs.getString(1));
                worker.setID(rs.getString(2));
                break;
        		}
       	   }

    	 }finally {
    	    
    	    try{
    	    
    	        if (rs != null) 
			        rs.close();
			    
			    if (stm != null)
			        stm.close();
			    
			    if (connection != null)
			        connection.close();
		    
    	    
	    	}catch(Exception e){
    	        e.printStackTrace();
    	        }
    	 }
    	
         return worker;
        
     }
    
    /*******************************************************************************
     * 張棟撪梕偺奣梫:崻悩SQL?嬪??晞崌梫媮揑?岺怣懅
     * 
     * @param   堷悢:堦??帵??悢悩?揑SQL?嬪
     * @return  栠傝抣:resultVo,懚??岺婎杮怣懅丆?岺?悢榓暘??? 
     * @exception  ?忢丗Exception
     *******************************************************************************
     */
      public ResultVo search(String strSql)throws Exception{
      
    	ResultSet rs1    = null; 
    	
    	Integer          integer;
    	int page         = 0;
    	int rest         = 0;
    	int i            = 0;
    	//sql_all is a SQL that search database
    	String sql_all   = Constants.SQL_HEAD_ALL + strSql;
    	//sql_count is a SQL that count the resultset
    	String sql_count = Constants.SQL_HEAD_COUNT + strSql;
    	
        ArrayList partVos = new ArrayList();
        ArrayList list    = new ArrayList();
        ResultVo resultVo = new ResultVo();
        PartVo partVo;     
        Connection con    = connectToDb();
        
        try{
            
          stm   = con.createStatement();
          
          rs1   = stm.executeQuery(sql_count);
          rs1.next();
          int count = rs1.getInt(1);
          
          rs    = stm.executeQuery(sql_all);
          
         
          //choose PAGENUM datas and set partVo 
          while(rs.next() && i < Constants.PAGENUM){
              
               partVo = new PartVo();
               partVo.setName(rs.getString("name"));
               partVo.setId(rs.getString("ID"));
               partVo.setSex(rs.getString("sex"));
               partVo.setDep_name(rs.getString("dep_name"));
               partVos.add(partVo);
               i++;
        	   }
          
          
          //set resultVo
         
          
          resultVo.setRecords(count);
          
          rest = count % Constants.PAGENUM;
          page = count /Constants.PAGENUM;
         
          int pages = (0 == rest) ? page : page + 1;
          resultVo.setPages(1);
          
          resultVo.setPartVos(partVos);
          
          //set page list
          for(int j = 1;j <= pages;j++) {
              if (1 == j){
                  integer = new Integer(-1);
                  list.add(integer);
              }
              else{ 
                  integer = new Integer(j);
              	  list.add(integer);
              }
          }
          resultVo.setList(list);

    	 }finally{
            
            try{
                
                silentClose(rs);
                
                silentClose(rs1);
        	    
        	    silentClose(stm);
        	    
    	        silentClose(con);
              
            }catch(Exception e){
                e.printStackTrace();
                }
         }
    	
         return resultVo;
        
     }
      /*       
    *//*******************************************************************************
     * 張棟撪梕偺奣梫:??悢悩暘??帵
     * 
     * @param   堷悢:堦??帵??悢悩?揑SQL?嬪丆強廀?帵?悢榓??悢
     * @return  栠傝抣:resultVo,懚??岺婎杮怣懅丆?岺?悢榓暘??? 
     * @exception  ?忢丗Exception
     *******************************************************************************
     */
    public ResultVo turn_search(String strSql,int pagenumber)throws Exception{
          
          Integer          integer;
      	  //sql_all is a SQL that search database
      	  String sql_all    = Constants.SQL_HEAD_ALL + strSql;
      	  String sql_count  = Constants.SQL_HEAD_COUNT + strSql;
          ArrayList partVos = new ArrayList();
          ArrayList list    = new ArrayList();
          PartVo partVo;
          ResultVo resultVo = new ResultVo();
          Connection con    = connectToDb();
          ResultSet rs1;
          
          try{
              
            stm   = con.createStatement();
            rs1   = stm.executeQuery(sql_count);
            rs1.next();
            int count = rs1.getInt(1);
            
            rs    = stm.executeQuery(sql_all);
            if(pagenumber != 1)
                
                rs.absolute((pagenumber - 1) * Constants.PAGENUM );
                
            //choose PAGENUM datas and set partVo