privilegedaoimpl.java

该系统可以实现邮件的收发

package com.dao.impl;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import com.dao.PrivilegeDao;
import com.domain.Node;
import com.domain.Privilege;
import com.util.JdbcUtil;

public class PrivilegeDaoImpl implements PrivilegeDao {
	
	private String DELETE_PP = "delete from positionPrivilege where priId = ?";

	public List searchPrivilegeByPositionId(int positionId) {
		
		Connection conn = JdbcUtil.getConnection();
		String info = "select n.nodeName,p.priId,p.nodeId,p.privilegeName,p.description from node n,privilege p,positionPrivilege pp " +
					  "where n.nodeid =p.nodeid and p.priId = pp.priId and pp.positionId = "+positionId;
		List<Privilege> list = new ArrayList<Privilege>();
		
		try {
			PreparedStatement ps = conn.prepareStatement(info);
			ResultSet rs = ps.executeQuery();

			while(rs.next()){
				Privilege privilege = new Privilege();
				privilege.setPriId(rs.getInt("priId"));
				privilege.setDescription(rs.getString("description"));
				privilege.setNodeId(rs.getInt("nodeId"));
				privilege.setPrivilegeName(rs.getString("privilegeName"));
				Node node = new Node();
				node.setNodeName(rs.getString("nodeName"));
				privilege.setNode(node);
				list.add(privilege);
			}
			rs.close();
			ps.close();			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		return list;
	}

	public void deletePrivilege(String positionId, String[] priId) {
		
		Connection conn = JdbcUtil.getConnection();
		PreparedStatement ps;

		try {
			ps = conn.prepareStatement(DELETE_PP);
			
			for(int i = 0; i < priId.length;i ++){
				ps.setString(1, priId[i]);
				ps.execute();
			}
			
			ps.close();
			conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	public List searchPrivilege(String privilegeName) {
		Connection conn = JdbcUtil.getConnection();
		String SELECT_PRIVILEGE = "select * from privilege where privilegeName not in ("+privilegeName+")";
		
		List<Privilege> list = new ArrayList<Privilege>();
		try {
			PreparedStatement ps = conn.prepareStatement(SELECT_PRIVILEGE);
			ResultSet rs = ps.executeQuery();

			while(rs.next()){
				Privilege privilege = new Privilege();
				privilege.setPriId(rs.getInt("priId"));
				privilege.setDescription(rs.getString("description"));
				privilege.setNodeId(rs.getInt("nodeId"));
				privilege.setPrivilegeName(rs.getString("privilegeName"));
			
				list.add(privilege);
			}
			rs.close();
			ps.close();			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		return list;
	}

	public void addPrivilege(String[] priId, String positionId) {
		
		String info = "insert into positionPrivilege (positionId,priId) values ("+positionId+",?"+")";
		Connection conn = JdbcUtil.getConnection();		
		PreparedStatement ps;
		
		try {
			ps = conn
				.prepareStatement(info);
			for(int i = 0;i < priId.length;i++){
				ps.setString(1, priId[i]);
				ps.executeQuery();
			}
			
			conn.close();
			ps.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}finally {
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
	
	public List searchNotPrivilege(String positionId){
		
		Connection conn = JdbcUtil.getConnection();		
		String info = "select privilegename from privilege where priid in (select priid from positionprivilege where positionId = '"+positionId+"')";
		List list = new ArrayList();
		PreparedStatement ps;
		
		try {
			ps = conn.prepareStatement(info);
		
		ResultSet rs = ps.executeQuery();
			while (rs.next()){
			
			Privilege privilege = new Privilege();
			privilege.setPrivilegeName(rs.getString("privilegename"));
			list.add(privilege);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		return list;
	}
}