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

  24. import org.openspcoop2.utils.TipiDatabase;
  25. import org.openspcoop2.utils.sql.ISQLQueryObject;

  27. import org.slf4j.Logger;

  29. import org.openspcoop2.generic_project.dao.jdbc.IJDBCServiceCRUDWithId;
  30. import org.openspcoop2.core.transazioni.IdTransazioneApplicativoServer;
  31. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  32. import org.openspcoop2.generic_project.beans.UpdateField;
  33. import org.openspcoop2.generic_project.beans.UpdateModel;

  35. import org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities;
  36. import org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject;
  37. import org.openspcoop2.generic_project.exception.NotFoundException;
  38. import org.openspcoop2.generic_project.exception.NotImplementedException;
  39. import org.openspcoop2.generic_project.exception.ServiceException;
  40. import org.openspcoop2.generic_project.expression.IExpression;
  41. import org.openspcoop2.generic_project.dao.jdbc.JDBCExpression;
  42. import org.openspcoop2.generic_project.dao.jdbc.JDBCPaginatedExpression;

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

  46. import org.openspcoop2.core.transazioni.TransazioneApplicativoServer;

  48. /**     
  49.  * JDBCTransazioneApplicativoServerServiceImpl
  50.  *
  51.  * @author Poli Andrea (poli@link.it)
  52.  * @author $Author$
  53.  * @version $Rev$, $Date$
  54.  */
  55. public class JDBCTransazioneApplicativoServerServiceImpl extends JDBCTransazioneApplicativoServerServiceSearchImpl
  56.     implements IJDBCServiceCRUDWithId<TransazioneApplicativoServer, IdTransazioneApplicativoServer, JDBCServiceManager> {

  58.     @Override
  59.     public void create(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, TransazioneApplicativoServer transazioneApplicativoServer, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {

  61.         if(TipiDatabase.POSTGRESQL.equals(jdbcProperties.getDatabase())){
  62.             if(transazioneApplicativoServer.getFault()!=null && org.openspcoop2.utils.jdbc.PostgreSQLUtilities.containsNullByteSequence(transazioneApplicativoServer.getFault())) {
  63.                 transazioneApplicativoServer.setFault(org.openspcoop2.utils.jdbc.PostgreSQLUtilities.normalizeString(transazioneApplicativoServer.getFault()));
  64.             }
  65.         }
  66.             
  67.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  68.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  69.         
  70.         ISQLQueryObject sqlQueryObjectInsert = sqlQueryObject.newSQLQueryObject();
  71.                 


  74.         // Object transazioneApplicativoServer
  75.         sqlQueryObjectInsert.addInsertTable(this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model()));
  76.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().ID_TRANSAZIONE,false),"?");
  77.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().SERVIZIO_APPLICATIVO_EROGATORE,false),"?");
  78.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CONNETTORE_NOME,false),"?");
  79.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_REGISTRAZIONE,false),"?");
  80.         // NONSERIALIZZATO SU DB sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().PROTOCOLLO,false),"?");
  81.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CONSEGNA_TERMINATA,false),"?");
  82.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_MESSAGGIO_SCADUTO,false),"?");
  83.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DETTAGLIO_ESITO,false),"?");
  84.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CONSEGNA_TRASPARENTE,false),"?");
  85.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CONSEGNA_INTEGRATION_MANAGER,false),"?");
  86.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().IDENTIFICATIVO_MESSAGGIO,false),"?");
  87.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_ACCETTAZIONE_RICHIESTA,false),"?");
  88.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_USCITA_RICHIESTA,false),"?");
  89.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_USCITA_RICHIESTA_STREAM,false),"?");
  90.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_ACCETTAZIONE_RISPOSTA,false),"?");
  91.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_INGRESSO_RISPOSTA,false),"?");
  92.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_INGRESSO_RISPOSTA_STREAM,false),"?");
  93.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().RICHIESTA_USCITA_BYTES,false),"?");
  94.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().RISPOSTA_INGRESSO_BYTES,false),"?");
  95.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().LOCATION_CONNETTORE,false),"?");
  96.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CODICE_RISPOSTA,false),"?");
  97.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().FAULT,false),"?");
  98.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().FORMATO_FAULT,false),"?");
  99.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_PRIMO_TENTATIVO,false),"?");
  100.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().NUMERO_TENTATIVI,false),"?");
  101.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CLUSTER_ID_PRESA_IN_CARICO,false),"?");
  102.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CLUSTER_ID_CONSEGNA,false),"?");
  103.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_ULTIMO_ERRORE,false),"?");
  104.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DETTAGLIO_ESITO_ULTIMO_ERRORE,false),"?");
  105.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CODICE_RISPOSTA_ULTIMO_ERRORE,false),"?");
  106.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().ULTIMO_ERRORE,false),"?");
  107.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().LOCATION_ULTIMO_ERRORE,false),"?");
  108.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CLUSTER_ID_ULTIMO_ERRORE,false),"?");
  109.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().FAULT_ULTIMO_ERRORE,false),"?");
  110.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().FORMATO_FAULT_ULTIMO_ERRORE,false),"?");
  111.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_PRIMO_PRELIEVO_IM,false),"?");
  112.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_PRELIEVO_IM,false),"?");
  113.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().NUMERO_PRELIEVI_IM,false),"?");
  114.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_ELIMINAZIONE_IM,false),"?");
  115.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CLUSTER_ID_PRELIEVO_IM,false),"?");
  116.         sqlQueryObjectInsert.addInsertField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CLUSTER_ID_ELIMINAZIONE_IM,false),"?");

  118.         // Insert transazioneApplicativoServer
  119.         org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator = this.getTransazioneApplicativoServerFetch().getKeyGeneratorObject(TransazioneApplicativoServer.model());
  120.         long id = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert, keyGenerator, jdbcProperties.isShowSql(),
  121.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getIdTransazione(),TransazioneApplicativoServer.model().ID_TRANSAZIONE.getFieldType()),
  122.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getServizioApplicativoErogatore(),TransazioneApplicativoServer.model().SERVIZIO_APPLICATIVO_EROGATORE.getFieldType()),
  123.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getConnettoreNome(),TransazioneApplicativoServer.model().CONNETTORE_NOME.getFieldType()),
  124.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getDataRegistrazione(),TransazioneApplicativoServer.model().DATA_REGISTRAZIONE.getFieldType()),
  125.             // NONSERIALIZZATO SU DB new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getProtocollo(),TransazioneApplicativoServer.model().PROTOCOLLO.getFieldType()),
  126.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getConsegnaTerminata(),TransazioneApplicativoServer.model().CONSEGNA_TERMINATA.getFieldType()),
  127.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getDataMessaggioScaduto(),TransazioneApplicativoServer.model().DATA_MESSAGGIO_SCADUTO.getFieldType()),
  128.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getDettaglioEsito(),TransazioneApplicativoServer.model().DETTAGLIO_ESITO.getFieldType()),
  129.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getConsegnaTrasparente(),TransazioneApplicativoServer.model().CONSEGNA_TRASPARENTE.getFieldType()),
  130.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getConsegnaIntegrationManager(),TransazioneApplicativoServer.model().CONSEGNA_INTEGRATION_MANAGER.getFieldType()),
  131.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getIdentificativoMessaggio(),TransazioneApplicativoServer.model().IDENTIFICATIVO_MESSAGGIO.getFieldType()),
  132.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getDataAccettazioneRichiesta(),TransazioneApplicativoServer.model().DATA_ACCETTAZIONE_RICHIESTA.getFieldType()),
  133.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getDataUscitaRichiesta(),TransazioneApplicativoServer.model().DATA_USCITA_RICHIESTA.getFieldType()),
  134.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getDataUscitaRichiestaStream(),TransazioneApplicativoServer.model().DATA_USCITA_RICHIESTA_STREAM.getFieldType()),
  135.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getDataAccettazioneRisposta(),TransazioneApplicativoServer.model().DATA_ACCETTAZIONE_RISPOSTA.getFieldType()),
  136.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getDataIngressoRisposta(),TransazioneApplicativoServer.model().DATA_INGRESSO_RISPOSTA.getFieldType()),
  137.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getDataIngressoRispostaStream(),TransazioneApplicativoServer.model().DATA_INGRESSO_RISPOSTA_STREAM.getFieldType()),
  138.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getRichiestaUscitaBytes(),TransazioneApplicativoServer.model().RICHIESTA_USCITA_BYTES.getFieldType()),
  139.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getRispostaIngressoBytes(),TransazioneApplicativoServer.model().RISPOSTA_INGRESSO_BYTES.getFieldType()),
  140.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getLocationConnettore(),TransazioneApplicativoServer.model().LOCATION_CONNETTORE.getFieldType()),
  141.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getCodiceRisposta(),TransazioneApplicativoServer.model().CODICE_RISPOSTA.getFieldType()),
  142.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getFault(),TransazioneApplicativoServer.model().FAULT.getFieldType()),
  143.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getFormatoFault(),TransazioneApplicativoServer.model().FORMATO_FAULT.getFieldType()),
  144.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getDataPrimoTentativo(),TransazioneApplicativoServer.model().DATA_PRIMO_TENTATIVO.getFieldType()),
  145.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getNumeroTentativi(),TransazioneApplicativoServer.model().NUMERO_TENTATIVI.getFieldType()),
  146.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getClusterIdPresaInCarico(),TransazioneApplicativoServer.model().CLUSTER_ID_PRESA_IN_CARICO.getFieldType()),
  147.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getClusterIdConsegna(),TransazioneApplicativoServer.model().CLUSTER_ID_CONSEGNA.getFieldType()),
  148.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getDataUltimoErrore(),TransazioneApplicativoServer.model().DATA_ULTIMO_ERRORE.getFieldType()),
  149.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getDettaglioEsitoUltimoErrore(),TransazioneApplicativoServer.model().DETTAGLIO_ESITO_ULTIMO_ERRORE.getFieldType()),
  150.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getCodiceRispostaUltimoErrore(),TransazioneApplicativoServer.model().CODICE_RISPOSTA_ULTIMO_ERRORE.getFieldType()),
  151.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getUltimoErrore(),TransazioneApplicativoServer.model().ULTIMO_ERRORE.getFieldType()),
  152.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getLocationUltimoErrore(),TransazioneApplicativoServer.model().LOCATION_ULTIMO_ERRORE.getFieldType()),
  153.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getClusterIdUltimoErrore(),TransazioneApplicativoServer.model().CLUSTER_ID_ULTIMO_ERRORE.getFieldType()),
  154.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getFaultUltimoErrore(),TransazioneApplicativoServer.model().FAULT_ULTIMO_ERRORE.getFieldType()),
  155.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getFormatoFaultUltimoErrore(),TransazioneApplicativoServer.model().FORMATO_FAULT_ULTIMO_ERRORE.getFieldType()),
  156.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getDataPrimoPrelievoIm(),TransazioneApplicativoServer.model().DATA_PRIMO_PRELIEVO_IM.getFieldType()),
  157.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getDataPrelievoIm(),TransazioneApplicativoServer.model().DATA_PRELIEVO_IM.getFieldType()),
  158.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getNumeroPrelieviIm(),TransazioneApplicativoServer.model().NUMERO_PRELIEVI_IM.getFieldType()),
  159.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getDataEliminazioneIm(),TransazioneApplicativoServer.model().DATA_ELIMINAZIONE_IM.getFieldType()),
  160.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getClusterIdPrelievoIm(),TransazioneApplicativoServer.model().CLUSTER_ID_PRELIEVO_IM.getFieldType()),
  161.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(transazioneApplicativoServer.getClusterIdEliminazioneIm(),TransazioneApplicativoServer.model().CLUSTER_ID_ELIMINAZIONE_IM.getFieldType())
  162.         );
  163.         transazioneApplicativoServer.setId(id);

  165.         
  166.     }

  168.     private static boolean efficiente = true;
  169.     public static boolean isEfficiente() {
  170.         return efficiente;
  171.     }
  172.     public static void setEfficiente(boolean efficiente) {
  173.         JDBCTransazioneApplicativoServerServiceImpl.efficiente = efficiente;
  174.     }
  175.     @Override
  176.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdTransazioneApplicativoServer oldId, TransazioneApplicativoServer transazioneApplicativoServer, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  177.         
  178.         if(efficiente) {
  179.         
  180.             long tableId = -1;
  181.             if(oldId!=null && oldId.getId()!=null && oldId.getId().longValue()>0) {
  182.                 tableId = oldId.getId().longValue();
  183.                 oldId = null; // uso l'id fisico se presente
  184.             }
  185.             this._update(jdbcProperties, log, connection, sqlQueryObject, tableId, transazioneApplicativoServer, idMappingResolutionBehaviour, oldId);
  186.             
  187.         }
  188.         else {
  189.         
  190.             ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObject.newSQLQueryObject();
  191.             Long longIdByLogicId = this.findIdTransazioneApplicativoServer(jdbcProperties, log, connection, sqlQueryObjectUpdate.newSQLQueryObject(), oldId, true);
  192.             Long tableId = transazioneApplicativoServer.getId();
  193.             if(tableId != null && tableId.longValue() > 0) {
  194.                 if(tableId.longValue() != longIdByLogicId.longValue()) {
  195.                     throw new Exception("Ambiguous parameter: transazioneApplicativoServer.id ["+tableId+"] does not match logic id ["+longIdByLogicId+"]");
  196.                 }
  197.             } else {
  198.                 tableId = longIdByLogicId;
  199.                 transazioneApplicativoServer.setId(tableId);
  200.             }
  201.             if(tableId==null || tableId<=0){
  202.                 throw new Exception("Retrieve tableId failed");
  203.             }
  204.     
  205.             this.update(jdbcProperties, log, connection, sqlQueryObject, tableId, transazioneApplicativoServer, idMappingResolutionBehaviour);
  206.             
  207.         }
  208.     }
  209.     @Override
  210.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, TransazioneApplicativoServer transazioneApplicativoServer, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  211.         this._update(jdbcProperties, log, connection, sqlQueryObject, tableId, transazioneApplicativoServer, idMappingResolutionBehaviour, null);
  212.     }
  213.     private void _update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  214.             long tableId, TransazioneApplicativoServer transazioneApplicativoServer, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour,
  215.             IdTransazioneApplicativoServer idLogico) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  216.     
  217.         if(TipiDatabase.POSTGRESQL.equals(jdbcProperties.getDatabase())){
  218.             if(transazioneApplicativoServer.getFault()!=null && org.openspcoop2.utils.jdbc.PostgreSQLUtilities.containsNullByteSequence(transazioneApplicativoServer.getFault())) {
  219.                 transazioneApplicativoServer.setFault(org.openspcoop2.utils.jdbc.PostgreSQLUtilities.normalizeString(transazioneApplicativoServer.getFault()));
  220.             }
  221.         }
  222.             
  223.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  224.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  225.         
  226.         ISQLQueryObject sqlQueryObjectInsert = sqlQueryObject.newSQLQueryObject();
  227.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObjectInsert.newSQLQueryObject();
  228.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObjectDelete.newSQLQueryObject();
  229.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObjectGet.newSQLQueryObject();
  230.         


  233.         // Object transazioneApplicativoServer
  234.         sqlQueryObjectUpdate.setANDLogicOperator(true);
  235.         sqlQueryObjectUpdate.addUpdateTable(this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model()));
  236.         boolean isUpdate_transazioneApplicativoServer = true;
  237.         java.util.List<JDBCObject> lstObjects_transazioneApplicativoServer = new java.util.ArrayList<>();
  238.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().ID_TRANSAZIONE,false), "?");
  239.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getIdTransazione(), TransazioneApplicativoServer.model().ID_TRANSAZIONE.getFieldType()));
  240.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().SERVIZIO_APPLICATIVO_EROGATORE,false), "?");
  241.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getServizioApplicativoErogatore(), TransazioneApplicativoServer.model().SERVIZIO_APPLICATIVO_EROGATORE.getFieldType()));
  242.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CONNETTORE_NOME,false), "?");
  243.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getConnettoreNome(), TransazioneApplicativoServer.model().CONNETTORE_NOME.getFieldType()));
  244.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_REGISTRAZIONE,false), "?");
  245.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getDataRegistrazione(), TransazioneApplicativoServer.model().DATA_REGISTRAZIONE.getFieldType()));
  246.         // NONSERIALIZZATO SU DB sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().PROTOCOLLO,false), "?");
  247.         // NONSERIALIZZATO SU DB lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getProtocollo(), TransazioneApplicativoServer.model().PROTOCOLLO.getFieldType()));
  248.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CONSEGNA_TERMINATA,false), "?");
  249.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getConsegnaTerminata(), TransazioneApplicativoServer.model().CONSEGNA_TERMINATA.getFieldType()));
  250.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_MESSAGGIO_SCADUTO,false), "?");
  251.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getDataMessaggioScaduto(), TransazioneApplicativoServer.model().DATA_MESSAGGIO_SCADUTO.getFieldType()));
  252.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DETTAGLIO_ESITO,false), "?");
  253.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getDettaglioEsito(), TransazioneApplicativoServer.model().DETTAGLIO_ESITO.getFieldType()));
  254.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CONSEGNA_TRASPARENTE,false), "?");
  255.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getConsegnaTrasparente(), TransazioneApplicativoServer.model().CONSEGNA_TRASPARENTE.getFieldType()));
  256.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CONSEGNA_INTEGRATION_MANAGER,false), "?");
  257.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getConsegnaIntegrationManager(), TransazioneApplicativoServer.model().CONSEGNA_INTEGRATION_MANAGER.getFieldType()));
  258.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().IDENTIFICATIVO_MESSAGGIO,false), "?");
  259.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getIdentificativoMessaggio(), TransazioneApplicativoServer.model().IDENTIFICATIVO_MESSAGGIO.getFieldType()));
  260.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_ACCETTAZIONE_RICHIESTA,false), "?");
  261.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getDataAccettazioneRichiesta(), TransazioneApplicativoServer.model().DATA_ACCETTAZIONE_RICHIESTA.getFieldType()));
  262.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_USCITA_RICHIESTA,false), "?");
  263.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getDataUscitaRichiesta(), TransazioneApplicativoServer.model().DATA_USCITA_RICHIESTA.getFieldType()));
  264.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_USCITA_RICHIESTA_STREAM,false), "?");
  265.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getDataUscitaRichiestaStream(), TransazioneApplicativoServer.model().DATA_USCITA_RICHIESTA_STREAM.getFieldType()));
  266.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_ACCETTAZIONE_RISPOSTA,false), "?");
  267.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getDataAccettazioneRisposta(), TransazioneApplicativoServer.model().DATA_ACCETTAZIONE_RISPOSTA.getFieldType()));
  268.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_INGRESSO_RISPOSTA,false), "?");
  269.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getDataIngressoRisposta(), TransazioneApplicativoServer.model().DATA_INGRESSO_RISPOSTA.getFieldType()));
  270.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_INGRESSO_RISPOSTA_STREAM,false), "?");
  271.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getDataIngressoRispostaStream(), TransazioneApplicativoServer.model().DATA_INGRESSO_RISPOSTA_STREAM.getFieldType()));
  272.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().RICHIESTA_USCITA_BYTES,false), "?");
  273.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getRichiestaUscitaBytes(), TransazioneApplicativoServer.model().RICHIESTA_USCITA_BYTES.getFieldType()));
  274.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().RISPOSTA_INGRESSO_BYTES,false), "?");
  275.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getRispostaIngressoBytes(), TransazioneApplicativoServer.model().RISPOSTA_INGRESSO_BYTES.getFieldType()));
  276.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().LOCATION_CONNETTORE,false), "?");
  277.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getLocationConnettore(), TransazioneApplicativoServer.model().LOCATION_CONNETTORE.getFieldType()));
  278.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CODICE_RISPOSTA,false), "?");
  279.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getCodiceRisposta(), TransazioneApplicativoServer.model().CODICE_RISPOSTA.getFieldType()));
  280.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().FAULT,false), "?");
  281.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getFault(), TransazioneApplicativoServer.model().FAULT.getFieldType()));
  282.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().FORMATO_FAULT,false), "?");
  283.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getFormatoFault(), TransazioneApplicativoServer.model().FORMATO_FAULT.getFieldType()));
  284.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_PRIMO_TENTATIVO,false), "?");
  285.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getDataPrimoTentativo(), TransazioneApplicativoServer.model().DATA_PRIMO_TENTATIVO.getFieldType()));
  286.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().NUMERO_TENTATIVI,false), "?");
  287.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getNumeroTentativi(), TransazioneApplicativoServer.model().NUMERO_TENTATIVI.getFieldType()));
  288.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CLUSTER_ID_PRESA_IN_CARICO,false), "?");
  289.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getClusterIdPresaInCarico(), TransazioneApplicativoServer.model().CLUSTER_ID_PRESA_IN_CARICO.getFieldType()));
  290.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CLUSTER_ID_CONSEGNA,false), "?");
  291.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getClusterIdConsegna(), TransazioneApplicativoServer.model().CLUSTER_ID_CONSEGNA.getFieldType()));
  292.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_ULTIMO_ERRORE,false), "?");
  293.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getDataUltimoErrore(), TransazioneApplicativoServer.model().DATA_ULTIMO_ERRORE.getFieldType()));
  294.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DETTAGLIO_ESITO_ULTIMO_ERRORE,false), "?");
  295.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getDettaglioEsitoUltimoErrore(), TransazioneApplicativoServer.model().DETTAGLIO_ESITO_ULTIMO_ERRORE.getFieldType()));
  296.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CODICE_RISPOSTA_ULTIMO_ERRORE,false), "?");
  297.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getCodiceRispostaUltimoErrore(), TransazioneApplicativoServer.model().CODICE_RISPOSTA_ULTIMO_ERRORE.getFieldType()));
  298.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().ULTIMO_ERRORE,false), "?");
  299.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getUltimoErrore(), TransazioneApplicativoServer.model().ULTIMO_ERRORE.getFieldType()));
  300.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().LOCATION_ULTIMO_ERRORE,false), "?");
  301.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getLocationUltimoErrore(), TransazioneApplicativoServer.model().LOCATION_ULTIMO_ERRORE.getFieldType()));
  302.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CLUSTER_ID_ULTIMO_ERRORE,false), "?");
  303.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getClusterIdUltimoErrore(), TransazioneApplicativoServer.model().CLUSTER_ID_ULTIMO_ERRORE.getFieldType()));
  304.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().FAULT_ULTIMO_ERRORE,false), "?");
  305.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getFaultUltimoErrore(), TransazioneApplicativoServer.model().FAULT_ULTIMO_ERRORE.getFieldType()));
  306.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().FORMATO_FAULT_ULTIMO_ERRORE,false), "?");
  307.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getFormatoFaultUltimoErrore(), TransazioneApplicativoServer.model().FORMATO_FAULT_ULTIMO_ERRORE.getFieldType()));
  308.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_PRIMO_PRELIEVO_IM,false), "?");
  309.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getDataPrimoPrelievoIm(), TransazioneApplicativoServer.model().DATA_PRIMO_PRELIEVO_IM.getFieldType()));
  310.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_PRELIEVO_IM,false), "?");
  311.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getDataPrelievoIm(), TransazioneApplicativoServer.model().DATA_PRELIEVO_IM.getFieldType()));
  312.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().NUMERO_PRELIEVI_IM,false), "?");
  313.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getNumeroPrelieviIm(), TransazioneApplicativoServer.model().NUMERO_PRELIEVI_IM.getFieldType()));
  314.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_ELIMINAZIONE_IM,false), "?");
  315.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getDataEliminazioneIm(), TransazioneApplicativoServer.model().DATA_ELIMINAZIONE_IM.getFieldType()));
  316.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CLUSTER_ID_PRELIEVO_IM,false), "?");
  317.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getClusterIdPrelievoIm(), TransazioneApplicativoServer.model().CLUSTER_ID_PRELIEVO_IM.getFieldType()));
  318.         sqlQueryObjectUpdate.addUpdateField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CLUSTER_ID_ELIMINAZIONE_IM,false), "?");
  319.         lstObjects_transazioneApplicativoServer.add(new JDBCObject(transazioneApplicativoServer.getClusterIdEliminazioneIm(), TransazioneApplicativoServer.model().CLUSTER_ID_ELIMINAZIONE_IM.getFieldType()));
  320.         if(idLogico!=null) {
  321.             sqlQueryObjectUpdate.addWhereCondition(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().ID_TRANSAZIONE,false)+ "=?");
  322.             sqlQueryObjectUpdate.addWhereCondition(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().SERVIZIO_APPLICATIVO_EROGATORE,false)+ "=?");
  323.             sqlQueryObjectUpdate.setANDLogicOperator(true);
  324.             lstObjects_transazioneApplicativoServer.add(new JDBCObject(idLogico.getIdTransazione(), String.class));
  325.             lstObjects_transazioneApplicativoServer.add(new JDBCObject(idLogico.getServizioApplicativoErogatore(), String.class));
  326.         }
  327.         else {
  328.             sqlQueryObjectUpdate.addWhereCondition("id=?");
  329.             lstObjects_transazioneApplicativoServer.add(new JDBCObject(tableId, Long.class));
  330.         }

  332.         if(isUpdate_transazioneApplicativoServer) {
  333.             // Update transazioneApplicativoServer
  334.             jdbcUtilities.executeUpdate(sqlQueryObjectUpdate.createSQLUpdate(), jdbcProperties.isShowSql(), 
  335.                 lstObjects_transazioneApplicativoServer.toArray(new JDBCObject[]{}));
  336.         }


  339.     }
  340.     
  341.     @Override
  342.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdTransazioneApplicativoServer id, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  343.         
  344.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  345.                 this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model()), 
  346.                 this.getMapTableToPKColumnEngine(), 
  347.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  348.                 this.getTransazioneApplicativoServerFieldConverter(), this, null, updateFields);
  349.     }
  350.     
  351.     @Override
  352.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdTransazioneApplicativoServer id, IExpression condition, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  353.         
  354.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  355.                 this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model()), 
  356.                 this.getMapTableToPKColumnEngine(), 
  357.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  358.                 this.getTransazioneApplicativoServerFieldConverter(), this, condition, updateFields);
  359.     }
  360.     
  361.     @Override
  362.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdTransazioneApplicativoServer id, UpdateModel ... updateModels) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  363.         
  364.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  365.                 this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model()), 
  366.                 this.getMapTableToPKColumnEngine(), 
  367.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  368.                 this.getTransazioneApplicativoServerFieldConverter(), this, updateModels);
  369.     }   
  370.     
  371.     @Override
  372.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  373.         java.util.List<Object> ids = new java.util.ArrayList<>();
  374.         ids.add(tableId);
  375.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  376.                 this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model()), 
  377.                 this.getMapTableToPKColumnEngine(), 
  378.                 ids,
  379.                 this.getTransazioneApplicativoServerFieldConverter(), this, null, updateFields);
  380.     }
  381.     
  382.     @Override
  383.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, IExpression condition, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  384.         java.util.List<Object> ids = new java.util.ArrayList<>();
  385.         ids.add(tableId);
  386.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  387.                 this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model()), 
  388.                 this.getMapTableToPKColumnEngine(), 
  389.                 ids,
  390.                 this.getTransazioneApplicativoServerFieldConverter(), this, condition, updateFields);
  391.     }
  392.     
  393.     @Override
  394.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, UpdateModel ... updateModels) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  395.         java.util.List<Object> ids = new java.util.ArrayList<>();
  396.         ids.add(tableId);
  397.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  398.                 this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model()), 
  399.                 this.getMapTableToPKColumnEngine(), 
  400.                 ids,
  401.                 this.getTransazioneApplicativoServerFieldConverter(), this, updateModels);
  402.     }
  403.     
  404.     @Override
  405.     public void updateOrCreate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdTransazioneApplicativoServer oldId, TransazioneApplicativoServer transazioneApplicativoServer, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {
  406.     
  407.         if(this.exists(jdbcProperties, log, connection, sqlQueryObject, oldId)) {
  408.             this.update(jdbcProperties, log, connection, sqlQueryObject, oldId, transazioneApplicativoServer,idMappingResolutionBehaviour);
  409.         } else {
  410.             this.create(jdbcProperties, log, connection, sqlQueryObject, transazioneApplicativoServer,idMappingResolutionBehaviour);
  411.         }
  412.         
  413.     }
  414.     
  415.     @Override
  416.     public void updateOrCreate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, TransazioneApplicativoServer transazioneApplicativoServer, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {
  417.         if(this.exists(jdbcProperties, log, connection, sqlQueryObject, tableId)) {
  418.             this.update(jdbcProperties, log, connection, sqlQueryObject, tableId, transazioneApplicativoServer,idMappingResolutionBehaviour);
  419.         } else {
  420.             this.create(jdbcProperties, log, connection, sqlQueryObject, transazioneApplicativoServer,idMappingResolutionBehaviour);
  421.         }
  422.     }
  423.     
  424.     @Override
  425.     public void delete(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, TransazioneApplicativoServer transazioneApplicativoServer) throws NotImplementedException,ServiceException,Exception {
  426.         
  427.         
  428.         Long longId = null;
  429.         if( (transazioneApplicativoServer.getId()!=null) && (transazioneApplicativoServer.getId()>0) ){
  430.             longId = transazioneApplicativoServer.getId();
  431.         }
  432.         else{
  433.             IdTransazioneApplicativoServer idTransazioneApplicativoServer = this.convertToId(jdbcProperties,log,connection,sqlQueryObject,transazioneApplicativoServer);
  434.             longId = this.findIdTransazioneApplicativoServer(jdbcProperties,log,connection,sqlQueryObject,idTransazioneApplicativoServer,false);
  435.             if(longId == null){
  436.                 return; // entry not exists
  437.             }
  438.         }       
  439.         
  440.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, longId);
  441.         
  442.     }

  444.     private void deleteEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long id) throws NotImplementedException,ServiceException,Exception {
  445.     
  446.         if(id!=null && id.longValue()<=0){
  447.             throw new ServiceException("Id is less equals 0");
  448.         }
  449.         
  450.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  451.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  452.         
  453.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObject.newSQLQueryObject();
  454.         

  456.         // Object transazioneApplicativoServer
  457.         sqlQueryObjectDelete.setANDLogicOperator(true);
  458.         sqlQueryObjectDelete.addDeleteTable(this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model()));
  459.         if(id != null)
  460.             sqlQueryObjectDelete.addWhereCondition("id=?");

  462.         // Delete transazioneApplicativoServer
  463.         jdbcUtilities.execute(sqlQueryObjectDelete.createSQLDelete(), jdbcProperties.isShowSql(), 
  464.             new JDBCObject(id,Long.class));

  466.     }

  468.     @Override
  469.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdTransazioneApplicativoServer idTransazioneApplicativoServer) throws NotImplementedException,ServiceException,Exception {

  471.         Long id = null;
  472.         try{
  473.             id = this.findIdTransazioneApplicativoServer(jdbcProperties, log, connection, sqlQueryObject, idTransazioneApplicativoServer, true);
  474.         }catch(NotFoundException notFound){
  475.             return;
  476.         }
  477.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  478.         
  479.     }
  480.     
  481.     @Override
  482.     public NonNegativeNumber deleteAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject) throws NotImplementedException,ServiceException,Exception {
  483.         
  484.         return this.deleteAll(jdbcProperties, log, connection, sqlQueryObject, new JDBCExpression(this.getTransazioneApplicativoServerFieldConverter()));

  486.     }

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

  491.         java.util.List<Long> lst = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, new JDBCPaginatedExpression(expression));
  492.         
  493.         for(Long id : lst) {
  494.             this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  495.         }
  496.         
  497.         return new NonNegativeNumber(lst.size());
  498.     
  499.     }



  503.     // -- DB
  504.     
  505.     @Override
  506.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws ServiceException, NotImplementedException, Exception {
  507.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  508.     }
  509.     
  510.     @Override
  511.     public int nativeUpdate(JDBCServiceManagerProperties jdbcProperties, Logger log,Connection connection,ISQLQueryObject sqlObject, String sql,Object ... param) throws ServiceException,NotImplementedException, Exception {
  512.     
  513.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeUpdate(jdbcProperties, log, connection, sqlObject,
  514.                                                                                             sql,param);
  515.     
  516.     }
  517. }
Created with JaCoCo 0.8.8.202204050719