在spring data jpa中更新和插入查询

Question

我正在制作一个rest api，其中我必须根据id进行更新，并通过spring data在表中插入没有id基础的数据。但我发现在这两种情况下都有一个错误，它运行插入查询，只有更新不工作

存储库文件@repository公共接口CustomerRepository扩展JpaRepository{CustomerEntity save（CustomerEntity CustomerEntity）；CustomerEntity findById（int id）；

public CustomerDO create（CustomerDO customerReqDO）{CustomerEntity CustomerEntity=null；CustomerDO customerresdo=new CustomerDO（）；if（null！=customerReqDO.getid（））{CustomerEntity=customerReqDO.findbyid（integer.parseint（customerReqDO.getid（）））；if（null！=CustomerEntity）{

            if(null != customerReqDO.getName())
                customerEntity.setName(customerReqDO.getName());

            if(null != customerReqDO.getPhone())
                customerEntity.setPhone(customerReqDO.getPhone());

            if(null != customerReqDO.getEmail())

                customerEntity.setEmail(customerReqDO.getEmail());

            if(null != customerReqDO.getPassword())
                customerEntity.setPassword(customerReqDO.getPassword());
            //if(null !=customerReqDO.getCredits())
                //customerReqEntity.setCredits(customerReqDO.getCredits());

            customerEntity =customerRepository.save(customerEntity);

          }else{
                    customerResDO.setError("Invalid Customer id "+customerReqDO.getId());
          }}else{
    customerEntity=new CustomerEntity();                    
    customerEntity.setName(customerReqDO.getName());
    customerEntity.setPhone(customerReqDO.getPhone());
    customerEntity.setEmail(customerReqDO.getEmail());

    //customerReqEntity.setFacebookID(customerReqDO.getFacebookID());
    customerEntity.setPassword(customerReqDO.getPassword());
    //customerReqEntity.setCredits(customerReqDO.getCredits());

    customerEntity =customerRepository.save(customerEntity);

            }if(null != customerEntity){
                customerResDO.setId(String.valueOf(customerEntity.getId()));
                customerResDO.setName(customerEntity.getName());
                customerResDO.setPhone(customerEntity.getPhone());
                customerResDO.setEmail(customerEntity.getEmail());
                customerResDO.setPassword(customerEntity.getPassword());
                //deliveryLocationResponseDO.setDeliverytimes(Arrays.asList(deliveryLocationEntity.getDeliverytimes()));
            }
    return customerResDO;

}



controller

@crossorigin(corigins=“*”）@postmapping()public CustomerResponseDTO register(@requestbody customuptaterequestdto registerRequestDTO）{CustomerDO customerReqDO=new CustomerDO（）；CustomerResponseDTO loginResponseDTO=new CustomerDO（）；customerReqDO loginResponseDTO（）；customerReqDO.setname（registerRequestDTO.getname（）

    CustomerDO  customerResDO = customerLoginManagerImpl.insert(customerReqDO);

    if(null != customerResDO.getError()){
        loginResponseDTO.setError(customerResDO.getError());
    }else{


    loginResponseDTO.setSucess(true);
}

    return loginResponseDTO;
}  

Answer 1

使用Hibernate中的条件：

Session session = sessionFactory.openSession();
Transaction tx = session.beginTransaction();

String query= "update TableName c set c.attribute= :newAttribute where c.id=:id";
int updatedEntities = s.createQuery( query )
    .setString( "newAttribute ", newAttribute )
    .setString( "id", id)
    .executeUpdate();
tx.commit();
session.close();