DriverConfigurazioneDB_routingTableLIB.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it). 
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */
  20. package org.openspcoop2.core.config.driver.db;

  22. import static org.openspcoop2.core.constants.CostantiDB.CREATE;

  24. import java.sql.Connection;
  25. import java.sql.PreparedStatement;
  26. import java.sql.ResultSet;
  27. import java.sql.SQLException;

  29. import org.openspcoop2.core.commons.DBUtils;
  30. import org.openspcoop2.core.config.Route;
  31. import org.openspcoop2.core.config.RouteGateway;
  32. import org.openspcoop2.core.config.RouteRegistro;
  33. import org.openspcoop2.core.config.RoutingTable;
  34. import org.openspcoop2.core.config.RoutingTableDefault;
  35. import org.openspcoop2.core.config.RoutingTableDestinazione;
  36. import org.openspcoop2.core.config.constants.CostantiConfigurazione;
  37. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  38. import org.openspcoop2.core.constants.CostantiDB;
  39. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  40. import org.openspcoop2.utils.sql.ISQLQueryObject;
  41. import org.openspcoop2.utils.sql.SQLObjectFactory;

  43. /**
  44.  * DriverConfigurazioneDB_routingTableLIB
  45.  * 
  46.  * @author Stefano Corallo - corallo@link.it
  47.  * @author $Author$
  48.  * @version $Rev$, $Date$
  49.  */
  50. public class DriverConfigurazioneDB_routingTableLIB {

  52.     public static void CRUDRoutingTable(int type, RoutingTable aRT, Connection con) throws DriverConfigurazioneException {
  53.         PreparedStatement updateStmt = null;
  54.         PreparedStatement insertStmt = null;
  55.         PreparedStatement updateStmtSelectRegistri = null;
  56.         ResultSet rsSelectRegistri = null;
  57.         String updateQuery = "";

  59.         int i = 0;

  61.         RoutingTableDestinazione rtd = null;
  62.         Route route = null;
  63.         RouteGateway gw = null;
  64.         RouteRegistro rg = null;
  65.         String tipo = null;
  66.         String nome = null;
  67.         long idRoute = 0;

  69.         try {

  71.             switch (type) {
  72.             case CREATE:

  74.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  75.                 sqlQueryObject.addUpdateTable(CostantiDB.CONFIGURAZIONE);
  76.                 sqlQueryObject.addUpdateField("routing_enabled", "?");
  77.                 updateQuery = sqlQueryObject.createSQLUpdate();
  78.                 updateStmt = con.prepareStatement(updateQuery);
  79.                 if(aRT.getAbilitata()!=null && aRT.getAbilitata())
  80.                     updateStmt.setString(1, CostantiConfigurazione.ABILITATO.toString());
  81.                 else
  82.                     updateStmt.setString(1, CostantiConfigurazione.DISABILITATO.toString());
  83.                 DriverConfigurazioneDBLib.log.debug("eseguo query :" + DBUtils.formatSQLString(updateQuery, (aRT.getAbilitata()!=null && aRT.getAbilitata())));
  84.                 updateStmt.executeUpdate();
  85.                 updateStmt.close();

  87.                 // CREATE
  88.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  89.                 sqlQueryObject.addInsertTable(CostantiDB.ROUTING);
  90.                 sqlQueryObject.addInsertField("tipo", "?");
  91.                 sqlQueryObject.addInsertField("nome", "?");
  92.                 sqlQueryObject.addInsertField("tiporotta", "?");
  93.                 sqlQueryObject.addInsertField("tiposoggrotta", "?");
  94.                 sqlQueryObject.addInsertField("nomesoggrotta", "?");
  95.                 sqlQueryObject.addInsertField("registrorotta", "?");
  96.                 sqlQueryObject.addInsertField("is_default", "?");
  97.                 updateQuery = sqlQueryObject.createSQLInsert();

  99.                 i = 0;
  100.                 if(aRT.getDefault()!=null){
  101.                     RoutingTableDefault rtDefault = aRT.getDefault();
  102.                     for (i = 0; i < rtDefault.sizeRouteList(); i++) {
  103.                         route = rtDefault.getRoute(i);
  104.     
  105.                         gw = route.getGateway();// rotta gateway
  106.                         rg = route.getRegistro();// rotta registro
  107.     
  108.                         updateStmt = con.prepareStatement(updateQuery);
  109.     
  110.                         updateStmt.setString(1, null);// nn ho tipo
  111.                         updateStmt.setString(2, null);// nn ho nome
  112.                         updateStmt.setString(3, (gw != null ? "gateway" : "registro"));
  113.                         updateStmt.setString(4, (gw != null ? gw.getTipo() : null));// se
  114.                         // rotta
  115.                         // gateway
  116.                         // setto
  117.                         // tiposoggrotta
  118.                         updateStmt.setString(5, (gw != null ? gw.getNome() : null));// se
  119.                         // rotta
  120.                         // gateway
  121.                         // setto
  122.                         // nomesoggrotta
  123.                         long registroRotta = 0;
  124.                         if(rg!=null){
  125.                             if(rg.getId()<=0){
  126.                                 if(rg.getNome()!=null && ("".equals(rg.getNome())==false)){
  127.                                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  128.                                     sqlQueryObject.addFromTable(CostantiDB.REGISTRI);
  129.                                     sqlQueryObject.addSelectField("id");
  130.                                     sqlQueryObject.addWhereCondition("nome = ?");
  131.                                     String selectQuery = sqlQueryObject.createSQLQuery();
  132.                                     updateStmtSelectRegistri = con.prepareStatement(selectQuery);
  133.                                     updateStmtSelectRegistri.setString(1, rg.getNome());
  134.                                     rsSelectRegistri = updateStmtSelectRegistri.executeQuery();
  135.                                     if(rsSelectRegistri!=null && rsSelectRegistri.next()){
  136.                                         registroRotta = rsSelectRegistri.getLong("id");
  137.                                     }
  138.                                     if(rsSelectRegistri!=null) {
  139.                                         rsSelectRegistri.close();
  140.                                     }
  141.                                     updateStmtSelectRegistri.close();
  142.                                 }
  143.                             }
  144.                         }
  145.                         updateStmt.setLong(6, registroRotta);
  146.     
  147.                         updateStmt.setInt(7, CostantiDB.TRUE);
  148.     
  149.                         updateStmt.executeUpdate();
  150.                         updateStmt.close();
  151.                     }
  152.                 }

  154.                 DriverConfigurazioneDBLib.log.debug("Inserted " + i + " Default route.");

  156.                 for (i = 0; i < aRT.sizeDestinazioneList(); i++) {
  157.                     rtd = aRT.getDestinazione(i);
  158.                     nome = rtd.getNome();
  159.                     tipo = rtd.getTipo();

  161.                     for (int j = 0; j < rtd.sizeRouteList(); j++) {
  162.                         route = rtd.getRoute(j);
  163.                         gw = route.getGateway();// rotta gateway
  164.                         rg = route.getRegistro();// rotta registro

  166.                         updateStmt = con.prepareStatement(updateQuery);

  168.                         updateStmt.setString(1, tipo);
  169.                         updateStmt.setString(2, nome);
  170.                         updateStmt.setString(3, (gw != null ? "gateway" : "registro"));
  171.                         updateStmt.setString(4, (gw != null ? gw.getTipo() : null));// se
  172.                         // rotta
  173.                         // gateway
  174.                         // setto
  175.                         // tiposoggrotta
  176.                         updateStmt.setString(5, (gw != null ? gw.getNome() : null));// se
  177.                         // rotta
  178.                         // gateway
  179.                         // setto
  180.                         // nomesoggrotta
  181.                         long registroRotta = 0;
  182.                         if(rg!=null){
  183.                             if(rg.getId()<=0){
  184.                                 if(rg.getNome()!=null && ("".equals(rg.getNome())==false)){
  185.                                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  186.                                     sqlQueryObject.addFromTable(CostantiDB.REGISTRI);
  187.                                     sqlQueryObject.addSelectField("id");
  188.                                     sqlQueryObject.addWhereCondition("nome = ?");
  189.                                     String selectQuery = sqlQueryObject.createSQLQuery();
  190.                                     updateStmtSelectRegistri = con.prepareStatement(selectQuery);
  191.                                     updateStmtSelectRegistri.setString(1, rg.getNome());
  192.                                     rsSelectRegistri = updateStmtSelectRegistri.executeQuery();
  193.                                     if(rsSelectRegistri!=null && rsSelectRegistri.next()){
  194.                                         registroRotta = rsSelectRegistri.getLong("id");
  195.                                     }
  196.                                     rsSelectRegistri.close();
  197.                                     updateStmtSelectRegistri.close();
  198.                                 }
  199.                             }
  200.                         }
  201.                         updateStmt.setLong(6, registroRotta);

  203.                         updateStmt.setInt(7, CostantiDB.FALSE);

  205.                         updateStmt.executeUpdate();
  206.                         updateStmt.close();
  207.                     }
  208.                 }

  210.                 DriverConfigurazioneDBLib.log.debug("Inserted " + i + " Destination route.");

  212.                 break;

  214.             case 2:
  215.                 // UPDATE

  217.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  218.                 sqlQueryObject.addUpdateTable(CostantiDB.CONFIGURAZIONE);
  219.                 sqlQueryObject.addUpdateField("routing_enabled", "?");
  220.                 updateQuery = sqlQueryObject.createSQLUpdate();
  221.                 updateStmt = con.prepareStatement(updateQuery);
  222.                 if(aRT.getAbilitata()!=null && aRT.getAbilitata())
  223.                     updateStmt.setString(1, CostantiConfigurazione.ABILITATO.toString());
  224.                 else
  225.                     updateStmt.setString(1, CostantiConfigurazione.DISABILITATO.toString());
  226.                 DriverConfigurazioneDBLib.log.debug("eseguo query :" + DBUtils.formatSQLString(updateQuery, aRT.getAbilitata()!=null && aRT.getAbilitata()));
  227.                 updateStmt.executeUpdate();
  228.                 updateStmt.close();

  230.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  231.                 sqlQueryObject.addUpdateTable(CostantiDB.ROUTING);
  232.                 sqlQueryObject.addUpdateField("tipo", "?");
  233.                 sqlQueryObject.addUpdateField("nome", "?");
  234.                 sqlQueryObject.addUpdateField("tiporotta", "?");
  235.                 sqlQueryObject.addUpdateField("tiposoggrotta", "?");
  236.                 sqlQueryObject.addUpdateField("nomesoggrotta", "?");
  237.                 sqlQueryObject.addUpdateField("registrorotta", "?");
  238.                 sqlQueryObject.addUpdateField("is_default", "?");
  239.                 sqlQueryObject.addWhereCondition("id = ?");
  240.                 updateQuery = sqlQueryObject.createSQLUpdate();

  242.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  243.                 sqlQueryObject.addInsertTable(CostantiDB.ROUTING);
  244.                 sqlQueryObject.addInsertField("tipo", "?");
  245.                 sqlQueryObject.addInsertField("nome", "?");
  246.                 sqlQueryObject.addInsertField("tiporotta", "?");
  247.                 sqlQueryObject.addInsertField("tiposoggrotta", "?");
  248.                 sqlQueryObject.addInsertField("nomesoggrotta", "?");
  249.                 sqlQueryObject.addInsertField("registrorotta", "?");
  250.                 sqlQueryObject.addInsertField("is_default", "?");
  251.                 String insertQuery = sqlQueryObject.createSQLInsert();

  253.                 /**
  254.                  * La lista contiene tutte e sole le entry necessarie
  255.                  */
  256.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  257.                 sqlQueryObject.setANDLogicOperator(true);
  258.                 sqlQueryObject.addDeleteTable(CostantiDB.ROUTING);
  259.                 //sqlQueryObject.addWhereCondition("is_default<>?");//cancello le rotte non di default
  260.                 String queryDelete = sqlQueryObject.createSQLDelete();
  261.                 DriverConfigurazioneDBLib.log.debug("DELETING Destination Route : "+queryDelete);
  262.                 updateStmt = con.prepareStatement(queryDelete);
  263.                 //updateStmt.setInt(1, CostantiDB.TRUE);
  264.                 int n = updateStmt.executeUpdate();
  265.                 updateStmt.close();
  266.                 DriverConfigurazioneDBLib.log.debug("Deleted " + n + " Destination route.");

  268.                 i = 0;
  269.                 if(aRT.getDefault()!=null){
  270.                     RoutingTableDefault rtDefault = aRT.getDefault();
  271.                     for (i = 0; i < rtDefault.sizeRouteList(); i++) {
  272.                         route = rtDefault.getRoute(i);

  274.                         idRoute = route.getId();
  275.     
  276.                         gw = route.getGateway();// rotta gateway
  277.                         rg = route.getRegistro();// rotta registro
  278.     
  279.                         long registroRotta = 0;
  280.                         if(rg!=null){
  281.                             if(rg.getId()<=0){
  282.                                 if(rg.getNome()!=null && ("".equals(rg.getNome())==false)){
  283.                                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  284.                                     sqlQueryObject.addFromTable(CostantiDB.REGISTRI);
  285.                                     sqlQueryObject.addSelectField("id");
  286.                                     sqlQueryObject.addWhereCondition("nome = ?");
  287.                                     String selectQuery = sqlQueryObject.createSQLQuery();
  288.                                     updateStmtSelectRegistri = con.prepareStatement(selectQuery);
  289.                                     updateStmtSelectRegistri.setString(1, rg.getNome());
  290.                                     rsSelectRegistri = updateStmtSelectRegistri.executeQuery();
  291.                                     if(rsSelectRegistri!=null && rsSelectRegistri.next()){
  292.                                         registroRotta = rsSelectRegistri.getLong("id");
  293.                                     }
  294.                                     rsSelectRegistri.close();
  295.                                     updateStmtSelectRegistri.close();
  296.                                 }
  297.                             }
  298.                         }
  299.     
  300.                         insertStmt = con.prepareStatement(insertQuery);
  301.     
  302.                         insertStmt.setString(1, null);// nn ho tipo
  303.                         insertStmt.setString(2, null);// nn ho nome
  304.                         insertStmt.setString(3, (gw != null ? "gateway" : "registro"));
  305.                         insertStmt.setString(4, (gw != null ? gw.getTipo() : null));// se
  306.                         // rotta
  307.                         // gateway
  308.                         // setto
  309.                         // tiposoggrotta
  310.                         insertStmt.setString(5, (gw != null ? gw.getNome() : null));// se
  311.                         // rotta
  312.                         // gateway
  313.                         // setto
  314.                         // nomesoggrotta
  315.     
  316.                         insertStmt.setLong(6, registroRotta);
  317.     
  318.                         insertStmt.setInt(7, CostantiDB.TRUE);
  319.                         insertStmt.executeUpdate();
  320.                         insertStmt.close();
  321.     
  322.                     }
  323.                 }

  325.                 DriverConfigurazioneDBLib.log.debug("Updated " + i + " Default route.");

  327.                 for (i = 0; i < aRT.sizeDestinazioneList(); i++) {
  328.                     rtd = aRT.getDestinazione(i);
  329.                     nome = rtd.getNome();
  330.                     tipo = rtd.getTipo();

  332.                     for (int j = 0; j < rtd.sizeRouteList(); j++) {
  333.                         route = rtd.getRoute(j);

  335.                         idRoute = route.getId();

  337.                         gw = route.getGateway();// rotta gateway
  338.                         rg = route.getRegistro();// rotta registro

  340.                         long registroRotta = 0;
  341.                         if(rg!=null){
  342.                             if(rg.getId()<=0){
  343.                                 if(rg.getNome()!=null && ("".equals(rg.getNome())==false)){
  344.                                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  345.                                     sqlQueryObject.addFromTable(CostantiDB.REGISTRI);
  346.                                     sqlQueryObject.addSelectField("id");
  347.                                     sqlQueryObject.addWhereCondition("nome = ?");
  348.                                     String selectQuery = sqlQueryObject.createSQLQuery();
  349.                                     updateStmtSelectRegistri = con.prepareStatement(selectQuery);
  350.                                     updateStmtSelectRegistri.setString(1, rg.getNome());
  351.                                     rsSelectRegistri = updateStmtSelectRegistri.executeQuery();
  352.                                     if(rsSelectRegistri!=null && rsSelectRegistri.next()){
  353.                                         registroRotta = rsSelectRegistri.getLong("id");
  354.                                     }
  355.                                     rsSelectRegistri.close();
  356.                                     updateStmtSelectRegistri.close();
  357.                                 }
  358.                             }
  359.                         }


  362.                         insertStmt = con.prepareStatement(insertQuery);

  364.                         insertStmt.setString(1, tipo);
  365.                         insertStmt.setString(2, nome);
  366.                         insertStmt.setString(3, (gw != null ? "gateway" : "registro"));
  367.                         insertStmt.setString(4, (gw != null ? gw.getTipo() : null));
  368.                         insertStmt.setString(5, (gw != null ? gw.getNome() : null));

  370.                         insertStmt.setLong(6, registroRotta);

  372.                         insertStmt.setInt(7, CostantiDB.FALSE);
  373.                         insertStmt.executeUpdate();
  374.                         insertStmt.close();

  376.                     }
  377.                 }

  379.                 DriverConfigurazioneDBLib.log.debug("Updated " + i + " Destination route.");



  383.                 break;

  385.             case 3:
  386.                 // DELETE
  387.                 i = 0;
  388.                 if(aRT.getDefault()!=null){
  389.                     RoutingTableDefault rtDefault = aRT.getDefault();
  390.                     for (i = 0; i < rtDefault.sizeRouteList(); i++) {
  391.                         route = rtDefault.getRoute(i);

  393.                         if (route.getId() == null || route.getId() <= 0)
  394.                             throw new DriverConfigurazioneException("[DriverConfigurazioneDB_LIB::CRUDRoutingTable(DELETE)] id route non valida.");
  395.                         idRoute = route.getId();
  396.                         sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverConfigurazioneDBLib.tipoDB);
  397.                         sqlQueryObject.addDeleteTable(CostantiDB.ROUTING);
  398.                         sqlQueryObject.addWhereCondition("id=?");
  399.                         String sqlQuery = sqlQueryObject.createSQLDelete();
  400.                         updateStmt = con.prepareStatement(sqlQuery);
  401.                         updateStmt.setLong(1, idRoute);
  402.                         updateStmt.executeUpdate();
  403.                         updateStmt.close();
  404.     
  405.                         DriverConfigurazioneDBLib.log.debug("Deleted " + i + " Destination route.");
  406.                     }
  407.                 }
  408.                 break;
  409.             }

  411.         } catch (SQLException se) {
  412.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB_LIB::CRUDRoutingTable] SQLException [" + se.getMessage() + "].",se);
  413.         }catch (Exception se) {
  414.             throw new DriverConfigurazioneException("[DriverConfigurazioneDB_LIB::CRUDRoutingTable] Exception [" + se.getMessage() + "].",se);
  415.         } finally {

  417.             JDBCUtilities.closeResources(updateStmt);
  418.             JDBCUtilities.closeResources(insertStmt);
  419.             JDBCUtilities.closeResources(rsSelectRegistri, updateStmtSelectRegistri);
  420.             
  421.         }
  422.     }
  423.     
  424. }
Created with JaCoCo 0.8.8.202204050719