JDBCEventoServiceImpl.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.eventi.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.IJDBCServiceCRUDWithoutId;
  29. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  30. import org.openspcoop2.generic_project.beans.UpdateField;
  31. import org.openspcoop2.generic_project.beans.UpdateModel;

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

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

  44. import org.openspcoop2.core.eventi.Evento;

  46. /**     
  47.  * JDBCEventoServiceImpl
  48.  *
  49.  * @author Poli Andrea (poli@link.it)
  50.  * @author $Author$
  51.  * @version $Rev$, $Date$
  52.  */
  53. public class JDBCEventoServiceImpl extends JDBCEventoServiceSearchImpl
  54.     implements IJDBCServiceCRUDWithoutId<Evento, JDBCServiceManager> {

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

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


  66.         // Object evento
  67.         sqlQueryObjectInsert.addInsertTable(this.getEventoFieldConverter().toTable(Evento.model()));
  68.         sqlQueryObjectInsert.addInsertField(this.getEventoFieldConverter().toColumn(Evento.model().TIPO,false),"?");
  69.         sqlQueryObjectInsert.addInsertField(this.getEventoFieldConverter().toColumn(Evento.model().CODICE,false),"?");
  70.         sqlQueryObjectInsert.addInsertField(this.getEventoFieldConverter().toColumn(Evento.model().SEVERITA,false),"?");
  71.         sqlQueryObjectInsert.addInsertField(this.getEventoFieldConverter().toColumn(Evento.model().ORA_REGISTRAZIONE,false),"?");
  72.         sqlQueryObjectInsert.addInsertField(this.getEventoFieldConverter().toColumn(Evento.model().DESCRIZIONE,false),"?");
  73.         sqlQueryObjectInsert.addInsertField(this.getEventoFieldConverter().toColumn(Evento.model().ID_TRANSAZIONE,false),"?");
  74.         sqlQueryObjectInsert.addInsertField(this.getEventoFieldConverter().toColumn(Evento.model().ID_CONFIGURAZIONE,false),"?");
  75.         sqlQueryObjectInsert.addInsertField(this.getEventoFieldConverter().toColumn(Evento.model().CONFIGURAZIONE,false),"?");
  76.         sqlQueryObjectInsert.addInsertField(this.getEventoFieldConverter().toColumn(Evento.model().CLUSTER_ID,false),"?");

  78.         // Insert evento
  79.         org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator = this.getEventoFetch().getKeyGeneratorObject(Evento.model());
  80.         long id = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert, keyGenerator, jdbcProperties.isShowSql(),
  81.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(evento.getTipo(),Evento.model().TIPO.getFieldType()),
  82.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(evento.getCodice(),Evento.model().CODICE.getFieldType()),
  83.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(evento.getSeverita(),Evento.model().SEVERITA.getFieldType()),
  84.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(evento.getOraRegistrazione(),Evento.model().ORA_REGISTRAZIONE.getFieldType()),
  85.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(evento.getDescrizione(),Evento.model().DESCRIZIONE.getFieldType()),
  86.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(evento.getIdTransazione(),Evento.model().ID_TRANSAZIONE.getFieldType()),
  87.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(evento.getIdConfigurazione(),Evento.model().ID_CONFIGURAZIONE.getFieldType()),
  88.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(evento.getConfigurazione(),Evento.model().CONFIGURAZIONE.getFieldType()),
  89.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(evento.getClusterId(),Evento.model().CLUSTER_ID.getFieldType())
  90.         );
  91.         evento.setId(id);

  93.         
  94.     }

  96.     @Override
  97.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Evento evento, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  98.         
  99.         Long tableId = evento.getId();
  100.         if(tableId==null || tableId<=0){
  101.             throw new Exception("Retrieve tableId failed");
  102.         }

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


  119.         // Object evento
  120.         sqlQueryObjectUpdate.setANDLogicOperator(true);
  121.         sqlQueryObjectUpdate.addUpdateTable(this.getEventoFieldConverter().toTable(Evento.model()));
  122.         boolean isUpdate_evento = true;
  123.         java.util.List<JDBCObject> lstObjects_evento = new java.util.ArrayList<>();
  124.         sqlQueryObjectUpdate.addUpdateField(this.getEventoFieldConverter().toColumn(Evento.model().TIPO,false), "?");
  125.         lstObjects_evento.add(new JDBCObject(evento.getTipo(), Evento.model().TIPO.getFieldType()));
  126.         sqlQueryObjectUpdate.addUpdateField(this.getEventoFieldConverter().toColumn(Evento.model().CODICE,false), "?");
  127.         lstObjects_evento.add(new JDBCObject(evento.getCodice(), Evento.model().CODICE.getFieldType()));
  128.         sqlQueryObjectUpdate.addUpdateField(this.getEventoFieldConverter().toColumn(Evento.model().SEVERITA,false), "?");
  129.         lstObjects_evento.add(new JDBCObject(evento.getSeverita(), Evento.model().SEVERITA.getFieldType()));
  130.         sqlQueryObjectUpdate.addUpdateField(this.getEventoFieldConverter().toColumn(Evento.model().ORA_REGISTRAZIONE,false), "?");
  131.         lstObjects_evento.add(new JDBCObject(evento.getOraRegistrazione(), Evento.model().ORA_REGISTRAZIONE.getFieldType()));
  132.         sqlQueryObjectUpdate.addUpdateField(this.getEventoFieldConverter().toColumn(Evento.model().DESCRIZIONE,false), "?");
  133.         lstObjects_evento.add(new JDBCObject(evento.getDescrizione(), Evento.model().DESCRIZIONE.getFieldType()));
  134.         sqlQueryObjectUpdate.addUpdateField(this.getEventoFieldConverter().toColumn(Evento.model().ID_TRANSAZIONE,false), "?");
  135.         lstObjects_evento.add(new JDBCObject(evento.getIdTransazione(), Evento.model().ID_TRANSAZIONE.getFieldType()));
  136.         sqlQueryObjectUpdate.addUpdateField(this.getEventoFieldConverter().toColumn(Evento.model().ID_CONFIGURAZIONE,false), "?");
  137.         lstObjects_evento.add(new JDBCObject(evento.getIdConfigurazione(), Evento.model().ID_CONFIGURAZIONE.getFieldType()));
  138.         sqlQueryObjectUpdate.addUpdateField(this.getEventoFieldConverter().toColumn(Evento.model().CONFIGURAZIONE,false), "?");
  139.         lstObjects_evento.add(new JDBCObject(evento.getConfigurazione(), Evento.model().CONFIGURAZIONE.getFieldType()));
  140.         sqlQueryObjectUpdate.addUpdateField(this.getEventoFieldConverter().toColumn(Evento.model().CLUSTER_ID,false), "?");
  141.         lstObjects_evento.add(new JDBCObject(evento.getClusterId(), Evento.model().CLUSTER_ID.getFieldType()));
  142.         sqlQueryObjectUpdate.addWhereCondition("id=?");
  143.         lstObjects_evento.add(new JDBCObject(tableId, Long.class));

  145.         if(isUpdate_evento) {
  146.             // Update evento
  147.             jdbcUtilities.executeUpdate(sqlQueryObjectUpdate.createSQLUpdate(), jdbcProperties.isShowSql(), 
  148.                 lstObjects_evento.toArray(new JDBCObject[]{}));
  149.         }


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

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

  267.         // Object evento
  268.         sqlQueryObjectDelete.setANDLogicOperator(true);
  269.         sqlQueryObjectDelete.addDeleteTable(this.getEventoFieldConverter().toTable(Evento.model()));
  270.         if(id != null)
  271.             sqlQueryObjectDelete.addWhereCondition("id=?");

  273.         // Delete evento
  274.         jdbcUtilities.execute(sqlQueryObjectDelete.createSQLDelete(), jdbcProperties.isShowSql(), 
  275.             new JDBCObject(id,Long.class));

  277.     }

  279.     
  280.     @Override
  281.     public NonNegativeNumber deleteAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject) throws NotImplementedException,ServiceException,Exception {
  282.         
  283.         return this.deleteAll(jdbcProperties, log, connection, sqlQueryObject, new JDBCExpression(this.getEventoFieldConverter()));

  285.     }

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

  290.         java.util.List<Long> lst = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, new JDBCPaginatedExpression(expression));
  291.         
  292.         for(Long id : lst) {
  293.             this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  294.         }
  295.         
  296.         return new NonNegativeNumber(lst.size());
  297.     
  298.     }



  302.     // -- DB
  303.     
  304.     @Override
  305.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws ServiceException, NotImplementedException, Exception {
  306.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  307.     }
  308.     
  309.     @Override
  310.     public int nativeUpdate(JDBCServiceManagerProperties jdbcProperties, Logger log,Connection connection,ISQLQueryObject sqlObject, String sql,Object ... param) throws ServiceException,NotImplementedException, Exception {
  311.     
  312.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeUpdate(jdbcProperties, log, connection, sqlObject,
  313.                                                                                             sql,param);
  314.     
  315.     }
  316. }
Created with JaCoCo 0.8.8.202204050719