JDBCCredenzialeMittenteServiceImpl.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.  */

  21. package org.openspcoop2.core.transazioni.dao.jdbc;

  23. import java.sql.Connection;

  25. import org.openspcoop2.utils.TipiDatabase;
  26. import org.openspcoop2.utils.sql.ISQLQueryObject;

  28. import org.slf4j.Logger;

  30. import org.openspcoop2.generic_project.dao.jdbc.IJDBCServiceCRUDWithId;
  31. import org.openspcoop2.core.transazioni.IdCredenzialeMittente;
  32. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  33. import org.openspcoop2.generic_project.beans.UpdateField;
  34. import org.openspcoop2.generic_project.beans.UpdateModel;

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

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

  47. import org.openspcoop2.core.transazioni.CredenzialeMittente;

  49. /**     
  50.  * JDBCCredenzialeMittenteServiceImpl
  51.  *
  52.  * @author Poli Andrea (poli@link.it)
  53.  * @author $Author$
  54.  * @version $Rev$, $Date$
  55.  */
  56. public class JDBCCredenzialeMittenteServiceImpl extends JDBCCredenzialeMittenteServiceSearchImpl
  57.     implements IJDBCServiceCRUDWithId<CredenzialeMittente, IdCredenzialeMittente, JDBCServiceManager> {

  59.     @Override
  60.     public void create(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, CredenzialeMittente credenzialeMittente, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {

  62.         if(TipiDatabase.POSTGRESQL.equals(jdbcProperties.getDatabase()) && org.openspcoop2.utils.jdbc.PostgreSQLUtilities.containsNullByteSequence(credenzialeMittente.getCredenziale())){
  63.             credenzialeMittente.setCredenziale(org.openspcoop2.utils.jdbc.PostgreSQLUtilities.normalizeString(credenzialeMittente.getCredenziale()));
  64.         }
  65.         
  66.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  67.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  68.         
  69.         ISQLQueryObject sqlQueryObjectInsert = sqlQueryObject.newSQLQueryObject();
  70.                 


  73.         // Object credenzialeMittente
  74.         sqlQueryObjectInsert.addInsertTable(this.getCredenzialeMittenteFieldConverter().toTable(CredenzialeMittente.model()));
  75.         sqlQueryObjectInsert.addInsertField(this.getCredenzialeMittenteFieldConverter().toColumn(CredenzialeMittente.model().TIPO,false),"?");
  76.         sqlQueryObjectInsert.addInsertField(this.getCredenzialeMittenteFieldConverter().toColumn(CredenzialeMittente.model().CREDENZIALE,false),"?");
  77.         sqlQueryObjectInsert.addInsertField(this.getCredenzialeMittenteFieldConverter().toColumn(CredenzialeMittente.model().ORA_REGISTRAZIONE,false),"?");
  78.         sqlQueryObjectInsert.addInsertField(this.getCredenzialeMittenteFieldConverter().toColumn(CredenzialeMittente.model().REF_CREDENZIALE,false),"?");

  80.         // Insert credenzialeMittente
  81.         org.openspcoop2.utils.jdbc.IKeyGeneratorObject keyGenerator = this.getCredenzialeMittenteFetch().getKeyGeneratorObject(CredenzialeMittente.model());
  82.         long id = jdbcUtilities.insertAndReturnGeneratedKey(sqlQueryObjectInsert, keyGenerator, jdbcProperties.isShowSql(),
  83.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(credenzialeMittente.getTipo(),CredenzialeMittente.model().TIPO.getFieldType()),
  84.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(credenzialeMittente.getCredenziale(),CredenzialeMittente.model().CREDENZIALE.getFieldType()),
  85.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(credenzialeMittente.getOraRegistrazione(),CredenzialeMittente.model().ORA_REGISTRAZIONE.getFieldType()),
  86.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(credenzialeMittente.getRefCredenziale(),CredenzialeMittente.model().REF_CREDENZIALE.getFieldType())
  87.         );
  88.         credenzialeMittente.setId(id);

  90.         
  91.     }

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

  110.         this.update(jdbcProperties, log, connection, sqlQueryObject, tableId, credenzialeMittente, idMappingResolutionBehaviour);
  111.     }
  112.     @Override
  113.     public void update(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, CredenzialeMittente credenzialeMittente, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  114.     
  115.         if(TipiDatabase.POSTGRESQL.equals(jdbcProperties.getDatabase()) && org.openspcoop2.utils.jdbc.PostgreSQLUtilities.containsNullByteSequence(credenzialeMittente.getCredenziale())){
  116.             credenzialeMittente.setCredenziale(org.openspcoop2.utils.jdbc.PostgreSQLUtilities.normalizeString(credenzialeMittente.getCredenziale()));
  117.         }
  118.         
  119.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  120.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  121.         
  122.         ISQLQueryObject sqlQueryObjectInsert = sqlQueryObject.newSQLQueryObject();
  123.         ISQLQueryObject sqlQueryObjectDelete = sqlQueryObjectInsert.newSQLQueryObject();
  124.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObjectDelete.newSQLQueryObject();
  125.         ISQLQueryObject sqlQueryObjectUpdate = sqlQueryObjectGet.newSQLQueryObject();
  126.         


  129.         // Object credenzialeMittente
  130.         sqlQueryObjectUpdate.setANDLogicOperator(true);
  131.         sqlQueryObjectUpdate.addUpdateTable(this.getCredenzialeMittenteFieldConverter().toTable(CredenzialeMittente.model()));
  132.         boolean isUpdate_credenzialeMittente = true;
  133.         java.util.List<JDBCObject> lstObjects_credenzialeMittente = new java.util.ArrayList<>();
  134.         sqlQueryObjectUpdate.addUpdateField(this.getCredenzialeMittenteFieldConverter().toColumn(CredenzialeMittente.model().TIPO,false), "?");
  135.         lstObjects_credenzialeMittente.add(new JDBCObject(credenzialeMittente.getTipo(), CredenzialeMittente.model().TIPO.getFieldType()));
  136.         sqlQueryObjectUpdate.addUpdateField(this.getCredenzialeMittenteFieldConverter().toColumn(CredenzialeMittente.model().CREDENZIALE,false), "?");
  137.         lstObjects_credenzialeMittente.add(new JDBCObject(credenzialeMittente.getCredenziale(), CredenzialeMittente.model().CREDENZIALE.getFieldType()));
  138.         sqlQueryObjectUpdate.addUpdateField(this.getCredenzialeMittenteFieldConverter().toColumn(CredenzialeMittente.model().ORA_REGISTRAZIONE,false), "?");
  139.         lstObjects_credenzialeMittente.add(new JDBCObject(credenzialeMittente.getOraRegistrazione(), CredenzialeMittente.model().ORA_REGISTRAZIONE.getFieldType()));
  140.         sqlQueryObjectUpdate.addUpdateField(this.getCredenzialeMittenteFieldConverter().toColumn(CredenzialeMittente.model().REF_CREDENZIALE,false), "?");
  141.         lstObjects_credenzialeMittente.add(new JDBCObject(credenzialeMittente.getRefCredenziale(), CredenzialeMittente.model().REF_CREDENZIALE.getFieldType()));
  142.         sqlQueryObjectUpdate.addWhereCondition("id=?");
  143.         lstObjects_credenzialeMittente.add(new JDBCObject(tableId, Long.class));

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


  152.     }
  153.     
  154.     @Override
  155.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdCredenzialeMittente id, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  156.         
  157.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  158.                 this.getCredenzialeMittenteFieldConverter().toTable(CredenzialeMittente.model()), 
  159.                 this.getMapTableToPKColumnEngine(), 
  160.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  161.                 this.getCredenzialeMittenteFieldConverter(), this, null, updateFields);
  162.     }
  163.     
  164.     @Override
  165.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdCredenzialeMittente id, IExpression condition, UpdateField ... updateFields) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  166.         
  167.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  168.                 this.getCredenzialeMittenteFieldConverter().toTable(CredenzialeMittente.model()), 
  169.                 this.getMapTableToPKColumnEngine(), 
  170.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  171.                 this.getCredenzialeMittenteFieldConverter(), this, condition, updateFields);
  172.     }
  173.     
  174.     @Override
  175.     public void updateFields(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdCredenzialeMittente id, UpdateModel ... updateModels) throws NotFoundException, NotImplementedException, ServiceException, Exception {
  176.         
  177.         GenericJDBCUtilities.updateFields(jdbcProperties, log, connection, sqlQueryObject, 
  178.                 this.getCredenzialeMittenteFieldConverter().toTable(CredenzialeMittente.model()), 
  179.                 this.getMapTableToPKColumnEngine(), 
  180.                 this.getRootTablePrimaryKeyValuesEngine(jdbcProperties, log, connection, sqlQueryObject, id),
  181.                 this.getCredenzialeMittenteFieldConverter(), 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.getCredenzialeMittenteFieldConverter().toTable(CredenzialeMittente.model()), 
  190.                 this.getMapTableToPKColumnEngine(), 
  191.                 ids,
  192.                 this.getCredenzialeMittenteFieldConverter(), 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.getCredenzialeMittenteFieldConverter().toTable(CredenzialeMittente.model()), 
  201.                 this.getMapTableToPKColumnEngine(), 
  202.                 ids,
  203.                 this.getCredenzialeMittenteFieldConverter(), 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.getCredenzialeMittenteFieldConverter().toTable(CredenzialeMittente.model()), 
  212.                 this.getMapTableToPKColumnEngine(), 
  213.                 ids,
  214.                 this.getCredenzialeMittenteFieldConverter(), this, updateModels);
  215.     }
  216.     
  217.     @Override
  218.     public void updateOrCreate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdCredenzialeMittente oldId, CredenzialeMittente credenzialeMittente, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {
  219.     
  220.         if(this.exists(jdbcProperties, log, connection, sqlQueryObject, oldId)) {
  221.             this.update(jdbcProperties, log, connection, sqlQueryObject, oldId, credenzialeMittente,idMappingResolutionBehaviour);
  222.         } else {
  223.             this.create(jdbcProperties, log, connection, sqlQueryObject, credenzialeMittente,idMappingResolutionBehaviour);
  224.         }
  225.         
  226.     }
  227.     
  228.     @Override
  229.     public void updateOrCreate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, CredenzialeMittente credenzialeMittente, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException,ServiceException,Exception {
  230.         if(this.exists(jdbcProperties, log, connection, sqlQueryObject, tableId)) {
  231.             this.update(jdbcProperties, log, connection, sqlQueryObject, tableId, credenzialeMittente,idMappingResolutionBehaviour);
  232.         } else {
  233.             this.create(jdbcProperties, log, connection, sqlQueryObject, credenzialeMittente,idMappingResolutionBehaviour);
  234.         }
  235.     }
  236.     
  237.     @Override
  238.     public void delete(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, CredenzialeMittente credenzialeMittente) throws NotImplementedException,ServiceException,Exception {
  239.         
  240.         
  241.         Long longId = null;
  242.         if( (credenzialeMittente.getId()!=null) && (credenzialeMittente.getId()>0) ){
  243.             longId = credenzialeMittente.getId();
  244.         }
  245.         else{
  246.             IdCredenzialeMittente idCredenzialeMittente = this.convertToId(jdbcProperties,log,connection,sqlQueryObject,credenzialeMittente);
  247.             longId = this.findIdCredenzialeMittente(jdbcProperties,log,connection,sqlQueryObject,idCredenzialeMittente,false);
  248.             if(longId == null){
  249.                 return; // entry not exists
  250.             }
  251.         }       
  252.         
  253.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, longId);
  254.         
  255.     }

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

  269.         // Object credenzialeMittente
  270.         sqlQueryObjectDelete.setANDLogicOperator(true);
  271.         sqlQueryObjectDelete.addDeleteTable(this.getCredenzialeMittenteFieldConverter().toTable(CredenzialeMittente.model()));
  272.         if(id != null)
  273.             sqlQueryObjectDelete.addWhereCondition("id=?");

  275.         // Delete credenzialeMittente
  276.         jdbcUtilities.execute(sqlQueryObjectDelete.createSQLDelete(), jdbcProperties.isShowSql(), 
  277.             new JDBCObject(id,Long.class));

  279.     }

  281.     @Override
  282.     public void deleteById(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdCredenzialeMittente idCredenzialeMittente) throws NotImplementedException,ServiceException,Exception {

  284.         Long id = null;
  285.         try{
  286.             id = this.findIdCredenzialeMittente(jdbcProperties, log, connection, sqlQueryObject, idCredenzialeMittente, true);
  287.         }catch(NotFoundException notFound){
  288.             return;
  289.         }
  290.         this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  291.         
  292.     }
  293.     
  294.     @Override
  295.     public NonNegativeNumber deleteAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject) throws NotImplementedException,ServiceException,Exception {
  296.         
  297.         return this.deleteAll(jdbcProperties, log, connection, sqlQueryObject, new JDBCExpression(this.getCredenzialeMittenteFieldConverter()));

  299.     }

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

  304.         java.util.List<Long> lst = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, new JDBCPaginatedExpression(expression));
  305.         
  306.         for(Long id : lst) {
  307.             this.deleteEngine(jdbcProperties, log, connection, sqlQueryObject, id);
  308.         }
  309.         
  310.         return new NonNegativeNumber(lst.size());
  311.     
  312.     }



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