DriverConfigurazioneDBSoggetti.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.sql.SQLException;
  26. import java.sql.Timestamp;
  27. import java.util.ArrayList;
  28. import java.util.List;

  30. import org.openspcoop2.core.commons.CoreException;
  31. import org.openspcoop2.core.commons.DBUtils;
  32. import org.openspcoop2.core.config.Soggetto;
  33. import org.openspcoop2.core.config.constants.CostantiConfigurazione;
  34. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  35. import org.openspcoop2.core.config.driver.DriverConfigurazioneNotFound;
  36. import org.openspcoop2.core.config.driver.FiltroRicercaSoggetti;
  37. import org.openspcoop2.core.config.driver.IDServizioUtils;
  38. import org.openspcoop2.core.constants.CostantiDB;
  39. import org.openspcoop2.core.id.IDServizio;
  40. import org.openspcoop2.core.id.IDSoggetto;
  41. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  42. import org.openspcoop2.utils.sql.ISQLQueryObject;
  43. import org.openspcoop2.utils.sql.SQLObjectFactory;

  45. /**
  46.  * DriverConfigurazioneDB_soggettiDriver
  47.  * 
  48.  * 
  49.  * @author Sandra Giangrandi (sandra@link.it)
  50.  * @author Stefano Corallo (corallo@link.it)
  51.  * @author $Author$
  52.  * @version $Rev$, $Date$
  53.  */
  54. public class DriverConfigurazioneDBSoggetti {

  56.     private DriverConfigurazioneDB driver = null;

  58.     private static final String ESEGUO_QUERY_PREFIX = "eseguo query : ";
  59.     private static final String OPERAZIONE_ATOMICA_PREFIX = "operazione this.driver.atomica = ";
  60.     
  61.     protected DriverConfigurazioneDBSoggetti(DriverConfigurazioneDB driver) {
  62.         this.driver = driver;
  63.     }
  64.     
  65.     protected IDSoggetto getIdSoggetto(long idSoggetto) throws DriverConfigurazioneException,DriverConfigurazioneNotFound {
  66.         return getIdSoggetto(idSoggetto,null);
  67.     }
  68.     protected IDSoggetto getIdSoggetto(long idSoggetto,Connection conParam) throws DriverConfigurazioneException,DriverConfigurazioneNotFound {

  70.         // conrollo consistenza
  71.         if (idSoggetto <= 0)
  72.             return null;

  74.         IDSoggetto idSoggettoObject = null;

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

  80.         if(conParam!=null){
  81.             con = conParam;
  82.         }
  83.         else if (this.driver.atomica) {
  84.             try {
  85.                 con = this.driver.getConnectionFromDatasource("getIdSoggetto(longId)");

  87.             } catch (Exception e) {
  88.                 throw new DriverConfigurazioneException("DriverConfigurazioneDB::getIdSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);

  90.             }

  92.         } else
  93.             con = this.driver.globalConnection;

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

  97.         try {
  98.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  99.             sqlQueryObject.addFromTable(this.driver.tabellaSoggetti);
  100.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO);
  101.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO);
  102.             sqlQueryObject.addWhereCondition("id = ?");
  103.             String sqlQuery = sqlQueryObject.createSQLQuery();

  105.             stm = con.prepareStatement(sqlQuery);

  107.             stm.setLong(1, idSoggetto);

  109.             this.driver.logDebug(ESEGUO_QUERY_PREFIX + DriverConfigurazioneDBLib.formatSQLString(sqlQuery, idSoggetto));
  110.             rs = stm.executeQuery();

  112.             if (rs.next()) {
  113.                 idSoggettoObject = new IDSoggetto();

  115.                 idSoggettoObject.setNome(rs.getString(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO));
  116.                 idSoggettoObject.setTipo(rs.getString(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO));

  118.             }else{
  119.                 throw new DriverConfigurazioneNotFound("Nessun risultato trovat eseguendo: "+DriverConfigurazioneDBLib.formatSQLString(sqlQuery, idSoggetto));
  120.             }

  122.             return idSoggettoObject;
  123.         } catch (SQLException se) {
  124.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::getIdSoggetto] SqlException: " + se.getMessage(),se);
  125.         }catch (DriverConfigurazioneNotFound se) {
  126.             throw se;
  127.         }catch (Exception se) {
  128.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::getIdSoggetto] Exception: " + se.getMessage(),se);
  129.         } finally {

  131.             //Chiudo statement and resultset
  132.             JDBCUtilities.closeResources(rs, stm);

  134.             this.driver.closeConnection(conParam, con);
  135.         }
  136.     }
  137.     
  138.     
  139.     
  140.     
  141.     
  142.     protected Soggetto getSoggetto(IDSoggetto aSoggetto) throws DriverConfigurazioneException,DriverConfigurazioneNotFound {

  144.         if ((aSoggetto == null) || (aSoggetto.getNome() == null) || (aSoggetto.getTipo() == null)) {
  145.             throw new DriverConfigurazioneException("[getSoggetto] Parametri Non Validi");
  146.         }

  148.         Soggetto soggetto = null;

  150.         Connection con = null;

  152.         String nomeSogg = aSoggetto.getNome();
  153.         String tipoSogg = aSoggetto.getTipo();
  154.         long idSoggetto= -1;
  155.         if (this.driver.atomica) {
  156.             try {
  157.                 con = this.driver.getConnectionFromDatasource("getSoggetto(idSoggetto)");

  159.             } catch (Exception e) {
  160.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::getSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);

  162.             }

  164.         } else
  165.             con = this.driver.globalConnection;

  167.         this.driver.logDebug(OPERAZIONE_ATOMICA_PREFIX + this.driver.atomica);

  169.         try {
  170.             idSoggetto=DBUtils.getIdSoggetto(nomeSogg, tipoSogg, con, this.driver.tipoDB,this.driver.tabellaSoggetti);
  171.             if(idSoggetto==-1)
  172.                 throw new DriverConfigurazioneNotFound("Soggetto ["+aSoggetto.toString()+"] non esistente");

  174.         } catch (DriverConfigurazioneNotFound se) {
  175.             throw se;
  176.         } catch (CoreException se) {
  177.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::getSoggetto] DriverException: " + se.getMessage(),se);
  178.         } catch (Exception se) {
  179.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::getSoggetto] Exception: " + se.getMessage(),se);
  180.         }finally {

  182.             this.driver.closeConnection(con);
  183.         }


  186.         soggetto=this.getSoggetto(idSoggetto);

  188.         if(soggetto==null){
  189.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::getSoggetto] Soggetto non Esistente.");
  190.         }

  192.         return soggetto;
  193.     }

  195.     protected void createSoggetto(org.openspcoop2.core.config.Soggetto soggetto) throws DriverConfigurazioneException {
  196.         if (soggetto == null)
  197.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::createSoggetto] Parametro non valido.");

  199.         Connection con = null;
  200.         boolean error = false;

  202.         if (this.driver.atomica) {
  203.             try {
  204.                 con = this.driver.getConnectionFromDatasource("createSoggetto");
  205.                 con.setAutoCommit(false);
  206.             } catch (Exception e) {
  207.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::createSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);

  209.             }

  211.         } else
  212.             con = this.driver.globalConnection;

  214.         this.driver.logDebug(OPERAZIONE_ATOMICA_PREFIX + this.driver.atomica);

  216.         try {
  217.             this.driver.logDebug("CRUDSoggetto type = 1");
  218.             // creo soggetto
  219.             DriverConfigurazioneDBSoggettiLib.CRUDSoggetto(1, soggetto, con);

  221.         } catch (Exception qe) {
  222.             error = true;
  223.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::createSoggetto] Errore durante la creazione del soggetto : " + qe.getMessage(),qe);
  224.         } finally {

  226.             this.driver.closeConnection(error,con);
  227.         }
  228.     }

  230.     protected void updateSoggetto(org.openspcoop2.core.config.Soggetto soggetto) throws DriverConfigurazioneException {
  231.         if (soggetto == null)
  232.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::updateSoggetto] Parametro non valido.");

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

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

  244.             }

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

  249.         this.driver.logDebug(OPERAZIONE_ATOMICA_PREFIX + this.driver.atomica);

  251.         try {
  252.             this.driver.logDebug("CRUDSoggetto type = 2");
  253.             // UPDATE soggetto
  254.             DriverConfigurazioneDBSoggettiLib.CRUDSoggetto(2, soggetto, con);

  256.         } catch (Exception qe) {
  257.             error = true;
  258.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::updateSoggetto] Errore durante la creazione del soggetto : " + qe.getMessage(),qe);
  259.         }finally {

  261.             this.driver.closeConnection(error,con);
  262.         }
  263.     }

  265.         
  266.     protected void deleteSoggetto(org.openspcoop2.core.config.Soggetto soggetto) throws DriverConfigurazioneException {
  267.         if (soggetto == null)
  268.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::deleteSoggetto] Parametro non valido.");

  270.         Connection con = null;
  271.         boolean error = false;

  273.         if (this.driver.atomica) {
  274.             try {
  275.                 con = this.driver.getConnectionFromDatasource("deleteSoggetto");
  276.                 con.setAutoCommit(false);
  277.             } catch (Exception e) {
  278.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::deleteSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);

  280.             }

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

  285.         this.driver.logDebug(OPERAZIONE_ATOMICA_PREFIX + this.driver.atomica);

  287.         try {
  288.             this.driver.logDebug("CRUDSoggetto type = 3");
  289.             // DELETE soggetto
  290.             DriverConfigurazioneDBSoggettiLib.CRUDSoggetto(3, soggetto, con);

  292.         } catch (Exception qe) {
  293.             error = true;
  294.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::deleteSoggetto] Errore durante la creazione del soggetto : " + qe.getMessage(),qe);
  295.         }finally {

  297.             this.driver.closeConnection(error,con);
  298.         }
  299.     }
  300.     
  301.     protected Soggetto getRouter() throws DriverConfigurazioneException,DriverConfigurazioneNotFound {

  303.         Soggetto soggetto = null;

  305.         Connection con = null;
  306.         PreparedStatement stm = null;
  307.         ResultSet rs = null;
  308.         String sqlQuery = "";

  310.         if (this.driver.atomica) {
  311.             try {
  312.                 con = this.driver.getConnectionFromDatasource("getRouter");

  314.             } catch (Exception e) {
  315.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::getRouter] Exception accedendo al datasource :" + e.getMessage(),e);

  317.             }

  319.         } else
  320.             con = this.driver.globalConnection;

  322.         this.driver.logDebug(OPERAZIONE_ATOMICA_PREFIX + this.driver.atomica);
  323.         long idRouter = -1;
  324.         try {
  325.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  326.             sqlQueryObject.addFromTable(this.driver.tabellaSoggetti);
  327.             sqlQueryObject.addSelectField("*");
  328.             sqlQueryObject.addWhereCondition("is_router = ?");
  329.             sqlQuery = sqlQueryObject.createSQLQuery();

  331.             stm = con.prepareStatement(sqlQuery);

  333.             stm.setInt(1, CostantiDB.TRUE);

  335.             this.driver.logDebug(ESEGUO_QUERY_PREFIX + DBUtils.formatSQLString(sqlQuery, CostantiConfigurazione.ABILITATO));
  336.             rs = stm.executeQuery();

  338.             // prendo il primo router se c'e' altrimenti lancio eccezione.
  339.             if (rs.next()) {
  340.                 idRouter = rs.getLong("id");
  341.             } else {
  342.                 throw new DriverConfigurazioneNotFound("[DriverConfigurazioneDB::getRouter] Non esiste un Soggetto Router.");
  343.             }

  345.         } catch (SQLException se) {
  346.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::getRouter] SqlException: " + se.getMessage(),se);
  347.         } catch (DriverConfigurazioneNotFound se) {
  348.             throw se;
  349.         } catch (Exception se) {
  350.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::getRouter] Exception: " + se.getMessage(),se);
  351.         } finally {
  352.             //Chiudo statement and resultset
  353.             JDBCUtilities.closeResources(rs, stm);
  354.             this.driver.closeConnection(con);
  355.         }

  357.         soggetto=this.getSoggetto(idRouter);
  358.         // e' sicuramente un router
  359.         soggetto.setRouter(true);
  360.         return soggetto;
  361.     }

  363.     protected List<IDSoggetto> getSoggettiWithSuperuser(String user) throws DriverConfigurazioneException {

  365.         List<IDSoggetto> idSoggetti = null;

  367.         Connection con = null;
  368.         PreparedStatement stm = null;
  369.         ResultSet rs = null;
  370.         String sqlQuery = "";

  372.         if (this.driver.atomica) {
  373.             try {
  374.                 con = this.driver.getConnectionFromDatasource("getSoggettiWithSuperuser");

  376.             } catch (Exception e) {
  377.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::getSoggettiWithSuperuser] Exception accedendo al datasource :" + e.getMessage(),e);

  379.             }

  381.         } else
  382.             con = this.driver.globalConnection;

  384.         this.driver.logDebug(OPERAZIONE_ATOMICA_PREFIX + this.driver.atomica);

  386.         try {
  387.             List<IDSoggetto> idTrovati = new ArrayList<>();
  388.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  389.             sqlQueryObject.addFromTable(this.driver.tabellaSoggetti);
  390.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO);
  391.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO);
  392.             sqlQueryObject.addWhereCondition("superuser = ?");
  393.             sqlQuery = sqlQueryObject.createSQLQuery();

  395.             stm = con.prepareStatement(sqlQuery);

  397.             stm.setString(1, user);

  399.             this.driver.logDebug(ESEGUO_QUERY_PREFIX + DBUtils.formatSQLString(sqlQuery, CostantiConfigurazione.ABILITATO));
  400.             rs = stm.executeQuery();

  402.             // prendo il primo router se c'e' altrimenti lancio eccezione.
  403.             while (rs.next()) {
  404.                 IDSoggetto id = new IDSoggetto();
  405.                 id.setTipo(rs.getString(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO));
  406.                 id.setNome(rs.getString(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO));
  407.                 idTrovati.add(id);
  408.             }

  410.             if(!idTrovati.isEmpty()){
  411.                 idSoggetti =  new ArrayList<>();
  412.                 idSoggetti.addAll(idTrovati);
  413.             }

  415.         } catch (SQLException se) {
  416.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::getSoggettiWithSuperuser] SqlException: " + se.getMessage(),se);
  417.         }catch (Exception se) {
  418.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::getSoggettiWithSuperuser] Exception: " + se.getMessage(),se);
  419.         } finally {
  420.             //Chiudo statement and resultset
  421.             JDBCUtilities.closeResources(rs, stm);
  422.             this.driver.closeConnection(con);
  423.         }
  424.         return idSoggetti;
  425.     }

  427.     protected List<IDSoggetto> getSoggettiVirtuali() throws DriverConfigurazioneException,DriverConfigurazioneNotFound {

  429.         List<IDSoggetto> soggettiVirtuali = new ArrayList<>();
  430.         Connection con = null;
  431.         PreparedStatement stm = null;
  432.         ResultSet rs = null;
  433.         String sqlQuery = "";
  434.         if (this.driver.atomica) {
  435.             try {
  436.                 con = this.driver.getConnectionFromDatasource("getSoggettiVirtuali");

  438.             } catch (Exception e) {
  439.                 throw new DriverConfigurazioneException("Exception accedendo al datasource :" + e.getMessage(),e);

  441.             }

  443.         } else
  444.             con = this.driver.globalConnection;

  446.         this.driver.logDebug(OPERAZIONE_ATOMICA_PREFIX + this.driver.atomica);

  448.         try {
  449.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  450.             sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE);
  451.             sqlQueryObject.setSelectDistinct(true);
  452.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO_VIRTUALE);
  453.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO_VIRTUALE);
  454.             sqlQueryObject.addWhereCondition("tipo_soggetto_virtuale IS NOT NULL");
  455.             sqlQueryObject.addWhereCondition("nome_soggetto_virtuale IS NOT NULL");
  456.             sqlQueryObject.addWhereCondition("tipo_soggetto_virtuale<>'\"\"'");
  457.             sqlQueryObject.addWhereCondition("nome_soggetto_virtuale<>'\"\"'");
  458.             sqlQueryObject.setANDLogicOperator(true);
  459.             sqlQuery = sqlQueryObject.createSQLQuery();

  461.             this.driver.logDebug(ESEGUO_QUERY_PREFIX + DBUtils.formatSQLString(sqlQuery));

  463.             stm = con.prepareStatement(sqlQuery);
  464.             rs = stm.executeQuery();

  466.             while (rs.next()) {
  467.                 IDSoggetto soggettoVirtuale = new IDSoggetto(rs.getString(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO_VIRTUALE) , rs.getString(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO_VIRTUALE));
  468.                 this.driver.logInfo("aggiunto Soggetto " + soggettoVirtuale + " alla lista dei Soggetti Virtuali");
  469.                 soggettiVirtuali.add(soggettoVirtuale);
  470.             }
  471.             rs.close();
  472.             stm.close();

  474.             if(soggettiVirtuali.isEmpty()){
  475.                 throw new DriverConfigurazioneNotFound("[getSoggettiVirtuali] Soggetti virtuali non esistenti");
  476.             }

  478.             this.driver.logInfo("aggiunti " + soggettiVirtuali.size() + " soggetti alla lista dei Soggetti Virtuali");
  479.             return soggettiVirtuali;
  480.         } catch (SQLException se) {
  481.             throw new DriverConfigurazioneException("SqlException: " + se.getMessage(), se);
  482.         } catch (DriverConfigurazioneNotFound se) {
  483.             throw se;
  484.         }catch (Exception se) {
  485.             throw new DriverConfigurazioneException("Exception: " + se.getMessage(), se);
  486.         } finally {
  487.             //Chiudo statement and resultset
  488.             JDBCUtilities.closeResources(rs, stm);
  489.             this.driver.closeConnection(con);
  490.         }

  492.     }
  493.     
  494.     /**
  495.      * Ritorna il {@linkplain Soggetto} utilizzando il {@link DriverConfigurazioneDB} che ha l'id passato come parametro 
  496.      */
  497.     protected Soggetto getSoggetto(long idSoggetto) throws DriverConfigurazioneException,DriverConfigurazioneNotFound {
  498.         return getSoggetto(idSoggetto,null);
  499.     }
  500.     protected Soggetto getSoggetto(long idSoggetto,Connection conParam) throws DriverConfigurazioneException,DriverConfigurazioneNotFound {

  502.         if (idSoggetto <= 0)
  503.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::getSoggetto] L'id del soggetto deve essere > 0.");

  505.         Soggetto soggetto = null;

  507.         Connection con = null;
  508.         PreparedStatement stm = null;
  509.         PreparedStatement stm1 = null;
  510.         ResultSet rs = null;
  511.         ResultSet rs1 = null;
  512.         String sqlQuery = "";

  514.         if(conParam!=null){
  515.             con = conParam;
  516.         }
  517.         else if (this.driver.atomica) {
  518.             try {
  519.                 con = this.driver.getConnectionFromDatasource("getSoggetto(longId)");
  520.             } catch (Exception e) {
  521.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::getSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);
  522.             }

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

  527.         this.driver.logDebug(OPERAZIONE_ATOMICA_PREFIX + this.driver.atomica);

  529.         try {

  531.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  532.             sqlQueryObject.addFromTable(this.driver.tabellaSoggetti);
  533.             sqlQueryObject.addSelectField("*");
  534.             sqlQueryObject.addWhereCondition("id=?");
  535.             sqlQuery = sqlQueryObject.createSQLQuery();

  537.             this.driver.logDebug(OPERAZIONE_ATOMICA_PREFIX + this.driver.atomica);

  539.             stm = con.prepareStatement(sqlQuery);

  541.             stm.setLong(1, idSoggetto);

  543.             this.driver.logDebug(ESEGUO_QUERY_PREFIX + DBUtils.formatSQLString(sqlQuery, idSoggetto));
  544.             rs = stm.executeQuery();

  546.             if (rs.next()) {
  547.                 soggetto = new Soggetto();

  549.                 soggetto.setId(rs.getLong("id"));

  551.                 soggetto.setNome(rs.getString(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO));

  553.                 soggetto.setTipo(rs.getString(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO));

  555.                 soggetto.setSuperUser(rs.getString("superuser"));

  557.                 String tmp = rs.getString("descrizione");
  558.                 soggetto.setDescrizione(((tmp == null || tmp.equals("")) ? null : tmp));

  560.                 tmp = rs.getString("identificativo_porta");
  561.                 soggetto.setIdentificativoPorta(((tmp == null || tmp.equals("")) ? null : tmp));

  563.                 int defaultR = rs.getInt("is_default");
  564.                 boolean isDefault = false;
  565.                 if (defaultR == CostantiDB.TRUE)
  566.                     isDefault = true;
  567.                 soggetto.setDominioDefault(isDefault);
  568.                 
  569.                 int router = rs.getInt("is_router");
  570.                 boolean isrouter = false;
  571.                 if (router == CostantiDB.TRUE)
  572.                     isrouter = true;
  573.                 soggetto.setRouter(isrouter);

  575.                 tmp = rs.getString("pd_url_prefix_rewriter");
  576.                 soggetto.setPdUrlPrefixRewriter(((tmp == null || tmp.equals("")) ? null : tmp));

  578.                 tmp = rs.getString("pa_url_prefix_rewriter");
  579.                 soggetto.setPaUrlPrefixRewriter(((tmp == null || tmp.equals("")) ? null : tmp));

  581.                 // Creava OutOfMemory, non dovrebbe servire
  582. /**             // Aggiungo i servizi applicativi
  583. //              sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  584. //              sqlQueryObject.addFromTable(CostantiDB.SERVIZI_APPLICATIVI);
  585. //              sqlQueryObject.addSelectField("id");
  586. //              sqlQueryObject.addSelectField("nome");
  587. //              sqlQueryObject.addWhereCondition("id_soggetto=?");
  588. //              sqlQuery = sqlQueryObject.createSQLQuery();
  589. //              stm1 = con.prepareStatement(sqlQuery);
  590. //              stm1.setLong(1, rs.getLong("id"));
  591. //              rs1 = stm1.executeQuery();
  592. //
  593. //              ServizioApplicativo servizioApplicativo = null;
  594. //              while (rs1.next()) {
  595. //                  // setto solo il nome come da specifica
  596. //                  servizioApplicativo = new ServizioApplicativo();
  597. //                  servizioApplicativo.setId(rs1.getLong("id"));
  598. //                  servizioApplicativo.setNome(rs1.getString("nome"));
  599. //                  Soggetto.addServizioApplicativo(servizioApplicativo);
  600. //              }
  601. //              rs1.close();
  602. //              stm1.close();*/

  604.             } else {
  605.                 throw new DriverConfigurazioneNotFound("[DriverConfigurazioneDB::getSoggetto] Soggetto non Esistente.");
  606.             }

  608.             return soggetto;

  610.         } catch (SQLException se) {

  612.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::getSoggetto] SqlException: " + se.getMessage(),se);
  613.         }catch (DriverConfigurazioneNotFound e) {
  614.             throw new DriverConfigurazioneNotFound(e);
  615.         } catch (Exception se) {

  617.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::getSoggetto] Exception: " + se.getMessage(),se);
  618.         } finally {
  619.             //Chiudo statement and resultset
  620.             JDBCUtilities.closeResources(rs1, stm1);
  621.             JDBCUtilities.closeResources(rs, stm);
  622.             this.driver.closeConnection(conParam, con);
  623.         }
  624.     }

  626.     
  627.     protected List<IDServizio> getServiziSoggettiVirtuali() throws DriverConfigurazioneException,DriverConfigurazioneNotFound {

  629.         List<IDServizio> servizi = new ArrayList<>();
  630.         Connection con = null;
  631.         PreparedStatement stm = null;
  632.         ResultSet rs = null;
  633.         String sqlQuery = "";
  634.         if (this.driver.atomica) {
  635.             try {
  636.                 con = this.driver.getConnectionFromDatasource("getServiziSoggettiVirtuali");

  638.             } catch (Exception e) {
  639.                 throw new DriverConfigurazioneException("Exception accedendo al datasource :" + e.getMessage(),e);

  641.             }

  643.         } else
  644.             con = this.driver.globalConnection;

  646.         this.driver.logDebug(OPERAZIONE_ATOMICA_PREFIX + this.driver.atomica);

  648.         try {
  649.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  650.             sqlQueryObject.addFromTable(CostantiDB.PORTE_APPLICATIVE);
  651.             sqlQueryObject.setSelectDistinct(true);
  652.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO_VIRTUALE);
  653.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO_VIRTUALE);
  654.             sqlQueryObject.addSelectField("tipo_servizio");
  655.             sqlQueryObject.addSelectField("servizio");
  656.             sqlQueryObject.addSelectField("versione_servizio");
  657.             sqlQueryObject.setANDLogicOperator(false);
  658.             sqlQueryObject.addWhereCondition("id_soggetto_virtuale<>-1");
  659.             sqlQueryObject.addWhereCondition(true, "tipo_soggetto_virtuale is not null", "nome_soggetto_virtuale is not null");
  660.             sqlQueryObject.setANDLogicOperator(false);
  661.             sqlQuery = sqlQueryObject.createSQLQuery();

  663.             this.driver.logDebug(ESEGUO_QUERY_PREFIX + DBUtils.formatSQLString(sqlQuery));

  665.             stm = con.prepareStatement(sqlQuery);
  666.             rs = stm.executeQuery();

  668.             while (rs.next()) {
  669.                 IDServizio servizio = IDServizioUtils.buildIDServizio(rs.getString("tipo_servizio"), rs.getString("servizio"), 
  670.                         new IDSoggetto(rs.getString(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO_VIRTUALE), rs.getString(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO_VIRTUALE)), 
  671.                         rs.getInt("versione_servizio"));
  672.                 servizi.add(servizio);
  673.                 this.driver.logInfo("aggiunto Servizio " + servizio.toString() + " alla lista dei servizi erogati da Soggetti Virtuali");
  674.             }

  676.             if(servizi.isEmpty()){
  677.                 throw new DriverConfigurazioneNotFound("[getServiziSoggettiVirtuali] Servizi erogati da Soggetti virtuali non esistenti");
  678.             }

  680.             this.driver.logInfo("aggiunti " + servizi.size() + " servizi alla lista dei servizi erogati da Soggetti Virtuali");
  681.             return servizi;
  682.         } catch (SQLException se) {
  683.             throw new DriverConfigurazioneException("SqlException: " + se.getMessage(), se);
  684.         }  catch (DriverConfigurazioneNotFound se) {
  685.             throw se;
  686.         }catch (Exception se) {
  687.             throw new DriverConfigurazioneException("Exception: " + se.getMessage(), se);
  688.         }finally {
  689.             //Chiudo statement and resultset
  690.             JDBCUtilities.closeResources(rs, stm);
  691.             this.driver.closeConnection(con);
  692.         }

  694.     }
  695.     
  696.     protected boolean existsSoggetto(IDSoggetto idSoggetto) throws DriverConfigurazioneException {

  698.         if(idSoggetto==null)throw new DriverConfigurazioneException("[existsSoggetto::existsSoggetto] Soggetto non Impostato.");
  699.         if(idSoggetto.getNome()==null || "".equals(idSoggetto.getNome()))throw new DriverConfigurazioneException("[existsSoggetto::existsServizioApplicativo] Nome Soggetto non Impostato.");
  700.         if(idSoggetto.getTipo()==null || "".equals(idSoggetto.getTipo()))throw new DriverConfigurazioneException("[existsSoggetto::existsServizioApplicativo] Nome Soggetto non Impostato.");

  702.         Connection con = null;

  704.         try {
  705.             
  706.             if (this.driver.atomica) {
  707.                 try {
  708.                     con = this.driver.getConnectionFromDatasource("existsSoggetto");
  709.                 } catch (Exception e) {
  710.                     throw new DriverConfigurazioneException("[DriverConfigurazioneDB::existsSoggetto] Exception accedendo al datasource :" + e.getMessage(),e);

  712.                 }

  714.             } else
  715.                 con = this.driver.globalConnection;
  716.             
  717.             return DBUtils.getIdSoggetto(idSoggetto.getNome(), idSoggetto.getTipo(), con, this.driver.tipoDB,this.driver.tabellaSoggetti)>0;
  718.         } catch (Exception qe) {
  719.             throw new DriverConfigurazioneException(qe);
  720.         } finally {

  722.             this.driver.closeConnection(con);

  724.         }
  725.     }
  726.     
  727.     protected List<Soggetto> getAllSoggetti() throws DriverConfigurazioneException {
  728.         String nomeMetodo = "getAllSoggetti";

  730.         Connection con = null;
  731.         PreparedStatement stmt=null;
  732.         ResultSet risultato=null;
  733.         ArrayList<Soggetto> lista = new ArrayList<>();

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

  741.             }

  743.         } else
  744.             con = this.driver.globalConnection;

  746.         this.driver.logDebug(OPERAZIONE_ATOMICA_PREFIX + this.driver.atomica);

  748.         try {

  750.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  751.             sqlQueryObject.addFromTable(this.driver.tabellaSoggetti);
  752.             sqlQueryObject.addSelectField("id");
  753.             String queryString = sqlQueryObject.createSQLQuery();
  754.             stmt = con.prepareStatement(queryString);
  755.             risultato = stmt.executeQuery();

  757.             while (risultato.next()) {

  759.                 Long id = risultato.getLong("id");
  760.                 lista.add(this.getSoggetto(id));

  762.             }

  764.             return lista;

  766.         } catch (Exception qe) {
  767.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  768.         } finally {
  769.             //Chiudo statement and resultset
  770.             JDBCUtilities.closeResources(risultato, stmt);
  771.             this.driver.closeConnection(con);
  772.         }
  773.     }
  774.     
  775.     protected List<IDSoggetto> getAllIdSoggetti(
  776.             FiltroRicercaSoggetti filtroRicerca) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{

  778.         Connection con = null;
  779.         PreparedStatement stm = null;
  780.         ResultSet rs = null;

  782.         this.driver.logDebug("getAllIdSoggetti...");

  784.         try {
  785.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  786.             // prendo la connessione dal pool
  787.             if (this.driver.atomica)
  788.                 con = this.driver.getConnectionFromDatasource("getAllIdSoggetti");
  789.             else
  790.                 con = this.driver.globalConnection;

  792.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  793.             sqlQueryObject.addFromTable(CostantiDB.SOGGETTI);
  794.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO);
  795.             sqlQueryObject.addSelectField(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO);
  796.             if(filtroRicerca!=null){
  797.                 // Filtro By Data
  798.                 if(filtroRicerca.getMinDate()!=null)
  799.                     sqlQueryObject.addWhereCondition("ora_registrazione > ?");
  800.                 if(filtroRicerca.getMaxDate()!=null)
  801.                     sqlQueryObject.addWhereCondition("ora_registrazione < ?");
  802.                 if(filtroRicerca.getTipo()!=null)
  803.                     sqlQueryObject.addWhereCondition("tipo_soggetto = ?");
  804.                 if(filtroRicerca.getNome()!=null)
  805.                     sqlQueryObject.addWhereCondition("nome_soggetto = ?");
  806.             }

  808.             sqlQueryObject.setANDLogicOperator(true);
  809.             String sqlQuery = sqlQueryObject.createSQLQuery();
  810.             this.driver.logDebug(ESEGUO_QUERY_PREFIX + sqlQuery );
  811.             stm = con.prepareStatement(sqlQuery);
  812.             int indexStmt = 1;
  813.             if(filtroRicerca!=null){
  814.                 if(filtroRicerca.getMinDate()!=null){
  815.                     this.driver.logDebug("minDate stmt.setTimestamp("+filtroRicerca.getMinDate()+")");
  816.                     stm.setTimestamp(indexStmt, new Timestamp(filtroRicerca.getMinDate().getTime()));
  817.                     indexStmt++;
  818.                 }
  819.                 if(filtroRicerca.getMaxDate()!=null){
  820.                     this.driver.logDebug("maxDate stmt.setTimestamp("+filtroRicerca.getMaxDate()+")");
  821.                     stm.setTimestamp(indexStmt, new Timestamp(filtroRicerca.getMaxDate().getTime()));
  822.                     indexStmt++;
  823.                 }   
  824.                 if(filtroRicerca.getTipo()!=null){
  825.                     this.driver.logDebug("tipoSoggetto stmt.setString("+filtroRicerca.getTipo()+")");
  826.                     stm.setString(indexStmt, filtroRicerca.getTipo());
  827.                     indexStmt++;
  828.                 }
  829.                 if(filtroRicerca.getNome()!=null){
  830.                     this.driver.logDebug("nomeSoggetto stmt.setString("+filtroRicerca.getNome()+")");
  831.                     stm.setString(indexStmt, filtroRicerca.getNome());
  832.                     indexStmt++;
  833.                 }   
  834.             }
  835.             rs = stm.executeQuery();
  836.             List<IDSoggetto> idSoggetti = new ArrayList<>();
  837.             while (rs.next()) {
  838.                 IDSoggetto idS = new IDSoggetto(rs.getString(CostantiDB.SOGGETTI_COLUMN_TIPO_SOGGETTO),rs.getString(CostantiDB.SOGGETTI_COLUMN_NOME_SOGGETTO));
  839.                 idSoggetti.add(idS);
  840.             }
  841.             if(idSoggetti.isEmpty()){
  842.                 if(filtroRicerca!=null)
  843.                     throw new DriverConfigurazioneNotFound("Soggetti non trovati che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  844.                 else
  845.                     throw new DriverConfigurazioneNotFound("Soggetti non trovati");
  846.             }else{
  847.                 return idSoggetti;
  848.             }
  849.         }catch(DriverConfigurazioneNotFound de){
  850.             throw de;
  851.         }
  852.         catch(Exception e){
  853.             throw new DriverConfigurazioneException("getAllIdSoggetti error",e);
  854.         } finally {

  856.             //Chiudo statement and resultset
  857.             JDBCUtilities.closeResources(rs, stm);

  859.             this.driver.closeConnection(con);

  861.         }

  863.     }
  864. }
Created with JaCoCo 0.8.8.202204050719