Spring Boot JPA中实体类动态使用模式名和表名的正确方法

你的尝试是不正确的，原因是：Spring Data JPA的原生查询中，命名参数（:schema、:table）只能用于替换SQL中的值，无法用来替换表名、Schema这类SQL标识符。框架会把这些参数处理成带引号的字符串，最终生成的SQL会是类似SELECT * FROM 'my_schema'.'my_table' WHERE ...的格式，这会直接导致SQL语法错误。

正确实现方式 #

方案1：使用EntityManager手动拼接查询 #

这是最稳妥的方式，适合需要动态指定Schema和表名的场景，同时可以严格控制SQL注入风险。

首先定义自定义仓库接口：

public interface PaymentRepositoryCustom {
    PaymentTable getPaymentDetails(String schema, String table, String billerNumber);
}

然后让主仓库接口继承这个自定义接口：

public interface PaymentRepository extends JpaRepository<PaymentTable, String>, PaymentRepositoryCustom {
}

实现自定义接口的逻辑：

@Repository
public class PaymentRepositoryImpl implements PaymentRepositoryCustom {

    @PersistenceContext
    private EntityManager entityManager;

    @Override
    public PaymentTable getPaymentDetails(String schema, String table, String billerNumber) {
        // 注意：必须对schema和table参数做严格校验，比如限制为预定义的合法值，避免SQL注入
        String sql = String.format("SELECT * FROM %s.%s WHERE STATUS='S' AND BILLER_NUMBER=?", schema, table);
        
        Query query = entityManager.createNativeQuery(sql, PaymentTable.class);
        query.setParameter(1, billerNumber);
        
        // 若查询结果可能为空，建议用getResultList()后判断，避免NoResultException
        List<PaymentTable> result = query.getResultList();
        return result.isEmpty() ? null : result.get(0);
    }
}

方案2：使用Spring Data JPA的SpEL表达式（Spring Data JPA 2.4+） #

如果你的Spring Data JPA版本在2.4及以上，可以用SpEL表达式直接在@Query中动态替换Schema和表名：

public interface PaymentRepository extends JpaRepository<PaymentTable, String> {
    @Query(value = "SELECT * FROM #{#schema}.#{#table} WHERE STATUS='S' AND BILLER_NUMBER=:billernumber", nativeQuery = true)
    PaymentTable getPaymentDetailsWithStatusAndBillerNumber(
            @Param("schema") String schema, 
            @Param("table") String table, 
            @Param("billernumber") String billernumber
    );
}

注意：这种方式本质是直接拼接SQL，必须对schema和table参数做严格校验，禁止传入用户可控的未校验值，否则会存在严重的SQL注入风险。

实体类补充说明 #

你的实体类定义是可行的，因为所有支付表结构一致，JPA可以将原生查询的结果映射到同一个PaymentTable实体。不需要给@Table注解指定固定表名，因为我们通过动态SQL指定了目标表。

内容的提问来源于stack exchange，提问作者Hashini Udara