start_end_time_001dataaccess.java

jsp考勤

/*
 *	Copyright (C) 2000, TOA-System Co.  All rights reserved.
 */
package dbcommon;

import java.util.*;
import java.sql.*;
import entity.*;
import util.*;
import exce.*;

/**
 *	偙偺僋儔僗偼丄幮堳忣曬傊傾僋僙僗偡傞偨傔偺僋儔僗偱偡丅<br>
 *	@version 2.00
 *	@author  TOA
 *	
 *	峏怴棜楌
 *	<ul>
 *		<li>僐儊儞僩傪捛壛
 *	</ul>
 */
public class Start_End_Time_001DataAccess extends DataAccess{
	ChangeField cf = new ChangeField();
	Status st = new Status();
	public Start_End_Time_001DataAccess() {}


public void lockStart_End_Time_001(Connection con, String whe) {
		ResultSet rs = null;
		try {
			// 偙偺儊僜僢僪偱幚峴偡傞SQL暥偱偡丅
			String sql = "SELECT * FROM START_END_TIME_001 " + whe + " FOR UPDATE NOWAIT";

			pstmt = this.sqlSet(con,sql);
			rs = this.exeQuery(pstmt);
			int size = 0;
			while (rs.next()) {
				size = size + 1;
			}
			if ( size == 0 ) {
				throw new MissingFindException("弌嬑戅嬑帪揰忣曬");			//Oracle梡偱張棟
			}

		} catch (MissingFindException misse) {
			
			throw new MissingFindException("弌嬑戅嬑帪揰忣曬");
		} catch (Exception e) {
			
			throw new OriginalException(e);
		} finally {
			// Statemet偼丆昁偢close()偟傑偡丅
			try {
				if (rs != null) rs.close();
				if (pstmt != null) pstmt.close();
			} catch (Exception ex) { }
		}
	}


	/**
	 *	幮堳忣曬偺捛壛(Insert)
	 *	@param	con		DB僪儔僀僶偺URL側偳
	 *			jme		User_Jouhou_002Entity僆僽僕僃僋僩 
	 */
	public void createStart_End_Time_001(Connection con, Start_End_Time_001Entity ee) {
		ResultSet rs = null;
		
		try {
			// 偙偺儊僜僢僪偱幚峴偡傞SQL暥偱偡
			String sql = "INSERT INTO START_END_TIME_001 (" 	+
				                "START_TIME,"+
				                "END_TIME,"+
								"UPDATE_USER,"+
								"UPDATE_TIME,"+
				                "OLUPDATE_USER,"+
								"OLUPDATE_TIME"+") values (" +
								
								"?,"					+		
								"?,"					+		
								"?,"					+		
								"SYSDATE,"				+		
								"?,"					+		
								"SYSDATE)";						

			pstmt = this.sqlSet(con,sql);

			pstmt.setInt(1,ee._start_time);					
			pstmt.setInt(2,ee._end_time);
			pstmt.setString(3,ee._update_user);
			pstmt.setString(4,ee._olupdate_user);
			
			int i = this.exeUpdate(pstmt);

		} catch (MissingFindException misse) {
			
			throw new MissingFindException("弌嬑戅嬑帪揰忣曬");
		} catch (OracleException orae) {
			st = orae.getStatus();
			throw new OracleException(st);
		} catch (SQLException sqle) {
			
			throw new OracleException(sqle);
		} catch (Exception e) {
			
			throw new OriginalException(e);
		} finally {
			// Statemet偼丆昁偢close()偟傑偡丅
			try {
				if (rs != null) rs.close();
				if (pstmt != null) pstmt.close();
			} catch (Exception ex) { }
		}
	}


