DriverRegistroServiziDB_accordiParteSpecificaFruitoreDriver.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.SQLException;
  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.commons.ISearch;
  35. import org.openspcoop2.core.commons.Liste;
  36. import org.openspcoop2.core.commons.SearchUtils;
  37. import org.openspcoop2.core.constants.CostantiDB;
  38. import org.openspcoop2.core.constants.ProprietariProtocolProperty;
  39. import org.openspcoop2.core.id.IDServizio;
  40. import org.openspcoop2.core.id.IDSoggetto;
  41. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  42. import org.openspcoop2.core.registry.Fruitore;
  43. import org.openspcoop2.core.registry.ProtocolProperty;
  44. import org.openspcoop2.core.registry.Soggetto;
  45. import org.openspcoop2.core.registry.constants.CostantiRegistroServizi;
  46. import org.openspcoop2.core.registry.constants.CredenzialeTipo;
  47. import org.openspcoop2.core.registry.constants.PddTipologia;
  48. import org.openspcoop2.core.registry.constants.StatiAccordo;
  49. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  50. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  51. import org.openspcoop2.core.registry.driver.ValidazioneStatoPackageException;
  52. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  53. import org.openspcoop2.utils.sql.ISQLQueryObject;
  54. import org.openspcoop2.utils.sql.SQLObjectFactory;

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

  67.     private DriverRegistroServiziDB driver = null;
  68.     
  69.     protected DriverRegistroServiziDB_accordiParteSpecificaFruitoreDriver(DriverRegistroServiziDB driver) {
  70.         this.driver = driver;
  71.     }
  72.     
  73.     

  75.     protected long getServizioFruitore(IDServizio idServizio, long idSogg) throws DriverRegistroServiziException {

  77.         long idFru = 0;
  78.         Connection connection;
  79.         PreparedStatement stm = null;
  80.         ResultSet rs = null;
  81.         if (this.driver.atomica) {
  82.             try {
  83.                 connection = this.driver.getConnectionFromDatasource("getServizioFruitore");
  84.             } catch (Exception e) {
  85.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::getServizioWithSoggettoAccordoServCorr] Exception accedendo al datasource :" + e.getMessage(),e);

  87.             }

  89.         } else
  90.             connection = this.driver.globalConnection;

  92.         this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  93.         try {
  94.             long idServ = 0;
  95.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  96.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  97.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  98.             sqlQueryObject.addSelectField(CostantiDB.SERVIZI+".id");
  99.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".nome_servizio = ?");
  100.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".tipo_servizio = ?");
  101.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".versione_servizio = ?");
  102.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".id_soggetto = "+CostantiDB.SOGGETTI+".id");
  103.             sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".nome_soggetto = ?");
  104.             sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".tipo_soggetto = ?");
  105.             sqlQueryObject.setANDLogicOperator(true);
  106.             String sqlQuery = sqlQueryObject.createSQLQuery();
  107.             stm = connection.prepareStatement(sqlQuery);
  108.             stm.setString(1, idServizio.getNome());
  109.             stm.setString(2, idServizio.getTipo());
  110.             stm.setInt(3, idServizio.getVersione());
  111.             stm.setString(4, idServizio.getSoggettoErogatore().getNome());
  112.             stm.setString(5, idServizio.getSoggettoErogatore().getTipo());
  113.             rs = stm.executeQuery();
  114.             if (rs.next())
  115.                 idServ = rs.getLong("id");
  116.             rs.close();
  117.             stm.close();

  119.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  120.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  121.             sqlQueryObject.addSelectField("*");
  122.             sqlQueryObject.addWhereCondition("id_servizio = ?");
  123.             sqlQueryObject.addWhereCondition("id_soggetto = ?");
  124.             sqlQueryObject.setANDLogicOperator(true);
  125.             sqlQuery = sqlQueryObject.createSQLQuery();
  126.             stm = connection.prepareStatement(sqlQuery);
  127.             stm.setLong(1, idServ);
  128.             stm.setLong(2, idSogg);
  129.             rs = stm.executeQuery();
  130.             if (rs.next())
  131.                 idFru = rs.getLong("id");
  132.             rs.close();
  133.             stm.close();
  134.         } catch (Exception e) {
  135.             throw new DriverRegistroServiziException(e.getMessage(),e);
  136.         } finally {

  138.             JDBCUtilities.closeResources(rs, stm);

  140.             this.driver.closeConnection(connection);
  141.         }

  143.         return idFru;
  144.     }

  146.     protected long getServizioFruitoreSoggettoFruitoreID(long idServizioFruitore) throws DriverRegistroServiziException {

  148.         long idSoggFru = 0;
  149.         Connection connection;
  150.         PreparedStatement stm = null;
  151.         ResultSet rs = null;
  152.         if (this.driver.atomica) {
  153.             try {
  154.                 connection = this.driver.getConnectionFromDatasource("getServizioFruitoreSoggettoFruitoreID");
  155.             } catch (Exception e) {
  156.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::getServizioFruitoreSoggettoFruitoreID] Exception accedendo al datasource :" + e.getMessage(),e);

  158.             }

  160.         } else
  161.             connection = this.driver.globalConnection;

  163.         this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  164.         try {
  165.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  166.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  167.             sqlQueryObject.addSelectField("id_soggetto");
  168.             sqlQueryObject.addWhereCondition("id = ?");
  169.             String sqlQuery = sqlQueryObject.createSQLQuery();
  170.             stm = connection.prepareStatement(sqlQuery);
  171.             stm.setLong(1, idServizioFruitore);
  172.             rs = stm.executeQuery();
  173.             if (rs.next())
  174.                 idSoggFru = rs.getLong("id_soggetto");
  175.             rs.close();
  176.             stm.close();
  177.         } catch (Exception e) {
  178.             throw new DriverRegistroServiziException(e.getMessage(),e);
  179.         } finally {

  181.             JDBCUtilities.closeResources(rs, stm);

  183.             this.driver.closeConnection(connection);
  184.         }

  186.         return idSoggFru;
  187.     }

  189.     protected long getServizioFruitoreServizioID(long idServizioFruitore) throws DriverRegistroServiziException {

  191.         long idServ = 0;
  192.         Connection connection;
  193.         PreparedStatement stm = null;
  194.         ResultSet rs = null;
  195.         if (this.driver.atomica) {
  196.             try {
  197.                 connection = this.driver.getConnectionFromDatasource("getServizioFruitoreServizioID");
  198.             } catch (Exception e) {
  199.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::getServizioFruitoreServizioID] Exception accedendo al datasource :" + e.getMessage(),e);

  201.             }

  203.         } else
  204.             connection = this.driver.globalConnection;

  206.         this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  207.         try {
  208.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  209.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  210.             sqlQueryObject.addSelectField("id_servizio");
  211.             sqlQueryObject.addWhereCondition("id = ?");
  212.             String sqlQuery = sqlQueryObject.createSQLQuery();
  213.             stm = connection.prepareStatement(sqlQuery);
  214.             stm.setLong(1, idServizioFruitore);
  215.             rs = stm.executeQuery();
  216.             if (rs.next())
  217.                 idServ = rs.getLong("id_servizio");
  218.             rs.close();
  219.             stm.close();
  220.         } catch (Exception e) {
  221.             throw new DriverRegistroServiziException(e.getMessage(),e);
  222.         } finally {

  224.             JDBCUtilities.closeResources(rs, stm);

  226.             this.driver.closeConnection(connection);
  227.         }

  229.         return idServ;
  230.     }

  232.     
  233.     protected boolean existFruizioniServiziSoggettoWithoutConnettore(long idSoggetto, boolean escludiSoggettiEsterni) throws DriverRegistroServiziException {
  234.         if (idSoggetto <= 0)
  235.             throw new DriverRegistroServiziException("idSoggetto non valido.");

  237.         Connection con = null;
  238.         PreparedStatement stm = null;
  239.         ResultSet rs = null;
  240.         boolean trovatoServ = false;
  241.         
  242.         try {
  243.             if (this.driver.atomica) {
  244.                 try {
  245.                     con = this.driver.getConnectionFromDatasource("existFruizioniWithoutConnettore");
  246.                 } catch (Exception e) {
  247.                     throw new DriverRegistroServiziException("Exception accedendo al datasource :" + e.getMessage(), e);

  249.                 }

  251.             } else
  252.                 con = this.driver.globalConnection;

  254.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  255.             
  256.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  257.             if(escludiSoggettiEsterni){
  258.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  259.                 sqlQueryObject.addFromTable(CostantiDB.PDD);
  260.             }
  261.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  262.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  263.             sqlQueryObject.addFromTable(CostantiDB.CONNETTORI, "cservizio");
  264.             sqlQueryObject.addFromTable(CostantiDB.CONNETTORI, "cfruizione");
  265.             sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI+".id");
  266.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI + ".id_soggetto = ?");
  267.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI + ".id_connettore = cservizio.id");
  268.             sqlQueryObject.addWhereCondition("cservizio.endpointtype = ?");
  269.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_servizio = "+CostantiDB.SERVIZI+".id");
  270.             if(escludiSoggettiEsterni){
  271.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_soggetto = "+CostantiDB.SOGGETTI+".id");
  272.                 sqlQueryObject.addWhereIsNotNullCondition(CostantiDB.SOGGETTI + ".server");
  273.                 sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI + ".server = "+CostantiDB.PDD+".nome");
  274.                 sqlQueryObject.addWhereCondition(false,CostantiDB.PDD + ".tipo = ?",CostantiDB.PDD + ".tipo = ?");
  275.             }
  276.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_connettore = cfruizione.id");
  277.             sqlQueryObject.addWhereCondition("cfruizione.endpointtype = ?");
  278.             sqlQueryObject.setANDLogicOperator(true);
  279.             String sqlQuery = sqlQueryObject.createSQLQuery();
  280.             stm = con.prepareStatement(sqlQuery);
  281.             int index = 1;
  282.             stm.setLong(index++, idSoggetto);
  283.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(CostantiRegistroServizi.DISABILITATO));
  284.             if(escludiSoggettiEsterni){
  285.                 stm.setString(index++, PddTipologia.OPERATIVO.toString());
  286.                 stm.setString(index++, PddTipologia.NONOPERATIVO.toString());
  287.             }
  288.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(CostantiRegistroServizi.DISABILITATO));
  289.             rs = stm.executeQuery();
  290.             if (rs.next())
  291.                 trovatoServ = true;

  293.             return trovatoServ;
  294.         } catch (Exception qe) {
  295.             throw new DriverRegistroServiziException("Errore durante existFruizioniWithoutConnettore: " + qe.getMessage(), qe);
  296.         } finally {
  297.             JDBCUtilities.closeResources(rs, stm);

  299.             this.driver.closeConnection(con);
  300.         }
  301.     }

  303.     protected boolean existFruizioniServizioWithoutConnettore(long idServizio, boolean escludiSoggettiEsterni) throws DriverRegistroServiziException {
  304.         if (idServizio <= 0)
  305.             throw new DriverRegistroServiziException("idServizio non valido.");

  307.         Connection con = null;
  308.         PreparedStatement stm = null;
  309.         ResultSet rs = null;
  310.         boolean trovatoServ = false;

  312.         if (this.driver.atomica) {
  313.             try {
  314.                 con = this.driver.getConnectionFromDatasource("existFruizioniServizioWithoutConnettore");
  315.             } catch (Exception e) {
  316.                 throw new DriverRegistroServiziException("Exception accedendo al datasource :" + e.getMessage(), e);

  318.             }

  320.         } else
  321.             con = this.driver.globalConnection;

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

  325.         try {
  326.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  327.             if(escludiSoggettiEsterni){
  328.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  329.                 sqlQueryObject.addFromTable(CostantiDB.PDD);
  330.             }
  331.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  332.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  333.             sqlQueryObject.addFromTable(CostantiDB.CONNETTORI, "cfruizione");
  334.             sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI+".id");
  335.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI + ".id = ?");
  336.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_servizio = "+CostantiDB.SERVIZI+".id");
  337.             if(escludiSoggettiEsterni){
  338.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_soggetto = "+CostantiDB.SOGGETTI+".id");
  339.                 sqlQueryObject.addWhereIsNotNullCondition(CostantiDB.SOGGETTI + ".server");
  340.                 sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI + ".server = "+CostantiDB.PDD+".nome");
  341.                 sqlQueryObject.addWhereCondition(false,CostantiDB.PDD + ".tipo = ?",CostantiDB.PDD + ".tipo = ?");
  342.             }
  343.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_connettore = cfruizione.id");
  344.             sqlQueryObject.addWhereCondition("cfruizione.endpointtype = ?");
  345.             sqlQueryObject.setANDLogicOperator(true);
  346.             String sqlQuery = sqlQueryObject.createSQLQuery();
  347.             stm = con.prepareStatement(sqlQuery);
  348.             int index = 1;
  349.             stm.setLong(index++, idServizio);
  350.             if(escludiSoggettiEsterni){
  351.                 stm.setString(index++, PddTipologia.OPERATIVO.toString());
  352.                 stm.setString(index++, PddTipologia.NONOPERATIVO.toString());
  353.             }
  354.             stm.setString(index++, DriverRegistroServiziDB_LIB.getValue(CostantiRegistroServizi.DISABILITATO));
  355.             rs = stm.executeQuery();
  356.             if (rs.next())
  357.                 trovatoServ = true;

  359.             return trovatoServ;
  360.         } catch (Exception qe) {
  361.             throw new DriverRegistroServiziException("Errore durante existFruizioniServizioWithoutConnettore: " + qe.getMessage(), qe);
  362.         } finally {
  363.             JDBCUtilities.closeResources(rs, stm);
  364.             
  365.             this.driver.closeConnection(con);
  366.         }
  367.     }
  368.     
  369.     
  370.     protected List<AccordoServizioParteSpecifica> servizioWithSoggettoFruitore(IDSoggetto idSoggetto) throws DriverRegistroServiziException {
  371.         String nomeMetodo = "servizioWithSoggettoFruitore";

  373.         String queryString;

  375.         Connection con = null;
  376.         PreparedStatement stmt = null;
  377.         ResultSet risultato = null;

  379.         ArrayList<AccordoServizioParteSpecifica> idServizi = new ArrayList<AccordoServizioParteSpecifica>();

  381.         if (this.driver.atomica) {
  382.             try {
  383.                 con = this.driver.getConnectionFromDatasource("servizioWithSoggettoFruitore");

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

  388.             }

  390.         } else
  391.             con = this.driver.globalConnection;

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

  395.         try {
  396.             ISQLQueryObject sqlQueryObjectSoggetti = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  397.             sqlQueryObjectSoggetti.addFromTable(CostantiDB.SOGGETTI);
  398.             sqlQueryObjectSoggetti.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  399.             sqlQueryObjectSoggetti.addFromTable(CostantiDB.SERVIZI);
  400.             sqlQueryObjectSoggetti.setSelectDistinct(true);
  401.             sqlQueryObjectSoggetti.addSelectAliasField(CostantiDB.SERVIZI, "id","idServizio");
  402.             sqlQueryObjectSoggetti.addWhereCondition(CostantiDB.SERVIZI_FRUITORI+".id_servizio="+CostantiDB.SERVIZI+".id");
  403.             sqlQueryObjectSoggetti.addWhereCondition(CostantiDB.SERVIZI_FRUITORI+".id_soggetto="+CostantiDB.SOGGETTI+".id");
  404.             sqlQueryObjectSoggetti.addWhereCondition(CostantiDB.SOGGETTI+".tipo_soggetto=?");
  405.             sqlQueryObjectSoggetti.addWhereCondition(CostantiDB.SOGGETTI+".nome_soggetto=?");
  406.             sqlQueryObjectSoggetti.setANDLogicOperator(true);
  407.             queryString = sqlQueryObjectSoggetti.createSQLQuery();

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

  411.             stmt = con.prepareStatement(queryString);
  412.             stmt.setString(1,idSoggetto.getTipo());
  413.             stmt.setString(2,idSoggetto.getNome());
  414.             risultato = stmt.executeQuery();

  416.             while (risultato.next()) {

  418.                 long idServizioLong = risultato.getLong("idServizio");
  419.                 AccordoServizioParteSpecifica serv = this.driver.getAccordoServizioParteSpecifica(idServizioLong);
  420.                 Soggetto s = this.driver.getSoggetto(serv.getIdSoggetto());
  421.                 serv.setTipoSoggettoErogatore(s.getTipo());
  422.                 serv.setNomeSoggettoErogatore(s.getNome());

  424.                 idServizi.add(serv);

  426.             }

  428.         } catch (Exception se) {

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

  433.             //Chiudo statement and resultset
  434.             JDBCUtilities.closeResources(risultato, stmt);

  436.             this.driver.closeConnection(con);
  437.         }


  440.         return idServizi;
  441.     }
  442.     
  443.     

  445.     protected Fruitore getAccordoErogatoreFruitore(long id) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  446.         this.driver.logDebug("richiesto getAccordoErogatoreFruitore: " + id);
  447.         // conrollo consistenza
  448.         if (id <= 0)
  449.             return null;

  451.         org.openspcoop2.core.registry.Fruitore fruitore = null;
  452.         Connection con = null;
  453.         PreparedStatement stm = null;
  454.         ResultSet rs = null;

  456.         try {
  457.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  458.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  459.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  460.             sqlQueryObject.addSelectField("*");
  461.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI+".id = ?");
  462.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI+".id_soggetto = "+CostantiDB.SOGGETTI+".id");
  463.             sqlQueryObject.setANDLogicOperator(true);
  464.             String sqlQuery = sqlQueryObject.createSQLQuery();

  466.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  467.             // prendo la connessione dal pool
  468.             if (this.driver.atomica)
  469.                 con = this.driver.getConnectionFromDatasource("getAccordoErogatoreFruitore");
  470.             else
  471.                 con = this.driver.globalConnection;

  473.             stm = con.prepareStatement(sqlQuery);

  475.             stm.setLong(1, id);

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

  480.             if (rs.next()) {
  481.                 fruitore = new org.openspcoop2.core.registry.Fruitore();

  483.                 fruitore.setId(id);
  484.                 fruitore.setTipo(rs.getString(CostantiDB.SOGGETTI + ".tipo_soggetto"));
  485.                 fruitore.setNome(rs.getString(CostantiDB.SOGGETTI + ".nome_soggetto"));
  486.                 long idConnettore = rs.getLong(CostantiDB.SOGGETTI + "id_connettore");
  487.                 fruitore.setConnettore(this.driver.getConnettore(idConnettore, con));
  488.             } else {
  489.                 throw new DriverRegistroServiziNotFound("[DriverRegistroServiziDB::getAccordoErogatoreFruitore] rs.next non ha restituito valori con la seguente interrogazione :\n" + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, id));
  490.             }

  492.             return fruitore;

  494.         } catch (SQLException se) {
  495.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getAccordoErogatoreFruitore] SQLException :" + se.getMessage(),se);
  496.         }catch (DriverRegistroServiziNotFound e) {
  497.             throw e;
  498.         }catch (Exception se) {
  499.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getAccordoErogatoreFruitore] Exception :" + se.getMessage(),se);
  500.         } finally {

  502.             JDBCUtilities.closeResources(rs, stm);

  504.             this.driver.closeConnection(con);

  506.         }
  507.     }

  509.     protected Fruitore getErogatoreFruitore(long id) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  510.         this.driver.logDebug("richiesto getErogatoreFruitore: " + id);
  511.         // conrollo consistenza
  512.         if (id <= 0)
  513.             return null;

  515.         org.openspcoop2.core.registry.Fruitore fruitore = null;
  516.         Connection con = null;
  517.         PreparedStatement stm = null;
  518.         ResultSet rs = null;

  520.         try {
  521.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  522.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  523.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  524.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI + ".tipo_soggetto");
  525.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI + ".nome_soggetto");
  526.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI + ".id_connettore");
  527.             sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI+".stato");
  528.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI+".id = ?");
  529.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI+".id_soggetto = "+CostantiDB.SOGGETTI+".id");
  530.             sqlQueryObject.setANDLogicOperator(true);
  531.             String sqlQuery = sqlQueryObject.createSQLQuery();

  533.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  534.             // prendo la connessione dal pool
  535.             if (this.driver.atomica)
  536.                 con = this.driver.getConnectionFromDatasource("getErogatoreFruitore");
  537.             else
  538.                 con = this.driver.globalConnection;

  540.             stm = con.prepareStatement(sqlQuery);

  542.             stm.setLong(1, id);

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

  547.             if (rs.next()) {
  548.                 fruitore = new org.openspcoop2.core.registry.Fruitore();

  550.                 fruitore.setId(id);
  551.                 fruitore.setTipo(rs.getString("tipo_soggetto"));
  552.                 fruitore.setNome(rs.getString("nome_soggetto"));
  553.                 fruitore.setStatoPackage(rs.getString("stato"));
  554.                 long idConnettore = rs.getLong("id_connettore");
  555.                 fruitore.setConnettore(this.driver.getConnettore(idConnettore, con));
  556.             } else {
  557.                 throw new DriverRegistroServiziNotFound("[DriverRegistroServiziDB::getErogatoreFruitore] rs.next non ha restituito valori con la seguente interrogazione :\n" + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, id));
  558.             }

  560.             return fruitore;

  562.         } catch (SQLException se) {
  563.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getErogatoreFruitore] SQLException :" + se.getMessage(),se);
  564.         }catch (DriverRegistroServiziNotFound e) {
  565.             throw e;
  566.         }catch (Exception se) {
  567.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getErogatoreFruitore] Exception :" + se.getMessage(),se);
  568.         } finally {

  570.             JDBCUtilities.closeResources(rs, stm);

  572.             this.driver.closeConnection(con);

  574.         }
  575.     }
  576.     
  577.     protected Fruitore getServizioFruitore(long idServFru) throws DriverRegistroServiziException {
  578.         String nomeMetodo = "getServizioFruitore";
  579.         String queryString;

  581.         Connection con = null;
  582.         PreparedStatement stmt = null;
  583.         ResultSet risultato = null;

  585.         //ArrayList<Fruitore> lista = new ArrayList<Fruitore>();

  587.         if (this.driver.atomica) {
  588.             try {
  589.                 con = this.driver.getConnectionFromDatasource("getServizioFruitore");

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

  594.             }

  596.         } else
  597.             con = this.driver.globalConnection;

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

  601.         try {
  602.             // ricavo le entries
  603.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  604.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  605.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  606.             sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI+".id");
  607.             sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI+".id_soggetto");
  608.             sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI+".id_servizio");
  609.             sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI+".id_connettore");
  610.             sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI+".wsdl_implementativo_erogatore");
  611.             sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI+".wsdl_implementativo_fruitore");
  612.             sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI+".stato");
  613.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI+".nome_soggetto");
  614.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI+".tipo_soggetto");
  615.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI+".id = ?");
  616.             sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".id = "+CostantiDB.SERVIZI_FRUITORI+".id_soggetto");
  617.             sqlQueryObject.setANDLogicOperator(true);
  618.             queryString = sqlQueryObject.createSQLQuery();
  619.             stmt = con.prepareStatement(queryString);
  620.             stmt.setLong(1, idServFru);
  621.             risultato = stmt.executeQuery();

  623.             Fruitore f = null;
  624.             if (risultato.next()) {

  626.                 f = new Fruitore();

  628.                 f.setId(risultato.getLong("id"));
  629.                 f.setIdSoggetto(risultato.getLong("id_soggetto"));
  630.                 f.setIdServizio(risultato.getLong("id_servizio"));
  631.                 f.setNome(risultato.getString("nome_soggetto"));
  632.                 f.setTipo(risultato.getString("tipo_soggetto"));
  633.                 long idConnettore = risultato.getLong("id_connettore");
  634.                 f.setConnettore(this.driver.getConnettore(idConnettore, con));
  635.                 f.setByteWsdlImplementativoErogatore(risultato.getString("wsdl_implementativo_erogatore")!=null && !risultato.getString("wsdl_implementativo_erogatore").trim().equals("") ? risultato.getString("wsdl_implementativo_erogatore").trim().getBytes() : null);
  636.                 f.setByteWsdlImplementativoFruitore(risultato.getString("wsdl_implementativo_fruitore")!=null && !risultato.getString("wsdl_implementativo_fruitore").trim().equals("") ? risultato.getString("wsdl_implementativo_fruitore").trim().getBytes() : null);
  637.                 f.setStatoPackage(risultato.getString("stato"));
  638.                 
  639.                 // Protocol Properties
  640.                 try{
  641.                     List<ProtocolProperty> listPP = DriverRegistroServiziDB_LIB.getListaProtocolProperty(f.getId(), ProprietariProtocolProperty.FRUITORE, con, 
  642.                             this.driver.tipoDB, this.driver.getDriverUnwrapBYOK());
  643.                     if(listPP!=null && !listPP.isEmpty()){
  644.                         for (ProtocolProperty protocolProperty : listPP) {
  645.                             f.addProtocolProperty(protocolProperty);
  646.                         }
  647.                     }
  648.                 }catch(DriverRegistroServiziNotFound dNotFound){
  649.                     // ignore
  650.                 }
  651.             }

  653.             return f;

  655.         } catch (Exception se) {

  657.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  658.         } finally {
  659.             //Chiudo statement and resultset
  660.             JDBCUtilities.closeResources(risultato, stmt);
  661.             this.driver.closeConnection(con);
  662.         }
  663.     }

  665.     
  666.     protected List<Fruitore> serviziFruitoriList(long idServizi, ISearch ricerca) throws DriverRegistroServiziException {
  667.         String nomeMetodo = "serviziFruitoriList";
  668.         int idLista = Liste.SERVIZI_FRUITORI;
  669.         int offset;
  670.         int limit;
  671.         String search;
  672.         String queryString;

  674.         limit = ricerca.getPageSize(idLista);
  675.         offset = ricerca.getIndexIniziale(idLista);
  676.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));

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

  680.         this.driver.logDebug("search : " + search);
  681.         this.driver.logDebug("filterStatoAccordo : " + filterStatoAccordo);
  682.         

  684.         Connection con = null;
  685.         PreparedStatement stmt = null;
  686.         ResultSet risultato = null;

  688.         ArrayList<Fruitore> lista = null;

  690.         if (this.driver.atomica) {
  691.             try {
  692.                 con = this.driver.getConnectionFromDatasource("serviziFruitoriList");

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

  697.             }

  699.         } else {
  700.             con = this.driver.globalConnection;
  701.         }

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

  705.         try {

  707.             if (!search.equals("")) {
  708.                 //query con search
  709.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  710.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  711.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  712.                 sqlQueryObject.addSelectCountField("*", "cont");
  713.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_servizio = ?");
  714.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_soggetto = " + CostantiDB.SOGGETTI + ".id");
  715.                 sqlQueryObject.addWhereCondition(false, 
  716.                         sqlQueryObject.getWhereLikeCondition(CostantiDB.SOGGETTI + ".nome_soggetto",search,true,true)); 
  717.                         //sqlQueryObject.getWhereLikeCondition(CostantiDB.SOGGETTI + ".tipo_soggetto",search,true,true));
  718.                 if(filterStatoAccordo!=null && !filterStatoAccordo.equals("")) {
  719.                     sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".stato = ?");
  720.                 }
  721.                 sqlQueryObject.setANDLogicOperator(true);
  722.                 queryString = sqlQueryObject.createSQLQuery();
  723.             } else {
  724.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  725.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  726.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  727.                 sqlQueryObject.addSelectCountField("*", "cont");
  728.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_servizio = ?");
  729.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_soggetto = " + CostantiDB.SOGGETTI + ".id");
  730.                 if(filterStatoAccordo!=null && !filterStatoAccordo.equals("")) {
  731.                     sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".stato = ?");
  732.                 }
  733.                 sqlQueryObject.setANDLogicOperator(true);
  734.                 queryString = sqlQueryObject.createSQLQuery();
  735.             } 
  736.             stmt = con.prepareStatement(queryString);
  737.             int index = 1;
  738.             stmt.setLong(index++, idServizi);
  739.             if(filterStatoAccordo!=null && !filterStatoAccordo.equals("")) {
  740.                 stmt.setString(index++, filterStatoAccordo);
  741.             }
  742.             risultato = stmt.executeQuery();
  743.             if (risultato.next()) {
  744.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  745.             }
  746.             risultato.close();
  747.             stmt.close();

  749.             // ricavo le entries
  750.             if (limit == 0) {
  751.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  752.             }
  753.             if (!search.equals("")) {
  754.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  755.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  756.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  757.                 sqlQueryObject.addSelectAliasField(CostantiDB.SERVIZI_FRUITORI,"id","idFruitore");
  758.                 sqlQueryObject.addSelectAliasField(CostantiDB.SERVIZI_FRUITORI,"stato","statoFruitore");
  759.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI + ".tipo_soggetto");
  760.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI + ".nome_soggetto");
  761.                 sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI + ".id_servizio");
  762.                 sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI + ".id_soggetto");
  763.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI + ".id");
  764.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_servizio = ?");
  765.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_soggetto = " + CostantiDB.SOGGETTI + ".id");
  766.                 sqlQueryObject.addWhereCondition(false, 
  767.                         sqlQueryObject.getWhereLikeCondition(CostantiDB.SOGGETTI + ".nome_soggetto",search,true,true)); 
  768.                         //sqlQueryObject.getWhereLikeCondition(CostantiDB.SOGGETTI + ".tipo_soggetto",search,true,true));
  769.                 if(filterStatoAccordo!=null && !filterStatoAccordo.equals("")) {
  770.                     sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".stato = ?");
  771.                 }
  772.                 sqlQueryObject.setANDLogicOperator(true);
  773.                 sqlQueryObject.addOrderBy(CostantiDB.SOGGETTI + ".tipo_soggetto");
  774.                 sqlQueryObject.addOrderBy(CostantiDB.SOGGETTI + ".nome_soggetto");
  775.                 sqlQueryObject.setSortType(true);
  776.                 sqlQueryObject.setLimit(limit);
  777.                 sqlQueryObject.setOffset(offset);
  778.                 queryString = sqlQueryObject.createSQLQuery();
  779.             } else {
  780.                 // senza search
  781.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  782.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  783.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  784.                 sqlQueryObject.addSelectAliasField(CostantiDB.SERVIZI_FRUITORI,"id","idFruitore");
  785.                 sqlQueryObject.addSelectAliasField(CostantiDB.SERVIZI_FRUITORI,"stato","statoFruitore");
  786.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI + ".tipo_soggetto");
  787.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI + ".nome_soggetto");
  788.                 sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI + ".id_servizio");
  789.                 sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI + ".id_soggetto");
  790.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI + ".id");
  791.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_servizio = ?");
  792.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_soggetto = " + CostantiDB.SOGGETTI + ".id");
  793.                 if(filterStatoAccordo!=null && !filterStatoAccordo.equals("")) {
  794.                     sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".stato = ?");
  795.                 }
  796.                 sqlQueryObject.setANDLogicOperator(true);
  797.                 sqlQueryObject.addOrderBy(CostantiDB.SOGGETTI + ".tipo_soggetto");
  798.                 sqlQueryObject.addOrderBy(CostantiDB.SOGGETTI + ".nome_soggetto");
  799.                 sqlQueryObject.setSortType(true);
  800.                 sqlQueryObject.setLimit(limit);
  801.                 sqlQueryObject.setOffset(offset);
  802.                 queryString = sqlQueryObject.createSQLQuery();
  803.             }
  804.             stmt = con.prepareStatement(queryString);
  805.             index = 1;
  806.             stmt.setLong(index++, idServizi);
  807.             if(filterStatoAccordo!=null && !filterStatoAccordo.equals("")) {
  808.                 stmt.setString(index++, filterStatoAccordo);
  809.             }
  810.             risultato = stmt.executeQuery();

  812.             Fruitore f;
  813.             lista = new ArrayList<Fruitore>();
  814.             while (risultato.next()) {
  815.                 f = new Fruitore();

  817.                 f.setId(risultato.getLong("idFruitore"));
  818.                 f.setNome(risultato.getString("nome_soggetto"));
  819.                 f.setTipo(risultato.getString("tipo_soggetto"));
  820.                 f.setIdSoggetto(risultato.getLong("id_soggetto"));
  821.                 f.setIdServizio(risultato.getLong("id_servizio"));
  822.                 f.setStatoPackage(risultato.getString("statoFruitore"));

  824.                 lista.add(f);
  825.             }

  827.             return lista;

  829.         } catch (Exception se) {

  831.             throw new DriverRegistroServiziException("[DriverControlStationDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  832.         } finally {
  833.             //Chiudo statement and resultset
  834.             JDBCUtilities.closeResources(risultato, stmt);
  835.             this.driver.closeConnection(con);
  836.         }

  838.     }
  839.     
  840.     protected long getIdServizioFruitore(long idServizio, long idSoggetto) throws DriverRegistroServiziException {
  841.         long idFru = 0;
  842.         Connection connection;
  843.         PreparedStatement stm = null;
  844.         ResultSet rs = null;
  845.         if (this.driver.atomica) {
  846.             try {
  847.                 connection = this.driver.getConnectionFromDatasource("getIdServizioFruitore");
  848.             } catch (Exception e) {
  849.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::getIdServizioFruitore] Exception accedendo al datasource :" + e.getMessage(),e);

  851.             }

  853.         } else
  854.             connection = this.driver.globalConnection;

  856.         this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  857.         try {
  858.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  859.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  860.             sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI + ".id");
  861.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_servizio = ?");
  862.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_soggetto = ?");
  863.             sqlQueryObject.setANDLogicOperator(true);
  864.             String sqlQuery = sqlQueryObject.createSQLQuery();
  865.             stm = connection.prepareStatement(sqlQuery);
  866.             stm.setLong(1, idServizio);
  867.             stm.setLong(2, idSoggetto);
  868.             rs = stm.executeQuery();
  869.             if (rs.next())
  870.                 idFru = rs.getLong("id");
  871.             rs.close();
  872.             stm.close();
  873.         } catch (Exception e) {
  874.             throw new DriverRegistroServiziException(e.getMessage(),e);
  875.         } finally {

  877.             JDBCUtilities.closeResources(rs, stm);

  879.             this.driver.closeConnection(connection);
  880.         }

  882.         return idFru;
  883.     }

  885.     protected List<Fruitore> getServiziFruitoriWithServizio(long idServizio) throws DriverRegistroServiziException {
  886.         String nomeMetodo = "getServiziFruitoriWithServizio";
  887.         String queryString;

  889.         Connection con = null;
  890.         PreparedStatement stmt = null;
  891.         ResultSet risultato = null;

  893.         ArrayList<Fruitore> lista = null;

  895.         if (this.driver.atomica) {
  896.             try {
  897.                 con = this.driver.getConnectionFromDatasource("getServiziFruitoriWithServizio");

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

  902.             }

  904.         } else {
  905.             con = this.driver.globalConnection;
  906.         }

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

  910.         try {

  912.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  913.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  914.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  915.             sqlQueryObject.setSelectDistinct(true);
  916.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI + ".tipo_soggetto");
  917.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI + ".nome_soggetto");
  918.             sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI + ".id = " + CostantiDB.SERVIZI_FRUITORI + ".id_soggetto");
  919.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_servizio = ?");
  920.             sqlQueryObject.setANDLogicOperator(true);
  921.             queryString = sqlQueryObject.createSQLQuery();
  922.             stmt = con.prepareStatement(queryString);
  923.             stmt.setLong(1, idServizio);
  924.             risultato = stmt.executeQuery();

  926.             Fruitore f;
  927.             lista = new ArrayList<Fruitore>();
  928.             while (risultato.next()) {

  930.                 f = new Fruitore();

  932.                 f.setNome(risultato.getString("nome_soggetto"));
  933.                 f.setTipo(risultato.getString("tipo_soggetto"));

  935.                 lista.add(f);
  936.             }

  938.             return lista;

  940.         } catch (Exception se) {

  942.             throw new DriverRegistroServiziException("[DriverControlStationDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  943.         } finally {
  944.             //Chiudo statement and resultset
  945.             JDBCUtilities.closeResources(risultato, stmt);
  946.             this.driver.closeConnection(con);
  947.         }

  949.     }
  950.     
  951.     protected List<AccordoServizioParteSpecifica> getServiziByFruitore(Fruitore fruitore) throws DriverRegistroServiziException {
  952.         String nomeMetodo = "getServiziByFruitore";
  953.         String queryString;

  955.         Connection con = null;
  956.         PreparedStatement stmt = null;
  957.         ResultSet risultato = null;

  959.         ArrayList<AccordoServizioParteSpecifica> lista = null;

  961.         if (this.driver.atomica) {
  962.             try {
  963.                 con = this.driver.getConnectionFromDatasource("getServiziByFruitore");

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

  968.             }

  970.         } else {
  971.             con = this.driver.globalConnection;
  972.         }

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

  976.         try {

  978.             long idFruitore = DBUtils.getIdSoggetto(fruitore.getNome(), fruitore.getTipo(), con, this.driver.tipoDB);

  980.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  981.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  982.             sqlQueryObject.addWhereCondition("id_soggetto = ?");
  983.             sqlQueryObject.setANDLogicOperator(true);
  984.             queryString = sqlQueryObject.createSQLQuery();
  985.             stmt = con.prepareStatement(queryString);
  986.             stmt.setLong(1, idFruitore);
  987.             risultato = stmt.executeQuery();

  989.             lista = new ArrayList<AccordoServizioParteSpecifica>();
  990.             while (risultato.next()) {
  991.                 long id=risultato.getLong("id");
  992.                 AccordoServizioParteSpecifica se=this.driver.getAccordoServizioParteSpecifica(id, con);
  993.                 lista.add(se);
  994.             }

  996.             return lista;

  998.         } catch (Exception se) {

  1000.             throw new DriverRegistroServiziException("[DriverControlStationDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1001.         } finally {
  1002.             //Chiudo statement and resultset
  1003.             JDBCUtilities.closeResources(risultato, stmt);
  1004.             this.driver.closeConnection(con);
  1005.         }

  1007.     }

  1009.     protected List<Fruitore> getSoggettiWithServizioNotFruitori(long idServizio, boolean escludiSoggettiEsterni, CredenzialeTipo credenzialeTipo) throws DriverRegistroServiziException {
  1010.         String nomeMetodo = "getSoggettiWithServizioNotFruitori";
  1011.         String queryString;

  1013.         Connection con = null;
  1014.         PreparedStatement stmt = null;
  1015.         ResultSet risultato = null;

  1017.         ArrayList<Fruitore> lista = new ArrayList<Fruitore>();

  1019.         if (this.driver.atomica) {
  1020.             try {
  1021.                 con = this.driver.getConnectionFromDatasource("getSoggettiWithServizioNotFruitori");

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

  1026.             }

  1028.         } else {
  1029.             con = this.driver.globalConnection;
  1030.         }

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

  1034.         try {

  1036.             // Condizione where not
  1037.             ISQLQueryObject sqlQueryObjectWhere = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1038.             sqlQueryObjectWhere.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  1039.             sqlQueryObjectWhere.addSelectField("*");
  1040.             sqlQueryObjectWhere.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_soggetto = " + CostantiDB.SOGGETTI + ".id");
  1041.             sqlQueryObjectWhere.addWhereCondition(CostantiDB.SERVIZI_FRUITORI + ".id_servizio = ?");
  1042.             sqlQueryObjectWhere.setANDLogicOperator(true);

  1044.             // Query
  1045.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1046.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1047.             if(escludiSoggettiEsterni){
  1048.                 sqlQueryObject.addFromTable(CostantiDB.PDD);
  1049.             }
  1050.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI + ".id");
  1051.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI + ".tipo_soggetto");
  1052.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI + ".nome_soggetto");
  1053.             if(escludiSoggettiEsterni){
  1054.                 sqlQueryObject.addWhereIsNotNullCondition(CostantiDB.SOGGETTI + ".server");
  1055.                 sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI + ".server = "+CostantiDB.PDD+".nome");
  1056.                 sqlQueryObject.addWhereCondition(false,CostantiDB.PDD + ".tipo = ?",CostantiDB.PDD + ".tipo = ?");
  1057.             }
  1058.             if(credenzialeTipo!=null){
  1059.                 sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI + ".tipoauth = ?");
  1060.             }
  1061.             sqlQueryObject.addWhereExistsCondition(true, sqlQueryObjectWhere);
  1062.             sqlQueryObject.setSelectDistinct(true);
  1063.             sqlQueryObject.setANDLogicOperator(true);
  1064.             sqlQueryObject.addOrderBy(CostantiDB.SOGGETTI + ".tipo_soggetto");
  1065.             sqlQueryObject.addOrderBy(CostantiDB.SOGGETTI + ".nome_soggetto");
  1066.             queryString = sqlQueryObject.createSQLQuery();
  1067.             stmt = con.prepareStatement(queryString);
  1068.             int index = 1;
  1069.             if(escludiSoggettiEsterni){
  1070.                 stmt.setString(index++, PddTipologia.OPERATIVO.toString());
  1071.                 stmt.setString(index++, PddTipologia.NONOPERATIVO.toString());
  1072.             }
  1073.             if(credenzialeTipo!=null){
  1074.                 stmt.setString(index++, credenzialeTipo.getValue());
  1075.             }
  1076.             stmt.setLong(index++, idServizio);
  1077.             risultato = stmt.executeQuery();

  1079.             Fruitore f;
  1080.             while (risultato.next()) {
  1081.                 f = new Fruitore();

  1083.                 f.setId(risultato.getLong("id"));
  1084.                 f.setNome(risultato.getString("nome_soggetto"));
  1085.                 f.setTipo(risultato.getString("tipo_soggetto"));

  1087.                 lista.add(f);
  1088.             }

  1090.             return lista;

  1092.         } catch (Exception se) {

  1094.             throw new DriverRegistroServiziException("[DriverControlStationDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1095.         } finally {
  1096.             //Chiudo statement and resultset
  1097.             JDBCUtilities.closeResources(risultato, stmt);
  1098.             this.driver.closeConnection(con);
  1099.         }

  1101.     }
  1102.     
  1103.     protected void validaStatoFruitoreServizio(Fruitore fruitore,AccordoServizioParteSpecifica serv) throws ValidazioneStatoPackageException{

  1105.         ValidazioneStatoPackageException erroreValidazione =
  1106.                 new ValidazioneStatoPackageException("FruitoreServizio",fruitore.getStatoPackage(),null);

  1108.         try{

  1110.             // Controlli di stato
  1111.             if(StatiAccordo.bozza.toString().equals(fruitore.getStatoPackage()) == false){

  1113.                 String uriAPS = this.driver.idServizioFactory.getUriFromAccordo(serv);
  1114.                 
  1115.                 if(StatiAccordo.operativo.toString().equals(fruitore.getStatoPackage())){
  1116.                     if(StatiAccordo.finale.toString().equals(serv.getStatoPackage())==false && StatiAccordo.operativo.toString().equals(serv.getStatoPackage())==false){
  1117.                         erroreValidazione.addErroreValidazione("servizio riferito ["+uriAPS+"] possiede lo stato ["+serv.getStatoPackage()+"]");
  1118.                     }
  1119.                 }
  1120.                 
  1121.                 else if(StatiAccordo.finale.toString().equals(fruitore.getStatoPackage())){

  1123.                     if(StatiAccordo.finale.toString().equals(serv.getStatoPackage())==false){
  1124.                         erroreValidazione.addErroreValidazione("servizio ["+uriAPS+"] in uno stato non finale ["+serv.getStatoPackage()+"]");
  1125.                     }
  1126.                 }

  1128.             }

  1130.         }catch(Exception e){
  1131.             throw new ValidazioneStatoPackageException(e);
  1132.         }

  1134.         if(erroreValidazione.sizeErroriValidazione()>0){
  1135.             throw erroreValidazione;
  1136.         }
  1137.     }
  1138. }
Created with JaCoCo 0.8.8.202204050719