Hibernate的CRUD以及junit测试

Hibernate的CRUD以及junit测试

1:第一步创建动态工程引包,省略。

2:第二步,创建数据库和数据表,省略。

3:第三步,创建实体类,如User.java,源码如下所示:

  对于实体类,一般实现构造方法,而构造方法一般实现三个:

    一个无参构造方法;

    一个有参的构造方法;

    一个不带id的构造方法;

 1 package com.bie.po;
 2 /** 
 3 * @author BieHongLi 
 4 * @version 创建时间:2017年3月8日 下午5:17:23 
 5 * 
 6 */
 7 public class User {
 8 
 9     private int id;
10     private String name;
11     private String password;
12     private String email;
13     private String phone;
14     public int getId() {
15         return id;
16     }
17     public void setId(int id) {
18         this.id = id;
19     }
20     public String getName() {
21         return name;
22     }
23     public void setName(String name) {
24         this.name = name;
25     }
26     public String getEmail() {
27         return email;
28     }
29     public void setEmail(String email) {
30         this.email = email;
31     }
32     public String getPhone() {
33         return phone;
34     }
35     public void setPhone(String phone) {
36         this.phone = phone;
37     }
38     public String getPassword() {
39         return password;
40     }
41     public void setPassword(String password) {
42         this.password = password;
43     }
44     @Override
45     public String toString() {
46         return "User [id=" + id + ", name=" + name + ", password=" + password + ", email=" + email + ", phone=" + phone
47                 + "]";
48     }
49     public User(String name, String password, String email, String phone) {
50         super();
51         this.name = name;
52         this.password = password;
53         this.email = email;
54         this.phone = phone;
55     }
56     public User(int id, String name, String password, String email, String phone) {
57         super();
58         this.id = id;
59         this.name = name;
60         this.password = password;
61         this.email = email;
62         this.phone = phone;
63     }
64     public User() {
65         super();
66     }
67     
68     
69 }

4:配置数据表和实体类之间的映射,起名如实体类.hbm.xml,源码如下所示:

 1 <?xml version="1.0"?>
 2 <!DOCTYPE hibernate-mapping PUBLIC 
 3     "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
 4     "http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">
 5     
 6 <hibernate-mapping package="com.bie.po"> 
 7     <!-- 操作条件:
 8         1:对象与表
 9         2:属性与字段的对应
10         3:类型的对应,类型默认采用属性的类型,type不写的话
11      -->
12     <class name="User" table="user">
13         <!-- 主键,映射 -->
14         <id name="id" column="id">
15             <generator class="native"></generator>
16         </id>
17         
18         <!-- 非主键,映射 -->
19         <property name="name" column="name"></property>
20         <property name="password" column="password"></property>
21         <property name="email" column="email"></property>
22         <property name="phone" column="phone"></property>
23         
24         
25     </class>
26 
27 </hibernate-mapping>

5:完成实体类和数据表之间的配置,就开始配置数据库连接和加载映射,hibernate,cfg.xml

 1 <!DOCTYPE hibernate-configuration PUBLIC
 2     "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
 3     "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">
 4 
 5 <hibernate-configuration>
 6     <session-factory>
 7         <!-- 
 8             1:数据连接配置
 9             2:加载所有的映射(*.hbm.xml)
10          -->
11          
12          <!-- 1:数据连接配置 -->
13          <property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
14          <property name="hibernate.connection.url">jdbc:mysql:///test</property>
15          <property name="hibernate.connection.username">root</property>
16          <property name="hibernate.connection.password">123456</property>
17          <!-- mysql数据库的方言 -->
18          <property name="hibernate.dialect">org.hibernate.dialect.MySQLDialect</property>
19          
20          <property name="hibernate.show_sql">true</property>
21          
22          <!-- 2:加载所有的映射(*.hbm.xml) -->
23          <mapping resource="com/bie/po/User.hbm.xml"/>
24          
25     </session-factory>
26 </hibernate-configuration>

6:提取工具类HibernateUtils.java,简化开发:

 1 package com.bie.utils;
 2 
 3 import org.hibernate.Session;
 4 import org.hibernate.SessionFactory;
 5 import org.hibernate.cfg.Configuration;
 6 
 7 /** 
 8 * @author BieHongLi 
 9 * @version 创建时间:2017年3月10日 下午1:47:55 
10 * 创建工具类
11 */
12 public class HibernateUtils {
13 
14     private static SessionFactory sf;
15     static{
16         //加载主配置文件,并且创建session的工厂
17         sf=new Configuration().configure().buildSessionFactory();
18     }
19     
20     //创建session对象
21     public static Session getSession(){
22         return sf.openSession();
23     }
24 }

