JDBCConfigurazioneStatisticaServiceImpl.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.statistiche.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.statistiche.IdConfigurazioneStatistica;
  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.statistiche.ConfigurazioneStatistica;

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

  61.     @Override
  62.     public void create(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, ConfigurazioneStatistica configurazioneStatistica, 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.         
  69.         if(configurazioneStatistica.getIdConfigurazioneServizioAzione()==null){
  70.             throw new ServiceException("IdConfigurazioneServizioAzione is null");
  71.         }
  72.         if(configurazioneStatistica.getIdConfigurazioneServizioAzione().getAzione()==null){
  73.             throw new ServiceException("IdConfigurazioneServizioAzione.azione is null");
  74.         }
  75.         if(configurazioneStatistica.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio()==null){
  76.             throw new ServiceException("IdConfigurazioneServizioAzione.idConfigurazioneServizio is null");
  77.         }
  78.                 
  79.          // Object _configurazioneServizioAzione
  80.         Long id_configurazioneServizioAzione = 
  81.                 JDBCConfigurazioneServizioAzioneBaseLib.getIdConfigurazioneServizioAzione(connection, jdbcProperties, log, 
  82.                         configurazioneStatistica.getIdConfigurazioneServizioAzione().getAzione(),
  83.                         configurazioneStatistica.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().getAccordo(), 
  84.                         configurazioneStatistica.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().getTipoSoggettoReferente(), 
  85.                         configurazioneStatistica.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().getNomeSoggettoReferente(), 
  86.                         configurazioneStatistica.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().getVersione(), 
  87.                         configurazioneStatistica.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().getServizio(), 
  88.                         true);
  89.         

  91.         // Object _plugin
  92.         if(configurazioneStatistica.getPlugin()==null || configurazioneStatistica.getPlugin().getClassName()==null){
  93.             throw new ServiceException("ClassName del plugin non fornito");
  94.         }
  95.         Long id_plugin = JDBCPluginsBaseLib.getIdPlugin(connection, jdbcProperties, log, TipoPlugin.STATISTICA, configurazioneStatistica.getPlugin().getClassName(), true);


  98.         // Object configurazioneStatistica
  99.         sqlQueryObjectInsert.addInsertTable(this.getConfigurazioneStatisticaFieldConverter().toTable(ConfigurazioneStatistica.model()));
  100.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneStatisticaFieldConverter().toColumn(ConfigurazioneStatistica.model().ID_CONFIGURAZIONE_STATISTICA,false),"?");
  101.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneStatisticaFieldConverter().toColumn(ConfigurazioneStatistica.model().ENABLED,false),"?");
  102.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneStatisticaFieldConverter().toColumn(ConfigurazioneStatistica.model().LABEL,false),"?");
  103.         sqlQueryObjectInsert.addInsertField("id_configurazione","?");
  104.         sqlQueryObjectInsert.addInsertField("id_plugin","?");

  106.         // Insert configurazioneStatistica
  107.         org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator = this.getConfigurazioneStatisticaFetch().getKeyGeneratorObject(ConfigurazioneStatistica.model());
  108.         long id = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert, keyGenerator, jdbcProperties.isShowSql(),
  109.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneStatistica.getIdConfigurazioneStatistica(),ConfigurazioneStatistica.model().ID_CONFIGURAZIONE_STATISTICA.getFieldType()),
  110.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneStatistica.getEnabled(),ConfigurazioneStatistica.model().ENABLED.getFieldType()),
  111.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneStatistica.getLabel(),ConfigurazioneStatistica.model().LABEL.getFieldType()),
  112.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(id_configurazioneServizioAzione,Long.class),
  113.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(id_plugin,Long.class)
  114.         );
  115.         configurazioneStatistica.setId(id);

  117.         
  118.     }

  120.     @Override
  121.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneStatistica oldId, ConfigurazioneStatistica configurazioneStatistica, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  122.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObject.newSQLQueryObject();
  123.         Long longIdByLogicId = this.findIdConfigurazioneStatistica(jdbcProperties, log, connection, sqlQueryObjectUpdate.newSQLQueryObject(), oldId, true);
  124.         Long tableId = configurazioneStatistica.getId();
  125.         if(tableId != null && tableId.longValue() > 0) {
  126.             if(tableId.longValue() != longIdByLogicId.longValue()) {
  127.                 throw new Exception("Ambiguous parameter: configurazioneStatistica.id ["+tableId+"] does not match logic id ["+longIdByLogicId+"]");
  128.             }
  129.         } else {
  130.             tableId = longIdByLogicId;
  131.             configurazioneStatistica.setId(tableId);
  132.         }
  133.         if(tableId==null || tableId<=0){
  134.             throw new Exception("Retrieve tableId failed");
  135.         }

  137.         this.update(jdbcProperties, log, connection, sqlQueryObject, tableId, configurazioneStatistica, idMappingResolutionBehaviour);
  138.     }
  139.     @Override
  140.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, ConfigurazioneStatistica configurazioneStatistica, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  141.     
  142.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  143.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  144.         
  145.         ISQLQueryObject sqlQueryObjectInsert = sqlQueryObject.newSQLQueryObject();
  146.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObjectInsert.newSQLQueryObject();
  147.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObjectDelete.newSQLQueryObject();
  148.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObjectGet.newSQLQueryObject();
  149.         
  150.         boolean setIdMappingResolutionBehaviour = 
  151.             (idMappingResolutionBehaviour==null) ||
  152.             org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour) ||
  153.             org.openspcoop2.generic_project.beans.IDMappingBehaviour.USE_TABLE_ID.equals(idMappingResolutionBehaviour);
  154.             

  156.         // Object _configurazioneStatistica_configurazioneServizioAzione
  157.         Long id_configurazioneStatistica_configurazioneServizioAzione = null;
  158.         org.openspcoop2.monitor.engine.config.statistiche.IdConfigurazioneServizioAzione idLogic_configurazioneStatistica_configurazioneServizioAzione = null;
  159.         idLogic_configurazioneStatistica_configurazioneServizioAzione = configurazioneStatistica.getIdConfigurazioneServizioAzione();
  160.         if(idLogic_configurazioneStatistica_configurazioneServizioAzione!=null){
  161.             if(idMappingResolutionBehaviour==null ||
  162.                 (org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour))){
  163.                 id_configurazioneStatistica_configurazioneServizioAzione = 
  164.                         JDBCConfigurazioneServizioAzioneBaseLib.getIdConfigurazioneServizioAzione(connection, jdbcProperties, log, 
  165.                                 idLogic_configurazioneStatistica_configurazioneServizioAzione.getAzione(),
  166.                                 idLogic_configurazioneStatistica_configurazioneServizioAzione.getIdConfigurazioneServizio().getAccordo(), 
  167.                                 idLogic_configurazioneStatistica_configurazioneServizioAzione.getIdConfigurazioneServizio().getTipoSoggettoReferente(), 
  168.                                 idLogic_configurazioneStatistica_configurazioneServizioAzione.getIdConfigurazioneServizio().getNomeSoggettoReferente(), 
  169.                                 idLogic_configurazioneStatistica_configurazioneServizioAzione.getIdConfigurazioneServizio().getVersione(), 
  170.                                 idLogic_configurazioneStatistica_configurazioneServizioAzione.getIdConfigurazioneServizio().getServizio(), 
  171.                                 true);
  172.             }
  173.             else if(org.openspcoop2.generic_project.beans.IDMappingBehaviour.USE_TABLE_ID.equals(idMappingResolutionBehaviour)){
  174.                 id_configurazioneStatistica_configurazioneServizioAzione = idLogic_configurazioneStatistica_configurazioneServizioAzione.getId();
  175.                 if(id_configurazioneStatistica_configurazioneServizioAzione==null || id_configurazioneStatistica_configurazioneServizioAzione<=0){
  176.                     throw new Exception("Logic id not contains table id");
  177.                 }
  178.             }
  179.             configurazioneStatistica.setId(tableId);
  180.         }
  181.         
  182.         // Object _plugin
  183.         if(configurazioneStatistica.getPlugin()==null || configurazioneStatistica.getPlugin().getClassName()==null){
  184.             throw new ServiceException("ClassName del plugin non fornito");
  185.         }
  186.         Long id_plugin = JDBCPluginsBaseLib.getIdPlugin(connection, jdbcProperties, log, TipoPlugin.STATISTICA, configurazioneStatistica.getPlugin().getClassName(), true);


  189.         // Object configurazioneStatistica
  190.         sqlQueryObjectUpdate.setANDLogicOperator(true);
  191.         sqlQueryObjectUpdate.addUpdateTable(this.getConfigurazioneStatisticaFieldConverter().toTable(ConfigurazioneStatistica.model()));
  192.         boolean isUpdate_configurazioneStatistica = true;
  193.         java.util.List<JDBCObject> lstObjects_configurazioneStatistica = new java.util.ArrayList<>();
  194.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneStatisticaFieldConverter().toColumn(ConfigurazioneStatistica.model().ID_CONFIGURAZIONE_STATISTICA,false), "?");
  195.         lstObjects_configurazioneStatistica.add(new JDBCObject(configurazioneStatistica.getIdConfigurazioneStatistica(), ConfigurazioneStatistica.model().ID_CONFIGURAZIONE_STATISTICA.getFieldType()));
  196.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneStatisticaFieldConverter().toColumn(ConfigurazioneStatistica.model().ENABLED,false), "?");
  197.         lstObjects_configurazioneStatistica.add(new JDBCObject(configurazioneStatistica.getEnabled(), ConfigurazioneStatistica.model().ENABLED.getFieldType()));
  198.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneStatisticaFieldConverter().toColumn(ConfigurazioneStatistica.model().LABEL,false), "?");
  199.         lstObjects_configurazioneStatistica.add(new JDBCObject(configurazioneStatistica.getLabel(), ConfigurazioneStatistica.model().LABEL.getFieldType()));
  200.         if(setIdMappingResolutionBehaviour){
  201.             sqlQueryObjectUpdate.addUpdateField("id_configurazione","?");
  202.         }
  203.         if(setIdMappingResolutionBehaviour){
  204.             sqlQueryObjectUpdate.addUpdateField("id_plugin", "?");
  205.         }
  206.         if(setIdMappingResolutionBehaviour){
  207.             lstObjects_configurazioneStatistica.add(new JDBCObject(id_configurazioneStatistica_configurazioneServizioAzione, Long.class));
  208.         }
  209.         if(setIdMappingResolutionBehaviour){
  210.             lstObjects_configurazioneStatistica.add(new JDBCObject(id_plugin, Long.class));
  211.         }
  212.         sqlQueryObjectUpdate.addWhereCondition("pid=?");
  213.         lstObjects_configurazioneStatistica.add(new JDBCObject(tableId, Long.class));

  215.         if(isUpdate_configurazioneStatistica) {
  216.             // Update configurazioneStatistica
  217.             jdbcUtilities.executeUpdate(sqlQueryObjectUpdate.createSQLUpdate(), jdbcProperties.isShowSql(), 
  218.                 lstObjects_configurazioneStatistica.toArray(new JDBCObject[]{}));
  219.         }

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

  327.     private void deleteEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long id) throws NotImplementedException,ServiceException,Exception {
  328.     
  329.         if(id!=null && id.longValue()<=0){
  330.             throw new ServiceException("Id is less equals 0");
  331.         }
  332.         
  333.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  334.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  335.         
  336.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObject.newSQLQueryObject();
  337.         

  339.         // Object configurazioneStatistica
  340.         sqlQueryObjectDelete.setANDLogicOperator(true);
  341.         sqlQueryObjectDelete.addDeleteTable(this.getConfigurazioneStatisticaFieldConverter().toTable(ConfigurazioneStatistica.model()));
  342.         if(id != null)
  343.             sqlQueryObjectDelete.addWhereCondition("pid=?");

  345.         // Delete configurazioneStatistica
  346.         jdbcUtilities.execute(sqlQueryObjectDelete.createSQLDelete(), jdbcProperties.isShowSql(), 
  347.             new JDBCObject(id,Long.class));

  349.     }

  351.     @Override
  352.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneStatistica idConfigurazioneStatistica) throws NotImplementedException,ServiceException,Exception {

  354.         Long id = null;
  355.         try{
  356.             id = this.findIdConfigurazioneStatistica(jdbcProperties, log, connection, sqlQueryObject, idConfigurazioneStatistica, true);
  357.         }catch(NotFoundException notFound){
  358.             return;
  359.         }
  360.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  361.         
  362.     }
  363.     
  364.     @Override
  365.     public NonNegativeNumber deleteAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject) throws NotImplementedException,ServiceException,Exception {
  366.         
  367.         return this.deleteAll(jdbcProperties, log, connection, sqlQueryObject, new JDBCExpression(this.getConfigurazioneStatisticaFieldConverter()));

  369.     }

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

  374.         java.util.List<Long> lst = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, new JDBCPaginatedExpression(expression));
  375.         
  376.         for(Long id : lst) {
  377.             this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  378.         }
  379.         
  380.         return new NonNegativeNumber(lst.size());
  381.     
  382.     }



  386.     // -- DB
  387.     
  388.     @Override
  389.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws ServiceException, NotImplementedException, Exception {
  390.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  391.     }
  392.     
  393.     @Override
  394.     public int nativeUpdate(JDBCServiceManagerProperties jdbcProperties, Logger log,Connection connection,ISQLQueryObject sqlObject, String sql,Object ... param) throws ServiceException,NotImplementedException, Exception {
  395.     
  396.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeUpdate(jdbcProperties, log, connection, sqlObject,
  397.                                                                                             sql,param);
  398.     
  399.     }
  400. }
Created with JaCoCo 0.8.8.202204050719