JDBCAllarmeServiceImpl.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.allarmi.dao.jdbc;

  22. import java.sql.Connection;

  24. import org.openspcoop2.core.allarmi.Allarme;
  25. import org.openspcoop2.core.allarmi.AllarmeFiltro;
  26. import org.openspcoop2.core.allarmi.AllarmeHistory;
  27. import org.openspcoop2.core.allarmi.AllarmeMail;
  28. import org.openspcoop2.core.allarmi.AllarmeNotifica;
  29. import org.openspcoop2.core.allarmi.AllarmeParametro;
  30. import org.openspcoop2.core.allarmi.AllarmeRaggruppamento;
  31. import org.openspcoop2.core.allarmi.AllarmeScript;
  32. import org.openspcoop2.core.allarmi.IdAllarme;
  33. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  34. import org.openspcoop2.generic_project.beans.UpdateField;
  35. import org.openspcoop2.generic_project.beans.UpdateModel;
  36. import org.openspcoop2.generic_project.dao.IDBServiceUtilities;
  37. import org.openspcoop2.generic_project.dao.jdbc.IJDBCServiceCRUDWithId;
  38. import org.openspcoop2.generic_project.dao.jdbc.JDBCExpression;
  39. import org.openspcoop2.generic_project.dao.jdbc.JDBCPaginatedExpression;
  40. import org.openspcoop2.generic_project.dao.jdbc.JDBCServiceManagerProperties;
  41. import org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject;
  42. import org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities;
  43. import org.openspcoop2.generic_project.exception.NotFoundException;
  44. import org.openspcoop2.generic_project.exception.NotImplementedException;
  45. import org.openspcoop2.generic_project.exception.ServiceException;
  46. import org.openspcoop2.generic_project.expression.IExpression;
  47. import org.openspcoop2.utils.sql.ISQLQueryObject;
  48. import org.slf4j.Logger;

  50. /**     
  51.  * JDBCAllarmeServiceImpl
  52.  *
  53.  * @author Poli Andrea (poli@link.it)
  54.  * @author $Author$
  55.  * @version $Rev$, $Date$
  56.  */
  57. public class JDBCAllarmeServiceImpl extends JDBCAllarmeServiceSearchImpl
  58.     implements IJDBCServiceCRUDWithId<Allarme, IdAllarme, JDBCServiceManager> {

  60.     @Override
  61.     public void create(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Allarme allarme, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {

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


  70.         // Object allarme
  71.         sqlQueryObjectInsert.addInsertTable(this.getAllarmeFieldConverter().toTable(Allarme.model()));
  72.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().NOME,false),"?");
  73.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().ALIAS,false),"?");
  74.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().DESCRIZIONE,false),"?");
  75.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().TIPO,false),"?");
  76.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().TIPO_ALLARME,false),"?");
  77.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().MAIL.INVIA,false),"?");
  78.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().MAIL.INVIA_WARNING,false),"?");
  79.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().MAIL.DESTINATARI,false),"?");
  80.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().MAIL.SUBJECT,false),"?");
  81.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().MAIL.BODY,false),"?");
  82.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().SCRIPT.INVOCA,false),"?");
  83.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().SCRIPT.INVOCA_WARNING,false),"?");
  84.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().SCRIPT.COMMAND,false),"?");
  85.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().SCRIPT.ARGS,false),"?");
  86.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().STATO_PRECEDENTE,false),"?");
  87.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().STATO,false),"?");
  88.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().DETTAGLIO_STATO,false),"?");
  89.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().LASTTIMESTAMP_CREATE,false),"?");
  90.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().LASTTIMESTAMP_UPDATE,false),"?");
  91.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().ENABLED,false),"?");
  92.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().ACKNOWLEDGED,false),"?");
  93.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().DETTAGLIO_ACKNOWLEDGED,false),"?");
  94.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().TIPO_PERIODO,false),"?");
  95.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().PERIODO,false),"?");
  96.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.ENABLED,false),"?");
  97.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.PROTOCOLLO,false),"?");
  98.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.RUOLO_PORTA,false),"?");
  99.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.NOME_PORTA,false),"?");
  100.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.TIPO_FRUITORE,false),"?");
  101.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.NOME_FRUITORE,false),"?");
  102.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.RUOLO_FRUITORE,false),"?");
  103.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.SERVIZIO_APPLICATIVO_FRUITORE,false),"?");
  104.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.TIPO_EROGATORE,false),"?");
  105.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.NOME_EROGATORE,false),"?");
  106.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.RUOLO_EROGATORE,false),"?");
  107.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.TAG,false),"?");
  108.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.TIPO_SERVIZIO,false),"?");
  109.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.NOME_SERVIZIO,false),"?");
  110.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.VERSIONE_SERVIZIO,false),"?");
  111.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.AZIONE,false),"?");
  112.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.ENABLED,false),"?");
  113.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.RUOLO_PORTA,false),"?");
  114.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.PROTOCOLLO,false),"?");
  115.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.FRUITORE,false),"?");
  116.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.SERVIZIO_APPLICATIVO_FRUITORE,false),"?");
  117.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.IDENTIFICATIVO_AUTENTICATO,false),"?");
  118.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.TOKEN,false),"?");
  119.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.EROGATORE,false),"?");
  120.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.SERVIZIO,false),"?");
  121.         sqlQueryObjectInsert.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.AZIONE,false),"?");

  123.         // Insert allarme
  124.         org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator = this.getAllarmeFetch().getKeyGeneratorObject(Allarme.model());
  125.         long id = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert, keyGenerator, jdbcProperties.isShowSql(),
  126.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getNome(),Allarme.model().NOME.getFieldType()),
  127.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getAlias(),Allarme.model().ALIAS.getFieldType()),
  128.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getDescrizione(),Allarme.model().DESCRIZIONE.getFieldType()),
  129.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getTipo(),Allarme.model().TIPO.getFieldType()),
  130.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getTipoAllarme(),Allarme.model().TIPO_ALLARME.getFieldType()),
  131.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getMail().getInvia(),Allarme.model().MAIL.INVIA.getFieldType()),
  132.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getMail().getInviaWarning(),Allarme.model().MAIL.INVIA_WARNING.getFieldType()),
  133.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getMail().getDestinatari(),Allarme.model().MAIL.DESTINATARI.getFieldType()),
  134.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getMail().getSubject(),Allarme.model().MAIL.SUBJECT.getFieldType()),
  135.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getMail().getBody(),Allarme.model().MAIL.BODY.getFieldType()),
  136.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getScript().getInvoca(),Allarme.model().SCRIPT.INVOCA.getFieldType()),
  137.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getScript().getInvocaWarning(),Allarme.model().SCRIPT.INVOCA_WARNING.getFieldType()),
  138.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getScript().getCommand(),Allarme.model().SCRIPT.COMMAND.getFieldType()),
  139.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getScript().getArgs(),Allarme.model().SCRIPT.ARGS.getFieldType()),
  140.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getStatoPrecedente(),Allarme.model().STATO_PRECEDENTE.getFieldType()),
  141.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getStato(),Allarme.model().STATO.getFieldType()),
  142.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getDettaglioStato(),Allarme.model().DETTAGLIO_STATO.getFieldType()),
  143.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getLasttimestampCreate(),Allarme.model().LASTTIMESTAMP_CREATE.getFieldType()),
  144.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getLasttimestampUpdate(),Allarme.model().LASTTIMESTAMP_UPDATE.getFieldType()),
  145.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getEnabled(),Allarme.model().ENABLED.getFieldType()),
  146.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getAcknowledged(),Allarme.model().ACKNOWLEDGED.getFieldType()),
  147.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getDettaglioAcknowledged(),Allarme.model().DETTAGLIO_ACKNOWLEDGED.getFieldType()),
  148.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getTipoPeriodo(),Allarme.model().TIPO_PERIODO.getFieldType()),
  149.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getPeriodo(),Allarme.model().PERIODO.getFieldType()),
  150.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getFiltro().getEnabled(),Allarme.model().FILTRO.ENABLED.getFieldType()),
  151.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getFiltro().getProtocollo(),Allarme.model().FILTRO.PROTOCOLLO.getFieldType()),
  152.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getFiltro().getRuoloPorta(),Allarme.model().FILTRO.RUOLO_PORTA.getFieldType()),
  153.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getFiltro().getNomePorta(),Allarme.model().FILTRO.NOME_PORTA.getFieldType()),
  154.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getFiltro().getTipoFruitore(),Allarme.model().FILTRO.TIPO_FRUITORE.getFieldType()),
  155.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getFiltro().getNomeFruitore(),Allarme.model().FILTRO.NOME_FRUITORE.getFieldType()),
  156.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getFiltro().getRuoloFruitore(),Allarme.model().FILTRO.RUOLO_FRUITORE.getFieldType()),
  157.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getFiltro().getServizioApplicativoFruitore(),Allarme.model().FILTRO.SERVIZIO_APPLICATIVO_FRUITORE.getFieldType()),
  158.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getFiltro().getTipoErogatore(),Allarme.model().FILTRO.TIPO_EROGATORE.getFieldType()),
  159.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getFiltro().getNomeErogatore(),Allarme.model().FILTRO.NOME_EROGATORE.getFieldType()),
  160.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getFiltro().getRuoloErogatore(),Allarme.model().FILTRO.RUOLO_EROGATORE.getFieldType()),
  161.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getFiltro().getTag(),Allarme.model().FILTRO.TAG.getFieldType()),
  162.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getFiltro().getTipoServizio(),Allarme.model().FILTRO.TIPO_SERVIZIO.getFieldType()),
  163.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getFiltro().getNomeServizio(),Allarme.model().FILTRO.NOME_SERVIZIO.getFieldType()),
  164.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getFiltro().getVersioneServizio(),Allarme.model().FILTRO.VERSIONE_SERVIZIO.getFieldType()),
  165.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getFiltro().getAzione(),Allarme.model().FILTRO.AZIONE.getFieldType()),
  166.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getGroupBy().getEnabled(),Allarme.model().GROUP_BY.ENABLED.getFieldType()),
  167.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getGroupBy().getRuoloPorta(),Allarme.model().GROUP_BY.RUOLO_PORTA.getFieldType()),
  168.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getGroupBy().getProtocollo(),Allarme.model().GROUP_BY.PROTOCOLLO.getFieldType()),
  169.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getGroupBy().getFruitore(),Allarme.model().GROUP_BY.FRUITORE.getFieldType()),
  170.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getGroupBy().getServizioApplicativoFruitore(),Allarme.model().GROUP_BY.SERVIZIO_APPLICATIVO_FRUITORE.getFieldType()),
  171.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getGroupBy().getIdentificativoAutenticato(),Allarme.model().GROUP_BY.IDENTIFICATIVO_AUTENTICATO.getFieldType()),
  172.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getGroupBy().getToken(),Allarme.model().GROUP_BY.TOKEN.getFieldType()),
  173.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getGroupBy().getErogatore(),Allarme.model().GROUP_BY.EROGATORE.getFieldType()),
  174.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getGroupBy().getServizio(),Allarme.model().GROUP_BY.SERVIZIO.getFieldType()),
  175.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getGroupBy().getAzione(),Allarme.model().GROUP_BY.AZIONE.getFieldType())
  176.         );
  177.         allarme.setId(id);

  179.         // for allarme
  180.         for (int i = 0; i < allarme.getAllarmeParametroList().size(); i++) {


  183.             // Object allarme.getAllarmeParametroList().get(i)
  184.             ISQLQueryObject sqlQueryObjectInsert_allarmeParametro = sqlQueryObjectInsert.newSQLQueryObject();
  185.             sqlQueryObjectInsert_allarmeParametro.addInsertTable(this.getAllarmeFieldConverter().toTable(Allarme.model().ALLARME_PARAMETRO));
  186.             sqlQueryObjectInsert_allarmeParametro.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().ALLARME_PARAMETRO.ID_PARAMETRO,false),"?");
  187.             sqlQueryObjectInsert_allarmeParametro.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().ALLARME_PARAMETRO.VALORE,false),"?");
  188.             sqlQueryObjectInsert_allarmeParametro.addInsertField("id_allarme","?");

  190.             // Insert allarme.getAllarmeParametroList().get(i)
  191.             org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator_allarmeParametro = this.getAllarmeFetch().getKeyGeneratorObject(Allarme.model().ALLARME_PARAMETRO);
  192.             long idAllarmeParametro = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert_allarmeParametro, keyGenerator_allarmeParametro, jdbcProperties.isShowSql(),
  193.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getAllarmeParametroList().get(i).getIdParametro(),Allarme.model().ALLARME_PARAMETRO.ID_PARAMETRO.getFieldType()),
  194.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme.getAllarmeParametroList().get(i).getValore(),Allarme.model().ALLARME_PARAMETRO.VALORE.getFieldType()),
  195.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(Long.valueOf(id),Long.class)
  196.             );
  197.             allarme.getAllarmeParametroList().get(i).setId(idAllarmeParametro);
  198.         } // fine for 

  200.         
  201.     }

  203.     @Override
  204.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAllarme oldId, Allarme allarme, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  205.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObject.newSQLQueryObject();
  206.         Long longIdByLogicId = this.findIdAllarme(jdbcProperties, log, connection, sqlQueryObjectUpdate.newSQLQueryObject(), oldId, true);
  207.         Long tableId = allarme.getId();
  208.         if(tableId != null && tableId.longValue() > 0) {
  209.             if(tableId.longValue() != longIdByLogicId.longValue()) {
  210.                 throw new Exception("Ambiguous parameter: allarme.id ["+tableId+"] does not match logic id ["+longIdByLogicId+"]");
  211.             }
  212.         } else {
  213.             tableId = longIdByLogicId;
  214.             allarme.setId(tableId);
  215.         }
  216.         if(tableId==null || tableId<=0){
  217.             throw new Exception("Retrieve tableId failed");
  218.         }

  220.         this.update(jdbcProperties, log, connection, sqlQueryObject, tableId, allarme, idMappingResolutionBehaviour);
  221.     }
  222.     @Override
  223.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, Allarme allarme, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  224.     
  225.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  226.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  227.         
  228.         ISQLQueryObject sqlQueryObjectInsert = sqlQueryObject.newSQLQueryObject();
  229.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObjectInsert.newSQLQueryObject();
  230.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObjectDelete.newSQLQueryObject();
  231.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObjectGet.newSQLQueryObject();
  232.         


  235.         // Object allarme
  236.         sqlQueryObjectUpdate.setANDLogicOperator(true);
  237.         sqlQueryObjectUpdate.addUpdateTable(this.getAllarmeFieldConverter().toTable(Allarme.model()));
  238.         boolean isUpdate = true;
  239.         java.util.List<JDBCObject> lstObjects = new java.util.ArrayList<>();
  240.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().NOME,false), "?");
  241.         lstObjects.add(new JDBCObject(allarme.getNome(), Allarme.model().NOME.getFieldType()));
  242.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().ALIAS,false), "?");
  243.         lstObjects.add(new JDBCObject(allarme.getAlias(), Allarme.model().ALIAS.getFieldType()));
  244.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().DESCRIZIONE,false), "?");
  245.         lstObjects.add(new JDBCObject(allarme.getDescrizione(), Allarme.model().DESCRIZIONE.getFieldType()));
  246.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().TIPO,false), "?");
  247.         lstObjects.add(new JDBCObject(allarme.getTipo(), Allarme.model().TIPO.getFieldType()));
  248.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().TIPO_ALLARME,false), "?");
  249.         lstObjects.add(new JDBCObject(allarme.getTipoAllarme(), Allarme.model().TIPO_ALLARME.getFieldType()));
  250.         AllarmeMail allarme_mail = allarme.getMail();
  251.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().MAIL.INVIA,false), "?");
  252.         lstObjects.add(new JDBCObject(allarme_mail.getInvia(), Allarme.model().MAIL.INVIA.getFieldType()));
  253.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().MAIL.INVIA_WARNING,false), "?");
  254.         lstObjects.add(new JDBCObject(allarme_mail.getInviaWarning(), Allarme.model().MAIL.INVIA_WARNING.getFieldType()));
  255.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().MAIL.DESTINATARI,false), "?");
  256.         lstObjects.add(new JDBCObject(allarme_mail.getDestinatari(), Allarme.model().MAIL.DESTINATARI.getFieldType()));
  257.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().MAIL.SUBJECT,false), "?");
  258.         lstObjects.add(new JDBCObject(allarme_mail.getSubject(), Allarme.model().MAIL.SUBJECT.getFieldType()));
  259.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().MAIL.BODY,false), "?");
  260.         lstObjects.add(new JDBCObject(allarme_mail.getBody(), Allarme.model().MAIL.BODY.getFieldType()));
  261.         AllarmeScript allarme_script = allarme.getScript();
  262.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().SCRIPT.INVOCA,false), "?");
  263.         lstObjects.add(new JDBCObject(allarme_script.getInvoca(), Allarme.model().SCRIPT.INVOCA.getFieldType()));
  264.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().SCRIPT.INVOCA_WARNING,false), "?");
  265.         lstObjects.add(new JDBCObject(allarme_script.getInvocaWarning(), Allarme.model().SCRIPT.INVOCA_WARNING.getFieldType()));
  266.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().SCRIPT.COMMAND,false), "?");
  267.         lstObjects.add(new JDBCObject(allarme_script.getCommand(), Allarme.model().SCRIPT.COMMAND.getFieldType()));
  268.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().SCRIPT.ARGS,false), "?");
  269.         lstObjects.add(new JDBCObject(allarme_script.getArgs(), Allarme.model().SCRIPT.ARGS.getFieldType()));
  270.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().STATO_PRECEDENTE,false), "?");
  271.         lstObjects.add(new JDBCObject(allarme.getStatoPrecedente(), Allarme.model().STATO_PRECEDENTE.getFieldType()));
  272.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().STATO,false), "?");
  273.         lstObjects.add(new JDBCObject(allarme.getStato(), Allarme.model().STATO.getFieldType()));
  274.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().DETTAGLIO_STATO,false), "?");
  275.         lstObjects.add(new JDBCObject(allarme.getDettaglioStato(), Allarme.model().DETTAGLIO_STATO.getFieldType()));
  276.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().LASTTIMESTAMP_CREATE,false), "?");
  277.         lstObjects.add(new JDBCObject(allarme.getLasttimestampCreate(), Allarme.model().LASTTIMESTAMP_CREATE.getFieldType()));
  278.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().LASTTIMESTAMP_UPDATE,false), "?");
  279.         lstObjects.add(new JDBCObject(allarme.getLasttimestampUpdate(), Allarme.model().LASTTIMESTAMP_UPDATE.getFieldType()));
  280.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().ENABLED,false), "?");
  281.         lstObjects.add(new JDBCObject(allarme.getEnabled(), Allarme.model().ENABLED.getFieldType()));
  282.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().ACKNOWLEDGED,false), "?");
  283.         lstObjects.add(new JDBCObject(allarme.getAcknowledged(), Allarme.model().ACKNOWLEDGED.getFieldType()));
  284.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().DETTAGLIO_ACKNOWLEDGED,false), "?");
  285.         lstObjects.add(new JDBCObject(allarme.getDettaglioAcknowledged(), Allarme.model().DETTAGLIO_ACKNOWLEDGED.getFieldType()));
  286.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().TIPO_PERIODO,false), "?");
  287.         lstObjects.add(new JDBCObject(allarme.getTipoPeriodo(), Allarme.model().TIPO_PERIODO.getFieldType()));
  288.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().PERIODO,false), "?");
  289.         lstObjects.add(new JDBCObject(allarme.getPeriodo(), Allarme.model().PERIODO.getFieldType()));
  290.         AllarmeFiltro allarme_filtro = allarme.getFiltro();
  291.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.ENABLED,false), "?");
  292.         lstObjects.add(new JDBCObject(allarme_filtro.getEnabled(), Allarme.model().FILTRO.ENABLED.getFieldType()));
  293.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.PROTOCOLLO,false), "?");
  294.         lstObjects.add(new JDBCObject(allarme_filtro.getProtocollo(), Allarme.model().FILTRO.PROTOCOLLO.getFieldType()));
  295.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.RUOLO_PORTA,false), "?");
  296.         lstObjects.add(new JDBCObject(allarme_filtro.getRuoloPorta(), Allarme.model().FILTRO.RUOLO_PORTA.getFieldType()));
  297.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.NOME_PORTA,false), "?");
  298.         lstObjects.add(new JDBCObject(allarme_filtro.getNomePorta(), Allarme.model().FILTRO.NOME_PORTA.getFieldType()));
  299.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.TIPO_FRUITORE,false), "?");
  300.         lstObjects.add(new JDBCObject(allarme_filtro.getTipoFruitore(), Allarme.model().FILTRO.TIPO_FRUITORE.getFieldType()));
  301.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.NOME_FRUITORE,false), "?");
  302.         lstObjects.add(new JDBCObject(allarme_filtro.getNomeFruitore(), Allarme.model().FILTRO.NOME_FRUITORE.getFieldType()));
  303.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.RUOLO_FRUITORE,false), "?");
  304.         lstObjects.add(new JDBCObject(allarme_filtro.getRuoloFruitore(), Allarme.model().FILTRO.RUOLO_FRUITORE.getFieldType()));
  305.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.SERVIZIO_APPLICATIVO_FRUITORE,false), "?");
  306.         lstObjects.add(new JDBCObject(allarme_filtro.getServizioApplicativoFruitore(), Allarme.model().FILTRO.SERVIZIO_APPLICATIVO_FRUITORE.getFieldType()));
  307.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.TIPO_EROGATORE,false), "?");
  308.         lstObjects.add(new JDBCObject(allarme_filtro.getTipoErogatore(), Allarme.model().FILTRO.TIPO_EROGATORE.getFieldType()));
  309.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.NOME_EROGATORE,false), "?");
  310.         lstObjects.add(new JDBCObject(allarme_filtro.getNomeErogatore(), Allarme.model().FILTRO.NOME_EROGATORE.getFieldType()));
  311.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.RUOLO_EROGATORE,false), "?");
  312.         lstObjects.add(new JDBCObject(allarme_filtro.getRuoloErogatore(), Allarme.model().FILTRO.RUOLO_EROGATORE.getFieldType()));
  313.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.TAG,false), "?");
  314.         lstObjects.add(new JDBCObject(allarme_filtro.getTag(), Allarme.model().FILTRO.TAG.getFieldType()));
  315.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.TIPO_SERVIZIO,false), "?");
  316.         lstObjects.add(new JDBCObject(allarme_filtro.getTipoServizio(), Allarme.model().FILTRO.TIPO_SERVIZIO.getFieldType()));
  317.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.NOME_SERVIZIO,false), "?");
  318.         lstObjects.add(new JDBCObject(allarme_filtro.getNomeServizio(), Allarme.model().FILTRO.NOME_SERVIZIO.getFieldType()));
  319.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.VERSIONE_SERVIZIO,false), "?");
  320.         lstObjects.add(new JDBCObject(allarme_filtro.getVersioneServizio(), Allarme.model().FILTRO.VERSIONE_SERVIZIO.getFieldType()));
  321.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().FILTRO.AZIONE,false), "?");
  322.         lstObjects.add(new JDBCObject(allarme_filtro.getAzione(), Allarme.model().FILTRO.AZIONE.getFieldType()));
  323.         AllarmeRaggruppamento allarme_groupBy = allarme.getGroupBy();
  324.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.ENABLED,false), "?");
  325.         lstObjects.add(new JDBCObject(allarme_groupBy.getEnabled(), Allarme.model().GROUP_BY.ENABLED.getFieldType()));
  326.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.RUOLO_PORTA,false), "?");
  327.         lstObjects.add(new JDBCObject(allarme_groupBy.getRuoloPorta(), Allarme.model().GROUP_BY.RUOLO_PORTA.getFieldType()));
  328.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.PROTOCOLLO,false), "?");
  329.         lstObjects.add(new JDBCObject(allarme_groupBy.getProtocollo(), Allarme.model().GROUP_BY.PROTOCOLLO.getFieldType()));
  330.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.FRUITORE,false), "?");
  331.         lstObjects.add(new JDBCObject(allarme_groupBy.getFruitore(), Allarme.model().GROUP_BY.FRUITORE.getFieldType()));
  332.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.SERVIZIO_APPLICATIVO_FRUITORE,false), "?");
  333.         lstObjects.add(new JDBCObject(allarme_groupBy.getServizioApplicativoFruitore(), Allarme.model().GROUP_BY.SERVIZIO_APPLICATIVO_FRUITORE.getFieldType()));
  334.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.IDENTIFICATIVO_AUTENTICATO,false), "?");
  335.         lstObjects.add(new JDBCObject(allarme_groupBy.getIdentificativoAutenticato(), Allarme.model().GROUP_BY.IDENTIFICATIVO_AUTENTICATO.getFieldType()));
  336.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.TOKEN,false), "?");
  337.         lstObjects.add(new JDBCObject(allarme_groupBy.getToken(), Allarme.model().GROUP_BY.TOKEN.getFieldType()));
  338.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.EROGATORE,false), "?");
  339.         lstObjects.add(new JDBCObject(allarme_groupBy.getErogatore(), Allarme.model().GROUP_BY.EROGATORE.getFieldType()));
  340.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.SERVIZIO,false), "?");
  341.         lstObjects.add(new JDBCObject(allarme_groupBy.getServizio(), Allarme.model().GROUP_BY.SERVIZIO.getFieldType()));
  342.         sqlQueryObjectUpdate.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().GROUP_BY.AZIONE,false), "?");
  343.         lstObjects.add(new JDBCObject(allarme_groupBy.getAzione(), Allarme.model().GROUP_BY.AZIONE.getFieldType()));
  344.         sqlQueryObjectUpdate.addWhereCondition("id=?");
  345.         lstObjects.add(new JDBCObject(tableId, Long.class));

  347.         if(isUpdate) {
  348.             // Update allarme
  349.             jdbcUtilities.executeUpdate(sqlQueryObjectUpdate.createSQLUpdate(), jdbcProperties.isShowSql(), 
  350.                 lstObjects.toArray(new JDBCObject[]{}));
  351.         }
  352.         // for allarme_allarmeParametro

  354.         java.util.List<Long> ids_allarmeParametro_da_non_eliminare = new java.util.ArrayList<Long>();
  355.         for (Object allarme_allarmeParametro_object : allarme.getAllarmeParametroList()) {
  356.             AllarmeParametro allarme_allarmeParametro = (AllarmeParametro) allarme_allarmeParametro_object;
  357.             if(allarme_allarmeParametro.getId() == null || allarme_allarmeParametro.getId().longValue() <= 0) {

  359.                 long id = allarme.getId();          

  361.                 // Object allarme_allarmeParametro
  362.                 ISQLQueryObject sqlQueryObjectInsert_allarmeParametro = sqlQueryObjectInsert.newSQLQueryObject();
  363.                 sqlQueryObjectInsert_allarmeParametro.addInsertTable(this.getAllarmeFieldConverter().toTable(Allarme.model().ALLARME_PARAMETRO));
  364.                 sqlQueryObjectInsert_allarmeParametro.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().ALLARME_PARAMETRO.ID_PARAMETRO,false),"?");
  365.                 sqlQueryObjectInsert_allarmeParametro.addInsertField(this.getAllarmeFieldConverter().toColumn(Allarme.model().ALLARME_PARAMETRO.VALORE,false),"?");
  366.                 sqlQueryObjectInsert_allarmeParametro.addInsertField("id_allarme","?");

  368.                 // Insert allarme_allarmeParametro
  369.                 org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator_allarmeParametro = this.getAllarmeFetch().getKeyGeneratorObject(Allarme.model().ALLARME_PARAMETRO);
  370.                 long idAllarmeParametro = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert_allarmeParametro, keyGenerator_allarmeParametro, jdbcProperties.isShowSql(),
  371.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme_allarmeParametro.getIdParametro(),Allarme.model().ALLARME_PARAMETRO.ID_PARAMETRO.getFieldType()),
  372.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme_allarmeParametro.getValore(),Allarme.model().ALLARME_PARAMETRO.VALORE.getFieldType()),
  373.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(Long.valueOf(id),Long.class)
  374.                 );
  375.                 allarme_allarmeParametro.setId(idAllarmeParametro);

  377.                 ids_allarmeParametro_da_non_eliminare.add(allarme_allarmeParametro.getId());
  378.             } else {


  381.                 // Object allarme_allarmeParametro
  382.                 ISQLQueryObject sqlQueryObjectUpdate_allarmeParametro = sqlQueryObjectUpdate.newSQLQueryObject();
  383.                 sqlQueryObjectUpdate_allarmeParametro.setANDLogicOperator(true);
  384.                 sqlQueryObjectUpdate_allarmeParametro.addUpdateTable(this.getAllarmeFieldConverter().toTable(Allarme.model().ALLARME_PARAMETRO));
  385.                 boolean isUpdate_allarmeParametro = true;
  386.                 java.util.List<JDBCObject> lstObjects_allarmeParametro = new java.util.ArrayList<>();
  387.                 sqlQueryObjectUpdate_allarmeParametro.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().ALLARME_PARAMETRO.ID_PARAMETRO,false), "?");
  388.                 lstObjects_allarmeParametro.add(new JDBCObject(allarme_allarmeParametro.getIdParametro(), Allarme.model().ALLARME_PARAMETRO.ID_PARAMETRO.getFieldType()));
  389.                 sqlQueryObjectUpdate_allarmeParametro.addUpdateField(this.getAllarmeFieldConverter().toColumn(Allarme.model().ALLARME_PARAMETRO.VALORE,false), "?");
  390.                 lstObjects_allarmeParametro.add(new JDBCObject(allarme_allarmeParametro.getValore(), Allarme.model().ALLARME_PARAMETRO.VALORE.getFieldType()));
  391.                 sqlQueryObjectUpdate_allarmeParametro.addWhereCondition("chk_param_id=?");
  392.                 ids_allarmeParametro_da_non_eliminare.add(allarme_allarmeParametro.getId());
  393.                 lstObjects_allarmeParametro.add(new JDBCObject(allarme_allarmeParametro.getId(),Long.class));

  395.                 if(isUpdate_allarmeParametro) {
  396.                     // Update allarme_allarmeParametro
  397.                     jdbcUtilities.executeUpdate(sqlQueryObjectUpdate_allarmeParametro.createSQLUpdate(), jdbcProperties.isShowSql(), 
  398.                         lstObjects_allarmeParametro.toArray(new JDBCObject[]{}));
  399.                 }
  400.             }
  401.         } // fine for allarme_allarmeParametro

  403.         // elimino tutte le occorrenze di allarme_allarmeParametro non presenti nell'update

  405.         ISQLQueryObject sqlQueryObjectUpdate_allarmeParametrodeleteEngineList = sqlQueryObjectUpdate.newSQLQueryObject();
  406.         sqlQueryObjectUpdate_allarmeParametrodeleteEngineList.setANDLogicOperator(true);
  407.         sqlQueryObjectUpdate_allarmeParametrodeleteEngineList.addDeleteTable(this.getAllarmeFieldConverter().toTable(Allarme.model().ALLARME_PARAMETRO));
  408.         java.util.List<JDBCObject> jdbcObjects_allarmeParametrodeleteEngine = new java.util.ArrayList<>();

  410.         sqlQueryObjectUpdate_allarmeParametrodeleteEngineList.addWhereCondition("id_allarme=?");
  411.         jdbcObjects_allarmeParametrodeleteEngine.add(new JDBCObject(allarme.getId(), Long.class));

  413.         StringBuilder marks_allarmeParametro = new StringBuilder();
  414.         if(ids_allarmeParametro_da_non_eliminare.size() > 0) {
  415.             for(Long ids : ids_allarmeParametro_da_non_eliminare) {
  416.                 if(marks_allarmeParametro.length() > 0) {
  417.                     marks_allarmeParametro.append(",");
  418.                 }
  419.                 marks_allarmeParametro.append("?");
  420.                 jdbcObjects_allarmeParametrodeleteEngine.add(new JDBCObject(ids, Long.class));

  422.             }
  423.             sqlQueryObjectUpdate_allarmeParametrodeleteEngineList.addWhereCondition("chk_param_id NOT IN ("+marks_allarmeParametro.toString()+")");
  424.         }

  426.         jdbcUtilities.execute(sqlQueryObjectUpdate_allarmeParametrodeleteEngineList.createSQLDelete(), jdbcProperties.isShowSql(), jdbcObjects_allarmeParametrodeleteEngine.toArray(new JDBCObject[]{}));



  430.     }
  431.     
  432.     @Override
  433.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAllarme id, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  434.         
  435.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  436.                 this.getAllarmeFieldConverter().toTable(Allarme.model()), 
  437.                 this.getMapTableToPKColumnEngine(), 
  438.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  439.                 this.getAllarmeFieldConverter(), this, null, updateFields);
  440.     }
  441.     
  442.     @Override
  443.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAllarme id, IExpression condition, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  444.         
  445.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  446.                 this.getAllarmeFieldConverter().toTable(Allarme.model()), 
  447.                 this.getMapTableToPKColumnEngine(), 
  448.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  449.                 this.getAllarmeFieldConverter(), this, condition, updateFields);
  450.     }
  451.     
  452.     @Override
  453.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAllarme id, UpdateModel ... updateModels) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  454.         
  455.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  456.                 this.getAllarmeFieldConverter().toTable(Allarme.model()), 
  457.                 this.getMapTableToPKColumnEngine(), 
  458.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  459.                 this.getAllarmeFieldConverter(), this, updateModels);
  460.     }   
  461.     
  462.     @Override
  463.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  464.         java.util.List<Object> ids = new java.util.ArrayList<>();
  465.         ids.add(tableId);
  466.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  467.                 this.getAllarmeFieldConverter().toTable(Allarme.model()), 
  468.                 this.getMapTableToPKColumnEngine(), 
  469.                 ids,
  470.                 this.getAllarmeFieldConverter(), this, null, updateFields);
  471.     }
  472.     
  473.     @Override
  474.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, IExpression condition, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  475.         java.util.List<Object> ids = new java.util.ArrayList<>();
  476.         ids.add(tableId);
  477.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  478.                 this.getAllarmeFieldConverter().toTable(Allarme.model()), 
  479.                 this.getMapTableToPKColumnEngine(), 
  480.                 ids,
  481.                 this.getAllarmeFieldConverter(), this, condition, updateFields);
  482.     }
  483.     
  484.     @Override
  485.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, UpdateModel ... updateModels) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  486.         java.util.List<Object> ids = new java.util.ArrayList<>();
  487.         ids.add(tableId);
  488.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  489.                 this.getAllarmeFieldConverter().toTable(Allarme.model()), 
  490.                 this.getMapTableToPKColumnEngine(), 
  491.                 ids,
  492.                 this.getAllarmeFieldConverter(), this, updateModels);
  493.     }
  494.     
  495.     @Override
  496.     public void updateOrCreate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAllarme oldId, Allarme allarme, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {
  497.     
  498.         if(this.exists(jdbcProperties, log, connection, sqlQueryObject, oldId)) {
  499.             this.update(jdbcProperties, log, connection, sqlQueryObject, oldId, allarme,idMappingResolutionBehaviour);
  500.         } else {
  501.             this.create(jdbcProperties, log, connection, sqlQueryObject, allarme,idMappingResolutionBehaviour);
  502.         }
  503.         
  504.     }
  505.     
  506.     @Override
  507.     public void updateOrCreate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, Allarme allarme, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {
  508.         if(this.exists(jdbcProperties, log, connection, sqlQueryObject, tableId)) {
  509.             this.update(jdbcProperties, log, connection, sqlQueryObject, tableId, allarme,idMappingResolutionBehaviour);
  510.         } else {
  511.             this.create(jdbcProperties, log, connection, sqlQueryObject, allarme,idMappingResolutionBehaviour);
  512.         }
  513.     }
  514.     
  515.     @Override
  516.     public void delete(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Allarme allarme) throws NotImplementedException,ServiceException,Exception {
  517.         
  518.         
  519.         Long longId = null;
  520.         if( (allarme.getId()!=null) && (allarme.getId()>0) ){
  521.             longId = allarme.getId();
  522.         }
  523.         else{
  524.             IdAllarme idAllarme = this.convertToId(jdbcProperties,log,connection,sqlQueryObject,allarme);
  525.             longId = this.findIdAllarme(jdbcProperties,log,connection,sqlQueryObject,idAllarme,false);
  526.             if(longId == null){
  527.                 return; // entry not exists
  528.             }
  529.         }       
  530.         
  531.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, longId);
  532.         
  533.     }

  535.     private void deleteEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long id) throws NotImplementedException,ServiceException,Exception {
  536.     
  537.         if(id==null){
  538.             throw new ServiceException("Id is null");
  539.         }
  540.         if(id!=null && id.longValue()<=0){
  541.             throw new ServiceException("Id is less equals 0");
  542.         }
  543.         
  544.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  545.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  546.         
  547.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObject.newSQLQueryObject();
  548.         

  550.         //Recupero oggetto _allarmeParametro
  551.         ISQLQueryObject sqlQueryObjectDelete_allarmeParametrogetEngineToDelete = sqlQueryObjectDelete.newSQLQueryObject();
  552.         sqlQueryObjectDelete_allarmeParametrogetEngineToDelete.setANDLogicOperator(true);
  553.         sqlQueryObjectDelete_allarmeParametrogetEngineToDelete.addFromTable(this.getAllarmeFieldConverter().toTable(Allarme.model().ALLARME_PARAMETRO));
  554.         sqlQueryObjectDelete_allarmeParametrogetEngineToDelete.addWhereCondition("id_allarme=?");
  555.         java.util.List<Object> allarme_allarmeParametro_toDelete_list = (java.util.List<Object>) jdbcUtilities.executeQuery(sqlQueryObjectDelete_allarmeParametrogetEngineToDelete.createSQLQuery(), jdbcProperties.isShowSql(), Allarme.model().ALLARME_PARAMETRO, this.getAllarmeFetch(),
  556.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(id,Long.class));

  558.         // for allarme_allarmeParametro
  559.         for (Object allarme_allarmeParametro_object : allarme_allarmeParametro_toDelete_list) {
  560.             AllarmeParametro allarme_allarmeParametro = (AllarmeParametro) allarme_allarmeParametro_object;

  562.             // Object allarme_allarmeParametro
  563.             ISQLQueryObject sqlQueryObjectDelete_allarmeParametro = sqlQueryObjectDelete.newSQLQueryObject();
  564.             sqlQueryObjectDelete_allarmeParametro.setANDLogicOperator(true);
  565.             sqlQueryObjectDelete_allarmeParametro.addDeleteTable(this.getAllarmeFieldConverter().toTable(Allarme.model().ALLARME_PARAMETRO));
  566.             sqlQueryObjectDelete_allarmeParametro.addWhereCondition("chk_param_id=?");

  568.             // Delete allarme_allarmeParametro
  569.             if(allarme_allarmeParametro != null){
  570.                 jdbcUtilities.execute(sqlQueryObjectDelete_allarmeParametro.createSQLDelete(), jdbcProperties.isShowSql(), 
  571.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(allarme_allarmeParametro.getId(),Long.class));
  572.             }
  573.         } // fine for allarme_allarmeParametro

  575.         // Object allarme
  576.         sqlQueryObjectDelete.setANDLogicOperator(true);
  577.         sqlQueryObjectDelete.addDeleteTable(this.getAllarmeFieldConverter().toTable(Allarme.model()));
  578.         if(id != null)
  579.             sqlQueryObjectDelete.addWhereCondition("id=?");

  581.         
  582.         // Delete history
  583.         @SuppressWarnings("unchecked")
  584.         IDBServiceUtilities<AllarmeHistory> dbHistoryServiceUtilities = (IDBServiceUtilities<AllarmeHistory>) this.getServiceManager().getAllarmeHistoryServiceSearch();
  585.         
  586.         ISQLQueryObject sqlQueryObjectDelete_allarmeHistorydeleteEngine = sqlQueryObjectDelete.newSQLQueryObject();
  587.         sqlQueryObjectDelete_allarmeHistorydeleteEngine.setANDLogicOperator(true);
  588.         sqlQueryObjectDelete_allarmeHistorydeleteEngine.addDeleteTable(dbHistoryServiceUtilities.getFieldConverter().toTable(AllarmeHistory.model()));
  589.         sqlQueryObjectDelete_allarmeHistorydeleteEngine.addWhereCondition("id_allarme=?");
  590.         jdbcUtilities.execute(sqlQueryObjectDelete_allarmeHistorydeleteEngine.createSQLDelete(), jdbcProperties.isShowSql(), 
  591.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(id,Long.class));
  592.                 

  594.         
  595.         // Delete notifiche
  596.         @SuppressWarnings("unchecked")
  597.         IDBServiceUtilities<AllarmeNotifica> dbNotificaServiceUtilities = (IDBServiceUtilities<AllarmeNotifica>) this.getServiceManager().getAllarmeNotificaServiceSearch();
  598.         
  599.         ISQLQueryObject sqlQueryObjectDelete_allarmeNotificadeleteEngine = sqlQueryObjectDelete.newSQLQueryObject();
  600.         sqlQueryObjectDelete_allarmeNotificadeleteEngine.setANDLogicOperator(true);
  601.         sqlQueryObjectDelete_allarmeNotificadeleteEngine.addDeleteTable(dbNotificaServiceUtilities.getFieldConverter().toTable(AllarmeNotifica.model()));
  602.         sqlQueryObjectDelete_allarmeNotificadeleteEngine.addWhereCondition("id_allarme=?");
  603.         jdbcUtilities.execute(sqlQueryObjectDelete_allarmeNotificadeleteEngine.createSQLDelete(), jdbcProperties.isShowSql(), 
  604.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(id,Long.class));
  605.         
  606.         
  607.         
  608.         // Delete allarme
  609.         jdbcUtilities.execute(sqlQueryObjectDelete.createSQLDelete(), jdbcProperties.isShowSql(), 
  610.             new JDBCObject(id,Long.class));

  612.     }

  614.     @Override
  615.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAllarme idAllarme) throws NotImplementedException,ServiceException,Exception {

  617.         Long id = null;
  618.         try{
  619.             id = this.findIdAllarme(jdbcProperties, log, connection, sqlQueryObject, idAllarme, true);
  620.         }catch(NotFoundException notFound){
  621.             return;
  622.         }
  623.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  624.         
  625.     }
  626.     
  627.     @Override
  628.     public NonNegativeNumber deleteAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject) throws NotImplementedException,ServiceException,Exception {
  629.         
  630.         return this.deleteAll(jdbcProperties, log, connection, sqlQueryObject, new JDBCExpression(this.getAllarmeFieldConverter()));

  632.     }

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

  637.         java.util.List<Long> lst = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, new JDBCPaginatedExpression(expression));
  638.         
  639.         for(Long id : lst) {
  640.             this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  641.         }
  642.         
  643.         return new NonNegativeNumber(lst.size());
  644.     
  645.     }



  649.     // -- DB
  650.     
  651.     @Override
  652.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws ServiceException, NotImplementedException, Exception {
  653.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  654.     }
  655.     
  656.     @Override
  657.     public int nativeUpdate(JDBCServiceManagerProperties jdbcProperties, Logger log,Connection connection,ISQLQueryObject sqlObject, String sql,Object ... param) throws ServiceException,NotImplementedException, Exception {
  658.     
  659.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeUpdate(jdbcProperties, log, connection, sqlObject,
  660.                                                                                             sql,param);
  661.     
  662.     }
  663. }
Created with JaCoCo 0.8.8.202204050719