【框架】[Hibernate]利用Hibernate进行单表的增删改查-Web实例(1)

简介: 【框架】[Hibernate]利用Hibernate进行单表的增删改查-Web实例

前面两篇博客已经将Hibernate的基础知识讲解得差不多了,差不多到写实例的时候了。

本篇只用hibernate进行单表的增删改查、

应用Hibernate,对students表进行增删改查。

service层和DAO层,我都是直接写实现类了(因为这里主要是演示一下Hibernate的使用),如果是开发项目,注意一定要写接口!

准备数据库:

首先准备一个students表:

create database hib charset=utf8;
use hib;
create table students(
    sId varchar(8) primary key,
    sName varchar(40),
    sAge int,
    deptId varchar(8)
);

插入数据:

insert into students(sId,sName,sAge,deptId) values('S001','Jack',23,'D001');
insert into students(sId,sName,sAge,deptId) values('S002','Tom',25,'D001');
insert into students(sId,sName,sAge,deptId) values('S003','张三',43,'D001');
insert into students(sId,sName,sAge,deptId) values('S004','李四',55,'D001');
insert into students(sId,sName,sAge,deptId) values('S005','Jack',23,'D002');
insert into students(sId,sName,sAge,deptId) values('S006','Tom',25,'D003');
insert into students(sId,sName,sAge,deptId) values('S007','张三',43,'D002');
insert into students(sId,sName,sAge,deptId) values('S008','李四',55,'D002');

image.png

需要的Jar包

数据库连接包以及hibernate必须包,这些包在项目的WEBROOT/WEBINF的bin目录下都有。

image.png

链接:

https://github.com/chenhaoxiang/Java/blob/master/Hibernate/myHibWeb/myHibWeb.zip

部分核心源码:

Student.java:

package cn.hncu.domain;
public class Student {
    private String sId;
    private String sName;
    private Integer sAge;
    private String deptId;
    public String getDeptId() {
        return deptId;
    }
    public void setDeptId(String deptId) {
        this.deptId = deptId;
    }
    public Student() {
        super();
    }
    public String getsId() {
        return sId;
    }
    public void setsId(String sId) {
        this.sId = sId;
    }
    public String getsName() {
        return sName;
    }
    public void setsName(String sName) {
        this.sName = sName;
    }
    public Integer getsAge() {
        return sAge;
    }
    public void setsAge(Integer sAge) {
        this.sAge = sAge;
    }
    @Override
    public String toString() {
        return "Student [sId=" + sId + ", sName=" + sName + ", sAge=" + sAge
                + ", deptId=" + deptId + "]";
    }
}

hibernate.cfg.xml

<?xml version='1.0' encoding='UTF-8'?>
<!DOCTYPE hibernate-configuration PUBLIC
          "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
          "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">
<hibernate-configuration>
    <!-- 这是最简单的配置版!!! -->
    <session-factory>
        <property name="connection.driver_class">
            com.mysql.jdbc.Driver
        </property>
        <property name="connection.url">
            jdbc:mysql://127.0.0.1:3306/hib
        </property>
        <property name="connection.username">root</property>
        <property name="connection.password">1234</property>
        <property name="dialect">
            org.hibernate.dialect.MySQLDialect
        </property>
          <!--是否在后台显示Hibernate用到的SQL语句,开发时设置为true,便于查错,
        程序运行时可以在Eclipse的控制台显示Hibernate的执行Sql语句。
        项目部署后可以设置为false,提高运行效率-->   
        <property name="hibernate.show_sql">true </property>   
        <!--jdbc.fetch_size是指Hibernate每次从数据库中取出并放到JDBC的Statement中的记录条数。
        Fetch Size设的越大,读数据库的次数越少,速度越快,Fetch Size越小,读数据库的次数越多,速度越慢-->   
        <property name="jdbc.fetch_size">50 </property> 
        <!--jdbc.batch_size是指Hibernate批量插入,删除和更新时每次操作的记录数。
        Batch Size越大,批量操作的向数据库发送Sql的次数越少,速度就越快,同样耗用内存就越大-->   
        <property name="jdbc.batch_size">23 </property>  
        <!--jdbc.use_scrollable_resultset是否允许Hibernate用JDBC的可滚动的结果集。
        对分页的结果集。对分页时的设置非常有帮助-->   
        <property name="jdbc.use_scrollable_resultset">false </property> 
        <!--connection.useUnicode连接数据库时是否使用Unicode编码 -->
        <property name="connection.useUnicode">true</property>
        <!--connection.characterEncoding连接数据库时数据的传输字符集编码方式 -->
        <property name="connection.characterEncoding">utf-8</property>
        <mapping resource="cn/hncu/domain/Student.hbm.xml" />
    </session-factory>
