📄 classesdao.java
字号:
package edu.yinhe.mis.model;
/**
* @author 李亭 <p>
* 下面给出如何调用DAO中删除方法的例子
* <p>
* <blockquote>
* <pre>
* ClassesDAO =DAOFactory.getClassesDAO(conn);
* ClassesDAO.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.ClassesDTO;
import edu.yinhe.mis.vo.ClassesVO;
import edu.yinhe.system.model.BaseDAO;
public class ClassesDAO extends BaseDAO {
/**
* @author 李亭 <p>
* Creation date:05-04-2008
* 提供给其他模块调用,当删除校区的同时将班级的状态改成不可用
* @param obj 传入SchoolDTO对象
*@throws SQLException
* @return integer 当为1表示修改数据成功 为0就表示修改失败
*/
public Object delete(Object obj) throws SQLException {
Integer delete =0;
int a = 0;
PreparedStatement ps = null;
ResultSet rs=null;
ClassesDTO classdto = null;
String SQL = null;
String classNo = (String) obj;
try {
SQL="UPDATE classes SET CLASS_STATE='2' WHERE CLASS_NO='"+classNo+"'";
ps = conn.prepareStatement(SQL);
ps.executeUpdate();
delete = 1;
} catch (SQLException e) {
e.printStackTrace();
}finally{
if(ps != null)ps.close();
if(rs != null)rs.close();
SQL = null;
classdto = null;
}
return delete;
}
public Object find() throws SQLException {
return null;
}
/**
* @author 李亭 <p>
* Creation date:05-04-2008
* 提供给其他模块调用,其可以根据需求提取必要的信息
* @param obj 传入SchoolDTO对象
*@throws SQLException
* @return list 返回ArrayList集合;
*/
public Object find(Object obj) throws SQLException {
PreparedStatement ps = null;
ResultSet rs = null;
ArrayList list = new ArrayList();
String SQL = null;
StringBuffer strBuf = new StringBuffer("SELECT * FROM classes WHERE 1=1 ");
ClassesVO classvo = null;
ClassesDTO classdto = (ClassesDTO) obj;
try {
if(classdto.getClassState()!=null&&!"".equals(classdto.getClassState())){
strBuf.append(" AND CLASS_STATE ='"+classdto.getClassState()+"'");
}
if(classdto.getClassType()!=null&&!"".equals(classdto.getClassType())){
strBuf.append(" AND CLASS_TYPE ='"+classdto.getClassType()+"'");
}
if(classdto.getSchoolNo()!=null&&!"".equals(classdto.getSchoolNo())){
strBuf.append(" AND SCHOOL_NO='"+classdto.getSchoolNo()+"'");
}
if(classdto.getClassNo()!=null&&!"".equals(classdto.getClassNo())){
strBuf.append(" AND CLASS_NO='"+classdto.getClassNo()+"'");
}
SQL=strBuf.toString();
ps = conn.prepareStatement(SQL);
rs = ps.executeQuery();
while(rs.next()){
classvo = new ClassesVO();
classvo.setId(rs.getInt("ID"));
classvo.setClassNo(rs.getString("CLASS_NO"));
classvo.setSchoolNo(rs.getString("SCHOOL_NO"));
classvo.setClassroomNo(rs.getString("CLASSROOM_NO"));
classvo.setClassType(rs.getString("CLASS_TYPE"));
classvo.setStuNum(rs.getString("STU_NUM"));
classvo.setTeacherNo(rs.getString("TEACHER_NO"));
classvo.setOpenDate(rs.getString("OPEN_DATE"));
classvo.setEndDate(rs.getString("END_DATE"));
classvo.setCouresNo(rs.getString("COURSE_NO"));
classvo.setClassName(rs.getString("CLASS_NAME"));
classvo.setClassState(rs.getString("CLASS_STATE"));
list.add(classvo);
}
} catch (NumberFormatException e) {
e.printStackTrace();
}finally{
if(ps != null)ps.close();
if(rs != null)rs.close();
SQL = null;
classvo = null;
}
return list;
}
public Object findAll() throws SQLException {
return null;
}
/**
* @author 李亭 <p>
* Creation date:05-04-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 classes WHERE 1=1 ");
ClassesVO classvo = null;
Integer integer = new Integer(0);
Object[] objs = new Object[2];
ClassesDTO classdto = (ClassesDTO) obj;
try {
integer = getCount(classdto);
if(classdto.getClassState()!=null&&!"".equals(classdto.getClassState())){
strBuf.append(" AND CLASS_STATE ='"+classdto.getClassState()+"'");
}
if(classdto.getClassType()!=null&&!"".equals(classdto.getClassType())){
strBuf.append(" AND CLASS_TYPE ='"+classdto.getClassType()+"'");
}
if(classdto.getSchoolNo()!=null&&!"".equals(classdto.getSchoolNo())){
strBuf.append(" AND SCHOOL_NO='"+classdto.getSchoolNo()+"'");
}
int i = (Integer.parseInt(classdto.getCurrentPage())-1)*Integer.parseInt(classdto.getRowPerPage());
strBuf.append(" ORDER BY ID DESC LIMIT "+i+","+classdto.getRowPerPage());
SQL = strBuf.toString();
ps = conn.prepareStatement(SQL);
rs = ps.executeQuery();
objs[0]=list;
objs[1]=integer;
while(rs.next()){
classvo = new ClassesVO();
classvo.setId(rs.getInt("ID"));
classvo.setClassNo(rs.getString("CLASS_NO"));
classvo.setSchoolNo(rs.getString("SCHOOL_NO"));
classvo.setClassroomNo(rs.getString("CLASSROOM_NO"));
classvo.setClassType(rs.getString("CLASS_TYPE"));
classvo.setStuNum(rs.getString("STU_NUM"));
classvo.setTeacherNo(rs.getString("TEACHER_NO"));
classvo.setOpenDate(rs.getString("OPEN_DATE"));
classvo.setEndDate(rs.getString("END_DATE"));
classvo.setCouresNo(rs.getString("COURSE_NO"));
classvo.setClassName(rs.getString("CLASS_NAME"));
classvo.setClassState(rs.getString("CLASS_STATE"));
list.add(classvo);
}
} catch (NumberFormatException e) {
e.printStackTrace();
}finally{
if(ps != null)ps.close();
if(rs != null)rs.close();
SQL = null;
classvo = null;
}
return objs;
}
/**
* @author 李亭 <p>
* Creation date:05-04-2008
* 根据ID获得该条信息
* @param obj ID
*@throws SQLException
* @return ClassesVO 返回ClassesVO对象;
*/
public Object findById(Object obj) throws SQLException {
PreparedStatement ps = null;
ResultSet rs = null;
String SQL = null;
Integer id = (Integer) obj;
ClassesVO classvo = null;
try {
StringBuffer strBuf = new StringBuffer("SELECT * FROM classes WHERE ID="+id);
SQL = strBuf.toString();
ps = conn.prepareStatement(SQL);
rs = ps.executeQuery();
while(rs.next()){
classvo = new ClassesVO();
classvo.setId(rs.getInt("ID"));
classvo.setClassNo(rs.getString("CLASS_NO"));
classvo.setSchoolNo(rs.getString("SCHOOL_NO"));
classvo.setClassroomNo(rs.getString("CLASSROOM_NO"));
classvo.setClassType(rs.getString("CLASS_TYPE"));
classvo.setStuNum(rs.getString("STU_NUM"));
classvo.setTeacherNo(rs.getString("TEACHER_NO"));
classvo.setOpenDate(rs.getString("OPEN_DATE"));
classvo.setEndDate(rs.getString("END_DATE"));
classvo.setCouresNo(rs.getString("COURSE_NO"));
classvo.setClassName(rs.getString("CLASS_NAME"));
classvo.setClassState(rs.getString("CLASS_STATE"));
}
} catch (NumberFormatException e) {
e.printStackTrace();
}finally{
if(ps != null)ps.close();
if(rs != null)rs.close();
SQL = null;
}
return classvo;
}
/**
* @author 李亭 <p>
* Creation date:05-04-2008
* 根据班级名称查询班级信息
* @param obj 传入SchoolDTO对象
*@throws SQLException
* @return list 返回ArrayList集合list.size为0表示该班级名称可用 不为0表示不可用;
*/
public Object findByObject(Object obj) throws SQLException {
PreparedStatement ps = null;
ResultSet rs = null;
ArrayList list = new ArrayList();
String SQL = null;
String cname = (String) obj;
ClassesVO classvo = null;
try {
StringBuffer strBuf = new StringBuffer("SELECT * FROM classes WHERE CLASS_NAME='"+cname+"'");
SQL=strBuf.toString();
ps = conn.prepareStatement(SQL);
rs = ps.executeQuery();
while(rs.next()){
classvo = new ClassesVO();
classvo.setId(rs.getInt("ID"));
classvo.setClassNo(rs.getString("CLASS_NO"));
classvo.setSchoolNo(rs.getString("SCHOOL_NO"));
classvo.setClassroomNo(rs.getString("CLASSROOM_NO"));
classvo.setClassType(rs.getString("CLASS_TYPE"));
classvo.setStuNum(rs.getString("STU_NUM"));
classvo.setTeacherNo(rs.getString("TEACHER_NO"));
classvo.setOpenDate(rs.getString("OPEN_DATE"));
classvo.setEndDate(rs.getString("END_DATE"));
classvo.setCouresNo(rs.getString("COURSE_NO"));
classvo.setClassName(rs.getString("CLASS_NAME"));
classvo.setClassState(rs.getString("CLASS_STATE"));
list.add(classvo);
}
} catch (NumberFormatException e) {
e.printStackTrace();
}finally{
if(ps != null)ps.close();
if(rs != null)rs.close();
SQL = null;
classvo = null;
}
return list;
}
/**
* @author 李亭 <p>
* Creation date:05-04-2008
* 查询classes表中的信息的总条数
* @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 classes WHERE 1=1 ");
ClassesDTO classdto = (ClassesDTO) obj;
try {
if(classdto.getClassState()!=null&&!"".equals(classdto.getClassState())){
strBuf.append(" AND CLASS_STATE ='"+classdto.getClassState()+"'");
}
if(classdto.getClassType()!=null&&!"".equals(classdto.getClassType())){
strBuf.append(" AND CLASS_TYPE ='"+classdto.getClassType()+"'");
}
if(classdto.getSchoolNo()!=null&&!"".equals(classdto.getSchoolNo())){
strBuf.append(" AND SCHOOL_NO='"+classdto.getSchoolNo()+"'");
}
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;
classdto = null;
}
return integer;
}
/**
* @author 李亭 <p>
* Creation date:05-04-2008
* 当排课模块设置上课教室的时候调用此方法修改CLASSROOM_NO
* @param obj 传入SchoolDTO对象
*@throws SQLException
* @return integer 当为1表示修改数据成功 为0就表示修改失败
*/
public Object getMaxId(Object obj) throws SQLException {
Integer delete =0;
int a = 0;
PreparedStatement ps = null;
ResultSet rs=null;
ClassesDTO classdto = null;
String SQL = null;
String cno = (String) obj;
classdto = (ClassesDTO) obj;
try {
SQL="UPDATE classes SET CLASSROOM_NO=? WHERE CLASS_NO=?";
ps = conn.prepareStatement(SQL);
ps.setString(1, classdto.getClassroomNo());
ps.setString(2, cno);
a=ps.executeUpdate();
if(a!=-1){
delete = 1;
}
} catch (SQLException e) {
e.printStackTrace();
}finally{
if(ps != null)ps.close();
if(rs != null)rs.close();
SQL = null;
classdto = null;
}
return delete;
}
/**
* @author 李亭 <p>
* Creation date:05-04-2008
* 查询schools表中的信息的总条数
* @param obj 传入ClassesDTO对象
*@throws SQLException
* @return integer 当为1表示插入数据库成功 为0就表示插入失败
*/
public Object insert(Object obj) throws SQLException {
int idext = 1;
Integer insert = 0;
int a = 0;
ClassesDTO classdto = null;
String SQL = null;
PreparedStatement ps = null;
try {
classdto = (ClassesDTO)obj;
SQL="INSERT INTO classes(CLASS_NO,SCHOOL_NO,CLASSROOM_NO,CLASS_TYPE,STU_NUM,TEACHER_NO,OPEN_DATE,END_DATE,COURSE_NO,CLASS_NAME,CLASS_STATE) VALUES(?,?,?,?,?,?,?,?,?,?,?)";
ps = conn.prepareStatement(SQL);
ps.setString(idext++,classdto.getClassNo());
ps.setString(idext++,classdto.getSchoolNo());
ps.setString(idext++,classdto.getClassroomNo());
ps.setString(idext++,classdto.getClassType());
ps.setString(idext++,classdto.getStuNum());
ps.setString(idext++,classdto.getTeacherNo());
ps.setString(idext++,classdto.getOpenDate());
ps.setString(idext++,classdto.getEndDate());
ps.setString(idext++,classdto.getCouresNo());
ps.setString(idext++,classdto.getClassName());
ps.setString(idext++,classdto.getClassState());
a = ps.executeUpdate();
if(a!=-1){
insert = 1;
}
conn.commit();
} catch (RuntimeException e) {
e.printStackTrace();
}finally{
if(ps!=null)ps.close();
SQL = null;
classdto = null;
}
return insert;
}
/**
* @author 李亭 <p>
* Creation date:05-05-2008
* 根据ID修改校区信息
* @param obj 传入ClassesDTO对象
*@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;
ClassesDTO classdto = null;
String SQL = null;
classdto = (ClassesDTO) obj;
try {
SQL="UPDATE classes SET CLASS_NO=?,SCHOOL_NO=?,CLASSROOM_NO=?,CLASS_TYPE=?,STU_NUM=?,TEACHER_NO=?,OPEN_DATE=?,END_DATE=?,COURSE_NO=?,CLASS_NAME=?,CLASS_STATE=? WHERE ID=?";
pstmt = conn.prepareStatement(SQL);
pstmt.setString(1, classdto.getClassNo());
pstmt.setString(2, classdto.getSchoolNo());
pstmt.setString(3, classdto.getClassroomNo());
pstmt.setString(4, classdto.getClassType());
pstmt.setString(5, classdto.getStuNum());
pstmt.setString(6, classdto.getTeacherNo());
pstmt.setString(7, classdto.getOpenDate());
pstmt.setString(8, classdto.getEndDate());
pstmt.setString(9, classdto.getCouresNo());
pstmt.setString(10, classdto.getClassName());
pstmt.setString(11, classdto.getClassState());
pstmt.setInt(12, classdto.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;
classdto = null;
}
return update;
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -