ConfigurazioneTransazioneFetch.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.monitor.engine.config.transazioni.dao.jdbc.fetch;

  22. import org.openspcoop2.generic_project.beans.IModel;
  23. import org.openspcoop2.generic_project.dao.jdbc.utils.AbstractJDBCFetch;
  24. import org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCParameterUtilities;
  25. import org.openspcoop2.generic_project.exception.ServiceException;

  27. import java.sql.ResultSet;
  28. import java.util.Map;

  30. import org.openspcoop2.utils.TipiDatabase;
  31. import org.openspcoop2.utils.jdbc.IKeyGeneratorObject;

  33. import org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazioneRisorsaContenuto;
  34. import org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazionePlugin;
  35. import org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazioneStato;
  36. import org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazione;


  39. /**     
  40.  * ConfigurazioneTransazioneFetch
  41.  *
  42.  * @author Poli Andrea (poli@link.it)
  43.  * @author $Author$
  44.  * @version $Rev$, $Date$
  45.  */
  46. public class ConfigurazioneTransazioneFetch extends AbstractJDBCFetch {

  48.     @Override
  49.     public Object fetch(TipiDatabase tipoDatabase, IModel<?> model , ResultSet rs) throws ServiceException {
  50.         
  51.         try{
  52.             GenericJDBCParameterUtilities jdbcParameterUtilities =  
  53.                     new GenericJDBCParameterUtilities(tipoDatabase);

  55.             if(model.equals(ConfigurazioneTransazione.model())){
  56.                 ConfigurazioneTransazione object = new ConfigurazioneTransazione();
  57.                 setParameter(object, "setId", Long.class,
  58.                     jdbcParameterUtilities.readParameter(rs, "id", Long.class));
  59.                 setParameter(object, "setEnabled", ConfigurazioneTransazione.model().ENABLED.getFieldType(),
  60.                     jdbcParameterUtilities.readParameter(rs, "enabled", ConfigurazioneTransazione.model().ENABLED.getFieldType()));
  61.                 return object;
  62.             }
  63.             if(model.equals(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN)){
  64.                 ConfigurazioneTransazionePlugin object = new ConfigurazioneTransazionePlugin();
  65.                 setParameter(object, "setId", Long.class,
  66.                     jdbcParameterUtilities.readParameter(rs, "id", Long.class));
  67.                 setParameter(object, "setIdConfigurazioneTransazionePlugin", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN.ID_CONFIGURAZIONE_TRANSAZIONE_PLUGIN.getFieldType(),
  68.                     jdbcParameterUtilities.readParameter(rs, "id_conf_trans_plugin", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN.ID_CONFIGURAZIONE_TRANSAZIONE_PLUGIN.getFieldType()));
  69.                 setParameter(object, "setEnabled", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN.ENABLED.getFieldType(),
  70.                     jdbcParameterUtilities.readParameter(rs, "enabled", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN.ENABLED.getFieldType()));
  71.                 return object;
  72.             }
  73.             if(model.equals(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO)){
  74.                 ConfigurazioneTransazioneStato object = new ConfigurazioneTransazioneStato();
  75.                 setParameter(object, "setId", Long.class,
  76.                     jdbcParameterUtilities.readParameter(rs, "id", Long.class));
  77.                 setParameter(object, "setEnabled", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.ENABLED.getFieldType(),
  78.                     jdbcParameterUtilities.readParameter(rs, "enabled", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.ENABLED.getFieldType()));
  79.                 setParameter(object, "setNome", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.NOME.getFieldType(),
  80.                     jdbcParameterUtilities.readParameter(rs, "nome", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.NOME.getFieldType()));
  81.                 setParameter(object, "setTipoControlloRawEnumValue", String.class,
  82.                     jdbcParameterUtilities.readParameter(rs, "tipo_controllo", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.TIPO_CONTROLLO.getFieldType())+"");
  83.                 setParameter(object, "setTipoMessaggioRawEnumValue", String.class,
  84.                     jdbcParameterUtilities.readParameter(rs, "tipo_messaggio", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.TIPO_MESSAGGIO.getFieldType())+"");
  85.                 setParameter(object, "setValore", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.VALORE.getFieldType(),
  86.                     jdbcParameterUtilities.readParameter(rs, "valore", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.VALORE.getFieldType()));
  87.                 setParameter(object, "setXpath", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.XPATH.getFieldType(),
  88.                     jdbcParameterUtilities.readParameter(rs, "xpath", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.XPATH.getFieldType()));
  89.                 return object;
  90.             }
  91.             if(model.equals(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO)){
  92.                 ConfigurazioneTransazioneRisorsaContenuto object = new ConfigurazioneTransazioneRisorsaContenuto();
  93.                 setParameter(object, "setId", Long.class,
  94.                     jdbcParameterUtilities.readParameter(rs, "id", Long.class));
  95.                 setParameter(object, "setAbilitaAnonimizzazione", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ABILITA_ANONIMIZZAZIONE.getFieldType(),
  96.                     jdbcParameterUtilities.readParameter(rs, "abilita_anonimizzazione", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ABILITA_ANONIMIZZAZIONE.getFieldType()));
  97.                 setParameter(object, "setAbilitaCompressione", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ABILITA_COMPRESSIONE.getFieldType(),
  98.                     jdbcParameterUtilities.readParameter(rs, "abilita_compressione", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ABILITA_COMPRESSIONE.getFieldType()));
  99.                 setParameter(object, "setTipoCompressioneRawEnumValue", String.class,
  100.                     jdbcParameterUtilities.readParameter(rs, "tipo_compressione", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.TIPO_COMPRESSIONE.getFieldType())+"");
  101.                 setParameter(object, "setCarattereMaschera", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.CARATTERE_MASCHERA.getFieldType(),
  102.                     jdbcParameterUtilities.readParameter(rs, "carattere_maschera", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.CARATTERE_MASCHERA.getFieldType()));
  103.                 setParameter(object, "setNumeroCaratteriMaschera", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.NUMERO_CARATTERI_MASCHERA.getFieldType(),
  104.                     jdbcParameterUtilities.readParameter(rs, "num_char_maschera", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.NUMERO_CARATTERI_MASCHERA.getFieldType()));
  105.                 setParameter(object, "setPosizionamentoMascheraRawEnumValue", String.class,
  106.                     jdbcParameterUtilities.readParameter(rs, "posizionamento_maschera", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.POSIZIONAMENTO_MASCHERA.getFieldType())+"");
  107.                 setParameter(object, "setTipoMascheramentoRawEnumValue", String.class,
  108.                     jdbcParameterUtilities.readParameter(rs, "tipo_mascheramento", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.TIPO_MASCHERAMENTO.getFieldType())+"");
  109.                 setParameter(object, "setEnabled", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ENABLED.getFieldType(),
  110.                     jdbcParameterUtilities.readParameter(rs, "enabled", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ENABLED.getFieldType()));
  111.                 setParameter(object, "setNome", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.NOME.getFieldType(),
  112.                     jdbcParameterUtilities.readParameter(rs, "nome", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.NOME.getFieldType()));
  113.                 setParameter(object, "setTipoMessaggioRawEnumValue", String.class,
  114.                     jdbcParameterUtilities.readParameter(rs, "tipo_messaggio", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.TIPO_MESSAGGIO.getFieldType())+"");
  115.                 setParameter(object, "setXpath", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.XPATH.getFieldType(),
  116.                     jdbcParameterUtilities.readParameter(rs, "xpath", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.XPATH.getFieldType()));
  117.                 setParameter(object, "setStatEnabled", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.STAT_ENABLED.getFieldType(),
  118.                     jdbcParameterUtilities.readParameter(rs, "stat_enabled", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.STAT_ENABLED.getFieldType()));
  119.                 return object;
  120.             }
  121.             
  122.             else{
  123.                 throw new ServiceException("Model ["+model.toString()+"] not supported by fetch: "+this.getClass().getName());
  124.             }   
  125.                     
  126.         }catch(Exception e){
  127.             throw new ServiceException("Model ["+model.toString()+"] occurs error in fetch: "+e.getMessage(),e);
  128.         }
  129.         
  130.     }
  131.     
  132.     @Override
  133.     public Object fetch(TipiDatabase tipoDatabase, IModel<?> model , Map<String,Object> map ) throws ServiceException {
  134.         
  135.         try{

  137.             if(model.equals(ConfigurazioneTransazione.model())){
  138.                 ConfigurazioneTransazione object = new ConfigurazioneTransazione();
  139.                 setParameter(object, "setId", Long.class,
  140.                     this.getObjectFromMap(map,"id"));
  141.                 setParameter(object, "setEnabled", ConfigurazioneTransazione.model().ENABLED.getFieldType(),
  142.                     this.getObjectFromMap(map,"enabled"));
  143.                 return object;
  144.             }
  145.             if(model.equals(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN)){
  146.                 ConfigurazioneTransazionePlugin object = new ConfigurazioneTransazionePlugin();
  147.                 setParameter(object, "setId", Long.class,
  148.                     this.getObjectFromMap(map,"configurazione-transazione-plugin.id"));
  149.                 setParameter(object, "setIdConfigurazioneTransazionePlugin", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN.ID_CONFIGURAZIONE_TRANSAZIONE_PLUGIN.getFieldType(),
  150.                     this.getObjectFromMap(map,"configurazione-transazione-plugin.id-configurazione-transazione-plugin"));
  151.                 setParameter(object, "setEnabled", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN.ENABLED.getFieldType(),
  152.                     this.getObjectFromMap(map,"configurazione-transazione-plugin.enabled"));
  153.                 return object;
  154.             }
  155.             if(model.equals(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO)){
  156.                 ConfigurazioneTransazioneStato object = new ConfigurazioneTransazioneStato();
  157.                 setParameter(object, "setId", Long.class,
  158.                     this.getObjectFromMap(map,"configurazione-transazione-stato.id"));
  159.                 setParameter(object, "setEnabled", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.ENABLED.getFieldType(),
  160.                     this.getObjectFromMap(map,"configurazione-transazione-stato.enabled"));
  161.                 setParameter(object, "setNome", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.NOME.getFieldType(),
  162.                     this.getObjectFromMap(map,"configurazione-transazione-stato.nome"));
  163.                 setParameter(object, "setTipoControlloRawEnumValue", String.class,
  164.                     this.getObjectFromMap(map,"configurazione-transazione-stato.tipo-controllo"));
  165.                 setParameter(object, "setTipoMessaggioRawEnumValue", String.class,
  166.                     this.getObjectFromMap(map,"configurazione-transazione-stato.tipo-messaggio"));
  167.                 setParameter(object, "setValore", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.VALORE.getFieldType(),
  168.                     this.getObjectFromMap(map,"configurazione-transazione-stato.valore"));
  169.                 setParameter(object, "setXpath", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.XPATH.getFieldType(),
  170.                     this.getObjectFromMap(map,"configurazione-transazione-stato.xpath"));
  171.                 return object;
  172.             }
  173.             if(model.equals(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO)){
  174.                 ConfigurazioneTransazioneRisorsaContenuto object = new ConfigurazioneTransazioneRisorsaContenuto();
  175.                 setParameter(object, "setId", Long.class,
  176.                     this.getObjectFromMap(map,"configurazione-transazione-risorsa-contenuto.id"));
  177.                 setParameter(object, "setAbilitaAnonimizzazione", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ABILITA_ANONIMIZZAZIONE.getFieldType(),
  178.                     this.getObjectFromMap(map,"configurazione-transazione-risorsa-contenuto.abilita-anonimizzazione"));
  179.                 setParameter(object, "setAbilitaCompressione", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ABILITA_COMPRESSIONE.getFieldType(),
  180.                     this.getObjectFromMap(map,"configurazione-transazione-risorsa-contenuto.abilita-compressione"));
  181.                 setParameter(object, "setTipoCompressioneRawEnumValue", String.class,
  182.                     this.getObjectFromMap(map,"configurazione-transazione-risorsa-contenuto.tipo-compressione"));
  183.                 setParameter(object, "setCarattereMaschera", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.CARATTERE_MASCHERA.getFieldType(),
  184.                     this.getObjectFromMap(map,"configurazione-transazione-risorsa-contenuto.carattere-maschera"));
  185.                 setParameter(object, "setNumeroCaratteriMaschera", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.NUMERO_CARATTERI_MASCHERA.getFieldType(),
  186.                     this.getObjectFromMap(map,"configurazione-transazione-risorsa-contenuto.numero-caratteri-maschera"));
  187.                 setParameter(object, "setPosizionamentoMascheraRawEnumValue", String.class,
  188.                     this.getObjectFromMap(map,"configurazione-transazione-risorsa-contenuto.posizionamento-maschera"));
  189.                 setParameter(object, "setTipoMascheramentoRawEnumValue", String.class,
  190.                     this.getObjectFromMap(map,"configurazione-transazione-risorsa-contenuto.tipo-mascheramento"));
  191.                 setParameter(object, "setEnabled", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ENABLED.getFieldType(),
  192.                     this.getObjectFromMap(map,"configurazione-transazione-risorsa-contenuto.enabled"));
  193.                 setParameter(object, "setNome", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.NOME.getFieldType(),
  194.                     this.getObjectFromMap(map,"configurazione-transazione-risorsa-contenuto.nome"));
  195.                 setParameter(object, "setTipoMessaggioRawEnumValue", String.class,
  196.                     this.getObjectFromMap(map,"configurazione-transazione-risorsa-contenuto.tipo-messaggio"));
  197.                 setParameter(object, "setXpath", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.XPATH.getFieldType(),
  198.                     this.getObjectFromMap(map,"configurazione-transazione-risorsa-contenuto.xpath"));
  199.                 setParameter(object, "setStatEnabled", ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.STAT_ENABLED.getFieldType(),
  200.                     this.getObjectFromMap(map,"configurazione-transazione-risorsa-contenuto.stat-enabled"));
  201.                 return object;
  202.             }
  203.             
  204.             else{
  205.                 throw new ServiceException("Model ["+model.toString()+"] not supported by fetch: "+this.getClass().getName());
  206.             }   
  207.                     
  208.         }catch(Exception e){
  209.             throw new ServiceException("Model ["+model.toString()+"] occurs error in fetch: "+e.getMessage(),e);
  210.         }
  211.         
  212.     }
  213.     
  214.     
  215.     @Override
  216.     public IKeyGeneratorObject getKeyGeneratorObject( IModel<?> model )  throws ServiceException {
  217.         
  218.         try{

  220.             if(model.equals(ConfigurazioneTransazione.model())){
  221.                 return new org.openspcoop2.utils.jdbc.CustomKeyGeneratorObject("config_transazioni","id","seq_config_transazioni","config_transazioni_init_seq");
  222.             }
  223.             if(model.equals(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN)){
  224.                 return new org.openspcoop2.utils.jdbc.CustomKeyGeneratorObject("config_tran_plugins","id","seq_config_tran_plugins","config_tran_plugins_init_seq");
  225.             }
  226.             if(model.equals(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO)){
  227.                 return new org.openspcoop2.utils.jdbc.CustomKeyGeneratorObject("configurazione_stati","id","seq_configurazione_stati","configurazione_stati_init_seq");
  228.             }
  229.             if(model.equals(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO)){
  230.                 return new org.openspcoop2.utils.jdbc.CustomKeyGeneratorObject("conf_risorse_contenuti","id","seq_conf_risorse_contenuti","conf_risorse_contenuti_init_seq");
  231.             }
  232.             
  233.             else{
  234.                 throw new ServiceException("Model ["+model.toString()+"] not supported by getKeyGeneratorObject: "+this.getClass().getName());
  235.             }

  237.         }catch(Exception e){
  238.             throw new ServiceException("Model ["+model.toString()+"] occurs error in getKeyGeneratorObject: "+e.getMessage(),e);
  239.         }
  240.         
  241.     }

  243. }
Created with JaCoCo 0.8.8.202204050719