我需要在 Spring Data Repository 中使用原始 SQL,这可能吗?我所看到的一切@Query
都是基于实体的。
6 回答
是的,您可以通过以下方式执行此操作:
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.使用EntityManager
假设您的查询是“ 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 构造函数将获取一个对象数组并使用该对象设置数据。
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
.
谢谢 :)
可以在 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();
这是您可以以简单形式使用的方式
@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;
}
}