DBConsegnePreseInCaricoManager.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.  * DBConsegnePreseInCaricoManager
  44.  *
  45.  * @author Poli Andrea (poli@link.it)
  46.  * @author $Author$
  47.  * @version $Rev$, $Date$
  48.  */
  49. public class DBConsegnePreseInCaricoManager implements IMonitoraggioRisorsa {

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

  149.     private Logger log;
  150.     
  151.     private DBManager dbManagerRuntimePdD;
  152.     private DBTransazioniManager dbManagerTransazioni;
  153.     public boolean useDefaultManager() {
  154.         return this.dbManagerRuntimePdD!=null || this.dbManagerTransazioni!=null;
  155.     }
  156.     public boolean useRuntimePdD() {
  157.         if(useDefaultManager()) {
  158.             return this.dbManagerRuntimePdD!=null || this.dbManagerTransazioni.useRuntimePdD();
  159.         }
  160.         return false;
  161.     }
  162.     private DataSource datasourceDedicato;
  163.     private String identita;
  164.     
  165.     private DBConsegnePreseInCaricoManager(DBManager dbManagerRuntimePdD,Logger alog,String tipoDatabase,boolean smistatore) throws Exception {
  166.         this(alog, tipoDatabase, smistatore, false);
  167.         this.dbManagerRuntimePdD = dbManagerRuntimePdD;
  168.     }
  169.     private DBConsegnePreseInCaricoManager(DBTransazioniManager dbManagerTransazioni,Logger alog,String tipoDatabase) throws Exception {
  170.         this(alog, tipoDatabase, false, true);
  171.         this.dbManagerTransazioni = dbManagerTransazioni;
  172.     }

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

  328.                 }
  329.             }

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