java.sql.BatchUpdateException: ORA-02049

[Marcel Jacome]

Hi everyone , i have a problem persisting to the database using jpa . I am getting this exception 11:32:09,508 ERROR [JDBCExceptionReporter] ORA-02049: timeout: transacci¾n distribuida esperando bloqueo

I have two entities with the following code:

import java.io.Serializable;
import java.math.BigDecimal;
import java.math.BigInteger;
import java.util.Date;
import java.util.List;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.FetchType;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.ManyToOne;
import javax.persistence.NamedQueries;
import javax.persistence.NamedQuery;
import javax.persistence.OneToMany;
import javax.persistence.OneToOne;
import javax.persistence.SequenceGenerator;
import javax.persistence.Table;
import javax.persistence.Temporal;
import javax.persistence.TemporalType;


@Entity
@Table(name = "APORTE2")
@SequenceGenerator(name = "AportePortafolioDosSequence", sequenceName = "APORTES_2_SEQ", allocationSize = 1)


})
public class AportePortafolioDos implements Serializable {

	private static final long serialVersionUID = -7262597273934001258L;

	@Id
	@GeneratedValue(generator = "AportePortafolioDosSequence", strategy = GenerationType.SEQUENCE)
	@Column(name = "CODIGOAPORTE", nullable = false)
	private Long codigoAporte;

	@Column(name = "CEDULA", nullable = false)
	private String cedula;

	@Column(name = "NOMBRE")
	private String nombre;

	@Column(name = "RUCPATRONAL")
	private String rucPatronal;

	@Column(name = "NOMBREEMPRESA")
	private String nombreEmpresa;

	@Column(name = "SUCURSALSECCION")
	private String sucursalSeccion;

	@Column(name = "SECTOR")
	private String sector;

	@Column(name = "NUMEROBOLETIN")
	private String numeroBoletin;

	@Column(name = "SECUENCIALPLANILLA")
	private BigInteger secuencialPlanilla;

	@Column(name = "FECHACOMPROBANTE")
	private String fechaComprobante;

	@Column(name = "PERIODODESDE")
	private String periodoDesde;

	@Column(name = "PERIODOHASTA")
	private String periodoHasta;

	@Column(name = "PERIODOANIO")
	private Long periodoAnio;

	@Column(name = "PERIODOMES")
	private Long periodoMes;

	@Column(name = "TIPOPERIODO")
	private String tipoPeriodo;

	@Column(name = "TIPOPLANILLA")
	private String tipoPlanilla;

	@Column(name = "TIPOREGISTRO")
	private String tipoRegistro;

	@Column(name = "ESTADOAPORTE")
	private String estadoAporte;

	// @Column(name = "CONDICIONAFILIADO")
	// private String condicionAfiliado;

	@Column(name = "VALORCAPITAL")
	private BigDecimal valorCapital;

	@Column(name = "FECHADEPAGO")
	private String fechaPago;

	@Column(name = "TIPODOCUMENTOORIGENDELPAGO")
	private String tipoDocumentoOrigenPago;

	@Column(name = "NUMERODEDOCUMENTOORIGENPAGO")
	private String numeroDocumentoOrigenPago;

	@Column(name = "VALORCAPITALPAGADO")
	private BigDecimal valorCapitalPagado;

	@Column(name = "VALORINTERESPAGADO")
	private BigDecimal valorInteresPagado;

	@Column(name = "VALORMONTOPAGADO")
	private BigDecimal valorMontoPagado;

	@Column(name = "VALORGASTOPAGADO")
	private BigDecimal valorGastoPagado;

	@Column(name = "VALORLIQUIDOPAGADO")
	private BigDecimal valorLiquidoPagado;

	// @Column(name = "VALORCAPITALSOLICITUD")
	// private BigDecimal valorCapitalSolicitud;

	// @Column(name = "VALORINTERESSOLICITUD")
	// private BigDecimal valorInteresSolicitud;

	// @Column(name = "VALORMONTOSOLICITUD")
	// private BigDecimal valorMontoSolicitud;

	// @Column(name = "VALORGASTODESOLICITUD")
	// private BigDecimal valorGastoSolicitud;

	@Column(name = "VALORCOMPROMETIDOFRCAPITAL")
	private BigDecimal ValorComprometidoFrCapital;

	@Column(name = "VALORCOMPROMETIDOFRINTERES")
	private BigDecimal ValorComprometidoFrInteres;

	@Column(name = "VALORCOMPROMETIDOFRMONTO")
	private BigDecimal ValorComprometidoFrMonto;

	@Column(name = "VALORCOMPROMETIDOFRGASTOADM")
	private BigDecimal ValorComprometidoFrGastoAdm;

	@Column(name = "VALORCOMPROMETIDOGARPQCAP")
	private BigDecimal ValorComprometidoGarpqCap;

	@Column(name = "VALORSALDOCAPITAL")
	private BigDecimal valorSaldoCapital;

	@Column(name = "VALORCAPITALDISPONIBLE")
	private BigDecimal valorCapitalDisponible;

	@Column(name = "VALORESEXCESOS")
	private BigDecimal valoresExcesos;

