DriverConfigurazioneDBSoggettiSearch.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.openspcoop2.core.commons.DBUtils;
  29. import org.openspcoop2.core.commons.Filtri;
  30. import org.openspcoop2.core.commons.ISearch;
  31. import org.openspcoop2.core.commons.Liste;
  32. import org.openspcoop2.core.commons.SearchUtils;
  33. import org.openspcoop2.core.config.Soggetto;
  34. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  35. import org.openspcoop2.core.constants.CostantiDB;
  36. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  37. import org.openspcoop2.utils.sql.ISQLQueryObject;
  38. import org.openspcoop2.utils.sql.SQLObjectFactory;

  40. /**
  41.  * DriverConfigurazioneDB_soggettiSearchDriver
  42.  * 
  43.  * 
  44.  * @author Sandra Giangrandi (sandra@link.it)
  45.  * @author Stefano Corallo (corallo@link.it)
  46.  * @author $Author$
  47.  * @version $Rev$, $Date$
  48.  */
  49. public class DriverConfigurazioneDBSoggettiSearch {

  51.     private DriverConfigurazioneDB driver = null;
  52.     
  53.     protected DriverConfigurazioneDBSoggettiSearch(DriverConfigurazioneDB driver) {
  54.         this.driver = driver;
  55.     }
  56.     
  57.     private String getPrefixError(String nomeMetodo) {
  58.         return "[DriverConfigurazioneDB::" + nomeMetodo + "] "; 
  59.     }
  60.     
  61.     protected List<Soggetto> soggettiList(String superuser, ISearch ricerca) throws DriverConfigurazioneException {
  62.         String nomeMetodo = "soggettiList";
  63.         int idLista = Liste.SOGGETTI;
  64.         int offset;
  65.         int limit;
  66.         String search;
  67.         String queryString;

  69.         limit = ricerca.getPageSize(idLista);
  70.         offset = ricerca.getIndexIniziale(idLista);
  71.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));

  73.         String filterProtocollo = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_PROTOCOLLO);
  74.         String filterProtocolli = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_PROTOCOLLI);
  75.         List<String> tipoSoggettiProtocollo = null;
  76.         try {
  77.             tipoSoggettiProtocollo = Filtri.convertToTipiSoggetti(filterProtocollo, filterProtocolli);
  78.         }catch(Exception e) {
  79.             throw new DriverConfigurazioneException(e.getMessage(),e);
  80.         }
  81.         
  82.         String filtroProprietaNome = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_PROPRIETA_NOME);
  83.         String filtroProprietaValore = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_PROPRIETA_VALORE);
  84.         if((filtroProprietaNome!=null && "".equals(filtroProprietaNome))) {
  85.             filtroProprietaNome=null;
  86.         }
  87.         if((filtroProprietaValore!=null && "".equals(filtroProprietaValore))) {
  88.             filtroProprietaValore=null;
  89.         }
  90.         boolean filtroProprieta = filtroProprietaNome!=null || filtroProprietaValore!=null;

  92.         this.driver.logDebug("search : " + search);
  93.         this.driver.logDebug("filterProtocollo : " + filterProtocollo);
  94.         this.driver.logDebug("filterProtocolli : " + filterProtocolli);
  95.         this.driver.logDebug("filtroProprietaNome : " + filtroProprietaNome);
  96.         this.driver.logDebug("filtroProprietaValore : " + filtroProprietaValore);
  97.         
  98.         Connection con = null;
  99.         PreparedStatement stmt=null;
  100.         ResultSet risultato=null;
  101.         ArrayList<Soggetto> lista = new ArrayList<>();

  103.         if (this.driver.atomica) {
  104.             try {
  105.                 con = this.driver.getConnectionFromDatasource("soggettiList");
  106.             } catch (Exception e) {
  107.                 throw new DriverConfigurazioneException(getPrefixError(nomeMetodo)+"Exception accedendo al datasource :" + e.getMessage(),e);

  109.             }

  111.         } else
  112.             con = this.driver.globalConnection;

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

  116.         try {

  118.             if (!search.equals("")) {
  119.                 //query con search
  120.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  121.                 sqlQueryObject.addFromTable(this.driver.tabellaSoggetti);
  122.                 sqlQueryObject.addSelectCountField("*", "cont");
  123.                 if(tipoSoggettiProtocollo!=null && !tipoSoggettiProtocollo.isEmpty()) {
  124.                     sqlQueryObject.addWhereINCondition(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO, true, tipoSoggettiProtocollo.toArray(new String[1]));
  125.                 }
  126.                 if(this.driver.useSuperUser && superuser!=null && !superuser.equals(""))
  127.                     sqlQueryObject.addWhereCondition(CostantiDB.SUPERUSER_COLUMN+"= ?");
  128.                 sqlQueryObject.addWhereLikeCondition(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO, search, true, true);
  129.                 if(this.driver.useSuperUser && superuser!=null && !superuser.equals(""))
  130.                     sqlQueryObject.setANDLogicOperator(true);
  131.                 if(filtroProprieta) {
  132.                     DBUtils.setFiltriProprietaSoggetto(sqlQueryObject, this.driver.tipoDB, 
  133.                             filtroProprietaNome, filtroProprietaValore);
  134.                 }
  135.                 queryString = sqlQueryObject.createSQLQuery();
  136.             } else {
  137.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  138.                 sqlQueryObject.addFromTable(this.driver.tabellaSoggetti);
  139.                 sqlQueryObject.addSelectCountField("*", "cont");
  140.                 if(tipoSoggettiProtocollo!=null && !tipoSoggettiProtocollo.isEmpty()) {
  141.                     sqlQueryObject.addWhereINCondition(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO, true, tipoSoggettiProtocollo.toArray(new String[1]));
  142.                 }
  143.                 if(this.driver.useSuperUser && superuser!=null && !superuser.equals(""))
  144.                     sqlQueryObject.addWhereCondition(CostantiDB.SUPERUSER_COLUMN+"= ?");
  145.                 if(filtroProprieta) {
  146.                     DBUtils.setFiltriProprietaSoggetto(sqlQueryObject, this.driver.tipoDB, 
  147.                             filtroProprietaNome, filtroProprietaValore);
  148.                 }
  149.                 queryString = sqlQueryObject.createSQLQuery();
  150.             }
  151.             stmt = con.prepareStatement(queryString);
  152.             if(this.driver.useSuperUser && superuser!=null && !superuser.equals(""))
  153.                 stmt.setString(1, superuser);
  154.             risultato = stmt.executeQuery();
  155.             if (risultato.next())
  156.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  157.             risultato.close();
  158.             stmt.close();

  160.             // ricavo le entries
  161.             if (limit == 0) // con limit
  162.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  163.             if (!search.equals("")) { // con search
  164.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  165.                 sqlQueryObject.addFromTable(this.driver.tabellaSoggetti);
  166.                 sqlQueryObject.addSelectField("id");
  167.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO);
  168.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO);
  169.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_DESCRIZIONE);
  170.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_IDENTIFICATIVO_PORTA);
  171.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_ROUTER);
  172.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_DEFAULT);
  173.                 if(tipoSoggettiProtocollo!=null && !tipoSoggettiProtocollo.isEmpty()) {
  174.                     sqlQueryObject.addWhereINCondition(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO, true, tipoSoggettiProtocollo.toArray(new String[1]));
  175.                 }
  176.                 if(this.driver.useSuperUser && superuser!=null && !superuser.equals(""))
  177.                     sqlQueryObject.addWhereCondition(CostantiDB.SUPERUSER_COLUMN+"= ?");
  178.                 if(filtroProprieta) {
  179.                     DBUtils.setFiltriProprietaSoggetto(sqlQueryObject, this.driver.tipoDB, 
  180.                             filtroProprietaNome, filtroProprietaValore);
  181.                 }
  182.                 sqlQueryObject.addWhereLikeCondition(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO, search, true, true);
  183.                 if(this.driver.useSuperUser && superuser!=null && !superuser.equals(""))
  184.                     sqlQueryObject.setANDLogicOperator(true);
  185.                 sqlQueryObject.addOrderBy(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO);
  186.                 sqlQueryObject.addOrderBy(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO);
  187.                 sqlQueryObject.setSortType(true);
  188.                 sqlQueryObject.setLimit(limit);
  189.                 sqlQueryObject.setOffset(offset);
  190.                 queryString = sqlQueryObject.createSQLQuery();
  191.             } else {
  192.                 // senza search
  193.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  194.                 sqlQueryObject.addFromTable(this.driver.tabellaSoggetti);
  195.                 sqlQueryObject.addSelectField("id");
  196.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO);
  197.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO);
  198.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_DESCRIZIONE);
  199.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_IDENTIFICATIVO_PORTA);
  200.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_ROUTER);
  201.                 sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_DEFAULT);
  202.                 if(tipoSoggettiProtocollo!=null && !tipoSoggettiProtocollo.isEmpty()) {
  203.                     sqlQueryObject.addWhereINCondition(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO, true, tipoSoggettiProtocollo.toArray(new String[1]));
  204.                 }
  205.                 if(this.driver.useSuperUser && superuser!=null && !superuser.equals(""))
  206.                     sqlQueryObject.addWhereCondition(CostantiDB.SUPERUSER_COLUMN+"= ?");
  207.                 if(filtroProprieta) {
  208.                     DBUtils.setFiltriProprietaSoggetto(sqlQueryObject, this.driver.tipoDB, 
  209.                             filtroProprietaNome, filtroProprietaValore);
  210.                 }
  211.                 sqlQueryObject.addOrderBy(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO);
  212.                 sqlQueryObject.addOrderBy(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO);
  213.                 sqlQueryObject.setSortType(true);
  214.                 sqlQueryObject.setLimit(limit);
  215.                 sqlQueryObject.setOffset(offset);
  216.                 queryString = sqlQueryObject.createSQLQuery();
  217.             }
  218.             stmt = con.prepareStatement(queryString);
  219.             if(this.driver.useSuperUser && superuser!=null && !superuser.equals(""))
  220.                 stmt.setString(1, superuser);
  221.             risultato = stmt.executeQuery();

  223.             Soggetto sog;
  224.             while (risultato.next()) {

  226.                 sog = new Soggetto();
  227.                 sog.setId(risultato.getLong("id"));
  228.                 sog.setNome(risultato.getString(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO));
  229.                 sog.setTipo(risultato.getString(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO));
  230.                 sog.setDescrizione(risultato.getString(CostantiDB.SOGGETTI_COLUMN_DESCRIZIONE));
  231.                 sog.setIdentificativoPorta(risultato.getString(CostantiDB.SOGGETTI_COLUMN_IDENTIFICATIVO_PORTA));
  232.                 sog.setRouter(risultato.getInt(CostantiDB.SOGGETTI_COLUMN_ROUTER) == CostantiDB.TRUE);
  233.                 sog.setDominioDefault(risultato.getInt(CostantiDB.SOGGETTI_COLUMN_DEFAULT) == CostantiDB.TRUE);
  234.                 lista.add(sog);
  235.             }

  237.             return lista;

  239.         } catch (Exception qe) {
  240.             throw new DriverConfigurazioneException(getPrefixError(nomeMetodo)+"Errore : " + qe.getMessage(),qe);
  241.         } finally {
  242.             //Chiudo statement and resultset
  243.             JDBCUtilities.closeResources(risultato, stmt);
  244.             this.driver.closeConnection(con);
  245.         }
  246.     }

  248.     protected List<Soggetto> soggettiWithServiziList(ISearch ricerca) throws DriverConfigurazioneException {
  249.         return soggettiWithServiziList(null,ricerca);
  250.     }
  251.     protected List<Soggetto> soggettiWithServiziList(String superuser,ISearch ricerca) throws DriverConfigurazioneException {
  252.         String nomeMetodo = "soggettiWithServiziList";
  253.         int idLista = Liste.SOGGETTI;
  254.         int offset;
  255.         int limit;
  256.         String queryString;

  258.         limit = ricerca.getPageSize(idLista);
  259.         offset = ricerca.getIndexIniziale(idLista);
  260.         
  261.         Connection con = null;
  262.         PreparedStatement stmt=null;
  263.         ResultSet risultato=null;
  264.         ArrayList<Soggetto> lista = new ArrayList<>();

  266.         if (this.driver.atomica) {
  267.             try {
  268.                 con = this.driver.getConnectionFromDatasource("soggettiWithServiziList");
  269.             } catch (Exception e) {
  270.                 throw new DriverConfigurazioneException(getPrefixError(nomeMetodo)+"Exception accedendo al datasource :" + e.getMessage(),e);

  272.             }

  274.         } else
  275.             con = this.driver.globalConnection;

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

  279.         try {

  281.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  282.             sqlQueryObject.addFromTable(this.driver.tabellaSoggetti);
  283.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  284.             sqlQueryObject.addSelectCountField(this.driver.tabellaSoggetti+".id", "cont", true);
  285.             sqlQueryObject.addWhereCondition(this.driver.tabellaSoggetti+".id = "+CostantiDB.SERVIZI+".id_soggetto");
  286.             if(this.driver.useSuperUser && superuser!=null && (!"".equals(superuser))){
  287.                 sqlQueryObject.addWhereCondition(this.driver.tabellaSoggetti+".superuser=?");
  288.             }
  289.             sqlQueryObject.setANDLogicOperator(true);
  290.             queryString = sqlQueryObject.createSQLQuery();
  291.             stmt = con.prepareStatement(queryString);
  292.             if(this.driver.useSuperUser && superuser!=null && (!"".equals(superuser))){
  293.                 stmt.setString(1, superuser);
  294.             }
  295.             risultato = stmt.executeQuery();
  296.             if (risultato.next())
  297.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  298.             risultato.close();
  299.             stmt.close();

  301.             // ricavo le entries
  302.             if (limit == 0) // con limit
  303.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  304.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  305.             sqlQueryObject.addFromTable(this.driver.tabellaSoggetti);
  306.             sqlQueryObject.addFromTable(CostantiDB.SERVIZI);
  307.             sqlQueryObject.setSelectDistinct(true);
  308.             sqlQueryObject.addSelectField(this.driver.tabellaSoggetti+".id");
  309.             sqlQueryObject.addSelectField(this.driver.tabellaSoggetti+".tipo_soggetto");
  310.             sqlQueryObject.addSelectField(this.driver.tabellaSoggetti+".nome_soggetto");
  311.             sqlQueryObject.addWhereCondition(this.driver.tabellaSoggetti+".id = "+CostantiDB.SERVIZI+".id_soggetto");
  312.             if(this.driver.useSuperUser && superuser!=null && (!"".equals(superuser))){
  313.                 sqlQueryObject.addWhereCondition(this.driver.tabellaSoggetti+".superuser=?");
  314.             }
  315.             sqlQueryObject.setANDLogicOperator(true);
  316.             sqlQueryObject.addOrderBy(this.driver.tabellaSoggetti+".tipo_soggetto");
  317.             sqlQueryObject.addOrderBy(this.driver.tabellaSoggetti+".nome_soggetto");
  318.             sqlQueryObject.setSortType(true);
  319.             sqlQueryObject.setLimit(limit);
  320.             sqlQueryObject.setOffset(offset);
  321.             queryString = sqlQueryObject.createSQLQuery();
  322.             stmt = con.prepareStatement(queryString);
  323.             if(this.driver.useSuperUser && superuser!=null && (!"".equals(superuser))){
  324.                 stmt.setString(1, superuser);
  325.             }
  326.             risultato = stmt.executeQuery();

  328.             Soggetto sog;
  329.             while (risultato.next()) {

  331.                 sog = new Soggetto();
  332.                 sog.setId(risultato.getLong("id"));
  333.                 sog.setNome(risultato.getString(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO));
  334.                 sog.setTipo(risultato.getString(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO));
  335.                 lista.add(sog);
  336.             }

  338.             return lista;

  340.         } catch (Exception qe) {
  341.             throw new DriverConfigurazioneException(getPrefixError(nomeMetodo)+"Errore : " + qe.getMessage(),qe);
  342.         } finally {
  343.             //Chiudo statement and resultset
  344.             JDBCUtilities.closeResources(risultato, stmt);
  345.             this.driver.closeConnection(con);
  346.         }
  347.     }
  348.     
  349.     
  350.     
  351. }
Created with JaCoCo 0.8.8.202204050719