DriverConfigurazioneDB_gestioneErroreLIB.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.  */
  20. package org.openspcoop2.core.config.driver.db;

  22. import static org.openspcoop2.core.constants.CostantiDB.CREATE;
  23. import static org.openspcoop2.core.constants.CostantiDB.DELETE;
  24. import static org.openspcoop2.core.constants.CostantiDB.UPDATE;

  26. import java.sql.Connection;
  27. import java.sql.PreparedStatement;
  28. import java.sql.ResultSet;
  29. import java.sql.SQLException;

  31. import org.openspcoop2.core.commons.DBUtils;
  32. import org.openspcoop2.core.config.GestioneErrore;
  33. import org.openspcoop2.core.config.GestioneErroreCodiceTrasporto;
  34. import org.openspcoop2.core.config.GestioneErroreSoapFault;
  35. import org.openspcoop2.core.config.constants.GestioneErroreComportamento;
  36. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  37. import org.openspcoop2.core.config.driver.DriverConfigurazioneNotFound;
  38. import org.openspcoop2.core.constants.CostantiDB;
  39. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  40. import org.openspcoop2.utils.sql.ISQLQueryObject;
  41. import org.openspcoop2.utils.sql.SQLObjectFactory;

  43. /**
  44.  * DriverConfigurazioneDB_gestioneErroreLIB
  45.  * 
  46.  * @author Stefano Corallo - corallo@link.it
  47.  * @author $Author$
  48.  * @version $Rev$, $Date$
  49.  */
  50. public class DriverConfigurazioneDB_gestioneErroreLIB {


  53.     
  54.     public static GestioneErrore getGestioneErrore(long idGestioneErrore,Connection con) throws DriverConfigurazioneException,DriverConfigurazioneNotFound{
  55.         
  56.         GestioneErrore gestioneErrore = null;
  57.         
  58.         PreparedStatement stm = null;
  59.         ResultSet rs = null;
  60.         PreparedStatement stm1 = null;
  61.         ResultSet rs1 = null;
  62.         
  63.         try {
  64.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  65.             
  66.             // Get gestione errore generale
  67.             sqlQueryObject.addFromTable(CostantiDB.GESTIONE_ERRORE);
  68.             sqlQueryObject.addSelectField("comportamento_default");
  69.             sqlQueryObject.addSelectField("cadenza_rispedizione");
  70.             sqlQueryObject.addSelectField("nome");
  71.             sqlQueryObject.addWhereCondition("id=?");
  72.             String sqlQuery = sqlQueryObject.createSQLQuery();

  74.             DriverConfigurazioneDBLib.log.debug("eseguo query: " + DBUtils.formatSQLString(sqlQuery));
  75.             stm = con.prepareStatement(sqlQuery);
  76.             stm.setLong(1, idGestioneErrore);
  77.             rs = stm.executeQuery();

  79.             if (rs.next()) {
  80.                 gestioneErrore = new GestioneErrore();
  81.                 gestioneErrore.setId(idGestioneErrore);
  82.                 gestioneErrore.setComportamento(GestioneErroreComportamento.toEnumConstant(rs.getString("comportamento_default")));
  83.                 gestioneErrore.setCadenzaRispedizione(rs.getString("cadenza_rispedizione"));
  84.                 gestioneErrore.setNome(rs.getString("nome"));

  86.                 //trasporto
  87.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  88.                 sqlQueryObject.addFromTable(CostantiDB.GESTIONE_ERRORE_TRASPORTO);
  89.                 sqlQueryObject.addSelectField("*");
  90.                 sqlQueryObject.addWhereCondition("id_gestione_errore = ?");
  91.                 sqlQuery = sqlQueryObject.createSQLQuery();
  92.                 stm1 = con.prepareStatement(sqlQuery);
  93.                 stm1.setLong(1, gestioneErrore.getId());
  94.                 rs1 = stm1.executeQuery();
  95.                 while(rs1.next())
  96.                 {
  97.                     GestioneErroreCodiceTrasporto trasporto = new GestioneErroreCodiceTrasporto();
  98.                     trasporto.setComportamento(GestioneErroreComportamento.toEnumConstant(rs1.getString("comportamento")));
  99.                     trasporto.setCadenzaRispedizione(rs1.getString("cadenza_rispedizione"));
  100.                     if(rs1.getLong("valore_massimo")>0){
  101.                         String maxVal = ""+rs1.getLong("valore_massimo");
  102.                         trasporto.setValoreMassimo(!maxVal.equals("") ? Integer.valueOf(maxVal) : null);
  103.                     }
  104.                     if(rs1.getLong("valore_minimo")>0){
  105.                         String minVal = ""+rs1.getLong("valore_minimo");
  106.                         trasporto.setValoreMinimo(!minVal.equals("") ? Integer.valueOf(minVal) : null);
  107.                     }
  108.                     gestioneErrore.addCodiceTrasporto(trasporto);
  109.                 }
  110.                 rs1.close();
  111.                 stm1.close();

  113.                 //soap
  114.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  115.                 sqlQueryObject.addFromTable(CostantiDB.GESTIONE_ERRORE_SOAP);
  116.                 sqlQueryObject.addSelectField("*");
  117.                 sqlQueryObject.addWhereCondition("id_gestione_errore = ?");
  118.                 sqlQuery = sqlQueryObject.createSQLQuery();
  119.                 stm1 = con.prepareStatement(sqlQuery);
  120.                 stm1.setLong(1, gestioneErrore.getId());
  121.                 rs1 = stm1.executeQuery();
  122.                 while(rs1.next())
  123.                 {
  124.                     GestioneErroreSoapFault soap = new GestioneErroreSoapFault();
  125.                     soap.setComportamento(GestioneErroreComportamento.toEnumConstant(rs1.getString("comportamento")));
  126.                     soap.setCadenzaRispedizione(rs1.getString("cadenza_rispedizione"));
  127.                     soap.setFaultActor(rs1.getString("fault_actor"));
  128.                     soap.setFaultCode(rs1.getString("fault_code"));
  129.                     soap.setFaultString(rs1.getString("fault_string"));
  130.                     gestioneErrore.addSoapFault(soap);
  131.                 }
  132.                 rs1.close();
  133.                 stm1.close();

  135.             } else {
  136.                 throw new DriverConfigurazioneNotFound("Gestione errore con id["+idGestioneErrore+"] non presente");
  137.             }
  138.             rs.close();
  139.             stm.close();

  141.             return gestioneErrore;

  143.         } catch (SQLException se) {
  144.             throw new DriverConfigurazioneException(" SqlException: " + se.getMessage(),se);
  145.         }catch (DriverConfigurazioneNotFound e) {
  146.             throw new DriverConfigurazioneNotFound(e);
  147.         }catch (Exception se) {
  148.             throw new DriverConfigurazioneException(" Exception: " + se.getMessage(),se);
  149.         } finally {
  150.             //Chiudo statement and resultset
  151.             JDBCUtilities.closeResources(rs1, stm1);
  152.             JDBCUtilities.closeResources(rs, stm);
  153.         }
  154.     }
  155.     
  156.     public static long getIdGestioneErrore(String nomeGestioneErrore,Connection con) throws DriverConfigurazioneException
  157.     {
  158.         PreparedStatement stm = null;
  159.         ResultSet rs = null;
  160.         long idGestioneErrore=-1;
  161.         try
  162.         {
  163.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  164.             sqlQueryObject.addFromTable(CostantiDB.GESTIONE_ERRORE);
  165.             sqlQueryObject.addSelectField("id");
  166.             sqlQueryObject.addWhereCondition("nome = ?");
  167.             String query = sqlQueryObject.createSQLQuery();
  168.             stm=con.prepareStatement(query);
  169.             stm.setString(1, nomeGestioneErrore);
  170.             rs=stm.executeQuery();

  172.             if(rs.next()){
  173.                 idGestioneErrore = rs.getLong("id");
  174.             }

  176.             return idGestioneErrore;

  178.         }catch (SQLException e) {
  179.             throw new DriverConfigurazioneException(e);
  180.         }catch (Exception e) {
  181.             throw new DriverConfigurazioneException(e);
  182.         }finally
  183.         {
  184.             //Chiudo statement and resultset
  185.             JDBCUtilities.closeResources(rs, stm);

  187.         }
  188.     }
  189.     
  190.     
  191.     
  192.     public static long CRUDGestioneErroreServizioApplicativo(int type, org.openspcoop2.core.config.GestioneErrore gestioneErrore, 
  193.             long idSoggettoProprietario,long idServizioApplicativo,boolean invocazioneServizio,
  194.             Connection con)throws DriverConfigurazioneException{
  195.         if(invocazioneServizio)
  196.             return CRUDGestioneErrore(type, gestioneErrore, idSoggettoProprietario, idServizioApplicativo,1,con);
  197.         else
  198.             return CRUDGestioneErrore(type, gestioneErrore, idSoggettoProprietario, idServizioApplicativo,2,con);
  199.     }
  200.     public static long CRUDGestioneErroreComponenteCooperazione(int type, org.openspcoop2.core.config.GestioneErrore gestioneErrore, 
  201.             Connection con) throws DriverConfigurazioneException{
  202.         return CRUDGestioneErrore(type, gestioneErrore, -1,-1,3,con) ;
  203.     }
  204.     public static long CRUDGestioneErroreComponenteIntegrazione(int type, org.openspcoop2.core.config.GestioneErrore gestioneErrore, 
  205.             Connection con) throws DriverConfigurazioneException{
  206.         return CRUDGestioneErrore(type, gestioneErrore,-1,-1,4,con) ;
  207.     }
  208.     
  209.     private static long CRUDGestioneErrore(int type, org.openspcoop2.core.config.GestioneErrore gestioneErrore, 
  210.             long idSoggettoProprietario,long idServizioApplicativo,
  211.             int tipoCRUD,Connection con) throws DriverConfigurazioneException {

  213.         if (gestioneErrore == null)
  214.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB_LIB::CRUDGestioneErrore] Parametro non valido.");
  215.         
  216.         String nomeGestioneErrore = null; // Costruito obbligatoriamente dal driver
  217.         if(tipoCRUD==1 || tipoCRUD==2){
  218.             // crud servizioApplicativo invocazioneServizio(1) o rispostaAsincrona(2)
  219.             if(idSoggettoProprietario<=0){
  220.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB_LIB::CRUDGestioneErrore] Soggetto proprietario non fornito.");
  221.             }
  222.             if(idServizioApplicativo<=0){
  223.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB_LIB::CRUDGestioneErrore] Servizio applicativo non fornito.");
  224.             }
  225.             nomeGestioneErrore = "Soggetto("+idSoggettoProprietario+")_SA("+idServizioApplicativo+")_";
  226.             if(tipoCRUD==1)
  227.                 nomeGestioneErrore = nomeGestioneErrore + "INV";
  228.             else
  229.                 nomeGestioneErrore = nomeGestioneErrore + "RISP";
  230.         }else if(tipoCRUD==3){
  231.             // componente cooperazione
  232.             nomeGestioneErrore = "componenteCooperazioneGestioneErroreDefaultPdD";
  233.         }else if(tipoCRUD==4){
  234.             // componente integrazione
  235.             nomeGestioneErrore = "componenteIntegrazioneGestioneErroreDefaultPdD";
  236.         }

  238.         // updateNome
  239.         gestioneErrore.setNome(nomeGestioneErrore);

  241.         // Type
  242.         int tipoOperazione = type;
  243.         // Recupero id gestione errore se presente
  244.         long idGestioneErroreChange = -1;
  245.         if (type == CostantiDB.UPDATE){
  246.             try{
  247.                 idGestioneErroreChange = getIdGestioneErrore(nomeGestioneErrore, con);
  248.             }catch (Exception e) {
  249.                 throw new DriverConfigurazioneException(e.getMessage(),e);
  250.             }
  251.             if(idGestioneErroreChange<=0){
  252.                 tipoOperazione = CostantiDB.CREATE;
  253.             }
  254.         }
  255.         
  256.         
  257.         PreparedStatement updateStmt = null;
  258.         PreparedStatement selectStmt = null;
  259.         String updateQuery = "";
  260.         String selectQuery = "";
  261.         ResultSet selectRS = null;
  262.         int n = 0;
  263.         try {

  265.             // preparo lo statement in base al tipo di operazione
  266.             switch (tipoOperazione) {
  267.             case CREATE:
  268.                 // CREATE
  269.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  270.                 sqlQueryObject.addInsertTable(CostantiDB.GESTIONE_ERRORE);
  271.                 sqlQueryObject.addInsertField("comportamento_default", "?");
  272.                 sqlQueryObject.addInsertField("cadenza_rispedizione", "?");
  273.                 sqlQueryObject.addInsertField("nome", "?");
  274.                 updateQuery = sqlQueryObject.createSQLInsert();
  275.                 updateStmt = con.prepareStatement(updateQuery);

  277.                 updateStmt.setString(1, DriverConfigurazioneDBLib.getValue(gestioneErrore.getComportamento()));
  278.                 updateStmt.setString(2, gestioneErrore.getCadenzaRispedizione());
  279.                 updateStmt.setString(3, gestioneErrore.getNome());
  280.                 // eseguo lo statement
  281.                 n = updateStmt.executeUpdate();
  282.                 updateStmt.close();

  284.                 DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore CREATE : \n" + DBUtils.formatSQLString(updateQuery, 
  285.                         gestioneErrore.getComportamento(),gestioneErrore.getCadenzaRispedizione(),gestioneErrore.getNome()));
  286.                 DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore type = " + type + " row affected =" + n);

  288.                 // Recupero id
  289.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  290.                 sqlQueryObject.addFromTable(CostantiDB.GESTIONE_ERRORE);
  291.                 sqlQueryObject.addSelectField("id");
  292.                 sqlQueryObject.addWhereCondition("nome = ?");
  293.                 selectQuery = sqlQueryObject.createSQLQuery();
  294.                 selectStmt = con.prepareStatement(selectQuery);
  295.                 selectStmt.setString(1, gestioneErrore.getNome());
  296.                 selectRS = selectStmt.executeQuery();
  297.                 if (selectRS.next()) {
  298.                     gestioneErrore.setId(selectRS.getLong("id"));
  299.                 }else{
  300.                     throw new Exception("id gestione errore non trovato dopo inserimento con nome ["+gestioneErrore.getNome()+"]");
  301.                 }
  302.                 selectRS.close();
  303.                 selectStmt.close();
  304.                 
  305.                 // Insert gestione errore trasporto
  306.                 for(int i=0; i<gestioneErrore.sizeCodiceTrasportoList(); i++){
  307.                     GestioneErroreCodiceTrasporto tr = gestioneErrore.getCodiceTrasporto(i);
  308.                     
  309.                     int valoreMassimo = -1;
  310.                     int valoreMinimo = -1;
  311.                     if(tr.getValoreMassimo()!=null){
  312.                         valoreMassimo = tr.getValoreMassimo().intValue();
  313.                     }
  314.                     if(tr.getValoreMinimo()!=null){
  315.                         valoreMinimo = tr.getValoreMinimo().intValue();
  316.                     }
  317.                     
  318.                     
  319.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  320.                     sqlQueryObject.addInsertTable(CostantiDB.GESTIONE_ERRORE_TRASPORTO);
  321.                     sqlQueryObject.addInsertField("id_gestione_errore", "?");
  322.                     if(valoreMassimo>=0)
  323.                         sqlQueryObject.addInsertField("valore_massimo", "?");
  324.                     if(valoreMinimo>=0)
  325.                         sqlQueryObject.addInsertField("valore_minimo", "?");
  326.                     sqlQueryObject.addInsertField("comportamento", "?");
  327.                     sqlQueryObject.addInsertField("cadenza_rispedizione", "?");
  328.                     updateQuery = sqlQueryObject.createSQLInsert();
  329.                     updateStmt = con.prepareStatement(updateQuery);

  331.                     int index = 1;
  332.                     updateStmt.setLong(index, gestioneErrore.getId()); index++;
  333.                     if(valoreMassimo>=0){
  334.                         updateStmt.setInt(index, valoreMassimo); index++;
  335.                     }
  336.                     if(valoreMinimo>=0){
  337.                         updateStmt.setInt(index, valoreMinimo); index++;
  338.                     }
  339.                     updateStmt.setString(index, DriverConfigurazioneDBLib.getValue(tr.getComportamento())); index++;
  340.                     updateStmt.setString(index, tr.getCadenzaRispedizione()); index++;

  342.                     // eseguo lo statement
  343.                     n = updateStmt.executeUpdate();
  344.                     updateStmt.close();
  345.                     
  346.                     if(valoreMassimo>=0 && valoreMinimo>=0){
  347.                         DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore_Trasporto("+i+") CREATE : \n" + DBUtils.formatSQLString(updateQuery, 
  348.                                 gestioneErrore.getId(),valoreMassimo,valoreMinimo,tr.getComportamento(),tr.getCadenzaRispedizione()));
  349.                     }else if(valoreMassimo>=0){
  350.                         DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore_Trasporto("+i+") CREATE : \n" + DBUtils.formatSQLString(updateQuery, 
  351.                                 gestioneErrore.getId(),valoreMassimo,tr.getComportamento(),tr.getCadenzaRispedizione()));
  352.                     }else if(valoreMinimo>=0){
  353.                         DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore_Trasporto("+i+") CREATE : \n" + DBUtils.formatSQLString(updateQuery, 
  354.                                 gestioneErrore.getId(),valoreMinimo,tr.getComportamento(),tr.getCadenzaRispedizione()));
  355.                     }else{
  356.                         DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore_Trasporto("+i+") CREATE : \n" + DBUtils.formatSQLString(updateQuery, 
  357.                                 gestioneErrore.getId(),tr.getComportamento(),tr.getCadenzaRispedizione()));
  358.                     }
  359.                     DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore_Trasporto("+i+") type = " + type + " row affected =" + n);
  360.                 }
  361.                 
  362.                 // Insert gestione errore SOAP FAULT
  363.                 for(int i=0; i<gestioneErrore.sizeSoapFaultList(); i++){
  364.                     GestioneErroreSoapFault sf = gestioneErrore.getSoapFault(i);
  365.                                         
  366.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  367.                     sqlQueryObject.addInsertTable(CostantiDB.GESTIONE_ERRORE_SOAP);
  368.                     sqlQueryObject.addInsertField("id_gestione_errore", "?");
  369.                     sqlQueryObject.addInsertField("fault_actor", "?");
  370.                     sqlQueryObject.addInsertField("fault_code", "?");
  371.                     sqlQueryObject.addInsertField("fault_string", "?");
  372.                     sqlQueryObject.addInsertField("comportamento", "?");
  373.                     sqlQueryObject.addInsertField("cadenza_rispedizione", "?");
  374.                     updateQuery = sqlQueryObject.createSQLInsert();
  375.                     updateStmt = con.prepareStatement(updateQuery);

  377.                     updateStmt.setLong(1, gestioneErrore.getId()); 
  378.                     updateStmt.setString(2, sf.getFaultActor());
  379.                     updateStmt.setString(3,sf.getFaultCode());
  380.                     updateStmt.setString(4,sf.getFaultString());
  381.                     updateStmt.setString(5,DriverConfigurazioneDBLib.getValue(sf.getComportamento()));
  382.                     updateStmt.setString(6, sf.getCadenzaRispedizione());

  384.                     // eseguo lo statement
  385.                     n = updateStmt.executeUpdate();
  386.                     updateStmt.close();
  387.                     
  388.                     DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore_SoapFault("+i+") CREATE : \n" + DBUtils.formatSQLString(updateQuery, 
  389.                                 gestioneErrore.getId(),sf.getFaultActor(),sf.getFaultCode(),sf.getFaultString(),sf.getComportamento(),sf.getCadenzaRispedizione()));
  390.                     DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore_SoapFault("+i+") type = " + type + " row affected =" + n);
  391.                 }
  392.                 
  393.                 break;

  395.             case UPDATE:
  396.             
  397.                 // UPDATE (ci entro solo se prima ho trovato un gestore errore inserito (idGestioneErroreChange) )
  398.                     
  399.                 // Set idGestionErrore
  400.                 gestioneErrore.setId(idGestioneErroreChange);
  401.                 
  402.                 // Update gestion errore
  403.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  404.                 sqlQueryObject.addUpdateTable(CostantiDB.GESTIONE_ERRORE);
  405.                 sqlQueryObject.addUpdateField("comportamento_default", "?");
  406.                 sqlQueryObject.addUpdateField("cadenza_rispedizione", "?");
  407.                 sqlQueryObject.addWhereCondition("id=?");
  408.                 sqlQueryObject.setANDLogicOperator(true);
  409.                 updateQuery = sqlQueryObject.createSQLUpdate();
  410.                 updateStmt = con.prepareStatement(updateQuery);
  411.                 
  412.                 updateStmt.setString(1, DriverConfigurazioneDBLib.getValue(gestioneErrore.getComportamento()));
  413.                 updateStmt.setString(2, gestioneErrore.getCadenzaRispedizione());
  414.                 updateStmt.setLong(3, idGestioneErroreChange);
  415.                 n = updateStmt.executeUpdate();
  416.                 updateStmt.close();
  417.             
  418.                 DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore UPDATE : \n" + DBUtils.formatSQLString(updateQuery, 
  419.                         gestioneErrore.getComportamento(),gestioneErrore.getCadenzaRispedizione(),idGestioneErroreChange));
  420.                 DriverConfigurazioneDBLib.log.debug("CRUGestioneErrore type = " + type + " row affected =" + n);
  421.                 
  422.                 // Delete vecchie gestione errore trasporto
  423.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  424.                 sqlQueryObject.addDeleteTable(CostantiDB.GESTIONE_ERRORE_TRASPORTO);
  425.                 sqlQueryObject.addWhereCondition("id_gestione_errore=?");
  426.                 updateQuery = sqlQueryObject.createSQLDelete();
  427.                 updateStmt = con.prepareStatement(updateQuery);
  428.                 updateStmt.setLong(1, idGestioneErroreChange);
  429.                 n = updateStmt.executeUpdate();
  430.                 updateStmt.close();
  431.                 DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore (Delete old trasporto) UPDATE : \n" + DBUtils.formatSQLString(updateQuery, 
  432.                         idGestioneErroreChange));
  433.                 DriverConfigurazioneDBLib.log.debug("CRUGestioneErrore (Delete old trasporto) type = " + type + " row affected =" + n);
  434.                 
  435.                 // Delete vecchie gestione errore soap fault
  436.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  437.                 sqlQueryObject.addDeleteTable(CostantiDB.GESTIONE_ERRORE_SOAP);
  438.                 sqlQueryObject.addWhereCondition("id_gestione_errore=?");
  439.                 updateQuery = sqlQueryObject.createSQLDelete();
  440.                 updateStmt = con.prepareStatement(updateQuery);
  441.                 updateStmt.setLong(1, idGestioneErroreChange);
  442.                 n = updateStmt.executeUpdate();
  443.                 updateStmt.close();
  444.                 DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore (Delete old soap fault) UPDATE : \n" + DBUtils.formatSQLString(updateQuery, 
  445.                         idGestioneErroreChange));
  446.                 DriverConfigurazioneDBLib.log.debug("CRUGestioneErrore (Delete old soap fault) type = " + type + " row affected =" + n);
  447.                 
  448.                 //  Insert gestione errore trasporto
  449.                 for(int i=0; i<gestioneErrore.sizeCodiceTrasportoList(); i++){
  450.                     GestioneErroreCodiceTrasporto tr = gestioneErrore.getCodiceTrasporto(i);
  451.                     
  452.                     int valoreMassimo = -1;
  453.                     int valoreMinimo = -1;
  454.                     if(tr.getValoreMassimo()!=null){
  455.                         valoreMassimo = tr.getValoreMassimo().intValue();
  456.                     }
  457.                     if(tr.getValoreMinimo()!=null){
  458.                         valoreMinimo = tr.getValoreMinimo().intValue();
  459.                     }
  460.                     
  461.                     
  462.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  463.                     sqlQueryObject.addInsertTable(CostantiDB.GESTIONE_ERRORE_TRASPORTO);
  464.                     sqlQueryObject.addInsertField("id_gestione_errore", "?");
  465.                     if(valoreMassimo>=0)
  466.                         sqlQueryObject.addInsertField("valore_massimo", "?");
  467.                     if(valoreMinimo>=0)
  468.                         sqlQueryObject.addInsertField("valore_minimo", "?");
  469.                     sqlQueryObject.addInsertField("comportamento", "?");
  470.                     sqlQueryObject.addInsertField("cadenza_rispedizione", "?");
  471.                     updateQuery = sqlQueryObject.createSQLInsert();
  472.                     updateStmt = con.prepareStatement(updateQuery);

  474.                     int index = 1;
  475.                     updateStmt.setLong(index, gestioneErrore.getId()); index++;
  476.                     if(valoreMassimo>=0){
  477.                         updateStmt.setInt(index, valoreMassimo); index++;
  478.                     }
  479.                     if(valoreMinimo>=0){
  480.                         updateStmt.setInt(index, valoreMinimo); index++;
  481.                     }
  482.                     updateStmt.setString(index, DriverConfigurazioneDBLib.getValue(tr.getComportamento())); index++;
  483.                     updateStmt.setString(index, tr.getCadenzaRispedizione()); index++;

  485.                     // eseguo lo statement
  486.                     n = updateStmt.executeUpdate();
  487.                     updateStmt.close();
  488.                     
  489.                     if(valoreMassimo>=0 && valoreMinimo>=0){
  490.                         DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore_Trasporto("+i+") CREATE : \n" + DBUtils.formatSQLString(updateQuery, 
  491.                                 gestioneErrore.getId(),valoreMassimo,valoreMinimo,tr.getComportamento(),tr.getCadenzaRispedizione()));
  492.                     }else if(valoreMassimo>=0){
  493.                         DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore_Trasporto("+i+") CREATE : \n" + DBUtils.formatSQLString(updateQuery, 
  494.                                 gestioneErrore.getId(),valoreMassimo,tr.getComportamento(),tr.getCadenzaRispedizione()));
  495.                     }else if(valoreMinimo>=0){
  496.                         DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore_Trasporto("+i+") CREATE : \n" + DBUtils.formatSQLString(updateQuery, 
  497.                                 gestioneErrore.getId(),valoreMinimo,tr.getComportamento(),tr.getCadenzaRispedizione()));
  498.                     }else{
  499.                         DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore_Trasporto("+i+") CREATE : \n" + DBUtils.formatSQLString(updateQuery, 
  500.                                 gestioneErrore.getId(),tr.getComportamento(),tr.getCadenzaRispedizione()));
  501.                     }
  502.                     DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore_Trasporto("+i+") type = " + type + " row affected =" + n);
  503.                 }
  504.                 
  505.                 // Insert gestione errore SOAP FAULT
  506.                 for(int i=0; i<gestioneErrore.sizeSoapFaultList(); i++){
  507.                     GestioneErroreSoapFault sf = gestioneErrore.getSoapFault(i);
  508.                                         
  509.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  510.                     sqlQueryObject.addInsertTable(CostantiDB.GESTIONE_ERRORE_SOAP);
  511.                     sqlQueryObject.addInsertField("id_gestione_errore", "?");
  512.                     sqlQueryObject.addInsertField("fault_actor", "?");
  513.                     sqlQueryObject.addInsertField("fault_code", "?");
  514.                     sqlQueryObject.addInsertField("fault_string", "?");
  515.                     sqlQueryObject.addInsertField("comportamento", "?");
  516.                     sqlQueryObject.addInsertField("cadenza_rispedizione", "?");
  517.                     updateQuery = sqlQueryObject.createSQLInsert();
  518.                     updateStmt = con.prepareStatement(updateQuery);

  520.                     updateStmt.setLong(1, gestioneErrore.getId()); 
  521.                     updateStmt.setString(2, sf.getFaultActor());
  522.                     updateStmt.setString(3,sf.getFaultCode());
  523.                     updateStmt.setString(4,sf.getFaultString());
  524.                     updateStmt.setString(5,DriverConfigurazioneDBLib.getValue(sf.getComportamento()));
  525.                     updateStmt.setString(6, sf.getCadenzaRispedizione());

  527.                     // eseguo lo statement
  528.                     n = updateStmt.executeUpdate();
  529.                     updateStmt.close();
  530.                     
  531.                     DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore_SoapFault("+i+") CREATE : \n" + DBUtils.formatSQLString(updateQuery, 
  532.                                 gestioneErrore.getId(),sf.getFaultActor(),sf.getFaultCode(),sf.getFaultString(),sf.getComportamento(),sf.getCadenzaRispedizione()));
  533.                     DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore_SoapFault("+i+") type = " + type + " row affected =" + n);
  534.                 }
  535.                 
  536.                 break;

  538.             case DELETE:
  539.                 // DELETE
  540.                 
  541.                 long idGestioneErrore = getIdGestioneErrore(nomeGestioneErrore, con);
  542.                 
  543.                 gestioneErrore.setId(idGestioneErrore);
  544.                 
  545.                 if(idGestioneErrore>0){
  546.                     
  547.                     // Delete gestione errore trasporto
  548.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  549.                     sqlQueryObject.addDeleteTable(CostantiDB.GESTIONE_ERRORE_TRASPORTO);
  550.                     sqlQueryObject.addWhereCondition("id_gestione_errore=?");
  551.                     updateQuery = sqlQueryObject.createSQLDelete();
  552.                     updateStmt = con.prepareStatement(updateQuery);
  553.                     updateStmt.setLong(1, idGestioneErrore);
  554.                     n = updateStmt.executeUpdate();
  555.                     updateStmt.close();
  556.                     DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore (Delete trasporto) UPDATE : \n" + DBUtils.formatSQLString(updateQuery, 
  557.                             idGestioneErrore));
  558.                     DriverConfigurazioneDBLib.log.debug("CRUGestioneErrore (Delete trasporto) type = " + type + " row affected =" + n);
  559.                     
  560.                     // Delete gestione errore soap fault
  561.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  562.                     sqlQueryObject.addDeleteTable(CostantiDB.GESTIONE_ERRORE_SOAP);
  563.                     sqlQueryObject.addWhereCondition("id_gestione_errore=?");
  564.                     updateQuery = sqlQueryObject.createSQLDelete();
  565.                     updateStmt = con.prepareStatement(updateQuery);
  566.                     updateStmt.setLong(1, idGestioneErrore);
  567.                     n = updateStmt.executeUpdate();
  568.                     updateStmt.close();
  569.                     DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore (Delete soap fault) UPDATE : \n" + DBUtils.formatSQLString(updateQuery, 
  570.                             idGestioneErrore));
  571.                     DriverConfigurazioneDBLib.log.debug("CRUGestioneErrore (Delete soap fault) type = " + type + " row affected =" + n);

  573.                     // Delete gestione errore
  574.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  575.                     sqlQueryObject.addDeleteTable(CostantiDB.GESTIONE_ERRORE);
  576.                     sqlQueryObject.addWhereCondition("id=?");
  577.                     updateQuery = sqlQueryObject.createSQLDelete();
  578.                     updateStmt = con.prepareStatement(updateQuery);
  579.                     updateStmt.setLong(1, idGestioneErrore);
  580.                     n = updateStmt.executeUpdate();
  581.                     updateStmt.close();
  582.     
  583.                     DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore type = " + type + " row affected =" + n);
  584.                     DriverConfigurazioneDBLib.log.debug("CRUDGestioneErrore DELETE : \n" + DBUtils.formatSQLString(updateQuery, 
  585.                             idGestioneErrore));
  586.                     
  587.                 }
  588.                 break;
  589.             }


  592.             return n;

  594.         } catch (SQLException se) {
  595.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB_LIB::CRUDGestioneErrore] SQLException [" + se.getMessage() + "].",se);
  596.         }catch (Exception se) {
  597.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB_LIB::CRUDGestioneErrore] Exception [" + se.getMessage() + "].",se);
  598.         } finally {         
  599.             JDBCUtilities.closeResources(selectRS, selectStmt);
  600.             JDBCUtilities.closeResources(updateStmt);
  601.         }
  602.     }

  604.     
  605. }
Created with JaCoCo 0.8.8.202204050719