使用Hibernate进行CRUD操作

野性酷女 2022-02-17 17:21 434阅读 0赞

CRUD操作
1、使用hibernate把数据库模型和java对象进行ORM映射，通过配置文件或者注解完成。
2、程序通过hibernate提供的API进行CRUD，
C操作对应hibernate方法为save();（添加）
R操作对应hibernate方法为get();（查询）
U操作对应hibernate方法为update();（修改）
D操作对应hibernate方法为delete()。（删除）

项目主体结构：

在这里插入图片描述

下面分析几个添加的功能已实现CRUD功能。

User实体类、映射文件和hibernate配置文件请小伙伴们自己添加哦，这里忽略。

①封装数据库的类（HibernateUtils.java）

  1. package com.connection;
  2. import org.hibernate.Session;
  3. import org.hibernate.SessionFactory;
  4. import org.hibernate.cfg.Configuration;
  5. public class HibernateUtils { 
  6.     private static SessionFactory factory;
  7.     //static只初始化一次.
  8.     static
  9.     { 
  10.         try{ 
  11.                 //默认读取的是hibernate.cfg.xml 文件.
  12.                 Configuration cfg = new Configuration().configure();
  13.                 //建立SessionFactory.
  14.                 factory = cfg.buildSessionFactory();
  15.         }catch(Exception e )
  16.         { 
  17.             e.printStackTrace();
  18.         }
  19.     }
  20.     public static Session getSession()
  21.     { 
  22.         //打开session.
  23.         return factory.openSession();
  24.     }
  25.     //关闭session.
  26.     public static void closeSession(Session session)
  27.     { 
  28.         //判断是否为空.
  29.         //判断是否是打开状态再进行关闭.
  30.         if(session!=null)
  31.         { 
  32.             if(session.isOpen())
  33.             { 
  34.                 session.close();
  35.             }
  36.         }
  37.     }
  38.     //返回工厂类.
  39.     public static SessionFactory getSessionFactory()
  40.     { 
  41.         return factory;
  42.     }
  43. }

②定义相应功能的类（UserDao.java）

