在线考试系统（struts+spring+hibernate）

package com.qinghuait.hibernate.beans; import java.util.List; import org.hibernate.Query; import org.hibernate.Session; import org.hibernate.Transaction; import com.qinghuait.util.Page; /** * 考生 DAO 类 * @author 米强 * */ public class UserDAO extends HibernateDAO implements IPage { public UserDAO() { } /** * 持久化一个 User 对象 * @param user User 对象 * @return 事务是否提交成功 */ public boolean saveUser(User user){ boolean b = false; Session session = getSession(); Transaction tran = null; try{ tran = session.beginTransaction(); session.save(user); tran.commit(); }catch (Exception e) { if(tran != null){ tran.rollback(); } }finally{ // 判断事务是否提交成功 b = tran.wasCommitted(); session.close(); } return b; } /** * 删除数据 * @param id 主键 * @return 事务是否提交成功 */ public boolean deleteUser(int id){ return deleteUser(queryUser(id)); } /** * 删除数据 * @param user User 对象 * @return 事务是否提交成功 */ public boolean deleteUser(User user){ boolean b = false; Session session = getSession(); Transaction tran = null; try{ // 开始事务 tran = session.beginTransaction(); // 删除 session.delete(user); // 事务提交 tran.commit(); }catch (Exception e) { if(tran != null){ // 事务回滚 tran.rollback(); } }finally{ // 获得事务是否提交成功 b = tran.wasCommitted(); session.close(); } return b; } /** * 更新数据 * @param user User 对象 * @return 事务是否提交成功 */ public boolean updateUser(User user){ boolean b = false; Session session = getSession(); Transaction tran = null; try{ // 开始事务 tran = session.beginTransaction(); // 更新 session.update(user); // 事务提交 tran.commit(); }catch (Exception e) { if(tran != null){ // 事务回滚 tran.rollback(); } }finally{ // 获得事务是否提交成功 b = tran.wasCommitted(); session.close(); } return b; } /** * 按主键 id 查询 * @param id 主键 * @return User 对象 */ public User queryUser(int id){ User user = null; Session session = getSession(); try{ user = (User) session.get(User.class, id); }catch (Exception e) { }finally{ session.close(); } return user; } /** * 按用户名称查询 * @param userName 名称 * @return User 对象 */ public User queryUser(String userName){ User user = null; Session session = getSession(); try{ String hql = "from User as u where u.userName=:userName"; Query query = session.createQuery(hql); query.setString("userName", userName); // 获取唯一的 User 对象，该列有唯一性约束时使用。 user = (User) query.uniqueResult(); }catch (Exception e) { }finally{ session.close(); } return user; } /** * 查询所有数据 * @return 数据 list */ @SuppressWarnings("unchecked") public List<User> queryAll(){ List<User> list = null; Session session = getSession(); try{ String hql = "from User"; Query query = session.createQuery(hql); list = query.list(); }catch (Exception e) { }finally{ session.close(); } return list; } /* * 需要分页显示所有考生则需要实现接口下的三个方法 * @see com.qinghuait.hibernate.beans.IPage#getPage(int) */ @Override public Page getPage(int pageId) { // 调用下面的方法重载 return getPage(new Page(pageId)); } @SuppressWarnings("unchecked") @Override public Page getPage(Page page) { Session session = getSession(); // 返回数据总数的 HQL 语句 String hql = "select count(*) from User"; Query q = session.createQuery(hql); List<Integer> l = q.list(); if(l.size() > 0){ page.setCountRows(l.get(0)); // 计算 Page 对象的其它值 page.setup(); } session.close(); return page; } @SuppressWarnings("unchecked") @Override public List<User> list(Page page) { List<User> list = null; Session session = getSession(); String hql = "from User"; Query q = session.createQuery(hql); // 设置需要获取的第一条记录的位置（由 0 开始） q.setFirstResult(page.getStartRow()); // 设置需要获取数据的最大条数 q.setMaxResults(page.getPageSize()); list = q.list(); session.close(); return list; } }