博客

如何使用Java持久化框架？

  • Post category:Java

下面是完整的使用Java持久化框架的攻略。

什么是Java持久化框架？

Java持久化框架是一组API和标准，用于将Java对象存储在数据库中，从而实现数据持久化。Java持久化框架通常包括以下方面：
– 对象关系映射（ORM）：Java对象和数据库表之间的映射关系。
– 数据库访问API：用于执行对数据库的操作，如查询、插入、更新和删除等。
– 事务管理：用于管理在数据库事务期间执行的操作。
– 数据库连接的池化：用于优化对数据库的连接和资源使用。

Java持久化框架的类型

Java持久化框架通常分为两种类型：
– 面向关系型数据库的持久化框架，如Hibernate, MyBatis。
– 面向非关系型数据库的持久化框架，如MongoDB Java Driver。

使用Hibernate持久化框架的过程

下面以Hibernate作为例子，介绍如何使用Java持久化框架。

步骤1：引入Hibernate库

在Maven项目中，在pom.xml文件中加入Hibernate的依赖库。

<dependency>
   <groupId>org.hibernate</groupId>
   <artifactId>hibernate-core</artifactId>
   <version>5.5.7.Final</version>
</dependency>

步骤2：配置Hibernate

在项目的资源文件夹中，创建hibernate.cfg.xml文件，并在文件中配置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="hibernate.connection.driver_class">com.mysql.cj.jdbc.Driver</property>
    <property name="hibernate.connection.url">jdbc:mysql://localhost:3306/test</property>
    <property name="hibernate.connection.username">root</property>
    <property name="hibernate.connection.password">password</property>
    <property name="hibernate.dialect">org.hibernate.dialect.MySQL8Dialect</property>
    <property name="show_sql">true</property>
  </session-factory>
</hibernate-configuration>

其中，hibernate.connection.url填写具体的数据库连接地址，hibernate.connection.username和hibernate.connection.password填写数据库的用户名和密码。

步骤3：创建实体类

在Java中创建一个与数据库表映射的实体类，如下所示：

import javax.persistence.*;

@Entity
@Table(name = "users")
public class User {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private int id;
    private String name;
    private int age;
    // getter、setter省略
}

其中，@Entity表示这个类是一个实体类，@Table定义了实体类对应的数据库表名，@Id表示这个属性是表的主键，@GeneratedValue表示这个主键是自动生成的。

步骤4：定义Hibernate的持久层接口和实现

定义一个Hibernate的持久层接口和实现类。

public interface UserDao {
    void save(User user);
}

public class UserDaoImpl implements UserDao {
    private SessionFactory sessionFactory;

    public void setSessionFactory(SessionFactory sessionFactory) {
        this.sessionFactory = sessionFactory;
    }

    public void save(User user) {
        Session session = sessionFactory.getCurrentSession();
        session.save(user);
    }
}

其中，UserDao是持久层接口，UserDaoImpl是实现类。setSessionFactory方法用于注入SessionFactory属性。在save方法中，我们使用org.hibernate.Session对象执行数据库操作。

步骤5：使用Hibernate进行数据库操作

可以通过以下步骤调用Hibernate持久层：

ApplicationContext ctx = new ClassPathXmlApplicationContext("applicationContext.xml");
UserDao userDao = ctx.getBean(UserDao.class);

User user = new User();
user.setName("Tom");
user.setAge(20);
userDao.save(user);

上述代码中，首先创建ApplicationContext对象，并传入spring的配置文件路径，然后从容器中获取UserDao对象。接着，我们创建一个User对象，并设置它的属性。最后，我们调用save方法将User对象保存到数据库中。

示例1：使用Hibernate查询操作

下面以Hibernate的查询操作为例，展示如何使用Java持久化框架。

步骤1：配置UserDao接口和实现类

定义两个方法：查询所有用户和根据用户ID查询用户。

public interface UserDao {
    void save(User user);
    List<User> findAllUsers();
    User findUserById(int id);
}

public class UserDaoImpl implements UserDao {
    private SessionFactory sessionFactory;

    public void setSessionFactory(SessionFactory sessionFactory) {
        this.sessionFactory = sessionFactory;
    }

    public void save(User user) {
        Session session = sessionFactory.getCurrentSession();
        session.save(user);
    }

    public List<User> findAllUsers() {
        Session session = sessionFactory.getCurrentSession();
        List<User> users = session.createQuery("from User").list();
        return users;
    }

    public User findUserById(int id) {
        Session session = sessionFactory.getCurrentSession();
        User user = (User) session.get(User.class, id);
        return user;
    }
}

在UserDaoImpl的实现类中，我们通过Session对象执行Hibernate操作。findAllUsers方法通过Hibernate HQL语句from User查询所有用户，findUserById方法通过Hibernate的get方法根据ID查询用户。

步骤2：测试

下面是测试代码：

ApplicationContext ctx = new ClassPathXmlApplicationContext("applicationContext.xml");
UserDao userDao = ctx.getBean(UserDao.class);

// 保存用户
User user = new User();
user.setName("Tom");
user.setAge(20);
userDao.save(user);

// 查询所有用户
List<User> users = userDao.findAllUsers();
System.out.println("查询所有用户：");
for(User u : users) {
    System.out.println(u.getName());
}

// 根据ID查询用户
User u = userDao.findUserById(1);
System.out.println("id为1的用户是：" + u.getName());

在测试代码中，我们先创建了User对象，并保存到数据库。接着，我们使用findAllUsers方法查询所有用户，并打印出他们的名字。最后，我们使用findUserById方法根据用户ID查询用户，并打印出他的名字。

示例2：使用Hibernate事务管理

下面以Hibernate的事务管理为例，展示如何使用Java持久化框架进行事务操作。

步骤1：配置UserDao接口和实现

新建User实体类和UserDao接口，添加save方法，用于插入一个新用户。

public interface UserDao {
    void save(User user);
}

public class UserDaoImpl implements UserDao {
    private SessionFactory sessionFactory;

    public void setSessionFactory(SessionFactory sessionFactory) {
        this.sessionFactory = sessionFactory;
    }

    public void save(User user) {
        Session session = sessionFactory.getCurrentSession();
        session.save(user);
    }
}

在UserDaoImpl中，我们通过getCurrentSession获取了当前线程的会话对象Session，Hibernate会话是线程相关的，可以看作是一系列持久化操作的一个单元。在save方法中，我们将User对象保存到数据库中。

步骤2：测试事务

下面是测试代码：

ApplicationContext ctx = new ClassPathXmlApplicationContext("applicationContext.xml");
UserDao userDao = ctx.getBean(UserDao.class);

TransactionManager transactionManager = ctx.getBean(TransactionManager.class);

TransactionStatus status = transactionManager.getTransaction(new DefaultTransactionDefinition());

try {
    User user = new User();
    user.setName("Jim");
    user.setAge(25);
    userDao.save(user);
    //另一个操作
    //...
    transactionManager.commit(status);
} catch (Exception e) {
    transactionManager.rollback(status);
}

在测试中，我们从Spring应用程序上下文中获取了UserDao和TransactionManager，并创建了一个事务。在事务中，我们插入新用户，并执行其他操作。如果在事务中抛出了异常，则我们使用TransactionManager执行回滚操作。

总结

无论采用什么样的Java持久化框架，基本的使用流程都是这样的：引入框架库，配置框架，编写模型（即实体类），定义持久层接口和实现类，并通过持久层接口调用方法执行数据库操作。此外，对于复杂的数据库操作，我们还可以选择使用事务来管理操作。

至此，完整的使用Java持久化框架的攻略介绍完毕。

Tags: