schooldao.java

中应用程序的访问权限对Java Web Console 中应用程序的访问权限 成功登录 Web 控制台后,可能无法自动访问在该控制台中注册的所有应用程序。通常,必须安装应用程序,才能让所有的用户在控制

package edu.yinhe.mis.model;

/**
 * @author 李亭 <p>
 * 下面给出如何调用DAO中删除方法的例子
 * <p>
 * 	<blockquote>
 * 		<pre>
 * 			SchoolDAO =DAOFactory.getSchoolDAO(conn);
 * 			SchoolDAO.delete(obj);
 * 		</pre>
 * 	</blockquote>
 * @version	jdk1.6.0_03
 * @since 从jdk1.0版本开始	
 */

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import edu.yinhe.mis.dto.SchoolDTO;
import edu.yinhe.mis.vo.SchoolVO;
import edu.yinhe.system.model.BaseDAO;


public class SchoolDAO extends BaseDAO{

	/**
	 * @author 李亭 <p>
	 * Creation date:04-30-2008
	 * 根据schoolNo删除schools表中的相应信息
	 * @param obj 传入schoolNo
	 *@throws SQLException
	 * @return delete 返回一个Integer类型起值为1则删除成功 为0则删除不成功
	 */
	public Object delete(Object obj) throws SQLException {
		Integer delete = 0;
		PreparedStatement ps = null;
		String SQL = null;
		String sno = (String) obj;
		try {
			SQL="DELETE FROM schools WHERE SCHOOL_NO='"+sno+"'";
			ps = conn.prepareStatement(SQL);
			ps.executeUpdate();
			delete = 1;
		} catch (RuntimeException e) {
			e.printStackTrace();
		}finally{
			if(ps != null)ps.close();
			SQL = null;
		}
		return delete;
	}

	public Object find() throws SQLException {
		return null;
	}

	public Object find(Object obj) throws SQLException {

		return null;
	}

	/**
	 * @author 张启悟
	 */
	public Object findAll() throws SQLException {
		PreparedStatement ps = null;
		ResultSet rs = null;
		ArrayList list = new ArrayList();
		String SQL = null;
		StringBuffer strBuf = new StringBuffer("SELECT * FROM schools WHERE 1=1 ");
		SchoolVO schoolvo = null;
		Integer integer = new Integer(0);

		try {

			SQL = strBuf.toString();
			ps = conn.prepareStatement(SQL);
			rs = ps.executeQuery();
			while(rs.next()){
				
				schoolvo = new SchoolVO();
				
				schoolvo.setId(rs.getInt("ID"));
				schoolvo.setSchoolNo(rs.getString("SCHOOL_NO"));
				schoolvo.setSchoolName(rs.getString("SCHOOL_NAME"));
				schoolvo.setSchoolmaster(rs.getString("SCHOOLMASTER"));
				schoolvo.setTel(rs.getString("TEL"));
				schoolvo.setAddress(rs.getString("ADDRESS"));
				list.add(schoolvo);
			}
		} catch (NumberFormatException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			if(ps != null)ps.close();
			if(rs != null)rs.close();
			SQL = null;
			schoolvo = null;
		}

		return list;
	}

	/**
	 * @author 李亭 <p>
	 * Creation date:04-30-2008
	 * 根据条件查询schools表中的相应信息
	 * @param obj 传入SchoolDTO对象
	 *@throws SQLException
	 * @return objs 返回一个objs数组 objs[0]为信息集合;objs[1]为集合的总记录数;			
	 */
	public Object findAll(Object obj) throws SQLException {
		
		
		PreparedStatement ps = null;
		ResultSet rs = null;
		ArrayList list = new ArrayList();
		String SQL = null;
		StringBuffer strBuf = new StringBuffer("SELECT * FROM schools WHERE 1=1 ");
		SchoolVO schoolvo = null;
		Integer integer = new Integer(0);
		Object[] objs = new Object[2];
		SchoolDTO schooldto = (SchoolDTO) obj;
		try {
			integer = getCount(schooldto);
			if(schooldto.getSchoolmaster()!=null&&!"".equals(schooldto.getSchoolmaster())){
				strBuf.append("AND SCHOOLMASTER='"+schooldto.getSchoolmaster().trim()+"'");
			}
			int i = (Integer.parseInt(schooldto.getCurrentPage())-1)*Integer.parseInt(schooldto.getRowPerPage());
			strBuf.append(" ORDER BY ID DESC LIMIT "+i+","+schooldto.getRowPerPage());
			SQL = strBuf.toString();
			ps = conn.prepareStatement(SQL);
			rs = ps.executeQuery();
			objs[0]=list;
			objs[1]=integer;
			while(rs.next()){
				schoolvo = new SchoolVO();
				schoolvo.setId(rs.getInt("ID"));
				schoolvo.setSchoolNo(rs.getString("SCHOOL_NO"));
				schoolvo.setSchoolName(rs.getString("SCHOOL_NAME"));
				schoolvo.setSchoolmaster(rs.getString("SCHOOLMASTER"));
				schoolvo.setTel(rs.getString("TEL"));
				schoolvo.setAddress(rs.getString("ADDRESS"));
				list.add(schoolvo);
			}
		} catch (NumberFormatException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			if(ps != null)ps.close();
			if(rs != null)rs.close();
			SQL = null;
			schoolvo = null;
		}

		return objs;
	}