</hibernate-configuration>


Student.hbm.xml

<?xml version="1.0" encoding="utf-8"?>
<!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<hibernate-mapping package="cn.hncu.domain">
    <!--name指的是POJO类的类名,table是数据库的表名,catalog是数据库的名称  -->
    <class name="Student" table="students" catalog="hib">
        <!--id表示此字段为数据库的主键,这里也可以用property来写,name为Student类的成员变量名,type为类型的包全名  -->
        <id name="sId" type="java.lang.String">
            <!--column表示映射的数据库的字段,name表示数据库中字段名,length表示varchar/char型的长度  -->
            <column name="sId" length="8"></column>
            <generator class="assigned"></generator>            
        </id>
        <property name="sName" type="java.lang.String">
            <column name="sName" length="40" />
        </property>
        <property name="sAge" type="java.lang.Integer">
            <column name="sAge" />
        </property>
        <property name="deptId" type="java.lang.String">
        <column name="deptId" length="8" />
     </property>
    </class>
</hibernate-mapping>

BaseServlet.java

package cn.hncu.utils;
import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
public abstract class BaseServlet extends HttpServlet {
    private static final long serialVersionUID = 1L;
    @Override
    public void doGet(HttpServletRequest req, HttpServletResponse resp)
            throws ServletException, IOException {
        doPost(req, resp);
    }
    @Override
    public void doPost(HttpServletRequest req, HttpServletResponse resp)
            throws ServletException, IOException {
        req.setCharacterEncoding("utf-8");
        resp.setCharacterEncoding("utf-8");
        resp.setContentType("text/html;charset=utf-8");
        String cmd = req.getParameter("cmd");
        if (null == cmd || cmd.trim().equals("")) {
            cmd = "execute";
        }
        try {
            Method method = this.getClass().getMethod(cmd,
                    HttpServletRequest.class, HttpServletResponse.class);
            method.invoke(this, req, resp);
        } catch (NoSuchMethodException e) {
            throw new RuntimeException("没有此方法:" + e.getMessage(), e);
        }catch(InvocationTargetException e){
            throw new RuntimeException("目标方法执行失败:" + e.getMessage(), e);
        }catch(IllegalAccessException e){
            throw new RuntimeException("你可能访问了一个私有的方法:" + e.getMessage(), e);
        }catch(Exception e){
            throw new RuntimeException(e.getMessage(), e);
        }
    }
    public abstract void execute(HttpServletRequest req,
            HttpServletResponse resp) throws Exception;
}

HibernateSessionFactory.java

package cn.hncu.hib;
import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;
public class HibernateSessionFactory {
   private static String configFile = "/hibernate.cfg.xml";
   private static Configuration config = new Configuration();
   private static SessionFactory sessionFactory =null;
   private static final ThreadLocal<Session> t = new ThreadLocal<Session>();
   static{
       try {
           config.configure(configFile);
           sessionFactory = config.buildSessionFactory();
        } catch (HibernateException e) {
            e.printStackTrace();
        }
   }
   public static Session getSession() throws HibernateException{
       Session session = t.get();
       if(session == null || !session.isOpen()){
           if(sessionFactory==null){
               rebuildSessionFactory();
           }
           session = (sessionFactory!=null) ? sessionFactory.openSession() : null;
           t.set(session);
       }
       return session;
   }
   private static void rebuildSessionFactory() {
       try {
           config.configure(configFile);
           sessionFactory = config.buildSessionFactory();
        } catch (HibernateException e) {
            e.printStackTrace();
        }
   }
   //关闭与数据库的会话
   public static void closeSession() throws HibernateException{
       Session session = t.get();
       t.set(null);
       if(session!=null){
           session.close();
       }
   }
}

