mailaddrbooktypedao.java

来自「功能是公安和学校的管理系统,用struts+hibernate+spring等匡」· Java 代码 · 共 190 行

package com.comingnet.bean;

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

import com.db.DBUtils;
import com.db.KeyGenerator;
import com.db.ProxoolAction;

public class MailAddrBookTypeDAO {
	private Connection conn ;
	private PreparedStatement pstmt ;
	private ResultSet rs ;
	
	public ArrayList<MailAddrBookType> queryAll(int xxid,int ryid){
		String sqlStr= "SELECT * FROM txl_lb WHERE (xxid=? AND ryid=?) 	OR (xxid=0 and ryid=0) 	ORDER BY xxid "  ;
		MailAddrBookType addrBookType = null ;
		ArrayList<MailAddrBookType> listResult = new ArrayList<MailAddrBookType>() ; 
		try {
			conn = ProxoolAction.getConnection();
			pstmt = conn.prepareStatement(sqlStr);
			pstmt.setInt(1, xxid) ;
			pstmt.setInt(2, ryid) ;
			rs = pstmt.executeQuery() ;
			
			while(rs.next()){
				addrBookType = new MailAddrBookType() ;
				addrBookType.setFzlbid(rs.getInt("fzlbid")) ;
				addrBookType.setFzlbmc(rs.getString("fzlbmc")) ;
				addrBookType.setRyid(rs.getInt("ryid")) ;
				addrBookType.setXxid(rs.getInt("xxid"))  ;
				
				listResult.add(addrBookType) ;
			}
		} catch (Exception e) {
			// TODO: handle exception
			System.out.println("MailAddrBookTypeDAO.queryAll.exception------------->"+e) ;
		}finally{
			ProxoolAction.closeResultSet(rs) ;
			ProxoolAction.closeStatement(pstmt) ;
			ProxoolAction.closeConnection(conn) ;
		}
		return listResult ;
	}
	
	public ArrayList<MailAddrBookType> queryAllOther(int xxid,int ryid){//除了系统中固定的，即个人添加的
		String sqlStr= "SELECT * FROM txl_lb WHERE xxid=? AND ryid=? "  ;
		MailAddrBookType addrBookType = null ;
		ArrayList<MailAddrBookType> listResult = new ArrayList<MailAddrBookType>() ; 
		try {
			conn = ProxoolAction.getConnection();
			pstmt = conn.prepareStatement(sqlStr);
			pstmt.setInt(1, xxid) ;
			pstmt.setInt(2, ryid) ;
			rs = pstmt.executeQuery() ;
			
			while(rs.next()){
				addrBookType = new MailAddrBookType() ;
				addrBookType.setFzlbid(rs.getInt("fzlbid")) ;
				addrBookType.setFzlbmc(rs.getString("fzlbmc")) ;
				addrBookType.setRyid(rs.getInt("ryid")) ;
				addrBookType.setXxid(rs.getInt("xxid"))  ;
				
				listResult.add(addrBookType) ;
			}
		} catch (Exception e) {
			// TODO: handle exception
			System.out.println("MailAddrBookTypeDAO.queryAll.exception------------->"+e) ;
		}finally{
			ProxoolAction.closeResultSet(rs) ;
			ProxoolAction.closeStatement(pstmt) ;
			ProxoolAction.closeConnection(conn) ;
		}
		return listResult ;
	}
		