	/**
	 * @author 李亭 <p>
	 * Creation date:05-04-2008
	 * 根据ID获得该条信息
	 * @param obj ID
	 *@throws SQLException
	 * @return SchoolVO 返回SchoolVO对象;			
	 */
	public Object findById(Object obj) throws SQLException {

		PreparedStatement ps = null;
		ResultSet rs = null;
		Integer id = (Integer) obj;
		String SQL = null;
		SchoolVO schoolvo = null;
		
		try {
			StringBuffer strBuf = new StringBuffer("SELECT * FROM schools WHERE ID="+id);
			SQL = strBuf.toString();
			ps = conn.prepareStatement(SQL);
			rs = ps.executeQuery();
			
			while(rs.next()){
				schoolvo = new SchoolVO();
				schoolvo.setId(rs.getInt("ID"));
				schoolvo.setSchoolNo(rs.getString("SCHOOL_NO"));
				schoolvo.setSchoolName(rs.getString("SCHOOL_NAME"));
				schoolvo.setSchoolmaster(rs.getString("SCHOOLMASTER"));
				schoolvo.setTel(rs.getString("TEL"));
				schoolvo.setAddress(rs.getString("ADDRESS"));
				
			}
		} catch (NumberFormatException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			if(ps != null)ps.close();
			if(rs != null)rs.close();
			SQL = null;
		}

		return schoolvo;
	}

