JDBCAttivazionePolicyServiceImpl.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.controllo_traffico.dao.jdbc;

  22. import java.sql.Connection;

  24. import org.openspcoop2.utils.date.DateManager;
  25. import org.openspcoop2.utils.sql.ISQLQueryObject;

  27. import org.slf4j.Logger;

  29. import org.openspcoop2.generic_project.dao.jdbc.IJDBCServiceCRUDWithId;
  30. import org.openspcoop2.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;
  44. import org.openspcoop2.core.controllo_traffico.AttivazionePolicy;
  45. import org.openspcoop2.core.controllo_traffico.AttivazionePolicyFiltro;
  46. import org.openspcoop2.core.controllo_traffico.AttivazionePolicyRaggruppamento;
  47. import org.openspcoop2.core.controllo_traffico.IdActivePolicy;

  49. /**     
  50.  * JDBCAttivazionePolicyServiceImpl
  51.  *
  52.  * @author Poli Andrea (poli@link.it)
  53.  * @author $Author$
  54.  * @version $Rev$, $Date$
  55.  */
  56. public class JDBCAttivazionePolicyServiceImpl extends JDBCAttivazionePolicyServiceSearchImpl
  57.     implements IJDBCServiceCRUDWithId<AttivazionePolicy, IdActivePolicy, JDBCServiceManager> {

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

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

  69.         // Object attivazionePolicy
  70.         sqlQueryObjectInsert.addInsertTable(this.getAttivazionePolicyFieldConverter().toTable(AttivazionePolicy.model()));
  71.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ID_ACTIVE_POLICY,false),"?");
  72.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ALIAS,false),"?");
  73.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().UPDATE_TIME,false),"?");
  74.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().POSIZIONE,false),"?");
  75.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().CONTINUA_VALUTAZIONE,false),"?");
  76.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ID_POLICY,false),"?");
  77.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ENABLED,false),"?");
  78.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().WARNING_ONLY,false),"?");
  79.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().RIDEFINISCI,false),"?");
  80.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().VALORE,false),"?");
  81.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().VALORE_2,false),"?");
  82.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.ENABLED,false),"?");
  83.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.PROTOCOLLO,false),"?");
  84.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.RUOLO_PORTA,false),"?");
  85.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.NOME_PORTA,false),"?");
  86.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.TIPO_FRUITORE,false),"?");
  87.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.NOME_FRUITORE,false),"?");
  88.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.RUOLO_FRUITORE,false),"?");
  89.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.SERVIZIO_APPLICATIVO_FRUITORE,false),"?");
  90.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.TIPO_EROGATORE,false),"?");
  91.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.NOME_EROGATORE,false),"?");
  92.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.RUOLO_EROGATORE,false),"?");
  93.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.SERVIZIO_APPLICATIVO_EROGATORE,false),"?");
  94.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.TAG,false),"?");
  95.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.TIPO_SERVIZIO,false),"?");
  96.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.NOME_SERVIZIO,false),"?");
  97.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.VERSIONE_SERVIZIO,false),"?");
  98.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.AZIONE,false),"?");
  99.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.TOKEN_CLAIMS,false),"?");
  100.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_ENABLED,false),"?");
  101.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_TIPO,false),"?");
  102.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_NOME,false),"?");
  103.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_VALORE,false),"?");
  104.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.ENABLED,false),"?");
  105.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.RUOLO_PORTA,false),"?");
  106.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.PROTOCOLLO,false),"?");
  107.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.FRUITORE,false),"?");
  108.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.SERVIZIO_APPLICATIVO_FRUITORE,false),"?");
  109.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.IDENTIFICATIVO_AUTENTICATO,false),"?");
  110.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.TOKEN,false),"?");
  111.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.EROGATORE,false),"?");
  112.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.SERVIZIO_APPLICATIVO_EROGATORE,false),"?");
  113.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.SERVIZIO,false),"?");
  114.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.AZIONE,false),"?");
  115.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_ENABLED,false),"?");
  116.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_TIPO,false),"?");
  117.         sqlQueryObjectInsert.addInsertField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_NOME,false),"?");

  119.         // Insert attivazionePolicy
  120.         org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator = this.getAttivazionePolicyFetch().getKeyGeneratorObject(AttivazionePolicy.model());
  121.         long id = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert, keyGenerator, jdbcProperties.isShowSql(),
  122.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getIdActivePolicy(),AttivazionePolicy.model().ID_ACTIVE_POLICY.getFieldType()),
  123.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getAlias(),AttivazionePolicy.model().ALIAS.getFieldType()),
  124.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getUpdateTime(),AttivazionePolicy.model().UPDATE_TIME.getFieldType()),
  125.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getPosizione(),AttivazionePolicy.model().POSIZIONE.getFieldType()),
  126.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getContinuaValutazione(),AttivazionePolicy.model().CONTINUA_VALUTAZIONE.getFieldType()),
  127.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getIdPolicy(),AttivazionePolicy.model().ID_POLICY.getFieldType()),
  128.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getEnabled(),AttivazionePolicy.model().ENABLED.getFieldType()),
  129.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getWarningOnly(),AttivazionePolicy.model().WARNING_ONLY.getFieldType()),
  130.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getRidefinisci(),AttivazionePolicy.model().RIDEFINISCI.getFieldType()),
  131.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getValore(),AttivazionePolicy.model().VALORE.getFieldType()),
  132.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getValore2(),AttivazionePolicy.model().VALORE_2.getFieldType()),
  133.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getEnabled(),AttivazionePolicy.model().FILTRO.ENABLED.getFieldType()),
  134.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getProtocollo(),AttivazionePolicy.model().FILTRO.PROTOCOLLO.getFieldType()),
  135.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getRuoloPorta(),AttivazionePolicy.model().FILTRO.RUOLO_PORTA.getFieldType()),
  136.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getNomePorta(),AttivazionePolicy.model().FILTRO.NOME_PORTA.getFieldType()),
  137.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getTipoFruitore(),AttivazionePolicy.model().FILTRO.TIPO_FRUITORE.getFieldType()),
  138.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getNomeFruitore(),AttivazionePolicy.model().FILTRO.NOME_FRUITORE.getFieldType()),
  139.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getRuoloFruitore(),AttivazionePolicy.model().FILTRO.RUOLO_FRUITORE.getFieldType()),
  140.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getServizioApplicativoFruitore(),AttivazionePolicy.model().FILTRO.SERVIZIO_APPLICATIVO_FRUITORE.getFieldType()),
  141.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getTipoErogatore(),AttivazionePolicy.model().FILTRO.TIPO_EROGATORE.getFieldType()),
  142.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getNomeErogatore(),AttivazionePolicy.model().FILTRO.NOME_EROGATORE.getFieldType()),
  143.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getRuoloErogatore(),AttivazionePolicy.model().FILTRO.RUOLO_EROGATORE.getFieldType()),
  144.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getServizioApplicativoErogatore(),AttivazionePolicy.model().FILTRO.SERVIZIO_APPLICATIVO_EROGATORE.getFieldType()),
  145.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getTag(),AttivazionePolicy.model().FILTRO.TAG.getFieldType()),
  146.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getTipoServizio(),AttivazionePolicy.model().FILTRO.TIPO_SERVIZIO.getFieldType()),
  147.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getNomeServizio(),AttivazionePolicy.model().FILTRO.NOME_SERVIZIO.getFieldType()),
  148.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getVersioneServizio(),AttivazionePolicy.model().FILTRO.VERSIONE_SERVIZIO.getFieldType()),
  149.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getAzione(),AttivazionePolicy.model().FILTRO.AZIONE.getFieldType()),
  150.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getTokenClaims(),AttivazionePolicy.model().FILTRO.TOKEN_CLAIMS.getFieldType()),
  151.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getInformazioneApplicativaEnabled(),AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_ENABLED.getFieldType()),
  152.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getInformazioneApplicativaTipo(),AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_TIPO.getFieldType()),
  153.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getInformazioneApplicativaNome(),AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_NOME.getFieldType()),
  154.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getFiltro().getInformazioneApplicativaValore(),AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_VALORE.getFieldType()),
  155.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getGroupBy().getEnabled(),AttivazionePolicy.model().GROUP_BY.ENABLED.getFieldType()),
  156.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getGroupBy().getRuoloPorta(),AttivazionePolicy.model().GROUP_BY.RUOLO_PORTA.getFieldType()),
  157.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getGroupBy().getProtocollo(),AttivazionePolicy.model().GROUP_BY.PROTOCOLLO.getFieldType()),
  158.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getGroupBy().getFruitore(),AttivazionePolicy.model().GROUP_BY.FRUITORE.getFieldType()),
  159.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getGroupBy().getServizioApplicativoFruitore(),AttivazionePolicy.model().GROUP_BY.SERVIZIO_APPLICATIVO_FRUITORE.getFieldType()),
  160.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getGroupBy().getIdentificativoAutenticato(),AttivazionePolicy.model().GROUP_BY.IDENTIFICATIVO_AUTENTICATO.getFieldType()),
  161.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getGroupBy().getToken(),AttivazionePolicy.model().GROUP_BY.TOKEN.getFieldType()),
  162.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getGroupBy().getErogatore(),AttivazionePolicy.model().GROUP_BY.EROGATORE.getFieldType()),
  163.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getGroupBy().getServizioApplicativoErogatore(),AttivazionePolicy.model().GROUP_BY.SERVIZIO_APPLICATIVO_EROGATORE.getFieldType()),
  164.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getGroupBy().getServizio(),AttivazionePolicy.model().GROUP_BY.SERVIZIO.getFieldType()),
  165.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getGroupBy().getAzione(),AttivazionePolicy.model().GROUP_BY.AZIONE.getFieldType()),
  166.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getGroupBy().getInformazioneApplicativaEnabled(),AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_ENABLED.getFieldType()),
  167.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getGroupBy().getInformazioneApplicativaTipo(),AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_TIPO.getFieldType()),
  168.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(attivazionePolicy.getGroupBy().getInformazioneApplicativaNome(),AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_NOME.getFieldType())
  169.         );
  170.         attivazionePolicy.setId(id);

  172.         
  173.     }

  175.     @Override
  176.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdActivePolicy oldId, AttivazionePolicy attivazionePolicy, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  177.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObject.newSQLQueryObject();
  178.         Long longIdByLogicId = this.findIdAttivazionePolicy(jdbcProperties, log, connection, sqlQueryObjectUpdate.newSQLQueryObject(), oldId, true);
  179.         Long tableId = attivazionePolicy.getId();
  180.         if(tableId != null && tableId.longValue() > 0) {
  181.             if(tableId.longValue() != longIdByLogicId.longValue()) {
  182.                 throw new Exception("Ambiguous parameter: attivazionePolicy.id ["+tableId+"] does not match logic id ["+longIdByLogicId+"]");
  183.             }
  184.         } else {
  185.             tableId = longIdByLogicId;
  186.             attivazionePolicy.setId(tableId);
  187.         }
  188.         if(tableId==null || tableId<=0){
  189.             throw new Exception("Retrieve tableId failed");
  190.         }

  192.         this.update(jdbcProperties, log, connection, sqlQueryObject, tableId, attivazionePolicy, idMappingResolutionBehaviour);
  193.     }
  194.     @Override
  195.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, AttivazionePolicy attivazionePolicy, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  196.     
  197.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  198.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  199.         
  200.         ISQLQueryObject sqlQueryObjectInsert = sqlQueryObject.newSQLQueryObject();
  201.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObjectInsert.newSQLQueryObject();
  202.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObjectDelete.newSQLQueryObject();
  203.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObjectGet.newSQLQueryObject();
  204.         

  206.         // Check se è avvenuto effettivamente un aggiornamento
  207.         AttivazionePolicy attivazioneLettoDaDB = this.get(jdbcProperties, log, connection, sqlQueryObjectUpdate, tableId, idMappingResolutionBehaviour);
  208.         if(attivazioneLettoDaDB.equals(attivazionePolicy)){
  209.             log.debug("Non sono state apportate differenze");
  210.             return;
  211.         }
  212.         else{
  213.             StringBuilder bf = new StringBuilder();
  214.             attivazioneLettoDaDB.diff(attivazionePolicy, bf);
  215.             log.debug("Esistono differenze: "+bf.toString());
  216.             attivazionePolicy.setUpdateTime(DateManager.getDate());
  217.         }
  218.         
  219.         // Object attivazionePolicy
  220.         sqlQueryObjectUpdate.setANDLogicOperator(true);
  221.         sqlQueryObjectUpdate.addUpdateTable(this.getAttivazionePolicyFieldConverter().toTable(AttivazionePolicy.model()));
  222.         boolean isUpdate = true;
  223.         java.util.List<JDBCObject> lstObjects = new java.util.ArrayList<>();
  224.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ID_ACTIVE_POLICY,false), "?");
  225.         lstObjects.add(new JDBCObject(attivazionePolicy.getIdActivePolicy(), AttivazionePolicy.model().ID_ACTIVE_POLICY.getFieldType()));
  226.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ALIAS,false), "?");
  227.         lstObjects.add(new JDBCObject(attivazionePolicy.getAlias(), AttivazionePolicy.model().ALIAS.getFieldType()));
  228.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().UPDATE_TIME,false), "?");
  229.         lstObjects.add(new JDBCObject(attivazionePolicy.getUpdateTime(), AttivazionePolicy.model().UPDATE_TIME.getFieldType()));
  230.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().POSIZIONE,false), "?");
  231.         lstObjects.add(new JDBCObject(attivazionePolicy.getPosizione(), AttivazionePolicy.model().POSIZIONE.getFieldType()));
  232.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().CONTINUA_VALUTAZIONE,false), "?");
  233.         lstObjects.add(new JDBCObject(attivazionePolicy.getContinuaValutazione(), AttivazionePolicy.model().CONTINUA_VALUTAZIONE.getFieldType()));
  234.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ID_POLICY,false), "?");
  235.         lstObjects.add(new JDBCObject(attivazionePolicy.getIdPolicy(), AttivazionePolicy.model().ID_POLICY.getFieldType()));
  236.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ENABLED,false), "?");
  237.         lstObjects.add(new JDBCObject(attivazionePolicy.getEnabled(), AttivazionePolicy.model().ENABLED.getFieldType()));
  238.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().WARNING_ONLY,false), "?");
  239.         lstObjects.add(new JDBCObject(attivazionePolicy.getWarningOnly(), AttivazionePolicy.model().WARNING_ONLY.getFieldType()));
  240.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().RIDEFINISCI,false), "?");
  241.         lstObjects.add(new JDBCObject(attivazionePolicy.getRidefinisci(), AttivazionePolicy.model().RIDEFINISCI.getFieldType()));
  242.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().VALORE,false), "?");
  243.         lstObjects.add(new JDBCObject(attivazionePolicy.getValore(), AttivazionePolicy.model().VALORE.getFieldType()));
  244.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().VALORE_2,false), "?");
  245.         lstObjects.add(new JDBCObject(attivazionePolicy.getValore2(), AttivazionePolicy.model().VALORE_2.getFieldType()));
  246.         AttivazionePolicyFiltro attivazionePolicy_filtro = attivazionePolicy.getFiltro();
  247.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.ENABLED,false), "?");
  248.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getEnabled(), AttivazionePolicy.model().FILTRO.ENABLED.getFieldType()));
  249.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.PROTOCOLLO,false), "?");
  250.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getProtocollo(), AttivazionePolicy.model().FILTRO.PROTOCOLLO.getFieldType()));
  251.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.RUOLO_PORTA,false), "?");
  252.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getRuoloPorta(), AttivazionePolicy.model().FILTRO.RUOLO_PORTA.getFieldType()));
  253.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.NOME_PORTA,false), "?");
  254.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getNomePorta(), AttivazionePolicy.model().FILTRO.NOME_PORTA.getFieldType()));
  255.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.TIPO_FRUITORE,false), "?");
  256.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getTipoFruitore(), AttivazionePolicy.model().FILTRO.TIPO_FRUITORE.getFieldType()));
  257.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.NOME_FRUITORE,false), "?");
  258.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getNomeFruitore(), AttivazionePolicy.model().FILTRO.NOME_FRUITORE.getFieldType()));
  259.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.RUOLO_FRUITORE,false), "?");
  260.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getRuoloFruitore(), AttivazionePolicy.model().FILTRO.RUOLO_FRUITORE.getFieldType()));
  261.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.SERVIZIO_APPLICATIVO_FRUITORE,false), "?");
  262.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getServizioApplicativoFruitore(), AttivazionePolicy.model().FILTRO.SERVIZIO_APPLICATIVO_FRUITORE.getFieldType()));
  263.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.TIPO_EROGATORE,false), "?");
  264.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getTipoErogatore(), AttivazionePolicy.model().FILTRO.TIPO_EROGATORE.getFieldType()));
  265.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.NOME_EROGATORE,false), "?");
  266.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getNomeErogatore(), AttivazionePolicy.model().FILTRO.NOME_EROGATORE.getFieldType()));
  267.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.RUOLO_EROGATORE,false), "?");
  268.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getRuoloErogatore(), AttivazionePolicy.model().FILTRO.RUOLO_EROGATORE.getFieldType()));
  269.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.SERVIZIO_APPLICATIVO_EROGATORE,false), "?");
  270.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getServizioApplicativoErogatore(), AttivazionePolicy.model().FILTRO.SERVIZIO_APPLICATIVO_EROGATORE.getFieldType()));
  271.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.TAG,false), "?");
  272.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getTag(), AttivazionePolicy.model().FILTRO.TAG.getFieldType()));
  273.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.TIPO_SERVIZIO,false), "?");
  274.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getTipoServizio(), AttivazionePolicy.model().FILTRO.TIPO_SERVIZIO.getFieldType()));
  275.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.NOME_SERVIZIO,false), "?");
  276.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getNomeServizio(), AttivazionePolicy.model().FILTRO.NOME_SERVIZIO.getFieldType()));
  277.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.VERSIONE_SERVIZIO,false), "?");
  278.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getVersioneServizio(), AttivazionePolicy.model().FILTRO.VERSIONE_SERVIZIO.getFieldType()));
  279.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.AZIONE,false), "?");
  280.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getAzione(), AttivazionePolicy.model().FILTRO.AZIONE.getFieldType()));
  281.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.TOKEN_CLAIMS,false), "?");
  282.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getTokenClaims(), AttivazionePolicy.model().FILTRO.TOKEN_CLAIMS.getFieldType()));
  283.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_ENABLED,false), "?");
  284.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getInformazioneApplicativaEnabled(), AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_ENABLED.getFieldType()));
  285.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_TIPO,false), "?");
  286.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getInformazioneApplicativaTipo(), AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_TIPO.getFieldType()));
  287.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_NOME,false), "?");
  288.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getInformazioneApplicativaNome(), AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_NOME.getFieldType()));
  289.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_VALORE,false), "?");
  290.         lstObjects.add(new JDBCObject(attivazionePolicy_filtro.getInformazioneApplicativaValore(), AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_VALORE.getFieldType()));
  291.         AttivazionePolicyRaggruppamento attivazionePolicy_groupBy = attivazionePolicy.getGroupBy();
  292.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.ENABLED,false), "?");
  293.         lstObjects.add(new JDBCObject(attivazionePolicy_groupBy.getEnabled(), AttivazionePolicy.model().GROUP_BY.ENABLED.getFieldType()));
  294.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.RUOLO_PORTA,false), "?");
  295.         lstObjects.add(new JDBCObject(attivazionePolicy_groupBy.getRuoloPorta(), AttivazionePolicy.model().GROUP_BY.RUOLO_PORTA.getFieldType()));
  296.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.PROTOCOLLO,false), "?");
  297.         lstObjects.add(new JDBCObject(attivazionePolicy_groupBy.getProtocollo(), AttivazionePolicy.model().GROUP_BY.PROTOCOLLO.getFieldType()));
  298.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.FRUITORE,false), "?");
  299.         lstObjects.add(new JDBCObject(attivazionePolicy_groupBy.getFruitore(), AttivazionePolicy.model().GROUP_BY.FRUITORE.getFieldType()));
  300.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.SERVIZIO_APPLICATIVO_FRUITORE,false), "?");
  301.         lstObjects.add(new JDBCObject(attivazionePolicy_groupBy.getServizioApplicativoFruitore(), AttivazionePolicy.model().GROUP_BY.SERVIZIO_APPLICATIVO_FRUITORE.getFieldType()));
  302.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.IDENTIFICATIVO_AUTENTICATO,false), "?");
  303.         lstObjects.add(new JDBCObject(attivazionePolicy_groupBy.getIdentificativoAutenticato(), AttivazionePolicy.model().GROUP_BY.IDENTIFICATIVO_AUTENTICATO.getFieldType()));
  304.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.TOKEN,false), "?");
  305.         lstObjects.add(new JDBCObject(attivazionePolicy_groupBy.getToken(), AttivazionePolicy.model().GROUP_BY.TOKEN.getFieldType()));
  306.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.EROGATORE,false), "?");
  307.         lstObjects.add(new JDBCObject(attivazionePolicy_groupBy.getErogatore(), AttivazionePolicy.model().GROUP_BY.EROGATORE.getFieldType()));
  308.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.SERVIZIO_APPLICATIVO_EROGATORE,false), "?");
  309.         lstObjects.add(new JDBCObject(attivazionePolicy_groupBy.getServizioApplicativoErogatore(), AttivazionePolicy.model().GROUP_BY.SERVIZIO_APPLICATIVO_EROGATORE.getFieldType()));
  310.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.SERVIZIO,false), "?");
  311.         lstObjects.add(new JDBCObject(attivazionePolicy_groupBy.getServizio(), AttivazionePolicy.model().GROUP_BY.SERVIZIO.getFieldType()));
  312.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.AZIONE,false), "?");
  313.         lstObjects.add(new JDBCObject(attivazionePolicy_groupBy.getAzione(), AttivazionePolicy.model().GROUP_BY.AZIONE.getFieldType()));
  314.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_ENABLED,false), "?");
  315.         lstObjects.add(new JDBCObject(attivazionePolicy_groupBy.getInformazioneApplicativaEnabled(), AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_ENABLED.getFieldType()));
  316.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_TIPO,false), "?");
  317.         lstObjects.add(new JDBCObject(attivazionePolicy_groupBy.getInformazioneApplicativaTipo(), AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_TIPO.getFieldType()));
  318.         sqlQueryObjectUpdate.addUpdateField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_NOME,false), "?");
  319.         lstObjects.add(new JDBCObject(attivazionePolicy_groupBy.getInformazioneApplicativaNome(), AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_NOME.getFieldType()));
  320.         sqlQueryObjectUpdate.addWhereCondition("id=?");
  321.         lstObjects.add(new JDBCObject(tableId, Long.class));

  323.         if(isUpdate) {
  324.             // Update attivazionePolicy
  325.             jdbcUtilities.executeUpdate(sqlQueryObjectUpdate.createSQLUpdate(), jdbcProperties.isShowSql(), 
  326.                 lstObjects.toArray(new JDBCObject[]{}));
  327.         }


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

  435.     private void deleteEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long id) throws NotImplementedException,ServiceException,Exception {
  436.     
  437.         if(id!=null && id.longValue()<=0){
  438.             throw new ServiceException("Id is less equals 0");
  439.         }
  440.         
  441.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  442.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  443.         
  444.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObject.newSQLQueryObject();
  445.         

  447.         // Object attivazionePolicy
  448.         sqlQueryObjectDelete.setANDLogicOperator(true);
  449.         sqlQueryObjectDelete.addDeleteTable(this.getAttivazionePolicyFieldConverter().toTable(AttivazionePolicy.model()));
  450.         if(id != null)
  451.             sqlQueryObjectDelete.addWhereCondition("id=?");

  453.         // Delete attivazionePolicy
  454.         jdbcUtilities.execute(sqlQueryObjectDelete.createSQLDelete(), jdbcProperties.isShowSql(), 
  455.             new JDBCObject(id,Long.class));

  457.     }

  459.     @Override
  460.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdActivePolicy idAttivazionePolicy) throws NotImplementedException,ServiceException,Exception {

  462.         Long id = null;
  463.         try{
  464.             id = this.findIdAttivazionePolicy(jdbcProperties, log, connection, sqlQueryObject, idAttivazionePolicy, true);
  465.         }catch(NotFoundException notFound){
  466.             return;
  467.         }
  468.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  469.         
  470.     }
  471.     
  472.     @Override
  473.     public NonNegativeNumber deleteAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject) throws NotImplementedException,ServiceException,Exception {
  474.         
  475.         return this.deleteAll(jdbcProperties, log, connection, sqlQueryObject, new JDBCExpression(this.getAttivazionePolicyFieldConverter()));

  477.     }

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

  482.         java.util.List<Long> lst = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, new JDBCPaginatedExpression(expression));
  483.         
  484.         for(Long id : lst) {
  485.             this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  486.         }
  487.         
  488.         return new NonNegativeNumber(lst.size());
  489.     
  490.     }



  494.     // -- DB
  495.     
  496.     @Override
  497.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws ServiceException, NotImplementedException, Exception {
  498.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  499.     }
  500.     
  501.     @Override
  502.     public int nativeUpdate(JDBCServiceManagerProperties jdbcProperties, Logger log,Connection connection,ISQLQueryObject sqlObject, String sql,Object ... param) throws ServiceException,NotImplementedException, Exception {
  503.     
  504.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeUpdate(jdbcProperties, log, connection, sqlObject,
  505.                                                                                             sql,param);
  506.     
  507.     }
  508. }
Created with JaCoCo 0.8.8.202204050719