Hibernate的CRUD以及junit测试

Hibernate的CRUD以及junit测试

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

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

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

　　对于实体类，一般实现构造方法，而构造方法一般实现三个：

　　　　一个无参构造方法；

　　　　一个有参的构造方法；

　　　　一个不带id的构造方法；

package com.bie.po;
/** 
* @author BieHongLi 
* @version 创建时间：2017年3月8日 下午5:17:23 
* 
*/
public class User {

    private int id;
    private String name;
    private String password;
    private String email;
    private String phone;
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getEmail() {
        return email;
    }
    public void setEmail(String email) {
        this.email = email;
    }
    public String getPhone() {
        return phone;
    }
    public void setPhone(String phone) {
        this.phone = phone;
    }
    public String getPassword() {
        return password;
    }
    public void setPassword(String password) {
        this.password = password;
    }
    @Override
    public String toString() {
        return "User [id=" + id + ", name=" + name + ", password=" + password + ", email=" + email + ", phone=" + phone
                + "]";
    }
    public User(String name, String password, String email, String phone) {
        super();
        this.name = name;
        this.password = password;
        this.email = email;
        this.phone = phone;
    }
    public User(int id, String name, String password, String email, String phone) {
        super();
        this.id = id;
        this.name = name;
        this.password = password;
        this.email = email;
        this.phone = phone;
    }
    public User() {
        super();
    }
    
    
}

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

<?xml version="1.0"?>
<!DOCTYPE hibernate-mapping PUBLIC 
    "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
    "http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">
    
<hibernate-mapping package="com.bie.po"> 
    <!-- 操作条件：
        1：对象与表
        2：属性与字段的对应
        3：类型的对应,类型默认采用属性的类型，type不写的话
     -->
    <class name="User" table="user">
        <!-- 主键，映射 -->
        <id name="id" column="id">
            <generator class="native"></generator>
        </id>
        
        <!-- 非主键，映射 -->
        <property name="name" column="name"></property>
        <property name="password" column="password"></property>
        <property name="email" column="email"></property>
        <property name="phone" column="phone"></property>
        
        
    </class>

</hibernate-mapping>

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

<!DOCTYPE hibernate-configuration PUBLIC
    "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
    "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">

<hibernate-configuration>
    <session-factory>
        <!-- 
            1:数据连接配置
            2:加载所有的映射（*.hbm.xml）
         -->
         
         <!-- 1:数据连接配置 -->
         <property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
         <property name="hibernate.connection.url">jdbc:mysql:///test</property>
         <property name="hibernate.connection.username">root</property>
         <property name="hibernate.connection.password">123456</property>
         <!-- mysql数据库的方言 -->
         <property name="hibernate.dialect">org.hibernate.dialect.MySQLDialect</property>
         
         <property name="hibernate.show_sql">true</property>
         
         <!-- 2:加载所有的映射（*.hbm.xml） -->
         <mapping resource="com/bie/po/User.hbm.xml"/>
         
    </session-factory>
</hibernate-configuration>

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

package com.bie.utils;

import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;

/** 
* @author BieHongLi 
* @version 创建时间：2017年3月10日 下午1:47:55 
* 创建工具类
*/
public class HibernateUtils {

    private static SessionFactory sf;
    static{
        //加载主配置文件，并且创建session的工厂
        sf=new Configuration().configure().buildSessionFactory();
    }
    
    //创建session对象
    public static Session getSession(){
        return sf.openSession();
    }
}

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

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

　　注意：

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

package com.bie.dao;

import java.util.List;

import com.bie.po.User;

/** 
* @author BieHongLi 
* @version 创建时间：2017年3月10日 下午1:35:14 
* 
*/
public interface UserDao {

    /***
     * 用户信息保存的方法
     * @param user
     */
    public void insertUser(User user);
    
    
    /***
     * 用户信息更改的方法
     * @param user
     */
    public void updateUser(User user);
    
    
    /***
     * 根据用户的编号用户信息查询的方法
     * @param id
     * @return
     */
    public User selectUserId(int id);
    
    
    /**
     * 用户查询所有的信息
     * @return
     */
    public List<User> selectAll();
    
    /***
     * 
     * @param name
     * @return
     */
    public List<User> selectAll(String name);
    
    /***
     * 分页查询的方法
     * @param index
     * @param count
     * @return
     */
    public List<User> selectPage(int index,int count);
    
    /***
     * 删除的方法
     * @param id
     */
    public void deleteUser(int id);
}

package com.bie.dao.impl;

import java.util.List;

import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;

import com.bie.dao.UserDao;
import com.bie.po.User;
import com.bie.utils.HibernateUtils;

/** 
* @author BieHongLi 
* @version 创建时间：2017年3月10日 下午1:35:27 
* 
*/
public class UserDaoImpl implements UserDao{

