DriverRegistroServiziDB_gruppiDriver.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it). 
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */



  23. package org.openspcoop2.core.registry.driver.db;

  25. import java.sql.Connection;
  26. import java.sql.Date;
  27. import java.sql.PreparedStatement;
  28. import java.sql.ResultSet;
  29. import java.sql.SQLException;
  30. import java.sql.Timestamp;
  31. import java.util.ArrayList;
  32. import java.util.List;

  34. import org.openspcoop2.core.commons.Filtri;
  35. import org.openspcoop2.core.commons.ISearch;
  36. import org.openspcoop2.core.commons.Liste;
  37. import org.openspcoop2.core.commons.SearchUtils;
  38. import org.openspcoop2.core.constants.CostantiDB;
  39. import org.openspcoop2.core.id.IDGruppo;
  40. import org.openspcoop2.core.registry.Gruppo;
  41. import org.openspcoop2.core.registry.constants.ServiceBinding;
  42. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  43. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  44. import org.openspcoop2.core.registry.driver.FiltroRicercaGruppi;
  45. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  46. import org.openspcoop2.utils.sql.ISQLQueryObject;
  47. import org.openspcoop2.utils.sql.SQLObjectFactory;

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

  60.     private DriverRegistroServiziDB driver = null;
  61.     
  62.     protected DriverRegistroServiziDB_gruppiDriver(DriverRegistroServiziDB driver) {
  63.         this.driver = driver;
  64.     }
  65.     
  66.     protected Gruppo getGruppo(
  67.             IDGruppo idGruppo) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{

  69.         this.driver.logDebug("richiesto getGruppo: " + idGruppo);
  70.         // conrollo consistenza
  71.         if (idGruppo == null)
  72.             throw new DriverRegistroServiziException("[getGruppo] Parametro idGruppo is null");
  73.         if (idGruppo.getNome()==null || idGruppo.getNome().trim().equals(""))
  74.             throw new DriverRegistroServiziException("[getGruppo] Parametro idGruppo.nome non e' definito");

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

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

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

  87.             }

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

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

  94.         try {

  96.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  97.             sqlQueryObject.addFromTable(CostantiDB.GRUPPI);
  98.             sqlQueryObject.addSelectField("*");
  99.             sqlQueryObject.addWhereCondition("nome = ?");
  100.             String queryString = sqlQueryObject
  101.                     .createSQLQuery();
  102.             stm = con.prepareStatement(queryString);
  103.             stm.setString(1, idGruppo.getNome());
  104.             rs = stm.executeQuery();
  105.             Gruppo gruppo = null;
  106.             if (rs.next()) {
  107.                 gruppo = new Gruppo();
  108.                 gruppo.setId(rs.getLong("id"));
  109.                 gruppo.setNome(rs.getString("nome"));
  110.                 gruppo.setDescrizione(rs.getString("descrizione"));
  111.                 String serviceBinding = rs.getString("service_binding");
  112.                 if(serviceBinding!=null){
  113.                     gruppo.setServiceBinding(ServiceBinding.toEnumConstant(serviceBinding));
  114.                 }
  115.                 gruppo.setSuperUser(rs.getString("superuser"));

  117.                 // Ora Registrazione
  118.                 if(rs.getTimestamp("ora_registrazione")!=null){
  119.                     gruppo.setOraRegistrazione(new Date(rs.getTimestamp("ora_registrazione").getTime()));
  120.                 }

  122.                 // Proprieta Oggetto
  123.                 gruppo.setProprietaOggetto(DriverRegistroServiziDB_utilsDriver.readProprietaOggetto(rs,false));
  124.                 
  125.             } else {
  126.                 throw new DriverRegistroServiziNotFound("[DriverRegistroServiziDB::getGruppo] rs.next non ha restituito valori con la seguente interrogazione :\n" + 
  127.                         DriverRegistroServiziDB_LIB.formatSQLString(queryString, idGruppo.getNome()));
  128.             }

  130.             return gruppo;

  132.         }catch (DriverRegistroServiziNotFound e) {
  133.             throw e;
  134.         } catch (SQLException se) {

  136.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getGruppo] SqlException: " + se.getMessage(),se);
  137.         }catch (Exception se) {

  139.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getGruppo] Exception: " + se.getMessage(),se);
  140.         } finally {
  141.             JDBCUtilities.closeResources(rs, stm);
  142.             this.driver.closeConnection(con);
  143.         }
  144.     }

  146.     protected Gruppo getGruppo(
  147.             long idGruppo) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{

  149.         this.driver.logDebug("richiesto getGruppo: " + idGruppo);
  150.         // conrollo consistenza
  151.         if (idGruppo <=0)
  152.             throw new DriverRegistroServiziException("[getGruppo] Parametro idGruppo non valido");

  154.         Connection con = null;
  155.         PreparedStatement stm = null;
  156.         ResultSet rs = null;

  158.         if (this.driver.atomica) {
  159.             try {
  160.                 con = this.driver.getConnectionFromDatasource("getGruppo(id)");

  162.             } catch (Exception e) {
  163.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::getGruppo] Exception accedendo al datasource :" + e.getMessage(),e);

  165.             }

  167.         } else
  168.             con = this.driver.globalConnection;

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

  172.         IDGruppo idGruppoObject = null;
  173.         try {

  175.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  176.             sqlQueryObject.addFromTable(CostantiDB.GRUPPI);
  177.             sqlQueryObject.addSelectField("nome");
  178.             sqlQueryObject.addWhereCondition("id = ?");
  179.             String queryString = sqlQueryObject.createSQLQuery();
  180.             stm = con.prepareStatement(queryString);
  181.             stm.setLong(1, idGruppo);
  182.             rs = stm.executeQuery();
  183.             if (rs.next()) {
  184.                 idGruppoObject = new IDGruppo(rs.getString("nome"));
  185.             } else {
  186.                 throw new DriverRegistroServiziNotFound("[DriverRegistroServiziDB::getGruppo] rs.next non ha restituito valori con la seguente interrogazione :\n" + 
  187.                         DriverRegistroServiziDB_LIB.formatSQLString(queryString, idGruppo));
  188.             }

  190.         }catch (DriverRegistroServiziNotFound e) {
  191.             throw e;
  192.         } catch (SQLException se) {

  194.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getGruppo] SqlException: " + se.getMessage(),se);
  195.         }catch (Exception se) {

  197.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getGruppo] Exception: " + se.getMessage(),se);
  198.         } finally {
  199.             JDBCUtilities.closeResources(rs, stm);
  200.             this.driver.closeConnection(con);
  201.         }
  202.         
  203.         return this.getGruppo(idGruppoObject);
  204.     }

  206.     protected List<IDGruppo> getAllIdGruppi(
  207.             FiltroRicercaGruppi filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{

  209.         Connection con = null;
  210.         PreparedStatement stm = null;
  211.         ResultSet rs = null;

  213.         boolean filtroRicercaTipo = false;
  214.         if(filtroRicerca!=null){
  215.             filtroRicercaTipo = filtroRicerca.getServiceBinding()!=null;
  216.         }
  217.         
  218.         List<String> tipoSoggettiProtocollo = null;
  219.         try {
  220.             if(filtroRicerca!=null && (filtroRicerca.getProtocollo()!=null || (filtroRicerca.getProtocolli()!=null && !filtroRicerca.getProtocolli().isEmpty()))){
  221.                 tipoSoggettiProtocollo = Filtri.convertToTipiSoggetti(filtroRicerca.getProtocollo(), Filtri.convertToString(filtroRicerca.getProtocolli()));
  222.             }
  223.         }catch(Exception e) {
  224.             throw new DriverRegistroServiziException(e.getMessage(),e);
  225.         }
  226.         boolean searchByTipoSoggetto = (tipoSoggettiProtocollo!=null && !tipoSoggettiProtocollo.isEmpty());
  227.         
  228.         this.driver.logDebug("getAllIdGruppi...");

  230.         try {
  231.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  232.             // prendo la connessione dal pool
  233.             if (this.driver.atomica)
  234.                 con = this.driver.getConnectionFromDatasource("getAllIdGruppi");
  235.             else
  236.                 con = this.driver.globalConnection;

  238.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  239.             sqlQueryObject.addFromTable(CostantiDB.GRUPPI);
  240.             if(searchByTipoSoggetto) {
  241.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_GRUPPI);
  242.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI);
  243.                 sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  244.             }
  245.             sqlQueryObject.addSelectField(CostantiDB.GRUPPI, "nome");
  246.             if(searchByTipoSoggetto) {
  247.                 sqlQueryObject.setSelectDistinct(true);
  248.             }
  249.             if(filtroRicerca!=null){
  250.                 // Filtro By Data
  251.                 if(filtroRicerca.getMinDate()!=null)
  252.                     sqlQueryObject.addWhereCondition(CostantiDB.GRUPPI+".ora_registrazione > ?");
  253.                 if(filtroRicerca.getMaxDate()!=null)
  254.                     sqlQueryObject.addWhereCondition(CostantiDB.GRUPPI+".ora_registrazione < ?");
  255.                 if(filtroRicerca.getNome()!=null)
  256.                     sqlQueryObject.addWhereCondition(CostantiDB.GRUPPI+".nome = ?");
  257.                 if(filtroRicercaTipo){
  258.                     
  259.                     ISQLQueryObject sqlQueryObjectServiceBinding = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  260.                     sqlQueryObjectServiceBinding.addWhereIsNullCondition(CostantiDB.GRUPPI+".service_binding");
  261.                     sqlQueryObjectServiceBinding.addWhereCondition(CostantiDB.GRUPPI+".service_binding= ?");
  262.                     sqlQueryObjectServiceBinding.setANDLogicOperator(false);
  263.                     sqlQueryObject.addWhereCondition(sqlQueryObjectServiceBinding.createSQLConditions());
  264.                     
  265.                 }
  266.                 if(searchByTipoSoggetto) {
  267.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_GRUPPI+".id_gruppo="+CostantiDB.GRUPPI+".id");
  268.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI_GRUPPI+".id_accordo="+CostantiDB.ACCORDI+".id");
  269.                     sqlQueryObject.addWhereCondition(CostantiDB.ACCORDI+".id_referente="+CostantiDB.SOGGETTI+".id");
  270.                     sqlQueryObject.addWhereINCondition(CostantiDB.SOGGETTI+".tipo_soggetto", true, tipoSoggettiProtocollo.toArray(new String[1]));
  271.                 }
  272.                 
  273.                 if(filtroRicerca.isOrdinaDataRegistrazione())
  274.                     sqlQueryObject.addOrderBy(CostantiDB.GRUPPI+".ora_registrazione");
  275.                 
  276.                 sqlQueryObject.addOrderBy(CostantiDB.GRUPPI+".nome");
  277.             }

  279.             sqlQueryObject.setANDLogicOperator(true);
  280.             String sqlQuery = sqlQueryObject.createSQLQuery();
  281.             this.driver.logDebug("eseguo query : " + sqlQuery );
  282.             stm = con.prepareStatement(sqlQuery);
  283.             int indexStmt = 1;
  284.             if(filtroRicerca!=null){
  285.                 if(filtroRicerca.getMinDate()!=null){
  286.                     this.driver.logDebug("minDate stmt.setTimestamp("+filtroRicerca.getMinDate()+")");
  287.                     stm.setTimestamp(indexStmt, new Timestamp(filtroRicerca.getMinDate().getTime()));
  288.                     indexStmt++;
  289.                 }
  290.                 if(filtroRicerca.getMaxDate()!=null){
  291.                     this.driver.logDebug("maxDate stmt.setTimestamp("+filtroRicerca.getMaxDate()+")");
  292.                     stm.setTimestamp(indexStmt, new Timestamp(filtroRicerca.getMaxDate().getTime()));
  293.                     indexStmt++;
  294.                 }   
  295.                 if(filtroRicerca.getNome()!=null){
  296.                     this.driver.logDebug("nome stmt.setString("+filtroRicerca.getNome()+")");
  297.                     stm.setString(indexStmt, filtroRicerca.getNome());
  298.                     indexStmt++;
  299.                 }   
  300.                 if(filtroRicercaTipo){
  301.                     this.driver.logDebug("serviceBinding stmt.setString("+filtroRicerca.getServiceBinding().getValue()+")");
  302.                     stm.setString(indexStmt, filtroRicerca.getServiceBinding().getValue());
  303.                     indexStmt++;
  304.                 }
  305.             }
  306.             rs = stm.executeQuery();
  307.             List<IDGruppo> nomiGruppi = new ArrayList<>();
  308.             while (rs.next()) {
  309.                 nomiGruppi.add(new IDGruppo(rs.getString("nome")));
  310.             }
  311.             if(nomiGruppi.isEmpty()){
  312.                 if(filtroRicerca!=null)
  313.                     throw new DriverRegistroServiziNotFound("Gruppi non trovati che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  314.                 else
  315.                     throw new DriverRegistroServiziNotFound("Gruppi non trovati");
  316.             }else{
  317.                 return nomiGruppi;
  318.             }
  319.         }catch(DriverRegistroServiziNotFound de){
  320.             throw de;
  321.         }
  322.         catch(Exception e){
  323.             throw new DriverRegistroServiziException("getAllIdGruppi error",e);
  324.         } finally {

  326.             //Chiudo statement and resultset
  327.             JDBCUtilities.closeResources(rs, stm);
  328.             this.driver.closeConnection(con);

  330.         }
  331.     }



  335.     protected void createGruppo(Gruppo gruppo) throws DriverRegistroServiziException{
  336.         if (gruppo == null)
  337.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createGruppo] Parametro non valido.");

  339.         Connection con = null;
  340.         boolean error = false;

  342.         if (this.driver.atomica) {
  343.             try {
  344.                 con = this.driver.getConnectionFromDatasource("createGruppo");
  345.                 con.setAutoCommit(false);
  346.             } catch (Exception e) {
  347.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createGruppo] Exception accedendo al datasource :" + e.getMessage(),e);

  349.             }

  351.         } else
  352.             con = this.driver.globalConnection;

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

  356.         try {
  357.             this.driver.logDebug("CRUDGruppo type = 1");
  358.             DriverRegistroServiziDB_LIB.CRUDGruppo(CostantiDB.CREATE, gruppo, con);

  360.         } catch (Exception qe) {
  361.             error = true;
  362.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createGruppo] Errore durante la creazione del gruppo : " + qe.getMessage(), qe);
  363.         } finally {

  365.             this.driver.closeConnection(error,con);
  366.         }
  367.     }

  369.     protected boolean existsGruppo(IDGruppo idGruppo) throws DriverRegistroServiziException{
  370.         boolean exist = false;
  371.         Connection con = null;
  372.         PreparedStatement stm = null;
  373.         ResultSet rs = null;

  375.         if (idGruppo == null)
  376.             throw new DriverRegistroServiziException("Parametro non valido");

  378.         if (idGruppo.getNome()==null || idGruppo.getNome().equals(""))
  379.             throw new DriverRegistroServiziException("Parametro vuoto non valido");

  381.         if (this.driver.atomica) {
  382.             try {
  383.                 con = this.driver.getConnectionFromDatasource("existsGruppo");
  384.             } catch (Exception e) {
  385.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::existsGruppo] Exception accedendo al datasource :" + e.getMessage(),e);

  387.             }

  389.         } else
  390.             con = this.driver.globalConnection;

  392.         try {
  393.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  394.             sqlQueryObject.addFromTable(CostantiDB.GRUPPI);
  395.             sqlQueryObject.addSelectField("*");
  396.             sqlQueryObject.addWhereCondition("nome = ?");
  397.             sqlQueryObject.setANDLogicOperator(true);
  398.             String sqlQuery = sqlQueryObject.createSQLQuery();
  399.             stm = con.prepareStatement(sqlQuery);
  400.             stm.setString(1, idGruppo.getNome());
  401.             rs = stm.executeQuery();
  402.             if (rs.next())
  403.                 exist = true;
  404.             rs.close();
  405.             stm.close();

  407.         } catch (Exception e) {
  408.             exist = false;
  409.             this.driver.log.error("Errore durante verifica esistenza gruppo: "+e.getMessage(), e);
  410.         } finally {

  412.             //Chiudo statement and resultset
  413.             JDBCUtilities.closeResources(rs, stm);

  415.             this.driver.closeConnection(con);
  416.         }

  418.         return exist;
  419.     }

  421.     protected void updateGruppo(Gruppo gruppo) throws DriverRegistroServiziException{
  422.         if (gruppo == null)
  423.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateGruppo] Parametro non valido.");

  425.         Connection con = null;
  426.         boolean error = false;

  428.         if (this.driver.atomica) {
  429.             try {
  430.                 con = this.driver.getConnectionFromDatasource("updateGruppo");
  431.                 con.setAutoCommit(false);
  432.             } catch (Exception e) {
  433.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateGruppo] Exception accedendo al datasource :" + e.getMessage(),e);

  435.             }

  437.         } else
  438.             con = this.driver.globalConnection;

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

  442.         try {

  444.             this.driver.logDebug("CRUDGruppo type = 2");
  445.             DriverRegistroServiziDB_LIB.CRUDGruppo(CostantiDB.UPDATE, gruppo, con);

  447.         } catch (Exception qe) {
  448.             error = true;
  449.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateGruppo] Errore durante l'aggiornamento del gruppo : " + qe.getMessage(),qe);
  450.         } finally {

  452.             this.driver.closeConnection(error,con);
  453.         }
  454.     }   

  456.     protected void deleteGruppo(Gruppo gruppo) throws DriverRegistroServiziException{
  457.         if (gruppo == null)
  458.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteGruppo] Parametro non valido.");

  460.         Connection con = null;
  461.         boolean error = false;

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

  470.             }

  472.         } else
  473.             con = this.driver.globalConnection;

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

  477.         try {
  478.             this.driver.logDebug("CRUDGruppo type = 3");
  479.             DriverRegistroServiziDB_LIB.CRUDGruppo(CostantiDB.DELETE, gruppo, con);

  481.         } catch (Exception qe) {
  482.             error = true;
  483.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteGruppo] Errore durante l'eliminazione del gruppo : " + qe.getMessage(),qe);
  484.         } finally {

  486.             this.driver.closeConnection(error,con);
  487.         }
  488.     }
  489.     
  490.     
  491.     protected List<Gruppo> gruppiList(String superuser, ISearch ricerca) throws DriverRegistroServiziException {
  492.         String nomeMetodo = "gruppiList";
  493.         int idLista = Liste.GRUPPI;
  494.         int offset;
  495.         int limit;
  496.         String search;
  497.         String queryString;

  499.         limit = ricerca.getPageSize(idLista);
  500.         offset = ricerca.getIndexIniziale(idLista);
  501.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));

  503.         String filterServiceBinding = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_SERVICE_BINDING);
  504.         ServiceBinding serviceBinding = null;
  505.         if(filterServiceBinding!=null) {
  506.             serviceBinding = ServiceBinding.toEnumConstant(filterServiceBinding);
  507.         }
  508.                 
  509.         Connection con = null;
  510.         PreparedStatement stmt = null;
  511.         ResultSet risultato = null;
  512.         ArrayList<Gruppo> lista = new ArrayList<>();

  514.         if (this.driver.atomica) {
  515.             try {
  516.                 con = this.driver.getConnectionFromDatasource("gruppiList");
  517.             } catch (Exception e) {
  518.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  520.             }

  522.         } else
  523.             con = this.driver.globalConnection;

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

  527.         List<IDGruppo> listIdGruppi = null;
  528.         try {

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

  572.             risultato = stmt.executeQuery();
  573.             if (risultato.next())
  574.                 ricerca.setNumEntries(idLista,risultato.getInt(1));
  575.             risultato.close();
  576.             stmt.close();

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

  624.             listIdGruppi = new ArrayList<>();
  625.             while (risultato.next()) {

  627.                 listIdGruppi.add(new IDGruppo(risultato.getString("nome")));

  629.             }

  631.         } catch (Exception qe) {
  632.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  633.         } finally {

  635.             //Chiudo statement and resultset
  636.             JDBCUtilities.closeResources(risultato, stmt);

  638.             this.driver.closeConnection(con);
  639.         }
  640.         
  641.         
  642.         if(listIdGruppi!=null){
  643.             for (IDGruppo idGruppo : listIdGruppi) {
  644.                 try{
  645.                     lista.add(this.getGruppo(idGruppo));
  646.                 }catch(DriverRegistroServiziNotFound notFound){
  647.                     // non può capitare
  648.                     throw new DriverRegistroServiziException(notFound.getMessage(),notFound);
  649.                 }
  650.             }
  651.         }
  652.         
  653.         return lista;
  654.     }
  655. }
Created with JaCoCo 0.8.8.202204050719