orclclerktaskdao.java

这是一个基于大唐电信的一个任务管理模块程序

package com.datang.struts.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;

import com.datang.struts.common.DbCommon;
import com.datang.struts.daoface.ClerkTaskDao;
import com.datang.struts.dto.TangTask;
import com.datang.struts.util.DbUtil;

public class OrclClerkTaskDao implements ClerkTaskDao{

	public ArrayList selectClerkTask(TangTask task) {
		ArrayList<TangTask> al = new ArrayList<TangTask>();
		Connection conn = DbUtil.getConnection();
		String sql = "SELECT * FROM tang_task WHERE clerk_id=?";
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		try {
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, task.getClerk_id());
			rs = pstmt.executeQuery();
			while(rs.next()){
				TangTask task1 = new TangTask();
				task1.setTask_id(rs.getInt(1));
				task1.setTask_name(rs.getString(2));
				task1.setTask_description(rs.getString(3));
				task1.setTask_start(rs.getDate(4));
				task1.setTask_end(rs.getDate(5));
				task1.setTask_exp_start(rs.getDate(6));
				task1.setTask_exp_end(rs.getDate(7));
				task1.setManager_id(rs.getString(8));
				task1.setClerk_id(rs.getString(9));
				task1.setTask_state(rs.getString(10));
				al.add(task1);				
			}
			return al;
		} catch (SQLException e) {
			if(DbCommon.DEBUG)
				e.printStackTrace();
			return null;
		}finally{
			try {
				rs.close();
			} catch (SQLException e) {
				if(DbCommon.DEBUG)
					e.printStackTrace();
			}
			try {
				pstmt.close();
			} catch (SQLException e) {
				if(DbCommon.DEBUG)
					e.printStackTrace();
			}
			try {
				conn.close();
			} catch (SQLException e) {
				if(DbCommon.DEBUG)
					e.printStackTrace();
			}
		}
	}

	public String selectManager_name(String employee_id) {
		Connection conn = DbUtil.getConnection();
		String sql = "SELECT t2.employee_name "
					+"FROM tang_employee t1 INNER JOIN tang_employee t2 ON(t1.manager_id=t2.employee_id)"
					+" WHERE t1.employee_id=?";
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		try {
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, employee_id);
			rs = pstmt.executeQuery();
			if(rs.next()){
				String manager_name = rs.getString(1);
				return manager_name;
			}else{
				return null;
			}
		} catch (SQLException e) {
			if(DbCommon.DEBUG)
				e.printStackTrace();
			return null;
		}finally{
			try {
				rs.close();
			} catch (SQLException e) {
				if(DbCommon.DEBUG)
					e.printStackTrace();
			}
			try {
				pstmt.close();
			} catch (SQLException e) {
				if(DbCommon.DEBUG)
					e.printStackTrace();
			}
			try {
				conn.close();
			} catch (SQLException e) {
				if(DbCommon.DEBUG)
					e.printStackTrace();
			}
		}
		
	}

}