DriverControlStationDB_LIB.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.  */


  22. package org.openspcoop2.web.ctrlstat.driver;

  24. import static org.openspcoop2.core.constants.CostantiDB.CREATE;
  25. import static org.openspcoop2.core.constants.CostantiDB.DELETE;
  26. import static org.openspcoop2.core.constants.CostantiDB.UPDATE;

  28. import java.sql.Connection;
  29. import java.sql.PreparedStatement;
  30. import java.sql.ResultSet;
  31. import java.sql.SQLException;
  32. import java.sql.Timestamp;
  33. import java.text.MessageFormat;

  35. import org.openspcoop2.core.constants.CostantiDB;
  36. import org.openspcoop2.core.registry.constants.StatoFunzionalita;
  37. import org.openspcoop2.core.registry.driver.db.DriverRegistroServiziDB_LIB;
  38. import org.openspcoop2.utils.certificate.CertificateUtils;
  39. import org.openspcoop2.utils.certificate.PrincipalType;
  40. import org.openspcoop2.utils.sql.ISQLQueryObject;
  41. import org.openspcoop2.utils.sql.SQLObjectFactory;
  42. import org.openspcoop2.web.ctrlstat.dao.PdDControlStation;
  43. import org.slf4j.Logger;

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

  57.     private static Logger log = null;
  58.     public static void initialize(Logger logParam){
  59.         log = logParam;
  60.     }

  62.     // Tipo database ereditato da DriverControlStationDB
  63.     private static String tipoDB = null;

  65.     // Setto il tipoDB
  66.     public static void setTipoDB(String tipoDatabase) {
  67.         DriverControlStationDB_LIB.tipoDB = tipoDatabase;
  68.     }

  70.     public static void CRUDPdd(int type, PdDControlStation pdd, Connection con) throws DriverControlStationException {
  71.         if (pdd == null) {
  72.             throw new DriverControlStationException("[DriverControlStationDB_LIB::CRUDPdd] Parametro non valido.");
  73.         }

  75.         if ((type != CostantiDB.CREATE) && (pdd.getId() <= 0)) {
  76.             throw new DriverControlStationException("[DriverControlStationDB_LIB::CRUDPdd] ID Pdd non valido.");
  77.         }

  79.         String nome = pdd.getNome();
  80.         String descrizione = pdd.getDescrizione();

  82.         String ip = pdd.getIp();
  83.         int porta = pdd.getPorta();
  84.         String ipGestione = pdd.getIpGestione();
  85.         int portaGestione = pdd.getPortaGestione();
  86.         String protocollo = pdd.getProtocollo();
  87.         String protocolloGestione = pdd.getProtocolloGestione();

  89.         String tipo = pdd.getTipo();
  90.         String implementazione = pdd.getImplementazione();

  92.         String subject = pdd.getSubject();
  93.         String password = pdd.getPassword();
  94.         StatoFunzionalita client_auth = pdd.getClientAuth();

  96.         String superuser = pdd.getSuperUser();

  98.         PreparedStatement updateStmt = null;
  99.         String updateQuery = "";
  100.         PreparedStatement selectStmt = null;
  101.         String selectQuery = "";
  102.         ResultSet selectRS = null;
  103.         int n = 0;

  105.         try {

  107.             // preparo lo statement in base al tipo di operazione
  108.             switch (type) {
  109.                 case CREATE:
  110.                     // CREATE
  111.                     ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverControlStationDB_LIB.tipoDB);
  112.                     sqlQueryObject.addInsertTable(CostantiDB.PDD);
  113.                     sqlQueryObject.addInsertField("nome", "?");
  114.                     sqlQueryObject.addInsertField("descrizione", "?");
  115.                     sqlQueryObject.addInsertField("ip", "?");
  116.                     sqlQueryObject.addInsertField("porta", "?");
  117.                     sqlQueryObject.addInsertField("ip_gestione", "?");
  118.                     sqlQueryObject.addInsertField("porta_gestione", "?");
  119.                     sqlQueryObject.addInsertField("protocollo", "?");
  120.                     sqlQueryObject.addInsertField("protocollo_gestione", "?");
  121.                     sqlQueryObject.addInsertField("tipo", "?");
  122.                     sqlQueryObject.addInsertField("implementazione", "?");
  123.                     sqlQueryObject.addInsertField("subject", "?");
  124.                     sqlQueryObject.addInsertField("password", "?");
  125.                     sqlQueryObject.addInsertField("client_auth", "?");
  126.                     sqlQueryObject.addInsertField("superuser", "?");
  127.                     if (pdd.getOraRegistrazione() != null)
  128.                         sqlQueryObject.addInsertField("ora_registrazione", "?");

  130.                     updateQuery = sqlQueryObject.createSQLInsert();
  131.                     updateStmt = con.prepareStatement(updateQuery);

  133.                     int index = 1;
  134.                     updateStmt.setString(index++, nome);
  135.                     updateStmt.setString(index++, descrizione);
  136.                     updateStmt.setString(index++, ip);
  137.                     updateStmt.setInt(index++, porta);
  138.                     updateStmt.setString(index++, ipGestione);
  139.                     updateStmt.setInt(index++, portaGestione);
  140.                     updateStmt.setString(index++, protocollo);
  141.                     updateStmt.setString(index++, protocolloGestione);
  142.                     updateStmt.setString(index++, tipo);
  143.                     updateStmt.setString(index++, implementazione);
  144.                     updateStmt.setString(index++, (subject != null ? CertificateUtils.formatPrincipal(subject, PrincipalType.SUBJECT) : null));
  145.                     updateStmt.setString(index++, password);
  146.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(client_auth));
  147.                     updateStmt.setString(index++, superuser);
  148.                     if (pdd.getOraRegistrazione() != null)
  149.                         updateStmt.setTimestamp(index++, new Timestamp(pdd.getOraRegistrazione().getTime()));

  151.                     // eseguo lo statement
  152.                     n = updateStmt.executeUpdate();

  154.                     updateStmt.close();

  156.                     DriverControlStationDB_LIB.log.debug("CRUDPdd type = " + type + " row affected =" + n);

  158.                     DriverControlStationDB_LIB.log.debug("CRUDPdd CREATE : \n" + DriverControlStationDB_LIB.formatSQLString(updateQuery, nome, descrizione, ip, porta, ipGestione, portaGestione, protocollo, protocolloGestione, tipo, implementazione, subject, password, client_auth));

  160.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverControlStationDB_LIB.tipoDB);
  161.                     sqlQueryObject.addFromTable(CostantiDB.PDD);
  162.                     sqlQueryObject.addSelectField("id");
  163.                     sqlQueryObject.addWhereCondition("nome = ?");
  164.                     selectQuery = sqlQueryObject.createSQLQuery();
  165.                     selectStmt = con.prepareStatement(selectQuery);
  166.                     selectStmt.setString(1, nome);

  168.                     selectRS = selectStmt.executeQuery();
  169.                     if (selectRS.next()) {
  170.                         pdd.setId(selectRS.getLong("id"));
  171.                     }
  172.                     selectRS.close();
  173.                     selectStmt.close();
  174.                     break;

  176.                 case UPDATE:
  177.                     // UPDATE

  179.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverControlStationDB_LIB.tipoDB);
  180.                     sqlQueryObject.addUpdateTable(CostantiDB.PDD);
  181.                     sqlQueryObject.addUpdateField("descrizione", "?");
  182.                     sqlQueryObject.addUpdateField("ip", "?");
  183.                     sqlQueryObject.addUpdateField("porta", "?");
  184.                     sqlQueryObject.addUpdateField("ip_gestione", "?");
  185.                     sqlQueryObject.addUpdateField("porta_gestione", "?");
  186.                     sqlQueryObject.addUpdateField("protocollo", "?");
  187.                     sqlQueryObject.addUpdateField("protocollo_gestione", "?");
  188.                     sqlQueryObject.addUpdateField("tipo", "?");
  189.                     sqlQueryObject.addUpdateField("implementazione", "?");
  190.                     sqlQueryObject.addUpdateField("subject", "?");
  191.                     sqlQueryObject.addUpdateField("password", "?");
  192.                     sqlQueryObject.addUpdateField("client_auth", "?");
  193.                     sqlQueryObject.addUpdateField("superuser", "?");
  194.                     sqlQueryObject.addUpdateField("nome", "?");
  195.                     if (pdd.getOraRegistrazione() != null)
  196.                         sqlQueryObject.addUpdateField("ora_registrazione", "?");
  197.                     sqlQueryObject.addWhereCondition("id=?");
  198.                     updateQuery = sqlQueryObject.createSQLUpdate();
  199.                     updateStmt = con.prepareStatement(updateQuery);

  201.                     index = 1;
  202.                     updateStmt.setString(index++, descrizione);
  203.                     updateStmt.setString(index++, ip);
  204.                     updateStmt.setInt(index++, porta);
  205.                     updateStmt.setString(index++, ipGestione);
  206.                     updateStmt.setInt(index++, portaGestione);
  207.                     updateStmt.setString(index++, protocollo);
  208.                     updateStmt.setString(index++, protocolloGestione);
  209.                     updateStmt.setString(index++, tipo);
  210.                     updateStmt.setString(index++, implementazione);
  211.                     updateStmt.setString(index++, (subject != null ? CertificateUtils.formatPrincipal(subject, PrincipalType.SUBJECT) : null));
  212.                     updateStmt.setString(index++, password);
  213.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(client_auth));
  214.                     updateStmt.setString(index++, superuser);
  215.                     updateStmt.setString(index++, nome);
  216.                     if (pdd.getOraRegistrazione() != null)
  217.                         updateStmt.setTimestamp(index++, new Timestamp(pdd.getOraRegistrazione().getTime()));

  219.                     updateStmt.setLong(index++, pdd.getId());

  221.                     // eseguo lo statement
  222.                     n = updateStmt.executeUpdate();
  223.                     updateStmt.close();
  224.                     DriverControlStationDB_LIB.log.debug("CRUDPdd type = " + type + " row affected =" + n);

  226.                     DriverControlStationDB_LIB.log.debug("CRUDPdd UPDATE : \n" + DriverControlStationDB_LIB.formatSQLString(updateQuery, descrizione, ip, porta, ipGestione, portaGestione, protocollo, protocolloGestione, tipo, implementazione, subject, password, client_auth, pdd.getId()));

  228.                     break;

  230.                 case DELETE:
  231.                     // DELETE

  233.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverControlStationDB_LIB.tipoDB);
  234.                     sqlQueryObject.addDeleteTable(CostantiDB.PDD);
  235.                     sqlQueryObject.addWhereCondition("id=?");
  236.                     updateQuery = sqlQueryObject.createSQLDelete();
  237.                     updateStmt = con.prepareStatement(updateQuery);

  239.                     updateStmt.setLong(1, pdd.getId());

  241.                     // eseguo lo statement
  242.                     n = updateStmt.executeUpdate();
  243.                     updateStmt.close();
  244.                     DriverControlStationDB_LIB.log.debug("CRUDPdd type = " + type + " row affected =" + n);

  246.                     DriverControlStationDB_LIB.log.debug("CRUDPdd DELETE : \n" + DriverControlStationDB_LIB.formatSQLString(updateQuery, pdd.getId()));

  248.                     break;
  249.             }

  251.         } catch (SQLException se) {
  252.             throw new DriverControlStationException("[DriverControlStationDB_LIB::CRUDPdd] SQLException [" + se.getMessage() + "].");
  253.         } catch (Exception se) {
  254.             throw new DriverControlStationException("[DriverControlStationDB_LIB::CRUDPdd] Exception [" + se.getMessage() + "].");
  255.         } finally {

  257.             try {
  258.                 if(updateStmt!=null) {
  259.                     updateStmt.close();
  260.                 }
  261.             } catch (Exception e) {
  262.                 // ignore exception
  263.             }
  264.             try {
  265.                 if(selectRS!=null) {
  266.                     selectRS.close();
  267.                 }
  268.             } catch (Exception e) {
  269.                 // ignore exception
  270.             }
  271.             try {
  272.                 if(selectStmt!=null) {
  273.                     selectStmt.close();
  274.                 }
  275.             } catch (Exception e) {
  276.                 // ignore exception
  277.             }
  278.         }
  279.     }

  281.     /**
  282.      * Utility per formattare la string sql con i parametri passati, e stamparla
  283.      * per debug
  284.      * 
  285.      * @param sql
  286.      *            la string sql utilizzata nel prepared statement
  287.      * @param params
  288.      *            i parametri da inserire nella stringa che sostituiranno i '?'
  289.      * @return La stringa sql con al posto dei '?' ha i parametri passati
  290.      */
  291.     public static String formatSQLString(String sql, Object... params) {
  292.         String res = sql;

  294.         for (int i = 0; i < params.length; i++) {
  295.             res = res.replaceFirst("\\?", "{" + i + "}");
  296.         }

  298.         return MessageFormat.format(res, params);

  300.     }

  302. }
Created with JaCoCo 0.8.8.202204050719