DumpMessaggioFieldConverter.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.core.transazioni.dao.jdbc.converter;

  22. import org.openspcoop2.generic_project.beans.IField;
  23. import org.openspcoop2.generic_project.beans.IModel;
  24. import org.openspcoop2.generic_project.exception.ExpressionException;
  25. import org.openspcoop2.generic_project.expression.impl.sql.AbstractSQLFieldConverter;
  26. import org.openspcoop2.utils.TipiDatabase;
  27. import org.openspcoop2.core.constants.CostantiDB;
  28. import org.openspcoop2.core.transazioni.DumpMessaggio;


  31. /**     
  32.  * DumpMessaggioFieldConverter
  33.  *
  34.  * @author Poli Andrea (poli@link.it)
  35.  * @author $Author$
  36.  * @version $Rev$, $Date$
  37.  */
  38. public class DumpMessaggioFieldConverter extends AbstractSQLFieldConverter {

  40.     private TipiDatabase databaseType;
  41.     
  42.     public DumpMessaggioFieldConverter(String databaseType){
  43.         this.databaseType = TipiDatabase.toEnumConstant(databaseType);
  44.     }
  45.     public DumpMessaggioFieldConverter(TipiDatabase databaseType){
  46.         this.databaseType = databaseType;
  47.     }


  50.     @Override
  51.     public IModel<?> getRootModel() throws ExpressionException {
  52.         return DumpMessaggio.model();
  53.     }
  54.     
  55.     @Override
  56.     public TipiDatabase getDatabaseType() throws ExpressionException {
  57.         return this.databaseType;
  58.     }
  59.     


  62.     @Override
  63.     public String toColumn(IField field,boolean returnAlias,boolean appendTablePrefix) throws ExpressionException {
  64.         
  65.         // In the case of columns with alias, using parameter returnAlias​​, 
  66.         // it is possible to drive the choice whether to return only the alias or 
  67.         // the full definition of the column containing the alias
  68.         
  69.         if(field.equals(DumpMessaggio.model().ID_TRANSAZIONE)){
  70.             if(appendTablePrefix){
  71.                 return this.toAliasTable(field)+".id_transazione";
  72.             }else{
  73.                 return "id_transazione";
  74.             }
  75.         }
  76.         if(field.equals(DumpMessaggio.model().PROTOCOLLO)){
  77.             if(appendTablePrefix){
  78.                 return this.toAliasTable(field)+".protocollo";
  79.             }else{
  80.                 return "protocollo";
  81.             }
  82.         }
  83.         if(field.equals(DumpMessaggio.model().SERVIZIO_APPLICATIVO_EROGATORE)){
  84.             if(appendTablePrefix){
  85.                 return this.toAliasTable(field)+".servizio_applicativo_erogatore";
  86.             }else{
  87.                 return "servizio_applicativo_erogatore";
  88.             }
  89.         }
  90.         if(field.equals(DumpMessaggio.model().DATA_CONSEGNA_EROGATORE)){
  91.             if(appendTablePrefix){
  92.                 return this.toAliasTable(field)+".data_consegna_erogatore";
  93.             }else{
  94.                 return "data_consegna_erogatore";
  95.             }
  96.         }
  97.         if(field.equals(DumpMessaggio.model().TIPO_MESSAGGIO)){
  98.             if(appendTablePrefix){
  99.                 return this.toAliasTable(field)+".tipo_messaggio";
  100.             }else{
  101.                 return "tipo_messaggio";
  102.             }
  103.         }
  104.         if(field.equals(DumpMessaggio.model().FORMATO_MESSAGGIO)){
  105.             if(appendTablePrefix){
  106.                 return this.toAliasTable(field)+".formato_messaggio";
  107.             }else{
  108.                 return "formato_messaggio";
  109.             }
  110.         }
  111.         if(field.equals(DumpMessaggio.model().CONTENT_TYPE)){
  112.             if(appendTablePrefix){
  113.                 return this.toAliasTable(field)+".content_type";
  114.             }else{
  115.                 return "content_type";
  116.             }
  117.         }
  118.         if(field.equals(DumpMessaggio.model().CONTENT_LENGTH)){
  119.             if(appendTablePrefix){
  120.                 return this.toAliasTable(field)+".content_length";
  121.             }else{
  122.                 return "content_length";
  123.             }
  124.         }
  125.         if(field.equals(DumpMessaggio.model().MULTIPART_CONTENT_TYPE)){
  126.             if(appendTablePrefix){
  127.                 return this.toAliasTable(field)+".multipart_content_type";
  128.             }else{
  129.                 return "multipart_content_type";
  130.             }
  131.         }
  132.         if(field.equals(DumpMessaggio.model().MULTIPART_CONTENT_ID)){
  133.             if(appendTablePrefix){
  134.                 return this.toAliasTable(field)+".multipart_content_id";
  135.             }else{
  136.                 return "multipart_content_id";
  137.             }
  138.         }
  139.         if(field.equals(DumpMessaggio.model().MULTIPART_CONTENT_LOCATION)){
  140.             if(appendTablePrefix){
  141.                 return this.toAliasTable(field)+".multipart_content_location";
  142.             }else{
  143.                 return "multipart_content_location";
  144.             }
  145.         }
  146.         if(field.equals(DumpMessaggio.model().MULTIPART_HEADER.NOME)){
  147.             if(appendTablePrefix){
  148.                 return this.toAliasTable(field)+".nome";
  149.             }else{
  150.                 return "nome";
  151.             }
  152.         }
  153.         if(field.equals(DumpMessaggio.model().MULTIPART_HEADER.VALORE)){
  154.             if(appendTablePrefix){
  155.                 return this.toAliasTable(field)+".valore";
  156.             }else{
  157.                 return "valore";
  158.             }
  159.         }
  160.         if(field.equals(DumpMessaggio.model().MULTIPART_HEADER.DUMP_TIMESTAMP)){
  161.             if(appendTablePrefix){
  162.                 return this.toAliasTable(field)+".dump_timestamp";
  163.             }else{
  164.                 return "dump_timestamp";
  165.             }
  166.         }
  167.         if(field.equals(DumpMessaggio.model().BODY)){
  168.             if(appendTablePrefix){
  169.                 return this.toAliasTable(field)+".body";
  170.             }else{
  171.                 return "body";
  172.             }
  173.         }
  174.         if(field.equals(DumpMessaggio.model().HEADER_TRASPORTO.NOME)){
  175.             if(appendTablePrefix){
  176.                 return this.toAliasTable(field)+".nome";
  177.             }else{
  178.                 return "nome";
  179.             }
  180.         }
  181.         if(field.equals(DumpMessaggio.model().HEADER_TRASPORTO.VALORE)){
  182.             if(appendTablePrefix){
  183.                 return this.toAliasTable(field)+".valore";
  184.             }else{
  185.                 return "valore";
  186.             }
  187.         }
  188.         if(field.equals(DumpMessaggio.model().HEADER_TRASPORTO.DUMP_TIMESTAMP)){
  189.             if(appendTablePrefix){
  190.                 return this.toAliasTable(field)+".dump_timestamp";
  191.             }else{
  192.                 return "dump_timestamp";
  193.             }
  194.         }
  195.         if(field.equals(DumpMessaggio.model().ALLEGATO.CONTENT_TYPE)){
  196.             if(appendTablePrefix){
  197.                 return this.toAliasTable(field)+".content_type";
  198.             }else{
  199.                 return "content_type";
  200.             }
  201.         }
  202.         if(field.equals(DumpMessaggio.model().ALLEGATO.CONTENT_ID)){
  203.             if(appendTablePrefix){
  204.                 return this.toAliasTable(field)+".content_id";
  205.             }else{
  206.                 return "content_id";
  207.             }
  208.         }
  209.         if(field.equals(DumpMessaggio.model().ALLEGATO.CONTENT_LOCATION)){
  210.             if(appendTablePrefix){
  211.                 return this.toAliasTable(field)+".content_location";
  212.             }else{
  213.                 return "content_location";
  214.             }
  215.         }
  216.         if(field.equals(DumpMessaggio.model().ALLEGATO.ALLEGATO)){
  217.             if(appendTablePrefix){
  218.                 return this.toAliasTable(field)+".allegato";
  219.             }else{
  220.                 return "allegato";
  221.             }
  222.         }
  223.         if(field.equals(DumpMessaggio.model().ALLEGATO.HEADER.NOME)){
  224.             if(appendTablePrefix){
  225.                 return this.toAliasTable(field)+".nome";
  226.             }else{
  227.                 return "nome";
  228.             }
  229.         }
  230.         if(field.equals(DumpMessaggio.model().ALLEGATO.HEADER.VALORE)){
  231.             if(appendTablePrefix){
  232.                 return this.toAliasTable(field)+".valore";
  233.             }else{
  234.                 return "valore";
  235.             }
  236.         }
  237.         if(field.equals(DumpMessaggio.model().ALLEGATO.HEADER.DUMP_TIMESTAMP)){
  238.             if(appendTablePrefix){
  239.                 return this.toAliasTable(field)+".dump_timestamp";
  240.             }else{
  241.                 return "dump_timestamp";
  242.             }
  243.         }
  244.         if(field.equals(DumpMessaggio.model().ALLEGATO.DUMP_TIMESTAMP)){
  245.             if(appendTablePrefix){
  246.                 return this.toAliasTable(field)+".dump_timestamp";
  247.             }else{
  248.                 return "dump_timestamp";
  249.             }
  250.         }
  251.         if(field.equals(DumpMessaggio.model().ALLEGATO.HEADER_EXT)){
  252.             if(appendTablePrefix){
  253.                 return this.toAliasTable(field)+".header_ext";
  254.             }else{
  255.                 return "header_ext";
  256.             }
  257.         }
  258.         if(field.equals(DumpMessaggio.model().CONTENUTO.NOME)){
  259.             if(appendTablePrefix){
  260.                 return this.toAliasTable(field)+".nome";
  261.             }else{
  262.                 return "nome";
  263.             }
  264.         }
  265.         if(field.equals(DumpMessaggio.model().CONTENUTO.VALORE)){
  266.             if(appendTablePrefix){
  267.                 return this.toAliasTable(field)+".valore";
  268.             }else{
  269.                 return "valore";
  270.             }
  271.         }
  272.         if(field.equals(DumpMessaggio.model().CONTENUTO.VALORE_AS_BYTES)){
  273.             if(appendTablePrefix){
  274.                 return this.toAliasTable(field)+".valore_as_bytes";
  275.             }else{
  276.                 return "valore_as_bytes";
  277.             }
  278.         }
  279.         if(field.equals(DumpMessaggio.model().CONTENUTO.DUMP_TIMESTAMP)){
  280.             if(appendTablePrefix){
  281.                 return this.toAliasTable(field)+".dump_timestamp";
  282.             }else{
  283.                 return "dump_timestamp";
  284.             }
  285.         }
  286.         if(field.equals(DumpMessaggio.model().DUMP_TIMESTAMP)){
  287.             if(appendTablePrefix){
  288.                 return this.toAliasTable(field)+".dump_timestamp";
  289.             }else{
  290.                 return "dump_timestamp";
  291.             }
  292.         }
  293.         if(field.equals(DumpMessaggio.model().POST_PROCESS_HEADER)){
  294.             if(appendTablePrefix){
  295.                 return this.toAliasTable(field)+".post_process_header";
  296.             }else{
  297.                 return "post_process_header";
  298.             }
  299.         }
  300.         if(field.equals(DumpMessaggio.model().POST_PROCESS_FILENAME)){
  301.             if(appendTablePrefix){
  302.                 return this.toAliasTable(field)+".post_process_filename";
  303.             }else{
  304.                 return "post_process_filename";
  305.             }
  306.         }
  307.         if(field.equals(DumpMessaggio.model().POST_PROCESS_CONTENT)){
  308.             if(appendTablePrefix){
  309.                 return this.toAliasTable(field)+".post_process_content";
  310.             }else{
  311.                 return "post_process_content";
  312.             }
  313.         }
  314.         if(field.equals(DumpMessaggio.model().POST_PROCESS_CONFIG_ID)){
  315.             if(appendTablePrefix){
  316.                 return this.toAliasTable(field)+".post_process_config_id";
  317.             }else{
  318.                 return "post_process_config_id";
  319.             }
  320.         }
  321.         if(field.equals(DumpMessaggio.model().POST_PROCESS_TIMESTAMP)){
  322.             if(appendTablePrefix){
  323.                 return this.toAliasTable(field)+".post_process_timestamp";
  324.             }else{
  325.                 return "post_process_timestamp";
  326.             }
  327.         }
  328.         if(field.equals(DumpMessaggio.model().POST_PROCESSED)){
  329.             if(appendTablePrefix){
  330.                 return this.toAliasTable(field)+".post_processed";
  331.             }else{
  332.                 return "post_processed";
  333.             }
  334.         }
  335.         if(field.equals(DumpMessaggio.model().MULTIPART_HEADER_EXT)){
  336.             if(appendTablePrefix){
  337.                 return this.toAliasTable(field)+".multipart_header_ext";
  338.             }else{
  339.                 return "multipart_header_ext";
  340.             }
  341.         }
  342.         if(field.equals(DumpMessaggio.model().HEADER_EXT)){
  343.             if(appendTablePrefix){
  344.                 return this.toAliasTable(field)+".header_ext";
  345.             }else{
  346.                 return "header_ext";
  347.             }
  348.         }


  351.         return super.toColumn(field,returnAlias,appendTablePrefix);
  352.         
  353.     }
  354.     
  355.     @Override
  356.     public String toTable(IField field,boolean returnAlias) throws ExpressionException {
  357.         
  358.         // In the case of table with alias, using parameter returnAlias​​, 
  359.         // it is possible to drive the choice whether to return only the alias or 
  360.         // the full definition of the table containing the alias
  361.         
  362.         if(field.equals(DumpMessaggio.model().ID_TRANSAZIONE)){
  363.             return this.toTable(DumpMessaggio.model(), returnAlias);
  364.         }
  365.         if(field.equals(DumpMessaggio.model().PROTOCOLLO)){
  366.             return this.toTable(DumpMessaggio.model(), returnAlias);
  367.         }
  368.         if(field.equals(DumpMessaggio.model().SERVIZIO_APPLICATIVO_EROGATORE)){
  369.             return this.toTable(DumpMessaggio.model(), returnAlias);
  370.         }
  371.         if(field.equals(DumpMessaggio.model().DATA_CONSEGNA_EROGATORE)){
  372.             return this.toTable(DumpMessaggio.model(), returnAlias);
  373.         }
  374.         if(field.equals(DumpMessaggio.model().TIPO_MESSAGGIO)){
  375.             return this.toTable(DumpMessaggio.model(), returnAlias);
  376.         }
  377.         if(field.equals(DumpMessaggio.model().FORMATO_MESSAGGIO)){
  378.             return this.toTable(DumpMessaggio.model(), returnAlias);
  379.         }
  380.         if(field.equals(DumpMessaggio.model().CONTENT_TYPE)){
  381.             return this.toTable(DumpMessaggio.model(), returnAlias);
  382.         }
  383.         if(field.equals(DumpMessaggio.model().CONTENT_LENGTH)){
  384.             return this.toTable(DumpMessaggio.model(), returnAlias);
  385.         }
  386.         if(field.equals(DumpMessaggio.model().MULTIPART_CONTENT_TYPE)){
  387.             return this.toTable(DumpMessaggio.model(), returnAlias);
  388.         }
  389.         if(field.equals(DumpMessaggio.model().MULTIPART_CONTENT_ID)){
  390.             return this.toTable(DumpMessaggio.model(), returnAlias);
  391.         }
  392.         if(field.equals(DumpMessaggio.model().MULTIPART_CONTENT_LOCATION)){
  393.             return this.toTable(DumpMessaggio.model(), returnAlias);
  394.         }
  395.         if(field.equals(DumpMessaggio.model().MULTIPART_HEADER.NOME)){
  396.             return this.toTable(DumpMessaggio.model().MULTIPART_HEADER, returnAlias);
  397.         }
  398.         if(field.equals(DumpMessaggio.model().MULTIPART_HEADER.VALORE)){
  399.             return this.toTable(DumpMessaggio.model().MULTIPART_HEADER, returnAlias);
  400.         }
  401.         if(field.equals(DumpMessaggio.model().MULTIPART_HEADER.DUMP_TIMESTAMP)){
  402.             return this.toTable(DumpMessaggio.model().MULTIPART_HEADER, returnAlias);
  403.         }
  404.         if(field.equals(DumpMessaggio.model().BODY)){
  405.             return this.toTable(DumpMessaggio.model(), returnAlias);
  406.         }
  407.         if(field.equals(DumpMessaggio.model().HEADER_TRASPORTO.NOME)){
  408.             return this.toTable(DumpMessaggio.model().HEADER_TRASPORTO, returnAlias);
  409.         }
  410.         if(field.equals(DumpMessaggio.model().HEADER_TRASPORTO.VALORE)){
  411.             return this.toTable(DumpMessaggio.model().HEADER_TRASPORTO, returnAlias);
  412.         }
  413.         if(field.equals(DumpMessaggio.model().HEADER_TRASPORTO.DUMP_TIMESTAMP)){
  414.             return this.toTable(DumpMessaggio.model().HEADER_TRASPORTO, returnAlias);
  415.         }
  416.         if(field.equals(DumpMessaggio.model().ALLEGATO.CONTENT_TYPE)){
  417.             return this.toTable(DumpMessaggio.model().ALLEGATO, returnAlias);
  418.         }
  419.         if(field.equals(DumpMessaggio.model().ALLEGATO.CONTENT_ID)){
  420.             return this.toTable(DumpMessaggio.model().ALLEGATO, returnAlias);
  421.         }
  422.         if(field.equals(DumpMessaggio.model().ALLEGATO.CONTENT_LOCATION)){
  423.             return this.toTable(DumpMessaggio.model().ALLEGATO, returnAlias);
  424.         }
  425.         if(field.equals(DumpMessaggio.model().ALLEGATO.ALLEGATO)){
  426.             return this.toTable(DumpMessaggio.model().ALLEGATO, returnAlias);
  427.         }
  428.         if(field.equals(DumpMessaggio.model().ALLEGATO.HEADER.NOME)){
  429.             return this.toTable(DumpMessaggio.model().ALLEGATO.HEADER, returnAlias);
  430.         }
  431.         if(field.equals(DumpMessaggio.model().ALLEGATO.HEADER.VALORE)){
  432.             return this.toTable(DumpMessaggio.model().ALLEGATO.HEADER, returnAlias);
  433.         }
  434.         if(field.equals(DumpMessaggio.model().ALLEGATO.HEADER.DUMP_TIMESTAMP)){
  435.             return this.toTable(DumpMessaggio.model().ALLEGATO.HEADER, returnAlias);
  436.         }
  437.         if(field.equals(DumpMessaggio.model().ALLEGATO.DUMP_TIMESTAMP)){
  438.             return this.toTable(DumpMessaggio.model().ALLEGATO, returnAlias);
  439.         }
  440.         if(field.equals(DumpMessaggio.model().ALLEGATO.HEADER_EXT)){
  441.             return this.toTable(DumpMessaggio.model().ALLEGATO, returnAlias);
  442.         }
  443.         if(field.equals(DumpMessaggio.model().CONTENUTO.NOME)){
  444.             return this.toTable(DumpMessaggio.model().CONTENUTO, returnAlias);
  445.         }
  446.         if(field.equals(DumpMessaggio.model().CONTENUTO.VALORE)){
  447.             return this.toTable(DumpMessaggio.model().CONTENUTO, returnAlias);
  448.         }
  449.         if(field.equals(DumpMessaggio.model().CONTENUTO.VALORE_AS_BYTES)){
  450.             return this.toTable(DumpMessaggio.model().CONTENUTO, returnAlias);
  451.         }
  452.         if(field.equals(DumpMessaggio.model().CONTENUTO.DUMP_TIMESTAMP)){
  453.             return this.toTable(DumpMessaggio.model().CONTENUTO, returnAlias);
  454.         }
  455.         if(field.equals(DumpMessaggio.model().DUMP_TIMESTAMP)){
  456.             return this.toTable(DumpMessaggio.model(), returnAlias);
  457.         }
  458.         if(field.equals(DumpMessaggio.model().POST_PROCESS_HEADER)){
  459.             return this.toTable(DumpMessaggio.model(), returnAlias);
  460.         }
  461.         if(field.equals(DumpMessaggio.model().POST_PROCESS_FILENAME)){
  462.             return this.toTable(DumpMessaggio.model(), returnAlias);
  463.         }
  464.         if(field.equals(DumpMessaggio.model().POST_PROCESS_CONTENT)){
  465.             return this.toTable(DumpMessaggio.model(), returnAlias);
  466.         }
  467.         if(field.equals(DumpMessaggio.model().POST_PROCESS_CONFIG_ID)){
  468.             return this.toTable(DumpMessaggio.model(), returnAlias);
  469.         }
  470.         if(field.equals(DumpMessaggio.model().POST_PROCESS_TIMESTAMP)){
  471.             return this.toTable(DumpMessaggio.model(), returnAlias);
  472.         }
  473.         if(field.equals(DumpMessaggio.model().POST_PROCESSED)){
  474.             return this.toTable(DumpMessaggio.model(), returnAlias);
  475.         }
  476.         if(field.equals(DumpMessaggio.model().MULTIPART_HEADER_EXT)){
  477.             return this.toTable(DumpMessaggio.model(), returnAlias);
  478.         }
  479.         if(field.equals(DumpMessaggio.model().HEADER_EXT)){
  480.             return this.toTable(DumpMessaggio.model(), returnAlias);
  481.         }


  484.         return super.toTable(field,returnAlias);
  485.         
  486.     }

  488.     @Override
  489.     public String toTable(IModel<?> model,boolean returnAlias) throws ExpressionException {
  490.         
  491.         // In the case of table with alias, using parameter returnAlias​​, 
  492.         // it is possible to drive the choice whether to return only the alias or 
  493.         // the full definition of the table containing the alias
  494.         
  495.         if(model.equals(DumpMessaggio.model())){
  496.             return CostantiDB.DUMP_MESSAGGI;
  497.         }
  498.         if(model.equals(DumpMessaggio.model().MULTIPART_HEADER)){
  499.             return CostantiDB.DUMP_MULTIPART_HEADER;
  500.         }
  501.         if(model.equals(DumpMessaggio.model().HEADER_TRASPORTO)){
  502.             return CostantiDB.DUMP_HEADER_TRASPORTO;
  503.         }
  504.         if(model.equals(DumpMessaggio.model().ALLEGATO)){
  505.             return CostantiDB.DUMP_ALLEGATI;
  506.         }
  507.         if(model.equals(DumpMessaggio.model().ALLEGATO.HEADER)){
  508.             return CostantiDB.DUMP_ALLEGATI_HEADER;
  509.         }
  510.         if(model.equals(DumpMessaggio.model().CONTENUTO)){
  511.             return CostantiDB.DUMP_CONTENUTI;
  512.         }


  515.         return super.toTable(model,returnAlias);
  516.         
  517.     }

  519. }
Created with JaCoCo 0.8.8.202204050719