JDBCDumpMessaggioServiceImpl.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.sql.ISQLQueryObject;

  26. import org.slf4j.Logger;

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

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

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

  45. import org.openspcoop2.core.transazioni.DumpHeaderTrasporto;
  46. import org.openspcoop2.core.transazioni.DumpHeaderAllegato;
  47. import org.openspcoop2.core.transazioni.DumpContenuto;
  48. import org.openspcoop2.core.transazioni.DumpAllegato;
  49. import org.openspcoop2.core.transazioni.DumpMessaggio;
  50. import org.openspcoop2.core.transazioni.DumpMultipartHeader;

  52. /**     
  53.  * JDBCDumpMessaggioServiceImpl
  54.  *
  55.  * @author Poli Andrea (poli@link.it)
  56.  * @author $Author$
  57.  * @version $Rev$, $Date$
  58.  */
  59. public class JDBCDumpMessaggioServiceImpl extends JDBCDumpMessaggioServiceSearchImpl
  60.     implements IJDBCServiceCRUDWithId<DumpMessaggio, IdDumpMessaggio, JDBCServiceManager> {

  62.     @Override
  63.     public void create(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, DumpMessaggio dumpMessaggio, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {

  65.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  66.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  67.         
  68.         ISQLQueryObject sqlQueryObjectInsert = sqlQueryObject.newSQLQueryObject();
  69.                 


  72.         // Object dumpMessaggio
  73.         sqlQueryObjectInsert.addInsertTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model()));
  74.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ID_TRANSAZIONE,false),"?");
  75.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().PROTOCOLLO,false),"?");
  76.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().SERVIZIO_APPLICATIVO_EROGATORE,false),"?");
  77.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().DATA_CONSEGNA_EROGATORE,false),"?");
  78.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().TIPO_MESSAGGIO,false),"?");
  79.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().FORMATO_MESSAGGIO,false),"?");
  80.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENT_TYPE,false),"?");
  81.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENT_LENGTH,false),"?");
  82.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_CONTENT_TYPE,false),"?");
  83.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_CONTENT_ID,false),"?");
  84.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_CONTENT_LOCATION,false),"?");
  85.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().BODY,false),"?");
  86.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().DUMP_TIMESTAMP,false),"?");
  87.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESS_HEADER,false),"?");
  88.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESS_FILENAME,false),"?");
  89.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESS_CONTENT,false),"?");
  90.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESS_CONFIG_ID,false),"?");
  91.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESS_TIMESTAMP,false),"?");
  92.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESSED,false),"?");
  93.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_HEADER_EXT,false),"?");
  94.         sqlQueryObjectInsert.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().HEADER_EXT,false),"?");

  96.         // Insert dumpMessaggio
  97.         org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator = this.getDumpMessaggioFetch().getKeyGeneratorObject(DumpMessaggio.model());
  98.         long id = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert, keyGenerator, jdbcProperties.isShowSql(),
  99.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getIdTransazione(),DumpMessaggio.model().ID_TRANSAZIONE.getFieldType()),
  100.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getProtocollo(),DumpMessaggio.model().PROTOCOLLO.getFieldType()),
  101.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getServizioApplicativoErogatore(),DumpMessaggio.model().SERVIZIO_APPLICATIVO_EROGATORE.getFieldType()),
  102.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getDataConsegnaErogatore(),DumpMessaggio.model().DATA_CONSEGNA_EROGATORE.getFieldType()),
  103.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getTipoMessaggio(),DumpMessaggio.model().TIPO_MESSAGGIO.getFieldType()),
  104.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getFormatoMessaggio(),DumpMessaggio.model().FORMATO_MESSAGGIO.getFieldType()),
  105.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getContentType(),DumpMessaggio.model().CONTENT_TYPE.getFieldType()),
  106.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getContentLength(),DumpMessaggio.model().CONTENT_LENGTH.getFieldType()),
  107.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getMultipartContentType(),DumpMessaggio.model().MULTIPART_CONTENT_TYPE.getFieldType()),
  108.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getMultipartContentId(),DumpMessaggio.model().MULTIPART_CONTENT_ID.getFieldType()),
  109.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getMultipartContentLocation(),DumpMessaggio.model().MULTIPART_CONTENT_LOCATION.getFieldType()),
  110.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getBody(),DumpMessaggio.model().BODY.getFieldType()),
  111.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getDumpTimestamp(),DumpMessaggio.model().DUMP_TIMESTAMP.getFieldType()),
  112.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getPostProcessHeader(),DumpMessaggio.model().POST_PROCESS_HEADER.getFieldType()),
  113.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getPostProcessFilename(),DumpMessaggio.model().POST_PROCESS_FILENAME.getFieldType()),
  114.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getPostProcessContent(),DumpMessaggio.model().POST_PROCESS_CONTENT.getFieldType()),
  115.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getPostProcessConfigId(),DumpMessaggio.model().POST_PROCESS_CONFIG_ID.getFieldType()),
  116.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getPostProcessTimestamp(),DumpMessaggio.model().POST_PROCESS_TIMESTAMP.getFieldType()),
  117.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getPostProcessed(),DumpMessaggio.model().POST_PROCESSED.getFieldType()),
  118.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getMultipartHeaderExt(),DumpMessaggio.model().MULTIPART_HEADER_EXT.getFieldType()),
  119.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getHeaderExt(),DumpMessaggio.model().HEADER_EXT.getFieldType())
  120.         );
  121.         dumpMessaggio.setId(id);

  123.         // for dumpMessaggio
  124.         for (int i = 0; i < dumpMessaggio.getAllegatoList().size(); i++) {


  127.             // Object dumpMessaggio.getAllegatoList().get(i)
  128.             ISQLQueryObject sqlQueryObjectInsert_allegato = sqlQueryObjectInsert.newSQLQueryObject();
  129.             sqlQueryObjectInsert_allegato.addInsertTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO));
  130.             sqlQueryObjectInsert_allegato.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.CONTENT_TYPE,false),"?");
  131.             sqlQueryObjectInsert_allegato.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.CONTENT_ID,false),"?");
  132.             sqlQueryObjectInsert_allegato.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.CONTENT_LOCATION,false),"?");
  133.             sqlQueryObjectInsert_allegato.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.ALLEGATO,false),"?");
  134.             sqlQueryObjectInsert_allegato.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.DUMP_TIMESTAMP,false),"?");
  135.             sqlQueryObjectInsert_allegato.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER_EXT,false),"?");
  136.             sqlQueryObjectInsert_allegato.addInsertField("id_messaggio","?");

  138.             // Insert dumpMessaggio.getAllegatoList().get(i)
  139.             org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator_allegato = this.getDumpMessaggioFetch().getKeyGeneratorObject(DumpMessaggio.model().ALLEGATO);
  140.             long id_allegato = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert_allegato, keyGenerator_allegato, jdbcProperties.isShowSql(),
  141.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getAllegatoList().get(i).getContentType(),DumpMessaggio.model().ALLEGATO.CONTENT_TYPE.getFieldType()),
  142.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getAllegatoList().get(i).getContentId(),DumpMessaggio.model().ALLEGATO.CONTENT_ID.getFieldType()),
  143.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getAllegatoList().get(i).getContentLocation(),DumpMessaggio.model().ALLEGATO.CONTENT_LOCATION.getFieldType()),
  144.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getAllegatoList().get(i).getAllegato(),DumpMessaggio.model().ALLEGATO.ALLEGATO.getFieldType()),
  145.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getAllegatoList().get(i).getDumpTimestamp(),DumpMessaggio.model().ALLEGATO.DUMP_TIMESTAMP.getFieldType()),
  146.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getAllegatoList().get(i).getHeaderExt(),DumpMessaggio.model().ALLEGATO.HEADER_EXT.getFieldType()),
  147.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(Long.valueOf(id),Long.class)
  148.             );
  149.             dumpMessaggio.getAllegatoList().get(i).setId(id_allegato);

  151.             // for dumpMessaggio.getAllegatoList().get(i)
  152.             for (int i_allegato = 0; i_allegato < dumpMessaggio.getAllegatoList().get(i).getHeaderList().size(); i_allegato++) {

  154.                 // Bug fix OPPT-466 per gestione empty string as null on oracle
  155.                 // Rilasciare il vincolo di not null 'fisico' sul database.
  156.                 // Imporlo logicamente, in modo che non siano permessi insert o update con valori null.
  157.                 // Dopodichè, se nella get viene recuperato un valore null, deve essere trasformato in stringa vuota.
  158.                 DumpHeaderAllegato dht = dumpMessaggio.getAllegatoList().get(i).getHeaderList().get(i_allegato);
  159.                 if(dht.getValore()==null){
  160.                     throw new ServiceException("Header ["+dht.getNome()+"] dell'allegato-"+i+" ["+dumpMessaggio.getAllegatoList().get(i).getContentId()+"] with value null");
  161.                 }

  163.                 // Object dumpMessaggio.getAllegatoList().get(i).getHeaderList().get(i_allegato)
  164.                 ISQLQueryObject sqlQueryObjectInsert_allegato_header = sqlQueryObjectInsert.newSQLQueryObject();
  165.                 sqlQueryObjectInsert_allegato_header.addInsertTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO.HEADER));
  166.                 sqlQueryObjectInsert_allegato_header.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER.NOME,false),"?");
  167.                 sqlQueryObjectInsert_allegato_header.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER.VALORE,false),"?");
  168.                 sqlQueryObjectInsert_allegato_header.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER.DUMP_TIMESTAMP,false),"?");
  169.                 sqlQueryObjectInsert_allegato_header.addInsertField("id_allegato","?");

  171.                 // Insert dumpMessaggio.getAllegatoList().get(i).getHeaderList().get(i_allegato)
  172.                 org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator_allegato_header = this.getDumpMessaggioFetch().getKeyGeneratorObject(DumpMessaggio.model().ALLEGATO.HEADER);
  173.                 long id_allegato_header = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert_allegato_header, keyGenerator_allegato_header, jdbcProperties.isShowSql(),
  174.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getAllegatoList().get(i).getHeaderList().get(i_allegato).getNome(),DumpMessaggio.model().ALLEGATO.HEADER.NOME.getFieldType()),
  175.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getAllegatoList().get(i).getHeaderList().get(i_allegato).getValore(),DumpMessaggio.model().ALLEGATO.HEADER.VALORE.getFieldType()),
  176.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getAllegatoList().get(i).getHeaderList().get(i_allegato).getDumpTimestamp(),DumpMessaggio.model().ALLEGATO.HEADER.DUMP_TIMESTAMP.getFieldType()),
  177.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(Long.valueOf(id_allegato),Long.class)
  178.                 );
  179.                 dumpMessaggio.getAllegatoList().get(i).getHeaderList().get(i_allegato).setId(id_allegato_header);
  180.             } // fine for _allegato
  181.         } // fine for 

  183.         // for dumpMessaggio
  184.         for (int i = 0; i < dumpMessaggio.getContenutoList().size(); i++) {


  187.             // Object dumpMessaggio.getContenutoList().get(i)
  188.             ISQLQueryObject sqlQueryObjectInsert_contenuto = sqlQueryObjectInsert.newSQLQueryObject();
  189.             sqlQueryObjectInsert_contenuto.addInsertTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().CONTENUTO));
  190.             sqlQueryObjectInsert_contenuto.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENUTO.NOME,false),"?");
  191.             sqlQueryObjectInsert_contenuto.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENUTO.VALORE,false),"?");
  192.             sqlQueryObjectInsert_contenuto.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENUTO.VALORE_AS_BYTES,false),"?");
  193.             sqlQueryObjectInsert_contenuto.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENUTO.DUMP_TIMESTAMP,false),"?");
  194.             sqlQueryObjectInsert_contenuto.addInsertField("id_messaggio","?");

  196.             // Insert dumpMessaggio.getContenutoList().get(i)
  197.             org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator_contenuto = this.getDumpMessaggioFetch().getKeyGeneratorObject(DumpMessaggio.model().CONTENUTO);
  198.             long id_contenuto = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert_contenuto, keyGenerator_contenuto, jdbcProperties.isShowSql(),
  199.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getContenutoList().get(i).getNome(),DumpMessaggio.model().CONTENUTO.NOME.getFieldType()),
  200.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getContenutoList().get(i).getValore(),DumpMessaggio.model().CONTENUTO.VALORE.getFieldType()),
  201.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getContenutoList().get(i).getValoreAsBytes(),DumpMessaggio.model().CONTENUTO.VALORE_AS_BYTES.getFieldType()),
  202.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getContenutoList().get(i).getDumpTimestamp(),DumpMessaggio.model().CONTENUTO.DUMP_TIMESTAMP.getFieldType()),
  203.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(Long.valueOf(id),Long.class)
  204.             );
  205.             dumpMessaggio.getContenutoList().get(i).setId(id_contenuto);
  206.         } // fine for 

  208.         // for dumpMessaggio
  209.         for (int i = 0; i < dumpMessaggio.getHeaderTrasportoList().size(); i++) {

  211.             // Bug fix OPPT-466 per gestione empty string as null on oracle
  212.             // Rilasciare il vincolo di not null 'fisico' sul database.
  213.             // Imporlo logicamente, in modo che non siano permessi insert o update con valori null.
  214.             // Dopodichè, se nella get viene recuperato un valore null, deve essere trasformato in stringa vuota.
  215.             DumpHeaderTrasporto dht = dumpMessaggio.getHeaderTrasporto(i);
  216.             if(dht.getValore()==null){
  217.                 throw new ServiceException("Header ["+dht.getNome()+"] with value null");
  218.             }

  220.             // Object dumpMessaggio.getHeaderTrasportoList().get(i)
  221.             ISQLQueryObject sqlQueryObjectInsert_headerTrasporto = sqlQueryObjectInsert.newSQLQueryObject();
  222.             sqlQueryObjectInsert_headerTrasporto.addInsertTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().HEADER_TRASPORTO));
  223.             sqlQueryObjectInsert_headerTrasporto.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().HEADER_TRASPORTO.NOME,false),"?");
  224.             sqlQueryObjectInsert_headerTrasporto.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().HEADER_TRASPORTO.VALORE,false),"?");
  225.             sqlQueryObjectInsert_headerTrasporto.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().HEADER_TRASPORTO.DUMP_TIMESTAMP,false),"?");
  226.             sqlQueryObjectInsert_headerTrasporto.addInsertField("id_messaggio","?");

  228.             // Insert dumpMessaggio.getHeaderTrasportoList().get(i)
  229.             org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator_headerTrasporto = this.getDumpMessaggioFetch().getKeyGeneratorObject(DumpMessaggio.model().HEADER_TRASPORTO);
  230.             long id_headerTrasporto = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert_headerTrasporto, keyGenerator_headerTrasporto, jdbcProperties.isShowSql(),
  231.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getHeaderTrasportoList().get(i).getNome(),DumpMessaggio.model().HEADER_TRASPORTO.NOME.getFieldType()),
  232.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getHeaderTrasportoList().get(i).getValore(),DumpMessaggio.model().HEADER_TRASPORTO.VALORE.getFieldType()),
  233.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getHeaderTrasportoList().get(i).getDumpTimestamp(),DumpMessaggio.model().HEADER_TRASPORTO.DUMP_TIMESTAMP.getFieldType()),
  234.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(Long.valueOf(id),Long.class)
  235.             );
  236.             dumpMessaggio.getHeaderTrasportoList().get(i).setId(id_headerTrasporto);
  237.         } // fine for 

  239.         // for dumpMessaggio
  240.         for (int i = 0; i < dumpMessaggio.getMultipartHeaderList().size(); i++) {

  242.             // Bug fix OPPT-466 per gestione empty string as null on oracle
  243.             // Rilasciare il vincolo di not null 'fisico' sul database.
  244.             // Imporlo logicamente, in modo che non siano permessi insert o update con valori null.
  245.             // Dopodichè, se nella get viene recuperato un valore null, deve essere trasformato in stringa vuota.
  246.             DumpMultipartHeader dht = dumpMessaggio.getMultipartHeader(i);
  247.             if(dht.getValore()==null){
  248.                 throw new ServiceException("Header ["+dht.getNome()+"] with value null");
  249.             }

  251.             // Object dumpMessaggio.getMultipartHeaderList().get(i)
  252.             ISQLQueryObject sqlQueryObjectInsert_multipartHeader = sqlQueryObjectInsert.newSQLQueryObject();
  253.             sqlQueryObjectInsert_multipartHeader.addInsertTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().MULTIPART_HEADER));
  254.             sqlQueryObjectInsert_multipartHeader.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_HEADER.NOME,false),"?");
  255.             sqlQueryObjectInsert_multipartHeader.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_HEADER.VALORE,false),"?");
  256.             sqlQueryObjectInsert_multipartHeader.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_HEADER.DUMP_TIMESTAMP,false),"?");
  257.             sqlQueryObjectInsert_multipartHeader.addInsertField("id_messaggio","?");

  259.             // Insert dumpMessaggio.getMultipartHeaderList().get(i)
  260.             org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator_multipartHeader = this.getDumpMessaggioFetch().getKeyGeneratorObject(DumpMessaggio.model().MULTIPART_HEADER);
  261.             long id_multipartHeader = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert_multipartHeader, keyGenerator_multipartHeader, jdbcProperties.isShowSql(),
  262.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getMultipartHeaderList().get(i).getNome(),DumpMessaggio.model().MULTIPART_HEADER.NOME.getFieldType()),
  263.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getMultipartHeaderList().get(i).getValore(),DumpMessaggio.model().MULTIPART_HEADER.VALORE.getFieldType()),
  264.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio.getMultipartHeaderList().get(i).getDumpTimestamp(),DumpMessaggio.model().MULTIPART_HEADER.DUMP_TIMESTAMP.getFieldType()),
  265.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(Long.valueOf(id),Long.class)
  266.             );
  267.             dumpMessaggio.getMultipartHeaderList().get(i).setId(id_multipartHeader);
  268.         } // fine for 

  270.         
  271.     }

  273.     @Override
  274.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdDumpMessaggio oldId, DumpMessaggio dumpMessaggio, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  275.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObject.newSQLQueryObject();
  276.         Long longIdByLogicId = this.findIdDumpMessaggio(jdbcProperties, log, connection, sqlQueryObjectUpdate.newSQLQueryObject(), oldId, true);
  277.         Long tableId = dumpMessaggio.getId();
  278.         if(tableId != null && tableId.longValue() > 0) {
  279.             if(tableId.longValue() != longIdByLogicId.longValue()) {
  280.                 throw new Exception("Ambiguous parameter: dumpMessaggio.id ["+tableId+"] does not match logic id ["+longIdByLogicId+"]");
  281.             }
  282.         } else {
  283.             tableId = longIdByLogicId;
  284.             dumpMessaggio.setId(tableId);
  285.         }
  286.         if(tableId==null || tableId<=0){
  287.             throw new Exception("Retrieve tableId failed");
  288.         }

  290.         this.update(jdbcProperties, log, connection, sqlQueryObject, tableId, dumpMessaggio, idMappingResolutionBehaviour);
  291.     }
  292.     @Override
  293.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, DumpMessaggio dumpMessaggio, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  294.     
  295.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  296.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  297.         
  298.         ISQLQueryObject sqlQueryObjectInsert = sqlQueryObject.newSQLQueryObject();
  299.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObjectInsert.newSQLQueryObject();
  300.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObjectDelete.newSQLQueryObject();
  301.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObjectGet.newSQLQueryObject();
  302.         


  305.         // Object dumpMessaggio
  306.         sqlQueryObjectUpdate.setANDLogicOperator(true);
  307.         sqlQueryObjectUpdate.addUpdateTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model()));
  308.         boolean isUpdate_dumpMessaggio = true;
  309.         java.util.List<JDBCObject> lstObjects_dumpMessaggio = new java.util.ArrayList<>();
  310.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ID_TRANSAZIONE,false), "?");
  311.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getIdTransazione(), DumpMessaggio.model().ID_TRANSAZIONE.getFieldType()));
  312.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().PROTOCOLLO,false), "?");
  313.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getProtocollo(), DumpMessaggio.model().PROTOCOLLO.getFieldType()));
  314.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().SERVIZIO_APPLICATIVO_EROGATORE,false), "?");
  315.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getServizioApplicativoErogatore(), DumpMessaggio.model().SERVIZIO_APPLICATIVO_EROGATORE.getFieldType()));
  316.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().DATA_CONSEGNA_EROGATORE,false), "?");
  317.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getDataConsegnaErogatore(), DumpMessaggio.model().DATA_CONSEGNA_EROGATORE.getFieldType()));
  318.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().TIPO_MESSAGGIO,false), "?");
  319.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getTipoMessaggio(), DumpMessaggio.model().TIPO_MESSAGGIO.getFieldType()));
  320.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().FORMATO_MESSAGGIO,false), "?");
  321.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getFormatoMessaggio(), DumpMessaggio.model().FORMATO_MESSAGGIO.getFieldType()));
  322.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENT_TYPE,false), "?");
  323.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getContentType(), DumpMessaggio.model().CONTENT_TYPE.getFieldType()));
  324.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENT_LENGTH,false), "?");
  325.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getContentLength(), DumpMessaggio.model().CONTENT_LENGTH.getFieldType()));
  326.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_CONTENT_TYPE,false), "?");
  327.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getMultipartContentType(), DumpMessaggio.model().MULTIPART_CONTENT_TYPE.getFieldType()));
  328.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_CONTENT_ID,false), "?");
  329.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getMultipartContentId(), DumpMessaggio.model().MULTIPART_CONTENT_ID.getFieldType()));
  330.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_CONTENT_LOCATION,false), "?");
  331.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getMultipartContentLocation(), DumpMessaggio.model().MULTIPART_CONTENT_LOCATION.getFieldType()));
  332.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().BODY,false), "?");
  333.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getBody(), DumpMessaggio.model().BODY.getFieldType()));
  334.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().DUMP_TIMESTAMP,false), "?");
  335.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getDumpTimestamp(), DumpMessaggio.model().DUMP_TIMESTAMP.getFieldType()));
  336.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESS_HEADER,false), "?");
  337.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getPostProcessHeader(), DumpMessaggio.model().POST_PROCESS_HEADER.getFieldType()));
  338.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESS_FILENAME,false), "?");
  339.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getPostProcessFilename(), DumpMessaggio.model().POST_PROCESS_FILENAME.getFieldType()));
  340.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESS_CONTENT,false), "?");
  341.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getPostProcessContent(), DumpMessaggio.model().POST_PROCESS_CONTENT.getFieldType()));
  342.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESS_CONFIG_ID,false), "?");
  343.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getPostProcessConfigId(), DumpMessaggio.model().POST_PROCESS_CONFIG_ID.getFieldType()));
  344.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESS_TIMESTAMP,false), "?");
  345.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getPostProcessTimestamp(), DumpMessaggio.model().POST_PROCESS_TIMESTAMP.getFieldType()));
  346.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESSED,false), "?");
  347.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getPostProcessed(), DumpMessaggio.model().POST_PROCESSED.getFieldType()));
  348.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_HEADER_EXT,false), "?");
  349.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getMultipartHeaderExt(), DumpMessaggio.model().MULTIPART_HEADER_EXT.getFieldType()));
  350.         sqlQueryObjectUpdate.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().HEADER_EXT,false), "?");
  351.         lstObjects_dumpMessaggio.add(new JDBCObject(dumpMessaggio.getHeaderExt(), DumpMessaggio.model().HEADER_EXT.getFieldType()));
  352.         sqlQueryObjectUpdate.addWhereCondition("id=?");
  353.         lstObjects_dumpMessaggio.add(new JDBCObject(tableId, Long.class));

  355.         if(isUpdate_dumpMessaggio) {
  356.             // Update dumpMessaggio
  357.             jdbcUtilities.executeUpdate(sqlQueryObjectUpdate.createSQLUpdate(), jdbcProperties.isShowSql(), 
  358.                 lstObjects_dumpMessaggio.toArray(new JDBCObject[]{}));
  359.         }
  360.         // for dumpMessaggio_multipartHeader

  362.         java.util.List<Long> ids_dumpMessaggio_multipartHeader_da_non_eliminare = new java.util.ArrayList<Long>();
  363.         for (Object dumpMessaggio_multipartHeader_object : dumpMessaggio.getMultipartHeaderList()) {
  364.             DumpMultipartHeader dumpMessaggio_multipartHeader = (DumpMultipartHeader) dumpMessaggio_multipartHeader_object;
  365.             
  366.             // Bug fix OPPT-466 per gestione empty string as null on oracle
  367.             // Rilasciare il vincolo di not null 'fisico' sul database.
  368.             // Imporlo logicamente, in modo che non siano permessi insert o update con valori null.
  369.             // Dopodichè, se nella get viene recuperato un valore null, deve essere trasformato in stringa vuota.
  370.             if(dumpMessaggio_multipartHeader.getValore()==null){
  371.                 throw new ServiceException("Header ["+dumpMessaggio_multipartHeader.getNome()+"] with value null");
  372.             }
  373.             
  374.             if(dumpMessaggio_multipartHeader.getId() == null || dumpMessaggio_multipartHeader.getId().longValue() <= 0) {

  376.                 long id = dumpMessaggio.getId();            

  378.                 // Object dumpMessaggio_multipartHeader
  379.                 ISQLQueryObject sqlQueryObjectInsert_dumpMessaggio_multipartHeader = sqlQueryObjectInsert.newSQLQueryObject();
  380.                 sqlQueryObjectInsert_dumpMessaggio_multipartHeader.addInsertTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().MULTIPART_HEADER));
  381.                 sqlQueryObjectInsert_dumpMessaggio_multipartHeader.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_HEADER.NOME,false),"?");
  382.                 sqlQueryObjectInsert_dumpMessaggio_multipartHeader.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_HEADER.VALORE,false),"?");
  383.                 sqlQueryObjectInsert_dumpMessaggio_multipartHeader.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_HEADER.DUMP_TIMESTAMP,false),"?");
  384.                 sqlQueryObjectInsert_dumpMessaggio_multipartHeader.addInsertField("id_messaggio","?");

  386.                 // Insert dumpMessaggio_multipartHeader
  387.                 org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator_dumpMessaggio_multipartHeader = this.getDumpMessaggioFetch().getKeyGeneratorObject(DumpMessaggio.model().MULTIPART_HEADER);
  388.                 long id_dumpMessaggio_multipartHeader = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert_dumpMessaggio_multipartHeader, keyGenerator_dumpMessaggio_multipartHeader, jdbcProperties.isShowSql(),
  389.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_multipartHeader.getNome(),DumpMessaggio.model().MULTIPART_HEADER.NOME.getFieldType()),
  390.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_multipartHeader.getValore(),DumpMessaggio.model().MULTIPART_HEADER.VALORE.getFieldType()),
  391.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_multipartHeader.getDumpTimestamp(),DumpMessaggio.model().MULTIPART_HEADER.DUMP_TIMESTAMP.getFieldType()),
  392.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(Long.valueOf(id),Long.class)
  393.                 );
  394.                 dumpMessaggio_multipartHeader.setId(id_dumpMessaggio_multipartHeader);

  396.                 ids_dumpMessaggio_multipartHeader_da_non_eliminare.add(dumpMessaggio_multipartHeader.getId());
  397.             } else {


  400.                 // Object dumpMessaggio_multipartHeader
  401.                 ISQLQueryObject sqlQueryObjectUpdate_dumpMessaggio_multipartHeader = sqlQueryObjectUpdate.newSQLQueryObject();
  402.                 sqlQueryObjectUpdate_dumpMessaggio_multipartHeader.setANDLogicOperator(true);
  403.                 sqlQueryObjectUpdate_dumpMessaggio_multipartHeader.addUpdateTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().MULTIPART_HEADER));
  404.                 boolean isUpdate_dumpMessaggio_multipartHeader = true;
  405.                 java.util.List<JDBCObject> lstObjects_dumpMessaggio_multipartHeader = new java.util.ArrayList<>();
  406.                 sqlQueryObjectUpdate_dumpMessaggio_multipartHeader.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_HEADER.NOME,false), "?");
  407.                 lstObjects_dumpMessaggio_multipartHeader.add(new JDBCObject(dumpMessaggio_multipartHeader.getNome(), DumpMessaggio.model().MULTIPART_HEADER.NOME.getFieldType()));
  408.                 sqlQueryObjectUpdate_dumpMessaggio_multipartHeader.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_HEADER.VALORE,false), "?");
  409.                 lstObjects_dumpMessaggio_multipartHeader.add(new JDBCObject(dumpMessaggio_multipartHeader.getValore(), DumpMessaggio.model().MULTIPART_HEADER.VALORE.getFieldType()));
  410.                 sqlQueryObjectUpdate_dumpMessaggio_multipartHeader.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_HEADER.DUMP_TIMESTAMP,false), "?");
  411.                 lstObjects_dumpMessaggio_multipartHeader.add(new JDBCObject(dumpMessaggio_multipartHeader.getDumpTimestamp(), DumpMessaggio.model().MULTIPART_HEADER.DUMP_TIMESTAMP.getFieldType()));
  412.                 sqlQueryObjectUpdate_dumpMessaggio_multipartHeader.addWhereCondition("id=?");
  413.                 ids_dumpMessaggio_multipartHeader_da_non_eliminare.add(dumpMessaggio_multipartHeader.getId());
  414.                 lstObjects_dumpMessaggio_multipartHeader.add(new JDBCObject(dumpMessaggio_multipartHeader.getId(),Long.class));

  416.                 if(isUpdate_dumpMessaggio_multipartHeader) {
  417.                     // Update dumpMessaggio_multipartHeader
  418.                     jdbcUtilities.executeUpdate(sqlQueryObjectUpdate_dumpMessaggio_multipartHeader.createSQLUpdate(), jdbcProperties.isShowSql(), 
  419.                         lstObjects_dumpMessaggio_multipartHeader.toArray(new JDBCObject[]{}));
  420.                 }
  421.             }
  422.         } // fine for dumpMessaggio_multipartHeader

  424.         // elimino tutte le occorrenze di dumpMessaggio_multipartHeader non presenti nell'update

  426.         ISQLQueryObject sqlQueryObjectUpdate_multipartHeaderdeleteEngineList = sqlQueryObjectUpdate.newSQLQueryObject();
  427.         sqlQueryObjectUpdate_multipartHeaderdeleteEngineList.setANDLogicOperator(true);
  428.         sqlQueryObjectUpdate_multipartHeaderdeleteEngineList.addDeleteTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().MULTIPART_HEADER));
  429.         java.util.List<JDBCObject> jdbcObjects_dumpMessaggio_multipartHeaderdeleteEngine = new java.util.ArrayList<>();

  431.         sqlQueryObjectUpdate_multipartHeaderdeleteEngineList.addWhereCondition("id_messaggio=?");
  432.         jdbcObjects_dumpMessaggio_multipartHeaderdeleteEngine.add(new JDBCObject(dumpMessaggio.getId(), Long.class));

  434.         StringBuilder marks_dumpMessaggio_multipartHeader = new StringBuilder();
  435.         if(ids_dumpMessaggio_multipartHeader_da_non_eliminare.size() > 0) {
  436.             for(Long ids : ids_dumpMessaggio_multipartHeader_da_non_eliminare) {
  437.                 if(marks_dumpMessaggio_multipartHeader.length() > 0) {
  438.                     marks_dumpMessaggio_multipartHeader.append(",");
  439.                 }
  440.                 marks_dumpMessaggio_multipartHeader.append("?");
  441.                 jdbcObjects_dumpMessaggio_multipartHeaderdeleteEngine.add(new JDBCObject(ids, Long.class));

  443.             }
  444.             sqlQueryObjectUpdate_multipartHeaderdeleteEngineList.addWhereCondition("id NOT IN ("+marks_dumpMessaggio_multipartHeader.toString()+")");
  445.         }

  447.         jdbcUtilities.execute(sqlQueryObjectUpdate_multipartHeaderdeleteEngineList.createSQLDelete(), jdbcProperties.isShowSql(), jdbcObjects_dumpMessaggio_multipartHeaderdeleteEngine.toArray(new JDBCObject[]{}));

  449.         // for dumpMessaggio_headerTrasporto

  451.         java.util.List<Long> ids_dumpMessaggio_headerTrasporto_da_non_eliminare = new java.util.ArrayList<Long>();
  452.         for (Object dumpMessaggio_headerTrasporto_object : dumpMessaggio.getHeaderTrasportoList()) {
  453.             DumpHeaderTrasporto dumpMessaggio_headerTrasporto = (DumpHeaderTrasporto) dumpMessaggio_headerTrasporto_object;
  454.             
  455.             // Bug fix OPPT-466 per gestione empty string as null on oracle
  456.             // Rilasciare il vincolo di not null 'fisico' sul database.
  457.             // Imporlo logicamente, in modo che non siano permessi insert o update con valori null.
  458.             // Dopodichè, se nella get viene recuperato un valore null, deve essere trasformato in stringa vuota.
  459.             if(dumpMessaggio_headerTrasporto.getValore()==null){
  460.                 throw new ServiceException("Header ["+dumpMessaggio_headerTrasporto.getNome()+"] with value null");
  461.             }
  462.             
  463.             if(dumpMessaggio_headerTrasporto.getId() == null || dumpMessaggio_headerTrasporto.getId().longValue() <= 0) {

  465.                 long id = dumpMessaggio.getId();            

  467.                 // Object dumpMessaggio_headerTrasporto
  468.                 ISQLQueryObject sqlQueryObjectInsert_dumpMessaggio_headerTrasporto = sqlQueryObjectInsert.newSQLQueryObject();
  469.                 sqlQueryObjectInsert_dumpMessaggio_headerTrasporto.addInsertTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().HEADER_TRASPORTO));
  470.                 sqlQueryObjectInsert_dumpMessaggio_headerTrasporto.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().HEADER_TRASPORTO.NOME,false),"?");
  471.                 sqlQueryObjectInsert_dumpMessaggio_headerTrasporto.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().HEADER_TRASPORTO.VALORE,false),"?");
  472.                 sqlQueryObjectInsert_dumpMessaggio_headerTrasporto.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().HEADER_TRASPORTO.DUMP_TIMESTAMP,false),"?");
  473.                 sqlQueryObjectInsert_dumpMessaggio_headerTrasporto.addInsertField("id_messaggio","?");

  475.                 // Insert dumpMessaggio_headerTrasporto
  476.                 org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator_dumpMessaggio_headerTrasporto = this.getDumpMessaggioFetch().getKeyGeneratorObject(DumpMessaggio.model().HEADER_TRASPORTO);
  477.                 long id_dumpMessaggio_headerTrasporto = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert_dumpMessaggio_headerTrasporto, keyGenerator_dumpMessaggio_headerTrasporto, jdbcProperties.isShowSql(),
  478.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_headerTrasporto.getNome(),DumpMessaggio.model().HEADER_TRASPORTO.NOME.getFieldType()),
  479.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_headerTrasporto.getValore(),DumpMessaggio.model().HEADER_TRASPORTO.VALORE.getFieldType()),
  480.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_headerTrasporto.getDumpTimestamp(),DumpMessaggio.model().HEADER_TRASPORTO.DUMP_TIMESTAMP.getFieldType()),
  481.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(Long.valueOf(id),Long.class)
  482.                 );
  483.                 dumpMessaggio_headerTrasporto.setId(id_dumpMessaggio_headerTrasporto);

  485.                 ids_dumpMessaggio_headerTrasporto_da_non_eliminare.add(dumpMessaggio_headerTrasporto.getId());
  486.             } else {


  489.                 // Object dumpMessaggio_headerTrasporto
  490.                 ISQLQueryObject sqlQueryObjectUpdate_dumpMessaggio_headerTrasporto = sqlQueryObjectUpdate.newSQLQueryObject();
  491.                 sqlQueryObjectUpdate_dumpMessaggio_headerTrasporto.setANDLogicOperator(true);
  492.                 sqlQueryObjectUpdate_dumpMessaggio_headerTrasporto.addUpdateTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().HEADER_TRASPORTO));
  493.                 boolean isUpdate_dumpMessaggio_headerTrasporto = true;
  494.                 java.util.List<JDBCObject> lstObjects_dumpMessaggio_headerTrasporto = new java.util.ArrayList<>();
  495.                 sqlQueryObjectUpdate_dumpMessaggio_headerTrasporto.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().HEADER_TRASPORTO.NOME,false), "?");
  496.                 lstObjects_dumpMessaggio_headerTrasporto.add(new JDBCObject(dumpMessaggio_headerTrasporto.getNome(), DumpMessaggio.model().HEADER_TRASPORTO.NOME.getFieldType()));
  497.                 sqlQueryObjectUpdate_dumpMessaggio_headerTrasporto.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().HEADER_TRASPORTO.VALORE,false), "?");
  498.                 lstObjects_dumpMessaggio_headerTrasporto.add(new JDBCObject(dumpMessaggio_headerTrasporto.getValore(), DumpMessaggio.model().HEADER_TRASPORTO.VALORE.getFieldType()));
  499.                 sqlQueryObjectUpdate_dumpMessaggio_headerTrasporto.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().HEADER_TRASPORTO.DUMP_TIMESTAMP,false), "?");
  500.                 lstObjects_dumpMessaggio_headerTrasporto.add(new JDBCObject(dumpMessaggio_headerTrasporto.getDumpTimestamp(), DumpMessaggio.model().HEADER_TRASPORTO.DUMP_TIMESTAMP.getFieldType()));
  501.                 sqlQueryObjectUpdate_dumpMessaggio_headerTrasporto.addWhereCondition("id=?");
  502.                 ids_dumpMessaggio_headerTrasporto_da_non_eliminare.add(dumpMessaggio_headerTrasporto.getId());
  503.                 lstObjects_dumpMessaggio_headerTrasporto.add(new JDBCObject(dumpMessaggio_headerTrasporto.getId(),Long.class));

  505.                 if(isUpdate_dumpMessaggio_headerTrasporto) {
  506.                     // Update dumpMessaggio_headerTrasporto
  507.                     jdbcUtilities.executeUpdate(sqlQueryObjectUpdate_dumpMessaggio_headerTrasporto.createSQLUpdate(), jdbcProperties.isShowSql(), 
  508.                         lstObjects_dumpMessaggio_headerTrasporto.toArray(new JDBCObject[]{}));
  509.                 }
  510.             }
  511.         } // fine for dumpMessaggio_headerTrasporto

  513.         // elimino tutte le occorrenze di dumpMessaggio_headerTrasporto non presenti nell'update

  515.         ISQLQueryObject sqlQueryObjectUpdate_headerTrasportodeleteEngineList = sqlQueryObjectUpdate.newSQLQueryObject();
  516.         sqlQueryObjectUpdate_headerTrasportodeleteEngineList.setANDLogicOperator(true);
  517.         sqlQueryObjectUpdate_headerTrasportodeleteEngineList.addDeleteTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().HEADER_TRASPORTO));
  518.         java.util.List<JDBCObject> jdbcObjects_dumpMessaggio_headerTrasportodeleteEngine = new java.util.ArrayList<>();

  520.         sqlQueryObjectUpdate_headerTrasportodeleteEngineList.addWhereCondition("id_messaggio=?");
  521.         jdbcObjects_dumpMessaggio_headerTrasportodeleteEngine.add(new JDBCObject(dumpMessaggio.getId(), Long.class));

  523.         StringBuilder marks_dumpMessaggio_headerTrasporto = new StringBuilder();
  524.         if(ids_dumpMessaggio_headerTrasporto_da_non_eliminare.size() > 0) {
  525.             for(Long ids : ids_dumpMessaggio_headerTrasporto_da_non_eliminare) {
  526.                 if(marks_dumpMessaggio_headerTrasporto.length() > 0) {
  527.                     marks_dumpMessaggio_headerTrasporto.append(",");
  528.                 }
  529.                 marks_dumpMessaggio_headerTrasporto.append("?");
  530.                 jdbcObjects_dumpMessaggio_headerTrasportodeleteEngine.add(new JDBCObject(ids, Long.class));

  532.             }
  533.             sqlQueryObjectUpdate_headerTrasportodeleteEngineList.addWhereCondition("id NOT IN ("+marks_dumpMessaggio_headerTrasporto.toString()+")");
  534.         }

  536.         jdbcUtilities.execute(sqlQueryObjectUpdate_headerTrasportodeleteEngineList.createSQLDelete(), jdbcProperties.isShowSql(), jdbcObjects_dumpMessaggio_headerTrasportodeleteEngine.toArray(new JDBCObject[]{}));

  538.         // for dumpMessaggio_allegato

  540.         java.util.List<Long> ids_dumpMessaggio_allegato_da_non_eliminare = new java.util.ArrayList<Long>();
  541.         for (Object dumpMessaggio_allegato_object : dumpMessaggio.getAllegatoList()) {
  542.             DumpAllegato dumpMessaggio_allegato = (DumpAllegato) dumpMessaggio_allegato_object;
  543.             if(dumpMessaggio_allegato.getId() == null || dumpMessaggio_allegato.getId().longValue() <= 0) {

  545.                 long id = dumpMessaggio.getId();            

  547.                 // Object dumpMessaggio_allegato
  548.                 ISQLQueryObject sqlQueryObjectInsert_dumpMessaggio_allegato = sqlQueryObjectInsert.newSQLQueryObject();
  549.                 sqlQueryObjectInsert_dumpMessaggio_allegato.addInsertTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO));
  550.                 sqlQueryObjectInsert_dumpMessaggio_allegato.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.CONTENT_TYPE,false),"?");
  551.                 sqlQueryObjectInsert_dumpMessaggio_allegato.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.CONTENT_ID,false),"?");
  552.                 sqlQueryObjectInsert_dumpMessaggio_allegato.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.CONTENT_LOCATION,false),"?");
  553.                 sqlQueryObjectInsert_dumpMessaggio_allegato.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.ALLEGATO,false),"?");
  554.                 sqlQueryObjectInsert_dumpMessaggio_allegato.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.DUMP_TIMESTAMP,false),"?");
  555.                 sqlQueryObjectInsert_dumpMessaggio_allegato.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER_EXT,false),"?");
  556.                 sqlQueryObjectInsert_dumpMessaggio_allegato.addInsertField("id_messaggio","?");

  558.                 // Insert dumpMessaggio_allegato
  559.                 org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator_dumpMessaggio_allegato = this.getDumpMessaggioFetch().getKeyGeneratorObject(DumpMessaggio.model().ALLEGATO);
  560.                 long id_dumpMessaggio_allegato = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert_dumpMessaggio_allegato, keyGenerator_dumpMessaggio_allegato, jdbcProperties.isShowSql(),
  561.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_allegato.getContentType(),DumpMessaggio.model().ALLEGATO.CONTENT_TYPE.getFieldType()),
  562.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_allegato.getContentId(),DumpMessaggio.model().ALLEGATO.CONTENT_ID.getFieldType()),
  563.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_allegato.getContentLocation(),DumpMessaggio.model().ALLEGATO.CONTENT_LOCATION.getFieldType()),
  564.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_allegato.getAllegato(),DumpMessaggio.model().ALLEGATO.ALLEGATO.getFieldType()),
  565.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_allegato.getDumpTimestamp(),DumpMessaggio.model().ALLEGATO.DUMP_TIMESTAMP.getFieldType()),
  566.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_allegato.getHeaderExt(),DumpMessaggio.model().ALLEGATO.HEADER_EXT.getFieldType()),
  567.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(Long.valueOf(id),Long.class)
  568.                 );
  569.                 dumpMessaggio_allegato.setId(id_dumpMessaggio_allegato);

  571.                 // for dumpMessaggio_allegato
  572.                 for (int i_dumpMessaggio_allegato = 0; i_dumpMessaggio_allegato < dumpMessaggio_allegato.getHeaderList().size(); i_dumpMessaggio_allegato++) {

  574.                     // Bug fix OPPT-466 per gestione empty string as null on oracle
  575.                     // Rilasciare il vincolo di not null 'fisico' sul database.
  576.                     // Imporlo logicamente, in modo che non siano permessi insert o update con valori null.
  577.                     // Dopodichè, se nella get viene recuperato un valore null, deve essere trasformato in stringa vuota.
  578.                     if(dumpMessaggio_allegato.getHeaderList().get(i_dumpMessaggio_allegato).getValore()==null){
  579.                         throw new ServiceException("Header ["+dumpMessaggio_allegato.getHeaderList().get(i_dumpMessaggio_allegato).getNome()+"] dell'allegato ["+dumpMessaggio_allegato.getContentId()+"] with value null");
  580.                     }

  582.                     // Object dumpMessaggio_allegato.getHeaderList().get(i_dumpMessaggio_allegato)
  583.                     ISQLQueryObject sqlQueryObjectInsert_dumpMessaggio_allegato_header = sqlQueryObjectInsert.newSQLQueryObject();
  584.                     sqlQueryObjectInsert_dumpMessaggio_allegato_header.addInsertTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO.HEADER));
  585.                     sqlQueryObjectInsert_dumpMessaggio_allegato_header.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER.NOME,false),"?");
  586.                     sqlQueryObjectInsert_dumpMessaggio_allegato_header.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER.VALORE,false),"?");
  587.                     sqlQueryObjectInsert_dumpMessaggio_allegato_header.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER.DUMP_TIMESTAMP,false),"?");
  588.                     sqlQueryObjectInsert_dumpMessaggio_allegato_header.addInsertField("id_allegato","?");

  590.                     // Insert dumpMessaggio_allegato.getHeaderList().get(i_dumpMessaggio_allegato)
  591.                     org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator_dumpMessaggio_allegato_header = this.getDumpMessaggioFetch().getKeyGeneratorObject(DumpMessaggio.model().ALLEGATO.HEADER);
  592.                     long id_dumpMessaggio_allegato_header = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert_dumpMessaggio_allegato_header, keyGenerator_dumpMessaggio_allegato_header, jdbcProperties.isShowSql(),
  593.                         new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_allegato.getHeaderList().get(i_dumpMessaggio_allegato).getNome(),DumpMessaggio.model().ALLEGATO.HEADER.NOME.getFieldType()),
  594.                         new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_allegato.getHeaderList().get(i_dumpMessaggio_allegato).getValore(),DumpMessaggio.model().ALLEGATO.HEADER.VALORE.getFieldType()),
  595.                         new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_allegato.getHeaderList().get(i_dumpMessaggio_allegato).getDumpTimestamp(),DumpMessaggio.model().ALLEGATO.HEADER.DUMP_TIMESTAMP.getFieldType()),
  596.                         new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(Long.valueOf(id_dumpMessaggio_allegato),Long.class)
  597.                     );
  598.                     dumpMessaggio_allegato.getHeaderList().get(i_dumpMessaggio_allegato).setId(id_dumpMessaggio_allegato_header);
  599.                 } // fine for _dumpMessaggio_allegato

  601.                 ids_dumpMessaggio_allegato_da_non_eliminare.add(dumpMessaggio_allegato.getId());
  602.             } else {


  605.                 // Object dumpMessaggio_allegato
  606.                 ISQLQueryObject sqlQueryObjectUpdate_dumpMessaggio_allegato = sqlQueryObjectUpdate.newSQLQueryObject();
  607.                 sqlQueryObjectUpdate_dumpMessaggio_allegato.setANDLogicOperator(true);
  608.                 sqlQueryObjectUpdate_dumpMessaggio_allegato.addUpdateTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO));
  609.                 boolean isUpdate_dumpMessaggio_allegato = true;
  610.                 java.util.List<JDBCObject> lstObjects_dumpMessaggio_allegato = new java.util.ArrayList<>();
  611.                 sqlQueryObjectUpdate_dumpMessaggio_allegato.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.CONTENT_TYPE,false), "?");
  612.                 lstObjects_dumpMessaggio_allegato.add(new JDBCObject(dumpMessaggio_allegato.getContentType(), DumpMessaggio.model().ALLEGATO.CONTENT_TYPE.getFieldType()));
  613.                 sqlQueryObjectUpdate_dumpMessaggio_allegato.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.CONTENT_ID,false), "?");
  614.                 lstObjects_dumpMessaggio_allegato.add(new JDBCObject(dumpMessaggio_allegato.getContentId(), DumpMessaggio.model().ALLEGATO.CONTENT_ID.getFieldType()));
  615.                 sqlQueryObjectUpdate_dumpMessaggio_allegato.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.CONTENT_LOCATION,false), "?");
  616.                 lstObjects_dumpMessaggio_allegato.add(new JDBCObject(dumpMessaggio_allegato.getContentLocation(), DumpMessaggio.model().ALLEGATO.CONTENT_LOCATION.getFieldType()));
  617.                 sqlQueryObjectUpdate_dumpMessaggio_allegato.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.ALLEGATO,false), "?");
  618.                 lstObjects_dumpMessaggio_allegato.add(new JDBCObject(dumpMessaggio_allegato.getAllegato(), DumpMessaggio.model().ALLEGATO.ALLEGATO.getFieldType()));
  619.                 sqlQueryObjectUpdate_dumpMessaggio_allegato.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.DUMP_TIMESTAMP,false), "?");
  620.                 lstObjects_dumpMessaggio_allegato.add(new JDBCObject(dumpMessaggio_allegato.getDumpTimestamp(), DumpMessaggio.model().ALLEGATO.DUMP_TIMESTAMP.getFieldType()));
  621.                 sqlQueryObjectUpdate_dumpMessaggio_allegato.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER_EXT,false), "?");
  622.                 lstObjects_dumpMessaggio_allegato.add(new JDBCObject(dumpMessaggio_allegato.getHeaderExt(), DumpMessaggio.model().ALLEGATO.HEADER_EXT.getFieldType()));
  623.                 sqlQueryObjectUpdate_dumpMessaggio_allegato.addWhereCondition("id=?");
  624.                 ids_dumpMessaggio_allegato_da_non_eliminare.add(dumpMessaggio_allegato.getId());
  625.                 lstObjects_dumpMessaggio_allegato.add(new JDBCObject(dumpMessaggio_allegato.getId(),Long.class));

  627.                 if(isUpdate_dumpMessaggio_allegato) {
  628.                     // Update dumpMessaggio_allegato
  629.                     jdbcUtilities.executeUpdate(sqlQueryObjectUpdate_dumpMessaggio_allegato.createSQLUpdate(), jdbcProperties.isShowSql(), 
  630.                         lstObjects_dumpMessaggio_allegato.toArray(new JDBCObject[]{}));
  631.                 }
  632.                 // for dumpMessaggio_allegato_header

  634.                 java.util.List<Long> ids_dumpMessaggio_allegato_header_da_non_eliminare = new java.util.ArrayList<Long>();
  635.                 for (Object dumpMessaggio_allegato_header_object : dumpMessaggio_allegato.getHeaderList()) {
  636.                     DumpHeaderAllegato dumpMessaggio_allegato_header = (DumpHeaderAllegato) dumpMessaggio_allegato_header_object;
  637.                     if(dumpMessaggio_allegato_header.getId() == null || dumpMessaggio_allegato_header.getId().longValue() <= 0) {

  639.                         long id_dumpMessaggio_allegato = dumpMessaggio_allegato.getId();                    

  641.                         // Object dumpMessaggio_allegato_header
  642.                         ISQLQueryObject sqlQueryObjectInsert_dumpMessaggio_allegato_header = sqlQueryObjectInsert.newSQLQueryObject();
  643.                         sqlQueryObjectInsert_dumpMessaggio_allegato_header.addInsertTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO.HEADER));
  644.                         sqlQueryObjectInsert_dumpMessaggio_allegato_header.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER.NOME,false),"?");
  645.                         sqlQueryObjectInsert_dumpMessaggio_allegato_header.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER.VALORE,false),"?");
  646.                         sqlQueryObjectInsert_dumpMessaggio_allegato_header.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER.DUMP_TIMESTAMP,false),"?");
  647.                         sqlQueryObjectInsert_dumpMessaggio_allegato_header.addInsertField("id_allegato","?");

  649.                         // Insert dumpMessaggio_allegato_header
  650.                         org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator_dumpMessaggio_allegato_header = this.getDumpMessaggioFetch().getKeyGeneratorObject(DumpMessaggio.model().ALLEGATO.HEADER);
  651.                         long id_dumpMessaggio_allegato_header = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert_dumpMessaggio_allegato_header, keyGenerator_dumpMessaggio_allegato_header, jdbcProperties.isShowSql(),
  652.                             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_allegato_header.getNome(),DumpMessaggio.model().ALLEGATO.HEADER.NOME.getFieldType()),
  653.                             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_allegato_header.getValore(),DumpMessaggio.model().ALLEGATO.HEADER.VALORE.getFieldType()),
  654.                             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_allegato_header.getDumpTimestamp(),DumpMessaggio.model().ALLEGATO.HEADER.DUMP_TIMESTAMP.getFieldType()),
  655.                             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(Long.valueOf(id_dumpMessaggio_allegato),Long.class)
  656.                         );
  657.                         dumpMessaggio_allegato_header.setId(id_dumpMessaggio_allegato_header);

  659.                         ids_dumpMessaggio_allegato_header_da_non_eliminare.add(dumpMessaggio_allegato_header.getId());
  660.                     } else {


  663.                         // Object dumpMessaggio_allegato_header
  664.                         ISQLQueryObject sqlQueryObjectUpdate_dumpMessaggio_allegato_header = sqlQueryObjectUpdate.newSQLQueryObject();
  665.                         sqlQueryObjectUpdate_dumpMessaggio_allegato_header.setANDLogicOperator(true);
  666.                         sqlQueryObjectUpdate_dumpMessaggio_allegato_header.addUpdateTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO.HEADER));
  667.                         boolean isUpdate_dumpMessaggio_allegato_header = true;
  668.                         java.util.List<JDBCObject> lstObjects_dumpMessaggio_allegato_header = new java.util.ArrayList<>();
  669.                         sqlQueryObjectUpdate_dumpMessaggio_allegato_header.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER.NOME,false), "?");
  670.                         lstObjects_dumpMessaggio_allegato_header.add(new JDBCObject(dumpMessaggio_allegato_header.getNome(), DumpMessaggio.model().ALLEGATO.HEADER.NOME.getFieldType()));
  671.                         sqlQueryObjectUpdate_dumpMessaggio_allegato_header.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER.VALORE,false), "?");
  672.                         lstObjects_dumpMessaggio_allegato_header.add(new JDBCObject(dumpMessaggio_allegato_header.getValore(), DumpMessaggio.model().ALLEGATO.HEADER.VALORE.getFieldType()));
  673.                         sqlQueryObjectUpdate_dumpMessaggio_allegato_header.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER.DUMP_TIMESTAMP,false), "?");
  674.                         lstObjects_dumpMessaggio_allegato_header.add(new JDBCObject(dumpMessaggio_allegato_header.getDumpTimestamp(), DumpMessaggio.model().ALLEGATO.HEADER.DUMP_TIMESTAMP.getFieldType()));
  675.                         sqlQueryObjectUpdate_dumpMessaggio_allegato_header.addWhereCondition("id=?");
  676.                         ids_dumpMessaggio_allegato_header_da_non_eliminare.add(dumpMessaggio_allegato_header.getId());
  677.                         lstObjects_dumpMessaggio_allegato_header.add(new JDBCObject(dumpMessaggio_allegato_header.getId(),Long.class));

  679.                         if(isUpdate_dumpMessaggio_allegato_header) {
  680.                             // Update dumpMessaggio_allegato_header
  681.                             jdbcUtilities.executeUpdate(sqlQueryObjectUpdate_dumpMessaggio_allegato_header.createSQLUpdate(), jdbcProperties.isShowSql(), 
  682.                                 lstObjects_dumpMessaggio_allegato_header.toArray(new JDBCObject[]{}));
  683.                         }
  684.                     }
  685.                 } // fine for dumpMessaggio_allegato_header

  687.                 // elimino tutte le occorrenze di dumpMessaggio_allegato_header non presenti nell'update

  689.                 ISQLQueryObject sqlQueryObjectUpdate_dumpMessaggio_allegato_headerdeleteEngineList = sqlQueryObjectUpdate.newSQLQueryObject();
  690.                 sqlQueryObjectUpdate_dumpMessaggio_allegato_headerdeleteEngineList.setANDLogicOperator(true);
  691.                 sqlQueryObjectUpdate_dumpMessaggio_allegato_headerdeleteEngineList.addDeleteTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO.HEADER));
  692.                 java.util.List<JDBCObject> jdbcObjects_dumpMessaggio_allegato_headerdeleteEngine = new java.util.ArrayList<>();

  694.                 sqlQueryObjectUpdate_dumpMessaggio_allegato_headerdeleteEngineList.addWhereCondition("id_allegato=?");
  695.                 jdbcObjects_dumpMessaggio_allegato_headerdeleteEngine.add(new JDBCObject(dumpMessaggio_allegato.getId(), Long.class));

  697.                 StringBuilder marks_dumpMessaggio_allegato_header = new StringBuilder();
  698.                 if(ids_dumpMessaggio_allegato_header_da_non_eliminare.size() > 0) {
  699.                     for(Long ids : ids_dumpMessaggio_allegato_header_da_non_eliminare) {
  700.                         if(marks_dumpMessaggio_allegato_header.length() > 0) {
  701.                             marks_dumpMessaggio_allegato_header.append(",");
  702.                         }
  703.                         marks_dumpMessaggio_allegato_header.append("?");
  704.                         jdbcObjects_dumpMessaggio_allegato_headerdeleteEngine.add(new JDBCObject(ids, Long.class));

  706.                     }
  707.                     sqlQueryObjectUpdate_dumpMessaggio_allegato_headerdeleteEngineList.addWhereCondition("id NOT IN ("+marks_dumpMessaggio_allegato_header.toString()+")");
  708.                 }

  710.                 jdbcUtilities.execute(sqlQueryObjectUpdate_dumpMessaggio_allegato_headerdeleteEngineList.createSQLDelete(), jdbcProperties.isShowSql(), jdbcObjects_dumpMessaggio_allegato_headerdeleteEngine.toArray(new JDBCObject[]{}));

  712.             }
  713.         } // fine for dumpMessaggio_allegato

  715.         // elimino tutte le occorrenze di dumpMessaggio_allegato non presenti nell'update

  717.         ISQLQueryObject sqlQueryObjectUpdate_allegatodeleteEngineList = sqlQueryObjectUpdate.newSQLQueryObject();
  718.         sqlQueryObjectUpdate_allegatodeleteEngineList.setANDLogicOperator(true);
  719.         sqlQueryObjectUpdate_allegatodeleteEngineList.addDeleteTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO));
  720.         java.util.List<JDBCObject> jdbcObjects_dumpMessaggio_allegatodeleteEngine = new java.util.ArrayList<>();

  722.         sqlQueryObjectUpdate_allegatodeleteEngineList.addWhereCondition("id_messaggio=?");
  723.         jdbcObjects_dumpMessaggio_allegatodeleteEngine.add(new JDBCObject(dumpMessaggio.getId(), Long.class));

  725.         StringBuilder marks_dumpMessaggio_allegato = new StringBuilder();
  726.         if(ids_dumpMessaggio_allegato_da_non_eliminare.size() > 0) {
  727.             for(Long ids : ids_dumpMessaggio_allegato_da_non_eliminare) {
  728.                 if(marks_dumpMessaggio_allegato.length() > 0) {
  729.                     marks_dumpMessaggio_allegato.append(",");
  730.                 }
  731.                 marks_dumpMessaggio_allegato.append("?");
  732.                 jdbcObjects_dumpMessaggio_allegatodeleteEngine.add(new JDBCObject(ids, Long.class));

  734.             }
  735.             sqlQueryObjectUpdate_allegatodeleteEngineList.addWhereCondition("id NOT IN ("+marks_dumpMessaggio_allegato.toString()+")");
  736.         }

  738.         jdbcUtilities.execute(sqlQueryObjectUpdate_allegatodeleteEngineList.createSQLDelete(), jdbcProperties.isShowSql(), jdbcObjects_dumpMessaggio_allegatodeleteEngine.toArray(new JDBCObject[]{}));

  740.         // for dumpMessaggio_contenuto

  742.         java.util.List<Long> ids_dumpMessaggio_contenuto_da_non_eliminare = new java.util.ArrayList<Long>();
  743.         for (Object dumpMessaggio_contenuto_object : dumpMessaggio.getContenutoList()) {
  744.             DumpContenuto dumpMessaggio_contenuto = (DumpContenuto) dumpMessaggio_contenuto_object;
  745.             if(dumpMessaggio_contenuto.getId() == null || dumpMessaggio_contenuto.getId().longValue() <= 0) {

  747.                 long id = dumpMessaggio.getId();            

  749.                 // Object dumpMessaggio_contenuto
  750.                 ISQLQueryObject sqlQueryObjectInsert_dumpMessaggio_contenuto = sqlQueryObjectInsert.newSQLQueryObject();
  751.                 sqlQueryObjectInsert_dumpMessaggio_contenuto.addInsertTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().CONTENUTO));
  752.                 sqlQueryObjectInsert_dumpMessaggio_contenuto.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENUTO.NOME,false),"?");
  753.                 sqlQueryObjectInsert_dumpMessaggio_contenuto.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENUTO.VALORE,false),"?");
  754.                 sqlQueryObjectInsert_dumpMessaggio_contenuto.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENUTO.VALORE_AS_BYTES,false),"?");
  755.                 sqlQueryObjectInsert_dumpMessaggio_contenuto.addInsertField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENUTO.DUMP_TIMESTAMP,false),"?");
  756.                 sqlQueryObjectInsert_dumpMessaggio_contenuto.addInsertField("id_messaggio","?");

  758.                 // Insert dumpMessaggio_contenuto
  759.                 org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator_dumpMessaggio_contenuto = this.getDumpMessaggioFetch().getKeyGeneratorObject(DumpMessaggio.model().CONTENUTO);
  760.                 long id_dumpMessaggio_contenuto = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert_dumpMessaggio_contenuto, keyGenerator_dumpMessaggio_contenuto, jdbcProperties.isShowSql(),
  761.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_contenuto.getNome(),DumpMessaggio.model().CONTENUTO.NOME.getFieldType()),
  762.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_contenuto.getValore(),DumpMessaggio.model().CONTENUTO.VALORE.getFieldType()),
  763.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_contenuto.getValoreAsBytes(),DumpMessaggio.model().CONTENUTO.VALORE_AS_BYTES.getFieldType()),
  764.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_contenuto.getDumpTimestamp(),DumpMessaggio.model().CONTENUTO.DUMP_TIMESTAMP.getFieldType()),
  765.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(Long.valueOf(id),Long.class)
  766.                 );
  767.                 dumpMessaggio_contenuto.setId(id_dumpMessaggio_contenuto);

  769.                 ids_dumpMessaggio_contenuto_da_non_eliminare.add(dumpMessaggio_contenuto.getId());
  770.             } else {


  773.                 // Object dumpMessaggio_contenuto
  774.                 ISQLQueryObject sqlQueryObjectUpdate_dumpMessaggio_contenuto = sqlQueryObjectUpdate.newSQLQueryObject();
  775.                 sqlQueryObjectUpdate_dumpMessaggio_contenuto.setANDLogicOperator(true);
  776.                 sqlQueryObjectUpdate_dumpMessaggio_contenuto.addUpdateTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().CONTENUTO));
  777.                 boolean isUpdate_dumpMessaggio_contenuto = true;
  778.                 java.util.List<JDBCObject> lstObjects_dumpMessaggio_contenuto = new java.util.ArrayList<>();
  779.                 sqlQueryObjectUpdate_dumpMessaggio_contenuto.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENUTO.NOME,false), "?");
  780.                 lstObjects_dumpMessaggio_contenuto.add(new JDBCObject(dumpMessaggio_contenuto.getNome(), DumpMessaggio.model().CONTENUTO.NOME.getFieldType()));
  781.                 sqlQueryObjectUpdate_dumpMessaggio_contenuto.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENUTO.VALORE,false), "?");
  782.                 lstObjects_dumpMessaggio_contenuto.add(new JDBCObject(dumpMessaggio_contenuto.getValore(), DumpMessaggio.model().CONTENUTO.VALORE.getFieldType()));
  783.                 sqlQueryObjectUpdate_dumpMessaggio_contenuto.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENUTO.VALORE_AS_BYTES,false), "?");
  784.                 lstObjects_dumpMessaggio_contenuto.add(new JDBCObject(dumpMessaggio_contenuto.getValoreAsBytes(), DumpMessaggio.model().CONTENUTO.VALORE_AS_BYTES.getFieldType()));
  785.                 sqlQueryObjectUpdate_dumpMessaggio_contenuto.addUpdateField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENUTO.DUMP_TIMESTAMP,false), "?");
  786.                 lstObjects_dumpMessaggio_contenuto.add(new JDBCObject(dumpMessaggio_contenuto.getDumpTimestamp(), DumpMessaggio.model().CONTENUTO.DUMP_TIMESTAMP.getFieldType()));
  787.                 sqlQueryObjectUpdate_dumpMessaggio_contenuto.addWhereCondition("id=?");
  788.                 ids_dumpMessaggio_contenuto_da_non_eliminare.add(dumpMessaggio_contenuto.getId());
  789.                 lstObjects_dumpMessaggio_contenuto.add(new JDBCObject(dumpMessaggio_contenuto.getId(),Long.class));

  791.                 if(isUpdate_dumpMessaggio_contenuto) {
  792.                     // Update dumpMessaggio_contenuto
  793.                     jdbcUtilities.executeUpdate(sqlQueryObjectUpdate_dumpMessaggio_contenuto.createSQLUpdate(), jdbcProperties.isShowSql(), 
  794.                         lstObjects_dumpMessaggio_contenuto.toArray(new JDBCObject[]{}));
  795.                 }
  796.             }
  797.         } // fine for dumpMessaggio_contenuto

  799.         // elimino tutte le occorrenze di dumpMessaggio_contenuto non presenti nell'update

  801.         ISQLQueryObject sqlQueryObjectUpdate_contenutodeleteEngineList = sqlQueryObjectUpdate.newSQLQueryObject();
  802.         sqlQueryObjectUpdate_contenutodeleteEngineList.setANDLogicOperator(true);
  803.         sqlQueryObjectUpdate_contenutodeleteEngineList.addDeleteTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().CONTENUTO));
  804.         java.util.List<JDBCObject> jdbcObjects_dumpMessaggio_contenutodeleteEngine = new java.util.ArrayList<>();

  806.         sqlQueryObjectUpdate_contenutodeleteEngineList.addWhereCondition("id_messaggio=?");
  807.         jdbcObjects_dumpMessaggio_contenutodeleteEngine.add(new JDBCObject(dumpMessaggio.getId(), Long.class));

  809.         StringBuilder marks_dumpMessaggio_contenuto = new StringBuilder();
  810.         if(ids_dumpMessaggio_contenuto_da_non_eliminare.size() > 0) {
  811.             for(Long ids : ids_dumpMessaggio_contenuto_da_non_eliminare) {
  812.                 if(marks_dumpMessaggio_contenuto.length() > 0) {
  813.                     marks_dumpMessaggio_contenuto.append(",");
  814.                 }
  815.                 marks_dumpMessaggio_contenuto.append("?");
  816.                 jdbcObjects_dumpMessaggio_contenutodeleteEngine.add(new JDBCObject(ids, Long.class));

  818.             }
  819.             sqlQueryObjectUpdate_contenutodeleteEngineList.addWhereCondition("id NOT IN ("+marks_dumpMessaggio_contenuto.toString()+")");
  820.         }

  822.         jdbcUtilities.execute(sqlQueryObjectUpdate_contenutodeleteEngineList.createSQLDelete(), jdbcProperties.isShowSql(), jdbcObjects_dumpMessaggio_contenutodeleteEngine.toArray(new JDBCObject[]{}));



  826.     }
  827.     
  828.     @Override
  829.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdDumpMessaggio id, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  830.         
  831.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  832.                 this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model()), 
  833.                 this.getMapTableToPKColumnEngine(), 
  834.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  835.                 this.getDumpMessaggioFieldConverter(), this, null, updateFields);
  836.     }
  837.     
  838.     @Override
  839.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdDumpMessaggio id, IExpression condition, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  840.         
  841.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  842.                 this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model()), 
  843.                 this.getMapTableToPKColumnEngine(), 
  844.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  845.                 this.getDumpMessaggioFieldConverter(), this, condition, updateFields);
  846.     }
  847.     
  848.     @Override
  849.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdDumpMessaggio id, UpdateModel ... updateModels) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  850.         
  851.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  852.                 this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model()), 
  853.                 this.getMapTableToPKColumnEngine(), 
  854.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  855.                 this.getDumpMessaggioFieldConverter(), this, updateModels);
  856.     }   
  857.     
  858.     @Override
  859.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  860.         java.util.List<Object> ids = new java.util.ArrayList<>();
  861.         ids.add(tableId);
  862.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  863.                 this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model()), 
  864.                 this.getMapTableToPKColumnEngine(), 
  865.                 ids,
  866.                 this.getDumpMessaggioFieldConverter(), this, null, updateFields);
  867.     }
  868.     
  869.     @Override
  870.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, IExpression condition, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  871.         java.util.List<Object> ids = new java.util.ArrayList<>();
  872.         ids.add(tableId);
  873.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  874.                 this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model()), 
  875.                 this.getMapTableToPKColumnEngine(), 
  876.                 ids,
  877.                 this.getDumpMessaggioFieldConverter(), this, condition, updateFields);
  878.     }
  879.     
  880.     @Override
  881.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, UpdateModel ... updateModels) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  882.         java.util.List<Object> ids = new java.util.ArrayList<>();
  883.         ids.add(tableId);
  884.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  885.                 this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model()), 
  886.                 this.getMapTableToPKColumnEngine(), 
  887.                 ids,
  888.                 this.getDumpMessaggioFieldConverter(), this, updateModels);
  889.     }
  890.     
  891.     @Override
  892.     public void updateOrCreate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdDumpMessaggio oldId, DumpMessaggio dumpMessaggio, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {
  893.     
  894.         if(this.exists(jdbcProperties, log, connection, sqlQueryObject, oldId)) {
  895.             this.update(jdbcProperties, log, connection, sqlQueryObject, oldId, dumpMessaggio,idMappingResolutionBehaviour);
  896.         } else {
  897.             this.create(jdbcProperties, log, connection, sqlQueryObject, dumpMessaggio,idMappingResolutionBehaviour);
  898.         }
  899.         
  900.     }
  901.     
  902.     @Override
  903.     public void updateOrCreate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, DumpMessaggio dumpMessaggio, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {
  904.         if(this.exists(jdbcProperties, log, connection, sqlQueryObject, tableId)) {
  905.             this.update(jdbcProperties, log, connection, sqlQueryObject, tableId, dumpMessaggio,idMappingResolutionBehaviour);
  906.         } else {
  907.             this.create(jdbcProperties, log, connection, sqlQueryObject, dumpMessaggio,idMappingResolutionBehaviour);
  908.         }
  909.     }
  910.     
  911.     @Override
  912.     public void delete(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, DumpMessaggio dumpMessaggio) throws NotImplementedException,ServiceException,Exception {
  913.         
  914.         
  915.         Long longId = null;
  916.         if( (dumpMessaggio.getId()!=null) && (dumpMessaggio.getId()>0) ){
  917.             longId = dumpMessaggio.getId();
  918.         }
  919.         else{
  920.             IdDumpMessaggio idDumpMessaggio = this.convertToId(jdbcProperties,log,connection,sqlQueryObject,dumpMessaggio);
  921.             longId = this.findIdDumpMessaggio(jdbcProperties,log,connection,sqlQueryObject,idDumpMessaggio,false);
  922.             if(longId == null){
  923.                 return; // entry not exists
  924.             }
  925.         }       
  926.         
  927.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, longId);
  928.         
  929.     }

  931.     private void deleteEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long id) throws NotImplementedException,ServiceException,Exception {
  932.     
  933.         if(id==null) {
  934.             throw new ServiceException("Id is null");
  935.         }
  936.         if(id!=null && id.longValue()<=0){
  937.             throw new ServiceException("Id is less equals 0");
  938.         }
  939.         
  940.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  941.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  942.         
  943.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObject.newSQLQueryObject();
  944.         

  946.         //Recupero oggetto _dumpMessaggio_multipartHeader
  947.         ISQLQueryObject sqlQueryObjectDelete_dumpMessaggio_multipartHeadergetEngineToDelete = sqlQueryObjectDelete.newSQLQueryObject();
  948.         sqlQueryObjectDelete_dumpMessaggio_multipartHeadergetEngineToDelete.setANDLogicOperator(true);
  949.         sqlQueryObjectDelete_dumpMessaggio_multipartHeadergetEngineToDelete.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().MULTIPART_HEADER));
  950.         sqlQueryObjectDelete_dumpMessaggio_multipartHeadergetEngineToDelete.addWhereCondition("id_messaggio=?");
  951.         java.util.List<Object> dumpMessaggio_multipartHeader_toDelete_list = jdbcUtilities.executeQuery(sqlQueryObjectDelete_dumpMessaggio_multipartHeadergetEngineToDelete.createSQLQuery(), jdbcProperties.isShowSql(), DumpMessaggio.model().MULTIPART_HEADER, this.getDumpMessaggioFetch(),
  952.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(id,Long.class));

  954.         // for dumpMessaggio_multipartHeader
  955.         for (Object dumpMessaggio_multipartHeader_object : dumpMessaggio_multipartHeader_toDelete_list) {
  956.             DumpMultipartHeader dumpMessaggio_multipartHeader = (DumpMultipartHeader) dumpMessaggio_multipartHeader_object;

  958.             // Object dumpMessaggio_multipartHeader
  959.             ISQLQueryObject sqlQueryObjectDelete_dumpMessaggio_multipartHeader = sqlQueryObjectDelete.newSQLQueryObject();
  960.             sqlQueryObjectDelete_dumpMessaggio_multipartHeader.setANDLogicOperator(true);
  961.             sqlQueryObjectDelete_dumpMessaggio_multipartHeader.addDeleteTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().MULTIPART_HEADER));
  962.             sqlQueryObjectDelete_dumpMessaggio_multipartHeader.addWhereCondition("id=?");

  964.             // Delete dumpMessaggio_multipartHeader
  965.             if(dumpMessaggio_multipartHeader != null){
  966.                 jdbcUtilities.execute(sqlQueryObjectDelete_dumpMessaggio_multipartHeader.createSQLDelete(), jdbcProperties.isShowSql(), 
  967.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_multipartHeader.getId(),Long.class));
  968.             }
  969.         } // fine for dumpMessaggio_multipartHeader

  971.         //Recupero oggetto _dumpMessaggio_headerTrasporto
  972.         ISQLQueryObject sqlQueryObjectDelete_dumpMessaggio_headerTrasportogetEngineToDelete = sqlQueryObjectDelete.newSQLQueryObject();
  973.         sqlQueryObjectDelete_dumpMessaggio_headerTrasportogetEngineToDelete.setANDLogicOperator(true);
  974.         sqlQueryObjectDelete_dumpMessaggio_headerTrasportogetEngineToDelete.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().HEADER_TRASPORTO));
  975.         sqlQueryObjectDelete_dumpMessaggio_headerTrasportogetEngineToDelete.addWhereCondition("id_messaggio=?");
  976.         java.util.List<Object> dumpMessaggio_headerTrasporto_toDelete_list = jdbcUtilities.executeQuery(sqlQueryObjectDelete_dumpMessaggio_headerTrasportogetEngineToDelete.createSQLQuery(), jdbcProperties.isShowSql(), DumpMessaggio.model().HEADER_TRASPORTO, this.getDumpMessaggioFetch(),
  977.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(id,Long.class));

  979.         // for dumpMessaggio_headerTrasporto
  980.         for (Object dumpMessaggio_headerTrasporto_object : dumpMessaggio_headerTrasporto_toDelete_list) {
  981.             DumpHeaderTrasporto dumpMessaggio_headerTrasporto = (DumpHeaderTrasporto) dumpMessaggio_headerTrasporto_object;

  983.             // Object dumpMessaggio_headerTrasporto
  984.             ISQLQueryObject sqlQueryObjectDelete_dumpMessaggio_headerTrasporto = sqlQueryObjectDelete.newSQLQueryObject();
  985.             sqlQueryObjectDelete_dumpMessaggio_headerTrasporto.setANDLogicOperator(true);
  986.             sqlQueryObjectDelete_dumpMessaggio_headerTrasporto.addDeleteTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().HEADER_TRASPORTO));
  987.             sqlQueryObjectDelete_dumpMessaggio_headerTrasporto.addWhereCondition("id=?");

  989.             // Delete dumpMessaggio_headerTrasporto
  990.             if(dumpMessaggio_headerTrasporto != null){
  991.                 jdbcUtilities.execute(sqlQueryObjectDelete_dumpMessaggio_headerTrasporto.createSQLDelete(), jdbcProperties.isShowSql(), 
  992.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_headerTrasporto.getId(),Long.class));
  993.             }
  994.         } // fine for dumpMessaggio_headerTrasporto

  996.         //Recupero oggetto _dumpMessaggio_allegato
  997.         ISQLQueryObject sqlQueryObjectDelete_dumpMessaggio_allegatogetEngineToDelete = sqlQueryObjectDelete.newSQLQueryObject();
  998.         sqlQueryObjectDelete_dumpMessaggio_allegatogetEngineToDelete.setANDLogicOperator(true);
  999.         sqlQueryObjectDelete_dumpMessaggio_allegatogetEngineToDelete.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO));
  1000.         sqlQueryObjectDelete_dumpMessaggio_allegatogetEngineToDelete.addWhereCondition("id_messaggio=?");
  1001.         java.util.List<Object> dumpMessaggio_allegato_toDelete_list = jdbcUtilities.executeQuery(sqlQueryObjectDelete_dumpMessaggio_allegatogetEngineToDelete.createSQLQuery(), jdbcProperties.isShowSql(), DumpMessaggio.model().ALLEGATO, this.getDumpMessaggioFetch(),
  1002.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(id,Long.class));

  1004.         // for dumpMessaggio_allegato
  1005.         for (Object dumpMessaggio_allegato_object : dumpMessaggio_allegato_toDelete_list) {
  1006.             DumpAllegato dumpMessaggio_allegato = (DumpAllegato) dumpMessaggio_allegato_object;

  1008.             if(dumpMessaggio_allegato==null) {
  1009.                 continue;
  1010.             }
  1011.             
  1012.             //Recupero oggetto _dumpMessaggio_allegato_header
  1013.             ISQLQueryObject sqlQueryObjectDelete_dumpMessaggio_allegato_dumpMessaggio_allegato_headergetEngineToDelete = sqlQueryObjectDelete.newSQLQueryObject();
  1014.             sqlQueryObjectDelete_dumpMessaggio_allegato_dumpMessaggio_allegato_headergetEngineToDelete.setANDLogicOperator(true);
  1015.             sqlQueryObjectDelete_dumpMessaggio_allegato_dumpMessaggio_allegato_headergetEngineToDelete.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO.HEADER));
  1016.             sqlQueryObjectDelete_dumpMessaggio_allegato_dumpMessaggio_allegato_headergetEngineToDelete.addWhereCondition("id_allegato=?");
  1017.             java.util.List<Object> dumpMessaggio_allegato_header_toDelete_list = jdbcUtilities.executeQuery(sqlQueryObjectDelete_dumpMessaggio_allegato_dumpMessaggio_allegato_headergetEngineToDelete.createSQLQuery(), jdbcProperties.isShowSql(), DumpMessaggio.model().ALLEGATO.HEADER, this.getDumpMessaggioFetch(),
  1018.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_allegato.getId(),Long.class));

  1020.             // for dumpMessaggio_allegato_header
  1021.             for (Object dumpMessaggio_allegato_header_object : dumpMessaggio_allegato_header_toDelete_list) {
  1022.                 DumpHeaderAllegato dumpMessaggio_allegato_header = (DumpHeaderAllegato) dumpMessaggio_allegato_header_object;

  1024.                 // Object dumpMessaggio_allegato_header
  1025.                 ISQLQueryObject sqlQueryObjectDelete_dumpMessaggio_allegato_header = sqlQueryObjectDelete.newSQLQueryObject();
  1026.                 sqlQueryObjectDelete_dumpMessaggio_allegato_header.setANDLogicOperator(true);
  1027.                 sqlQueryObjectDelete_dumpMessaggio_allegato_header.addDeleteTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO.HEADER));
  1028.                 sqlQueryObjectDelete_dumpMessaggio_allegato_header.addWhereCondition("id=?");

  1030.                 // Delete dumpMessaggio_allegato_header
  1031.                 if(dumpMessaggio_allegato_header != null){
  1032.                     jdbcUtilities.execute(sqlQueryObjectDelete_dumpMessaggio_allegato_header.createSQLDelete(), jdbcProperties.isShowSql(), 
  1033.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_allegato_header.getId(),Long.class));
  1034.                 }
  1035.             } // fine for dumpMessaggio_allegato_header

  1037.             // Object dumpMessaggio_allegato
  1038.             ISQLQueryObject sqlQueryObjectDelete_dumpMessaggio_allegato = sqlQueryObjectDelete.newSQLQueryObject();
  1039.             sqlQueryObjectDelete_dumpMessaggio_allegato.setANDLogicOperator(true);
  1040.             sqlQueryObjectDelete_dumpMessaggio_allegato.addDeleteTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO));
  1041.             sqlQueryObjectDelete_dumpMessaggio_allegato.addWhereCondition("id=?");

  1043.             // Delete dumpMessaggio_allegato
  1044.             if(dumpMessaggio_allegato != null){
  1045.                 jdbcUtilities.execute(sqlQueryObjectDelete_dumpMessaggio_allegato.createSQLDelete(), jdbcProperties.isShowSql(), 
  1046.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_allegato.getId(),Long.class));
  1047.             }
  1048.         } // fine for dumpMessaggio_allegato

  1050.         //Recupero oggetto _dumpMessaggio_contenuto
  1051.         ISQLQueryObject sqlQueryObjectDelete_dumpMessaggio_contenutogetEngineToDelete = sqlQueryObjectDelete.newSQLQueryObject();
  1052.         sqlQueryObjectDelete_dumpMessaggio_contenutogetEngineToDelete.setANDLogicOperator(true);
  1053.         sqlQueryObjectDelete_dumpMessaggio_contenutogetEngineToDelete.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().CONTENUTO));
  1054.         sqlQueryObjectDelete_dumpMessaggio_contenutogetEngineToDelete.addWhereCondition("id_messaggio=?");
  1055.         java.util.List<Object> dumpMessaggio_contenuto_toDelete_list = jdbcUtilities.executeQuery(sqlQueryObjectDelete_dumpMessaggio_contenutogetEngineToDelete.createSQLQuery(), jdbcProperties.isShowSql(), DumpMessaggio.model().CONTENUTO, this.getDumpMessaggioFetch(),
  1056.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(id,Long.class));

  1058.         // for dumpMessaggio_contenuto
  1059.         for (Object dumpMessaggio_contenuto_object : dumpMessaggio_contenuto_toDelete_list) {
  1060.             DumpContenuto dumpMessaggio_contenuto = (DumpContenuto) dumpMessaggio_contenuto_object;

  1062.             // Object dumpMessaggio_contenuto
  1063.             ISQLQueryObject sqlQueryObjectDelete_dumpMessaggio_contenuto = sqlQueryObjectDelete.newSQLQueryObject();
  1064.             sqlQueryObjectDelete_dumpMessaggio_contenuto.setANDLogicOperator(true);
  1065.             sqlQueryObjectDelete_dumpMessaggio_contenuto.addDeleteTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().CONTENUTO));
  1066.             sqlQueryObjectDelete_dumpMessaggio_contenuto.addWhereCondition("id=?");

  1068.             // Delete dumpMessaggio_contenuto
  1069.             if(dumpMessaggio_contenuto != null){
  1070.                 jdbcUtilities.execute(sqlQueryObjectDelete_dumpMessaggio_contenuto.createSQLDelete(), jdbcProperties.isShowSql(), 
  1071.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(dumpMessaggio_contenuto.getId(),Long.class));
  1072.             }
  1073.         } // fine for dumpMessaggio_contenuto

  1075.         // Object dumpMessaggio
  1076.         sqlQueryObjectDelete.setANDLogicOperator(true);
  1077.         sqlQueryObjectDelete.addDeleteTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model()));
  1078.         if(id != null)
  1079.             sqlQueryObjectDelete.addWhereCondition("id=?");

  1081.         // Delete dumpMessaggio
  1082.         jdbcUtilities.execute(sqlQueryObjectDelete.createSQLDelete(), jdbcProperties.isShowSql(), 
  1083.             new JDBCObject(id,Long.class));

  1085.     }

  1087.     @Override
  1088.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdDumpMessaggio idDumpMessaggio) throws NotImplementedException,ServiceException,Exception {

  1090.         Long id = null;
  1091.         try{
  1092.             id = this.findIdDumpMessaggio(jdbcProperties, log, connection, sqlQueryObject, idDumpMessaggio, true);
  1093.         }catch(NotFoundException notFound){
  1094.             return;
  1095.         }
  1096.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  1097.         
  1098.     }
  1099.     
  1100.     @Override
  1101.     public NonNegativeNumber deleteAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject) throws NotImplementedException,ServiceException,Exception {
  1102.         
  1103.         return this.deleteAll(jdbcProperties, log, connection, sqlQueryObject, new JDBCExpression(this.getDumpMessaggioFieldConverter()));

  1105.     }

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

  1110.         java.util.List<Long> lst = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, new JDBCPaginatedExpression(expression));
  1111.         
  1112.         for(Long id : lst) {
  1113.             this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  1114.         }
  1115.         
  1116.         return new NonNegativeNumber(lst.size());
  1117.     
  1118.     }



  1122.     // -- DB
  1123.     
  1124.     @Override
  1125.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws ServiceException, NotImplementedException, Exception {
  1126.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  1127.     }
  1128.     
  1129.     @Override
  1130.     public int nativeUpdate(JDBCServiceManagerProperties jdbcProperties, Logger log,Connection connection,ISQLQueryObject sqlObject, String sql,Object ... param) throws ServiceException,NotImplementedException, Exception {
  1131.     
  1132.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeUpdate(jdbcProperties, log, connection, sqlObject,
  1133.                                                                                             sql,param);
  1134.     
  1135.     }
  1136. }
Created with JaCoCo 0.8.8.202204050719