二 Hibernate HQL实现学生管理系统的CRUD

package com.dao.impl;import java.sql.SQLException;import java.util.ArrayList;import java.util.List;import org.apache.commons.dbutils.QueryRunner;import org.apache.commons.dbutils.handlers.BeanHandler;import org.apache.commons.dbutils.handlers.BeanListHandler;import org.apache.commons.dbutils.handlers.ScalarHandler;import org.hibernate.Query;import org.hibernate.SQLQuery;import org.hibernate.Session;import org.hibernate.Transaction;import com.dao.StudentDao;import com.domain.Student;import com.util.HibernateUtils;import com.util.JDBCUtil02;import com.util.TextUtils;/** * 这是StudentDao的实现，针对前面定义的规范做出的具体实现 * */public class StudentDaoImpl implements StudentDao { ??????@Override ???/** ????* 查询所有学生 ????* @throws SQLException ?????*/ ???public List<Student> findAll() throws SQLException { ??????Session session = HibernateUtils.oppenSession(); ??????Transaction transaction = session.beginTransaction(); ??????//HQL查询,面向对象的查询语言，from Student ??????Query query = session.createQuery("from Student"); ??????List<Student> list = ?query.list(); ??????transaction.commit(); ???????????session.close(); ??????return list; ??????/* ???QueryRunner runner = new QueryRunner(JDBCUtil02.getDataSource()); ???????return runner.query("select * from students",new BeanListHandler<Student>(Student.class)); ???????*/} ???????@Override ???/** ????* 需要添加到数据库的学生 ????*/ ???public void insert(Student student) throws SQLException { ???/* ???QueryRunner runner = new QueryRunner(JDBCUtil02.getDataSource()); ????????runner.update("insert into students values(null,?,?,?,?,?,?)", ???????????????student.getSname(), ???????????????student.getGender(), ???????????????student.getPhone(), ???????????????student.getBirthday(), ???????????????student.getHobby(), ???????????????student.getInfo() ????????????????); */ ??????????Session session = HibernateUtils.oppenSession(); ??????????Transaction transaction = session.beginTransaction(); ??????????//HQL查询,面向对象的查询语言 ??????????session.save(student);// ??????????Query query = session.createQuery("insert into Student values(null,student.getSname(),student.getGender(),student.getPhone(),student.getBirthday(),student.getHobby(),student.getInfo())"); ??????????transaction.commit(); ???????????????session.close(); ???} ???????@Override ???/** ????* 根据id删除学生 ????*/ ???public void delete(int sid) throws SQLException { ???/* ???QueryRunner runner = new QueryRunner(JDBCUtil02.getDataSource()); ???????runner.update("delete from students where sid = ?" , sid);*/ ??????????Session session = HibernateUtils.oppenSession(); ??????????Transaction transaction = session.beginTransaction(); ??????????//HQL查询,面向对象的查询语言 ??????????Student student = session.get(Student.class, sid); ??????????session.delete(student);// ??????????Query query = session.createQuery("insert into Student values(null,student.getSname(),student.getGender(),student.getPhone(),student.getBirthday(),student.getHobby(),student.getInfo())"); ??????????transaction.commit(); ???????????????session.close(); ???} ???/** ????* 根据id查询单个学生 ????* @throws SQLException ?????*/ ???@Override ???public Student findStudentById(int sid) throws SQLException { ???/* ???QueryRunner runner = new QueryRunner(JDBCUtil02.getDataSource()); ???????return runner.query("select * from students where sid = ?", new BeanHandler<Student>(Student.class) , sid); ???*/ ??????????Session session = HibernateUtils.oppenSession(); ??????????Transaction transaction = session.beginTransaction(); ??????????//HQL查询,面向对象的查询语言 ??????????Student student = session.get(Student.class, sid); ??????????transaction.commit(); ???????????????session.close(); ??????????????return student; ???} ???@Override ???/** ????* 更新学生到数据库 ????*/ ???public void Update(Student stu, int sid) throws SQLException {/* ???????QueryRunner runner = new QueryRunner(JDBCUtil02.getDataSource()); ???????runner.update("update students set sname=?,gender=?,phone=?,birthday=?,hobby=?,info=? where sid = ? ", ????????????????stu.getSname(), ???????????????stu.getGender(), ???????????????stu.getPhone(), ???????????????stu.getBirthday(), ???????????????stu.getHobby(), ???????????????stu.getInfo(), ???????????????sid ???????????????);*/ ????Session session = HibernateUtils.oppenSession(); ????Transaction transaction = session.beginTransaction(); ????stu.setSid(sid); ????session.saveOrUpdate(stu); ????transaction.commit(); ????session.close(); ???} ???????@Override ???/** ????* 模糊查询的DAO层实现 ????*/ ???public List<Student> SearchStident(String sname, String sgender) throws SQLException { ???????QueryRunner runner = new QueryRunner(JDBCUtil02.getDataSource()); ???????/* ????????* select * from stu where sname like ? and gender = ? ????????* ?????????* 如果两个都没有就查询所有 ????????*/ ???????List<String> list = new ArrayList<String>(); ???????String sql = "select * from students where 1 = 1 "; ???????if(!TextUtils.isEmpty(sname)){ ???????????sql = sql + " and sname like ? "; ???????????list.add("%"+sname+"%"); ???????} ???????if(!TextUtils.isEmpty(sgender)){ ???????????sql = sql + " and gender = ? "; ???????????list.add(sgender); ???????} ????????return runner.query(sql, new BeanListHandler<Student>(Student.class),list.toArray()); ???????????} ???@Override ???/** ????* 分页查询，查询当前页的学生数据并封装成集合 ????*/ ???public List<Student> findStudentByPage(int currentPage) throws SQLException { ???????QueryRunner runner = new QueryRunner(JDBCUtil02.getDataSource()); ???????//第一个？返回记录数量，第二个？偏移量 ???????//第n页 ： ?5,5*n-1 ???????return runner.query("select * from students limit ? offset ?",new BeanListHandler<Student>(Student.class),PAGE_SIZE,PAGE_SIZE*(currentPage-1)); ???????} ???@Override ???/** ????* 查询学生记录数 ????*/ ???public int findCount() throws SQLException { ???????QueryRunner runner = new QueryRunner(JDBCUtil02.getDataSource()); ???????//用于处理平均值，总个数 ???????Long result = (Long)runner.query("select count(*) from students", new ScalarHandler()); ???????????return result.intValue(); ???} ???????}