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”比较,把注解加上就可以。

    推荐阅读