DriverConfigurazioneDB_porteApplicativeSearchDriver.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.  */
  20. package org.openspcoop2.core.config.driver.db;

  22. import java.sql.Connection;
  23. import java.sql.PreparedStatement;
  24. import java.sql.ResultSet;
  25. import java.util.ArrayList;
  26. import java.util.List;

  28. import org.apache.commons.lang.StringUtils;
  29. import org.openspcoop2.core.commons.Filtri;
  30. import org.openspcoop2.core.commons.ISearch;
  31. import org.openspcoop2.core.commons.Liste;
  32. import org.openspcoop2.core.commons.SearchUtils;
  33. import org.openspcoop2.core.config.CorrelazioneApplicativaElemento;
  34. import org.openspcoop2.core.config.CorrelazioneApplicativaRispostaElemento;
  35. import org.openspcoop2.core.config.MessageSecurityFlowParameter;
  36. import org.openspcoop2.core.config.MtomProcessorFlowParameter;
  37. import org.openspcoop2.core.config.PortaApplicativa;
  38. import org.openspcoop2.core.config.PortaApplicativaAutorizzazioneServizioApplicativo;
  39. import org.openspcoop2.core.config.PortaApplicativaAutorizzazioneSoggetto;
  40. import org.openspcoop2.core.config.PortaApplicativaAzione;
  41. import org.openspcoop2.core.config.Proprieta;
  42. import org.openspcoop2.core.config.ServizioApplicativo;
  43. import org.openspcoop2.core.config.constants.PortaApplicativaAzioneIdentificazione;
  44. import org.openspcoop2.core.config.constants.StatoFunzionalita;
  45. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  46. import org.openspcoop2.core.constants.CostantiDB;
  47. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  48. import org.openspcoop2.utils.sql.ISQLQueryObject;
  49. import org.openspcoop2.utils.sql.SQLObjectFactory;

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

  62.     private DriverConfigurazioneDB driver = null;
  63.     private DriverConfigurazioneDB_porteApplicativeDriver porteApplicativeDriver = null;
  64.     
  65.     protected DriverConfigurazioneDB_porteApplicativeSearchDriver(DriverConfigurazioneDB driver) {
  66.         this.driver = driver;
  67.         this.porteApplicativeDriver = new DriverConfigurazioneDB_porteApplicativeDriver(driver);
  68.     }
  69.     
  70.     protected List<String> portaApplicativaRuoliList(long idPA, ISearch ricerca) throws DriverConfigurazioneException {
  71.         String nomeMetodo = "portaApplicativaRuoliList";
  72.         int idLista = Liste.PORTE_APPLICATIVE_RUOLI;
  73.         String nomeTabella = CostantiDB.PORTE_APPLICATIVE_RUOLI;
  74.         return _portaApplicativaRuoliList(idPA, ricerca,
  75.                 nomeMetodo, nomeTabella, idLista);
  76.     }
  77.     protected List<String> portaApplicativaRuoliTokenList(long idPA, ISearch ricerca) throws DriverConfigurazioneException {
  78.         String nomeMetodo = "portaApplicativaRuoliTokenList";
  79.         int idLista = Liste.PORTE_APPLICATIVE_TOKEN_RUOLI;
  80.         String nomeTabella = CostantiDB.PORTE_APPLICATIVE_TOKEN_RUOLI;
  81.         return _portaApplicativaRuoliList(idPA, ricerca,
  82.                 nomeMetodo, nomeTabella, idLista);
  83.     }
  84.     private List<String> _portaApplicativaRuoliList(long idPA, ISearch ricerca,
  85.             String nomeMetodo, String nomeTabella, int idLista) throws DriverConfigurazioneException {
  86.         int offset;
  87.         int limit;
  88.         String search;
  89.         String queryString;

  91.         limit = ricerca.getPageSize(idLista);
  92.         offset = ricerca.getIndexIniziale(idLista);
  93.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));

  95.         Connection con = null;
  96.         PreparedStatement stmt = null;
  97.         ResultSet risultato = null;

  99.         if (this.driver.atomica) {
  100.             try {
  101.                 con = this.driver.getConnectionFromDatasource(nomeMetodo);
  102.             } catch (Exception e) {
  103.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  105.             }

  107.         } else
  108.             con = this.driver.globalConnection;

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

  112.         List<String> listIdRuoli = null;
  113.         try {

  115.             if (!search.equals("")) {
  116.                 //query con search
  117.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  118.                 sqlQueryObject.addFromTable(nomeTabella);
  119.                 sqlQueryObject.addSelectCountField("*", "cont");
  120.                 sqlQueryObject.addWhereCondition(nomeTabella+".id_porta=?");
  121.                 sqlQueryObject.addWhereLikeCondition(nomeTabella+".ruolo", search, true, true); 
  122.                 
  123.                 sqlQueryObject.setSelectDistinct(true);
  124.                 sqlQueryObject.setANDLogicOperator(true);
  125.                 queryString = sqlQueryObject.createSQLQuery();
  126.             } else {
  127.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  128.                 sqlQueryObject.addFromTable(nomeTabella);
  129.                 sqlQueryObject.addSelectCountField("*", "cont");
  130.                 sqlQueryObject.addWhereCondition(nomeTabella+".id_porta=?");

  132.                 sqlQueryObject.setSelectDistinct(true);
  133.                 sqlQueryObject.setANDLogicOperator(true);
  134.                 queryString = sqlQueryObject.createSQLQuery();
  135.             }
  136.             stmt = con.prepareStatement(queryString);
  137.             stmt.setLong(1, idPA);

  139.             risultato = stmt.executeQuery();
  140.             if (risultato.next())
  141.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  142.             risultato.close();
  143.             stmt.close();

  145.             // ricavo le entries
  146.             if (limit == 0) // con limit
  147.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  148.             if (!search.equals("")) { // con search
  149.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  150.                 sqlQueryObject.addFromTable(nomeTabella);
  151.                 sqlQueryObject.addSelectField(nomeTabella+".ruolo");
  152.                 sqlQueryObject.addWhereCondition(nomeTabella+".id_porta=?");
  153.                 sqlQueryObject.addWhereLikeCondition(nomeTabella+".ruolo", search, true, true); 
  154.                 
  155.                 sqlQueryObject.setSelectDistinct(true);
  156.                 sqlQueryObject.setANDLogicOperator(true);
  157.                 sqlQueryObject.addOrderBy(nomeTabella+".ruolo");
  158.                 sqlQueryObject.setSortType(true);
  159.                 sqlQueryObject.setLimit(limit);
  160.                 sqlQueryObject.setOffset(offset);
  161.                 queryString = sqlQueryObject.createSQLQuery();
  162.             } else {
  163.                 // senza search
  164.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  165.                 sqlQueryObject.addFromTable(nomeTabella);
  166.                 sqlQueryObject.addSelectField(nomeTabella+".ruolo");
  167.                 sqlQueryObject.addWhereCondition(nomeTabella+".id_porta=?");
  168.                 
  169.                 sqlQueryObject.setSelectDistinct(true);
  170.                 sqlQueryObject.setANDLogicOperator(true);
  171.                 sqlQueryObject.addOrderBy(nomeTabella+".ruolo");
  172.                 sqlQueryObject.setSortType(true);
  173.                 sqlQueryObject.setLimit(limit);
  174.                 sqlQueryObject.setOffset(offset);
  175.                 queryString = sqlQueryObject.createSQLQuery();
  176.             }
  177.             stmt = con.prepareStatement(queryString);
  178.             stmt.setLong(1, idPA);

  180.             risultato = stmt.executeQuery();

  182.             listIdRuoli = new ArrayList<>();
  183.             while (risultato.next()) {

  185.                 listIdRuoli.add(risultato.getString(1));

  187.             }

  189.         } catch (Exception qe) {
  190.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  191.         } finally {

  193.             //Chiudo statement and resultset
  194.             JDBCUtilities.closeResources(risultato, stmt);

  196.             this.driver.closeConnection(con);
  197.         }
  198.         
  199.         return listIdRuoli;
  200.     }
  201.     
  202.     protected List<String> portaApplicativaScopeList(long idPA, ISearch ricerca) throws DriverConfigurazioneException {
  203.         String nomeMetodo = "portaApplicativaScopeList";
  204.         int idLista = Liste.PORTE_APPLICATIVE_SCOPE;
  205.         int offset;
  206.         int limit;
  207.         String search;
  208.         String queryString;

  210.         limit = ricerca.getPageSize(idLista);
  211.         offset = ricerca.getIndexIniziale(idLista);
  212.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));

  214.         Connection con = null;
  215.         PreparedStatement stmt = null;
  216.         ResultSet risultato = null;

  218.         if (this.driver.atomica) {
  219.             try {
  220.                 con = this.driver.getConnectionFromDatasource(nomeMetodo);
  221.             } catch (Exception e) {
  222.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  224.             }

  226.         } else
  227.             con = this.driver.globalConnection;

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

  231.         List<String> listIdScope = null;
  232.         try {

  234.             if (!search.equals("")) {
  235.                 //query con search
  236.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  237.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_SCOPE);
  238.                 sqlQueryObject.addSelectCountField("*", "cont");
  239.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_APPLICATIVE_SCOPE+".id_porta=?");
  240.                 sqlQueryObject.addWhereLikeCondition(CostantiDB.PORTE_APPLICATIVE_SCOPE+".scope", search, true, true);  
  241.                 
  242.                 sqlQueryObject.setSelectDistinct(true);
  243.                 sqlQueryObject.setANDLogicOperator(true);
  244.                 queryString = sqlQueryObject.createSQLQuery();
  245.             } else {
  246.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  247.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_SCOPE);
  248.                 sqlQueryObject.addSelectCountField("*", "cont");
  249.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_APPLICATIVE_SCOPE+".id_porta=?");

  251.                 sqlQueryObject.setSelectDistinct(true);
  252.                 sqlQueryObject.setANDLogicOperator(true);
  253.                 queryString = sqlQueryObject.createSQLQuery();
  254.             }
  255.             stmt = con.prepareStatement(queryString);
  256.             stmt.setLong(1, idPA);

  258.             risultato = stmt.executeQuery();
  259.             if (risultato.next())
  260.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  261.             risultato.close();
  262.             stmt.close();

  264.             // ricavo le entries
  265.             if (limit == 0) // con limit
  266.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  267.             if (!search.equals("")) { // con search
  268.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  269.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_SCOPE);
  270.                 sqlQueryObject.addSelectField(CostantiDB.PORTE_APPLICATIVE_SCOPE+".scope");
  271.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_APPLICATIVE_SCOPE+".id_porta=?");
  272.                 sqlQueryObject.addWhereLikeCondition(CostantiDB.PORTE_APPLICATIVE_SCOPE+".scope", search, true, true);  
  273.                 
  274.                 sqlQueryObject.setSelectDistinct(true);
  275.                 sqlQueryObject.setANDLogicOperator(true);
  276.                 sqlQueryObject.addOrderBy(CostantiDB.PORTE_APPLICATIVE_SCOPE+".scope");
  277.                 sqlQueryObject.setSortType(true);
  278.                 sqlQueryObject.setLimit(limit);
  279.                 sqlQueryObject.setOffset(offset);
  280.                 queryString = sqlQueryObject.createSQLQuery();
  281.             } else {
  282.                 // senza search
  283.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  284.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_SCOPE);
  285.                 sqlQueryObject.addSelectField(CostantiDB.PORTE_APPLICATIVE_SCOPE+".scope");
  286.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_APPLICATIVE_SCOPE+".id_porta=?");
  287.                 
  288.                 sqlQueryObject.setSelectDistinct(true);
  289.                 sqlQueryObject.setANDLogicOperator(true);
  290.                 sqlQueryObject.addOrderBy(CostantiDB.PORTE_APPLICATIVE_SCOPE+".scope");
  291.                 sqlQueryObject.setSortType(true);
  292.                 sqlQueryObject.setLimit(limit);
  293.                 sqlQueryObject.setOffset(offset);
  294.                 queryString = sqlQueryObject.createSQLQuery();
  295.             }
  296.             stmt = con.prepareStatement(queryString);
  297.             stmt.setLong(1, idPA);

  299.             risultato = stmt.executeQuery();

  301.             listIdScope = new ArrayList<>();
  302.             while (risultato.next()) {

  304.                 listIdScope.add(risultato.getString(1));

  306.             }

  308.         } catch (Exception qe) {
  309.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  310.         } finally {

  312.             //Chiudo statement and resultset
  313.             JDBCUtilities.closeResources(risultato, stmt);

  315.             this.driver.closeConnection(con);
  316.         }
  317.         
  318.         return listIdScope;
  319.     }
  320.     
  321.     
  322.     protected List<PortaApplicativa> porteAppList(long idSoggetto, ISearch ricerca) throws DriverConfigurazioneException {
  323.         int offset;
  324.         int limit;
  325.         int idLista=Liste.PORTE_APPLICATIVE_BY_SOGGETTO;
  326.         String search;
  327.         String queryString;

  329.         limit = ricerca.getPageSize(idLista);
  330.         offset = ricerca.getIndexIniziale(idLista);
  331.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));

  333.         Connection con = null;
  334.         PreparedStatement stm=null;
  335.         ResultSet rs=null;
  336.         ArrayList<PortaApplicativa> lista = new ArrayList<>();

  338.         if (this.driver.atomica) {
  339.             try {
  340.                 con = this.driver.getConnectionFromDatasource("porteAppList");
  341.             } catch (Exception e) {
  342.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteAppList] Exception accedendo al datasource :" + e.getMessage(),e);

  344.             }

  346.         } else
  347.             con = this.driver.globalConnection;

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

  351.         try {

  353.             if (!search.equals("")) {
  354.                 //query con search
  355.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  356.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE);
  357.                 sqlQueryObject.addSelectCountField("*", "cont");
  358.                 sqlQueryObject.addWhereCondition("id_soggetto = ?");
  359.                 sqlQueryObject.addWhereLikeCondition("nome_porta",search,true, true);
  360.                 sqlQueryObject.setANDLogicOperator(true);
  361.                 queryString = sqlQueryObject.createSQLQuery();
  362.             } else {
  363.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  364.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE);
  365.                 sqlQueryObject.addSelectCountField("*", "cont");
  366.                 sqlQueryObject.addWhereCondition("id_soggetto = ?");
  367.                 queryString = sqlQueryObject.createSQLQuery();
  368.             }
  369.             stm = con.prepareStatement(queryString);
  370.             stm.setLong(1, idSoggetto);
  371.             rs = stm.executeQuery();
  372.             if (rs.next())
  373.                 ricerca.setNumEntries(idLista,rs.getInt(1));
  374.             rs.close();
  375.             stm.close();

  377.             // ricavo le entries
  378.             if (limit == 0) // con limit
  379.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  380.             if (!search.equals("")) { // con search
  381.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  382.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE);
  383.                 sqlQueryObject.addSelectField("id");
  384.                 sqlQueryObject.addSelectField("nome_porta");
  385.                 sqlQueryObject.addSelectField("id_soggetto");
  386.                 sqlQueryObject.addWhereCondition("id_soggetto = ?");
  387.                 sqlQueryObject.addWhereLikeCondition("nome_porta",search,true, true);
  388.                 sqlQueryObject.setANDLogicOperator(true);
  389.                 sqlQueryObject.addOrderBy("nome_porta");
  390.                 sqlQueryObject.setSortType(true);
  391.                 sqlQueryObject.setLimit(limit);
  392.                 sqlQueryObject.setOffset(offset);
  393.                 queryString = sqlQueryObject.createSQLQuery();
  394.             } else {
  395.                 // senza search
  396.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  397.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE);
  398.                 sqlQueryObject.addSelectField("id");
  399.                 sqlQueryObject.addSelectField("nome_porta");
  400.                 sqlQueryObject.addSelectField("id_soggetto");
  401.                 sqlQueryObject.addWhereCondition("id_soggetto = ?");
  402.                 sqlQueryObject.addOrderBy("nome_porta");
  403.                 sqlQueryObject.setSortType(true);
  404.                 sqlQueryObject.setLimit(limit);
  405.                 sqlQueryObject.setOffset(offset);
  406.                 queryString = sqlQueryObject.createSQLQuery();
  407.             }

  409.             stm = con.prepareStatement(queryString);
  410.             stm.setLong(1, idSoggetto);
  411.             rs = stm.executeQuery();

  413.             PortaApplicativa pa = null;
  414.             while (rs.next()) {
  415.                 pa = this.porteApplicativeDriver.getPortaApplicativa(rs.getLong("id"),con);
  416.                 lista.add(pa);
  417.             }

  419.             return lista;

  421.         } catch (Exception qe) {
  422.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteAppList] Errore : " + qe.getMessage(),qe);
  423.         } finally {
  424.             //Chiudo statement and resultset
  425.             JDBCUtilities.closeResources(rs, stm);

  427.             this.driver.closeConnection(con);
  428.         }

  430.     }
  431.     /**
  432.      * Ritorna la lista di tutte le Porte Applicative
  433.      * @param ricerca
  434.      * @return Una lista di Porte Applicative
  435.      * @throws DriverConfigurazioneException
  436.      */
  437.     protected List<PortaApplicativa> porteAppList(String superuser, ISearch ricerca) throws DriverConfigurazioneException {
  438.         int offset;
  439.         int limit;
  440.         int idLista=Liste.PORTE_APPLICATIVE;
  441.         String search;
  442.         String queryString;

  444.         limit = ricerca.getPageSize(idLista);
  445.         offset = ricerca.getIndexIniziale(idLista);
  446.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));

  448.         String filterProtocollo = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_PROTOCOLLO);
  449.         String filterProtocolli = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_PROTOCOLLI);
  450.         List<String> tipoSoggettiProtocollo = null;
  451.         try {
  452.             tipoSoggettiProtocollo = Filtri.convertToTipiSoggetti(filterProtocollo, filterProtocolli);
  453.         }catch(Exception e) {
  454.             throw new DriverConfigurazioneException(e.getMessage(),e);
  455.         }
  456.         
  457.         this.driver.logDebug("search : " + search);
  458.         this.driver.logDebug("filterProtocollo : " + filterProtocollo);
  459.         this.driver.logDebug("filterProtocolli : " + filterProtocolli);
  460.         
  461.         Connection con = null;
  462.         PreparedStatement stm=null;
  463.         ResultSet rs=null;
  464.         ArrayList<PortaApplicativa> lista = new ArrayList<>();

  466.         if (this.driver.atomica) {
  467.             try {
  468.                 con = this.driver.getConnectionFromDatasource("porteAppList");
  469.             } catch (Exception e) {
  470.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteAppList] Exception accedendo al datasource :" + e.getMessage(),e);

  472.             }

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

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

  479.         try {

  481.             if (!search.equals("")) {
  482.                 //query con search
  483.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  484.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE);
  485.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  486.                 sqlQueryObject.addSelectCountField("*", "cont");
  487.                 sqlQueryObject.addWhereCondition("id_soggetto = "+CostantiDB.SOGGETTI+".id");
  488.                 if(this.driver.useSuperUser && superuser!=null && (!"".equals(superuser)))
  489.                     sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".superuser = ?");
  490.                 sqlQueryObject.addWhereLikeCondition("nome_porta",search,true, true);
  491.                 if(tipoSoggettiProtocollo!=null && tipoSoggettiProtocollo.size()>0) {
  492.                     sqlQueryObject.addWhereINCondition("tipo_soggetto", true, tipoSoggettiProtocollo.toArray(new String[1]));
  493.                 }
  494.                 sqlQueryObject.setANDLogicOperator(true);
  495.                 queryString = sqlQueryObject.createSQLQuery();
  496.             } else {
  497.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  498.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE);
  499.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  500.                 sqlQueryObject.addSelectCountField("*", "cont");
  501.                 sqlQueryObject.addWhereCondition("id_soggetto = "+CostantiDB.SOGGETTI+".id");
  502.                 if(this.driver.useSuperUser && superuser!=null && (!"".equals(superuser)))
  503.                     sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".superuser = ?");
  504.                 if(tipoSoggettiProtocollo!=null && tipoSoggettiProtocollo.size()>0) {
  505.                     sqlQueryObject.addWhereINCondition("tipo_soggetto", true, tipoSoggettiProtocollo.toArray(new String[1]));
  506.                 }
  507.                 sqlQueryObject.setANDLogicOperator(true);
  508.                 queryString = sqlQueryObject.createSQLQuery();
  509.             }
  510.             stm = con.prepareStatement(queryString);
  511.             if(this.driver.useSuperUser && superuser!=null && (!"".equals(superuser)))
  512.                 stm.setString(1, superuser);
  513.             rs = stm.executeQuery();
  514.             if (rs.next())
  515.                 ricerca.setNumEntries(idLista,rs.getInt(1));
  516.             rs.close();
  517.             stm.close();

  519.             // ricavo le entries
  520.             if (limit == 0) // con limit
  521.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  522.             if (!search.equals("")) { // con search
  523.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  524.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE);
  525.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  526.                 sqlQueryObject.addSelectField(CostantiDB.PORTE_APPLICATIVE+".id");
  527.                 sqlQueryObject.addSelectField("nome_porta");
  528.                 sqlQueryObject.addWhereCondition("id_soggetto = "+CostantiDB.SOGGETTI+".id");
  529.                 if(this.driver.useSuperUser && superuser!=null && (!"".equals(superuser)))
  530.                     sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".superuser = ?");
  531.                 sqlQueryObject.addWhereLikeCondition("nome_porta",search,true, true);
  532.                 if(tipoSoggettiProtocollo!=null && tipoSoggettiProtocollo.size()>0) {
  533.                     sqlQueryObject.addWhereINCondition("tipo_soggetto", true, tipoSoggettiProtocollo.toArray(new String[1]));
  534.                 }
  535.                 sqlQueryObject.setANDLogicOperator(true);
  536.                 sqlQueryObject.addOrderBy("nome_porta");
  537.                 sqlQueryObject.setSortType(true);
  538.                 sqlQueryObject.setLimit(limit);
  539.                 sqlQueryObject.setOffset(offset);
  540.                 queryString = sqlQueryObject.createSQLQuery();
  541.             } else {
  542.                 // senza search
  543.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  544.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE);
  545.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  546.                 sqlQueryObject.addSelectField(CostantiDB.PORTE_APPLICATIVE+".id");
  547.                 sqlQueryObject.addSelectField("nome_porta");
  548.                 sqlQueryObject.addWhereCondition("id_soggetto = "+CostantiDB.SOGGETTI+".id");
  549.                 if(this.driver.useSuperUser && superuser!=null && (!"".equals(superuser)))
  550.                     sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".superuser = ?");
  551.                 if(tipoSoggettiProtocollo!=null && tipoSoggettiProtocollo.size()>0) {
  552.                     sqlQueryObject.addWhereINCondition("tipo_soggetto", true, tipoSoggettiProtocollo.toArray(new String[1]));
  553.                 }
  554.                 sqlQueryObject.setANDLogicOperator(true);
  555.                 sqlQueryObject.addOrderBy("nome_porta");
  556.                 sqlQueryObject.setSortType(true);
  557.                 sqlQueryObject.setLimit(limit);
  558.                 sqlQueryObject.setOffset(offset);
  559.                 queryString = sqlQueryObject.createSQLQuery();
  560.             }

  562.             stm = con.prepareStatement(queryString);
  563.             if(this.driver.useSuperUser && superuser!=null && (!"".equals(superuser)))
  564.                 stm.setString(1, superuser);
  565.             rs = stm.executeQuery();

  567.             PortaApplicativa pa = null;
  568.             while (rs.next()) {

  570.                 pa = this.porteApplicativeDriver.getPortaApplicativa(rs.getLong("id"),con);

  572.                 lista.add(pa);

  574.             }

  576.             return lista;

  578.         } catch (Exception qe) {
  579.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteAppList] Errore : " + qe.getMessage(),qe);
  580.         } finally {
  581.             //Chiudo statement and resultset
  582.             JDBCUtilities.closeResources(rs, stm);

  584.             this.driver.closeConnection(con);
  585.         }

  587.     }

  589.     /**
  590.      * Ritorna la lista di proprieta di una Porta Applicativa
  591.      */
  592.     protected List<Proprieta> porteAppPropList(long idPortaApplicativa, ISearch ricerca) throws DriverConfigurazioneException {
  593.         int offset;
  594.         int limit;
  595.         int idLista = Liste.PORTE_APPLICATIVE_PROP;
  596.         String search;
  597.         String queryString;

  599.         limit = ricerca.getPageSize(idLista);
  600.         offset = ricerca.getIndexIniziale(idLista);
  601.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));      


  604.         Connection con = null;
  605.         PreparedStatement stmt=null;
  606.         ResultSet risultato=null;
  607.         ArrayList<Proprieta> lista = new ArrayList<>();

  609.         if (this.driver.atomica) {
  610.             try {
  611.                 con = this.driver.getConnectionFromDatasource("porteAppPropList");
  612.             } catch (Exception e) {
  613.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteAppPropList] Exception accedendo al datasource :" + e.getMessage(),e);

  615.             }

  617.         } else
  618.             con = this.driver.globalConnection;

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

  622.         try {

  624.             if (!search.equals("")) {
  625.                 //query con search
  626.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  627.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_PROP);
  628.                 sqlQueryObject.addSelectCountField("*", "cont");
  629.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  630.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  631.                 sqlQueryObject.setANDLogicOperator(true);
  632.                 queryString = sqlQueryObject.createSQLQuery();
  633.             } else {
  634.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  635.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_PROP);
  636.                 sqlQueryObject.addSelectCountField("*", "cont");
  637.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  638.                 queryString = sqlQueryObject.createSQLQuery();
  639.             }
  640.             stmt = con.prepareStatement(queryString);
  641.             stmt.setLong(1, idPortaApplicativa);
  642.             risultato = stmt.executeQuery();
  643.             if (risultato.next())
  644.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  645.             risultato.close();
  646.             stmt.close();

  648.             // ricavo le entries
  649.             if (limit == 0) // con limit
  650.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  651.             if (!search.equals("")) { // con search
  652.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  653.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_PROP);
  654.                 sqlQueryObject.addSelectField("id_porta");
  655.                 sqlQueryObject.addSelectField("nome");
  656.                 sqlQueryObject.addSelectField("valore");
  657.                 sqlQueryObject.addSelectField("enc_value");
  658.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  659.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  660.                 sqlQueryObject.setANDLogicOperator(true);
  661.                 sqlQueryObject.addOrderBy("nome");
  662.                 sqlQueryObject.setSortType(true);
  663.                 sqlQueryObject.setLimit(limit);
  664.                 sqlQueryObject.setOffset(offset);
  665.                 queryString = sqlQueryObject.createSQLQuery();
  666.             } else {
  667.                 // senza search
  668.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  669.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_PROP);
  670.                 sqlQueryObject.addSelectField("id_porta");
  671.                 sqlQueryObject.addSelectField("nome");
  672.                 sqlQueryObject.addSelectField("valore");
  673.                 sqlQueryObject.addSelectField("enc_value");
  674.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  675.                 sqlQueryObject.addOrderBy("nome");
  676.                 sqlQueryObject.setSortType(true);
  677.                 sqlQueryObject.setLimit(limit);
  678.                 sqlQueryObject.setOffset(offset);
  679.                 queryString = sqlQueryObject.createSQLQuery();
  680.             }
  681.             stmt = con.prepareStatement(queryString);
  682.             stmt.setLong(1, idPortaApplicativa);
  683.             risultato = stmt.executeQuery();

  685.             Proprieta prop = null;
  686.             while (risultato.next()) {

  688.                 prop = new Proprieta();

  690.                 prop.setId(risultato.getLong("id_porta"));
  691.                 prop.setNome(risultato.getString("nome"));
  692.                 
  693.                 String plainValue = risultato.getString("valore");
  694.                 String encValue = risultato.getString("enc_value");
  695.                 if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  696.                     prop.setValore(encValue);
  697.                 }
  698.                 else {
  699.                     prop.setValore(plainValue);
  700.                 }

  702.                 lista.add(prop);
  703.             }

  705.             return lista;

  707.         } catch (Exception qe) {
  708.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteAppPropList] Errore : " + qe.getMessage(),qe);
  709.         } finally {
  710.             //Chiudo statement and resultset
  711.             JDBCUtilities.closeResources(risultato, stmt);
  712.             this.driver.closeConnection(con);
  713.         }
  714.     }
  715.     
  716.     protected List<Proprieta> porteApplicativeAutenticazioneCustomPropList(long idPortaApplicativa, ISearch ricerca) throws DriverConfigurazioneException {
  717.         int offset;
  718.         int limit;
  719.         int idLista = Liste.PORTE_APPLICATIVE_PROPRIETA_AUTENTICAZIONE;
  720.         String search;
  721.         String queryString;

  723.         limit = ricerca.getPageSize(idLista);
  724.         offset = ricerca.getIndexIniziale(idLista);
  725.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));      


  728.         Connection con = null;
  729.         PreparedStatement stmt=null;
  730.         ResultSet risultato=null;
  731.         ArrayList<Proprieta> lista = new ArrayList<>();

  733.         if (this.driver.atomica) {
  734.             try {
  735.                 con = this.driver.getConnectionFromDatasource("porteApplicativeAutorizzazioneCustomPropList");
  736.             } catch (Exception e) {
  737.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteAppPropList] Exception accedendo al datasource :" + e.getMessage(),e);

  739.             }

  741.         } else
  742.             con = this.driver.globalConnection;

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

  746.         try {

  748.             if (!search.equals("")) {
  749.                 //query con search
  750.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  751.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_AUTENTICAZIONE_PROP);
  752.                 sqlQueryObject.addSelectCountField("*", "cont");
  753.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  754.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  755.                 sqlQueryObject.setANDLogicOperator(true);
  756.                 queryString = sqlQueryObject.createSQLQuery();
  757.             } else {
  758.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  759.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_AUTENTICAZIONE_PROP);
  760.                 sqlQueryObject.addSelectCountField("*", "cont");
  761.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  762.                 queryString = sqlQueryObject.createSQLQuery();
  763.             }
  764.             stmt = con.prepareStatement(queryString);
  765.             stmt.setLong(1, idPortaApplicativa);
  766.             risultato = stmt.executeQuery();
  767.             if (risultato.next())
  768.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  769.             risultato.close();
  770.             stmt.close();

  772.             // ricavo le entries
  773.             if (limit == 0) // con limit
  774.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  775.             if (!search.equals("")) { // con search
  776.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  777.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_AUTENTICAZIONE_PROP);
  778.                 sqlQueryObject.addSelectField("id");
  779.                 sqlQueryObject.addSelectField("id_porta");
  780.                 sqlQueryObject.addSelectField("nome");
  781.                 sqlQueryObject.addSelectField("valore");
  782.                 sqlQueryObject.addSelectField("enc_value");
  783.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  784.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  785.                 sqlQueryObject.setANDLogicOperator(true);
  786.                 sqlQueryObject.addOrderBy("nome");
  787.                 sqlQueryObject.setSortType(true);
  788.                 sqlQueryObject.setLimit(limit);
  789.                 sqlQueryObject.setOffset(offset);
  790.                 queryString = sqlQueryObject.createSQLQuery();
  791.             } else {
  792.                 // senza search
  793.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  794.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_AUTENTICAZIONE_PROP);
  795.                 sqlQueryObject.addSelectField("id");
  796.                 sqlQueryObject.addSelectField("id_porta");
  797.                 sqlQueryObject.addSelectField("nome");
  798.                 sqlQueryObject.addSelectField("valore");
  799.                 sqlQueryObject.addSelectField("enc_value");
  800.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  801.                 sqlQueryObject.addOrderBy("nome");
  802.                 sqlQueryObject.setSortType(true);
  803.                 sqlQueryObject.setLimit(limit);
  804.                 sqlQueryObject.setOffset(offset);
  805.                 queryString = sqlQueryObject.createSQLQuery();
  806.             }
  807.             stmt = con.prepareStatement(queryString);
  808.             stmt.setLong(1, idPortaApplicativa);
  809.             risultato = stmt.executeQuery();

  811.             Proprieta prop = null;
  812.             while (risultato.next()) {

  814.                 prop = new Proprieta();

  816.                 prop.setId(risultato.getLong("id"));
  817.                 prop.setNome(risultato.getString("nome"));
  818.                 
  819.                 String plainValue = risultato.getString("valore");
  820.                 String encValue = risultato.getString("enc_value");
  821.                 if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  822.                     prop.setValore(encValue);
  823.                 }
  824.                 else {
  825.                     prop.setValore(plainValue);
  826.                 }

  828.                 lista.add(prop);
  829.             }

  831.             return lista;

  833.         } catch (Exception qe) {
  834.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteAppPropList] Errore : " + qe.getMessage(),qe);
  835.         } finally {
  836.             //Chiudo statement and resultset
  837.             JDBCUtilities.closeResources(risultato, stmt);
  838.             this.driver.closeConnection(con);
  839.         }
  840.     }
  841.     
  842.     /**
  843.      * Ritorna la lista di proprieta per l'autorizzazione custom di una Porta Applicativa
  844.      */
  845.     protected List<Proprieta> porteApplicativeAutorizzazioneCustomPropList(long idPortaApplicativa, ISearch ricerca) throws DriverConfigurazioneException {
  846.         int offset;
  847.         int limit;
  848.         int idLista = Liste.PORTE_APPLICATIVE_PROPRIETA_AUTORIZZAZIONE;
  849.         String search;
  850.         String queryString;

  852.         limit = ricerca.getPageSize(idLista);
  853.         offset = ricerca.getIndexIniziale(idLista);
  854.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));      


  857.         Connection con = null;
  858.         PreparedStatement stmt=null;
  859.         ResultSet risultato=null;
  860.         ArrayList<Proprieta> lista = new ArrayList<>();

  862.         if (this.driver.atomica) {
  863.             try {
  864.                 con = this.driver.getConnectionFromDatasource("porteApplicativeAutorizzazioneCustomPropList");
  865.             } catch (Exception e) {
  866.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteAppPropList] Exception accedendo al datasource :" + e.getMessage(),e);

  868.             }

  870.         } else
  871.             con = this.driver.globalConnection;

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

  875.         try {

  877.             if (!search.equals("")) {
  878.                 //query con search
  879.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  880.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_AUTORIZZAZIONE_PROP);
  881.                 sqlQueryObject.addSelectCountField("*", "cont");
  882.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  883.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  884.                 sqlQueryObject.setANDLogicOperator(true);
  885.                 queryString = sqlQueryObject.createSQLQuery();
  886.             } else {
  887.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  888.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_AUTORIZZAZIONE_PROP);
  889.                 sqlQueryObject.addSelectCountField("*", "cont");
  890.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  891.                 queryString = sqlQueryObject.createSQLQuery();
  892.             }
  893.             stmt = con.prepareStatement(queryString);
  894.             stmt.setLong(1, idPortaApplicativa);
  895.             risultato = stmt.executeQuery();
  896.             if (risultato.next())
  897.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  898.             risultato.close();
  899.             stmt.close();

  901.             // ricavo le entries
  902.             if (limit == 0) // con limit
  903.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  904.             if (!search.equals("")) { // con search
  905.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  906.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_AUTORIZZAZIONE_PROP);
  907.                 sqlQueryObject.addSelectField("id");
  908.                 sqlQueryObject.addSelectField("id_porta");
  909.                 sqlQueryObject.addSelectField("nome");
  910.                 sqlQueryObject.addSelectField("valore");
  911.                 sqlQueryObject.addSelectField("enc_value");
  912.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  913.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  914.                 sqlQueryObject.setANDLogicOperator(true);
  915.                 sqlQueryObject.addOrderBy("nome");
  916.                 sqlQueryObject.setSortType(true);
  917.                 sqlQueryObject.setLimit(limit);
  918.                 sqlQueryObject.setOffset(offset);
  919.                 queryString = sqlQueryObject.createSQLQuery();
  920.             } else {
  921.                 // senza search
  922.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  923.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_AUTORIZZAZIONE_PROP);
  924.                 sqlQueryObject.addSelectField("id");
  925.                 sqlQueryObject.addSelectField("id_porta");
  926.                 sqlQueryObject.addSelectField("nome");
  927.                 sqlQueryObject.addSelectField("valore");
  928.                 sqlQueryObject.addSelectField("enc_value");
  929.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  930.                 sqlQueryObject.addOrderBy("nome");
  931.                 sqlQueryObject.setSortType(true);
  932.                 sqlQueryObject.setLimit(limit);
  933.                 sqlQueryObject.setOffset(offset);
  934.                 queryString = sqlQueryObject.createSQLQuery();
  935.             }
  936.             stmt = con.prepareStatement(queryString);
  937.             stmt.setLong(1, idPortaApplicativa);
  938.             risultato = stmt.executeQuery();

  940.             Proprieta prop = null;
  941.             while (risultato.next()) {

  943.                 prop = new Proprieta();

  945.                 prop.setId(risultato.getLong("id"));
  946.                 prop.setNome(risultato.getString("nome"));
  947.                 
  948.                 String plainValue = risultato.getString("valore");
  949.                 String encValue = risultato.getString("enc_value");
  950.                 if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  951.                     prop.setValore(encValue);
  952.                 }
  953.                 else {
  954.                     prop.setValore(plainValue);
  955.                 }

  957.                 lista.add(prop);
  958.             }

  960.             return lista;

  962.         } catch (Exception qe) {
  963.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteAppPropList] Errore : " + qe.getMessage(),qe);
  964.         } finally {
  965.             //Chiudo statement and resultset
  966.             JDBCUtilities.closeResources(risultato, stmt);
  967.             this.driver.closeConnection(con);
  968.         }
  969.     }
  970.     
  971.     protected List<Proprieta> porteApplicativeAutorizzazioneContenutoCustomPropList(long idPortaApplicativa, ISearch ricerca) throws DriverConfigurazioneException {
  972.         int offset;
  973.         int limit;
  974.         int idLista = Liste.PORTE_APPLICATIVE_PROPRIETA_AUTORIZZAZIONE_CONTENUTO;
  975.         String search;
  976.         String queryString;

  978.         limit = ricerca.getPageSize(idLista);
  979.         offset = ricerca.getIndexIniziale(idLista);
  980.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));      


  983.         Connection con = null;
  984.         PreparedStatement stmt=null;
  985.         ResultSet risultato=null;
  986.         ArrayList<Proprieta> lista = new ArrayList<>();

  988.         if (this.driver.atomica) {
  989.             try {
  990.                 con = this.driver.getConnectionFromDatasource("porteApplicativeAutorizzazioneCustomPropList");
  991.             } catch (Exception e) {
  992.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteAppPropList] Exception accedendo al datasource :" + e.getMessage(),e);

  994.             }

  996.         } else
  997.             con = this.driver.globalConnection;

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

  1001.         try {

  1003.             if (!search.equals("")) {
  1004.                 //query con search
  1005.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1006.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_AUTORIZZAZIONE_CONTENUTI_PROP);
  1007.                 sqlQueryObject.addSelectCountField("*", "cont");
  1008.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1009.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1010.                 sqlQueryObject.setANDLogicOperator(true);
  1011.                 queryString = sqlQueryObject.createSQLQuery();
  1012.             } else {
  1013.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1014.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_AUTORIZZAZIONE_CONTENUTI_PROP);
  1015.                 sqlQueryObject.addSelectCountField("*", "cont");
  1016.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1017.                 queryString = sqlQueryObject.createSQLQuery();
  1018.             }
  1019.             stmt = con.prepareStatement(queryString);
  1020.             stmt.setLong(1, idPortaApplicativa);
  1021.             risultato = stmt.executeQuery();
  1022.             if (risultato.next())
  1023.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1024.             risultato.close();
  1025.             stmt.close();

  1027.             // ricavo le entries
  1028.             if (limit == 0) // con limit
  1029.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1030.             if (!search.equals("")) { // con search
  1031.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1032.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_AUTORIZZAZIONE_CONTENUTI_PROP);
  1033.                 sqlQueryObject.addSelectField("id");
  1034.                 sqlQueryObject.addSelectField("id_porta");
  1035.                 sqlQueryObject.addSelectField("nome");
  1036.                 sqlQueryObject.addSelectField("valore");
  1037.                 sqlQueryObject.addSelectField("enc_value");
  1038.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1039.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1040.                 sqlQueryObject.setANDLogicOperator(true);
  1041.                 sqlQueryObject.addOrderBy("nome");
  1042.                 sqlQueryObject.setSortType(true);
  1043.                 sqlQueryObject.setLimit(limit);
  1044.                 sqlQueryObject.setOffset(offset);
  1045.                 queryString = sqlQueryObject.createSQLQuery();
  1046.             } else {
  1047.                 // senza search
  1048.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1049.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_AUTORIZZAZIONE_CONTENUTI_PROP);
  1050.                 sqlQueryObject.addSelectField("id");
  1051.                 sqlQueryObject.addSelectField("id_porta");
  1052.                 sqlQueryObject.addSelectField("nome");
  1053.                 sqlQueryObject.addSelectField("valore");
  1054.                 sqlQueryObject.addSelectField("enc_value");
  1055.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1056.                 sqlQueryObject.addOrderBy("nome");
  1057.                 sqlQueryObject.setSortType(true);
  1058.                 sqlQueryObject.setLimit(limit);
  1059.                 sqlQueryObject.setOffset(offset);
  1060.                 queryString = sqlQueryObject.createSQLQuery();
  1061.             }
  1062.             stmt = con.prepareStatement(queryString);
  1063.             stmt.setLong(1, idPortaApplicativa);
  1064.             risultato = stmt.executeQuery();

  1066.             Proprieta prop = null;
  1067.             while (risultato.next()) {

  1069.                 prop = new Proprieta();

  1071.                 prop.setId(risultato.getLong("id"));
  1072.                 prop.setNome(risultato.getString("nome"));
  1073.                 
  1074.                 String plainValue = risultato.getString("valore");
  1075.                 String encValue = risultato.getString("enc_value");
  1076.                 if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  1077.                     prop.setValore(encValue);
  1078.                 }
  1079.                 else {
  1080.                     prop.setValore(plainValue);
  1081.                 }

  1083.                 lista.add(prop);
  1084.             }

  1086.             return lista;

  1088.         } catch (Exception qe) {
  1089.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteAppPropList] Errore : " + qe.getMessage(),qe);
  1090.         } finally {
  1091.             //Chiudo statement and resultset
  1092.             JDBCUtilities.closeResources(risultato, stmt);
  1093.             this.driver.closeConnection(con);
  1094.         }
  1095.     }
  1096.     
  1097.     /**
  1098.      * Ritorna la lista di Azioni di una  Porta Applicativa
  1099.      */
  1100.     protected List<PortaApplicativaAzione> porteAppAzioneList(long idPortaApplicativa, ISearch ricerca) throws DriverConfigurazioneException {
  1101.         int offset;
  1102.         int limit;
  1103.         int idLista = Liste.PORTE_APPLICATIVE_AZIONI;
  1104.         String search;
  1105.         String queryString;

  1107.         limit = ricerca.getPageSize(idLista);
  1108.         offset = ricerca.getIndexIniziale(idLista);
  1109.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));      


  1112.         Connection con = null;
  1113.         PreparedStatement stmt=null;
  1114.         ResultSet risultato=null;
  1115.         ArrayList<PortaApplicativaAzione> lista = new ArrayList<>();

  1117.         if (this.driver.atomica) {
  1118.             try {
  1119.                 con = this.driver.getConnectionFromDatasource("porteAppPropList");
  1120.             } catch (Exception e) {
  1121.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteAppPropList] Exception accedendo al datasource :" + e.getMessage(),e);

  1123.             }

  1125.         } else
  1126.             con = this.driver.globalConnection;

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

  1130.         try {

  1132.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1133.             sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_AZIONI);
  1134.             sqlQueryObject.addSelectCountField("*", "cont");
  1135.             sqlQueryObject.addWhereCondition("id_porta = ?");
  1136.             if (!search.equals("")) {
  1137.                 //query con search
  1138.                 sqlQueryObject.addWhereLikeCondition("azione", search, true, true);
  1139.             }
  1140.             sqlQueryObject.setANDLogicOperator(true);
  1141.             queryString = sqlQueryObject.createSQLQuery();
  1142.             
  1143.             stmt = con.prepareStatement(queryString);
  1144.             stmt.setLong(1, idPortaApplicativa);
  1145.             risultato = stmt.executeQuery();
  1146.             if (risultato.next())
  1147.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1148.             risultato.close();
  1149.             stmt.close();

  1151.             // ricavo le entries
  1152.             if (limit == 0) // con limit
  1153.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1154.             
  1155.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1156.             sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_AZIONI);
  1157.             sqlQueryObject.addSelectField("id_porta");
  1158.             sqlQueryObject.addSelectField("azione");
  1159.             sqlQueryObject.addSelectField("id");
  1160.             sqlQueryObject.addWhereCondition("id_porta = ?");
  1161.             
  1162.             if (!search.equals("")) { // con search
  1163.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1164.             } 
  1165.             
  1166.             sqlQueryObject.setANDLogicOperator(true);
  1167.             sqlQueryObject.addOrderBy("azione");
  1168.             sqlQueryObject.setSortType(true);
  1169.             sqlQueryObject.setLimit(limit);
  1170.             sqlQueryObject.setOffset(offset);
  1171.             queryString = sqlQueryObject.createSQLQuery();
  1172.             
  1173.             stmt = con.prepareStatement(queryString);
  1174.             stmt.setLong(1, idPortaApplicativa);
  1175.             risultato = stmt.executeQuery();

  1177.             PortaApplicativaAzione azione = null;
  1178.             while (risultato.next()) {

  1180.                 azione = new PortaApplicativaAzione();
  1181.                 
  1182.                 azione.setId(risultato.getLong("id"));
  1183.                 azione.setNome(risultato.getString("azione")) ;
  1184.                 
  1185.                 String nomePortaDelegante = null;
  1186.                 azione.setNomePortaDelegante(nomePortaDelegante);
  1187.                 PortaApplicativaAzioneIdentificazione identificazione = null;
  1188.                 azione.setIdentificazione(identificazione);
  1189.                 StatoFunzionalita forceInterfaceBased = StatoFunzionalita.ABILITATO; 
  1190.                 azione.setForceInterfaceBased(forceInterfaceBased);

  1192.                 lista.add(azione);
  1193.             }

  1195.             return lista;

  1197.         } catch (Exception qe) {
  1198.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteAppPropList] Errore : " + qe.getMessage(),qe);
  1199.         } finally {
  1200.             //Chiudo statement and resultset
  1201.             JDBCUtilities.closeResources(risultato, stmt);
  1202.             this.driver.closeConnection(con);
  1203.         }
  1204.     }

  1206.     protected List<ServizioApplicativo> porteAppServizioApplicativoList(long idPortaApplicativa, ISearch ricerca) throws DriverConfigurazioneException {
  1207.         String nomeMetodo = "porteAppServizioApplicativoList";
  1208.         int idLista = Liste.PORTE_APPLICATIVE_SERVIZIO_APPLICATIVO;
  1209.         int offset;
  1210.         int limit;
  1211.         String search;
  1212.         String queryString;

  1214.         limit = ricerca.getPageSize(idLista);
  1215.         offset = ricerca.getIndexIniziale(idLista);
  1216.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));

  1218.         Connection con = null;
  1219.         PreparedStatement stmt=null;
  1220.         PreparedStatement stmt1=null;
  1221.         ResultSet risultato=null;
  1222.         ArrayList<ServizioApplicativo> lista = new ArrayList<>();

  1224.         if (this.driver.atomica) {
  1225.             try {
  1226.                 con = this.driver.getConnectionFromDatasource("porteAppServizioApplicativoList");
  1227.             } catch (Exception e) {
  1228.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1230.             }

  1232.         } else
  1233.             con = this.driver.globalConnection;

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

  1237.         try {

  1239.             if (!search.equals("")) {
  1240.                 //query con search
  1241.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1242.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_SA);
  1243.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI_APPLICATIVI);
  1244.                 sqlQueryObject.addSelectCountField("*", "cont");
  1245.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1246.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_APPLICATIVE_SA+".id_servizio_applicativo="+CostantiDB.SERVIZI_APPLICATIVI+".id");
  1247.                 sqlQueryObject.addWhereLikeCondition(CostantiDB.SERVIZI_APPLICATIVI+".nome", search, true, true);
  1248.                 sqlQueryObject.setANDLogicOperator(true);
  1249.                 queryString = sqlQueryObject.createSQLQuery();
  1250.             } else {
  1251.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1252.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_SA);
  1253.                 sqlQueryObject.addSelectCountField("*", "cont");
  1254.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1255.                 queryString = sqlQueryObject.createSQLQuery();
  1256.             }
  1257.             stmt = con.prepareStatement(queryString);
  1258.             stmt.setLong(1, idPortaApplicativa);
  1259.             risultato = stmt.executeQuery();
  1260.             if (risultato.next())
  1261.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1262.             risultato.close();
  1263.             stmt.close();

  1265.             // ricavo le entries
  1266.             if (limit == 0) // con limit
  1267.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1268.             if (!search.equals("")) { // con search
  1269.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1270.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_SA);
  1271.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI_APPLICATIVI);
  1272.                 sqlQueryObject.addSelectField("id_servizio_applicativo");
  1273.                 sqlQueryObject.addSelectField("id_porta");
  1274.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1275.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_APPLICATIVE_SA+".id_servizio_applicativo="+CostantiDB.SERVIZI_APPLICATIVI+".id");
  1276.                 sqlQueryObject.addWhereLikeCondition(CostantiDB.SERVIZI_APPLICATIVI+".nome", search, true, true);
  1277.                 sqlQueryObject.setANDLogicOperator(true);
  1278.                 sqlQueryObject.addOrderBy("id_servizio_applicativo");
  1279.                 sqlQueryObject.setSortType(true);
  1280.                 sqlQueryObject.setLimit(limit);
  1281.                 sqlQueryObject.setOffset(offset);
  1282.                 queryString = sqlQueryObject.createSQLQuery();
  1283.             } else {
  1284.                 // senza search
  1285.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1286.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_SA);
  1287.                 sqlQueryObject.addSelectField("id_servizio_applicativo");
  1288.                 sqlQueryObject.addSelectField("id_porta");
  1289.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1290.                 sqlQueryObject.addOrderBy("id_servizio_applicativo");
  1291.                 sqlQueryObject.setSortType(true);
  1292.                 sqlQueryObject.setLimit(limit);
  1293.                 sqlQueryObject.setOffset(offset);
  1294.                 queryString = sqlQueryObject.createSQLQuery();
  1295.             }
  1296.             stmt = con.prepareStatement(queryString);
  1297.             stmt.setLong(1, idPortaApplicativa);
  1298.             risultato = stmt.executeQuery();

  1300.             ServizioApplicativo sa = null;
  1301.             ResultSet rs1;
  1302.             long idServizioApplicativo = 0;
  1303.             while (risultato.next()) {
  1304.                 idServizioApplicativo = risultato.getLong("id_servizio_applicativo");

  1306.                 sa = new ServizioApplicativo();

  1308.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1309.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI_APPLICATIVI);
  1310.                 sqlQueryObject.addSelectField("*");
  1311.                 sqlQueryObject.addWhereCondition("id = ?");
  1312.                 queryString = sqlQueryObject.createSQLQuery();

  1314.                 stmt1 = con.prepareStatement(queryString);
  1315.                 stmt1.setLong(1, idServizioApplicativo);

  1317.                 rs1 = stmt1.executeQuery();

  1319.                 // recupero i dati del servizio applicativo
  1320.                 if (rs1.next()) {
  1321.                     sa.setId(idServizioApplicativo);
  1322.                     sa.setNome(rs1.getString("nome"));
  1323.                     sa.setDescrizione(rs1.getString("descrizione"));
  1324.                     sa.setIdSoggetto(rs1.getLong("id_soggetto"));
  1325.                 } else
  1326.                     throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore recuperando i dati del Servizio Applicativo.");

  1328.                 rs1.close();
  1329.                 stmt1.close();
  1330.                 lista.add(sa);

  1332.             }
  1333.             risultato.close();
  1334.             stmt.close();
  1335.             return lista;

  1337.         } catch (Exception qe) {
  1338.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  1339.         } finally {

  1341.             //Chiudo statement and resultset
  1342.             JDBCUtilities.closeResources(risultato, stmt);
  1343.             JDBCUtilities.closeResources(stmt1);
  1344.             
  1345.             this.driver.closeConnection(con);
  1346.         }
  1347.     }
  1348.     
  1349.     protected List<PortaApplicativaAutorizzazioneSoggetto> porteAppSoggettoList(long idPortaApplicativa, ISearch ricerca) throws DriverConfigurazioneException {
  1350.         String nomeMetodo = "porteAppSoggettoList";
  1351.         int idLista = Liste.PORTE_APPLICATIVE_SOGGETTO;
  1352.         int offset;
  1353.         int limit;
  1354.         String search;
  1355.         String queryString;

  1357.         limit = ricerca.getPageSize(idLista);
  1358.         offset = ricerca.getIndexIniziale(idLista);
  1359.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));

  1361.         Connection con = null;
  1362.         PreparedStatement stmt=null;
  1363.         PreparedStatement stmt1=null;
  1364.         ResultSet risultato=null;
  1365.         ArrayList<PortaApplicativaAutorizzazioneSoggetto> lista = new ArrayList<>();

  1367.         if (this.driver.atomica) {
  1368.             try {
  1369.                 con = this.driver.getConnectionFromDatasource("porteAppSoggettoList");
  1370.             } catch (Exception e) {
  1371.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1373.             }

  1375.         } else
  1376.             con = this.driver.globalConnection;

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

  1380.         try {

  1382.             //query con search
  1383.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1384.             sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_SOGGETTI);
  1385.             sqlQueryObject.addSelectCountField("*", "cont");
  1386.             sqlQueryObject.addWhereCondition("id_porta = ?");
  1387.             if (!search.equals("")) {
  1388.                 sqlQueryObject.addWhereLikeCondition(CostantiDB.PORTE_APPLICATIVE_SOGGETTI+".nome_soggetto", search, true, true);
  1389.                 sqlQueryObject.setANDLogicOperator(true);
  1390.             } 
  1391.             queryString = sqlQueryObject.createSQLQuery();
  1392.             stmt = con.prepareStatement(queryString);
  1393.             stmt.setLong(1, idPortaApplicativa);
  1394.             risultato = stmt.executeQuery();
  1395.             if (risultato.next())
  1396.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1397.             risultato.close();
  1398.             stmt.close();

  1400.             // ricavo le entries
  1401.             if (limit == 0) // con limit
  1402.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1403.             
  1404.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1405.             sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_SOGGETTI);
  1406.             sqlQueryObject.addSelectField("id_porta");
  1407.             sqlQueryObject.addSelectField("tipo_soggetto");
  1408.             sqlQueryObject.addSelectField("nome_soggetto");
  1409.             sqlQueryObject.addWhereCondition("id_porta = ?");
  1410.             if (!search.equals("")) {
  1411.                 sqlQueryObject.addWhereLikeCondition(CostantiDB.PORTE_APPLICATIVE_SOGGETTI+".nome_soggetto", search, true, true);
  1412.                 sqlQueryObject.setANDLogicOperator(true);
  1413.             }
  1414.             sqlQueryObject.addOrderBy("tipo_soggetto");
  1415.             sqlQueryObject.addOrderBy("nome_soggetto");
  1416.             sqlQueryObject.setSortType(true);
  1417.             sqlQueryObject.setLimit(limit);
  1418.             sqlQueryObject.setOffset(offset);
  1419.             queryString = sqlQueryObject.createSQLQuery();
  1420.             
  1421.             stmt = con.prepareStatement(queryString);
  1422.             stmt.setLong(1, idPortaApplicativa);
  1423.             risultato = stmt.executeQuery();

  1425.             PortaApplicativaAutorizzazioneSoggetto paAuthSoggetto = null;
  1426.             while (risultato.next()) {
  1427.                 paAuthSoggetto = new PortaApplicativaAutorizzazioneSoggetto();
  1428.                 paAuthSoggetto.setNome(risultato.getString("nome_soggetto"));
  1429.                 paAuthSoggetto.setTipo(risultato.getString("tipo_soggetto"));
  1430.                 
  1431.                 lista.add(paAuthSoggetto);
  1432.             }
  1433.             risultato.close();
  1434.             stmt.close();
  1435.             return lista;

  1437.         } catch (Exception qe) {
  1438.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  1439.         } finally {

  1441.             //Chiudo statement and resultset
  1442.             JDBCUtilities.closeResources(risultato, stmt);
  1443.             JDBCUtilities.closeResources(stmt1);
  1444.             this.driver.closeConnection(con);
  1445.         }
  1446.     }
  1447.     
  1448.     protected List<PortaApplicativaAutorizzazioneServizioApplicativo> porteAppServiziApplicativiAutorizzatiList(long idPortaApplicativa, ISearch ricerca) throws DriverConfigurazioneException {
  1449.         String nomeMetodo = "porteAppServiziApplicativiAutorizzatiList";
  1450.         int idLista = Liste.PORTE_APPLICATIVE_SERVIZIO_APPLICATIVO_AUTORIZZATO;
  1451.         String nomeTabella = CostantiDB.PORTE_APPLICATIVE_SA_AUTORIZZATI;
  1452.         return _porteAppServiziApplicativiAutorizzatiTokenList(idPortaApplicativa, ricerca,
  1453.                 nomeMetodo, nomeTabella, idLista);
  1454.     }
  1455.     
  1456.     protected List<PortaApplicativaAutorizzazioneServizioApplicativo> porteAppServiziApplicativiAutorizzatiTokenList(long idPortaApplicativa, ISearch ricerca) throws DriverConfigurazioneException {
  1457.         String nomeMetodo = "porteAppServiziApplicativiAutorizzatiTokenList";
  1458.         int idLista = Liste.PORTE_APPLICATIVE_TOKEN_SERVIZIO_APPLICATIVO;
  1459.         String nomeTabella = CostantiDB.PORTE_APPLICATIVE_TOKEN_SA;
  1460.         return _porteAppServiziApplicativiAutorizzatiTokenList(idPortaApplicativa, ricerca,
  1461.                 nomeMetodo, nomeTabella, idLista);
  1462.     }
  1463.     private List<PortaApplicativaAutorizzazioneServizioApplicativo> _porteAppServiziApplicativiAutorizzatiTokenList(long idPortaApplicativa, ISearch ricerca,
  1464.             String nomeMetodo, String nomeTabella, int idLista) throws DriverConfigurazioneException {
  1465.         int offset;
  1466.         int limit;
  1467.         String search;
  1468.         String queryString;

  1470.         limit = ricerca.getPageSize(idLista);
  1471.         offset = ricerca.getIndexIniziale(idLista);
  1472.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));

  1474.         Connection con = null;
  1475.         PreparedStatement stmt=null;
  1476.         PreparedStatement stmt1=null;
  1477.         ResultSet risultato=null;
  1478.         ArrayList<PortaApplicativaAutorizzazioneServizioApplicativo> lista = new ArrayList<>();

  1480.         if (this.driver.atomica) {
  1481.             try {
  1482.                 con = this.driver.getConnectionFromDatasource("porteAppServiziApplicativiAutorizzatiTokenList");
  1483.             } catch (Exception e) {
  1484.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1486.             }

  1488.         } else
  1489.             con = this.driver.globalConnection;

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

  1493.         try {

  1495.             //query con search
  1496.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1497.             sqlQueryObject.addFromTable(nomeTabella);
  1498.             sqlQueryObject.addSelectCountField("*", "cont");
  1499.             sqlQueryObject.addWhereCondition("id_porta = ?");
  1500.             if (!search.equals("")) {
  1501.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI_APPLICATIVI);
  1502.                 sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_APPLICATIVI+".id="+nomeTabella+".id_servizio_applicativo");
  1503.                 sqlQueryObject.addWhereLikeCondition(CostantiDB.SERVIZI_APPLICATIVI+".nome", search, true, true);
  1504.             }
  1505.             sqlQueryObject.setANDLogicOperator(true);
  1506.             queryString = sqlQueryObject.createSQLQuery();
  1507.             stmt = con.prepareStatement(queryString);
  1508.             stmt.setLong(1, idPortaApplicativa);
  1509.             risultato = stmt.executeQuery();
  1510.             if (risultato.next())
  1511.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1512.             risultato.close();
  1513.             stmt.close();

  1515.             // ricavo le entries
  1516.             if (limit == 0) // con limit
  1517.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1518.             
  1519.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1520.             sqlQueryObject.addFromTable(nomeTabella);
  1521.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI_APPLICATIVI);
  1522.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1523.             sqlQueryObject.addSelectField("id_porta");
  1524.             sqlQueryObject.addSelectField("id_servizio_applicativo");
  1525.             sqlQueryObject.addSelectField("nome");
  1526.             sqlQueryObject.addSelectAliasField(CostantiDB.SERVIZI_APPLICATIVI, "id_soggetto", "idSoggettoProprietarioSA");
  1527.             sqlQueryObject.addSelectAliasField(CostantiDB.SOGGETTI, "tipo_soggetto", "tipoSoggettoProprietarioSA");
  1528.             sqlQueryObject.addSelectAliasField(CostantiDB.SOGGETTI, "nome_soggetto", "nomeSoggettoProprietarioSA");
  1529.             sqlQueryObject.addWhereCondition("id_porta = ?");
  1530.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_APPLICATIVI+".id="+nomeTabella+".id_servizio_applicativo");
  1531.             sqlQueryObject.addWhereCondition(CostantiDB.SERVIZI_APPLICATIVI+".id_soggetto="+CostantiDB.SOGGETTI+".id");
  1532.             sqlQueryObject.setANDLogicOperator(true);
  1533.             if (!search.equals("")) {
  1534.                 sqlQueryObject.addWhereLikeCondition(CostantiDB.SERVIZI_APPLICATIVI+".nome", search, true, true);
  1535.             }
  1536.             sqlQueryObject.addOrderBy(CostantiDB.SERVIZI_APPLICATIVI+".nome");
  1537.             sqlQueryObject.setSortType(true);
  1538.             sqlQueryObject.setLimit(limit);
  1539.             sqlQueryObject.setOffset(offset);
  1540.             queryString = sqlQueryObject.createSQLQuery();
  1541.             
  1542.             stmt = con.prepareStatement(queryString);
  1543.             stmt.setLong(1, idPortaApplicativa);
  1544.             risultato = stmt.executeQuery();

  1546.             PortaApplicativaAutorizzazioneServizioApplicativo paAuthSa = null;
  1547.             while (risultato.next()) {
  1548.                 paAuthSa = new PortaApplicativaAutorizzazioneServizioApplicativo();
  1549.                 paAuthSa.setNome(risultato.getString("nome"));
  1550.                 paAuthSa.setTipoSoggettoProprietario(risultato.getString("tipoSoggettoProprietarioSA"));
  1551.                 paAuthSa.setNomeSoggettoProprietario(risultato.getString("nomeSoggettoProprietarioSA"));
  1552.                 lista.add(paAuthSa);
  1553.             }
  1554.             risultato.close();
  1555.             stmt.close();
  1556.             return lista;

  1558.         } catch (Exception qe) {
  1559.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  1560.         } finally {

  1562.             //Chiudo statement and resultset
  1563.             JDBCUtilities.closeResources(risultato, stmt);
  1564.             JDBCUtilities.closeResources(stmt1);
  1565.             this.driver.closeConnection(con);
  1566.         }
  1567.     }

  1569.     protected List<MessageSecurityFlowParameter> porteAppMessageSecurityRequestList(long idPortaApplicativa, ISearch ricerca) throws DriverConfigurazioneException {
  1570.         String nomeMetodo = "porteAppMessageSecurityRequestList";
  1571.         int idLista = Liste.PORTE_APPLICATIVE_MESSAGE_SECURITY_REQUEST;

  1573.         int offset;
  1574.         int limit;
  1575.         String search;
  1576.         String queryString;
  1577.         limit = ricerca.getPageSize(idLista);
  1578.         offset = ricerca.getIndexIniziale(idLista);
  1579.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));


  1582.         Connection con = null;
  1583.         PreparedStatement stmt=null;
  1584.         ResultSet risultato=null;
  1585.         ArrayList<MessageSecurityFlowParameter> lista = new ArrayList<>();

  1587.         if (this.driver.atomica) {
  1588.             try {
  1589.                 con = this.driver.getConnectionFromDatasource("porteAppMessageSecurityRequestList");
  1590.             } catch (Exception e) {
  1591.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1593.             }

  1595.         } else
  1596.             con = this.driver.globalConnection;

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

  1600.         try {

  1602.             if (!search.equals("")) {
  1603.                 //query con search
  1604.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1605.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_MESSAGE_SECURITY_REQUEST);
  1606.                 sqlQueryObject.addSelectCountField("*", "cont");
  1607.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1608.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1609.                 sqlQueryObject.setANDLogicOperator(true);
  1610.                 queryString = sqlQueryObject.createSQLQuery();
  1611.             } else {
  1612.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1613.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_MESSAGE_SECURITY_REQUEST);
  1614.                 sqlQueryObject.addSelectCountField("*", "cont");
  1615.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1616.                 queryString = sqlQueryObject.createSQLQuery();
  1617.             }
  1618.             stmt = con.prepareStatement(queryString);
  1619.             stmt.setLong(1, idPortaApplicativa);
  1620.             risultato = stmt.executeQuery();
  1621.             if (risultato.next())
  1622.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1623.             risultato.close();
  1624.             stmt.close();

  1626.             // ricavo le entries
  1627.             if (limit == 0) // con limit
  1628.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1629.             if (!search.equals("")) { // con search
  1630.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1631.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_MESSAGE_SECURITY_REQUEST);
  1632.                 sqlQueryObject.addSelectField("id_porta");
  1633.                 sqlQueryObject.addSelectField("nome");
  1634.                 sqlQueryObject.addSelectField("valore");
  1635.                 sqlQueryObject.addSelectField("enc_value");
  1636.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1637.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1638.                 sqlQueryObject.setANDLogicOperator(true);
  1639.                 sqlQueryObject.addOrderBy("nome");
  1640.                 sqlQueryObject.setSortType(true);
  1641.                 sqlQueryObject.setLimit(limit);
  1642.                 sqlQueryObject.setOffset(offset);
  1643.                 queryString = sqlQueryObject.createSQLQuery();
  1644.             } else {
  1645.                 // senza search
  1646.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1647.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_MESSAGE_SECURITY_REQUEST);
  1648.                 sqlQueryObject.addSelectField("id_porta");
  1649.                 sqlQueryObject.addSelectField("nome");
  1650.                 sqlQueryObject.addSelectField("valore");
  1651.                 sqlQueryObject.addSelectField("enc_value");
  1652.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1653.                 sqlQueryObject.addOrderBy("nome");
  1654.                 sqlQueryObject.setSortType(true);
  1655.                 sqlQueryObject.setLimit(limit);
  1656.                 sqlQueryObject.setOffset(offset);
  1657.                 queryString = sqlQueryObject.createSQLQuery();
  1658.             }
  1659.             stmt = con.prepareStatement(queryString);
  1660.             stmt.setLong(1, idPortaApplicativa);
  1661.             risultato = stmt.executeQuery();

  1663.             MessageSecurityFlowParameter wsreq;
  1664.             while (risultato.next()) {

  1666.                 wsreq = new MessageSecurityFlowParameter();

  1668.                 wsreq.setId(risultato.getLong("id_porta"));
  1669.                 wsreq.setNome(risultato.getString("nome"));
  1670.                 
  1671.                 String plainValue = risultato.getString("valore");
  1672.                 String encValue = risultato.getString("enc_value");
  1673.                 if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  1674.                     wsreq.setValore(encValue);
  1675.                 }
  1676.                 else {
  1677.                     wsreq.setValore(plainValue);
  1678.                 }

  1680.                 lista.add(wsreq);
  1681.             }

  1683.             return lista;

  1685.         } catch (Exception qe) {
  1686.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  1687.         } finally {

  1689.             //Chiudo statement and resultset
  1690.             JDBCUtilities.closeResources(risultato, stmt);

  1692.             this.driver.closeConnection(con);
  1693.         }
  1694.     }

  1696.     protected List<MessageSecurityFlowParameter> porteAppMessageSecurityResponseList(long idPortaApplicativa, ISearch ricerca) throws DriverConfigurazioneException {
  1697.         String nomeMetodo = "porteAppMessageSecurityResponseList";
  1698.         int idLista = Liste.PORTE_APPLICATIVE_MESSAGE_SECURITY_RESPONSE;
  1699.         int offset;
  1700.         int limit;
  1701.         String search;
  1702.         String queryString;

  1704.         limit = ricerca.getPageSize(idLista);
  1705.         offset = ricerca.getIndexIniziale(idLista);
  1706.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));


  1709.         Connection con = null;
  1710.         PreparedStatement stmt=null;
  1711.         ResultSet risultato=null;
  1712.         ArrayList<MessageSecurityFlowParameter> lista = new ArrayList<>();

  1714.         if (this.driver.atomica) {
  1715.             try {
  1716.                 con = this.driver.getConnectionFromDatasource("porteAppMessageSecurityResponseList");
  1717.             } catch (Exception e) {
  1718.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1720.             }

  1722.         } else
  1723.             con = this.driver.globalConnection;

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

  1727.         try {

  1729.             if (!search.equals("")) {
  1730.                 //query con search
  1731.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1732.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_MESSAGE_SECURITY_RESPONSE);
  1733.                 sqlQueryObject.addSelectCountField("*", "cont");
  1734.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1735.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1736.                 sqlQueryObject.setANDLogicOperator(true);
  1737.                 queryString = sqlQueryObject.createSQLQuery();
  1738.             } else {
  1739.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1740.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_MESSAGE_SECURITY_RESPONSE);
  1741.                 sqlQueryObject.addSelectCountField("*", "cont");
  1742.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1743.                 queryString = sqlQueryObject.createSQLQuery();
  1744.             }
  1745.             stmt = con.prepareStatement(queryString);
  1746.             stmt.setLong(1, idPortaApplicativa);
  1747.             risultato = stmt.executeQuery();
  1748.             if (risultato.next())
  1749.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1750.             risultato.close();
  1751.             stmt.close();

  1753.             // ricavo le entries
  1754.             if (limit == 0) // con limit
  1755.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;

  1757.             if (!search.equals("")) { // con search
  1758.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1759.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_MESSAGE_SECURITY_RESPONSE);
  1760.                 sqlQueryObject.addSelectField("id_porta");
  1761.                 sqlQueryObject.addSelectField("nome");
  1762.                 sqlQueryObject.addSelectField("valore");
  1763.                 sqlQueryObject.addSelectField("enc_value");
  1764.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1765.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1766.                 sqlQueryObject.setANDLogicOperator(true);
  1767.                 sqlQueryObject.addOrderBy("nome");
  1768.                 sqlQueryObject.setSortType(true);
  1769.                 sqlQueryObject.setLimit(limit);
  1770.                 sqlQueryObject.setOffset(offset);
  1771.                 queryString = sqlQueryObject.createSQLQuery();
  1772.             } else {
  1773.                 // senza search
  1774.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1775.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_MESSAGE_SECURITY_RESPONSE);
  1776.                 sqlQueryObject.addSelectField("id_porta");
  1777.                 sqlQueryObject.addSelectField("nome");
  1778.                 sqlQueryObject.addSelectField("valore");
  1779.                 sqlQueryObject.addSelectField("enc_value");
  1780.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1781.                 sqlQueryObject.addOrderBy("nome");
  1782.                 sqlQueryObject.setSortType(true);
  1783.                 sqlQueryObject.setLimit(limit);
  1784.                 sqlQueryObject.setOffset(offset);
  1785.                 queryString = sqlQueryObject.createSQLQuery();
  1786.             }
  1787.             stmt = con.prepareStatement(queryString);
  1788.             stmt.setLong(1, idPortaApplicativa);
  1789.             risultato = stmt.executeQuery();

  1791.             MessageSecurityFlowParameter wsresp;
  1792.             while (risultato.next()) {

  1794.                 wsresp = new MessageSecurityFlowParameter();

  1796.                 wsresp.setId(risultato.getLong("id_porta"));
  1797.                 wsresp.setNome(risultato.getString("nome"));
  1798.                 
  1799.                 String plainValue = risultato.getString("valore");
  1800.                 String encValue = risultato.getString("enc_value");
  1801.                 if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  1802.                     wsresp.setValore(encValue);
  1803.                 }
  1804.                 else {
  1805.                     wsresp.setValore(plainValue);
  1806.                 }

  1808.                 lista.add(wsresp);
  1809.             }

  1811.             return lista;

  1813.         } catch (Exception qe) {
  1814.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  1815.         } finally {

  1817.             //Chiudo statement and resultset
  1818.             JDBCUtilities.closeResources(risultato, stmt);
  1819.             this.driver.closeConnection(con);
  1820.         }

  1822.     }
  1823.     
  1824.     protected List<CorrelazioneApplicativaElemento> porteApplicativeCorrelazioneApplicativaList(long idPortaApplicativa, ISearch ricerca) throws DriverConfigurazioneException {
  1825.         String nomeMetodo = "porteApplicativeCorrelazioneApplicativaList";
  1826.         int idLista = Liste.PORTE_APPLICATIVE_CORRELAZIONE_APPLICATIVA;
  1827.         int offset;
  1828.         int limit;
  1829.         String search;
  1830.         String queryString;

  1832.         limit = ricerca.getPageSize(idLista);
  1833.         offset = ricerca.getIndexIniziale(idLista);
  1834.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));


  1837.         Connection con = null;
  1838.         PreparedStatement stmt=null;
  1839.         ResultSet risultato=null;
  1840.         ArrayList<CorrelazioneApplicativaElemento> lista = new ArrayList<>();

  1842.         if (this.driver.atomica) {
  1843.             try {
  1844.                 con = this.driver.getConnectionFromDatasource("porteApplicativeCorrelazioneApplicativaList");
  1845.             } catch (Exception e) {
  1846.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1848.             }

  1850.         } else
  1851.             con = this.driver.globalConnection;

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

  1855.         try {

  1857.             if (!search.equals("")) {
  1858.                 //query con search
  1859.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1860.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_CORRELAZIONE);
  1861.                 sqlQueryObject.addSelectCountField("*", "cont");
  1862.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1863.                 sqlQueryObject.addWhereLikeCondition("nome_elemento", search, true, true);
  1864.                 sqlQueryObject.setANDLogicOperator(true);
  1865.                 queryString = sqlQueryObject.createSQLQuery();
  1866.             } else {
  1867.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1868.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_CORRELAZIONE);
  1869.                 sqlQueryObject.addSelectCountField("*", "cont");
  1870.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1871.                 queryString = sqlQueryObject.createSQLQuery();
  1872.             }
  1873.             stmt = con.prepareStatement(queryString);
  1874.             stmt.setLong(1, idPortaApplicativa);
  1875.             risultato = stmt.executeQuery();
  1876.             if (risultato.next())
  1877.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1878.             risultato.close();
  1879.             stmt.close();

  1881.             // ricavo le entries
  1882.             if (limit == 0) // con limit
  1883.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1884.             if (!search.equals("")) { // con search
  1885.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1886.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_CORRELAZIONE);
  1887.                 sqlQueryObject.addSelectField("id");
  1888.                 sqlQueryObject.addSelectField("nome_elemento");
  1889.                 sqlQueryObject.addSelectField("mode_correlazione");
  1890.                 sqlQueryObject.addSelectField("id_porta");
  1891.                 sqlQueryObject.addSelectField("identificazione_fallita");
  1892.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1893.                 sqlQueryObject.addWhereLikeCondition("nome_elemento", search, true, true);
  1894.                 sqlQueryObject.setANDLogicOperator(true);
  1895.                 sqlQueryObject.addOrderBy("id");
  1896.                 sqlQueryObject.setSortType(true);
  1897.                 sqlQueryObject.setLimit(limit);
  1898.                 sqlQueryObject.setOffset(offset);
  1899.                 queryString = sqlQueryObject.createSQLQuery();
  1900.             } else {
  1901.                 // senza search
  1902.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1903.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_CORRELAZIONE);
  1904.                 sqlQueryObject.addSelectField("id");
  1905.                 sqlQueryObject.addSelectField("nome_elemento");
  1906.                 sqlQueryObject.addSelectField("mode_correlazione");
  1907.                 sqlQueryObject.addSelectField("id_porta");
  1908.                 sqlQueryObject.addSelectField("identificazione_fallita");
  1909.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1910.                 sqlQueryObject.addOrderBy("id");
  1911.                 sqlQueryObject.setSortType(true);
  1912.                 sqlQueryObject.setLimit(limit);
  1913.                 sqlQueryObject.setOffset(offset);
  1914.                 queryString = sqlQueryObject.createSQLQuery();
  1915.             }
  1916.             stmt = con.prepareStatement(queryString);
  1917.             stmt.setLong(1, idPortaApplicativa);
  1918.             risultato = stmt.executeQuery();

  1920.             CorrelazioneApplicativaElemento cae = null;

  1922.             //long idServizioApplicativo = 0;
  1923.             while (risultato.next()) {
  1924.                 cae = new CorrelazioneApplicativaElemento();
  1925.                 cae.setId(risultato.getLong("id"));
  1926.                 cae.setNome(risultato.getString("nome_elemento"));
  1927.                 cae.setIdentificazione(DriverConfigurazioneDBLib.getEnumCorrelazioneApplicativaRichiestaIdentificazione(risultato.getString("mode_correlazione")));
  1928.                 cae.setIdentificazioneFallita(DriverConfigurazioneDBLib.getEnumCorrelazioneApplicativaGestioneIdentificazioneFallita(risultato.getString("identificazione_fallita")));
  1929.                 lista.add(cae);
  1930.             }

  1932.             return lista;

  1934.         } catch (Exception qe) {
  1935.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  1936.         } finally {

  1938.             //Chiudo statement and resultset
  1939.             JDBCUtilities.closeResources(risultato, stmt);

  1941.             this.driver.closeConnection(con);
  1942.         }
  1943.     }



  1947.     protected List<CorrelazioneApplicativaRispostaElemento> porteApplicativeCorrelazioneApplicativaRispostaList(long idPortaApplicativa, ISearch ricerca) throws DriverConfigurazioneException {
  1948.         String nomeMetodo = "porteApplicativeCorrelazioneApplicativaRispostaList";
  1949.         int idLista = Liste.PORTE_APPLICATIVE_CORRELAZIONE_APPLICATIVA_RISPOSTA;
  1950.         int offset;
  1951.         int limit;
  1952.         String search;
  1953.         String queryString;

  1955.         limit = ricerca.getPageSize(idLista);
  1956.         offset = ricerca.getIndexIniziale(idLista);
  1957.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));


  1960.         Connection con = null;
  1961.         PreparedStatement stmt=null;
  1962.         ResultSet risultato=null;
  1963.         ArrayList<CorrelazioneApplicativaRispostaElemento> lista = new ArrayList<>();

  1965.         if (this.driver.atomica) {
  1966.             try {
  1967.                 con = this.driver.getConnectionFromDatasource("porteApplicativeCorrelazioneApplicativaRispostaList");
  1968.             } catch (Exception e) {
  1969.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1971.             }

  1973.         } else
  1974.             con = this.driver.globalConnection;

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

  1978.         try {

  1980.             if (!search.equals("")) {
  1981.                 //query con search
  1982.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1983.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_CORRELAZIONE_RISPOSTA);
  1984.                 sqlQueryObject.addSelectCountField("*", "cont");
  1985.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1986.                 sqlQueryObject.addWhereLikeCondition("nome_elemento", search, true, true);
  1987.                 sqlQueryObject.setANDLogicOperator(true);
  1988.                 queryString = sqlQueryObject.createSQLQuery();
  1989.             } else {
  1990.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1991.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_CORRELAZIONE_RISPOSTA);
  1992.                 sqlQueryObject.addSelectCountField("*", "cont");
  1993.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1994.                 queryString = sqlQueryObject.createSQLQuery();
  1995.             }
  1996.             stmt = con.prepareStatement(queryString);
  1997.             stmt.setLong(1, idPortaApplicativa);
  1998.             risultato = stmt.executeQuery();
  1999.             if (risultato.next())
  2000.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  2001.             risultato.close();
  2002.             stmt.close();

  2004.             // ricavo le entries
  2005.             if (limit == 0) // con limit
  2006.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  2007.             if (!search.equals("")) { // con search
  2008.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2009.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_CORRELAZIONE_RISPOSTA);
  2010.                 sqlQueryObject.addSelectField("id");
  2011.                 sqlQueryObject.addSelectField("nome_elemento");
  2012.                 sqlQueryObject.addSelectField("mode_correlazione");
  2013.                 sqlQueryObject.addSelectField("id_porta");
  2014.                 sqlQueryObject.addSelectField("identificazione_fallita");
  2015.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  2016.                 sqlQueryObject.addWhereLikeCondition("nome_elemento", search, true, true);
  2017.                 sqlQueryObject.setANDLogicOperator(true);
  2018.                 sqlQueryObject.addOrderBy("id");
  2019.                 sqlQueryObject.setSortType(true);
  2020.                 sqlQueryObject.setLimit(limit);
  2021.                 sqlQueryObject.setOffset(offset);
  2022.                 queryString = sqlQueryObject.createSQLQuery();
  2023.             } else {
  2024.                 // senza search
  2025.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2026.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_CORRELAZIONE_RISPOSTA);
  2027.                 sqlQueryObject.addSelectField("id");
  2028.                 sqlQueryObject.addSelectField("nome_elemento");
  2029.                 sqlQueryObject.addSelectField("mode_correlazione");
  2030.                 sqlQueryObject.addSelectField("id_porta");
  2031.                 sqlQueryObject.addSelectField("identificazione_fallita");
  2032.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  2033.                 sqlQueryObject.addOrderBy("id");
  2034.                 sqlQueryObject.setSortType(true);
  2035.                 sqlQueryObject.setLimit(limit);
  2036.                 sqlQueryObject.setOffset(offset);
  2037.                 queryString = sqlQueryObject.createSQLQuery();
  2038.             }
  2039.             stmt = con.prepareStatement(queryString);
  2040.             stmt.setLong(1, idPortaApplicativa);
  2041.             risultato = stmt.executeQuery();

  2043.             CorrelazioneApplicativaRispostaElemento cae = null;

  2045.             //long idServizioApplicativo = 0;
  2046.             while (risultato.next()) {
  2047.                 cae = new CorrelazioneApplicativaRispostaElemento();
  2048.                 cae.setId(risultato.getLong("id"));
  2049.                 cae.setNome(risultato.getString("nome_elemento"));
  2050.                 cae.setIdentificazione(DriverConfigurazioneDBLib.getEnumCorrelazioneApplicativaRispostaIdentificazione(risultato.getString("mode_correlazione")));
  2051.                 cae.setIdentificazioneFallita(DriverConfigurazioneDBLib.getEnumCorrelazioneApplicativaGestioneIdentificazioneFallita(risultato.getString("identificazione_fallita")));
  2052.                 lista.add(cae);
  2053.             }

  2055.             return lista;

  2057.         } catch (Exception qe) {
  2058.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  2059.         } finally {

  2061.             //Chiudo statement and resultset
  2062.             JDBCUtilities.closeResources(risultato, stmt);

  2064.             this.driver.closeConnection(con);
  2065.         }
  2066.     }
  2067.     
  2068.     protected List<PortaApplicativa> serviziPorteAppList(String tipoServizio,String nomeServizio, Integer versioneServizio,
  2069.             long idServizio, long idSoggettoErogatore, ISearch ricerca) throws DriverConfigurazioneException {
  2070.         String nomeMetodo = "serviziPorteAppList";
  2071.         int idLista = Liste.CONFIGURAZIONE_EROGAZIONE;
  2072.         int offset;
  2073.         int limit;
  2074.         String search;
  2075.         String queryString;

  2077.         limit = ricerca.getPageSize(idLista);
  2078.         offset = ricerca.getIndexIniziale(idLista);
  2079.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  2080.         ricerca.getSearchString(idLista);

  2082.         Connection con = null;
  2083.         PreparedStatement stmt = null;
  2084.         ResultSet risultato = null;

  2086.         ArrayList<PortaApplicativa> lista = new ArrayList<PortaApplicativa>();

  2088.         try {

  2090.             if (this.driver.atomica) {
  2091.                 try {
  2092.                     con = this.driver.getConnectionFromDatasource(nomeMetodo);

  2094.                 } catch (Exception e) {
  2095.                     throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  2097.                 }

  2099.             } else
  2100.                 con = this.driver.globalConnection;

  2102.             this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);
  2103.             
  2104.             if (!search.equals("")) {
  2105.                 //query con search
  2106.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2107.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE);
  2108.                 sqlQueryObject.addSelectCountField("*", "cont");
  2109.                 sqlQueryObject.addWhereCondition(false, "id_soggetto = ? AND tipo_servizio = ? AND servizio=? AND versione_servizio=? AND id_soggetto_virtuale <= ?",
  2110.                         "id_soggetto = ? AND id_servizio = ? AND id_soggetto_virtuale <= ?", 
  2111.                         "id_soggetto_virtuale = ? AND tipo_servizio = ? AND servizio=?  AND versione_servizio=?",
  2112.                         "id_soggetto_virtuale = ? AND id_servizio = ?");
  2113.                 sqlQueryObject.addWhereLikeCondition("nome_porta", search, true, true);
  2114.                 sqlQueryObject.setANDLogicOperator(true);
  2115.                 queryString = sqlQueryObject.createSQLQuery();
  2116.             } else {
  2117.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2118.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE);
  2119.                 sqlQueryObject.addSelectCountField("*", "cont");
  2120.                 sqlQueryObject.addWhereCondition(false, "id_soggetto = ? AND tipo_servizio = ? AND servizio=? AND versione_servizio=? AND id_soggetto_virtuale <= ?",
  2121.                         "id_soggetto = ? AND id_servizio = ? AND id_soggetto_virtuale <= ?", 
  2122.                         "id_soggetto_virtuale = ? AND tipo_servizio = ? AND servizio=? AND versione_servizio=?",
  2123.                         "id_soggetto_virtuale = ? AND id_servizio = ?");
  2124.                 sqlQueryObject.setANDLogicOperator(true);
  2125.                 queryString = sqlQueryObject.createSQLQuery();
  2126.             }
  2127.             stmt = con.prepareStatement(queryString);

  2129.             int index = 1;
  2130.             
  2131.             stmt.setLong(index++, idSoggettoErogatore);
  2132.             stmt.setString(index++, tipoServizio);
  2133.             stmt.setString(index++, nomeServizio);
  2134.             stmt.setInt(index++, versioneServizio);
  2135.             stmt.setLong(index++, 0);

  2137.             stmt.setLong(index++, idSoggettoErogatore);
  2138.             stmt.setLong(index++, idServizio);
  2139.             stmt.setLong(index++, 0);

  2141.             stmt.setLong(index++, idSoggettoErogatore);
  2142.             stmt.setString(index++, tipoServizio);
  2143.             stmt.setString(index++, nomeServizio);
  2144.             stmt.setInt(index++, versioneServizio);

  2146.             stmt.setLong(index++, idSoggettoErogatore);
  2147.             stmt.setLong(index++, idServizio);

  2149.             risultato = stmt.executeQuery();
  2150.             if (risultato.next())
  2151.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  2152.             risultato.close();
  2153.             stmt.close();

  2155.             // ricavo le entries
  2156.             if (limit == 0) // con limit
  2157.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  2158.             if (!search.equals("")) { // con search
  2159.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2160.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE);
  2161.                 sqlQueryObject.addSelectField("id_soggetto");
  2162.                 sqlQueryObject.addSelectField("id_servizio");
  2163.                 sqlQueryObject.addSelectField("id_soggetto_virtuale");
  2164.                 sqlQueryObject.addSelectField("nome_porta");
  2165.                 sqlQueryObject.addSelectField("id");
  2166.                 sqlQueryObject.addWhereCondition(false, "id_soggetto = ? AND tipo_servizio = ? AND servizio=? AND versione_servizio=? AND id_soggetto_virtuale <= ?",
  2167.                         "id_soggetto = ? AND id_servizio = ? AND id_soggetto_virtuale <= ?", 
  2168.                         "id_soggetto_virtuale = ? AND tipo_servizio = ? AND servizio=? AND versione_servizio=?",
  2169.                         "id_soggetto_virtuale = ? AND id_servizio = ?");
  2170.                 sqlQueryObject.addWhereLikeCondition("nome_porta", search, true, true);
  2171.                 sqlQueryObject.setANDLogicOperator(true);
  2172.                 sqlQueryObject.addOrderBy("nome_porta");
  2173.                 sqlQueryObject.setSortType(true);
  2174.                 sqlQueryObject.setLimit(limit);
  2175.                 sqlQueryObject.setOffset(offset);
  2176.                 queryString = sqlQueryObject.createSQLQuery();
  2177.             } else {
  2178.                 // senza search
  2179.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2180.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE);
  2181.                 sqlQueryObject.addSelectField("id_soggetto");
  2182.                 sqlQueryObject.addSelectField("id_servizio");
  2183.                 sqlQueryObject.addSelectField("id_soggetto_virtuale");
  2184.                 sqlQueryObject.addSelectField("nome_porta");
  2185.                 sqlQueryObject.addSelectField("id");
  2186.                 sqlQueryObject.addWhereCondition(false, "id_soggetto = ? AND tipo_servizio = ? AND servizio=? AND versione_servizio=? AND id_soggetto_virtuale <= ?",
  2187.                         "id_soggetto = ? AND id_servizio = ? AND id_soggetto_virtuale <= ?", 
  2188.                         "id_soggetto_virtuale = ? AND tipo_servizio = ? AND servizio=? AND versione_servizio=?",
  2189.                         "id_soggetto_virtuale = ? AND id_servizio = ?");
  2190.                 sqlQueryObject.setANDLogicOperator(true);
  2191.                 sqlQueryObject.addOrderBy("nome_porta");
  2192.                 sqlQueryObject.setSortType(true);
  2193.                 sqlQueryObject.setLimit(limit);
  2194.                 sqlQueryObject.setOffset(offset);
  2195.                 queryString = sqlQueryObject.createSQLQuery();
  2196.             }
  2197.             stmt = con.prepareStatement(queryString);

  2199.             index = 1;
  2200.             
  2201.             stmt.setLong(index++, idSoggettoErogatore);
  2202.             stmt.setString(index++, tipoServizio);
  2203.             stmt.setString(index++, nomeServizio);
  2204.             stmt.setInt(index++, versioneServizio);
  2205.             stmt.setLong(index++, 0);

  2207.             stmt.setLong(index++, idSoggettoErogatore);
  2208.             stmt.setLong(index++, idServizio);
  2209.             stmt.setLong(index++, 0);

  2211.             stmt.setLong(index++, idSoggettoErogatore);
  2212.             stmt.setString(index++, tipoServizio);
  2213.             stmt.setString(index++, nomeServizio);
  2214.             stmt.setInt(index++, versioneServizio);

  2216.             stmt.setLong(index++, idSoggettoErogatore);
  2217.             stmt.setLong(index++, idServizio);

  2219.             risultato = stmt.executeQuery();

  2221.             PortaApplicativa pa = null;

  2223.             while (risultato.next()) {

  2225.                 pa = this.porteApplicativeDriver.getPortaApplicativa(risultato.getLong("id"));

  2227.                 lista.add(pa);

  2229.             }

  2231.             return lista;

  2233.         } catch (Exception se) {

  2235.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  2236.         } finally {
  2237.             //Chiudo statement and resultset
  2238.             JDBCUtilities.closeResources(risultato, stmt);
  2239.             this.driver.closeConnection(con);
  2240.         }
  2241.     }
  2242.     
  2243.     protected List<MtomProcessorFlowParameter> porteApplicativeMTOMRequestList(long idPortaApplicativa, ISearch ricerca) throws DriverConfigurazioneException {
  2244.         String nomeMetodo = "porteApplicativeMTOMRequestList";
  2245.         int idLista = Liste.PORTE_APPLICATIVE_MTOM_REQUEST;
  2246.         int offset;
  2247.         int limit;
  2248.         String search;
  2249.         String queryString;

  2251.         limit = ricerca.getPageSize(idLista);
  2252.         offset = ricerca.getIndexIniziale(idLista);
  2253.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));


  2256.         Connection con = null;
  2257.         PreparedStatement stmt=null;
  2258.         ResultSet risultato=null;
  2259.         ArrayList<MtomProcessorFlowParameter> lista = new ArrayList<>();

  2261.         if (this.driver.atomica) {
  2262.             try {
  2263.                 con = this.driver.getConnectionFromDatasource(nomeMetodo);
  2264.             } catch (Exception e) {
  2265.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  2267.             }

  2269.         } else
  2270.             con = this.driver.globalConnection;

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

  2274.         try {

  2276.             if (!search.equals("")) {
  2277.                 //query con search
  2278.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2279.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_MTOM_REQUEST);
  2280.                 sqlQueryObject.addSelectCountField("*", "cont");
  2281.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  2282.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  2283.                 sqlQueryObject.setANDLogicOperator(true);
  2284.                 queryString = sqlQueryObject.createSQLQuery();
  2285.             } else {
  2286.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2287.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_MTOM_REQUEST);
  2288.                 sqlQueryObject.addSelectCountField("*", "cont");
  2289.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  2290.                 queryString = sqlQueryObject.createSQLQuery();
  2291.             }
  2292.             stmt = con.prepareStatement(queryString);
  2293.             stmt.setLong(1, idPortaApplicativa);
  2294.             risultato = stmt.executeQuery();
  2295.             if (risultato.next())
  2296.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  2297.             risultato.close();
  2298.             stmt.close();

  2300.             // ricavo le entries
  2301.             if (limit == 0) // con limit
  2302.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;

  2304.             if (!search.equals("")) { // con search
  2305.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2306.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_MTOM_REQUEST);
  2307.                 sqlQueryObject.addSelectField("id_porta");
  2308.                 sqlQueryObject.addSelectField("nome");
  2309.                 sqlQueryObject.addSelectField("pattern");
  2310.                 sqlQueryObject.addSelectField("content_type");
  2311.                 sqlQueryObject.addSelectField("required");
  2312.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  2313.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  2314.                 sqlQueryObject.setANDLogicOperator(true);
  2315.                 sqlQueryObject.addOrderBy("nome");
  2316.                 sqlQueryObject.setSortType(true);
  2317.                 sqlQueryObject.setLimit(limit);
  2318.                 sqlQueryObject.setOffset(offset);
  2319.                 queryString = sqlQueryObject.createSQLQuery();
  2320.             } else {
  2321.                 // senza search
  2322.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2323.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_MTOM_REQUEST);
  2324.                 sqlQueryObject.addSelectField("id_porta");
  2325.                 sqlQueryObject.addSelectField("nome");
  2326.                 sqlQueryObject.addSelectField("pattern");
  2327.                 sqlQueryObject.addSelectField("content_type");
  2328.                 sqlQueryObject.addSelectField("required");
  2329.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  2330.                 sqlQueryObject.addOrderBy("nome");
  2331.                 sqlQueryObject.setSortType(true);
  2332.                 sqlQueryObject.setLimit(limit);
  2333.                 sqlQueryObject.setOffset(offset);
  2334.                 queryString = sqlQueryObject.createSQLQuery();
  2335.             }
  2336.             stmt = con.prepareStatement(queryString);
  2337.             stmt.setLong(1, idPortaApplicativa);
  2338.             risultato = stmt.executeQuery();

  2340.             MtomProcessorFlowParameter reqPar;
  2341.             while (risultato.next()) {

  2343.                 reqPar = new MtomProcessorFlowParameter();
  2344.                 
  2345.                 reqPar.setId(risultato.getLong("id_porta"));
  2346.                 reqPar.setNome(risultato.getString("nome"));
  2347.                 reqPar.setPattern(risultato.getString("pattern"));
  2348.                 reqPar.setContentType(risultato.getString("content_type"));
  2349.                 int required = risultato.getInt("required");
  2350.                 boolean isrequired = false;
  2351.                 if (required == CostantiDB.TRUE)
  2352.                     isrequired = true;
  2353.                 reqPar.setRequired(isrequired);

  2355.                 

  2357.                 lista.add(reqPar);
  2358.             }

  2360.             return lista;

  2362.         } catch (Exception qe) {
  2363.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  2364.         } finally {

  2366.             //Chiudo statement and resultset
  2367.             JDBCUtilities.closeResources(risultato, stmt);

  2369.             this.driver.closeConnection(con);
  2370.         }
  2371.     }

  2373.     protected List<MtomProcessorFlowParameter> porteApplicativeMTOMResponseList(long idPortaApplicativa, ISearch ricerca) throws DriverConfigurazioneException {
  2374.         String nomeMetodo = "porteApplicativeMTOMResponseList";
  2375.         int idLista = Liste.PORTE_APPLICATIVE_MTOM_RESPONSE;
  2376.         int offset;
  2377.         int limit;
  2378.         String search;
  2379.         String queryString;

  2381.         limit = ricerca.getPageSize(idLista);
  2382.         offset = ricerca.getIndexIniziale(idLista);
  2383.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));


  2386.         Connection con = null;
  2387.         PreparedStatement stmt=null;
  2388.         ResultSet risultato=null;
  2389.         ArrayList<MtomProcessorFlowParameter> lista = new ArrayList<>();

  2391.         if (this.driver.atomica) {
  2392.             try {
  2393.                 con = this.driver.getConnectionFromDatasource(nomeMetodo);
  2394.             } catch (Exception e) {
  2395.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  2397.             }

  2399.         } else
  2400.             con = this.driver.globalConnection;

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

  2404.         try {

  2406.             if (!search.equals("")) {
  2407.                 //query con search
  2408.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2409.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_MTOM_RESPONSE);
  2410.                 sqlQueryObject.addSelectCountField("*", "cont");
  2411.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  2412.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  2413.                 sqlQueryObject.setANDLogicOperator(true);
  2414.                 queryString = sqlQueryObject.createSQLQuery();
  2415.             } else {
  2416.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2417.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_MTOM_RESPONSE);
  2418.                 sqlQueryObject.addSelectCountField("*", "cont");
  2419.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  2420.                 queryString = sqlQueryObject.createSQLQuery();
  2421.             }
  2422.             stmt = con.prepareStatement(queryString);
  2423.             stmt.setLong(1, idPortaApplicativa);
  2424.             risultato = stmt.executeQuery();
  2425.             if (risultato.next())
  2426.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  2427.             risultato.close();
  2428.             stmt.close();

  2430.             // ricavo le entries
  2431.             if (limit == 0) // con limit
  2432.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;

  2434.             if (!search.equals("")) { // con search
  2435.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2436.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_MTOM_RESPONSE);
  2437.                 sqlQueryObject.addSelectField("id_porta");
  2438.                 sqlQueryObject.addSelectField("nome");
  2439.                 sqlQueryObject.addSelectField("pattern");
  2440.                 sqlQueryObject.addSelectField("content_type");
  2441.                 sqlQueryObject.addSelectField("required");
  2442.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  2443.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  2444.                 sqlQueryObject.setANDLogicOperator(true);
  2445.                 sqlQueryObject.addOrderBy("nome");
  2446.                 sqlQueryObject.setSortType(true);
  2447.                 sqlQueryObject.setLimit(limit);
  2448.                 sqlQueryObject.setOffset(offset);
  2449.                 queryString = sqlQueryObject.createSQLQuery();
  2450.             } else {
  2451.                 // senza search
  2452.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2453.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_MTOM_RESPONSE);
  2454.                 sqlQueryObject.addSelectField("id_porta");
  2455.                 sqlQueryObject.addSelectField("nome");
  2456.                 sqlQueryObject.addSelectField("pattern");
  2457.                 sqlQueryObject.addSelectField("content_type");
  2458.                 sqlQueryObject.addSelectField("required");
  2459.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  2460.                 sqlQueryObject.addOrderBy("nome");
  2461.                 sqlQueryObject.setSortType(true);
  2462.                 sqlQueryObject.setLimit(limit);
  2463.                 sqlQueryObject.setOffset(offset);
  2464.                 queryString = sqlQueryObject.createSQLQuery();
  2465.             }
  2466.             stmt = con.prepareStatement(queryString);
  2467.             stmt.setLong(1, idPortaApplicativa);
  2468.             risultato = stmt.executeQuery();

  2470.             MtomProcessorFlowParameter resPar;
  2471.             while (risultato.next()) {
  2472.                 
  2473.                 resPar = new MtomProcessorFlowParameter();
  2474.                 
  2475.                 resPar.setId(risultato.getLong("id_porta"));
  2476.                 resPar.setNome(risultato.getString("nome"));
  2477.                 resPar.setPattern(risultato.getString("pattern"));
  2478.                 resPar.setContentType(risultato.getString("content_type"));
  2479.                 int required = risultato.getInt("required");
  2480.                 boolean isrequired = false;
  2481.                 if (required == CostantiDB.TRUE)
  2482.                     isrequired = true;
  2483.                 resPar.setRequired(isrequired);

  2485.                 

  2487.                 lista.add(resPar);
  2488.             }

  2490.             return lista;

  2492.         } catch (Exception qe) {
  2493.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  2494.         } finally {

  2496.             //Chiudo statement and resultset
  2497.             JDBCUtilities.closeResources(risultato, stmt);

  2499.             this.driver.closeConnection(con);
  2500.         }
  2501.     }
  2502.     
  2503.     /**
  2504.      * Ritorna la lista di proprieta per la configurazione custom dei connettori multipli di una Porta Applicativa
  2505.      */
  2506.     protected List<Proprieta> porteApplicativeConnettoriMultipliConfigPropList(long idPortaApplicativa, ISearch ricerca) throws DriverConfigurazioneException {
  2507.         int offset;
  2508.         int limit;
  2509.         int idLista = Liste.PORTE_APPLICATIVE_CONNETTORI_MULTIPLI_CONFIG_PROPRIETA;
  2510.         String search;
  2511.         String queryString;

  2513.         limit = ricerca.getPageSize(idLista);
  2514.         offset = ricerca.getIndexIniziale(idLista);
  2515.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));      


  2518.         Connection con = null;
  2519.         PreparedStatement stmt=null;
  2520.         ResultSet risultato=null;
  2521.         ArrayList<Proprieta> lista = new ArrayList<>();

  2523.         if (this.driver.atomica) {
  2524.             try {
  2525.                 con = this.driver.getConnectionFromDatasource("porteApplicativeConnettoriMultipliConfigPropList");
  2526.             } catch (Exception e) {
  2527.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteApplicativeConnettoriMultipliConfigPropList] Exception accedendo al datasource :" + e.getMessage(),e);

  2529.             }

  2531.         } else
  2532.             con = this.driver.globalConnection;

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

  2536.         try {

  2538.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2539.             sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_BEHAVIOUR_PROPS);
  2540.             sqlQueryObject.addSelectCountField("*", "cont");
  2541.             sqlQueryObject.addWhereCondition("id_porta = ?");
  2542.             
  2543.             if (!search.equals("")) {
  2544.                 //query con search
  2545.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  2546.                 sqlQueryObject.setANDLogicOperator(true);
  2547.             } 
  2548.             
  2549.             queryString = sqlQueryObject.createSQLQuery();
  2550.             
  2551.             stmt = con.prepareStatement(queryString);
  2552.             stmt.setLong(1, idPortaApplicativa);
  2553.             risultato = stmt.executeQuery();
  2554.             if (risultato.next())
  2555.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  2556.             risultato.close();
  2557.             stmt.close();

  2559.             // ricavo le entries
  2560.             if (limit == 0) // con limit
  2561.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  2562.             
  2563.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2564.             sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_BEHAVIOUR_PROPS);
  2565.             sqlQueryObject.addSelectField("id");
  2566.             sqlQueryObject.addSelectField("id_porta");
  2567.             sqlQueryObject.addSelectField("nome");
  2568.             sqlQueryObject.addSelectField("valore");
  2569.             sqlQueryObject.addWhereCondition("id_porta = ?");
  2570.             
  2571.             if (!search.equals("")) { // con search
  2572.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  2573.                 sqlQueryObject.setANDLogicOperator(true);
  2574.             } 
  2575.             
  2576.             sqlQueryObject.addOrderBy("nome");
  2577.             sqlQueryObject.setSortType(true);
  2578.             sqlQueryObject.setLimit(limit);
  2579.             sqlQueryObject.setOffset(offset);
  2580.             queryString = sqlQueryObject.createSQLQuery();
  2581.             
  2582.             stmt = con.prepareStatement(queryString);
  2583.             stmt.setLong(1, idPortaApplicativa);
  2584.             risultato = stmt.executeQuery();

  2586.             Proprieta prop = null;
  2587.             while (risultato.next()) {

  2589.                 prop = new Proprieta();

  2591.                 prop.setId(risultato.getLong("id"));
  2592.                 prop.setNome(risultato.getString("nome"));
  2593.                 prop.setValore(risultato.getString("valore"));

  2595.                 lista.add(prop);
  2596.             }

  2598.             return lista;

  2600.         } catch (Exception qe) {
  2601.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteApplicativeConnettoriMultipliConfigPropList] Errore : " + qe.getMessage(),qe);
  2602.         } finally {
  2603.             //Chiudo statement and resultset
  2604.             JDBCUtilities.closeResources(risultato, stmt);
  2605.             this.driver.closeConnection(con);
  2606.         }
  2607.     }
  2608.     
  2609.     /**
  2610.      * Ritorna la lista di proprieta di un connettore multiplo di una Porta Applicativa 
  2611.      */
  2612.     protected List<Proprieta> porteApplicativeConnettoriMultipliPropList(long idPaSa, ISearch ricerca) throws DriverConfigurazioneException {
  2613.         int offset;
  2614.         int limit;
  2615.         int idLista = Liste.PORTE_APPLICATIVE_CONNETTORI_MULTIPLI_PROPRIETA;
  2616.         String search;
  2617.         String queryString;

  2619.         limit = ricerca.getPageSize(idLista);
  2620.         offset = ricerca.getIndexIniziale(idLista);
  2621.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));      


  2624.         Connection con = null;
  2625.         PreparedStatement stmt=null;
  2626.         ResultSet risultato=null;
  2627.         ArrayList<Proprieta> lista = new ArrayList<>();

  2629.         if (this.driver.atomica) {
  2630.             try {
  2631.                 con = this.driver.getConnectionFromDatasource("porteApplicativeAutorizzazioneCustomPropList");
  2632.             } catch (Exception e) {
  2633.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteAppPropList] Exception accedendo al datasource :" + e.getMessage(),e);

  2635.             }

  2637.         } else
  2638.             con = this.driver.globalConnection;

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

  2642.         try {

  2644.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2645.             sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_SA_PROPS);
  2646.             sqlQueryObject.addSelectCountField("*", "cont");
  2647.             sqlQueryObject.addWhereCondition("id_porta = ?");
  2648.             
  2649.             if (!search.equals("")) {
  2650.                 //query con search
  2651.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  2652.                 sqlQueryObject.setANDLogicOperator(true);
  2653.             } 
  2654.             
  2655.             queryString = sqlQueryObject.createSQLQuery();
  2656.             
  2657.             stmt = con.prepareStatement(queryString);
  2658.             stmt.setLong(1, idPaSa);
  2659.             risultato = stmt.executeQuery();
  2660.             if (risultato.next())
  2661.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  2662.             risultato.close();
  2663.             stmt.close();

  2665.             // ricavo le entries
  2666.             if (limit == 0) // con limit
  2667.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  2668.             
  2669.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2670.             sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE_SA_PROPS);
  2671.             sqlQueryObject.addSelectField("id");
  2672.             sqlQueryObject.addSelectField("id_porta");
  2673.             sqlQueryObject.addSelectField("nome");
  2674.             sqlQueryObject.addSelectField("valore");
  2675.             sqlQueryObject.addWhereCondition("id_porta = ?");
  2676.             
  2677.             if (!search.equals("")) { // con search
  2678.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  2679.                 sqlQueryObject.setANDLogicOperator(true);
  2680.             } 
  2681.             
  2682.             sqlQueryObject.addOrderBy("nome");
  2683.             sqlQueryObject.setSortType(true);
  2684.             sqlQueryObject.setLimit(limit);
  2685.             sqlQueryObject.setOffset(offset);
  2686.             queryString = sqlQueryObject.createSQLQuery();
  2687.             
  2688.             stmt = con.prepareStatement(queryString);
  2689.             stmt.setLong(1, idPaSa);
  2690.             risultato = stmt.executeQuery();

  2692.             Proprieta prop = null;
  2693.             while (risultato.next()) {

  2695.                 prop = new Proprieta();

  2697.                 prop.setId(risultato.getLong("id"));
  2698.                 prop.setNome(risultato.getString("nome"));
  2699.                 prop.setValore(risultato.getString("valore"));

  2701.                 lista.add(prop);
  2702.             }

  2704.             return lista;

  2706.         } catch (Exception qe) {
  2707.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteAppPropList] Errore : " + qe.getMessage(),qe);
  2708.         } finally {
  2709.             //Chiudo statement and resultset
  2710.             JDBCUtilities.closeResources(risultato, stmt);
  2711.             this.driver.closeConnection(con);
  2712.         }
  2713.     }
  2714. }
Created with JaCoCo 0.8.8.202204050719