DemoServlet.java

package cn.hncu.demo;
import java.io.PrintWriter;
import java.util.Date;
import java.util.List;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import cn.hncu.demo.service.DemoServiceImpl;
import cn.hncu.domain.Student;
import cn.hncu.utils.BaseServlet;
public class DemoServlet extends BaseServlet {
    DemoServiceImpl service = new DemoServiceImpl();
    @Override
    public void execute(HttpServletRequest req, HttpServletResponse resp)
            throws Exception {
        List<Student> list = service.queryAllStudents();
        req.getSession().setAttribute("list", list);
        req.getRequestDispatcher("/jsps/demo.jsp").forward(req, resp);
    }
    public void delStudent(HttpServletRequest req, HttpServletResponse resp)
            throws Exception {
        String studId = req.getParameter("studId");
        Student stud = new Student();
        stud.setsId(studId);
        service.delStudent(stud);
        resp.sendRedirect(getServletContext().getContextPath()+"?time="+(new Date().getTime()));
    }
    public void addStudent(HttpServletRequest req, HttpServletResponse resp)
            throws Exception {
        String studId = req.getParameter("studId");
        String studName = req.getParameter("studName");
        String strAge = req.getParameter("age");
        Integer age = Integer.valueOf(strAge);
        String deptId = req.getParameter("deptId");
        Student stud = new Student();
        stud.setsId(studId);
        //System.out.println(studName);//正常汉字
        stud.setsName(studName);
        stud.setsAge(age);
        stud.setDeptId(deptId);
        service.addStudent(stud);
        resp.sendRedirect(getServletContext().getContextPath());
    }
    public void queryStudents(HttpServletRequest req, HttpServletResponse resp)
            throws Exception {
        String studId = req.getParameter("studId");
        String studName = req.getParameter("studName");
        String deptId = req.getParameter("deptId");
        Student stud = new Student();
        stud.setsId(studId);
        stud.setsName(studName);
        stud.setDeptId(deptId);
        List<Student> qlist = service.queryStudents(stud);
        req.getSession().setAttribute("qlist", qlist);
        PrintWriter out = resp.getWriter();
        out.print("1"); //坑:不能使用out.println("1")
    }
}

DemoJdbcDao.java

