DriverRegistroServiziDB_utilsDriver.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.PreparedStatement;
  27. import java.sql.ResultSet;
  28. import java.sql.SQLException;
  29. import java.sql.Statement;

  31. import org.openspcoop2.core.commons.CoreException;
  32. import org.openspcoop2.core.constants.CostantiDB;
  33. import org.openspcoop2.core.registry.ProprietaOggetto;
  34. import org.openspcoop2.core.registry.beans.ProprietaOggettoSintetico;
  35. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  36. import org.openspcoop2.utils.UtilsMultiException;
  37. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  38. import org.openspcoop2.utils.sql.ISQLQueryObject;
  39. import org.openspcoop2.utils.sql.SQLObjectFactory;

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

  52.     private DriverRegistroServiziDB driver = null;
  53.     
  54.     protected DriverRegistroServiziDB_utilsDriver(DriverRegistroServiziDB driver) {
  55.         this.driver = driver;
  56.     }
  57.     
  58.     protected void reset() throws DriverRegistroServiziException {

  60.         Connection con = null;
  61.         boolean error = false;
  62.         PreparedStatement stmt=null;
  63.         String updateString;

  65.         if (this.driver.atomica) {
  66.             try {
  67.                 con = this.driver.getConnectionFromDatasource("reset");
  68.                 con.setAutoCommit(false);
  69.             } catch (Exception e) {
  70.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::reset] Exception accedendo al datasource :" + e.getMessage(),e);

  72.             }

  74.         } else
  75.             con = this.driver.globalConnection;

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

  79.         try {

  81.             //Svuoto il db del registro servizi
  82.             
  83.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  84.             sqlQueryObject.addDeleteTable(CostantiDB.SERVIZI_FRUITORI_AZIONE);
  85.             updateString = sqlQueryObject.createSQLDelete();
  86.             stmt = con.prepareStatement(updateString);
  87.             stmt.executeUpdate();
  88.             stmt.close();
  89.             
  90.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  91.             sqlQueryObject.addDeleteTable(CostantiDB.SERVIZI_FRUITORI_AZIONI);
  92.             updateString = sqlQueryObject.createSQLDelete();
  93.             stmt = con.prepareStatement(updateString);
  94.             stmt.executeUpdate();
  95.             stmt.close();
  96.             
  97.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  98.             sqlQueryObject.addDeleteTable(CostantiDB.SERVIZI_FRUITORI);
  99.             updateString = sqlQueryObject.createSQLDelete();
  100.             stmt = con.prepareStatement(updateString);
  101.             stmt.executeUpdate();
  102.             stmt.close();

  104.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  105.             sqlQueryObject.addDeleteTable(CostantiDB.SERVIZI_AZIONE);
  106.             updateString = sqlQueryObject.createSQLDelete();
  107.             stmt = con.prepareStatement(updateString);
  108.             stmt.executeUpdate();
  109.             stmt.close();
  110.             
  111.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  112.             sqlQueryObject.addDeleteTable(CostantiDB.SERVIZI_AZIONI);
  113.             updateString = sqlQueryObject.createSQLDelete();
  114.             stmt = con.prepareStatement(updateString);
  115.             stmt.executeUpdate();
  116.             stmt.close();

  118.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  119.             sqlQueryObject.addDeleteTable(CostantiDB.PORT_TYPE_AZIONI_OPERATION_MESSAGES);
  120.             updateString = sqlQueryObject.createSQLDelete();
  121.             stmt = con.prepareStatement(updateString);
  122.             stmt.executeUpdate();
  123.             stmt.close();

  125.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  126.             sqlQueryObject.addDeleteTable(CostantiDB.PORT_TYPE_AZIONI);
  127.             updateString = sqlQueryObject.createSQLDelete();
  128.             stmt = con.prepareStatement(updateString);
  129.             stmt.executeUpdate();
  130.             stmt.close();

  132.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  133.             sqlQueryObject.addDeleteTable(CostantiDB.PORT_TYPE);
  134.             updateString = sqlQueryObject.createSQLDelete();
  135.             stmt = con.prepareStatement(updateString);
  136.             stmt.executeUpdate();
  137.             stmt.close();

  139.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  140.             sqlQueryObject.addDeleteTable(CostantiDB.ACCORDI_AZIONI);
  141.             updateString = sqlQueryObject.createSQLDelete();
  142.             stmt = con.prepareStatement(updateString);
  143.             stmt.executeUpdate();
  144.             stmt.close();
  145.             
  146.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  147.             sqlQueryObject.addDeleteTable(CostantiDB.API_RESOURCES_PARAMETER);
  148.             updateString = sqlQueryObject.createSQLDelete();
  149.             stmt = con.prepareStatement(updateString);
  150.             stmt.executeUpdate();
  151.             stmt.close();
  152.             
  153.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  154.             sqlQueryObject.addDeleteTable(CostantiDB.API_RESOURCES_MEDIA);
  155.             updateString = sqlQueryObject.createSQLDelete();
  156.             stmt = con.prepareStatement(updateString);
  157.             stmt.executeUpdate();
  158.             stmt.close();
  159.             
  160.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  161.             sqlQueryObject.addDeleteTable(CostantiDB.API_RESOURCES_RESPONSE);
  162.             updateString = sqlQueryObject.createSQLDelete();
  163.             stmt = con.prepareStatement(updateString);
  164.             stmt.executeUpdate();
  165.             stmt.close();
  166.             
  167.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  168.             sqlQueryObject.addDeleteTable(CostantiDB.API_RESOURCES);
  169.             updateString = sqlQueryObject.createSQLDelete();
  170.             stmt = con.prepareStatement(updateString);
  171.             stmt.executeUpdate();
  172.             stmt.close();

  174.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  175.             sqlQueryObject.addDeleteTable(CostantiDB.ACCORDI_COOPERAZIONE_PARTECIPANTI);
  176.             updateString = sqlQueryObject.createSQLDelete();
  177.             stmt = con.prepareStatement(updateString);
  178.             stmt.executeUpdate();
  179.             stmt.close();

  181.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  182.             sqlQueryObject.addDeleteTable(CostantiDB.ACCORDI_SERVIZI_COMPONENTI);
  183.             updateString = sqlQueryObject.createSQLDelete();
  184.             stmt = con.prepareStatement(updateString);
  185.             stmt.executeUpdate();
  186.             stmt.close();

  188.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  189.             sqlQueryObject.addDeleteTable(CostantiDB.ACCORDI_SERVIZI_COMPOSTO);
  190.             updateString = sqlQueryObject.createSQLDelete();
  191.             stmt = con.prepareStatement(updateString);
  192.             stmt.executeUpdate();
  193.             stmt.close();

  195.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  196.             sqlQueryObject.addDeleteTable(CostantiDB.SERVIZI);
  197.             updateString = sqlQueryObject.createSQLDelete();
  198.             stmt = con.prepareStatement(updateString);
  199.             stmt.executeUpdate();
  200.             stmt.close();

  202.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  203.             sqlQueryObject.addDeleteTable(CostantiDB.ACCORDI);
  204.             updateString = sqlQueryObject.createSQLDelete();
  205.             stmt = con.prepareStatement(updateString);
  206.             stmt.executeUpdate();
  207.             stmt.close();

  209.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  210.             sqlQueryObject.addDeleteTable(CostantiDB.ACCORDI_COOPERAZIONE);
  211.             updateString = sqlQueryObject.createSQLDelete();
  212.             stmt = con.prepareStatement(updateString);
  213.             stmt.executeUpdate();
  214.             stmt.close();

  216.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  217.             sqlQueryObject.addDeleteTable(CostantiDB.SOGGETTI_PROPS);
  218.             updateString = sqlQueryObject.createSQLDelete();
  219.             stmt = con.prepareStatement(updateString);
  220.             stmt.executeUpdate();
  221.             stmt.close();
  222.             
  223.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  224.             sqlQueryObject.addDeleteTable(CostantiDB.SOGGETTI_CREDENZIALI);
  225.             updateString = sqlQueryObject.createSQLDelete();
  226.             stmt = con.prepareStatement(updateString);
  227.             stmt.executeUpdate();
  228.             stmt.close();
  229.             
  230.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  231.             sqlQueryObject.addDeleteTable(CostantiDB.SOGGETTI_RUOLI);
  232.             updateString = sqlQueryObject.createSQLDelete();
  233.             stmt = con.prepareStatement(updateString);
  234.             stmt.executeUpdate();
  235.             stmt.close();
  236.             
  237.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  238.             sqlQueryObject.addDeleteTable(CostantiDB.SOGGETTI);
  239.             updateString = sqlQueryObject.createSQLDelete();
  240.             stmt = con.prepareStatement(updateString);
  241.             stmt.executeUpdate();
  242.             stmt.close();

  244.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  245.             sqlQueryObject.addDeleteTable(CostantiDB.CONNETTORI_CUSTOM);
  246.             updateString = sqlQueryObject.createSQLDelete();
  247.             stmt = con.prepareStatement(updateString);
  248.             stmt.executeUpdate();
  249.             stmt.close();

  251.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  252.             sqlQueryObject.addDeleteTable(CostantiDB.CONNETTORI);
  253.             updateString = sqlQueryObject.createSQLDelete();
  254.             stmt = con.prepareStatement(updateString);
  255.             stmt.executeUpdate();
  256.             stmt.close();

  258.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  259.             sqlQueryObject.addDeleteTable(CostantiDB.DOCUMENTI);
  260.             updateString = sqlQueryObject.createSQLDelete();
  261.             stmt = con.prepareStatement(updateString);
  262.             stmt.executeUpdate();
  263.             stmt.close();

  265.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  266.             sqlQueryObject.addDeleteTable(CostantiDB.RUOLI);
  267.             updateString = sqlQueryObject.createSQLDelete();
  268.             stmt = con.prepareStatement(updateString);
  269.             stmt.executeUpdate();
  270.             stmt.close();
  271.             
  272.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  273.             sqlQueryObject.addDeleteTable(CostantiDB.SCOPE);
  274.             updateString = sqlQueryObject.createSQLDelete();
  275.             stmt = con.prepareStatement(updateString);
  276.             stmt.executeUpdate();
  277.             stmt.close();
  278.             
  279.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  280.             sqlQueryObject.addDeleteTable(CostantiDB.PDD);
  281.             updateString = sqlQueryObject.createSQLDelete();
  282.             stmt = con.prepareStatement(updateString);
  283.             stmt.executeUpdate();
  284.             stmt.close();
  285.             
  286.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  287.             sqlQueryObject.addDeleteTable(CostantiDB.PROTOCOL_PROPERTIES);
  288.             updateString = sqlQueryObject.createSQLDelete();
  289.             stmt = con.prepareStatement(updateString);
  290.             stmt.executeUpdate();
  291.             stmt.close();

  293.         } catch (SQLException qe) {
  294.             error = true;
  295.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::reset] Errore durante il reset : " + qe.getMessage(),qe);
  296.         }catch (Exception qe) {
  297.             error = true;
  298.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::reset] Errore durante il reset : " + qe.getMessage(),qe);
  299.         } finally {

  301.             //Chiudo statement and resultset
  302.             JDBCUtilities.closeResources(stmt);

  304.             this.driver.closeConnection(error,con);
  305.         }
  306.     }

  308.     protected void resetCtrlstat() throws DriverRegistroServiziException {
  309.         Connection con = null;
  310.         boolean error = false;
  311.         PreparedStatement stmt=null;
  312.         String updateString;

  314.         if (this.driver.atomica) {
  315.             try {
  316.                 con = this.driver.getConnectionFromDatasource("resetCtrlstat");
  317.                 con.setAutoCommit(false);
  318.             } catch (Exception e) {
  319.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::resetCtrlstat] Exception accedendo al datasource :" + e.getMessage(),e);

  321.             }

  323.         } else
  324.             con = this.driver.globalConnection;

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

  328.         try {
  329.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  330.             sqlQueryObject.addDeleteTable(CostantiDB.MAPPING_EROGAZIONE_PA);
  331.             updateString = sqlQueryObject.createSQLDelete();
  332.             stmt = con.prepareStatement(updateString);
  333.             stmt.executeUpdate();
  334.             stmt.close();

  336.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  337.             sqlQueryObject.addDeleteTable(CostantiDB.MAPPING_FRUIZIONE_PD);
  338.             updateString = sqlQueryObject.createSQLDelete();
  339.             stmt = con.prepareStatement(updateString);
  340.             stmt.executeUpdate();
  341.             stmt.close();

  343.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  344.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_ATTRIBUTE_AUTHORITY);
  345.             updateString = sqlQueryObject.createSQLDelete();
  346.             stmt = con.prepareStatement(updateString);
  347.             stmt.executeUpdate();
  348.             stmt.close();

  350.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  351.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_ATTRIBUTE_AUTHORITY);
  352.             updateString = sqlQueryObject.createSQLDelete();
  353.             stmt = con.prepareStatement(updateString);
  354.             stmt.executeUpdate();
  355.             stmt.close();
  356.             
  357.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  358.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_RUOLI);
  359.             updateString = sqlQueryObject.createSQLDelete();
  360.             stmt = con.prepareStatement(updateString);
  361.             stmt.executeUpdate();
  362.             stmt.close();

  364.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  365.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_RUOLI);
  366.             updateString = sqlQueryObject.createSQLDelete();
  367.             stmt = con.prepareStatement(updateString);
  368.             stmt.executeUpdate();
  369.             stmt.close();
  370.             
  371.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  372.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_TOKEN_RUOLI);
  373.             updateString = sqlQueryObject.createSQLDelete();
  374.             stmt = con.prepareStatement(updateString);
  375.             stmt.executeUpdate();
  376.             stmt.close();

  378.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  379.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_TOKEN_RUOLI);
  380.             updateString = sqlQueryObject.createSQLDelete();
  381.             stmt = con.prepareStatement(updateString);
  382.             stmt.executeUpdate();
  383.             stmt.close();

  385.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  386.             sqlQueryObject.addDeleteTable(CostantiDB.SERVIZI_APPLICATIVI_CREDENZIALI);
  387.             updateString = sqlQueryObject.createSQLDelete();
  388.             stmt = con.prepareStatement(updateString);
  389.             stmt.executeUpdate();
  390.             stmt.close();
  391.             
  392.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  393.             sqlQueryObject.addDeleteTable(CostantiDB.SERVIZI_APPLICATIVI_PROPS);
  394.             updateString = sqlQueryObject.createSQLDelete();
  395.             stmt = con.prepareStatement(updateString);
  396.             stmt.executeUpdate();
  397.             stmt.close();
  398.             
  399.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  400.             sqlQueryObject.addDeleteTable(CostantiDB.SERVIZI_APPLICATIVI_RUOLI);
  401.             updateString = sqlQueryObject.createSQLDelete();
  402.             stmt = con.prepareStatement(updateString);
  403.             stmt.executeUpdate();
  404.             stmt.close();
  405.             
  406.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  407.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_TOKEN_SA);
  408.             updateString = sqlQueryObject.createSQLDelete();
  409.             stmt = con.prepareStatement(updateString);
  410.             stmt.executeUpdate();
  411.             stmt.close();
  412.             
  413.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  414.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_SA);
  415.             updateString = sqlQueryObject.createSQLDelete();
  416.             stmt = con.prepareStatement(updateString);
  417.             stmt.executeUpdate();
  418.             stmt.close();

  420.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  421.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_SA_PROPS);
  422.             updateString = sqlQueryObject.createSQLDelete();
  423.             stmt = con.prepareStatement(updateString);
  424.             stmt.executeUpdate();
  425.             stmt.close();
  426.             
  427.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  428.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_TOKEN_SA);
  429.             updateString = sqlQueryObject.createSQLDelete();
  430.             stmt = con.prepareStatement(updateString);
  431.             stmt.executeUpdate();
  432.             stmt.close();
  433.             
  434.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  435.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_SA);
  436.             updateString = sqlQueryObject.createSQLDelete();
  437.             stmt = con.prepareStatement(updateString);
  438.             stmt.executeUpdate();
  439.             stmt.close();

  441.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  442.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_BEHAVIOUR_PROPS);
  443.             updateString = sqlQueryObject.createSQLDelete();
  444.             stmt = con.prepareStatement(updateString);
  445.             stmt.executeUpdate();
  446.             stmt.close();
  447.             
  448.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  449.             sqlQueryObject.addDeleteTable(CostantiDB.SERVIZI_APPLICATIVI);
  450.             updateString = sqlQueryObject.createSQLDelete();
  451.             stmt = con.prepareStatement(updateString);
  452.             stmt.executeUpdate();
  453.             stmt.close();

  455.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  456.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_RATE_LIMITING_PROP);
  457.             updateString = sqlQueryObject.createSQLDelete();
  458.             stmt = con.prepareStatement(updateString);
  459.             stmt.executeUpdate();
  460.             stmt.close();
  461.             
  462.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  463.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_AUTORIZZAZIONE_CONTENUTI_PROP);
  464.             updateString = sqlQueryObject.createSQLDelete();
  465.             stmt = con.prepareStatement(updateString);
  466.             stmt.executeUpdate();
  467.             stmt.close();
  468.             
  469.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  470.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_AUTORIZZAZIONE_PROP);
  471.             updateString = sqlQueryObject.createSQLDelete();
  472.             stmt = con.prepareStatement(updateString);
  473.             stmt.executeUpdate();
  474.             stmt.close();
  475.             
  476.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  477.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_AUTENTICAZIONE_PROP);
  478.             updateString = sqlQueryObject.createSQLDelete();
  479.             stmt = con.prepareStatement(updateString);
  480.             stmt.executeUpdate();
  481.             stmt.close();
  482.             
  483.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  484.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_PROP);
  485.             updateString = sqlQueryObject.createSQLDelete();
  486.             stmt = con.prepareStatement(updateString);
  487.             stmt.executeUpdate();
  488.             stmt.close();

  490.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  491.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_MESSAGE_SECURITY_REQUEST);
  492.             updateString = sqlQueryObject.createSQLDelete();
  493.             stmt = con.prepareStatement(updateString);
  494.             stmt.executeUpdate();
  495.             stmt.close();

  497.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  498.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_MESSAGE_SECURITY_RESPONSE);
  499.             updateString = sqlQueryObject.createSQLDelete();
  500.             stmt = con.prepareStatement(updateString);
  501.             stmt.executeUpdate();
  502.             stmt.close();

  504.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  505.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_CORRELAZIONE);
  506.             updateString = sqlQueryObject.createSQLDelete();
  507.             stmt = con.prepareStatement(updateString);
  508.             stmt.executeUpdate();
  509.             stmt.close();

  511.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  512.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_CORRELAZIONE_RISPOSTA);
  513.             updateString = sqlQueryObject.createSQLDelete();
  514.             stmt = con.prepareStatement(updateString);
  515.             stmt.executeUpdate();
  516.             stmt.close();

  518.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  519.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_CACHE_REGOLE);
  520.             updateString = sqlQueryObject.createSQLDelete();
  521.             stmt = con.prepareStatement(updateString);
  522.             stmt.executeUpdate();
  523.             stmt.close();

  525.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  526.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTE_HEADER);
  527.             updateString = sqlQueryObject.createSQLDelete();
  528.             stmt = con.prepareStatement(updateString);
  529.             stmt.executeUpdate();
  530.             stmt.close();
  531.             
  532.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  533.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTE);
  534.             updateString = sqlQueryObject.createSQLDelete();
  535.             stmt = con.prepareStatement(updateString);
  536.             stmt.executeUpdate();
  537.             stmt.close();
  538.             
  539.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  540.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_HEADER);
  541.             updateString = sqlQueryObject.createSQLDelete();
  542.             stmt = con.prepareStatement(updateString);
  543.             stmt.executeUpdate();
  544.             stmt.close();
  545.             
  546.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  547.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_URL);
  548.             updateString = sqlQueryObject.createSQLDelete();
  549.             stmt = con.prepareStatement(updateString);
  550.             stmt.executeUpdate();
  551.             stmt.close();
  552.             
  553.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  554.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI);
  555.             updateString = sqlQueryObject.createSQLDelete();
  556.             stmt = con.prepareStatement(updateString);
  557.             stmt.executeUpdate();
  558.             stmt.close();
  559.             
  560.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  561.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE);
  562.             updateString = sqlQueryObject.createSQLDelete();
  563.             stmt = con.prepareStatement(updateString);
  564.             stmt.executeUpdate();
  565.             stmt.close();

  567.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  568.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_RATE_LIMITING_PROP);
  569.             updateString = sqlQueryObject.createSQLDelete();
  570.             stmt = con.prepareStatement(updateString);
  571.             stmt.executeUpdate();
  572.             stmt.close();
  573.             
  574.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  575.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_AUTORIZZAZIONE_CONTENUTI_PROP);
  576.             updateString = sqlQueryObject.createSQLDelete();
  577.             stmt = con.prepareStatement(updateString);
  578.             stmt.executeUpdate();
  579.             stmt.close();
  580.             
  581.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  582.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_AUTORIZZAZIONE_PROP);
  583.             updateString = sqlQueryObject.createSQLDelete();
  584.             stmt = con.prepareStatement(updateString);
  585.             stmt.executeUpdate();
  586.             stmt.close();
  587.             
  588.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  589.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_AUTENTICAZIONE_PROP);
  590.             updateString = sqlQueryObject.createSQLDelete();
  591.             stmt = con.prepareStatement(updateString);
  592.             stmt.executeUpdate();
  593.             stmt.close();
  594.             
  595.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  596.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_AUTENTICAZIONE_PROP);
  597.             updateString = sqlQueryObject.createSQLDelete();
  598.             stmt = con.prepareStatement(updateString);
  599.             stmt.executeUpdate();
  600.             stmt.close();
  601.             
  602.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  603.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_PROP);
  604.             updateString = sqlQueryObject.createSQLDelete();
  605.             stmt = con.prepareStatement(updateString);
  606.             stmt.executeUpdate();
  607.             stmt.close();
  608.             
  609.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  610.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_MESSAGE_SECURITY_REQUEST);
  611.             updateString = sqlQueryObject.createSQLDelete();
  612.             stmt = con.prepareStatement(updateString);
  613.             stmt.executeUpdate();
  614.             stmt.close();

  616.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  617.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_MESSAGE_SECURITY_RESPONSE);
  618.             updateString = sqlQueryObject.createSQLDelete();
  619.             stmt = con.prepareStatement(updateString);
  620.             stmt.executeUpdate();
  621.             stmt.close();

  623.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  624.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_CORRELAZIONE);
  625.             updateString = sqlQueryObject.createSQLDelete();
  626.             stmt = con.prepareStatement(updateString);
  627.             stmt.executeUpdate();
  628.             stmt.close();

  630.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  631.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_CORRELAZIONE_RISPOSTA);
  632.             updateString = sqlQueryObject.createSQLDelete();
  633.             stmt = con.prepareStatement(updateString);
  634.             stmt.executeUpdate();
  635.             stmt.close();

  637.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  638.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_CACHE_REGOLE);
  639.             updateString = sqlQueryObject.createSQLDelete();
  640.             stmt = con.prepareStatement(updateString);
  641.             stmt.executeUpdate();
  642.             stmt.close();

  644.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  645.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_RISPOSTE_HEADER);
  646.             updateString = sqlQueryObject.createSQLDelete();
  647.             stmt = con.prepareStatement(updateString);
  648.             stmt.executeUpdate();
  649.             stmt.close();
  650.             
  651.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  652.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_RISPOSTE);
  653.             updateString = sqlQueryObject.createSQLDelete();
  654.             stmt = con.prepareStatement(updateString);
  655.             stmt.executeUpdate();
  656.             stmt.close();
  657.             
  658.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  659.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_HEADER);
  660.             updateString = sqlQueryObject.createSQLDelete();
  661.             stmt = con.prepareStatement(updateString);
  662.             stmt.executeUpdate();
  663.             stmt.close();
  664.             
  665.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  666.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_URL);
  667.             updateString = sqlQueryObject.createSQLDelete();
  668.             stmt = con.prepareStatement(updateString);
  669.             stmt.executeUpdate();
  670.             stmt.close();
  671.             
  672.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  673.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI);
  674.             updateString = sqlQueryObject.createSQLDelete();
  675.             stmt = con.prepareStatement(updateString);
  676.             stmt.executeUpdate();
  677.             stmt.close();
  678.             
  679.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  680.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE);
  681.             updateString = sqlQueryObject.createSQLDelete();
  682.             stmt = con.prepareStatement(updateString);
  683.             stmt.executeUpdate();
  684.             stmt.close();
  685.             
  686.         } catch (SQLException qe) {
  687.             error = true;
  688.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::resetCtrlstat] Errore durante la reset : " + qe.getMessage(),qe);
  689.         }catch (Exception qe) {
  690.             error = true;
  691.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::resetCtrlstat] Errore durante la reset : " + qe.getMessage(),qe);
  692.         }finally {

  694.             //Chiudo statement and resultset
  695.             JDBCUtilities.closeResources(stmt);

  697.             this.driver.closeConnection(error,con);
  698.         }
  699.     }
  700.     
  701.     protected void isAlive() throws CoreException{

  703.         if(this.driver.create==false)
  704.             throw new CoreException("Driver non inizializzato");

  706.         if(this.driver.atomica){
  707.             // Verifico la connessione
  708.             Connection con = null;
  709.             Statement stmtTest = null;
  710.             try {
  711.                 con = this.driver.getConnectionFromDatasource("isAlive");
  712.                 if(con == null)
  713.                     throw new Exception("Connessione is null");
  714.                 // test:
  715.                 try {
  716.                     stmtTest = con.createStatement();
  717.                     ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  718.                     sqlQueryObject.addFromTable(CostantiDB.DB_INFO_CONSOLE);
  719.                     sqlQueryObject.addSelectField("*");
  720.                     String sqlQuery = sqlQueryObject.createSQLQuery();
  721.                     stmtTest.execute(sqlQuery);
  722.                 }catch(Throwable t) {
  723.                     JDBCUtilities.closeResources(stmtTest);
  724.                     try {
  725.                         stmtTest = con.createStatement();
  726.                         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  727.                         sqlQueryObject.addFromTable(CostantiDB.DB_INFO);
  728.                         sqlQueryObject.addSelectField("*");
  729.                         String sqlQuery = sqlQueryObject.createSQLQuery();
  730.                         stmtTest.execute(sqlQuery);
  731.                     }catch(Throwable tInternal) {
  732.                         throw new UtilsMultiException(t,tInternal);
  733.                     }
  734.                 }
  735.             } catch (Exception e) {
  736.                 throw new CoreException("Connessione al registro non disponibile: "+e.getMessage(),e);

  738.             }finally{
  739.                 JDBCUtilities.closeResources(stmtTest);
  740.                 try{
  741.                     JDBCUtilities.closeConnection(DriverRegistroServiziDB.getCheckLogger(), con, DriverRegistroServiziDB.isCheckAutocommit(), DriverRegistroServiziDB.isCheckIsClosed());
  742.                 }catch(Exception e){
  743.                     // close
  744.                 }
  745.             }
  746.         }else{
  747.             Statement stmtTest = null;
  748.             try {
  749.                 if(this.driver.globalConnection == null)
  750.                     throw new Exception("Connessione is null");
  751.                 // test:
  752.                 try {
  753.                     stmtTest = this.driver.globalConnection.createStatement();
  754.                     ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  755.                     sqlQueryObject.addFromTable(CostantiDB.DB_INFO_CONSOLE);
  756.                     sqlQueryObject.addSelectField("*");
  757.                     String sqlQuery = sqlQueryObject.createSQLQuery();
  758.                     stmtTest.execute(sqlQuery);
  759.                 }catch(Throwable t) {
  760.                     JDBCUtilities.closeResources(stmtTest);
  761.                     try {
  762.                         stmtTest = this.driver.globalConnection.createStatement();
  763.                         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  764.                         sqlQueryObject.addFromTable(CostantiDB.DB_INFO);
  765.                         sqlQueryObject.addSelectField("*");
  766.                         String sqlQuery = sqlQueryObject.createSQLQuery();
  767.                         stmtTest.execute(sqlQuery);
  768.                     }catch(Throwable tInternal) {
  769.                         throw new UtilsMultiException(t,tInternal);
  770.                     }
  771.                 }
  772.             } catch (Exception e) {
  773.                 throw new CoreException("Connessione al registro non disponibile: "+e.getMessage(),e);

  775.             }finally{
  776.                 JDBCUtilities.closeResources(stmtTest);
  777.             }
  778.         }
  779.     }
  780.     
  781.     public static ProprietaOggetto readProprietaOggetto(ResultSet rs, boolean useAlias) throws SQLException {
  782.         ProprietaOggetto p = null;
  783.         // Proprieta Oggetto
  784.         if(rs!=null) {
  785.             String utenteRichiedente = rs.getString(useAlias ? CostantiDB.PROPRIETA_OGGETTO_ALIAS_UTENTE_RICHIEDENTE : CostantiDB.PROPRIETA_OGGETTO_UTENTE_RICHIEDENTE);
  786.             java.util.Date dataCreazione  = rs.getTimestamp(useAlias ? CostantiDB.PROPRIETA_OGGETTO_ALIAS_DATA_CREAZIONE : CostantiDB.PROPRIETA_OGGETTO_DATA_CREAZIONE);
  787.             String utenteUltimaModifica = rs.getString(useAlias ? CostantiDB.PROPRIETA_OGGETTO_ALIAS_UTENTE_ULTIMA_MODIFICA : CostantiDB.PROPRIETA_OGGETTO_UTENTE_ULTIMA_MODIFICA);
  788.             java.util.Date dataUltimaModifica  = rs.getTimestamp(useAlias ? CostantiDB.PROPRIETA_OGGETTO_ALIAS_DATA_ULTIMA_MODIFICA : CostantiDB.PROPRIETA_OGGETTO_DATA_ULTIMA_MODIFICA);
  789.             if(utenteRichiedente!=null || dataCreazione!=null || utenteUltimaModifica!=null || dataUltimaModifica!=null) {
  790.                 p = new ProprietaOggetto();
  791.                 p.setUtenteRichiedente(utenteRichiedente);
  792.                 p.setDataCreazione(dataCreazione);
  793.                 p.setUtenteUltimaModifica(utenteUltimaModifica);
  794.                 p.setDataUltimaModifica(dataUltimaModifica);
  795.             }
  796.         }
  797.         return p;
  798.     }
  799.     
  800.     public static ProprietaOggettoSintetico readProprietaOggettoSintetico(ResultSet rs, boolean useAlias) throws SQLException {
  801.         ProprietaOggettoSintetico p = null;
  802.         // Proprieta Oggetto
  803.         if(rs!=null) {
  804.             String utenteRichiedente = rs.getString(useAlias ? CostantiDB.PROPRIETA_OGGETTO_ALIAS_UTENTE_RICHIEDENTE : CostantiDB.PROPRIETA_OGGETTO_UTENTE_RICHIEDENTE);
  805.             java.util.Date dataCreazione  = rs.getTimestamp(useAlias ? CostantiDB.PROPRIETA_OGGETTO_ALIAS_DATA_CREAZIONE : CostantiDB.PROPRIETA_OGGETTO_DATA_CREAZIONE);
  806.             String utenteUltimaModifica = rs.getString(useAlias ? CostantiDB.PROPRIETA_OGGETTO_ALIAS_UTENTE_ULTIMA_MODIFICA : CostantiDB.PROPRIETA_OGGETTO_UTENTE_ULTIMA_MODIFICA);
  807.             java.util.Date dataUltimaModifica  = rs.getTimestamp(useAlias ? CostantiDB.PROPRIETA_OGGETTO_ALIAS_DATA_ULTIMA_MODIFICA : CostantiDB.PROPRIETA_OGGETTO_DATA_ULTIMA_MODIFICA);
  808.             if(utenteRichiedente!=null || dataCreazione!=null || utenteUltimaModifica!=null || dataUltimaModifica!=null) {
  809.                 p = new ProprietaOggettoSintetico();
  810.                 p.setUtenteRichiedente(utenteRichiedente);
  811.                 p.setDataCreazione(dataCreazione);
  812.                 p.setUtenteUltimaModifica(utenteUltimaModifica);
  813.                 p.setDataUltimaModifica(dataUltimaModifica);
  814.             }
  815.         }
  816.         return p;
  817.     }
  818. }
Created with JaCoCo 0.8.8.202204050719