7:最后完成Dao层的替换,由之前使用的基本的Connection创建连接替换成为session创建连接;

  首先创建接口再实现接口;

  注意:

     更新的时候,索引是从0开始的,不是从1开始的,切记;

 1 package com.bie.dao;
 2 
 3 import java.util.List;
 4 
 5 import com.bie.po.User;
 6 
 7 /** 
 8 * @author BieHongLi 
 9 * @version 创建时间:2017年3月10日 下午1:35:14 
10 * 
11 */
12 public interface UserDao {
13 
14     /***
15      * 用户信息保存的方法
16      * @param user
17      */
18     public void insertUser(User user);
19     
20     
21     /***
22      * 用户信息更改的方法
23      * @param user
24      */
25     public void updateUser(User user);
26     
27     
28     /***
29      * 根据用户的编号用户信息查询的方法
30      * @param id
31      * @return
32      */
33     public User selectUserId(int id);
34     
35     
36     /**
37      * 用户查询所有的信息
38      * @return
39      */
40     public List<User> selectAll();
41     
42     /***
43      * 
44      * @param name
45      * @return
46      */
47     public List<User> selectAll(String name);
48     
49     /***
50      * 分页查询的方法
51      * @param index
52      * @param count
53      * @return
54      */
55     public List<User> selectPage(int index,int count);
56     
57     /***
58      * 删除的方法
59      * @param id
60      */
61     public void deleteUser(int id);
62 }
  1 package com.bie.dao.impl;
  2 
  3 import java.util.List;
  4 
  5 import org.hibernate.Query;
  6 import org.hibernate.Session;
  7 import org.hibernate.Transaction;
  8 
  9 import com.bie.dao.UserDao;
 10 import com.bie.po.User;
 11 import com.bie.utils.HibernateUtils;
 12 
 13 /** 
 14 * @author BieHongLi 
 15 * @version 创建时间:2017年3月10日 下午1:35:27 
 16 * 
 17 */
 18 public class UserDaoImpl implements UserDao{
 19 
 20     @Override
 21     public void insertUser(User user) {
 22         Session session=null;
 23         Transaction tx=null;
 24         try {
 25             //获取session
 26             session=HibernateUtils.getSession();
 27             //开启事务
 28             tx=session.beginTransaction();
 29             //插入即保存
 30             session.save(user);
 31         } catch (Exception e) {
 32             throw new RuntimeException(e);
 33         }finally{
 34             //提交事务
 35             tx.commit();
 36             //关闭session
 37             session.close();
 38         }
 39         
 40     }
 41 
 42     @Override
 43     public void updateUser(User user) {
 44         Session session=null;
 45         Transaction tx=null;
 46         try {
 47             session=HibernateUtils.getSession();
 48             tx=session.beginTransaction();
 49             session.update(user);
 50         } catch (Exception e) {
 51             throw new RuntimeException(e);
 52         }finally{
 53             //提交事务
 54             tx.commit();
 55             //关闭事务
 56             session.close();
 57         }
 58         
 59     }
 60 
 61     @Override
 62     public User selectUserId(int id) {
 63         //获取session
 64         Session session=null;
 65         //事务
 66         Transaction tx=null;
 67         try {
 68             //获取session
 69             session=HibernateUtils.getSession();
 70             //开启事务
 71             tx=session.beginTransaction();
 72             
 73             return (User)session.get(User.class, id);
 74         } catch (Exception e) {
 75             throw new RuntimeException(e);
 76         }finally{
 77             //提交事务
 78             tx.commit();
 79             //关闭session
 80             session.close();
 81         }
 82     }
 83 
 84     @Override
 85     public List<User> selectAll() {
 86         //session
 87         Session session=null;
 88         //事务
 89         Transaction tx=null;
 90         try {
 91             //获取session
 92             session=HibernateUtils.getSession();
 93             //开启事务
 94             tx=session.beginTransaction();
 95             //HQL语句
 96             Query q=session.createQuery("from User");
 97             
 98             List<User> list=q.list();
 99             return list;
100         } catch (Exception e) {
101             throw new RuntimeException(e);
102         }finally{
103             //提交事务
104             tx.commit();
105             //关闭session
106             session.close();
107         }
108     }
109 
110     @Override
111     public List<User> selectAll(String name) {
112         //session
113         Session session=null;
114         //事务
115         Transaction tx=null;
116         try {
117             //获取session
118             session=HibernateUtils.getSession();
119             //开启事务
120             tx=session.beginTransaction();
121             //HQL语句
122             Query q = session.createQuery("from User user where user.name=? ");
123             //注意:参数索引从0开始
124             q.setString(0, name);
125             
126             return q.list();
127         } catch (Exception e) {
128             throw new RuntimeException();
129         }finally{
130             //提交事务
131             tx.commit();
132             //关闭session
133             session.close();
134         }
135     }
136 
137     @Override
138     public List<User> selectPage(int index, int count) {
139         //session
140         Session session=null;
141         //事务
142         Transaction tx=null;
143         try {
144             //获取session
145             session=HibernateUtils.getSession();
146             //开启事务
147             tx=session.beginTransaction();
148             //HQL查询
149             Query q = session.createQuery("from User ");
150             //设置分页参数
151             q.setFirstResult(index);//查询起始行
152             q.setMaxResults(count);//查询返回的行数
153             
154             return q.list();
155         } catch (Exception e) {
156             throw new RuntimeException();
157         }finally{
158             //提交事务
159             tx.commit();
160             //关闭session
161             session.close();
162         }
163     }
164 
165     @Override
166     public void deleteUser(int id) {
167         Session session=null;
168         Transaction tx=null;
169         try {
170             session=HibernateUtils.getSession();
171             tx=session.beginTransaction();
172             //先根据id查询出用户的信息再删除
173             Object obj=session.get(User.class, id);
174             if(obj!=null){
175                 session.delete(obj);
176             }
177         } catch (Exception e) {
178             throw new RuntimeException();
179         }finally{
180             //提交事务
181             tx.commit();
182             //关闭session
183             session.close();
184         }
185     }
186 
187     
188 }

