Hibernate 简明教程

Hibernate - Examples

现在我们举个例子,了解如何使用 Hibernate 在独立的应用程序中提供 Java 持久性。我们将介绍在使用 Hibernate 技术创建 Java 应用程序时涉及到的不同步骤。

Create POJO Classes

创建应用程序的第一步是构建 Java POJO 类或类,具体取决于将持久化到数据库的应用程序。考虑我们的 Employee 类,其方法 getXXXsetXXX 使其成为 JavaBeans 兼容类。

POJO(普通旧 Java 对象)是不扩展或不实现 EJB 框架分别要求的某些专门类和接口的 Java 对象。所有常规 Java 对象都是 POJO。

在设计要由 Hibernate 持久化的类时,重要的是提供 JavaBeans 兼容代码以及一个属性,该属性可像 Employee 类中的 id 属性一样用作索引。

public class Employee {
   private int id;
   private String firstName;
   private String lastName;
   private int salary;

   public Employee() {}
   public Employee(String fname, String lname, int salary) {
      this.firstName = fname;
      this.lastName = lname;
      this.salary = salary;
   }

   public int getId() {
      return id;
   }

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

   public String getFirstName() {
      return firstName;
   }

   public void setFirstName( String first_name ) {
      this.firstName = first_name;
   }

   public String getLastName() {
      return lastName;
   }

   public void setLastName( String last_name ) {
      this.lastName = last_name;
   }

   public int getSalary() {
      return salary;
   }

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

Create Database Tables

第二步是创建数据库中的表。希望提供持久性的每个对象都会对应一个表。考虑需要将以上对象存储和检索到以下 RDBMS 表中 -

create table EMPLOYEE (
   id INT NOT NULL auto_increment,
   first_name VARCHAR(20) default NULL,
   last_name  VARCHAR(20) default NULL,
   salary     INT  default NULL,
   PRIMARY KEY (id)
);

Create Mapping Configuration File

此步骤是创建映射文件,指示 Hibernate 如何将已定义的类或类映射到数据库表。

<?xml version = "1.0" encoding = "utf-8"?>
<!DOCTYPE hibernate-mapping PUBLIC
"-//Hibernate/Hibernate Mapping DTD//EN"
"http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">

<hibernate-mapping>
   <class name = "Employee" table = "EMPLOYEE">

      <meta attribute = "class-description">
         This class contains the employee detail.
      </meta>

      <id name = "id" type = "int" column = "id">
         <generator class="native"/>
      </id>

      <property name = "firstName" column = "first_name" type = "string"/>
      <property name = "lastName" column = "last_name" type = "string"/>
      <property name = "salary" column = "salary" type = "int"/>

   </class>
</hibernate-mapping>

应该以格式 <classname>.hbm.xml 保存映射文档到文件中。我们将映射文档保存到 Employee.hbm.xml 文件中。我们详细了解下映射文档 -

  1. 映射文档是 XML 文档,拥有 <hibernate-mapping> 作为根元素,其中包含所有 <class> 元素。

  2. &lt;class&gt; 元素是用来定义从 Java 类到数据库表间的特定映射。使用 class 元素的 name 属性指定 Java 类名,使用 table 属性指定数据库表名。

  3. &lt;meta&gt; 元素是可选元素,可用来创建类描述。

  4. &lt;id&gt; 元素将类中的唯一 ID 属性映射到数据库表的为主键。id 元素的 name 属性引用类中的属性,而 column 属性引用数据库表中的列。 type 属性保存 Hibernate 映射类型,这些映射类型将从 Java 转换为 SQL 数据类型。

  5. id 元素中的 &lt;generator&gt; 元素用来自动生成主键值。generator 元素的 class 属性被设置为 native ,以便让 Hibernate 选择 identity, sequencehilo 算法来根据底层数据库的功能创建主键。

