JDBCConfigurazioneFiltroServiceImpl.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.plugins.dao.jdbc;

  22. import java.sql.Connection;

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

  26. import org.slf4j.Logger;

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

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

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

  45. import org.openspcoop2.core.plugins.ConfigurazioneFiltro;

  47. /**     
  48.  * JDBCConfigurazioneFiltroServiceImpl
  49.  *
  50.  * @author Poli Andrea (poli@link.it)
  51.  * @author $Author$
  52.  * @version $Rev$, $Date$
  53.  */
  54. public class JDBCConfigurazioneFiltroServiceImpl extends JDBCConfigurazioneFiltroServiceSearchImpl
  55.     implements IJDBCServiceCRUDWithId<ConfigurazioneFiltro, IdConfigurazioneFiltro, JDBCServiceManager> {

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

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


  67.         // Object configurazioneFiltro
  68.         sqlQueryObjectInsert.addInsertTable(this.getConfigurazioneFiltroFieldConverter().toTable(ConfigurazioneFiltro.model()));
  69.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().NOME,false),"?");
  70.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().DESCRIZIONE,false),"?");
  71.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().TIPO_MITTENTE,false),"?");
  72.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().NOME_MITTENTE,false),"?");
  73.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().IDPORTA_MITTENTE,false),"?");
  74.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().TIPO_DESTINATARIO,false),"?");
  75.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().NOME_DESTINATARIO,false),"?");
  76.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().IDPORTA_DESTINATARIO,false),"?");
  77.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().TIPO_SERVIZIO,false),"?");
  78.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().NOME_SERVIZIO,false),"?");
  79.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().VERSIONE_SERVIZIO,false),"?");
  80.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().AZIONE,false),"?");

  82.         // Insert configurazioneFiltro
  83.         org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator = this.getConfigurazioneFiltroFetch().getKeyGeneratorObject(ConfigurazioneFiltro.model());
  84.         long id = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert, keyGenerator, jdbcProperties.isShowSql(),
  85.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneFiltro.getNome(),ConfigurazioneFiltro.model().NOME.getFieldType()),
  86.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneFiltro.getDescrizione(),ConfigurazioneFiltro.model().DESCRIZIONE.getFieldType()),
  87.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneFiltro.getTipoMittente(),ConfigurazioneFiltro.model().TIPO_MITTENTE.getFieldType()),
  88.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneFiltro.getNomeMittente(),ConfigurazioneFiltro.model().NOME_MITTENTE.getFieldType()),
  89.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneFiltro.getIdportaMittente(),ConfigurazioneFiltro.model().IDPORTA_MITTENTE.getFieldType()),
  90.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneFiltro.getTipoDestinatario(),ConfigurazioneFiltro.model().TIPO_DESTINATARIO.getFieldType()),
  91.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneFiltro.getNomeDestinatario(),ConfigurazioneFiltro.model().NOME_DESTINATARIO.getFieldType()),
  92.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneFiltro.getIdportaDestinatario(),ConfigurazioneFiltro.model().IDPORTA_DESTINATARIO.getFieldType()),
  93.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneFiltro.getTipoServizio(),ConfigurazioneFiltro.model().TIPO_SERVIZIO.getFieldType()),
  94.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneFiltro.getNomeServizio(),ConfigurazioneFiltro.model().NOME_SERVIZIO.getFieldType()),
  95.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneFiltro.getVersioneServizio(),ConfigurazioneFiltro.model().VERSIONE_SERVIZIO.getFieldType()),
  96.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneFiltro.getAzione(),ConfigurazioneFiltro.model().AZIONE.getFieldType())
  97.         );
  98.         configurazioneFiltro.setId(id);

  100.         
  101.     }

  103.     @Override
  104.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneFiltro oldId, ConfigurazioneFiltro configurazioneFiltro, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  105.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObject.newSQLQueryObject();
  106.         Long longIdByLogicId = this.findIdConfigurazioneFiltro(jdbcProperties, log, connection, sqlQueryObjectUpdate.newSQLQueryObject(), oldId, true);
  107.         Long tableId = configurazioneFiltro.getId();
  108.         if(tableId != null && tableId.longValue() > 0) {
  109.             if(tableId.longValue() != longIdByLogicId.longValue()) {
  110.                 throw new Exception("Ambiguous parameter: configurazioneFiltro.id ["+tableId+"] does not match logic id ["+longIdByLogicId+"]");
  111.             }
  112.         } else {
  113.             tableId = longIdByLogicId;
  114.             configurazioneFiltro.setId(tableId);
  115.         }
  116.         if(tableId==null || tableId<=0){
  117.             throw new Exception("Retrieve tableId failed");
  118.         }

  120.         this.update(jdbcProperties, log, connection, sqlQueryObject, tableId, configurazioneFiltro, idMappingResolutionBehaviour);
  121.     }
  122.     @Override
  123.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, ConfigurazioneFiltro configurazioneFiltro, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  124.     
  125.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  126.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  127.         
  128.         ISQLQueryObject sqlQueryObjectInsert = sqlQueryObject.newSQLQueryObject();
  129.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObjectInsert.newSQLQueryObject();
  130.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObjectDelete.newSQLQueryObject();
  131.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObjectGet.newSQLQueryObject();
  132.         
  133.         @SuppressWarnings("unused")
  134.         boolean setIdMappingResolutionBehaviour = 
  135.             (idMappingResolutionBehaviour==null) ||
  136.             org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour) ||
  137.             org.openspcoop2.generic_project.beans.IDMappingBehaviour.USE_TABLE_ID.equals(idMappingResolutionBehaviour);
  138.             


  141.         // Object configurazioneFiltro
  142.         sqlQueryObjectUpdate.setANDLogicOperator(true);
  143.         sqlQueryObjectUpdate.addUpdateTable(this.getConfigurazioneFiltroFieldConverter().toTable(ConfigurazioneFiltro.model()));
  144.         boolean isUpdate_configurazioneFiltro = true;
  145.         java.util.List<JDBCObject> lstObjects_configurazioneFiltro = new java.util.ArrayList<>();
  146.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().NOME,false), "?");
  147.         lstObjects_configurazioneFiltro.add(new JDBCObject(configurazioneFiltro.getNome(), ConfigurazioneFiltro.model().NOME.getFieldType()));
  148.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().DESCRIZIONE,false), "?");
  149.         lstObjects_configurazioneFiltro.add(new JDBCObject(configurazioneFiltro.getDescrizione(), ConfigurazioneFiltro.model().DESCRIZIONE.getFieldType()));
  150.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().TIPO_MITTENTE,false), "?");
  151.         lstObjects_configurazioneFiltro.add(new JDBCObject(configurazioneFiltro.getTipoMittente(), ConfigurazioneFiltro.model().TIPO_MITTENTE.getFieldType()));
  152.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().NOME_MITTENTE,false), "?");
  153.         lstObjects_configurazioneFiltro.add(new JDBCObject(configurazioneFiltro.getNomeMittente(), ConfigurazioneFiltro.model().NOME_MITTENTE.getFieldType()));
  154.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().IDPORTA_MITTENTE,false), "?");
  155.         lstObjects_configurazioneFiltro.add(new JDBCObject(configurazioneFiltro.getIdportaMittente(), ConfigurazioneFiltro.model().IDPORTA_MITTENTE.getFieldType()));
  156.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().TIPO_DESTINATARIO,false), "?");
  157.         lstObjects_configurazioneFiltro.add(new JDBCObject(configurazioneFiltro.getTipoDestinatario(), ConfigurazioneFiltro.model().TIPO_DESTINATARIO.getFieldType()));
  158.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().NOME_DESTINATARIO,false), "?");
  159.         lstObjects_configurazioneFiltro.add(new JDBCObject(configurazioneFiltro.getNomeDestinatario(), ConfigurazioneFiltro.model().NOME_DESTINATARIO.getFieldType()));
  160.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().IDPORTA_DESTINATARIO,false), "?");
  161.         lstObjects_configurazioneFiltro.add(new JDBCObject(configurazioneFiltro.getIdportaDestinatario(), ConfigurazioneFiltro.model().IDPORTA_DESTINATARIO.getFieldType()));
  162.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().TIPO_SERVIZIO,false), "?");
  163.         lstObjects_configurazioneFiltro.add(new JDBCObject(configurazioneFiltro.getTipoServizio(), ConfigurazioneFiltro.model().TIPO_SERVIZIO.getFieldType()));
  164.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().NOME_SERVIZIO,false), "?");
  165.         lstObjects_configurazioneFiltro.add(new JDBCObject(configurazioneFiltro.getNomeServizio(), ConfigurazioneFiltro.model().NOME_SERVIZIO.getFieldType()));
  166.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().VERSIONE_SERVIZIO,false), "?");
  167.         lstObjects_configurazioneFiltro.add(new JDBCObject(configurazioneFiltro.getVersioneServizio(), ConfigurazioneFiltro.model().VERSIONE_SERVIZIO.getFieldType()));
  168.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneFiltroFieldConverter().toColumn(ConfigurazioneFiltro.model().AZIONE,false), "?");
  169.         lstObjects_configurazioneFiltro.add(new JDBCObject(configurazioneFiltro.getAzione(), ConfigurazioneFiltro.model().AZIONE.getFieldType()));
  170.         sqlQueryObjectUpdate.addWhereCondition("id=?");
  171.         lstObjects_configurazioneFiltro.add(new JDBCObject(tableId, Long.class));

  173.         if(isUpdate_configurazioneFiltro) {
  174.             // Update configurazioneFiltro
  175.             jdbcUtilities.executeUpdate(sqlQueryObjectUpdate.createSQLUpdate(), jdbcProperties.isShowSql(), 
  176.                 lstObjects_configurazioneFiltro.toArray(new JDBCObject[]{}));
  177.         }


  180.     }
  181.     
  182.     @Override
  183.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneFiltro id, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  184.         
  185.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  186.                 this.getConfigurazioneFiltroFieldConverter().toTable(ConfigurazioneFiltro.model()), 
  187.                 this.getMapTableToPKColumnEngine(), 
  188.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  189.                 this.getConfigurazioneFiltroFieldConverter(), this, null, updateFields);
  190.     }
  191.     
  192.     @Override
  193.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneFiltro id, IExpression condition, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  194.         
  195.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  196.                 this.getConfigurazioneFiltroFieldConverter().toTable(ConfigurazioneFiltro.model()), 
  197.                 this.getMapTableToPKColumnEngine(), 
  198.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  199.                 this.getConfigurazioneFiltroFieldConverter(), this, condition, updateFields);
  200.     }
  201.     
  202.     @Override
  203.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneFiltro id, UpdateModel ... updateModels) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  204.         
  205.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  206.                 this.getConfigurazioneFiltroFieldConverter().toTable(ConfigurazioneFiltro.model()), 
  207.                 this.getMapTableToPKColumnEngine(), 
  208.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  209.                 this.getConfigurazioneFiltroFieldConverter(), this, updateModels);
  210.     }   
  211.     
  212.     @Override
  213.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  214.         java.util.List<Object> ids = new java.util.ArrayList<>();
  215.         ids.add(tableId);
  216.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  217.                 this.getConfigurazioneFiltroFieldConverter().toTable(ConfigurazioneFiltro.model()), 
  218.                 this.getMapTableToPKColumnEngine(), 
  219.                 ids,
  220.                 this.getConfigurazioneFiltroFieldConverter(), this, null, updateFields);
  221.     }
  222.     
  223.     @Override
  224.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, IExpression condition, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  225.         java.util.List<Object> ids = new java.util.ArrayList<>();
  226.         ids.add(tableId);
  227.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  228.                 this.getConfigurazioneFiltroFieldConverter().toTable(ConfigurazioneFiltro.model()), 
  229.                 this.getMapTableToPKColumnEngine(), 
  230.                 ids,
  231.                 this.getConfigurazioneFiltroFieldConverter(), this, condition, updateFields);
  232.     }
  233.     
  234.     @Override
  235.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, UpdateModel ... updateModels) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  236.         java.util.List<Object> ids = new java.util.ArrayList<>();
  237.         ids.add(tableId);
  238.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  239.                 this.getConfigurazioneFiltroFieldConverter().toTable(ConfigurazioneFiltro.model()), 
  240.                 this.getMapTableToPKColumnEngine(), 
  241.                 ids,
  242.                 this.getConfigurazioneFiltroFieldConverter(), this, updateModels);
  243.     }
  244.     
  245.     @Override
  246.     public void updateOrCreate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneFiltro oldId, ConfigurazioneFiltro configurazioneFiltro, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {
  247.     
  248.         if(this.exists(jdbcProperties, log, connection, sqlQueryObject, oldId)) {
  249.             this.update(jdbcProperties, log, connection, sqlQueryObject, oldId, configurazioneFiltro,idMappingResolutionBehaviour);
  250.         } else {
  251.             this.create(jdbcProperties, log, connection, sqlQueryObject, configurazioneFiltro,idMappingResolutionBehaviour);
  252.         }
  253.         
  254.     }
  255.     
  256.     @Override
  257.     public void updateOrCreate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, ConfigurazioneFiltro configurazioneFiltro, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {
  258.         if(this.exists(jdbcProperties, log, connection, sqlQueryObject, tableId)) {
  259.             this.update(jdbcProperties, log, connection, sqlQueryObject, tableId, configurazioneFiltro,idMappingResolutionBehaviour);
  260.         } else {
  261.             this.create(jdbcProperties, log, connection, sqlQueryObject, configurazioneFiltro,idMappingResolutionBehaviour);
  262.         }
  263.     }
  264.     
  265.     @Override
  266.     public void delete(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, ConfigurazioneFiltro configurazioneFiltro) throws NotImplementedException,ServiceException,Exception {
  267.         
  268.         
  269.         Long longId = null;
  270.         if( (configurazioneFiltro.getId()!=null) && (configurazioneFiltro.getId()>0) ){
  271.             longId = configurazioneFiltro.getId();
  272.         }
  273.         else{
  274.             IdConfigurazioneFiltro idConfigurazioneFiltro = this.convertToId(jdbcProperties,log,connection,sqlQueryObject,configurazioneFiltro);
  275.             longId = this.findIdConfigurazioneFiltro(jdbcProperties,log,connection,sqlQueryObject,idConfigurazioneFiltro,false);
  276.             if(longId == null){
  277.                 return; // entry not exists
  278.             }
  279.         }       
  280.         
  281.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, longId);
  282.         
  283.     }

  285.     private void deleteEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long id) throws NotImplementedException,ServiceException,Exception {
  286.     
  287.         if(id!=null && id.longValue()<=0){
  288.             throw new ServiceException("Id is less equals 0");
  289.         }
  290.         
  291.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  292.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  293.         
  294.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObject.newSQLQueryObject();
  295.         

  297.         // Object configurazioneFiltro
  298.         sqlQueryObjectDelete.setANDLogicOperator(true);
  299.         sqlQueryObjectDelete.addDeleteTable(this.getConfigurazioneFiltroFieldConverter().toTable(ConfigurazioneFiltro.model()));
  300.         if(id != null)
  301.             sqlQueryObjectDelete.addWhereCondition("id=?");

  303.         // Delete configurazioneFiltro
  304.         jdbcUtilities.execute(sqlQueryObjectDelete.createSQLDelete(), jdbcProperties.isShowSql(), 
  305.             new JDBCObject(id,Long.class));

  307.     }

  309.     @Override
  310.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneFiltro idConfigurazioneFiltro) throws NotImplementedException,ServiceException,Exception {

  312.         Long id = null;
  313.         try{
  314.             id = this.findIdConfigurazioneFiltro(jdbcProperties, log, connection, sqlQueryObject, idConfigurazioneFiltro, true);
  315.         }catch(NotFoundException notFound){
  316.             return;
  317.         }
  318.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  319.         
  320.     }
  321.     
  322.     @Override
  323.     public NonNegativeNumber deleteAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject) throws NotImplementedException,ServiceException,Exception {
  324.         
  325.         return this.deleteAll(jdbcProperties, log, connection, sqlQueryObject, new JDBCExpression(this.getConfigurazioneFiltroFieldConverter()));

  327.     }

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

  332.         java.util.List<Long> lst = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, new JDBCPaginatedExpression(expression));
  333.         
  334.         for(Long id : lst) {
  335.             this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  336.         }
  337.         
  338.         return new NonNegativeNumber(lst.size());
  339.     
  340.     }



  344.     // -- DB
  345.     
  346.     @Override
  347.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws ServiceException, NotImplementedException, Exception {
  348.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  349.     }
  350.     
  351.     @Override
  352.     public int nativeUpdate(JDBCServiceManagerProperties jdbcProperties, Logger log,Connection connection,ISQLQueryObject sqlObject, String sql,Object ... param) throws ServiceException,NotImplementedException, Exception {
  353.     
  354.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeUpdate(jdbcProperties, log, connection, sqlObject,
  355.                                                                                             sql,param);
  356.     
  357.     }
  358. }
Created with JaCoCo 0.8.8.202204050719