DriverConfigurazioneDBUtils.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.Statement;

  28. import org.openspcoop2.core.commons.CoreException;
  29. import org.openspcoop2.core.config.ProprietaOggetto;
  30. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  31. import org.openspcoop2.core.constants.CostantiDB;
  32. import org.openspcoop2.utils.UtilsMultiException;
  33. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  34. import org.openspcoop2.utils.sql.ISQLQueryObject;
  35. import org.openspcoop2.utils.sql.SQLObjectFactory;

  37. /**
  38.  * DriverConfigurazioneDB_utilsDriver
  39.  * 
  40.  * 
  41.  * @author Sandra Giangrandi (sandra@link.it)
  42.  * @author Stefano Corallo (corallo@link.it)
  43.  * @author $Author$
  44.  * @version $Rev$, $Date$
  45.  */
  46. public class DriverConfigurazioneDBUtils {
  47.     
  48.     private DriverConfigurazioneDB driver = null;
  49.     
  50.     protected DriverConfigurazioneDBUtils(DriverConfigurazioneDB driver) {
  51.         this.driver = driver;
  52.     }
  53.     
  54.     protected void reset() throws DriverConfigurazioneException {
  55.         this.reset(true);
  56.     }
  57.     protected void reset(boolean resetConfigurazione) throws DriverConfigurazioneException{
  58.         Connection con = null;
  59.         boolean error = false;
  60.         PreparedStatement stmt=null;
  61.         String updateString;

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

  70.             }

  72.         } else
  73.             con = this.driver.globalConnection;

  75.         try {

  77.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  78.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_TOKEN_RUOLI);
  79.             updateString = sqlQueryObject.createSQLDelete();
  80.             stmt = con.prepareStatement(updateString);
  81.             stmt.executeUpdate();
  82.             stmt.close();
  83.             
  84.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  85.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_TOKEN_SA);
  86.             updateString = sqlQueryObject.createSQLDelete();
  87.             stmt = con.prepareStatement(updateString);
  88.             stmt.executeUpdate();
  89.             stmt.close();
  90.             
  91.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  92.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_ATTRIBUTE_AUTHORITY);
  93.             updateString = sqlQueryObject.createSQLDelete();
  94.             stmt = con.prepareStatement(updateString);
  95.             stmt.executeUpdate();
  96.             stmt.close();
  97.             
  98.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  99.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_HANDLERS);
  100.             updateString = sqlQueryObject.createSQLDelete();
  101.             stmt = con.prepareStatement(updateString);
  102.             stmt.executeUpdate();
  103.             stmt.close();
  104.             
  105.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  106.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_SA_AUTORIZZATI);
  107.             updateString = sqlQueryObject.createSQLDelete();
  108.             stmt = con.prepareStatement(updateString);
  109.             stmt.executeUpdate();
  110.             stmt.close();
  111.             
  112.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  113.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_SOGGETTI);
  114.             updateString = sqlQueryObject.createSQLDelete();
  115.             stmt = con.prepareStatement(updateString);
  116.             stmt.executeUpdate();
  117.             stmt.close();
  118.             
  119.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  120.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_RUOLI);
  121.             updateString = sqlQueryObject.createSQLDelete();
  122.             stmt = con.prepareStatement(updateString);
  123.             stmt.executeUpdate();
  124.             stmt.close();
  125.             
  126.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  127.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_SCOPE);
  128.             updateString = sqlQueryObject.createSQLDelete();
  129.             stmt = con.prepareStatement(updateString);
  130.             stmt.executeUpdate();
  131.             stmt.close();
  132.             
  133.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  134.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_AZIONI);
  135.             updateString = sqlQueryObject.createSQLDelete();
  136.             stmt = con.prepareStatement(updateString);
  137.             stmt.executeUpdate();
  138.             stmt.close();

  140.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  141.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_SA_PROPS);
  142.             updateString = sqlQueryObject.createSQLDelete();
  143.             stmt = con.prepareStatement(updateString);
  144.             stmt.executeUpdate();
  145.             stmt.close();
  146.             
  147.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  148.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_SA);
  149.             updateString = sqlQueryObject.createSQLDelete();
  150.             stmt = con.prepareStatement(updateString);
  151.             stmt.executeUpdate();
  152.             stmt.close();
  153.             
  154.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  155.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_BEHAVIOUR_PROPS);
  156.             updateString = sqlQueryObject.createSQLDelete();
  157.             stmt = con.prepareStatement(updateString);
  158.             stmt.executeUpdate();
  159.             stmt.close();

  161.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  162.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_AUTENTICAZIONE_PROP);
  163.             updateString = sqlQueryObject.createSQLDelete();
  164.             stmt = con.prepareStatement(updateString);
  165.             stmt.executeUpdate();
  166.             stmt.close();
  167.             
  168.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  169.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_AUTORIZZAZIONE_PROP);
  170.             updateString = sqlQueryObject.createSQLDelete();
  171.             stmt = con.prepareStatement(updateString);
  172.             stmt.executeUpdate();
  173.             stmt.close();
  174.             
  175.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  176.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_AUTORIZZAZIONE_CONTENUTI_PROP);
  177.             updateString = sqlQueryObject.createSQLDelete();
  178.             stmt = con.prepareStatement(updateString);
  179.             stmt.executeUpdate();
  180.             stmt.close();
  181.             
  182.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  183.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_RATE_LIMITING_PROP);
  184.             updateString = sqlQueryObject.createSQLDelete();
  185.             stmt = con.prepareStatement(updateString);
  186.             stmt.executeUpdate();
  187.             stmt.close();
  188.             
  189.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  190.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_PROP);
  191.             updateString = sqlQueryObject.createSQLDelete();
  192.             stmt = con.prepareStatement(updateString);
  193.             stmt.executeUpdate();
  194.             stmt.close();

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

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

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

  217.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  218.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_CORRELAZIONE_RISPOSTA);
  219.             updateString = sqlQueryObject.createSQLDelete();
  220.             stmt = con.prepareStatement(updateString);
  221.             stmt.executeUpdate();
  222.             stmt.close();
  223.             
  224.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  225.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_CACHE_REGOLE);
  226.             updateString = sqlQueryObject.createSQLDelete();
  227.             stmt = con.prepareStatement(updateString);
  228.             stmt.executeUpdate();
  229.             stmt.close();

  231.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  232.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTE_HEADER);
  233.             updateString = sqlQueryObject.createSQLDelete();
  234.             stmt = con.prepareStatement(updateString);
  235.             stmt.executeUpdate();
  236.             stmt.close();
  237.             
  238.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  239.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_RISPOSTE);
  240.             updateString = sqlQueryObject.createSQLDelete();
  241.             stmt = con.prepareStatement(updateString);
  242.             stmt.executeUpdate();
  243.             stmt.close();
  244.             
  245.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  246.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_HEADER);
  247.             updateString = sqlQueryObject.createSQLDelete();
  248.             stmt = con.prepareStatement(updateString);
  249.             stmt.executeUpdate();
  250.             stmt.close();
  251.             
  252.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  253.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_URL);
  254.             updateString = sqlQueryObject.createSQLDelete();
  255.             stmt = con.prepareStatement(updateString);
  256.             stmt.executeUpdate();
  257.             stmt.close();
  258.             
  259.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  260.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_SOGGETTI);
  261.             updateString = sqlQueryObject.createSQLDelete();
  262.             stmt = con.prepareStatement(updateString);
  263.             stmt.executeUpdate();
  264.             stmt.close();
  265.             
  266.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  267.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI_SA);
  268.             updateString = sqlQueryObject.createSQLDelete();
  269.             stmt = con.prepareStatement(updateString);
  270.             stmt.executeUpdate();
  271.             stmt.close();
  272.             
  273.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  274.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE_TRASFORMAZIONI);
  275.             updateString = sqlQueryObject.createSQLDelete();
  276.             stmt = con.prepareStatement(updateString);
  277.             stmt.executeUpdate();
  278.             stmt.close();

  280.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  281.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_APPLICATIVE);
  282.             updateString = sqlQueryObject.createSQLDelete();
  283.             stmt = con.prepareStatement(updateString);
  284.             stmt.executeUpdate();
  285.             stmt.close();

  287.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  288.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_TOKEN_RUOLI);
  289.             updateString = sqlQueryObject.createSQLDelete();
  290.             stmt = con.prepareStatement(updateString);
  291.             stmt.executeUpdate();
  292.             stmt.close();
  293.             
  294.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  295.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_TOKEN_SA);
  296.             updateString = sqlQueryObject.createSQLDelete();
  297.             stmt = con.prepareStatement(updateString);
  298.             stmt.executeUpdate();
  299.             stmt.close();
  300.             
  301.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  302.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_ATTRIBUTE_AUTHORITY);
  303.             updateString = sqlQueryObject.createSQLDelete();
  304.             stmt = con.prepareStatement(updateString);
  305.             stmt.executeUpdate();
  306.             stmt.close();
  307.             
  308.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  309.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_HANDLERS);
  310.             updateString = sqlQueryObject.createSQLDelete();
  311.             stmt = con.prepareStatement(updateString);
  312.             stmt.executeUpdate();
  313.             stmt.close();
  314.             
  315.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  316.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_RUOLI);
  317.             updateString = sqlQueryObject.createSQLDelete();
  318.             stmt = con.prepareStatement(updateString);
  319.             stmt.executeUpdate();
  320.             stmt.close();
  321.             
  322.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  323.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_SCOPE);
  324.             updateString = sqlQueryObject.createSQLDelete();
  325.             stmt = con.prepareStatement(updateString);
  326.             stmt.executeUpdate();
  327.             stmt.close();
  328.             
  329.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  330.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_AZIONI);
  331.             updateString = sqlQueryObject.createSQLDelete();
  332.             stmt = con.prepareStatement(updateString);
  333.             stmt.executeUpdate();
  334.             stmt.close();
  335.             
  336.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  337.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_SA);
  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_RATE_LIMITING_PROP);
  345.             updateString = sqlQueryObject.createSQLDelete();
  346.             stmt = con.prepareStatement(updateString);
  347.             stmt.executeUpdate();
  348.             stmt.close();
  349.             
  350.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  351.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_AUTORIZZAZIONE_CONTENUTI_PROP);
  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_AUTORIZZAZIONE_PROP);
  359.             updateString = sqlQueryObject.createSQLDelete();
  360.             stmt = con.prepareStatement(updateString);
  361.             stmt.executeUpdate();
  362.             stmt.close();
  363.             
  364.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  365.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_AUTENTICAZIONE_PROP);
  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_PROP);
  373.             updateString = sqlQueryObject.createSQLDelete();
  374.             stmt = con.prepareStatement(updateString);
  375.             stmt.executeUpdate();
  376.             stmt.close();
  377.             
  378.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  379.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_MESSAGE_SECURITY_REQUEST);
  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.PORTE_DELEGATE_MESSAGE_SECURITY_RESPONSE);
  387.             updateString = sqlQueryObject.createSQLDelete();
  388.             stmt = con.prepareStatement(updateString);
  389.             stmt.executeUpdate();
  390.             stmt.close();

  392.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  393.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_CORRELAZIONE);
  394.             updateString = sqlQueryObject.createSQLDelete();
  395.             stmt = con.prepareStatement(updateString);
  396.             stmt.executeUpdate();
  397.             stmt.close();

  399.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  400.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_CORRELAZIONE_RISPOSTA);
  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_CACHE_REGOLE);
  408.             updateString = sqlQueryObject.createSQLDelete();
  409.             stmt = con.prepareStatement(updateString);
  410.             stmt.executeUpdate();
  411.             stmt.close();

  413.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  414.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_RISPOSTE_HEADER);
  415.             updateString = sqlQueryObject.createSQLDelete();
  416.             stmt = con.prepareStatement(updateString);
  417.             stmt.executeUpdate();
  418.             stmt.close();
  419.             
  420.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  421.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_RISPOSTE);
  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_DELEGATE_TRASFORMAZIONI_HEADER);
  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_DELEGATE_TRASFORMAZIONI_URL);
  436.             updateString = sqlQueryObject.createSQLDelete();
  437.             stmt = con.prepareStatement(updateString);
  438.             stmt.executeUpdate();
  439.             stmt.close();
  440.             
  441.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  442.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE_TRASFORMAZIONI_SA);
  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.PORTE_DELEGATE_TRASFORMAZIONI);
  450.             updateString = sqlQueryObject.createSQLDelete();
  451.             stmt = con.prepareStatement(updateString);
  452.             stmt.executeUpdate();
  453.             stmt.close();
  454.             
  455.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  456.             sqlQueryObject.addDeleteTable(CostantiDB.PORTE_DELEGATE);
  457.             updateString = sqlQueryObject.createSQLDelete();
  458.             stmt = con.prepareStatement(updateString);
  459.             stmt.executeUpdate();
  460.             stmt.close();

  462.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  463.             sqlQueryObject.addDeleteTable(CostantiDB.SERVIZI_APPLICATIVI_CREDENZIALI);
  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.SERVIZI_APPLICATIVI_PROPS);
  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.SERVIZI_APPLICATIVI_RUOLI);
  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.SERVIZI_APPLICATIVI);
  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(this.driver.tabellaSoggetti);
  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.CONNETTORI_CUSTOM);
  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.CONNETTORI);
  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.GESTIONE_ERRORE_SOAP);
  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.GESTIONE_ERRORE_TRASPORTO);
  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.GESTIONE_ERRORE);
  527.             updateString = sqlQueryObject.createSQLDelete();
  528.             stmt = con.prepareStatement(updateString);
  529.             stmt.executeUpdate();
  530.             stmt.close();

  532.             if(resetConfigurazione){

  534.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  535.                 sqlQueryObject.addDeleteTable(CostantiDB.REGISTRI);
  536.                 updateString = sqlQueryObject.createSQLDelete();
  537.                 stmt = con.prepareStatement(updateString);
  538.                 stmt.executeUpdate();
  539.                 stmt.close();

  541.                 /* ROUTING DI DEFAULT */
  542.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  543.                 sqlQueryObject.addDeleteTable(CostantiDB.ROUTING);
  544.                 sqlQueryObject.addWhereCondition(true, true, "tiporotta='registro'", "registrorotta=0", "is_default=1");
  545.                 updateString = sqlQueryObject.createSQLDelete();
  546.                 stmt = con.prepareStatement(updateString);
  547.                 stmt.executeUpdate();
  548.                 stmt.close();

  550.                 /** NON DEVE ESSERE CANCELLATA!
  551.                 updateString = "DELETE FROM " + CostantiDB.CONFIGURAZIONE;
  552.                 stmt = con.prepareStatement(updateString);
  553.                 stmt.executeUpdate();
  554.                 stmt.close();
  555.                  */
  556.             }


  559.         } catch (Exception qe) {
  560.             error = true;
  561.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::updateSoggetto] Errore durante la reset : " + qe.getMessage(),qe);
  562.         }finally {

  564.             //Chiudo statement and resultset
  565.             JDBCUtilities.closeResources(stmt);

  567.             this.driver.closeConnection(error,con);
  568.         }
  569.     }

  571.     /**
  572.      * Reset delle tabelle del db govwayConsole gestito da questo driver
  573.      */
  574.     protected void resetCtrlstat() throws DriverConfigurazioneException {
  575.         Connection con = null;
  576.         boolean error = false;
  577.         PreparedStatement stmt=null;
  578.         String updateString;

  580.         if (this.driver.atomica) {
  581.             try {
  582.                 con = this.driver.getConnectionFromDatasource("resetCtrlstat");
  583.                 con.setAutoCommit(false);
  584.             } catch (Exception e) {
  585.                 throw new DriverConfigurazioneException("[DriverConfigurazioneDB::resetCtrlstat] Exception accedendo al datasource :" + e.getMessage(),e);

  587.             }

  589.         } else
  590.             con = this.driver.globalConnection;

  592.         try {
  593.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  594.             sqlQueryObject.addDeleteTable(CostantiDB.MAPPING_EROGAZIONE_PA);
  595.             updateString = sqlQueryObject.createSQLDelete();
  596.             stmt = con.prepareStatement(updateString);
  597.             stmt.executeUpdate();
  598.             stmt.close();

  600.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  601.             sqlQueryObject.addDeleteTable(CostantiDB.MAPPING_FRUIZIONE_PD);
  602.             updateString = sqlQueryObject.createSQLDelete();
  603.             stmt = con.prepareStatement(updateString);
  604.             stmt.executeUpdate();
  605.             stmt.close();

  607.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  608.             sqlQueryObject.addDeleteTable(CostantiDB.SERVIZI_FRUITORI);
  609.             updateString = sqlQueryObject.createSQLDelete();
  610.             stmt = con.prepareStatement(updateString);
  611.             stmt.executeUpdate();
  612.             stmt.close();

  614.             sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  615.             sqlQueryObject.addDeleteTable(CostantiDB.SERVIZI);
  616.             updateString = sqlQueryObject.createSQLDelete();
  617.             stmt = con.prepareStatement(updateString);
  618.             stmt.executeUpdate();
  619.             stmt.close();
  620.         } catch (Exception qe) {
  621.             error = true;
  622.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB::resetCtrlstat] Errore durante la reset : " + qe.getMessage(),qe);
  623.         }finally {

  625.             //Chiudo statement and resultset
  626.             JDBCUtilities.closeResources(stmt);

  628.             this.driver.closeConnection(error,con);
  629.         }
  630.     }
  631.     
  632.     protected void isAlive() throws CoreException{
  633.         if(!this.driver.create)
  634.             throw new CoreException("Driver non inizializzato");

  636.         if(this.driver.atomica){
  637.             // Verifico la connessione
  638.             Connection con = null;
  639.             Statement stmtTest = null;
  640.             try {
  641.                 con = this.driver.getConnectionFromDatasource("isAlive");
  642.                 if(con == null)
  643.                     throw new CoreException("Connessione is null");
  644.                 // test:
  645.                 try {
  646.                     stmtTest = con.createStatement();
  647.                     ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  648.                     sqlQueryObject.addFromTable(CostantiDB.DB_INFO_CONSOLE);
  649.                     sqlQueryObject.addSelectField("*");
  650.                     String sqlQuery = sqlQueryObject.createSQLQuery();
  651.                     stmtTest.execute(sqlQuery);
  652.                 }catch(Throwable t) {
  653.                     JDBCUtilities.closeResources(stmtTest);
  654.                     try {
  655.                         stmtTest = con.createStatement();
  656.                         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  657.                         sqlQueryObject.addFromTable(CostantiDB.DB_INFO);
  658.                         sqlQueryObject.addSelectField("*");
  659.                         String sqlQuery = sqlQueryObject.createSQLQuery();
  660.                         stmtTest.execute(sqlQuery);
  661.                     }catch(Throwable tInternal) {
  662.                         throw new UtilsMultiException(t,tInternal);
  663.                     }
  664.                 }
  665.             } catch (Exception e) {
  666.                 throw new CoreException("Connessione alla configurazione non disponibile: "+e.getMessage(),e);

  668.             }finally{
  669.                 JDBCUtilities.closeResources(stmtTest);
  670.                 try{
  671.                     JDBCUtilities.closeConnection(DriverConfigurazioneDB.getCheckLogger(), con, DriverConfigurazioneDB.isCheckAutocommit(), DriverConfigurazioneDB.isCheckIsClosed());
  672.                 }catch(Exception e){
  673.                     // close
  674.                 }
  675.             }
  676.         }else{
  677.             Statement stmtTest = null;
  678.             try {
  679.                 if(this.driver.globalConnection == null)
  680.                     throw new CoreException("Connessione is null");
  681.                 // test:
  682.                 try {
  683.                     stmtTest = this.driver.globalConnection.createStatement();
  684.                     ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  685.                     sqlQueryObject.addFromTable(CostantiDB.DB_INFO_CONSOLE);
  686.                     sqlQueryObject.addSelectField("*");
  687.                     String sqlQuery = sqlQueryObject.createSQLQuery();
  688.                     stmtTest.execute(sqlQuery);
  689.                 }catch(Throwable t) {
  690.                     JDBCUtilities.closeResources(stmtTest);
  691.                     try {
  692.                         stmtTest = this.driver.globalConnection.createStatement();
  693.                         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  694.                         sqlQueryObject.addFromTable(CostantiDB.DB_INFO);
  695.                         sqlQueryObject.addSelectField("*");
  696.                         String sqlQuery = sqlQueryObject.createSQLQuery();
  697.                         stmtTest.execute(sqlQuery);
  698.                     }catch(Throwable tInternal) {
  699.                         throw new UtilsMultiException(t,tInternal);
  700.                     }
  701.                 }
  702.             } catch (Exception e) {
  703.                 throw new CoreException("Connessione alla configurazione registro non disponibile: "+e.getMessage(),e);

  705.             }finally{
  706.                 JDBCUtilities.closeResources(stmtTest);
  707.             }
  708.         }
  709.     }
  710.     
  711.     
  712.     public ProprietaOggetto readProprietaOggetto(ResultSet rs, boolean useAlias) throws SQLException {
  713.         ProprietaOggetto p = null;
  714.         // Proprieta Oggetto
  715.         if(rs!=null) {
  716.             String utenteRichiedente = rs.getString(useAlias ? CostantiDB.PROPRIETA_OGGETTO_ALIAS_UTENTE_RICHIEDENTE : CostantiDB.PROPRIETA_OGGETTO_UTENTE_RICHIEDENTE);
  717.             java.util.Date dataCreazione  = rs.getTimestamp(useAlias ? CostantiDB.PROPRIETA_OGGETTO_ALIAS_DATA_CREAZIONE : CostantiDB.PROPRIETA_OGGETTO_DATA_CREAZIONE);
  718.             String utenteUltimaModifica = rs.getString(useAlias ? CostantiDB.PROPRIETA_OGGETTO_ALIAS_UTENTE_ULTIMA_MODIFICA : CostantiDB.PROPRIETA_OGGETTO_UTENTE_ULTIMA_MODIFICA);
  719.             java.util.Date dataUltimaModifica  = rs.getTimestamp(useAlias ? CostantiDB.PROPRIETA_OGGETTO_ALIAS_DATA_ULTIMA_MODIFICA : CostantiDB.PROPRIETA_OGGETTO_DATA_ULTIMA_MODIFICA);
  720.             if(utenteRichiedente!=null || dataCreazione!=null || utenteUltimaModifica!=null || dataUltimaModifica!=null) {
  721.                 p = new ProprietaOggetto();
  722.                 p.setUtenteRichiedente(utenteRichiedente);
  723.                 p.setDataCreazione(dataCreazione);
  724.                 p.setUtenteUltimaModifica(utenteUltimaModifica);
  725.                 p.setDataUltimaModifica(dataUltimaModifica);
  726.             }
  727.         }
  728.         return p;
  729.     }
  730. }
Created with JaCoCo 0.8.8.202204050719