📄 enroldaoimp.java
字号:
package com.stuman.dao.imp;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.hibernate.HibernateException;
import org.hibernate.Session;
import com.stuman.dao.EnrolDAO;
import com.stuman.dao.hibernate.HibernateUtil;
import com.stuman.domain.Classes;
import com.stuman.domain.Course;
import com.stuman.domain.Enrol;
import com.stuman.domain.EnrolId;
import com.stuman.domain.Score;
import com.stuman.domain.Student;
import com.stuman.util.BaseDao;
import com.stuman.util.PageBean;
public class EnrolDAOImp extends BaseDao implements EnrolDAO {
private static Log log = LogFactory.getLog(EnrolDAOImp.class);
public List getEnrol() {
// TODO Auto-generated method enrob
try {
Session s = HibernateUtil.currentSession();
HibernateUtil.beginTransaction();
List results = s.createQuery("from Enrol enro").list();
HibernateUtil.commitTransaction();
HibernateUtil.closeSession();
if (results != null && results.size() > 0) {
return results;
}
} catch (HibernateException e) {
log.fatal(e);
}
return null;
}
public boolean deleteEnrolByID(EnrolId id) {
// TODO Auto-generated method enrob
try {
Session s = HibernateUtil.currentSession();
HibernateUtil.beginTransaction();
String classes_id = ((Classes) id.getClasses()).getId();
String stu_id = ((Student) id.getStudent()).getId();
// System.out.println("in deleteEnrolByID " + classes_id + " "
// + stu_id);
s.createQuery("delete com.stuman.domain.Enrol where class_id = '"
+ classes_id
+ "' and stu_id = '"
+ stu_id
+ "'");
HibernateUtil.commitTransaction();
s.flush();
HibernateUtil.closeSession();
return true;
} catch (HibernateException e) {
log.fatal(e);
}
return false;
}
public Enrol getEnrolByID(EnrolId id) {
// TODO Auto-generated method enrob
try {
Session s = HibernateUtil.currentSession();
HibernateUtil.beginTransaction();
// Enrol enro = (Enrol) s.load(Enrol.class, id);
String classes_id = ((Classes) id.getClasses()).getId();
String stu_id = ((Student) id.getStudent()).getId();
System.out.println("in deleteEnrolByID " + classes_id + " "
+ stu_id);
Enrol enro = (Enrol)s.createQuery("from Enrol where class_id = '"
+ classes_id
+ "' and stu_id = '"
+ stu_id
+ "'").list().get(0);
HibernateUtil.commitTransaction();
HibernateUtil.closeSession();
return enro;
} catch (HibernateException e) {
log.fatal(e);
}
return null;
}
public boolean updateEnrol(Enrol enro) {
// TODO Auto-generated method enrob
try {
Session s = HibernateUtil.currentSession();
HibernateUtil.beginTransaction();
System.out.println("update Enrol id =" + enro.getId()+" score=="+ enro.getScore());
s.update(enro);
System.out.println("update Enrol id =" + enro.getId());
HibernateUtil.commitTransaction();
s.flush();
HibernateUtil.closeSession();
// Enrol en2=this.getEnrolByID(enro.getId());
// System.out.println("update ater Enrol2 id =" + en2.getId()+" score2=="+ en2.getScore());
return true;
} catch (HibernateException e) {
log.fatal(e);
}
return false;
}
public boolean saveEnrol(Enrol enro) {
// TODO Auto-generated method enrob
try {
Session s = HibernateUtil.currentSession();
HibernateUtil.beginTransaction();
// Enrol oldEenro = (Enrol) s.load(Enrol.class, id);
s.saveOrUpdate(enro);
// System.out.println("save Enrol id =" + enrob.getId());
HibernateUtil.commitTransaction();
s.flush();
HibernateUtil.closeSession();
return true;
} catch (HibernateException e) {
log.fatal(e);
}
return false;
}
public boolean addEnrol(String stuid, String classid) throws SQLException {
// TODO Auto-generated method stub
try {
// ���Session
Session s = HibernateUtil.currentSession();
// // ִ�в���
// Connection conn = s.connection();
// Statement sql = conn.createStatement();
// System.out.println("insert into enrol ( class_id, stu_id) values('"+classid+"','"+stuid+"')");
// sql.execute("insert into enrol ( class_id, stu_id) values('"+classid+"','"+stuid+"')");
//
// sql.close();
// �
Enrol enrol=new Enrol();
Student stu=new Student();
stu.setId(stuid);
Classes cla=new Classes();
cla.setId(classid);
EnrolId id=new EnrolId();
id.setClasses(cla);
id.setStudent(stu);
enrol.setId(id);
enrol.setClasses(cla);
enrol.setStudent(stu);
HibernateUtil.beginTransaction();
// Enrol oldEenro = (Enrol) s.load(Enrol.class, id);
s.save(enrol);
// System.out.println("save Enrol id =" + enrob.getId());
HibernateUtil.commitTransaction();
s.flush();
HibernateUtil.closeSession();
return true;
} catch (HibernateException e) {
log.fatal(e);
}
return false;
}
public List getByStuId(String stuid) throws SQLException {
// TODO Auto-generated method stub
ArrayList results = new ArrayList();
try {
// 获得Session
Session s = HibernateUtil.currentSession();
// 执行操作
Connection conn = s.connection();
Statement sql = conn.createStatement();
String str="select name, mark, score from enrol,classes,course where stu_id = '"+stuid+"' and class_id = classes.id and course.id = classes.cour_id";
System.out.println(str);
ResultSet rs = sql.executeQuery(str);
while (rs.next()) {
Score score = new Score();
score.setCourse(rs.getString(1));
score.setMark(rs.getString(2));
String mm="";
if(rs.getString(3)!=null){
mm=rs.getString(3);
}
score.setScore(mm);
results.add(score);
}
rs.close();
sql.close();
// 关闭Session
HibernateUtil.closeSession();
if (results != null && results.size() > 0) {
return results;
}
} catch (HibernateException e) {
log.fatal(e);
}
return null;
}
public PageBean getEnrolList(PageBean page){
PageBean page2= this.getObjects(Course.class, page);
return page2;
}
public boolean upateEnrolForTea(String score,String classId,String stuId) throws SQLException {
// TODO Auto-generated method stub
try {
// ���Session
Session s = HibernateUtil.currentSession();
Connection conn = s.connection();
Statement sql = conn.createStatement();
String upSql=" update enrol set score='"+score+"'"+" where class_id='"+classId+"' and stu_id='"+stuId+"'";
System.out.println(upSql);
sql.execute(upSql);
sql.close();
HibernateUtil.beginTransaction();
// System.out.println("save Enrol id =" + enrob.getId());
HibernateUtil.commitTransaction();
s.flush();
HibernateUtil.closeSession();
return true;
} catch (HibernateException e) {
log.fatal(e);
}
return false;
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -