实战突击：Java Web项目整合开发 7-10 源码

package com.hiernate.util; import java.util.List; import org.hibernate.Query; import org.hibernate.Session; import org.hibernate.Transaction; import com.hiernate.persistence.*; //hibernate工具类，于数据库交互． public class HibernateUtil { static Session session; static GetHibernate hib = new GetHibernate(); //创建 // 按照用户名和密码寻找用户 public static List findUser(String strUserName, String strPwd) { Transaction tx = null; List list = null; try { Session session = hib.openSession(); //调用公共类的开启session方法． tx = (Transaction) session.beginTransaction(); //开启事物 Query query = session.createQuery("from User as u where u.userName=:strUserName and u.pwd=:strPwd"); //应用HQL检索查找满足条件的集合 query.setString("strUserName", strUserName); //动态绑定参数 query.setString("strPwd", strPwd); list = query.list(); //list方法用来执行HQL语句 tx.commit(); //事务的提交 hib.closeSession(session); //关闭session } catch (Exception e) { e.printStackTrace(); //输出异常信息 tx.rollback(); //事务的回滚 } return list; } // 查出所有用户并分页 public static List findUser(int recPerPage,int pages) { Transaction tx = null; List list = null; try { Session session = hib.openSession(); tx = (Transaction) session.beginTransaction(); Query query = session.createQuery("from User"); query.setFirstResult(recPerPage); query.setMaxResults(pages); list = query.list(); tx.commit(); hib.closeSession(session); } catch (Exception e) { e.printStackTrace(); tx.rollback(); } return list; } // 查找员工的总记录数 public static int findUserCount() { Transaction tx = null; int intCount=0; try { Session session = hib.openSession(); tx = (Transaction) session.beginTransaction(); String count = (session.createQuery("select count(*)from User").uniqueResult()).toString(); intCount = Integer.parseInt(count); tx.commit(); hib.closeSession(session); } catch (Exception e) { e.printStackTrace(); tx.rollback(); } return intCount; } // 修改用户信息 public static void updateUser(User user) { Transaction tx = null; try { Session session = hib.openSession(); tx = (Transaction) session.beginTransaction(); session.update(user); tx.commit(); hib.closeSession(session); } catch (Exception e) { e.printStackTrace(); tx.rollback(); } } // 删除用户 public static void deleUser(User user) { Transaction tx = null; try { Session session = hib.openSession(); tx = (Transaction) session.beginTransaction(); session.delete(user); tx.commit(); hib.closeSession(session); } catch (Exception e) { e.printStackTrace(); tx.rollback(); } } // 查找用户id方法 public static List findUserId(int intId) { Transaction tx = null; List list = null; try { Session session = hib.openSession(); tx = (Transaction) session.beginTransaction(); Query query = session .createQuery("from User as u where u.id =:intMedeId"); query.setInteger("intMedeId", intId); list = query.list(); tx.commit(); hib.closeSession(session); } catch (Exception e) { e.printStackTrace(); tx.rollback(); } return list; } // 按部门查找用户 public static List findUser(String strBranch,int intFrist,int intPages) { Transaction tx = null; List list = null; try { Session session = hib.openSession(); tx = (Transaction) session.beginTransaction(); Query query = session .createQuery("from User as u where u.branch=:strBranch"); query.setString("strBranch", strBranch); query.setFirstResult(intFrist); query.setMaxResults(intPages); list = query.list(); tx.commit(); hib.closeSession(session); } catch (Exception e) { e.printStackTrace(); tx.rollback(); } return list; } // 按部门查找员工的总记录数 public static int findUserCount(String branch) { Transaction tx = null; int intCount=0; try { Session session = hib.openSession(); tx = (Transaction) session.beginTransaction(); intCount = Integer.parseInt( (session.createQuery("select count(*)from User u where u.branch ="+"'"+branch+"'").uniqueResult()).toString()); tx.commit(); hib.closeSession(session); } catch (Exception e) { e.printStackTrace(); tx.rollback(); } return intCount; } // 查找优秀员工 public static List findU() { Transaction tx = null; List list = null; try { Session session = hib.openSession(); tx = (Transaction) session.beginTransaction(); Query query = session .createQuery("from User as u where u.bestMan =1"); list = query.list(); tx.commit(); hib.closeSession(session); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); tx.rollback(); } return list; } // 查找菜单 public static List findMenu(int intMendId) { Transaction tx = null; List list = null; try { Session session = hib.openSession(); //利用公共类开启session tx = (Transaction) session.beginTransaction(); //开启事务 Query query = session .createQuery("from Menu as m where m.modeId =:intMedeId"); query.setInteger("intMedeId", intMendId); //绑定查询参数 list = query.list(); tx.commit(); hib.closeSession(session); //利用公共类关闭session } catch (Exception e) { e.printStackTrace(); tx.rollback(); } return list; } // 查出会议记录,并分页 public static List finMeeting(int intFrint,int intpages) { Transaction tx = null; List list = null; try { Session session = hib.openSession(); //打开session tx = (Transaction) session.beginTransaction(); //开启事务 Query query = session.createQuery("from Meeting"); //创建Query对象 query.setFirstResult(intFrint); //调用Query的分页方法 query.setMaxResults(intpages); list = query.list(); //查询结果返回list集合 tx.commit(); //提交事务 hib.closeSession(session); //关闭session } catch (Exception e) { e.printStackTrace(); tx.rollback(); } return list; } // 查找会议的总记录数 public static int findMeetingCount() { Transaction tx = null; //创建事务 int intCount=0; //声明int型变量 try { Session session = hib.openSession(); //调用公共类打开session tx = (Transaction) session.beginTransaction();//开启事务 intCount = Integer.parseInt((session.createQuery("select count(*)from Meeting").uniqueResult()).toString()); //如果在不确定查询结果类型的时候，可用uniqueResult()方法，返回Object tx.commit(); //提交事务 hib.closeSession(session); //关闭session } catch (Exception e) { e.printStackTrace(); tx.rollback(); //撤消事务 } return intCount; } // 查出符合会议id集合 public static List findMeetingid(int intid) { Transaction tx = null; List list = null; try { Session session = hib.openSession(); //调用公共类打开session tx = (Transaction) session.beginTransaction(); //开启事务 Query query = session.createQuery("from Meeting as m where m.id =:intid"); //按id号检索对象 query.setInteger("intid",intid); //动态绑定参数 list = query.list(); //执行HQL语句 tx.commit();