Hibernate案例-------基于xml配置，使用Hibernate实现对员工表的增、删、改、查功能

1.1 问题

使用Hibernate实现对员工表的增、删、改、查。

1.2 方案

Hibernate使用步骤：

导入Hibernate包，以及数据库驱动包。
引入Hibernate主配置文件hibernate.cfg.xml。
创建实体类。
创建映射关系文件。
使用Hibernate常用API执行增删改查操作。

1.3 步骤

实现此案例需要按照如下步骤进行。

环境为：myeclipse 6.5 ，mysql 5.0 ，Hibernate 3 。

步骤一：准备工作创建员工表EMP，建表语句如下：

CREATE TABLE `emp` (
  `ID` INT(4) NOT NULL AUTO_INCREMENT,
  `NAME` VARCHAR(50) NOT NULL,
  `AGE` INT(11) DEFAULT NULL,
  `SALARY` DOUBLE(7,2) DEFAULT NULL,
  `MARRY` CHAR(1) DEFAULT NULL,
  `BIRTHDAY` DATE DEFAULT NULL,
  `LAST_LOGIN_TIME` DATE DEFAULT NULL,
  PRIMARY KEY (`ID`)
) ENGINE=INNODB DEFAULT CHARSET=utf8

创建一个WEB项目，名为Hibernate。

步骤二：导入Hibernate开发包，以及数据库驱动包，完成后项目的包结构如下图：

网盘下载jar包： http://yunpan.cn/cmRG5gzdMtGMX 访问密码 3747

步骤三：引入Hibernate主配置文件

将Hibernate主配置文件hibernate.cfg.xml复制到项目中，放在src根路径下。并在主配置文件中配置好数据库连接信息，以及Hibernate框架参数，代码如下：

<?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.url">jdbc:mysql://localhost:3306/souvc</property>
        <property name="connection.username">root</property>
        <property name="connection.password">123456</property>
        <property name="connection.driver_class">com.mysql.jdbc.Driver</property>

        <!-- Hibernate配置信息 -->
        <!-- dialect方言，用于配置生成针对哪个数据库的SQL语句 -->
        <property name="dialect">
            <!-- 方言类，Hibernate提供的，用于封装某种特定数据库的方言 -->
            <!-- org.hibernate.dialect.OracleDialect -->
            org.hibernate.dialect.MySQLDialect
        </property>
        <!-- Hibernate生成的SQL是否输出到控制台 -->
        <property name="show_sql">true</property>
        <!-- 将SQL输出时是否格式化 -->
        <property name="format_sql">true</property>


    </session-factory>
</hibernate-configuration>

步骤四：创建实体类

创建包com.souvc.entity，并在该包下创建员工表对应的实体类Emp.java，用于封装员工表的数据，代码如下：

package comsouvc.entity;

import java.sql.Date;
import java.sql.Timestamp;

public class Emp {
    private Integer id;
    private String name;
    private Integer age;
    private Double salary;
    private Boolean marry;
    private Date birthday;
    private Timestamp lastLoginTime;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getAge() {
        return age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }

    public Double getSalary() {
        return salary;
    }

    public void setSalary(Double salary) {
        this.salary = salary;
    }

    public Boolean getMarry() {
        return marry;
    }

    public void setMarry(Boolean marry) {
        this.marry = marry;
    }

    public Date getBirthday() {
        return birthday;
    }

    public void setBirthday(Date birthday) {
        this.birthday = birthday;
    }

    public Timestamp getLastLoginTime() {
        return lastLoginTime;
    }

    public void setLastLoginTime(Timestamp lastLoginTime) {
        this.lastLoginTime = lastLoginTime;
    }
}

步骤五：创建映射关系文件

在com.souvc.entity包下，创建员工实体类的映射关系文件，名为Emp.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>
    <!-- 配置实体类和表的关系 -->
    <class name="com.souvc.entity.Emp" table="emp">
        <!-- 配置主键属性和字段的关系 -->
        <id name="id" type="java.lang.Integer" column="id">
            <!-- 用来指明主键的生成方式 -->
            <!-- 
            <generator class="sequence">
                <param name="sequence">emp_seq</param>
            </generator>
            -->
            <generator class="native">
            </generator>
        </id>

        <!-- 配置实体类中属性与表中字段的关系 -->
        <property name="name" type="java.lang.String" column="name" />
        <property name="age" type="java.lang.Integer" column="age" />
        <property name="salary" type="java.lang.Double" column="salary" />
        <property name="birthday" type="java.sql.Date"
            column="birthday" />
        <property name="lastLoginTime" type="java.sql.Timestamp"
            column="last_login_time" />
    </class>
</hibernate-mapping>

步骤六：声明映射关系文件

在主配置文件hibernate.cfg.xml中，声明映射关系文件Emp.hbm.xml，代码如下：

