DriverRegistroServiziDB_pddDriver.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.openspcoop2.core.commons.ISearch;
  36. import org.openspcoop2.core.commons.Liste;
  37. import org.openspcoop2.core.constants.CostantiDB;
  38. import org.openspcoop2.core.registry.PortaDominio;
  39. import org.openspcoop2.core.registry.Soggetto;
  40. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  41. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  42. import org.openspcoop2.core.registry.driver.FiltroRicerca;
  43. import org.openspcoop2.utils.certificate.CertificateUtils;
  44. import org.openspcoop2.utils.certificate.PrincipalType;
  45. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  46. import org.openspcoop2.utils.sql.ISQLQueryObject;
  47. import org.openspcoop2.utils.sql.SQLObjectFactory;

  49. /**
  50.  * DriverRegistroServiziDB_pddDriver
  51.  * 
  52.  * 
  53.  * @author Sandra Giangrandi (sandra@link.it)
  54.  * @author Stefano Corallo (corallo@link.it)
  55.  * @author $Author$
  56.  * @version $Rev$, $Date$
  57.  */
  58. public class DriverRegistroServiziDB_pddDriver {

  60.     private DriverRegistroServiziDB driver = null;
  61.     
  62.     protected DriverRegistroServiziDB_pddDriver(DriverRegistroServiziDB driver) {
  63.         this.driver = driver;
  64.     }
  65.     
  66.     protected org.openspcoop2.core.registry.PortaDominio getPortaDominio(String nomePdD) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  68.         this.driver.logDebug("richiesto getPortaDominio: " + nomePdD);
  69.         // conrollo consistenza
  70.         if (nomePdD == null)
  71.             throw new DriverRegistroServiziException("[getPortaDominio] Parametro nomePdD is null");
  72.         if (nomePdD.trim().equals(""))
  73.             throw new DriverRegistroServiziException("[getPortaDominio] Parametro nomePdD non e' definito");

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

  79.         if (this.driver.atomica) {
  80.             try {
  81.                 con = this.driver.getConnectionFromDatasource("getPortaDominio(nome)");

  83.             } catch (Exception e) {
  84.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::getPortaDominio] Exception accedendo al datasource :" + e.getMessage(),e);

  86.             }

  88.         } else
  89.             con = this.driver.globalConnection;

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

  93.         try {

  95.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  96.             sqlQueryObject.addFromTable(CostantiDB.PDD);
  97.             sqlQueryObject.addSelectField("*");
  98.             sqlQueryObject.addWhereCondition("nome = ?");
  99.             String queryString = sqlQueryObject
  100.                     .createSQLQuery();
  101.             stm = con.prepareStatement(queryString);
  102.             stm.setString(1, nomePdD);
  103.             rs = stm.executeQuery();
  104.             PortaDominio pdd = null;
  105.             if (rs.next()) {
  106.                 pdd = new PortaDominio();
  107.                 pdd.setId(rs.getLong("id"));
  108.                 pdd.setNome(rs.getString("nome"));
  109.                 pdd.setDescrizione(rs.getString("descrizione"));
  110.                 pdd.setImplementazione(rs.getString("implementazione"));
  111.                 pdd.setSubject(rs.getString("subject"));
  112.                 pdd.setClientAuth(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(rs.getString("client_auth")));
  113.                 pdd.setSuperUser(rs.getString("superuser"));

  115.                 // Ora Registrazione
  116.                 if(rs.getTimestamp("ora_registrazione")!=null){
  117.                     pdd.setOraRegistrazione(new Date(rs.getTimestamp("ora_registrazione").getTime()));
  118.                 }

  120.             } else {
  121.                 throw new DriverRegistroServiziNotFound("[DriverRegistroServiziDB::getPortaDominio] rs.next non ha restituito valori con la seguente interrogazione :\n" + DriverRegistroServiziDB_LIB.formatSQLString(queryString, nomePdD));
  122.             }

  124.             return pdd;

  126.         }catch (DriverRegistroServiziNotFound e) {
  127.             throw e;
  128.         } catch (SQLException se) {

  130.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getPortaDominio] SqlException: " + se.getMessage(),se);
  131.         }catch (Exception se) {

  133.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getPortaDominio] Exception: " + se.getMessage(),se);
  134.         } finally {
  135.             JDBCUtilities.closeResources(rs, stm);
  136.             this.driver.closeConnection(con);
  137.         }
  138.     }


  141.     protected List<String> getAllIdPorteDominio(FiltroRicerca filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  143.         Connection con = null;
  144.         PreparedStatement stm = null;
  145.         ResultSet rs = null;

  147.         this.driver.logDebug("getAllIdPorteDominio...");

  149.         try {
  150.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  151.             // prendo la connessione dal pool
  152.             if (this.driver.atomica)
  153.                 con = this.driver.getConnectionFromDatasource("getAllIdPorteDominio");
  154.             else
  155.                 con = this.driver.globalConnection;

  157.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  158.             sqlQueryObject.addFromTable(CostantiDB.PDD);
  159.             sqlQueryObject.addSelectField("nome");
  160.             if(filtroRicerca!=null){
  161.                 // Filtro By Data
  162.                 if(filtroRicerca.getMinDate()!=null)
  163.                     sqlQueryObject.addWhereCondition("ora_registrazione > ?");
  164.                 if(filtroRicerca.getMaxDate()!=null)
  165.                     sqlQueryObject.addWhereCondition("ora_registrazione < ?");
  166.                 if(filtroRicerca.getNome()!=null)
  167.                     sqlQueryObject.addWhereCondition("nome = ?");
  168.                 if(filtroRicerca.getTipo()!=null)
  169.                     sqlQueryObject.addWhereCondition("tipo = ?");
  170.             }

  172.             sqlQueryObject.setANDLogicOperator(true);
  173.             String sqlQuery = sqlQueryObject.createSQLQuery();
  174.             this.driver.logDebug("eseguo query : " + sqlQuery );
  175.             stm = con.prepareStatement(sqlQuery);
  176.             int indexStmt = 1;
  177.             if(filtroRicerca!=null){
  178.                 if(filtroRicerca.getMinDate()!=null){
  179.                     this.driver.logDebug("minDate stmt.setTimestamp("+filtroRicerca.getMinDate()+")");
  180.                     stm.setTimestamp(indexStmt, new Timestamp(filtroRicerca.getMinDate().getTime()));
  181.                     indexStmt++;
  182.                 }
  183.                 if(filtroRicerca.getMaxDate()!=null){
  184.                     this.driver.logDebug("maxDate stmt.setTimestamp("+filtroRicerca.getMaxDate()+")");
  185.                     stm.setTimestamp(indexStmt, new Timestamp(filtroRicerca.getMaxDate().getTime()));
  186.                     indexStmt++;
  187.                 }   
  188.                 if(filtroRicerca.getNome()!=null){
  189.                     this.driver.logDebug("nome stmt.setString("+filtroRicerca.getNome()+")");
  190.                     stm.setString(indexStmt, filtroRicerca.getNome());
  191.                     indexStmt++;
  192.                 }   
  193.                 if(filtroRicerca.getTipo()!=null){
  194.                     this.driver.logDebug("tipoPdd stmt.setString("+filtroRicerca.getTipo()+")");
  195.                     stm.setString(indexStmt, filtroRicerca.getTipo());
  196.                     indexStmt++;
  197.                 }
  198.             }
  199.             rs = stm.executeQuery();
  200.             List<String> nomiPdd = new ArrayList<>();
  201.             while (rs.next()) {
  202.                 nomiPdd.add(rs.getString("nome"));
  203.             }
  204.             if(nomiPdd.size()==0){
  205.                 if(filtroRicerca!=null)
  206.                     throw new DriverRegistroServiziNotFound("Porte di Dominio non trovate che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  207.                 else
  208.                     throw new DriverRegistroServiziNotFound("Porte di Dominio non trovate");
  209.             }else{
  210.                 return nomiPdd;
  211.             }
  212.         }catch(DriverRegistroServiziNotFound de){
  213.             throw de;
  214.         }
  215.         catch(Exception e){
  216.             throw new DriverRegistroServiziException("getAllIdPorteDominio error",e);
  217.         } finally {

  219.             //Chiudo statement and resultset
  220.             JDBCUtilities.closeResources(rs, stm);

  222.             this.driver.closeConnection(con);

  224.         }
  225.     }



  229.     protected void createPortaDominio(PortaDominio pdd) throws DriverRegistroServiziException{
  230.         if (pdd == null)
  231.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createPortaDominio] Parametro non valido.");

  233.         Connection con = null;
  234.         boolean error = false;

  236.         if (this.driver.atomica) {
  237.             try {
  238.                 con = this.driver.getConnectionFromDatasource("createPortaDominio");
  239.                 con.setAutoCommit(false);
  240.             } catch (Exception e) {
  241.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createPortaDominio] Exception accedendo al datasource :" + e.getMessage(),e);

  243.             }

  245.         } else
  246.             con = this.driver.globalConnection;

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

  250.         try {
  251.             this.driver.logDebug("CRUDPortaDominio type = 1");
  252.             DriverRegistroServiziDB_soggettiLIB.CRUDPortaDominio(CostantiDB.CREATE, pdd, con);

  254.         } catch (Exception qe) {
  255.             error = true;
  256.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createPortaDominio] Errore durante la creazione della porta di dominio : " + qe.getMessage(), qe);
  257.         } finally {

  259.             this.driver.closeConnection(error,con);
  260.         }
  261.     }

  263.     protected boolean existsPortaDominio(String nome) throws DriverRegistroServiziException{
  264.         boolean exist = false;
  265.         Connection con = null;
  266.         PreparedStatement stm = null;
  267.         ResultSet rs = null;

  269.         if (nome == null)
  270.             throw new DriverRegistroServiziException("Parametro non valido");

  272.         if (nome.equals(""))
  273.             throw new DriverRegistroServiziException("Parametro vuoto non valido");

  275.         if (this.driver.atomica) {
  276.             try {
  277.                 con = this.driver.getConnectionFromDatasource("existsPortaDominio");
  278.             } catch (Exception e) {
  279.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::existsPortaDominio] Exception accedendo al datasource :" + e.getMessage(),e);

  281.             }

  283.         } else
  284.             con = this.driver.globalConnection;

  286.         try {
  287.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  288.             sqlQueryObject.addFromTable(CostantiDB.PDD);
  289.             sqlQueryObject.addSelectField("*");
  290.             sqlQueryObject.addWhereCondition("nome = ?");
  291.             sqlQueryObject.setANDLogicOperator(true);
  292.             String sqlQuery = sqlQueryObject.createSQLQuery();
  293.             stm = con.prepareStatement(sqlQuery);
  294.             stm.setString(1, nome);
  295.             rs = stm.executeQuery();
  296.             if (rs.next())
  297.                 exist = true;
  298.             rs.close();
  299.             stm.close();

  301.         } catch (Exception e) {
  302.             exist = false;
  303.             this.driver.log.error("Errore durante verifica esistenza porta di dominio :", e);
  304.         } finally {

  306.             //Chiudo statement and resultset
  307.             JDBCUtilities.closeResources(rs, stm);

  309.             this.driver.closeConnection(con);
  310.         }

  312.         return exist;
  313.     }

  315.     protected void updatePortaDominio(PortaDominio pdd) throws DriverRegistroServiziException{
  316.         if (pdd == null)
  317.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updatePortaDominio] Parametro non valido.");

  319.         Connection con = null;
  320.         boolean error = false;

  322.         if (this.driver.atomica) {
  323.             try {
  324.                 con = this.driver.getConnectionFromDatasource("updatePortaDominio");
  325.                 con.setAutoCommit(false);
  326.             } catch (Exception e) {
  327.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updatePortaDominio] Exception accedendo al datasource :" + e.getMessage(),e);

  329.             }

  331.         } else
  332.             con = this.driver.globalConnection;

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

  336.         try {

  338.             this.driver.logDebug("CRUDPortaDominio type = 2");
  339.             DriverRegistroServiziDB_soggettiLIB.CRUDPortaDominio(CostantiDB.UPDATE, pdd, con);

  341.         } catch (Exception qe) {
  342.             error = true;
  343.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updatePortaDominio] Errore durante l'aggiornamento della porta di dominio : " + qe.getMessage(),qe);
  344.         } finally {

  346.             this.driver.closeConnection(error,con);
  347.         }
  348.     }   


  351.     protected void updateTipoPortaDominio(String nomePdd,String tipo) throws DriverRegistroServiziException{
  352.         if (nomePdd == null)
  353.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateTipoPortaDominio] Parametro non valido.");
  354.         if (tipo == null)
  355.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateTipoPortaDominio] Parametro.tipo non valido.");

  357.         PreparedStatement stm=null;
  358.         Connection con = null;
  359.         boolean error = false;

  361.         if (this.driver.atomica) {
  362.             try {
  363.                 con = this.driver.getConnectionFromDatasource("updateTipoPortaDominio");
  364.                 con.setAutoCommit(false);
  365.             } catch (Exception e) {
  366.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updatePortaDominio] Exception accedendo al datasource :" + e.getMessage(),e);

  368.             }

  370.         } else
  371.             con = this.driver.globalConnection;

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

  375.         try {

  377.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  378.             sqlQueryObject.addUpdateTable(CostantiDB.PDD);
  379.             sqlQueryObject.addUpdateField("tipo", "?");
  380.             sqlQueryObject.addWhereCondition("nome = ?");
  381.             sqlQueryObject.setANDLogicOperator(true);
  382.             String sqlQuery = sqlQueryObject.createSQLUpdate();
  383.             stm = con.prepareStatement(sqlQuery);

  385.             stm.setString(1, tipo);
  386.             stm.setString(2, nomePdd);

  388.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, tipo, nomePdd));
  389.             stm.executeUpdate();

  391.         } catch (Exception qe) {
  392.             error = true;
  393.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updatePortaDominio] Errore durante l'aggiornamento della porta di dominio : " + qe.getMessage(),qe);
  394.         } finally {

  396.             JDBCUtilities.closeResources(stm);

  398.             this.driver.closeConnection(error,con);
  399.         }
  400.     }   
  401.     
  402.     protected String getTipoPortaDominio(String nome) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  403.         Connection con = null;
  404.         PreparedStatement stm = null;
  405.         ResultSet rs = null;

  407.         if (nome == null)
  408.             throw new DriverRegistroServiziException("Parametro non valido");

  410.         if (nome.equals(""))
  411.             throw new DriverRegistroServiziException("Parametro vuoto non valido");

  413.         if (this.driver.atomica) {
  414.             try {
  415.                 con = this.driver.getConnectionFromDatasource("getTipoPortaDominio");
  416.             } catch (Exception e) {
  417.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getTipoPortaDominio] Exception accedendo al datasource :" + e.getMessage(),e);

  419.             }

  421.         } else
  422.             con = this.driver.globalConnection;

  424.         try {
  425.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  426.             sqlQueryObject.addFromTable(CostantiDB.PDD);
  427.             sqlQueryObject.addSelectField("tipo");
  428.             sqlQueryObject.addWhereCondition("nome = ?");
  429.             sqlQueryObject.setANDLogicOperator(true);
  430.             String sqlQuery = sqlQueryObject.createSQLQuery();
  431.             stm = con.prepareStatement(sqlQuery);
  432.             stm.setString(1, nome);
  433.             rs = stm.executeQuery();
  434.             if (rs.next()){
  435.                 return rs.getString("tipo");
  436.             }
  437.             rs.close();
  438.             stm.close();

  440.             throw new DriverRegistroServiziNotFound("Porta di Dominio ["+nome+"] non esistente");
  441.             
  442.         } catch (DriverRegistroServiziNotFound e) {
  443.             throw e;
  444.         }catch (Exception e) {
  445.             this.driver.log.error("Errore durante verifica esistenza porta di dominio :", e);
  446.             throw new DriverRegistroServiziException(e.getMessage(),e); 
  447.         } finally {

  449.             //Chiudo statement and resultset
  450.             JDBCUtilities.closeResources(rs, stm);

  452.             this.driver.closeConnection(con);
  453.         }

  455.     }


  458.     protected void deletePortaDominio(PortaDominio pdd) throws DriverRegistroServiziException{
  459.         if (pdd == null)
  460.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deletePortaDominio] Parametro non valido.");

  462.         Connection con = null;
  463.         boolean error = false;

  465.         if (this.driver.atomica) {
  466.             try {
  467.                 con = this.driver.getConnectionFromDatasource("deletePortaDominio");
  468.                 con.setAutoCommit(false);
  469.             } catch (Exception e) {
  470.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deletePortaDominio] Exception accedendo al datasource :" + e.getMessage(),e);

  472.             }

  474.         } else
  475.             con = this.driver.globalConnection;

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

  479.         try {
  480.             this.driver.logDebug("CRUDPortaDominio type = 3");
  481.             DriverRegistroServiziDB_soggettiLIB.CRUDPortaDominio(CostantiDB.DELETE, pdd, con);

  483.         } catch (Exception qe) {
  484.             error = true;
  485.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deletePortaDominio] Errore durante l'eliminazione della porta di dominio : " + qe.getMessage(),qe);
  486.         } finally {

  488.             this.driver.closeConnection(error,con);
  489.         }
  490.     }
  491.     
  492.     protected List<PortaDominio> porteDominioList(String superuser, ISearch ricerca) throws DriverRegistroServiziException{
  493.         return this.porteDominioList(superuser, null, ricerca);
  494.     }
  495.     protected List<PortaDominio> porteDominioList(String superuser,String tipo, ISearch ricerca) throws DriverRegistroServiziException{
  496.         String nomeMetodo = "porteDominioList";
  497.         int idLista = Liste.PDD;
  498.         int offset;
  499.         int limit;
  500.         String search;
  501.         String queryString;

  503.         limit = ricerca.getPageSize(idLista);
  504.         offset = ricerca.getIndexIniziale(idLista);
  505.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));


  508.         Connection con = null;
  509.         PreparedStatement stmt = null;
  510.         ResultSet risultato = null;

  512.         ArrayList<PortaDominio> lista = null;

  514.         if (this.driver.atomica) {
  515.             try {
  516.                 con = this.driver.getConnectionFromDatasource("porteDominioList");

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

  521.             }

  523.         } else {
  524.             con = this.driver.globalConnection;
  525.         }

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

  529.         try {

  531.             if (!search.equals("")) {
  532.                 // query con search
  533.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  534.                 sqlQueryObject
  535.                 .addFromTable(CostantiDB.PDD);
  536.                 sqlQueryObject.addSelectCountField("*",
  537.                         "cont");
  538.                 if(this.driver.useSuperUser && superuser!=null && (!superuser.equals("")))
  539.                     sqlQueryObject.addWhereCondition("superuser = ?");
  540.                 if (tipo!=null && (!tipo.equals("")))
  541.                     sqlQueryObject.addWhereCondition("tipo = ?");
  542.                 sqlQueryObject.addWhereLikeCondition(
  543.                         "nome", search, true, true);
  544.                 sqlQueryObject.setANDLogicOperator(true);
  545.                 queryString = sqlQueryObject
  546.                         .createSQLQuery();
  547.             } else {
  548.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  549.                 sqlQueryObject
  550.                 .addFromTable(CostantiDB.PDD);
  551.                 sqlQueryObject.addSelectCountField("*",
  552.                         "cont");
  553.                 if(this.driver.useSuperUser && superuser!=null && (!superuser.equals("")))
  554.                     sqlQueryObject.addWhereCondition("superuser = ?");
  555.                 if (tipo!=null && (!tipo.equals("")))
  556.                     sqlQueryObject.addWhereCondition("tipo = ?");
  557.                 sqlQueryObject.setANDLogicOperator(true);
  558.                 queryString = sqlQueryObject
  559.                         .createSQLQuery();
  560.             }
  561.             stmt = con.prepareStatement(queryString);
  562.             int index = 1;
  563.             if(this.driver.useSuperUser && superuser!=null && (!superuser.equals("")))
  564.                 stmt.setString(index++, superuser);
  565.             if (tipo!=null && (!tipo.equals("")))
  566.                 stmt.setString(index++, tipo);
  567.             risultato = stmt.executeQuery();
  568.             if (risultato.next()) {
  569.                 ricerca.setNumEntries(idLista, risultato.getInt(1));
  570.             }
  571.             risultato.close();
  572.             stmt.close();

  574.             // ricavo le entries
  575.             if (limit == 0) {
  576.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  577.             }
  578.             if (!search.equals("")) {
  579.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  580.                 sqlQueryObject
  581.                 .addFromTable(CostantiDB.PDD);
  582.                 sqlQueryObject.addSelectField("nome");
  583.                 if(this.driver.useSuperUser && superuser!=null && (!superuser.equals("")))
  584.                     sqlQueryObject.addWhereCondition("superuser = ?");
  585.                 if (tipo!=null && (!tipo.equals("")))
  586.                     sqlQueryObject.addWhereCondition("tipo = ?");
  587.                 sqlQueryObject.addWhereLikeCondition(
  588.                         "nome", search, true, true);
  589.                 sqlQueryObject.setANDLogicOperator(true);
  590.                 sqlQueryObject.addOrderBy("nome");
  591.                 sqlQueryObject.setSortType(true);
  592.                 sqlQueryObject.setLimit(limit);
  593.                 sqlQueryObject.setOffset(offset);
  594.                 queryString = sqlQueryObject
  595.                         .createSQLQuery();
  596.             } else {
  597.                 // senza search
  598.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  599.                 sqlQueryObject
  600.                 .addFromTable(CostantiDB.PDD);
  601.                 sqlQueryObject.addSelectField("nome");
  602.                 if(this.driver.useSuperUser && superuser!=null && (!superuser.equals("")))
  603.                     sqlQueryObject.addWhereCondition("superuser = ?");
  604.                 if (tipo!=null && (!tipo.equals("")))
  605.                     sqlQueryObject.addWhereCondition("tipo = ?");
  606.                 sqlQueryObject.setANDLogicOperator(true);
  607.                 sqlQueryObject.addOrderBy("nome");
  608.                 sqlQueryObject.setSortType(true);
  609.                 sqlQueryObject.setLimit(limit);
  610.                 sqlQueryObject.setOffset(offset);
  611.                 queryString = sqlQueryObject
  612.                         .createSQLQuery();
  613.             }
  614.             stmt = con.prepareStatement(queryString);
  615.             index = 1;
  616.             if(this.driver.useSuperUser && superuser!=null && (!superuser.equals("")))
  617.                 stmt.setString(index++, superuser);
  618.             if (tipo!=null && (!tipo.equals("")))
  619.                 stmt.setString(index++, tipo);
  620.             risultato = stmt.executeQuery();

  622.             PortaDominio pdd;
  623.             lista = new ArrayList<PortaDominio>();
  624.             while (risultato.next()) {
  625.                 String nome = risultato.getString("nome");
  626.                 pdd = this.getPortaDominio(nome);
  627.                 lista.add(pdd);
  628.             }

  630.             return lista;

  632.         } catch (Exception se) {

  634.             throw new DriverRegistroServiziException("[DriverControlStationDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  635.         } finally {
  636.             //Chiudo statement and resultset
  637.             JDBCUtilities.closeResources(risultato, stmt);
  638.             this.driver.closeConnection(con);
  639.         }
  640.     }

  642.     protected boolean isPddInUso(PortaDominio pdd, List<String> whereIsInUso)
  643.             throws DriverRegistroServiziException {
  644.         String nomeMetodo = "pddInUso";

  646.         Connection con = null;
  647.         PreparedStatement stmt = null;
  648.         ResultSet risultato = null;
  649.         String queryString;

  651.         if (this.driver.atomica) {
  652.             try {
  653.                 con = this.driver.getConnectionFromDatasource("isPddInUso");

  655.             } catch (Exception e) {
  656.                 throw new DriverRegistroServiziException(
  657.                         "[DriverRegistroServiziDB::" + nomeMetodo
  658.                         + "] Exception accedendo al datasource :"
  659.                         + e.getMessage(), e);

  661.             }

  663.         } else {
  664.             con = this.driver.globalConnection;
  665.         }

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

  669.         try {

  671.             // Controllo che il pdd non sia in uso
  672.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  673.             sqlQueryObject
  674.             .addFromTable(CostantiDB.SOGGETTI);
  675.             sqlQueryObject.addSelectField("*");
  676.             sqlQueryObject
  677.             .addWhereCondition("server = ?");
  678.             queryString = sqlQueryObject
  679.                     .createSQLQuery();
  680.             stmt = con.prepareStatement(queryString);
  681.             stmt.setString(1, pdd.getNome());
  682.             risultato = stmt.executeQuery();
  683.             boolean isInUso = false;
  684.             while (risultato.next()) {
  685.                 String tipo_soggetto = risultato.getString("tipo_soggetto");
  686.                 String nome_soggetto = risultato.getString("nome_soggetto");
  687.                 whereIsInUso.add(tipo_soggetto + "/" + nome_soggetto);
  688.                 isInUso = true;
  689.             }

  691.             return isInUso;

  693.         } catch (Exception se) {
  694.             throw new DriverRegistroServiziException("[DriverRegistroServiziException::"
  695.                     + nomeMetodo + "] Exception: " + se.getMessage(),se);
  696.         } finally {
  697.             // Chiudo statement and resultset
  698.             JDBCUtilities.closeResources(risultato, stmt);
  699.             this.driver.closeConnection(con);
  700.         }
  701.     }

  703.     protected List<Soggetto> pddSoggettiList(long idPdd, ISearch ricerca) throws DriverRegistroServiziException {
  704.         String nomeMetodo = "pddSoggettiList";
  705.         int idLista = Liste.PDD_SOGGETTI;
  706.         int offset;
  707.         int limit;
  708.         String search;
  709.         String queryString;

  711.         limit = ricerca.getPageSize(idLista);
  712.         offset = ricerca.getIndexIniziale(idLista);
  713.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  714.         ricerca.getSearchString(idLista);

  716.         Connection con = null;
  717.         PreparedStatement stmt = null;
  718.         ResultSet risultato = null;

  720.         if (this.driver.atomica) {
  721.             try {
  722.                 con = this.driver.getConnectionFromDatasource("pddSoggettiList");

  724.             } catch (Exception e) {
  725.                 throw new DriverRegistroServiziException(
  726.                         "[DriverRegistroServiziDB::" + nomeMetodo
  727.                         + "] Exception accedendo al datasource :"
  728.                         + e.getMessage(), e);

  730.             }

  732.         } else {
  733.             con = this.driver.globalConnection;
  734.         }

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

  738.         ArrayList<Soggetto> lista = null;

  740.         try {

  742.             // Prendo il nome del pdd
  743.             String nomePdd = "";
  744.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  745.             sqlQueryObject.addFromTable(CostantiDB.PDD);
  746.             sqlQueryObject.addSelectField("*");
  747.             sqlQueryObject.addWhereCondition("id = ?");
  748.             queryString = sqlQueryObject
  749.                     .createSQLQuery();
  750.             stmt = con.prepareStatement(queryString);
  751.             stmt.setLong(1, idPdd);
  752.             risultato = stmt.executeQuery();
  753.             if (risultato.next()) {
  754.                 nomePdd = risultato.getString("nome");
  755.             }
  756.             risultato.close();
  757.             stmt.close();

  759.             if (!search.equals("")) {
  760.                 // query con search
  761.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  762.                 sqlQueryObject
  763.                 .addFromTable(CostantiDB.SOGGETTI);
  764.                 sqlQueryObject.addSelectCountField("*",
  765.                         "cont");
  766.                 sqlQueryObject
  767.                 .addWhereCondition("server = ?");
  768.                 sqlQueryObject.addWhereCondition(false,
  769.                         sqlQueryObject
  770.                         .getWhereLikeCondition("nome_soggetto", search,
  771.                                 true, true),
  772.                                 sqlQueryObject
  773.                                 .getWhereLikeCondition("tipo_soggetto", search,
  774.                                         true, true));
  775.                 sqlQueryObject.setANDLogicOperator(true);
  776.                 queryString = sqlQueryObject
  777.                         .createSQLQuery();
  778.             } else {
  779.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  780.                 sqlQueryObject
  781.                 .addFromTable(CostantiDB.SOGGETTI);
  782.                 sqlQueryObject.addSelectCountField("*",
  783.                         "cont");
  784.                 sqlQueryObject
  785.                 .addWhereCondition("server = ?");
  786.                 queryString = sqlQueryObject
  787.                         .createSQLQuery();
  788.             }
  789.             stmt = con.prepareStatement(queryString);
  790.             stmt.setString(1, nomePdd);
  791.             risultato = stmt.executeQuery();
  792.             if (risultato.next()) {
  793.                 ricerca.setNumEntries(idLista, risultato.getInt(1));
  794.             }
  795.             risultato.close();
  796.             stmt.close();

  798.             // ricavo le entries
  799.             if (limit == 0) {
  800.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  801.             }
  802.             if (!search.equals("")) {
  803.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  804.                 sqlQueryObject
  805.                 .addFromTable(CostantiDB.SOGGETTI);
  806.                 sqlQueryObject.addSelectField("tipo_soggetto");
  807.                 sqlQueryObject.addSelectField("nome_soggetto");
  808.                 sqlQueryObject.addSelectField("server");
  809.                 sqlQueryObject.addSelectField("id");
  810.                 sqlQueryObject
  811.                 .addWhereCondition("server = ?");
  812.                 sqlQueryObject.addWhereCondition(false,
  813.                         sqlQueryObject
  814.                         .getWhereLikeCondition("nome_soggetto", search,
  815.                                 true, true),
  816.                                 sqlQueryObject
  817.                                 .getWhereLikeCondition("tipo_soggetto", search,
  818.                                         true, true));
  819.                 sqlQueryObject.setANDLogicOperator(true);
  820.                 sqlQueryObject
  821.                 .addOrderBy("tipo_soggetto");
  822.                 sqlQueryObject
  823.                 .addOrderBy("nome_soggetto");
  824.                 sqlQueryObject.setSortType(true);
  825.                 sqlQueryObject.setLimit(limit);
  826.                 sqlQueryObject.setOffset(offset);
  827.                 queryString = sqlQueryObject
  828.                         .createSQLQuery();
  829.             } else {
  830.                 // senza search
  831.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  832.                 sqlQueryObject
  833.                 .addFromTable(CostantiDB.SOGGETTI);
  834.                 sqlQueryObject.addSelectField("tipo_soggetto");
  835.                 sqlQueryObject.addSelectField("nome_soggetto");
  836.                 sqlQueryObject.addSelectField("server");
  837.                 sqlQueryObject.addSelectField("id");
  838.                 sqlQueryObject
  839.                 .addWhereCondition("server = ?");
  840.                 sqlQueryObject
  841.                 .addOrderBy("tipo_soggetto");
  842.                 sqlQueryObject
  843.                 .addOrderBy("nome_soggetto");
  844.                 sqlQueryObject.setSortType(true);
  845.                 sqlQueryObject.setLimit(limit);
  846.                 sqlQueryObject.setOffset(offset);
  847.                 queryString = sqlQueryObject
  848.                         .createSQLQuery();
  849.             }
  850.             stmt = con.prepareStatement(queryString);
  851.             stmt.setString(1, nomePdd);
  852.             risultato = stmt.executeQuery();

  854.             lista = new ArrayList<Soggetto>();
  855.             Soggetto sog = null;
  856.             while (risultato.next()) {
  857.                 long ids = risultato.getLong("id");
  858.                 sog = this.driver.getSoggetto(ids,con);
  859.                 lista.add(sog);
  860.             }

  862.             return lista;

  864.         } catch (Exception se) {

  866.             throw new DriverRegistroServiziException("[DriverControlStationDB::"
  867.                     + nomeMetodo + "] Exception: " + se.getMessage(), se);
  868.         } finally {
  869.             // Chiudo statement and resultset
  870.             JDBCUtilities.closeResources(risultato, stmt);
  871.             this.driver.closeConnection(con);
  872.         }

  874.     }
  875.     
  876.     protected List<PortaDominio> porteDominioWithSubject(String subject)throws DriverRegistroServiziException {
  877.         String nomeMetodo = "porteDominioWithSubject";
  878.         String queryString;

  880.         Connection con = null;
  881.         PreparedStatement stmt=null;
  882.         ResultSet risultato=null;
  883.         ArrayList<PortaDominio> lista = new ArrayList<>();

  885.         if (this.driver.atomica) {
  886.             try {
  887.                 con = this.driver.getConnectionFromDatasource("porteDominioWithSubject");
  888.             } catch (Exception e) {
  889.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  891.             }

  893.         } else
  894.             con = this.driver.globalConnection;

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

  898.         try {

  900.             Map<String, List<String>> hashSubject = CertificateUtils.getPrincipalIntoMap(subject, PrincipalType.SUBJECT);

  902.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  903.             sqlQueryObject.addFromTable(CostantiDB.PDD);
  904.             sqlQueryObject.addSelectField("nome");
  905.             sqlQueryObject.addSelectField("subject");
  906.             for (String key : hashSubject.keySet()) {               
  907.                 List<String> listValues = hashSubject.get(key);
  908.                 for (String value : listValues) {
  909.                     sqlQueryObject.addWhereLikeCondition("subject", "/"+CertificateUtils.formatKeyPrincipal(key)+"="+CertificateUtils.formatValuePrincipal(value)+"/", true, false);
  910.                 }
  911.             }
  912.             sqlQueryObject.setANDLogicOperator(true);
  913.             queryString = sqlQueryObject.createSQLQuery();
  914.             stmt = con.prepareStatement(queryString);

  916.             risultato = stmt.executeQuery();

  918.             PortaDominio pdd;
  919.             while (risultato.next()) {

  921.                 // Possono esistere piu' pdd che hanno una porzione di subject uguale, devo quindi verificare che sia proprio quello che cerco
  922.                 String subjectPotenziale =  risultato.getString("subject");
  923.                 if(CertificateUtils.sslVerify(subjectPotenziale, subject, PrincipalType.SUBJECT, this.driver.log)){
  924.                     pdd=this.getPortaDominio(risultato.getString("nome"));
  925.                     lista.add(pdd);
  926.                 }
  927.             }

  929.             return lista;

  931.         } catch (Exception qe) {
  932.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  933.         } finally {

  935.             //Chiudo statement and resultset
  936.             JDBCUtilities.closeResources(risultato, stmt);

  938.             this.driver.closeConnection(con);
  939.         }
  940.     }
  941. }
Created with JaCoCo 0.8.8.202204050719