DriverRegistroServiziDB_soggettiDriver.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;
  33. import java.util.Map;

  35. import org.apache.commons.lang.StringUtils;
  36. import org.openspcoop2.core.byok.IDriverBYOK;
  37. import org.openspcoop2.core.commons.DBUtils;
  38. import org.openspcoop2.core.commons.ErrorsHandlerCostant;
  39. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  40. import org.openspcoop2.core.constants.CostantiDB;
  41. import org.openspcoop2.core.constants.ProprietariProtocolProperty;
  42. import org.openspcoop2.core.id.IDSoggetto;
  43. import org.openspcoop2.core.registry.AccordoCooperazione;
  44. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  45. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  46. import org.openspcoop2.core.registry.Connettore;
  47. import org.openspcoop2.core.registry.CredenzialiSoggetto;
  48. import org.openspcoop2.core.registry.Proprieta;
  49. import org.openspcoop2.core.registry.ProtocolProperty;
  50. import org.openspcoop2.core.registry.RuoliSoggetto;
  51. import org.openspcoop2.core.registry.Ruolo;
  52. import org.openspcoop2.core.registry.RuoloSoggetto;
  53. import org.openspcoop2.core.registry.Soggetto;
  54. import org.openspcoop2.core.registry.constants.CostantiRegistroServizi;
  55. import org.openspcoop2.core.registry.constants.CredenzialeTipo;
  56. import org.openspcoop2.core.registry.constants.StatiAccordo;
  57. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  58. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  59. import org.openspcoop2.core.registry.driver.FiltroRicercaSoggetti;
  60. import org.openspcoop2.utils.certificate.ArchiveLoader;
  61. import org.openspcoop2.utils.certificate.ArchiveType;
  62. import org.openspcoop2.utils.certificate.Certificate;
  63. import org.openspcoop2.utils.certificate.CertificateUtils;
  64. import org.openspcoop2.utils.certificate.PrincipalType;
  65. import org.openspcoop2.utils.crypt.CryptConfig;
  66. import org.openspcoop2.utils.crypt.CryptFactory;
  67. import org.openspcoop2.utils.crypt.ICrypt;
  68. import org.openspcoop2.utils.jdbc.IJDBCAdapter;
  69. import org.openspcoop2.utils.jdbc.JDBCAdapterFactory;
  70. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  71. import org.openspcoop2.utils.sql.ISQLQueryObject;
  72. import org.openspcoop2.utils.sql.SQLObjectFactory;

  74. /**
  75.  * DriverRegistroServiziDB_soggettiDriver
  76.  * 
  77.  * 
  78.  * @author Sandra Giangrandi (sandra@link.it)
  79.  * @author Stefano Corallo (corallo@link.it)
  80.  * @author $Author$
  81.  * @version $Rev$, $Date$
  82.  */
  83. public class DriverRegistroServiziDB_soggettiDriver {

  85.     private DriverRegistroServiziDB driver = null;
  86.     private DriverRegistroServiziDB_protocolPropertiesDriver protocolPropertiesDriver = null;
  87.     
  88.     protected DriverRegistroServiziDB_soggettiDriver(DriverRegistroServiziDB driver) {
  89.         this.driver = driver;
  90.         this.protocolPropertiesDriver = new DriverRegistroServiziDB_protocolPropertiesDriver(driver);
  91.     }
  92.     
  93.     protected org.openspcoop2.core.registry.Soggetto getSoggetto(IDSoggetto idSoggetto) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  94.         // conrollo consistenza
  95.         if (idSoggetto == null)
  96.             throw new DriverRegistroServiziException("[getSoggetto] Parametro idSoggetto is null");

  98.         String nomeSogg = idSoggetto.getNome();
  99.         String tipoSogg = idSoggetto.getTipo();

  101.         if (nomeSogg == null || nomeSogg.trim().equals("") || tipoSogg == null || tipoSogg.trim().equals(""))
  102.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getSoggetto] : soggetto non specificato.");

  104.         long idSoggettoLong;

  106.         Connection con = null;
  107.         PreparedStatement stm = null;
  108.         ResultSet rs = null;

  110.         if (this.driver.atomica) {
  111.             try {
  112.                 con = this.driver.getConnectionFromDatasource("getSoggetto(idSoggetto)");

  114.             } catch (Exception e) {
  115.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::getSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);

  117.             }

  119.         } else
  120.             con = this.driver.globalConnection;

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

  124.         try {
  125.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  126.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  127.             sqlQueryObject.addSelectField("id");
  128.             sqlQueryObject.addWhereCondition("nome_soggetto = ?");
  129.             sqlQueryObject.addWhereCondition("tipo_soggetto = ?");
  130.             sqlQueryObject.setANDLogicOperator(true);
  131.             String sqlQuery = sqlQueryObject.createSQLQuery();

  133.             stm = con.prepareStatement(sqlQuery);

  135.             stm.setString(1, nomeSogg);
  136.             stm.setString(2, tipoSogg);

  138.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, nomeSogg, tipoSogg));
  139.             rs = stm.executeQuery();

  141.             if (rs.next()) {
  142.                 idSoggettoLong = rs.getLong("id");
  143.                 
  144.             }else{
  145.                 throw new DriverRegistroServiziNotFound("Nessun soggetto trovato eseguendo: "+DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, nomeSogg, tipoSogg));
  146.             }
  147.             
  148.         }catch (DriverRegistroServiziNotFound e) {
  149.             throw e;
  150.         } catch (SQLException se) {

  152.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getSoggetto] SqlException: " + se.getMessage(),se);
  153.         }catch (Exception se) {

  155.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getSoggetto] Exception: " + se.getMessage(),se);
  156.         } finally {
  157.             JDBCUtilities.closeResources(rs, stm);
  158.             this.driver.closeConnection(con);
  159.         }
  160.         
  161.         return this.getSoggetto(idSoggettoLong);
  162.     }

  164.     
  165.     protected Soggetto getSoggetto(long idSoggetto) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  166.         return getSoggetto(idSoggetto,null);
  167.     }
  168.     protected Soggetto getSoggetto(long idSoggetto,Connection conParam) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {

  170.         // conrollo consistenza
  171.         if (idSoggetto <= 0)
  172.             return null;

  174.         Soggetto soggetto = null;

  176.         Connection con = null;
  177.         PreparedStatement stm = null;
  178.         ResultSet rs = null;

  180.         if(conParam!=null){
  181.             con = conParam;
  182.         }
  183.         else if (this.driver.atomica) {
  184.             try {
  185.                 con = this.driver.getConnectionFromDatasource("getSoggetto(longId)");

  187.             } catch (Exception e) {
  188.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::getSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);

  190.             }

  192.         } else
  193.             con = this.driver.globalConnection;

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

  197.         try {
  198.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  199.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  200.             sqlQueryObject.addSelectField("*");
  201.             sqlQueryObject.addWhereCondition("id = ?");
  202.             String sqlQuery = sqlQueryObject.createSQLQuery();

  204.             stm = con.prepareStatement(sqlQuery);

  206.             stm.setLong(1, idSoggetto);

  208.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idSoggetto));
  209.             rs = stm.executeQuery();

  211.             if (rs.next()) {
  212.                 soggetto = new Soggetto();

  214.                 soggetto.setId(rs.getLong("id"));

  216.                 String nomeSogg = rs.getString("nome_soggetto");
  217.                 soggetto.setNome(nomeSogg);

  219.                 String tipoSogg = rs.getString("tipo_soggetto");
  220.                 soggetto.setTipo(tipoSogg);

  222.                 String tmp = rs.getString("descrizione");
  223.                 soggetto.setDescrizione(((tmp == null || tmp.equals("")) ? null : tmp));

  225.                 tmp = rs.getString("identificativo_porta");
  226.                 soggetto.setIdentificativoPorta(((tmp == null || tmp.equals("")) ? null : tmp));

  228.                 tmp = rs.getString("server");
  229.                 soggetto.setPortaDominio(((tmp == null || tmp.equals("")) ? null : tmp));

  231.                 tmp = rs.getString("superuser");
  232.                 soggetto.setSuperUser(((tmp == null || tmp.equals("")) ? null : tmp));

  234.                 if(rs.getInt("privato")==1)
  235.                     soggetto.setPrivato(true);
  236.                 else
  237.                     soggetto.setPrivato(false);

  239.                 tmp = rs.getString("codice_ipa");
  240.                 soggetto.setCodiceIpa(((tmp == null || tmp.equals("")) ? null : tmp));

  242.                 //  Ora Registrazione
  243.                 if(rs.getTimestamp("ora_registrazione")!=null){
  244.                     soggetto.setOraRegistrazione(new Date(rs.getTimestamp("ora_registrazione").getTime()));
  245.                 }

  247.                 long idConnettore = rs.getLong("id_connettore");
  248.                 Connettore connettore = this.driver.getConnettore(idConnettore, con);

  250.                 String profilo = rs.getString("profilo");
  251.                 if(profilo!=null){
  252.                     profilo = profilo.trim();
  253.                     soggetto.setVersioneProtocollo(profilo);
  254.                 }

  256.                 String tipoAuth = rs.getString("tipoauth");
  257.                 if(tipoAuth != null && !tipoAuth.equals("")){
  258.                     CredenzialiSoggetto credenziali = new CredenzialiSoggetto();
  259.                     credenziali.setTipo(DriverRegistroServiziDB_LIB.getEnumCredenzialeTipo(tipoAuth));
  260.                     
  261.                     credenziali.setUser(rs.getString("utente"));        
  262.                     credenziali.setPassword(rs.getString("password"));
  263.                     
  264.                     if(org.openspcoop2.core.registry.constants.CredenzialeTipo.APIKEY.equals(credenziali.getTipo())) {
  265.                         credenziali.setAppId(CostantiDB.isAPPID(rs.getString("issuer")));
  266.                     }
  267.                     else {
  268.                         credenziali.setIssuer(rs.getString("issuer"));
  269.                     }
  270.                     credenziali.setSubject(rs.getString("subject"));
  271.                     credenziali.setCnSubject(rs.getString("cn_subject"));
  272.                     credenziali.setCnIssuer(rs.getString("cn_issuer"));
  273.                     IJDBCAdapter jdbcAdapter = JDBCAdapterFactory.createJDBCAdapter(this.driver.tipoDB);
  274.                     credenziali.setCertificate(jdbcAdapter.getBinaryData(rs, "certificate"));
  275.                     int strict = rs.getInt("cert_strict_verification");
  276.                     if(strict == CostantiDB.TRUE) {
  277.                         credenziali.setCertificateStrictVerification(true);
  278.                     }
  279.                     else if(strict == CostantiDB.FALSE) {
  280.                         credenziali.setCertificateStrictVerification(false);
  281.                     }
  282.                                 
  283.                     soggetto.addCredenziali( credenziali );
  284.                 }
  285.                 
  286.                 // aggiungo connettore
  287.                 soggetto.setConnettore(connettore);

  289.                 // Proprieta Oggetto
  290.                 soggetto.setProprietaOggetto(DriverRegistroServiziDB_utilsDriver.readProprietaOggetto(rs,false));
  291.                 
  292.                 rs.close();
  293.                 stm.close();
  294.                 
  295.                 
  296.                 // RUOLI
  297.                 
  298.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  299.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI_RUOLI);
  300.                 sqlQueryObject.addSelectField("*");
  301.                 sqlQueryObject.addWhereCondition("id_soggetto = ?");
  302.                 sqlQueryObject.setANDLogicOperator(true);
  303.                 sqlQuery = sqlQueryObject.createSQLQuery();
  304.                 stm = con.prepareStatement(sqlQuery);
  305.                 stm.setLong(1, soggetto.getId());
  306.                 this.driver.logDebug("eseguo query ruoli: " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, soggetto.getId()));
  307.                 rs = stm.executeQuery();
  308.                 while (rs.next()) {
  309.                     if(soggetto.getRuoli()==null){
  310.                         soggetto.setRuoli(new RuoliSoggetto());
  311.                     }   
  312.                     RuoloSoggetto ruolo = new RuoloSoggetto();
  313.                     ruolo.setId(rs.getLong("id_ruolo"));
  314.                     soggetto.getRuoli().addRuolo(ruolo);
  315.                 }
  316.                 rs.close();
  317.                 stm.close();
  318.                 
  319.                 if(soggetto.getRuoli()!=null && soggetto.getRuoli().sizeRuoloList()>0){
  320.                     for (int i = 0; i < soggetto.getRuoli().sizeRuoloList(); i++) {
  321.                         Ruolo ruolo = this.driver.getRuolo(con,soggetto.getRuoli().getRuolo(i).getId());
  322.                         soggetto.getRuoli().getRuolo(i).setNome(ruolo.getNome());
  323.                     }
  324.                 }
  325.                 
  326.                 
  327.                 // CREDENZIALI
  328.                 
  329.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  330.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI_CREDENZIALI);
  331.                 sqlQueryObject.addSelectField("*");
  332.                 sqlQueryObject.addWhereCondition("id_soggetto = ?");
  333.                 sqlQueryObject.setANDLogicOperator(true);
  334.                 sqlQueryObject.addOrderBy("id", true);
  335.                 sqlQuery = sqlQueryObject.createSQLQuery();
  336.                 stm = con.prepareStatement(sqlQuery);
  337.                 stm.setLong(1, soggetto.getId());
  338.                 this.driver.logDebug("eseguo query credenziali: " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, soggetto.getId()));
  339.                 rs = stm.executeQuery();
  340.                 while (rs.next()) {
  341.                     CredenzialiSoggetto credenziali = new CredenzialiSoggetto();
  342.                     credenziali.setTipo(DriverRegistroServiziDB_LIB.getEnumCredenzialeTipo(tipoAuth));
  343.                     
  344.                     credenziali.setIssuer(rs.getString("issuer"));
  345.                     credenziali.setSubject(rs.getString("subject"));
  346.                     credenziali.setCnSubject(rs.getString("cn_subject"));
  347.                     credenziali.setCnIssuer(rs.getString("cn_issuer"));
  348.                     IJDBCAdapter jdbcAdapter = JDBCAdapterFactory.createJDBCAdapter(this.driver.tipoDB);
  349.                     credenziali.setCertificate(jdbcAdapter.getBinaryData(rs, "certificate"));
  350.                     int strict = rs.getInt("cert_strict_verification");
  351.                     if(strict == CostantiDB.TRUE) {
  352.                         credenziali.setCertificateStrictVerification(true);
  353.                     }
  354.                     else if(strict == CostantiDB.FALSE) {
  355.                         credenziali.setCertificateStrictVerification(false);
  356.                     }
  357.                                 
  358.                     soggetto.addCredenziali( credenziali );
  359.                 }
  360.                 rs.close();
  361.                 stm.close();
  362.                 
  363.                 
  364.                 // PROPERTIES
  365.                 
  366.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  367.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI_PROPS);
  368.                 sqlQueryObject.addSelectField("*");
  369.                 sqlQueryObject.addWhereCondition("id_soggetto = ?");
  370.                 sqlQueryObject.setANDLogicOperator(true);
  371.                 sqlQuery = sqlQueryObject.createSQLQuery();
  372.                 stm = con.prepareStatement(sqlQuery);
  373.                 stm.setLong(1, soggetto.getId());
  374.                 this.driver.logDebug("eseguo query ruoli: " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, soggetto.getId()));
  375.                 rs = stm.executeQuery();
  376.                 while (rs.next()) {
  377.                     
  378.                     Proprieta proprieta = new Proprieta();
  379.                     proprieta.setNome(rs.getString("nome"));
  380.                     
  381.                     String plainValue = rs.getString("valore");
  382.                     String encValue = rs.getString("enc_value");
  383.                     if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  384.                         IDriverBYOK driverBYOK = this.driver.getDriverUnwrapBYOK();
  385.                         if(driverBYOK!=null) {
  386.                             proprieta.setValore(driverBYOK.unwrapAsString(encValue));
  387.                         }
  388.                         else {
  389.                             proprieta.setValore(encValue);
  390.                         }
  391.                     }
  392.                     else {
  393.                         proprieta.setValore(plainValue);
  394.                     }
  395.                     
  396.                     soggetto.addProprieta(proprieta);

  398.                 }
  399.                 rs.close();
  400.                 stm.close();
  401.                 
  402.                 
  403.                 
  404.             }else{
  405.                 throw new DriverRegistroServiziNotFound("Nessun risultato trovato eseguendo: "+DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idSoggetto));
  406.             }

  408.             // Protocol Properties
  409.             try{
  410.                 List<ProtocolProperty> listPP = DriverRegistroServiziDB_LIB.getListaProtocolProperty(soggetto.getId(), ProprietariProtocolProperty.SOGGETTO, con, 
  411.                         this.driver.tipoDB, this.driver.getDriverUnwrapBYOK());
  412.                 if(listPP!=null && !listPP.isEmpty()){
  413.                     for (ProtocolProperty protocolProperty : listPP) {
  414.                         soggetto.addProtocolProperty(protocolProperty);
  415.                     }
  416.                 }
  417.             }catch(DriverRegistroServiziNotFound dNotFound){
  418.                 // ignore
  419.             }
  420.             
  421.             return soggetto;
  422.         } catch (SQLException se) {
  423.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getSoggetto] SqlException: " + se.getMessage(),se);
  424.         }catch (DriverRegistroServiziNotFound se) {
  425.             throw se;
  426.         }catch (Exception se) {
  427.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getSoggetto] Exception: " + se.getMessage(),se);
  428.         } finally {

  430.             //Chiudo statement and resultset
  431.             JDBCUtilities.closeResources(rs, stm);

  433.             this.driver.closeConnection(conParam, con);
  434.         }
  435.     }
  436.     
  437.     
  438.     
  439.     protected List<IDSoggetto> getAllIdSoggetti(FiltroRicercaSoggetti filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  440.         Connection con = null;
  441.         PreparedStatement stm = null;
  442.         ResultSet rs = null;

  444.         this.driver.logDebug("getAllIdSoggettiRegistro...");

  446.         Certificate certificatoFiltro = null;
  447.         try {
  448.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  449.             // prendo la connessione dal pool
  450.             if (this.driver.atomica)
  451.                 con = this.driver.getConnectionFromDatasource("getAllIdSoggetti");
  452.             else
  453.                 con = this.driver.globalConnection;

  455.             boolean testInChiaro = false;
  456.             ICrypt crypt = null;
  457.             if(filtroRicerca!=null && filtroRicerca.getCredenzialiSoggetto()!=null && filtroRicerca.getCredenzialiSoggetto().getPassword()!=null){
  458.                 CredenzialeTipo cTipo = filtroRicerca.getCredenzialiSoggetto().getTipo();
  459.                 if(CredenzialeTipo.BASIC.equals(cTipo)){
  460.                     CryptConfig config = filtroRicerca.getCryptConfig();
  461.                     if(config==null || config.isBackwardCompatibility()) {
  462.                         testInChiaro = true;
  463.                     }
  464.                     if(config!=null) {
  465.                         try {
  466.                             crypt = CryptFactory.getCrypt(this.driver.log, config);
  467.                         }catch(Exception e) {
  468.                             throw new DriverRegistroServiziException(e.getMessage(),e);
  469.                         }
  470.                     }
  471.                 }
  472.                 else if(CredenzialeTipo.APIKEY.equals(cTipo)){
  473.                     CryptConfig config = filtroRicerca.getCryptConfig();
  474.                     if(config!=null) {
  475.                         try {
  476.                             crypt = CryptFactory.getCrypt(this.driver.log, config);
  477.                         }catch(Exception e) {
  478.                             throw new DriverRegistroServiziException(e.getMessage(),e);
  479.                         }
  480.                     }
  481.                     else {
  482.                         testInChiaro = true;
  483.                     }
  484.                 }
  485.             }
  486.             
  487.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  488.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  489.             if(filtroRicerca!=null){
  490.                 if(filtroRicerca.getIdRuolo()!=null){
  491.                     sqlQueryObject.addFromTable(CostantiDB.SOGGETTI_RUOLI);
  492.                     sqlQueryObject.addFromTable(CostantiDB.RUOLI);
  493.                 }
  494.             }
  495.             sqlQueryObject.setSelectDistinct(true);
  496.             sqlQueryObject.addSelectField("tipo_soggetto");
  497.             sqlQueryObject.addSelectField("nome_soggetto");
  498.             sqlQueryObject.setSelectDistinct(true);
  499.             if(filtroRicerca!=null){
  500.                 // Filtro By Data
  501.                 if(filtroRicerca.getMinDate()!=null)
  502.                     sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".ora_registrazione > ?");
  503.                 if(filtroRicerca.getMaxDate()!=null)
  504.                     sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".ora_registrazione < ?");
  505.                 // Filtro By Tipo e Nome
  506.                 if(filtroRicerca.getTipo()!=null)
  507.                     sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".tipo_soggetto = ?");
  508.                 if(filtroRicerca.getNome()!=null)
  509.                     sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".nome_soggetto = ?");
  510.                 // Filtro By Pdd
  511.                 if(filtroRicerca.getNomePdd()!=null)
  512.                     sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".server = ?");
  513.                 // Filtro By Ruoli
  514.                 if(filtroRicerca.getIdRuolo()!=null){
  515.                     sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI_RUOLI+".id_soggetto="+CostantiDB.SOGGETTI+".id");
  516.                     sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI_RUOLI+".id_ruolo="+CostantiDB.RUOLI+".id");
  517.                     sqlQueryObject.addWhereCondition(CostantiDB.RUOLI+".nome = ?");
  518.                 }
  519.                 // Filtro By Credenziali (per ssl vengono cercate solo nelle credenziali principali)
  520.                 if(filtroRicerca.getCredenzialiSoggetto()!=null){
  521.                     if(filtroRicerca.getCredenzialiSoggetto().getTipo()!=null){
  522.                         sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".tipoauth = ?");
  523.                         if(CredenzialeTipo.APIKEY.equals(filtroRicerca.getCredenzialiSoggetto().getTipo())){
  524.                             sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".cert_strict_verification = ?");
  525.                         }
  526.                     }
  527.                     if(filtroRicerca.getCredenzialiSoggetto().getUser()!=null){
  528.                         sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".utente = ?");
  529.                     }
  530.                     if(filtroRicerca.getCredenzialiSoggetto().getPassword()!=null){
  531.                         //sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".password = ?");
  532.                         sqlQueryObject.addSelectField(CostantiDB.SOGGETTI+".password");
  533.                     }
  534.                     if(filtroRicerca.getCredenzialiSoggetto().getSubject()!=null){
  535.                         
  536.                         // Autenticazione SSL deve essere LIKE
  537.                         Map<String, List<String>> hashSubject = CertificateUtils.getPrincipalIntoMap(filtroRicerca.getCredenzialiSoggetto().getSubject(), PrincipalType.SUBJECT);
  538.                         Map<String, List<String>> hashIssuer = null;
  539.                         if(filtroRicerca.getCredenzialiSoggetto().getIssuer()!=null) {
  540.                             hashIssuer = CertificateUtils.getPrincipalIntoMap(filtroRicerca.getCredenzialiSoggetto().getIssuer(), PrincipalType.ISSUER);
  541.                         }
  542.                         
  543.                         for (String key : hashSubject.keySet()) {
  544.                             List<String> listValues = hashSubject.get(key);
  545.                             for (String value : listValues) {
  546.                                 sqlQueryObject.addWhereLikeCondition(CostantiDB.SOGGETTI+".subject", "/"+CertificateUtils.formatKeyPrincipal(key)+"="+CertificateUtils.formatValuePrincipal(value)+"/", true, true, false);
  547.                             }
  548.                             
  549.                             sqlQueryObject.addSelectField("subject");
  550.                         }
  551.                         
  552.                         if(hashIssuer!=null) {
  553.                             for (String key : hashIssuer.keySet()) {
  554.                                 List<String> listValues = hashIssuer.get(key);
  555.                                 for (String value : listValues) {
  556.                                     sqlQueryObject.addWhereLikeCondition(CostantiDB.SOGGETTI+".issuer", "/"+CertificateUtils.formatKeyPrincipal(key)+"="+CertificateUtils.formatValuePrincipal(value)+"/", true, true, false);
  557.                                 }
  558.                             }
  559.                             
  560.                             sqlQueryObject.addSelectField("issuer");
  561.                         }
  562.                         else {
  563.                             sqlQueryObject.addWhereIsNullCondition("issuer");
  564.                         }
  565.                         
  566.                     }
  567.                     if(filtroRicerca.getCredenzialiSoggetto().getCertificate()!=null){
  568.                         sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".cn_subject = ?");
  569.                         sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".cn_issuer = ?");
  570.                         sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".cert_strict_verification = ?");
  571.                         
  572.                         sqlQueryObject.addSelectField("certificate");
  573.                     }
  574.                 }
  575.                 DBUtils.setPropertiesForSearch(sqlQueryObject, filtroRicerca.getProprieta(), CostantiDB.SOGGETTI, CostantiDB.SOGGETTI_PROPS, "nome", "valore", "id_soggetto");
  576.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(sqlQueryObject, filtroRicerca, CostantiDB.SOGGETTI);
  577.             }

  579.             sqlQueryObject.setANDLogicOperator(true);
  580.             String sqlQuery = sqlQueryObject.createSQLQuery();
  581.             this.driver.logDebug("eseguo query : " + sqlQuery );
  582.             stm = con.prepareStatement(sqlQuery);
  583.             int indexStmt = 1;
  584.             if(filtroRicerca!=null){
  585.                 if(filtroRicerca.getMinDate()!=null){
  586.                     this.driver.logDebug("minDate stmt.setTimestamp("+filtroRicerca.getMinDate()+")");
  587.                     stm.setTimestamp(indexStmt, new Timestamp(filtroRicerca.getMinDate().getTime()));
  588.                     indexStmt++;
  589.                 }
  590.                 if(filtroRicerca.getMaxDate()!=null){
  591.                     this.driver.logDebug("maxDate stmt.setTimestamp("+filtroRicerca.getMaxDate()+")");
  592.                     stm.setTimestamp(indexStmt, new Timestamp(filtroRicerca.getMaxDate().getTime()));
  593.                     indexStmt++;
  594.                 }   
  595.                 if(filtroRicerca.getTipo()!=null){
  596.                     this.driver.logDebug("tipoSoggetto stmt.setString("+filtroRicerca.getTipo()+")");
  597.                     stm.setString(indexStmt, filtroRicerca.getTipo());
  598.                     indexStmt++;
  599.                 }
  600.                 if(filtroRicerca.getNome()!=null){
  601.                     this.driver.logDebug("nomeSoggetto stmt.setString("+filtroRicerca.getNome()+")");
  602.                     stm.setString(indexStmt, filtroRicerca.getNome());
  603.                     indexStmt++;
  604.                 }   
  605.                 if(filtroRicerca.getNomePdd()!=null){
  606.                     this.driver.logDebug("nomePdD stmt.setString("+filtroRicerca.getNomePdd()+")");
  607.                     stm.setString(indexStmt, filtroRicerca.getNomePdd());
  608.                     indexStmt++;
  609.                 }
  610.                 if(filtroRicerca.getIdRuolo()!=null){
  611.                     this.driver.logDebug("ruolo stmt.setString("+filtroRicerca.getIdRuolo().getNome()+")");
  612.                     stm.setString(indexStmt, filtroRicerca.getIdRuolo().getNome());
  613.                     indexStmt++;
  614.                 }
  615.                 if(filtroRicerca.getCredenzialiSoggetto()!=null){
  616.                     if(filtroRicerca.getCredenzialiSoggetto().getTipo()!=null){
  617.                         this.driver.logDebug("credenziali.tipo stmt.setString("+filtroRicerca.getCredenzialiSoggetto().getTipo().getValue()+")");
  618.                         stm.setString(indexStmt, filtroRicerca.getCredenzialiSoggetto().getTipo().getValue());
  619.                         indexStmt++;
  620.                         if(CredenzialeTipo.APIKEY.equals(filtroRicerca.getCredenzialiSoggetto().getTipo())){
  621.                             int v = filtroRicerca.getCredenzialiSoggetto().isCertificateStrictVerification() ?  CostantiDB.TRUE :  CostantiDB.FALSE;
  622.                             this.driver.logDebug("credenziali.certificateStrictVerification stmt.setInt("+v+")");
  623.                             stm.setInt(indexStmt, v);
  624.                             indexStmt++;
  625.                         }
  626.                     }
  627.                     if(filtroRicerca.getCredenzialiSoggetto().getUser()!=null){
  628.                         this.driver.logDebug("credenziali.user stmt.setString("+filtroRicerca.getCredenzialiSoggetto().getUser()+")");
  629.                         stm.setString(indexStmt, filtroRicerca.getCredenzialiSoggetto().getUser());
  630.                         indexStmt++;
  631.                     }
  632. //                  if(filtroRicerca.getCredenzialiSoggetto().getPassword()!=null){
  633. //                      this.driver.logDebug("credenziali.password stmt.setString("+filtroRicerca.getCredenzialiSoggetto().getPassword()+")");
  634. //                      stm.setString(indexStmt, filtroRicerca.getCredenzialiSoggetto().getPassword());
  635. //                      indexStmt++;
  636. //                  }
  637.                     if(filtroRicerca.getCredenzialiSoggetto().getSubject()!=null){
  638.                         // nop;
  639.                     }
  640.                     if(filtroRicerca.getCredenzialiSoggetto().getCertificate()!=null){
  641.                         
  642.                         certificatoFiltro = ArchiveLoader.load(ArchiveType.CER, filtroRicerca.getCredenzialiSoggetto().getCertificate(), 0, null);  
  643.                         String cnSubject = certificatoFiltro.getCertificate().getSubject().getCN();
  644.                         String cnIssuer = certificatoFiltro.getCertificate().getIssuer().getCN();
  645.                         
  646.                         stm.setString(indexStmt++, cnSubject);
  647.                         this.driver.logDebug("credenziali.cnSubject stmt.setString(" + cnSubject +")");
  648.                         stm.setString(indexStmt++, cnIssuer);
  649.                         this.driver.logDebug("credenziali.cnIssuer stmt.setString(" + cnIssuer +")");
  650.                         if(filtroRicerca.getCredenzialiSoggetto().isCertificateStrictVerification()) {
  651.                             this.driver.logDebug("credenziali.strict stmt.setInt(" + CostantiDB.TRUE +")");
  652.                             stm.setInt(indexStmt++, CostantiDB.TRUE);
  653.                         }
  654.                         else {
  655.                             this.driver.logDebug("credenziali.strict stmt.setInt(" + CostantiDB.FALSE +")");
  656.                             stm.setInt(indexStmt++, CostantiDB.FALSE);
  657.                         }
  658.                     }
  659.                 }
  660.                 DBUtils.setPropertiesForSearch(stm, indexStmt, filtroRicerca.getProprieta(), this.driver.tipoDB, this.driver.log);
  661.                 this.protocolPropertiesDriver.setProtocolPropertiesForSearch(stm, indexStmt, filtroRicerca, ProprietariProtocolProperty.SOGGETTO);
  662.             }
  663.             rs = stm.executeQuery();
  664.             List<IDSoggetto> idSoggetti = new ArrayList<IDSoggetto>();
  665.             IJDBCAdapter jdbcAdapter = JDBCAdapterFactory.createJDBCAdapter(this.driver.tipoDB);
  666.             while (rs.next()) {
  667.                 
  668.                 if(filtroRicerca!=null &&
  669.                         filtroRicerca.getCredenzialiSoggetto()!=null && 
  670.                         filtroRicerca.getCredenzialiSoggetto().getPassword()!=null){
  671.                     String passwordDB =  rs.getString("password");
  672.                     
  673.                     boolean found = false;
  674.                     if(testInChiaro) {
  675.                         found = filtroRicerca.getCredenzialiSoggetto().getPassword().equals(passwordDB);
  676.                     }
  677.                     if(!found && crypt!=null) {
  678.                         found = crypt.check(filtroRicerca.getCredenzialiSoggetto().getPassword(), passwordDB);
  679.                     }
  680.                     if( !found ) {
  681.                         continue;
  682.                     }
  683.                 }
  684.                 
  685.                 if(filtroRicerca!=null &&
  686.                         filtroRicerca.getCredenzialiSoggetto()!=null && 
  687.                         filtroRicerca.getCredenzialiSoggetto().getSubject()!=null){
  688.                 
  689.                     // Possono esistere piu' soggetti che hanno una porzione di subject uguale, devo quindi verificare che sia proprio quello che cerco
  690.                                         
  691.                     String subjectPotenziale =  rs.getString("subject");
  692.                     boolean subjectValid = CertificateUtils.sslVerify(subjectPotenziale, filtroRicerca.getCredenzialiSoggetto().getSubject(), PrincipalType.SUBJECT, this.driver.log);
  693.                     
  694.                     boolean issuerValid = true;
  695.                     if(filtroRicerca.getCredenzialiSoggetto().getIssuer()!=null) {
  696.                         String issuerPotenziale =  rs.getString("issuer");
  697.                         if(StringUtils.isNotEmpty(issuerPotenziale)) {
  698.                             issuerValid = CertificateUtils.sslVerify(issuerPotenziale, filtroRicerca.getCredenzialiSoggetto().getIssuer(), PrincipalType.ISSUER, this.driver.log);
  699.                         }
  700.                         else {
  701.                             issuerValid = false;
  702.                         }
  703.                     }
  704.                     
  705.                     if( !subjectValid || !issuerValid ) {
  706.                         continue;
  707.                     }
  708.                 }
  709.                 
  710.                 if(certificatoFiltro!=null) {

  712.                     // ricerca per certificato
  713.                     // Possono esistere piu' soggetti che hanno un CN con subject e issuer diverso.
  714.                     
  715.                     byte[] certificatoBytes = jdbcAdapter.getBinaryData(rs, "certificate");
  716.                     Certificate certificato = ArchiveLoader.load(ArchiveType.CER, certificatoBytes, 0, null);
  717.                     //int tmpStrict = rs.getInt("cert_strict_verification");
  718.                     //boolean strict = tmpStrict == CostantiDB.TRUE;
  719.                     
  720.                     if(!certificatoFiltro.getCertificate().equals(certificato.getCertificate(),filtroRicerca.getCredenzialiSoggetto().isCertificateStrictVerification())) {
  721.                         continue;
  722.                     }
  723.                 }
  724.                                 
  725.                 IDSoggetto idS = new IDSoggetto(rs.getString("tipo_soggetto"),rs.getString("nome_soggetto"));
  726.                 idSoggetti.add(idS);
  727.             }
  728.             if(idSoggetti.size()==0){
  729.                 if(filtroRicerca!=null)
  730.                     throw new DriverRegistroServiziNotFound("Soggetti non trovati che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  731.                 else
  732.                     throw new DriverRegistroServiziNotFound("Soggetti non trovati");
  733.             }else{
  734.                 return idSoggetti;
  735.             }
  736.         }catch(DriverRegistroServiziNotFound de){
  737.             throw de;
  738.         }
  739.         catch(Exception e){
  740.             throw new DriverRegistroServiziException("getAllIdSoggettiRegistro error",e);
  741.         } finally {

  743.             //Chiudo statement and resultset
  744.             JDBCUtilities.closeResources(rs, stm);

  746.             this.driver.closeConnection(con);

  748.         }
  749.     }

  751.     protected void createSoggetto(org.openspcoop2.core.registry.Soggetto soggetto) throws DriverRegistroServiziException {
  752.         if (soggetto == null)
  753.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createSoggetto] Parametro non valido.");

  755.         Connection con = null;
  756.         boolean error = false;

  758.         if (this.driver.atomica) {
  759.             try {
  760.                 con = this.driver.getConnectionFromDatasource("createSoggetto");
  761.                 con.setAutoCommit(false);
  762.             } catch (Exception e) {
  763.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);

  765.             }

  767.         } else
  768.             con = this.driver.globalConnection;

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

  772.         try {
  773.             this.driver.logDebug("CRUDSoggetto type = 1");
  774.             // creo soggetto
  775.             DriverRegistroServiziDB_soggettiLIB.CRUDSoggetto(1, soggetto, con, this.driver.tipoDB, this.driver.getDriverWrapBYOK());

  777.         } catch (Exception qe) {
  778.             error = true;
  779.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createSoggetto] Errore durante la creazione del soggetto : " + qe.getMessage(), qe);
  780.         } finally {

  782.             this.driver.closeConnection(error,con);
  783.         }
  784.     }

  786.     protected boolean existsSoggetto(IDSoggetto idSoggetto) throws DriverRegistroServiziException {
  787.         boolean exist = false;
  788.         Connection con = null;
  789.         
  790.         if (this.driver.atomica) {
  791.             try {
  792.                 con = this.driver.getConnectionFromDatasource("existsSoggetto(idSoggetto)");
  793.             } catch (Exception e) {
  794.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::existsSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);

  796.             }

  798.         } else
  799.             con = this.driver.globalConnection;

  801.         try {
  802.             exist = existsSoggetto(con, idSoggetto);

  804.         } catch (Exception e) {
  805.             exist = false;
  806.             this.driver.log.error("Errore durante verifica esistenza soggetto :", e);
  807.         } finally {

  809.             this.driver.closeConnection(con);
  810.         }

  812.         return exist;
  813.     }
  814.     protected boolean existsSoggetto(Connection conParam, IDSoggetto idSoggetto) throws DriverRegistroServiziException {
  815.         boolean exist = false;
  816.         PreparedStatement stm = null;
  817.         ResultSet rs = null;

  819.         if (idSoggetto == null)
  820.             throw new DriverRegistroServiziException("Parametro non valido");

  822.         String nome_soggetto = idSoggetto.getNome();
  823.         String tipo_soggetto = idSoggetto.getTipo();
  824.         if (nome_soggetto == null || nome_soggetto.equals(""))
  825.             throw new DriverRegistroServiziException("Parametro Nome non valido");
  826.         if (tipo_soggetto == null || tipo_soggetto.equals(""))
  827.             throw new DriverRegistroServiziException("Parametro Tipo non valido");

  829.         try {
  830.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  831.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  832.             sqlQueryObject.addSelectField("*");
  833.             sqlQueryObject.addWhereCondition("nome_soggetto = ?");
  834.             sqlQueryObject.addWhereCondition("tipo_soggetto = ?");
  835.             sqlQueryObject.setANDLogicOperator(true);
  836.             String sqlQuery = sqlQueryObject.createSQLQuery();
  837.             stm = conParam.prepareStatement(sqlQuery);
  838.             stm.setString(1, nome_soggetto);
  839.             stm.setString(2, tipo_soggetto);
  840.             rs = stm.executeQuery();
  841.             if (rs.next())
  842.                 exist = true;
  843.             rs.close();
  844.             stm.close();

  846.         } catch (Exception e) {
  847.             exist = false;
  848.             this.driver.log.error("Errore durante verifica esistenza soggetto :", e);
  849.         } finally {

  851.             //Chiudo statement and resultset
  852.             JDBCUtilities.closeResources(rs, stm);

  854.         }

  856.         return exist;
  857.     }

  859.     protected boolean existsSoggetto(long idSoggetto) throws DriverRegistroServiziException {
  860.         boolean exist = false;
  861.         Connection con = null;
  862.         PreparedStatement stm = null;
  863.         ResultSet rs = null;
  864.         if (this.driver.atomica) {
  865.             try {
  866.                 con = this.driver.getConnectionFromDatasource("existsSoggetto(longId)");
  867.             } catch (Exception e) {
  868.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::existsSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);

  870.             }

  872.         } else
  873.             con = this.driver.globalConnection;

  875.         try {
  876.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  877.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  878.             sqlQueryObject.addSelectField("*");
  879.             sqlQueryObject.addWhereCondition("id = ?");
  880.             String sqlQuery = sqlQueryObject.createSQLQuery();
  881.             stm = con.prepareStatement(sqlQuery);
  882.             stm.setLong(1, idSoggetto);
  883.             rs = stm.executeQuery();
  884.             if (rs.next())
  885.                 exist = true;
  886.             rs.close();
  887.             stm.close();

  889.         } catch (Exception e) {
  890.             exist = false;
  891.             this.driver.log.error("Errore durante verifica esistenza soggetto :", e);
  892.         } finally {
  893.             //Chiudo statement and resultset
  894.             JDBCUtilities.closeResources(rs, stm);
  895.             this.driver.closeConnection(con);
  896.         }

  898.         return exist;
  899.     }

  901.     protected boolean existsSoggetto(String codiceIPA) throws DriverRegistroServiziException {
  902.         boolean exist = false;
  903.         Connection con = null;
  904.         PreparedStatement stm = null;
  905.         ResultSet rs = null;

  907.         if (codiceIPA == null|| codiceIPA.equals(""))
  908.             throw new DriverRegistroServiziException("Parametro non valido");

  910.         if (this.driver.atomica) {
  911.             try {
  912.                 con = this.driver.getConnectionFromDatasource("existsSoggetto(codiceIPA)");
  913.             } catch (Exception e) {
  914.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::existsSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);

  916.             }

  918.         } else
  919.             con = this.driver.globalConnection;

  921.         try {
  922.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  923.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  924.             sqlQueryObject.addSelectField("*");
  925.             sqlQueryObject.addWhereCondition("codice_ipa = ?");
  926.             sqlQueryObject.setANDLogicOperator(true);
  927.             String sqlQuery = sqlQueryObject.createSQLQuery();
  928.             stm = con.prepareStatement(sqlQuery);
  929.             stm.setString(1, codiceIPA);
  930.             rs = stm.executeQuery();
  931.             if (rs.next())
  932.                 exist = true;
  933.             rs.close();
  934.             stm.close();

  936.         } catch (Exception e) {
  937.             exist = false;
  938.             this.driver.log.error("Errore durante verifica esistenza soggetto :", e);
  939.         } finally {

  941.             //Chiudo statement and resultset
  942.             JDBCUtilities.closeResources(rs, stm);

  944.             this.driver.closeConnection(con);
  945.         }

  947.         return exist;
  948.     }

  950.     protected Soggetto getSoggetto(String codiceIPA) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  951.         Connection con = null;
  952.         PreparedStatement stm = null;
  953.         ResultSet rs = null;
  954.         long idSoggetto = -1;

  956.         if (codiceIPA == null|| codiceIPA.equals(""))
  957.             throw new DriverRegistroServiziException("Parametro non valido");

  959.         if (this.driver.atomica) {
  960.             try {
  961.                 con = this.driver.getConnectionFromDatasource("getSoggetto(codiceIPA)");
  962.             } catch (Exception e) {
  963.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::existsSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);

  965.             }

  967.         } else
  968.             con = this.driver.globalConnection;

  970.         try {
  971.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  972.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  973.             sqlQueryObject.addSelectField("*");
  974.             sqlQueryObject.addWhereCondition("codice_ipa = ?");
  975.             sqlQueryObject.setANDLogicOperator(true);
  976.             String sqlQuery = sqlQueryObject.createSQLQuery();
  977.             stm = con.prepareStatement(sqlQuery);
  978.             stm.setString(1, codiceIPA);
  979.             rs = stm.executeQuery();
  980.             if (rs.next()){
  981.                 idSoggetto = rs.getLong("id");
  982.             }
  983.             rs.close();
  984.             stm.close();

  986.         } catch (Exception e) {
  987.             this.driver.log.error("Errore durante verifica esistenza soggetto :", e);
  988.         } finally {

  990.             //Chiudo statement and resultset
  991.             JDBCUtilities.closeResources(rs, stm);

  993.             this.driver.closeConnection(con);
  994.         }

  996.         if(idSoggetto<=0){
  997.             throw new DriverRegistroServiziNotFound("Soggetto con Codice IPA ["+codiceIPA+"] non trovato");
  998.         }
  999.         else{
  1000.             return this.getSoggetto(idSoggetto);
  1001.         }

  1003.     }

  1005.     protected String getCodiceIPA(IDSoggetto idSoggetto) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  1006.         Connection con = null;
  1007.         PreparedStatement stm = null;
  1008.         ResultSet rs = null;
  1009.         String codiceIPA = null;
  1010.         if (idSoggetto == null)
  1011.             throw new DriverRegistroServiziException("Parametro non valido");

  1013.         String nome_soggetto = idSoggetto.getNome();
  1014.         String tipo_soggetto = idSoggetto.getTipo();
  1015.         if (nome_soggetto == null || nome_soggetto.equals(""))
  1016.             throw new DriverRegistroServiziException("Parametro Nome non valido");
  1017.         if (tipo_soggetto == null || tipo_soggetto.equals(""))
  1018.             throw new DriverRegistroServiziException("Parametro Tipo non valido");

  1020.         if (this.driver.atomica) {
  1021.             try {
  1022.                 con = this.driver.getConnectionFromDatasource("getCodiceIPA(idSoggetto)");
  1023.             } catch (Exception e) {
  1024.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::existsSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);

  1026.             }

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

  1031.         try {
  1032.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1033.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1034.             sqlQueryObject.addSelectField("*");
  1035.             sqlQueryObject.addWhereCondition("tipo_soggetto = ?");
  1036.             sqlQueryObject.addWhereCondition("nome_soggetto = ?");
  1037.             sqlQueryObject.setANDLogicOperator(true);
  1038.             String sqlQuery = sqlQueryObject.createSQLQuery();
  1039.             stm = con.prepareStatement(sqlQuery);
  1040.             stm.setString(1, tipo_soggetto);
  1041.             stm.setString(2, nome_soggetto);
  1042.             rs = stm.executeQuery();
  1043.             if (rs.next()){
  1044.                 codiceIPA = rs.getString("codice_ipa");
  1045.             }
  1046.             rs.close();
  1047.             stm.close();

  1049.         } catch (Exception e) {
  1050.             this.driver.log.error("Errore durante verifica esistenza soggetto :", e);
  1051.         } finally {

  1053.             //Chiudo statement and resultset
  1054.             JDBCUtilities.closeResources(rs, stm);

  1056.             this.driver.closeConnection(con);
  1057.         }

  1059.         if(codiceIPA==null){
  1060.             throw new DriverRegistroServiziNotFound("Soggetto ["+tipo_soggetto+"/"+nome_soggetto+"] non trovato");
  1061.         }
  1062.         else{
  1063.             return codiceIPA;
  1064.         }

  1066.     }

  1068.     protected void updateSoggetto(org.openspcoop2.core.registry.Soggetto soggetto) throws DriverRegistroServiziException {
  1069.         if (soggetto == null)
  1070.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateSoggetto] Parametro non valido.");

  1072.         PreparedStatement stm=null;
  1073.         ResultSet rs=null;
  1074.         Connection con = null;
  1075.         boolean error = false;

  1077.         if (this.driver.atomica) {
  1078.             try {
  1079.                 con = this.driver.getConnectionFromDatasource("updateSoggetto");
  1080.                 con.setAutoCommit(false);
  1081.             } catch (Exception e) {
  1082.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);

  1084.             }

  1086.         } else
  1087.             con = this.driver.globalConnection;

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

  1091.         try {

  1093.             /**
  1094.              * L'aggiornamente del tipo/nome soggetto scatena anche l'aggiornamento del nome
  1095.              * dei connettori oltre che del soggetto stesso anche dei fruitori di servizi in cui il soggetto puo essere
  1096.              * o l'erogatore o il fruitore
  1097.              */
  1098.             String oldNomeSoggetto=null;
  1099.             String oldTipoSoggetto=null;
  1100.             if(soggetto.getOldIDSoggettoForUpdate()!=null){
  1101.                 oldNomeSoggetto = soggetto.getOldIDSoggettoForUpdate().getNome();
  1102.                 oldTipoSoggetto = soggetto.getOldIDSoggettoForUpdate().getTipo();
  1103.             }
  1104.             String nomeSoggetto=soggetto.getNome();
  1105.             String tipoSoggetto=soggetto.getTipo();

  1107.             if(tipoSoggetto==null || tipoSoggetto.equals("")) throw new DriverRegistroServiziException("Parametro Tipo Soggetto non valido.");
  1108.             if(nomeSoggetto==null || nomeSoggetto.equals("")) throw new DriverRegistroServiziException("Parametro Nome Soggetto non valido.");

  1110.             if(oldNomeSoggetto==null || oldNomeSoggetto.equals("")) oldNomeSoggetto=nomeSoggetto;
  1111.             if(oldTipoSoggetto==null || oldTipoSoggetto.equals("")) oldTipoSoggetto=tipoSoggetto;

  1113.             //se tipo o nome sono cambiati effettuo modifiche su connettore
  1114.             if(!tipoSoggetto.equals(oldTipoSoggetto) || !nomeSoggetto.equals(oldNomeSoggetto)){

  1116.                 //pattern nome connettore servizio fruitore
  1117.                 // CNT_SF_tipo/nome(fruitore del servizio)+tipo/nome(erogatore del servizio)+tipo/nome(servizio)
  1118.                 // "CNT_SF_"  + tipoFruitore  + "/" + nomeFruitore+"_"+  tipoErogatore+"/"+nomeErogatore +"_"+ tiposervizio + "/" + nomeservizio
  1119.                 //devo modificare la prima e la seconda parte del pattern
  1120.                 String regex = "CNT_SF_(.*)\\/(.*)_(.*)\\/(.*)_(.*)\\/(.*)";

  1122.                 //recupero i connettori da modificare dove il soggetto e' erogatore
  1123.                 //0 soggetti
  1124.                 //1 servizi
  1125.                 //2 servizi_fruitori
  1126.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1127.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1128.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  1129.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  1130.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI+".tipo_soggetto");
  1131.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI+".nome_soggetto");
  1132.                 sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI+".id_connettore");
  1133.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI+".id_servizio = "+CostantiDB.SERVIZI+".id");
  1134.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI+".id_soggetto = "+CostantiDB.SOGGETTI+".id");
  1135.                 sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".tipo_soggetto = ?");
  1136.                 sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".nome_soggetto = ?");
  1137.                 sqlQueryObject.setANDLogicOperator(true);
  1138.                 String sqlQuery = sqlQueryObject.createSQLQuery();
  1139.                 stm=con.prepareStatement(sqlQuery);
  1140.                 stm.setString(1, oldTipoSoggetto);
  1141.                 stm.setString(2, oldNomeSoggetto);
  1142.                 rs=stm.executeQuery();
  1143.                 while(rs.next()){
  1144.                     long idConnettore=rs.getLong("id_connettore");
  1145.                     Connettore connettore = this.driver.getConnettore(idConnettore, con);
  1146.                     String oldNomeConnettore=connettore.getNome();
  1147.                     //controllo se il nome connettore matcha la regex
  1148.                     if(oldNomeConnettore.matches(regex)){
  1149.                         this.driver.logDebug("Tento aggiornamento connettore id: ["+idConnettore+"] oldNome: ["+oldNomeConnettore+"]...");
  1150.                         //splitto la stringa in modo da prendermi i valori separatamente
  1151.                         //l'array sara composto da [CNT,SF,tipo/nomeFruitore,tipo/nomeErogatore,tipo/nomeServizio]
  1152.                         String[] val=oldNomeConnettore.split("_");
  1153.                         //i=2 contiene il tipo/nome del soggetto fruitore
  1154.                         //i=3 contiene il tipo/nome del soggetto erogatore (che bisogna cambiare)
  1155.                         //i=4 contiene il tipo/nome del servizio
  1156.                         String newNomeConnettore = "CNT_SF_"+val[2]+ tipoSoggetto+"/"+nomeSoggetto +val[4];
  1157.                         this.driver.logDebug("nuovo nome connettore ["+newNomeConnettore+"]");
  1158.                         connettore.setNome(newNomeConnettore);
  1159.                         //aggiorno il connettore
  1160.                         DriverRegistroServiziDB_connettoriLIB.CRUDConnettore(CostantiDB.UPDATE, connettore, con, this.driver.getDriverWrapBYOK());
  1161.                     }
  1162.                 }
  1163.                 rs.close();
  1164.                 stm.close();
  1165.                 //recupero i connettori da modificare dove il soggetto e' fruitore
  1166.                 //0 soggetti
  1167.                 //1 servizi_fruitori
  1168.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1169.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1170.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  1171.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI+".tipo_soggetto");
  1172.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI+".nome_soggetto");
  1173.                 sqlQueryObject.addSelectField(CostantiDB.SERVIZI_FRUITORI+".id_connettore");
  1174.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_FRUITORI+".id_soggetto = "+CostantiDB.SOGGETTI+".id");
  1175.                 sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".tipo_soggetto = ?");
  1176.                 sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".nome_soggetto = ?");
  1177.                 sqlQueryObject.setANDLogicOperator(true);
  1178.                 sqlQuery = sqlQueryObject.createSQLQuery();
  1179.                 stm=con.prepareStatement(sqlQuery);
  1180.                 stm.setString(1, oldTipoSoggetto);
  1181.                 stm.setString(2, oldNomeSoggetto);
  1182.                 rs=stm.executeQuery();
  1183.                 while(rs.next()){
  1184.                     long idConnettore=rs.getLong("id_connettore");
  1185.                     Connettore connettore = this.driver.getConnettore(idConnettore, con);
  1186.                     String oldNomeConnettore=connettore.getNome();
  1187.                     //controllo se il nome connettore matcha la regex
  1188.                     if(oldNomeConnettore.matches(regex)){
  1189.                         this.driver.logDebug("Tento aggiornamento connettore id: ["+idConnettore+"] oldNome: ["+oldNomeConnettore+"]...");
  1190.                         //splitto la stringa in modo da prendermi i valori separatamente
  1191.                         //l'array sara composto da [CNT,SF,tipo/nomeFruitore,tipo/nomeErogatore,tipo/nomeServizio]
  1192.                         String[] val=oldNomeConnettore.split("_");
  1193.                         //i=2 contiene il tipo/nome del soggetto fruitore (che bisogna cambiare)
  1194.                         //i=3 contiene il tipo/nome del soggetto erogatore 
  1195.                         //i=4 contiene il tipo/nome del servizio
  1196.                         String newNomeConnettore = "CNT_SF_"+tipoSoggetto+"/"+nomeSoggetto+val[3]+val[4];
  1197.                         this.driver.logDebug("nuovo nome connettore ["+newNomeConnettore+"]");
  1198.                         connettore.setNome(newNomeConnettore);
  1199.                         //aggiorno il connettore
  1200.                         DriverRegistroServiziDB_connettoriLIB.CRUDConnettore(CostantiDB.UPDATE, connettore, con, this.driver.getDriverWrapBYOK());
  1201.                     }
  1202.                 }
  1203.                 rs.close();
  1204.                 stm.close();
  1205.             }

  1207.             // UPDATE soggetto
  1208.             DriverRegistroServiziDB_soggettiLIB.CRUDSoggetto(2, soggetto, con, this.driver.tipoDB, this.driver.getDriverWrapBYOK());

  1210.         } catch (Exception qe) {
  1211.             error = true;
  1212.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateSoggetto] Errore durante l'aggiornamento del soggetto : " + qe.getMessage(),qe);
  1213.         } finally {

  1215.             JDBCUtilities.closeResources(rs, stm);

  1217.             this.driver.closeConnection(error,con);
  1218.         }
  1219.     }

  1221.     protected void deleteSoggetto(org.openspcoop2.core.registry.Soggetto soggetto) throws DriverRegistroServiziException {
  1222.         if (soggetto == null)
  1223.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteSoggetto] Parametro non valido.");

  1225.         Connection con = null;
  1226.         boolean error = false;

  1228.         if (this.driver.atomica) {
  1229.             try {
  1230.                 con = this.driver.getConnectionFromDatasource("deleteSoggetto");
  1231.                 con.setAutoCommit(false);
  1232.             } catch (Exception e) {
  1233.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);

  1235.             }

  1237.         } else
  1238.             con = this.driver.globalConnection;

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

  1242.         try {
  1243.             this.driver.logDebug("CRUDSoggetto type = 3");
  1244.             // DELETE soggetto
  1245.             DriverRegistroServiziDB_soggettiLIB.CRUDSoggetto(3, soggetto, con, this.driver.tipoDB, this.driver.getDriverWrapBYOK());

  1247.         } catch (Exception qe) {
  1248.             error = true;
  1249.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteSoggetto] Errore durante l'eliminazione del soggetto : " + qe.getMessage(),qe);
  1250.         } finally {

  1252.             this.driver.closeConnection(error,con);
  1253.         }
  1254.     }

  1256.     protected IDSoggetto[] getSoggettiWithSuperuser(String user) throws DriverRegistroServiziException {

  1258.         IDSoggetto [] idSoggetti = null;

  1260.         Connection con = null;
  1261.         PreparedStatement stm = null;
  1262.         ResultSet rs = null;
  1263.         String sqlQuery = "";

  1265.         if (this.driver.atomica) {
  1266.             try {
  1267.                 con = this.driver.getConnectionFromDatasource("getSoggettiWithSuperuser");

  1269.             } catch (Exception e) {
  1270.                 throw new DriverRegistroServiziException("[DriverRegistroServiziException::getSoggettiWithSuperuser] Exception accedendo al datasource :" + e.getMessage(),e);

  1272.             }

  1274.         } else
  1275.             con = this.driver.globalConnection;

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

  1279.         try {
  1280.             List<IDSoggetto> idTrovati = new ArrayList<IDSoggetto>();
  1281.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1282.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1283.             sqlQueryObject.addSelectField("tipo_soggetto");
  1284.             sqlQueryObject.addSelectField("nome_soggetto");
  1285.             sqlQueryObject.addWhereCondition("superuser = ?");
  1286.             sqlQuery = sqlQueryObject.createSQLQuery();

  1288.             stm = con.prepareStatement(sqlQuery);

  1290.             stm.setString(1, user);

  1292.             this.driver.logDebug("eseguo query : " + DBUtils.formatSQLString(sqlQuery, CostantiRegistroServizi.ABILITATO));
  1293.             rs = stm.executeQuery();

  1295.             // prendo il primo router se c'e' altrimenti lancio eccezione.
  1296.             while (rs.next()) {
  1297.                 IDSoggetto id = new IDSoggetto();
  1298.                 id.setTipo(rs.getString("tipo_soggetto"));
  1299.                 id.setNome(rs.getString("nome_soggetto"));
  1300.                 idTrovati.add(id);
  1301.             }

  1303.             if(idTrovati.size()>0){
  1304.                 idSoggetti =  new IDSoggetto[1];
  1305.                 idSoggetti = idTrovati.toArray(idSoggetti);
  1306.             }

  1308.         } catch (SQLException se) {
  1309.             throw new DriverRegistroServiziException("[DriverRegistroServiziException::getSoggettiWithSuperuser] SqlException: " + se.getMessage(),se);
  1310.         }catch (Exception se) {
  1311.             throw new DriverRegistroServiziException("[DriverRegistroServiziException::getSoggettiWithSuperuser] Exception: " + se.getMessage(),se);
  1312.         } finally {
  1313.             //Chiudo statement and resultset
  1314.             JDBCUtilities.closeResources(rs, stm);
  1315.             this.driver.closeConnection(con);
  1316.         }
  1317.         return idSoggetti;
  1318.     }
  1319.     
  1320.     protected List<String> nomiProprietaSoggetti(List<String> tipoSoggettiProtocollo) throws DriverConfigurazioneException {
  1321.         String queryString;

  1323.         Connection con = null;
  1324.         PreparedStatement stmt=null;
  1325.         ResultSet risultato=null;
  1326.         ArrayList<String> lista = new ArrayList<>();

  1328.         if (this.driver.atomica) {
  1329.             try {
  1330.                 con = this.driver.getConnectionFromDatasource("nomiProprietaSoggetti");
  1331.             } catch (Exception e) {
  1332.                 throw new DriverConfigurazioneException("[DriverRegistroServiziDB::nomiProprietaSoggetti] Exception accedendo al datasource :" + e.getMessage(),e);

  1334.             }

  1336.         } else
  1337.             con = this.driver.globalConnection;

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

  1341.         try {

  1343.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1344.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI_PROPS);
  1345.             sqlQueryObject.setSelectDistinct(true);
  1346.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_PROPS + ".nome");
  1347.             
  1348.             if((tipoSoggettiProtocollo != null && tipoSoggettiProtocollo.size() > 0)) {
  1349.                 sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI_PROPS + ".id_soggetto = "+CostantiDB.SOGGETTI+".id");
  1350.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1351.                 String [] tipiServiziProtocolloS = tipoSoggettiProtocollo.toArray(new String[tipoSoggettiProtocollo.size()]); 
  1352.                 sqlQueryObject.addWhereINCondition(CostantiDB.SOGGETTI+".tipo_soggetto", true, tipiServiziProtocolloS);
  1353.             }
  1354.             
  1355.             sqlQueryObject.addOrderBy(CostantiDB.SOGGETTI_PROPS + ".nome"); 
  1356.             sqlQueryObject.setSortType(true);
  1357.             sqlQueryObject.setANDLogicOperator(true);
  1358.             
  1359.             queryString = sqlQueryObject.createSQLQuery();
  1360.             stmt = con.prepareStatement(queryString);
  1361.             risultato = stmt.executeQuery();
  1362.             while (risultato.next()) {
  1363.                 lista.add(risultato.getString("nome"));
  1364.             }
  1365.             return lista;
  1366.         } catch (Exception qe) {
  1367.             throw new DriverConfigurazioneException("[DriverRegistroServiziDB::nomiProprietaSoggetti] Errore : " + qe.getMessage(),qe);
  1368.         } finally {
  1369.             //Chiudo statement and resultset
  1370.             JDBCUtilities.closeResources(risultato, stmt);
  1371.             this.driver.closeConnection(con);
  1372.         }
  1373.     }
  1374.     
  1375.     protected boolean isSoggettoInUsoInPackageFinali(Soggetto ss, Map<ErrorsHandlerCostant,String> whereIsInUso) throws DriverRegistroServiziException {
  1376.         return isSoggettoInUso(ss,whereIsInUso,true,false);
  1377.     }
  1378.     protected boolean isSoggettoInUsoInPackagePubblici(Soggetto ss, Map<ErrorsHandlerCostant,String> whereIsInUso) throws DriverRegistroServiziException {
  1379.         return isSoggettoInUso(ss,whereIsInUso,false,true);
  1380.     }
  1381.     protected boolean isSoggettoInUso(Soggetto ss, Map<ErrorsHandlerCostant,String> whereIsInUso) throws DriverRegistroServiziException {
  1382.         return isSoggettoInUso(ss,whereIsInUso,false,false);
  1383.     }
  1384.     private boolean isSoggettoInUso(Soggetto ss, Map<ErrorsHandlerCostant,String> whereIsInUso,boolean checkOnlyStatiFinali,boolean checkOnlyStatiPubblici) throws DriverRegistroServiziException {
  1385.         String nomeMetodo = "isSoggettoInUso";
  1386.         Connection con = null;
  1387.         PreparedStatement stmt = null;
  1388.         ResultSet risultato = null;

  1390.         if (this.driver.atomica) {
  1391.             try {
  1392.                 con = this.driver.getConnectionFromDatasource("isSoggettoInUso");

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

  1397.             }

  1399.         } else
  1400.             con = this.driver.globalConnection;

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

  1404.         try {
  1405.             boolean isInUso = false;
  1406.             List<String> nomiServizi = new ArrayList<>();
  1407.             List<String> serviziFruitori = new ArrayList<>();
  1408.             List<String> accordi = new ArrayList<>();
  1409.             List<String> accordi_cooperazione = new ArrayList<>();
  1410.             List<String> partecipanti = new ArrayList<>();

  1412.             //controllo se in uso in servizi
  1413.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1414.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  1415.             sqlQueryObject.addSelectField("*");
  1416.             sqlQueryObject.addWhereCondition("id_soggetto = ?");
  1417.             if(checkOnlyStatiFinali){
  1418.                 sqlQueryObject.addWhereCondition("stato = ?");
  1419.             }
  1420.             if(checkOnlyStatiPubblici){
  1421.                 sqlQueryObject.addWhereCondition("privato = ?");
  1422.             }
  1423.             sqlQueryObject.setANDLogicOperator(true);
  1424.             String queryString = sqlQueryObject.createSQLQuery();
  1425.             stmt = con.prepareStatement(queryString);
  1426.             stmt.setLong(1, ss.getId());
  1427.             int index = 2;
  1428.             if(checkOnlyStatiFinali){
  1429.                 stmt.setString(index, StatiAccordo.finale.toString());
  1430.                 index++;
  1431.             }
  1432.             if(checkOnlyStatiPubblici){
  1433.                 stmt.setInt(index, 0);
  1434.                 index++;
  1435.             }
  1436.             risultato = stmt.executeQuery();
  1437.             while (risultato.next()){
  1438.                 isInUso=true;
  1439.                 String nomeServizio = risultato.getString("tipo_servizio")+"/"+risultato.getString("nome_servizio");
  1440.                 nomiServizi.add(nomeServizio);
  1441.             }
  1442.             risultato.close();
  1443.             stmt.close();

  1445.             if(nomiServizi.size()>0) whereIsInUso.put(ErrorsHandlerCostant.IN_USO_IN_SERVIZI, nomiServizi.toString());

  1447.             // controllo se in uso in fruitori
  1448.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1449.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI_FRUITORI);
  1450.             sqlQueryObject.addSelectField("*");
  1451.             sqlQueryObject.addWhereCondition("id_soggetto = ?");
  1452.             if(checkOnlyStatiFinali){
  1453.                 sqlQueryObject.addWhereCondition("stato = ?");
  1454.             }
  1455.             sqlQueryObject.setANDLogicOperator(true);
  1456.             queryString = sqlQueryObject.createSQLQuery();
  1457.             stmt = con.prepareStatement(queryString);
  1458.             stmt.setLong(1, ss.getId());
  1459.             if(checkOnlyStatiFinali){
  1460.                 stmt.setString(2, StatiAccordo.finale.toString());
  1461.             }
  1462.             risultato = stmt.executeQuery();
  1463.             while (risultato.next()){
  1464.                 isInUso=true;
  1465.                 AccordoServizioParteSpecifica servizio = this.driver.getAccordoServizioParteSpecifica(risultato.getLong("id_servizio"));
  1466.                 String uriServizio = this.driver.idServizioFactory.getUriFromAccordo(servizio);
  1467.                 if(checkOnlyStatiPubblici){
  1468.                     if(servizio.getPrivato()==null || servizio.getPrivato()==false){
  1469.                         serviziFruitori.add(uriServizio);
  1470.                     }
  1471.                 }else{
  1472.                     serviziFruitori.add(uriServizio);
  1473.                 }       
  1474.             }
  1475.             risultato.close();
  1476.             stmt.close();

  1478.             if(serviziFruitori.size()>0) whereIsInUso.put(ErrorsHandlerCostant.POSSIEDE_FRUITORI, serviziFruitori.toString());


  1481.             //controllo se referente
  1482.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1483.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  1484.             sqlQueryObject.addSelectField("*");
  1485.             sqlQueryObject.addWhereCondition("id_referente = ?");
  1486.             if(checkOnlyStatiFinali){
  1487.                 sqlQueryObject.addWhereCondition("stato = ?");
  1488.             }
  1489.             if(checkOnlyStatiPubblici){
  1490.                 sqlQueryObject.addWhereCondition("privato = ?");
  1491.             }
  1492.             sqlQueryObject.setANDLogicOperator(true);
  1493.             queryString = sqlQueryObject.createSQLQuery();
  1494.             stmt = con.prepareStatement(queryString);
  1495.             stmt.setLong(1, ss.getId());
  1496.             index = 2;
  1497.             if(checkOnlyStatiFinali){
  1498.                 stmt.setString(index, StatiAccordo.finale.toString());
  1499.                 index++;
  1500.             }
  1501.             if(checkOnlyStatiPubblici){
  1502.                 stmt.setInt(index, 0);
  1503.                 index++;
  1504.             }
  1505.             risultato = stmt.executeQuery();
  1506.             while (risultato.next()){
  1507.                 isInUso=true;
  1508.                 AccordoServizioParteComune accordo = this.driver.getAccordoServizioParteComune(risultato.getLong("id"));
  1509.                 accordi.add(this.driver.idAccordoFactory.getUriFromAccordo(accordo));
  1510.             }
  1511.             risultato.close();
  1512.             stmt.close();

  1514.             if(accordi.size()>0) whereIsInUso.put(ErrorsHandlerCostant.IS_REFERENTE, accordi.toString());


  1517.             //controllo se referente in accordi cooperazione
  1518.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1519.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE);
  1520.             sqlQueryObject.addSelectField("*");
  1521.             sqlQueryObject.addWhereCondition("id_referente = ?");
  1522.             if(checkOnlyStatiFinali){
  1523.                 sqlQueryObject.addWhereCondition("stato = ?");
  1524.             }
  1525.             if(checkOnlyStatiPubblici){
  1526.                 sqlQueryObject.addWhereCondition("privato = ?");
  1527.             }
  1528.             sqlQueryObject.setANDLogicOperator(true);
  1529.             queryString = sqlQueryObject.createSQLQuery();
  1530.             stmt = con.prepareStatement(queryString);
  1531.             stmt.setLong(1, ss.getId());
  1532.             index = 2;
  1533.             if(checkOnlyStatiFinali){
  1534.                 stmt.setString(index, StatiAccordo.finale.toString());
  1535.                 index++;
  1536.             }
  1537.             if(checkOnlyStatiPubblici){
  1538.                 stmt.setInt(index, 0);
  1539.                 index++;
  1540.             }
  1541.             risultato = stmt.executeQuery();
  1542.             while (risultato.next()){
  1543.                 isInUso=true;
  1544.                 AccordoCooperazione accordo = this.driver.getAccordoCooperazione(risultato.getLong("id"));
  1545.                 accordi_cooperazione.add(this.driver.idAccordoCooperazioneFactory.getUriFromAccordo(accordo));
  1546.             }
  1547.             risultato.close();
  1548.             stmt.close();

  1550.             if(accordi_cooperazione.size()>0) whereIsInUso.put(ErrorsHandlerCostant.IS_REFERENTE_COOPERAZIONE, accordi_cooperazione.toString());


  1553.             //controllo se partecipante in cooperazione
  1554.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1555.             sqlQueryObject.addFromTable(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI);
  1556.             sqlQueryObject.addSelectField("*");
  1557.             sqlQueryObject.addWhereCondition("id_soggetto = ?");
  1558.             sqlQueryObject.setANDLogicOperator(true);
  1559.             queryString = sqlQueryObject.createSQLQuery();
  1560.             stmt = con.prepareStatement(queryString);
  1561.             stmt.setLong(1, ss.getId());
  1562.             risultato = stmt.executeQuery();
  1563.             while (risultato.next()){
  1564.                 AccordoCooperazione accordo = this.driver.getAccordoCooperazione(risultato.getLong("id_accordo_cooperazione"));
  1565.                 if(checkOnlyStatiFinali){
  1566.                     if(StatiAccordo.finale.toString().equals(accordo.getStatoPackage())){
  1567.                         isInUso=true;
  1568.                         partecipanti.add(this.driver.idAccordoCooperazioneFactory.getUriFromAccordo(accordo));
  1569.                     }
  1570.                 }else if(checkOnlyStatiPubblici){
  1571.                     if(accordo.getPrivato()==null || accordo.getPrivato()==false){
  1572.                         isInUso=true;
  1573.                         partecipanti.add(this.driver.idAccordoCooperazioneFactory.getUriFromAccordo(accordo));
  1574.                     }
  1575.                 }else{
  1576.                     isInUso=true;
  1577.                     partecipanti.add(this.driver.idAccordoCooperazioneFactory.getUriFromAccordo(accordo));
  1578.                 }
  1579.             }
  1580.             risultato.close();
  1581.             stmt.close();

  1583.             if(partecipanti.size()>0) whereIsInUso.put(ErrorsHandlerCostant.IS_PARTECIPANTE_COOPERAZIONE, partecipanti.toString());


  1586.             return isInUso;

  1588.         } catch (Exception se) {

  1590.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1591.         } finally {
  1592.             //Chiudo statement and resultset
  1593.             JDBCUtilities.closeResources(risultato, stmt);
  1594.             this.driver.closeConnection(con);
  1595.         }
  1596.     }

  1598.     
  1599.     protected IDSoggetto getIdSoggetto(long idSoggetto) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  1600.         return getIdSoggetto(idSoggetto,null);
  1601.     }
  1602.     protected IDSoggetto getIdSoggetto(long idSoggetto,Connection conParam) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {

  1604.         // conrollo consistenza
  1605.         if (idSoggetto <= 0)
  1606.             return null;

  1608.         IDSoggetto idSoggettoObject = null;

  1610.         Connection con = null;
  1611.         PreparedStatement stm = null;
  1612.         ResultSet rs = null;

  1614.         if(conParam!=null){
  1615.             con = conParam;
  1616.         }
  1617.         else if (this.driver.atomica) {
  1618.             try {
  1619.                 con = this.driver.getConnectionFromDatasource("getIdSoggetto(longId)");

  1621.             } catch (Exception e) {
  1622.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::getIdSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);

  1624.             }

  1626.         } else
  1627.             con = this.driver.globalConnection;

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

  1631.         try {
  1632.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1633.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1634.             sqlQueryObject.addSelectField("tipo_soggetto");
  1635.             sqlQueryObject.addSelectField("nome_soggetto");
  1636.             sqlQueryObject.addWhereCondition("id = ?");
  1637.             String sqlQuery = sqlQueryObject.createSQLQuery();

  1639.             stm = con.prepareStatement(sqlQuery);

  1641.             stm.setLong(1, idSoggetto);

  1643.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idSoggetto));
  1644.             rs = stm.executeQuery();

  1646.             if (rs.next()) {
  1647.                 idSoggettoObject = new IDSoggetto();

  1649.                 // String tmp = rs.getString("nomeprov");
  1650.                 // soggetto.setNome(( (tmp==null || tmp.equals("") ) ?
  1651.                 // null : tmp));
  1652.                 idSoggettoObject.setNome(rs.getString("nome_soggetto"));
  1653.                 // tmp = rs.getString("tipoprov");
  1654.                 // soggetto.setTipo(( (tmp==null || tmp.equals("") ) ?
  1655.                 // null : tmp));
  1656.                 idSoggettoObject.setTipo(rs.getString("tipo_soggetto"));

  1658.             }else{
  1659.                 throw new DriverRegistroServiziNotFound("Nessun risultato trovato eseguendo: "+DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idSoggetto));
  1660.             }

  1662.             return idSoggettoObject;
  1663.         } catch (SQLException se) {
  1664.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getIdSoggetto] SqlException: " + se.getMessage(),se);
  1665.         }catch (DriverRegistroServiziNotFound se) {
  1666.             throw se;
  1667.         }catch (Exception se) {
  1668.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getIdSoggetto] Exception: " + se.getMessage(),se);
  1669.         } finally {

  1671.             //Chiudo statement and resultset
  1672.             JDBCUtilities.closeResources(rs, stm);

  1674.             this.driver.closeConnection(conParam, con);
  1675.         }
  1676.     }
  1677.     
  1678.     
  1679.     
  1680.     protected List<IDSoggetto> getSoggettiDefault() throws DriverRegistroServiziException {
  1681.         return getSoggettiDefault(null);
  1682.     }
  1683.     protected List<IDSoggetto> getSoggettiDefault(Connection conParam) throws DriverRegistroServiziException {

  1685.         List<IDSoggetto> soggettiDefault = new ArrayList<IDSoggetto>();

  1687.         Connection con = null;
  1688.         PreparedStatement stm = null;
  1689.         ResultSet rs = null;

  1691.         if(conParam!=null){
  1692.             con = conParam;
  1693.         }
  1694.         else if (this.driver.atomica) {
  1695.             try {
  1696.                 con = this.driver.getConnectionFromDatasource("getSoggettiDefault()");

  1698.             } catch (Exception e) {
  1699.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::getSoggettiDefault] Exception accedendo al datasource :" + e.getMessage(),e);

  1701.             }

  1703.         } else
  1704.             con = this.driver.globalConnection;

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

  1708.         try {
  1709.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1710.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1711.             sqlQueryObject.addSelectField("tipo_soggetto");
  1712.             sqlQueryObject.addSelectField("nome_soggetto");
  1713.             sqlQueryObject.addWhereCondition("is_default = ?");
  1714.             sqlQueryObject.setANDLogicOperator(true);
  1715.             String sqlQuery = sqlQueryObject.createSQLQuery();

  1717.             stm = con.prepareStatement(sqlQuery);

  1719.             stm.setInt(1, CostantiDB.TRUE);

  1721.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, CostantiDB.TRUE));
  1722.             rs = stm.executeQuery();

  1724.             while (rs.next()) {
  1725.                 
  1726.                 IDSoggetto idSoggetto = new IDSoggetto(rs.getString("tipo_soggetto"), rs.getString("nome_soggetto"));
  1727.                 soggettiDefault.add(idSoggetto);

  1729.             }
  1730.             
  1731.             if(soggettiDefault.isEmpty()) {
  1732.                 throw new DriverRegistroServiziNotFound("Nessun risultato trovato eseguendo: "+DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, CostantiDB.TRUE));
  1733.             }

  1735.             return soggettiDefault;
  1736.         } catch (SQLException se) {
  1737.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getSoggettiDefault] SqlException: " + se.getMessage(),se);
  1738.         }catch (Exception se) {
  1739.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getSoggettiDefault] Exception: " + se.getMessage(),se);
  1740.         } finally {

  1742.             //Chiudo statement and resultset
  1743.             JDBCUtilities.closeResources(rs, stm);

  1745.             this.driver.closeConnection(conParam, con);
  1746.         }
  1747.     }
  1748. }
Created with JaCoCo 0.8.8.202204050719