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

  21. package org.openspcoop2.protocol.engine.registry;

  23. import java.sql.Connection;
  24. import java.util.HashMap;
  25. import java.util.List;
  26. import java.util.Map;

  28. import org.openspcoop2.core.commons.ErrorsHandlerCostant;
  29. import org.openspcoop2.core.id.IDAccordo;
  30. import org.openspcoop2.core.id.IDPortType;
  31. import org.openspcoop2.core.id.IDPortTypeAzione;
  32. import org.openspcoop2.core.id.IDResource;
  33. import org.openspcoop2.core.id.IDSoggetto;
  34. import org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet;
  35. import org.openspcoop2.core.registry.driver.db.DriverRegistroServiziDB;
  36. import org.openspcoop2.protocol.engine.utils.DBOggettiInUsoUtils;
  37. import org.openspcoop2.protocol.sdk.registry.IRegistryReaderInUso;
  38. import org.openspcoop2.protocol.sdk.registry.RegistryException;
  39. import org.slf4j.Logger;

  41. /**
  42.  *  RegistryReaderInUso
  43.  *
  44.  * @author Poli Andrea (apoli@link.it)
  45.  * @author $Author$
  46.  * @version $Rev$, $Date$
  47.  */
  48. public class RegistryReaderInUso implements IRegistryReaderInUso {

  50.     private IDriverRegistroServiziGet driverRegistroServiziGET; 
  51.     @SuppressWarnings("unused")
  52.     private Logger log;
  53.     
  54.     public RegistryReaderInUso() {}
  55.     
  56.     @Override
  57.     public void init(IDriverRegistroServiziGet driverRegistroServizi, Logger log) {
  58.         this.driverRegistroServiziGET = driverRegistroServizi;
  59.         this.log = log;
  60.     }
  61.     
  62.     
  63.     
  64.     // SOGGETTI
  65.     
  66.     @Override
  67.     public boolean inUso(IDSoggetto idSoggetto, boolean verificaRuoli) throws RegistryException{
  68.         if(this.driverRegistroServiziGET instanceof DriverRegistroServiziDB) {
  69.             DriverRegistroServiziDB driverDB = (DriverRegistroServiziDB) this.driverRegistroServiziGET;
  70.             Connection connection = null;
  71.             try {
  72.                 connection = driverDB.getConnection("inUso(IDSoggetto)");
  73.                 
  74.                 Map<ErrorsHandlerCostant, List<String>> whereIsInUso = new HashMap<ErrorsHandlerCostant, List<String>>();
  75.                 
  76.                 boolean normalizeObjectIds = true;
  77.                 return DBOggettiInUsoUtils.isSoggettoRegistryInUso(connection, driverDB.getTipoDB(), idSoggetto, true, whereIsInUso, normalizeObjectIds, verificaRuoli);
  78.                 
  79.             }
  80.             catch(Exception e) {
  81.                 throw new RegistryException(e.getMessage(),e);
  82.             }
  83.             finally {
  84.                 driverDB.releaseConnection(connection);
  85.             }
  86.         }
  87.         else {
  88.             throw new RuntimeException("Not Implemented");
  89.         }
  90.     }
  91.     @Override
  92.     public String getDettagliInUso(IDSoggetto idSoggetto, boolean verificaRuoli) throws RegistryException{
  93.         if(this.driverRegistroServiziGET instanceof DriverRegistroServiziDB) {
  94.             DriverRegistroServiziDB driverDB = (DriverRegistroServiziDB) this.driverRegistroServiziGET;
  95.             Connection connection = null;
  96.             try {
  97.                 connection = driverDB.getConnection("getDettagliInUso(IDSoggetto)");
  98.                 
  99.                 Map<ErrorsHandlerCostant, List<String>> whereIsInUso = new HashMap<ErrorsHandlerCostant, List<String>>();
  100.                 
  101.                 boolean normalizeObjectIds = true;
  102.                 boolean inUso = DBOggettiInUsoUtils.isSoggettoRegistryInUso(connection, driverDB.getTipoDB(), idSoggetto, true, whereIsInUso, normalizeObjectIds, verificaRuoli);
  103.                 if(inUso) {
  104.                     return DBOggettiInUsoUtils.toString(idSoggetto , whereIsInUso, false, "\n", normalizeObjectIds);
  105.                 }
  106.                 else {
  107.                     return null;
  108.                 }
  109.             }
  110.             catch(Exception e) {
  111.                 throw new RegistryException(e.getMessage(),e);
  112.             }
  113.             finally {
  114.                 driverDB.releaseConnection(connection);
  115.             }
  116.         }
  117.         else {
  118.             throw new RuntimeException("Not Implemented");
  119.         }
  120.     }
  121.     
  122.     
  123.     // ACCORDI PARTE COMUNE
  124.     
  125.     @Override
  126.     public boolean inUso(IDAccordo idAccordo) throws RegistryException{
  127.         if(this.driverRegistroServiziGET instanceof DriverRegistroServiziDB) {
  128.             DriverRegistroServiziDB driverDB = (DriverRegistroServiziDB) this.driverRegistroServiziGET;
  129.             Connection connection = null;
  130.             try {
  131.                 connection = driverDB.getConnection("inUso(IDAccordo)");
  132.                 
  133.                 Map<ErrorsHandlerCostant, List<String>> whereIsInUso = new HashMap<ErrorsHandlerCostant, List<String>>();
  134.                 
  135.                 boolean normalizeObjectIds = true;
  136.                 return DBOggettiInUsoUtils.isAccordoServizioParteComuneInUso(connection, driverDB.getTipoDB(), idAccordo, whereIsInUso, normalizeObjectIds);
  137.                 
  138.             }
  139.             catch(Exception e) {
  140.                 throw new RegistryException(e.getMessage(),e);
  141.             }
  142.             finally {
  143.                 driverDB.releaseConnection(connection);
  144.             }
  145.         }
  146.         else {
  147.             throw new RuntimeException("Not Implemented");
  148.         }
  149.     }
  150.     @Override
  151.     public String getDettagliInUso(IDAccordo idAccordo) throws RegistryException{
  152.         if(this.driverRegistroServiziGET instanceof DriverRegistroServiziDB) {
  153.             DriverRegistroServiziDB driverDB = (DriverRegistroServiziDB) this.driverRegistroServiziGET;
  154.             Connection connection = null;
  155.             try {
  156.                 connection = driverDB.getConnection("getDettagliInUso(IDAccordo)");
  157.                 
  158.                 Map<ErrorsHandlerCostant, List<String>> whereIsInUso = new HashMap<ErrorsHandlerCostant, List<String>>();
  159.                 
  160.                 boolean normalizeObjectIds = true;
  161.                 boolean inUso = DBOggettiInUsoUtils.isAccordoServizioParteComuneInUso(connection, driverDB.getTipoDB(), idAccordo, whereIsInUso, normalizeObjectIds);
  162.                 if(inUso) {
  163.                     return DBOggettiInUsoUtils.toString(idAccordo , whereIsInUso, false, "\n", normalizeObjectIds);
  164.                 }
  165.                 else {
  166.                     return null;
  167.                 }
  168.             }
  169.             catch(Exception e) {
  170.                 throw new RegistryException(e.getMessage(),e);
  171.             }
  172.             finally {
  173.                 driverDB.releaseConnection(connection);
  174.             }
  175.         }
  176.         else {
  177.             throw new RuntimeException("Not Implemented");
  178.         }
  179.     }
  180.     
  181.     
  182.     
  183.     // ELEMENTI INTERNI ALL'ACCORDO PARTE COMUNE
  184.     
  185.     @Override
  186.     public boolean inUso(IDPortType id) throws RegistryException{
  187.         if(this.driverRegistroServiziGET instanceof DriverRegistroServiziDB) {
  188.             DriverRegistroServiziDB driverDB = (DriverRegistroServiziDB) this.driverRegistroServiziGET;
  189.             Connection connection = null;
  190.             try {
  191.                 connection = driverDB.getConnection("inUso(IDPortType)");
  192.                 
  193.                 Map<ErrorsHandlerCostant, List<String>> whereIsInUso = new HashMap<ErrorsHandlerCostant, List<String>>();
  194.                 
  195.                 boolean normalizeObjectIds = true;
  196.                 return DBOggettiInUsoUtils.isPortTypeInUso(connection, driverDB.getTipoDB(), id, whereIsInUso, normalizeObjectIds);
  197.                 
  198.             }
  199.             catch(Exception e) {
  200.                 throw new RegistryException(e.getMessage(),e);
  201.             }
  202.             finally {
  203.                 driverDB.releaseConnection(connection);
  204.             }
  205.         }
  206.         else {
  207.             throw new RuntimeException("Not Implemented");
  208.         }
  209.     }
  210.     @Override
  211.     public String getDettagliInUso(IDPortType id) throws RegistryException{
  212.         if(this.driverRegistroServiziGET instanceof DriverRegistroServiziDB) {
  213.             DriverRegistroServiziDB driverDB = (DriverRegistroServiziDB) this.driverRegistroServiziGET;
  214.             Connection connection = null;
  215.             try {
  216.                 connection = driverDB.getConnection("getDettagliInUso(IDPortType)");
  217.                 
  218.                 Map<ErrorsHandlerCostant, List<String>> whereIsInUso = new HashMap<ErrorsHandlerCostant, List<String>>();
  219.                 
  220.                 boolean normalizeObjectIds = true;
  221.                 boolean inUso = DBOggettiInUsoUtils.isPortTypeInUso(connection, driverDB.getTipoDB(), id, whereIsInUso, normalizeObjectIds);
  222.                 if(inUso) {
  223.                     return DBOggettiInUsoUtils.toString(id , whereIsInUso, false, "\n", "");
  224.                 }
  225.                 else {
  226.                     return null;
  227.                 }
  228.             }
  229.             catch(Exception e) {
  230.                 throw new RegistryException(e.getMessage(),e);
  231.             }
  232.             finally {
  233.                 driverDB.releaseConnection(connection);
  234.             }
  235.         }
  236.         else {
  237.             throw new RuntimeException("Not Implemented");
  238.         }
  239.     }
  240.     
  241.     
  242.     @Override
  243.     public boolean inUso(IDPortTypeAzione id) throws RegistryException{
  244.         if(this.driverRegistroServiziGET instanceof DriverRegistroServiziDB) {
  245.             DriverRegistroServiziDB driverDB = (DriverRegistroServiziDB) this.driverRegistroServiziGET;
  246.             Connection connection = null;
  247.             try {
  248.                 connection = driverDB.getConnection("inUso(IDPortTypeAzione)");
  249.                 
  250.                 Map<ErrorsHandlerCostant, List<String>> whereIsInUso = new HashMap<ErrorsHandlerCostant, List<String>>();
  251.                 
  252.                 boolean normalizeObjectIds = true;
  253.                 return DBOggettiInUsoUtils.isOperazioneInUso(connection, driverDB.getTipoDB(), id, whereIsInUso, normalizeObjectIds);
  254.                 
  255.             }
  256.             catch(Exception e) {
  257.                 throw new RegistryException(e.getMessage(),e);
  258.             }
  259.             finally {
  260.                 driverDB.releaseConnection(connection);
  261.             }
  262.         }
  263.         else {
  264.             throw new RuntimeException("Not Implemented");
  265.         }
  266.     }
  267.     @Override
  268.     public String getDettagliInUso(IDPortTypeAzione id) throws RegistryException{
  269.         if(this.driverRegistroServiziGET instanceof DriverRegistroServiziDB) {
  270.             DriverRegistroServiziDB driverDB = (DriverRegistroServiziDB) this.driverRegistroServiziGET;
  271.             Connection connection = null;
  272.             try {
  273.                 connection = driverDB.getConnection("getDettagliInUso(IDPortTypeAzione)");
  274.                 
  275.                 Map<ErrorsHandlerCostant, List<String>> whereIsInUso = new HashMap<ErrorsHandlerCostant, List<String>>();
  276.                 
  277.                 boolean normalizeObjectIds = true;
  278.                 boolean inUso = DBOggettiInUsoUtils.isOperazioneInUso(connection, driverDB.getTipoDB(), id, whereIsInUso, normalizeObjectIds);
  279.                 if(inUso) {
  280.                     return DBOggettiInUsoUtils.toString(id , whereIsInUso, false, "\n", "");
  281.                 }
  282.                 else {
  283.                     return null;
  284.                 }
  285.             }
  286.             catch(Exception e) {
  287.                 throw new RegistryException(e.getMessage(),e);
  288.             }
  289.             finally {
  290.                 driverDB.releaseConnection(connection);
  291.             }
  292.         }
  293.         else {
  294.             throw new RuntimeException("Not Implemented");
  295.         }
  296.     }
  297.     
  298.     
  299.     @Override
  300.     public boolean inUso(IDResource id) throws RegistryException{
  301.         if(this.driverRegistroServiziGET instanceof DriverRegistroServiziDB) {
  302.             DriverRegistroServiziDB driverDB = (DriverRegistroServiziDB) this.driverRegistroServiziGET;
  303.             Connection connection = null;
  304.             try {
  305.                 connection = driverDB.getConnection("inUso(IDResource)");
  306.                 
  307.                 Map<ErrorsHandlerCostant, List<String>> whereIsInUso = new HashMap<ErrorsHandlerCostant, List<String>>();
  308.                 
  309.                 boolean normalizeObjectIds = true;
  310.                 return DBOggettiInUsoUtils.isRisorsaInUso(connection, driverDB.getTipoDB(), id, whereIsInUso, normalizeObjectIds);
  311.                 
  312.             }
  313.             catch(Exception e) {
  314.                 throw new RegistryException(e.getMessage(),e);
  315.             }
  316.             finally {
  317.                 driverDB.releaseConnection(connection);
  318.             }
  319.         }
  320.         else {
  321.             throw new RuntimeException("Not Implemented");
  322.         }
  323.     }
  324.     @Override
  325.     public String getDettagliInUso(IDResource id) throws RegistryException{
  326.         if(this.driverRegistroServiziGET instanceof DriverRegistroServiziDB) {
  327.             DriverRegistroServiziDB driverDB = (DriverRegistroServiziDB) this.driverRegistroServiziGET;
  328.             Connection connection = null;
  329.             try {
  330.                 connection = driverDB.getConnection("getDettagliInUso(IDResource)");
  331.                 
  332.                 Map<ErrorsHandlerCostant, List<String>> whereIsInUso = new HashMap<ErrorsHandlerCostant, List<String>>();
  333.                 
  334.                 boolean normalizeObjectIds = true;
  335.                 boolean inUso = DBOggettiInUsoUtils.isRisorsaInUso(connection, driverDB.getTipoDB(), id, whereIsInUso, normalizeObjectIds);
  336.                 if(inUso) {
  337.                     
  338.                     String methodPath = null; // prefix non aggiunto
  339.                     
  340.                     return DBOggettiInUsoUtils.toString(id , methodPath, whereIsInUso, false, "\n", "");
  341.                 }
  342.                 else {
  343.                     return null;
  344.                 }
  345.             }
  346.             catch(Exception e) {
  347.                 throw new RegistryException(e.getMessage(),e);
  348.             }
  349.             finally {
  350.                 driverDB.releaseConnection(connection);
  351.             }
  352.         }
  353.         else {
  354.             throw new RuntimeException("Not Implemented");
  355.         }
  356.     }

  358. }
Created with JaCoCo 0.8.8.202204050719