超简单！手把手教你用JPA连接数据库，代码示例一网打尽

后端

2023-06-19 10:05:58

使用Java Persistence API (JPA) 畅游数据库世界

在当今以数据为导向的世界中，数据库不再是枯燥乏味的数据存储库。它们是推动现代应用程序的生命线，存储着各种各样的信息，从客户详细信息到交易记录。与这些数据库有效交互是开发人员面临的关键挑战之一。

Java Persistence API (JPA) 的出场

Java Persistence API (JPA) 应运而生，为 Java 开发人员提供了一个强大的工具，用于无缝连接和操作关系数据库。它通过一个标准化接口简化了数据库访问，消除了手动编写繁琐 SQL 查询和管理底层连接的需要。

踏上与 JPA 的连接之旅

要使用 JPA 与数据库建立连接，你需要遵循以下步骤：

1. 引入 JPA 依赖

首先，将 JPA 依赖添加到你的项目中。对于 Maven 用户，在 pom.xml 文件中添加以下内容：

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>

对于 Gradle 用户，在 build.gradle 文件中添加以下内容：

implementation 'org.springframework.boot:spring-boot-starter-data-jpa'

2. 配置数据源

下一步是配置数据源，告诉 JPA 如何连接到你的数据库。在 application.properties 文件中添加以下配置：

spring.jpa.database=postgresql
spring.jpa.host=localhost
spring.jpa.port=5432
spring.jpa.username=postgres
spring.jpa.password=mysecretpassword

请根据你的实际情况修改这些配置。

3. 定义实体类

实体类是 Java 对象，映射到数据库中的表。例如，如果你有一个名为 "users" 的表，你可以创建一个名为 "User" 的实体类：

@Entity
public class User {

  @Id
  @GeneratedValue(strategy = GenerationType.IDENTITY)
  private Long id;

  private String name;

  private String email;

  // getters and setters
}

4. 创建 DAO 接口

DAO（数据访问对象）接口定义了可以对实体类执行的各种操作，例如查找、保存、更新和删除。对于 "User" 实体，DAO 接口将如下所示：

public interface UserDao {

  List<User> findAll();

  User findById(Long id);

  User save(User user);

  void delete(User user);
}

5. 实现 DAO 接口

实现 DAO 接口将包含实际的数据库操作代码。使用 JPA 的 @Repository 注解自动装配 EntityManager：

@Repository
public class UserDaoImpl implements UserDao {

  @Autowired
  private EntityManager entityManager;

  @Override
  public List<User> findAll() {
    return entityManager.createQuery("SELECT u FROM User u", User.class).getResultList();
  }

  @Override
  public User findById(Long id) {
    return entityManager.find(User.class, id);
  }

  @Override
  public User save(User user) {
    entityManager.persist(user);
    return user;
  }

  @Override
  public void delete(User user) {
    entityManager.remove(user);
  }
}

6. 测试连接

最后，通过编写测试来验证你的 JPA 连接是否有效：

@RunWith(SpringRunner.class)
@DataJpaTest
public class UserDaoTests {

  @Autowired
  private UserDao userDao;

  @Test
  public void testFindAll() {
    List<User> users = userDao.findAll();
    assertThat(users).isNotEmpty();
  }

  @Test
  public void testFindById() {
    User user = userDao.findById(1L);
    assertThat(user).isNotNull();
  }

  @Test
  public void testSave() {
    User user = new User();
    user.setName("John Doe");
    user.setEmail("john.doe@example.com");
    User savedUser = userDao.save(user);
    assertThat(savedUser.getId()).isNotNull();
  }

  @Test
  public void testDelete() {
    User user = userDao.findById(1L);
    userDao.delete(user);
    User deletedUser = userDao.findById(1L);
    assertThat(deletedUser).isNull();
  }
}