DriverRegistroServiziDB_accordiCooperazioneDriver.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.Date;
  27. import java.sql.PreparedStatement;
  28. import java.sql.ResultSet;
  29. import java.sql.SQLException;
  30. import java.sql.Timestamp;
  31. import java.util.ArrayList;
  32. import java.util.List;

  34. import org.openspcoop2.core.commons.DBUtils;
  35. import org.openspcoop2.core.commons.Filtri;
  36. import org.openspcoop2.core.commons.ISearch;
  37. import org.openspcoop2.core.commons.Liste;
  38. import org.openspcoop2.core.commons.SearchUtils;
  39. import org.openspcoop2.core.constants.CostantiDB;
  40. import org.openspcoop2.core.constants.ProprietariProtocolProperty;
  41. import org.openspcoop2.core.id.IDAccordoCooperazione;
  42. import org.openspcoop2.core.id.IDSoggetto;
  43. import org.openspcoop2.core.registry.AccordoCooperazione;
  44. import org.openspcoop2.core.registry.AccordoCooperazionePartecipanti;
  45. import org.openspcoop2.core.registry.Documento;
  46. import org.openspcoop2.core.registry.IdSoggetto;
  47. import org.openspcoop2.core.registry.ProtocolProperty;
  48. import org.openspcoop2.core.registry.Soggetto;
  49. import org.openspcoop2.core.registry.constants.ProprietariDocumento;
  50. import org.openspcoop2.core.registry.constants.RuoliDocumento;
  51. import org.openspcoop2.core.registry.constants.StatiAccordo;
  52. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  53. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  54. import org.openspcoop2.core.registry.driver.FiltroRicercaAccordi;
  55. import org.openspcoop2.core.registry.driver.ValidazioneStatoPackageException;
  56. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  57. import org.openspcoop2.utils.sql.ISQLQueryObject;
  58. import org.openspcoop2.utils.sql.SQLObjectFactory;

  60. /**
  61.  * DriverRegistroServiziDB_accordiCooperazioneDriver
  62.  * 
  63.  * 
  64.  * @author Sandra Giangrandi (sandra@link.it)
  65.  * @author Stefano Corallo (corallo@link.it)
  66.  * @author $Author$
  67.  * @version $Rev$, $Date$
  68.  */
  69. public class DriverRegistroServiziDB_accordiCooperazioneDriver {

  71.     private DriverRegistroServiziDB driver = null;
  72.     private DriverRegistroServiziDB_protocolPropertiesDriver protocolPropertiesDriver = null;
  73.     
  74.     protected DriverRegistroServiziDB_accordiCooperazioneDriver(DriverRegistroServiziDB driver) {
  75.         this.driver = driver;
  76.         this.protocolPropertiesDriver = new DriverRegistroServiziDB_protocolPropertiesDriver(driver);
  77.     }
  78.     
  79.     
  80.     /* Accordi di Cooperazione */

  82.     protected org.openspcoop2.core.registry.AccordoCooperazione getAccordoCooperazione(IDAccordoCooperazione idAccordo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  83.         return getAccordoCooperazione(idAccordo,false);
  84.     }
  85.     protected org.openspcoop2.core.registry.AccordoCooperazione getAccordoCooperazione(IDAccordoCooperazione idAccordo,boolean readContenutoAllegati) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  87.         // conrollo consistenza
  88.         if (idAccordo == null)
  89.             throw new DriverRegistroServiziException("[getAccordoCooperazione] Parametro idAccordo is null");
  90.         if (idAccordo.getNome() == null)
  91.             throw new DriverRegistroServiziException("[getAccordoCooperazione] Parametro idAccordo.getNome is null");
  92.         if (idAccordo.getNome().trim().equals(""))
  93.             throw new DriverRegistroServiziException("[getAccordoCooperazione] Parametro idAccordo.getNome non e' definito");

  95.         this.driver.logDebug("richiesto getAccordoCooperazione: " + idAccordo.toString());

  97.         org.openspcoop2.core.registry.AccordoCooperazione accordoCooperazione = null;
  98.         Connection con = null;
  99.         PreparedStatement stm = null;
  100.         ResultSet rs = null;
  101.         PreparedStatement stm2 = null;
  102.         ResultSet rs2 = null;

  104.         try {

  106.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  107.             // prendo la connessione dal pool
  108.             if (this.driver.atomica)
  109.                 con = this.driver.getConnectionFromDatasource("getAccordoCooperazione(idAccordo)");
  110.             else
  111.                 con = this.driver.globalConnection;

  113.             long idAccordoLong = DBUtils.getIdAccordoCooperazione(idAccordo, con, this.driver.tipoDB);
  114.             if(idAccordoLong<=0){
  115.                 throw new DriverRegistroServiziNotFound("[DriverRegistroServiziDB::getAccordoCooperazione] Accordo non trovato (id:"+idAccordoLong+")");
  116.             }


  119.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  120.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE);
  121.             sqlQueryObject.addSelectField("*");
  122.             sqlQueryObject.addWhereCondition("id = ?");
  123.             sqlQueryObject.setANDLogicOperator(true);
  124.             String sqlQuery = sqlQueryObject.createSQLQuery();



  128.             stm = con.prepareStatement(sqlQuery);

  130.             stm.setLong(1, idAccordoLong);


  133.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idAccordoLong));
  134.             rs = stm.executeQuery();

  136.             if (rs.next()) {
  137.                 accordoCooperazione = new org.openspcoop2.core.registry.AccordoCooperazione();

  139.                 accordoCooperazione.setId(rs.getLong("id"));

  141.                 String tmp = rs.getString("nome");
  142.                 // se tmp==null oppure tmp=="" then setNome(null) else
  143.                 // setNome(tmp)
  144.                 accordoCooperazione.setNome(((tmp == null || tmp.equals("")) ? null : tmp));

  146.                 tmp = rs.getString("descrizione");
  147.                 accordoCooperazione.setDescrizione(((tmp == null || tmp.equals("")) ? null : tmp));

  149.                 // Soggetto referente
  150.                 long id_referente = rs.getLong("id_referente");
  151.                 if(id_referente>0) {
  152.                     IDSoggetto soggettoReferente = null;
  153.                     try {
  154.                         soggettoReferente = this.driver.getIdSoggetto(id_referente,con);
  155.                         if(soggettoReferente==null){
  156.                             throw new DriverRegistroServiziNotFound ("non esiste");
  157.                         }
  158.                     }catch(DriverRegistroServiziNotFound notFound) {
  159.                         throw new Exception ("Soggetto referente ["+id_referente+"] dell'accordo non esiste");
  160.                     }
  161.                     IdSoggetto assr = new IdSoggetto();
  162.                     assr.setTipo(soggettoReferente.getTipo());
  163.                     assr.setNome(soggettoReferente.getNome());
  164.                     accordoCooperazione.setSoggettoReferente(assr);
  165.                 }

  167.                 //Versione
  168.                 if(rs.getString("versione")!=null && !"".equals(rs.getString("versione")))
  169.                     accordoCooperazione.setVersione(rs.getInt("versione"));

  171.                 // Stato
  172.                 tmp = rs.getString("stato");
  173.                 accordoCooperazione.setStatoPackage(((tmp == null || tmp.equals("")) ? null : tmp));

  175.                 // Privato
  176.                 if(rs.getInt("privato")==1)
  177.                     accordoCooperazione.setPrivato(true);
  178.                 else
  179.                     accordoCooperazione.setPrivato(false);

  181.                 tmp = rs.getString("superuser");
  182.                 accordoCooperazione.setSuperUser(((tmp == null || tmp.equals("")) ? null : tmp));

  184.                 // Ora Registrazione
  185.                 if(rs.getTimestamp("ora_registrazione")!=null){
  186.                     accordoCooperazione.setOraRegistrazione(new Date(rs.getTimestamp("ora_registrazione").getTime()));
  187.                 }

  189.                 rs.close();
  190.                 stm.close();


  193.                 // Aggiungo ServiziComposti
  194.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  195.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_SERVIZI_COMPOSTO);
  196.                 sqlQueryObject.addSelectField("id_accordo");
  197.                 sqlQueryObject.addWhereCondition("id_accordo_cooperazione = ?");
  198.                 sqlQuery = sqlQueryObject.createSQLQuery();
  199.                 stm = con.prepareStatement(sqlQuery);
  200.                 stm.setLong(1, idAccordoLong);

  202.                 this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idAccordoLong));

  204.                 rs = stm.executeQuery();

  206.                 while (rs.next()) {

  208.                     long idAccServizioComposto = rs.getLong("id_accordo");

  210.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  211.                     sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  212.                     sqlQueryObject.addSelectField("nome");
  213.                     sqlQueryObject.addSelectField("versione");
  214.                     sqlQueryObject.addSelectField("id_referente");
  215.                     sqlQueryObject.addWhereCondition("id = ?");
  216.                     sqlQuery = sqlQueryObject.createSQLQuery();
  217.                     stm2 = con.prepareStatement(sqlQuery);
  218.                     stm2.setLong(1, idAccServizioComposto);
  219.                     rs2 = stm2.executeQuery();
  220.                     if(rs2.next()){
  221.                         IDSoggetto soggettoReferente = null;
  222.                         long id_referenteInternal = rs2.getLong("id_referente");
  223.                         if(id_referenteInternal>0){
  224.                             try {
  225.                                 soggettoReferente = this.driver.getIdSoggetto(id_referenteInternal,con);
  226.                                 if(soggettoReferente==null){
  227.                                     throw new DriverRegistroServiziNotFound ("non esiste");
  228.                                 }
  229.                             }catch(DriverRegistroServiziNotFound notFound) {
  230.                                 throw new Exception ("Soggetto referente ["+id_referenteInternal+"] dell'accordo non esiste");
  231.                             }
  232.                         }
  233.                         String uriAccordo = this.driver.idAccordoFactory.getUriFromValues(rs2.getString("nome"), soggettoReferente, rs2.getInt("versione"));
  234.                         accordoCooperazione.addUriServiziComposti(uriAccordo);
  235.                     }else{
  236.                         throw new DriverRegistroServiziException("IDAccordo con id ["+rs.getLong("id_accordo_servizio")+"] non presente");
  237.                     }
  238.                     rs2.close();
  239.                     stm2.close();

  241.                 }
  242.                 rs.close();
  243.                 stm.close();




  248.                 // Aggiungo Partecipanti
  249.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  250.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI);
  251.                 sqlQueryObject.addSelectField("*");
  252.                 sqlQueryObject.addWhereCondition("id_accordo_cooperazione = ?");
  253.                 sqlQuery = sqlQueryObject.createSQLQuery();
  254.                 stm = con.prepareStatement(sqlQuery);
  255.                 stm.setLong(1, idAccordoLong);

  257.                 this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idAccordoLong));

  259.                 rs = stm.executeQuery();

  261.                 IdSoggetto accCompPartecipante = null;
  262.                 AccordoCooperazionePartecipanti accCopPartecipanti = null;
  263.                 while (rs.next()) {

  265.                     accCompPartecipante = new IdSoggetto();
  266.                     accCompPartecipante.setIdSoggetto(rs.getLong("id_soggetto"));

  268.                     Soggetto s = this.driver.getSoggetto(rs.getLong("id_soggetto"),con);
  269.                     accCompPartecipante.setTipo(s.getTipo());
  270.                     accCompPartecipante.setNome(s.getNome());

  272.                     if(accCopPartecipanti==null){
  273.                         accCopPartecipanti = new AccordoCooperazionePartecipanti();
  274.                         accordoCooperazione.setElencoPartecipanti(accCopPartecipanti);
  275.                     }
  276.                     accordoCooperazione.getElencoPartecipanti().addSoggettoPartecipante(accCompPartecipante);

  278.                 }
  279.                 rs.close();
  280.                 stm.close();


  283.                 // read Documenti generici: i bytes non vengono ritornati se readContenutoAllegati==false, utilizzare il metodo apposta per averli: 
  284.                 //                                               DriverRegistroServiziDB_LIB.getDocumento(id, readBytes, connection);
  285.                 try{
  286.                     List<?> allegati = DriverRegistroServiziDB_documentiLIB.getListaDocumenti(RuoliDocumento.allegato.toString(), idAccordoLong, 
  287.                             ProprietariDocumento.accordoCooperazione,readContenutoAllegati, con, this.driver.tipoDB);
  288.                     for(int i=0; i<allegati.size();i++){
  289.                         accordoCooperazione.addAllegato((Documento) allegati.get(i));
  290.                     }
  291.                 }catch(DriverRegistroServiziNotFound dNotFound){}
  292.                 try{
  293.                     List<?> specificheSemiformali = DriverRegistroServiziDB_documentiLIB.getListaDocumenti(RuoliDocumento.specificaSemiformale.toString(), 
  294.                             idAccordoLong, ProprietariDocumento.accordoCooperazione,readContenutoAllegati, con, this.driver.tipoDB);
  295.                     for(int i=0; i<specificheSemiformali.size();i++){
  296.                         accordoCooperazione.addSpecificaSemiformale((Documento) specificheSemiformali.get(i));
  297.                     }
  298.                 }catch(DriverRegistroServiziNotFound dNotFound){}

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

  315.             } else {
  316.                 throw new DriverRegistroServiziNotFound("[DriverRegistroServiziDB::getAccordoCooperazione] rs.next non ha restituito valori con la seguente interrogazione :\n" + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idAccordoLong));
  317.             }


  320.             return accordoCooperazione;

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

  328.             JDBCUtilities.closeResources(rs2, stm2);

  330.             JDBCUtilities.closeResources(rs, stm);

  332.             this.driver.closeConnection(con);

  334.         }
  335.     }

  337.     protected IDAccordoCooperazione getIdAccordoCooperazione(long id) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  338.         return getIdAccordoCooperazione(id,null);
  339.     }
  340.     protected IDAccordoCooperazione getIdAccordoCooperazione(long id,Connection conParam) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  341.         this.driver.logDebug("richiesto getIdAccordoCooperazione: " + id);
  342.         // conrollo consistenza
  343.         if (id <= 0)
  344.             return null;

  346.         Connection con = null;
  347.         PreparedStatement stm = null;
  348.         ResultSet rs = null;

  350.         IDAccordoCooperazione idAccordo = null;
  351.         try {
  352.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  353.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE);
  354.             sqlQueryObject.addSelectField("nome");
  355.             sqlQueryObject.addSelectField("id_referente");
  356.             sqlQueryObject.addSelectField("versione");
  357.             sqlQueryObject.addWhereCondition("id = ?");
  358.             String sqlQuery = sqlQueryObject.createSQLQuery();

  360.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  361.             // prendo la connessione dal pool
  362.             if(conParam!=null){
  363.                 con = conParam;
  364.             }
  365.             else if (this.driver.atomica)
  366.                 con = this.driver.getConnectionFromDatasource("getIdAccordoCooperazione(longId)");
  367.             else
  368.                 con = this.driver.globalConnection;

  370.             stm = con.prepareStatement(sqlQuery);

  372.             stm.setLong(1, id);

  374.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, id));
  375.             rs = stm.executeQuery();


  378.             if (rs.next()) {

  380.                 IDSoggetto referente = null;
  381.                 long idReferente = rs.getLong("id_referente");
  382.                 if(idReferente>0){
  383.                     referente = this.driver.getIdSoggetto(idReferente,con);
  384.                     if(referente==null){
  385.                         throw new Exception("Soggetto referente non presente?");
  386.                     }
  387.                 }

  389.                 idAccordo = this.driver.idAccordoCooperazioneFactory.getIDAccordoFromValues(rs.getString("nome"),referente,rs.getInt("versione"));

  391.             } else {
  392.                 rs.close();
  393.                 stm.close();
  394.                 throw new DriverRegistroServiziNotFound("[DriverRegistroServiziDB::getIdAccordoCooperazione] rs.next non ha restituito valori con la seguente interrogazione :\n" + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, id));
  395.             }

  397.             rs.close();
  398.             stm.close();

  400.         } catch (SQLException se) {
  401.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getIdAccordoCooperazione] SQLException :" + se.getMessage(),se);
  402.         }catch (DriverRegistroServiziNotFound e) {
  403.             throw e;
  404.         }catch (Exception se) {
  405.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getIdAccordoCooperazione] Exception :" + se.getMessage(),se);
  406.         } finally {

  408.             //Chiudo statement and resultset
  409.             JDBCUtilities.closeResources(rs, stm);

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

  413.         }

  415.         return idAccordo;
  416.     }


  419.     protected AccordoCooperazione getAccordoCooperazione(long id) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  420.         return getAccordoCooperazione(id,null);
  421.     }
  422.     protected AccordoCooperazione getAccordoCooperazione(long id,Connection conParam) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  423.         this.driver.logDebug("richiesto getAccordoCooperazione: " + id);
  424.         // conrollo consistenza
  425.         if (id <= 0)
  426.             return null;

  428.         Connection con = null;
  429.         PreparedStatement stm = null;
  430.         ResultSet rs = null;

  432.         IDAccordoCooperazione idAccordo = null;
  433.         try {
  434.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  435.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE);
  436.             sqlQueryObject.addSelectField("nome");
  437.             sqlQueryObject.addSelectField("id_referente");
  438.             sqlQueryObject.addSelectField("versione");
  439.             sqlQueryObject.addWhereCondition("id = ?");
  440.             String sqlQuery = sqlQueryObject.createSQLQuery();

  442.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  443.             // prendo la connessione dal pool
  444.             if(conParam!=null){
  445.                 con = conParam;
  446.             }
  447.             else if (this.driver.atomica)
  448.                 con = this.driver.getConnectionFromDatasource("getAccordoCooperazione(longId)");
  449.             else
  450.                 con = this.driver.globalConnection;

  452.             stm = con.prepareStatement(sqlQuery);

  454.             stm.setLong(1, id);

  456.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, id));
  457.             rs = stm.executeQuery();


  460.             if (rs.next()) {

  462.                 IDSoggetto referente = null;
  463.                 long idReferente = rs.getLong("id_referente");
  464.                 if(idReferente>0){
  465.                     referente = this.driver.getIdSoggetto(idReferente,con);
  466.                     if(referente==null){
  467.                         throw new Exception("Soggetto referente non presente?");
  468.                     }
  469.                 }
  470.                 
  471.                 idAccordo = this.driver.idAccordoCooperazioneFactory.getIDAccordoFromValues(rs.getString("nome"),referente,rs.getInt("versione"));

  473.             } else {
  474.                 rs.close();
  475.                 stm.close();
  476.                 throw new DriverRegistroServiziNotFound("[DriverRegistroServiziDB::getAccordoCooperazione] rs.next non ha restituito valori con la seguente interrogazione :\n" + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, id));
  477.             }

  479.             rs.close();
  480.             stm.close();

  482.         } catch (SQLException se) {
  483.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getAccordoCooperazione] SQLException :" + se.getMessage(),se);
  484.         }catch (DriverRegistroServiziNotFound e) {
  485.             throw e;
  486.         }catch (Exception se) {
  487.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getAccordoCooperazione] Exception :" + se.getMessage(),se);
  488.         } finally {

  490.             //Chiudo statement and resultset
  491.             JDBCUtilities.closeResources(rs, stm);

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

  495.         }

  497.         return this.getAccordoCooperazione(idAccordo, false);
  498.     }

  500.     /**
  501.      * Ritorna gli identificatori degli accordi che rispettano il parametro di ricerca
  502.      * 
  503.      * @param filtroRicerca
  504.      * @return Una lista di ID degli accordi trovati
  505.      * @throws DriverRegistroServiziException
  506.      * @throws DriverRegistroServiziNotFound
  507.      */
  508.     protected List<IDAccordoCooperazione> getAllIdAccordiCooperazione(FiltroRicercaAccordi filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  509.         Connection con = null;
  510.         PreparedStatement stm = null;
  511.         ResultSet rs = null;

  513.         this.driver.logDebug("getAllIdAccordiCooperazione...");

  515.         try {
  516.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  517.             // prendo la connessione dal pool
  518.             if (this.driver.atomica)
  519.                 con = this.driver.getConnectionFromDatasource("getAllIdAccordiCooperazione");
  520.             else
  521.                 con = this.driver.globalConnection;

  523.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  524.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE);
  525.             sqlQueryObject.addFromTable(this.driver.tabellaSoggetti);

  527.             sqlQueryObject.addSelectField(CostantiDB.ACCORDI_COOPERAZIONE,"nome");
  528.             sqlQueryObject.addSelectField(CostantiDB.ACCORDI_COOPERAZIONE,"versione");
  529.             sqlQueryObject.addSelectField(this.driver.tabellaSoggetti,"tipo_soggetto");
  530.             sqlQueryObject.addSelectField(this.driver.tabellaSoggetti,"nome_soggetto");
  531.             sqlQueryObject.setSelectDistinct(true);
  532.             sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE+".id_referente="+this.driver.tabellaSoggetti+".id");
  533.             if(filtroRicerca!=null){
  534.                 // Filtro By Data
  535.                 if(filtroRicerca.getMinDate()!=null)
  536.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE+".ora_registrazione > ?");
  537.                 if(filtroRicerca.getMaxDate()!=null)
  538.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE+".ora_registrazione < ?");
  539.                 if(filtroRicerca.getNomeAccordo()!=null)
  540.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE+".nome = ?");
  541.                 if(filtroRicerca.getVersione()!=null)
  542.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE+".versione = ?");
  543.                 if(filtroRicerca.getTipoSoggettoReferente()!=null)
  544.                     sqlQueryObject.addWhereCondition(this.driver.tabellaSoggetti+".tipo_soggetto=?");
  545.                 if(filtroRicerca.getNomeSoggettoReferente()!=null)
  546.                     sqlQueryObject.addWhereCondition(this.driver.tabellaSoggetti+".nome_soggetto=?");
  547.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(sqlQueryObject, filtroRicerca, CostantiDB.ACCORDI_COOPERAZIONE);
  548.             }

  550.             sqlQueryObject.setANDLogicOperator(true);
  551.             String sqlQuery = sqlQueryObject.createSQLQuery();
  552.             this.driver.logDebug("eseguo query : " + sqlQuery );
  553.             stm = con.prepareStatement(sqlQuery);
  554.             int indexStmt = 1;
  555.             if(filtroRicerca!=null){
  556.                 if(filtroRicerca.getMinDate()!=null){
  557.                     this.driver.logDebug("minDate stmt.setTimestamp("+filtroRicerca.getMinDate()+")");
  558.                     stm.setTimestamp(indexStmt, new Timestamp(filtroRicerca.getMinDate().getTime()));
  559.                     indexStmt++;
  560.                 }
  561.                 if(filtroRicerca.getMaxDate()!=null){
  562.                     this.driver.logDebug("maxDate stmt.setTimestamp("+filtroRicerca.getMaxDate()+")");
  563.                     stm.setTimestamp(indexStmt, new Timestamp(filtroRicerca.getMaxDate().getTime()));
  564.                     indexStmt++;
  565.                 }   
  566.                 if(filtroRicerca.getNomeAccordo()!=null){
  567.                     this.driver.logDebug("nomeAccordo stmt.setString("+filtroRicerca.getNomeAccordo()+")");
  568.                     stm.setString(indexStmt, filtroRicerca.getNomeAccordo());
  569.                     indexStmt++;
  570.                 }   
  571.                 if(filtroRicerca.getVersione()!=null){
  572.                     this.driver.logDebug("versioneAccordo stmt.setString("+filtroRicerca.getVersione()+")");
  573.                     stm.setInt(indexStmt, filtroRicerca.getVersione());
  574.                     indexStmt++;
  575.                 }   
  576.                 if(filtroRicerca.getTipoSoggettoReferente()!=null){
  577.                     this.driver.logDebug("tipoSoggettoReferenteAccordo stmt.setString("+filtroRicerca.getTipoSoggettoReferente()+")");
  578.                     stm.setString(indexStmt, filtroRicerca.getTipoSoggettoReferente());
  579.                     indexStmt++;
  580.                 }
  581.                 if(filtroRicerca.getNomeSoggettoReferente()!=null){
  582.                     this.driver.logDebug("nomeSoggettoReferenteAccordo stmt.setString("+filtroRicerca.getNomeSoggettoReferente()+")");
  583.                     stm.setString(indexStmt, filtroRicerca.getNomeSoggettoReferente());
  584.                     indexStmt++;
  585.                 }   
  586.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(stm, indexStmt, filtroRicerca, ProprietariProtocolProperty.ACCORDO_COOPERAZIONE);
  587.             }
  588.             rs = stm.executeQuery();
  589.             List<IDAccordoCooperazione> idAccordi = new ArrayList<IDAccordoCooperazione>();
  590.             while (rs.next()) {
  591.                 IDSoggetto idSoggetto = new IDSoggetto(rs.getString("tipo_soggetto"), rs.getString("nome_soggetto"));
  592.                 IDAccordoCooperazione idAccordo = this.driver.idAccordoCooperazioneFactory.getIDAccordoFromValues(rs.getString("nome"),idSoggetto,rs.getInt("versione"));
  593.                 idAccordi.add(idAccordo);
  594.             }
  595.             if(idAccordi.size()==0){
  596.                 if(filtroRicerca!=null)
  597.                     throw new DriverRegistroServiziNotFound("Accordi non trovati che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  598.                 else
  599.                     throw new DriverRegistroServiziNotFound("Accordi non trovati");
  600.             }else{
  601.                 return idAccordi;
  602.             }
  603.         }catch(DriverRegistroServiziNotFound de){
  604.             throw de;
  605.         }
  606.         catch(Exception e){
  607.             throw new DriverRegistroServiziException("getAllIdAccordiCooperazione error",e);
  608.         } finally {

  610.             //Chiudo statement and resultset
  611.             JDBCUtilities.closeResources(rs, stm);

  613.             this.driver.closeConnection(con);

  615.         }
  616.     }




  621.     /**
  622.      * Crea un nuovo AccordoCooperazione
  623.      * 
  624.      * @param accordoCooperazione
  625.      * @throws DriverRegistroServiziException
  626.      */
  627.     protected void createAccordoCooperazione(AccordoCooperazione accordoCooperazione) throws DriverRegistroServiziException{
  628.         if (accordoCooperazione == null)
  629.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createAccordoCooperazione] Parametro non valido.");

  631.         Connection con = null;
  632.         boolean error = false;

  634.         if (this.driver.atomica) {
  635.             try {
  636.                 con = this.driver.getConnectionFromDatasource("createAccordoCooperazione");
  637.                 con.setAutoCommit(false);
  638.             } catch (Exception e) {
  639.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createAccordoCooperazione] Exception accedendo al datasource :" + e.getMessage(),e);

  641.             }

  643.         } else
  644.             con = this.driver.globalConnection;

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

  648.         try {
  649.             this.driver.logDebug("CRUDServizio tupe=1");
  650.             // CREATE
  651.             DriverRegistroServiziDB_accordiCooperazioneLIB.CRUDAccordoCooperazione(CostantiDB.CREATE, accordoCooperazione, con, 
  652.                     this.driver.tipoDB, this.driver.getDriverWrapBYOK());

  654.         } catch (Exception qe) {
  655.             error = true;
  656.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createAccordoCooperazione] Errore durante la creazione dell'accordo : " + qe.getMessage(), qe);
  657.         } finally {
  658.             this.driver.closeConnection(error, con);
  659.         }
  660.     }

  662.     /**
  663.      * Verifica l'esistenza di un accordo registrato.
  664.      *
  665.      * @param idAccordo dell'accordo da verificare
  666.      * @return true se l'accordo esiste, false altrimenti
  667.      * @throws DriverRegistroServiziException
  668.      */    
  669.     protected boolean existsAccordoCooperazione(IDAccordoCooperazione idAccordo) throws DriverRegistroServiziException{
  670.         Connection connection;
  671.         if (this.driver.atomica) {
  672.             try {
  673.                 connection = this.driver.getConnectionFromDatasource("existsAccordoCooperazione");
  674.             } catch (Exception e) {
  675.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::createAccordoServizio] Exception accedendo al datasource :" + e.getMessage(),e);

  677.             }

  679.         } else
  680.             connection = this.driver.globalConnection;

  682.         this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  683.         try {
  684.             long idAccordoLong = DBUtils.getIdAccordoCooperazione(idAccordo, connection, this.driver.tipoDB);
  685.             if (idAccordoLong <= 0)
  686.                 return false;
  687.             else
  688.                 return true;
  689.         } catch (Exception e) {
  690.             throw new DriverRegistroServiziException(e.getMessage(),e);
  691.         } finally {
  692.             this.driver.closeConnection(connection);
  693.         }
  694.     }

  696.     /**
  697.      * Aggiorna l'AccordoCooperazione con i nuovi valori.
  698.      *  
  699.      * @param accordoCooperazione
  700.      * @throws DriverRegistroServiziException
  701.      */
  702.     protected void updateAccordoCooperazione(AccordoCooperazione accordoCooperazione) throws DriverRegistroServiziException{
  703.         if (accordoCooperazione == null)
  704.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateAccordoCooperazione] Parametro non valido.");
  705.         Connection con = null;
  706.         boolean error = false;

  708.         if (this.driver.atomica) {
  709.             try {
  710.                 con = this.driver.getConnectionFromDatasource("updateAccordoCooperazione");
  711.                 con.setAutoCommit(false);
  712.             } catch (Exception e) {
  713.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateAccordoCooperazione] Exception accedendo al datasource :" + e.getMessage(),e);

  715.             }

  717.         } else
  718.             con = this.driver.globalConnection;

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

  722.         try {

  724.             // UPDATE
  725.             DriverRegistroServiziDB_accordiCooperazioneLIB.CRUDAccordoCooperazione(CostantiDB.UPDATE, accordoCooperazione, con, 
  726.                     this.driver.tipoDB, this.driver.getDriverWrapBYOK());

  728.         } catch (Exception qe) {
  729.             error = true;
  730.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateAccordoCooperazione] Errore durante l'update dell'accordo : " + qe.getMessage(),qe);
  731.         } finally {
  732.             this.driver.closeConnection(error, con);
  733.         }
  734.     }

  736.     /**
  737.      * Elimina un AccordoCooperazione 
  738.      *  
  739.      * @param accordoCooperazione
  740.      * @throws DriverRegistroServiziException
  741.      */
  742.     protected void deleteAccordoCooperazione(AccordoCooperazione accordoCooperazione) throws DriverRegistroServiziException{
  743.         if (accordoCooperazione == null)
  744.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteAccordoCooperazione] Parametro non valido.");

  746.         Connection con = null;
  747.         boolean error = false;

  749.         if (this.driver.atomica) {
  750.             try {
  751.                 con = this.driver.getConnectionFromDatasource("deleteAccordoCooperazione");
  752.                 con.setAutoCommit(false);
  753.             } catch (Exception e) {
  754.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteAccordoCooperazione] Exception accedendo al datasource :" + e.getMessage(),e);

  756.             }

  758.         } else
  759.             con = this.driver.globalConnection;

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

  763.         try {
  764.             this.driver.logDebug("CRUDServizio type = 3");
  765.             // creo soggetto
  766.             DriverRegistroServiziDB_accordiCooperazioneLIB.CRUDAccordoCooperazione(CostantiDB.DELETE, accordoCooperazione, con, 
  767.                     this.driver.tipoDB, this.driver.getDriverWrapBYOK());

  769.         } catch (Exception qe) {
  770.             error = true;
  771.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteAccordoCooperazione] Errore durante la delete dell'accordo : " + qe.getMessage(),qe);
  772.         } finally {
  773.             this.driver.closeConnection(error, con);
  774.         }
  775.     }

  777.     protected List<AccordoCooperazione> accordiCooperazioneList(String superuser, ISearch ricerca) throws DriverRegistroServiziException {
  778.         String nomeMetodo = "accordiCooperazioneList";
  779.         int idLista = Liste.ACCORDI_COOPERAZIONE;
  780.         int offset;
  781.         int limit;
  782.         String search;
  783.         String queryString;

  785.         limit = ricerca.getPageSize(idLista);
  786.         offset = ricerca.getIndexIniziale(idLista);
  787.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  788.         ricerca.getSearchString(idLista);

  790.         String filterProtocollo = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_PROTOCOLLO);
  791.         String filterProtocolli = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_PROTOCOLLI);
  792.         List<String> tipoSoggettiProtocollo = null;
  793.         try {
  794.             tipoSoggettiProtocollo = Filtri.convertToTipiSoggetti(filterProtocollo, filterProtocolli);
  795.         }catch(Exception e) {
  796.             throw new DriverRegistroServiziException(e.getMessage(),e);
  797.         }

  799.         String filterStatoAccordo = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_STATO_ACCORDO);

  801.         this.driver.logDebug("search : " + search);
  802.         this.driver.logDebug("filterProtocollo : " + filterProtocollo);
  803.         this.driver.logDebug("filterProtocolli : " + filterProtocolli);
  804.         this.driver.logDebug("filterStatoAccordo : " + filterStatoAccordo);

  806.         Connection con = null;
  807.         PreparedStatement stmt = null;
  808.         ResultSet risultato = null;

  810.         ArrayList<IDAccordoCooperazione> idAccordi = new ArrayList<IDAccordoCooperazione>();

  812.         if (this.driver.atomica) {
  813.             try {
  814.                 con = this.driver.getConnectionFromDatasource("accordiCooperazioneList");

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

  819.             }

  821.         } else
  822.             con = this.driver.globalConnection;

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

  826.         try {

  828.             if (!search.equals("")) {
  829.                 //query con search
  830.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  831.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE);
  832.                 sqlQueryObject.addSelectCountField("*", "cont");
  833.                 if(this.driver.useSuperUser && superuser!=null && (!superuser.equals("")))
  834.                     sqlQueryObject.addWhereCondition("superuser = ?");
  835.                 sqlQueryObject.addWhereCondition(false, 
  836.                         sqlQueryObject.getWhereLikeCondition("nome", search, true, true));
  837.                         //sqlQueryObject.getWhereLikeCondition("versione", search, true, true)); // e' un intero
  838.                 if(tipoSoggettiProtocollo!=null && tipoSoggettiProtocollo.size()>0) {
  839.                     sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  840.                     sqlQueryObject.addWhereCondition("id_referente = "+CostantiDB.SOGGETTI+".id");
  841.                     sqlQueryObject.addWhereINCondition(CostantiDB.SOGGETTI+".tipo_soggetto", true, tipoSoggettiProtocollo.toArray(new String[1]));
  842.                 }
  843.                 if(filterStatoAccordo!=null && !filterStatoAccordo.equals("")) {
  844.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE+".stato = ?");
  845.                 }
  846.                 sqlQueryObject.setANDLogicOperator(true);
  847.                 queryString = sqlQueryObject.createSQLQuery();
  848.             } else {
  849.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  850.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE);
  851.                 sqlQueryObject.addSelectCountField("*", "cont");
  852.                 if(this.driver.useSuperUser && superuser!=null && (!superuser.equals("")))
  853.                     sqlQueryObject.addWhereCondition("superuser = ?");
  854.                 if(tipoSoggettiProtocollo!=null && tipoSoggettiProtocollo.size()>0) {
  855.                     sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  856.                     sqlQueryObject.addWhereCondition("id_referente = "+CostantiDB.SOGGETTI+".id");
  857.                     sqlQueryObject.addWhereINCondition(CostantiDB.SOGGETTI+".tipo_soggetto", true, tipoSoggettiProtocollo.toArray(new String[1]));
  858.                 }
  859.                 if(filterStatoAccordo!=null && !filterStatoAccordo.equals("")) {
  860.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE+".stato = ?");
  861.                 }
  862.                 sqlQueryObject.setANDLogicOperator(true);
  863.                 queryString = sqlQueryObject.createSQLQuery();
  864.             }

  866.             stmt = con.prepareStatement(queryString);
  867.             int index = 1;
  868.             if(this.driver.useSuperUser && superuser!=null && (!superuser.equals("")))
  869.                 stmt.setString(index++, superuser);
  870.             if(filterStatoAccordo!=null && !filterStatoAccordo.equals("")) {
  871.                 stmt.setString(index++, filterStatoAccordo);
  872.             }
  873.             risultato = stmt.executeQuery();
  874.             if (risultato.next())
  875.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  876.             risultato.close();
  877.             stmt.close();

  879.             // ricavo le entries
  880.             if (limit == 0) // con limit
  881.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  882.             if (!search.equals("")) { // con search
  883.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  884.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE);
  885.                 sqlQueryObject.addSelectAliasField(CostantiDB.ACCORDI_COOPERAZIONE,"id","idAccordoCooperazione");
  886.                 sqlQueryObject.addSelectField("nome");
  887.                 sqlQueryObject.addSelectField("id_referente");
  888.                 sqlQueryObject.addSelectAliasField(CostantiDB.ACCORDI_COOPERAZIONE,"descrizione","descrizioneAccordoCooperazione");
  889.                 sqlQueryObject.addSelectField("versione");
  890.                 if(this.driver.useSuperUser && superuser!=null && (!superuser.equals("")))
  891.                     sqlQueryObject.addWhereCondition("superuser = ?");
  892.                 sqlQueryObject.addWhereCondition(false, 
  893.                         sqlQueryObject.getWhereLikeCondition("nome", search, true, true));
  894.                         //sqlQueryObject.getWhereLikeCondition("versione", search, true, true));  // e' un intero
  895.                 if(tipoSoggettiProtocollo!=null && tipoSoggettiProtocollo.size()>0) {
  896.                     sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  897.                     sqlQueryObject.addWhereCondition("id_referente = "+CostantiDB.SOGGETTI+".id");
  898.                     sqlQueryObject.addWhereINCondition(CostantiDB.SOGGETTI+".tipo_soggetto", true, tipoSoggettiProtocollo.toArray(new String[1]));
  899.                 }
  900.                 if(filterStatoAccordo!=null && !filterStatoAccordo.equals("")) {
  901.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE+".stato = ?");
  902.                 }
  903.                 sqlQueryObject.setANDLogicOperator(true);
  904.                 sqlQueryObject.addOrderBy("nome");
  905.                 sqlQueryObject.addOrderBy("versione");
  906.                 sqlQueryObject.setSortType(true);
  907.                 sqlQueryObject.setLimit(limit);
  908.                 sqlQueryObject.setOffset(offset);
  909.                 queryString = sqlQueryObject.createSQLQuery();
  910.             } else {
  911.                 // senza search
  912.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  913.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE);
  914.                 sqlQueryObject.addSelectAliasField(CostantiDB.ACCORDI_COOPERAZIONE,"id","idAccordoCooperazione");
  915.                 sqlQueryObject.addSelectField("nome");
  916.                 sqlQueryObject.addSelectField("id_referente");
  917.                 sqlQueryObject.addSelectAliasField(CostantiDB.ACCORDI_COOPERAZIONE,"descrizione","descrizioneAccordoCooperazione");
  918.                 sqlQueryObject.addSelectField("versione");
  919.                 if(this.driver.useSuperUser && superuser!=null && (!superuser.equals("")))
  920.                     sqlQueryObject.addWhereCondition("superuser = ?");
  921.                 if(tipoSoggettiProtocollo!=null && tipoSoggettiProtocollo.size()>0) {
  922.                     sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  923.                     sqlQueryObject.addWhereCondition("id_referente = "+CostantiDB.SOGGETTI+".id");
  924.                     sqlQueryObject.addWhereINCondition(CostantiDB.SOGGETTI+".tipo_soggetto", true, tipoSoggettiProtocollo.toArray(new String[1]));
  925.                 }
  926.                 if(filterStatoAccordo!=null && !filterStatoAccordo.equals("")) {
  927.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE+".stato = ?");
  928.                 }
  929.                 sqlQueryObject.setANDLogicOperator(true);
  930.                 sqlQueryObject.addOrderBy("nome");
  931.                 sqlQueryObject.addOrderBy("versione");
  932.                 sqlQueryObject.setSortType(true);
  933.                 sqlQueryObject.setLimit(limit);
  934.                 sqlQueryObject.setOffset(offset);
  935.                 queryString = sqlQueryObject.createSQLQuery();
  936.             }


  939.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(queryString));

  941.             stmt = con.prepareStatement(queryString);
  942.             index = 1;
  943.             if(this.driver.useSuperUser && superuser!=null && (!superuser.equals("")))
  944.                 stmt.setString(index++, superuser);
  945.             if(filterStatoAccordo!=null && !filterStatoAccordo.equals("")) {
  946.                 stmt.setString(index++, filterStatoAccordo);
  947.             }
  948.             risultato = stmt.executeQuery();

  950.             while (risultato.next()) {

  952.                 String nomeAcc = risultato.getString("nome"); 
  953.                 int versioneAcc = risultato.getInt("versione");
  954.                 long idReferente = risultato.getLong("id_referente");

  956.                 IDSoggetto soggettoReferente = null;
  957.                 if(idReferente>0){
  958.                     Soggetto s = this.driver.getSoggetto(idReferente);
  959.                     soggettoReferente = new IDSoggetto(s.getTipo(),s.getNome());
  960.                 }
  961.                 
  962.                 IDAccordoCooperazione id = this.driver.idAccordoCooperazioneFactory.getIDAccordoFromValues(nomeAcc, soggettoReferente, versioneAcc);

  964.                 idAccordi.add(id);

  966.             }

  968.             this.driver.logDebug("size lista :" + ((idAccordi == null) ? null : idAccordi.size()));


  971.         } catch (Exception se) {

  973.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  974.         } finally {

  976.             //Chiudo statement and resultset
  977.             JDBCUtilities.closeResources(risultato, stmt);

  979.             this.driver.closeConnection(con);
  980.         }


  983.         ArrayList<AccordoCooperazione> lista = new ArrayList<AccordoCooperazione>();
  984.         for(int i=-0; i<idAccordi.size(); i++){
  985.             try{
  986.                 lista.add(this.getAccordoCooperazione(idAccordi.get(i)));
  987.             }catch(DriverRegistroServiziNotFound dNot){
  988.                 throw new DriverRegistroServiziException("Accordo non trovato con id?: "+dNot.getMessage(),dNot);
  989.             }
  990.         }
  991.         return lista;
  992.     }

  994.     protected List<IDSoggetto> accordiCoopPartecipantiList(long idAccordo,ISearch ricerca) throws DriverRegistroServiziException {
  995.         String nomeMetodo = "accordiCoopPartecipantiList";
  996.         int idLista = Liste.ACCORDI_COOP_PARTECIPANTI;
  997.         int offset;
  998.         int limit;
  999.         String search;
  1000.         String queryString;

  1002.         limit = ricerca.getPageSize(idLista);
  1003.         offset = ricerca.getIndexIniziale(idLista);
  1004.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  1005.         ricerca.getSearchString(idLista);

  1007.         this.driver.logDebug("search : " + search);

  1009.         Connection con = null;
  1010.         PreparedStatement stmt = null;
  1011.         ResultSet risultato = null;

  1013.         ArrayList<IDSoggetto> idSoggetti = new ArrayList<IDSoggetto>();

  1015.         if (this.driver.atomica) {
  1016.             try {
  1017.                 con = this.driver.getConnectionFromDatasource("accordiCoopPartecipantiList");

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

  1022.             }

  1024.         } else
  1025.             con = this.driver.globalConnection;

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

  1029.         try {

  1031.             if (!search.equals("")) {
  1032.                 ISQLQueryObject sqlQueryObjectSoggetti = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1033.                 sqlQueryObjectSoggetti.addFromTable(CostantiDB.SOGGETTI);
  1034.                 sqlQueryObjectSoggetti.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI);
  1035.                 sqlQueryObjectSoggetti.addSelectCountField("*", "cont");
  1036.                 sqlQueryObjectSoggetti.addWhereCondition(true,
  1037.                         sqlQueryObjectSoggetti.getWhereLikeCondition(CostantiDB.SOGGETTI+".nome_soggetto", search, true, true),
  1038.                             CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI+".id_soggetto="+CostantiDB.SOGGETTI+".id");
  1039.                 sqlQueryObjectSoggetti.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI+".id_accordo_cooperazione=?");
  1040.                 sqlQueryObjectSoggetti.setANDLogicOperator(true);
  1041.                 queryString = sqlQueryObjectSoggetti.createSQLQuery();
  1042.             }else {
  1043.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1044.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI);
  1045.                 sqlQueryObject.addSelectCountField("*", "cont");
  1046.                 sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI+".id_accordo_cooperazione=?");
  1047.                 sqlQueryObject.setANDLogicOperator(true);
  1048.                 queryString = sqlQueryObject.createSQLQuery();
  1049.             }

  1051.             stmt = con.prepareStatement(queryString);
  1052.             stmt.setLong(1, idAccordo);
  1053.             risultato = stmt.executeQuery();
  1054.             if (risultato.next())
  1055.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1056.             risultato.close();
  1057.             stmt.close();

  1059.             // ricavo le entries
  1060.             if (limit == 0) // con limit
  1061.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1062.             if (!search.equals("")) { // con search
  1063.                 ISQLQueryObject sqlQueryObjectSoggetti = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1064.                 sqlQueryObjectSoggetti.addFromTable(CostantiDB.SOGGETTI);
  1065.                 sqlQueryObjectSoggetti.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI);
  1066.                 sqlQueryObjectSoggetti.addSelectField(CostantiDB.SOGGETTI, "nome_soggetto");
  1067.                 sqlQueryObjectSoggetti.addSelectField(CostantiDB.SOGGETTI, "tipo_soggetto");
  1068.                 sqlQueryObjectSoggetti.addSelectField(CostantiDB.SOGGETTI, "id");
  1069.                 sqlQueryObjectSoggetti.addSelectField(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI, "id_soggetto");
  1070.                 sqlQueryObjectSoggetti.addSelectField(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI, "id_accordo_cooperazione");

  1072.                 sqlQueryObjectSoggetti.addWhereCondition(true,
  1073.                         sqlQueryObjectSoggetti.getWhereLikeCondition(CostantiDB.SOGGETTI+".nome_soggetto", search, true, true),
  1074.                         CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI+".id_soggetto="+CostantiDB.SOGGETTI+".id");

  1076.                 sqlQueryObjectSoggetti.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI+".id_accordo_cooperazione=?");

  1078.                 sqlQueryObjectSoggetti.setANDLogicOperator(true);
  1079.                 sqlQueryObjectSoggetti.addOrderBy("tipo_soggetto");
  1080.                 sqlQueryObjectSoggetti.addOrderBy("nome_soggetto");
  1081.                 sqlQueryObjectSoggetti.setSortType(true);
  1082.                 sqlQueryObjectSoggetti.setLimit(limit);
  1083.                 sqlQueryObjectSoggetti.setOffset(offset);
  1084.                 queryString = sqlQueryObjectSoggetti.createSQLQuery();
  1085.             } else {
  1086.                 // senza search
  1087.                 ISQLQueryObject sqlQueryObjectSoggetti = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1088.                 sqlQueryObjectSoggetti.addFromTable(CostantiDB.SOGGETTI);
  1089.                 sqlQueryObjectSoggetti.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI);
  1090.                 sqlQueryObjectSoggetti.addSelectField(CostantiDB.SOGGETTI, "nome_soggetto");
  1091.                 sqlQueryObjectSoggetti.addSelectField(CostantiDB.SOGGETTI, "tipo_soggetto");
  1092.                 sqlQueryObjectSoggetti.addSelectField(CostantiDB.SOGGETTI, "id");
  1093.                 sqlQueryObjectSoggetti.addSelectField(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI, "id_soggetto");
  1094.                 sqlQueryObjectSoggetti.addSelectField(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI, "id_accordo_cooperazione");

  1096.                 sqlQueryObjectSoggetti.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI+".id_accordo_cooperazione=?");
  1097.                 sqlQueryObjectSoggetti.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI+".id_soggetto="+CostantiDB.SOGGETTI+".id");

  1099.                 sqlQueryObjectSoggetti.setANDLogicOperator(true);
  1100.                 sqlQueryObjectSoggetti.addOrderBy("tipo_soggetto");
  1101.                 sqlQueryObjectSoggetti.addOrderBy("nome_soggetto");
  1102.                 sqlQueryObjectSoggetti.setSortType(true);
  1103.                 sqlQueryObjectSoggetti.setLimit(limit);
  1104.                 sqlQueryObjectSoggetti.setOffset(offset);
  1105.                 queryString = sqlQueryObjectSoggetti.createSQLQuery();
  1106.             }


  1109.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(queryString));

  1111.             stmt = con.prepareStatement(queryString);
  1112.             stmt.setLong(1, idAccordo);
  1113.             risultato = stmt.executeQuery();

  1115.             while (risultato.next()) {

  1117.                 String tipo = risultato.getString("tipo_soggetto");
  1118.                 String nome = risultato.getString("nome_soggetto");
  1119.                 IDSoggetto idSogg = new IDSoggetto(tipo,nome);
  1120.                 idSoggetti.add(idSogg);

  1122.             }

  1124.         } catch (Exception se) {

  1126.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1127.         } finally {

  1129.             //Chiudo statement and resultset
  1130.             JDBCUtilities.closeResources(risultato, stmt);

  1132.             this.driver.closeConnection(con);
  1133.         }


  1136.         return idSoggetti;
  1137.     }

  1139.     protected List<AccordoCooperazione> accordiCoopWithSoggettoPartecipante(IDSoggetto idSoggetto) throws DriverRegistroServiziException {
  1140.         String nomeMetodo = "accordiCoopWithSoggettoPartecipante";

  1142.         String queryString;

  1144.         Connection con = null;
  1145.         PreparedStatement stmt = null;
  1146.         ResultSet risultato = null;

  1148.         ArrayList<AccordoCooperazione> idAccordoCooperazione = new ArrayList<AccordoCooperazione>();

  1150.         if (this.driver.atomica) {
  1151.             try {
  1152.                 con = this.driver.getConnectionFromDatasource("accordiCoopWithSoggettoPartecipante");

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

  1157.             }

  1159.         } else
  1160.             con = this.driver.globalConnection;

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

  1164.         try {
  1165.             ISQLQueryObject sqlQueryObjectSoggetti = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1166.             sqlQueryObjectSoggetti.addFromTable(CostantiDB.SOGGETTI);
  1167.             sqlQueryObjectSoggetti.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI);
  1168.             sqlQueryObjectSoggetti.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE);
  1169.             sqlQueryObjectSoggetti.addSelectAliasField(CostantiDB.ACCORDI_COOPERAZIONE, "id","idAccordoCooperazione");
  1170.             sqlQueryObjectSoggetti.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI+".id_accordo_cooperazione="+CostantiDB.ACCORDI_COOPERAZIONE+".id");
  1171.             sqlQueryObjectSoggetti.addWhereCondition(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI+".id_soggetto="+CostantiDB.SOGGETTI+".id");
  1172.             sqlQueryObjectSoggetti.addWhereCondition(CostantiDB.SOGGETTI+".tipo_soggetto=?");
  1173.             sqlQueryObjectSoggetti.addWhereCondition(CostantiDB.SOGGETTI+".nome_soggetto=?");
  1174.             sqlQueryObjectSoggetti.setANDLogicOperator(true);
  1175.             queryString = sqlQueryObjectSoggetti.createSQLQuery();

  1177.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(queryString));

  1179.             stmt = con.prepareStatement(queryString);
  1180.             stmt.setString(1,idSoggetto.getTipo());
  1181.             stmt.setString(2,idSoggetto.getNome());
  1182.             risultato = stmt.executeQuery();

  1184.             while (risultato.next()) {

  1186.                 long idAccordoCooperazioneLong = risultato.getLong("idAccordoCooperazione");
  1187.                 idAccordoCooperazione.add(this.getAccordoCooperazione(idAccordoCooperazioneLong));

  1189.             }

  1191.         } catch (Exception se) {

  1193.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1194.         } finally {

  1196.             //Chiudo statement and resultset
  1197.             JDBCUtilities.closeResources(risultato, stmt);

  1199.             this.driver.closeConnection(con);
  1200.         }


  1203.         return idAccordoCooperazione;
  1204.     }
  1205.     
  1206.     protected void validaStatoAccordoCooperazione(AccordoCooperazione ac) throws ValidazioneStatoPackageException{

  1208.         ValidazioneStatoPackageException erroreValidazione =
  1209.                 new ValidazioneStatoPackageException("AccordoCooperazione",ac.getStatoPackage(),null);

  1211.         try{

  1213.             // Controlli di visibilita
  1214.             if(ac.getPrivato()==null || ac.getPrivato()==false){
  1215.                 if(ac.getSoggettoReferente()!=null){
  1216.                     IDSoggetto idS = new IDSoggetto(ac.getSoggettoReferente().getTipo(),ac.getSoggettoReferente().getNome());
  1217.                     try{
  1218.                         Soggetto s = this.driver.getSoggetto(idS);
  1219.                         if(s.getPrivato()!=null && s.getPrivato()){
  1220.                             erroreValidazione.addErroreValidazione("soggetto referente ["+idS+"] con visibilita' privata, in un accordo di cooperazione con visibilita' pubblica");
  1221.                         }
  1222.                     }catch(DriverRegistroServiziNotFound dNot){}
  1223.                 }
  1224.             }
  1225.             if(ac.getElencoPartecipanti()!=null){
  1226.                 AccordoCooperazionePartecipanti partecipanti = ac.getElencoPartecipanti();
  1227.                 if(partecipanti.sizeSoggettoPartecipanteList()>=2){
  1228.                     for(int i=0; i<partecipanti.sizeSoggettoPartecipanteList(); i++){
  1229.                         IdSoggetto idSoggettoPartecipante = partecipanti.getSoggettoPartecipante(i);
  1230.                         if(idSoggettoPartecipante.getIdSoggetto()!=null && idSoggettoPartecipante.getIdSoggetto()>0){
  1231.                             try{
  1232.                                 Soggetto s = this.driver.getSoggetto(partecipanti.getSoggettoPartecipante(i).getIdSoggetto());
  1233.                                 if(s.getPrivato()!=null && s.getPrivato()){
  1234.                                     erroreValidazione.addErroreValidazione("soggetto partecipante ["+s.getTipo()+"/"+s.getNome()+"] con visibilita' privata, in un accordo di cooperazione con visibilita' pubblica");
  1235.                                 }
  1236.                             }catch(DriverRegistroServiziNotFound dNot){}
  1237.                         }
  1238.                         else if(idSoggettoPartecipante.getTipo()!=null && idSoggettoPartecipante.getNome()!=null){
  1239.                             try{
  1240.                                 Soggetto s = this.driver.getSoggetto(new IDSoggetto(idSoggettoPartecipante.getTipo(), idSoggettoPartecipante.getNome()));
  1241.                                 if(s.getPrivato()!=null && s.getPrivato()){
  1242.                                     erroreValidazione.addErroreValidazione("soggetto partecipante ["+s.getTipo()+"/"+s.getNome()+"] con visibilita' privata, in un accordo di cooperazione con visibilita' pubblica");
  1243.                                 }
  1244.                             }catch(DriverRegistroServiziNotFound dNot){}
  1245.                         }
  1246.                     }
  1247.                 }
  1248.             }

  1250.             // Controlli di stato
  1251.             if(StatiAccordo.bozza.toString().equals(ac.getStatoPackage()) == false){

  1253.                 // Validazione necessaria sia ad uno stato operativo che finale
  1254.                 if(ac.getElencoPartecipanti()==null){
  1255.                     erroreValidazione.addErroreValidazione("soggetti partecipanti non definiti");   
  1256.                 }
  1257.                 else if(ac.getElencoPartecipanti().sizeSoggettoPartecipanteList()<=0){
  1258.                     erroreValidazione.addErroreValidazione("soggetti partecipanti non definiti");   
  1259.                 }else{
  1260.                     if(ac.getElencoPartecipanti().sizeSoggettoPartecipanteList()<2){
  1261.                         erroreValidazione.addErroreValidazione("almeno 2 soggetti partecipanti devono essere definiti");    
  1262.                     }
  1263.                 }

  1265.             }

  1267.         }catch(Exception e){
  1268.             throw new ValidazioneStatoPackageException(e);
  1269.         }

  1271.         if(erroreValidazione.sizeErroriValidazione()>0){
  1272.             throw erroreValidazione;
  1273.         }
  1274.     }
  1275. }
Created with JaCoCo 0.8.8.202204050719