8:最后一步,完成测试。源码如下所示:

 1 package com.bie.test;
 2 
 3 import java.util.List;
 4 
 5 import org.junit.Test;
 6 
 7 import com.bie.dao.UserDao;
 8 import com.bie.dao.impl.UserDaoImpl;
 9 import com.bie.po.User;
10 
11 /** 
12 * @author BieHongLi 
13 * @version 创建时间:2017年3月10日 下午2:34:48 
14 * 
15 */
16 public class UserCRUD {
17 
18     private UserDao dao=new UserDaoImpl();
19     
20     @Test
21     public void insertUser(){
22         dao.insertUser(new User("曹操","111","111111","111111@163.com"));
23         
24     }
25     
26     @Test
27     public void updateUser(){
28         User user=new User();
29         user.setId(1);
30         user.setName("刘备222");
31         
32         dao.updateUser(user);
33     }
34     
35     @Test
36     public void deleteUser(){
37         dao.deleteUser(30);
38     }
39     
40     @Test
41     public void selectUserId(){
42         //根据用户的编号进行查询
43         User user=dao.selectUserId(1);
44         System.out.println(user);
45     }
46     
47     @Test
48     public void selectUser(){
49         //查询用户的所有信息
50         List<User> list = dao.selectAll();
51         System.out.println(list);
52     }
53     
54     @Test
55     public void selectUserName(){
56         //根据用户姓名查询信息
57         List<User> list=dao.selectAll("李四");
58         System.out.println(list);
59     }
60     
61     @Test
62     public void selectPage(){
63         //分页查询,第一个参数是起始行,第二个参数是每页的个数
64         List<User> list=dao.selectPage(0, 5);
65         System.out.println(list);
66     }
67 }

运行效果如下所示:

路在远方,人丑就该多码Coding!!!

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏菩提树下的杨过

mybatis3.2.8 与 hibernate4.3.6 混用

mybatis、hibernate这二个框架各有特色,对于复杂的查询,利用mybatis直接手写sql控制起来更灵活,而一般的insert/update,hib...

1796
来自专栏Hongten

Hibernate的性能优化之 dynamic-update dynamic-insert

public class Guestbook implements java.io.Serializable {

662
来自专栏lgp20151222

Struts+Hibernate+jsp页面,实现分页

822
来自专栏帅小子的日常

redis和spring集成

33713
来自专栏Java3y

Spring【依赖注入】就是这么简单

前言 在Spring的第二篇中主要讲解了Spring Core模块的使用IOC容器创建对象的问题,Spring Core模块主要是解决对象的创建和对象之间的依赖...

3425
来自专栏Hongten

spring开发_spring+hibernate

http://www.cnblogs.com/hongten/gallery/image/112469.html

833
来自专栏androidBlog

关于RecyclerView的Adapter的notifyItemInserted()的一些分析

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/gdutxiaoxu/article/details/...

941
来自专栏Hongten

Hibernate的二级缓存 下

import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hi...

501
来自专栏Danny的专栏

【SSH快速进阶】——Spring IOC容器注入的几种方式

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/huyuyang6688/article/...

963
来自专栏别先生

c3p0和QueryRunner的结合使用,让开发更加简便

1:DBUtils中的QueryRunner的使用:   1.1:QueryRunner中提供了对SQL语句操作的api;   1.2:主要有三个方法:    ...

3458

扫码关注云+社区