TracciaProducer.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it). 
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */



  23. package org.openspcoop2.protocol.basic.tracciamento;

  25. import java.sql.Connection;
  26. import java.sql.PreparedStatement;
  27. import java.sql.ResultSet;
  28. import java.util.ArrayList;
  29. import java.util.Date;
  30. import java.util.List;

  32. import org.openspcoop2.core.config.OpenspcoopAppender;
  33. import org.openspcoop2.core.constants.CostantiDB;
  34. import org.openspcoop2.core.id.IDSoggetto;
  35. import org.openspcoop2.protocol.basic.BasicConnectionResult;
  36. import org.openspcoop2.protocol.basic.BasicProducer;
  37. import org.openspcoop2.protocol.basic.BasicProducerType;
  38. import org.openspcoop2.protocol.sdk.Allegato;
  39. import org.openspcoop2.protocol.sdk.Busta;
  40. import org.openspcoop2.protocol.sdk.Eccezione;
  41. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  42. import org.openspcoop2.protocol.sdk.ProtocolException;
  43. import org.openspcoop2.protocol.sdk.Riscontro;
  44. import org.openspcoop2.protocol.sdk.Trasmissione;
  45. import org.openspcoop2.protocol.sdk.constants.TipoSerializzazione;
  46. import org.openspcoop2.protocol.sdk.tracciamento.ITracciaProducer;
  47. import org.openspcoop2.protocol.sdk.tracciamento.Traccia;
  48. import org.openspcoop2.protocol.sdk.tracciamento.TracciamentoException;
  49. import org.openspcoop2.utils.TipiDatabase;
  50. import org.openspcoop2.utils.jdbc.CustomKeyGeneratorObject;
  51. import org.openspcoop2.utils.jdbc.InsertAndGeneratedKey;
  52. import org.openspcoop2.utils.jdbc.InsertAndGeneratedKeyJDBCType;
  53. import org.openspcoop2.utils.jdbc.InsertAndGeneratedKeyObject;
  54. import org.openspcoop2.utils.jdbc.JDBCUtilities;

  56. /**
  57.  * Contiene l'implementazione di un appender personalizzato,
  58.  * per la registrazione dei tracciamenti su database.
  59.  *
  60.  * @author Poli Andrea (apoli@link.it)
  61.  * @author $Author$
  62.  * @version $Rev$, $Date$
  63.  */

  65. public class TracciaProducer extends BasicProducer implements ITracciaProducer{

  67.     public TracciaProducer(IProtocolFactory<?> factory) throws ProtocolException{
  68.         super(factory, BasicProducerType.TRACCE);
  69.     }

  71.     /**
  72.      * Inizializza l'engine di un appender per la registrazione
  73.      * di un tracciamento emesso da una porta di dominio.
  74.      * 
  75.      * @param appenderProperties Proprieta' dell'appender
  76.      * @throws TracciamentoException
  77.      */
  78.     @Override
  79.     public void initializeAppender(OpenspcoopAppender appenderProperties) throws TracciamentoException{
  80.         try{
  81.             this.initializeAppender(appenderProperties, true);
  82.         }catch(Exception e){
  83.             throw new TracciamentoException("Errore durante l'inizializzazione dell'appender: "+e.getMessage(),e);
  84.         }
  85.     }



  89.     /**
  90.      * Registra una traccia prodotta da una porta di dominio, utilizzando le informazioni definite dalla specifica SPC.
  91.      * 
  92.      * @param conOpenSPCoopPdD Connessione verso il database
  93.      * @param traccia Traccia
  94.      * @throws TracciamentoException
  95.      */
  96.     @Override
  97.     public void log(Connection conOpenSPCoopPdD, Traccia traccia) throws TracciamentoException{

  99.         if(traccia==null)
  100.             throw new TracciamentoException("Errore durante il tracciamento: traccia is null");

  102.         Busta busta = traccia.getBusta();
  103.         if(busta==null)
  104.             throw new TracciamentoException("Errore durante il tracciamento di un busta: busta is null");

  106.         Date gdo = traccia.getGdo();
  107.         IDSoggetto idSoggetto = traccia.getIdSoggetto();
  108.         String tipoMessaggio = traccia.getTipoMessaggio().getTipo();
  109.         String location = traccia.getLocation();
  110.         String idCorrelazioneApplicativa = traccia.getCorrelazioneApplicativa();
  111.         String idCorrelazioneApplicativaRisposta = traccia.getCorrelazioneApplicativaRisposta();
  112.         
  113.         if(this.debug){
  114.             this.log.debug("@@ log["+busta.getID()+"] ....");
  115.         }
  116.         
  117.         PreparedStatement stmt = null;
  118.         ResultSet rs = null;
  119.         Connection con = null;
  120.         BasicConnectionResult cr = null;
  121.         try{
  122.             //  Connessione al DB
  123.             cr = this.getConnection(conOpenSPCoopPdD,"traccia.log");
  124.             con = cr.getConnection();

  126.             if(this.debug){
  127.                 this.log.debug("@@ log["+busta.getID()+"] (getConnection finished) ....");
  128.             }
  129.             
  130.             //Inserimento della traccia nel DB
  131.             if(!TipiDatabase.isAMember(this.tipoDatabase)){
  132.                 throw new TracciamentoException("Tipo database ["+this.tipoDatabase+"] non supportato");
  133.             }
  134.             TipiDatabase tipo = TipiDatabase.toEnumConstant(this.tipoDatabase);
  135.             // ** Preparazione parametri
  136.             java.sql.Timestamp gdoT = new java.sql.Timestamp(gdo.getTime());
  137.             java.sql.Timestamp oraRegistrazioneT = null;
  138.             java.sql.Timestamp scadenzaT = null;
  139.             if(busta.getOraRegistrazione()!=null)
  140.                 oraRegistrazioneT = new java.sql.Timestamp(busta.getOraRegistrazione().getTime());
  141.             if (busta.getScadenza() != null)
  142.                 scadenzaT =  new java.sql.Timestamp(busta.getScadenza().getTime());
  143.             int confermaRicezione = -1;
  144.             if(busta.isConfermaRicezione())
  145.                 confermaRicezione = 1;
  146.             else
  147.                 confermaRicezione = 0 ;
  148.             
  149.             String headerProtocollo = null;
  150.             if(traccia.getBustaAsRawContent()!=null){
  151.                 try{
  152.                     headerProtocollo = traccia.getBustaAsRawContent().toString(TipoSerializzazione.DEFAULT);
  153.                 }catch(Exception e){
  154.                     throw new Exception("Serializzazione RawContent non riuscita: "+e.getMessage(),e);
  155.                 }
  156.             }
  157.             else if(traccia.getBustaAsString()!=null){
  158.                 headerProtocollo = traccia.getBustaAsString();
  159.             }else if(traccia.getBustaAsByteArray()!=null){
  160.                 headerProtocollo = new String(traccia.getBustaAsByteArray());
  161.             }else{
  162.                 // ProtocolFactoryManager non utilizzabile in questo package
  163.                 /*
  164.                 headerProtocollo = 
  165.                         ProtocolFactoryManager.getInstance().
  166.                             getProtocolFactoryByName(traccia.getProtocollo()).
  167.                                 createBustaBuilder().toString(busta, org.openspcoop2.protocol.sdk.constants.TipoTraccia.RICHIESTA.equals(traccia.getTipoMessaggio()));
  168.                                 */
  169.             }
  170.             
  171.             if(this.debug){
  172.                 this.log.debug("@@ log["+busta.getID()+"] (prima inserimento traccia) ....");
  173.             }
  174.             List<InsertAndGeneratedKeyObject> listInsertAndGeneratedKeyObject = new ArrayList<>();
  175.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_GDO, gdoT , InsertAndGeneratedKeyJDBCType.TIMESTAMP) );
  176.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_GDO_INT, gdoT.getTime(), InsertAndGeneratedKeyJDBCType.LONG) );
  177.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_PDD_CODICE, idSoggetto.getCodicePorta(), InsertAndGeneratedKeyJDBCType.STRING) );
  178.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_PDD_TIPO_SOGGETTO, idSoggetto.getTipo(), InsertAndGeneratedKeyJDBCType.STRING) );
  179.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_PDD_NOME_SOGGETTO, idSoggetto.getNome(), InsertAndGeneratedKeyJDBCType.STRING) );
  180.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_PDD_RUOLO, traccia.getTipoPdD().getTipo(), InsertAndGeneratedKeyJDBCType.STRING) );
  181.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_TIPO_MESSAGGIO, tipoMessaggio, InsertAndGeneratedKeyJDBCType.STRING) );
  182.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_ESITO_ELABORAZIONE, traccia.getEsitoElaborazioneMessaggioTracciato().getEsito().toString(), InsertAndGeneratedKeyJDBCType.STRING) );
  183.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_DETTAGLIO_ESITO_ELABORAZIONE, traccia.getEsitoElaborazioneMessaggioTracciato().getDettaglio(), InsertAndGeneratedKeyJDBCType.STRING) );
  184.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_MITTENTE_IDPORTA, busta.getIdentificativoPortaMittente(), InsertAndGeneratedKeyJDBCType.STRING) );
  185.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_MITTENTE_NOME, busta.getMittente(), InsertAndGeneratedKeyJDBCType.STRING) );
  186.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_MITTENTE_TIPO, busta.getTipoMittente(), InsertAndGeneratedKeyJDBCType.STRING) );
  187.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_MITTENTE_INDIRIZZO, busta.getIndirizzoMittente(), InsertAndGeneratedKeyJDBCType.STRING) );
  188.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_DESTINATARIO_IDPORTA, busta.getIdentificativoPortaDestinatario(), InsertAndGeneratedKeyJDBCType.STRING) );
  189.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_DESTINATARIO_NOME, busta.getDestinatario(), InsertAndGeneratedKeyJDBCType.STRING) );
  190.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_DESTINATARIO_TIPO, busta.getTipoDestinatario(), InsertAndGeneratedKeyJDBCType.STRING) );
  191.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_DESTINATARIO_INDIRIZZO, busta.getIndirizzoDestinatario(), InsertAndGeneratedKeyJDBCType.STRING) );
  192.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_PROFILO_COLLABORAZIONE, busta.getProfiloDiCollaborazioneValue(), InsertAndGeneratedKeyJDBCType.STRING) );
  193.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_PROFILO_COLLABORAZIONE_SDK_CONSTANT, busta.getProfiloDiCollaborazione() == null ? null : busta.getProfiloDiCollaborazione().getEngineValue(), InsertAndGeneratedKeyJDBCType.STRING) );
  194.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_SERVIZIO_CORRELATO_NOME, busta.getServizioCorrelato(), InsertAndGeneratedKeyJDBCType.STRING) );
  195.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_SERVIZIO_CORRELATO_TIPO, busta.getTipoServizioCorrelato(), InsertAndGeneratedKeyJDBCType.STRING) );
  196.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_COLLABORAZIONE, busta.getCollaborazione(), InsertAndGeneratedKeyJDBCType.STRING) );
  197.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_SERVIZIO_VERSIONE, busta.getVersioneServizio(), InsertAndGeneratedKeyJDBCType.INT) );
  198.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_SERVIZIO_NOME, busta.getServizio(), InsertAndGeneratedKeyJDBCType.STRING) );
  199.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_SERVIZIO_TIPO, busta.getTipoServizio(), InsertAndGeneratedKeyJDBCType.STRING) );
  200.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_AZIONE, busta.getAzione(), InsertAndGeneratedKeyJDBCType.STRING) );
  201.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_ID_MESSAGGIO, busta.getID(), InsertAndGeneratedKeyJDBCType.STRING) );
  202.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_ORA_REGISTRAZIONE,oraRegistrazioneT,InsertAndGeneratedKeyJDBCType.TIMESTAMP) );
  203.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_ORA_REGISTRAZIONE_TIPO, busta.getTipoOraRegistrazioneValue(), InsertAndGeneratedKeyJDBCType.STRING) );
  204.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_ORA_REGISTRAZIONE_TIPO_SDK_CONSTANT,  busta.getTipoOraRegistrazione() == null ? null : busta.getTipoOraRegistrazione().getEngineValue(), InsertAndGeneratedKeyJDBCType.STRING) );
  205.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_RIFERIMENTO_MESSAGGIO, busta.getRiferimentoMessaggio(), InsertAndGeneratedKeyJDBCType.STRING) );
  206.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_SCADENZA,scadenzaT,InsertAndGeneratedKeyJDBCType.TIMESTAMP) );
  207.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_INOLTRO, busta.getInoltroValue(), InsertAndGeneratedKeyJDBCType.STRING) );
  208.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_INOLTRO_SDK_CONSTANT, busta.getInoltro() == null ? null : busta.getInoltro().getEngineValue(), InsertAndGeneratedKeyJDBCType.STRING) );
  209.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_CONFERMA_RICEZIONE, confermaRicezione, InsertAndGeneratedKeyJDBCType.INT) );
  210.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_SEQUENZA, busta.getSequenza(), InsertAndGeneratedKeyJDBCType.LONG) );
  211.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_LOCATION, location, InsertAndGeneratedKeyJDBCType.STRING) );
  212.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_CORRELAZIONE_APPLICATIVA_RICHIESTA, idCorrelazioneApplicativa, InsertAndGeneratedKeyJDBCType.STRING) );
  213.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_CORRELAZIONE_APPLICATIVA_RISPOSTA, idCorrelazioneApplicativaRisposta, InsertAndGeneratedKeyJDBCType.STRING) );
  214.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_SA_FRUITORE, busta.getServizioApplicativoFruitore(), InsertAndGeneratedKeyJDBCType.STRING) );
  215.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_SA_EROGATORE, busta.getServizioApplicativoErogatore(), InsertAndGeneratedKeyJDBCType.STRING) );
  216.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_PROTOCOLLO, traccia.getProtocollo(), InsertAndGeneratedKeyJDBCType.STRING) );
  217.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_DIGEST, busta.getDigest(), InsertAndGeneratedKeyJDBCType.STRING) );
  218.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_SOAP, headerProtocollo, InsertAndGeneratedKeyJDBCType.STRING) );
  219.             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRACCE_COLUMN_ID_TRANSAZIONE, traccia.getIdTransazione(), InsertAndGeneratedKeyJDBCType.STRING) );
  220.             
  221.             
  222.             // ** Insert and return generated key
  223.             long idtraccia = InsertAndGeneratedKey.insertAndReturnGeneratedKey(con, tipo, 
  224.                     new CustomKeyGeneratorObject(CostantiDB.TRACCE, CostantiDB.TRACCE_COLUMN_ID, CostantiDB.TRACCE_SEQUENCE, CostantiDB.TRACCE_TABLE_FOR_ID),
  225.                     listInsertAndGeneratedKeyObject.toArray(new InsertAndGeneratedKeyObject[1]));
  226.             if(idtraccia<=0){
  227.                 throw new Exception("ID autoincrementale non ottenuto");
  228.             }
  229.             traccia.setId(idtraccia);

  231.             if(this.debug){
  232.                 this.log.debug("@@ log["+busta.getID()+"] (traccia inserita) ....");
  233.             }
  234.             
  235.             
  236.             
  237.             String sqlString = null;
  238.             
  239.             if(this.debug){
  240.                 this.log.debug("@@ log["+busta.getID()+"] (inserimento "+busta.sizeListaRiscontri()+" riscontri) ....");
  241.             }
  242.             for (int i = 0; i < busta.sizeListaRiscontri(); i++) {
  243.                 Riscontro riscontro = busta.getRiscontro(i);

  245.                 //Inserimento nel DB
  246.                 sqlString = "INSERT INTO "+CostantiDB.TRACCE_RISCONTRI+" ("+
  247.                         CostantiDB.TRACCE_RISCONTRI_COLUMN_ID_TRACCIA+", "+
  248.                         CostantiDB.TRACCE_RISCONTRI_COLUMN_ID_RISCONTRO+", "+
  249.                         CostantiDB.TRACCE_RISCONTRI_COLUMN_RICEVUTA+", "+
  250.                         CostantiDB.TRACCE_RISCONTRI_COLUMN_ORA_REGISTRAZIONE+", "+
  251.                         CostantiDB.TRACCE_RISCONTRI_COLUMN_ORA_REGISTRAZIONE_TIPO+", "+
  252.                         CostantiDB.TRACCE_RISCONTRI_COLUMN_ORA_REGISTRAZIONE_TIPO_SDK_CONSTANT+", "+
  253.                         CostantiDB.TRACCE_RISCONTRI_COLUMN_GDO+
  254.                         ") VALUES (?, ?, ?, ?, ?, ?, ?)";
  255.                 stmt = con.prepareStatement(sqlString);
  256.                 int index = 1;
  257.                 stmt.setLong(index++, idtraccia);
  258.                 JDBCUtilities.setSQLStringValue(stmt,index++, riscontro.getID());
  259.                 JDBCUtilities.setSQLStringValue(stmt,index++, riscontro.getRicevuta());
  260.                 if(riscontro.getOraRegistrazione()!=null)
  261.                     stmt.setTimestamp(index++, new java.sql.Timestamp(riscontro.getOraRegistrazione().getTime()));
  262.                 else
  263.                     stmt.setTimestamp(index++, null);
  264.                 JDBCUtilities.setSQLStringValue(stmt,index++, riscontro.getTipoOraRegistrazioneValue(this.protocolFactory));
  265.                 JDBCUtilities.setSQLStringValue(stmt,index++, riscontro.getTipoOraRegistrazione().getEngineValue());
  266.                 stmt.setTimestamp(index++, gdoT);
  267.                 stmt.executeUpdate();
  268.                 stmt.close();
  269.             }
  270.             if(this.debug){
  271.                 this.log.debug("@@ log["+busta.getID()+"] (inserimento "+busta.sizeListaRiscontri()+" riscontri effettuato) ....");
  272.             }
  273.             
  274.             if(this.debug){
  275.                 this.log.debug("@@ log["+busta.getID()+"] (inserimento "+busta.sizeListaTrasmissioni()+" trasmissioni) ....");
  276.             }
  277.             for (int i = 0; i < busta.sizeListaTrasmissioni(); i++) {
  278.                 Trasmissione trasmissione = busta.getTrasmissione(i);

  280.                 //Inserimento nel DB
  281.                 sqlString = "INSERT INTO "+CostantiDB.TRACCE_TRASMISSIONI+" ("+
  282.                         CostantiDB.TRACCE_TRASMISSIONI_COLUMN_ID_TRACCIA+", "+
  283.                         CostantiDB.TRACCE_TRASMISSIONI_COLUMN_ORIGINE+", "+
  284.                         CostantiDB.TRACCE_TRASMISSIONI_COLUMN_ORIGINE_TIPO+", "+
  285.                         CostantiDB.TRACCE_TRASMISSIONI_COLUMN_ORIGINE_INDIRIZZO+", "+
  286.                         CostantiDB.TRACCE_TRASMISSIONI_COLUMN_ORIGINE_IDPORTA+", "+
  287.                         CostantiDB.TRACCE_TRASMISSIONI_COLUMN_DESTINAZIONE+", "+
  288.                         CostantiDB.TRACCE_TRASMISSIONI_COLUMN_DESTINAZIONE_TIPO+", "+
  289.                         CostantiDB.TRACCE_TRASMISSIONI_COLUMN_DESTINAZIONE_INDIRIZZO+", "+
  290.                         CostantiDB.TRACCE_TRASMISSIONI_COLUMN_DESTINAZIONE_IDPORTA+", "+
  291.                         CostantiDB.TRACCE_TRASMISSIONI_COLUMN_ORA_REGISTRAZIONE+", "+
  292.                         CostantiDB.TRACCE_TRASMISSIONI_COLUMN_ORA_REGISTRAZIONE_TIPO+", "+
  293.                         CostantiDB.TRACCE_TRASMISSIONI_COLUMN_ORA_REGISTRAZIONE_TIPO_SDK_CONSTANT+", "+
  294.                         CostantiDB.TRACCE_TRASMISSIONI_COLUMN_GDO+
  295.                         ") VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
  296.                 stmt = con.prepareStatement(sqlString);
  297.                 int index = 1;
  298.                 stmt.setLong(index++, idtraccia);
  299.                 JDBCUtilities.setSQLStringValue(stmt,index++, trasmissione.getOrigine());
  300.                 JDBCUtilities.setSQLStringValue(stmt,index++, trasmissione.getTipoOrigine());
  301.                 JDBCUtilities.setSQLStringValue(stmt,index++, trasmissione.getIndirizzoOrigine());
  302.                 JDBCUtilities.setSQLStringValue(stmt,index++, trasmissione.getIdentificativoPortaOrigine());
  303.                 JDBCUtilities.setSQLStringValue(stmt,index++, trasmissione.getDestinazione());
  304.                 JDBCUtilities.setSQLStringValue(stmt,index++, trasmissione.getTipoDestinazione());
  305.                 JDBCUtilities.setSQLStringValue(stmt,index++, trasmissione.getIndirizzoDestinazione());
  306.                 JDBCUtilities.setSQLStringValue(stmt,index++, trasmissione.getIdentificativoPortaDestinazione());
  307.                 if(trasmissione.getOraRegistrazione()!=null)
  308.                     stmt.setTimestamp(index++, new java.sql.Timestamp(trasmissione.getOraRegistrazione().getTime()));
  309.                 else
  310.                     stmt.setTimestamp(index++, null);
  311.                 JDBCUtilities.setSQLStringValue(stmt,index++, trasmissione.getTempoValue(this.protocolFactory));
  312.                 JDBCUtilities.setSQLStringValue(stmt,index++, trasmissione.getTempo().getEngineValue());
  313.                 stmt.setTimestamp(index++, gdoT);
  314.                 stmt.executeUpdate();
  315.                 stmt.close();
  316.             }
  317.             if(this.debug){
  318.                 this.log.debug("@@ log["+busta.getID()+"] (inserimento "+busta.sizeListaTrasmissioni()+" trasmissioni effettuato) ....");
  319.             }
  320.             
  321.             if(this.debug){
  322.                 this.log.debug("@@ log["+busta.getID()+"] (inserimento "+busta.sizeListaEccezioni()+" eccezioni) ....");
  323.             }
  324.             for (int i = 0; i < busta.sizeListaEccezioni(); i++) {
  325.                 Eccezione eccezione = busta.getEccezione(i);

  327.                 //Inserimento nel DB
  328.                 String subCodiceMeta = "";
  329.                 String subCodiceMetaInsert = "";
  330.                 if(eccezione.getSubCodiceEccezione()!=null && eccezione.getSubCodiceEccezione().getSubCodice()!=null){
  331.                     subCodiceMeta = CostantiDB.TRACCE_ECCEZIONI_COLUMN_CODICE_ECCEZIONE_SUBCOD_SDK_CONSTANT+", ";
  332.                     subCodiceMetaInsert = "?,";
  333.                 }
  334.                 sqlString = "INSERT INTO "+CostantiDB.TRACCE_ECCEZIONI+" ("+
  335.                         CostantiDB.TRACCE_ECCEZIONI_COLUMN_ID_TRACCIA+", "+
  336.                         CostantiDB.TRACCE_ECCEZIONI_COLUMN_CONTESTO_CODIFICA+", "+
  337.                         CostantiDB.TRACCE_ECCEZIONI_COLUMN_CONTESTO_CODIFICA_SDK_CONSTANT+", "+
  338.                         CostantiDB.TRACCE_ECCEZIONI_COLUMN_CODICE_ECCEZIONE+", "+
  339.                         CostantiDB.TRACCE_ECCEZIONI_COLUMN_CODICE_ECCEZIONE_SDK_CONSTANT+", "+
  340.                         subCodiceMeta+
  341.                         CostantiDB.TRACCE_ECCEZIONI_COLUMN_RILEVANZA+", "+
  342.                         CostantiDB.TRACCE_ECCEZIONI_COLUMN_RILEVANZA_SDK_CONSTANT+", "+
  343.                         CostantiDB.TRACCE_ECCEZIONI_COLUMN_POSIZIONE+", "+
  344.                         CostantiDB.TRACCE_ECCEZIONI_COLUMN_GDO+
  345.                         ") VALUES (?, ?, ?, ?, ?, "+subCodiceMetaInsert+" ?, ? , ? , ?)";
  346.                 stmt = con.prepareStatement(sqlString);
  347.                 int index = 1;
  348.                 stmt.setLong(index++, idtraccia);
  349.                 JDBCUtilities.setSQLStringValue(stmt,index++, eccezione.getContestoCodificaValue(this.protocolFactory));
  350.                 JDBCUtilities.setSQLStringValue(stmt,index++, eccezione.getContestoCodifica().getEngineValue());
  351.                 JDBCUtilities.setSQLStringValue(stmt,index++, eccezione.getCodiceEccezioneValue(this.protocolFactory));
  352.                 stmt.setInt(index++, eccezione.getCodiceEccezione().getCodice());
  353.                 if(eccezione.getSubCodiceEccezione()!=null && eccezione.getSubCodiceEccezione().getSubCodice()!=null)
  354.                     stmt.setInt(index++, eccezione.getSubCodiceEccezione().getSubCodice());
  355.                 JDBCUtilities.setSQLStringValue(stmt,index++, eccezione.getRilevanzaValue(this.protocolFactory));
  356.                 JDBCUtilities.setSQLStringValue(stmt,index++, eccezione.getRilevanza().getEngineValue());
  357.                 JDBCUtilities.setSQLStringValue(stmt,index++, eccezione.getDescrizione(this.protocolFactory));
  358.                 stmt.setTimestamp(index++, gdoT);
  359.                 stmt.executeUpdate();
  360.                 stmt.close();
  361.             }
  362.             if(this.debug){
  363.                 this.log.debug("@@ log["+busta.getID()+"] (inserimento "+busta.sizeListaEccezioni()+" eccezioni effettuato) ....");
  364.             }
  365.             
  366.             if(this.debug){
  367.                 this.log.debug("@@ log["+busta.getID()+"] (inserimento "+traccia.sizeListaAllegati()+" allegati) ....");
  368.             }
  369.             for (int i = 0; i < traccia.sizeListaAllegati(); i++) {
  370.                 Allegato allegato = traccia.getAllegato(i);

  372.                 //Inserimento nel DB
  373.                 sqlString = "INSERT INTO "+CostantiDB.TRACCE_ALLEGATI+" ("+
  374.                         CostantiDB.TRACCE_ALLEGATI_COLUMN_ID_TRACCIA+", "+
  375.                         CostantiDB.TRACCE_ALLEGATI_COLUMN_CONTENT_ID+", "+
  376.                         CostantiDB.TRACCE_ALLEGATI_COLUMN_CONTENT_LOCATION+", "+
  377.                         CostantiDB.TRACCE_ALLEGATI_COLUMN_CONTENT_TYPE+", "+
  378.                         CostantiDB.TRACCE_ALLEGATI_COLUMN_DIGEST+", "+
  379.                         CostantiDB.TRACCE_ALLEGATI_COLUMN_GDO+
  380.                         ") VALUES (?, ?, ?, ?, ?, ?)";
  381.                 stmt = con.prepareStatement(sqlString);
  382.                 int index = 1;
  383.                 stmt.setLong(index++, idtraccia);
  384.                 JDBCUtilities.setSQLStringValue(stmt,index++, allegato.getContentId());
  385.                 JDBCUtilities.setSQLStringValue(stmt,index++, allegato.getContentLocation());
  386.                 JDBCUtilities.setSQLStringValue(stmt,index++, allegato.getContentType());
  387.                 JDBCUtilities.setSQLStringValue(stmt,index++, allegato.getDigest());
  388.                 stmt.setTimestamp(index++, gdoT);
  389.                 stmt.executeUpdate();
  390.                 stmt.close();
  391.             }
  392.             if(this.debug){
  393.                 this.log.debug("@@ log["+busta.getID()+"] (inserimento "+traccia.sizeListaAllegati()+" allegati effettuato) ....");
  394.             }
  395.                         
  396.             String [] propertiesNames = busta.getPropertiesNames();
  397.             if(propertiesNames!=null){
  398.                 if(this.debug){
  399.                     this.log.debug("@@ log["+busta.getID()+"] (inserimento "+propertiesNames.length+" ext-protocol-info) ....");
  400.                 }
  401.                 for (int i = 0; i < propertiesNames.length; i++) {
  402.     
  403.                     String v = busta.getProperty(propertiesNames[i]);
  404.                                         
  405.                     int limit = 2800; // TRACCE_EXT_SEARCH ON tracce_ext_protocol_info (name,value) la somma di name e value deve essere minore di 3072 bytes per mysql
  406.                     if(TipiDatabase.POSTGRESQL.equals(this.tipoDatabase)) {
  407.                         // The maximum length for a value in a B-tree index, which includes primary keys, is one third of the size of a buffer page, by default floor(8192/3) = 2730 bytes
  408.                         // Altrimenti si ha un errore del genere:
  409.                         // Caused by: org.postgresql.util.PSQLException: ERROR: index row size 2864 exceeds maximum 2712 for index "tracce_ext_search"
  410.                         //  Hint: Values larger than 1/3 of a buffer page cannot be indexed.
  411.                         //  Consider a function index of an MD5 hash of the value, or use full text indexing.
  412.                         int sum = 20; // si parte da 20, la dimensione dell'id della join
  413.                         if(propertiesNames[i]!=null) {
  414.                             sum = sum + propertiesNames[i].length();
  415.                         }
  416.                         if(v!=null) {
  417.                             sum = sum + v.length();
  418.                         }
  419.                         if(sum>2711) {
  420.                             limit = (2711 - 20) - propertiesNames[i].length();
  421.                         }
  422.                     }
  423.                     
  424.                     String columnExtV = "";
  425.                     String valueExtV = "";
  426.                     if(v!=null && v.length()>limit) {
  427.                         columnExtV = CostantiDB.TRACCE_EXT_PROTOCOL_INFO_COLUMN_EXT_VALUE+", ";
  428.                         valueExtV = ", ?";
  429.                     }
  430.                     
  431.                     //Inserimento nel DB
  432.                     sqlString = "INSERT INTO "+CostantiDB.TRACCE_EXT_INFO+" ("+
  433.                         CostantiDB.TRACCE_EXT_PROTOCOL_INFO_COLUMN_ID_TRACCIA+", "+
  434.                         CostantiDB.TRACCE_EXT_PROTOCOL_INFO_COLUMN_NAME+", "+
  435.                         CostantiDB.TRACCE_EXT_PROTOCOL_INFO_COLUMN_VALUE+", "+
  436.                         columnExtV+
  437.                         CostantiDB.TRACCE_EXT_PROTOCOL_INFO_COLUMN_GDO+
  438.                     ") VALUES (?, ?, ?"+valueExtV+", ?)";
  439.                     stmt = con.prepareStatement(sqlString);
  440.                     int index = 1;
  441.                     stmt.setLong(index++, idtraccia);
  442.                     JDBCUtilities.setSQLStringValue(stmt,index++, propertiesNames[i]);
  443.                     if(v!=null && v.length()>limit) {
  444.                         JDBCUtilities.setSQLStringValue(stmt,index++, v.substring(0, limit));
  445.                         JDBCUtilities.setSQLStringValue(stmt,index++, v);
  446.                     }
  447.                     else {
  448.                         JDBCUtilities.setSQLStringValue(stmt,index++, v);
  449.                     }
  450.                     stmt.setTimestamp(index++, gdoT);
  451.                     stmt.executeUpdate();
  452.                     stmt.close();
  453.                 
  454.                 }
  455.                 if(this.debug){
  456.                     this.log.debug("@@ log["+busta.getID()+"] (inserimento "+propertiesNames.length+" effettuato) ....");
  457.                 }
  458.             }
  459.             
  460.             if(this.debug){
  461.                 this.log.debug("@@ log["+busta.getID()+"] completato");
  462.             }

  464.         }catch(Exception e){
  465.             throw new TracciamentoException("Errore durante il tracciamento di una busta: "+e.getMessage()+"\nL'id del messaggio della busta era: "+busta.getID(),e);
  466.         }finally{
  467.             try{
  468.                 if(rs!=null)
  469.                     rs.close();
  470.             }catch(Exception e){
  471.                 // close
  472.             }
  473.             try{
  474.                 if(stmt!=null)
  475.                     stmt.close();
  476.             }catch(Exception e){
  477.                 // close
  478.             }
  479.             try{
  480.                 this.releaseConnection(cr, "traccia.log");
  481.             }catch(Exception e){
  482.                 // close
  483.             }
  484.         }
  485.     }


  488. }
Created with JaCoCo 0.8.8.202204050719