  6. &lt;property&gt; 元素用来将 Java 类属性映射到数据库表中的一列。element 的 name 属性引用类中的属性,而 column 属性引用数据库表中的列。 type 属性保存 Hibernate 映射类型,这些映射类型将从 Java 转换为 SQL 数据类型。

还有其他可在映射文档中使用的属性和元素,在我讨论其他 Hibernate 相关主题时将尝试涵盖尽可能多的内容。

Create Application Class

最后,我们将使用 main() 方法创建我们的应用程序类来运行应用程序。我们将使用此应用程序来保存一些 Employee 的记录,然后我们将对这些记录应用 CRUD 操作。

import java.util.List;
import java.util.Date;
import java.util.Iterator;

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

public class ManageEmployee {
   private static SessionFactory factory;
   public static void main(String[] args) {

      try {
         factory = new Configuration().configure().buildSessionFactory();
      } catch (Throwable ex) {
         System.err.println("Failed to create sessionFactory object." + ex);
         throw new ExceptionInInitializerError(ex);
      }

      ManageEmployee ME = new ManageEmployee();

      /* Add few employee records in database */
      Integer empID1 = ME.addEmployee("Zara", "Ali", 1000);
      Integer empID2 = ME.addEmployee("Daisy", "Das", 5000);
      Integer empID3 = ME.addEmployee("John", "Paul", 10000);

      /* List down all the employees */
      ME.listEmployees();

      /* Update employee's records */
      ME.updateEmployee(empID1, 5000);

      /* Delete an employee from the database */
      ME.deleteEmployee(empID2);

      /* List down new list of the employees */
      ME.listEmployees();
   }

   /* Method to CREATE an employee in the database */
   public Integer addEmployee(String fname, String lname, int salary){
      Session session = factory.openSession();
      Transaction tx = null;
      Integer employeeID = null;

      try {
         tx = session.beginTransaction();
         Employee employee = new Employee(fname, lname, salary);
         employeeID = (Integer) session.save(employee);
         tx.commit();
      } catch (HibernateException e) {
         if (tx!=null) tx.rollback();
         e.printStackTrace();
      } finally {
         session.close();
      }
      return employeeID;
   }

   /* Method to  READ all the employees */
   public void listEmployees( ){
      Session session = factory.openSession();
      Transaction tx = null;

      try {
         tx = session.beginTransaction();
         List employees = session.createQuery("FROM Employee").list();
         for (Iterator iterator = employees.iterator(); iterator.hasNext();){
            Employee employee = (Employee) iterator.next();
            System.out.print("First Name: " + employee.getFirstName());
            System.out.print("  Last Name: " + employee.getLastName());
            System.out.println("  Salary: " + employee.getSalary());
         }
         tx.commit();
      } catch (HibernateException e) {
         if (tx!=null) tx.rollback();
         e.printStackTrace();
      } finally {
         session.close();
      }
   }

   /* Method to UPDATE salary for an employee */
   public void updateEmployee(Integer EmployeeID, int salary ){
      Session session = factory.openSession();
      Transaction tx = null;

      try {
         tx = session.beginTransaction();
         Employee employee = (Employee)session.get(Employee.class, EmployeeID);
         employee.setSalary( salary );
		 session.update(employee);
         tx.commit();
      } catch (HibernateException e) {
         if (tx!=null) tx.rollback();
         e.printStackTrace();
      } finally {
         session.close();
      }
   }

   /* Method to DELETE an employee from the records */
   public void deleteEmployee(Integer EmployeeID){
      Session session = factory.openSession();
      Transaction tx = null;

      try {
         tx = session.beginTransaction();
         Employee employee = (Employee)session.get(Employee.class, EmployeeID);
         session.delete(employee);
         tx.commit();
      } catch (HibernateException e) {
         if (tx!=null) tx.rollback();
         e.printStackTrace();
      } finally {
         session.close();
      }
   }
}

Compilation and Execution

以下是编译和运行上述应用程序的步骤。请确保在继续编译和执行之前,已适当地设置 PATH 和 CLASSPATH。

  1. 如配置章节中所述,创建 hibernate.cfg.xml 配置文件。

  2. 如上所示创建 Employee.hbm.xml 映射文件。

  3. 创建 Employee.java 源文件(如上所示),并进行编译。

  4. 按上方代码创建一个 ManageEmployee.java 源文件并进行编译。

  5. 执行 ManageEmployee 二进制文件来运行该程序。

Output

您将获得以下结果,并且将在 EMPLOYEE 表中创建记录。

$java ManageEmployee
.......VARIOUS LOG MESSAGES WILL DISPLAY HERE........

First Name: Zara  Last Name: Ali  Salary: 1000
First Name: Daisy  Last Name: Das  Salary: 5000
First Name: John  Last Name: Paul  Salary: 10000
First Name: Zara  Last Name: Ali  Salary: 5000
First Name: John  Last Name: Paul  Salary: 10000

如果检查您的 EMPLOYEE 表,它应包含以下记录 −

mysql> select * from EMPLOYEE;
+----+------------+-----------+--------+
| id | first_name | last_name | salary |
+----+------------+-----------+--------+
| 29 | Zara       | Ali       |   5000 |
| 31 | John       | Paul      |  10000 |
+----+------------+-----------+--------+
2 rows in set (0.00 sec

mysql>