DriverConfigurazioneDBTrasformazioniLib.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;
  30. import java.util.ArrayList;
  31. import java.util.Collections;
  32. import java.util.HashMap;
  33. import java.util.List;

  35. import org.openspcoop2.core.commons.DBUtils;
  36. import org.openspcoop2.core.config.TrasformazioneRegola;
  37. import org.openspcoop2.core.config.TrasformazioneRegolaApplicabilitaRichiesta;
  38. import org.openspcoop2.core.config.TrasformazioneRegolaApplicabilitaRisposta;
  39. import org.openspcoop2.core.config.TrasformazioneRegolaApplicabilitaServizioApplicativo;
  40. import org.openspcoop2.core.config.TrasformazioneRegolaApplicabilitaSoggetto;
  41. import org.openspcoop2.core.config.TrasformazioneRegolaParametro;
  42. import org.openspcoop2.core.config.TrasformazioneRegolaRichiesta;
  43. import org.openspcoop2.core.config.TrasformazioneRegolaRisposta;
  44. import org.openspcoop2.core.config.TrasformazioneRest;
  45. import org.openspcoop2.core.config.TrasformazioneSoap;
  46. import org.openspcoop2.core.config.TrasformazioneSoapRisposta;
  47. import org.openspcoop2.core.config.Trasformazioni;
  48. import org.openspcoop2.core.config.constants.StatoFunzionalita;
  49. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  50. import org.openspcoop2.core.constants.CostantiDB;
  51. import org.openspcoop2.utils.TipiDatabase;
  52. import org.openspcoop2.utils.jdbc.CustomKeyGeneratorObject;
  53. import org.openspcoop2.utils.jdbc.IJDBCAdapter;
  54. import org.openspcoop2.utils.jdbc.InsertAndGeneratedKey;
  55. import org.openspcoop2.utils.jdbc.InsertAndGeneratedKeyJDBCType;
  56. import org.openspcoop2.utils.jdbc.InsertAndGeneratedKeyObject;
  57. import org.openspcoop2.utils.jdbc.JDBCAdapterException;
  58. import org.openspcoop2.utils.jdbc.JDBCAdapterFactory;
  59. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  60. import org.openspcoop2.utils.sql.ISQLQueryObject;
  61. import org.openspcoop2.utils.sql.SQLObjectFactory;

  63. /**
  64.  * DriverConfigurazioneDB_trasformazioniLIB
  65.  * 
  66.  * @author Stefano Corallo - corallo@link.it
  67.  * @author $Author$
  68.  * @version $Rev$, $Date$
  69.  */
  70. public class DriverConfigurazioneDBTrasformazioniLib {
  71.     
  72.     private DriverConfigurazioneDBTrasformazioniLib() {}

  74.     private static final String ESEGUO_QUERY_PREFIX = "eseguo query : ";
  75.     
  76.     private static void normalizePositionsEngine(Trasformazioni trasformazioni) {
  77.         if(trasformazioni==null || trasformazioni.sizeRegolaList()<=0) {
  78.             return;
  79.         }
  80.         
  81.         List<Integer> posizioni = new ArrayList<>();
  82.         HashMap<Integer, TrasformazioneRegola> regole = new HashMap<>();
  83.         for (TrasformazioneRegola regola : trasformazioni.getRegolaList()) {
  84.             posizioni.add(regola.getPosizione());
  85.             regole.put(regola.getPosizione(), regola);
  86.         }
  87.         while(trasformazioni.sizeRegolaList()>0) {
  88.             trasformazioni.removeRegola(0);
  89.         }
  90.         Collections.sort( posizioni );
  91.         int posNew = 1;
  92.         for (Integer pos : posizioni) {
  93.             TrasformazioneRegola regola = regole.get(pos);
  94.             regola.setPosizione(posNew);
  95.             trasformazioni.addRegola(regola);
  96.             posNew++;
  97.         }
  98.         
  99.         // normalizzazione delle risposte
  100.         for (TrasformazioneRegola regola : trasformazioni.getRegolaList()) {
  101.             
  102.             if(regola.getRispostaList()==null || regola.sizeRispostaList()<=0){
  103.                 continue;
  104.             }
  105.             
  106.             List<Integer> posizioniRisposta = new ArrayList<>();
  107.             HashMap<Integer, TrasformazioneRegolaRisposta> regoleRisposta = new HashMap<>();
  108.             for (TrasformazioneRegolaRisposta regolaRisposta : regola.getRispostaList()) {
  109.                 posizioniRisposta.add(regolaRisposta.getPosizione());
  110.                 regoleRisposta.put(regolaRisposta.getPosizione(), regolaRisposta);
  111.             }
  112.             while(regola.sizeRispostaList()>0) {
  113.                 regola.removeRisposta(0);
  114.             }
  115.             Collections.sort( posizioniRisposta );
  116.             int posRispostaNew = 1;
  117.             for (Integer posRisposta : posizioniRisposta) {
  118.                 TrasformazioneRegolaRisposta regolaRisposta = regoleRisposta.get(posRisposta);
  119.                 regolaRisposta.setPosizione(posRispostaNew);
  120.                 regola.addRisposta(regolaRisposta);
  121.                 posRispostaNew++;
  122.             }
  123.         }
  124.     }
  125.     
  126.     static void CRUDTrasformazioni(int type, Connection con, Trasformazioni trasformazioni, 
  127.             Long idProprietario, boolean portaDelegata) throws DriverConfigurazioneException, JDBCAdapterException {
  128.         
  129.         PreparedStatement updateStmt = null;
  130.         ResultSet rs = null;
  131.         IJDBCAdapter jdbcAdapter = JDBCAdapterFactory.createJDBCAdapter(DriverConfigurazioneDBLib.tipoDB);
  132.         try {
  133.             switch (type) {
  134.             case CREATE:
  135.         
  136.                 if(trasformazioni==null || trasformazioni.sizeRegolaList()<=0) {
  137.                     break;
  138.                 }
  139.                 
  140.                 normalizePositionsEngine(trasformazioni);
  141.                 
  142.                 for (TrasformazioneRegola regola : trasformazioni.getRegolaList()) {
  143.                     
  144.                     String applicabilitaAzioni = null;
  145.                     if(regola.getApplicabilita()!=null && regola.getApplicabilita().sizeAzioneList()>0) {
  146.                         StringBuilder bf = new StringBuilder();
  147.                         for (int i = 0; i < regola.getApplicabilita().sizeAzioneList(); i++) {
  148.                             if(i>0) {
  149.                                 bf.append(",");
  150.                             }
  151.                             bf.append(regola.getApplicabilita().getAzione(i));
  152.                         }
  153.                         if(bf.length()>0) {
  154.                             applicabilitaAzioni = bf.toString();
  155.                         }
  156.                     }
  157.                     
  158.                     String applicabilitaCT = null;
  159.                     if(regola.getApplicabilita()!=null && regola.getApplicabilita().sizeContentTypeList()>0) {
  160.                         StringBuilder bf = new StringBuilder();
  161.                         for (int i = 0; i < regola.getApplicabilita().sizeContentTypeList(); i++) {
  162.                             if(i>0) {
  163.                                 bf.append(",");
  164.                             }
  165.                             bf.append(regola.getApplicabilita().getContentType(i));
  166.                         }
  167.                         if(bf.length()>0) {
  168.                             applicabilitaCT = bf.toString();
  169.                         }
  170.                     }
  171.                     
  172.                     String applicabilitaConnettori = null;
  173.                     if(regola.getApplicabilita()!=null && regola.getApplicabilita().sizeConnettoreList()>0) {
  174.                         StringBuilder bf = new StringBuilder();
  175.                         for (int i = 0; i < regola.getApplicabilita().sizeConnettoreList(); i++) {
  176.                             if(i>0) {
  177.                                 bf.append(",");
  178.                             }
  179.                             bf.append(regola.getApplicabilita().getConnettore(i));
  180.                         }
  181.                         if(bf.length()>0) {
  182.                             applicabilitaConnettori = bf.toString();
  183.                         }
  184.                     }
  185.                     
  186.                     List<InsertAndGeneratedKeyObject> listInsertAndGeneratedKeyObject = new ArrayList<>();
  187.                     listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("id_porta", idProprietario , InsertAndGeneratedKeyJDBCType.LONG) );
  188.                     listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("nome", regola.getNome() , InsertAndGeneratedKeyJDBCType.STRING) );
  189.                     listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRASFORMAZIONI_COLUMN_POSIZIONE, regola.getPosizione() , InsertAndGeneratedKeyJDBCType.INT) );
  190.                     listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("stato", DriverConfigurazioneDBLib.getValue(regola.getStato()) , InsertAndGeneratedKeyJDBCType.STRING) );
  191.                     listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("applicabilita_azioni", applicabilitaAzioni , InsertAndGeneratedKeyJDBCType.STRING) );
  192.                     listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRASFORMAZIONI_COLUMN_APPLICABILITA_CT, applicabilitaCT , InsertAndGeneratedKeyJDBCType.STRING) );
  193.                     listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRASFORMAZIONI_COLUMN_APPLICABILITA_PATTERN, (regola.getApplicabilita()!=null ? regola.getApplicabilita().getPattern() : null) , InsertAndGeneratedKeyJDBCType.STRING) );
  194.                     listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("applicabilita_connettori", applicabilitaConnettori , InsertAndGeneratedKeyJDBCType.STRING) );
  195.                     listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("req_conversione_enabled", ( regola.getRichiesta()!=null && regola.getRichiesta().getConversione()) ? CostantiDB.TRUE : CostantiDB.FALSE , InsertAndGeneratedKeyJDBCType.INT) );
  196.                     listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("req_conversione_tipo", (regola.getRichiesta()!=null ? regola.getRichiesta().getConversioneTipo() : null) , InsertAndGeneratedKeyJDBCType.STRING) );
  197.                     listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("req_content_type", (regola.getRichiesta()!=null ? regola.getRichiesta().getContentType() : null) , InsertAndGeneratedKeyJDBCType.STRING) );
  198.                     if(regola.getRichiesta()!=null && regola.getRichiesta().getTrasformazioneRest()!=null) {
  199.                         listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("rest_transformation", CostantiDB.TRUE , InsertAndGeneratedKeyJDBCType.INT) );
  200.                         listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("rest_method", regola.getRichiesta().getTrasformazioneRest().getMetodo() , InsertAndGeneratedKeyJDBCType.STRING) );
  201.                         listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("rest_path", regola.getRichiesta().getTrasformazioneRest().getPath() , InsertAndGeneratedKeyJDBCType.STRING) );
  202.                     }
  203.                     if(regola.getRichiesta()!=null && regola.getRichiesta().getTrasformazioneSoap()!=null) {
  204.                         listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("soap_transformation", CostantiDB.TRUE , InsertAndGeneratedKeyJDBCType.INT) );
  205.                         listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("soap_version", DriverConfigurazioneDBLib.getValue(regola.getRichiesta().getTrasformazioneSoap().getVersione()) , InsertAndGeneratedKeyJDBCType.STRING) );
  206.                         listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("soap_action", regola.getRichiesta().getTrasformazioneSoap().getSoapAction() , InsertAndGeneratedKeyJDBCType.STRING) );
  207.                         listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRASFORMAZIONI_COLUMN_SOAP_ENVELOPE, (regola.getRichiesta().getTrasformazioneSoap().getEnvelope() ? CostantiDB.TRUE : CostantiDB.FALSE) , InsertAndGeneratedKeyJDBCType.INT) );
  208.                         listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRASFORMAZIONI_COLUMN_SOAP_ENVELOPE_AS_ATTACH, (regola.getRichiesta().getTrasformazioneSoap().getEnvelopeAsAttachment() ? CostantiDB.TRUE : CostantiDB.FALSE) , InsertAndGeneratedKeyJDBCType.INT) );
  209.                         listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRASFORMAZIONI_COLUMN_SOAP_ENVELOPE_TIPO, regola.getRichiesta().getTrasformazioneSoap().getEnvelopeBodyConversioneTipo() , InsertAndGeneratedKeyJDBCType.STRING) );
  210.                     }
  211.                     // Insert and return generated key
  212.                     String tableName = null;
  213.                     String columnIdName = null;
  214.                     String sequence = null;
  215.                     String tableForId = null;
  216.                     if(portaDelegata) {
  217.                         tableName = CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI;
  218.                         columnIdName = CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_COLUMN_ID;
  219.                         sequence = CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_SEQUENCE;
  220.                         tableForId = CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_TABLE_FOR_ID;
  221.                     }
  222.                     else {
  223.                         tableName = CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI;
  224.                         columnIdName = CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_COLUMN_ID;
  225.                         sequence = CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_SEQUENCE;
  226.                         tableForId = CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_TABLE_FOR_ID;
  227.                     }
  228.                     long idtrasformazione = InsertAndGeneratedKey.insertAndReturnGeneratedKey(con, TipiDatabase.toEnumConstant(DriverConfigurazioneDBLib.tipoDB), 
  229.                             new CustomKeyGeneratorObject(tableName, columnIdName, sequence, tableForId),
  230.                             listInsertAndGeneratedKeyObject.toArray(new InsertAndGeneratedKeyObject[1]));
  231.                     if(idtrasformazione<=0){
  232.                         throw new DriverConfigurazioneException("ID autoincrementale non ottenuto");
  233.                     }
  234.                     
  235.                     if( regola.getRichiesta()!=null && 
  236.                             (
  237.                                     regola.getRichiesta().getConversioneTemplate()!=null 
  238.                                     ||
  239.                                     (regola.getRichiesta().getTrasformazioneSoap()!=null && regola.getRichiesta().getTrasformazioneSoap().getEnvelopeBodyConversioneTemplate()!=null)
  240.                             ) ) {
  241.                         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  242.                         sqlQueryObject.addUpdateTable(tableName);
  243.                         if(regola.getRichiesta().getConversioneTemplate()!=null ) {
  244.                             sqlQueryObject.addUpdateField("req_conversione_template", "?");
  245.                         }
  246.                         if(regola.getRichiesta().getTrasformazioneSoap()!=null && regola.getRichiesta().getTrasformazioneSoap().getEnvelopeBodyConversioneTemplate()!=null) {
  247.                             sqlQueryObject.addUpdateField(CostantiDB.TRASFORMAZIONI_COLUMN_SOAP_ENVELOPE_TEMPLATE, "?");
  248.                         }
  249.                         sqlQueryObject.addWhereCondition(columnIdName+"=?");
  250.                         String updateQuery = sqlQueryObject.createSQLUpdate();
  251.                         updateStmt = con.prepareStatement(updateQuery);
  252.                         int index = 1;
  253.                         if(regola.getRichiesta().getConversioneTemplate()!=null ) {
  254.                             jdbcAdapter.setBinaryData(updateStmt, index++, regola.getRichiesta()!=null ? regola.getRichiesta().getConversioneTemplate() : null);
  255.                         }
  256.                         if(regola.getRichiesta().getTrasformazioneSoap()!=null && regola.getRichiesta().getTrasformazioneSoap().getEnvelopeBodyConversioneTemplate()!=null) {
  257.                             jdbcAdapter.setBinaryData(updateStmt, index++, regola.getRichiesta().getTrasformazioneSoap().getEnvelopeBodyConversioneTemplate());
  258.                         }
  259.                         updateStmt.setLong(index++, idtrasformazione);
  260.                         updateStmt.executeUpdate();
  261.                         updateStmt.close();
  262.                     }
  263.                 
  264.                     
  265.                     if(regola.getRichiesta()!=null) {
  266.                         
  267.                         if(regola.getApplicabilita()!=null) {
  268.                             
  269.                             if(!portaDelegata && regola.getApplicabilita().sizeSoggettoList()>0) {
  270.                                 // Soggetti
  271.                                 int n=0;
  272.                                 for (int j = 0; j < regola.getApplicabilita().sizeSoggettoList(); j++) {
  273.                                     TrasformazioneRegolaApplicabilitaSoggetto soggetto = regola.getApplicabilita().getSoggetto(j);
  274.                                     ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  275.                                     sqlQueryObject.addInsertTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_SOGGETTI);
  276.                                     sqlQueryObject.addInsertField(CostantiDB.TRASFORMAZIONI_COLUMN_ID_RIF_TRASFORMAZIONE, "?");
  277.                                     sqlQueryObject.addInsertField(CostantiDB.TRASFORMAZIONI_COLUMN_TIPO_SOGGETTO, "?");
  278.                                     sqlQueryObject.addInsertField(CostantiDB.TRASFORMAZIONI_COLUMN_NOME_SOGGETTO, "?");
  279.                                     String sqlQuery = sqlQueryObject.createSQLInsert();
  280.                                     updateStmt = con.prepareStatement(sqlQuery);
  281.                                     updateStmt.setLong(1, idtrasformazione);
  282.                                     updateStmt.setString(2, soggetto.getTipo());
  283.                                     updateStmt.setString(3, soggetto.getNome());
  284.                                     updateStmt.executeUpdate();
  285.                                     updateStmt.close();
  286.                                     n++;
  287.                                     DriverConfigurazioneDBLib.logDebug("Aggiunto soggetto [" + soggetto.getTipo() + "/"+soggetto.getNome()+"] alla Trasformazione[" + idtrasformazione + "]");
  288.                                 }
  289.                                 
  290.                                 DriverConfigurazioneDBLib.logDebug("Aggiunti " + n + " soggetti alla Trasformazione[" + idtrasformazione + "]");
  291.                             }
  292.                             
  293.                             
  294.                             // serviziapplicativi
  295.                             if(regola.getApplicabilita().sizeServizioApplicativoList()>0) {
  296.                                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  297.                                 if(portaDelegata) {
  298.                                     sqlQueryObject.addInsertTable(CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_SA);
  299.                                 }
  300.                                 else {
  301.                                     sqlQueryObject.addInsertTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_SA);
  302.                                 }
  303.                                 sqlQueryObject.addInsertField(CostantiDB.TRASFORMAZIONI_COLUMN_ID_RIF_TRASFORMAZIONE, "?");
  304.                                 sqlQueryObject.addInsertField("id_servizio_applicativo", "?");
  305.                                 String sqlQuery = sqlQueryObject.createSQLInsert();
  306.                                 updateStmt = con.prepareStatement(sqlQuery);
  307.                 
  308.                                 int i = 0;
  309.                                 for (i = 0; i < regola.getApplicabilita().sizeServizioApplicativoList(); i++) {
  310.                                     TrasformazioneRegolaApplicabilitaServizioApplicativo servizioApplicativo = regola.getApplicabilita().getServizioApplicativo(i);
  311.                                     String nomeSA = servizioApplicativo.getNome();
  312.                                     String nomeProprietarioSA = servizioApplicativo.getNomeSoggettoProprietario();
  313.                                     String tipoProprietarioSA = servizioApplicativo.getTipoSoggettoProprietario();
  314.                                     if (nomeSA == null || nomeSA.equals(""))
  315.                                         throw new DriverConfigurazioneException("[CRUDPortaApplicativa(CREATE)[Transf]::Nome del ServizioApplicativo associato non valido.");
  316.                                     if (nomeProprietarioSA == null || nomeProprietarioSA.equals(""))
  317.                                         throw new DriverConfigurazioneException("[CRUDPortaApplicativa(CREATE)[Transf]::Nome Proprietario del ServizioApplicativo associato non valido.");
  318.                                     if (tipoProprietarioSA == null || tipoProprietarioSA.equals(""))
  319.                                         throw new DriverConfigurazioneException("[CRUDPortaApplicativa(CREATE)[Transf]::Tipo Proprietario del ServizioApplicativo associato non valido.");
  320.                 
  321.                                     long idSA = DriverConfigurazioneDB_serviziApplicativiLIB.getIdServizioApplicativo(nomeSA, tipoProprietarioSA, nomeProprietarioSA, con, DriverConfigurazioneDBLib.tipoDB,DriverConfigurazioneDBLib.tabellaSoggetti);
  322.                 
  323.                                     if (idSA <= 0)
  324.                                         throw new DriverConfigurazioneException("Impossibile recuperare l'id del Servizio Applicativo [" + nomeSA + "] di [" + tipoProprietarioSA + "/" + nomeProprietarioSA + "]");
  325.                 
  326.                                     updateStmt.setLong(1, idtrasformazione);
  327.                                     updateStmt.setLong(2, idSA);
  328.                                     updateStmt.executeUpdate();
  329.                                 }
  330.                                 updateStmt.close();
  331.                                 DriverConfigurazioneDBLib.logDebug("Inseriti " + i + " servizi applicativi autorizzati associati alla Trasformazione[" + idtrasformazione + "]");
  332.                             }
  333.                             
  334.                         }
  335.                         
  336.                         if(regola.getRichiesta().sizeHeaderList()>0) {
  337.                             for (TrasformazioneRegolaParametro parametro : regola.getRichiesta().getHeaderList()) {
  338.                                 
  339.                                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  340.                                 if(portaDelegata) {
  341.                                     sqlQueryObject.addInsertTable(CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_HEADER);
  342.                                 }
  343.                                 else {
  344.                                     sqlQueryObject.addInsertTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_HEADER);
  345.                                 }
  346.                                 sqlQueryObject.addInsertField(CostantiDB.TRASFORMAZIONI_COLUMN_ID_RIF_TRASFORMAZIONE, "?");
  347.                                 sqlQueryObject.addInsertField("tipo", "?");
  348.                                 sqlQueryObject.addInsertField("nome", "?");
  349.                                 sqlQueryObject.addInsertField(CostantiDB.TRASFORMAZIONI_COLUMN_VALORE, "?");
  350.                                 sqlQueryObject.addInsertField(CostantiDB.TRASFORMAZIONI_COLUMN_IDENTIFICAZIONE_FALLITA, "?");
  351.                                 
  352.                                 String updateQuery = sqlQueryObject.createSQLInsert();
  353.                                 updateStmt = con.prepareStatement(updateQuery);
  354.                                 int index = 1;
  355.                                 updateStmt.setLong(index++, idtrasformazione);
  356.                                 updateStmt.setString(index++, DriverConfigurazioneDBLib.getValue(parametro.getConversioneTipo()));
  357.                                 updateStmt.setString(index++, parametro.getNome());
  358.                                 updateStmt.setString(index++, parametro.getValore());
  359.                                 updateStmt.setString(index++, DriverConfigurazioneDBLib.getValue(parametro.getIdentificazioneFallita()));
  360.                                 updateStmt.executeUpdate();
  361.                                 updateStmt.close();
  362.                             }
  363.                         }
  364.                         
  365.                         if(regola.getRichiesta().sizeParametroUrlList()>0) {
  366.                             for (TrasformazioneRegolaParametro parametro : regola.getRichiesta().getParametroUrlList()) {
  367.                                 
  368.                                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  369.                                 if(portaDelegata) {
  370.                                     sqlQueryObject.addInsertTable(CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_URL);
  371.                                 }
  372.                                 else {
  373.                                     sqlQueryObject.addInsertTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_URL);
  374.                                 }
  375.                                 sqlQueryObject.addInsertField(CostantiDB.TRASFORMAZIONI_COLUMN_ID_RIF_TRASFORMAZIONE, "?");
  376.                                 sqlQueryObject.addInsertField("tipo", "?");
  377.                                 sqlQueryObject.addInsertField("nome", "?");
  378.                                 sqlQueryObject.addInsertField(CostantiDB.TRASFORMAZIONI_COLUMN_VALORE, "?");
  379.                                 sqlQueryObject.addInsertField(CostantiDB.TRASFORMAZIONI_COLUMN_IDENTIFICAZIONE_FALLITA, "?");
  380.                                 
  381.                                 String updateQuery = sqlQueryObject.createSQLInsert();
  382.                                 updateStmt = con.prepareStatement(updateQuery);
  383.                                 int index = 1;
  384.                                 updateStmt.setLong(index++, idtrasformazione);
  385.                                 updateStmt.setString(index++, DriverConfigurazioneDBLib.getValue(parametro.getConversioneTipo()));
  386.                                 updateStmt.setString(index++, parametro.getNome());
  387.                                 updateStmt.setString(index++, parametro.getValore());
  388.                                 updateStmt.setString(index++, DriverConfigurazioneDBLib.getValue(parametro.getIdentificazioneFallita()));
  389.                                 updateStmt.executeUpdate();
  390.                                 updateStmt.close();
  391.                             }
  392.                         }
  393.                     }
  394.                     
  395.                     if(regola.sizeRispostaList()>0) {
  396.                         
  397.                         for (TrasformazioneRegolaRisposta regolaRisposta : regola.getRispostaList()) {
  398.                             
  399.                             String applicabilitaCtResponse = null;
  400.                             if(regolaRisposta.getApplicabilita()!=null && regolaRisposta.getApplicabilita().sizeContentTypeList()>0) {
  401.                                 StringBuilder bf = new StringBuilder();
  402.                                 for (int i = 0; i < regolaRisposta.getApplicabilita().sizeContentTypeList(); i++) {
  403.                                     if(i>0) {
  404.                                         bf.append(",");
  405.                                     }
  406.                                     bf.append(regolaRisposta.getApplicabilita().getContentType(i));
  407.                                 }
  408.                                 if(bf.length()>0) {
  409.                                     applicabilitaCtResponse = bf.toString();
  410.                                 }
  411.                             }
  412.                             
  413.                             listInsertAndGeneratedKeyObject = new ArrayList<>();
  414.                             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRASFORMAZIONI_COLUMN_ID_RIF_TRASFORMAZIONE, idtrasformazione , InsertAndGeneratedKeyJDBCType.LONG) );
  415.                             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("nome", regolaRisposta.getNome() , InsertAndGeneratedKeyJDBCType.STRING) );
  416.                             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRASFORMAZIONI_COLUMN_POSIZIONE, regolaRisposta.getPosizione() , InsertAndGeneratedKeyJDBCType.INT) );
  417.                             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("applicabilita_status_min", 
  418.                                     (regolaRisposta.getApplicabilita()!=null && regolaRisposta.getApplicabilita().getReturnCodeMin()!=null && 
  419.                                     regolaRisposta.getApplicabilita().getReturnCodeMin().intValue()>0) ? regolaRisposta.getApplicabilita().getReturnCodeMin().intValue() : null , InsertAndGeneratedKeyJDBCType.INT) );
  420.                             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("applicabilita_status_max", 
  421.                                     (regolaRisposta.getApplicabilita()!=null && regolaRisposta.getApplicabilita().getReturnCodeMax()!=null && 
  422.                                     regolaRisposta.getApplicabilita().getReturnCodeMax().intValue()>0) ? regolaRisposta.getApplicabilita().getReturnCodeMax().intValue() : null , InsertAndGeneratedKeyJDBCType.INT) );
  423.                             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRASFORMAZIONI_COLUMN_APPLICABILITA_CT, applicabilitaCtResponse , InsertAndGeneratedKeyJDBCType.STRING) );
  424.                             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRASFORMAZIONI_COLUMN_APPLICABILITA_PATTERN, (regolaRisposta.getApplicabilita()!=null ? regolaRisposta.getApplicabilita().getPattern() : null) , InsertAndGeneratedKeyJDBCType.STRING) );
  425.                             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("conversione_enabled", regolaRisposta.getConversione() ? CostantiDB.TRUE : CostantiDB.FALSE , InsertAndGeneratedKeyJDBCType.INT) );
  426.                             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("conversione_tipo", regolaRisposta.getConversioneTipo() , InsertAndGeneratedKeyJDBCType.STRING) );
  427.                             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("content_type", regolaRisposta.getContentType() , InsertAndGeneratedKeyJDBCType.STRING) );
  428.                             listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject("return_code", regolaRisposta.getReturnCode(), InsertAndGeneratedKeyJDBCType.STRING) );
  429.                             if(regolaRisposta.getTrasformazioneSoap()!=null) {
  430.                                 listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRASFORMAZIONI_COLUMN_SOAP_ENVELOPE, (regolaRisposta.getTrasformazioneSoap().getEnvelope() ? CostantiDB.TRUE : CostantiDB.FALSE) , InsertAndGeneratedKeyJDBCType.INT) );
  431.                                 listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRASFORMAZIONI_COLUMN_SOAP_ENVELOPE_AS_ATTACH, (regolaRisposta.getTrasformazioneSoap().getEnvelopeAsAttachment() ? CostantiDB.TRUE : CostantiDB.FALSE) , InsertAndGeneratedKeyJDBCType.INT) );
  432.                                 listInsertAndGeneratedKeyObject.add( new InsertAndGeneratedKeyObject(CostantiDB.TRASFORMAZIONI_COLUMN_SOAP_ENVELOPE_TIPO, regolaRisposta.getTrasformazioneSoap().getEnvelopeBodyConversioneTipo() , InsertAndGeneratedKeyJDBCType.STRING) );
  433.                             }
  434.                             // Insert and return generated key
  435.                             tableName = null;
  436.                             columnIdName = null;
  437.                             sequence = null;
  438.                             tableForId = null;
  439.                             if(portaDelegata) {
  440.                                 tableName = CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_RISPOSTE;
  441.                                 columnIdName = CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_RISPOSTE_COLUMN_ID;
  442.                                 sequence = CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_RISPOSTE_SEQUENCE;
  443.                                 tableForId = CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_RISPOSTE_TABLE_FOR_ID;
  444.                             }
  445.                             else {
  446.                                 tableName = CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTE;
  447.                                 columnIdName = CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTE_COLUMN_ID;
  448.                                 sequence = CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTE_SEQUENCE;
  449.                                 tableForId = CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTE_TABLE_FOR_ID;
  450.                             }
  451.                             long idtrasformazioneRisposta = InsertAndGeneratedKey.insertAndReturnGeneratedKey(con, TipiDatabase.toEnumConstant(DriverConfigurazioneDBLib.tipoDB), 
  452.                                     new CustomKeyGeneratorObject(tableName, columnIdName, sequence, tableForId),
  453.                                     listInsertAndGeneratedKeyObject.toArray(new InsertAndGeneratedKeyObject[1]));
  454.                             if(idtrasformazioneRisposta<=0){
  455.                                 throw new DriverConfigurazioneException("ID autoincrementale non ottenuto");
  456.                             }
  457.                             
  458.                             if(     regolaRisposta.getConversioneTemplate()!=null 
  459.                                             ||
  460.                                             (regolaRisposta.getTrasformazioneSoap()!=null && regolaRisposta.getTrasformazioneSoap().getEnvelopeBodyConversioneTemplate()!=null)
  461.                                  ) {
  462.                                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  463.                                 sqlQueryObject.addUpdateTable(tableName);
  464.                                 if(regolaRisposta.getConversioneTemplate()!=null ) {
  465.                                     sqlQueryObject.addUpdateField("conversione_template", "?");
  466.                                 }
  467.                                 if(regolaRisposta.getTrasformazioneSoap()!=null && regolaRisposta.getTrasformazioneSoap().getEnvelopeBodyConversioneTemplate()!=null) {
  468.                                     sqlQueryObject.addUpdateField(CostantiDB.TRASFORMAZIONI_COLUMN_SOAP_ENVELOPE_TEMPLATE, "?");
  469.                                 }
  470.                                 sqlQueryObject.addWhereCondition(columnIdName+"=?");
  471.                                 String updateQuery = sqlQueryObject.createSQLUpdate();
  472.                                 updateStmt = con.prepareStatement(updateQuery);
  473.                                 int index = 1;
  474.                                 if(regolaRisposta.getConversioneTemplate()!=null ) {
  475.                                     jdbcAdapter.setBinaryData(updateStmt, index++, regolaRisposta.getConversioneTemplate());
  476.                                 }
  477.                                 if(regolaRisposta.getTrasformazioneSoap()!=null && regolaRisposta.getTrasformazioneSoap().getEnvelopeBodyConversioneTemplate()!=null) {
  478.                                     jdbcAdapter.setBinaryData(updateStmt, index++, regolaRisposta.getTrasformazioneSoap().getEnvelopeBodyConversioneTemplate());
  479.                                 }
  480.                                 updateStmt.setLong(index++, idtrasformazioneRisposta);
  481.                                 updateStmt.executeUpdate();
  482.                                 updateStmt.close();
  483.                             }
  484.                             
  485.                             if(regolaRisposta.sizeHeaderList()>0) {
  486.                                 for (TrasformazioneRegolaParametro parametro : regolaRisposta.getHeaderList()) {
  487.                                     
  488.                                     ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  489.                                     if(portaDelegata) {
  490.                                         sqlQueryObject.addInsertTable(CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_RISPOSTE_HEADER);
  491.                                     }
  492.                                     else {
  493.                                         sqlQueryObject.addInsertTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTE_HEADER);
  494.                                     }
  495.                                     sqlQueryObject.addInsertField("id_transform_risp", "?");
  496.                                     sqlQueryObject.addInsertField("tipo", "?");
  497.                                     sqlQueryObject.addInsertField("nome", "?");
  498.                                     sqlQueryObject.addInsertField(CostantiDB.TRASFORMAZIONI_COLUMN_VALORE, "?");
  499.                                     sqlQueryObject.addInsertField(CostantiDB.TRASFORMAZIONI_COLUMN_IDENTIFICAZIONE_FALLITA, "?");
  500.                                     
  501.                                     String updateQuery = sqlQueryObject.createSQLInsert();
  502.                                     updateStmt = con.prepareStatement(updateQuery);
  503.                                     int index = 1;
  504.                                     updateStmt.setLong(index++, idtrasformazioneRisposta);
  505.                                     updateStmt.setString(index++, DriverConfigurazioneDBLib.getValue(parametro.getConversioneTipo()));
  506.                                     updateStmt.setString(index++, parametro.getNome());
  507.                                     updateStmt.setString(index++, parametro.getValore());
  508.                                     updateStmt.setString(index++, DriverConfigurazioneDBLib.getValue(parametro.getIdentificazioneFallita()));
  509.                                     updateStmt.executeUpdate();
  510.                                     updateStmt.close();
  511.                                 }
  512.                             }
  513.                         }
  514.                         
  515.                     }
  516.                     
  517.                 }
  518.                 
  519.                 break;
  520.                 
  521.             case UPDATE:
  522.                 
  523.                 // Per la delete recupero l'immagine attuale del configurazione
  524.                 Trasformazioni trasformazioniOld = readTrasformazioni(idProprietario, portaDelegata, con);
  525.                 if(trasformazioniOld!=null) {
  526.                     CRUDTrasformazioni(DELETE, con, trasformazioniOld, idProprietario, portaDelegata);
  527.                 }
  528.                 
  529.                 // Creo la nuova immagine
  530.                 if(trasformazioni!=null) {
  531.                     
  532.                     normalizePositionsEngine(trasformazioni);
  533.                     
  534.                     CRUDTrasformazioni(CREATE, con, trasformazioni, idProprietario, portaDelegata);
  535.                 }
  536.                 break;
  537.                 
  538.             case DELETE:
  539.                 
  540.                 if(trasformazioni==null) {
  541.                     break;
  542.                 }
  543.                 
  544.                 String tableName = portaDelegata ? CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI : CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI;
  545.                 String tableNameSoggetti = portaDelegata ? null : CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_SOGGETTI;
  546.                 String tableNameSA = portaDelegata ? CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_SA : CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_SA;
  547.                 String tableNameHeader = portaDelegata ? CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_HEADER : CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_HEADER;
  548.                 String tableNameUrl = portaDelegata ? CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_URL : CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_URL;
  549.                 String tableNameRisposte = portaDelegata ? CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_RISPOSTE : CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTE;
  550.                 String tableNameRisposteHeader = portaDelegata ? CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_RISPOSTE_HEADER : CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTE_HEADER;
  551.                 List<Long> idTrasformazioneList = new ArrayList<>();
  552.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  553.                 sqlQueryObject.addFromTable(tableName);
  554.                 sqlQueryObject.addSelectField("id");
  555.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTA_COLUMN_ID_REF+"=?");
  556.                 sqlQueryObject.setANDLogicOperator(true);
  557.                 String updateQuery = sqlQueryObject.createSQLQuery();
  558.                 updateStmt = con.prepareStatement(updateQuery);
  559.                 updateStmt.setLong(1, idProprietario);
  560.                 rs = updateStmt.executeQuery();
  561.                 while(rs.next()) {
  562.                     idTrasformazioneList.add(rs.getLong("id"));
  563.                 }
  564.                 rs.close();
  565.                 updateStmt.close();
  566.                 
  567.                 if(idTrasformazioneList.isEmpty()) {
  568.                     break;
  569.                 }
  570.                 
  571.                 for (Long idTrasformazione : idTrasformazioneList) {
  572.                     
  573.                     if(tableNameSoggetti!=null) {
  574.                         sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  575.                         sqlQueryObject.addDeleteTable(tableNameSoggetti);
  576.                         sqlQueryObject.addWhereCondition(CostantiDB.TRASFORMAZIONI_COLUMN_ID_RIF_TRASFORMAZIONE+"=?");
  577.                         sqlQueryObject.setANDLogicOperator(true);
  578.                         updateQuery = sqlQueryObject.createSQLDelete();
  579.                         updateStmt = con.prepareStatement(updateQuery);
  580.                         updateStmt.setLong(1, idTrasformazione);
  581.                         updateStmt.executeUpdate();
  582.                         updateStmt.close();
  583.                     }
  584.                     
  585.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  586.                     sqlQueryObject.addDeleteTable(tableNameSA);
  587.                     sqlQueryObject.addWhereCondition(CostantiDB.TRASFORMAZIONI_COLUMN_ID_RIF_TRASFORMAZIONE+"=?");
  588.                     sqlQueryObject.setANDLogicOperator(true);
  589.                     updateQuery = sqlQueryObject.createSQLDelete();
  590.                     updateStmt = con.prepareStatement(updateQuery);
  591.                     updateStmt.setLong(1, idTrasformazione);
  592.                     updateStmt.executeUpdate();
  593.                     updateStmt.close();
  594.                     
  595.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  596.                     sqlQueryObject.addDeleteTable(tableNameHeader);
  597.                     sqlQueryObject.addWhereCondition(CostantiDB.TRASFORMAZIONI_COLUMN_ID_RIF_TRASFORMAZIONE+"=?");
  598.                     sqlQueryObject.setANDLogicOperator(true);
  599.                     updateQuery = sqlQueryObject.createSQLDelete();
  600.                     updateStmt = con.prepareStatement(updateQuery);
  601.                     updateStmt.setLong(1, idTrasformazione);
  602.                     updateStmt.executeUpdate();
  603.                     updateStmt.close();
  604.                     
  605.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  606.                     sqlQueryObject.addDeleteTable(tableNameUrl);
  607.                     sqlQueryObject.addWhereCondition(CostantiDB.TRASFORMAZIONI_COLUMN_ID_RIF_TRASFORMAZIONE+"=?");
  608.                     sqlQueryObject.setANDLogicOperator(true);
  609.                     updateQuery = sqlQueryObject.createSQLDelete();
  610.                     updateStmt = con.prepareStatement(updateQuery);
  611.                     updateStmt.setLong(1, idTrasformazione);
  612.                     updateStmt.executeUpdate();
  613.                     updateStmt.close();
  614.                     
  615.                     List<Long> idTrasformazioneRisposteList = new ArrayList<>();
  616.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  617.                     sqlQueryObject.addFromTable(tableNameRisposte);
  618.                     sqlQueryObject.addSelectField("id");
  619.                     sqlQueryObject.addWhereCondition(CostantiDB.TRASFORMAZIONI_COLUMN_ID_RIF_TRASFORMAZIONE+"=?");
  620.                     sqlQueryObject.setANDLogicOperator(true);
  621.                     updateQuery = sqlQueryObject.createSQLQuery();
  622.                     updateStmt = con.prepareStatement(updateQuery);
  623.                     updateStmt.setLong(1, idTrasformazione);
  624.                     rs = updateStmt.executeQuery();
  625.                     while(rs.next()) {
  626.                         idTrasformazioneRisposteList.add(rs.getLong("id"));
  627.                     }
  628.                     rs.close();
  629.                     updateStmt.close();
  630.                     
  631.                     if(!idTrasformazioneRisposteList.isEmpty()) {
  632.                         
  633.                         for (Long idTrasformazioneRisposta : idTrasformazioneRisposteList) {
  634.                             
  635.                             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  636.                             sqlQueryObject.addDeleteTable(tableNameRisposteHeader);
  637.                             sqlQueryObject.addWhereCondition("id_transform_risp=?");
  638.                             sqlQueryObject.setANDLogicOperator(true);
  639.                             updateQuery = sqlQueryObject.createSQLDelete();
  640.                             updateStmt = con.prepareStatement(updateQuery);
  641.                             updateStmt.setLong(1, idTrasformazioneRisposta);
  642.                             updateStmt.executeUpdate();
  643.                             updateStmt.close();
  644.                             
  645.                         }
  646.                         
  647.                     }
  648.                     
  649.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  650.                     sqlQueryObject.addDeleteTable(tableNameRisposte);
  651.                     sqlQueryObject.addWhereCondition(CostantiDB.TRASFORMAZIONI_COLUMN_ID_RIF_TRASFORMAZIONE+"=?");
  652.                     sqlQueryObject.setANDLogicOperator(true);
  653.                     updateQuery = sqlQueryObject.createSQLDelete();
  654.                     updateStmt = con.prepareStatement(updateQuery);
  655.                     updateStmt.setLong(1, idTrasformazione);
  656.                     updateStmt.executeUpdate();
  657.                     updateStmt.close();
  658.                     
  659.                 }
  660.                 
  661.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  662.                 sqlQueryObject.addDeleteTable(tableName);
  663.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTA_COLUMN_ID_REF+"=?");
  664.                 sqlQueryObject.setANDLogicOperator(true);
  665.                 updateQuery = sqlQueryObject.createSQLDelete();
  666.                 updateStmt = con.prepareStatement(updateQuery);
  667.                 updateStmt.setLong(1, idProprietario);
  668.                 updateStmt.executeUpdate();
  669.                 updateStmt.close();
  670.                 
  671.                 break;
  672.                 
  673.             default:
  674.                 break;
  675.             }
  676.         
  677.         } catch (SQLException se) {
  678.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB_LIB::CRUDConfigurazioneGenerale] SQLException [" + se.getMessage() + "].",se);
  679.         }catch (Exception se) {
  680.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB_LIB::CRUDConfigurazioneGenerale] Exception [" + se.getMessage() + "].",se);
  681.         } finally {
  682.     
  683.             JDBCUtilities.closeResources(rs, updateStmt);
  684.             
  685.         }
  686.     }
  687.     
  688.     public static Trasformazioni readTrasformazioni(long idPorta, boolean portaDelegata, Connection con) throws Exception {
  689.         
  690.         PreparedStatement stm = null;
  691.         ResultSet rs = null;
  692.         PreparedStatement stm1 = null;
  693.         ResultSet rs1 = null;
  694.         Trasformazioni trasformazioni = null;
  695.         try {
  696.             
  697.             String nomeTabella = portaDelegata ? CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI : CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI;
  698.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  699.             sqlQueryObject.addFromTable(nomeTabella);
  700.             sqlQueryObject.addSelectField("*");
  701.             sqlQueryObject.addWhereCondition(CostantiDB.PORTA_COLUMN_ID_REF+"=?");
  702.             sqlQueryObject.addOrderBy(CostantiDB.TRASFORMAZIONI_COLUMN_POSIZIONE);
  703.             sqlQueryObject.addOrderBy("nome");
  704.             sqlQueryObject.setSortType(true);
  705.             String sqlQuery = sqlQueryObject.createSQLQuery();
  706.             stm = con.prepareStatement(sqlQuery);
  707.             stm.setLong(1, idPorta);
  708.     
  709.             DriverConfigurazioneDBLib.logDebug(ESEGUO_QUERY_PREFIX + DBUtils.formatSQLString(sqlQuery, idPorta));
  710.             rs = stm.executeQuery();
  711.     
  712.             while (rs.next()) {
  713.                 
  714.                 if(trasformazioni==null) {
  715.                     trasformazioni = new Trasformazioni();
  716.                 }
  717.                 
  718.                 TrasformazioneRegola regola = new TrasformazioneRegola();
  719.                 
  720.                 String nome = rs.getString("nome");
  721.                 regola.setNome(nome);
  722.                 
  723.                 int posizione = rs.getInt(CostantiDB.TRASFORMAZIONI_COLUMN_POSIZIONE);
  724.                 regola.setPosizione(posizione);
  725.                 
  726.                 StatoFunzionalita stato = DriverConfigurazioneDBLib.getEnumStatoFunzionalita(rs.getString("stato"));
  727.                 regola.setStato(stato);
  728.                 
  729.                 String applicabilitaAzioni = rs.getString("applicabilita_azioni");
  730.                 String applicabilitaCT = rs.getString(CostantiDB.TRASFORMAZIONI_COLUMN_APPLICABILITA_CT);
  731.                 String applicabilitaPattern = rs.getString(CostantiDB.TRASFORMAZIONI_COLUMN_APPLICABILITA_PATTERN);
  732.                 String applicabilitaConnettori = rs.getString("applicabilita_connettori");
  733.                 if( (applicabilitaAzioni!=null && !"".equals(applicabilitaAzioni)) ||
  734.                         (applicabilitaCT!=null && !"".equals(applicabilitaCT)) ||
  735.                         (applicabilitaPattern!=null && !"".equals(applicabilitaPattern))  ||
  736.                         (applicabilitaConnettori!=null && !"".equals(applicabilitaConnettori)) 
  737.                         ) {
  738.                     TrasformazioneRegolaApplicabilitaRichiesta applicabilita = new TrasformazioneRegolaApplicabilitaRichiesta();
  739.                     
  740.                     if( (applicabilitaAzioni!=null && !"".equals(applicabilitaAzioni)) ) {
  741.                         if(applicabilitaAzioni.contains(",")) {
  742.                             String [] tmp = applicabilitaAzioni.split(",");
  743.                             for (int i = 0; i < tmp.length; i++) {
  744.                                 applicabilita.addAzione(tmp[i].trim());
  745.                             }
  746.                         }
  747.                         else {
  748.                             applicabilita.addAzione(applicabilitaAzioni);
  749.                         }
  750.                     }
  751.                     
  752.                     if( (applicabilitaCT!=null && !"".equals(applicabilitaCT)) ) {
  753.                         if(applicabilitaCT.contains(",")) {
  754.                             String [] tmp = applicabilitaCT.split(",");
  755.                             for (int i = 0; i < tmp.length; i++) {
  756.                                 applicabilita.addContentType(tmp[i].trim());
  757.                             }
  758.                         }
  759.                         else {
  760.                             applicabilita.addContentType(applicabilitaCT);
  761.                         }
  762.                     }
  763.                     
  764.                     if(applicabilitaPattern!=null && !"".equals(applicabilitaPattern)){
  765.                         applicabilita.setPattern(applicabilitaPattern);
  766.                     }
  767.                     
  768.                     if( (applicabilitaConnettori!=null && !"".equals(applicabilitaConnettori)) ) {
  769.                         if(applicabilitaConnettori.contains(",")) {
  770.                             String [] tmp = applicabilitaConnettori.split(",");
  771.                             for (int i = 0; i < tmp.length; i++) {
  772.                                 applicabilita.addConnettore(tmp[i].trim());
  773.                             }
  774.                         }
  775.                         else {
  776.                             applicabilita.addConnettore(applicabilitaConnettori);
  777.                         }
  778.                     }
  779.                     
  780.                     regola.setApplicabilita(applicabilita);
  781.                 }
  782.                 
  783.                 TrasformazioneRegolaRichiesta richiesta = new TrasformazioneRegolaRichiesta();
  784.                 
  785.                 int reqConversioneEnabled = rs.getInt("req_conversione_enabled");
  786.                 richiesta.setConversione(CostantiDB.TRUE == reqConversioneEnabled);

  788.                 richiesta.setConversioneTipo(rs.getString("req_conversione_tipo"));
  789.                 IJDBCAdapter jdbcAdapter = JDBCAdapterFactory.createJDBCAdapter(DriverConfigurazioneDBLib.tipoDB);
  790.                 richiesta.setConversioneTemplate(jdbcAdapter.getBinaryData(rs, "req_conversione_template"));
  791.                 richiesta.setContentType(rs.getString("req_content_type"));
  792.                 
  793.                 int trasformazioneRestIntValue = rs.getInt("rest_transformation");
  794.                 if(CostantiDB.TRUE == trasformazioneRestIntValue) {
  795.                     TrasformazioneRest trasformazioneRest = new TrasformazioneRest();
  796.                     trasformazioneRest.setMetodo(rs.getString("rest_method"));
  797.                     trasformazioneRest.setPath(rs.getString("rest_path"));
  798.                     richiesta.setTrasformazioneRest(trasformazioneRest);
  799.                 }
  800.                     
  801.                 int trasformazioneSoapIntValue = rs.getInt("soap_transformation");
  802.                 if(CostantiDB.TRUE == trasformazioneSoapIntValue) {
  803.                     TrasformazioneSoap trasformazioneSoap = new TrasformazioneSoap();
  804.                     
  805.                     trasformazioneSoap.setVersione(DriverConfigurazioneDBLib.getEnumVersioneSOAP(rs.getString("soap_version")));
  806.                     trasformazioneSoap.setSoapAction(rs.getString("soap_action"));
  807.                     
  808.                     int envelope = rs.getInt(CostantiDB.TRASFORMAZIONI_COLUMN_SOAP_ENVELOPE);
  809.                     trasformazioneSoap.setEnvelope(CostantiDB.TRUE == envelope);
  810.                     
  811.                     int envelopeAsAttach = rs.getInt(CostantiDB.TRASFORMAZIONI_COLUMN_SOAP_ENVELOPE_AS_ATTACH);
  812.                     if(CostantiDB.TRUE == envelopeAsAttach) {
  813.                         trasformazioneSoap.setEnvelopeAsAttachment(true);
  814.                         
  815.                         trasformazioneSoap.setEnvelopeBodyConversioneTipo(rs.getString(CostantiDB.TRASFORMAZIONI_COLUMN_SOAP_ENVELOPE_TIPO));
  816.                         trasformazioneSoap.setEnvelopeBodyConversioneTemplate(jdbcAdapter.getBinaryData(rs, CostantiDB.TRASFORMAZIONI_COLUMN_SOAP_ENVELOPE_TEMPLATE));
  817.                     }
  818.                     else {
  819.                         trasformazioneSoap.setEnvelopeAsAttachment(false);
  820.                     }
  821.                     
  822.                     richiesta.setTrasformazioneSoap(trasformazioneSoap);
  823.                 }
  824.                 
  825.                 regola.setId(rs.getLong("id"));
  826.                 
  827.                 regola.setRichiesta(richiesta);
  828.                 
  829.                 trasformazioni.addRegola(regola);
  830.                 
  831.             }
  832.             rs.close();
  833.             stm.close();
  834.             
  835.             if(trasformazioni==null) {
  836.                 return trasformazioni;
  837.             }
  838.             
  839.             for (TrasformazioneRegola regola : trasformazioni.getRegolaList()) {
  840.                 

  842.                 // ** SOGGETTI **
  843.                 
  844.                 if(!portaDelegata) {
  845.                     
  846.                     nomeTabella = CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_SOGGETTI;
  847.                     
  848.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  849.                     sqlQueryObject.addFromTable(nomeTabella);
  850.                     sqlQueryObject.addSelectField("*");
  851.                     sqlQueryObject.addWhereCondition(CostantiDB.TRASFORMAZIONI_COLUMN_ID_RIF_TRASFORMAZIONE+"=?");
  852.                     sqlQuery = sqlQueryObject.createSQLQuery();
  853.                     stm = con.prepareStatement(sqlQuery);
  854.                     stm.setLong(1, regola.getId());
  855.                     rs = stm.executeQuery();
  856.     
  857.                     while (rs.next()) {
  858.                         
  859.                         if(regola.getApplicabilita()==null) {
  860.                             regola.setApplicabilita(new TrasformazioneRegolaApplicabilitaRichiesta());
  861.                         }
  862.                         
  863.                         TrasformazioneRegolaApplicabilitaSoggetto soggetto = new TrasformazioneRegolaApplicabilitaSoggetto();
  864.                         soggetto.setTipo(rs.getString(CostantiDB.TRASFORMAZIONI_COLUMN_TIPO_SOGGETTO));
  865.                         soggetto.setNome(rs.getString(CostantiDB.TRASFORMAZIONI_COLUMN_NOME_SOGGETTO));
  866.                         
  867.                         regola.getApplicabilita().addSoggetto(soggetto);
  868.                     
  869.                     }
  870.                     rs.close();
  871.                     stm.close();
  872.                 }
  873.                 
  874.                 
  875.                 // ** APPLICATIVI **
  876.                 
  877.                 nomeTabella = portaDelegata ? CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_SA : CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_SA;
  878.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  879.                 sqlQueryObject.addFromTable(nomeTabella);
  880.                 sqlQueryObject.addSelectField("*");
  881.                 sqlQueryObject.addWhereCondition(CostantiDB.TRASFORMAZIONI_COLUMN_ID_RIF_TRASFORMAZIONE+"=?");
  882.                 sqlQuery = sqlQueryObject.createSQLQuery();
  883.                 stm = con.prepareStatement(sqlQuery);
  884.                 stm.setLong(1, regola.getId());
  885.                 rs = stm.executeQuery();

  887.                 // per ogni entry 
  888.                 // prendo l'id del servizio associato, recupero il nome e
  889.                 // aggiungo
  890.                 // il servizio applicativo alla PortaDelegata da ritornare
  891.                 while (rs.next()) {
  892.                     long idSA = rs.getLong("id_servizio_applicativo");

  894.                     if (idSA != 0) {
  895.                         sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  896.                         sqlQueryObject.addFromTable(CostantiDB.SERVIZI_APPLICATIVI);
  897.                         sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  898.                         sqlQueryObject.addSelectField("nome");
  899.                         sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO);
  900.                         sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO);
  901.                         sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_APPLICATIVI+".id=?");
  902.                         sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_APPLICATIVI+".id_soggetto="+CostantiDB.SOGGETTI+".id");
  903.                         sqlQueryObject.setANDLogicOperator(true);
  904.                         sqlQuery = sqlQueryObject.createSQLQuery();
  905.                         stm1 = con.prepareStatement(sqlQuery);
  906.                         stm1.setLong(1, idSA);

  908.                         DriverConfigurazioneDBLib.logDebug(ESEGUO_QUERY_PREFIX + DBUtils.formatSQLString(sqlQuery, idSA));

  910.                         rs1 = stm1.executeQuery();

  912.                         TrasformazioneRegolaApplicabilitaServizioApplicativo servizioApplicativo = null;
  913.                         if (rs1.next()) {
  914.                             // setto solo il nome come da specifica
  915.                             servizioApplicativo = new TrasformazioneRegolaApplicabilitaServizioApplicativo();
  916.                             servizioApplicativo.setId(idSA);
  917.                             servizioApplicativo.setNome(rs1.getString("nome"));
  918.                             servizioApplicativo.setTipoSoggettoProprietario(rs1.getString(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO));
  919.                             servizioApplicativo.setNomeSoggettoProprietario(rs1.getString(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO));
  920.                             if(regola.getApplicabilita()==null) {
  921.                                 regola.setApplicabilita(new TrasformazioneRegolaApplicabilitaRichiesta());
  922.                             }
  923.                             regola.getApplicabilita().addServizioApplicativo(servizioApplicativo);
  924.                         }
  925.                         rs1.close();
  926.                         stm1.close();
  927.                     }
  928.                 }
  929.                 rs.close();
  930.                 stm.close();
  931.                 
  932.                 
  933.                 // ** HEADER **
  934.                 
  935.                 nomeTabella = portaDelegata ? CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_HEADER : CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_HEADER;
  936.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  937.                 sqlQueryObject.addFromTable(nomeTabella);
  938.                 sqlQueryObject.addSelectField("*");
  939.                 sqlQueryObject.addWhereCondition(CostantiDB.TRASFORMAZIONI_COLUMN_ID_RIF_TRASFORMAZIONE+"=?");
  940.                 sqlQuery = sqlQueryObject.createSQLQuery();
  941.                 stm = con.prepareStatement(sqlQuery);
  942.                 stm.setLong(1, regola.getId());
  943.         
  944.                 DriverConfigurazioneDBLib.logDebug(ESEGUO_QUERY_PREFIX + DBUtils.formatSQLString(sqlQuery, idPorta));
  945.                 rs = stm.executeQuery();
  946.         
  947.                 while (rs.next()) {
  948.                     TrasformazioneRegolaParametro parametro = new TrasformazioneRegolaParametro();
  949.                     parametro.setConversioneTipo(DriverConfigurazioneDBLib.getEnumTrasformazioneRegolaParametroTipoAzione(rs.getString("tipo")));
  950.                     parametro.setNome(rs.getString("nome"));
  951.                     parametro.setValore(rs.getString(CostantiDB.TRASFORMAZIONI_COLUMN_VALORE));
  952.                     parametro.setIdentificazioneFallita(DriverConfigurazioneDBLib.getEnumTrasformazioneIdentificazioneRisorsaFallita(rs.getString(CostantiDB.TRASFORMAZIONI_COLUMN_IDENTIFICAZIONE_FALLITA)));
  953.                     parametro.setId(rs.getLong("id"));
  954.                     regola.getRichiesta().addHeader(parametro);
  955.                 }
  956.                 
  957.                 rs.close();
  958.                 stm.close();
  959.                 
  960.                 
  961.                 // ** URL **
  962.                 
  963.                 nomeTabella = portaDelegata ? CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_URL : CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_URL;
  964.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  965.                 sqlQueryObject.addFromTable(nomeTabella);
  966.                 sqlQueryObject.addSelectField("*");
  967.                 sqlQueryObject.addWhereCondition(CostantiDB.TRASFORMAZIONI_COLUMN_ID_RIF_TRASFORMAZIONE+"=?");
  968.                 sqlQuery = sqlQueryObject.createSQLQuery();
  969.                 stm = con.prepareStatement(sqlQuery);
  970.                 stm.setLong(1, regola.getId());
  971.         
  972.                 DriverConfigurazioneDBLib.logDebug(ESEGUO_QUERY_PREFIX + DBUtils.formatSQLString(sqlQuery, idPorta));
  973.                 rs = stm.executeQuery();
  974.         
  975.                 while (rs.next()) {
  976.                     TrasformazioneRegolaParametro parametro = new TrasformazioneRegolaParametro();
  977.                     parametro.setConversioneTipo(DriverConfigurazioneDBLib.getEnumTrasformazioneRegolaParametroTipoAzione(rs.getString("tipo")));
  978.                     parametro.setNome(rs.getString("nome"));
  979.                     parametro.setValore(rs.getString(CostantiDB.TRASFORMAZIONI_COLUMN_VALORE));
  980.                     parametro.setIdentificazioneFallita(DriverConfigurazioneDBLib.getEnumTrasformazioneIdentificazioneRisorsaFallita(rs.getString(CostantiDB.TRASFORMAZIONI_COLUMN_IDENTIFICAZIONE_FALLITA)));
  981.                     parametro.setId(rs.getLong("id"));
  982.                     regola.getRichiesta().addParametroUrl(parametro);
  983.                 }
  984.                 
  985.                 rs.close();
  986.                 stm.close();
  987.                 
  988.                 
  989.                 
  990.                 // ** RISPOSTE **
  991.                 
  992.                 nomeTabella = portaDelegata ? CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_RISPOSTE : CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTE;
  993.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  994.                 sqlQueryObject.addFromTable(nomeTabella);
  995.                 sqlQueryObject.addSelectField("*");
  996.                 sqlQueryObject.addWhereCondition(CostantiDB.TRASFORMAZIONI_COLUMN_ID_RIF_TRASFORMAZIONE+"=?");
  997.                 sqlQueryObject.addOrderBy(CostantiDB.TRASFORMAZIONI_COLUMN_POSIZIONE);
  998.                 sqlQueryObject.addOrderBy("nome");
  999.                 sqlQueryObject.setSortType(true);
  1000.                 sqlQuery = sqlQueryObject.createSQLQuery();
  1001.                 stm = con.prepareStatement(sqlQuery);
  1002.                 stm.setLong(1, regola.getId());
  1003.         
  1004.                 DriverConfigurazioneDBLib.logDebug(ESEGUO_QUERY_PREFIX + DBUtils.formatSQLString(sqlQuery, idPorta));
  1005.                 rs = stm.executeQuery();
  1006.         
  1007.                 while (rs.next()) {
  1008.                 
  1009.                     TrasformazioneRegolaRisposta risposta = new TrasformazioneRegolaRisposta();
  1010.                     
  1011.                     String nome = rs.getString("nome");
  1012.                     risposta.setNome(nome);
  1013.                     
  1014.                     int posizione = rs.getInt(CostantiDB.TRASFORMAZIONI_COLUMN_POSIZIONE);
  1015.                     risposta.setPosizione(posizione);
  1016.                     
  1017.                     int applicabilitaStatusMin = rs.getInt("applicabilita_status_min");
  1018.                     int applicabilitaStatusMax = rs.getInt("applicabilita_status_max");
  1019.                     String applicabilitaCT = rs.getString(CostantiDB.TRASFORMAZIONI_COLUMN_APPLICABILITA_CT);
  1020.                     String applicabilitaPattern = rs.getString(CostantiDB.TRASFORMAZIONI_COLUMN_APPLICABILITA_PATTERN);
  1021.                     if( (applicabilitaStatusMin >0 || applicabilitaStatusMax>0) ||
  1022.                             (applicabilitaCT!=null && !"".equals(applicabilitaCT)) ||
  1023.                             (applicabilitaPattern!=null && !"".equals(applicabilitaPattern)) 
  1024.                             ) {
  1025.                         TrasformazioneRegolaApplicabilitaRisposta applicabilita = new TrasformazioneRegolaApplicabilitaRisposta();
  1026.                         
  1027.                         if(applicabilitaStatusMin>0) {
  1028.                             applicabilita.setReturnCodeMin(applicabilitaStatusMin);
  1029.                         }
  1030.                         if(applicabilitaStatusMax>0) {
  1031.                             applicabilita.setReturnCodeMax(applicabilitaStatusMax);
  1032.                         }

  1034.                         if( (applicabilitaCT!=null && !"".equals(applicabilitaCT)) ) {
  1035.                             if(applicabilitaCT.contains(",")) {
  1036.                                 String [] tmp = applicabilitaCT.split(",");
  1037.                                 for (int i = 0; i < tmp.length; i++) {
  1038.                                     applicabilita.addContentType(tmp[i].trim());
  1039.                                 }
  1040.                             }
  1041.                             else {
  1042.                                 applicabilita.addContentType(applicabilitaCT);
  1043.                             }
  1044.                         }
  1045.                         
  1046.                         if(applicabilitaPattern!=null && !"".equals(applicabilitaPattern)){
  1047.                             applicabilita.setPattern(applicabilitaPattern);
  1048.                         }
  1049.                         
  1050.                         risposta.setApplicabilita(applicabilita);
  1051.                     }
  1052.                     
  1053.                     int conversioneEnabled = rs.getInt("conversione_enabled");
  1054.                     risposta.setConversione(CostantiDB.TRUE == conversioneEnabled);

  1056.                     risposta.setConversioneTipo(rs.getString("conversione_tipo"));
  1057.                     IJDBCAdapter jdbcAdapter = JDBCAdapterFactory.createJDBCAdapter(DriverConfigurazioneDBLib.tipoDB);
  1058.                     risposta.setConversioneTemplate(jdbcAdapter.getBinaryData(rs, "conversione_template"));
  1059.                     risposta.setContentType(rs.getString("content_type"));
  1060.                     risposta.setReturnCode(rs.getString("return_code"));
  1061.                     
  1062.                     if(regola.getRichiesta().getTrasformazioneRest()!=null) { // La risposta deve essere ritrasformata in soap
  1063.                     
  1064.                         TrasformazioneSoapRisposta trasformazioneSoap = new TrasformazioneSoapRisposta();
  1065.                         
  1066.                         int envelope = rs.getInt(CostantiDB.TRASFORMAZIONI_COLUMN_SOAP_ENVELOPE);
  1067.                         trasformazioneSoap.setEnvelope(CostantiDB.TRUE == envelope);
  1068.                         
  1069.                         int envelopeAsAttach = rs.getInt(CostantiDB.TRASFORMAZIONI_COLUMN_SOAP_ENVELOPE_AS_ATTACH);
  1070.                         if(CostantiDB.TRUE == envelopeAsAttach) {
  1071.                             trasformazioneSoap.setEnvelopeAsAttachment(true);
  1072.                             
  1073.                             trasformazioneSoap.setEnvelopeBodyConversioneTipo(rs.getString(CostantiDB.TRASFORMAZIONI_COLUMN_SOAP_ENVELOPE_TIPO));
  1074.                             trasformazioneSoap.setEnvelopeBodyConversioneTemplate(jdbcAdapter.getBinaryData(rs, CostantiDB.TRASFORMAZIONI_COLUMN_SOAP_ENVELOPE_TEMPLATE));
  1075.                         }
  1076.                         else {
  1077.                             trasformazioneSoap.setEnvelopeAsAttachment(false);
  1078.                         }
  1079.                         
  1080.                         risposta.setTrasformazioneSoap(trasformazioneSoap);
  1081.                         
  1082.                     }

  1084.                     risposta.setId(rs.getLong("id"));
  1085.                     
  1086.                     regola.addRisposta(risposta);
  1087.                     
  1088.                 }
  1089.                 
  1090.                 rs.close();
  1091.                 stm.close();
  1092.                 
  1093.                 
  1094.                 // ** HEADER RISPOSTA **
  1095.                 
  1096.                 for (TrasformazioneRegolaRisposta risposta : regola.getRispostaList()) {
  1097.                     
  1098.                     nomeTabella = portaDelegata ? CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_RISPOSTE_HEADER : CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTE_HEADER;
  1099.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  1100.                     sqlQueryObject.addFromTable(nomeTabella);
  1101.                     sqlQueryObject.addSelectField("*");
  1102.                     sqlQueryObject.addWhereCondition("id_transform_risp=?");
  1103.                     sqlQuery = sqlQueryObject.createSQLQuery();
  1104.                     stm = con.prepareStatement(sqlQuery);
  1105.                     stm.setLong(1, risposta.getId());
  1106.             
  1107.                     DriverConfigurazioneDBLib.logDebug(ESEGUO_QUERY_PREFIX + DBUtils.formatSQLString(sqlQuery, idPorta));
  1108.                     rs = stm.executeQuery();
  1109.             
  1110.                     while (rs.next()) {
  1111.                         TrasformazioneRegolaParametro parametro = new TrasformazioneRegolaParametro();
  1112.                         parametro.setConversioneTipo(DriverConfigurazioneDBLib.getEnumTrasformazioneRegolaParametroTipoAzione(rs.getString("tipo")));
  1113.                         parametro.setNome(rs.getString("nome"));
  1114.                         parametro.setValore(rs.getString(CostantiDB.TRASFORMAZIONI_COLUMN_VALORE));
  1115.                         parametro.setIdentificazioneFallita(DriverConfigurazioneDBLib.getEnumTrasformazioneIdentificazioneRisorsaFallita(rs.getString(CostantiDB.TRASFORMAZIONI_COLUMN_IDENTIFICAZIONE_FALLITA)));
  1116.                         parametro.setId(rs.getLong("id"));
  1117.                         risposta.addHeader(parametro);
  1118.                     }
  1119.                     
  1120.                     rs.close();
  1121.                     stm.close();
  1122.                     
  1123.                 }
  1124.             }
  1125.             
  1126.         }finally {
  1127.             JDBCUtilities.closeResources(rs1, stm1);
  1128.             JDBCUtilities.closeResources(rs, stm);
  1129.         }
  1130.         
  1131.         return trasformazioni;
  1132.     }
  1133.     
  1134.     
  1135. }
Created with JaCoCo 0.8.8.202204050719