leavedao.java

在J2ME中实现虚拟代理

package com.qiny.dao;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import javax.naming.NamingException;
import javax.sql.DataSource;

import com.qiny.leave.LeaveApply;
import com.qiny.leave.LeaveApprove;

public class LeaveDAO {

	protected static DataSource ds = null;
	protected static LeaveDAO ld = new LeaveDAO();

	public LeaveDAO() {
		if (ds == null) {
			try {
				javax.naming.Context initCtx = new javax.naming.InitialContext();
				javax.naming.Context ctx = (javax.naming.Context) initCtx
						.lookup("java:comp/env");
				ds = (javax.sql.DataSource) ctx
						.lookup("java:JSQLConnectDB_LeaveApply");
			} catch (NamingException e) {
				System.out.println("初始化错误:" + e.getMessage());
			}
		}

	}

	public LeaveDAO(String s) {
	}

	public void addLeaveApply(LeaveApply leaveApply) {
		try {
			String date = ld.getDate();
			String exeSql = ""
					+ " INSERT INTO bus_leaveApply (applicant,reason,applyTime,dayCount,wfid)"
					+ " VALUES ('" + leaveApply.getApplicant() + "','"
					+ leaveApply.getReason() + "','" + date + "','"
					+ leaveApply.getDayCount() + "'," + leaveApply.getWfid()
					+ ")";
			Connection connection = ds.getConnection();
			Statement statement = connection.createStatement();
			statement.execute(exeSql);
			statement.close();
			connection.close();
		} catch (SQLException ex) {
			throw new RuntimeException("DAO addLeaveApply failed!\n"
					+ ex.getMessage());
		}
	}

	public void addLeaveApprove(LeaveApprove leaveApproval) {
		try {
			String date = ld.getDate();
			String exeSql = ""
					+ " INSERT INTO bus_leaveApprove (applyID,approver,approveTime,opinion)"
					+ " VALUES ('" + leaveApproval.getApplyID() + "','"
					+ leaveApproval.getApprover() + "','" + date + "',"
					+ leaveApproval.getOpinion() + ")";
			Connection connection = ds.getConnection();
			Statement statement = connection.createStatement();
			statement.execute(exeSql);
			statement.close();
			connection.close();
		} catch (SQLException ex) {
			throw new RuntimeException("DAO addLeaveApprove failed!\n"
					+ ex.getMessage());
		}
	}

	public LeaveApply getLeaveApply(long wfid) {
		LeaveApply leaveApply = new LeaveApply();
		try {
			String querySql = ""
					+ " SELECT applyID,applicant,reason,applyTime,dayCount,wfid "
					+ " FROM bus_leaveApply WHERE wfid=" + wfid;
			Connection connection = ds.getConnection();
			Statement statement = connection.createStatement();
			ResultSet rs = statement.executeQuery(querySql);
			if (rs.next()) {
				leaveApply.setApplyID(rs.getInt("applyID"));
				leaveApply.setApplicant(rs.getString("applicant"));
				leaveApply.setReason(rs.getString("reason"));
				leaveApply.setApplyTime(rs.getString("applyTime"));
				leaveApply.setDayCount(rs.getInt("dayCount"));
				leaveApply.setWfid(rs.getLong("wfid"));
			}
			rs.close();
			statement.close();
			connection.close();
		} catch (SQLException ex) {
			throw new RuntimeException("DAO getLeaveApply failed!\n"
					+ ex.getMessage());
		}
		return leaveApply;
	}

	public List getLeaveAprovals(int applyID) {
		List approvals = new ArrayList();
		try {
			String querySql = ""
					+ " SELECT applyID,approver,approveTime,opinion "
					+ " FROM bus_leaveApprove WHERE applyID=" + applyID;
			Connection connection = ds.getConnection();
			Statement statement = connection.createStatement();
			ResultSet rs = statement.executeQuery(querySql);
			while (rs.next()) {
				LeaveApprove leaveApproval = new LeaveApprove();
				leaveApproval.setApplyID(rs.getInt("applyID"));
				leaveApproval.setApprover(rs.getString("approver"));
				leaveApproval.setApproveTime(rs.getString("approveTime"));
				leaveApproval.setOpinion(rs.getInt("opinion"));
				approvals.add(leaveApproval);
			}
			rs.close();
			statement.close();
			connection.close();
		} catch (SQLException ex) {
			throw new RuntimeException("DAO getLeaveAprovals failed!\n"
					+ ex.getMessage());
		}
		return approvals;
	}

	public String getDate() {
		Date date = new Date();
		DateFormat format = SimpleDateFormat.getDateInstance();
		return format.format(date);
	}

	public static void main(String[] args) {
		LeaveDAO ld = new LeaveDAO();
	}
}