	public MailAddrBookType queryById(int fzlbid ,int xxid ,int ryid){
		String sqlStr= "SELECT * FROM txl_lb WHERE (xxid=? AND ryid=? AND fzlbid=? ) "  ;
		MailAddrBookType addrBookType = null ;
		try {
			conn = ProxoolAction.getConnection();
			pstmt = conn.prepareStatement(sqlStr);
			pstmt.setInt(1, xxid) ;
			pstmt.setInt(2, ryid) ;
			pstmt.setInt(3, fzlbid) ;
			rs = pstmt.executeQuery() ;
			
			while(rs.next()){
				addrBookType = new MailAddrBookType() ;
				addrBookType.setFzlbid(rs.getInt("fzlbid")) ;
				addrBookType.setFzlbmc(rs.getString("fzlbmc")) ;
				addrBookType.setRyid(rs.getInt("ryid")) ;
				addrBookType.setXxid(rs.getInt("xxid"))  ;
				
			}
		} catch (Exception e) {
			// TODO: handle exception
			System.out.println("MailAddrBookTypeDAO.queryById.exception------------->"+e) ;
		}finally{
			ProxoolAction.closeResultSet(rs) ;
			ProxoolAction.closeStatement(pstmt) ;
			ProxoolAction.closeConnection(conn) ;
		}	
		return addrBookType ;
	}
	
	public boolean add(MailAddrBookType addrBookType){
		boolean flag = false ;
		String sqlStr = "INSERT INTO txl_lb(fzlbmc,fzlbid,xxid,ryid)VALUES(?,?,?,?) ";
		int fzlbid ;
		
		try {
			fzlbid = KeyGenerator.getInstance().getNextKey("txl_lb") ;
			conn = ProxoolAction.getConnection() ;
			pstmt = conn.prepareStatement(sqlStr) ;
			pstmt.setString(1, addrBookType.getFzlbmc()) ;
			pstmt.setInt(2, fzlbid) ;
			pstmt.setInt(3, addrBookType.getXxid()) ;
			pstmt.setInt(4, addrBookType.getRyid()) ;
			
			pstmt.executeUpdate() ;
			flag = true ;
				} catch (Exception e) {
			System.out.println("MailAddrBookTypeDAO.add.exception------------->"+e) ;
			
		}finally{
			ProxoolAction.closeStatement(pstmt) ;
			ProxoolAction.closeConnection(conn) ;
		}
		return flag ;
	}
	
	public boolean edit(MailAddrBookType addrBookType){
			boolean flag = false ;
			String sqlStr = "UPDATE txl_lb SET fzlbmc=? WHERE fzlbid=? AND xxid=? AND ryid=?" ;
			System.out.println("1111------->"+addrBookType.getFzlbmc()) ;
			System.out.println("22222222-"+addrBookType.getFzlbid()) ;
			try {
				conn = ProxoolAction.getConnection() ;
				pstmt = conn.prepareStatement(sqlStr) ;
				pstmt.setString(1, addrBookType.getFzlbmc()) ;
				pstmt.setInt(2, addrBookType.getFzlbid()) ;
				pstmt.setInt(3, addrBookType.getXxid()) ;
				pstmt.setInt(4, addrBookType.getRyid()) ;
				
				pstmt.executeUpdate() ;
				flag = true ;
					} catch (Exception e) {
				System.out.println("MailAddrBookTypeDAO.edit.exception------------->"+e) ;
				
			}finally{
				ProxoolAction.closeStatement(pstmt) ;
				ProxoolAction.closeConnection(conn) ;
			}
			return flag ;
	}
	
	public boolean delete(int fzlbid){
		boolean flag = false ;
		String sqlStr1 = "DELETE FROM txl_lb WHERE fzlbid =? " ;
		String sqlStr2 = "DELETE FROM txl_xx WHERE lb_id = ?" ;
		try {
			conn = ProxoolAction.getConnection() ;
			conn.setAutoCommit(false) ;
			pstmt = conn.prepareStatement(sqlStr1) ;
			pstmt.setInt(1,fzlbid) ;
			pstmt.executeUpdate() ;
			
			pstmt = conn.prepareStatement(sqlStr2) ;
			pstmt.setInt(1, fzlbid) ;
			pstmt.executeUpdate() ;
			
			conn.commit() ;
			conn.setAutoCommit(true) ;
			flag = true ;
			
		} catch (Exception e) {
			System.out.println("MailAddrBookTypeDAO.delete.exception------------->"+e) ;
			return flag ;
		}finally{
			ProxoolAction.closeStatement(pstmt) ;
			ProxoolAction.closeConnection(conn) ;
		}
		return flag ;
	}
	
}