我需要在 Spring Data Repository 中使用原始 SQL，这可能吗？我在@Query 周围看到的一切都是基于实体的。
【问题讨论】：
标签： java hibernate spring-data-jpa
@Query 注解允许通过将 nativeQuery 标志设置为 true 来执行本机查询。
引用自 Spring Data JPA reference docs。
另外，请参阅this section，了解如何使用命名的本机查询。
【讨论】：
@Query(value = "SELECT * FROM USERS WHERE EMAIL_ADDRESS = ?1", nativeQuery = true)
是的，您可以通过以下方式做到这一点：
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
谢谢:)
【讨论】：
可以在 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);
【讨论】：
也可以使用Spring Data JDBC repository，这是一个建立在 Spring Data Commons 之上的社区项目，可以使用原始 SQL 访问数据库，而无需使用 JPA。
它不如 Spring Data JPA 强大，但如果您想要简单项目的轻量级解决方案而不使用像 Hibernate 这样的 ORM，那么值得一试的解决方案。
【讨论】：
我们可以使用 createNativeQuery("Here Native SQL Query");
例如：
Query q = em.createNativeQuery("SELECT a.firstname, a.lastname FROM Author a");
List<Object[]> authors = q.getResultList();
【讨论】：
em 变量，将会很有用/完整。
这就是你如何以简单的形式使用
@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;
}
}
【讨论】：