	@Column(name = "DETALLESEXCESOS")
	private String detallesExcesos;

	@Column(name = "BLOQUEOS")
	private String bloqueos;

	@Column(name = "DESCRIPCIONBLOQUEO")
	private String descripcionBloqueo;

	@Column(name = "INCONSISTENCIAS")
	private String inconsistencias;

	@Column(name = "ESTADOBLOQUEO")
	private String estadoBloqueo;

	@Column(name = "NUMEROIMPOSICIONESAPORTE")
	private Long numeroImposicionesAporte;

	@Column(name = "CUMPLEIMPOSICIONES")
	private String cumpleImposiciones;

	// @Column(name = "FECHACUMPLEIMPOSICION")
	// private String fechaCumpleImposicion;

	@Column(name = "SECUENCIAL_PRORRATEO")
	private String secuencialProrrateo;

	@Column(name = "MARCADISPONIBLE")
	private String marcaDisponible;

	// @Column(name = "NUMIMPOREAL")
	// private Long numImpoReal;

	// @Column(name = "PROCESADO")
	// private String procesado;

	@Temporal(value = TemporalType.DATE)
	@Column(name = "FECHARETIRO")
	private Date fechaRetiro;

	// @Column(name = "FECHARENDIMIENTO")
	// private String fechaRendimiento;

	@Column(name = "FECHAINICIORENDIMIENTOS")
	private String fechaInicioRendimientos;

	@Column(name = "FECHAORDEN")
	private String fechaOrden;
	
	@Column(name = "CODRELTRA") //
	private String codRelTra;

	@OneToMany(fetch = FetchType.LAZY, mappedBy = "aportePortafolioDos")
	private List<BloqueoAporte> bloqueoAporteList;
	
		
	@Column(name = "RE_ID_REINTEGRO") // This is the field of the foreign key
	private Long idReintegro;
	
		
	...getters and setters

}

The other entity is

import java.io.Serializable;
import javax.persistence.*;

import java.util.Date;

/**
 * Clase de persistencia para tabla de cabecera de reintegro de valores.
 * 
 */
@Entity
@Table(name = "REINTEGRO")

public class Reintegro implements Serializable {
	private static final long serialVersionUID = 1L;

	@Id
	@SequenceGenerator(name = "FR_REINTEGROS_TBL_IDREINTEGRO_GENERATOR", sequenceName = "FR_REINTEGROS_SEQ")
	@GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "FR_REINTEGROS_TBL_IDREINTEGRO_GENERATOR")
	@Column(name = "RE_ID_REINTEGRO")
	private int idReintegro;

	@Column(name = "CA_CAT_ORIGEN_REINT")
	private String catalogoOrigenReintegro;

	private String codfun;

	private Long codsolafi;

	private String codtipsolafi;

	@Column(name = "DC_COD_ORIGEN_REINT")
	private String origenReintegro;

	@Column(name = "RE_ANULADO")
	private String anulado;

	@Column(name = "RE_COD_LEGAL")
	private String codigoDocumentoLegal;

	@Column(name = "RE_DIRECC_IP")
	private String direccionIp;

	@Temporal(TemporalType.DATE)
	@Column(name = "RE_FEC_BOLETIN")
	private Date fechaBoletin;

	@Temporal(TemporalType.DATE)
	@Column(name = "RE_FEC_REGISTRO")
	private Date fechaRegistro;

	@Column(name = "RE_NUM_BOLETIN")
	private String numeroBoletin;

	@Column(name = "RE_OBSERVACION")
	private String observacion;

	// bi-directional many-to-one association to CargaReintegros
	@ManyToOne(fetch = FetchType.LAZY)
	@JoinColumn(name = "CR_ID_CARGA")
	private CargaReintegros cargaReintegro;

	....getters and setters

	
}

This is where i persist

