emaildao.java

用java编的用到

package djr.dao;

import java.sql.*;
import java.util.*;
import djr.dto.EmailDTO;

public class EmailDAO extends CommonDAO
{

	/**保存邮件信息*/
	public boolean saveEmail(EmailDTO emailDTO, Connection conn)
	{
		String preSql = "insert into emailinfo values(?,?,?,?,?,?)";
		
		PreparedStatement pstmt = null;
		try
		{
			pstmt = conn.prepareStatement(preSql);
			pstmt.setString(1, emailDTO.getMailDate());
			pstmt.setString(2, emailDTO.getFrom());
			pstmt.setString(3, emailDTO.getTitle());
			pstmt.setString(4, emailDTO.getContent());
			if (emailDTO.getAttFilePath() != null) {
				pstmt.setString(5, emailDTO.getAttFilePath());
			}
			else {
				pstmt.setString(5, "");
			}
			pstmt.setString(6, emailDTO.getUserID());
			
			int flag = pstmt.executeUpdate();
			if (flag == 1)
			{
				return true;
			}
		}
		catch (SQLException e)
		{
			e.printStackTrace();
		}
		finally
		{
			close(pstmt, null);
		}

		return false;
	}

	/**取得邮件列表*/
	public List<EmailDTO> getMailList(EmailDTO emailDTO, Connection conn)
	{

		String sql = "select emailID,edate,efrom,theme,econtent,attPath "
				+ "from emailinfo where userid='" + emailDTO.getUserID()
				+ "' order by emailID desc";

		List<EmailDTO> mailList = new ArrayList<EmailDTO>();
		ResultSet rs = null;
		try
		{
			rs = execSelect(sql, conn);
			while (rs.next())
			{
				emailDTO = new EmailDTO();
				emailDTO.setEmailID(rs.getInt("emailID") + "");
				emailDTO.setFrom(rs.getString("efrom"));
				emailDTO.setMailDate(rs.getString("edate"));
				emailDTO.setTitle(rs.getString("theme"));
				emailDTO.setContent(rs.getString("econtent"));
				emailDTO.setAttFilePath(rs.getString("attPath"));

				mailList.add(emailDTO);
			}
			return mailList;
		}
		catch (Exception e)
		{
			e.printStackTrace();
		}
		finally
		{
			close(null, rs);
		}
		return null;
	}

	/** 取得指定邮件编号的邮件信息*/
	public EmailDTO getMail(int emailID, Connection conn)
	{
		String sql = "select emailID,edate,efrom,theme,econtent,attPath "
				+ "from emailinfo where " + "emailID =" + emailID;

		EmailDTO emailDTO = null;
		ResultSet rs = null;
		try
		{
			rs = execSelect(sql, conn);
			while (rs.next())
			{
				emailDTO = new EmailDTO();
				emailDTO.setEmailID(rs.getInt("emailID") + "");
				emailDTO.setFrom(rs.getString("efrom"));
				emailDTO.setMailDate(rs.getString("edate"));
				emailDTO.setTitle(rs.getString("theme"));
				emailDTO.setContent(rs.getString("econtent"));
				emailDTO.setAttFilePath(rs.getString("attPath"));
			}

		}
		catch (Exception e)
		{
			e.printStackTrace();
		}
		finally
		{
			close(null, rs);
		}
		return emailDTO;
	}

	/**彻底删除指定编号的邮件*/
	public boolean killEmail(int emailID, Connection conn)
	{
		String sql = "delete emailinfo where emailID=" + emailID;

		int flag = execUpdate(sql, conn);
		if (flag == 1)
		{
			return true;
		}

		return false;
	}
}