DriverRegistroServiziDB_accordiSoapDriver.java

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



  23. package org.openspcoop2.core.registry.driver.db;

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

  31. import org.openspcoop2.core.commons.DBUtils;
  32. import org.openspcoop2.core.commons.ISearch;
  33. import org.openspcoop2.core.commons.Liste;
  34. import org.openspcoop2.core.constants.CostantiDB;
  35. import org.openspcoop2.core.constants.ProprietariProtocolProperty;
  36. import org.openspcoop2.core.id.IDPortType;
  37. import org.openspcoop2.core.id.IDServizio;
  38. import org.openspcoop2.core.id.IDSoggetto;
  39. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  40. import org.openspcoop2.core.registry.Azione;
  41. import org.openspcoop2.core.registry.Message;
  42. import org.openspcoop2.core.registry.MessagePart;
  43. import org.openspcoop2.core.registry.Operation;
  44. import org.openspcoop2.core.registry.PortType;
  45. import org.openspcoop2.core.registry.ProtocolProperty;
  46. import org.openspcoop2.core.registry.constants.CostantiRegistroServizi;
  47. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  48. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  49. import org.openspcoop2.utils.date.DateManager;
  50. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  51. import org.openspcoop2.utils.sql.ISQLQueryObject;
  52. import org.openspcoop2.utils.sql.SQLObjectFactory;

  54. /**
  55.  * DriverRegistroServiziDB_accordiDriver
  56.  * 
  57.  * 
  58.  * @author Sandra Giangrandi (sandra@link.it)
  59.  * @author Stefano Corallo (corallo@link.it)
  60.  * @author $Author$
  61.  * @version $Rev$, $Date$
  62.  */
  63. public class DriverRegistroServiziDB_accordiSoapDriver {

  65.     private DriverRegistroServiziDB driver = null;
  66.     
  67.     protected DriverRegistroServiziDB_accordiSoapDriver(DriverRegistroServiziDB driver) {
  68.         this.driver = driver;
  69.     }
  70.     
  71.     protected void readPortTypes(AccordoServizioParteComune as,Connection conParam) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  72.         // Aggiungo port type

  74.         Connection con = null;
  75.         PreparedStatement stm = null;
  76.         ResultSet rs = null;
  77.         String sqlQuery = null;

  79.         try {
  80.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  81.             // prendo la connessione dal pool
  82.             if(conParam!=null)
  83.                 con = conParam;
  84.             else if (this.driver.atomica)
  85.                 con = this.driver.getConnectionFromDatasource("readPortTypes");
  86.             else
  87.                 con = this.driver.globalConnection;

  89.             if(as.getId()==null || as.getId()<=0)
  90.                 throw new Exception("Accordo id non definito");

  92.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  93.             sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE);
  94.             sqlQueryObject.addSelectField("*");
  95.             sqlQueryObject.addWhereCondition("id_accordo = ?");
  96.             sqlQueryObject.setANDLogicOperator(true);
  97.             sqlQueryObject.addOrderBy("nome");
  98.             sqlQueryObject.setSortType(true);
  99.             sqlQuery = sqlQueryObject.createSQLQuery();
  100.             stm = con.prepareStatement(sqlQuery);
  101.             stm.setLong(1, as.getId());

  103.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, as.getId()));
  104.             rs = stm.executeQuery();

  106.             while (rs.next()) {

  108.                 PortType pt = new PortType();

  110.                 String tmp = rs.getString("nome");
  111.                 pt.setNome(((tmp == null || tmp.equals("")) ? null : tmp));

  113.                 tmp = rs.getString("descrizione");
  114.                 pt.setDescrizione(((tmp == null || tmp.equals("")) ? null : tmp));

  116.                 tmp = rs.getString("profilo_collaborazione");
  117.                 pt.setProfiloCollaborazione(DriverRegistroServiziDB_LIB.getEnumProfiloCollaborazione(((tmp == null || tmp.equals("")) ? null : tmp)));

  119.                 tmp = rs.getString("filtro_duplicati");
  120.                 pt.setFiltroDuplicati(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  122.                 tmp = rs.getString("conferma_ricezione");
  123.                 pt.setConfermaRicezione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  125.                 tmp = rs.getString("identificativo_collaborazione");
  126.                 pt.setIdCollaborazione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  128.                 tmp = rs.getString("id_riferimento_richiesta");
  129.                 pt.setIdRiferimentoRichiesta(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  130.                 
  131.                 tmp = rs.getString("consegna_in_ordine");
  132.                 pt.setConsegnaInOrdine(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  134.                 tmp = rs.getString("scadenza");
  135.                 pt.setScadenza(((tmp == null || tmp.equals("")) ? null : tmp));

  137.                 tmp = rs.getString("profilo_pt");
  138.                 if (tmp == null || tmp.equals(""))
  139.                     pt.setProfiloPT(CostantiRegistroServizi.PROFILO_AZIONE_DEFAULT);
  140.                 else
  141.                     pt.setProfiloPT(tmp);

  143.                 tmp = rs.getString("soap_style");
  144.                 pt.setStyle(DriverRegistroServiziDB_LIB.getEnumBindingStyle(((tmp == null || tmp.equals("")) ? null : tmp)));

  146.                 tmp = rs.getString("message_type");
  147.                 pt.setMessageType(DriverRegistroServiziDB_LIB.getEnumMessageType((tmp == null || tmp.equals("")) ? null : tmp));
  148.                 
  149.                 pt.setIdAccordo(as.getId());

  151.                 long idPortType = rs.getLong("id");
  152.                 pt.setId(idPortType);

  154.                 // Aggiungo azioni a port type
  155.                 this.readAzioniPortTypes(pt,con);

  157.                 // Protocol Properties
  158.                 try{
  159.                     List<ProtocolProperty> listPP = DriverRegistroServiziDB_LIB.getListaProtocolProperty(idPortType, ProprietariProtocolProperty.PORT_TYPE, con, 
  160.                             this.driver.tipoDB, this.driver.getDriverUnwrapBYOK());
  161.                     if(listPP!=null && !listPP.isEmpty()){
  162.                         for (ProtocolProperty protocolProperty : listPP) {
  163.                             pt.addProtocolProperty(protocolProperty);
  164.                         }
  165.                     }
  166.                 }catch(DriverRegistroServiziNotFound dNotFound){
  167.                     // ignore
  168.                 }
  169.                 
  170.                 as.addPortType(pt);

  172.             }
  173.             rs.close();
  174.             stm.close();

  176.         }catch (DriverRegistroServiziNotFound e) {
  177.             throw e;
  178.         }catch (Exception se) {
  179.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::readPortTypes] Exception :" + se.getMessage(),se);
  180.         } finally {

  182.             JDBCUtilities.closeResources(rs, stm);

  184.             this.driver.closeConnection(conParam, con);

  186.         }
  187.     }

  189.     private void readAzioniPortTypes(PortType pt,Connection conParam) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  190.         // Aggiungo port type

  192.         Connection con = null;
  193.         PreparedStatement stm = null;
  194.         ResultSet rs = null;
  195.         String sqlQuery = null;

  197.         try {
  198.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  199.             // prendo la connessione dal pool
  200.             if(conParam!=null)
  201.                 con = conParam;
  202.             else if (this.driver.atomica)
  203.                 con = this.driver.getConnectionFromDatasource("readAzioniPortTypes");
  204.             else
  205.                 con = this.driver.globalConnection;

  207.             if(pt.getId()==null || pt.getId()<=0)
  208.                 throw new Exception("Port Type id non definito");

  210.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  211.             sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  212.             sqlQueryObject.addSelectField("*");
  213.             sqlQueryObject.addWhereCondition("id_port_type = ?");
  214.             sqlQueryObject.setANDLogicOperator(true);
  215.             sqlQueryObject.addOrderBy("nome");
  216.             sqlQueryObject.setSortType(true);
  217.             sqlQuery = sqlQueryObject.createSQLQuery();
  218.             stm = con.prepareStatement(sqlQuery);
  219.             stm.setLong(1, pt.getId());

  221.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, pt.getId()));

  223.             rs = stm.executeQuery();

  225.             org.openspcoop2.core.registry.Operation azionePT = null;
  226.             while (rs.next()) {

  228.                 azionePT = new org.openspcoop2.core.registry.Operation();

  230.                 String tmp = rs.getString("conferma_ricezione");
  231.                 azionePT.setConfermaRicezione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  233.                 tmp = rs.getString("consegna_in_ordine");
  234.                 azionePT.setConsegnaInOrdine(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  236.                 tmp = rs.getString("filtro_duplicati");
  237.                 azionePT.setFiltroDuplicati(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  239.                 tmp = rs.getString("identificativo_collaborazione");
  240.                 azionePT.setIdCollaborazione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  242.                 tmp = rs.getString("id_riferimento_richiesta");
  243.                 azionePT.setIdRiferimentoRichiesta(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  244.                 
  245.                 tmp = rs.getString("nome");
  246.                 azionePT.setNome(((tmp == null || tmp.equals("")) ? null : tmp));

  248.                 tmp = rs.getString("scadenza");
  249.                 azionePT.setScadenza(((tmp == null || tmp.equals("")) ? null : tmp));

  251.                 tmp = rs.getString("profilo_collaborazione");
  252.                 azionePT.setProfiloCollaborazione(DriverRegistroServiziDB_LIB.getEnumProfiloCollaborazione(((tmp == null || tmp.equals("")) ? null : tmp)));

  254.                 tmp = rs.getString("correlata_servizio");
  255.                 azionePT.setCorrelataServizio(((tmp == null || tmp.equals("")) ? null : tmp));

  257.                 tmp = rs.getString("correlata");
  258.                 azionePT.setCorrelata(((tmp == null || tmp.equals("")) ? null : tmp));

  260.                 tmp = rs.getString("profilo_pt_azione");
  261.                 if (tmp == null || tmp.equals(""))
  262.                     azionePT.setProfAzione(CostantiRegistroServizi.PROFILO_AZIONE_DEFAULT);
  263.                 else
  264.                     azionePT.setProfAzione(tmp);

  266.                 tmp = rs.getString("soap_style");
  267.                 azionePT.setStyle(DriverRegistroServiziDB_LIB.getEnumBindingStyle(((tmp == null || tmp.equals("")) ? null : tmp)));

  269.                 tmp = rs.getString("soap_action");
  270.                 azionePT.setSoapAction(((tmp == null || tmp.equals("")) ? null : tmp));

  272.                 azionePT.setIdPortType(pt.getId());

  274.                 long idAzionePortType = rs.getLong("id");
  275.                 azionePT.setId(idAzionePortType);

  277.                 // Aggiungo messages nell'azione del port type
  278.                 this.readMessagesAzioniPortTypes(azionePT,con);

  280.                 String msgInput = rs.getString("soap_use_msg_input");
  281.                 if(azionePT.getMessageInput()!=null || msgInput!=null){
  282.                     if(azionePT.getMessageInput()==null){
  283.                         azionePT.setMessageInput(new Message());
  284.                     }
  285.                     azionePT.getMessageInput().setUse(DriverRegistroServiziDB_LIB.getEnumBindingUse(((msgInput == null || msgInput.equals("")) ? null : msgInput)));
  286.                     tmp = rs.getString("soap_namespace_msg_input");
  287.                     azionePT.getMessageInput().setSoapNamespace(((tmp == null || tmp.equals("")) ? null : tmp));
  288.                 }

  290.                 String msgOutput = rs.getString("soap_use_msg_output");
  291.                 if(azionePT.getMessageOutput()!=null || msgOutput!=null){
  292.                     if(azionePT.getMessageOutput()==null){
  293.                         azionePT.setMessageOutput(new Message());
  294.                     }
  295.                      
  296.                     azionePT.getMessageOutput().setUse(DriverRegistroServiziDB_LIB.getEnumBindingUse(((msgOutput == null || msgOutput.equals("")) ? null : msgOutput)));
  297.                     tmp = rs.getString("soap_namespace_msg_output");
  298.                     azionePT.getMessageOutput().setSoapNamespace(((tmp == null || tmp.equals("")) ? null : tmp));
  299.                 }

  301.                 // Protocol Properties
  302.                 try{
  303.                     List<ProtocolProperty> listPP = DriverRegistroServiziDB_LIB.getListaProtocolProperty(idAzionePortType, ProprietariProtocolProperty.OPERATION, con, 
  304.                             this.driver.tipoDB, this.driver.getDriverUnwrapBYOK());
  305.                     if(listPP!=null && !listPP.isEmpty()){
  306.                         for (ProtocolProperty protocolProperty : listPP) {
  307.                             azionePT.addProtocolProperty(protocolProperty);
  308.                         }
  309.                     }
  310.                 }catch(DriverRegistroServiziNotFound dNotFound){
  311.                     // ignore
  312.                 }
  313.                 
  314.                 pt.addAzione(azionePT);

  316.             }
  317.             rs.close();
  318.             stm.close();

  320.         }catch (DriverRegistroServiziNotFound e) {
  321.             throw e;
  322.         }catch (Exception se) {
  323.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::readAzioniPortTypes] Exception :" + se.getMessage(),se);
  324.         } finally {

  326.             JDBCUtilities.closeResources(rs, stm);

  328.             this.driver.closeConnection(conParam, con);
  329.         }
  330.     }

  332.     private void readMessagesAzioniPortTypes(Operation azionePT,Connection conParam) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  333.         // Aggiungo port type

  335.         Connection con = null;
  336.         PreparedStatement stm = null;
  337.         ResultSet rs = null;
  338.         String sqlQuery = null;

  340.         try {
  341.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  342.             // prendo la connessione dal pool
  343.             if(conParam!=null)
  344.                 con = conParam;
  345.             else if (this.driver.atomica)
  346.                 con = this.driver.getConnectionFromDatasource("readMessagesAzioniPortTypes");
  347.             else
  348.                 con = this.driver.globalConnection;

  350.             if(azionePT.getId()==null || azionePT.getId()<=0)
  351.                 throw new Exception("Port Type azione id non definito");

  353.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  354.             sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI_OPERATION_MESSAGES);
  355.             sqlQueryObject.addSelectField("*");
  356.             sqlQueryObject.addWhereCondition("id_port_type_azione = ?");
  357.             sqlQueryObject.setANDLogicOperator(true);
  358.             sqlQuery = sqlQueryObject.createSQLQuery();
  359.             stm = con.prepareStatement(sqlQuery);
  360.             stm.setLong(1, azionePT.getId());

  362.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, azionePT.getId()));

  364.             rs = stm.executeQuery();

  366.             org.openspcoop2.core.registry.Message messageInputPart = null;
  367.             org.openspcoop2.core.registry.Message messageOutputPart = null;
  368.             while (rs.next()) {

  370.                 boolean isInputMessage = false;
  371.                 if(rs.getInt("input_message")==1)
  372.                     isInputMessage = true;

  374.                 MessagePart part = new MessagePart();

  376.                 String name = rs.getString("name");
  377.                 name = ((name == null || name.equals("")) ? null : name);
  378.                 part.setName(name);

  380.                 String elementName = rs.getString("element_name");
  381.                 elementName = ((elementName == null || elementName.equals("")) ? null : elementName);
  382.                 part.setElementName(elementName);

  384.                 String elementNamespace = rs.getString("element_namespace");
  385.                 elementNamespace = ((elementNamespace == null || elementNamespace.equals("")) ? null : elementNamespace);
  386.                 part.setElementNamespace(elementNamespace);

  388.                 String typeName = rs.getString("type_name");
  389.                 typeName = ((typeName == null || typeName.equals("")) ? null : typeName);
  390.                 part.setTypeName(typeName);

  392.                 String typeNamespace = rs.getString("type_namespace");
  393.                 typeNamespace = ((typeNamespace == null || typeNamespace.equals("")) ? null : typeNamespace);
  394.                 part.setTypeNamespace(typeNamespace);

  396.                 long idMessage = rs.getLong("id");
  397.                 part.setId(idMessage);

  399.                 if(isInputMessage){

  401.                     if(messageInputPart==null)
  402.                         messageInputPart = new org.openspcoop2.core.registry.Message();
  403.                     messageInputPart.addPart(part);

  405.                 }else{

  407.                     if(messageOutputPart==null)
  408.                         messageOutputPart = new org.openspcoop2.core.registry.Message();
  409.                     messageOutputPart.addPart(part);

  411.                 }

  413.             }

  415.             if(messageInputPart!=null){
  416.                 azionePT.setMessageInput(messageInputPart);
  417.             }
  418.             if(messageOutputPart!=null){
  419.                 azionePT.setMessageOutput(messageOutputPart);
  420.             }

  422.             rs.close();
  423.             stm.close();

  425.         }catch (DriverRegistroServiziNotFound e) {
  426.             throw e;
  427.         }catch (Exception se) {
  428.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::readMessagesAzioniPortTypes] Exception :" + se.getMessage(),se);
  429.         } finally {

  431.             JDBCUtilities.closeResources(rs, stm);

  433.             this.driver.closeConnection(conParam, con);

  435.         }
  436.     }
  437.     
  438.     
  439.     
  440.     protected PortType getPortType(long id) throws DriverRegistroServiziException {
  441.         String nomeMetodo = "getPortType(long)";

  443.         Connection con = null;
  444.         PreparedStatement stmt = null;
  445.         ResultSet rs = null;
  446.         String queryString;

  448.         if (this.driver.atomica) {
  449.             try {
  450.                 con = this.driver.getConnectionFromDatasource("getPortType");

  452.             } catch (Exception e) {
  453.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(), e);

  455.             }

  457.         } else {
  458.             con = this.driver.globalConnection;
  459.         }

  461.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  463.         try {

  465.             // Controllo che il pdd non sia in uso
  466.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  467.             sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE);
  468.             sqlQueryObject.setANDLogicOperator(true);
  469.             sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE+".id=?");
  470.             queryString = sqlQueryObject.createSQLQuery();
  471.             stmt = con.prepareStatement(queryString);
  472.             stmt.setLong(1, id);

  474.             rs = stmt.executeQuery();
  475.             PortType pt = null;
  476.             if (rs.next()) {
  477.                 pt = new PortType();
  478.                 String tmp = rs.getString("nome");
  479.                 pt.setNome(((tmp == null || tmp.equals("")) ? null : tmp));

  481.                 tmp = rs.getString("descrizione");
  482.                 pt.setDescrizione(((tmp == null || tmp.equals("")) ? null : tmp));

  484.                 tmp = rs.getString("profilo_collaborazione");
  485.                 pt.setProfiloCollaborazione(DriverRegistroServiziDB_LIB.getEnumProfiloCollaborazione(((tmp == null || tmp.equals("")) ? null : tmp)));

  487.                 tmp = rs.getString("filtro_duplicati");
  488.                 pt.setFiltroDuplicati(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  490.                 tmp = rs.getString("conferma_ricezione");
  491.                 pt.setConfermaRicezione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  493.                 tmp = rs.getString("identificativo_collaborazione");
  494.                 pt.setIdCollaborazione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  495.                 
  496.                 tmp = rs.getString("id_riferimento_richiesta");
  497.                 pt.setIdRiferimentoRichiesta(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  499.                 tmp = rs.getString("consegna_in_ordine");
  500.                 pt.setConsegnaInOrdine(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  502.                 tmp = rs.getString("scadenza");
  503.                 pt.setScadenza(((tmp == null || tmp.equals("")) ? null : tmp));

  505.                 tmp = rs.getString("profilo_pt");
  506.                 if (tmp == null || tmp.equals(""))
  507.                     pt.setProfiloPT(CostantiRegistroServizi.PROFILO_AZIONE_DEFAULT);
  508.                 else
  509.                     pt.setProfiloPT(tmp);

  511.                 tmp = rs.getString("soap_style");
  512.                 pt.setStyle(DriverRegistroServiziDB_LIB.getEnumBindingStyle(((tmp == null || tmp.equals("")) ? null : tmp)));

  514.                 pt.setIdAccordo(rs.getLong("id_accordo"));

  516.                 long idPortType = rs.getLong("id");
  517.                 pt.setId(idPortType);

  519.                 // Aggiungo azioni a port type
  520.                 this.readAzioniPortTypes(pt,con);
  521.             }

  523.             return pt;

  525.         } catch (Exception se) {
  526.             throw new DriverRegistroServiziException("[DriverRegistroServiziException::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  527.         } finally {
  528.             // Chiudo statement and resultset
  529.             JDBCUtilities.closeResources(rs, stmt);
  530.             
  531.             this.driver.closeConnection(con);
  532.         }
  533.     }
  534.     
  535.     
  536.     protected List<PortType> accordiPorttypeCompatibiliList(long idAccordo,boolean isErogazione, ISearch ricerca) throws DriverRegistroServiziException {
  537.         String nomeMetodo = "accordiPorttypeCompatibiliList";
  538.         int idLista = Liste.ACCORDI_PORTTYPE;
  539.         int offset;
  540.         int limit;
  541.         String search;
  542.         String queryString;

  544.         limit = ricerca.getPageSize(idLista);
  545.         offset = ricerca.getIndexIniziale(idLista);
  546.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  547.         ricerca.getSearchString(idLista);

  549.         Connection con = null;
  550.         PreparedStatement stmt = null;
  551.         ResultSet risultato = null;

  553.         ArrayList<PortType> lista = new ArrayList<PortType>();

  555.         if (this.driver.atomica) {
  556.             try {
  557.                 con = this.driver.getConnectionFromDatasource("accordiPorttypeCompatibiliList");

  559.             } catch (Exception e) {
  560.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  562.             }

  564.         } else
  565.             con = this.driver.globalConnection;

  567.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  569.         try {

  571.             ISQLQueryObject sqlquery = DriverRegistroServiziDB_accordiLIB.getSQLRicercaServiziValidiByIdAccordo(isErogazione);
  572.             sqlquery.setANDLogicOperator(true);
  573.             if (!search.equals("")) {
  574.                 //query con search
  575.                 sqlquery.addSelectCountField("*", "cont");
  576.                 sqlquery.addWhereLikeCondition("nome", search, true, true);
  577.                 sqlquery.setANDLogicOperator(true);
  578.                 queryString = sqlquery.createSQLQuery();
  579.             } else {
  580.                 sqlquery.addSelectCountField("*", "cont");
  581.                 queryString = sqlquery.createSQLQuery();
  582.             }
  583.             stmt = con.prepareStatement(queryString);
  584.             stmt.setLong(1,idAccordo);
  585.             risultato = stmt.executeQuery();
  586.             if (risultato.next())
  587.                 ricerca.setNumEntries(idLista,risultato.getInt("cont"));
  588.             risultato.close();
  589.             stmt.close();


  592.             //resetto query
  593.             sqlquery = DriverRegistroServiziDB_accordiLIB.getSQLRicercaServiziValidiByIdAccordo(isErogazione);
  594.             sqlquery.setANDLogicOperator(true);
  595.             // ricavo le entries
  596.             if (limit == 0) // con limit
  597.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  598.             if (!search.equals("")) { // con search

  600.                 sqlquery.addSelectField("id_accordo");
  601.                 sqlquery.addSelectField("nome");
  602.                 sqlquery.addSelectField("descrizione");
  603.                 sqlquery.addSelectField("profilo_collaborazione");
  604.                 sqlquery.addSelectField("filtro_duplicati");
  605.                 sqlquery.addSelectField("conferma_ricezione");
  606.                 sqlquery.addSelectField("identificativo_collaborazione");
  607.                 sqlquery.addSelectField("id_riferimento_richiesta");
  608.                 sqlquery.addSelectField("consegna_in_ordine");
  609.                 sqlquery.addSelectField("scadenza");
  610.                 sqlquery.addSelectField("profilo_pt");
  611.                 sqlquery.addSelectField("soap_style");
  612.                 sqlquery.addSelectField("id");

  614.                 sqlquery.addWhereLikeCondition("nome", search, true, true);
  615.                 sqlquery.setANDLogicOperator(true);
  616.                 sqlquery.addOrderBy("nome");
  617.                 sqlquery.setSortType(true);
  618.                 sqlquery.setLimit(limit);
  619.                 sqlquery.setOffset(offset);
  620.                 queryString = sqlquery.createSQLQuery();
  621.             } else {
  622.                 // senza search
  623.                 sqlquery.addSelectField("id_accordo");
  624.                 sqlquery.addSelectField("nome");
  625.                 sqlquery.addSelectField("descrizione");
  626.                 sqlquery.addSelectField("profilo_collaborazione");
  627.                 sqlquery.addSelectField("filtro_duplicati");
  628.                 sqlquery.addSelectField("conferma_ricezione");
  629.                 sqlquery.addSelectField("identificativo_collaborazione");
  630.                 sqlquery.addSelectField("id_riferimento_richiesta");
  631.                 sqlquery.addSelectField("consegna_in_ordine");
  632.                 sqlquery.addSelectField("scadenza");
  633.                 sqlquery.addSelectField("profilo_pt");
  634.                 sqlquery.addSelectField("soap_style");
  635.                 sqlquery.addSelectField("id");

  637.                 sqlquery.addOrderBy("nome");
  638.                 sqlquery.setSortType(true);
  639.                 sqlquery.setLimit(limit);
  640.                 sqlquery.setOffset(offset);
  641.                 queryString = sqlquery.createSQLQuery();
  642.             }
  643.             stmt = con.prepareStatement(queryString);
  644.             stmt.setLong(1, idAccordo);
  645.             risultato = stmt.executeQuery();

  647.             PortType pt;
  648.             while (risultato.next()) {
  649.                 pt = new PortType();

  651.                 String tmp = risultato.getString("nome");
  652.                 pt.setNome(((tmp == null || tmp.equals("")) ? null : tmp));
  653.                 tmp = risultato.getString("descrizione");
  654.                 pt.setDescrizione(((tmp == null || tmp.equals("")) ? null : tmp));
  655.                 tmp = risultato.getString("profilo_collaborazione");
  656.                 pt.setProfiloCollaborazione(DriverRegistroServiziDB_LIB.getEnumProfiloCollaborazione(((tmp == null || tmp.equals("")) ? null : tmp)));
  657.                 tmp = risultato.getString("filtro_duplicati");
  658.                 pt.setFiltroDuplicati(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  659.                 tmp = risultato.getString("conferma_ricezione");
  660.                 pt.setConfermaRicezione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  661.                 tmp = risultato.getString("identificativo_collaborazione");
  662.                 pt.setIdCollaborazione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  663.                 tmp = risultato.getString("id_riferimento_richiesta");
  664.                 pt.setIdRiferimentoRichiesta(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  665.                 tmp = risultato.getString("consegna_in_ordine");
  666.                 pt.setConsegnaInOrdine(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  667.                 tmp = risultato.getString("scadenza");
  668.                 pt.setScadenza(((tmp == null || tmp.equals("")) ? null : tmp));
  669.                 tmp = risultato.getString("profilo_pt");
  670.                 if (tmp == null || tmp.equals(""))
  671.                     pt.setProfiloPT(CostantiRegistroServizi.PROFILO_AZIONE_DEFAULT);
  672.                 else
  673.                     pt.setProfiloPT(tmp);
  674.                 tmp = risultato.getString("soap_style");
  675.                 pt.setStyle(DriverRegistroServiziDB_LIB.getEnumBindingStyle(((tmp == null || tmp.equals("")) ? null : tmp)));
  676.                 pt.setIdAccordo(risultato.getLong("id_accordo"));
  677.                 long idPortType = risultato.getLong("id");
  678.                 pt.setId(idPortType);

  680.                 this.readAzioniPortTypes(pt, con);

  682.                 lista.add(pt);              
  683.             }

  685.             return lista;

  687.         } catch (Exception se) {

  689.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  690.         } finally {
  691.             //Chiudo statement and resultset
  692.             JDBCUtilities.closeResources(risultato, stmt);
  693.             
  694.             this.driver.closeConnection(con);
  695.         }
  696.     }
  697.     
  698.     
  699.     protected void updatePortType(org.openspcoop2.core.registry.PortType portType, String user) throws DriverRegistroServiziException {

  701.         if (portType == null)
  702.             throw new DriverRegistroServiziException("Il port-type non puo' essere null.");

  704.         String nome = portType.getNome();
  705.         if (nome == null || nome.equals(""))
  706.             throw new DriverRegistroServiziException("Il nome del port-type non e' valido.");

  708.         Connection connection = null;
  709.         PreparedStatement stm = null;
  710.         PreparedStatement updateStmt = null;
  711.         ResultSet rs =null;

  713.         boolean error = false;

  715.         if (this.driver.atomica) {
  716.             try {
  717.                 connection = this.driver.getConnectionFromDatasource("updatePortType");
  718.                 connection.setAutoCommit(false);
  719.             } catch (Exception e) {
  720.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::updatePortType] Exception accedendo al datasource :" + e.getMessage(),e);

  722.             }

  724.         } else
  725.             connection = this.driver.globalConnection;

  727.         this.driver.logDebug("operazione atomica = " + this.driver.atomica);

  729.         try {

  731.             // NOTA: questo metodo viene chiamato solo quando si vogliono aggiornare le azioni

  733.             //Prendo l'accordo per gestire il caso di "usa profilo accordo"
  734.             AccordoServizioParteComune as = this.driver.getAccordoServizioParteComune(portType.getIdAccordo(), connection);

  736.             if(portType.getId()==null || portType.getId()<=0){
  737.                 for (PortType ptCheck : as.getPortTypeList()) {
  738.                     if(ptCheck.getNome().equals(portType.getNome())){
  739.                         portType.setId(ptCheck.getId());
  740.                     }
  741.                 }
  742.             }
  743.             if(portType.getId()==null || portType.getId()<=0){
  744.                 throw new DriverRegistroServiziException("Id PortType undefined");
  745.             }
  746.                         
  747.             List<Long> idsOperation = new ArrayList<>();
  748.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  749.             sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  750.             sqlQueryObject.addWhereCondition("id_port_type=?");
  751.             String queryString = sqlQueryObject.createSQLQuery();
  752.             stm = connection.prepareStatement(queryString);
  753.             stm.setLong(1, portType.getId());
  754.             rs=stm.executeQuery();
  755.             while(rs.next()){
  756.                 idsOperation.add(rs.getLong("id"));
  757.             }
  758.             rs.close();
  759.             stm.close();
  760.             
  761.             if(idsOperation!=null && !idsOperation.isEmpty()){
  762.                 for (Long id : idsOperation) {
  763.                     ISQLQueryObject sqlQueryObjectMessages = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  764.                     sqlQueryObjectMessages.addDeleteTable(CostantiDB.PORT_TYPE_AZIONI_OPERATION_MESSAGES);
  765.                     sqlQueryObjectMessages.addWhereCondition("id_port_type_azione=?");
  766.                     String updateString = sqlQueryObjectMessages.createSQLDelete();
  767.                     stm = connection.prepareStatement(updateString);
  768.                     stm.setLong(1, id);
  769.                     int n=stm.executeUpdate();
  770.                     stm.close();
  771.                     this.driver.logDebug("Cancellate "+n+" operation messages associate all'azione con id "+id+" del port type "+portType.getNome()+ " dell'accordo: "+as.getNome());
  772.                 }
  773.             }
  774.             
  775.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  776.             sqlQueryObject.addDeleteTable(CostantiDB.PORT_TYPE_AZIONI);
  777.             sqlQueryObject.addWhereCondition("id_port_type=?");
  778.             String updateString = sqlQueryObject.createSQLDelete();
  779.             stm = connection.prepareStatement(updateString);
  780.             stm.setLong(1, portType.getId());
  781.             int n=stm.executeUpdate();
  782.             stm.close();
  783.             this.driver.logDebug("Cancellate "+n+" azioni associate al portType "+portType.getNome()+ " dell'accordo: "+(as!=null ? as.getNome() : null));
  784.             
  785.             for (int i = 0; i < portType.sizeAzioneList(); i++) {
  786.                 Operation azione = portType.getAzione(i);           
  787.                 DriverRegistroServiziDB_accordiSoapLIB.CRUDAzionePortType(CostantiDB.CREATE,as,portType,azione, connection, portType.getId(),
  788.                         this.driver.getDriverWrapBYOK());
  789.             }
  790.             this.driver.logDebug("inserite " + portType.sizeAzioneList() + " azioni relative al port type["+portType.getNome()+"] id-porttype["+portType.getId()+"]");
  791.             
  792.             if(user!=null && as!=null && as.getId()!=null && as.getId().longValue()>0 ) {
  793.                 ISQLQueryObject sqlQueryObjectUpdate = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  794.                 sqlQueryObjectUpdate.addUpdateTable(CostantiDB.ACCORDI);
  795.                 sqlQueryObjectUpdate.addUpdateField("utente_ultima_modifica", "?");
  796.                 sqlQueryObjectUpdate.addUpdateField("data_ultima_modifica", "?");
  797.                 sqlQueryObjectUpdate.addWhereCondition("id=?");
  798.                 updateString = sqlQueryObjectUpdate.createSQLUpdate();
  799.                 stm = connection.prepareStatement(updateString);
  800.                 int index = 1;
  801.                 stm.setString(index++, user);
  802.                 stm.setTimestamp(index++, DateManager.getTimestamp());
  803.                 stm.setLong(index, as.getId().longValue());
  804.                 n=stm.executeUpdate();
  805.                 stm.close();
  806.                 this.driver.logDebug("Aggiornata "+n+" entry per l'operazione di ultima modifica dell'accordo: "+as.getNome());
  807.             }
  808.         } 
  809.         catch (Exception se) {
  810.             this.driver.log.error(se.getMessage(),se);
  811.             error = true;
  812.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updatePortType] Exception [" + se.getMessage() + "].",se);
  813.         }finally {
  814.             JDBCUtilities.closeResources(rs, stm);
  815.             JDBCUtilities.closeResources(updateStmt);
  816.             this.driver.closeConnection(error,connection);
  817.         }

  819.     }
  820.     
  821.     protected List<Azione> accordiAzioniList(long idAccordo, ISearch ricerca) throws DriverRegistroServiziException{
  822.         String nomeMetodo = "accordiAzioniList";
  823.         int idLista = Liste.ACCORDI_AZIONI;
  824.         int offset;
  825.         int limit;
  826.         String search;
  827.         String queryString;

  829.         limit = ricerca.getPageSize(idLista);
  830.         offset = ricerca.getIndexIniziale(idLista);
  831.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  832.         ricerca.getSearchString(idLista);

  834.         Connection con = null;
  835.         PreparedStatement stmt = null;
  836.         ResultSet risultato = null;
  837.         ArrayList<Azione> lista = new ArrayList<>();

  839.         if (this.driver.atomica) {
  840.             try {
  841.                 con = this.driver.getConnectionFromDatasource("accordiAzioniList");
  842.             } catch (Exception e) {
  843.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  845.             }

  847.         } else
  848.             con = this.driver.globalConnection;

  850.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  852.         try {

  854.             // ricavo il numero di entries totale
  855.             if (!search.equals("")) {
  856.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  857.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_AZIONI);
  858.                 sqlQueryObject.addSelectCountField("*", "cont");
  859.                 sqlQueryObject.addWhereCondition("id_accordo = ?");
  860.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  861.                 sqlQueryObject.setANDLogicOperator(true);
  862.                 queryString = sqlQueryObject.createSQLQuery();
  863.             } else {
  864.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  865.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_AZIONI);
  866.                 sqlQueryObject.addSelectCountField("*", "cont");
  867.                 sqlQueryObject.addWhereCondition("id_accordo = ?");
  868.                 queryString = sqlQueryObject.createSQLQuery();
  869.             }
  870.             stmt = con.prepareStatement(queryString);
  871.             stmt.setLong(1, idAccordo);
  872.             risultato = stmt.executeQuery();
  873.             if (risultato.next())
  874.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  875.             risultato.close();
  876.             stmt.close();

  878.             // ricavo le entries
  879.             if (limit == 0) // con limit
  880.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  881.             if (!search.equals("")) { // con search
  882.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  883.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_AZIONI);
  884.                 sqlQueryObject.addSelectAliasField("id","idAzione");
  885.                 sqlQueryObject.addSelectField("nome");
  886.                 sqlQueryObject.addSelectField("conferma_ricezione");
  887.                 sqlQueryObject.addSelectField("consegna_in_ordine");
  888.                 sqlQueryObject.addSelectField("filtro_duplicati");
  889.                 sqlQueryObject.addSelectField("identificativo_collaborazione");
  890.                 sqlQueryObject.addSelectField("id_riferimento_richiesta");
  891.                 sqlQueryObject.addSelectField("scadenza");
  892.                 sqlQueryObject.addSelectField("profilo_collaborazione");
  893.                 sqlQueryObject.addSelectField("profilo_azione");
  894.                 sqlQueryObject.addSelectField("id_accordo");
  895.                 sqlQueryObject.addWhereCondition("id_accordo = ?");
  896.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  897.                 sqlQueryObject.setANDLogicOperator(true);
  898.                 sqlQueryObject.addOrderBy("nome");
  899.                 sqlQueryObject.setSortType(true);
  900.                 sqlQueryObject.setLimit(limit);
  901.                 sqlQueryObject.setOffset(offset);
  902.                 queryString = sqlQueryObject.createSQLQuery();
  903.             } else {
  904.                 // senza search
  905.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  906.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_AZIONI);
  907.                 sqlQueryObject.addSelectAliasField("id","idAzione");
  908.                 sqlQueryObject.addSelectField("nome");
  909.                 sqlQueryObject.addSelectField("conferma_ricezione");
  910.                 sqlQueryObject.addSelectField("consegna_in_ordine");
  911.                 sqlQueryObject.addSelectField("filtro_duplicati");
  912.                 sqlQueryObject.addSelectField("identificativo_collaborazione");
  913.                 sqlQueryObject.addSelectField("id_riferimento_richiesta");
  914.                 sqlQueryObject.addSelectField("scadenza");
  915.                 sqlQueryObject.addSelectField("profilo_collaborazione");
  916.                 sqlQueryObject.addSelectField("profilo_azione");
  917.                 sqlQueryObject.addSelectField("id_accordo");
  918.                 sqlQueryObject.addWhereCondition("id_accordo = ?");
  919.                 sqlQueryObject.addOrderBy("nome");
  920.                 sqlQueryObject.setSortType(true);
  921.                 sqlQueryObject.setLimit(limit);
  922.                 sqlQueryObject.setOffset(offset);
  923.                 queryString = sqlQueryObject.createSQLQuery();
  924.             }

  926.             stmt = con.prepareStatement(queryString);
  927.             stmt.setLong(1, idAccordo);
  928.             risultato = stmt.executeQuery();

  930.             Azione az;
  931.             while (risultato.next()) {

  933.                 az = new Azione();

  935.                 //az.setId(risultato.getLong("id_accordo"));  nn c'e' un id per questo oggetto

  937.                 //fix by stefano: Aggiunto campo idAzione alla query in modo da leggere l'id dell'oggetto azione
  938.                 az.setId(risultato.getLong("idAzione"));
  939.                 az.setNome(risultato.getString("nome"));
  940.                 az.setConfermaRicezione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(risultato.getString("conferma_ricezione")));
  941.                 az.setConsegnaInOrdine(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(risultato.getString("consegna_in_ordine")));
  942.                 az.setFiltroDuplicati(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(risultato.getString("filtro_duplicati")));
  943.                 az.setIdCollaborazione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(risultato.getString("identificativo_collaborazione")));
  944.                 az.setIdRiferimentoRichiesta(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(risultato.getString("id_riferimento_richiesta")));
  945.                 az.setScadenza(risultato.getString("scadenza"));
  946.                 az.setProfiloCollaborazione(DriverRegistroServiziDB_LIB.getEnumProfiloCollaborazione(risultato.getString("profilo_collaborazione")));
  947.                 az.setProfAzione(risultato.getString("profilo_azione"));
  948.                 lista.add(az);
  949.             }

  951.             return lista;

  953.         } catch (Exception qe) {
  954.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  955.         } finally {

  957.             //Chiudo statement and resultset
  958.             JDBCUtilities.closeResources(risultato, stmt);

  960.             this.driver.closeConnection(con);
  961.         }
  962.     }

  964.     /**
  965.      * Recupera la lista di azioni dell'Accordo con id idAccordo, con il profilo di collaborazione specificato
  966.      * Il profilo di collaborazione viene ricercato nell'accordo di servizio se l'azione ha profilo di defaul
  967.      * altrimenti viene controllato il profilo di collaborazione dell'azione 
  968.      * @param idAccordo
  969.      * @param profiloCollaborazione Opzionale
  970.      * @param ricerca
  971.      * @return Lista di {@link Azione} dell'accordo idAccordo con profilo di collaborazione 'profiloCollaborazione' se specificato altrimenti tutte.
  972.      * @throws DriverRegistroServiziException
  973.      */
  974.     protected List<Azione> accordiAzioniList(long idAccordo,String profiloCollaborazione, ISearch ricerca) throws DriverRegistroServiziException {
  975.         String nomeMetodo = "accordiAzioniList";
  976.         int idLista = Liste.ACCORDI_AZIONI;
  977.         int offset;
  978.         int limit;
  979.         String search;
  980.         String queryString;

  982.         limit = ricerca.getPageSize(idLista);
  983.         offset = ricerca.getIndexIniziale(idLista);
  984.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  985.         ricerca.getSearchString(idLista);

  987.         Connection con = null;
  988.         PreparedStatement stmt = null;
  989.         ResultSet risultato = null;
  990.         ArrayList<Azione> lista = new ArrayList<>();

  992.         if (this.driver.atomica) {
  993.             try {
  994.                 con = this.driver.getConnectionFromDatasource("accordiAzioniList");
  995.             } catch (Exception e) {
  996.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  998.             }

  1000.         } else
  1001.             con = this.driver.globalConnection;

  1003.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  1005.         try {

  1007.             /**
  1008.              * SELECT a.id as idAccordo,aa.id,aa.nome 
  1009.              * from accordi as a, accordi_azioni as aa 
  1010.              * where a.id=aa.id_accordo 
  1011.              * and( (aa.profilo_azione='ridefinito' and aa.profilo_collaborazione='asincronoAsimmetrico') or a.profilo_collaborazione='asincronoAsimmetrico') 
  1012.              * and aa.id_accordo=12;
  1013.              */
  1014.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1015.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  1016.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI_AZIONI);
  1017.             sqlQueryObject.addSelectCountField(CostantiDB.ACCORDI_AZIONI+".id", "cont");
  1018.             sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_AZIONI+".id_accordo = "+CostantiDB.ACCORDI+".id");
  1019.             sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_AZIONI+".id_accordo = ?");
  1020.             //(aa.profilo_azione='ridefinito' and aa.profilo_collaborazione='asincronoAsimmetrico') or a.profilo_collaborazione='asincronoAsimmetrico')
  1021.             sqlQueryObject.addWhereCondition(false, 
  1022.                     CostantiDB.ACCORDI_AZIONI+".profilo_collaborazione = ? AND "+CostantiDB.ACCORDI_AZIONI+".profilo_azione= ?",
  1023.                     CostantiDB.ACCORDI+".profilo_collaborazione=?");
  1024.             sqlQueryObject.setANDLogicOperator(true);

  1026.             if (!search.equals("")) {
  1027.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1028.             }

  1030.             queryString = sqlQueryObject.createSQLQuery();

  1032.             stmt = con.prepareStatement(queryString);
  1033.             stmt.setLong(1, idAccordo);
  1034.             stmt.setString(2, profiloCollaborazione);
  1035.             stmt.setString(3, CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO);
  1036.             stmt.setString(4, profiloCollaborazione);

  1038.             risultato = stmt.executeQuery();
  1039.             if (risultato.next())
  1040.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1041.             risultato.close();
  1042.             stmt.close();

  1044.             // ricavo le entries
  1045.             if (limit == 0) // con limit
  1046.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;

  1048.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1049.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  1050.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI_AZIONI);

  1052.             sqlQueryObject.addSelectField(CostantiDB.ACCORDI_AZIONI,"nome");
  1053.             sqlQueryObject.addSelectField(CostantiDB.ACCORDI_AZIONI,"conferma_ricezione");
  1054.             sqlQueryObject.addSelectField(CostantiDB.ACCORDI_AZIONI,"consegna_in_ordine");
  1055.             sqlQueryObject.addSelectField(CostantiDB.ACCORDI_AZIONI,"filtro_duplicati");
  1056.             sqlQueryObject.addSelectField(CostantiDB.ACCORDI_AZIONI,"identificativo_collaborazione");
  1057.             sqlQueryObject.addSelectField(CostantiDB.ACCORDI_AZIONI,"id_riferimento_richiesta");
  1058.             sqlQueryObject.addSelectField(CostantiDB.ACCORDI_AZIONI,"scadenza");
  1059.             sqlQueryObject.addSelectField(CostantiDB.ACCORDI_AZIONI,"profilo_collaborazione");
  1060.             sqlQueryObject.addSelectField(CostantiDB.ACCORDI_AZIONI,"profilo_azione");
  1061.             sqlQueryObject.addSelectField(CostantiDB.ACCORDI_AZIONI,"id_accordo");
  1062.             sqlQueryObject.addSelectField(CostantiDB.ACCORDI_AZIONI,"correlata");
  1063.             //where
  1064.             sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_AZIONI+".id_accordo = "+CostantiDB.ACCORDI+".id");
  1065.             sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_AZIONI+".id_accordo = ?");
  1066.             //(aa.profilo_azione='ridefinito' and aa.profilo_collaborazione='asincronoAsimmetrico') or a.profilo_collaborazione='asincronoAsimmetrico')
  1067.             sqlQueryObject.addWhereCondition(false, 
  1068.                     CostantiDB.ACCORDI_AZIONI+".profilo_collaborazione = ? AND "+CostantiDB.ACCORDI_AZIONI+".profilo_azione= ?",
  1069.                     CostantiDB.ACCORDI+".profilo_collaborazione=?");

  1071.             sqlQueryObject.setANDLogicOperator(true);
  1072.             sqlQueryObject.setLimit(limit);
  1073.             sqlQueryObject.setOffset(offset);

  1075.             sqlQueryObject.addOrderBy(CostantiDB.ACCORDI_AZIONI+".nome");

  1077.             if (!search.equals("")) {
  1078.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1079.             }

  1081.             queryString = sqlQueryObject.createSQLQuery();


  1084.             stmt = con.prepareStatement(queryString);
  1085.             stmt.setLong(1, idAccordo);
  1086.             stmt.setString(2, profiloCollaborazione);
  1087.             stmt.setString(3, CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO);
  1088.             stmt.setString(4, profiloCollaborazione);

  1090.             risultato = stmt.executeQuery();

  1092.             Azione az;
  1093.             while (risultato.next()) {

  1095.                 az = new Azione();

  1097.                 //az.setId(risultato.getLong("id_accordo"));  nn c'e' un id per questo oggetto

  1099.                 az.setNome(risultato.getString("nome"));
  1100.                 az.setConfermaRicezione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(risultato.getString("conferma_ricezione")));
  1101.                 az.setConsegnaInOrdine(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(risultato.getString("consegna_in_ordine")));
  1102.                 az.setFiltroDuplicati(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(risultato.getString("filtro_duplicati")));
  1103.                 az.setIdCollaborazione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(risultato.getString("identificativo_collaborazione")));
  1104.                 az.setIdRiferimentoRichiesta(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(risultato.getString("id_riferimento_richiesta")));
  1105.                 az.setScadenza(risultato.getString("scadenza"));
  1106.                 az.setProfiloCollaborazione(DriverRegistroServiziDB_LIB.getEnumProfiloCollaborazione(risultato.getString("profilo_collaborazione")));
  1107.                 az.setProfAzione(risultato.getString("profilo_azione"));
  1108.                 az.setCorrelata(risultato.getString("correlata"));
  1109.                 lista.add(az);
  1110.             }

  1112.             return lista;

  1114.         } catch (Exception qe) {
  1115.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  1116.         } finally {

  1118.             //Chiudo statement and resultset
  1119.             JDBCUtilities.closeResources(risultato, stmt);

  1121.             this.driver.closeConnection(con);
  1122.         }
  1123.     }
  1124.     
  1125.     protected void deleteAzione(long idAccordo, String nomeAzione) throws DriverRegistroServiziException {
  1126.         String nomeMetodo = "deleteAzione";
  1127.         Connection con = null;
  1128.         PreparedStatement stmt = null;

  1130.         if (this.driver.atomica) {
  1131.             try {
  1132.                 con = this.driver.getConnectionFromDatasource("deleteAzione");

  1134.             } catch (Exception e) {
  1135.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1137.             }

  1139.         } else
  1140.             con = this.driver.globalConnection;

  1142.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  1144.         try {
  1145.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1146.             sqlQueryObject.addDeleteTable(CostantiDB.ACCORDI_AZIONI);
  1147.             sqlQueryObject.addWhereCondition("id_accordo=?");
  1148.             sqlQueryObject.addWhereCondition("nome=?");
  1149.             sqlQueryObject.setANDLogicOperator(true);
  1150.             String updateString = sqlQueryObject.createSQLDelete();
  1151.             stmt = con.prepareStatement(updateString);
  1152.             stmt.setLong(1, idAccordo);
  1153.             stmt.setString(2, nomeAzione);
  1154.             stmt.executeUpdate();
  1155.             stmt.close();

  1157.         } catch (Exception se) {
  1158.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1159.         } finally {
  1160.             //Chiudo statement and resultset
  1161.             JDBCUtilities.closeResources(stmt);
  1162.             
  1163.             this.driver.closeConnection(con);
  1164.         }

  1166.     }
  1167.     
  1168.     protected List<PortType> accordiPorttypeList(long idAccordo, ISearch ricerca) throws DriverRegistroServiziException {
  1169.         String nomeMetodo = "accordiPorttypeList";
  1170.         int idLista = Liste.ACCORDI_PORTTYPE;
  1171.         int offset;
  1172.         int limit;
  1173.         String search;
  1174.         String queryString;

  1176.         limit = ricerca.getPageSize(idLista);
  1177.         offset = ricerca.getIndexIniziale(idLista);
  1178.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  1179.         ricerca.getSearchString(idLista);

  1181.         Connection con = null;
  1182.         PreparedStatement stmt = null;
  1183.         ResultSet risultato = null;

  1185.         ArrayList<PortType> lista = new ArrayList<PortType>();

  1187.         if (this.driver.atomica) {
  1188.             try {
  1189.                 con = this.driver.getConnectionFromDatasource("accordiPorttypeList");

  1191.             } catch (Exception e) {
  1192.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1194.             }

  1196.         } else
  1197.             con = this.driver.globalConnection;

  1199.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  1201.         try {

  1203.             if (!search.equals("")) {
  1204.                 //query con search
  1205.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1206.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE);
  1207.                 sqlQueryObject.addSelectCountField("*", "cont");
  1208.                 sqlQueryObject.addWhereCondition("id_accordo = ?");
  1209.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1210.                 sqlQueryObject.setANDLogicOperator(true);
  1211.                 queryString = sqlQueryObject.createSQLQuery();
  1212.             } else {
  1213.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1214.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE);
  1215.                 sqlQueryObject.addSelectCountField("*", "cont");
  1216.                 sqlQueryObject.addWhereCondition("id_accordo = ?");
  1217.                 queryString = sqlQueryObject.createSQLQuery();
  1218.             }
  1219.             stmt = con.prepareStatement(queryString);
  1220.             stmt.setLong(1,idAccordo);
  1221.             risultato = stmt.executeQuery();
  1222.             if (risultato.next())
  1223.                 ricerca.setNumEntries(idLista,risultato.getInt("cont"));
  1224.             risultato.close();
  1225.             stmt.close();

  1227.             // ricavo le entries
  1228.             if (limit == 0) // con limit
  1229.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1230.             if (!search.equals("")) { // con search
  1231.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1232.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE);
  1233.                 sqlQueryObject.addSelectField("id");
  1234.                 sqlQueryObject.addSelectField("nome");
  1235.                 sqlQueryObject.addWhereCondition("id_accordo = ?");
  1236.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1237.                 sqlQueryObject.setANDLogicOperator(true);
  1238.                 sqlQueryObject.addOrderBy("nome");
  1239.                 sqlQueryObject.setSortType(true);
  1240.                 sqlQueryObject.setLimit(limit);
  1241.                 sqlQueryObject.setOffset(offset);
  1242.                 queryString = sqlQueryObject.createSQLQuery();
  1243.             } else {
  1244.                 // senza search
  1245.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1246.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE);
  1247.                 sqlQueryObject.addSelectField("id");
  1248.                 sqlQueryObject.addSelectField("nome");
  1249.                 sqlQueryObject.addWhereCondition("id_accordo = ?");
  1250.                 sqlQueryObject.addOrderBy("nome");
  1251.                 sqlQueryObject.setSortType(true);
  1252.                 sqlQueryObject.setLimit(limit);
  1253.                 sqlQueryObject.setOffset(offset);
  1254.                 queryString = sqlQueryObject.createSQLQuery();
  1255.             }
  1256.             stmt = con.prepareStatement(queryString);
  1257.             stmt.setLong(1, idAccordo);
  1258.             risultato = stmt.executeQuery();

  1260.             List<Long> listID = new ArrayList<Long>();
  1261.             while (risultato.next()) {
  1262.                 
  1263.                 long idPortType = risultato.getLong("id");
  1264.                 listID.add(idPortType);
  1265.             }

  1267.             if(listID.size()>0) {
  1268.                 for (Long idPT : listID) {
  1269.                     lista.add(this.getPortType(idPT));
  1270.                 }
  1271.             }
  1272.             
  1273.             return lista;

  1275.         } catch (Exception se) {

  1277.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1278.         } finally {
  1279.             //Chiudo statement and resultset
  1280.             JDBCUtilities.closeResources(risultato, stmt);
  1281.             
  1282.             this.driver.closeConnection(con);
  1283.         }
  1284.     }

  1286.     protected List<PortType> accordiPorttypeList(long idAccordo, String profiloCollaborazione, ISearch ricerca) throws DriverRegistroServiziException {
  1287.         String nomeMetodo = "accordiPorttypeList";
  1288.         int idLista = Liste.ACCORDI_PORTTYPE;
  1289.         int offset;
  1290.         int limit;
  1291.         String search;
  1292.         String queryString;

  1294.         limit = ricerca.getPageSize(idLista);
  1295.         offset = ricerca.getIndexIniziale(idLista);
  1296.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  1297.         ricerca.getSearchString(idLista);

  1299.         Connection con = null;
  1300.         PreparedStatement stmt = null;
  1301.         ResultSet risultato = null;

  1303.         ArrayList<PortType> lista = new ArrayList<PortType>();

  1305.         if (this.driver.atomica) {
  1306.             try {
  1307.                 con = this.driver.getConnectionFromDatasource("accordiPorttypeList");

  1309.             } catch (Exception e) {
  1310.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1312.             }

  1314.         } else
  1315.             con = this.driver.globalConnection;

  1317.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  1319.         try {

  1321.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1322.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  1323.             sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE);
  1324.             sqlQueryObject.addSelectCountField("*", "cont");
  1325.             sqlQueryObject.setANDLogicOperator(true);
  1326.             sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE+".id_accordo = "+CostantiDB.ACCORDI+".id");
  1327.             sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE+".id_accordo = ?");
  1328.             if(profiloCollaborazione!=null){
  1329.                 sqlQueryObject.addWhereCondition(false,
  1330.                         CostantiDB.ACCORDI+".profilo_collaborazione=?"
  1331.                         ,CostantiDB.PORT_TYPE+".profilo_collaborazione = ? AND "+CostantiDB.PORT_TYPE+".profilo_pt= ?");
  1332.             }
  1333.             if (!search.equals("")) {
  1334.                 //query con search
  1335.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1336.             }
  1337.             queryString = sqlQueryObject.createSQLQuery();
  1338.             stmt = con.prepareStatement(queryString);
  1339.             stmt.setLong(1,idAccordo);
  1340.             if(profiloCollaborazione!=null){
  1341.                 stmt.setString(2,profiloCollaborazione);
  1342.                 stmt.setString(3,profiloCollaborazione);
  1343.                 stmt.setString(4,CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO);
  1344.             }
  1345.             risultato = stmt.executeQuery();
  1346.             if (risultato.next())
  1347.                 ricerca.setNumEntries(idLista,risultato.getInt("cont"));
  1348.             risultato.close();
  1349.             stmt.close();

  1351.             // ricavo le entries
  1352.             if (limit == 0) // con limit
  1353.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;

  1355.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1356.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  1357.             sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE);
  1358.             sqlQueryObject.addSelectField(CostantiDB.PORT_TYPE, "id_accordo");
  1359.             sqlQueryObject.addSelectField(CostantiDB.PORT_TYPE, "nome");
  1360.             sqlQueryObject.addSelectField(CostantiDB.PORT_TYPE, "descrizione");
  1361.             sqlQueryObject.addSelectField(CostantiDB.PORT_TYPE, "profilo_collaborazione");
  1362.             sqlQueryObject.addSelectField(CostantiDB.PORT_TYPE, "filtro_duplicati");
  1363.             sqlQueryObject.addSelectField(CostantiDB.PORT_TYPE, "conferma_ricezione");
  1364.             sqlQueryObject.addSelectField(CostantiDB.PORT_TYPE, "identificativo_collaborazione");
  1365.             sqlQueryObject.addSelectField(CostantiDB.PORT_TYPE, "id_riferimento_richiesta");
  1366.             sqlQueryObject.addSelectField(CostantiDB.PORT_TYPE, "consegna_in_ordine");
  1367.             sqlQueryObject.addSelectField(CostantiDB.PORT_TYPE, "scadenza");
  1368.             sqlQueryObject.addSelectField(CostantiDB.PORT_TYPE, "profilo_pt");
  1369.             sqlQueryObject.addSelectField(CostantiDB.PORT_TYPE, "soap_style");
  1370.             sqlQueryObject.addSelectField(CostantiDB.PORT_TYPE, "id");
  1371.             sqlQueryObject.setANDLogicOperator(true);
  1372.             sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE+".id_accordo = "+CostantiDB.ACCORDI+".id");
  1373.             sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE+".id_accordo = ?");
  1374.             if(profiloCollaborazione!=null){
  1375.                 sqlQueryObject.addWhereCondition(false,
  1376.                         CostantiDB.ACCORDI+".profilo_collaborazione=?"
  1377.                         ,CostantiDB.PORT_TYPE+".profilo_collaborazione = ? AND "+CostantiDB.PORT_TYPE+".profilo_pt= ?");
  1378.             }
  1379.             if (!search.equals("")) { // con search
  1380.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1381.             }
  1382.             sqlQueryObject.addOrderBy(CostantiDB.PORT_TYPE+".nome");
  1383.             sqlQueryObject.setSortType(true);
  1384.             sqlQueryObject.setLimit(limit);
  1385.             sqlQueryObject.setOffset(offset);
  1386.             queryString = sqlQueryObject.createSQLQuery();
  1387.             stmt = con.prepareStatement(queryString);
  1388.             stmt.setLong(1, idAccordo);
  1389.             if(profiloCollaborazione!=null){
  1390.                 stmt.setString(2,profiloCollaborazione);
  1391.                 stmt.setString(3,profiloCollaborazione);
  1392.                 stmt.setString(4,CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO);
  1393.             }
  1394.             risultato = stmt.executeQuery();

  1396.             PortType pt;
  1397.             while (risultato.next()) {
  1398.                 pt = new PortType();

  1400.                 String tmp = risultato.getString("nome");
  1401.                 pt.setNome(((tmp == null || tmp.equals("")) ? null : tmp));
  1402.                 tmp = risultato.getString("descrizione");
  1403.                 pt.setDescrizione(((tmp == null || tmp.equals("")) ? null : tmp));
  1404.                 tmp = risultato.getString("profilo_collaborazione");
  1405.                 pt.setProfiloCollaborazione(DriverRegistroServiziDB_LIB.getEnumProfiloCollaborazione(((tmp == null || tmp.equals("")) ? null : tmp)));
  1406.                 tmp = risultato.getString("filtro_duplicati");
  1407.                 pt.setFiltroDuplicati(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  1408.                 tmp = risultato.getString("conferma_ricezione");
  1409.                 pt.setConfermaRicezione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  1410.                 tmp = risultato.getString("identificativo_collaborazione");
  1411.                 pt.setIdCollaborazione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  1412.                 tmp = risultato.getString("id_riferimento_richiesta");
  1413.                 pt.setIdRiferimentoRichiesta(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  1414.                 tmp = risultato.getString("consegna_in_ordine");
  1415.                 pt.setConsegnaInOrdine(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  1416.                 tmp = risultato.getString("scadenza");
  1417.                 pt.setScadenza(((tmp == null || tmp.equals("")) ? null : tmp));
  1418.                 tmp = risultato.getString("profilo_pt");
  1419.                 if (tmp == null || tmp.equals(""))
  1420.                     pt.setProfiloPT(CostantiRegistroServizi.PROFILO_AZIONE_DEFAULT);
  1421.                 else
  1422.                     pt.setProfiloPT(tmp);
  1423.                 tmp = risultato.getString("soap_style");
  1424.                 pt.setStyle(DriverRegistroServiziDB_LIB.getEnumBindingStyle(((tmp == null || tmp.equals("")) ? null : tmp)));
  1425.                 pt.setIdAccordo(risultato.getLong("id_accordo"));
  1426.                 long idPortType = risultato.getLong("id");
  1427.                 pt.setId(idPortType);
  1428.                 lista.add(pt);
  1429.             }

  1431.             return lista;

  1433.         } catch (Exception se) {

  1435.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1436.         } finally {
  1437.             //Chiudo statement and resultset
  1438.             JDBCUtilities.closeResources(risultato, stmt);
  1439.             
  1440.             this.driver.closeConnection(con);
  1441.         }
  1442.     }
  1443.     
  1444.     protected List<Operation> accordiPorttypeOperationList(long idPortType,String profiloCollaborazione, ISearch ricerca) throws DriverRegistroServiziException {
  1445.         String nomeMetodo = "accordiPorttypeOperationsList";
  1446.         int idLista = Liste.ACCORDI_PORTTYPE_AZIONI;
  1447.         int offset;
  1448.         int limit;
  1449.         String search;
  1450.         String queryString;

  1452.         limit = ricerca.getPageSize(idLista);
  1453.         offset = ricerca.getIndexIniziale(idLista);
  1454.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  1455.         ricerca.getSearchString(idLista);

  1457.         Connection con = null;
  1458.         PreparedStatement stmt = null;
  1459.         ResultSet risultato = null;

  1461.         ArrayList<Operation> lista = new ArrayList<Operation>();

  1463.         if (this.driver.atomica) {
  1464.             try {
  1465.                 con = this.driver.getConnectionFromDatasource("accordiPorttypeOperationList");

  1467.             } catch (Exception e) {
  1468.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1470.             }

  1472.         } else
  1473.             con = this.driver.globalConnection;

  1475.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  1477.         try {

  1479.             /*SELECT a.id,pt.nome,pta.nome 
  1480.              * from accordi a,port_type pt,port_type_azioni pta
  1481.                 where a.id=pt.id_accordo and pt.id=pta.id_port_type
  1482.                 and 
  1483.                 (
  1484.                     a.profilo_collaborazione='asincronoAsimmetrico'
  1485.                     OR (pt.profilo_pt='ridefinito' AND pt.profilo_collaborazione='asincronoAsimmetrico')
  1486.                     OR (pta.profilo_pt_azione='ridefinito' AND pta.profilo_collaborazione='asincronoAsimmetrico')
  1487.                 ));
  1488.              */ 
  1489.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1490.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  1491.             sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE);
  1492.             sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  1493.             //count
  1494.             sqlQueryObject.addSelectCountField(CostantiDB.PORT_TYPE_AZIONI+".id", "cont");
  1495.             //condizioni di join
  1496.             sqlQueryObject.setANDLogicOperator(true);

  1498.             sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE+".id_accordo = "+CostantiDB.ACCORDI+".id");
  1499.             sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".id_port_type = "+CostantiDB.PORT_TYPE+".id");
  1500.             sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE+".id = ?");

  1502.             sqlQueryObject.addWhereCondition(false,
  1503.                     CostantiDB.ACCORDI+".profilo_collaborazione=?"
  1504.                     ,CostantiDB.PORT_TYPE+".profilo_collaborazione = ? AND "+CostantiDB.PORT_TYPE+".profilo_pt= ?"
  1505.                     ,CostantiDB.PORT_TYPE_AZIONI+".profilo_collaborazione = ? AND "+CostantiDB.PORT_TYPE_AZIONI+".profilo_pt_azione= ?");

  1507.             if (!search.equals("")) {
  1508.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1509.             }

  1511.             queryString = sqlQueryObject.createSQLQuery();

  1513.             stmt = con.prepareStatement(queryString);
  1514.             stmt.setLong(1,idPortType);
  1515.             stmt.setString(2,profiloCollaborazione);
  1516.             stmt.setString(3,profiloCollaborazione);
  1517.             stmt.setString(4,CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO);
  1518.             stmt.setString(5,profiloCollaborazione);
  1519.             stmt.setString(6,CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO);

  1521.             risultato = stmt.executeQuery();
  1522.             if (risultato.next())
  1523.                 ricerca.setNumEntries(idLista,risultato.getInt("cont"));
  1524.             risultato.close();
  1525.             stmt.close();

  1527.             // ricavo le entries
  1528.             if (limit == 0) // con limit
  1529.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;


  1532.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1533.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  1534.             sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE);
  1535.             sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  1536.             //select
  1537.             sqlQueryObject.addSelectField(CostantiDB.PORT_TYPE_AZIONI,"id_port_type");
  1538.             sqlQueryObject.addSelectAliasField(CostantiDB.PORT_TYPE_AZIONI,"nome","nomePTAz");
  1539.             sqlQueryObject.addSelectAliasField(CostantiDB.PORT_TYPE_AZIONI,"profilo_collaborazione","profCollPTAz");
  1540.             sqlQueryObject.addSelectAliasField(CostantiDB.PORT_TYPE_AZIONI,"filtro_duplicati","filtro_duplicatiPTAz");
  1541.             sqlQueryObject.addSelectAliasField(CostantiDB.PORT_TYPE_AZIONI,"conferma_ricezione","conferma_ricezionePTAz");
  1542.             sqlQueryObject.addSelectAliasField(CostantiDB.PORT_TYPE_AZIONI,"identificativo_collaborazione","idCollPTAz");
  1543.             sqlQueryObject.addSelectAliasField(CostantiDB.PORT_TYPE_AZIONI,"id_riferimento_richiesta","idRifRichiestaPTAz");
  1544.             sqlQueryObject.addSelectAliasField(CostantiDB.PORT_TYPE_AZIONI,"consegna_in_ordine","consegna_in_ordinePTAz");
  1545.             sqlQueryObject.addSelectAliasField(CostantiDB.PORT_TYPE_AZIONI,"scadenza","scadenzaPTAz");
  1546.             sqlQueryObject.addSelectAliasField(CostantiDB.PORT_TYPE_AZIONI,"correlata","correlataPTAz");
  1547.             sqlQueryObject.addSelectAliasField(CostantiDB.PORT_TYPE_AZIONI,"correlata_servizio","correlataServizioPTAz");
  1548.             sqlQueryObject.addSelectField(CostantiDB.PORT_TYPE_AZIONI,"profilo_pt_azione");
  1549.             sqlQueryObject.addSelectAliasField(CostantiDB.PORT_TYPE_AZIONI,"id","idPTAz");
  1550.             //condizioni di join
  1551.             sqlQueryObject.setANDLogicOperator(true);

  1553.             sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE+".id_accordo = "+CostantiDB.ACCORDI+".id");
  1554.             sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".id_port_type = "+CostantiDB.PORT_TYPE+".id");
  1555.             sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE+".id = ?");

  1557.             sqlQueryObject.addWhereCondition(false,
  1558.                     CostantiDB.ACCORDI+".profilo_collaborazione=?"
  1559.                     ,CostantiDB.PORT_TYPE+".profilo_collaborazione = ? AND "+CostantiDB.PORT_TYPE+".profilo_pt= ?"
  1560.                     ,CostantiDB.PORT_TYPE_AZIONI+".profilo_collaborazione = ? AND "+CostantiDB.PORT_TYPE_AZIONI+".profilo_pt_azione= ?");

  1562.             if (!search.equals("")) {
  1563.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1564.             }

  1566.             sqlQueryObject.addOrderBy(CostantiDB.PORT_TYPE_AZIONI+".nome");
  1567.             sqlQueryObject.setSortType(true);
  1568.             sqlQueryObject.setLimit(limit);
  1569.             sqlQueryObject.setOffset(offset);

  1571.             queryString = sqlQueryObject.createSQLQuery();

  1573.             this.driver.logDebug("Query: "+queryString);

  1575.             stmt = con.prepareStatement(queryString);
  1576.             stmt.setLong(1,idPortType);
  1577.             stmt.setString(2,profiloCollaborazione);
  1578.             stmt.setString(3,profiloCollaborazione);
  1579.             stmt.setString(4,CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO);
  1580.             stmt.setString(5,profiloCollaborazione);
  1581.             stmt.setString(6,CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO);


  1584.             risultato = stmt.executeQuery();
  1585.             Operation op;
  1586.             while (risultato.next()) {
  1587.                 op = new Operation();

  1589.                 String tmp = risultato.getString("nomePTAz");
  1590.                 op.setNome(((tmp == null || tmp.equals("")) ? null : tmp));
  1591.                 tmp = risultato.getString("profCollPTAz");
  1592.                 op.setProfiloCollaborazione(DriverRegistroServiziDB_LIB.getEnumProfiloCollaborazione(((tmp == null || tmp.equals("")) ? null : tmp)));
  1593.                 tmp = risultato.getString("filtro_duplicatiPTAz");
  1594.                 op.setFiltroDuplicati(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  1595.                 tmp = risultato.getString("conferma_ricezionePTAz");
  1596.                 op.setConfermaRicezione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  1597.                 tmp = risultato.getString("idCollPTAz");
  1598.                 op.setIdCollaborazione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  1599.                 tmp = risultato.getString("idRifRichiestaPTAz");
  1600.                 op.setIdRiferimentoRichiesta(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  1601.                 tmp = risultato.getString("consegna_in_ordinePTAz");
  1602.                 op.setConsegnaInOrdine(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  1603.                 tmp = risultato.getString("scadenzaPTAz");
  1604.                 op.setScadenza(((tmp == null || tmp.equals("")) ? null : tmp));
  1605.                 tmp = risultato.getString("correlataPTAz");
  1606.                 op.setCorrelata(((tmp == null || tmp.equals("")) ? null : tmp));
  1607.                 tmp = risultato.getString("correlataServizioPTAz");
  1608.                 op.setCorrelataServizio(((tmp == null || tmp.equals("")) ? null : tmp));
  1609.                 tmp = risultato.getString("profilo_pt_azione");
  1610.                 if (tmp == null || tmp.equals(""))
  1611.                     op.setProfAzione(CostantiRegistroServizi.PROFILO_AZIONE_DEFAULT);
  1612.                 else
  1613.                     op.setProfAzione(tmp);
  1614.                 op.setIdPortType(risultato.getLong("id_port_type"));
  1615.                 long idOperation = risultato.getLong("idPTAz");
  1616.                 op.setId(idOperation);
  1617.                 lista.add(op);
  1618.             }

  1620.             return lista;

  1622.         } catch (Exception se) {
  1623.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1624.         } finally {
  1625.             //Chiudo statement and resultset
  1626.             JDBCUtilities.closeResources(risultato, stmt);
  1627.             
  1628.             this.driver.closeConnection(con);
  1629.         }
  1630.     }


  1633.     protected List<Operation> accordiPorttypeOperationList(long idPortType, ISearch ricerca) throws DriverRegistroServiziException {
  1634.         String nomeMetodo = "accordiPorttypeOperationsList";
  1635.         int idLista = Liste.ACCORDI_PORTTYPE_AZIONI;
  1636.         int offset;
  1637.         int limit;
  1638.         String search;
  1639.         String queryString;

  1641.         limit = ricerca.getPageSize(idLista);
  1642.         offset = ricerca.getIndexIniziale(idLista);
  1643.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  1644.         ricerca.getSearchString(idLista);

  1646.         Connection con = null;
  1647.         PreparedStatement stmt = null;
  1648.         ResultSet risultato = null;

  1650.         ArrayList<Operation> lista = new ArrayList<Operation>();

  1652.         if (this.driver.atomica) {
  1653.             try {
  1654.                 con = this.driver.getConnectionFromDatasource("accordiPorttypeOperationList");

  1656.             } catch (Exception e) {
  1657.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1659.             }

  1661.         } else
  1662.             con = this.driver.globalConnection;

  1664.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  1666.         try {

  1668.             if (!search.equals("")) {
  1669.                 //query con search
  1670.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1671.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  1672.                 sqlQueryObject.addSelectCountField("*", "cont");
  1673.                 sqlQueryObject.addWhereCondition("id_port_type = ?");
  1674.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1675.                 sqlQueryObject.setANDLogicOperator(true);
  1676.                 queryString = sqlQueryObject.createSQLQuery();
  1677.             } else {
  1678.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1679.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  1680.                 sqlQueryObject.addSelectCountField("*", "cont");
  1681.                 sqlQueryObject.addWhereCondition("id_port_type = ?");
  1682.                 queryString = sqlQueryObject.createSQLQuery();
  1683.             }
  1684.             stmt = con.prepareStatement(queryString);
  1685.             stmt.setLong(1,idPortType);
  1686.             risultato = stmt.executeQuery();
  1687.             if (risultato.next())
  1688.                 ricerca.setNumEntries(idLista,risultato.getInt("cont"));
  1689.             risultato.close();
  1690.             stmt.close();

  1692.             // ricavo le entries
  1693.             if (limit == 0) // con limit
  1694.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1695.             if (!search.equals("")) { // con search
  1696.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1697.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  1698.                 sqlQueryObject.addSelectField("id_port_type");
  1699.                 sqlQueryObject.addSelectField("nome");
  1700.                 sqlQueryObject.addSelectField("profilo_collaborazione");
  1701.                 sqlQueryObject.addSelectField("filtro_duplicati");
  1702.                 sqlQueryObject.addSelectField("conferma_ricezione");
  1703.                 sqlQueryObject.addSelectField("identificativo_collaborazione");
  1704.                 sqlQueryObject.addSelectField("id_riferimento_richiesta");
  1705.                 sqlQueryObject.addSelectField("consegna_in_ordine");
  1706.                 sqlQueryObject.addSelectField("scadenza");
  1707.                 sqlQueryObject.addSelectField("profilo_pt_azione");
  1708.                 sqlQueryObject.addSelectField("id");
  1709.                 sqlQueryObject.addWhereCondition("id_port_type = ?");
  1710.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1711.                 sqlQueryObject.setANDLogicOperator(true);
  1712.                 sqlQueryObject.addOrderBy("nome");
  1713.                 sqlQueryObject.setSortType(true);
  1714.                 sqlQueryObject.setLimit(limit);
  1715.                 sqlQueryObject.setOffset(offset);
  1716.                 queryString = sqlQueryObject.createSQLQuery();
  1717.             } else {
  1718.                 // senza search
  1719.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1720.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  1721.                 sqlQueryObject.addSelectField("id_port_type");
  1722.                 sqlQueryObject.addSelectField("nome");
  1723.                 sqlQueryObject.addSelectField("profilo_collaborazione");
  1724.                 sqlQueryObject.addSelectField("filtro_duplicati");
  1725.                 sqlQueryObject.addSelectField("conferma_ricezione");
  1726.                 sqlQueryObject.addSelectField("identificativo_collaborazione");
  1727.                 sqlQueryObject.addSelectField("id_riferimento_richiesta");
  1728.                 sqlQueryObject.addSelectField("consegna_in_ordine");
  1729.                 sqlQueryObject.addSelectField("scadenza");
  1730.                 sqlQueryObject.addSelectField("profilo_pt_azione");
  1731.                 sqlQueryObject.addSelectField("id");
  1732.                 sqlQueryObject.addWhereCondition("id_port_type = ?");
  1733.                 sqlQueryObject.addOrderBy("nome");
  1734.                 sqlQueryObject.setSortType(true);
  1735.                 sqlQueryObject.setLimit(limit);
  1736.                 sqlQueryObject.setOffset(offset);
  1737.                 queryString = sqlQueryObject.createSQLQuery();
  1738.             }
  1739.             stmt = con.prepareStatement(queryString);
  1740.             stmt.setLong(1, idPortType);
  1741.             risultato = stmt.executeQuery();

  1743.             Operation op;
  1744.             while (risultato.next()) {
  1745.                 op = new Operation();

  1747.                 String tmp = risultato.getString("nome");
  1748.                 op.setNome(((tmp == null || tmp.equals("")) ? null : tmp));
  1749.                 tmp = risultato.getString("profilo_collaborazione");
  1750.                 op.setProfiloCollaborazione(DriverRegistroServiziDB_LIB.getEnumProfiloCollaborazione(((tmp == null || tmp.equals("")) ? null : tmp)));
  1751.                 tmp = risultato.getString("filtro_duplicati");
  1752.                 op.setFiltroDuplicati(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  1753.                 tmp = risultato.getString("conferma_ricezione");
  1754.                 op.setConfermaRicezione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  1755.                 tmp = risultato.getString("identificativo_collaborazione");
  1756.                 op.setIdCollaborazione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  1757.                 tmp = risultato.getString("id_riferimento_richiesta");
  1758.                 op.setIdRiferimentoRichiesta(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  1759.                 tmp = risultato.getString("consegna_in_ordine");
  1760.                 op.setConsegnaInOrdine(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));
  1761.                 tmp = risultato.getString("scadenza");
  1762.                 op.setScadenza(((tmp == null || tmp.equals("")) ? null : tmp));
  1763.                 tmp = risultato.getString("profilo_pt_azione");
  1764.                 if (tmp == null || tmp.equals(""))
  1765.                     op.setProfAzione(CostantiRegistroServizi.PROFILO_AZIONE_DEFAULT);
  1766.                 else
  1767.                     op.setProfAzione(tmp);
  1768.                 op.setIdPortType(risultato.getLong("id_port_type"));
  1769.                 long idOperation = risultato.getLong("id");
  1770.                 op.setId(idOperation);
  1771.                 lista.add(op);
  1772.             }

  1774.             return lista;

  1776.         } catch (Exception se) {

  1778.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1779.         } finally {
  1780.             //Chiudo statement and resultset
  1781.             JDBCUtilities.closeResources(risultato, stmt);
  1782.             
  1783.             this.driver.closeConnection(con);
  1784.         }
  1785.     }
  1786.     
  1787.     protected List<MessagePart> accordiPorttypeOperationMessagePartList(long idOperation, boolean isInput, ISearch ricerca) throws DriverRegistroServiziException {
  1788.         String nomeMetodo = "accordiPorttypeOperationMessagePartList";
  1789.         int idLista = Liste.ACCORDI_PORTTYPE_AZIONI_MESSAGE_INPUT;
  1790.         if(!isInput)
  1791.             idLista = Liste.ACCORDI_PORTTYPE_AZIONI_MESSAGE_OUTPUT;
  1792.         int offset;
  1793.         int limit;
  1794.         String search;
  1795.         String queryString;

  1797.         limit = ricerca.getPageSize(idLista);
  1798.         offset = ricerca.getIndexIniziale(idLista);
  1799.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  1800.         ricerca.getSearchString(idLista);

  1802.         Connection con = null;
  1803.         PreparedStatement stmt = null;
  1804.         ResultSet risultato = null;

  1806.         ArrayList<MessagePart> lista = new ArrayList<MessagePart>();

  1808.         if (this.driver.atomica) {
  1809.             try {
  1810.                 con = this.driver.getConnectionFromDatasource("accordiPorttypeOperationMessagePartList");

  1812.             } catch (Exception e) {
  1813.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1815.             }

  1817.         } else
  1818.             con = this.driver.globalConnection;

  1820.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  1822.         try {

  1824.             if (!search.equals("")) {
  1825.                 //query con search
  1826.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1827.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI_OPERATION_MESSAGES);
  1828.                 sqlQueryObject.addSelectCountField("*", "cont");
  1829.                 sqlQueryObject.addWhereCondition("id_port_type_azione = ?");
  1830.                 if(isInput)
  1831.                     sqlQueryObject.addWhereCondition("input_message = 1");
  1832.                 else
  1833.                     sqlQueryObject.addWhereCondition("input_message != 1");
  1834.                 sqlQueryObject.addWhereLikeCondition("name", search, true, true);
  1835.                 sqlQueryObject.setANDLogicOperator(true);
  1836.                 queryString = sqlQueryObject.createSQLQuery();
  1837.             } else {
  1838.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1839.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI_OPERATION_MESSAGES);
  1840.                 sqlQueryObject.addSelectCountField("*", "cont");
  1841.                 sqlQueryObject.addWhereCondition("id_port_type_azione = ?");
  1842.                 
  1843.                 if(isInput)
  1844.                     sqlQueryObject.addWhereCondition("input_message = 1");
  1845.                 else
  1846.                     sqlQueryObject.addWhereCondition("input_message != 1");
  1847.                 sqlQueryObject.setANDLogicOperator(true);
  1848.                 queryString = sqlQueryObject.createSQLQuery();
  1849.             }
  1850.             stmt = con.prepareStatement(queryString);
  1851.             stmt.setLong(1,idOperation);
  1852.             risultato = stmt.executeQuery();
  1853.             if (risultato.next())
  1854.                 ricerca.setNumEntries(idLista,risultato.getInt("cont"));
  1855.             risultato.close();
  1856.             stmt.close();

  1858.             // ricavo le entries
  1859.             if (limit == 0) // con limit
  1860.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1861.             if (!search.equals("")) { // con search
  1862.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1863.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI_OPERATION_MESSAGES);
  1864.                 sqlQueryObject.addSelectField("name");
  1865.                 sqlQueryObject.addSelectField("element_name");
  1866.                 sqlQueryObject.addSelectField("element_namespace");
  1867.                 sqlQueryObject.addSelectField("type_name");
  1868.                 sqlQueryObject.addSelectField("type_namespace");
  1869.                 sqlQueryObject.addSelectField("id");
  1870.                 sqlQueryObject.addWhereCondition("id_port_type_azione = ?");
  1871.                 if(isInput)
  1872.                     sqlQueryObject.addWhereCondition("input_message = 1");
  1873.                 else
  1874.                     sqlQueryObject.addWhereCondition("input_message != 1");
  1875.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1876.                 sqlQueryObject.setANDLogicOperator(true);
  1877.                 sqlQueryObject.addOrderBy("name");
  1878.                 sqlQueryObject.setSortType(true);
  1879.                 sqlQueryObject.setLimit(limit);
  1880.                 sqlQueryObject.setOffset(offset);
  1881.                 queryString = sqlQueryObject.createSQLQuery();
  1882.             } else {
  1883.                 // senza search
  1884.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1885.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI_OPERATION_MESSAGES);
  1886.                 sqlQueryObject.addSelectField("name");
  1887.                 sqlQueryObject.addSelectField("element_name");
  1888.                 sqlQueryObject.addSelectField("element_namespace");
  1889.                 sqlQueryObject.addSelectField("type_name");
  1890.                 sqlQueryObject.addSelectField("type_namespace");
  1891.                 sqlQueryObject.addSelectField("id");
  1892.                 sqlQueryObject.addWhereCondition("id_port_type_azione = ?");
  1893.                 if(isInput)
  1894.                     sqlQueryObject.addWhereCondition("input_message = 1");
  1895.                 else
  1896.                     sqlQueryObject.addWhereCondition("input_message != 1");
  1897.                 sqlQueryObject.setANDLogicOperator(true);
  1898.                 sqlQueryObject.addOrderBy("name");
  1899.                 sqlQueryObject.setSortType(true);
  1900.                 sqlQueryObject.setLimit(limit);
  1901.                 sqlQueryObject.setOffset(offset);
  1902.                 queryString = sqlQueryObject.createSQLQuery();
  1903.             }
  1904.             stmt = con.prepareStatement(queryString);
  1905.             stmt.setLong(1, idOperation);
  1906.             risultato = stmt.executeQuery();

  1908.             
  1909.             MessagePart mp;
  1910.             
  1911.             while (risultato.next()) {
  1912.                 mp = new MessagePart();

  1914.                 String tmp = risultato.getString("name");
  1915.                 mp.setName(((tmp == null || tmp.equals("")) ? null : tmp));
  1916.                 tmp = risultato.getString("element_name");
  1917.                 mp.setElementName(((tmp == null || tmp.equals("")) ? null : tmp));
  1918.                 tmp = risultato.getString("element_namespace");
  1919.                 mp.setElementNamespace(((tmp == null || tmp.equals("")) ? null : tmp));
  1920.                 tmp = risultato.getString("type_name");
  1921.                 mp.setTypeName(((tmp == null || tmp.equals("")) ? null : tmp));
  1922.                 tmp = risultato.getString("type_namespace");
  1923.                 mp.setTypeNamespace(((tmp == null || tmp.equals("")) ? null : tmp));
  1924.                 long idMessage = risultato.getLong("id");
  1925.                 mp.setId(idMessage);
  1926.                 lista.add(mp);
  1927.             }

  1929.             return lista;

  1931.         } catch (Exception se) {

  1933.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1934.         } finally {
  1935.             //Chiudo statement and resultset
  1936.             JDBCUtilities.closeResources(risultato, stmt);
  1937.             
  1938.             this.driver.closeConnection(con);
  1939.         }
  1940.     }
  1941.     
  1942.     /**
  1943.      * Controlla se l'azione e' usata come Azione correlata in qualche azione dell'accordo con id idAccordo 
  1944.      * @param idAccordo
  1945.      * @param nomeAzione
  1946.      * @return true se se l'azione e' usata come Azione correlata in qualche azione dell'accordo con id idAccordo 
  1947.      * @throws DriverRegistroServiziException
  1948.      */
  1949.     protected boolean isCorrelata(long idAccordo,String nomeAzione,String owner) throws DriverRegistroServiziException {
  1950.         String nomeMetodo = "isCorrelata";

  1952.         String queryString;

  1954.         Connection con = null;
  1955.         PreparedStatement stmt = null;
  1956.         ResultSet risultato = null;

  1958.         if (this.driver.atomica) {
  1959.             try {
  1960.                 con = this.driver.getConnectionFromDatasource("isCorrelata");

  1962.             } catch (Exception e) {
  1963.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1965.             }

  1967.         } else
  1968.             con = this.driver.globalConnection;

  1970.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  1972.         try {           

  1974.             // ricavo le entries

  1976.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1977.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI_AZIONI);
  1978.             sqlQueryObject.addSelectCountField("id", "tot");

  1980.             sqlQueryObject.addWhereCondition("id_accordo = ?");
  1981.             sqlQueryObject.addWhereCondition("correlata = ?");
  1982.             sqlQueryObject.addWhereCondition("nome <> ?");

  1984.             sqlQueryObject.setANDLogicOperator(true);

  1986.             queryString = sqlQueryObject.createSQLQuery();

  1988.             stmt = con.prepareStatement(queryString);
  1989.             stmt.setLong(1, idAccordo);
  1990.             stmt.setString(2, nomeAzione);
  1991.             stmt.setString(3, owner);

  1993.             risultato = stmt.executeQuery();

  1995.             int tot=0;
  1996.             if (risultato.next()) {
  1997.                 tot=risultato.getInt("tot");
  1998.             }
  1999.             risultato.close();

  2001.             return tot>0;


  2004.         } catch (Exception se) {

  2006.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  2007.         } finally {
  2008.             //Chiudo statement and resultset
  2009.             JDBCUtilities.closeResources(risultato, stmt);
  2010.             
  2011.             this.driver.closeConnection(con);
  2012.         }
  2013.     }

  2015.     /**
  2016.      * Controlla se l'azione e' usata come Azione correlata in qualche azione dell'accordo con id idAccordo 
  2017.      * @param idPortType
  2018.      * @param nomeCorrelata
  2019.      * @return true se l'azione e' usata come Azione correlata in qualche azione dell'accordo con id idAccordo 
  2020.      * @throws DriverRegistroServiziException
  2021.      */
  2022.     protected boolean isOperationCorrelata(long idPortType,String nomeCorrelata,String owner) throws DriverRegistroServiziException {
  2023.         String nomeMetodo = "isOperationCorrelata";

  2025.         String queryString;

  2027.         Connection con = null;
  2028.         PreparedStatement stmt = null;
  2029.         ResultSet risultato = null;

  2031.         if (this.driver.atomica) {
  2032.             try {
  2033.                 con = this.driver.getConnectionFromDatasource("isOperationCorrelata");

  2035.             } catch (Exception e) {
  2036.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  2038.             }

  2040.         } else
  2041.             con = this.driver.globalConnection;

  2043.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  2045.         try {           

  2047.             // ricavo le entries

  2049.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2050.             sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  2051.             sqlQueryObject.addSelectCountField("id", "tot");

  2053.             sqlQueryObject.addWhereCondition("id_port_type = ?");
  2054.             sqlQueryObject.addWhereCondition("correlata = ?");
  2055.             sqlQueryObject.addWhereCondition("nome <> ?");

  2057.             sqlQueryObject.setANDLogicOperator(true);

  2059.             queryString = sqlQueryObject.createSQLQuery();

  2061.             stmt = con.prepareStatement(queryString);
  2062.             stmt.setLong(1, idPortType);
  2063.             stmt.setString(2, nomeCorrelata);
  2064.             stmt.setString(3, owner);

  2066.             risultato = stmt.executeQuery();

  2068.             int tot=0;
  2069.             if (risultato.next()) {
  2070.                 tot=risultato.getInt("tot");
  2071.             }
  2072.             risultato.close();

  2074.             return tot>0;


  2077.         } catch (Exception se) {

  2079.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  2080.         } finally {
  2081.             //Chiudo statement and resultset
  2082.             JDBCUtilities.closeResources(risultato, stmt);
  2083.             
  2084.             this.driver.closeConnection(con);
  2085.         }
  2086.     }

  2088.     protected boolean isOperationCorrelataDaAltraAzione(String nomePortType,long idPortType,String azioneDaVerificare,long idAzioneDaVerificare) throws DriverRegistroServiziException {
  2089.         return this.isOperationCorrelata(nomePortType, idPortType, azioneDaVerificare, idAzioneDaVerificare, false, true);
  2090.     }
  2091.     protected boolean isOperationCorrelataRichiesta(String nomePortType,long idPortType,String azioneDaVerificare,long idAzioneDaVerificare) throws DriverRegistroServiziException {
  2092.         return this.isOperationCorrelata(nomePortType, idPortType, azioneDaVerificare, idAzioneDaVerificare, true, false);
  2093.     }
  2094.     protected boolean isOperationCorrelata(String nomePortType,long idPortType,String azioneDaVerificare,long idAzioneDaVerificare) throws DriverRegistroServiziException {
  2095.         return this.isOperationCorrelata(nomePortType, idPortType, azioneDaVerificare, idAzioneDaVerificare, true, true);
  2096.     }
  2097.     private boolean isOperationCorrelata(String nomePortType,long idPortType,String azioneDaVerificare,long idAzioneDaVerificare,
  2098.             boolean checkCorrelazioneARichiesta,boolean checkCorrelazioneDaAltraAzione) throws DriverRegistroServiziException {
  2099.         String nomeMetodo = "isOperationCorrelata";

  2101.         String queryString;

  2103.         Connection con = null;
  2104.         PreparedStatement stmt = null;
  2105.         ResultSet risultato = null;

  2107.         if (this.driver.atomica) {
  2108.             try {
  2109.                 con = this.driver.getConnectionFromDatasource("isOperationCorrelata(nomePortType,id,azione,idAzione,check)");

  2111.             } catch (Exception e) {
  2112.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  2114.             }

  2116.         } else
  2117.             con = this.driver.globalConnection;

  2119.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  2121.         try {           

  2123.             // VERIFICO CORRELAZIONE AD UNA RICHIESTA
  2124.             boolean correlataAdUnaRichiesta = false;
  2125.             if(checkCorrelazioneARichiesta){
  2126.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2127.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  2128.                 sqlQueryObject.addSelectCountField("id", "tot");
  2129.                 // seleziono il port type
  2130.                 sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".id_port_type = ?");
  2131.                 // seleziono l'azione
  2132.                 sqlQueryObject.addWhereCondition("nome = ?");
  2133.                 // verifico che l'azione non sia correlata ad una richiesta
  2134.                 sqlQueryObject.addWhereCondition(false,CostantiDB.PORT_TYPE_AZIONI+".correlata is not null",CostantiDB.PORT_TYPE_AZIONI+".correlata_servizio is not null");
  2135.                 sqlQueryObject.setANDLogicOperator(true);
  2136.                 queryString = sqlQueryObject.createSQLQuery();
  2137.                 this.driver.logDebug("VERIFICO CORRELAZIONE AD UNA RICHIESTA ["+idPortType+"] ["+azioneDaVerificare+"]: "+queryString);
  2138.                 stmt = con.prepareStatement(queryString);
  2139.                 stmt.setLong(1, idPortType);
  2140.                 stmt.setString(2, azioneDaVerificare);
  2141.                 risultato = stmt.executeQuery();
  2142.                 int tot=0;
  2143.                 if (risultato.next()) {
  2144.                     tot=risultato.getInt("tot");
  2145.                 }
  2146.                 risultato.close();
  2147.                 stmt.close();
  2148.                 correlataAdUnaRichiesta = tot>0;
  2149.                 this.driver.logDebug("VERIFICO CORRELAZIONE AD UNA RICHIESTA, risultato ["+tot+"]: "+correlataAdUnaRichiesta);
  2150.             }

  2152.             // VERIFICO CHE NON SIA CORRELATA DA UN'ALTRA AZIONE
  2153.             boolean correlataDaUnAltraAzione = false;
  2154.             if(checkCorrelazioneDaAltraAzione){

  2156.                 // Correlazione precisa: per asincrono simmetrico e asincrono asimmetrico con port type diversi
  2157.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2158.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  2159.                 sqlQueryObject.addSelectCountField("id", "tot");
  2160.                 sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".id<>?");
  2161.                 sqlQueryObject.addWhereCondition(true,CostantiDB.PORT_TYPE_AZIONI+".correlata =?",CostantiDB.PORT_TYPE_AZIONI+".correlata_servizio =?");
  2162.                 sqlQueryObject.setANDLogicOperator(true);
  2163.                 queryString = sqlQueryObject.createSQLQuery();
  2164.                 stmt = con.prepareStatement(queryString);
  2165.                 this.driver.logDebug("VERIFICO CHE NON SIA CORRELATA DA UN'ALTRA AZIONE (AS e AA con PT diverso) ["+idAzioneDaVerificare+"] ["+azioneDaVerificare+"] ["+nomePortType+"]: "+queryString);
  2166.                 stmt.setLong(1, idAzioneDaVerificare);
  2167.                 stmt.setString(2, azioneDaVerificare);
  2168.                 stmt.setString(3, nomePortType);
  2169.                 risultato = stmt.executeQuery();
  2170.                 int tot=0;
  2171.                 if (risultato.next()) {
  2172.                     tot=risultato.getInt("tot");
  2173.                 }
  2174.                 risultato.close();
  2175.                 stmt.close();
  2176.                 correlataDaUnAltraAzione = tot>0;
  2177.                 this.driver.logDebug("VERIFICO CHE NON SIA CORRELATA DA UN'ALTRA AZIONE (AS e AA con PT diverso), risultato ["+tot+"]: "+correlataDaUnAltraAzione);

  2179.                 if(correlataDaUnAltraAzione==false){
  2180.                     // Correlazione sullo stesso port type
  2181.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2182.                     sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  2183.                     sqlQueryObject.addSelectCountField("id", "tot");
  2184.                     sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".id<>?");
  2185.                     sqlQueryObject.addWhereCondition(true,CostantiDB.PORT_TYPE_AZIONI+".correlata =?",CostantiDB.PORT_TYPE_AZIONI+".correlata_servizio is null",CostantiDB.PORT_TYPE_AZIONI+".id_port_type = ?");
  2186.                     sqlQueryObject.setANDLogicOperator(true);
  2187.                     queryString = sqlQueryObject.createSQLQuery();
  2188.                     stmt = con.prepareStatement(queryString);
  2189.                     this.driver.logDebug("VERIFICO CHE NON SIA CORRELATA DA UN'ALTRA AZIONE (AA con stesso port type) ["+idAzioneDaVerificare+"] ["+azioneDaVerificare+"] ["+nomePortType+"] ["+azioneDaVerificare+"] ["+idPortType+"]: "+queryString);
  2190.                     stmt.setLong(1, idAzioneDaVerificare);
  2191.                     stmt.setString(2, azioneDaVerificare);
  2192.                     stmt.setLong(3, idPortType);
  2193.                     risultato = stmt.executeQuery();
  2194.                     tot=0;
  2195.                     if (risultato.next()) {
  2196.                         tot=risultato.getInt("tot");
  2197.                     }
  2198.                     risultato.close();
  2199.                     stmt.close();
  2200.                     correlataDaUnAltraAzione = tot>0;
  2201.                     this.driver.logDebug("VERIFICO CHE NON SIA CORRELATA DA UN'ALTRA AZIONE (AA con stesso port type), risultato ["+tot+"]: "+correlataDaUnAltraAzione);
  2202.                 }
  2203.             }

  2205.             if(correlataAdUnaRichiesta){
  2206.                 return true;
  2207.             }
  2208.             else if(correlataDaUnAltraAzione){
  2209.                 return true;
  2210.             }
  2211.             else{
  2212.                 return false;
  2213.             }

  2215.         } catch (Exception se) {

  2217.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  2218.         } finally {
  2219.             //Chiudo statement and resultset
  2220.             JDBCUtilities.closeResources(risultato, stmt);
  2221.             
  2222.             this.driver.closeConnection(con);
  2223.         }
  2224.     }
  2225.     
  2226.     protected PortType getPortType(IDPortType idPT) throws DriverRegistroServiziException {
  2227.         String nomeMetodo = "getPortType";

  2229.         Connection con = null;

  2231.         if (this.driver.atomica) {
  2232.             try {
  2233.                 con = this.driver.getConnectionFromDatasource("getPortType");

  2235.             } catch (Exception e) {
  2236.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(), e);

  2238.             }

  2240.         } else {
  2241.             con = this.driver.globalConnection;
  2242.         }

  2244.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  2246.         try {
  2247.         
  2248.             return this.getPortType(DBUtils.getIdPortType(DBUtils.getIdAccordoServizioParteComune(idPT.getIdAccordo(), con, this.driver.tipoDB), idPT.getNome(), con));
  2249.             
  2250.         } catch (Exception se) {
  2251.             throw new DriverRegistroServiziException("[DriverRegistroServiziException::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  2252.         } finally {
  2253.             // Chiudo statement and resultset
  2254.             
  2255.             this.driver.closeConnection(con);
  2256.         }
  2257.         
  2258.     }


  2261.     protected List<IDServizio> getIdServiziWithPortType(IDPortType idPT) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  2262.         String nomeMetodo = "getIdServiziWithPortType";

  2264.         Connection con = null;
  2265.         PreparedStatement stmt = null;
  2266.         ResultSet rs = null;
  2267.         String queryString;

  2269.         if (this.driver.atomica) {
  2270.             try {
  2271.                 con = this.driver.getConnectionFromDatasource("getIdServiziWithPortType");

  2273.             } catch (Exception e) {
  2274.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(), e);

  2276.             }

  2278.         } else {
  2279.             con = this.driver.globalConnection;
  2280.         }

  2282.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  2284.         List<IDServizio> idServizi = new ArrayList<IDServizio>(); 
  2285.         try {

  2287.             //recupero idAccordo
  2288.             long idAccordoLong = DBUtils.getIdAccordoServizioParteComune(idPT.getIdAccordo(), con, this.driver.tipoDB);
  2289.             // Controllo che il pdd non sia in uso
  2290.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2291.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  2292.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  2293.             sqlQueryObject.addSelectField("nome_servizio");
  2294.             sqlQueryObject.addSelectField("tipo_servizio");
  2295.             sqlQueryObject.addSelectField("versione_servizio");
  2296.             sqlQueryObject.addSelectField("nome_soggetto");
  2297.             sqlQueryObject.addSelectField("tipo_soggetto");
  2298.             sqlQueryObject.setANDLogicOperator(true);
  2299.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".id_accordo=?");
  2300.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".port_type=?");
  2301.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".id_soggetto="+CostantiDB.SOGGETTI+".id");
  2302.             queryString = sqlQueryObject.createSQLQuery();
  2303.             stmt = con.prepareStatement(queryString);
  2304.             stmt.setLong(1, idAccordoLong);
  2305.             stmt.setString(2, idPT.getNome());

  2307.             rs = stmt.executeQuery();
  2308.             while (rs.next()) {
  2309.                 IDSoggetto soggettoErogatore = new IDSoggetto(rs.getString("tipo_soggetto"), rs.getString("nome_soggetto"));
  2310.                 IDServizio idServizio = 
  2311.                         this.driver.idServizioFactory.getIDServizioFromValues(rs.getString("tipo_servizio"), 
  2312.                                 rs.getString("nome_servizio"), soggettoErogatore, rs.getInt("versione_servizio"));
  2313.                 idServizi.add(idServizio);
  2314.             }

  2316.             if(idServizi.size()<=0){
  2317.                 throw new DriverRegistroServiziNotFound("Servizi non trovato che implementano il servizio "+idPT.getNome()+" dell'accordo di servizio "+idPT.getIdAccordo().toString());
  2318.             }
  2319.             else{
  2320.                 return idServizi;
  2321.             }

  2323.         }catch(DriverRegistroServiziNotFound dNot){
  2324.             throw dNot;
  2325.         }catch (Exception se) {
  2326.             throw new DriverRegistroServiziException("[DriverRegistroServiziException::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  2327.         } finally {
  2328.             // Chiudo statement and resultset
  2329.             JDBCUtilities.closeResources(rs, stmt);
  2330.             
  2331.             this.driver.closeConnection(con);
  2332.         }
  2333.     }
  2334.     
  2335.     protected boolean isUnicaAzioneInAccordi(String azione) throws DriverRegistroServiziException {
  2336.         String nomeMetodo = "isUnicaAzioneInAccordi";

  2338.         Connection con = null;
  2339.         PreparedStatement stmt = null;
  2340.         ResultSet rs = null;
  2341.         String queryString;

  2343.         if (this.driver.atomica) {
  2344.             try {
  2345.                 con = this.driver.getConnectionFromDatasource("isUnicaAzioneInAccordi");

  2347.             } catch (Exception e) {
  2348.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(), e);

  2350.             }

  2352.         } else {
  2353.             con = this.driver.globalConnection;
  2354.         }

  2356.         this.driver.logDebug("operazione this.atomica = " + this.driver.atomica);

  2358.         try {

  2360.             // AZIONI direttamente negli accordi
  2361.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2362.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI_AZIONI);
  2363.             sqlQueryObject.addSelectCountField("nome", "countAzioni");
  2364.             sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_AZIONI+".nome=?");
  2365.             queryString = sqlQueryObject.createSQLQuery();
  2366.             stmt = con.prepareStatement(queryString);
  2367.             stmt.setString(1, azione);
  2368.             rs = stmt.executeQuery();
  2369.             int count = 0;
  2370.             if(rs.next()){
  2371.                 count = rs.getInt("countAzioni");
  2372.             }
  2373.             else{
  2374.                 throw new Exception("Azione ["+azione+"] non trovata (rs.next fallita)");
  2375.             }
  2376.             rs.close();
  2377.             stmt.close();

  2379.             // AZIONI dei port types
  2380.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2381.             sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  2382.             sqlQueryObject.addSelectCountField("nome", "countAzioni");
  2383.             sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".nome=?");
  2384.             queryString = sqlQueryObject.createSQLQuery();
  2385.             stmt = con.prepareStatement(queryString);
  2386.             stmt.setString(1, azione);
  2387.             rs = stmt.executeQuery();
  2388.             if(rs.next()){
  2389.                 count = count + rs.getInt("countAzioni");
  2390.             }
  2391.             else{
  2392.                 throw new Exception("Azione ["+azione+"] non trovata (rs.next fallita pt)");
  2393.             }

  2395.             if(count<=0){
  2396.                 throw new Exception("Azione ["+azione+"] non trovata");
  2397.             }else{
  2398.                 return count==1;
  2399.             }

  2401.         }catch (Exception se) {
  2402.             throw new DriverRegistroServiziException("[DriverRegistroServiziException::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  2403.         } finally {
  2404.             // Chiudo statement and resultset
  2405.             JDBCUtilities.closeResources(rs, stmt);
  2406.             
  2407.             this.driver.closeConnection(con);
  2408.         }
  2409.     }
  2410. }
Created with JaCoCo 0.8.8.202204050719