inboxdao.java

一个jsp的oa系统,里面有很多亮点学习!

package com.oa.lp.dao;

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

import com.oa.lp.model.InBox;
import com.oa.lp.model.InBoxAnnex;
import com.oa.lp.model.OutBox;
import com.oa.lp.util.DTOPopulator;
import com.oa.lp.util.PageList;
import com.oa.lp.util.Pages;

public class InboxDAO {
	private Connection conn;
	public Connection getConn() {
		return conn;
	}

	public void setConn(Connection conn) {
		this.conn = conn;
	}
	//添加收邮件,和附件
	public void addInbox(InBox inbox,List annexList) throws SQLException{
		int inboxId=0;
		//添加收邮件
		String sql = "insert into INBOX(EMP_ID,SEND_PERSON_ID,SEND_PERSON_NAME,ACCEPT_PERSON_ID,ACCEPT_PERSON_NAME,TITLE,CONTENT,SEND_TIME)" +
				"values(?,?,?,?,?,?,?,getDate()) select SCOPE_IDENTITY()"; 
		PreparedStatement pstmt = conn.prepareStatement(sql);
		pstmt.setInt(1,inbox.getEmpId());
		pstmt.setString(2,inbox.getSendPersonId());
		pstmt.setString(3,inbox.getSendPersonName());
		pstmt.setString(4,inbox.getAcceptPersonId());
		pstmt.setString(5,inbox.getAcceptPersonName());
		pstmt.setString(6,inbox.getTitle());
		pstmt.setString(7,inbox.getContent());
		ResultSet rs = pstmt.executeQuery();
		if(rs.next()){
			inboxId = rs.getInt(1);
		}
		rs.close();
		pstmt.close();
		//添加附件
		if(annexList!=null){
			sql = "insert into INBOX_ANNEX(INBOX_ID,NAME,PATH)values(?,?,?)";
			pstmt = conn.prepareStatement(sql);
			for(int i=0;i<annexList.size();i++){
				InBoxAnnex annex=(InBoxAnnex)annexList.get(i);
				pstmt.setInt(1,inboxId);
				pstmt.setString(2,annex.getName());
				pstmt.setString(3,annex.getPath());
				pstmt.executeUpdate();
			}
		}
		rs.close();
		pstmt.close();
	}
	/*
	 * 删除
	 */
	public void delInBox(int inId) throws SQLException{
		//先删除附件 
		String sql = "delete from INBOX_ANNEX where INBOX_ID=?";
		PreparedStatement pstmt = conn.prepareStatement(sql);
		pstmt.setInt(1,inId);
		pstmt.executeUpdate();
		pstmt.close();
		//再删除收件
		sql = "delete from INBOX where INBOX_ID=?";
		pstmt = conn.prepareStatement(sql);
		pstmt.setInt(1,inId);
		pstmt.executeUpdate();
		pstmt.close();
	}
	/*
	 * 通过empId 返回 收件列表
	 */
	public PageList listAllInBox(Pages page,int empId) throws Exception{
		PageList pageList = null;
		//总录数
		page.setAllRecord(countDraft());
		page.doPage();
		StringBuffer sql = new StringBuffer();
		sql.append("select * from (");
		sql.append("select top "+page.getPageSize()+" * from (");
		sql.append("select top "+(page.getPageSize()*page.getCPage())+" * from ");
		sql.append("INBOX order by INBOX_ID desc) t1 order by INBOX_ID asc) t2 order by INBOX_ID desc");
		sql.append("where EMP_ID=?");
		PreparedStatement pstmt = conn.prepareStatement(sql.toString());
		pstmt.setInt(1,empId);
		ResultSet rs = pstmt.executeQuery();
		//将结果集中的每一行记录封装成一个对象,再放进集合返回
		List list = DTOPopulator.populate(rs, InBox.class);
		
		pageList.setPage(page);
		pageList.setObjectList(list);
		pstmt.close();
		
		return pageList;
	}
	/*
	 * 通过inId返回收件
	 */
	public InBox getById(int inId) throws Exception{
		InBox inbox =null;
		String sql = "select * from INBOX where INBOX_ID=?";
		PreparedStatement pstmt = conn.prepareStatement(sql);
		pstmt.setInt(1,inId);
		ResultSet rs = pstmt.executeQuery();
		//将结果集中的每一行记录封装成一个对象,再放进集合返回
		List list = DTOPopulator.populate(rs, InBox.class);
		//取集合中的第一个元素返回
		if(list.size()>0){
			inbox=(InBox)list.get(0);
		}
		rs.close();
		pstmt.close();
		return inbox;
	}
	/*
	 * 通过inId返回收件箱附件列表
	 */
	public List getAnnexById(int inId) throws Exception{
		List list = null;
		String sql = "select * from INBOX_ANNEX where INBOX_ID=?";
		PreparedStatement pstmt = conn.prepareStatement(sql);
		pstmt.setInt(1,inId);
		ResultSet rs = pstmt.executeQuery();
		list=DTOPopulator.populate(rs, InBoxAnnex.class);
		rs.close();
		pstmt.close();
		return list;
	}
	
	/**
	 * 收件总记录数
	 * @return
	 * @throws SQLException
	 */
	public int countDraft() throws SQLException{
		int count = 0;
		String sql = "select count(*) from INBOX";
		PreparedStatement pstmt = conn.prepareStatement(sql);
		ResultSet rs = pstmt.executeQuery(); 
		if(rs.next()){
			count = rs.getInt(1);
		}
		pstmt.close();
		return count;
	}
	/*
	 * 通过empId 返回收件列表,不分页
	 */
	public List listAllInBox(int empId) throws Exception{
		List list=null;
		String sql="select *from INBOX where EMP_ID=?";
		PreparedStatement pstmt = conn.prepareStatement(sql);
		pstmt.setInt(1,empId);
		ResultSet rs = pstmt.executeQuery();
		//将结果集中的每一行记录封装成一个对象,再放进集合返回
		list=DTOPopulator.populate(rs, InBox.class);
		rs.close();
		pstmt.close();
		return list;
	}
	

}