JDBCConfigurazioneServizioServiceImpl.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.IdConfigurazioneServizio;
  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.ConfigurazioneServizio;

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

  57.     @Override
  58.     public void create(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, ConfigurazioneServizio configurazioneServizio, 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 configurazioneServizio
  68.         sqlQueryObjectInsert.addInsertTable(this.getConfigurazioneServizioFieldConverter().toTable(ConfigurazioneServizio.model()));
  69.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneServizioFieldConverter().toColumn(ConfigurazioneServizio.model().ACCORDO,false),"?");
  70.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneServizioFieldConverter().toColumn(ConfigurazioneServizio.model().TIPO_SOGGETTO_REFERENTE,false),"?");
  71.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneServizioFieldConverter().toColumn(ConfigurazioneServizio.model().NOME_SOGGETTO_REFERENTE,false),"?");
  72.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneServizioFieldConverter().toColumn(ConfigurazioneServizio.model().VERSIONE,false),"?");
  73.         sqlQueryObjectInsert.addInsertField(this.getConfigurazioneServizioFieldConverter().toColumn(ConfigurazioneServizio.model().SERVIZIO,false),"?");

  75.         // Insert configurazioneServizio
  76.         org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator = this.getConfigurazioneServizioFetch().getKeyGeneratorObject(ConfigurazioneServizio.model());
  77.         long id = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert, keyGenerator, jdbcProperties.isShowSql(),
  78.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneServizio.getAccordo(),ConfigurazioneServizio.model().ACCORDO.getFieldType()),
  79.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneServizio.getTipoSoggettoReferente(),ConfigurazioneServizio.model().TIPO_SOGGETTO_REFERENTE.getFieldType()),
  80.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneServizio.getNomeSoggettoReferente(),ConfigurazioneServizio.model().NOME_SOGGETTO_REFERENTE.getFieldType()),
  81.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneServizio.getVersione(),ConfigurazioneServizio.model().VERSIONE.getFieldType()),
  82.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(configurazioneServizio.getServizio(),ConfigurazioneServizio.model().SERVIZIO.getFieldType())
  83.         );
  84.         configurazioneServizio.setId(id);

  86.         
  87.     }

  89.     @Override
  90.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneServizio oldId, ConfigurazioneServizio configurazioneServizio, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  91.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObject.newSQLQueryObject();
  92.         Long longIdByLogicId = this.findIdConfigurazioneServizio(jdbcProperties, log, connection, sqlQueryObjectUpdate.newSQLQueryObject(), oldId, true);
  93.         Long tableId = configurazioneServizio.getId();
  94.         if(tableId != null && tableId.longValue() > 0) {
  95.             if(tableId.longValue() != longIdByLogicId.longValue()) {
  96.                 throw new Exception("Ambiguous parameter: configurazioneServizio.id ["+tableId+"] does not match logic id ["+longIdByLogicId+"]");
  97.             }
  98.         } else {
  99.             tableId = longIdByLogicId;
  100.             configurazioneServizio.setId(tableId);
  101.         }
  102.         if(tableId==null || tableId<=0){
  103.             throw new Exception("Retrieve tableId failed");
  104.         }

  106.         this.update(jdbcProperties, log, connection, sqlQueryObject, tableId, configurazioneServizio, idMappingResolutionBehaviour);
  107.     }
  108.     @Override
  109.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, ConfigurazioneServizio configurazioneServizio, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  110.     
  111.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  112.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  113.         
  114.         ISQLQueryObject sqlQueryObjectInsert = sqlQueryObject.newSQLQueryObject();
  115.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObjectInsert.newSQLQueryObject();
  116.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObjectDelete.newSQLQueryObject();
  117.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObjectGet.newSQLQueryObject();
  118.         


  121.         // Object configurazioneServizio
  122.         sqlQueryObjectUpdate.setANDLogicOperator(true);
  123.         sqlQueryObjectUpdate.addUpdateTable(this.getConfigurazioneServizioFieldConverter().toTable(ConfigurazioneServizio.model()));
  124.         boolean isUpdate_configurazioneServizio = true;
  125.         java.util.List<JDBCObject> lstObjects_configurazioneServizio = new java.util.ArrayList<>();
  126.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneServizioFieldConverter().toColumn(ConfigurazioneServizio.model().ACCORDO,false), "?");
  127.         lstObjects_configurazioneServizio.add(new JDBCObject(configurazioneServizio.getAccordo(), ConfigurazioneServizio.model().ACCORDO.getFieldType()));
  128.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneServizioFieldConverter().toColumn(ConfigurazioneServizio.model().TIPO_SOGGETTO_REFERENTE,false), "?");
  129.         lstObjects_configurazioneServizio.add(new JDBCObject(configurazioneServizio.getTipoSoggettoReferente(), ConfigurazioneServizio.model().TIPO_SOGGETTO_REFERENTE.getFieldType()));
  130.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneServizioFieldConverter().toColumn(ConfigurazioneServizio.model().NOME_SOGGETTO_REFERENTE,false), "?");
  131.         lstObjects_configurazioneServizio.add(new JDBCObject(configurazioneServizio.getNomeSoggettoReferente(), ConfigurazioneServizio.model().NOME_SOGGETTO_REFERENTE.getFieldType()));
  132.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneServizioFieldConverter().toColumn(ConfigurazioneServizio.model().VERSIONE,false), "?");
  133.         lstObjects_configurazioneServizio.add(new JDBCObject(configurazioneServizio.getVersione(), ConfigurazioneServizio.model().VERSIONE.getFieldType()));
  134.         sqlQueryObjectUpdate.addUpdateField(this.getConfigurazioneServizioFieldConverter().toColumn(ConfigurazioneServizio.model().SERVIZIO,false), "?");
  135.         lstObjects_configurazioneServizio.add(new JDBCObject(configurazioneServizio.getServizio(), ConfigurazioneServizio.model().SERVIZIO.getFieldType()));
  136.         sqlQueryObjectUpdate.addWhereCondition("id=?");
  137.         lstObjects_configurazioneServizio.add(new JDBCObject(tableId, Long.class));

  139.         if(isUpdate_configurazioneServizio) {
  140.             // Update configurazioneServizio
  141.             jdbcUtilities.executeUpdate(sqlQueryObjectUpdate.createSQLUpdate(), jdbcProperties.isShowSql(), 
  142.                 lstObjects_configurazioneServizio.toArray(new JDBCObject[]{}));
  143.         }


  146.     }
  147.     
  148.     @Override
  149.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneServizio id, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  150.         
  151.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  152.                 this.getConfigurazioneServizioFieldConverter().toTable(ConfigurazioneServizio.model()), 
  153.                 this.getMapTableToPKColumnEngine(), 
  154.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  155.                 this.getConfigurazioneServizioFieldConverter(), this, null, updateFields);
  156.     }
  157.     
  158.     @Override
  159.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneServizio id, IExpression condition, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  160.         
  161.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  162.                 this.getConfigurazioneServizioFieldConverter().toTable(ConfigurazioneServizio.model()), 
  163.                 this.getMapTableToPKColumnEngine(), 
  164.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  165.                 this.getConfigurazioneServizioFieldConverter(), this, condition, updateFields);
  166.     }
  167.     
  168.     @Override
  169.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneServizio id, UpdateModel ... updateModels) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  170.         
  171.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  172.                 this.getConfigurazioneServizioFieldConverter().toTable(ConfigurazioneServizio.model()), 
  173.                 this.getMapTableToPKColumnEngine(), 
  174.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  175.                 this.getConfigurazioneServizioFieldConverter(), this, updateModels);
  176.     }   
  177.     
  178.     @Override
  179.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  180.         java.util.List<Object> ids = new java.util.ArrayList<>();
  181.         ids.add(tableId);
  182.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  183.                 this.getConfigurazioneServizioFieldConverter().toTable(ConfigurazioneServizio.model()), 
  184.                 this.getMapTableToPKColumnEngine(), 
  185.                 ids,
  186.                 this.getConfigurazioneServizioFieldConverter(), this, null, updateFields);
  187.     }
  188.     
  189.     @Override
  190.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, IExpression condition, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  191.         java.util.List<Object> ids = new java.util.ArrayList<>();
  192.         ids.add(tableId);
  193.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  194.                 this.getConfigurazioneServizioFieldConverter().toTable(ConfigurazioneServizio.model()), 
  195.                 this.getMapTableToPKColumnEngine(), 
  196.                 ids,
  197.                 this.getConfigurazioneServizioFieldConverter(), this, condition, updateFields);
  198.     }
  199.     
  200.     @Override
  201.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, UpdateModel ... updateModels) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  202.         java.util.List<Object> ids = new java.util.ArrayList<>();
  203.         ids.add(tableId);
  204.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  205.                 this.getConfigurazioneServizioFieldConverter().toTable(ConfigurazioneServizio.model()), 
  206.                 this.getMapTableToPKColumnEngine(), 
  207.                 ids,
  208.                 this.getConfigurazioneServizioFieldConverter(), this, updateModels);
  209.     }
  210.     
  211.     @Override
  212.     public void updateOrCreate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneServizio oldId, ConfigurazioneServizio configurazioneServizio, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {
  213.     
  214.         if(this.exists(jdbcProperties, log, connection, sqlQueryObject, oldId)) {
  215.             this.update(jdbcProperties, log, connection, sqlQueryObject, oldId, configurazioneServizio,idMappingResolutionBehaviour);
  216.         } else {
  217.             this.create(jdbcProperties, log, connection, sqlQueryObject, configurazioneServizio,idMappingResolutionBehaviour);
  218.         }
  219.         
  220.     }
  221.     
  222.     @Override
  223.     public void updateOrCreate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, ConfigurazioneServizio configurazioneServizio, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {
  224.         if(this.exists(jdbcProperties, log, connection, sqlQueryObject, tableId)) {
  225.             this.update(jdbcProperties, log, connection, sqlQueryObject, tableId, configurazioneServizio,idMappingResolutionBehaviour);
  226.         } else {
  227.             this.create(jdbcProperties, log, connection, sqlQueryObject, configurazioneServizio,idMappingResolutionBehaviour);
  228.         }
  229.     }
  230.     
  231.     @Override
  232.     public void delete(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, ConfigurazioneServizio configurazioneServizio) throws NotImplementedException,ServiceException,Exception {
  233.         
  234.         
  235.         Long longId = null;
  236.         if( (configurazioneServizio.getId()!=null) && (configurazioneServizio.getId()>0) ){
  237.             longId = configurazioneServizio.getId();
  238.         }
  239.         else{
  240.             IdConfigurazioneServizio idConfigurazioneServizio = this.convertToId(jdbcProperties,log,connection,sqlQueryObject,configurazioneServizio);
  241.             longId = this.findIdConfigurazioneServizio(jdbcProperties,log,connection,sqlQueryObject,idConfigurazioneServizio,false);
  242.             if(longId == null){
  243.                 return; // entry not exists
  244.             }
  245.         }       
  246.         
  247.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, longId);
  248.         
  249.     }

  251.     private void deleteEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long id) throws NotImplementedException,ServiceException,Exception {
  252.     
  253.         if(id!=null && id.longValue()<=0){
  254.             throw new ServiceException("Id is less equals 0");
  255.         }
  256.         
  257.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  258.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  259.         
  260.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObject.newSQLQueryObject();
  261.         

  263.         // Object configurazioneServizio
  264.         sqlQueryObjectDelete.setANDLogicOperator(true);
  265.         sqlQueryObjectDelete.addDeleteTable(this.getConfigurazioneServizioFieldConverter().toTable(ConfigurazioneServizio.model()));
  266.         if(id != null)
  267.             sqlQueryObjectDelete.addWhereCondition("id=?");

  269.         // Delete configurazioneServizio
  270.         jdbcUtilities.execute(sqlQueryObjectDelete.createSQLDelete(), jdbcProperties.isShowSql(), 
  271.             new JDBCObject(id,Long.class));

  273.     }

  275.     @Override
  276.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneServizio idConfigurazioneServizio) throws NotImplementedException,ServiceException,Exception {

  278.         Long id = null;
  279.         try{
  280.             id = this.findIdConfigurazioneServizio(jdbcProperties, log, connection, sqlQueryObject, idConfigurazioneServizio, true);
  281.         }catch(NotFoundException notFound){
  282.             return;
  283.         }
  284.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  285.         
  286.     }
  287.     
  288.     @Override
  289.     public NonNegativeNumber deleteAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject) throws NotImplementedException,ServiceException,Exception {
  290.         
  291.         return this.deleteAll(jdbcProperties, log, connection, sqlQueryObject, new JDBCExpression(this.getConfigurazioneServizioFieldConverter()));

  293.     }

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

  298.         java.util.List<Long> lst = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, new JDBCPaginatedExpression(expression));
  299.         
  300.         for(Long id : lst) {
  301.             this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  302.         }
  303.         
  304.         return new NonNegativeNumber(lst.size());
  305.     
  306.     }



  310.     // -- DB
  311.     
  312.     @Override
  313.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws ServiceException, NotImplementedException, Exception {
  314.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  315.     }
  316.     
  317.     @Override
  318.     public int nativeUpdate(JDBCServiceManagerProperties jdbcProperties, Logger log,Connection connection,ISQLQueryObject sqlObject, String sql,Object ... param) throws ServiceException,NotImplementedException, Exception {
  319.     
  320.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeUpdate(jdbcProperties, log, connection, sqlObject,
  321.                                                                                             sql,param);
  322.     
  323.     }
  324. }
Created with JaCoCo 0.8.8.202204050719