JDBCConfigurazioneRicercaServiceImpl.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.monitor.engine.config.ricerche.dao.jdbc;

  22. import java.sql.Connection;

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

  26. import org.slf4j.Logger;

  28. import org.openspcoop2.core.plugins.constants.TipoPlugin;
  29. import org.openspcoop2.core.plugins.dao.jdbc.JDBCConfigurazioneServizioAzioneBaseLib;
  30. import org.openspcoop2.core.plugins.dao.jdbc.JDBCPluginsBaseLib;

  32. import org.openspcoop2.generic_project.dao.jdbc.IJDBCServiceCRUDWithId;
  33. import org.openspcoop2.monitor.engine.config.ricerche.IdConfigurazioneRicerca;
  34. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  35. import org.openspcoop2.generic_project.beans.UpdateField;
  36. import org.openspcoop2.generic_project.beans.UpdateModel;

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

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

  49. import org.openspcoop2.monitor.engine.config.ricerche.ConfigurazioneRicerca;

  51. /**     
  52.  * JDBCConfigurazioneRicercaServiceImpl
  53.  *
  54.  * @author Poli Andrea (poli@link.it)
  55.  * @author $Author$
  56.  * @version $Rev$, $Date$
  57.  */
  58. public class JDBCConfigurazioneRicercaServiceImpl extends JDBCConfigurazioneRicercaServiceSearchImpl
  59.     implements IJDBCServiceCRUDWithId<ConfigurazioneRicerca, IdConfigurazioneRicerca, JDBCServiceManager> {

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

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

  70.         // Object _configurazioneServizioAzione
  71.         Long id_configurazioneServizioAzione = 
  72.                 JDBCConfigurazioneServizioAzioneBaseLib.getIdConfigurazioneServizioAzione(connection, jdbcProperties, log, 
  73.                         configurazioneRicerca.getIdConfigurazioneServizioAzione().getAzione(),
  74.                         configurazioneRicerca.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().getAccordo(), 
  75.                         configurazioneRicerca.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().getTipoSoggettoReferente(), 
  76.                         configurazioneRicerca.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().getNomeSoggettoReferente(), 
  77.                         configurazioneRicerca.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().getVersione(), 
  78.                         configurazioneRicerca.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().getServizio(), 
  79.                         true);

  81.         // Object _plugin
  82.         if(configurazioneRicerca.getPlugin()==null || configurazioneRicerca.getPlugin().getClassName()==null){
  83.             throw new ServiceException("ClassName del plugin non fornito");
  84.         }
  85.         Long id_plugin = JDBCPluginsBaseLib.getIdPlugin(connection, jdbcProperties, log, TipoPlugin.RICERCA, configurazioneRicerca.getPlugin().getClassName(), true);


  88.         // Object configurazioneRicerca
  89.         sqlQueryObjectInsert.addInsertTable(this.getConfigurazioneRicercaFieldConverter().toTable(ConfigurazioneRicerca.model()));
  90.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneRicercaFieldConverter().toColumn(ConfigurazioneRicerca.model().ID_CONFIGURAZIONE_RICERCA,false),"?");
  91.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneRicercaFieldConverter().toColumn(ConfigurazioneRicerca.model().ENABLED,false),"?");
  92.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneRicercaFieldConverter().toColumn(ConfigurazioneRicerca.model().LABEL,false),"?");
  93.         sqlQueryObjectInsert.addInsertField("id_configurazione","?");
  94.         sqlQueryObjectInsert.addInsertField("id_plugin","?");

  96.         // Insert configurazioneRicerca
  97.         org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator = this.getConfigurazioneRicercaFetch().getKeyGeneratorObject(ConfigurazioneRicerca.model());
  98.         long id = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert, keyGenerator, jdbcProperties.isShowSql(),
  99.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneRicerca.getIdConfigurazioneRicerca(),ConfigurazioneRicerca.model().ID_CONFIGURAZIONE_RICERCA.getFieldType()),
  100.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneRicerca.getEnabled(),ConfigurazioneRicerca.model().ENABLED.getFieldType()),
  101.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneRicerca.getLabel(),ConfigurazioneRicerca.model().LABEL.getFieldType()),
  102.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(id_configurazioneServizioAzione,Long.class),
  103.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(id_plugin,Long.class)
  104.         );
  105.         configurazioneRicerca.setId(id);

  107.         
  108.     }

  110.     @Override
  111.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneRicerca oldId, ConfigurazioneRicerca configurazioneRicerca, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  112.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObject.newSQLQueryObject();
  113.         Long longIdByLogicId = this.findIdConfigurazioneRicerca(jdbcProperties, log, connection, sqlQueryObjectUpdate.newSQLQueryObject(), oldId, true);
  114.         Long tableId = configurazioneRicerca.getId();
  115.         if(tableId != null && tableId.longValue() > 0) {
  116.             if(tableId.longValue() != longIdByLogicId.longValue()) {
  117.                 throw new Exception("Ambiguous parameter: configurazioneRicerca.id ["+tableId+"] does not match logic id ["+longIdByLogicId+"]");
  118.             }
  119.         } else {
  120.             tableId = longIdByLogicId;
  121.             configurazioneRicerca.setId(tableId);
  122.         }
  123.         if(tableId==null || tableId<=0){
  124.             throw new Exception("Retrieve tableId failed");
  125.         }

  127.         this.update(jdbcProperties, log, connection, sqlQueryObject, tableId, configurazioneRicerca, idMappingResolutionBehaviour);
  128.     }
  129.     @Override
  130.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, ConfigurazioneRicerca configurazioneRicerca, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  131.     
  132.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  133.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  134.         
  135.         ISQLQueryObject sqlQueryObjectInsert = sqlQueryObject.newSQLQueryObject();
  136.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObjectInsert.newSQLQueryObject();
  137.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObjectDelete.newSQLQueryObject();
  138.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObjectGet.newSQLQueryObject();
  139.         
  140.         boolean setIdMappingResolutionBehaviour = 
  141.             (idMappingResolutionBehaviour==null) ||
  142.             org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour) ||
  143.             org.openspcoop2.generic_project.beans.IDMappingBehaviour.USE_TABLE_ID.equals(idMappingResolutionBehaviour);
  144.             

  146.         // Object _configurazioneRicerca_configurazioneServizioAzione
  147.         Long id_configurazioneRicerca_configurazioneServizioAzione = null;
  148.         org.openspcoop2.monitor.engine.config.ricerche.IdConfigurazioneServizioAzione idLogic_configurazioneRicerca_configurazioneServizioAzione = null;
  149.         idLogic_configurazioneRicerca_configurazioneServizioAzione = configurazioneRicerca.getIdConfigurazioneServizioAzione();
  150.         if(idLogic_configurazioneRicerca_configurazioneServizioAzione!=null){
  151.             if(idMappingResolutionBehaviour==null ||
  152.                 (org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour))){
  153.                 id_configurazioneRicerca_configurazioneServizioAzione = 
  154.                         JDBCConfigurazioneServizioAzioneBaseLib.getIdConfigurazioneServizioAzione(connection, jdbcProperties, log, 
  155.                                 idLogic_configurazioneRicerca_configurazioneServizioAzione.getAzione(),
  156.                                 idLogic_configurazioneRicerca_configurazioneServizioAzione.getIdConfigurazioneServizio().getAccordo(), 
  157.                                 idLogic_configurazioneRicerca_configurazioneServizioAzione.getIdConfigurazioneServizio().getTipoSoggettoReferente(), 
  158.                                 idLogic_configurazioneRicerca_configurazioneServizioAzione.getIdConfigurazioneServizio().getNomeSoggettoReferente(), 
  159.                                 idLogic_configurazioneRicerca_configurazioneServizioAzione.getIdConfigurazioneServizio().getVersione(), 
  160.                                 idLogic_configurazioneRicerca_configurazioneServizioAzione.getIdConfigurazioneServizio().getServizio(), 
  161.                                 true);
  162.             }
  163.             else if(org.openspcoop2.generic_project.beans.IDMappingBehaviour.USE_TABLE_ID.equals(idMappingResolutionBehaviour)){
  164.                 id_configurazioneRicerca_configurazioneServizioAzione = idLogic_configurazioneRicerca_configurazioneServizioAzione.getId();
  165.                 if(id_configurazioneRicerca_configurazioneServizioAzione==null || id_configurazioneRicerca_configurazioneServizioAzione<=0){
  166.                     throw new Exception("Logic id not contains table id");
  167.                 }
  168.             }
  169.             configurazioneRicerca.setId(tableId);
  170.         }

  172.         // Object _plugin
  173.         if(configurazioneRicerca.getPlugin()==null || configurazioneRicerca.getPlugin().getClassName()==null){
  174.             throw new ServiceException("ClassName del plugin non fornito");
  175.         }
  176.         Long id_plugin = JDBCPluginsBaseLib.getIdPlugin(connection, jdbcProperties, log, TipoPlugin.RICERCA, configurazioneRicerca.getPlugin().getClassName(), true);
  177.         
  178.         // Object configurazioneRicerca
  179.         sqlQueryObjectUpdate.setANDLogicOperator(true);
  180.         sqlQueryObjectUpdate.addUpdateTable(this.getConfigurazioneRicercaFieldConverter().toTable(ConfigurazioneRicerca.model()));
  181.         boolean isUpdate_configurazioneRicerca = true;
  182.         java.util.List<JDBCObject> lstObjects_configurazioneRicerca = new java.util.ArrayList<>();
  183.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneRicercaFieldConverter().toColumn(ConfigurazioneRicerca.model().ID_CONFIGURAZIONE_RICERCA,false), "?");
  184.         lstObjects_configurazioneRicerca.add(new JDBCObject(configurazioneRicerca.getIdConfigurazioneRicerca(), ConfigurazioneRicerca.model().ID_CONFIGURAZIONE_RICERCA.getFieldType()));
  185.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneRicercaFieldConverter().toColumn(ConfigurazioneRicerca.model().ENABLED,false), "?");
  186.         lstObjects_configurazioneRicerca.add(new JDBCObject(configurazioneRicerca.getEnabled(), ConfigurazioneRicerca.model().ENABLED.getFieldType()));
  187.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneRicercaFieldConverter().toColumn(ConfigurazioneRicerca.model().LABEL,false), "?");
  188.         lstObjects_configurazioneRicerca.add(new JDBCObject(configurazioneRicerca.getLabel(), ConfigurazioneRicerca.model().LABEL.getFieldType()));
  189.         if(setIdMappingResolutionBehaviour){
  190.             sqlQueryObjectUpdate.addUpdateField("id_configurazione","?");
  191.         }
  192.         if(setIdMappingResolutionBehaviour){
  193.             sqlQueryObjectUpdate.addUpdateField("id_plugin", "?");
  194.         }
  195.         if(setIdMappingResolutionBehaviour){
  196.             lstObjects_configurazioneRicerca.add(new JDBCObject(id_configurazioneRicerca_configurazioneServizioAzione, Long.class));
  197.         }
  198.         if(setIdMappingResolutionBehaviour){
  199.             lstObjects_configurazioneRicerca.add(new JDBCObject(id_plugin, Long.class));
  200.         }
  201.         sqlQueryObjectUpdate.addWhereCondition("pid=?");
  202.         lstObjects_configurazioneRicerca.add(new JDBCObject(tableId, Long.class));

  204.         if(isUpdate_configurazioneRicerca) {
  205.             // Update configurazioneRicerca
  206.             jdbcUtilities.executeUpdate(sqlQueryObjectUpdate.createSQLUpdate(), jdbcProperties.isShowSql(), 
  207.                 lstObjects_configurazioneRicerca.toArray(new JDBCObject[]{}));
  208.         }

  210.     }
  211.     
  212.     @Override
  213.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneRicerca id, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  214.         
  215.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  216.                 this.getConfigurazioneRicercaFieldConverter().toTable(ConfigurazioneRicerca.model()), 
  217.                 this.getMapTableToPKColumnEngine(), 
  218.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  219.                 this.getConfigurazioneRicercaFieldConverter(), this, null, updateFields);
  220.     }
  221.     
  222.     @Override
  223.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneRicerca id, IExpression condition, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  224.         
  225.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  226.                 this.getConfigurazioneRicercaFieldConverter().toTable(ConfigurazioneRicerca.model()), 
  227.                 this.getMapTableToPKColumnEngine(), 
  228.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  229.                 this.getConfigurazioneRicercaFieldConverter(), this, condition, updateFields);
  230.     }
  231.     
  232.     @Override
  233.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneRicerca id, UpdateModel ... updateModels) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  234.         
  235.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  236.                 this.getConfigurazioneRicercaFieldConverter().toTable(ConfigurazioneRicerca.model()), 
  237.                 this.getMapTableToPKColumnEngine(), 
  238.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  239.                 this.getConfigurazioneRicercaFieldConverter(), this, updateModels);
  240.     }   
  241.     
  242.     @Override
  243.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  244.         java.util.List<Object> ids = new java.util.ArrayList<>();
  245.         ids.add(tableId);
  246.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  247.                 this.getConfigurazioneRicercaFieldConverter().toTable(ConfigurazioneRicerca.model()), 
  248.                 this.getMapTableToPKColumnEngine(), 
  249.                 ids,
  250.                 this.getConfigurazioneRicercaFieldConverter(), this, null, updateFields);
  251.     }
  252.     
  253.     @Override
  254.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, IExpression condition, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  255.         java.util.List<Object> ids = new java.util.ArrayList<>();
  256.         ids.add(tableId);
  257.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  258.                 this.getConfigurazioneRicercaFieldConverter().toTable(ConfigurazioneRicerca.model()), 
  259.                 this.getMapTableToPKColumnEngine(), 
  260.                 ids,
  261.                 this.getConfigurazioneRicercaFieldConverter(), this, condition, updateFields);
  262.     }
  263.     
  264.     @Override
  265.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, UpdateModel ... updateModels) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  266.         java.util.List<Object> ids = new java.util.ArrayList<>();
  267.         ids.add(tableId);
  268.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  269.                 this.getConfigurazioneRicercaFieldConverter().toTable(ConfigurazioneRicerca.model()), 
  270.                 this.getMapTableToPKColumnEngine(), 
  271.                 ids,
  272.                 this.getConfigurazioneRicercaFieldConverter(), this, updateModels);
  273.     }
  274.     
  275.     @Override
  276.     public void updateOrCreate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneRicerca oldId, ConfigurazioneRicerca configurazioneRicerca, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {
  277.     
  278.         if(this.exists(jdbcProperties, log, connection, sqlQueryObject, oldId)) {
  279.             this.update(jdbcProperties, log, connection, sqlQueryObject, oldId, configurazioneRicerca,idMappingResolutionBehaviour);
  280.         } else {
  281.             this.create(jdbcProperties, log, connection, sqlQueryObject, configurazioneRicerca,idMappingResolutionBehaviour);
  282.         }
  283.         
  284.     }
  285.     
  286.     @Override
  287.     public void updateOrCreate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, ConfigurazioneRicerca configurazioneRicerca, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {
  288.         if(this.exists(jdbcProperties, log, connection, sqlQueryObject, tableId)) {
  289.             this.update(jdbcProperties, log, connection, sqlQueryObject, tableId, configurazioneRicerca,idMappingResolutionBehaviour);
  290.         } else {
  291.             this.create(jdbcProperties, log, connection, sqlQueryObject, configurazioneRicerca,idMappingResolutionBehaviour);
  292.         }
  293.     }
  294.     
  295.     @Override
  296.     public void delete(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, ConfigurazioneRicerca configurazioneRicerca) throws NotImplementedException,ServiceException,Exception {
  297.         
  298.         
  299.         Long longId = null;
  300.         if( (configurazioneRicerca.getId()!=null) && (configurazioneRicerca.getId()>0) ){
  301.             longId = configurazioneRicerca.getId();
  302.         }
  303.         else{
  304.             IdConfigurazioneRicerca idConfigurazioneRicerca = this.convertToId(jdbcProperties,log,connection,sqlQueryObject,configurazioneRicerca);
  305.             longId = this.findIdConfigurazioneRicerca(jdbcProperties,log,connection,sqlQueryObject,idConfigurazioneRicerca,false);
  306.             if(longId == null){
  307.                 return; // entry not exists
  308.             }
  309.         }       
  310.         
  311.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, longId);
  312.         
  313.     }

  315.     private void deleteEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long id) throws NotImplementedException,ServiceException,Exception {
  316.     
  317.         if(id!=null && id.longValue()<=0){
  318.             throw new ServiceException("Id is less equals 0");
  319.         }
  320.         
  321.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  322.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  323.         
  324.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObject.newSQLQueryObject();
  325.         

  327.         // Object configurazioneRicerca
  328.         sqlQueryObjectDelete.setANDLogicOperator(true);
  329.         sqlQueryObjectDelete.addDeleteTable(this.getConfigurazioneRicercaFieldConverter().toTable(ConfigurazioneRicerca.model()));
  330.         if(id != null)
  331.             sqlQueryObjectDelete.addWhereCondition("pid=?");

  333.         // Delete configurazioneRicerca
  334.         jdbcUtilities.execute(sqlQueryObjectDelete.createSQLDelete(), jdbcProperties.isShowSql(), 
  335.             new JDBCObject(id,Long.class));

  337.     }

  339.     @Override
  340.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneRicerca idConfigurazioneRicerca) throws NotImplementedException,ServiceException,Exception {

  342.         Long id = null;
  343.         try{
  344.             id = this.findIdConfigurazioneRicerca(jdbcProperties, log, connection, sqlQueryObject, idConfigurazioneRicerca, true);
  345.         }catch(NotFoundException notFound){
  346.             return;
  347.         }
  348.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  349.         
  350.     }
  351.     
  352.     @Override
  353.     public NonNegativeNumber deleteAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject) throws NotImplementedException,ServiceException,Exception {
  354.         
  355.         return this.deleteAll(jdbcProperties, log, connection, sqlQueryObject, new JDBCExpression(this.getConfigurazioneRicercaFieldConverter()));

  357.     }

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

  362.         java.util.List<Long> lst = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, new JDBCPaginatedExpression(expression));
  363.         
  364.         for(Long id : lst) {
  365.             this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  366.         }
  367.         
  368.         return new NonNegativeNumber(lst.size());
  369.     
  370.     }



  374.     // -- DB
  375.     
  376.     @Override
  377.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws ServiceException, NotImplementedException, Exception {
  378.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  379.     }
  380.     
  381.     @Override
  382.     public int nativeUpdate(JDBCServiceManagerProperties jdbcProperties, Logger log,Connection connection,ISQLQueryObject sqlObject, String sql,Object ... param) throws ServiceException,NotImplementedException, Exception {
  383.     
  384.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeUpdate(jdbcProperties, log, connection, sqlObject,
  385.                                                                                             sql,param);
  386.     
  387.     }
  388. }
Created with JaCoCo 0.8.8.202204050719