    @Override
    public void insertUser(User user) {
        Session session=null;
        Transaction tx=null;
        try {
            //获取session
            session=HibernateUtils.getSession();
            //开启事务
            tx=session.beginTransaction();
            //插入即保存
            session.save(user);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }finally{
            //提交事务
            tx.commit();
            //关闭session
            session.close();
        }
        
    }

    @Override
    public void updateUser(User user) {
        Session session=null;
        Transaction tx=null;
        try {
            session=HibernateUtils.getSession();
            tx=session.beginTransaction();
            session.update(user);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }finally{
            //提交事务
            tx.commit();
            //关闭事务
            session.close();
        }
        
    }

    @Override
    public User selectUserId(int id) {
        //获取session
        Session session=null;
        //事务
        Transaction tx=null;
        try {
            //获取session
            session=HibernateUtils.getSession();
            //开启事务
            tx=session.beginTransaction();
            
            return (User)session.get(User.class, id);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }finally{
            //提交事务
            tx.commit();
            //关闭session
            session.close();
        }
    }

    @Override
    public List<User> selectAll() {
        //session
        Session session=null;
        //事务
        Transaction tx=null;
        try {
            //获取session
            session=HibernateUtils.getSession();
            //开启事务
            tx=session.beginTransaction();
            //HQL语句
            Query q=session.createQuery("from User");
            
            List<User> list=q.list();
            return list;
        } catch (Exception e) {
            throw new RuntimeException(e);
        }finally{
            //提交事务
            tx.commit();
            //关闭session
            session.close();
        }
    }

    @Override
    public List<User> selectAll(String name) {
        //session
        Session session=null;
        //事务
        Transaction tx=null;
        try {
            //获取session
            session=HibernateUtils.getSession();
            //开启事务
            tx=session.beginTransaction();
            //HQL语句
            Query q = session.createQuery("from User user where user.name=? ");
            //注意：参数索引从0开始
            q.setString(0, name);
            
            return q.list();
        } catch (Exception e) {
            throw new RuntimeException();
        }finally{
            //提交事务
            tx.commit();
            //关闭session
            session.close();
        }
    }

    @Override
    public List<User> selectPage(int index, int count) {
        //session
        Session session=null;
        //事务
        Transaction tx=null;
        try {
            //获取session
            session=HibernateUtils.getSession();
            //开启事务
            tx=session.beginTransaction();
            //HQL查询
            Query q = session.createQuery("from User ");
            //设置分页参数
            q.setFirstResult(index);//查询起始行
            q.setMaxResults(count);//查询返回的行数
            
            return q.list();
        } catch (Exception e) {
            throw new RuntimeException();
        }finally{
            //提交事务
            tx.commit();
            //关闭session
            session.close();
        }
    }

    @Override
    public void deleteUser(int id) {
        Session session=null;
        Transaction tx=null;
        try {
            session=HibernateUtils.getSession();
            tx=session.beginTransaction();
            //先根据id查询出用户的信息再删除
            Object obj=session.get(User.class, id);
            if(obj!=null){
                session.delete(obj);
            }
        } catch (Exception e) {
            throw new RuntimeException();
        }finally{
            //提交事务
            tx.commit();
            //关闭session
            session.close();
        }
    }

    
}

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

package com.bie.test;

import java.util.List;

import org.junit.Test;

import com.bie.dao.UserDao;
import com.bie.dao.impl.UserDaoImpl;
import com.bie.po.User;

/** 
* @author BieHongLi 
* @version 创建时间：2017年3月10日 下午2:34:48 
* 
*/
public class UserCRUD {

    private UserDao dao=new UserDaoImpl();
    
    @Test
    public void insertUser(){
        dao.insertUser(new User("曹操","111","111111","111111@163.com"));
        
    }
    
    @Test
    public void updateUser(){
        User user=new User();
        user.setId(1);
        user.setName("刘备222");
        
        dao.updateUser(user);
    }
    
    @Test
    public void deleteUser(){
        dao.deleteUser(30);
    }
    
    @Test
    public void selectUserId(){
        //根据用户的编号进行查询
        User user=dao.selectUserId(1);
        System.out.println(user);
    }
    
    @Test
    public void selectUser(){
        //查询用户的所有信息
        List<User> list = dao.selectAll();
        System.out.println(list);
    }
    
    @Test
    public void selectUserName(){
        //根据用户姓名查询信息
        List<User> list=dao.selectAll("李四");
        System.out.println(list);
    }
    
    @Test
    public void selectPage(){
        //分页查询,第一个参数是起始行，第二个参数是每页的个数
        List<User> list=dao.selectPage(0, 5);
        System.out.println(list);
    }
}

运行效果如下所示：

---

路在远方，人丑就该多码Coding！！！