码迷,mamicode.com
首页 > Web开发 > 详细

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

时间:2015-09-04 17:08:15      阅读:176      评论:0      收藏:0      [点我收藏+]

标签:

 

1.1 问题

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

1.2 方案

Hibernate使用步骤:

  1. 导入Hibernate包,以及数据库驱动包。
  2. 引入Hibernate主配置文件hibernate.cfg.xml。
  3. 创建实体类。
  4. 创建映射关系文件。
  5. 使用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: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>


    </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

 

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

标签:

原文地址:http://www.cnblogs.com/liuhongfeng/p/4781835.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!