CRUD的功能定义在此文件，在Action中调用相应方法。
学习的理解都写在了注解中。

  1. package com.dao;
  2. import java.util.ArrayList;
  3. import java.util.List;
  4. import org.hibernate.Session;
  5. import com.bean.User;
  6. import com.connection.HibernateUtils;
  7. public class UserDao {     
  8.     List<User> users=new ArrayList<User>();
  9.     List<User> useres=new ArrayList<User>();    
  10.     //查询并返回一个用户
  11.     public List<User> getOneUsers(int id) { 
  12.         Session session=HibernateUtils.getSession();//获取session对象
  13.         User u=session.get(User.class, id);//id自动转换为Integer类型
  14.         if(u!=null) { 
  15.             users.add(u);
  16.             System.out.println("查询用户成功");
  17.             System.out.println("用户名："+u.getUsername()+",密码：
  18.             "+u.getUserpass()+",生日："+u.getBirthday());
  19.         }
  20.         else
  21.             System.out.println("没有这个用户id");
  22.         HibernateUtils.closeSession(session);//关闭session
  23.         return users;    
  24.     }
  26.     //查询并返回多个用户
  27.     public List<User> getMultipleUsers(String username) {     
  28.         Session session=HibernateUtils.getSession();//获取session对象
  29.         users=session.createQuery("from User").list();
  30.         for(int i=0;i<users.size();i++) { 
  31.             User user = users.get(i);
  32.             if(username.equals(user.getUsername())){ 
  33.                 useres.add(user);
  34.                 System.out.println("ID:"+user.getId()+" 用户名："+user.getUsername());
  35.             }
  36.         }
  37.         if(useres.size()!=0)
  38.             System.out.println("查询用户成功");
  39.         else
  40.             System.out.println("没有这个用户名");
  41.         HibernateUtils.closeSession(session);//关闭session
  42.         return useres;
  43.     }
  45.     //查询并返回所有用户
  46.     public List<User> getAllUsers(){     
  47.         Session session=HibernateUtils.getSession();//获取session对象
  48.         users=session.createQuery("from User").list();//hql
  49.         //获取集合里所有User对象数据存储到list中
  50.         System.out.println("查询所有用户成功");
  51.         //通过循环迭代userList集合 列出user对象
  52.         for(int i=0;i<users.size();i++) { 
  53.             User u = users.get(i);
  54.             System.out.println("用户名："+u.getUsername()+",
  55.             密码："+u.getUserpass()+",生日："+u.getBirthday());
  56.         }
  57.         HibernateUtils.closeSession(session);//关闭session
  58.         return users;
  59.     }
  61.     //查询是否存在该用户名（注册检查）
  62.     public int queryregister(String username) { 
  63.         int flag=1;//不存在
  64.         Session session=HibernateUtils.getSession();//获取session对象
  65.         users=session.createQuery("from User").list();
  66.         for(int i=0;i<users.size();i++) { 
  67.             User user = users.get(i);
  68.             if(username.equals(user.getUsername())){ 
  69.                 flag=0;
  70.                 System.out.println("ID:"+user.getId()+" 用户名："+user.getUsername());
  71.                 break;
  72.             }
  73.         }
  74.         HibernateUtils.closeSession(session);//关闭session
  75.         return flag;
  76.     }
  78.     //查询是否存在该用户名如果存在再判断密码是否匹配（登录）
  79.     public void querylogin(String username,String userpass) { 
  80.         if(queryregister(username)==0) { 
  81.             Session session=HibernateUtils.getSession();//获取session对象
  82.             users=session.createQuery("from User").list();
  83.             for(int i=0;i<users.size();i++) { 
  84.                 User user = users.get(i);
  85.                 if(username.equals(user.getUsername())){ 
  86.                     if(userpass.equals(user.getUserpass())){ 
  87.                         System.out.println("ID:"+user.getId()+" 
  88.                         用户名："+user.getUsername()+" 密码："+user.getUserpass());
  89.                         System.out.println("登录成功");
  90.                     }
  91.                     else
  92.                         System.out.println("密码不正确");
  93.                     break;
  94.                 }
  95.             }
  96.             HibernateUtils.closeSession(session);//关闭session
  97.         }
  98.         else
  99.             System.out.println("没有这个用户名");
  100.     }
  102.     //添加用户
  103.     public void add(User u){ 
  104.         if(queryregister(u.getUsername())==1) { 
  105.             Session session=HibernateUtils.getSession();//获取session对象
  106.             session.beginTransaction();//开启事务
  107.             //session.persist(u);//写入到数据库
  108.             session.save(u);//保存到数据库
  109.             session.getTransaction().commit();//提交事务
  110.             System.out.println("添加用户成功");
  111.             HibernateUtils.closeSession(session);//关闭session
  112.         }
  113.         else
  114.             System.out.println("数据库已存在该用户名，请重新添加");
  115.     }
  117.     //修改用户
  118.     public void updateone(User newuser,int id) { 
  120.         if(queryregister(newuser.getUsername())==1) { 
  121.             Session session=HibernateUtils.getSession();//获取session对象
  122.             session.beginTransaction();//开启事务
  123.             User u=session.get(User.class, id);
  124.             if(u!=null) { 
  125.                 u.setUsername(newuser.getUsername());
  126.                 u.setUserpass(newuser.getUserpass());
  127.                 u.setBirthday(newuser.getBirthday());
  128.                 session.update(u);//修改数据
  129.                 session.getTransaction().commit();//提交事务
  130.                 System.out.println("修改用户成功");
  131.                 System.out.println("用户名："+u.getUsername()+",密码：
  132.                 "+u.getUserpass()+",生日："+u.getBirthday());
  133.             }
  134.             else
  135.                 System.out.println("没有这个用户id");
  136.             HibernateUtils.closeSession(session);//关闭session
  137.         }
  138.         else
  139.             System.out.println("数据库已存在该用户名，请重新修改");
  140.     }
  142.     public void update(User newuser,int id) { 
  143.         Session session=HibernateUtils.getSession();//获取session对象
  144.         session.beginTransaction();//开启事务
  145.         User u=session.get(User.class, id);
  146.         if(u!=null) { 
  147.     if(queryregister(newuser.getUsername())==1||
  148.     newuser.getUsername().equals(u.getUsername())) 
  149.     { 
  150.                 u.setUsername(newuser.getUsername());
  151.                 u.setUserpass(newuser.getUserpass());
  152.                 u.setBirthday(newuser.getBirthday());
  153.                 session.update(u);//修改数据
  154.                 session.getTransaction().commit();//提交事务
  155.                 System.out.println("修改用户成功");
  156.                 System.out.println("用户名："+u.getUsername()+",密码：
  157.                 "+u.getUserpass()+",生日："+u.getBirthday());
  158.             }
  159.             else
  160.                 System.out.println("数据库已存在该用户名，请重新修改");
  161.             HibernateUtils.closeSession(session);//关闭session
  162.         }
  163.         else
  164.             System.out.println("没有这个用户id");
  165.     }
  167.     //删除用户
  168.     public void delete(int id) { 
  170.         Session session=HibernateUtils.getSession();//获取session对象
  171.         session.beginTransaction();//开启事务
  172.         User u=session.get(User.class, id);
  173.         if(u!=null) { 
  174.             session.delete(u);//删除数据
  175.             session.getTransaction().commit();//提交事务
  176.             System.out.println("删除用户成功");
  177.         }
  178.         else
  179.             System.out.println("没有这个用户id");
  180.         HibernateUtils.closeSession(session);//关闭session
  182.     }
  184. }

③Action实现类（JDBCAction.java）

从Dao调用方法使用，这要配合struts.xml和相应jsp页面一起看。

  1. package com.action;
  2. import java.util.ArrayList;
  3. import java.util.Date;
  4. import java.util.List;
  5. import javax.servlet.http.HttpServletRequest;
  6. import org.apache.struts2.ServletActionContext;
  7. import com.bean.User;
  8. import com.dao.UserDao;
  9. import com.opensymphony.xwork2.ActionContext;
  10. import com.opensymphony.xwork2.ActionSupport;
  12. public class JDBCAction extends ActionSupport{ 
  13.     private User user;
  14.     public User getUser() { 
  15.         return user;
  16.     }
  17.     public void setUser(User user) { 
  18.         this.user = user;
  19.     }
  21.     List<User> users=new ArrayList<User>();//存储User对象的list
  22.     public List<User> getUsers() { 
  23.         return users;
  24.     }
  25.     public void setUsers(List<User> users) { 
  26.         this.users = users;
  27.     }
  29.     UserDao userDao=new UserDao();
  31.     public String aone() { 
  32.         users=this.userDao.get OneUsers(user.getId());
  33.         if(users.size()==0)
  34.             request.setAttribute("tip","不存在该用户id");
  35.         return "list";
  36.     }
  38.     public String multiple() { 
  39.         users=this.userDao.getMultipleUsers(user.getUsername());
  40.         if(users.size()==0)
  41.             request.setAttribute("tip","不存在该用户名");
  42.         return "list";
  43.     }
  45.     public String list() { 
  46.         users=this.userDao.getAllUsers();
  47.         if(users.size()==0)
  48.             request.setAttribute("tip","还没有用户哟");
  49.         return "list";
  50.     }
  52.     public String add(){ 
  53.         this.userDao.add(this.user);
  54.         return "success";
  55.     }
  57.     public String update() { 
  58.         this.userDao.update(user,user.getId());
  59.         return "success";
  60.     }
  62.     public String delete() { 
  63.         this.userDao.delete(user.getId());
  64.         return "success";
  65.     }
  67.     public String edit(){ 
  68.         return "edit";
  69.     }
  71.     public void validateAone() { 
  72.         if (user.getId()==null) { 
  73.             this.addFieldError("user.id","请输入搜索内容");
  74.         }
  75.     }
  77.     public void validateMultiple() { 
  78.         if (user.getUsername()==null||"".equals(user.getUsername().trim())) { 
  79.             this.addFieldError("user.username","请输入搜索内容");
  80.         }
  81.     }
  82. }

④struts.xml

这里我使用通配符的形式，根据从jsp传来的数据调用相应的方法。

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE struts PUBLIC
  3.     "-//Apache Software Foundation//DTD Struts Configuration 2.3//EN"
  4.     "http://struts.apache.org/dtds/struts-2.3.dtd">
  6. <struts>
  7.     <!-- 配置Struts可以受理请求的扩展名value -->
  8.     <constant name="struts.action.extension" value="action,do,"></constant>
  10.     <!-- 打开允许动态方法条用的开关，默认是false -->
  11.     <constant name="struts.enable.DynamicMethodInvocation" value="true"></constant>
  13.     <package name="text"  extends="struts-default">
  15.     <default-interceptor-ref name="paramsPrepareParamsStack"></default-interceptor-ref>
  17.           <action name="user_*" class="com.action.JDBCAction" method="{1}">
  18.                 <result name="list">/user_list.jsp</result>
  19.                 <result name="input">/user_list.jsp</result>
  20.                 <result name="{1}">/user_{ 1}.jsp</result>
  21.                 <result name="success" type="redirectAction">user_list</result>
  22.           </action>
  23.     </package>
  24. </struts>

⑤前台JSP页面（index.jsp、user_add.jsp、user_list.jsp、user_edit.jsp）

（1）一个简单的直接跳转到管理用户界面的按钮（index.jsp）

  1. <%@ page language="java" contentType="text/html; charset=UTF-8"
  2.     pageEncoding="UTF-8"%>
  3. <!DOCTYPE html>
  4. <html>
  5. <head>
  6. <meta charset="UTF-8">
  7. <title>Insert title here</title>
  8. </head>
  9. <body>
  10.     <a href="user_list">list</a>
  11. </body>
  12. </html>

（2）注册界面（user_add.jsp）

  1. <%@page language="java" contentType="text/html;charset=UTF-8" pageEncoding="UTF-8"%>
  2. <%@taglib prefix="s" uri="/struts-tags"%>
  3. <!DOCTYPE html>
  4. <html>
  5.     <head>
  6.         <meta charset="UTF-8">
  7.         <title><s:text name="registerTitle"/></title>
  8.         <style>
  9.             table{ 
  10.                 background-size:100% 100%;
  11.                 border:2px solid gray;
  12.                 margin:10% auto 0% auto;
  13.             }
  14.             td{ 
  15.                 border:1px solid gray;
  16.                 text-align:center;
  17.             }
  18.         </style>
  19.     </head>
  20.     <body>
  21.         <s:form action="user_add">
  22.             <s:textfield name="user.username" key="用户名"/>
  23.             <s:password name="user.userpass" key="密码"/>
  24.             <s:textfield name="user.birthday" key="出生年月日"/>
  25.             <s:submit name="submit" key="register"/>
  26.         </s:form>
  27.     </body>
  28. </html>

（3）实现ID查询、用户名查询、用户修改和删除的界面（user_list.jsp）

  1. <%@ page language="java" contentType="text/html; charset=UTF-8"
  2.     pageEncoding="UTF-8"%>
  3. <%@taglib prefix="s" uri="/struts-tags"%>
  4. <!DOCTYPE html>
  5. <html>
  6. <head>
  7. <meta charset="UTF-8">
  8. <title>Insert title here</title>
  9.         <style>
  10.             table{ 
  11.                 background-size:100% 100%;
  12.                 border:2px solid gray;
  13.                 margin:1% auto 0% auto;
  14.             }
  15.             th,td{ 
  16.                 background-color: #EBEBEB;
  17.                 border:1px solid gray;
  18.                 text-align:center;
  19.             }
  20.         </style>
  21. </head>
  22. <body>
  23.     <s:debug></s:debug>
  24.     <font color="red" size="5">${ tip}</font><br>
  25.     <s:form action="user_aone">
  26.         <s:textfield name="user.id" label="id"/>
  27.         <s:submit/>
  28.     </s:form>
  29.     <s:form action="user_multiple">
  30.         <s:textfield name="user.username" label="username"/>
  31.         <s:submit/>
  32.     </s:form>
  33.     <table>
  34.         <tr>
  35.             <td colspan="6"><a href="user_list">管理所有用户</a></td>
  36.         </tr>
  37.         <tr>
  38.             <td colspan="6">查询结果</td>
  39.         </tr>
  40.         <tr>
  41.             <th>ID</th>
  42.             <th>用户名</th>
  43.             <th>密码</th>
  44.             <th>生日</th>
  45.             <th colspan="2">操作</th>
  46.         </tr>
  47.         <!--users是action类中获取数据访问层中的方法返回的结果-->
  48.         <s:iterator value="users" var="u">
  49.             <tr>
  50.                 <td>${ u.id}</td>
  51.                 <td><s:property value="username"/></td>
  52.                 <td>${ userpass}</td>
  53.                 <td>${ u.birthday}</td>
  54.                 <td><a href="user_edit?user.id=${u.id}">修改</a></td>
  55.                 <td><a href="user_delete?user.id=${u.id}">删除</a></td>
  56.             </tr>
  57.         </s:iterator>
  58.         <tr>
  59.             <td colspan="6"><a href="user_add.jsp">添加</a></td>
  60.         </tr>
  61.     </table>
  62. </body>
  63. </html>

（4）修改信息的界面（user_edit.jsp）

  1. <%@ page language="java" contentType="text/html; charset=UTF-8"
  2.     pageEncoding="UTF-8"%>
  3. <%@taglib prefix="s" uri="/struts-tags"%>
  4. <!DOCTYPE html>
  5. <html>
  6. <head>
  7. <meta charset="UTF-8">
  8. <title>Insert title here</title>
  9.         <style>
  10.             table{ 
  11.                 background-size:100% 100%;
  12.                 border:2px solid gray;
  13.                 margin:10% auto 0% auto;
  14.             }
  15.             td{ 
  16.                 border:1px solid gray;
  17.                 text-align:center;
  18.             }
  19.         </style>
  20. </head>
  21. <body>
  22.     <s:form action="user_update">
  23.         <s:hidden name="user.id"></s:hidden>
  24.         <s:textfield name="user.username" key="用户名"/>
  25.         <s:password name="user.userpass" key="密码"/>
  26.         <s:textfield name="user.birthday" key="出生年月日"/>
  27.         <s:submit name="submit" key="提交"/>
  28.     </s:form>
  29. </body>
  30. </html>

⑥操作展示

添加：

在这里插入图片描述
在这里插入图片描述

查询：

在这里插入图片描述

修改：

在这里插入图片描述
在这里插入图片描述

删除：

在这里插入图片描述
我的ID为什么不从1开始呢?因为我在前面测试的时候进行过添加删除等操作，数据库后台的ID自增了，想从1重新开始的话要重启数据库。

感谢你看到这里，希望对你有一丢丢的帮助！

发表评论

表情：
评论列表 （有 0 条评论，434人围观）

还没有评论，来说两句吧...

相关阅读