Spring Boot原生查询接口投影CLOB字段报错求助

问题根因 #

该错误源于原生查询绕过了实体类的映射规则：JDBC直接返回java.sql.Clob对象，但接口投影无法自动将Clob代理实例转换为String类型——即便你在实体类上添加@Lob等注解也无效，因为原生查询不会读取实体的映射配置。

有效解决方法 #

方法1：Oracle SQL层面直接转换CLOB为字符串 #

最简洁的方案是利用Oracle内置函数dbms_lob.substr()，在查询阶段就把CLOB字段转成字符串，返回结果直接匹配接口投影的String类型：

@Query(
       value = """
               select submission_id as "submissionId", dbms_lob.substr(text) as "textAnswer"
               from answer
               where answer_id = :answerId
               """,
       nativeQuery = true)
public MyDTO findDTO(Long answerId);

说明：dbms_lob.substr()默认截取前4000字符，若CLOB内容更长，可指定第二个参数扩展长度，例如dbms_lob.substr(text, 20000)。

方法2：类投影+构造器内转换 #

若不想修改SQL，可改用**类投影（DTO类）**替代接口投影，在DTO构造器中直接处理Clob到String的转换：

import java.sql.Clob;
import java.io.BufferedReader;
import java.io.Reader;
import java.util.stream.Collectors;

public class MyDTO {
    private String submissionId;
    private String textAnswer;

    // 构造器接收Clob参数并转换为String
    public MyDTO(String submissionId, Clob textAnswer) {
        this.submissionId = submissionId;
        if (textAnswer == null) {
            this.textAnswer = null;
            return;
        }
        try (Reader reader = textAnswer.getCharacterStream()) {
            this.textAnswer = new BufferedReader(reader).lines().collect(Collectors.joining("\n"));
        } catch (Exception e) {
            throw new RuntimeException("CLOB转String失败", e);
        }
    }

    // getter方法
    public String getTextAnswer() { return textAnswer; }
    public String getSubmissionId() { return submissionId; }
}

仓库查询代码无需修改，Spring Data会自动匹配构造器参数类型，完成转换后返回DTO实例。

方法3：自定义仓库实现 #

若以上方案不适用，可通过自定义仓库实现类手动处理查询结果：

1. 定义仓库主接口：

public interface AnswerRepository extends JpaRepository<Answer, Long>, AnswerRepositoryCustom {
}

2. 定义自定义接口：

public interface AnswerRepositoryCustom {
    MyDTO findDTO(Long answerId);
}

3. 实现自定义逻辑：

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import java.sql.Clob;
import java.io.BufferedReader;
import java.io.Reader;
import java.util.stream.Collectors;

public class AnswerRepositoryCustomImpl implements AnswerRepositoryCustom {

    @PersistenceContext
    private EntityManager entityManager;

    @Override
    public MyDTO findDTO(Long answerId) {
        Object[] result = (Object[]) entityManager.createNativeQuery("""
                select submission_id, text from answer where answer_id = ?
                """)
                .setParameter(1, answerId)
                .getSingleResult();

        String submissionId = (String) result[0];
        Clob textClob = (Clob) result[1];
        String textAnswer = null;
        
        if (textClob != null) {
            try (Reader reader = textClob.getCharacterStream()) {
                textAnswer = new BufferedReader(reader).lines().collect(Collectors.joining("\n"));
            } catch (Exception e) {
                throw new RuntimeException("CLOB转String失败", e);
            }
        }

        return new MyDTO(submissionId, textAnswer);
    }
}

推荐方案 #

优先选择方法1，无需修改Java代码，SQL层面转换更高效，且实现成本最低。

内容的提问来源于stack exchange，提问作者Kaj Hejer