/* * To change this license header, choose License Headers in Project Properties. * To change this template file, choose Tools | Templates * and open the template in the editor. */ package com.euroccp.tps.entities.facade; import com.euroccp.tps.entities.mapping.Positions; import com.euroccp.tps.entities.mapping.PositionsInterface; import com.mysql.clusterj.Session; import com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException; import java.math.BigDecimal; import java.math.BigInteger; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import javax.persistence.EntityManager; /** * * @author Administrator */ public class PositionsFacade { public void updateRecordClusterJ(Session session, int id, BigDecimal amount) throws Exception { PositionsInterface positionsInterface = session.find(PositionsInterface.class, id); if (positionsInterface == null) { //Insert positionsInterface = session.newInstance(PositionsInterface.class); positionsInterface.setId(id); positionsInterface.setTotal(amount); session.persist(positionsInterface); } else { //Update positionsInterface.setTotal(positionsInterface.getTotal().add(amount)); session.updatePersistent(positionsInterface); } } }