DriverRegistroServiziDB_accordiFindAllDriver.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.sql.Timestamp;
  29. import java.util.ArrayList;
  30. import java.util.List;

  32. import org.openspcoop2.core.commons.DBUtils;
  33. import org.openspcoop2.core.commons.Filtri;
  34. import org.openspcoop2.core.constants.CostantiDB;
  35. import org.openspcoop2.core.constants.ProprietariProtocolProperty;
  36. import org.openspcoop2.core.id.IDAccordo;
  37. import org.openspcoop2.core.id.IDAccordoAzione;
  38. import org.openspcoop2.core.id.IDPortType;
  39. import org.openspcoop2.core.id.IDPortTypeAzione;
  40. import org.openspcoop2.core.id.IDResource;
  41. import org.openspcoop2.core.id.IDSoggetto;
  42. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  43. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  44. import org.openspcoop2.core.registry.driver.FiltroRicercaAccordi;
  45. import org.openspcoop2.core.registry.driver.FiltroRicercaAzioni;
  46. import org.openspcoop2.core.registry.driver.FiltroRicercaOperations;
  47. import org.openspcoop2.core.registry.driver.FiltroRicercaPortTypes;
  48. import org.openspcoop2.core.registry.driver.FiltroRicercaResources;
  49. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  50. import org.openspcoop2.utils.sql.ISQLQueryObject;
  51. import org.openspcoop2.utils.sql.SQLObjectFactory;

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

  64.     private DriverRegistroServiziDB driver = null;
  65.     private DriverRegistroServiziDB_protocolPropertiesDriver protocolPropertiesDriver = null;
  66.     
  67.     protected DriverRegistroServiziDB_accordiFindAllDriver(DriverRegistroServiziDB driver) {
  68.         this.driver = driver;
  69.         this.protocolPropertiesDriver = new DriverRegistroServiziDB_protocolPropertiesDriver(driver);
  70.     }
  71.     

  73.     protected List<IDAccordo> getAllIdAccordiServizioParteComune(FiltroRicercaAccordi filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  75.         List<IDAccordo> list = new ArrayList<IDAccordo>();
  76.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdAccordiServizioParteComune", filtroRicerca, null, null, null, null, list);
  77.         return list;
  78.     
  79.     }
  80.     
  81.     protected List<IDPortType> getAllIdPortType(FiltroRicercaPortTypes filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  82.         
  83.         List<IDPortType> list = new ArrayList<IDPortType>();
  84.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdPortType", filtroRicerca, filtroRicerca, null, null, null, list);
  85.         return list;
  86.         
  87.     }
  88.     
  89.     protected List<IDPortTypeAzione> getAllIdAzionePortType(FiltroRicercaOperations filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  90.     
  91.         List<IDPortTypeAzione> list = new ArrayList<IDPortTypeAzione>();
  92.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdAzionePortType", filtroRicerca, null, filtroRicerca, null, null, list);
  93.         return list;
  94.         
  95.     }
  96.     
  97.     protected List<IDAccordoAzione> getAllIdAzioneAccordo(FiltroRicercaAzioni filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  98.         
  99.         List<IDAccordoAzione> list = new ArrayList<IDAccordoAzione>();
  100.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdAzioneAccordo", filtroRicerca, null, null, filtroRicerca, null, list);
  101.         return list;
  102.         
  103.     }
  104.     
  105.     protected List<IDResource> getAllIdResource(FiltroRicercaResources filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  106.         
  107.         List<IDResource> list = new ArrayList<IDResource>();
  108.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdResource", filtroRicerca, null, null, null, filtroRicerca, list);
  109.         return list;
  110.         
  111.     }
  112.     
  113.     @SuppressWarnings("unchecked")
  114.     private <T> void _fillAllIdAccordiServizioParteComuneEngine(String nomeMetodo, 
  115.             FiltroRicercaAccordi filtroRicercaBase,
  116.             FiltroRicercaPortTypes filtroPT, FiltroRicercaOperations filtroOP, FiltroRicercaAzioni filtroAZ,
  117.             FiltroRicercaResources filtroResource,
  118.             List<T> listReturn) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  120.         Connection con = null;
  121.         PreparedStatement stm = null;
  122.         ResultSet rs = null;

  124.         this.driver.logDebug(nomeMetodo+"...");

  126.         if(listReturn==null){
  127.             throw new DriverRegistroServiziException("Lista per collezionare i risultati non definita");
  128.         }
  129.         
  130.         try {
  131.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  132.             // prendo la connessione dal pool
  133.             if (this.driver.atomica)
  134.                 con = this.driver.getConnectionFromDatasource(nomeMetodo);
  135.             else
  136.                 con = this.driver.globalConnection;

  138.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  139.             
  140.             List<String> tipoSoggettiProtocollo = null;
  141.             try {
  142.                 if(filtroRicercaBase!=null && (filtroRicercaBase.getProtocollo()!=null || (filtroRicercaBase.getProtocolli()!=null && !filtroRicercaBase.getProtocolli().isEmpty()))){
  143.                     tipoSoggettiProtocollo = Filtri.convertToTipiSoggetti(filtroRicercaBase.getProtocollo(), Filtri.convertToString(filtroRicercaBase.getProtocolli()));
  144.                 }
  145.             }catch(Exception e) {
  146.                 throw new DriverRegistroServiziException(e.getMessage(),e);
  147.             }
  148.             boolean searchByTipoSoggetto = (tipoSoggettiProtocollo!=null && tipoSoggettiProtocollo.size()>0);
  149.             
  150.             // from
  151.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  152.             if(filtroRicercaBase!=null){
  153.                 if( searchByTipoSoggetto || filtroRicercaBase.getTipoSoggettoReferente()!=null || filtroRicercaBase.getNomeSoggettoReferente()!=null){
  154.                     sqlQueryObject.addFromTable(this.driver.tabellaSoggetti);
  155.                 }
  156.             }
  157.             if(filtroPT!=null){
  158.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE);
  159.                 sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".id="+CostantiDB.PORT_TYPE+".id_accordo");
  160.             }
  161.             if(filtroOP!=null){
  162.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE);
  163.                 sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".id="+CostantiDB.PORT_TYPE+".id_accordo");
  164.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  165.                 sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE+".id="+CostantiDB.PORT_TYPE_AZIONI+".id_port_type");
  166.             }
  167.             if(filtroAZ!=null){
  168.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_AZIONI);
  169.                 sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".id="+CostantiDB.ACCORDI_AZIONI+".id_accordo");
  170.             }
  171.             if(filtroResource!=null){
  172.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES);
  173.                 sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".id="+CostantiDB.API_RESOURCES+".id_accordo");
  174.             }
  175.             if(filtroRicercaBase!=null){
  176.                 if(filtroRicercaBase.getIdGruppo()!=null && filtroRicercaBase.getIdGruppo().getNome()!=null) {
  177.                     sqlQueryObject.addFromTable(CostantiDB.GRUPPI);
  178.                     sqlQueryObject.addFromTable(CostantiDB.ACCORDI_GRUPPI);
  179.                     sqlQueryObject.addWhereCondition(CostantiDB.GRUPPI+".id="+CostantiDB.ACCORDI_GRUPPI+".id_gruppo");
  180.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".id="+CostantiDB.ACCORDI_GRUPPI+".id_accordo");
  181.                 }
  182.             }
  183.             
  184.             // select field
  185.             sqlQueryObject.addSelectAliasField(CostantiDB.ACCORDI,"nome","nomeAccordo");
  186.             sqlQueryObject.addSelectField(CostantiDB.ACCORDI,"versione");
  187.             sqlQueryObject.addSelectField(CostantiDB.ACCORDI,"id_referente");
  188.             if(filtroPT!=null){
  189.                 sqlQueryObject.addSelectAliasField(CostantiDB.PORT_TYPE,"nome","nomePT");
  190.             }
  191.             if(filtroOP!=null){
  192.                 sqlQueryObject.addSelectAliasField(CostantiDB.PORT_TYPE,"nome","nomePT");
  193.                 sqlQueryObject.addSelectAliasField(CostantiDB.PORT_TYPE_AZIONI,"nome","nomeOP");
  194.             }
  195.             if(filtroAZ!=null){
  196.                 sqlQueryObject.addSelectAliasField(CostantiDB.ACCORDI_AZIONI,"nome","nomeAZ");
  197.             }
  198.             if(filtroResource!=null){
  199.                 sqlQueryObject.addSelectAliasField(CostantiDB.API_RESOURCES,"nome","nomeResource");
  200.             }
  201.             sqlQueryObject.setSelectDistinct(true);
  202.             
  203.             // order
  204.             if(filtroRicercaBase!=null && filtroRicercaBase.isOrder()) {
  205.                 sqlQueryObject.addOrderBy("nomeAccordo");
  206.                 sqlQueryObject.addOrderBy("versione");
  207.                 if(searchByTipoSoggetto){
  208.                     sqlQueryObject.addSelectAliasField(this.driver.tabellaSoggetti,"tipo_soggetto","tipoSoggettoReferente");
  209.                     sqlQueryObject.addSelectAliasField(this.driver.tabellaSoggetti,"nome_soggetto","nomeSoggettoReferente");
  210.                     sqlQueryObject.addOrderBy("tipoSoggettoReferente");
  211.                     sqlQueryObject.addOrderBy("nomeSoggettoReferente");
  212.                 }
  213.                 if(filtroPT!=null){
  214.                     sqlQueryObject.addOrderBy("nomePT");
  215.                 }
  216.                 else if(filtroOP!=null){
  217.                     sqlQueryObject.addOrderBy("nomePT");
  218.                     sqlQueryObject.addOrderBy("nomeOP");
  219.                 }
  220.                 else if(filtroAZ!=null){
  221.                     sqlQueryObject.addOrderBy("nomeAZ");
  222.                 }
  223.                 else if(filtroResource!=null){
  224.                     sqlQueryObject.addOrderBy("nomeResource");
  225.                 }
  226.             }
  227.             
  228.             if(filtroRicercaBase!=null){
  229.                 // Filtro Base
  230.                 if(filtroRicercaBase.getMinDate()!=null)
  231.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".ora_registrazione > ?");
  232.                 if(filtroRicercaBase.getMaxDate()!=null)
  233.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".ora_registrazione < ?");
  234.                 if(filtroRicercaBase.getNomeAccordo()!=null)
  235.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".nome = ?");
  236.                 if(filtroRicercaBase.getVersione()!=null)
  237.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".versione = ?");
  238.                 if(searchByTipoSoggetto || filtroRicercaBase.getTipoSoggettoReferente()!=null || filtroRicercaBase.getNomeSoggettoReferente()!=null){
  239.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".id_referente="+this.driver.tabellaSoggetti+".id");
  240.                     if(filtroRicercaBase.getTipoSoggettoReferente()!=null) {
  241.                         sqlQueryObject.addWhereCondition(this.driver.tabellaSoggetti+".tipo_soggetto=?");
  242.                     }
  243.                     else if(searchByTipoSoggetto) {
  244.                         sqlQueryObject.addWhereINCondition(this.driver.tabellaSoggetti+".tipo_soggetto", true, tipoSoggettiProtocollo.toArray(new String[1]));
  245.                     }
  246.                     if(filtroRicercaBase.getNomeSoggettoReferente()!=null)
  247.                         sqlQueryObject.addWhereCondition(this.driver.tabellaSoggetti+".nome_soggetto=?");
  248.                 }
  249.                 if(filtroRicercaBase.getServiceBinding()!=null)
  250.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".service_binding = ?");
  251.                 if(filtroRicercaBase.getIdGruppo()!=null && filtroRicercaBase.getIdGruppo().getNome()!=null) {
  252.                     sqlQueryObject.addWhereCondition(CostantiDB.GRUPPI+".nome = ?");
  253.                 }
  254.                 
  255.                 if( (filtroRicercaBase.getIdAccordoCooperazione()!=null &&
  256.                         (filtroRicercaBase.getIdAccordoCooperazione().getNome()!=null || 
  257.                         filtroRicercaBase.getIdAccordoCooperazione().getSoggettoReferente()!=null || 
  258.                         filtroRicercaBase.getIdAccordoCooperazione().getVersione()!=null)) ){
  259.                     ISQLQueryObject sqlQueryObjectASComposti = sqlQueryObject.newSQLQueryObject();
  260.                     sqlQueryObjectASComposti.addFromTable(CostantiDB.ACCORDI_SERVIZI_COMPOSTO);
  261.                     sqlQueryObjectASComposti.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE);
  262.                     sqlQueryObjectASComposti.addSelectField(CostantiDB.ACCORDI_SERVIZI_COMPOSTO+".id");
  263.                     sqlQueryObjectASComposti.setANDLogicOperator(true);
  264.                     sqlQueryObjectASComposti.addWhereCondition(CostantiDB.ACCORDI+".id="+CostantiDB.ACCORDI_SERVIZI_COMPOSTO+".id_accordo");
  265.                     sqlQueryObjectASComposti.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE+".id="+CostantiDB.ACCORDI_SERVIZI_COMPOSTO+".id_accordo_cooperazione");
  266.                     if(filtroRicercaBase.getIdAccordoCooperazione().getNome()!=null){
  267.                         sqlQueryObjectASComposti.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE+".nome=?");
  268.                     }
  269.                     if(filtroRicercaBase.getIdAccordoCooperazione().getSoggettoReferente()!=null){
  270.                         sqlQueryObjectASComposti.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE+".id_referente=?");
  271.                     }
  272.                     if(filtroRicercaBase.getIdAccordoCooperazione().getVersione()!=null){
  273.                         sqlQueryObjectASComposti.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE+".versione=?");
  274.                     }
  275.                     sqlQueryObject.addWhereExistsCondition(false, sqlQueryObjectASComposti);
  276.                 }
  277.                 else if(filtroRicercaBase.isServizioComposto()!=null){
  278.                     ISQLQueryObject sqlQueryObjectASComposti = sqlQueryObject.newSQLQueryObject();
  279.                     sqlQueryObjectASComposti.addFromTable(CostantiDB.ACCORDI_SERVIZI_COMPOSTO);
  280.                     sqlQueryObjectASComposti.addSelectField("id");
  281.                     sqlQueryObjectASComposti.setANDLogicOperator(true);
  282.                     sqlQueryObjectASComposti.addWhereCondition(CostantiDB.ACCORDI+".id="+CostantiDB.ACCORDI_SERVIZI_COMPOSTO+".id_accordo");
  283.                     sqlQueryObject.addWhereExistsCondition(!filtroRicercaBase.isServizioComposto(), sqlQueryObjectASComposti);
  284.                 }
  285.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(sqlQueryObject, filtroRicercaBase, CostantiDB.ACCORDI);
  286.             }
  287.             
  288.             if(filtroPT!=null){
  289.                 if(filtroPT.getNomePortType()!=null)
  290.                     sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE+".nome=?");
  291.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(sqlQueryObject, filtroPT, CostantiDB.PORT_TYPE);
  292.             }
  293.             
  294.             if(filtroOP!=null){
  295.                 if(filtroOP.getNomePortType()!=null)
  296.                     sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE+".nome=?");
  297.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(sqlQueryObject, filtroOP, CostantiDB.PORT_TYPE);
  298.                 
  299.                 if(filtroOP.getNomeAzione()!=null)
  300.                     sqlQueryObject.addWhereCondition(CostantiDB.PORT_TYPE_AZIONI+".nome=?");
  301.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(sqlQueryObject, filtroOP, CostantiDB.PORT_TYPE_AZIONI);
  302.             }
  303.             
  304.             if(filtroAZ!=null){
  305.                 if(filtroAZ.getNomeAzione()!=null)
  306.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_AZIONI+".nome=?");
  307.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(sqlQueryObject, filtroAZ, CostantiDB.ACCORDI_AZIONI);
  308.             }
  309.             
  310.             if(filtroResource!=null){
  311.                 if(filtroResource.getResourceName()!=null)
  312.                     sqlQueryObject.addWhereCondition(CostantiDB.API_RESOURCES+".nome=?");
  313.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(sqlQueryObject, filtroResource, CostantiDB.API_RESOURCES);
  314.             }

  316.             sqlQueryObject.setANDLogicOperator(true);
  317.             String sqlQuery = sqlQueryObject.createSQLQuery();
  318.             this.driver.logDebug("eseguo query : " + sqlQuery );
  319.             stm = con.prepareStatement(sqlQuery);
  320.             int indexStmt = 1;
  321.             if(filtroRicercaBase!=null){
  322.                 if(filtroRicercaBase.getMinDate()!=null){
  323.                     this.driver.logDebug("minDate stmt.setTimestamp("+filtroRicercaBase.getMinDate()+")");
  324.                     stm.setTimestamp(indexStmt, new Timestamp(filtroRicercaBase.getMinDate().getTime()));
  325.                     indexStmt++;
  326.                 }
  327.                 if(filtroRicercaBase.getMaxDate()!=null){
  328.                     this.driver.logDebug("maxDate stmt.setTimestamp("+filtroRicercaBase.getMaxDate()+")");
  329.                     stm.setTimestamp(indexStmt, new Timestamp(filtroRicercaBase.getMaxDate().getTime()));
  330.                     indexStmt++;
  331.                 }   
  332.                 if(filtroRicercaBase.getNomeAccordo()!=null){
  333.                     this.driver.logDebug("nomeAccordo stmt.setString("+filtroRicercaBase.getNomeAccordo()+")");
  334.                     stm.setString(indexStmt, filtroRicercaBase.getNomeAccordo());
  335.                     indexStmt++;
  336.                 }   
  337.                 if(filtroRicercaBase.getVersione()!=null){
  338.                     this.driver.logDebug("versioneAccordo stmt.setString("+filtroRicercaBase.getVersione()+")");
  339.                     stm.setInt(indexStmt, filtroRicercaBase.getVersione());
  340.                     indexStmt++;
  341.                 }   
  342.                 if(filtroRicercaBase.getTipoSoggettoReferente()!=null || filtroRicercaBase.getNomeSoggettoReferente()!=null){
  343.                     if(filtroRicercaBase.getTipoSoggettoReferente()!=null){
  344.                         this.driver.logDebug("tipoSoggettoReferenteAccordo stmt.setString("+filtroRicercaBase.getTipoSoggettoReferente()+")");
  345.                         stm.setString(indexStmt, filtroRicercaBase.getTipoSoggettoReferente());
  346.                         indexStmt++;
  347.                     }
  348.                     if(filtroRicercaBase.getNomeSoggettoReferente()!=null){
  349.                         this.driver.logDebug("nomeSoggettoReferenteAccordo stmt.setString("+filtroRicercaBase.getNomeSoggettoReferente()+")");
  350.                         stm.setString(indexStmt, filtroRicercaBase.getNomeSoggettoReferente());
  351.                         indexStmt++;
  352.                     }
  353.                 }
  354.                 if(filtroRicercaBase.getServiceBinding()!=null) {
  355.                     this.driver.logDebug("serviceBinding stmt.setString("+filtroRicercaBase.getServiceBinding().getValue()+")");
  356.                     stm.setString(indexStmt, filtroRicercaBase.getServiceBinding().getValue());
  357.                     indexStmt++;
  358.                 }
  359.                 if(filtroRicercaBase.getIdGruppo()!=null && filtroRicercaBase.getIdGruppo().getNome()!=null) {
  360.                     this.driver.logDebug("gruppo stmt.setString("+filtroRicercaBase.getIdGruppo().getNome()+")");
  361.                     stm.setString(indexStmt, filtroRicercaBase.getIdGruppo().getNome());
  362.                     indexStmt++;
  363.                 }   
  364.                 
  365.                 if(filtroRicercaBase.getIdAccordoCooperazione()!=null &&
  366.                         (filtroRicercaBase.getIdAccordoCooperazione().getNome()!=null || 
  367.                         filtroRicercaBase.getIdAccordoCooperazione().getSoggettoReferente()!=null || 
  368.                         filtroRicercaBase.getIdAccordoCooperazione().getVersione()!=null) ){
  369.                     if(filtroRicercaBase.getIdAccordoCooperazione().getNome()!=null){
  370.                         this.driver.logDebug("nomeAccordoCooperazione stmt.setString("+filtroRicercaBase.getIdAccordoCooperazione().getNome()+")");
  371.                         stm.setString(indexStmt, filtroRicercaBase.getIdAccordoCooperazione().getNome());
  372.                         indexStmt++;
  373.                     }
  374.                     if(filtroRicercaBase.getIdAccordoCooperazione().getSoggettoReferente()!=null){
  375.                         long idReferenteAccordoCooperazione = DBUtils.getIdSoggetto(filtroRicercaBase.getIdAccordoCooperazione().getSoggettoReferente().getNome(), 
  376.                                 filtroRicercaBase.getIdAccordoCooperazione().getSoggettoReferente().getTipo(), con, this.driver.tipoDB, this.driver.tabellaSoggetti);
  377.                         this.driver.logDebug("referenteAccordoCooperazione stmt.setLong("+idReferenteAccordoCooperazione+")");
  378.                         stm.setLong(indexStmt, idReferenteAccordoCooperazione);
  379.                         indexStmt++;
  380.                     }
  381.                     if(filtroRicercaBase.getIdAccordoCooperazione().getVersione()!=null){
  382.                         this.driver.logDebug("versioneAccordoCooperazione stmt.setString("+filtroRicercaBase.getIdAccordoCooperazione().getVersione()+")");
  383.                         stm.setInt(indexStmt, filtroRicercaBase.getIdAccordoCooperazione().getVersione());
  384.                         indexStmt++;
  385.                     }
  386.                 }
  387.                 
  388.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(stm, indexStmt, filtroRicercaBase, ProprietariProtocolProperty.ACCORDO_SERVIZIO_PARTE_COMUNE);
  389.             }
  390.             
  391.             if(filtroPT!=null){
  392.                 if(filtroPT.getNomePortType()!=null){
  393.                     stm.setString(indexStmt, filtroPT.getNomePortType());
  394.                     indexStmt++;
  395.                 }
  396.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(stm, indexStmt, filtroPT, ProprietariProtocolProperty.PORT_TYPE);
  397.             }
  398.             
  399.             if(filtroOP!=null){
  400.                 if(filtroOP.getNomePortType()!=null){
  401.                     stm.setString(indexStmt, filtroOP.getNomePortType());
  402.                     indexStmt++;
  403.                 }
  404.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(stm, indexStmt, filtroOP, ProprietariProtocolProperty.PORT_TYPE);
  405.                 
  406.                 if(filtroOP.getNomeAzione()!=null){
  407.                     stm.setString(indexStmt, filtroOP.getNomeAzione());
  408.                     indexStmt++;
  409.                 }
  410.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(stm, indexStmt, filtroOP, ProprietariProtocolProperty.OPERATION);
  411.             }
  412.             
  413.             if(filtroAZ!=null){
  414.                 if(filtroAZ.getNomeAzione()!=null){
  415.                     stm.setString(indexStmt, filtroAZ.getNomeAzione());
  416.                     indexStmt++;
  417.                 }
  418.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(stm, indexStmt, filtroAZ, ProprietariProtocolProperty.AZIONE_ACCORDO);
  419.             }
  420.             
  421.             if(filtroResource!=null){
  422.                 if(filtroResource.getResourceName()!=null){
  423.                     stm.setString(indexStmt, filtroResource.getResourceName());
  424.                     indexStmt++;
  425.                 }
  426.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(stm, indexStmt, filtroResource, ProprietariProtocolProperty.RESOURCE);
  427.             }
  428.             
  429.             rs = stm.executeQuery();
  430.             while (rs.next()) {
  431.                 long idReferente = rs.getLong("id_referente");
  432.                 IDSoggetto idSoggettoReferente = null;
  433.                 Exception excp = null;
  434.                 if(idReferente>0){
  435.                     try {
  436.                         idSoggettoReferente = this.driver.getIdSoggetto(idReferente,con);
  437.                         if(idSoggettoReferente==null){
  438.                             throw new DriverRegistroServiziNotFound ("non esiste");
  439.                         }
  440.                     }catch(DriverRegistroServiziNotFound notFound) {
  441.                         try{
  442.                             excp = new Exception("Soggetto referente ["+idReferente+"] presente nell'accordo ["+rs.getString("nome")+"] (versione ["+rs.getInt("versione")+"]) non presente?");
  443.                         }finally{
  444.                             try{
  445.                                 if(rs!=null){
  446.                                     rs.close();
  447.                                     rs = null;
  448.                                 }
  449.                             }catch (Exception e) {
  450.                                 // close
  451.                             }
  452.                             try{
  453.                                 if(stm!=null){
  454.                                     stm.close();
  455.                                     stm=null;
  456.                                 }
  457.                             }catch (Exception e) {
  458.                                 // close
  459.                             }
  460.                         }
  461.                     }
  462.                 }
  463.                 
  464.                 if(excp!=null) {
  465.                     throw excp;
  466.                 }
  467.                 if(rs==null) {
  468.                     throw new Exception("Ricerca referente non riuscita");
  469.                 }

  471.                 IDAccordo idAccordo = this.driver.idAccordoFactory.getIDAccordoFromValues(rs.getString("nomeAccordo"),idSoggettoReferente,rs.getInt("versione"));
  472.                 if(filtroPT!=null){
  473.                     IDPortType idPT = new IDPortType();
  474.                     idPT.setIdAccordo(idAccordo);
  475.                     idPT.setNome(rs.getString("nomePT"));
  476.                     listReturn.add((T) idPT);   
  477.                 }
  478.                 else if(filtroOP!=null){
  479.                     IDPortTypeAzione idAzione = new IDPortTypeAzione();
  480.                     IDPortType idPT = new IDPortType();
  481.                     idPT.setIdAccordo(idAccordo);
  482.                     idPT.setNome(rs.getString("nomePT"));
  483.                     idAzione.setIdPortType(idPT);
  484.                     idAzione.setNome(rs.getString("nomeOP"));
  485.                     listReturn.add((T) idAzione);   
  486.                 }
  487.                 else if(filtroAZ!=null){
  488.                     IDAccordoAzione idAzione = new IDAccordoAzione();
  489.                     idAzione.setIdAccordo(idAccordo);
  490.                     idAzione.setNome(rs.getString("nomeAZ"));
  491.                     listReturn.add((T) idAzione);   
  492.                 }
  493.                 else if(filtroResource!=null){
  494.                     IDResource idResource = new IDResource();
  495.                     idResource.setIdAccordo(idAccordo);
  496.                     idResource.setNome(rs.getString("nomeResource"));
  497.                     listReturn.add((T) idResource);     
  498.                 }
  499.                 else{
  500.                     listReturn.add((T) idAccordo);  
  501.                 }
  502.             }
  503.             if(listReturn.size()<=0){
  504.                 String msgFiltro = "Elementi non trovati che rispettano il filtro di ricerca selezionato: ";
  505.                 if(filtroPT!=null){
  506.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroPT.toString());
  507.                 }
  508.                 else if(filtroOP!=null){
  509.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroOP.toString());
  510.                 }
  511.                 else if(filtroAZ!=null){
  512.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroAZ.toString());
  513.                 }
  514.                 else if(filtroResource!=null){
  515.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroResource.toString());
  516.                 }
  517.                 else if(filtroRicercaBase!=null){
  518.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroRicercaBase.toString());
  519.                 }
  520.                 else{
  521.                     throw new DriverRegistroServiziNotFound("Elementi non trovati");
  522.                 }
  523.             }
  524.         }catch(DriverRegistroServiziNotFound de){
  525.             throw de;
  526.         }
  527.         catch(Exception e){
  528.             throw new DriverRegistroServiziException(nomeMetodo+" error",e);
  529.         } finally {

  531.             JDBCUtilities.closeResources(rs, stm);

  533.             this.driver.closeConnection(con);

  535.         }
  536.     }
  537. }
Created with JaCoCo 0.8.8.202204050719