是否可以在 Spring 存储库中使用原始 SQL

Posted 2023-02-26

【中文标题】是否可以在 Spring 存储库中使用原始 SQL

【英文标题】：Is it possible to use raw SQL within a Spring Repository

【发布时间】：2013-04-03 15:34:22

【问题描述】：

我需要在 Spring Data Repository 中使用原始 SQL，这可能吗？我在@Query 周围看到的一切都是基于实体的。

【问题讨论】：

SqlQuery 会做吗？ static.springsource.org/spring/docs/2.5.x/api

如何在存储库中使用它？还是我不会使用 repo，而只是在我的服务中使用该对象？

你使用spring-data-jpa吗？

@Webnet 我自己对 Spring 有点陌生，但在我看来你可以将它用作对象

你试过 Spring JDBCTemplate 吗？

【参考方案1】：

@Query 注解允许通过将 nativeQuery 标志设置为 true 来执行本机查询。

引用自 Spring Data JPA reference docs。

另外，请参阅this section，了解如何使用命名的本机查询。

【讨论】：

@user454322，参数以1开头，所以是：@Query(value = "SELECT * FROM USERS WHERE EMAIL_ADDRESS = ?1", nativeQuery = true)

nativeQuery = true 把我从 IllegalArgumentException 中救了出来

【参考方案2】：

是的，您可以通过以下方式做到这一点：

1.通过 CrudRepository（投影）

Spring Data Repositories 在使用查询方法时通常会返回域模型。但是，有时，您可能出于各种原因需要更改该模型的视图。

假设你的实体是这样的：

    import javax.persistence.*;
    import java.math.BigDecimal;
    
    @Entity
    @Table(name = "USER_INFO_TEST")
    public class UserInfoTest 
        private int id;
        private String name;
        private String rollNo;
    
        public UserInfoTest() 
        

        public UserInfoTest(int id, String name) 
        this.id = id;
        this.name = name;
        
     
        @Id
        @GeneratedValue(strategy = GenerationType.IDENTITY)
        @Column(name = "ID", nullable = false, precision = 0)
        public int getId() 
            return id;
        
    
        public void setId(int id) 
            this.id = id;
        
    
        @Basic
        @Column(name = "name", nullable = true)
        public String getName() 
            return name;
        
    
        public void setName(String name) 
            this.name = name;
        
    
        @Basic
        @Column(name = "roll_no", nullable = true)
        public String getRollNo() 
            return rollNo;
        
    
        public void setRollNo(String rollNo) 
            this.rollNo = rollNo;
        
    

现在您的 Projection 类如下所示。它可以是您需要的那些字段。

public interface IUserProjection 
     int getId();
     String getName();
     String getRollNo();

还有Your Data Access Object(Dao) is like bellow：

import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.CrudRepository;

import java.util.ArrayList;

public interface UserInfoTestDao extends CrudRepository<UserInfoTest,Integer> 
    @Query(value = "select id,name,roll_no from USER_INFO_TEST where rollNo = ?1", nativeQuery = true)
    ArrayList<IUserProjection> findUserUsingRollNo(String rollNo);

现在ArrayList<IUserProjection> findUserUsingRollNo(String rollNo) 会给你用户列表。

2。使用实体管理器

假设您的查询是“select id,name from users where roll_no = 1001”。

这里查询将返回一个带有 id 和 name 列的对象。您的 Response 类如下所示：

你的 Response 类是这样的：

public class UserObject
        int id;
        String name;
        String rollNo;

        public UserObject(Object[] columns) 
            this.id = (columns[0] != null)?((BigDecimal)columns[0]).intValue():0;
            this.name = (String) columns[1];
        

        public int getId() 
            return id;
        

        public void setId(int id) 
            this.id = id;
        

        public String getName() 
            return name;
        

        public void setName(String name) 
            this.name = name;
        

        public String getRollNo() 
            return rollNo;
        

        public void setRollNo(String rollNo) 
            this.rollNo = rollNo;
        
    

这里的UserObject构造函数会得到一个Object Array并用该对象设置数据。

public UserObject(Object[] columns) 
            this.id = (columns[0] != null)?((BigDecimal)columns[0]).intValue():0;
            this.name = (String) columns[1];
        

您的查询执行功能如下所示：

public UserObject getUserByRoll(EntityManager entityManager,String rollNo) 

        String queryStr = "select id,name from users where roll_no = ?1";
        try 
            Query query = entityManager.createNativeQuery(queryStr);
            query.setParameter(1, rollNo);

            return new UserObject((Object[]) query.getSingleResult());
         catch (Exception e) 
            e.printStackTrace();
            throw e;
        
    

这里你必须导入波纹管包：

import javax.persistence.Query;
import javax.persistence.EntityManager;

现在你的主类，你必须调用这个函数。首先获取 EntityManager 并调用此 getUserByRoll(EntityManager entityManager,String rollNo) 函数。调用过程如下：

这里是导入

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;

通过这种方式获取EntityManager：

@PersistenceContext
private EntityManager entityManager;

UserObject userObject = getUserByRoll(entityManager,"1001");

现在你在这个 userObject 中有数据了。

注意：

query.getSingleResult() 返回一个对象数组。您必须使用查询列位置来维护列位置和数据类型。

select id,name from users where roll_no = 1001 

查询返回一个数组，它是[0] --> id and [1] -> name。

更多信息请访问thread和this Thread

谢谢:)

【参考方案3】：

可以在 Spring 存储库中使用原始查询。

      @Query(value = "SELECT A.IS_MUTUAL_AID FROM planex AS A 
             INNER JOIN planex_rel AS B ON A.PLANEX_ID=B.PLANEX_ID  
             WHERE B.GOOD_ID = :goodId",nativeQuery = true)

      Boolean mutualAidFlag(@Param("goodId")Integer goodId);

【参考方案4】：

也可以使用Spring Data JDBC repository，这是一个建立在 Spring Data Commons 之上的社区项目，可以使用原始 SQL 访问数据库，而无需使用 JPA。

它不如 Spring Data JPA 强大，但如果您想要简单项目的轻量级解决方案而不使用像 Hibernate 这样的 ORM，那么值得一试的解决方案。

【参考方案5】：

我们可以使用 createNativeQuery("Here Native SQL Query");

例如：

Query q = em.createNativeQuery("SELECT a.firstname, a.lastname FROM Author a");
List<Object[]> authors = q.getResultList();

【讨论】：

如果您还展示了如何创建 em 变量，将会很有用/完整。

em 是“javax.persistence.EntityManager”。就我而言，我只是@Autowired。

是的。 EntityManager 类

【参考方案6】：

这就是你如何以简单的形式使用

@RestController
public class PlaceAPIController 

 @Autowired
 private EntityManager entityManager;

 @RequestMapping(value = "/api/places", method = RequestMethod.GET)
 public List<Place> getPlaces() 
 List<Place> results = entityManager.createNativeQuery("SELECT *  FROM places p limit 10").getResultList();
    return results;
 

【讨论】：

这是一个简单的解决方案，对我有用！想知道它是否有一些缺点，因为这里我们不使用 Service 和 Repository 层。