DiagnosticDriverUtilities.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.protocol.basic.diagnostica;

  23. import java.sql.Connection;
  24. import java.sql.PreparedStatement;
  25. import java.sql.ResultSet;
  26. import java.sql.SQLException;
  27. import java.sql.Timestamp;
  28. import java.text.SimpleDateFormat;
  29. import java.util.Date;
  30. import java.util.List;

  32. import org.openspcoop2.core.constants.CostantiDB;
  33. import org.openspcoop2.core.id.IDSoggetto;
  34. import org.openspcoop2.protocol.sdk.diagnostica.FiltroRicercaDiagnostici;
  35. import org.openspcoop2.protocol.sdk.diagnostica.FiltroRicercaDiagnosticiConPaginazione;
  36. import org.openspcoop2.protocol.sdk.diagnostica.MsgDiagnostico;
  37. import org.openspcoop2.utils.StringWrapper;
  38. import org.openspcoop2.utils.date.DateUtils;
  39. import org.openspcoop2.utils.sql.ISQLQueryObject;
  40. import org.openspcoop2.utils.sql.SQLObjectFactory;
  41. import org.openspcoop2.utils.sql.SQLQueryObjectException;
  42. import org.slf4j.Logger;

  44. /**
  45.  * DriverMsgDiagnosticiUtilities
  46.  *
  47.  * @author Stefano Corallo (corallo@link.it)
  48.  * @author $Author$
  49.  * @version $Rev$, $Date$
  50.  */
  51. public class DiagnosticDriverUtilities {
  52.     
  53.     private DiagnosticDriverUtilities() {}
  54.     
  55.     public static ISQLQueryObject createSQLQueryObj_searchMessaggiDiagnostici(FiltroRicercaDiagnosticiConPaginazione filter,String tipoDatabase) throws SQLQueryObjectException{
  56.         return DiagnosticDriverUtilities.createSQLQueryObj(filter, tipoDatabase, DiagnosticSearchType.MSGDIAGNOSTICI);
  57.     }
  58.     public static ISQLQueryObject createSQLQueryObj_countMessaggiDiagnostici(FiltroRicercaDiagnostici filter,String tipoDatabase) throws SQLQueryObjectException{
  59.         return DiagnosticDriverUtilities.createSQLQueryObj(filter, tipoDatabase, DiagnosticSearchType.COUNT_MSGDIAGNOSTICI);
  60.     }
  61.     public static ISQLQueryObject createSQLQueryObj_deleteMessaggiDiagnostici(FiltroRicercaDiagnostici filter,String tipoDatabase) throws SQLQueryObjectException{
  62.         ISQLQueryObject from = DiagnosticDriverUtilities.createSQLQueryObj(filter, tipoDatabase, DiagnosticSearchType.DELETE_MSGDIAGNOSTICI);
  63.         ISQLQueryObject sqlQueryObjectDelete = SQLObjectFactory.createSQLQueryObject(tipoDatabase);
  64.         sqlQueryObjectDelete.addDeleteTable(CostantiDB.MSG_DIAGNOSTICI);
  65.         sqlQueryObjectDelete.addWhereINSelectSQLCondition(false, "id", from);
  66.         return sqlQueryObjectDelete;
  67.     }
  68.     
  69.     private static ISQLQueryObject createSQLQueryObj(FiltroRicercaDiagnostici filter,String tipoDatabase,DiagnosticSearchType tipoRicerca) throws SQLQueryObjectException{
  70.         
  71.         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(tipoDatabase);
  72.         
  73.         //select field
  74.         boolean distinct = true;
  75.         switch (tipoRicerca) {
  76.         case MSGDIAGNOSTICI:
  77.             sqlQueryObject.setSelectDistinct(distinct);
  78.             sqlQueryObject.addSelectAliasField(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_ID, "idMsgDiagnostico");
  79.             sqlQueryObject.addSelectField(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_GDO);
  80.             break;
  81.         case COUNT_MSGDIAGNOSTICI:
  82.             sqlQueryObject.addSelectCountField(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_ID, "countMsgDiagnostici",distinct);
  83.             break;
  84.         case DELETE_MSGDIAGNOSTICI:
  85.             sqlQueryObject.setSelectDistinct(distinct);
  86.             sqlQueryObject.addSelectAliasField(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_ID, "idMsgDiagnostico");
  87.             break;
  88.         }
  89.         
  90.         
  91.         //from
  92.         sqlQueryObject.addFromTable(CostantiDB.MSG_DIAGNOSTICI);
  93.         
  94.         sqlQueryObject.setANDLogicOperator(true);
  95.         
  96.         
  97.         //where
  98.         
  99.         
  100.         //data inizio
  101.         if(DiagnosticDriverUtilities.isDefined(filter.getDataInizio())){
  102.             sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_GDO+">=?");
  103.         }
  104.         //data fine
  105.         if(DiagnosticDriverUtilities.isDefined(filter.getDataFine())){
  106.             sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_GDO+"<=?");
  107.         }
  108.         
  109.         if(DiagnosticDriverUtilities.isDefined(filter.getIdTransazione())){
  110.             sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_ID_TRANSAZIONE+"=?");
  111.         }
  112.         
  113.         if(DiagnosticDriverUtilities.isDefined(filter.getIdFunzione())){
  114.             String idF  = filter.getIdFunzione();
  115.             if("RicezioneContenutiApplicativi".equals(idF)
  116.                     ||"Imbustamento".equals(idF)
  117.                     ||"RicezioneBuste".equals(idF)
  118.                     ||"Sbustamento".equals(idF)
  119.             ){
  120.                 sqlQueryObject.addWhereLikeCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_IDFUNZIONE,idF,true,true);
  121.             }
  122.             else if("InoltroBuste".equals(idF)){
  123.                 sqlQueryObject.addWhereCondition(false, 
  124.                         sqlQueryObject.getWhereLikeCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_IDFUNZIONE, idF),
  125.                         sqlQueryObject.getWhereLikeCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_IDFUNZIONE, "InoltroRisposte"));
  126.             }
  127.             else if("ConsegnaContenutiApplicativi".equals(idF)){
  128.                 sqlQueryObject.addWhereLikeCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_IDFUNZIONE, idF);
  129.             }
  130.             else{
  131.                 sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_IDFUNZIONE+"=?");
  132.             }
  133.         }
  134.         if(DiagnosticDriverUtilities.isDefined(filter.getDominio())){
  135.             if(DiagnosticDriverUtilities.isDefined(filter.getDominio().getCodicePorta())){
  136.                 sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_PDD_CODICE+"=?");
  137.             }
  138.             if(DiagnosticDriverUtilities.isDefined(filter.getDominio().getTipo())){
  139.                 sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_PDD_TIPO_SOGGETTO+"=?");
  140.             }
  141.             if(DiagnosticDriverUtilities.isDefined(filter.getDominio().getNome())){
  142.                 sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_PDD_NOME_SOGGETTO+"=?");
  143.             }
  144.         }
  145.         
  146.         if(DiagnosticDriverUtilities.isDefined(filter.getIdBustaRichiesta())){
  147.             sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_IDMESSAGGIO+"=?");
  148.         }
  149.         if(DiagnosticDriverUtilities.isDefined(filter.getIdBustaRisposta())){
  150.             sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_IDMESSAGGIO_RISPOSTA+"=?");
  151.         }
  152.         
  153.         if(DiagnosticDriverUtilities.isDefined(filter.getSeverita())){
  154.             sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_SEVERITA+"<=?");
  155.         }
  156.         
  157.         if(DiagnosticDriverUtilities.isDefined(filter.getCodice())){
  158.             sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_CODICE+"=?");
  159.         }
  160.         
  161.         if( DiagnosticDriverUtilities.isDefined(filter.getMessaggioCercatoInternamenteTestoDiagnostico()) )
  162.             sqlQueryObject.addWhereLikeCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_MESSAGGIO, filter.getMessaggioCercatoInternamenteTestoDiagnostico(),true,true);
  163.         
  164.         if(DiagnosticDriverUtilities.isDefined(filter.getProtocollo())){
  165.             sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_PROTOCOLLO+"=?");
  166.         }
  167.         
  168.         if(DiagnosticDriverUtilities.isDefined(filter.getApplicativo())){
  169.             sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_APPLICATIVO+"=?");
  170.         }
  171.         else if(DiagnosticDriverUtilities.isDefined(filter.getCheckApplicativoIsNull()) && filter.getCheckApplicativoIsNull()!=null && filter.getCheckApplicativoIsNull().booleanValue()){
  172.             sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI+"."+CostantiDB.MSG_DIAGNOSTICI_COLUMN_APPLICATIVO+" is null");
  173.         }
  174.         
  175.         if(filter.getProperties()!=null){
  176.             for (String key : filter.getProperties().keySet()) {
  177.                 switch (tipoRicerca) {
  178.                 case MSGDIAGNOSTICI:
  179.                 case COUNT_MSGDIAGNOSTICI:
  180.                 case DELETE_MSGDIAGNOSTICI:
  181.                     if(DiagnosticDriver.IDDIAGNOSTICI.equals(key)){
  182.                         // Caso particolare dell'id long della traccia
  183.                         sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI+".id=?");
  184.                     }else{
  185.                         sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI+"."+key+"=?");
  186.                     }
  187.                     break;
  188.                 }
  189.             }
  190.         }
  191.         
  192.         
  193.         switch (tipoRicerca) {
  194.         case MSGDIAGNOSTICI:
  195.             
  196.             FiltroRicercaDiagnosticiConPaginazione f = (FiltroRicercaDiagnosticiConPaginazione) filter;
  197.             //limit
  198.             if(f.getLimit()>0)
  199.                 sqlQueryObject.setLimit(f.getLimit());
  200.             /**else 
  201.                 sqlQueryObject.setLimit(1000);*/
  202.             // Offset
  203.             if(f.getOffset()>0)
  204.                 sqlQueryObject.setOffset(f.getOffset());
  205.             
  206.             sqlQueryObject.addOrderBy("gdo");
  207.             sqlQueryObject.setSortType(f.isAsc());  
  208.             break;
  209.         case COUNT_MSGDIAGNOSTICI:
  210.         case DELETE_MSGDIAGNOSTICI:
  211.             // Niente da effettuare
  212.             break;
  213.         }
  214.                 
  215.         return sqlQueryObject;

  217.     }
  218.     
  219.     public static int setValues_searchMessaggiDiagnostici(FiltroRicercaDiagnostici filter,Object object,int startIndex) throws SQLQueryObjectException, SQLException{
  220.         return DiagnosticDriverUtilities.setValuesSearch(filter, object,startIndex, DiagnosticSearchType.MSGDIAGNOSTICI);
  221.     }
  222.     public static int setValues_countMessaggiDiagnostici(FiltroRicercaDiagnostici filter,Object object,int startIndex) throws SQLQueryObjectException, SQLException{
  223.         return DiagnosticDriverUtilities.setValuesSearch(filter, object,startIndex, DiagnosticSearchType.COUNT_MSGDIAGNOSTICI);
  224.     }
  225.     public static int setValues_deleteMessaggiDiagnostici(FiltroRicercaDiagnostici filter,Object object,int startIndex) throws SQLQueryObjectException, SQLException{
  226.         return DiagnosticDriverUtilities.setValuesSearch(filter, object,startIndex, DiagnosticSearchType.DELETE_MSGDIAGNOSTICI);
  227.     }
  228.         
  229.     private static int setValuesSearch(FiltroRicercaDiagnostici filter,Object object,int startIndex, DiagnosticSearchType tipoRicerca) throws SQLException{
  230.         
  231.         if(tipoRicerca!=null) {
  232.             // nop
  233.         }
  234.         
  235.         SimpleDateFormat dateformat = DateUtils.getSimpleDateFormatMs();
  236.         
  237.         PreparedStatement pstmt = null;
  238.         StringWrapper query = null;
  239.         if(object instanceof PreparedStatement){
  240.             pstmt = (PreparedStatement) object;
  241.         }
  242.         else if(object instanceof StringWrapper){
  243.             query = (StringWrapper) object;
  244.         }
  245.         else{
  246.             throw new SQLException("Tipo di parametro ["+object.getClass().getName()+"] non gestito");
  247.         }
  248.         
  249.         
  250.         
  251.         //where
  252.         
  253.         
  254.         //data inizio
  255.         if(DiagnosticDriverUtilities.isDefined(filter.getDataInizio())){
  256.             if(pstmt!=null)
  257.                 pstmt.setTimestamp(startIndex++, new Timestamp(filter.getDataInizio().getTime()));
  258.             if(query!=null)
  259.                 query.replaceFirst("\\?","'"+dateformat.format(filter.getDataInizio())+"'");
  260.         }
  261.         //data fine
  262.         if(DiagnosticDriverUtilities.isDefined(filter.getDataFine())){
  263.             if(pstmt!=null)
  264.                 pstmt.setTimestamp(startIndex++, new Timestamp(filter.getDataFine().getTime()));
  265.             if(query!=null)
  266.                 query.replaceFirst("\\?","'"+dateformat.format(filter.getDataFine())+"'");
  267.         }
  268.         
  269.         // id transazione
  270.         if(DiagnosticDriverUtilities.isDefined(filter.getIdTransazione())){
  271.             if(pstmt!=null)
  272.                 pstmt.setString(startIndex++, filter.getIdTransazione());
  273.             if(query!=null)
  274.                 query.replaceFirst("\\?","'"+filter.getIdTransazione()+"'");
  275.         }
  276.         
  277.         if(DiagnosticDriverUtilities.isDefined(filter.getIdFunzione())){
  278.             String idF  = filter.getIdFunzione();
  279.             if("RicezioneContenutiApplicativi".equals(idF)
  280.                     ||"Imbustamento".equals(idF)
  281.                     ||"RicezioneBuste".equals(idF)
  282.                     ||"Sbustamento".equals(idF)
  283.             ){
  284.                 // Like impostato in sqlQueryObject
  285.             }
  286.             else if("InoltroBuste".equals(idF)){
  287.                 // Like impostato in sqlQueryObject
  288.             }
  289.             else if("ConsegnaContenutiApplicativi".equals(idF)){
  290.                 // Like impostato in sqlQueryObject
  291.             }
  292.             else{
  293.                 if(pstmt!=null)
  294.                     pstmt.setString(startIndex++, idF);
  295.                 if(query!=null)
  296.                     query.replaceFirst("\\?","'"+idF+"'");
  297.             }
  298.         }
  299.         if(DiagnosticDriverUtilities.isDefined(filter.getDominio())){
  300.             if(DiagnosticDriverUtilities.isDefined(filter.getDominio().getCodicePorta())){
  301.                 if(pstmt!=null)
  302.                     pstmt.setString(startIndex++, filter.getDominio().getCodicePorta());
  303.                 if(query!=null)
  304.                     query.replaceFirst("\\?","'"+filter.getDominio().getCodicePorta()+"'");
  305.             }
  306.             if(DiagnosticDriverUtilities.isDefined(filter.getDominio().getTipo())){
  307.                 if(pstmt!=null)
  308.                     pstmt.setString(startIndex++, filter.getDominio().getTipo());
  309.                 if(query!=null)
  310.                     query.replaceFirst("\\?","'"+filter.getDominio().getTipo()+"'");
  311.             }
  312.             if(DiagnosticDriverUtilities.isDefined(filter.getDominio().getNome())){
  313.                 if(pstmt!=null)
  314.                     pstmt.setString(startIndex++, filter.getDominio().getNome());
  315.                 if(query!=null)
  316.                     query.replaceFirst("\\?","'"+filter.getDominio().getNome()+"'");
  317.             }
  318.         }
  319.         
  320.         if(DiagnosticDriverUtilities.isDefined(filter.getIdBustaRichiesta())){
  321.             if(pstmt!=null)
  322.                 pstmt.setString(startIndex++, filter.getIdBustaRichiesta());
  323.             if(query!=null)
  324.                 query.replaceFirst("\\?","'"+filter.getIdBustaRichiesta()+"'");
  325.         }
  326.         if(DiagnosticDriverUtilities.isDefined(filter.getIdBustaRisposta())){
  327.             if(pstmt!=null)
  328.                 pstmt.setString(startIndex++, filter.getIdBustaRisposta());
  329.             if(query!=null)
  330.                 query.replaceFirst("\\?","'"+filter.getIdBustaRisposta()+"'");
  331.         }
  332.                 
  333.         if(DiagnosticDriverUtilities.isDefined(filter.getSeverita())){
  334.             if(pstmt!=null)
  335.                 pstmt.setInt(startIndex++, filter.getSeverita());
  336.             if(query!=null)
  337.                 query.replaceFirst("\\?",filter.getSeverita()+"");
  338.         }
  339.         
  340.         if(DiagnosticDriverUtilities.isDefined(filter.getCodice())){
  341.             if(pstmt!=null)
  342.                 pstmt.setString(startIndex++, filter.getCodice());
  343.             if(query!=null)
  344.                 query.replaceFirst("\\?","'"+filter.getCodice()+"'");
  345.         }
  346.         
  347.         if(DiagnosticDriverUtilities.isDefined(filter.getProtocollo())){
  348.             if(pstmt!=null)
  349.                 pstmt.setString(startIndex++, filter.getProtocollo());
  350.             if(query!=null)
  351.                 query.replaceFirst("\\?","'"+filter.getProtocollo()+"'");
  352.         }
  353.         
  354.         if(DiagnosticDriverUtilities.isDefined(filter.getApplicativo())){
  355.             if(pstmt!=null)
  356.                 pstmt.setString(startIndex++, filter.getApplicativo());
  357.             if(query!=null)
  358.                 query.replaceFirst("\\?","'"+filter.getApplicativo()+"'");
  359.         }
  360.         else if(DiagnosticDriverUtilities.isDefined(filter.getCheckApplicativoIsNull()) && filter.getCheckApplicativoIsNull()!=null && filter.getCheckApplicativoIsNull().booleanValue()){
  361.             // nop
  362.         }
  363.         
  364.         if(filter.getProperties()!=null){
  365.             for (String key : filter.getProperties().keySet()) {
  366.                 String value = filter.getProperties().get(key);
  367.                 if(DiagnosticDriver.IDDIAGNOSTICI.equals(key)){
  368.                     // Caso particolare dell'id long della traccia
  369.                     if(pstmt!=null)
  370.                         pstmt.setLong(startIndex++, Long.parseLong(value));
  371.                     if(query!=null)
  372.                         query.replaceFirst("\\?",value);
  373.                 }else{
  374.                     if(pstmt!=null)
  375.                         pstmt.setString(startIndex++, value);
  376.                     if(query!=null)
  377.                         query.replaceFirst("\\?","'"+value+"'");
  378.                 }
  379.             }
  380.         }
  381.         
  382.         
  383.         return startIndex;
  384.     }
  385.     
  386.     
  387.     public static MsgDiagnostico getMsgDiagnostico(Connection c,String tipoDatabase, 
  388.             Logger log,long id,List<String> properties) throws SQLQueryObjectException, SQLException {
  389.         
  390.         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(tipoDatabase);
  391.         sqlQueryObject.addFromTable(CostantiDB.MSG_DIAGNOSTICI);
  392.         sqlQueryObject.addWhereCondition(CostantiDB.MSG_DIAGNOSTICI_COLUMN_ID+"=?");
  393.         
  394.         String msgD = "Eseguo query : "+sqlQueryObject.createSQLQuery().replaceFirst("\\?", id+"");
  395.         log.debug(msgD);
  396.         PreparedStatement stmt=null;
  397.         ResultSet rs= null;
  398.         try{
  399.             stmt=c.prepareStatement(sqlQueryObject.createSQLQuery());
  400.             stmt.setLong(1, id);
  401.             rs=stmt.executeQuery();
  402.             if(rs.next()){
  403.                 
  404.                 MsgDiagnostico msg = new MsgDiagnostico();
  405.                 
  406.                 msg.setId(rs.getLong(CostantiDB.MSG_DIAGNOSTICI_COLUMN_ID));
  407.                 msg.addProperty(DiagnosticDriver.IDDIAGNOSTICI, msg.getId()+"");
  408.                 
  409.                 Timestamp gdo=rs.getTimestamp(CostantiDB.MSG_DIAGNOSTICI_COLUMN_GDO);
  410.                 msg.setGdo(gdo);
  411.                 
  412.                 msg.setIdTransazione(rs.getString(CostantiDB.MSG_DIAGNOSTICI_COLUMN_ID_TRANSAZIONE));
  413.                 
  414.                 msg.setApplicativo(rs.getString(CostantiDB.MSG_DIAGNOSTICI_COLUMN_APPLICATIVO));
  415.                 
  416.                 IDSoggetto idSoggetto = new IDSoggetto();
  417.                 idSoggetto.setCodicePorta(rs.getString(CostantiDB.MSG_DIAGNOSTICI_COLUMN_PDD_CODICE));
  418.                 idSoggetto.setNome(rs.getString(CostantiDB.MSG_DIAGNOSTICI_COLUMN_PDD_NOME_SOGGETTO));
  419.                 idSoggetto.setTipo(rs.getString(CostantiDB.MSG_DIAGNOSTICI_COLUMN_PDD_TIPO_SOGGETTO));
  420.                 msg.setIdSoggetto(idSoggetto);
  421.                 
  422.                 msg.setIdFunzione(rs.getString(CostantiDB.MSG_DIAGNOSTICI_COLUMN_IDFUNZIONE));

  424.                 msg.setSeverita(rs.getInt(CostantiDB.MSG_DIAGNOSTICI_COLUMN_SEVERITA));
  425.                 
  426.                 msg.setMessaggio(rs.getString(CostantiDB.MSG_DIAGNOSTICI_COLUMN_MESSAGGIO));
  427.                 
  428.                 msg.setIdBusta(rs.getString(CostantiDB.MSG_DIAGNOSTICI_COLUMN_IDMESSAGGIO));
  429.                 
  430.                 msg.setIdBustaRisposta(rs.getString(CostantiDB.MSG_DIAGNOSTICI_COLUMN_IDMESSAGGIO_RISPOSTA));
  431.                 
  432.                 msg.setCodice(rs.getString(CostantiDB.MSG_DIAGNOSTICI_COLUMN_CODICE));
  433.                 
  434.                 msg.setProtocollo(rs.getString(CostantiDB.MSG_DIAGNOSTICI_COLUMN_PROTOCOLLO));
  435.                 
  436.                 if(properties!=null){
  437.                     for (int i = 0; i < properties.size(); i++) {
  438.                         String key = properties.get(i);
  439.                         msg.addProperty(key, rs.getString(key));
  440.                     }
  441.                 }
  442.                 
  443.                 return msg;
  444.                 
  445.             }
  446.             else{
  447.                 
  448.                 throw new SQLQueryObjectException("MsgDiagnostico con id["+id+"] non trovato");
  449.                 
  450.             }
  451.         }finally{
  452.             try{
  453.                 if(rs!=null){
  454.                     rs.close();
  455.                 }
  456.             }catch(Exception eClose){
  457.                 // close
  458.             }
  459.             try{
  460.                 if(stmt!=null){
  461.                     stmt.close();
  462.                 }
  463.             }catch(Exception eClose){
  464.                 // close
  465.             }
  466.         }
  467.     }
  468.     
  469.     
  470.     
  471.     protected static boolean isDefined(String v){
  472.         return v!=null && !"".equals(v);
  473.     }
  474.     protected static boolean isDefined(Boolean v){
  475.         return v!=null;
  476.     }
  477.     protected static boolean isDefined(Integer v){
  478.         return v!=null;
  479.     }
  480.     protected static boolean isDefined(List<?> v){
  481.         return v!=null && !v.isEmpty();
  482.     }
  483.     protected static boolean isDefined(Date v){
  484.         return v!=null;
  485.     }
  486.     protected static boolean isDefined(IDSoggetto v){
  487.         return v!=null;
  488.     }
  489. }
Created with JaCoCo 0.8.8.202204050719