<!-- 声明映射关系文件 -->
        <mapping resource="com/souvc/entity/Emp.hbm.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.url">
            jdbc:oracle:thin:@localhost:1521:xe
        </property>
        <property name="connection.username">lhh</property>
        <property name="connection.password">123456</property>
        <property name="connection.driver_class">
            oracle.jdbc.OracleDriver
        </property>
        -->      
            
        <property name="connection.url">jdbc:mysql://localhost:3306/souvc</property>
        <property name="connection.username">root</property>
        <property name="connection.password">123456</property>
        <property name="connection.driver_class">com.mysql.jdbc.Driver</property>

        <!-- Hibernate配置信息 -->
        <!-- dialect方言，用于配置生成针对哪个数据库的SQL语句 -->
        <property name="dialect">
            <!-- 方言类，Hibernate提供的，用于封装某种特定数据库的方言 -->
            <!-- org.hibernate.dialect.OracleDialect -->
            org.hibernate.dialect.MySQLDialect
        </property>
        <!-- Hibernate生成的SQL是否输出到控制台 -->
        <property name="show_sql">true</property>
        <!-- 将SQL输出时是否格式化 -->
        <property name="format_sql">true</property>


        <!-- 声明映射关系文件 -->
        <mapping resource="com/souvc/entity/Emp.hbm.xml" />
        
        
    </session-factory>
</hibernate-configuration>

步骤七：创建Session工具类

创建HibernateUtil工具类，用于创建Session对象，代码如下：

package com.souvc.util;

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

public class HibernateUtil {
    private static SessionFactory sessionFactory;

    static {
        // 加载Hibernate主配置文件
        Configuration conf = new Configuration();
        conf.configure("/hibernate.cfg.xml");
        sessionFactory = conf.buildSessionFactory();
    }

    /**
     * 创建session
     */
    public static Session getSession() {
        return sessionFactory.openSession();
    }

    public static void main(String[] args) {
        System.out.println(getSession());
    }
}

输出效果：

SessionImpl(PersistenceContext[entityKeys=[],collectionKeys=[]];ActionQueue[insertions=[] updates=[] deletions=[] collectionCreations=[] collectionRemovals=[] collectionUpdates=[]])

步骤八：练习使用Hibernate对员工表进行增删改查

创建包com.souvc.test，并在该包下创建一个JUNIT测试类，并在类中使用Hibernate写出对EMP表的增删改查的方法，代码如下：

package com.souvc.test;

import java.sql.Date;
import java.sql.Timestamp;
import java.util.List;

import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.junit.Test;

import com.souvc.util.HibernateUtil;
import comsouvc.entity.Emp;

/**
 * 演示Hibernate的基本使用
 */
public class TestEmp {
    /**
     * 新增emp
     */
    @Test
    public void add() {
        // 模拟要新增的emp
        Emp e = new Emp();
        e.setName("ggg");
        e.setAge(29);
        e.setMarry(false);
        e.setSalary(8000.00);
        e.setBirthday(Date.valueOf("1983-10-20"));
        e.setLastLoginTime(new Timestamp(System.currentTimeMillis()));
        // 获取session
        Session session = HibernateUtil.getSession();
        // 开启事务
        Transaction ts = session.beginTransaction();
        try {
            // 执行新增
            session.save(e);
            // 提交事务
            ts.commit();
        } catch (HibernateException e1) {
            e1.printStackTrace();
            // 回滚事务
            ts.rollback();
        } finally {
            session.close();
        }
    }

    /**
     * 根据ID查询emp
     */
    @Test
    public void findById() {
        Session session = HibernateUtil.getSession();
        Emp emp = (Emp) session.get(Emp.class, 1);
        System.out.println(emp.getName());
        System.out.println(emp.getBirthday());
        System.out.println(emp.getLastLoginTime());
        session.close();
    }

    /**
     * 修改emp
     */
    @Test
    public void update() {
        Session session = HibernateUtil.getSession();
        // 查询要修改的数据
        Emp emp = (Emp) session.get(Emp.class, 1);
        // 开启事务
        Transaction ts = session.beginTransaction();
        try {
            // 模拟修改数据
            emp.setName("ee");
            emp.setAge(20);
            // 执行修改
            session.update(emp);
            // 提交事务
            ts.commit();
        } catch (HibernateException e) {
            e.printStackTrace();
            // 回滚事务
            ts.rollback();
        } finally {
            // 关闭连接
            session.close();
        }
    }

    /**
     * 删除emp
     */
    @Test
    public void delete() {
        Session session = HibernateUtil.getSession();
        Emp emp = (Emp) session.get(Emp.class, 1);
        Transaction ts = session.beginTransaction();
        try {
            session.delete(emp);
            ts.commit();
        } catch (HibernateException e) {
            e.printStackTrace();
            ts.rollback();
        } finally {
            session.close();
        }
    }

    /**
     * 查询全部emp
     */
    @Test
    public void findAll() {
        String hql = "from Emp";
        Session session = HibernateUtil.getSession();
        Query query = session.createQuery(hql);
        List<Emp> emps = query.list();
        for (Emp e : emps) {
            System.out.println(e.getName());
        }
        session.close();
    }
}

九、实例的效果图如下：

增加：

通过id查询：

查询全部：

更新：

删除：

温馨提示：注意数据库要存在id为1 的数据，才能进行这些数据的操作。根据自己里面的数据来定id。

源码如下： http://yunpan.cn/cmR97XCh6SvB6 访问密码 afb4