try {//Ingresar reintegro
		    Reintegro reintegroSolicitud = new Reintegro();
		    reintegroSolicitud = this.armarReintegro(parametros);
		    etapa = "INGRESAR REINTEGRO ";
		    reintegroSolicitud = reintegroDao.persistirReintegro(reintegroSolicitud);
			
            if (parametros.get("tipoReintegroSolicitud").equals(REINTEGRO_SOLICITUD_PAGADO)) {            	
            	
            	Solicitud solicitudOriginal = new Solicitud();
            	SolicitudPk solicitudPk = new SolicitudPk();
            	TipoSolicitud tipoSolicitud = new TipoSolicitud();
            	
            	//Extraemos la secuencia
            	etapa = "TIPO DE SOLICITUD ";
            	tipoSolicitud = tiposolicitudDao
            	      .buscarTipoSolicitud((String) parametros.get("tipoSolicitudParaPagados"));
            	long secuencia = tipoSolicitud.getNumeroSolicitud();
            	secuencia = secuencia + 1 ;
            	tipoSolicitud.setNumeroSolicitud(secuencia);
            	
            	//Persistir la secuencia
            	tipoSolicitud = tiposolicitudDao.actualizarTipoSolicitud(tipoSolicitud);
            	
            	solicitudPk.setCodsolafi(Long.valueOf(secuencia).toString());
            	solicitudPk.setCodtipsolafi((String) parametros.get("tipoSolicitudParaPagados"));
            	
            	SolicitudPk solicitudPkAnterior = new SolicitudPk();
            	solicitudPkAnterior.setCodsolafi((String) parametros.get("codigoSolicitud"));
            	solicitudPkAnterior.setCodtipsolafi((String) parametros.get("tipoSolicitud"));
            	
            	//Buscamos la solicitud original
            	etapa = "BUSQUEDA SOLICITUD ";
            	solicitudOriginal = solicitudDao
            	        .buscarSolicitudPorCedulaPk((String) parametros.get("cedula"), solicitudPkAnterior);
            	
            	            	
            	if (solicitudOriginal.getSolicitudPk() == null) {
            		log.error("No se ha hallado la solicitud Original " 
            				+ solicitudPk.getCodsolafi() + "-" +solicitudPk.getCodtipsolafi());
            		etapa = etapa.
            		concat(" ").
            		concat("NO SE HA ENCONTRADO SOLICITUD ORIGINAL " 
            				+ solicitudPk.getCodsolafi() + "-" +solicitudPk.getCodtipsolafi());
            		throw new Exception();
            	}
            	
               	//Armar solicitud a insertar
            	
            	etapa = "INGRESO SOLICITUD ";
            	
            	solicitud.setNumafi(solicitudOriginal.getNumafi());
            	solicitud.setNomafi(solicitudOriginal.getNomafi());
            	solicitud.setSolicitudPk(solicitudPk);
            	solicitud.setValapo(solicitudOriginal.getValapo());
            	solicitud.setValint(solicitudOriginal.getValint());
            	solicitud.setValgasadm(solicitudOriginal.getValgasadm());
            	solicitud.setValsolafi(solicitudOriginal.getValsolafi());
            	solicitud.setCoddivpolpro(solicitudOriginal.getCoddivpolpro());
            	solicitud.setCoddivpolcan(solicitudOriginal.getCoddivpolcan());
            	solicitud.setCoddivpolpar(solicitudOriginal.getCoddivpolpar());
            	solicitud.setCoddivpolpro(solicitudOriginal.getCoddivpolpro());
            	solicitud.setCoddivpolafi(solicitudOriginal.getCoddivpolafi());            	
            	solicitud.setCodestsolafi(ESTADO_SOLICITUD_PAGADA);
            	solicitud.setFecregsol(new Date());
            	solicitud.setFecpagsol(new Date());
            	solicitud.setFechaIngreso(new Date());
            	solicitud.setObssolafi("REINTEGRO DE VALORES #: " + reintegroSolicitud.getIdReintegro());
            	solicitud.setFecpro(new Date()); 
            	solicitud.setEstproctaind(solicitudOriginal.getEstproctaind());            	
            	solicitud = solicitudDao.persistirSolicitud(solicitud);
            	
            }            
            
            int cnt = 0;
           
            for (PagoAportes pagoAporte : listaAportesPagados) {
            	
            
            	AportePortafolioDos aportePortafolioDos = new AportePortafolioDos();               
            	aportePortafolioDos = null;                 
               	 aportePortafolioDos = this.armarAportePortafolioDosReintegroSolicitud
               	 (pagoAporte, (String)parametros
               			 .get("tipoReintegroSolicitud"), parametros, reintegroSolicitud.getIdReintegro()); 
                 
                 etapa = "INGRESO APORTE " + aportePortafolioDos.getRucPatronal() + " " + aportePortafolioDos.getValorCapital();
				 
				 //HERE IS WHERE THE ORA-02049 lock HAPPENS , THE EXCEPTION IS THROWN WHEN AT FLUSH TIME
                 aportePortafolioDosDao.persistirAportePortafolioDos(aportePortafolioDos);                
                 listaAportesPortafolioDos.add(aportePortafolioDos);
            
               
    		}

What i basically do here is :

1. populate and persist a Reintegro type object , so as to get a sequence number (idReintegro) from a sequence generator
2. find and persist other entities (No problem here)
3. Take the sequence obtained in step 1 (idReintegro) , assign it to aportePortafolioDos object (foreign key value)
4. Persist the aportePortafolioDos object


The thing is that once the persistence context is synchronized with the Oracle 11g database , it hangs for a few minutes and then throws the exception ORA-02049: , which indicates there is a lock . The lock occurs while trying to persist aportePortafolioDos on an insert statement.

If I disable the foreign key on the table mapped by AportePortafolioDos , everything works as expected . but if the foreign key is active then i get the deadlock.

I have been trying to find a solution for days , to no avail. Is there anything to do at all ? Please help!!!

[Martin Vashko]

I'm no expert on ORM, so I'm just guessing based on what you wrote: did you index the foreign key? If you're deleting from a parent table (which I assume is happening when you persist), Oracle needs to lock entire child table if there is not an index on its foreign key.

Generally, foreign keys should always be indexed in Oracle. Only when you never delete from the parent table, you don't need the index on foreign key. And by "you delete from a table", I actually mean "your persistence framework deletes from a table".