DBConsegneMessageBoxManager.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.pdd.config;

  23. import java.sql.Connection;
  24. import java.sql.Statement;

  26. import javax.sql.DataSource;

  28. import org.openspcoop2.core.commons.CoreException;
  29. import org.openspcoop2.core.commons.IMonitoraggioRisorsa;
  30. import org.openspcoop2.core.constants.Costanti;
  31. import org.openspcoop2.core.constants.CostantiDB;
  32. import org.openspcoop2.core.id.IDSoggetto;
  33. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  34. import org.openspcoop2.utils.LoggerWrapperFactory;
  35. import org.openspcoop2.utils.UtilsAlreadyExistsException;
  36. import org.openspcoop2.utils.datasource.DataSourceFactory;
  37. import org.openspcoop2.utils.datasource.DataSourceParams;
  38. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  39. import org.openspcoop2.utils.resources.GestoreJNDI;
  40. import org.slf4j.Logger;

  42. /**     
  43.  * DBConsegneMessageBoxManager
  44.  *
  45.  * @author Poli Andrea (poli@link.it)
  46.  * @author $Author$
  47.  * @version $Rev$, $Date$
  48.  */
  49. public class DBConsegneMessageBoxManager implements IMonitoraggioRisorsa {

  51.     
  52.     private static DBConsegneMessageBoxManager staticInstanceDBRuntimeManager;
  53.     public static synchronized void initRuntime(DBManager dbManagerRuntimePdD,Logger alog,String tipoDatabase) throws Exception {
  54.         if(staticInstanceDBRuntimeManager==null) {
  55.             staticInstanceDBRuntimeManager = new DBConsegneMessageBoxManager(dbManagerRuntimePdD, alog, tipoDatabase);
  56.         }
  57.     }
  58.     public static synchronized void initRuntime(DBConsegnePreseInCaricoManager dbConsegnePreseInCaricoManager,Logger alog,String tipoDatabase) throws Exception {
  59.         if(staticInstanceDBRuntimeManager==null) {
  60.             staticInstanceDBRuntimeManager = new DBConsegneMessageBoxManager(dbConsegnePreseInCaricoManager, alog, tipoDatabase,false);
  61.         }
  62.     }
  63.     public static synchronized void initRuntime(String nomeDataSource, java.util.Properties context,Logger alog,String tipoDatabase, 
  64.             boolean useOp2UtilsDatasource, boolean bindJMX) throws Exception {
  65.         if(staticInstanceDBRuntimeManager==null) {
  66.             staticInstanceDBRuntimeManager = new DBConsegneMessageBoxManager(nomeDataSource, context, alog, tipoDatabase, useOp2UtilsDatasource, bindJMX,
  67.                     false);
  68.         }
  69.     }
  70.     public static DBConsegneMessageBoxManager getInstanceRuntime() {
  71.         // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  72.         if (staticInstanceDBRuntimeManager == null) {
  73.             synchronized (DBConsegneMessageBoxManager.class) {
  74.                 if (staticInstanceDBRuntimeManager == null) {
  75.                     return null;
  76.                 }
  77.             }
  78.         }
  79.         return staticInstanceDBRuntimeManager;
  80.     }
  81.     
  82.     
  83.     private static DBConsegneMessageBoxManager staticInstanceDBTransazioniManager;
  84.     public static synchronized void initTransazioni(DBTransazioniManager dbManagerTransazioni,Logger alog,String tipoDatabase) throws Exception {
  85.         if(staticInstanceDBTransazioniManager==null) {
  86.             staticInstanceDBTransazioniManager = new DBConsegneMessageBoxManager(dbManagerTransazioni, alog, tipoDatabase);
  87.         }
  88.     }
  89.     public static synchronized void initTransazioni(DBConsegnePreseInCaricoManager dbConsegnePreseInCaricoManager,Logger alog,String tipoDatabase) throws Exception {
  90.         if(staticInstanceDBTransazioniManager==null) {
  91.             staticInstanceDBTransazioniManager = new DBConsegneMessageBoxManager(dbConsegnePreseInCaricoManager, alog, tipoDatabase, true);
  92.         }
  93.     }
  94.     public static synchronized void initTransazioni(String nomeDataSource, java.util.Properties context,Logger alog,String tipoDatabase, 
  95.             boolean useOp2UtilsDatasource, boolean bindJMX) throws Exception {
  96.         if(staticInstanceDBTransazioniManager==null) {
  97.             staticInstanceDBTransazioniManager = new DBConsegneMessageBoxManager(nomeDataSource, context, alog, tipoDatabase, useOp2UtilsDatasource, bindJMX,
  98.                     true);
  99.         }
  100.     }
  101.     public static DBConsegneMessageBoxManager getInstanceTransazioni() {
  102.         // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  103.         if (staticInstanceDBTransazioniManager == null) {
  104.             synchronized (DBConsegneMessageBoxManager.class) {
  105.                 if (staticInstanceDBTransazioniManager == null) {
  106.                     return null;
  107.                 }
  108.             }
  109.         }
  110.         return staticInstanceDBTransazioniManager;
  111.     }
  112.     
  113.     
  114.     /** Informazione sui proprietari che hanno richiesto una connessione */
  115.     private static java.util.concurrent.ConcurrentHashMap<String,Resource> risorseInGestioneRuntime = new java.util.concurrent.ConcurrentHashMap<>();
  116.     private static java.util.concurrent.ConcurrentHashMap<String,Resource> risorseInGestioneTransazioni = new java.util.concurrent.ConcurrentHashMap<>();
  117.     
  118.     public static String[] getStatoRisorse_runtime() throws Exception{  
  119.         return DBManager.getStatoRisorse(DBConsegneMessageBoxManager.risorseInGestioneRuntime);
  120.     }
  121.     public static String[] getStatoRisorse_transazioni() throws Exception{  
  122.         return DBManager.getStatoRisorse(DBConsegneMessageBoxManager.risorseInGestioneTransazioni);
  123.     }
  124.     
  125.     
  126.     private String tipoDatabase;
  127.     public String getTipoDatabase() {
  128.         return this.tipoDatabase;
  129.     }

  131.     private Logger log;
  132.     
  133.     private DBManager dbManagerRuntimePdD;
  134.     private DBTransazioniManager dbManagerTransazioni;
  135.     private DBConsegnePreseInCaricoManager dbConsegnePreseInCaricoManager;
  136.     public boolean useDefaultManager() {
  137.         return this.dbManagerRuntimePdD!=null || this.dbManagerTransazioni!=null;
  138.     }
  139.     public boolean useConsegnePreseInCaricoManager() {
  140.         return this.dbConsegnePreseInCaricoManager!=null;
  141.     }
  142.     public boolean useRuntimePdD() {
  143.         if(useDefaultManager()) {
  144.             return this.dbManagerRuntimePdD!=null || this.dbManagerTransazioni.useRuntimePdD();
  145.         }
  146.         else if(useConsegnePreseInCaricoManager()) {
  147.             return this.dbConsegnePreseInCaricoManager.useRuntimePdD();
  148.         }
  149.         return false;
  150.     }
  151.     private DataSource datasourceDedicato;
  152.     private String identita;
  153.     
  154.     private DBConsegneMessageBoxManager(DBManager dbManagerRuntimePdD,Logger alog,String tipoDatabase) throws Exception {
  155.         this(alog, tipoDatabase, false);
  156.         this.dbManagerRuntimePdD = dbManagerRuntimePdD;
  157.     }
  158.     private DBConsegneMessageBoxManager(DBTransazioniManager dbManagerTransazioni,Logger alog,String tipoDatabase) throws Exception {
  159.         this(alog, tipoDatabase, true);
  160.         this.dbManagerTransazioni = dbManagerTransazioni;
  161.     }
  162.     private DBConsegneMessageBoxManager(DBConsegnePreseInCaricoManager dbConsegnePreseInCaricoManager,Logger alog,String tipoDatabase, boolean tracce) throws Exception {
  163.         this(alog, tipoDatabase, tracce);
  164.         this.dbConsegnePreseInCaricoManager = dbConsegnePreseInCaricoManager;
  165.     }

  167.     private DBConsegneMessageBoxManager(String nomeDataSource, java.util.Properties context,Logger alog,String tipoDatabase, 
  168.             boolean useOp2UtilsDatasource, boolean bindJMX,
  169.             boolean tracce) throws Exception {
  170.         
  171.         this(alog, tipoDatabase, tracce);
  172.         
  173.         try {
  174.             
  175.             if(useOp2UtilsDatasource){
  176.                 DataSourceParams dsParams = Costanti.getDataSourceParamsPdD(bindJMX, tipoDatabase);
  177.                 try{
  178.                     this.datasourceDedicato = DataSourceFactory.newInstance(nomeDataSource, context, dsParams);
  179.                 }catch(UtilsAlreadyExistsException exists){
  180.                     this.datasourceDedicato = DataSourceFactory.getInstance(nomeDataSource); 
  181.                     if(this.datasourceDedicato==null){
  182.                         throw new Exception("Lookup datasource non riuscita ("+exists.getMessage()+")",exists);
  183.                     }
  184.                 }
  185.             }
  186.             else{
  187.                 GestoreJNDI gestoreJNDI = new GestoreJNDI(context);
  188.                 this.datasourceDedicato = (DataSource) gestoreJNDI.lookup(nomeDataSource);
  189.             }
  190.         } catch (Exception ne) {
  191.             this.log.error("Impossibile instanziare il manager: " + ne.getMessage(),ne);
  192.             throw ne;
  193.         }
  194.     }
  195.     
  196.     private DBConsegneMessageBoxManager(Logger alog,String tipoDatabase,boolean tracce) throws Exception {
  197.         this.log = alog;
  198.         this.tipoDatabase = tipoDatabase;
  199.         if(tracce) {
  200.             this.identita = "DBConsegneMessageBoxTransazioniManager";
  201.         }
  202.         else {
  203.             this.identita = "DBConsegneMessageBoxRuntimeManager";
  204.         }
  205.             
  206.     }
  207.     private boolean isIamRuntimeManager() {
  208.         return "DBConsegneMessageBoxRuntimeManager".equals(this.identita);
  209.     }
  210.     private boolean isIamTransazioniManager() {
  211.         return "DBConsegneMessageBoxTransazioniManager".equals(this.identita);
  212.     }
  213.     
  214.     
  215.     public Resource getResource(IDSoggetto idPDD,String modulo,String idTransazione) throws Exception {
  216.         return this.getResource(idPDD, modulo, idTransazione, true);
  217.     }
  218.     public Resource getResource(IDSoggetto idPDD,String modulo,String idTransazione, boolean logError) throws Exception {
  219.         if(this.dbManagerRuntimePdD!=null) {
  220.             /**System.out.println("id ["+idTransazione+"] prendo da dbManager");*/
  221.             return this.dbManagerRuntimePdD.getResource(idPDD, modulo, idTransazione, logError);
  222.         }
  223.         else if(this.dbManagerTransazioni!=null) {
  224.             /**System.out.println("id ["+idTransazione+"] prendo da dbManagerTransazioni");*/
  225.             return this.dbManagerTransazioni.getResource(idPDD, modulo, idTransazione, logError);
  226.         }
  227.         else if(this.dbConsegnePreseInCaricoManager!=null) {
  228.             /**System.out.println("id ["+idTransazione+"] prendo da dbManagerTransazioni");*/
  229.             return this.dbConsegnePreseInCaricoManager.getResource(idPDD, modulo, idTransazione, logError);
  230.         }
  231.         else {
  232.             /**System.out.println("id ["+idTransazione+"] negozio");*/
  233.             try {
  234.                 StringBuilder bf = new StringBuilder();
  235.                 if(idPDD!=null) {
  236.                     bf.append(idPDD.toString());
  237.                     if(modulo!=null) {
  238.                         bf.append(".");
  239.                     }
  240.                 }
  241.                 if(modulo!=null) {
  242.                     bf.append(modulo);
  243.                 }
  244.                 if(bf.length()<=0) {
  245.                     bf.append(this.identita);
  246.                 }
  247.                 Resource risorsa = DBManager.buildResource(this.identita, this.getConnectionFromDatasource(bf.toString(), idTransazione),
  248.                         idPDD, modulo, idTransazione);  
  249.                 
  250.                 if(this.isIamRuntimeManager()) {
  251.                     DBConsegneMessageBoxManager.risorseInGestioneRuntime.put(risorsa.getId(), risorsa);
  252.                 }
  253.                 else if(this.isIamTransazioniManager()) {
  254.                     DBConsegneMessageBoxManager.risorseInGestioneTransazioni.put(risorsa.getId(), risorsa);
  255.                 }
  256.                 
  257.                 return risorsa;
  258.             }
  259.             catch(Exception e) {
  260.                 this.log.error("Errore durante l'ottenimento di una connessione: "+e.getMessage(),e);
  261.                 throw e;
  262.             }
  263.         }
  264.     }
  265.     
  266.     private Connection getConnectionFromDatasource(String methodName, String idTransazione) throws Exception{
  267.         if(this.datasourceDedicato instanceof org.openspcoop2.utils.datasource.DataSource){
  268.             return ((org.openspcoop2.utils.datasource.DataSource)this.datasourceDedicato).getWrappedConnection(idTransazione, this.identita+"."+methodName);
  269.         }
  270.         else{
  271.             return this.datasourceDedicato.getConnection();
  272.         }
  273.     }
  274.     
  275.     public void releaseResource(IDSoggetto idPDD,String modulo,Resource resource){
  276.         this.releaseResource(idPDD, modulo, resource, true);
  277.     }
  278.     public void releaseResource(IDSoggetto idPDD,String modulo,Resource resource, boolean logError){
  279.         try {
  280.             if(this.dbManagerRuntimePdD!=null) {
  281.                 this.dbManagerRuntimePdD.releaseResource(idPDD, modulo, resource, logError);
  282.             }
  283.             else if(this.dbManagerTransazioni!=null) {
  284.                 this.dbManagerTransazioni.releaseResource(idPDD, modulo, resource, logError);
  285.             }
  286.             else if(this.dbConsegnePreseInCaricoManager!=null) {
  287.                 this.dbConsegnePreseInCaricoManager.releaseResource(idPDD, modulo, resource, logError);
  288.             }
  289.             else {
  290.                 if(resource!=null){
  291.                     
  292.                     if(resource.getResource()!=null){
  293.                         Connection connectionDB = (Connection) resource.getResource();
  294.                         if(connectionDB != null && (!connectionDB.isClosed())){
  295.                             Logger logR = OpenSPCoop2Logger.getLoggerOpenSPCoopResources()!=null ? OpenSPCoop2Logger.getLoggerOpenSPCoopResources() : LoggerWrapperFactory.getLogger(DBConsegneMessageBoxManager.class);
  296.                             boolean checkAutocommit = (OpenSPCoop2Properties.getInstance()==null) || OpenSPCoop2Properties.getInstance().isJdbcCloseConnectionCheckAutocommit();
  297.                             boolean checkIsClosed = (OpenSPCoop2Properties.getInstance()==null) || OpenSPCoop2Properties.getInstance().isJdbcCloseConnectionCheckIsClosed();
  298.                             JDBCUtilities.closeConnection(logR, connectionDB, checkAutocommit, checkIsClosed);
  299.                         }
  300.                     }   
  301.                     
  302.                     if(this.isIamRuntimeManager()) {
  303.                         if(DBConsegneMessageBoxManager.risorseInGestioneRuntime.containsKey(resource.getId())) {
  304.                             DBConsegneMessageBoxManager.risorseInGestioneRuntime.remove(resource.getId());
  305.                         }
  306.                     }
  307.                     else if(this.isIamTransazioniManager()) {
  308.                         if(DBConsegneMessageBoxManager.risorseInGestioneTransazioni.containsKey(resource.getId())) {
  309.                             DBConsegneMessageBoxManager.risorseInGestioneTransazioni.remove(resource.getId());
  310.                         }
  311.                     }

  313.                 }
  314.             }

  316.         }
  317.         catch(Exception e) {
  318.             this.log.error("Errore durante il rilascio di una risorsa: "+e.getMessage(),e);
  319.         }
  320.     }
  321.     
  322.     
  323.     
  324.     /**
  325.      * Metodo che verica la connessione ad una risorsa.
  326.      * Se la connessione non e' presente, viene lanciata una eccezione che contiene il motivo della mancata connessione
  327.      * 
  328.      * @throws DriverException eccezione che contiene il motivo della mancata connessione
  329.      */
  330.     @Override
  331.     public void isAlive() throws CoreException{
  332.         if(this.dbManagerRuntimePdD!=null) {
  333.             this.dbManagerRuntimePdD.isAlive();
  334.         }
  335.         else if(this.dbManagerTransazioni!=null) {
  336.             this.dbManagerTransazioni.isAlive();
  337.         }
  338.         else if(this.dbConsegnePreseInCaricoManager!=null) {
  339.             this.dbConsegnePreseInCaricoManager.isAlive();
  340.         }
  341.         else {
  342.             // Verifico la connessione
  343.             Resource resource = null;
  344.             Statement stmtTest = null;
  345.             IDSoggetto idSoggettAlive = new IDSoggetto();
  346.             idSoggettAlive.setCodicePorta(this.identita);
  347.             idSoggettAlive.setTipo(this.identita);
  348.             idSoggettAlive.setNome(this.identita);
  349.             try {
  350.                 try{
  351.                     resource = this.getResource(idSoggettAlive, "CheckIsAlive", null);
  352.                 }catch(Exception e){
  353.                     throw e;
  354.                 }
  355.                 if(resource == null)
  356.                     throw new Exception("Resource is null");
  357.                 if(resource.getResource() == null)
  358.                     throw new Exception("Connessione is null");
  359.                 Connection con = (Connection) resource.getResource();
  360.                 // test:
  361.                 stmtTest = con.createStatement();
  362.                 stmtTest.execute("SELECT * from "+CostantiDB.DB_INFO);
  363.                         
  364.             } catch (Exception e) {
  365.                 throw new CoreException("Connessione al database 'GovWay' ("+this.identita+") non disponibile: "+e.getMessage(),e);
  366.     
  367.             }finally{
  368.                 try{
  369.                     if(stmtTest!=null)
  370.                         stmtTest.close();
  371.                 }catch(Exception e){
  372.                     // close
  373.                 }
  374.                 try{
  375.                     this.releaseResource(idSoggettAlive, "CheckIsAlive", resource);
  376.                 }catch(Exception e){
  377.                     // close
  378.                 }
  379.             }
  380.         }
  381.     }
  382. }
Created with JaCoCo 0.8.8.202204050719