JDBCTransazioneServiceImpl.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;

  22. import java.sql.Connection;
  23. import java.util.ArrayList;
  24. import java.util.Date;
  25. import java.util.List;

  27. import org.openspcoop2.utils.TipiDatabase;
  28. import org.openspcoop2.utils.date.DateUtils;
  29. import org.openspcoop2.utils.date.UnitaTemporale;
  30. import org.openspcoop2.utils.jdbc.JDBCAdapterException;
  31. import org.openspcoop2.utils.sql.ISQLQueryObject;
  32. import org.openspcoop2.utils.sql.SQLQueryObjectException;
  33. import org.slf4j.Logger;

  35. import org.openspcoop2.generic_project.dao.jdbc.IJDBCServiceCRUDWithId;
  36. import java.lang.String;
  37. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  38. import org.openspcoop2.generic_project.beans.UpdateField;
  39. import org.openspcoop2.generic_project.beans.UpdateModel;

  41. import org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities;
  42. import org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject;
  43. import org.openspcoop2.generic_project.exception.ExpressionException;
  44. import org.openspcoop2.generic_project.exception.NotFoundException;
  45. import org.openspcoop2.generic_project.exception.NotImplementedException;
  46. import org.openspcoop2.generic_project.exception.ServiceException;
  47. import org.openspcoop2.generic_project.expression.IExpression;
  48. import org.openspcoop2.generic_project.dao.jdbc.JDBCExpression;
  49. import org.openspcoop2.generic_project.dao.jdbc.JDBCPaginatedExpression;

  51. import org.openspcoop2.generic_project.dao.jdbc.JDBCServiceManagerProperties;

  53. import org.openspcoop2.core.transazioni.Transazione;
  54. import org.openspcoop2.core.transazioni.TransazioneExtendedInfo;
  55. import org.openspcoop2.core.transazioni.utils.TransazioneDaoExt;

  57. /**     
  58.  * JDBCTransazioneServiceImpl
  59.  *
  60.  * @author Poli Andrea (poli@link.it)
  61.  * @author $Author$
  62.  * @version $Rev$, $Date$
  63.  */
  64. public class JDBCTransazioneServiceImpl extends JDBCTransazioneServiceSearchImpl
  65.     implements IJDBCServiceCRUDWithId<Transazione, String, JDBCServiceManager> {

  67.     @Override
  68.     public void create(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Transazione transazione, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {

  70.         if(TipiDatabase.POSTGRESQL.equals(jdbcProperties.getDatabase())){
  71.             if(transazione.getFaultCooperazione()!=null && org.openspcoop2.utils.jdbc.PostgreSQLUtilities.containsNullByteSequence(transazione.getFaultCooperazione())) {
  72.                 transazione.setFaultCooperazione(org.openspcoop2.utils.jdbc.PostgreSQLUtilities.normalizeString(transazione.getFaultCooperazione()));
  73.             }
  74.             if(transazione.getFaultIntegrazione()!=null && org.openspcoop2.utils.jdbc.PostgreSQLUtilities.containsNullByteSequence(transazione.getFaultIntegrazione())) {
  75.                 transazione.setFaultIntegrazione(org.openspcoop2.utils.jdbc.PostgreSQLUtilities.normalizeString(transazione.getFaultIntegrazione()));
  76.             }
  77.             if(transazione.getCredenziali()!=null && org.openspcoop2.utils.jdbc.PostgreSQLUtilities.containsNullByteSequence(transazione.getCredenziali())) {
  78.                 transazione.setCredenziali(org.openspcoop2.utils.jdbc.PostgreSQLUtilities.normalizeString(transazione.getCredenziali()));
  79.             }
  80.         }
  81.             
  82.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  83.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  84.         
  85.         ISQLQueryObject sqlQueryObjectInsert = sqlQueryObject.newSQLQueryObject();
  86.                 


  89.         // Object transazione
  90.         sqlQueryObjectInsert.addInsertTable(this.getTransazioneFieldConverter().toTable(Transazione.model()));
  91.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_TRANSAZIONE,false),"?");
  92.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().STATO,false),"?");
  93.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().RUOLO_TRANSAZIONE,false),"?");
  94.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ESITO,false),"?");
  95.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ESITO_SINCRONO,false),"?");
  96.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().CONSEGNE_MULTIPLE_IN_CORSO,false),"?");
  97.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ESITO_CONTESTO,false),"?");
  98.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PROTOCOLLO,false),"?");
  99.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TIPO_RICHIESTA,false),"?");
  100.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().CODICE_RISPOSTA_INGRESSO,false),"?");
  101.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().CODICE_RISPOSTA_USCITA,false),"?");
  102.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_ACCETTAZIONE_RICHIESTA,false),"?");
  103.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_INGRESSO_RICHIESTA,false),"?");
  104.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_INGRESSO_RICHIESTA_STREAM,false),"?");
  105.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_USCITA_RICHIESTA,false),"?");
  106.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_USCITA_RICHIESTA_STREAM,false),"?");
  107.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_ACCETTAZIONE_RISPOSTA,false),"?");
  108.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_INGRESSO_RISPOSTA,false),"?");
  109.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_INGRESSO_RISPOSTA_STREAM,false),"?");
  110.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_USCITA_RISPOSTA,false),"?");
  111.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_USCITA_RISPOSTA_STREAM,false),"?");
  112.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().RICHIESTA_INGRESSO_BYTES,false),"?");
  113.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().RICHIESTA_USCITA_BYTES,false),"?");
  114.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().RISPOSTA_INGRESSO_BYTES,false),"?");
  115.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().RISPOSTA_USCITA_BYTES,false),"?");
  116.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PDD_CODICE,false),"?");
  117.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PDD_TIPO_SOGGETTO,false),"?");
  118.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PDD_NOME_SOGGETTO,false),"?");
  119.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PDD_RUOLO,false),"?");
  120.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().FAULT_INTEGRAZIONE,false),"?");
  121.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().FORMATO_FAULT_INTEGRAZIONE,false),"?");
  122.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().FAULT_COOPERAZIONE,false),"?");
  123.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().FORMATO_FAULT_COOPERAZIONE,false),"?");
  124.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TIPO_SOGGETTO_FRUITORE,false),"?");
  125.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().NOME_SOGGETTO_FRUITORE,false),"?");
  126.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().IDPORTA_SOGGETTO_FRUITORE,false),"?");
  127.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().INDIRIZZO_SOGGETTO_FRUITORE,false),"?");
  128.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TIPO_SOGGETTO_EROGATORE,false),"?");
  129.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().NOME_SOGGETTO_EROGATORE,false),"?");
  130.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().IDPORTA_SOGGETTO_EROGATORE,false),"?");
  131.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().INDIRIZZO_SOGGETTO_EROGATORE,false),"?");
  132.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_MESSAGGIO_RICHIESTA,false),"?");
  133.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_MESSAGGIO_RISPOSTA,false),"?");
  134.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_ID_MSG_RICHIESTA,false),"?");
  135.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_ID_MSG_RISPOSTA,false),"?");
  136.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PROFILO_COLLABORAZIONE_OP_2,false),"?");
  137.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PROFILO_COLLABORAZIONE_PROT,false),"?");
  138.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_COLLABORAZIONE,false),"?");
  139.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().URI_ACCORDO_SERVIZIO,false),"?");
  140.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TIPO_SERVIZIO,false),"?");
  141.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().NOME_SERVIZIO,false),"?");
  142.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().VERSIONE_SERVIZIO,false),"?");
  143.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().AZIONE,false),"?");
  144.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_ASINCRONO,false),"?");
  145.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TIPO_SERVIZIO_CORRELATO,false),"?");
  146.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().NOME_SERVIZIO_CORRELATO,false),"?");
  147.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().HEADER_PROTOCOLLO_RICHIESTA,false),"?");
  148.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DIGEST_RICHIESTA,false),"?");
  149.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PROTOCOLLO_EXT_INFO_RICHIESTA,false),"?");
  150.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().HEADER_PROTOCOLLO_RISPOSTA,false),"?");
  151.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DIGEST_RISPOSTA,false),"?");
  152.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PROTOCOLLO_EXT_INFO_RISPOSTA,false),"?");
  153.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TRACCIA_RICHIESTA,false),"?");
  154.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TRACCIA_RISPOSTA,false),"?");
  155.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DIAGNOSTICI,false),"?");
  156.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DIAGNOSTICI_LIST_1,false),"?");
  157.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DIAGNOSTICI_LIST_2,false),"?");
  158.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DIAGNOSTICI_LIST_EXT,false),"?");
  159.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DIAGNOSTICI_EXT,false),"?");
  160.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ERROR_LOG,false),"?");
  161.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().WARNING_LOG,false),"?");
  162.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_CORRELAZIONE_APPLICATIVA,false),"?");
  163.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_CORRELAZIONE_APPLICATIVA_RISPOSTA,false),"?");
  164.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().SERVIZIO_APPLICATIVO_FRUITORE,false),"?");
  165.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().SERVIZIO_APPLICATIVO_EROGATORE,false),"?");
  166.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().OPERAZIONE_IM,false),"?");
  167.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().LOCATION_RICHIESTA,false),"?");
  168.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().LOCATION_RISPOSTA,false),"?");
  169.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().NOME_PORTA,false),"?");
  170.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().CREDENZIALI,false),"?");
  171.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().LOCATION_CONNETTORE,false),"?");
  172.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().URL_INVOCAZIONE,false),"?");
  173.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TRASPORTO_MITTENTE,false),"?");
  174.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TOKEN_ISSUER,false),"?");
  175.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TOKEN_CLIENT_ID,false),"?");
  176.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TOKEN_SUBJECT,false),"?");
  177.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TOKEN_USERNAME,false),"?");
  178.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TOKEN_MAIL,false),"?");
  179.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TOKEN_INFO,false),"?");
  180.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TEMPI_ELABORAZIONE,false),"?");
  181.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DUPLICATI_RICHIESTA,false),"?");
  182.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DUPLICATI_RISPOSTA,false),"?");
  183.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().CLUSTER_ID,false),"?");
  184.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().SOCKET_CLIENT_ADDRESS,false),"?");
  185.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TRANSPORT_CLIENT_ADDRESS,false),"?");
  186.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().CLIENT_ADDRESS,false),"?");
  187.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().EVENTI_GESTIONE,false),"?");
  188.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TIPO_API,false),"?");
  189.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().URI_API,false),"?");
  190.         sqlQueryObjectInsert.addInsertField(this.getTransazioneFieldConverter().toColumn(Transazione.model().GRUPPI,false),"?");
  191.         if(transazione.sizeTransazioneExtendedInfoList()>0){
  192.             for (TransazioneExtendedInfo transazioneExtedendInfo : transazione.getTransazioneExtendedInfoList()) {
  193.                 sqlQueryObjectInsert.addInsertField(transazioneExtedendInfo.getNome(),"?");
  194.             }
  195.         }
  196.             
  197.         // Insert transazione
  198.         String insertSql = sqlQueryObjectInsert.createSQLInsert();
  199.         List<JDBCObject> listaJDBCObject = new ArrayList<>();
  200.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getIdTransazione(),Transazione.model().ID_TRANSAZIONE.getFieldType()) );
  201.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getStato(),Transazione.model().STATO.getFieldType()) );
  202.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getRuoloTransazione(),Transazione.model().RUOLO_TRANSAZIONE.getFieldType()) );
  203.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getEsito(),Transazione.model().ESITO.getFieldType()) );
  204.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getEsitoSincrono(),Transazione.model().ESITO_SINCRONO.getFieldType()) );
  205.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getConsegneMultipleInCorso(),Transazione.model().CONSEGNE_MULTIPLE_IN_CORSO.getFieldType()) );
  206.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getEsitoContesto(),Transazione.model().ESITO_CONTESTO.getFieldType()) );
  207.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getProtocollo(),Transazione.model().PROTOCOLLO.getFieldType()) );
  208.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTipoRichiesta(),Transazione.model().TIPO_RICHIESTA.getFieldType()) );
  209.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getCodiceRispostaIngresso(),Transazione.model().CODICE_RISPOSTA_INGRESSO.getFieldType()) );
  210.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getCodiceRispostaUscita(),Transazione.model().CODICE_RISPOSTA_USCITA.getFieldType()) );
  211.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDataAccettazioneRichiesta(),Transazione.model().DATA_ACCETTAZIONE_RICHIESTA.getFieldType()) );
  212.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDataIngressoRichiesta(),Transazione.model().DATA_INGRESSO_RICHIESTA.getFieldType()) );
  213.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDataIngressoRichiestaStream(),Transazione.model().DATA_INGRESSO_RICHIESTA_STREAM.getFieldType()) );
  214.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDataUscitaRichiesta(),Transazione.model().DATA_USCITA_RICHIESTA.getFieldType()) );
  215.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDataUscitaRichiestaStream(),Transazione.model().DATA_USCITA_RICHIESTA_STREAM.getFieldType()) );
  216.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDataAccettazioneRisposta(),Transazione.model().DATA_ACCETTAZIONE_RISPOSTA.getFieldType()) );
  217.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDataIngressoRisposta(),Transazione.model().DATA_INGRESSO_RISPOSTA.getFieldType()) );
  218.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDataIngressoRispostaStream(),Transazione.model().DATA_INGRESSO_RISPOSTA_STREAM.getFieldType()) );
  219.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDataUscitaRisposta(),Transazione.model().DATA_USCITA_RISPOSTA.getFieldType()) );
  220.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDataUscitaRispostaStream(),Transazione.model().DATA_USCITA_RISPOSTA_STREAM.getFieldType()) );
  221.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getRichiestaIngressoBytes(),Transazione.model().RICHIESTA_INGRESSO_BYTES.getFieldType()) );
  222.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getRichiestaUscitaBytes(),Transazione.model().RICHIESTA_USCITA_BYTES.getFieldType()) );
  223.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getRispostaIngressoBytes(),Transazione.model().RISPOSTA_INGRESSO_BYTES.getFieldType()) );
  224.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getRispostaUscitaBytes(),Transazione.model().RISPOSTA_USCITA_BYTES.getFieldType()) );
  225.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getPddCodice(),Transazione.model().PDD_CODICE.getFieldType()) );
  226.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getPddTipoSoggetto(),Transazione.model().PDD_TIPO_SOGGETTO.getFieldType()) );
  227.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getPddNomeSoggetto(),Transazione.model().PDD_NOME_SOGGETTO.getFieldType()) );
  228.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getPddRuolo(),Transazione.model().PDD_RUOLO.getFieldType()) );
  229.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getFaultIntegrazione(),Transazione.model().FAULT_INTEGRAZIONE.getFieldType()) );
  230.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getFormatoFaultIntegrazione(),Transazione.model().FORMATO_FAULT_INTEGRAZIONE.getFieldType()) );
  231.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getFaultCooperazione(),Transazione.model().FAULT_COOPERAZIONE.getFieldType()) );
  232.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getFormatoFaultCooperazione(),Transazione.model().FORMATO_FAULT_COOPERAZIONE.getFieldType()) );
  233.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTipoSoggettoFruitore(),Transazione.model().TIPO_SOGGETTO_FRUITORE.getFieldType()) );
  234.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getNomeSoggettoFruitore(),Transazione.model().NOME_SOGGETTO_FRUITORE.getFieldType()) );
  235.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getIdportaSoggettoFruitore(),Transazione.model().IDPORTA_SOGGETTO_FRUITORE.getFieldType()) );
  236.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getIndirizzoSoggettoFruitore(),Transazione.model().INDIRIZZO_SOGGETTO_FRUITORE.getFieldType()) );
  237.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTipoSoggettoErogatore(),Transazione.model().TIPO_SOGGETTO_EROGATORE.getFieldType()) );
  238.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getNomeSoggettoErogatore(),Transazione.model().NOME_SOGGETTO_EROGATORE.getFieldType()) );
  239.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getIdportaSoggettoErogatore(),Transazione.model().IDPORTA_SOGGETTO_EROGATORE.getFieldType()) );
  240.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getIndirizzoSoggettoErogatore(),Transazione.model().INDIRIZZO_SOGGETTO_EROGATORE.getFieldType()) );
  241.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getIdMessaggioRichiesta(),Transazione.model().ID_MESSAGGIO_RICHIESTA.getFieldType()) );
  242.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getIdMessaggioRisposta(),Transazione.model().ID_MESSAGGIO_RISPOSTA.getFieldType()) );
  243.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDataIdMsgRichiesta(),Transazione.model().DATA_ID_MSG_RICHIESTA.getFieldType()) );
  244.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDataIdMsgRisposta(),Transazione.model().DATA_ID_MSG_RISPOSTA.getFieldType()) );
  245.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getProfiloCollaborazioneOp2(),Transazione.model().PROFILO_COLLABORAZIONE_OP_2.getFieldType()) );
  246.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getProfiloCollaborazioneProt(),Transazione.model().PROFILO_COLLABORAZIONE_PROT.getFieldType()) );
  247.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getIdCollaborazione(),Transazione.model().ID_COLLABORAZIONE.getFieldType()) );
  248.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getUriAccordoServizio(),Transazione.model().URI_ACCORDO_SERVIZIO.getFieldType()) );
  249.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTipoServizio(),Transazione.model().TIPO_SERVIZIO.getFieldType()) );
  250.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getNomeServizio(),Transazione.model().NOME_SERVIZIO.getFieldType()) );
  251.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getVersioneServizio(),Transazione.model().VERSIONE_SERVIZIO.getFieldType()) );
  252.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getAzione(),Transazione.model().AZIONE.getFieldType()) );
  253.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getIdAsincrono(),Transazione.model().ID_ASINCRONO.getFieldType()) );
  254.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTipoServizioCorrelato(),Transazione.model().TIPO_SERVIZIO_CORRELATO.getFieldType()) );
  255.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getNomeServizioCorrelato(),Transazione.model().NOME_SERVIZIO_CORRELATO.getFieldType()) );
  256.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getHeaderProtocolloRichiesta(),Transazione.model().HEADER_PROTOCOLLO_RICHIESTA.getFieldType()) );
  257.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDigestRichiesta(),Transazione.model().DIGEST_RICHIESTA.getFieldType()) );
  258.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getProtocolloExtInfoRichiesta(),Transazione.model().PROTOCOLLO_EXT_INFO_RICHIESTA.getFieldType()) );
  259.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getHeaderProtocolloRisposta(),Transazione.model().HEADER_PROTOCOLLO_RISPOSTA.getFieldType()) );
  260.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDigestRisposta(),Transazione.model().DIGEST_RISPOSTA.getFieldType()) );
  261.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getProtocolloExtInfoRisposta(),Transazione.model().PROTOCOLLO_EXT_INFO_RISPOSTA.getFieldType()) );
  262.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTracciaRichiesta(),Transazione.model().TRACCIA_RICHIESTA.getFieldType()) );
  263.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTracciaRisposta(),Transazione.model().TRACCIA_RISPOSTA.getFieldType()) );
  264.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDiagnostici(),Transazione.model().DIAGNOSTICI.getFieldType()) );
  265.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDiagnosticiList1(),Transazione.model().DIAGNOSTICI_LIST_1.getFieldType()) );
  266.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDiagnosticiList2(),Transazione.model().DIAGNOSTICI_LIST_2.getFieldType()) );
  267.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDiagnosticiListExt(),Transazione.model().DIAGNOSTICI_LIST_EXT.getFieldType()) );
  268.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDiagnosticiExt(),Transazione.model().DIAGNOSTICI_EXT.getFieldType()) );
  269.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getErrorLog(),Transazione.model().ERROR_LOG.getFieldType()) );
  270.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getWarningLog(),Transazione.model().WARNING_LOG.getFieldType()) );
  271.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getIdCorrelazioneApplicativa(),Transazione.model().ID_CORRELAZIONE_APPLICATIVA.getFieldType()) );
  272.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getIdCorrelazioneApplicativaRisposta(),Transazione.model().ID_CORRELAZIONE_APPLICATIVA_RISPOSTA.getFieldType()) );
  273.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getServizioApplicativoFruitore(),Transazione.model().SERVIZIO_APPLICATIVO_FRUITORE.getFieldType()) );
  274.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getServizioApplicativoErogatore(),Transazione.model().SERVIZIO_APPLICATIVO_EROGATORE.getFieldType()) );
  275.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getOperazioneIm(),Transazione.model().OPERAZIONE_IM.getFieldType()) );
  276.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getLocationRichiesta(),Transazione.model().LOCATION_RICHIESTA.getFieldType()) );
  277.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getLocationRisposta(),Transazione.model().LOCATION_RISPOSTA.getFieldType()) );
  278.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getNomePorta(),Transazione.model().NOME_PORTA.getFieldType()) );
  279.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getCredenziali(),Transazione.model().CREDENZIALI.getFieldType()) );
  280.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getLocationConnettore(),Transazione.model().LOCATION_CONNETTORE.getFieldType()) );
  281.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getUrlInvocazione(),Transazione.model().URL_INVOCAZIONE.getFieldType()) );
  282.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTrasportoMittente(),Transazione.model().TRASPORTO_MITTENTE.getFieldType()) );
  283.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTokenIssuer(),Transazione.model().TOKEN_ISSUER.getFieldType()) );
  284.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTokenClientId(),Transazione.model().TOKEN_CLIENT_ID.getFieldType()) );
  285.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTokenSubject(),Transazione.model().TOKEN_SUBJECT.getFieldType()) );
  286.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTokenUsername(),Transazione.model().TOKEN_USERNAME.getFieldType()) );
  287.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTokenMail(),Transazione.model().TOKEN_MAIL.getFieldType()) );
  288.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTokenInfo(),Transazione.model().TOKEN_INFO.getFieldType()) );
  289.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTempiElaborazione(),Transazione.model().TEMPI_ELABORAZIONE.getFieldType()) );
  290.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDuplicatiRichiesta(),Transazione.model().DUPLICATI_RICHIESTA.getFieldType()) );
  291.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getDuplicatiRisposta(),Transazione.model().DUPLICATI_RISPOSTA.getFieldType()) );
  292.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getClusterId(),Transazione.model().CLUSTER_ID.getFieldType()) );
  293.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getSocketClientAddress(),Transazione.model().SOCKET_CLIENT_ADDRESS.getFieldType()) );
  294.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTransportClientAddress(),Transazione.model().TRANSPORT_CLIENT_ADDRESS.getFieldType()) );
  295.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getClientAddress(),Transazione.model().CLIENT_ADDRESS.getFieldType()));
  296.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getEventiGestione(),Transazione.model().EVENTI_GESTIONE.getFieldType()));
  297.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getTipoApi(),Transazione.model().TIPO_API.getFieldType()));
  298.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getUriApi(),Transazione.model().URI_API.getFieldType()));
  299.         listaJDBCObject.add(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazione.getGruppi(),Transazione.model().GRUPPI.getFieldType()));
  300.         // transazione-extended-info: serve ad estendere la tabella transazioni su progetti specifici (es. pdc, fwuuid)
  301.         if(transazione.sizeTransazioneExtendedInfoList()>0){
  302.             for (TransazioneExtendedInfo transazioneExtedendInfo : transazione.getTransazioneExtendedInfoList()) {
  303.                 listaJDBCObject.add( new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneExtedendInfo.getValore(),String.class));
  304.             }
  305.         }
  306.         jdbcUtilities.execute(insertSql, jdbcProperties.isShowSql(), 
  307.                 listaJDBCObject.toArray(new JDBCObject[1])
  308.         );
  309.         
  310.     }
  311.     
  312.     @Override
  313.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, String oldId, Transazione transazioneParam, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  314.         
  315.         Transazione transazione = null;
  316.         boolean useDayIntervalForUpdate = false;
  317.         if(transazioneParam instanceof TransazioneDaoExt) {
  318.             TransazioneDaoExt ext = (TransazioneDaoExt) transazioneParam;
  319.             transazione = ext.getWrapped();
  320.             useDayIntervalForUpdate = ext.isUseDayIntervalForUpdate();
  321.         }
  322.         else {
  323.             transazione = transazioneParam;
  324.         }
  325.         
  326.         if(TipiDatabase.POSTGRESQL.equals(jdbcProperties.getDatabase())){
  327.             if(transazione.getFaultCooperazione()!=null && org.openspcoop2.utils.jdbc.PostgreSQLUtilities.containsNullByteSequence(transazione.getFaultCooperazione())) {
  328.                 transazione.setFaultCooperazione(org.openspcoop2.utils.jdbc.PostgreSQLUtilities.normalizeString(transazione.getFaultCooperazione()));
  329.             }
  330.             if(transazione.getFaultIntegrazione()!=null && org.openspcoop2.utils.jdbc.PostgreSQLUtilities.containsNullByteSequence(transazione.getFaultIntegrazione())) {
  331.                 transazione.setFaultIntegrazione(org.openspcoop2.utils.jdbc.PostgreSQLUtilities.normalizeString(transazione.getFaultIntegrazione()));
  332.             }
  333.             if(transazione.getCredenziali()!=null && org.openspcoop2.utils.jdbc.PostgreSQLUtilities.containsNullByteSequence(transazione.getCredenziali())) {
  334.                 transazione.setCredenziali(org.openspcoop2.utils.jdbc.PostgreSQLUtilities.normalizeString(transazione.getCredenziali()));
  335.             }
  336.         }
  337.             
  338.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObject.newSQLQueryObject();
  339.         Object longIdByLogicId = this.findIdTransazione(jdbcProperties, log, connection, sqlQueryObjectUpdate.newSQLQueryObject(), oldId, true, false);
  340.         if(longIdByLogicId==null){
  341.             throw new Exception("Retrieve logicId failed");
  342.         }

  344.     
  345.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  346.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  347.         
  348.         // Object transazione
  349.         sqlQueryObjectUpdate.setANDLogicOperator(true);
  350.         sqlQueryObjectUpdate.addUpdateTable(this.getTransazioneFieldConverter().toTable(Transazione.model()));
  351.         boolean isUpdate_transazione = true;
  352.         java.util.List<JDBCObject> lstObjects_transazione = new java.util.ArrayList<>();
  353.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_TRANSAZIONE,false), "?");
  354.         lstObjects_transazione.add(new JDBCObject(transazione.getIdTransazione(), Transazione.model().ID_TRANSAZIONE.getFieldType()));
  355.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().STATO,false), "?");
  356.         lstObjects_transazione.add(new JDBCObject(transazione.getStato(), Transazione.model().STATO.getFieldType()));
  357.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().RUOLO_TRANSAZIONE,false), "?");
  358.         lstObjects_transazione.add(new JDBCObject(transazione.getRuoloTransazione(), Transazione.model().RUOLO_TRANSAZIONE.getFieldType()));
  359.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ESITO,false), "?");
  360.         lstObjects_transazione.add(new JDBCObject(transazione.getEsito(), Transazione.model().ESITO.getFieldType()));
  361.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ESITO_SINCRONO,false), "?");
  362.         lstObjects_transazione.add(new JDBCObject(transazione.getEsitoSincrono(), Transazione.model().ESITO_SINCRONO.getFieldType()));
  363.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().CONSEGNE_MULTIPLE_IN_CORSO,false), "?");
  364.         lstObjects_transazione.add(new JDBCObject(transazione.getConsegneMultipleInCorso(), Transazione.model().CONSEGNE_MULTIPLE_IN_CORSO.getFieldType()));
  365.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ESITO_CONTESTO,false), "?");
  366.         lstObjects_transazione.add(new JDBCObject(transazione.getEsitoContesto(), Transazione.model().ESITO_CONTESTO.getFieldType()));
  367.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PROTOCOLLO,false), "?");
  368.         lstObjects_transazione.add(new JDBCObject(transazione.getProtocollo(), Transazione.model().PROTOCOLLO.getFieldType()));
  369.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TIPO_RICHIESTA,false), "?");
  370.         lstObjects_transazione.add(new JDBCObject(transazione.getTipoRichiesta(), Transazione.model().TIPO_RICHIESTA.getFieldType()));
  371.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().CODICE_RISPOSTA_INGRESSO,false), "?");
  372.         lstObjects_transazione.add(new JDBCObject(transazione.getCodiceRispostaIngresso(), Transazione.model().CODICE_RISPOSTA_INGRESSO.getFieldType()));
  373.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().CODICE_RISPOSTA_USCITA,false), "?");
  374.         lstObjects_transazione.add(new JDBCObject(transazione.getCodiceRispostaUscita(), Transazione.model().CODICE_RISPOSTA_USCITA.getFieldType()));
  375.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_ACCETTAZIONE_RICHIESTA,false), "?");
  376.         lstObjects_transazione.add(new JDBCObject(transazione.getDataAccettazioneRichiesta(), Transazione.model().DATA_ACCETTAZIONE_RICHIESTA.getFieldType()));
  377.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_INGRESSO_RICHIESTA,false), "?");
  378.         lstObjects_transazione.add(new JDBCObject(transazione.getDataIngressoRichiesta(), Transazione.model().DATA_INGRESSO_RICHIESTA.getFieldType()));
  379.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_INGRESSO_RICHIESTA_STREAM,false), "?");
  380.         lstObjects_transazione.add(new JDBCObject(transazione.getDataIngressoRichiestaStream(), Transazione.model().DATA_INGRESSO_RICHIESTA_STREAM.getFieldType()));
  381.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_USCITA_RICHIESTA,false), "?");
  382.         lstObjects_transazione.add(new JDBCObject(transazione.getDataUscitaRichiesta(), Transazione.model().DATA_USCITA_RICHIESTA.getFieldType()));
  383.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_USCITA_RICHIESTA_STREAM,false), "?");
  384.         lstObjects_transazione.add(new JDBCObject(transazione.getDataUscitaRichiestaStream(), Transazione.model().DATA_USCITA_RICHIESTA_STREAM.getFieldType()));
  385.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_ACCETTAZIONE_RISPOSTA,false), "?");
  386.         lstObjects_transazione.add(new JDBCObject(transazione.getDataAccettazioneRisposta(), Transazione.model().DATA_ACCETTAZIONE_RISPOSTA.getFieldType()));
  387.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_INGRESSO_RISPOSTA,false), "?");
  388.         lstObjects_transazione.add(new JDBCObject(transazione.getDataIngressoRisposta(), Transazione.model().DATA_INGRESSO_RISPOSTA.getFieldType()));
  389.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_INGRESSO_RISPOSTA_STREAM,false), "?");
  390.         lstObjects_transazione.add(new JDBCObject(transazione.getDataIngressoRispostaStream(), Transazione.model().DATA_INGRESSO_RISPOSTA_STREAM.getFieldType()));
  391.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_USCITA_RISPOSTA,false), "?");
  392.         lstObjects_transazione.add(new JDBCObject(transazione.getDataUscitaRisposta(), Transazione.model().DATA_USCITA_RISPOSTA.getFieldType()));
  393.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_USCITA_RISPOSTA_STREAM,false), "?");
  394.         lstObjects_transazione.add(new JDBCObject(transazione.getDataUscitaRispostaStream(), Transazione.model().DATA_USCITA_RISPOSTA_STREAM.getFieldType()));
  395.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().RICHIESTA_INGRESSO_BYTES,false), "?");
  396.         lstObjects_transazione.add(new JDBCObject(transazione.getRichiestaIngressoBytes(), Transazione.model().RICHIESTA_INGRESSO_BYTES.getFieldType()));
  397.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().RICHIESTA_USCITA_BYTES,false), "?");
  398.         lstObjects_transazione.add(new JDBCObject(transazione.getRichiestaUscitaBytes(), Transazione.model().RICHIESTA_USCITA_BYTES.getFieldType()));
  399.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().RISPOSTA_INGRESSO_BYTES,false), "?");
  400.         lstObjects_transazione.add(new JDBCObject(transazione.getRispostaIngressoBytes(), Transazione.model().RISPOSTA_INGRESSO_BYTES.getFieldType()));
  401.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().RISPOSTA_USCITA_BYTES,false), "?");
  402.         lstObjects_transazione.add(new JDBCObject(transazione.getRispostaUscitaBytes(), Transazione.model().RISPOSTA_USCITA_BYTES.getFieldType()));
  403.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PDD_CODICE,false), "?");
  404.         lstObjects_transazione.add(new JDBCObject(transazione.getPddCodice(), Transazione.model().PDD_CODICE.getFieldType()));
  405.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PDD_TIPO_SOGGETTO,false), "?");
  406.         lstObjects_transazione.add(new JDBCObject(transazione.getPddTipoSoggetto(), Transazione.model().PDD_TIPO_SOGGETTO.getFieldType()));
  407.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PDD_NOME_SOGGETTO,false), "?");
  408.         lstObjects_transazione.add(new JDBCObject(transazione.getPddNomeSoggetto(), Transazione.model().PDD_NOME_SOGGETTO.getFieldType()));
  409.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PDD_RUOLO,false), "?");
  410.         lstObjects_transazione.add(new JDBCObject(transazione.getPddRuolo(), Transazione.model().PDD_RUOLO.getFieldType()));
  411.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().FAULT_INTEGRAZIONE,false), "?");
  412.         lstObjects_transazione.add(new JDBCObject(transazione.getFaultIntegrazione(), Transazione.model().FAULT_INTEGRAZIONE.getFieldType()));
  413.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().FORMATO_FAULT_INTEGRAZIONE,false), "?");
  414.         lstObjects_transazione.add(new JDBCObject(transazione.getFormatoFaultIntegrazione(), Transazione.model().FORMATO_FAULT_INTEGRAZIONE.getFieldType()));
  415.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().FAULT_COOPERAZIONE,false), "?");
  416.         lstObjects_transazione.add(new JDBCObject(transazione.getFaultCooperazione(), Transazione.model().FAULT_COOPERAZIONE.getFieldType()));
  417.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().FORMATO_FAULT_COOPERAZIONE,false), "?");
  418.         lstObjects_transazione.add(new JDBCObject(transazione.getFormatoFaultCooperazione(), Transazione.model().FORMATO_FAULT_COOPERAZIONE.getFieldType()));
  419.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TIPO_SOGGETTO_FRUITORE,false), "?");
  420.         lstObjects_transazione.add(new JDBCObject(transazione.getTipoSoggettoFruitore(), Transazione.model().TIPO_SOGGETTO_FRUITORE.getFieldType()));
  421.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().NOME_SOGGETTO_FRUITORE,false), "?");
  422.         lstObjects_transazione.add(new JDBCObject(transazione.getNomeSoggettoFruitore(), Transazione.model().NOME_SOGGETTO_FRUITORE.getFieldType()));
  423.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().IDPORTA_SOGGETTO_FRUITORE,false), "?");
  424.         lstObjects_transazione.add(new JDBCObject(transazione.getIdportaSoggettoFruitore(), Transazione.model().IDPORTA_SOGGETTO_FRUITORE.getFieldType()));
  425.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().INDIRIZZO_SOGGETTO_FRUITORE,false), "?");
  426.         lstObjects_transazione.add(new JDBCObject(transazione.getIndirizzoSoggettoFruitore(), Transazione.model().INDIRIZZO_SOGGETTO_FRUITORE.getFieldType()));
  427.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TIPO_SOGGETTO_EROGATORE,false), "?");
  428.         lstObjects_transazione.add(new JDBCObject(transazione.getTipoSoggettoErogatore(), Transazione.model().TIPO_SOGGETTO_EROGATORE.getFieldType()));
  429.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().NOME_SOGGETTO_EROGATORE,false), "?");
  430.         lstObjects_transazione.add(new JDBCObject(transazione.getNomeSoggettoErogatore(), Transazione.model().NOME_SOGGETTO_EROGATORE.getFieldType()));
  431.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().IDPORTA_SOGGETTO_EROGATORE,false), "?");
  432.         lstObjects_transazione.add(new JDBCObject(transazione.getIdportaSoggettoErogatore(), Transazione.model().IDPORTA_SOGGETTO_EROGATORE.getFieldType()));
  433.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().INDIRIZZO_SOGGETTO_EROGATORE,false), "?");
  434.         lstObjects_transazione.add(new JDBCObject(transazione.getIndirizzoSoggettoErogatore(), Transazione.model().INDIRIZZO_SOGGETTO_EROGATORE.getFieldType()));
  435.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_MESSAGGIO_RICHIESTA,false), "?");
  436.         lstObjects_transazione.add(new JDBCObject(transazione.getIdMessaggioRichiesta(), Transazione.model().ID_MESSAGGIO_RICHIESTA.getFieldType()));
  437.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_MESSAGGIO_RISPOSTA,false), "?");
  438.         lstObjects_transazione.add(new JDBCObject(transazione.getIdMessaggioRisposta(), Transazione.model().ID_MESSAGGIO_RISPOSTA.getFieldType()));
  439.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_ID_MSG_RICHIESTA,false), "?");
  440.         lstObjects_transazione.add(new JDBCObject(transazione.getDataIdMsgRichiesta(), Transazione.model().DATA_ID_MSG_RICHIESTA.getFieldType()));
  441.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_ID_MSG_RISPOSTA,false), "?");
  442.         lstObjects_transazione.add(new JDBCObject(transazione.getDataIdMsgRisposta(), Transazione.model().DATA_ID_MSG_RISPOSTA.getFieldType()));
  443.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PROFILO_COLLABORAZIONE_OP_2,false), "?");
  444.         lstObjects_transazione.add(new JDBCObject(transazione.getProfiloCollaborazioneOp2(), Transazione.model().PROFILO_COLLABORAZIONE_OP_2.getFieldType()));
  445.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PROFILO_COLLABORAZIONE_PROT,false), "?");
  446.         lstObjects_transazione.add(new JDBCObject(transazione.getProfiloCollaborazioneProt(), Transazione.model().PROFILO_COLLABORAZIONE_PROT.getFieldType()));
  447.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_COLLABORAZIONE,false), "?");
  448.         lstObjects_transazione.add(new JDBCObject(transazione.getIdCollaborazione(), Transazione.model().ID_COLLABORAZIONE.getFieldType()));
  449.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().URI_ACCORDO_SERVIZIO,false), "?");
  450.         lstObjects_transazione.add(new JDBCObject(transazione.getUriAccordoServizio(), Transazione.model().URI_ACCORDO_SERVIZIO.getFieldType()));
  451.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TIPO_SERVIZIO,false), "?");
  452.         lstObjects_transazione.add(new JDBCObject(transazione.getTipoServizio(), Transazione.model().TIPO_SERVIZIO.getFieldType()));
  453.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().NOME_SERVIZIO,false), "?");
  454.         lstObjects_transazione.add(new JDBCObject(transazione.getNomeServizio(), Transazione.model().NOME_SERVIZIO.getFieldType()));
  455.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().VERSIONE_SERVIZIO,false), "?");
  456.         lstObjects_transazione.add(new JDBCObject(transazione.getVersioneServizio(), Transazione.model().VERSIONE_SERVIZIO.getFieldType()));
  457.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().AZIONE,false), "?");
  458.         lstObjects_transazione.add(new JDBCObject(transazione.getAzione(), Transazione.model().AZIONE.getFieldType()));
  459.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_ASINCRONO,false), "?");
  460.         lstObjects_transazione.add(new JDBCObject(transazione.getIdAsincrono(), Transazione.model().ID_ASINCRONO.getFieldType()));
  461.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TIPO_SERVIZIO_CORRELATO,false), "?");
  462.         lstObjects_transazione.add(new JDBCObject(transazione.getTipoServizioCorrelato(), Transazione.model().TIPO_SERVIZIO_CORRELATO.getFieldType()));
  463.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().NOME_SERVIZIO_CORRELATO,false), "?");
  464.         lstObjects_transazione.add(new JDBCObject(transazione.getNomeServizioCorrelato(), Transazione.model().NOME_SERVIZIO_CORRELATO.getFieldType()));
  465.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().HEADER_PROTOCOLLO_RICHIESTA,false), "?");
  466.         lstObjects_transazione.add(new JDBCObject(transazione.getHeaderProtocolloRichiesta(), Transazione.model().HEADER_PROTOCOLLO_RICHIESTA.getFieldType()));
  467.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DIGEST_RICHIESTA,false), "?");
  468.         lstObjects_transazione.add(new JDBCObject(transazione.getDigestRichiesta(), Transazione.model().DIGEST_RICHIESTA.getFieldType()));
  469.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PROTOCOLLO_EXT_INFO_RICHIESTA,false), "?");
  470.         lstObjects_transazione.add(new JDBCObject(transazione.getProtocolloExtInfoRichiesta(), Transazione.model().PROTOCOLLO_EXT_INFO_RICHIESTA.getFieldType()));
  471.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().HEADER_PROTOCOLLO_RISPOSTA,false), "?");
  472.         lstObjects_transazione.add(new JDBCObject(transazione.getHeaderProtocolloRisposta(), Transazione.model().HEADER_PROTOCOLLO_RISPOSTA.getFieldType()));
  473.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DIGEST_RISPOSTA,false), "?");
  474.         lstObjects_transazione.add(new JDBCObject(transazione.getDigestRisposta(), Transazione.model().DIGEST_RISPOSTA.getFieldType()));
  475.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().PROTOCOLLO_EXT_INFO_RISPOSTA,false), "?");
  476.         lstObjects_transazione.add(new JDBCObject(transazione.getProtocolloExtInfoRisposta(), Transazione.model().PROTOCOLLO_EXT_INFO_RISPOSTA.getFieldType()));
  477.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TRACCIA_RICHIESTA,false), "?");
  478.         lstObjects_transazione.add(new JDBCObject(transazione.getTracciaRichiesta(), Transazione.model().TRACCIA_RICHIESTA.getFieldType()));
  479.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TRACCIA_RISPOSTA,false), "?");
  480.         lstObjects_transazione.add(new JDBCObject(transazione.getTracciaRisposta(), Transazione.model().TRACCIA_RISPOSTA.getFieldType()));
  481.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DIAGNOSTICI,false), "?");
  482.         lstObjects_transazione.add(new JDBCObject(transazione.getDiagnostici(), Transazione.model().DIAGNOSTICI.getFieldType()));
  483.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DIAGNOSTICI_LIST_1,false), "?");
  484.         lstObjects_transazione.add(new JDBCObject(transazione.getDiagnosticiList1(), Transazione.model().DIAGNOSTICI_LIST_1.getFieldType()));
  485.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DIAGNOSTICI_LIST_2,false), "?");
  486.         lstObjects_transazione.add(new JDBCObject(transazione.getDiagnosticiList2(), Transazione.model().DIAGNOSTICI_LIST_2.getFieldType()));
  487.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DIAGNOSTICI_LIST_EXT,false), "?");
  488.         lstObjects_transazione.add(new JDBCObject(transazione.getDiagnosticiListExt(), Transazione.model().DIAGNOSTICI_LIST_EXT.getFieldType()));
  489.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DIAGNOSTICI_EXT,false), "?");
  490.         lstObjects_transazione.add(new JDBCObject(transazione.getDiagnosticiExt(), Transazione.model().DIAGNOSTICI_EXT.getFieldType()));
  491.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ERROR_LOG,false), "?");
  492.         lstObjects_transazione.add(new JDBCObject(transazione.getErrorLog(), Transazione.model().ERROR_LOG.getFieldType()));
  493.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().WARNING_LOG,false), "?");
  494.         lstObjects_transazione.add(new JDBCObject(transazione.getWarningLog(), Transazione.model().WARNING_LOG.getFieldType()));
  495.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_CORRELAZIONE_APPLICATIVA,false), "?");
  496.         lstObjects_transazione.add(new JDBCObject(transazione.getIdCorrelazioneApplicativa(), Transazione.model().ID_CORRELAZIONE_APPLICATIVA.getFieldType()));
  497.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_CORRELAZIONE_APPLICATIVA_RISPOSTA,false), "?");
  498.         lstObjects_transazione.add(new JDBCObject(transazione.getIdCorrelazioneApplicativaRisposta(), Transazione.model().ID_CORRELAZIONE_APPLICATIVA_RISPOSTA.getFieldType()));
  499.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().SERVIZIO_APPLICATIVO_FRUITORE,false), "?");
  500.         lstObjects_transazione.add(new JDBCObject(transazione.getServizioApplicativoFruitore(), Transazione.model().SERVIZIO_APPLICATIVO_FRUITORE.getFieldType()));
  501.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().SERVIZIO_APPLICATIVO_EROGATORE,false), "?");
  502.         lstObjects_transazione.add(new JDBCObject(transazione.getServizioApplicativoErogatore(), Transazione.model().SERVIZIO_APPLICATIVO_EROGATORE.getFieldType()));
  503.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().OPERAZIONE_IM,false), "?");
  504.         lstObjects_transazione.add(new JDBCObject(transazione.getOperazioneIm(), Transazione.model().OPERAZIONE_IM.getFieldType()));
  505.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().LOCATION_RICHIESTA,false), "?");
  506.         lstObjects_transazione.add(new JDBCObject(transazione.getLocationRichiesta(), Transazione.model().LOCATION_RICHIESTA.getFieldType()));
  507.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().LOCATION_RISPOSTA,false), "?");
  508.         lstObjects_transazione.add(new JDBCObject(transazione.getLocationRisposta(), Transazione.model().LOCATION_RISPOSTA.getFieldType()));
  509.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().NOME_PORTA,false), "?");
  510.         lstObjects_transazione.add(new JDBCObject(transazione.getNomePorta(), Transazione.model().NOME_PORTA.getFieldType()));
  511.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().CREDENZIALI,false), "?");
  512.         lstObjects_transazione.add(new JDBCObject(transazione.getCredenziali(), Transazione.model().CREDENZIALI.getFieldType()));
  513.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().LOCATION_CONNETTORE,false), "?");
  514.         lstObjects_transazione.add(new JDBCObject(transazione.getLocationConnettore(), Transazione.model().LOCATION_CONNETTORE.getFieldType()));
  515.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().URL_INVOCAZIONE,false), "?");
  516.         lstObjects_transazione.add(new JDBCObject(transazione.getUrlInvocazione(), Transazione.model().URL_INVOCAZIONE.getFieldType()));
  517.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TRASPORTO_MITTENTE,false), "?");
  518.         lstObjects_transazione.add(new JDBCObject(transazione.getTrasportoMittente(), Transazione.model().TRASPORTO_MITTENTE.getFieldType()));
  519.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TOKEN_ISSUER,false), "?");
  520.         lstObjects_transazione.add(new JDBCObject(transazione.getTokenIssuer(), Transazione.model().TOKEN_ISSUER.getFieldType()));
  521.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TOKEN_CLIENT_ID,false), "?");
  522.         lstObjects_transazione.add(new JDBCObject(transazione.getTokenClientId(), Transazione.model().TOKEN_CLIENT_ID.getFieldType()));
  523.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TOKEN_SUBJECT,false), "?");
  524.         lstObjects_transazione.add(new JDBCObject(transazione.getTokenSubject(), Transazione.model().TOKEN_SUBJECT.getFieldType()));
  525.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TOKEN_USERNAME,false), "?");
  526.         lstObjects_transazione.add(new JDBCObject(transazione.getTokenUsername(), Transazione.model().TOKEN_USERNAME.getFieldType()));
  527.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TOKEN_MAIL,false), "?");
  528.         lstObjects_transazione.add(new JDBCObject(transazione.getTokenMail(), Transazione.model().TOKEN_MAIL.getFieldType()));
  529.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TOKEN_INFO,false), "?");
  530.         lstObjects_transazione.add(new JDBCObject(transazione.getTokenInfo(), Transazione.model().TOKEN_INFO.getFieldType()));
  531.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TEMPI_ELABORAZIONE,false), "?");
  532.         lstObjects_transazione.add(new JDBCObject(transazione.getTempiElaborazione(), Transazione.model().TEMPI_ELABORAZIONE.getFieldType()));
  533.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DUPLICATI_RICHIESTA,false), "?");
  534.         lstObjects_transazione.add(new JDBCObject(transazione.getDuplicatiRichiesta(), Transazione.model().DUPLICATI_RICHIESTA.getFieldType()));
  535.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().DUPLICATI_RISPOSTA,false), "?");
  536.         lstObjects_transazione.add(new JDBCObject(transazione.getDuplicatiRisposta(), Transazione.model().DUPLICATI_RISPOSTA.getFieldType()));
  537.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().CLUSTER_ID,false), "?");
  538.         lstObjects_transazione.add(new JDBCObject(transazione.getClusterId(), Transazione.model().CLUSTER_ID.getFieldType()));
  539.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().SOCKET_CLIENT_ADDRESS,false), "?");
  540.         lstObjects_transazione.add(new JDBCObject(transazione.getSocketClientAddress(), Transazione.model().SOCKET_CLIENT_ADDRESS.getFieldType()));
  541.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TRANSPORT_CLIENT_ADDRESS,false), "?");
  542.         lstObjects_transazione.add(new JDBCObject(transazione.getTransportClientAddress(), Transazione.model().TRANSPORT_CLIENT_ADDRESS.getFieldType()));
  543.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().CLIENT_ADDRESS,false), "?");
  544.         lstObjects_transazione.add(new JDBCObject(transazione.getClientAddress(), Transazione.model().CLIENT_ADDRESS.getFieldType()));
  545.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().EVENTI_GESTIONE,false), "?");
  546.         lstObjects_transazione.add(new JDBCObject(transazione.getEventiGestione(), Transazione.model().EVENTI_GESTIONE.getFieldType()));
  547.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().TIPO_API,false), "?");
  548.         lstObjects_transazione.add(new JDBCObject(transazione.getTipoApi(), Transazione.model().TIPO_API.getFieldType()));
  549.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().URI_API,false), "?");
  550.         lstObjects_transazione.add(new JDBCObject(transazione.getUriApi(), Transazione.model().URI_API.getFieldType()));
  551.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(Transazione.model().GRUPPI,false), "?");
  552.         lstObjects_transazione.add(new JDBCObject(transazione.getGruppi(), Transazione.model().GRUPPI.getFieldType()));
  553.         if(transazione.sizeTransazioneExtendedInfoList()>0){
  554.             for (TransazioneExtendedInfo transazioneExtedendInfo : transazione.getTransazioneExtendedInfoList()) {
  555.                 sqlQueryObjectUpdate.addUpdateField(transazioneExtedendInfo.getNome(), "?");
  556.                 lstObjects_transazione.add(new JDBCObject(transazioneExtedendInfo.getValore(), String.class));
  557.             }
  558.         }
  559.         sqlQueryObjectUpdate.addWhereCondition(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_TRANSAZIONE,false)+"=?");
  560.         lstObjects_transazione.add(new JDBCObject(longIdByLogicId, longIdByLogicId.getClass()));
  561.         
  562.         if(useDayIntervalForUpdate) {
  563.             
  564.             Date left = DateUtils.convertToLeftInterval(transazione.getDataIngressoRichiesta(), UnitaTemporale.GIORNALIERO);
  565.             sqlQueryObjectUpdate.addWhereCondition(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_INGRESSO_RICHIESTA,false)+">=?");
  566.             lstObjects_transazione.add(new JDBCObject(left, left.getClass()));
  567.             
  568.             Date right = DateUtils.convertToRightInterval(transazione.getDataIngressoRichiesta(), UnitaTemporale.GIORNALIERO);
  569.             sqlQueryObjectUpdate.addWhereCondition(this.getTransazioneFieldConverter().toColumn(Transazione.model().DATA_INGRESSO_RICHIESTA,false)+"<=?");
  570.             lstObjects_transazione.add(new JDBCObject(right, right.getClass()));
  571.             
  572.         }

  574.         if(isUpdate_transazione) {
  575.             // Update transazione
  576.             jdbcUtilities.executeUpdate(sqlQueryObjectUpdate.createSQLUpdate(), jdbcProperties.isShowSql(), 
  577.                 lstObjects_transazione.toArray(new JDBCObject[]{}));
  578.         }
  579.         
  580.     }
  581.     @Override
  582.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, Transazione transazione, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  583.         throw new NotImplementedException("Table without long id column PK");
  584.     }
  585.     
  586.     private static boolean efficiente = true;    
  587.     public static boolean isEfficiente() {
  588.         return efficiente;
  589.     }
  590.     public static void setEfficiente(boolean efficiente) {
  591.         JDBCTransazioneServiceImpl.efficiente = efficiente;
  592.     }
  593.     
  594.     @Override
  595.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, String id, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  596.         
  597.         if(efficiente) {
  598.             updateFieldsOptimized(jdbcProperties, log, connection, sqlQueryObject, id, null, updateFields);
  599.         }
  600.         else {
  601.             GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  602.                     this.getTransazioneFieldConverter().toTable(Transazione.model()), 
  603.                     this.getMapTableToPKColumnEngine(), 
  604.                     this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  605.                     this.getTransazioneFieldConverter(), this, null, updateFields);
  606.         }
  607.     }
  608.     
  609.     @Override
  610.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, String id, IExpression condition, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  611.         
  612.         if(efficiente) {
  613.             updateFieldsOptimized(jdbcProperties, log, connection, sqlQueryObject, id, condition, updateFields);
  614.         }
  615.         else {
  616.             GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  617.                     this.getTransazioneFieldConverter().toTable(Transazione.model()), 
  618.                     this.getMapTableToPKColumnEngine(), 
  619.                     this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  620.                     this.getTransazioneFieldConverter(), this, condition, updateFields);
  621.         }
  622.     }
  623.     
  624.     private void updateFieldsOptimized(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, String id, IExpression condition, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, SQLQueryObjectException, ExpressionException, JDBCAdapterException {
  625.     
  626.         String table =  this.getTransazioneFieldConverter().toTable(Transazione.model());
  627.         
  628.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObject.newSQLQueryObject();
  629.         sqlQueryObjectUpdate.setANDLogicOperator(true);
  630.         sqlQueryObjectUpdate.addUpdateTable(table);
  631.         
  632.         // update fields
  633.         java.util.List<JDBCObject> lstObjectsUpdate = new java.util.ArrayList<>();
  634.         for (UpdateField updateField : updateFields) {
  635.             sqlQueryObjectUpdate.addUpdateField(this.getTransazioneFieldConverter().toColumn(updateField.getField(),false), "?");
  636.             lstObjectsUpdate.add(new JDBCObject(updateField.getValue(), updateField.getField().getFieldType()));
  637.         }
  638.         
  639.         // id
  640.         sqlQueryObjectUpdate.addWhereCondition(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_TRANSAZIONE,false)+"=?");
  641.         lstObjectsUpdate.add(new JDBCObject(id, id.getClass()));
  642.         
  643.         // condition
  644.         if(condition instanceof JDBCExpression) {
  645.             JDBCExpression jdbc = (JDBCExpression) condition;
  646.             List<Object> oggetti = new ArrayList<>();
  647.             jdbc.toSqlForPreparedStatement(sqlQueryObjectUpdate, oggetti);
  648.             if(!oggetti.isEmpty()) {
  649.                 for (Object object : oggetti) {
  650.                     lstObjectsUpdate.add(new JDBCObject(object, object.getClass()));
  651.                 }
  652.             }
  653.         }
  654.         
  655.         // execute
  656.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  657.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  658.         int updateRow = jdbcUtilities.executeUpdate(sqlQueryObjectUpdate.createSQLUpdate(), jdbcProperties.isShowSql(), 
  659.                 lstObjectsUpdate.toArray(new JDBCObject[]{}));
  660.         String msg = "UpdateField["+table+"]: "+updateRow +" rows";
  661.         log.debug(msg);
  662.     }
  663.     
  664.     @Override
  665.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, String id, UpdateModel ... updateModels) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  666.         
  667.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  668.                 this.getTransazioneFieldConverter().toTable(Transazione.model()), 
  669.                 this.getMapTableToPKColumnEngine(), 
  670.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  671.                 this.getTransazioneFieldConverter(), this, updateModels);
  672.     }   
  673.     
  674.     @Override
  675.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  676.         throw new NotImplementedException("Table without long id column PK");
  677.     }
  678.     
  679.     @Override
  680.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, IExpression condition, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  681.         throw new NotImplementedException("Table without long id column PK");
  682.     }
  683.     
  684.     @Override
  685.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, UpdateModel ... updateModels) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  686.         throw new NotImplementedException("Table without long id column PK");
  687.     }
  688.     
  689.     @Override
  690.     public void updateOrCreate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, String oldId, Transazione transazione, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {
  691.     
  692.         if(this.exists(jdbcProperties, log, connection, sqlQueryObject, oldId)) {
  693.             this.update(jdbcProperties, log, connection, sqlQueryObject, oldId, transazione,idMappingResolutionBehaviour);
  694.         } else {
  695.             this.create(jdbcProperties, log, connection, sqlQueryObject, transazione,idMappingResolutionBehaviour);
  696.         }
  697.         
  698.     }
  699.     
  700.     @Override
  701.     public void updateOrCreate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, Transazione transazione, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {
  702.         throw new NotImplementedException("Table without long id column PK");
  703.     }
  704.     
  705.     @Override
  706.     public void delete(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Transazione transazione) throws NotImplementedException,ServiceException,Exception {
  707.         
  708.         
  709.         String idObject = transazione.getIdTransazione();
  710.         if(idObject==null){
  711.             throw new ServiceException("IdTransazione non presente nell'oggetto");
  712.         }
  713.         
  714.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, idObject);
  715.         
  716.     }

  718.     private void deleteEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Object id) throws NotImplementedException,ServiceException,Exception {
  719.         
  720.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  721.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  722.         
  723.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObject.newSQLQueryObject();
  724.         
  725.         // Object transazione
  726.         sqlQueryObjectDelete.setANDLogicOperator(true);
  727.         sqlQueryObjectDelete.addDeleteTable(this.getTransazioneFieldConverter().toTable(Transazione.model()));
  728.         sqlQueryObjectDelete.addWhereCondition(this.getTransazioneFieldConverter().toColumn(Transazione.model().ID_TRANSAZIONE,false)+"=?");

  730.         // Delete transazione
  731.         jdbcUtilities.execute(sqlQueryObjectDelete.createSQLDelete(), jdbcProperties.isShowSql(), 
  732.             new JDBCObject(id,id.getClass()));

  734.     }

  736.     @Override
  737.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, String idTransazione) throws NotImplementedException,ServiceException,Exception {

  739.         Object id = null;
  740.         try{
  741.             id = this.findIdTransazione(jdbcProperties, log, connection, sqlQueryObject, idTransazione, true, true);
  742.         }catch(NotFoundException notFound){
  743.             return;
  744.         }           
  745.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  746.         
  747.     }
  748.     
  749.     @Override
  750.     public NonNegativeNumber deleteAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject) throws NotImplementedException,ServiceException,Exception {
  751.         
  752.         return this.deleteAll(jdbcProperties, log, connection, sqlQueryObject, new JDBCExpression(this.getTransazioneFieldConverter()));

  754.     }

  756.     @Override
  757.     public NonNegativeNumber deleteAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws NotImplementedException, ServiceException,Exception {

  759.         java.util.List<Object> lst = this._findAllObjectIds(jdbcProperties, log, connection, sqlQueryObject, new JDBCPaginatedExpression(expression));
  760.         
  761.         for(Object id : lst) {
  762.             this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  763.         }
  764.         
  765.         return new NonNegativeNumber(lst.size());
  766.     
  767.     }



  771.     // -- DB
  772.     
  773.     @Override
  774.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws ServiceException, NotImplementedException, Exception {
  775.         throw new NotImplementedException("Table without long id column PK");
  776.     }
  777.     
  778.     @Override
  779.     public int nativeUpdate(JDBCServiceManagerProperties jdbcProperties, Logger log,Connection connection,ISQLQueryObject sqlObject, String sql,Object ... param) throws ServiceException,NotImplementedException, Exception {
  780.     
  781.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeUpdate(jdbcProperties, log, connection, sqlObject,
  782.                                                                                             sql,param);
  783.     
  784.     }
  785. }
Created with JaCoCo 0.8.8.202204050719