DriverConfigurazioneDB_porteDelegateSearchDriver.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.DBUtils;
  30. import org.openspcoop2.core.commons.Filtri;
  31. import org.openspcoop2.core.commons.ISearch;
  32. import org.openspcoop2.core.commons.Liste;
  33. import org.openspcoop2.core.commons.SearchUtils;
  34. import org.openspcoop2.core.config.CorrelazioneApplicativaElemento;
  35. import org.openspcoop2.core.config.CorrelazioneApplicativaRispostaElemento;
  36. import org.openspcoop2.core.config.MessageSecurityFlowParameter;
  37. import org.openspcoop2.core.config.MtomProcessorFlowParameter;
  38. import org.openspcoop2.core.config.PortaDelegata;
  39. import org.openspcoop2.core.config.Proprieta;
  40. import org.openspcoop2.core.config.ServizioApplicativo;
  41. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  42. import org.openspcoop2.core.constants.CostantiDB;
  43. import org.openspcoop2.core.id.IDServizio;
  44. import org.openspcoop2.core.id.IDSoggetto;
  45. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  46. import org.openspcoop2.utils.sql.ISQLQueryObject;
  47. import org.openspcoop2.utils.sql.SQLObjectFactory;

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

  60.     private DriverConfigurazioneDB driver = null;
  61.     private DriverConfigurazioneDB_porteDelegateDriver porteDelegateDriver = null;
  62.     
  63.     protected DriverConfigurazioneDB_porteDelegateSearchDriver(DriverConfigurazioneDB driver) {
  64.         this.driver = driver;
  65.         this.porteDelegateDriver = new DriverConfigurazioneDB_porteDelegateDriver(driver);
  66.     }
  67.     
  68.     protected List<String> portaDelegataRuoliList(long idPD, ISearch ricerca) throws DriverConfigurazioneException {
  69.         String nomeMetodo = "portaDelegataRuoliList";
  70.         int idLista = Liste.PORTE_DELEGATE_RUOLI;
  71.         String nomeTabella = CostantiDB.PORTE_DELEGATE_RUOLI;
  72.         return _portaDelegataRuoliList(idPD, ricerca,
  73.                 nomeMetodo, nomeTabella, idLista);
  74.     }
  75.     protected List<String> portaDelegataRuoliTokenList(long idPD, ISearch ricerca) throws DriverConfigurazioneException {
  76.         String nomeMetodo = "portaDelegataRuoliTokenList";
  77.         int idLista = Liste.PORTE_DELEGATE_TOKEN_RUOLI;
  78.         String nomeTabella = CostantiDB.PORTE_DELEGATE_TOKEN_RUOLI;
  79.         return _portaDelegataRuoliList(idPD, ricerca,
  80.                 nomeMetodo, nomeTabella, idLista);
  81.     }
  82.     private List<String> _portaDelegataRuoliList(long idPD, ISearch ricerca,
  83.             String nomeMetodo, String nomeTabella, int idLista) throws DriverConfigurazioneException {

  85.         int offset;
  86.         int limit;
  87.         String search;
  88.         String queryString;

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

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

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

  104.             }

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

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

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

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

  135.                 sqlQueryObject.setSelectDistinct(true);
  136.                 sqlQueryObject.setANDLogicOperator(true);
  137.                 queryString = sqlQueryObject.createSQLQuery();
  138.             }
  139.             stmt = con.prepareStatement(queryString);
  140.             stmt.setLong(1, idPD);

  142.             risultato = stmt.executeQuery();
  143.             if (risultato.next())
  144.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  145.             risultato.close();
  146.             stmt.close();

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

  187.             risultato = stmt.executeQuery();

  189.             listIdRuoli = new ArrayList<>();
  190.             while (risultato.next()) {

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

  194.             }

  196.         } catch (Exception qe) {
  197.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  198.         } finally {

  200.             //Chiudo statement and resultset
  201.             JDBCUtilities.closeResources(risultato, stmt);

  203.             this.driver.closeConnection(con);
  204.         }
  205.         
  206.         return listIdRuoli;
  207.     }
  208.     
  209.     
  210.     
  211.     protected List<String> portaDelegataScopeList(long idPD, ISearch ricerca) throws DriverConfigurazioneException {
  212.         String nomeMetodo = "portaDelegataScopeList";
  213.         int idLista = Liste.PORTE_DELEGATE_SCOPE;
  214.         int offset;
  215.         int limit;
  216.         String search;
  217.         String queryString;

  219.         limit = ricerca.getPageSize(idLista);
  220.         offset = ricerca.getIndexIniziale(idLista);
  221.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));

  223.         Connection con = null;
  224.         PreparedStatement stmt = null;
  225.         ResultSet risultato = null;

  227.         if (this.driver.atomica) {
  228.             try {
  229.                 con = this.driver.getConnectionFromDatasource(nomeMetodo);
  230.             } catch (Exception e) {
  231.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  233.             }

  235.         } else
  236.             con = this.driver.globalConnection;

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

  240.         List<String> listIdScope = null;
  241.         try {

  243.             if (!search.equals("")) {
  244.                 //query con search
  245.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  246.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  247.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_SCOPE);
  248.                 sqlQueryObject.addSelectCountField("*", "cont");
  249.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_DELEGATE+".id=?");
  250.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_DELEGATE+".id="+CostantiDB.PORTE_DELEGATE_SCOPE+".id_porta");
  251.                 sqlQueryObject.addWhereLikeCondition(CostantiDB.PORTE_DELEGATE_SCOPE+".scope", search, true, true); 
  252.                 
  253.                 sqlQueryObject.setSelectDistinct(true);
  254.                 sqlQueryObject.setANDLogicOperator(true);
  255.                 queryString = sqlQueryObject.createSQLQuery();
  256.             } else {
  257.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  258.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  259.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_SCOPE);
  260.                 sqlQueryObject.addSelectCountField("*", "cont");
  261.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_DELEGATE+".id=?");
  262.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_DELEGATE+".id="+CostantiDB.PORTE_DELEGATE_SCOPE+".id_porta");

  264.                 sqlQueryObject.setSelectDistinct(true);
  265.                 sqlQueryObject.setANDLogicOperator(true);
  266.                 queryString = sqlQueryObject.createSQLQuery();
  267.             }
  268.             stmt = con.prepareStatement(queryString);
  269.             stmt.setLong(1, idPD);

  271.             risultato = stmt.executeQuery();
  272.             if (risultato.next())
  273.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  274.             risultato.close();
  275.             stmt.close();

  277.             // ricavo le entries
  278.             if (limit == 0) // con limit
  279.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  280.             if (!search.equals("")) { // con search
  281.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  282.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  283.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_SCOPE);
  284.                 sqlQueryObject.addSelectField(CostantiDB.PORTE_DELEGATE_SCOPE+".scope");
  285.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_DELEGATE+".id=?");
  286.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_DELEGATE+".id="+CostantiDB.PORTE_DELEGATE_SCOPE+".id_porta");
  287.                 sqlQueryObject.addWhereLikeCondition(CostantiDB.PORTE_DELEGATE_SCOPE+".scope", search, true, true); 
  288.                 
  289.                 sqlQueryObject.setSelectDistinct(true);
  290.                 sqlQueryObject.setANDLogicOperator(true);
  291.                 sqlQueryObject.addOrderBy(CostantiDB.PORTE_DELEGATE_SCOPE+".scope");
  292.                 sqlQueryObject.setSortType(true);
  293.                 sqlQueryObject.setLimit(limit);
  294.                 sqlQueryObject.setOffset(offset);
  295.                 queryString = sqlQueryObject.createSQLQuery();
  296.             } else {
  297.                 // senza search
  298.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  299.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  300.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_SCOPE);
  301.                 sqlQueryObject.addSelectField(CostantiDB.PORTE_DELEGATE_SCOPE+".scope");
  302.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_DELEGATE+".id=?");
  303.                 sqlQueryObject.addWhereCondition(CostantiDB.PORTE_DELEGATE+".id="+CostantiDB.PORTE_DELEGATE_SCOPE+".id_porta");
  304.                 
  305.                 sqlQueryObject.setSelectDistinct(true);
  306.                 sqlQueryObject.setANDLogicOperator(true);
  307.                 sqlQueryObject.addOrderBy(CostantiDB.PORTE_DELEGATE_SCOPE+".scope");
  308.                 sqlQueryObject.setSortType(true);
  309.                 sqlQueryObject.setLimit(limit);
  310.                 sqlQueryObject.setOffset(offset);
  311.                 queryString = sqlQueryObject.createSQLQuery();
  312.             }
  313.             stmt = con.prepareStatement(queryString);
  314.             stmt.setLong(1, idPD);

  316.             risultato = stmt.executeQuery();

  318.             listIdScope = new ArrayList<>();
  319.             while (risultato.next()) {

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

  323.             }

  325.         } catch (Exception qe) {
  326.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  327.         } finally {

  329.             //Chiudo statement and resultset
  330.             JDBCUtilities.closeResources(risultato, stmt);

  332.             this.driver.closeConnection(con);
  333.         }
  334.         
  335.         return listIdScope;
  336.     }
  337.     
  338.     protected List<PortaDelegata> porteDelegateList(long idSoggetto, ISearch ricerca) throws DriverConfigurazioneException {
  339.         String nomeMetodo = "porteDelegateList";
  340.         int idLista = Liste.PORTE_DELEGATE_BY_SOGGETTO;
  341.         int offset;
  342.         int limit;
  343.         String search;
  344.         String queryString;

  346.         limit = ricerca.getPageSize(idLista);
  347.         offset = ricerca.getIndexIniziale(idLista);
  348.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));

  350.         Connection con = null;
  351.         PreparedStatement stmt=null;
  352.         ResultSet risultato=null;
  353.         ArrayList<PortaDelegata> lista = new ArrayList<>();

  355.         if (this.driver.atomica) {
  356.             try {
  357.                 con = this.driver.getConnectionFromDatasource("porteDelegateList");
  358.             } catch (Exception e) {
  359.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  361.             }

  363.         } else
  364.             con = this.driver.globalConnection;

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

  368.         try {

  370.             if (!search.equals("")) {
  371.                 //query con search
  372.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  373.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  374.                 sqlQueryObject.addSelectCountField("*", "cont");
  375.                 sqlQueryObject.addWhereCondition("id_soggetto = ?");
  376.                 sqlQueryObject.addWhereLikeCondition("nome_porta", search, true, true);
  377.                 sqlQueryObject.setANDLogicOperator(true);
  378.                 queryString = sqlQueryObject.createSQLQuery();
  379.             } else {
  380.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  381.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  382.                 sqlQueryObject.addSelectCountField("*", "cont");
  383.                 sqlQueryObject.addWhereCondition("id_soggetto = ?");
  384.                 sqlQueryObject.setANDLogicOperator(true);
  385.                 queryString = sqlQueryObject.createSQLQuery();
  386.             }
  387.             stmt = con.prepareStatement(queryString);
  388.             stmt.setLong(1, idSoggetto);
  389.             risultato = stmt.executeQuery();
  390.             if (risultato.next())
  391.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  392.             risultato.close();
  393.             stmt.close();

  395.             // ricavo le entries
  396.             if (limit == 0) // con limit
  397.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  398.             if (!search.equals("")) { // con search
  399.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  400.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  401.                 sqlQueryObject.addSelectField("id");
  402.                 sqlQueryObject.addSelectField("nome_porta");
  403.                 sqlQueryObject.addSelectField("id_soggetto");
  404.                 sqlQueryObject.addWhereCondition("id_soggetto = ?");
  405.                 sqlQueryObject.addWhereLikeCondition("nome_porta", search, true, true);
  406.                 sqlQueryObject.setANDLogicOperator(true);
  407.                 sqlQueryObject.addOrderBy("nome_porta");
  408.                 sqlQueryObject.setSortType(true);
  409.                 sqlQueryObject.setLimit(limit);
  410.                 sqlQueryObject.setOffset(offset);
  411.                 queryString = sqlQueryObject.createSQLQuery();
  412.             } else {
  413.                 // senza search
  414.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  415.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  416.                 sqlQueryObject.addSelectField("id");
  417.                 sqlQueryObject.addSelectField("nome_porta");
  418.                 sqlQueryObject.addSelectField("id_soggetto");
  419.                 sqlQueryObject.addWhereCondition("id_soggetto = ?");
  420.                 sqlQueryObject.setANDLogicOperator(true);
  421.                 sqlQueryObject.addOrderBy("nome_porta");
  422.                 sqlQueryObject.setSortType(true);
  423.                 sqlQueryObject.setLimit(limit);
  424.                 sqlQueryObject.setOffset(offset);
  425.                 queryString = sqlQueryObject.createSQLQuery();
  426.             }
  427.             stmt = con.prepareStatement(queryString);
  428.             stmt.setLong(1, idSoggetto);
  429.             risultato = stmt.executeQuery();

  431.             PortaDelegata pd;
  432.             while (risultato.next()) {
  433.                 pd = this.porteDelegateDriver.getPortaDelegata(risultato.getLong("id"),con);
  434.                 lista.add(pd);
  435.             }

  437.             return lista;

  439.         } catch (Exception qe) {
  440.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  441.         } finally {

  443.             //Chiudo statement and resultset
  444.             JDBCUtilities.closeResources(risultato, stmt);

  446.             this.driver.closeConnection(con);
  447.         }
  448.     }
  449.     
  450.     
  451.     protected List<Proprieta> porteDelegatePropList(long idPortaDelegata, ISearch ricerca) throws DriverConfigurazioneException {
  452.         int offset;
  453.         int limit;
  454.         int idLista = Liste.PORTE_DELEGATE_PROP;
  455.         String search;
  456.         String queryString;

  458.         limit = ricerca.getPageSize(idLista);
  459.         offset = ricerca.getIndexIniziale(idLista);
  460.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));      


  463.         Connection con = null;
  464.         PreparedStatement stmt=null;
  465.         ResultSet risultato=null;
  466.         ArrayList<Proprieta> lista = new ArrayList<>();

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

  474.             }

  476.         } else
  477.             con = this.driver.globalConnection;

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

  481.         try {

  483.             if (!search.equals("")) {
  484.                 //query con search
  485.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  486.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_PROP);
  487.                 sqlQueryObject.addSelectCountField("*", "cont");
  488.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  489.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  490.                 sqlQueryObject.setANDLogicOperator(true);
  491.                 queryString = sqlQueryObject.createSQLQuery();
  492.             } else {
  493.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  494.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_PROP);
  495.                 sqlQueryObject.addSelectCountField("*", "cont");
  496.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  497.                 queryString = sqlQueryObject.createSQLQuery();
  498.             }
  499.             stmt = con.prepareStatement(queryString);
  500.             stmt.setLong(1, idPortaDelegata);
  501.             risultato = stmt.executeQuery();
  502.             if (risultato.next())
  503.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  504.             risultato.close();
  505.             stmt.close();

  507.             // ricavo le entries
  508.             if (limit == 0) // con limit
  509.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  510.             if (!search.equals("")) { // con search
  511.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  512.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_PROP);
  513.                 sqlQueryObject.addSelectField("id");
  514.                 sqlQueryObject.addSelectField("id_porta");
  515.                 sqlQueryObject.addSelectField("nome");
  516.                 sqlQueryObject.addSelectField("valore");
  517.                 sqlQueryObject.addSelectField("enc_value");
  518.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  519.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  520.                 sqlQueryObject.setANDLogicOperator(true);
  521.                 sqlQueryObject.addOrderBy("nome");
  522.                 sqlQueryObject.setSortType(true);
  523.                 sqlQueryObject.setLimit(limit);
  524.                 sqlQueryObject.setOffset(offset);
  525.                 queryString = sqlQueryObject.createSQLQuery();
  526.             } else {
  527.                 // senza search
  528.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  529.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_PROP);
  530.                 sqlQueryObject.addSelectField("id");
  531.                 sqlQueryObject.addSelectField("id_porta");
  532.                 sqlQueryObject.addSelectField("nome");
  533.                 sqlQueryObject.addSelectField("valore");
  534.                 sqlQueryObject.addSelectField("enc_value");
  535.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  536.                 sqlQueryObject.addOrderBy("nome");
  537.                 sqlQueryObject.setSortType(true);
  538.                 sqlQueryObject.setLimit(limit);
  539.                 sqlQueryObject.setOffset(offset);
  540.                 queryString = sqlQueryObject.createSQLQuery();
  541.             }
  542.             stmt = con.prepareStatement(queryString);
  543.             stmt.setLong(1, idPortaDelegata);
  544.             risultato = stmt.executeQuery();

  546.             Proprieta prop = null;
  547.             while (risultato.next()) {

  549.                 prop = new Proprieta();

  551.                 prop.setId(risultato.getLong("id"));
  552.                 prop.setNome(risultato.getString("nome"));
  553.                 
  554.                 String plainValue = risultato.getString("valore");
  555.                 String encValue = risultato.getString("enc_value");
  556.                 if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  557.                     prop.setValore(encValue);
  558.                 }
  559.                 else {
  560.                     prop.setValore(plainValue);
  561.                 }

  563.                 lista.add(prop);
  564.             }

  566.             return lista;

  568.         } catch (Exception qe) {
  569.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteDelegatePropList] Errore : " + qe.getMessage(),qe);
  570.         } finally {
  571.             //Chiudo statement and resultset
  572.             JDBCUtilities.closeResources(risultato, stmt);
  573.             this.driver.closeConnection(con);
  574.         }
  575.     }
  576.     
  577.     
  578.     
  579.     protected List<Proprieta> porteDelegateAutenticazioneCustomPropList(long idPortaDelegata, ISearch ricerca) throws DriverConfigurazioneException {
  580.         int offset;
  581.         int limit;
  582.         int idLista = Liste.PORTE_DELEGATE_PROPRIETA_AUTENTICAZIONE;
  583.         String search;
  584.         String queryString;

  586.         limit = ricerca.getPageSize(idLista);
  587.         offset = ricerca.getIndexIniziale(idLista);
  588.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));      


  591.         Connection con = null;
  592.         PreparedStatement stmt=null;
  593.         ResultSet risultato=null;
  594.         ArrayList<Proprieta> lista = new ArrayList<>();

  596.         if (this.driver.atomica) {
  597.             try {
  598.                 con = this.driver.getConnectionFromDatasource("porteDelegatePropList");
  599.             } catch (Exception e) {
  600.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteDelegatePropList] Exception accedendo al datasource :" + e.getMessage(),e);

  602.             }

  604.         } else
  605.             con = this.driver.globalConnection;

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

  609.         try {

  611.             if (!search.equals("")) {
  612.                 //query con search
  613.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  614.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_AUTENTICAZIONE_PROP);
  615.                 sqlQueryObject.addSelectCountField("*", "cont");
  616.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  617.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  618.                 sqlQueryObject.setANDLogicOperator(true);
  619.                 queryString = sqlQueryObject.createSQLQuery();
  620.             } else {
  621.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  622.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_AUTENTICAZIONE_PROP);
  623.                 sqlQueryObject.addSelectCountField("*", "cont");
  624.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  625.                 queryString = sqlQueryObject.createSQLQuery();
  626.             }
  627.             stmt = con.prepareStatement(queryString);
  628.             stmt.setLong(1, idPortaDelegata);
  629.             risultato = stmt.executeQuery();
  630.             if (risultato.next())
  631.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  632.             risultato.close();
  633.             stmt.close();

  635.             // ricavo le entries
  636.             if (limit == 0) // con limit
  637.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  638.             if (!search.equals("")) { // con search
  639.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  640.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_AUTENTICAZIONE_PROP);
  641.                 sqlQueryObject.addSelectField("id");
  642.                 sqlQueryObject.addSelectField("id_porta");
  643.                 sqlQueryObject.addSelectField("nome");
  644.                 sqlQueryObject.addSelectField("valore");
  645.                 sqlQueryObject.addSelectField("enc_value");
  646.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  647.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  648.                 sqlQueryObject.setANDLogicOperator(true);
  649.                 sqlQueryObject.addOrderBy("nome");
  650.                 sqlQueryObject.setSortType(true);
  651.                 sqlQueryObject.setLimit(limit);
  652.                 sqlQueryObject.setOffset(offset);
  653.                 queryString = sqlQueryObject.createSQLQuery();
  654.             } else {
  655.                 // senza search
  656.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  657.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_AUTENTICAZIONE_PROP);
  658.                 sqlQueryObject.addSelectField("id");
  659.                 sqlQueryObject.addSelectField("id_porta");
  660.                 sqlQueryObject.addSelectField("nome");
  661.                 sqlQueryObject.addSelectField("valore");
  662.                 sqlQueryObject.addSelectField("enc_value");
  663.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  664.                 sqlQueryObject.addOrderBy("nome");
  665.                 sqlQueryObject.setSortType(true);
  666.                 sqlQueryObject.setLimit(limit);
  667.                 sqlQueryObject.setOffset(offset);
  668.                 queryString = sqlQueryObject.createSQLQuery();
  669.             }
  670.             stmt = con.prepareStatement(queryString);
  671.             stmt.setLong(1, idPortaDelegata);
  672.             risultato = stmt.executeQuery();

  674.             Proprieta prop = null;
  675.             while (risultato.next()) {

  677.                 prop = new Proprieta();

  679.                 prop.setId(risultato.getLong("id"));
  680.                 prop.setNome(risultato.getString("nome"));
  681.                 
  682.                 String plainValue = risultato.getString("valore");
  683.                 String encValue = risultato.getString("enc_value");
  684.                 if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  685.                     prop.setValore(encValue);
  686.                 }
  687.                 else {
  688.                     prop.setValore(plainValue);
  689.                 }

  691.                 lista.add(prop);
  692.             }

  694.             return lista;

  696.         } catch (Exception qe) {
  697.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteDelegatePropList] Errore : " + qe.getMessage(),qe);
  698.         } finally {
  699.             //Chiudo statement and resultset
  700.             JDBCUtilities.closeResources(risultato, stmt);
  701.             this.driver.closeConnection(con);
  702.         }
  703.     }
  704.     
  705.     protected List<Proprieta> porteDelegateAutorizzazioneCustomPropList(long idPortaDelegata, ISearch ricerca) throws DriverConfigurazioneException {
  706.         int offset;
  707.         int limit;
  708.         int idLista = Liste.PORTE_DELEGATE_PROPRIETA_AUTORIZZAZIONE;
  709.         String search;
  710.         String queryString;

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


  717.         Connection con = null;
  718.         PreparedStatement stmt=null;
  719.         ResultSet risultato=null;
  720.         ArrayList<Proprieta> lista = new ArrayList<>();

  722.         if (this.driver.atomica) {
  723.             try {
  724.                 con = this.driver.getConnectionFromDatasource("porteDelegatePropList");
  725.             } catch (Exception e) {
  726.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteDelegatePropList] Exception accedendo al datasource :" + e.getMessage(),e);

  728.             }

  730.         } else
  731.             con = this.driver.globalConnection;

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

  735.         try {

  737.             if (!search.equals("")) {
  738.                 //query con search
  739.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  740.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_AUTORIZZAZIONE_PROP);
  741.                 sqlQueryObject.addSelectCountField("*", "cont");
  742.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  743.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  744.                 sqlQueryObject.setANDLogicOperator(true);
  745.                 queryString = sqlQueryObject.createSQLQuery();
  746.             } else {
  747.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  748.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_AUTORIZZAZIONE_PROP);
  749.                 sqlQueryObject.addSelectCountField("*", "cont");
  750.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  751.                 queryString = sqlQueryObject.createSQLQuery();
  752.             }
  753.             stmt = con.prepareStatement(queryString);
  754.             stmt.setLong(1, idPortaDelegata);
  755.             risultato = stmt.executeQuery();
  756.             if (risultato.next())
  757.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  758.             risultato.close();
  759.             stmt.close();

  761.             // ricavo le entries
  762.             if (limit == 0) // con limit
  763.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  764.             if (!search.equals("")) { // con search
  765.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  766.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_AUTORIZZAZIONE_PROP);
  767.                 sqlQueryObject.addSelectField("id");
  768.                 sqlQueryObject.addSelectField("id_porta");
  769.                 sqlQueryObject.addSelectField("nome");
  770.                 sqlQueryObject.addSelectField("valore");
  771.                 sqlQueryObject.addSelectField("enc_value");
  772.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  773.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  774.                 sqlQueryObject.setANDLogicOperator(true);
  775.                 sqlQueryObject.addOrderBy("nome");
  776.                 sqlQueryObject.setSortType(true);
  777.                 sqlQueryObject.setLimit(limit);
  778.                 sqlQueryObject.setOffset(offset);
  779.                 queryString = sqlQueryObject.createSQLQuery();
  780.             } else {
  781.                 // senza search
  782.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  783.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_AUTORIZZAZIONE_PROP);
  784.                 sqlQueryObject.addSelectField("id");
  785.                 sqlQueryObject.addSelectField("id_porta");
  786.                 sqlQueryObject.addSelectField("nome");
  787.                 sqlQueryObject.addSelectField("valore");
  788.                 sqlQueryObject.addSelectField("enc_value");
  789.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  790.                 sqlQueryObject.addOrderBy("nome");
  791.                 sqlQueryObject.setSortType(true);
  792.                 sqlQueryObject.setLimit(limit);
  793.                 sqlQueryObject.setOffset(offset);
  794.                 queryString = sqlQueryObject.createSQLQuery();
  795.             }
  796.             stmt = con.prepareStatement(queryString);
  797.             stmt.setLong(1, idPortaDelegata);
  798.             risultato = stmt.executeQuery();

  800.             Proprieta prop = null;
  801.             while (risultato.next()) {

  803.                 prop = new Proprieta();

  805.                 prop.setId(risultato.getLong("id"));
  806.                 prop.setNome(risultato.getString("nome"));
  807.                 
  808.                 String plainValue = risultato.getString("valore");
  809.                 String encValue = risultato.getString("enc_value");
  810.                 if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  811.                     prop.setValore(encValue);
  812.                 }
  813.                 else {
  814.                     prop.setValore(plainValue);
  815.                 }

  817.                 lista.add(prop);
  818.             }

  820.             return lista;

  822.         } catch (Exception qe) {
  823.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteDelegatePropList] Errore : " + qe.getMessage(),qe);
  824.         } finally {
  825.             //Chiudo statement and resultset
  826.             JDBCUtilities.closeResources(risultato, stmt);
  827.             this.driver.closeConnection(con);
  828.         }
  829.     }
  830.     
  831.     protected List<Proprieta> porteDelegateAutorizzazioneContenutoCustomPropList(long idPortaDelegata, ISearch ricerca) throws DriverConfigurazioneException {
  832.         int offset;
  833.         int limit;
  834.         int idLista = Liste.PORTE_DELEGATE_PROPRIETA_AUTORIZZAZIONE_CONTENUTO;
  835.         String search;
  836.         String queryString;

  838.         limit = ricerca.getPageSize(idLista);
  839.         offset = ricerca.getIndexIniziale(idLista);
  840.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));      


  843.         Connection con = null;
  844.         PreparedStatement stmt=null;
  845.         ResultSet risultato=null;
  846.         ArrayList<Proprieta> lista = new ArrayList<>();

  848.         if (this.driver.atomica) {
  849.             try {
  850.                 con = this.driver.getConnectionFromDatasource("porteDelegatePropList");
  851.             } catch (Exception e) {
  852.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteDelegatePropList] Exception accedendo al datasource :" + e.getMessage(),e);

  854.             }

  856.         } else
  857.             con = this.driver.globalConnection;

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

  861.         try {

  863.             if (!search.equals("")) {
  864.                 //query con search
  865.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  866.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_AUTORIZZAZIONE_CONTENUTI_PROP);
  867.                 sqlQueryObject.addSelectCountField("*", "cont");
  868.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  869.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  870.                 sqlQueryObject.setANDLogicOperator(true);
  871.                 queryString = sqlQueryObject.createSQLQuery();
  872.             } else {
  873.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  874.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_AUTORIZZAZIONE_CONTENUTI_PROP);
  875.                 sqlQueryObject.addSelectCountField("*", "cont");
  876.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  877.                 queryString = sqlQueryObject.createSQLQuery();
  878.             }
  879.             stmt = con.prepareStatement(queryString);
  880.             stmt.setLong(1, idPortaDelegata);
  881.             risultato = stmt.executeQuery();
  882.             if (risultato.next())
  883.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  884.             risultato.close();
  885.             stmt.close();

  887.             // ricavo le entries
  888.             if (limit == 0) // con limit
  889.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  890.             if (!search.equals("")) { // con search
  891.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  892.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_AUTORIZZAZIONE_CONTENUTI_PROP);
  893.                 sqlQueryObject.addSelectField("id");
  894.                 sqlQueryObject.addSelectField("id_porta");
  895.                 sqlQueryObject.addSelectField("nome");
  896.                 sqlQueryObject.addSelectField("valore");
  897.                 sqlQueryObject.addSelectField("enc_value");
  898.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  899.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  900.                 sqlQueryObject.setANDLogicOperator(true);
  901.                 sqlQueryObject.addOrderBy("nome");
  902.                 sqlQueryObject.setSortType(true);
  903.                 sqlQueryObject.setLimit(limit);
  904.                 sqlQueryObject.setOffset(offset);
  905.                 queryString = sqlQueryObject.createSQLQuery();
  906.             } else {
  907.                 // senza search
  908.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  909.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_AUTORIZZAZIONE_CONTENUTI_PROP);
  910.                 sqlQueryObject.addSelectField("id");
  911.                 sqlQueryObject.addSelectField("id_porta");
  912.                 sqlQueryObject.addSelectField("nome");
  913.                 sqlQueryObject.addSelectField("valore");
  914.                 sqlQueryObject.addSelectField("enc_value");
  915.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  916.                 sqlQueryObject.addOrderBy("nome");
  917.                 sqlQueryObject.setSortType(true);
  918.                 sqlQueryObject.setLimit(limit);
  919.                 sqlQueryObject.setOffset(offset);
  920.                 queryString = sqlQueryObject.createSQLQuery();
  921.             }
  922.             stmt = con.prepareStatement(queryString);
  923.             stmt.setLong(1, idPortaDelegata);
  924.             risultato = stmt.executeQuery();

  926.             Proprieta prop = null;
  927.             while (risultato.next()) {

  929.                 prop = new Proprieta();

  931.                 prop.setId(risultato.getLong("id"));
  932.                 prop.setNome(risultato.getString("nome"));
  933.                 
  934.                 String plainValue = risultato.getString("valore");
  935.                 String encValue = risultato.getString("enc_value");
  936.                 if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  937.                     prop.setValore(encValue);
  938.                 }
  939.                 else {
  940.                     prop.setValore(plainValue);
  941.                 }

  943.                 lista.add(prop);
  944.             }

  946.             return lista;

  948.         } catch (Exception qe) {
  949.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::porteDelegatePropList] Errore : " + qe.getMessage(),qe);
  950.         } finally {
  951.             //Chiudo statement and resultset
  952.             JDBCUtilities.closeResources(risultato, stmt);
  953.             this.driver.closeConnection(con);
  954.         }
  955.     }

  957.     protected List<PortaDelegata> porteDelegateList(String superuser, ISearch ricerca) throws DriverConfigurazioneException {
  958.         String nomeMetodo = "porteDelegateList";
  959.         int idLista = Liste.PORTE_DELEGATE;
  960.         int offset;
  961.         int limit;
  962.         String search;
  963.         String queryString;

  965.         limit = ricerca.getPageSize(idLista);
  966.         offset = ricerca.getIndexIniziale(idLista);
  967.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));


  970.         String filterProtocollo = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_PROTOCOLLO);
  971.         String filterProtocolli = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_PROTOCOLLI);
  972.         List<String> tipoSoggettiProtocollo = null;
  973.         try {
  974.             tipoSoggettiProtocollo = Filtri.convertToTipiSoggetti(filterProtocollo, filterProtocolli);
  975.         }catch(Exception e) {
  976.             throw new DriverConfigurazioneException(e.getMessage(),e);
  977.         }
  978.         
  979.         this.driver.logDebug("search : " + search);
  980.         this.driver.logDebug("filterProtocollo : " + filterProtocollo);
  981.         this.driver.logDebug("filterProtocolli : " + filterProtocolli);

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

  988.         if (this.driver.atomica) {
  989.             try {
  990.                 con = this.driver.getConnectionFromDatasource("porteDelegateList");
  991.             } catch (Exception e) {
  992.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] 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_DELEGATE);
  1007.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1008.                 sqlQueryObject.addSelectCountField("*", "cont");
  1009.                 sqlQueryObject.addWhereCondition("id_soggetto = "+CostantiDB.SOGGETTI+".id");
  1010.                 if(this.driver.useSuperUser && superuser!=null && (!"".equals(superuser)))
  1011.                     sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".superuser = ?");
  1012.                 sqlQueryObject.addWhereLikeCondition("nome_porta", search, true, true);
  1013.                 if(tipoSoggettiProtocollo!=null && tipoSoggettiProtocollo.size()>0) {
  1014.                     sqlQueryObject.addWhereINCondition("tipo_soggetto", true, tipoSoggettiProtocollo.toArray(new String[1]));
  1015.                 }
  1016.                 sqlQueryObject.setANDLogicOperator(true);
  1017.                 queryString = sqlQueryObject.createSQLQuery();
  1018.             } else {
  1019.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1020.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  1021.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1022.                 sqlQueryObject.addSelectCountField("*", "cont");
  1023.                 sqlQueryObject.addWhereCondition("id_soggetto = "+CostantiDB.SOGGETTI+".id");
  1024.                 if(this.driver.useSuperUser && superuser!=null && (!"".equals(superuser)))
  1025.                     sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".superuser = ?");
  1026.                 if(tipoSoggettiProtocollo!=null && tipoSoggettiProtocollo.size()>0) {
  1027.                     sqlQueryObject.addWhereINCondition("tipo_soggetto", true, tipoSoggettiProtocollo.toArray(new String[1]));
  1028.                 }
  1029.                 sqlQueryObject.setANDLogicOperator(true);
  1030.                 queryString = sqlQueryObject.createSQLQuery();
  1031.             }
  1032.             stmt = con.prepareStatement(queryString);
  1033.             if(this.driver.useSuperUser && superuser!=null && (!"".equals(superuser)))
  1034.                 stmt.setString(1, superuser);
  1035.             risultato = stmt.executeQuery();
  1036.             if (risultato.next())
  1037.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1038.             risultato.close();
  1039.             stmt.close();

  1041.             // ricavo le entries
  1042.             if (limit == 0) // con limit
  1043.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1044.             if (!search.equals("")) { // con search
  1045.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1046.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  1047.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1048.                 sqlQueryObject.addSelectField(CostantiDB.PORTE_DELEGATE+".id");
  1049.                 sqlQueryObject.addSelectField("nome_porta");
  1050.                 sqlQueryObject.addWhereCondition("id_soggetto = "+CostantiDB.SOGGETTI+".id");
  1051.                 if(this.driver.useSuperUser && superuser!=null && (!"".equals(superuser)))
  1052.                     sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".superuser = ?");
  1053.                 sqlQueryObject.addWhereLikeCondition("nome_porta", search, true, true);
  1054.                 if(tipoSoggettiProtocollo!=null && tipoSoggettiProtocollo.size()>0) {
  1055.                     sqlQueryObject.addWhereINCondition("tipo_soggetto", true, tipoSoggettiProtocollo.toArray(new String[1]));
  1056.                 }
  1057.                 sqlQueryObject.setANDLogicOperator(true);
  1058.                 sqlQueryObject.addOrderBy("nome_porta");
  1059.                 sqlQueryObject.setSortType(true);
  1060.                 sqlQueryObject.setLimit(limit);
  1061.                 sqlQueryObject.setOffset(offset);
  1062.                 queryString = sqlQueryObject.createSQLQuery();
  1063.             } else {
  1064.                 // senza search
  1065.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1066.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  1067.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  1068.                 sqlQueryObject.addSelectField(CostantiDB.PORTE_DELEGATE+".id");
  1069.                 sqlQueryObject.addSelectField("nome_porta");
  1070.                 sqlQueryObject.addWhereCondition("id_soggetto = "+CostantiDB.SOGGETTI+".id");
  1071.                 if(this.driver.useSuperUser && superuser!=null && (!"".equals(superuser)))
  1072.                     sqlQueryObject.addWhereCondition(CostantiDB.SOGGETTI+".superuser = ?");
  1073.                 if(tipoSoggettiProtocollo!=null && tipoSoggettiProtocollo.size()>0) {
  1074.                     sqlQueryObject.addWhereINCondition("tipo_soggetto", true, tipoSoggettiProtocollo.toArray(new String[1]));
  1075.                 }
  1076.                 sqlQueryObject.setANDLogicOperator(true);
  1077.                 sqlQueryObject.addOrderBy("nome_porta");
  1078.                 sqlQueryObject.setSortType(true);
  1079.                 sqlQueryObject.setLimit(limit);
  1080.                 sqlQueryObject.setOffset(offset);
  1081.                 queryString = sqlQueryObject.createSQLQuery();
  1082.             }
  1083.             stmt = con.prepareStatement(queryString);
  1084.             if(this.driver.useSuperUser && superuser!=null && (!"".equals(superuser)))
  1085.                 stmt.setString(1, superuser);
  1086.             risultato = stmt.executeQuery();

  1088.             PortaDelegata pd;
  1089.             while (risultato.next()) {

  1091.                 pd = this.porteDelegateDriver.getPortaDelegata(risultato.getLong("id"),con);
  1092.                 lista.add(pd);
  1093.             }

  1095.             return lista;

  1097.         } catch (Exception qe) {
  1098.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  1099.         } finally {

  1101.             //Chiudo statement and resultset
  1102.             JDBCUtilities.closeResources(risultato, stmt);

  1104.             this.driver.closeConnection(con);
  1105.         }
  1106.     }
  1107.     
  1108.     
  1109.     protected List<ServizioApplicativo> porteDelegateServizioApplicativoList(long idPortaDelegata, ISearch ricerca) throws DriverConfigurazioneException {
  1110.         String nomeMetodo = "porteDelegateServizioApplicativoList";
  1111.         int idLista = Liste.PORTE_DELEGATE_SERVIZIO_APPLICATIVO;
  1112.         String nomeTabella = CostantiDB.PORTE_DELEGATE_SA;
  1113.         return _porteDelegateServizioApplicativoList(idPortaDelegata, ricerca,
  1114.                 nomeMetodo, nomeTabella, idLista);
  1115.     }
  1116.     protected List<ServizioApplicativo> porteDelegateServizioApplicativoTokenList(long idPortaDelegata, ISearch ricerca) throws DriverConfigurazioneException {
  1117.         String nomeMetodo = "porteDelegateServizioApplicativoTokenList";
  1118.         int idLista = Liste.PORTE_DELEGATE_TOKEN_SERVIZIO_APPLICATIVO;
  1119.         String nomeTabella = CostantiDB.PORTE_DELEGATE_TOKEN_SA;
  1120.         return _porteDelegateServizioApplicativoList(idPortaDelegata, ricerca,
  1121.                 nomeMetodo, nomeTabella, idLista);
  1122.     }
  1123.     private List<ServizioApplicativo> _porteDelegateServizioApplicativoList(long idPortaDelegata, ISearch ricerca,
  1124.             String nomeMetodo, String nomeTabella, int idLista) throws DriverConfigurazioneException {
  1125.         int offset;
  1126.         int limit;
  1127.         String search;
  1128.         String queryString;

  1130.         limit = ricerca.getPageSize(idLista);
  1131.         offset = ricerca.getIndexIniziale(idLista);
  1132.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));


  1135.         Connection con = null;
  1136.         PreparedStatement stmt=null;
  1137.         PreparedStatement stmt1=null;
  1138.         ResultSet risultato=null;
  1139.         ResultSet rs1=null;
  1140.         ArrayList<ServizioApplicativo> lista = new ArrayList<>();

  1142.         if (this.driver.atomica) {
  1143.             try {
  1144.                 con = this.driver.getConnectionFromDatasource("porteDelegateServizioApplicativoList");
  1145.             } catch (Exception e) {
  1146.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1148.             }

  1150.         } else
  1151.             con = this.driver.globalConnection;

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

  1155.         try {

  1157.             if (!search.equals("")) {
  1158.                 //query con search
  1159.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1160.                 sqlQueryObject.addFromTable(nomeTabella);
  1161.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI_APPLICATIVI);
  1162.                 sqlQueryObject.addSelectCountField("*", "cont");
  1163.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1164.                 sqlQueryObject.addWhereCondition(nomeTabella+".id_servizio_applicativo="+CostantiDB.SERVIZI_APPLICATIVI+".id");
  1165.                 sqlQueryObject.addWhereLikeCondition(CostantiDB.SERVIZI_APPLICATIVI+".nome", search, true, true);
  1166.                 sqlQueryObject.setANDLogicOperator(true);
  1167.                 queryString = sqlQueryObject.createSQLQuery();
  1168.             } else {
  1169.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1170.                 sqlQueryObject.addFromTable(nomeTabella);
  1171.                 sqlQueryObject.addSelectCountField("*", "cont");
  1172.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1173.                 queryString = sqlQueryObject.createSQLQuery();
  1174.             }
  1175.             stmt = con.prepareStatement(queryString);
  1176.             stmt.setLong(1, idPortaDelegata);
  1177.             risultato = stmt.executeQuery();
  1178.             if (risultato.next())
  1179.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1180.             risultato.close();
  1181.             stmt.close();

  1183.             // ricavo le entries
  1184.             if (limit == 0) // con limit
  1185.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1186.             if (!search.equals("")) { // con search
  1187.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1188.                 sqlQueryObject.addFromTable(nomeTabella);
  1189.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI_APPLICATIVI);
  1190.                 sqlQueryObject.addSelectField(nomeTabella,"id_servizio_applicativo");
  1191.                 sqlQueryObject.addSelectField(nomeTabella,"id_porta");
  1192.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1193.                 sqlQueryObject.addWhereCondition(nomeTabella+".id_servizio_applicativo="+CostantiDB.SERVIZI_APPLICATIVI+".id");
  1194.                 sqlQueryObject.addWhereLikeCondition(CostantiDB.SERVIZI_APPLICATIVI+".nome", search, true, true);
  1195.                 sqlQueryObject.setANDLogicOperator(true);
  1196.                 sqlQueryObject.addOrderBy("id_servizio_applicativo");
  1197.                 sqlQueryObject.setSortType(true);
  1198.                 sqlQueryObject.setLimit(limit);
  1199.                 sqlQueryObject.setOffset(offset);
  1200.                 queryString = sqlQueryObject.createSQLQuery();
  1201.             } else {
  1202.                 // senza search
  1203.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1204.                 sqlQueryObject.addFromTable(nomeTabella);
  1205.                 sqlQueryObject.addSelectField("id_servizio_applicativo");
  1206.                 sqlQueryObject.addSelectField("id_porta");
  1207.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1208.                 sqlQueryObject.addOrderBy("id_servizio_applicativo");
  1209.                 sqlQueryObject.setSortType(true);
  1210.                 sqlQueryObject.setLimit(limit);
  1211.                 sqlQueryObject.setOffset(offset);
  1212.                 queryString = sqlQueryObject.createSQLQuery();
  1213.             }
  1214.             stmt = con.prepareStatement(queryString);
  1215.             stmt.setLong(1, idPortaDelegata);
  1216.             risultato = stmt.executeQuery();

  1218.             ServizioApplicativo sa = null;

  1220.             long idServizioApplicativo = 0;
  1221.             while (risultato.next()) {
  1222.                 idServizioApplicativo = risultato.getLong("id_servizio_applicativo");

  1224.                 sa = new ServizioApplicativo();

  1226.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1227.                 sqlQueryObject.addFromTable(CostantiDB.SERVIZI_APPLICATIVI);
  1228.                 sqlQueryObject.addSelectField("*");
  1229.                 sqlQueryObject.addWhereCondition("id = ?");
  1230.                 queryString = sqlQueryObject.createSQLQuery();

  1232.                 stmt1 = con.prepareStatement(queryString);
  1233.                 stmt1.setLong(1, idServizioApplicativo);

  1235.                 rs1 = stmt1.executeQuery();

  1237.                 // recupero i dati del servizio applicativo
  1238.                 if (rs1.next()) {
  1239.                     sa.setId(idServizioApplicativo);
  1240.                     sa.setNome(rs1.getString("nome"));
  1241.                     sa.setDescrizione(rs1.getString("descrizione"));
  1242.                     sa.setIdSoggetto(rs1.getLong("id_soggetto"));
  1243.                 } else
  1244.                     throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore recuperando i dati del Servizio Applicativo.");

  1246.                 rs1.close();
  1247.                 stmt1.close();
  1248.                 lista.add(sa);

  1250.             }

  1252.             return lista;

  1254.         } catch (Exception qe) {
  1255.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  1256.         } finally {

  1258.             //Chiudo statement and resultset
  1259.             JDBCUtilities.closeResources(risultato, stmt);
  1260.             JDBCUtilities.closeResources(rs1, stmt1);
  1261.             
  1262.             this.driver.closeConnection(con);
  1263.         }
  1264.     }

  1266.     protected List<MessageSecurityFlowParameter> porteDelegateMessageSecurityRequestList(long idPortaDelegata, ISearch ricerca) throws DriverConfigurazioneException {
  1267.         String nomeMetodo = "porteDelegateMessageSecurityRequestList";
  1268.         int idLista = Liste.PORTE_DELEGATE_MESSAGE_SECURITY_REQUEST;
  1269.         int offset;
  1270.         int limit;
  1271.         String search;
  1272.         String queryString;

  1274.         limit = ricerca.getPageSize(idLista);
  1275.         offset = ricerca.getIndexIniziale(idLista);
  1276.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));


  1279.         Connection con = null;
  1280.         PreparedStatement stmt=null;
  1281.         ResultSet risultato=null;
  1282.         ArrayList<MessageSecurityFlowParameter> lista = new ArrayList<>();

  1284.         if (this.driver.atomica) {
  1285.             try {
  1286.                 con = this.driver.getConnectionFromDatasource("porteDelegateMessageSecurityRequestList");
  1287.             } catch (Exception e) {
  1288.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1290.             }

  1292.         } else
  1293.             con = this.driver.globalConnection;

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

  1297.         try {

  1299.             if (!search.equals("")) {
  1300.                 //query con search
  1301.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1302.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_MESSAGE_SECURITY_REQUEST);
  1303.                 sqlQueryObject.addSelectCountField("*", "cont");
  1304.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1305.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1306.                 sqlQueryObject.setANDLogicOperator(true);
  1307.                 queryString = sqlQueryObject.createSQLQuery();
  1308.             } else {
  1309.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1310.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_MESSAGE_SECURITY_REQUEST);
  1311.                 sqlQueryObject.addSelectCountField("*", "cont");
  1312.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1313.                 queryString = sqlQueryObject.createSQLQuery();
  1314.             }
  1315.             stmt = con.prepareStatement(queryString);
  1316.             stmt.setLong(1, idPortaDelegata);
  1317.             risultato = stmt.executeQuery();
  1318.             if (risultato.next())
  1319.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1320.             risultato.close();
  1321.             stmt.close();

  1323.             // ricavo le entries
  1324.             if (limit == 0) // con limit
  1325.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;

  1327.             if (!search.equals("")) { // con search
  1328.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1329.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_MESSAGE_SECURITY_REQUEST);
  1330.                 sqlQueryObject.addSelectField("id_porta");
  1331.                 sqlQueryObject.addSelectField("nome");
  1332.                 sqlQueryObject.addSelectField("valore");
  1333.                 sqlQueryObject.addSelectField("enc_value");
  1334.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1335.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1336.                 sqlQueryObject.setANDLogicOperator(true);
  1337.                 sqlQueryObject.addOrderBy("nome");
  1338.                 sqlQueryObject.setSortType(true);
  1339.                 sqlQueryObject.setLimit(limit);
  1340.                 sqlQueryObject.setOffset(offset);
  1341.                 queryString = sqlQueryObject.createSQLQuery();
  1342.             } else {
  1343.                 // senza search
  1344.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1345.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_MESSAGE_SECURITY_REQUEST);
  1346.                 sqlQueryObject.addSelectField("id_porta");
  1347.                 sqlQueryObject.addSelectField("nome");
  1348.                 sqlQueryObject.addSelectField("valore");
  1349.                 sqlQueryObject.addSelectField("enc_value");
  1350.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1351.                 sqlQueryObject.addOrderBy("nome");
  1352.                 sqlQueryObject.setSortType(true);
  1353.                 sqlQueryObject.setLimit(limit);
  1354.                 sqlQueryObject.setOffset(offset);
  1355.                 queryString = sqlQueryObject.createSQLQuery();
  1356.             }
  1357.             stmt = con.prepareStatement(queryString);
  1358.             stmt.setLong(1, idPortaDelegata);
  1359.             risultato = stmt.executeQuery();

  1361.             MessageSecurityFlowParameter wsreq;
  1362.             while (risultato.next()) {

  1364.                 wsreq = new MessageSecurityFlowParameter();

  1366.                 wsreq.setId(risultato.getLong("id_porta"));
  1367.                 wsreq.setNome(risultato.getString("nome"));
  1368.                 
  1369.                 String plainValue = risultato.getString("valore");
  1370.                 String encValue = risultato.getString("enc_value");
  1371.                 if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  1372.                     wsreq.setValore(encValue);
  1373.                 }
  1374.                 else {
  1375.                     wsreq.setValore(plainValue);
  1376.                 }

  1378.                 lista.add(wsreq);
  1379.             }

  1381.             return lista;

  1383.         } catch (Exception qe) {
  1384.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  1385.         } finally {

  1387.             //Chiudo statement and resultset
  1388.             JDBCUtilities.closeResources(risultato, stmt);

  1390.             this.driver.closeConnection(con);
  1391.         }
  1392.     }

  1394.     protected List<MessageSecurityFlowParameter> porteDelegateMessageSecurityResponseList(long idPortaDelegata, ISearch ricerca) throws DriverConfigurazioneException {
  1395.         String nomeMetodo = "porteDelegateMessageSecurityResponseList";
  1396.         int idLista = Liste.PORTE_DELEGATE_MESSAGE_SECURITY_RESPONSE;
  1397.         int offset;
  1398.         int limit;
  1399.         String search;
  1400.         String queryString;

  1402.         limit = ricerca.getPageSize(idLista);
  1403.         offset = ricerca.getIndexIniziale(idLista);
  1404.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));


  1407.         Connection con = null;
  1408.         PreparedStatement stmt=null;
  1409.         ResultSet risultato=null;
  1410.         ArrayList<MessageSecurityFlowParameter> lista = new ArrayList<>();

  1412.         if (this.driver.atomica) {
  1413.             try {
  1414.                 con = this.driver.getConnectionFromDatasource("porteDelegateMessageSecurityResponseList");
  1415.             } catch (Exception e) {
  1416.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1418.             }

  1420.         } else
  1421.             con = this.driver.globalConnection;

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

  1425.         try {

  1427.             if (!search.equals("")) {
  1428.                 //query con search
  1429.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1430.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_MESSAGE_SECURITY_RESPONSE);
  1431.                 sqlQueryObject.addSelectCountField("*", "cont");
  1432.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1433.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1434.                 sqlQueryObject.setANDLogicOperator(true);
  1435.                 queryString = sqlQueryObject.createSQLQuery();
  1436.             } else {
  1437.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1438.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_MESSAGE_SECURITY_RESPONSE);
  1439.                 sqlQueryObject.addSelectCountField("*", "cont");
  1440.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1441.                 queryString = sqlQueryObject.createSQLQuery();
  1442.             }
  1443.             stmt = con.prepareStatement(queryString);
  1444.             stmt.setLong(1, idPortaDelegata);
  1445.             risultato = stmt.executeQuery();
  1446.             if (risultato.next())
  1447.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1448.             risultato.close();
  1449.             stmt.close();

  1451.             // ricavo le entries
  1452.             if (limit == 0) // con limit
  1453.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;

  1455.             if (!search.equals("")) { // con search
  1456.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1457.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_MESSAGE_SECURITY_RESPONSE);
  1458.                 sqlQueryObject.addSelectField("id_porta");
  1459.                 sqlQueryObject.addSelectField("nome");
  1460.                 sqlQueryObject.addSelectField("valore");
  1461.                 sqlQueryObject.addSelectField("enc_value");
  1462.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1463.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1464.                 sqlQueryObject.setANDLogicOperator(true);
  1465.                 sqlQueryObject.addOrderBy("nome");
  1466.                 sqlQueryObject.setSortType(true);
  1467.                 sqlQueryObject.setLimit(limit);
  1468.                 sqlQueryObject.setOffset(offset);
  1469.                 queryString = sqlQueryObject.createSQLQuery();
  1470.             } else {
  1471.                 // senza search
  1472.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1473.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_MESSAGE_SECURITY_RESPONSE);
  1474.                 sqlQueryObject.addSelectField("id_porta");
  1475.                 sqlQueryObject.addSelectField("nome");
  1476.                 sqlQueryObject.addSelectField("valore");
  1477.                 sqlQueryObject.addSelectField("enc_value");
  1478.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1479.                 sqlQueryObject.addOrderBy("nome");
  1480.                 sqlQueryObject.setSortType(true);
  1481.                 sqlQueryObject.setLimit(limit);
  1482.                 sqlQueryObject.setOffset(offset);
  1483.                 queryString = sqlQueryObject.createSQLQuery();
  1484.             }
  1485.             stmt = con.prepareStatement(queryString);
  1486.             stmt.setLong(1, idPortaDelegata);
  1487.             risultato = stmt.executeQuery();

  1489.             MessageSecurityFlowParameter wsresp;
  1490.             while (risultato.next()) {

  1492.                 wsresp = new MessageSecurityFlowParameter();

  1494.                 wsresp.setId(risultato.getLong("id_porta"));
  1495.                 wsresp.setNome(risultato.getString("nome"));
  1496.                 
  1497.                 String plainValue = risultato.getString("valore");
  1498.                 String encValue = risultato.getString("enc_value");
  1499.                 if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  1500.                     wsresp.setValore(encValue);
  1501.                 }
  1502.                 else {
  1503.                     wsresp.setValore(plainValue);
  1504.                 }

  1506.                 lista.add(wsresp);
  1507.             }

  1509.             return lista;

  1511.         } catch (Exception qe) {
  1512.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  1513.         } finally {

  1515.             //Chiudo statement and resultset
  1516.             JDBCUtilities.closeResources(risultato, stmt);

  1518.             this.driver.closeConnection(con);
  1519.         }
  1520.     }

  1522.     protected List<CorrelazioneApplicativaElemento> porteDelegateCorrelazioneApplicativaList(long idPortaDelegata, ISearch ricerca) throws DriverConfigurazioneException {
  1523.         String nomeMetodo = "porteDelegateCorrelazioneApplicativaList";
  1524.         int idLista = Liste.PORTE_DELEGATE_CORRELAZIONE_APPLICATIVA;
  1525.         int offset;
  1526.         int limit;
  1527.         String search;
  1528.         String queryString;

  1530.         limit = ricerca.getPageSize(idLista);
  1531.         offset = ricerca.getIndexIniziale(idLista);
  1532.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));


  1535.         Connection con = null;
  1536.         PreparedStatement stmt=null;
  1537.         ResultSet risultato=null;
  1538.         ArrayList<CorrelazioneApplicativaElemento> lista = new ArrayList<>();

  1540.         if (this.driver.atomica) {
  1541.             try {
  1542.                 con = this.driver.getConnectionFromDatasource("porteDelegateCorrelazioneApplicativaList");
  1543.             } catch (Exception e) {
  1544.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1546.             }

  1548.         } else
  1549.             con = this.driver.globalConnection;

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

  1553.         try {

  1555.             if (!search.equals("")) {
  1556.                 //query con search
  1557.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1558.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_CORRELAZIONE);
  1559.                 sqlQueryObject.addSelectCountField("*", "cont");
  1560.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1561.                 sqlQueryObject.addWhereLikeCondition("nome_elemento", search, true, true);
  1562.                 sqlQueryObject.setANDLogicOperator(true);
  1563.                 queryString = sqlQueryObject.createSQLQuery();
  1564.             } else {
  1565.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1566.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_CORRELAZIONE);
  1567.                 sqlQueryObject.addSelectCountField("*", "cont");
  1568.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1569.                 queryString = sqlQueryObject.createSQLQuery();
  1570.             }
  1571.             stmt = con.prepareStatement(queryString);
  1572.             stmt.setLong(1, idPortaDelegata);
  1573.             risultato = stmt.executeQuery();
  1574.             if (risultato.next())
  1575.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1576.             risultato.close();
  1577.             stmt.close();

  1579.             // ricavo le entries
  1580.             if (limit == 0) // con limit
  1581.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1582.             if (!search.equals("")) { // con search
  1583.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1584.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_CORRELAZIONE);
  1585.                 sqlQueryObject.addSelectField("id");
  1586.                 sqlQueryObject.addSelectField("nome_elemento");
  1587.                 sqlQueryObject.addSelectField("mode_correlazione");
  1588.                 sqlQueryObject.addSelectField("id_porta");
  1589.                 sqlQueryObject.addSelectField("identificazione_fallita");
  1590.                 sqlQueryObject.addSelectField("riuso_id");
  1591.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1592.                 sqlQueryObject.addWhereLikeCondition("nome_elemento", search, true, true);
  1593.                 sqlQueryObject.setANDLogicOperator(true);
  1594.                 sqlQueryObject.addOrderBy("id");
  1595.                 sqlQueryObject.setSortType(true);
  1596.                 sqlQueryObject.setLimit(limit);
  1597.                 sqlQueryObject.setOffset(offset);
  1598.                 queryString = sqlQueryObject.createSQLQuery();
  1599.             } else {
  1600.                 // senza search
  1601.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1602.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_CORRELAZIONE);
  1603.                 sqlQueryObject.addSelectField("id");
  1604.                 sqlQueryObject.addSelectField("nome_elemento");
  1605.                 sqlQueryObject.addSelectField("mode_correlazione");
  1606.                 sqlQueryObject.addSelectField("id_porta");
  1607.                 sqlQueryObject.addSelectField("identificazione_fallita");
  1608.                 sqlQueryObject.addSelectField("riuso_id");
  1609.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1610.                 sqlQueryObject.addOrderBy("id");
  1611.                 sqlQueryObject.setSortType(true);
  1612.                 sqlQueryObject.setLimit(limit);
  1613.                 sqlQueryObject.setOffset(offset);
  1614.                 queryString = sqlQueryObject.createSQLQuery();
  1615.             }
  1616.             stmt = con.prepareStatement(queryString);
  1617.             stmt.setLong(1, idPortaDelegata);
  1618.             risultato = stmt.executeQuery();

  1620.             CorrelazioneApplicativaElemento cae = null;

  1622.             //long idServizioApplicativo = 0;
  1623.             while (risultato.next()) {
  1624.                 cae = new CorrelazioneApplicativaElemento();
  1625.                 cae.setId(risultato.getLong("id"));
  1626.                 cae.setNome(risultato.getString("nome_elemento"));
  1627.                 cae.setIdentificazione(DriverConfigurazioneDBLib.getEnumCorrelazioneApplicativaRichiestaIdentificazione(risultato.getString("mode_correlazione")));
  1628.                 cae.setIdentificazioneFallita(DriverConfigurazioneDBLib.getEnumCorrelazioneApplicativaGestioneIdentificazioneFallita(risultato.getString("identificazione_fallita")));
  1629.                 cae.setRiusoIdentificativo(DriverConfigurazioneDBLib.getEnumStatoFunzionalita(risultato.getString("riuso_id")));
  1630.                 lista.add(cae);
  1631.             }

  1633.             return lista;

  1635.         } catch (Exception qe) {
  1636.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  1637.         } finally {

  1639.             //Chiudo statement and resultset
  1640.             JDBCUtilities.closeResources(risultato, stmt);

  1642.             this.driver.closeConnection(con);
  1643.         }
  1644.     }

  1646.     protected List<CorrelazioneApplicativaRispostaElemento> porteDelegateCorrelazioneApplicativaRispostaList(long idPortaDelegata, ISearch ricerca) throws DriverConfigurazioneException {
  1647.         String nomeMetodo = "porteDelegateCorrelazioneApplicativaRispostaList";
  1648.         int idLista = Liste.PORTE_DELEGATE_CORRELAZIONE_APPLICATIVA_RISPOSTA;
  1649.         int offset;
  1650.         int limit;
  1651.         String search;
  1652.         String queryString;

  1654.         limit = ricerca.getPageSize(idLista);
  1655.         offset = ricerca.getIndexIniziale(idLista);
  1656.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));


  1659.         Connection con = null;
  1660.         PreparedStatement stmt=null;
  1661.         ResultSet risultato=null;
  1662.         ArrayList<CorrelazioneApplicativaRispostaElemento> lista = new ArrayList<>();

  1664.         if (this.driver.atomica) {
  1665.             try {
  1666.                 con = this.driver.getConnectionFromDatasource("porteDelegateCorrelazioneApplicativaRispostaList");
  1667.             } catch (Exception e) {
  1668.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1670.             }

  1672.         } else
  1673.             con = this.driver.globalConnection;

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

  1677.         try {

  1679.             if (!search.equals("")) {
  1680.                 //query con search
  1681.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1682.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_CORRELAZIONE_RISPOSTA);
  1683.                 sqlQueryObject.addSelectCountField("*", "cont");
  1684.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1685.                 sqlQueryObject.addWhereLikeCondition("nome_elemento", search, true, true);
  1686.                 sqlQueryObject.setANDLogicOperator(true);
  1687.                 queryString = sqlQueryObject.createSQLQuery();
  1688.             } else {
  1689.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1690.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_CORRELAZIONE_RISPOSTA);
  1691.                 sqlQueryObject.addSelectCountField("*", "cont");
  1692.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1693.                 queryString = sqlQueryObject.createSQLQuery();
  1694.             }
  1695.             stmt = con.prepareStatement(queryString);
  1696.             stmt.setLong(1, idPortaDelegata);
  1697.             risultato = stmt.executeQuery();
  1698.             if (risultato.next())
  1699.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1700.             risultato.close();
  1701.             stmt.close();

  1703.             // ricavo le entries
  1704.             if (limit == 0) // con limit
  1705.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1706.             if (!search.equals("")) { // con search
  1707.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1708.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_CORRELAZIONE_RISPOSTA);
  1709.                 sqlQueryObject.addSelectField("id");
  1710.                 sqlQueryObject.addSelectField("nome_elemento");
  1711.                 sqlQueryObject.addSelectField("mode_correlazione");
  1712.                 sqlQueryObject.addSelectField("id_porta");
  1713.                 sqlQueryObject.addSelectField("identificazione_fallita");
  1714.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1715.                 sqlQueryObject.addWhereLikeCondition("nome_elemento", search, true, true);
  1716.                 sqlQueryObject.setANDLogicOperator(true);
  1717.                 sqlQueryObject.addOrderBy("id");
  1718.                 sqlQueryObject.setSortType(true);
  1719.                 sqlQueryObject.setLimit(limit);
  1720.                 sqlQueryObject.setOffset(offset);
  1721.                 queryString = sqlQueryObject.createSQLQuery();
  1722.             } else {
  1723.                 // senza search
  1724.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1725.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_CORRELAZIONE_RISPOSTA);
  1726.                 sqlQueryObject.addSelectField("id");
  1727.                 sqlQueryObject.addSelectField("nome_elemento");
  1728.                 sqlQueryObject.addSelectField("mode_correlazione");
  1729.                 sqlQueryObject.addSelectField("id_porta");
  1730.                 sqlQueryObject.addSelectField("identificazione_fallita");
  1731.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  1732.                 sqlQueryObject.addOrderBy("id");
  1733.                 sqlQueryObject.setSortType(true);
  1734.                 sqlQueryObject.setLimit(limit);
  1735.                 sqlQueryObject.setOffset(offset);
  1736.                 queryString = sqlQueryObject.createSQLQuery();
  1737.             }
  1738.             stmt = con.prepareStatement(queryString);
  1739.             stmt.setLong(1, idPortaDelegata);
  1740.             risultato = stmt.executeQuery();

  1742.             CorrelazioneApplicativaRispostaElemento cae = null;

  1744.             //long idServizioApplicativo = 0;
  1745.             while (risultato.next()) {
  1746.                 cae = new CorrelazioneApplicativaRispostaElemento();
  1747.                 cae.setId(risultato.getLong("id"));
  1748.                 cae.setNome(risultato.getString("nome_elemento"));
  1749.                 cae.setIdentificazione(DriverConfigurazioneDBLib.getEnumCorrelazioneApplicativaRispostaIdentificazione(risultato.getString("mode_correlazione")));
  1750.                 cae.setIdentificazioneFallita(DriverConfigurazioneDBLib.getEnumCorrelazioneApplicativaGestioneIdentificazioneFallita(risultato.getString("identificazione_fallita")));
  1751.                 lista.add(cae);
  1752.             }

  1754.             return lista;

  1756.         } catch (Exception qe) {
  1757.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  1758.         } finally {

  1760.             //Chiudo statement and resultset
  1761.             JDBCUtilities.closeResources(risultato, stmt);

  1763.             this.driver.closeConnection(con);
  1764.         }
  1765.     }
  1766.     
  1767.     protected List<PortaDelegata> serviziFruitoriPorteDelegateList(long idSoggetto, String tipoServizio,String nomeServizio,Long idServizio, 
  1768.             String tipoSoggettoErogatore, String nomeSoggettoErogatore, Long idSoggettoErogatore, ISearch ricerca) throws DriverConfigurazioneException {
  1769.         String nomeMetodo = "serviziFruitoriPorteDelegateList";
  1770.         int idLista = Liste.SERVIZI_FRUITORI_PORTE_DELEGATE;
  1771.         int offset;
  1772.         int limit;
  1773.         String search;
  1774.         String queryString;

  1776.         limit = ricerca.getPageSize(idLista);
  1777.         offset = ricerca.getIndexIniziale(idLista);
  1778.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  1779.         ricerca.getSearchString(idLista);

  1781.         Connection con = null;
  1782.         PreparedStatement stmt = null;
  1783.         ResultSet risultato = null;

  1785.         ArrayList<PortaDelegata> lista = new ArrayList<PortaDelegata>();

  1787.         if (this.driver.atomica) {
  1788.             try {
  1789.                 con = this.driver.getConnectionFromDatasource(nomeMetodo);

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

  1794.             }

  1796.         } else
  1797.             con = this.driver.globalConnection;

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

  1801.         try {

  1803.             if (!search.equals("")) {
  1804.                 //query con search
  1805.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1806.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  1807.                 sqlQueryObject.addSelectCountField("*", "cont");
  1808.                 sqlQueryObject.addWhereCondition("id_soggetto = ?");
  1809.                 if(idSoggettoErogatore!=null && idSoggettoErogatore > 0){
  1810.                     sqlQueryObject.addWhereCondition(false, "id_soggetto_erogatore=?" , "tipo_soggetto_erogatore=? AND nome_soggetto_erogatore=?");
  1811.                 }
  1812.                 else{
  1813.                     sqlQueryObject.addWhereCondition("tipo_soggetto_erogatore=?");
  1814.                     sqlQueryObject.addWhereCondition("nome_soggetto_erogatore=?");
  1815.                 }
  1816.                 if(idServizio!=null && idServizio > 0){
  1817.                     sqlQueryObject.addWhereCondition(false, "id_servizio=?" , "tipo_servizio=? AND nome_servizio=?");
  1818.                 }
  1819.                 else{
  1820.                     sqlQueryObject.addWhereCondition("tipo_servizio=?");
  1821.                     sqlQueryObject.addWhereCondition("nome_servizio=?");
  1822.                 }
  1823.                 sqlQueryObject.addWhereLikeCondition("nome_porta", search, true, true);
  1824.                 sqlQueryObject.setANDLogicOperator(true);
  1825.                 queryString = sqlQueryObject.createSQLQuery();
  1826.             } else {
  1827.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1828.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  1829.                 sqlQueryObject.addSelectCountField("*", "cont");
  1830.                 sqlQueryObject.addWhereCondition("id_soggetto = ?");
  1831.                 if(idSoggettoErogatore!=null && idSoggettoErogatore > 0){
  1832.                     sqlQueryObject.addWhereCondition(false, "id_soggetto_erogatore=?" , "tipo_soggetto_erogatore=? AND nome_soggetto_erogatore=?");
  1833.                 }
  1834.                 else{
  1835.                     sqlQueryObject.addWhereCondition("tipo_soggetto_erogatore=?");
  1836.                     sqlQueryObject.addWhereCondition("nome_soggetto_erogatore=?");
  1837.                 }
  1838.                 if(idServizio!=null && idServizio > 0){
  1839.                     sqlQueryObject.addWhereCondition(false, "id_servizio=?" , "tipo_servizio=? AND nome_servizio=?");
  1840.                 }
  1841.                 else{
  1842.                     sqlQueryObject.addWhereCondition("tipo_servizio=?");
  1843.                     sqlQueryObject.addWhereCondition("nome_servizio=?");
  1844.                 }
  1845.                 sqlQueryObject.setANDLogicOperator(true);
  1846.                 queryString = sqlQueryObject.createSQLQuery();
  1847.             }
  1848.             stmt = con.prepareStatement(queryString);

  1850.             int index = 1;
  1851.             
  1852.             stmt.setLong(index++, idSoggetto);
  1853.             
  1854.             if(idSoggettoErogatore!=null && idSoggettoErogatore > 0){
  1855.                 stmt.setLong(index++, idSoggettoErogatore);
  1856.             }
  1857.             stmt.setString(index++, tipoSoggettoErogatore);
  1858.             stmt.setString(index++, nomeSoggettoErogatore);
  1859.             
  1860.             if(idServizio!=null && idServizio > 0){
  1861.                 stmt.setLong(index++, idServizio);
  1862.             }
  1863.             stmt.setString(index++, tipoServizio);
  1864.             stmt.setString(index++, nomeServizio);

  1866.             risultato = stmt.executeQuery();
  1867.             if (risultato.next())
  1868.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  1869.             risultato.close();
  1870.             stmt.close();

  1872.             // ricavo le entries
  1873.             if (limit == 0) // con limit
  1874.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1875.             if (!search.equals("")) { // con search
  1876.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1877.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  1878.                 sqlQueryObject.addSelectField("id");
  1879.                 sqlQueryObject.addSelectField("nome_porta");
  1880.                 sqlQueryObject.addWhereCondition("id_soggetto = ?");
  1881.                 if(idSoggettoErogatore!=null && idSoggettoErogatore > 0){
  1882.                     sqlQueryObject.addWhereCondition(false, "id_soggetto_erogatore=?" , "tipo_soggetto_erogatore=? AND nome_soggetto_erogatore=?");
  1883.                 }
  1884.                 else{
  1885.                     sqlQueryObject.addWhereCondition("tipo_soggetto_erogatore=?");
  1886.                     sqlQueryObject.addWhereCondition("nome_soggetto_erogatore=?");
  1887.                 }
  1888.                 if(idServizio!=null && idServizio > 0){
  1889.                     sqlQueryObject.addWhereCondition(false, "id_servizio=?" , "tipo_servizio=? AND nome_servizio=?");
  1890.                 }
  1891.                 else{
  1892.                     sqlQueryObject.addWhereCondition("tipo_servizio=?");
  1893.                     sqlQueryObject.addWhereCondition("nome_servizio=?");
  1894.                 }
  1895.                 sqlQueryObject.addWhereLikeCondition("nome_porta", search, true, true);
  1896.                 sqlQueryObject.setSelectDistinct(true);
  1897.                 sqlQueryObject.setANDLogicOperator(true);
  1898.                 sqlQueryObject.addOrderBy("nome_porta");
  1899.                 sqlQueryObject.setSortType(true);
  1900.                 sqlQueryObject.setLimit(limit);
  1901.                 sqlQueryObject.setOffset(offset);
  1902.                 queryString = sqlQueryObject.createSQLQuery();
  1903.             } else {
  1904.                 // senza search
  1905.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1906.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  1907.                 sqlQueryObject.addSelectField("id");
  1908.                 sqlQueryObject.addSelectField("nome_porta");
  1909.                 sqlQueryObject.addWhereCondition("id_soggetto = ?");
  1910.                 if(idSoggettoErogatore!=null && idSoggettoErogatore > 0){
  1911.                     sqlQueryObject.addWhereCondition(false, "id_soggetto_erogatore=?" , "tipo_soggetto_erogatore=? AND nome_soggetto_erogatore=?");
  1912.                 }
  1913.                 else{
  1914.                     sqlQueryObject.addWhereCondition("tipo_soggetto_erogatore=?");
  1915.                     sqlQueryObject.addWhereCondition("nome_soggetto_erogatore=?");
  1916.                 }
  1917.                 if(idServizio!=null && idServizio > 0){
  1918.                     sqlQueryObject.addWhereCondition(false, "id_servizio=?" , "tipo_servizio=? AND nome_servizio=?");
  1919.                 }
  1920.                 else{
  1921.                     sqlQueryObject.addWhereCondition("tipo_servizio=?");
  1922.                     sqlQueryObject.addWhereCondition("nome_servizio=?");
  1923.                 }
  1924.                 sqlQueryObject.setSelectDistinct(true);
  1925.                 sqlQueryObject.setANDLogicOperator(true);
  1926.                 sqlQueryObject.addOrderBy("nome_porta");
  1927.                 sqlQueryObject.setSortType(true);
  1928.                 sqlQueryObject.setLimit(limit);
  1929.                 sqlQueryObject.setOffset(offset);
  1930.                 queryString = sqlQueryObject.createSQLQuery();
  1931.             }
  1932.             stmt = con.prepareStatement(queryString);

  1934.             index = 1;
  1935.             
  1936.             stmt.setLong(index++, idSoggetto);
  1937.             
  1938.             if(idSoggettoErogatore!=null && idSoggettoErogatore > 0){
  1939.                 stmt.setLong(index++, idSoggettoErogatore);
  1940.             }
  1941.             stmt.setString(index++, tipoSoggettoErogatore);
  1942.             stmt.setString(index++, nomeSoggettoErogatore);
  1943.             
  1944.             if(idServizio!=null && idServizio > 0){
  1945.                 stmt.setLong(index++, idServizio);
  1946.             }
  1947.             stmt.setString(index++, tipoServizio);
  1948.             stmt.setString(index++, nomeServizio);

  1950.             risultato = stmt.executeQuery();

  1952.             PortaDelegata pd = null;

  1954.             while (risultato.next()) {

  1956.                 pd = this.porteDelegateDriver.getPortaDelegata(risultato.getLong("id"));

  1958.                 lista.add(pd);

  1960.             }

  1962.             return lista;

  1964.         } catch (Exception se) {

  1966.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1967.         } finally {
  1968.             //Chiudo statement and resultset
  1969.             JDBCUtilities.closeResources(risultato, stmt);
  1970.             this.driver.closeConnection(con);
  1971.         }
  1972.     }
  1973.     
  1974.     protected List<PortaDelegata> getPorteDelegateByFruitore(IDSoggetto fruitore,ISearch filters) throws DriverConfigurazioneException{
  1975.         return getPorteDelegate(null, fruitore,filters);
  1976.     }

  1978.     /**
  1979.      * Recupera tutte le porte delegate del soggetto fruitore, relative al servizio idServizio (se diverso da null), erogato dal soggetto erogatore del servizio.
  1980.      * @param idSE L'id del servizio, puo essere null in tal caso si comporta come il metodo getPorteDelegateByFruitore
  1981.      * @return List<PortaDelegata>
  1982.      * @throws DriverConfigurazioneException
  1983.      */
  1984.     protected List<PortaDelegata> getPorteDelegate(IDServizio idSE,IDSoggetto fruitore,ISearch filters) throws DriverConfigurazioneException{
  1985.         Connection con = null;
  1986.         PreparedStatement stmt = null;
  1987.         ResultSet risultato = null;
  1988.         String queryString = "";
  1989.         int idLista = Liste.PORTE_DELEGATE;


  1992.         int limit = filters.getPageSize(idLista);
  1993.         int offset = filters.getIndexIniziale(idLista);
  1994.         String search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(filters.getSearchString(idLista)) ? "" : filters.getSearchString(idLista));

  1996.         if (this.driver.atomica) {
  1997.             try {
  1998.                 con = this.driver.getConnectionFromDatasource("getPorteDelegate(idServizio,fruitore)");
  1999.             } catch (Exception e) {
  2000.                 throw new DriverConfigurazioneException(
  2001.                         "[DriverConfigurazioneDB::getPorteDelegate] Exception accedendo al datasource :"
  2002.                                 + e.getMessage(),e);

  2004.             }

  2006.         } else
  2007.             con = this.driver.globalConnection;
  2008.         ArrayList<PortaDelegata> lista = null;
  2009.         try {

  2011.             IDSoggetto erogatore = null;
  2012.             String nomeErogatore = null;
  2013.             String tipoErogatore = null;
  2014.             String tipoServizio = null;
  2015.             String nomeServizio = null;
  2016.             Integer versioneServizio = null;

  2018.             if(idSE!=null){
  2019.                 erogatore = idSE.getSoggettoErogatore();
  2020.                 nomeErogatore = erogatore.getNome();
  2021.                 tipoErogatore = erogatore.getTipo();
  2022.                 tipoServizio = idSE.getTipo();
  2023.                 nomeServizio = idSE.getNome();
  2024.                 versioneServizio = idSE.getVersione();
  2025.             }

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

  2029.             long idSoggettoErogatore =-1;
  2030.             long idServizio = -1;
  2031.             if(idSE!=null){
  2032.                 idSoggettoErogatore = DBUtils.getIdSoggetto(erogatore.getNome(), erogatore.getTipo(), con, this.driver.tipoDB);
  2033.                 idServizio = DBUtils.getIdServizio(nomeServizio, tipoServizio, versioneServizio, erogatore.getNome(), erogatore.getTipo(), con, this.driver.tipoDB);
  2034.             }


  2037.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2038.             sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  2039.             sqlQueryObject.addSelectCountField("*", "cont");
  2040.             sqlQueryObject.setANDLogicOperator(true);
  2041.             if (!search.equals("")) {
  2042.                 //query con search
  2043.                 sqlQueryObject.addWhereLikeCondition("nome_porta", search, true, true);
  2044.             } 
  2045.             queryString = sqlQueryObject.createSQLQuery();

  2047.             stmt = con.prepareStatement(queryString);
  2048.             risultato = stmt.executeQuery();
  2049.             if (risultato.next())
  2050.                 filters.setNumEntries(idLista,risultato.getInt(1));
  2051.             risultato.close();
  2052.             stmt.close();

  2054.             // ricavo le entries
  2055.             if (limit == 0) // con limit
  2056.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;


  2059.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2060.             sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE);
  2061.             sqlQueryObject.addSelectField("id");
  2062.             sqlQueryObject.addSelectField("nome_porta");
  2063.             sqlQueryObject.addWhereCondition("id_soggetto=?");
  2064.             sqlQueryObject.setANDLogicOperator(true);

  2066.             if(idSE!=null){
  2067.                 sqlQueryObject.addWhereCondition(false,"id_servizio=?","tipo_servizio=? AND nome_servizio=?");
  2068.                 sqlQueryObject.addWhereCondition(false,"id_soggetto_erogatore=?","nome_soggetto_erogatore=? AND tipo_soggetto_erogatore=?");
  2069.             }

  2071.             if (!search.equals("")) { 
  2072.                 // con search
  2073.                 sqlQueryObject.addWhereLikeCondition("nome_porta", search, true, true);             
  2074.             }
  2075.             //limit and order by
  2076.             sqlQueryObject.addOrderBy("nome_porta");
  2077.             sqlQueryObject.setSortType(true);
  2078.             sqlQueryObject.setLimit(limit);
  2079.             sqlQueryObject.setOffset(offset);
  2080.             queryString = sqlQueryObject.createSQLQuery();

  2082.             stmt = con.prepareStatement(queryString);

  2084.             stmt.setLong(1, idSoggettoFruitore);
  2085.             if(idSE!=null){
  2086.                 stmt.setLong(2, idServizio);
  2087.                 stmt.setString(3, tipoServizio);
  2088.                 stmt.setString(4, nomeServizio);
  2089.                 stmt.setLong(5, idSoggettoErogatore);
  2090.                 stmt.setString(6, nomeErogatore);
  2091.                 stmt.setString(7, tipoErogatore);
  2092.             }

  2094.             risultato = stmt.executeQuery();
  2095.             lista=new ArrayList<PortaDelegata>();
  2096.             while(risultato.next()){
  2097.                 long id=risultato.getLong("id");
  2098.                 PortaDelegata pd = this.porteDelegateDriver.getPortaDelegata(id);
  2099.                 lista.add(pd);
  2100.             }

  2102.             return lista;
  2103.         } catch (Exception qe) {
  2104.             throw new DriverConfigurazioneException(qe);
  2105.         } finally {

  2107.             JDBCUtilities.closeResources(risultato, stmt);
  2108.             
  2109.             this.driver.closeConnection(con);

  2111.         }

  2113.     }
  2114.     
  2115.     protected List<MtomProcessorFlowParameter> porteDelegateMTOMRequestList(long idPortaDelegata, ISearch ricerca) throws DriverConfigurazioneException {
  2116.         String nomeMetodo = "porteDelegateMTOMRequestList";
  2117.         int idLista = Liste.PORTE_DELEGATE_MTOM_REQUEST;
  2118.         int offset;
  2119.         int limit;
  2120.         String search;
  2121.         String queryString;

  2123.         limit = ricerca.getPageSize(idLista);
  2124.         offset = ricerca.getIndexIniziale(idLista);
  2125.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));


  2128.         Connection con = null;
  2129.         PreparedStatement stmt=null;
  2130.         ResultSet risultato=null;
  2131.         ArrayList<MtomProcessorFlowParameter> lista = new ArrayList<>();

  2133.         if (this.driver.atomica) {
  2134.             try {
  2135.                 con = this.driver.getConnectionFromDatasource(nomeMetodo);
  2136.             } catch (Exception e) {
  2137.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  2139.             }

  2141.         } else
  2142.             con = this.driver.globalConnection;

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

  2146.         try {

  2148.             if (!search.equals("")) {
  2149.                 //query con search
  2150.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2151.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_MTOM_REQUEST);
  2152.                 sqlQueryObject.addSelectCountField("*", "cont");
  2153.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  2154.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  2155.                 sqlQueryObject.setANDLogicOperator(true);
  2156.                 queryString = sqlQueryObject.createSQLQuery();
  2157.             } else {
  2158.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2159.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_MTOM_REQUEST);
  2160.                 sqlQueryObject.addSelectCountField("*", "cont");
  2161.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  2162.                 queryString = sqlQueryObject.createSQLQuery();
  2163.             }
  2164.             stmt = con.prepareStatement(queryString);
  2165.             stmt.setLong(1, idPortaDelegata);
  2166.             risultato = stmt.executeQuery();
  2167.             if (risultato.next())
  2168.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  2169.             risultato.close();
  2170.             stmt.close();

  2172.             // ricavo le entries
  2173.             if (limit == 0) // con limit
  2174.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;

  2176.             if (!search.equals("")) { // con search
  2177.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2178.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_MTOM_REQUEST);
  2179.                 sqlQueryObject.addSelectField("id_porta");
  2180.                 sqlQueryObject.addSelectField("nome");
  2181.                 sqlQueryObject.addSelectField("pattern");
  2182.                 sqlQueryObject.addSelectField("content_type");
  2183.                 sqlQueryObject.addSelectField("required");
  2184.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  2185.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  2186.                 sqlQueryObject.setANDLogicOperator(true);
  2187.                 sqlQueryObject.addOrderBy("nome");
  2188.                 sqlQueryObject.setSortType(true);
  2189.                 sqlQueryObject.setLimit(limit);
  2190.                 sqlQueryObject.setOffset(offset);
  2191.                 queryString = sqlQueryObject.createSQLQuery();
  2192.             } else {
  2193.                 // senza search
  2194.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  2195.                 sqlQueryObject.addFromTable(CostantiDB.PORTE_DELEGATE_MTOM_REQUEST);
  2196.                 sqlQueryObject.addSelectField("id_porta");
  2197.                 sqlQueryObject.addSelectField("nome");
  2198.                 sqlQueryObject.addSelectField("pattern");
  2199.                 sqlQueryObject.addSelectField("content_type");
  2200.                 sqlQueryObject.addSelectField("required");
  2201.                 sqlQueryObject.addWhereCondition("id_porta = ?");
  2202.                 sqlQueryObject.addOrderBy("nome");
  2203.                 sqlQueryObject.setSortType(true);
  2204.                 sqlQueryObject.setLimit(limit);
  2205.                 sqlQueryObject.setOffset(offset);
  2206.                 queryString = sqlQueryObject.createSQLQuery();
  2207.             }
  2208.             stmt = con.prepareStatement(queryString);
  2209.             stmt.setLong(1, idPortaDelegata);
  2210.             risultato = stmt.executeQuery();

  2212.             MtomProcessorFlowParameter reqPar;
  2213.             while (risultato.next()) {

  2215.                 reqPar = new MtomProcessorFlowParameter();
  2216.                 
  2217.                 reqPar.setId(risultato.getLong("id_porta"));
  2218.                 reqPar.setNome(risultato.getString("nome"));
  2219.                 reqPar.setPattern(risultato.getString("pattern"));
  2220.                 reqPar.setContentType(risultato.getString("content_type"));
  2221.                 int required = risultato.getInt("required");
  2222.                 boolean isrequired = false;
  2223.                 if (required == CostantiDB.TRUE)
  2224.                     isrequired = true;
  2225.                 reqPar.setRequired(isrequired);

  2227.                 

  2229.                 lista.add(reqPar);
  2230.             }

  2232.             return lista;

  2234.         } catch (Exception qe) {
  2235.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  2236.         } finally {

  2238.             //Chiudo statement and resultset
  2239.             JDBCUtilities.closeResources(risultato, stmt);

  2241.             this.driver.closeConnection(con);
  2242.         }
  2243.     }

  2245.     protected List<MtomProcessorFlowParameter> porteDelegateMTOMResponseList(long idPortaDelegata, ISearch ricerca) throws DriverConfigurazioneException {
  2246.         String nomeMetodo = "porteDelegateMTOMResponseList";
  2247.         int idLista = Liste.PORTE_DELEGATE_MTOM_RESPONSE;
  2248.         int offset;
  2249.         int limit;
  2250.         String search;
  2251.         String queryString;

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


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

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

  2269.             }

  2271.         } else
  2272.             con = this.driver.globalConnection;

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

  2276.         try {

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

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

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

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

  2357.                 

  2359.                 lista.add(resPar);
  2360.             }

  2362.             return lista;

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

  2368.             //Chiudo statement and resultset
  2369.             JDBCUtilities.closeResources(risultato, stmt);

  2371.             this.driver.closeConnection(con);
  2372.         }
  2373.     }
  2374. }
Created with JaCoCo 0.8.8.202204050719