package cn.hncu.demo.dao;
import java.util.List;
import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;
import cn.hncu.domain.Student;
import cn.hncu.hib.HibernateSessionFactory;
public class DemoJdbcDao {
    public List<Student> queryAllStudents() {
        Session s = HibernateSessionFactory.getSession();
        Query query = s.createQuery("from Student");
        List<Student> list = query.list();
        return list;
    }
    public void delStudent(Student stud) {
        Session s = HibernateSessionFactory.getSession();
            try {
                Transaction tran = s.beginTransaction();
                System.out.println("stud:"+stud);
                s.delete(stud);
//              Student stud2 = new Student();
//              stud2.setStudId("S001");
//              s.save(stud2);
                tran.commit();
            } catch (HibernateException e) {
                //tran.rollback();//可以不写,内部会进行回滚
                System.out.println("抓到异常...");
            }
    }
    public void addStudent(Student stud) {
        Session s = HibernateSessionFactory.getSession();
        Transaction tran = s.beginTransaction();
        try {
            System.out.println(stud.getsName());
            s.saveOrUpdate(stud);
            tran.commit();
        } catch (HibernateException e) {
        }
    }
    public List<Student> queryStudents(Student stud) {
        System.out.println(stud);
        boolean f1=false,f2=false,f3=false;
        Session s = HibernateSessionFactory.getSession();
        String hql = "from Student s where 1=1";
        if(stud.getsId()!=null && stud.getsId().trim().length()>0){
            hql = hql + " and s.sId=:sId";
            f1=true;
        }
        if(stud.getsName()!=null && stud.getsName().trim().length()>0){
            hql = hql + " and s.sName like :sName";
            f2=true;
        }
        if(stud.getDeptId()!=null && stud.getDeptId().trim().length()>0){
            hql = hql + " and s.deptId=:deptId";
            f3=true;
        }
        Query query = s.createQuery(hql);
        if(f1){
            query.setParameter("sId", stud.getsId().trim());
        }
        if(f2){
            query.setParameter("sName", "%"+stud.getsName().trim()+"%");
        }
        if(f3){
            query.setParameter("deptId", stud.getDeptId().trim());
        }
        return query.list();
    }
}
目录
相关文章
|
1月前
|
Java API 数据库
构建RESTful API已经成为现代Web开发的标准做法之一。Spring Boot框架因其简洁的配置、快速的启动特性及丰富的功能集而备受开发者青睐。
【10月更文挑战第11天】本文介绍如何使用Spring Boot构建在线图书管理系统的RESTful API。通过创建Spring Boot项目,定义`Book`实体类、`BookRepository`接口和`BookService`服务类,最后实现`BookController`控制器来处理HTTP请求,展示了从基础环境搭建到API测试的完整过程。
42 4
|
16天前
|
设计模式 前端开发 数据库
Python Web开发:Django框架下的全栈开发实战
【10月更文挑战第27天】本文介绍了Django框架在Python Web开发中的应用,涵盖了Django与Flask等框架的比较、项目结构、模型、视图、模板和URL配置等内容,并展示了实际代码示例,帮助读者快速掌握Django全栈开发的核心技术。
103 45
|
12天前
|
SQL 安全 PHP
探索PHP的现代演进:从Web开发到框架创新
PHP是一种流行的服务器端脚本语言,自诞生以来在Web开发领域占据重要地位。从简单的网页脚本到支持面向对象编程的现代语言,PHP经历了多次重大更新。本文探讨PHP的现代演进历程,重点介绍其在Web开发中的应用及框架创新,如Laravel、Symfony等。这些框架不仅简化了开发流程,还提高了开发效率和安全性。
19 3
|
11天前
|
前端开发 JavaScript 开发工具
从框架到现代Web开发实践
从框架到现代Web开发实践
21 1
|
14天前
|
SQL 安全 PHP
探索PHP的现代演进:从Web开发到框架创新
PHP 自发布以来一直在 Web 开发领域占据重要地位,历经多次重大更新,从简单的脚本语言进化为支持面向对象编程的现代语言。本文探讨 PHP 的演进历程,重点介绍其在 Web 开发中的应用及框架创新。自 PHP 5.3 引入命名空间后,PHP 迈向了面向对象编程时代;PHP 7 通过优化内核大幅提升性能;PHP 8 更是带来了属性、刚性类型等新特性。
24 3
|
17天前
|
前端开发 JavaScript
Bootstrap Web 前端 UI 框架
Bootstrap 是快速开发 Web 应用程序的前端工具包。
30 3
|
17天前
|
安全 数据库 开发者
Python Web开发:Django框架下的全栈开发实战
【10月更文挑战第26天】本文详细介绍了如何在Django框架下进行全栈开发,包括环境安装与配置、创建项目和应用、定义模型类、运行数据库迁移、创建视图和URL映射、编写模板以及启动开发服务器等步骤,并通过示例代码展示了具体实现过程。
29 2
|
18天前
|
缓存 Java 数据库连接
Hibernate:Java持久层框架的高效应用
通过上述步骤,可以在Java项目中高效应用Hibernate框架,实现对关系数据库的透明持久化管理。Hibernate提供的强大功能和灵活配置,使得开发者能够专注于业务逻辑的实现,而不必过多关注底层数据库操作。
12 1
|
1月前
|
前端开发 JavaScript UED
构建现代Web应用:使用React框架打造单页面应用
【10月更文挑战第9天】构建现代Web应用:使用React框架打造单页面应用
|
1月前
|
前端开发 JavaScript 开发者
探索现代Web前端技术:React框架入门
【10月更文挑战第9天】 探索现代Web前端技术:React框架入门

热门文章

最新文章