implementdepartmentdao.java

模仿腾讯QQ的

package com.softfz.jn0708.dao.oracle;

import java.io.Serializable;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import com.softfz.jn0708.dao.DBConnection;
import com.softfz.jn0708.dao.intef.IDepartmentDAO;
import com.softfz.jn0708.srcpackage.TDepartment;

/**-----------------------------------------------------------------------------
 * 
 * 
 *                   实现类，实现了IDepartmentDAO接口的一下方法：
 *                 
 *                ======查询 、添加 、删除、 修改 等方法======
 *     
 *     
 *-----------------------------------------------------------------------------     
 */
public class ImplementDepartmentDAO implements IDepartmentDAO ,Serializable{


	
	/**
	 * 
	 */
	private static final long serialVersionUID = 321918276370495608L;
	private ResultSet rs = null;//结果集对象
	private static Connection con = null;//连接对象	
	private static Statement stmt = null;//statement对象 =发送SQL语句
	private static PreparedStatement ps = null;	
//	TDepartment detp = new TDepartment();

	/**=========================================================================
	 *                     Connection数据库连接
	 *========================================================================= 
	 */	
	public ImplementDepartmentDAO(){		
		
		try {
			
			con = DBConnection.Connect();
			stmt = con.createStatement();			
			
		} catch (SQLException e) {

			e.printStackTrace();
			System.out.println("返回statement对象时发生错误");
			
		}
		
	}	
	

	
	
	/**=========================================================================
	 *                          实现添加接口
	 *=========================================================================
	 */
	public boolean add(TDepartment dept) {
		try {
			ps = con.prepareStatement("insert into TDEPARTMENT(DNO,DNAME,DSAFFICHE)values(?,?,?)");
			ps.setString(1,dept.getDno());
			ps.setString(2,dept.getDname());
			ps.setString(3,dept.getDsaffiche());
			ps.executeUpdate();
			return true;
		}catch (SQLException e){
			e.printStackTrace();
			return false;
		}		
		
	}
	/**=========================================================================
	 *                          实现删除接口
	 *=========================================================================  
	 */
	public boolean del(String dno) {
		try {
			ps = con.prepareStatement("delete from tdepartment where dno =?");
			ps.setString(1,dno);
			ps.executeUpdate();	
			return true;
		} catch (SQLException e) {
			e.printStackTrace();
			return false;
		}
		
		
	}
	/**=========================================================================
	 *                           实现修改接口
	 *========================================================================= 
	 */
	public boolean modify(TDepartment dept) {
		try {
			ps = con.prepareStatement("update tuser set UNAME=?,DSAFFICHE=? where DNO=?");
			ps.setString(1,dept.getDname());
			ps.setString(2,dept.getDsaffiche());
			ps.setString(3,dept.getDno());
			ps.executeUpdate();
			return true;
		}catch (SQLException e){
			e.printStackTrace();
			return false;
		}
		
		
	}

	/**
	 * 获取列名
	 */
	public List getColumnNames() {
		
		List list = new ArrayList();
		list.add("部门编号");
		list.add("部门名称");
		list.add("部门公告");	
		return list;
	}

	/**
	 * 获取行数据
	 */
	public List getRowData() {		
		List list =  new ArrayList();
		list = select("","");
		return list;
	}





	/**
	 * 获取最大编号(自动编号)
	 */
	public String getMaxDNO() {
		
		PreparedStatement ps = null;
		ResultSet rs = null;
		String s = null;
		try {
			ps = con.prepareStatement("select trim(to_char(to_number(nvl(max(DNO),0))+1,'0000'))"
							+ " as MaxDNO from TDEPARTMENT");

			rs = ps.executeQuery();
			while (rs.next()) {
				s = rs.getString(1);
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}

		return s;	
	}



	/**
	 *部门 查询
	 */
	public List select(String DNO, String DNAME) {
		
		List list = null;
		PreparedStatement ps = null;
		ResultSet rs = null;
		String sql = "select * from TDepartment where 1 = 1 ";	
		if (!DNO.equals("")){
			sql = sql + " and DNO ="+ DNO;	
		}		
		if (!DNAME.equals("")){
			sql=sql+" and DNAME = "+"'"+DNAME+"'";
		}
		
			sql = sql + " order by dno";
		try {
			ps = con.prepareStatement(sql);
			rs = ps.executeQuery();
			int count = rs.getMetaData().getColumnCount();
			
			list = new ArrayList();
			while(rs.next()){
				List row = new ArrayList();
				for(int i = 1; i <= count; i++){
					row.add(rs.getString(i));						
				}
				list.add(row);				
			}
			
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		} finally{
			
			try {
				if (rs != null)
					rs.close();
				if (ps != null)
					ps.close();
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
			
		}			
		return list;			
	}
}