JAVA专题--Springboot|JAVA专题--Springboot JPA 执行原生sql ,自定义SQL占位符增加参数
COVER:https://www.sojson.com/blog/294.html
JPA 实际上就是 Hibernate 的封装,根据Interface
方法名,生成对应的方法,也支持Query
注解的方式。现在说说执行原生 SQL 。
注解@Query方式执行原生SQL语句:
@Query(value="https://www.it610.com/article/select user.id from user where user.id =15", nativeQuery = true)
public User queryById(){}
【JAVA专题--Springboot|JAVA专题--Springboot JPA 执行原生sql ,自定义SQL占位符增加参数】注解的方式需要增加一个
“nativeQuery=true”
来表示是原生 SQL 。EntityManager.Query 方式:
Query query = entityManager.createNativeQuery("select user.id from user where user.id =15");
List list = query.getResultList()
复杂原生SQL,占位式:
@PersistenceContext
private EntityManager entityManager;
@Modifying
@Transactional
public StockDetails save(StockDetails o) {
StringBuffer sb = new StringBuffer();
sb.append("insert into b_stock_details (transaction_id, pid, price, cost_price, offer_name, game_type, ");
sb.append(" game_name, game_id, money, game_about, purchase_date, create_time, customer_id, ");
sb.append(" customer_name, customer_login_name,member_id, member_name, have_customer_id,status, ifrom,");
sb.append("trading_status,game_face_name, receipt_data_one, receipt_data_two) ");
sb.append(" SELECT ?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?FROM DUAL WHERE NOT EXISTS ");
sb.append("(SELECT transaction_id FROM b_stock_details where transaction_id= ?)");
Query query = entityManager.createNativeQuery(sb.toString());
query.setParameter(1,o.getTransactionId());
query.setParameter(2,o.getPid());
query.setParameter(3,o.getPrice());
query.setParameter(4,o.getCostPrice());
query.setParameter(5,o.getOfferName());
query.setParameter(6,o.getGameType());
query.setParameter(7,o.getGameName());
query.setParameter(8,o.getGameId());
query.setParameter(9,o.getMoney());
query.setParameter(10,o.getGameAbout());
query.setParameter(11,o.getPurchaseDate());
query.setParameter(12,o.getCreateTime());
query.setParameter(13,o.getCustomerId());
query.setParameter(14,o.getCustomerName());
query.setParameter(15,o.getCustomerLoginName());
query.setParameter(16,o.getMemberId());
query.setParameter(17,o.getMemberName());
query.setParameter(18,o.getHaveCustomerId());
query.setParameter(19,o.getStatus());
query.setParameter(20,o.getIfrom());
query.setParameter(21,o.getTradingStatus());
query.setParameter(22,o.getGameFaceName());
query.setParameter(23,o.getReceiptDataOne());
query.setParameter(24,o.getReceiptDataTwo());
query.setParameter(25,o.getTransactionId());
int result = query.executeUpdate();
log.debug("插入接口:{}",result>0?"成功":"数据已经重复存在");
return o;
}
这里是一个如果数据存在则不添加的业务。这里是用到了SOSO的 https://www.sojson.com/blog/288.html 的方案三。加上
query.setParameter(index,parms);
方式对“?”进行参数占位补充。返回值:由于是一个insert操作,另外成功则返回操作的条数,没有做数据改变则返回 0 。
如果出现 “
jpa Executing an update/delete query
”异常,那么是因为你没有添加事物和“@Modifying
”比较,把注解加上就可以。推荐阅读
- JAVA(抽象类与接口的区别&重载与重写&内存泄漏)
- 事件代理
- Java|Java OpenCV图像处理之SIFT角点检测详解
- java中如何实现重建二叉树
- 数组常用方法一
- 【Hadoop踩雷】Mac下安装Hadoop3以及Java版本问题
- Java|Java基础——数组
- RxJava|RxJava 在Android项目中的使用(一)
- java之static、static|java之static、static final、final的区别与应用
- Java基础-高级特性-枚举实现状态机