	/**
	 * @author 李亭 <p>
	 * Creation date:04-30-2008
	 * 查询schools表中的信息提供给其他模块调用 同时本身也可以通过schoolNo来查询信息
	 * @param obj 传入SchoolDTO对象
	 *@throws SQLException
	 * @return list 当是提供给其他模块调用的时候是列表集合，调用者可以提取需要的信息使用。
	 * 当是本模块调用时，list.size()为0则表示该编号可用；不为0就表示该编号不可用		
	 */
	public Object findByObject(Object obj) throws SQLException {
		PreparedStatement ps = null;
		ResultSet rs = null;
		ArrayList list = new ArrayList();
		String SQL = null;
		StringBuffer strBuf = new StringBuffer("SELECT * FROM schools WHERE 1=1 ");
		SchoolVO schoolvo = null;
		SchoolDTO schooldto = (SchoolDTO) obj;
		try {
			if(schooldto.getSchoonNo()!=null&&!"".equals(schooldto.getSchoonNo())){
				strBuf.append("AND SCHOOL_NO='"+schooldto.getSchoonNo()+"'");
			}
			
			SQL = strBuf.toString();
			ps = conn.prepareStatement(SQL);
			rs = ps.executeQuery();
			while(rs.next()){
				schoolvo =  new SchoolVO();
				schoolvo.setId(rs.getInt("ID"));
				schoolvo.setSchoolNo(rs.getString("SCHOOL_NO"));
				schoolvo.setSchoolName(rs.getString("SCHOOL_NAME"));
				schoolvo.setSchoolmaster(rs.getString("SCHOOLMASTER"));
				schoolvo.setTel(rs.getString("TEL"));
				schoolvo.setAddress(rs.getString("ADDRESS"));
				list.add(schoolvo);
			}
		} catch (RuntimeException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally{
			if(ps != null)ps.close();
			if(rs != null)rs.close();
			SQL = null;
			schoolvo = null;
		}

		return list;
	}

	/**
	 * @author 李亭 <p>
	 * Creation date:04-30-2008
	 * 查询schools表中的信息的总条数
	 * @param obj 传入SchoolDTO对象
	 * @throws SQLException
	 * @return 	integer 总记录数
	 */
	public int getCount(Object obj) throws SQLException {
		PreparedStatement ps = null;
		ResultSet rs = null;
		Integer integer = new Integer(0);
		String SQL = null;
		StringBuffer strBuf = new StringBuffer("SELECT COUNT(*)result FROM schools WHERE 1=1 ");
		SchoolDTO schooldto = (SchoolDTO) obj;
		try {
			if(schooldto.getSchoolmaster()!=null&&!"".equals(schooldto.getSchoolmaster())){
				strBuf.append("AND SCHOOLMASTER='"+schooldto.getSchoolmaster().trim()+"'");
			}
			SQL=strBuf.toString();
			ps = conn.prepareStatement(SQL);
			rs = ps.executeQuery();
			while(rs.next()){
				integer = new Integer(rs.getInt("result"));
			}
		} catch (RuntimeException e) {
			e.printStackTrace();
		}finally{
			if(ps != null)ps.close();
			if(rs != null)rs.close();
			SQL = null;
			schooldto = null;
		}
		
		return integer;
	}

	/**
	 * @author 李亭 <p>
	 * Creation date:05-08-2008
	 * 同时本身也可以通过schoolName来查询信息
	 * @param obj 传入SchoolDTO对象
	 *@throws SQLException
	 * @return list 当是提供给其他模块调用的时候是列表集合，调用者可以提取需要的信息使用。
	 * 当是本模块调用时，list.size()为0则表示该名称可用；不为0就表示该名称不可用		
	 */
	public Object getMaxId(Object obj) throws SQLException {
		PreparedStatement ps = null;
		ResultSet rs = null;
		ArrayList list = new ArrayList();
		String SQL = null;
		
		SchoolVO schoolvo = null;
		String  schoolname=  (String) obj;
		try {
			
			StringBuffer strBuf = new StringBuffer("SELECT * FROM schools WHERE SCHOOL_NAME='"+schoolname+"'");
			SQL = strBuf.toString();
			ps = conn.prepareStatement(SQL);
			rs = ps.executeQuery();
			while(rs.next()){
				schoolvo =  new SchoolVO();
				schoolvo.setId(rs.getInt("ID"));
				schoolvo.setSchoolNo(rs.getString("SCHOOL_NO"));
				schoolvo.setSchoolName(rs.getString("SCHOOL_NAME"));
				schoolvo.setSchoolmaster(rs.getString("SCHOOLMASTER"));
				schoolvo.setTel(rs.getString("TEL"));
				schoolvo.setAddress(rs.getString("ADDRESS"));
				list.add(schoolvo);
			}
		} catch (RuntimeException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally{
			if(ps != null)ps.close();
			if(rs != null)rs.close();
			SQL = null;
			schoolvo = null;
		}

		return list;
	}

	/**
	 * @author 李亭 <p>
	 * Creation date:04-30-2008
	 * 查询schools表中的信息的总条数
	 * @param obj 传入SchoolDTO对象
	 *@throws SQLException
	 * @return 	integer 当为1表示插入数据库成功 为0就表示插入失败
	 */
	public Object insert(Object obj) throws SQLException {
		int idext = 1;
		Integer insert = 0;
		int a = 0;
		SchoolDTO schooldto = null;
		String SQL = null;
		PreparedStatement ps = null;

		try {
			schooldto = (SchoolDTO)obj;
			SQL="INSERT INTO schools(SCHOOL_NO,SCHOOL_NAME,SCHOOLMASTER,TEL,ADDRESS) VALUES(?,?,?,?,?)";
			ps = conn.prepareStatement(SQL);
			ps.setString(idext++,schooldto.getSchoonNo());
			ps.setString(idext++,schooldto.getSchoolName());
			ps.setString(idext++,schooldto.getSchoolmaster());
			ps.setString(idext++,schooldto.getTel());
			ps.setString(idext++,schooldto.getAddress());
			a = ps.executeUpdate();
			if(a!=-1){
				insert = 1;
			}
			conn.commit();
			
		} catch (RuntimeException e) {
			e.printStackTrace();
		}finally{
			if(ps!=null)ps.close();
			SQL = null;
			schooldto = null;
		}

		return insert;
	}

	/**
	 * @author 李亭 <p>
	 * Creation date:05-05-2008
	 * 根据ID修改校区信息
	 * @param obj 传入SchoolDTO对象
	 *@throws SQLException
	 * @return 	integer 当为1表示修改数据成功 为0就表示修改失败
	 */
	public Object update(Object obj) throws SQLException {
		Integer update = 0;
		int a = 0;
		PreparedStatement pstmt = null;
		ResultSet rs=null;
		SchoolDTO schooldto = null;
		String SQL = null;
		schooldto = (SchoolDTO) obj;

		try {
			SQL="UPDATE schools SET SCHOOL_NO=?,SCHOOL_NAME=?,SCHOOLMASTER=?,ADDRESS=?,TEL=? WHERE ID=?";
			pstmt = conn.prepareStatement(SQL);
			pstmt.setString(1, schooldto.getSchoonNo());
			pstmt.setString(2, schooldto.getSchoolName());
			pstmt.setString(3, schooldto.getSchoolmaster());
			pstmt.setString(4, schooldto.getAddress());
			pstmt.setString(5, schooldto.getTel());
			pstmt.setInt(6, schooldto.getId());
			a = pstmt.executeUpdate();
			conn.commit();
			if(a!=-1){
				update = 1;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			if(pstmt != null)pstmt.close();
			if(rs != null)rs.close();
			SQL = null;
			schooldto = null;
		}

		return update;
	}

}