DriverConfigurazioneDBSoggettiLib.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 static org.openspcoop2.core.constants.CostantiDB.CREATE;
  23. import static org.openspcoop2.core.constants.CostantiDB.DELETE;
  24. import static org.openspcoop2.core.constants.CostantiDB.UPDATE;

  26. import java.sql.Connection;
  27. import java.sql.PreparedStatement;
  28. import java.sql.ResultSet;
  29. import java.sql.SQLException;

  31. import org.openspcoop2.core.commons.DBUtils;
  32. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  33. import org.openspcoop2.core.constants.CostantiDB;
  34. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  35. import org.openspcoop2.utils.sql.ISQLQueryObject;
  36. import org.openspcoop2.utils.sql.SQLObjectFactory;

  38. /**
  39.  * DriverConfigurazioneDB_soggettiLIB
  40.  * 
  41.  * @author Stefano Corallo - corallo@link.it
  42.  * @author $Author$
  43.  * @version $Rev$, $Date$
  44.  */
  45. public class DriverConfigurazioneDBSoggettiLib {
  46.     
  47.     private DriverConfigurazioneDBSoggettiLib() {}

  49.     private static String buildCrudSoggettoMessage(int type, int n) {
  50.         return "CRUDSoggetto type = " + type + " row affected =" + n;
  51.     }
  52.     
  53.     /**
  54.      * CRUD oggetto Soggetto Non si occupa di chiudere la connessione con
  55.      * il db in caso di errore in quanto verra' gestita dal metodo chiamante
  56.      * 
  57.      * @param type
  58.      *            Tipo operazione {1 (CREATE),2 (UPDATE),3 (DELETE)}
  59.      * @param soggetto
  60.      * @return L'ID dell'oggetto creato in caso di CREATE, altrimenti il numero
  61.      *         di righe che sono state modificate/cancellate
  62.      * @throws DriverConfigurazioneException
  63.      */
  64.     public static long CRUDSoggetto(int type, org.openspcoop2.core.config.Soggetto soggetto, Connection con) throws DriverConfigurazioneException {
  65.         if (soggetto == null)
  66.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB_LIB::CRUDSoggetto] Parametro non valido.");

  68.         String nome = soggetto.getNome();
  69.         String tipo = soggetto.getTipo();

  71.         if (nome == null || nome.equals(""))
  72.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB_LIB::CRUDSoggetto] Parametro Nome non valido.");
  73.         if (tipo == null || tipo.equals(""))
  74.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB_LIB::CRUDSoggetto] Parametro Tipo non valido.");

  76.         String descrizione = soggetto.getDescrizione();
  77.         String identificativoPorta = soggetto.getIdentificativoPorta();
  78.         String superuser = soggetto.getSuperUser();

  80.         boolean router = soggetto.getRouter();
  81.         boolean isDefault = soggetto.isDominioDefault();
  82.         
  83.         String pdUrlPrefixRewriter = soggetto.getPdUrlPrefixRewriter();
  84.         String paUrlPrefixRewriter = soggetto.getPaUrlPrefixRewriter();
  85.         
  86.         PreparedStatement updateStmt = null;
  87.         PreparedStatement selectStmt = null;
  88.         String updateQuery = "";
  89.         String selectQuery = "";
  90.         ResultSet selectRS = null;
  91.         int n = 0;
  92.         try {

  94.             // preparo lo statement in base al tipo di operazione
  95.             switch (type) {
  96.             case CREATE:
  97.                 // CREATE
  98.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  99.                 sqlQueryObject.addInsertTable(DriverConfigurazioneDBLib.tabellaSoggetti);
  100.                 sqlQueryObject.addInsertField("nome_soggetto", "?");
  101.                 sqlQueryObject.addInsertField("descrizione", "?");
  102.                 sqlQueryObject.addInsertField("identificativo_porta", "?");
  103.                 sqlQueryObject.addInsertField("tipo_soggetto", "?");
  104.                 sqlQueryObject.addInsertField("is_router", "?");
  105.                 sqlQueryObject.addInsertField("is_default", "?");
  106.                 sqlQueryObject.addInsertField("superuser", "?");
  107.                 sqlQueryObject.addInsertField("pd_url_prefix_rewriter", "?");
  108.                 sqlQueryObject.addInsertField("pa_url_prefix_rewriter", "?");
  109.                 updateQuery = sqlQueryObject.createSQLInsert();
  110.                 updateStmt = con.prepareStatement(updateQuery);

  112.                 int index = 1;
  113.                 updateStmt.setString(index++, nome);
  114.                 updateStmt.setString(index++, descrizione);
  115.                 updateStmt.setString(index++, identificativoPorta);
  116.                 updateStmt.setString(index++, tipo);
  117.                 updateStmt.setInt(index++, (router ? CostantiDB.TRUE : CostantiDB.FALSE));
  118.                 updateStmt.setInt(index++, (isDefault ? CostantiDB.TRUE : CostantiDB.FALSE));
  119.                 updateStmt.setString(index++, superuser);
  120.                 updateStmt.setString(index++, pdUrlPrefixRewriter);
  121.                 updateStmt.setString(index++, paUrlPrefixRewriter);
  122.                 // eseguo lo statement
  123.                 n = updateStmt.executeUpdate();

  125.                 DriverConfigurazioneDBLib.logDebug("CRUDSoggetto CREATE : \n" + DBUtils.formatSQLString(updateQuery, nome, descrizione, identificativoPorta, tipo, router, superuser));
  126.                 DriverConfigurazioneDBLib.logDebug(buildCrudSoggettoMessage(type, n));

  128.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  129.                 sqlQueryObject.addFromTable(DriverConfigurazioneDBLib.tabellaSoggetti);
  130.                 sqlQueryObject.addSelectField("id");
  131.                 sqlQueryObject.addWhereCondition("tipo_soggetto = ?");
  132.                 sqlQueryObject.addWhereCondition("nome_soggetto = ?");
  133.                 sqlQueryObject.setANDLogicOperator(true);
  134.                 selectQuery = sqlQueryObject.createSQLQuery();
  135.                 selectStmt = con.prepareStatement(selectQuery);
  136.                 selectStmt.setString(1, tipo);
  137.                 selectStmt.setString(2, nome);

  139.                 break;

  141.             case UPDATE:
  142.                 // UPDATE
  143.                 String oldNomeSoggetto = null;
  144.                 String oldTipoSoggetto = null;
  145.                 if(soggetto.getOldIDSoggettoForUpdate()!=null){
  146.                     oldNomeSoggetto = soggetto.getOldIDSoggettoForUpdate().getNome();
  147.                     oldTipoSoggetto = soggetto.getOldIDSoggettoForUpdate().getTipo();
  148.                 }
  149.                 // controllo se sono presenti i campi necessari per
  150.                 // l'aggiornamento
  151.                 if (oldNomeSoggetto == null || oldNomeSoggetto.equals(""))
  152.                     oldNomeSoggetto = nome;
  153.                 if (oldTipoSoggetto == null || oldTipoSoggetto.equals(""))
  154.                     oldTipoSoggetto = tipo;

  156.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  157.                 sqlQueryObject.addUpdateTable(DriverConfigurazioneDBLib.tabellaSoggetti);
  158.                 sqlQueryObject.addUpdateField("nome_soggetto", "?");
  159.                 sqlQueryObject.addUpdateField("descrizione", "?");
  160.                 sqlQueryObject.addUpdateField("identificativo_porta", "?");
  161.                 sqlQueryObject.addUpdateField("tipo_soggetto", "?");
  162.                 sqlQueryObject.addUpdateField("is_router", "?");
  163.                 sqlQueryObject.addUpdateField("is_default", "?");
  164.                 sqlQueryObject.addUpdateField("superuser", "?");
  165.                 sqlQueryObject.addUpdateField("pd_url_prefix_rewriter", "?");
  166.                 sqlQueryObject.addUpdateField("pa_url_prefix_rewriter", "?");
  167.                 sqlQueryObject.addWhereCondition("nome_soggetto=?");
  168.                 sqlQueryObject.addWhereCondition("tipo_soggetto=?");
  169.                 sqlQueryObject.setANDLogicOperator(true);
  170.                 updateQuery = sqlQueryObject.createSQLUpdate();
  171.                 updateStmt = con.prepareStatement(updateQuery);

  173.                 index = 1;
  174.                 updateStmt.setString(index++, nome);
  175.                 updateStmt.setString(index++, descrizione);
  176.                 updateStmt.setString(index++, identificativoPorta);
  177.                 updateStmt.setString(index++, tipo);
  178.                 updateStmt.setInt(index++, (router ? CostantiDB.TRUE : CostantiDB.FALSE));
  179.                 updateStmt.setInt(index++, (isDefault ? CostantiDB.TRUE : CostantiDB.FALSE));
  180.                 updateStmt.setString(index++, superuser);
  181.                 updateStmt.setString(index++, pdUrlPrefixRewriter);
  182.                 updateStmt.setString(index++, paUrlPrefixRewriter);
  183.                 updateStmt.setString(index++, oldNomeSoggetto);
  184.                 updateStmt.setString(index++, oldTipoSoggetto);
  185.                 // eseguo lo statement
  186.                 n = updateStmt.executeUpdate();
  187.                 updateStmt.close();

  189.                 DriverConfigurazioneDBLib.logDebug("CRUDSoggetto UPDATE : \n" + DBUtils.formatSQLString(updateQuery, nome, descrizione, identificativoPorta, tipo, router, soggetto.getId()));
  190.                 DriverConfigurazioneDBLib.logDebug(buildCrudSoggettoMessage(type, n));
  191.                 break;

  193.             case DELETE:
  194.                 // DELETE
  195.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  196.                 sqlQueryObject.addDeleteTable(DriverConfigurazioneDBLib.tabellaSoggetti);
  197.                 sqlQueryObject.addWhereCondition("nome_soggetto=?");
  198.                 sqlQueryObject.addWhereCondition("tipo_soggetto=?");
  199.                 sqlQueryObject.setANDLogicOperator(true);
  200.                 updateQuery = sqlQueryObject.createSQLDelete();
  201.                 updateStmt = con.prepareStatement(updateQuery);
  202.                 updateStmt.setString(1, soggetto.getNome());
  203.                 updateStmt.setString(2, soggetto.getTipo());
  204.                 n = updateStmt.executeUpdate();
  205.                 updateStmt.close();

  207.                 DriverConfigurazioneDBLib.logDebug(buildCrudSoggettoMessage(type, n));
  208.                 DriverConfigurazioneDBLib.logDebug("CRUDSoggetto DELETE : \n" + DBUtils.formatSQLString(updateQuery, soggetto.getNome(), soggetto.getTipo()));

  210.                 break;
  211.             default:
  212.                 break;
  213.             }

  215.             // in caso di create eseguo la select e ritorno l'id dell'oggetto
  216.             // creato
  217.             if (type == CostantiDB.CREATE &&
  218.                 selectStmt!=null) {
  219.                 selectRS = selectStmt.executeQuery();
  220.                 if (selectRS.next()) {
  221.                     soggetto.setId(selectRS.getLong("id"));
  222.                     return soggetto.getId();
  223.                 }
  224.             }

  226.             return n;

  228.         } catch (SQLException se) {
  229.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB_LIB::CRUDSoggetto] SQLException [" + se.getMessage() + "].",se);
  230.         }catch (Exception se) {
  231.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB_LIB::CRUDSoggetto] Exception [" + se.getMessage() + "].",se);
  232.         } finally {

  234.             JDBCUtilities.closeResources(selectRS, selectStmt);
  235.             JDBCUtilities.closeResources(updateStmt);
  236.             
  237.         }
  238.     }

  240.     
  241. }
Created with JaCoCo 0.8.8.202204050719