NotifierDump.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.pdd.core.handlers.notifier.engine;

  22. import java.io.File;
  23. import java.io.InputStream;
  24. import java.sql.Connection;
  25. import java.sql.PreparedStatement;
  26. import java.util.Iterator;
  27. import java.util.List;
  28. import java.util.Map;

  30. import org.openspcoop2.core.commons.dao.DAOFactory;
  31. import org.openspcoop2.core.commons.dao.DAOFactoryProperties;
  32. import org.openspcoop2.core.id.IDSoggetto;
  33. import org.openspcoop2.core.transazioni.DumpMessaggio;
  34. import org.openspcoop2.core.transazioni.constants.TipoMessaggio;
  35. import org.openspcoop2.core.transazioni.dao.jdbc.JDBCDumpMessaggioService;
  36. import org.openspcoop2.generic_project.expression.impl.sql.ISQLFieldConverter;
  37. import org.openspcoop2.generic_project.utils.ServiceManagerProperties;
  38. import org.openspcoop2.pdd.config.DBTransazioniManager;
  39. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  40. import org.openspcoop2.pdd.config.Resource;
  41. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  42. import org.openspcoop2.protocol.sdk.tracciamento.TracciamentoException;
  43. import org.openspcoop2.utils.date.DateManager;
  44. import org.openspcoop2.utils.jdbc.JDBCAdapterFactory;
  45. import org.openspcoop2.utils.sql.ISQLQueryObject;
  46. import org.openspcoop2.utils.sql.SQLObjectFactory;
  47. import org.slf4j.Logger;

  49. /**     
  50.  * NotifierDump
  51.  *
  52.  * @author Poli Andrea (poli@link.it)
  53.  * @author $Author$
  54.  * @version $Rev$, $Date$
  55.  */
  56. public class NotifierDump {

  58.     // STATIC

  60.     private static NotifierDump staticInstance = null;
  61.     private static synchronized void initialize() throws TracciamentoException{
  62.         if(staticInstance==null){
  63.             try{

  65.                 OpenSPCoop2Properties op2Properties = OpenSPCoop2Properties.getInstance();
  66.                 
  67.                 String tipoDatabase = op2Properties.getDatabaseType();
  68.                 if(tipoDatabase==null){
  69.                     throw new TracciamentoException("Tipo Database non definito");
  70.                 }

  72.                 boolean debug = op2Properties.isTransazioniDebug();
  73.                 Logger daoFactoryLogger = null;
  74.                 DAOFactory daoFactory = null;
  75.                 ServiceManagerProperties daoFactoryServiceManagerPropertiesTransazioni = null;
  76.                 try{
  77.                     DAOFactoryProperties daoFactoryProperties = null;
  78.                     daoFactoryLogger = OpenSPCoop2Logger.getLoggerOpenSPCoopTransazioniSql(debug);
  79.                     daoFactory = DAOFactory.getInstance(daoFactoryLogger);
  80.                     daoFactoryProperties = DAOFactoryProperties.getInstance(daoFactoryLogger);
  81.                     daoFactoryServiceManagerPropertiesTransazioni = daoFactoryProperties.getServiceManagerProperties(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance());
  82.                     daoFactoryServiceManagerPropertiesTransazioni.setShowSql(debug);    
  83.                     daoFactoryServiceManagerPropertiesTransazioni.setDatabaseType(DBTransazioniManager.getInstance().getTipoDatabase());
  84.                 }catch(Exception e){
  85.                     throw new TracciamentoException("Errore durante l'inizializzazione del daoFactory: "+e.getMessage(),e);
  86.                 }
  87.                 
  88.                 // GestoreDump
  89.                 staticInstance = new NotifierDump(debug, 
  90.                         //ds, 
  91.                         tipoDatabase, daoFactory, daoFactoryServiceManagerPropertiesTransazioni, daoFactoryLogger);

  93.             }catch(Exception e){
  94.                 throw new TracciamentoException("Errore durante l'inizializzazione del NotifierDump: "+e.getMessage(),e);
  95.             }
  96.         }
  97.     }
  98.     public static NotifierDump getInstance() throws TracciamentoException {
  99.         if(staticInstance==null){
  100.             // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  101.             synchronized (NotifierDump.class) {
  102.                 initialize();
  103.             }
  104.         }
  105.         return staticInstance;
  106.     }



  110.     // INSTANCE

  112.     private String tipoDatabase;
  113.     
  114.     private DAOFactory daoFactory = null;
  115.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesTransazioni = null;
  116.     private Logger daoFactoryLogger = null;
  117.     
  118.     boolean debug = false;
  119.     
  120.     private NotifierDump( boolean debug, 
  121.             String tipoDatabase,
  122.             DAOFactory daoFactory, ServiceManagerProperties daoFactoryServiceManagerPropertiesTransazioni, Logger daoFactoryLogger){
  123.         
  124.         this.debug = debug;
  125.         
  126.         this.tipoDatabase = tipoDatabase;
  127.         
  128.         this.daoFactory = daoFactory;
  129.         this.daoFactoryServiceManagerPropertiesTransazioni = daoFactoryServiceManagerPropertiesTransazioni;
  130.         this.daoFactoryLogger = daoFactoryLogger;
  131.     }

  133.     
  134.     private int save(NotifierCallback notifierCallback,
  135.             String idTransazione,TipoMessaggio tipoMessaggio,Map<String, List<String>> headerTrasporto,
  136.             long idDumpConfigurazione,
  137.             String contentType,
  138.             InputStream is,File file,byte[]buffer,
  139.             IDSoggetto dominio) throws Exception{

  141.         PreparedStatement stmt = null;
  142.         DBTransazioniManager dbManager = null;
  143.         Resource r = null;
  144.         String idModulo = "NotifierDump.save"+tipoMessaggio.getValue();
  145.         try{
  146.             notifierCallback.debug("@save getConnection.....");
  147.             
  148.             dbManager = DBTransazioniManager.getInstance();
  149.             r = dbManager.getResource(dominio, idModulo, idTransazione);
  150.             if(r==null){
  151.                 throw new Exception("Risorsa al database non disponibile");
  152.             }
  153.             Connection con = (Connection) r.getResource();
  154.             if(con == null)
  155.                 throw new Exception("Connessione non disponibile"); 

  157.             boolean autoCommit = true;
  158.             
  159.             org.openspcoop2.core.transazioni.dao.jdbc.JDBCServiceManager jdbcServiceManager =
  160.                     (org.openspcoop2.core.transazioni.dao.jdbc.JDBCServiceManager) this.daoFactory.
  161.                         getServiceManager(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance(), con, autoCommit,
  162.                             this.daoFactoryServiceManagerPropertiesTransazioni, this.daoFactoryLogger);
  163.             jdbcServiceManager.getJdbcProperties().setShowSql(this.debug);
  164.             
  165.             JDBCDumpMessaggioService dumpMessaggioService =  (JDBCDumpMessaggioService) jdbcServiceManager.getDumpMessaggioService();
  166.             
  167.             ISQLFieldConverter sqlFielConverter = dumpMessaggioService.getFieldConverter();
  168.             
  169.             // Devo usare per forza la prepared stameent per sfruttare la funzionalità di setStream.
  170.             
  171.             ISQLQueryObject insertSql = SQLObjectFactory.createSQLQueryObject(this.tipoDatabase);
  172.             insertSql.addInsertTable(sqlFielConverter.toTable(DumpMessaggio.model()));
  173.             insertSql.addInsertField(sqlFielConverter.toColumn(DumpMessaggio.model().ID_TRANSAZIONE, false), "?");
  174.             insertSql.addInsertField(sqlFielConverter.toColumn(DumpMessaggio.model().TIPO_MESSAGGIO, false), "?");
  175.             insertSql.addInsertField(sqlFielConverter.toColumn(DumpMessaggio.model().DUMP_TIMESTAMP, false), "?");
  176.             insertSql.addInsertField(sqlFielConverter.toColumn(DumpMessaggio.model().CONTENT_TYPE, false), "?");
  177.             insertSql.addInsertField(sqlFielConverter.toColumn(DumpMessaggio.model().POST_PROCESS_HEADER, false), "?");
  178.             if(file!=null){
  179.                 insertSql.addInsertField(sqlFielConverter.toColumn(DumpMessaggio.model().POST_PROCESS_FILENAME, false), "?");
  180.             }else{
  181.                 insertSql.addInsertField(sqlFielConverter.toColumn(DumpMessaggio.model().POST_PROCESS_CONTENT, false), "?");
  182.             }
  183.             insertSql.addInsertField("post_process_config_id", "?" );
  184.             insertSql.addInsertField(sqlFielConverter.toColumn(DumpMessaggio.model().POST_PROCESS_TIMESTAMP, false), "?");
  185.             insertSql.addInsertField(sqlFielConverter.toColumn(DumpMessaggio.model().POST_PROCESSED, false), "?");
  186.             
  187.             notifierCallback.debug("@save insertSql ["+insertSql.createSQLInsert()+"].....");
  188.                         
  189.             notifierCallback.debug("@save creo PreparedStatement.....");
  190.             
  191.             stmt = con.prepareStatement(insertSql.createSQLInsert());

  193.             int index = 1;
  194.             stmt.setString(index++, idTransazione);
  195.             stmt.setString(index++, tipoMessaggio.toString());
  196.             stmt.setTimestamp(index++, DateManager.getTimestamp());
  197.             stmt.setString(index++, contentType);
  198.             stmt.setString(index++, this.toString(headerTrasporto));
  199.             if(file!=null){
  200.                 notifierCallback.debug("set FileName.....");
  201.                 stmt.setString(index++, file.getName());
  202.             }else{
  203.                 if(is!=null){
  204.                     notifierCallback.debug("set BinaryStream.....");
  205.                     stmt.setBinaryStream(index++, is);
  206.                 }
  207.                 else{
  208.                     notifierCallback.debug("set JDBCAdapter.....");
  209.                     JDBCAdapterFactory.createJDBCAdapter(this.tipoDatabase).setBinaryData(stmt, index++, buffer);
  210.                 }
  211.             }
  212.             stmt.setLong(index++, idDumpConfigurazione);
  213.             stmt.setTimestamp(index++, DateManager.getTimestamp());
  214.             stmt.setInt(index++, 0); // dovra' essere processato in posto process.

  216.             notifierCallback.debug("set executeUpdate.....");
  217.             
  218.             int row = stmt.executeUpdate();
  219.             
  220.             notifierCallback.debug("return row ["+row+"].....");
  221.             return row;

  223.         }finally{
  224.             try{
  225.                 if(stmt!=null)
  226.                     stmt.close();
  227.             }catch(Exception eClose){}
  228.             try{
  229.                 if(r!=null)
  230.                     dbManager.releaseResource(dominio, idModulo, r);
  231.             }catch(Exception eClose){
  232.                 // close
  233.             }
  234.         }
  235.     }
  236.     
  237.     private String toString(Map<String, List<String>> headerTrasporto){
  238.         StringBuilder bf = new StringBuilder();
  239.         if(headerTrasporto!=null && headerTrasporto.size()>0){
  240.             Iterator<String> keys = headerTrasporto.keySet().iterator();
  241.             while (keys.hasNext()) {
  242.                 String key = keys.next();
  243.                 List<String> values = headerTrasporto.get(key);
  244.                 if(values!=null && !values.isEmpty()) {
  245.                     for (String value : values) {
  246.                         if(bf.length()>0){
  247.                             bf.append("\n");
  248.                         }
  249.                         bf.append(key).append("=").append(value);       
  250.                     }
  251.                 }
  252.             }
  253.         }
  254.         if(bf.length()>0){
  255.             return bf.toString();
  256.         }
  257.         else{
  258.             return null;
  259.         }
  260.     }
  261.     
  262.     public int saveOnDatabase(NotifierCallback notifierCallback,
  263.             String idTransazione,TipoMessaggio tipoMessaggio, Map<String, List<String>> headerTrasporto, 
  264.             long idDumpConfigurazione,
  265.             String contentType,InputStream is,
  266.             IDSoggetto dominio) throws Exception{
  267.         return this.save(notifierCallback,idTransazione, tipoMessaggio, headerTrasporto, idDumpConfigurazione, contentType, is, null, null, dominio);
  268.     }
  269.     
  270.     public int saveOnFileSystem(NotifierCallback notifierCallback,
  271.             String idTransazione,TipoMessaggio tipoMessaggio, Map<String, List<String>> headerTrasporto, 
  272.             long idDumpConfigurazione,
  273.             String contentType,File file,
  274.             IDSoggetto dominio) throws Exception{
  275.         return this.save(notifierCallback,idTransazione, tipoMessaggio, headerTrasporto, idDumpConfigurazione, contentType, null, file, null, dominio);
  276.     }
  277.     
  278.     public int saveBuffer(NotifierCallback notifierCallback,
  279.             String idTransazione,TipoMessaggio tipoMessaggio, Map<String, List<String>> headerTrasporto, 
  280.             long idDumpConfigurazione,
  281.             String contentType,byte[] content,
  282.             IDSoggetto dominio) throws Exception{
  283.         return this.save(notifierCallback,idTransazione, tipoMessaggio, headerTrasporto, idDumpConfigurazione, contentType, null, null, content, dominio);
  284.     }
  285.     
  286.     
  287.     public int update(NotifierCallback notifierCallback,
  288.             String idTransazione,TipoMessaggio tipoMessaggio,Map<String, List<String>> headerTrasporto,
  289.             IDSoggetto dominio) throws Exception{

  291.         PreparedStatement stmt = null;
  292.         DBTransazioniManager dbManager = null;
  293.         Resource r = null;
  294.         String idModulo = "NotifierDump.update"+tipoMessaggio.getValue();
  295.         try{
  296.             notifierCallback.debug("@save getConnection.....");
  297.             
  298.             dbManager = DBTransazioniManager.getInstance();
  299.             r = dbManager.getResource(dominio, idModulo, idTransazione);
  300.             if(r==null){
  301.                 throw new Exception("Risorsa al database non disponibile");
  302.             }
  303.             Connection con = (Connection) r.getResource();
  304.             if(con == null)
  305.                 throw new Exception("Connessione non disponibile"); 

  307.             boolean autoCommit = true;
  308.             
  309.             org.openspcoop2.core.transazioni.dao.jdbc.JDBCServiceManager jdbcServiceManager =
  310.                     (org.openspcoop2.core.transazioni.dao.jdbc.JDBCServiceManager) 
  311.                         this.daoFactory.getServiceManager(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance(), con, autoCommit,
  312.                             this.daoFactoryServiceManagerPropertiesTransazioni, this.daoFactoryLogger);
  313.             jdbcServiceManager.getJdbcProperties().setShowSql(this.debug);
  314.             
  315.             JDBCDumpMessaggioService dumpMessaggioService =  (JDBCDumpMessaggioService) jdbcServiceManager.getDumpMessaggioService();
  316.             
  317.             ISQLFieldConverter sqlFielConverter = dumpMessaggioService.getFieldConverter();
  318.             
  319.             // Devo usare per forza la prepared stameent per sfruttare la funzionalità di ritornare le righe modificate
  320.             
  321.             ISQLQueryObject updateSql = SQLObjectFactory.createSQLQueryObject(this.tipoDatabase);
  322.             updateSql.addUpdateTable(sqlFielConverter.toTable(DumpMessaggio.model()));
  323.             updateSql.addUpdateField(sqlFielConverter.toColumn(DumpMessaggio.model().POST_PROCESS_HEADER, false), "?");
  324.             updateSql.setANDLogicOperator(true);
  325.             updateSql.addWhereCondition(sqlFielConverter.toColumn(DumpMessaggio.model().ID_TRANSAZIONE, false)+"=?");
  326.             updateSql.addWhereCondition(sqlFielConverter.toColumn(DumpMessaggio.model().TIPO_MESSAGGIO, false)+"=?");

  328.             notifierCallback.debug("@save updateSql ["+updateSql.createSQLUpdate()+"].....");
  329.                         
  330.             notifierCallback.debug("@save creo PreparedStatement.....");
  331.             
  332.             stmt = con.prepareStatement(updateSql.createSQLUpdate());

  334.             stmt.setString(1, this.toString(headerTrasporto));
  335.             stmt.setString(2, idTransazione);
  336.             stmt.setString(3, tipoMessaggio.toString());

  338.             notifierCallback.debug("set executeUpdate.....");
  339.             
  340.             int row = stmt.executeUpdate();
  341.             
  342.             notifierCallback.debug("return row ["+row+"].....");
  343.             return row;

  345.         }finally{
  346.             try{
  347.                 if(stmt!=null)
  348.                     stmt.close();
  349.             }catch(Exception eClose){}
  350.             try{
  351.                 if(r!=null)
  352.                     dbManager.releaseResource(dominio, idModulo, r);
  353.             }catch(Exception eClose){
  354.                 // close
  355.             }
  356.         }
  357.     }
  358.     
  359. }
Created with JaCoCo 0.8.8.202204050719