	public Start_End_Time_001Entity[] findStart_End_Time_001(Connection con,String whe) {
		ResultSet rs 			= null;
		try {
			// 偙偺儊僜僢僪偱幚峴偡傞SQL暥偱偡丅
			String sql = "SELECT DISTINCT START_TIME,END_TIME,UPDATE_USER,UPDATE_TIME,OLUPDATE_USER,OLUPDATE_TIME FROM START_END_TIME_001 ";
			if(whe!=null&&!(whe.equals(""))){
				sql+=whe;
			}

			pstmt = this.sqlSet(con,sql);
			rs = this.exeQuery(pstmt);
			

			Vector v = new Vector();
			
			while (rs.next()) {
				// Entity僆僽僕僃僋僩傪侾偮偮偔傝丆偙傟偵抣傪奿擺偟傑偡丅
				Start_End_Time_001Entity ee 	= new Start_End_Time_001Entity();
				ee._start_time                  =rs.getInt("START_TIME");          //弌嬑帪揰              
				ee._end_time                    =rs.getInt("END_TIME");            //戅嬑帪揰		
				ee._update_user			        =rs.getString("UPDATE_USER");         //峏怴幰
				ee._update_time                 =rs.getDate("UPDATE_TIME");           //峏怴擔帪
				ee._olupdate_user               =rs.getString("OLUPDATE_USER");       //僆儞儔僀儞嵟廔峏怴幰               
				ee._olupdate_time               =rs.getDate("OLUPDATE_TIME");         //僆儞儔僀儞嵟廔峏怴擔帪  		
				
				v.addElement(ee);
			}
			// Vector 偐傜 Entity僆僽僕僃僋僩偺攝楍傊堏偟懼偊傑偡丅
			int size = v.size();
			Start_End_Time_001Entity[] ees = new Start_End_Time_001Entity[size];
			ees = (Start_End_Time_001Entity[])v.toArray(ees);
		
			return ees;			
			
		} catch (MissingFindException misse) {
			
			throw new MissingFindException("弌嬑戅嬑帪揰忣曬");
		} catch (OracleException orae) {
			st = orae.getStatus();
			throw new OracleException(st);
		} catch (SQLException sqle) {
			
			throw new OracleException(sqle);
		} catch (Exception e) {
			
			throw new OriginalException(e);
		} finally {
			// Statemet偼丆昁偢close()偟傑偡丅
			try {
				if (rs != null) rs.close();
				if (pstmt != null) pstmt.close();
			} catch (Exception ex) { }
		}
	
	}

	public void updateStart_End_Time_001(Connection con, Start_End_Time_001Entity ee) {
		ResultSet rs 			= null;
		
		try {
			// 懠偺抂枛偱儘僢僋傪偟偰偄側偄偐偳偆偐傪妋偐傔傑偡丅
			// 僔儞僌儖僐乕僩偑擖傞偙偲偼偁傝摼側偄乮愝掕僥乕僽儖)
		String whe = "";
			this.lockStart_End_Time_001(con, whe);

			// 偙偺儊僜僢僪偱幚峴偡傞SQL暥偱偡丅
			String sql = "UPDATE START_END_TIME_001 SET "  				+   //幮堳僐乕僪
					 					                                    
					" START_TIME 	= ?, " 						        +	//幮堳柤						
					" END_TIME 	 		= ?,"						    +	//晹栧僐乕僪

					" UPDATE_USER=?, "                                  +   //峏怴幰
					" UPDATE_TIME=SYSDATE, "                            +   //峏怴擔帪
					" OLUPDATE_USER=?, "                                +   //僆儞儔僀儞嵟廔峏怴幰
					" OLUPDATE_TIME=SYSDATE ";	                        //僆儞儔僀儞嵟廔峏怴擔帪

			pstmt = this.sqlSet(con,sql);

			
			pstmt.setInt(1,ee._start_time);					
			pstmt.setInt(2,ee._end_time);			
			pstmt.setString(3,ee._update_user);
			pstmt.setString(4,ee._olupdate_user);

			int i = this.exeUpdate(pstmt);

		} catch (MissingFindException misse) {
			
			throw new MissingFindException("弌嬑戅嬑帪揰忣曬");
		} catch (OracleException orae) {
			st = orae.getStatus();
			throw new OracleException(st);
		} catch (SQLException sqle) {
			
			throw new OracleException(sqle);
		} catch (Exception e) {
			
			throw new OriginalException(e);
		} finally {
			// Statemet偼丆昁偢close()偟傑偡丅
			try {
				if (rs != null) rs.close();
				if (pstmt != null) pstmt.close();
			} catch (Exception ex) { }
		}
	}


	public void deleteStart_End_Time_001(Connection con, String whe) {
		ResultSet rs = null;
		try {
			// 懠偺抂枛偱儘僢僋傪偟偰偄側偄偐偳偆偐傪妋偐傔傑偡丅
			this.lockStart_End_Time_001(con, whe);

			// 偙偺儊僜僢僪偱幚峴偡傞SQL暥偱偡丅
			String sql =    "DELETE START_END_TIME_001 " + whe;

			pstmt = this.sqlSet(con,sql);

			int i = this.exeUpdate(pstmt);

		} catch (MissingFindException misse) {
			
			throw new MissingFindException("弌嬑戅嬑帪揰忣曬");
		} catch (Exception e) {
			
			throw new OriginalException(e);
		} finally {
			// Statemet偼丆昁偢close()偟傑偡丅
			try {
				if (rs != null) rs.close();
				if (pstmt != null) pstmt.close();
			} catch (Exception ex) { }
		}
	}


}