使用 Spring Boot 执行原生 SQL 查询-java教程-PHP中文网

使用 Spring Boot 执行原生 SQL 查询

霞舞

发布： 2025-07-14 18:20:12

原创

749人浏览过

使用 spring boot 执行原生 sql 查询

本文档旨在指导开发者如何在 Java Spring Boot 项目中的任何类中执行原生 SQL 查询。我们将重点解决 TransactionRequiredException 异常，并提供正确的代码示例，确保在数据库操作中实现事务管理。通过本文，你将学会如何利用 EntityManager 执行原生 SQL，并避免常见的错误。

使用 EntityManager 执行原生 SQL 查询

在 Spring Boot 项目中，EntityManager 是执行原生 SQL 查询的关键接口。它允许你直接与数据库交互，执行诸如 DROP TABLE 这样的操作。下面将详细介绍如何正确地使用 EntityManager。

1. 注入 EntityManager

首先，确保你的类中注入了 EntityManager。Spring Boot 会自动管理 EntityManager 的实例。

import javax.persistence.EntityManager;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;

@Service
@RequiredArgsConstructor
public class MyService {

    private final EntityManager entityManager;

    // ...
}

登录后复制

2. 构建 SQL 查询字符串

接下来，构建你需要执行的 SQL 查询字符串。请注意，直接拼接字符串可能存在 SQL 注入的风险，但在某些情况下，例如删除表时，这可能是必要的。

String tableName = "your_table_name";
String query = "DROP TABLE " + tableName;

登录后复制

3. 执行原生 SQL 查询

使用 entityManager.createNativeQuery(query) 创建一个原生查询，然后调用 executeUpdate() 执行该查询。

蓝心千询

蓝心千询是vivo推出的一个多功能AI智能助手

查看详情

entityManager.createNativeQuery(query).executeUpdate();

登录后复制

4. 事务管理

为了确保数据的一致性，需要在事务中执行数据库操作。使用 @Transactional 注解可以方便地管理事务。

import org.springframework.transaction.annotation.Transactional;
import javax.persistence.EntityManager;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;

@Service
@RequiredArgsConstructor
public class MyService {

    private final EntityManager entityManager;

    @Transactional
    public void dropTable(String tableName) {
        String query = "DROP TABLE " + tableName;
        entityManager.createNativeQuery(query).executeUpdate();
    }
}

登录后复制

解决 TransactionRequiredException 异常

TransactionRequiredException 异常通常发生在尝试在没有事务的情况下执行数据库更新或删除操作时。要解决这个问题，请确保以下几点：

使用 @Transactional 注解: 将需要执行数据库操作的方法标记为 @Transactional。
事务传播行为: 检查事务的传播行为。默认情况下，Spring 使用 REQUIRED 传播行为，这意味着如果当前没有事务，则创建一个新事务；如果当前存在事务，则加入该事务。

完整示例

以下是一个完整的示例，展示了如何在 Spring Boot 项目中执行 DROP TABLE 操作。

package com.example.demo;

import javax.persistence.EntityManager;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
@RequiredArgsConstructor
@Slf4j
public class DatabaseService {

    private final EntityManager entityManager;

    @Transactional
    public void dropTable(String tableName) {
        try {
            String query = "DROP TABLE IF EXISTS " + tableName;
            entityManager.createNativeQuery(query).executeUpdate();
            log.info("Table {} dropped successfully.", tableName);
        } catch (Exception e) {
            log.error("Error dropping table {}: {}", tableName, e.getMessage());
            throw e; // Re-throw the exception to rollback the transaction
        }
    }
}

登录后复制

注意事项：