JDBCTransazioneApplicativoServerServiceSearchImpl.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.transazioni.dao.jdbc;

  22. import java.sql.Connection;
  23. import java.util.ArrayList;
  24. import java.util.List;
  25. import java.util.Map;

  27. import org.openspcoop2.core.transazioni.IdTransazioneApplicativoServer;
  28. import org.openspcoop2.core.transazioni.TransazioneApplicativoServer;
  29. import org.openspcoop2.core.transazioni.dao.jdbc.converter.TransazioneApplicativoServerFieldConverter;
  30. import org.openspcoop2.core.transazioni.dao.jdbc.fetch.TransazioneApplicativoServerFetch;
  31. import org.openspcoop2.generic_project.beans.CustomField;
  32. import org.openspcoop2.generic_project.beans.FunctionField;
  33. import org.openspcoop2.generic_project.beans.IField;
  34. import org.openspcoop2.generic_project.beans.InUse;
  35. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  36. import org.openspcoop2.generic_project.beans.Union;
  37. import org.openspcoop2.generic_project.beans.UnionExpression;
  38. import org.openspcoop2.generic_project.dao.jdbc.IJDBCServiceSearchWithId;
  39. import org.openspcoop2.generic_project.dao.jdbc.JDBCExpression;
  40. import org.openspcoop2.generic_project.dao.jdbc.JDBCPaginatedExpression;
  41. import org.openspcoop2.generic_project.dao.jdbc.JDBCServiceManagerProperties;
  42. import org.openspcoop2.generic_project.dao.jdbc.utils.IJDBCFetch;
  43. import org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject;
  44. import org.openspcoop2.generic_project.exception.MultipleResultException;
  45. import org.openspcoop2.generic_project.exception.NotFoundException;
  46. import org.openspcoop2.generic_project.exception.NotImplementedException;
  47. import org.openspcoop2.generic_project.exception.ServiceException;
  48. import org.openspcoop2.generic_project.expression.IExpression;
  49. import org.openspcoop2.generic_project.expression.impl.sql.ISQLFieldConverter;
  50. import org.openspcoop2.generic_project.utils.UtilsTemplate;
  51. import org.openspcoop2.utils.sql.ISQLQueryObject;
  52. import org.openspcoop2.utils.sql.SQLQueryObjectCore;
  53. import org.slf4j.Logger;

  55. /**     
  56.  * JDBCTransazioneApplicativoServerServiceSearchImpl
  57.  *
  58.  * @author Poli Andrea (poli@link.it)
  59.  * @author $Author$
  60.  * @version $Rev$, $Date$
  61.  */
  62. public class JDBCTransazioneApplicativoServerServiceSearchImpl implements IJDBCServiceSearchWithId<TransazioneApplicativoServer, IdTransazioneApplicativoServer, JDBCServiceManager> {

  64.     private TransazioneApplicativoServerFieldConverter _transazioneApplicativoServerFieldConverter = null;
  65.     public TransazioneApplicativoServerFieldConverter getTransazioneApplicativoServerFieldConverter() {
  66.         if(this._transazioneApplicativoServerFieldConverter==null){
  67.             this._transazioneApplicativoServerFieldConverter = new TransazioneApplicativoServerFieldConverter(this.jdbcServiceManager.getJdbcProperties().getDatabaseType());
  68.         }       
  69.         return this._transazioneApplicativoServerFieldConverter;
  70.     }
  71.     @Override
  72.     public ISQLFieldConverter getFieldConverter() {
  73.         return this.getTransazioneApplicativoServerFieldConverter();
  74.     }
  75.     
  76.     private TransazioneApplicativoServerFetch transazioneApplicativoServerFetch = new TransazioneApplicativoServerFetch();
  77.     public TransazioneApplicativoServerFetch getTransazioneApplicativoServerFetch() {
  78.         return this.transazioneApplicativoServerFetch;
  79.     }
  80.     @Override
  81.     public IJDBCFetch getFetch() {
  82.         return getTransazioneApplicativoServerFetch();
  83.     }
  84.     
  85.     
  86.     private JDBCServiceManager jdbcServiceManager = null;

  88.     @Override
  89.     public void setServiceManager(JDBCServiceManager serviceManager) throws ServiceException{
  90.         this.jdbcServiceManager = serviceManager;
  91.     }
  92.     
  93.     @Override
  94.     public JDBCServiceManager getServiceManager() throws ServiceException{
  95.         return this.jdbcServiceManager;
  96.     }
  97.     

  99.     @Override
  100.     public IdTransazioneApplicativoServer convertToId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, TransazioneApplicativoServer transazioneApplicativoServer) throws NotImplementedException, ServiceException, Exception{
  101.     
  102.         IdTransazioneApplicativoServer idTransazioneApplicativoServer = new IdTransazioneApplicativoServer();
  103.         idTransazioneApplicativoServer.setIdTransazione(transazioneApplicativoServer.getIdTransazione());
  104.         idTransazioneApplicativoServer.setServizioApplicativoErogatore(transazioneApplicativoServer.getServizioApplicativoErogatore());
  105.         return idTransazioneApplicativoServer;
  106.     }
  107.     
  108.     private static boolean efficiente = true;
  109.     public static boolean isEfficiente() {
  110.         return efficiente;
  111.     }
  112.     public static void setEfficiente(boolean efficiente) {
  113.         JDBCTransazioneApplicativoServerServiceSearchImpl.efficiente = efficiente;
  114.     }
  115.     @Override
  116.     public TransazioneApplicativoServer get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdTransazioneApplicativoServer id, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {
  117.         
  118.         long id_long = (id!=null && id.getId()!=null && id.getId()>0) ? id.getId() : -1;
  119.         
  120.         if(id_long<=0 && efficiente){
  121.         
  122.             if(id==null) {
  123.                 throw new ServiceException("Id non definito");
  124.             }
  125.             if(id.getIdTransazione()==null) {
  126.                 throw new ServiceException("IdTransazione non definito");
  127.             }
  128.             if(id.getServizioApplicativoErogatore()==null) {
  129.                 throw new ServiceException("IdServizioApplicativoErogatore non definito");
  130.             }
  131.             
  132.             JDBCPaginatedExpression pagExpr = this.newPaginatedExpression(log);
  133.             pagExpr.equals(TransazioneApplicativoServer.model().ID_TRANSAZIONE, id.getIdTransazione());
  134.             pagExpr.and();
  135.             pagExpr.equals(TransazioneApplicativoServer.model().SERVIZIO_APPLICATIVO_EROGATORE, id.getServizioApplicativoErogatore());
  136.             //pagExpr.limit(2); Inefficiente, per implementare il multipleresult che poi non può succedere
  137.             if(sqlQueryObject==null || !(sqlQueryObject instanceof SQLQueryObjectCore) || !((SQLQueryObjectCore)sqlQueryObject).isSelectForUpdate()) {
  138.                 pagExpr.limit(1);
  139.                 // essendoci lo unique comunque il limit serve a poco, e nello stesso tempo la select for update non lo vuole
  140.             }
  141.                         
  142.             List<TransazioneApplicativoServer> list = findAll(jdbcProperties, log, connection, sqlQueryObject, pagExpr, idMappingResolutionBehaviour);
  143.             
  144.             if(list==null || list.size()<1) {
  145.                 throw new NotFoundException();
  146.             }
  147.             // C'è lo unique sulle due colonne
  148. //          else if(list.size()>1) {
  149. //              throw new MultipleResultException();
  150. //          }
  151.             else {
  152.                 return list.get(0);
  153.             }
  154.             
  155.         }
  156.         else {
  157.         
  158.             Long id_transazioneApplicativoServer = ( (id!=null && id.getId()!=null && id.getId()>0) ? id.getId() : this.findIdTransazioneApplicativoServer(jdbcProperties, log, connection, sqlQueryObject, id, true));
  159.             return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, id_transazioneApplicativoServer,idMappingResolutionBehaviour);
  160.         
  161.         }
  162.     }
  163.     
  164.     @Override
  165.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdTransazioneApplicativoServer id) throws MultipleResultException, NotImplementedException, ServiceException,Exception {

  167.         Long id_transazioneApplicativoServer = this.findIdTransazioneApplicativoServer(jdbcProperties, log, connection, sqlQueryObject, id, false);
  168.         return id_transazioneApplicativoServer != null && id_transazioneApplicativoServer > 0;
  169.         
  170.     }
  171.     
  172.     @Override
  173.     public List<IdTransazioneApplicativoServer> findAllIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException, ServiceException,Exception {

  175.         List<IdTransazioneApplicativoServer> list = new ArrayList<IdTransazioneApplicativoServer>();

  177.         // TODO: implementazione non efficiente. 
  178.         // Per ottenere una implementazione efficiente:
  179.         // 1. Usare metodo select di questa classe indirizzando esattamente i field necessari a create l'ID logico
  180.         // 2. Usare metodo getTransazioneApplicativoServerFetch() sul risultato della select per ottenere un oggetto TransazioneApplicativoServer
  181.         //    La fetch con la map inserirà nell'oggetto solo i valori estratti 
  182.         // 3. Usare metodo convertToId per ottenere l'id

  184.         List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  185.         
  186.         for(Long id: ids) {
  187.             TransazioneApplicativoServer transazioneApplicativoServer = this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour);
  188.             IdTransazioneApplicativoServer idTransazioneApplicativoServer = this.convertToId(jdbcProperties,log,connection,sqlQueryObject,transazioneApplicativoServer);
  189.             list.add(idTransazioneApplicativoServer);
  190.         }

  192.         return list;
  193.         
  194.     }
  195.     
  196.     private static boolean distinct = false;
  197.     
  198.     public static boolean isDistinct() {
  199.         return distinct;
  200.     }
  201.     public static void setDistinct(boolean distinct) {
  202.         JDBCTransazioneApplicativoServerServiceSearchImpl.distinct = distinct;
  203.     }
  204.     @Override
  205.     public List<TransazioneApplicativoServer> findAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException, ServiceException,Exception {

  207.         List<TransazioneApplicativoServer> list = new ArrayList<TransazioneApplicativoServer>();

  209.         if(efficiente){
  210.         
  211.             List<IField> fields = new ArrayList<IField>();
  212.             fields.add(new CustomField("id", Long.class, "id", this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model())));  
  213.             fields.add(TransazioneApplicativoServer.model().ID_TRANSAZIONE);
  214.             fields.add(TransazioneApplicativoServer.model().SERVIZIO_APPLICATIVO_EROGATORE);
  215.             fields.add(TransazioneApplicativoServer.model().CONNETTORE_NOME);
  216.             fields.add(TransazioneApplicativoServer.model().DATA_REGISTRAZIONE);
  217.             // NONSERIALIZZATO SU DB fields.add(TransazioneApplicativoServer.model().PROTOCOLLO);
  218.             fields.add(TransazioneApplicativoServer.model().CONSEGNA_TERMINATA);
  219.             fields.add(TransazioneApplicativoServer.model().DATA_MESSAGGIO_SCADUTO);
  220.             fields.add(TransazioneApplicativoServer.model().DETTAGLIO_ESITO);
  221.             fields.add(TransazioneApplicativoServer.model().CONSEGNA_TRASPARENTE);
  222.             fields.add(TransazioneApplicativoServer.model().CONSEGNA_INTEGRATION_MANAGER);
  223.             fields.add(TransazioneApplicativoServer.model().IDENTIFICATIVO_MESSAGGIO);
  224.             fields.add(TransazioneApplicativoServer.model().DATA_ACCETTAZIONE_RICHIESTA);
  225.             fields.add(TransazioneApplicativoServer.model().DATA_USCITA_RICHIESTA);
  226.             fields.add(TransazioneApplicativoServer.model().DATA_USCITA_RICHIESTA_STREAM);
  227.             fields.add(TransazioneApplicativoServer.model().DATA_ACCETTAZIONE_RISPOSTA);
  228.             fields.add(TransazioneApplicativoServer.model().DATA_INGRESSO_RISPOSTA);
  229.             fields.add(TransazioneApplicativoServer.model().DATA_INGRESSO_RISPOSTA_STREAM);
  230.             fields.add(TransazioneApplicativoServer.model().RICHIESTA_USCITA_BYTES);
  231.             fields.add(TransazioneApplicativoServer.model().RISPOSTA_INGRESSO_BYTES);
  232.             fields.add(TransazioneApplicativoServer.model().LOCATION_CONNETTORE);
  233.             fields.add(TransazioneApplicativoServer.model().CODICE_RISPOSTA);
  234.             fields.add(TransazioneApplicativoServer.model().FAULT);
  235.             fields.add(TransazioneApplicativoServer.model().FORMATO_FAULT);
  236.             fields.add(TransazioneApplicativoServer.model().DATA_PRIMO_TENTATIVO);
  237.             fields.add(TransazioneApplicativoServer.model().NUMERO_TENTATIVI);
  238.             fields.add(TransazioneApplicativoServer.model().CLUSTER_ID_PRESA_IN_CARICO);
  239.             fields.add(TransazioneApplicativoServer.model().CLUSTER_ID_CONSEGNA);
  240.             fields.add(TransazioneApplicativoServer.model().DATA_ULTIMO_ERRORE);
  241.             fields.add(TransazioneApplicativoServer.model().DETTAGLIO_ESITO_ULTIMO_ERRORE);
  242.             fields.add(TransazioneApplicativoServer.model().CODICE_RISPOSTA_ULTIMO_ERRORE);
  243.             fields.add(TransazioneApplicativoServer.model().ULTIMO_ERRORE);
  244.             fields.add(TransazioneApplicativoServer.model().LOCATION_ULTIMO_ERRORE);
  245.             fields.add(TransazioneApplicativoServer.model().CLUSTER_ID_ULTIMO_ERRORE);
  246.             fields.add(TransazioneApplicativoServer.model().FAULT_ULTIMO_ERRORE);
  247.             fields.add(TransazioneApplicativoServer.model().FORMATO_FAULT_ULTIMO_ERRORE);
  248.             fields.add(TransazioneApplicativoServer.model().DATA_PRIMO_PRELIEVO_IM);
  249.             fields.add(TransazioneApplicativoServer.model().DATA_PRELIEVO_IM);
  250.             fields.add(TransazioneApplicativoServer.model().NUMERO_PRELIEVI_IM);
  251.             fields.add(TransazioneApplicativoServer.model().DATA_ELIMINAZIONE_IM);
  252.             fields.add(TransazioneApplicativoServer.model().CLUSTER_ID_PRELIEVO_IM);
  253.             fields.add(TransazioneApplicativoServer.model().CLUSTER_ID_ELIMINAZIONE_IM);
  254.             
  255.             List<Map<String, Object>> returnMap = null;
  256.             try{
  257.                  // Il distinct serve solo se ci sono le ricerche con contenuto.
  258.                 // NOTA: il distinct rende le ricerce inefficienti (ed inoltre non e' utilizzabile con campi clob in oracle)
  259.                 
  260.                 
  261.                 // BUG FIX: Siccome tra le colonne lette ci sono dei CLOB, in oracle non e' consentito utilizzare il DISTINCT.
  262.                 // Per questo motivo se c'e' da usare il distinct viene utilizzato il vecchio metodo
  263.                 if(distinct) {
  264.                     //System.out.println("NON EFFICIENTE");
  265.                     
  266.                      List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  267.                     
  268.                     for(Long id: ids) {
  269.                         list.add(this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour));
  270.                     }
  271.                     
  272.                 }
  273.                 else {
  274.                 
  275.                     //System.out.println("EFFICIENTE");
  276.                     
  277.                     returnMap = this.select(jdbcProperties, log, connection, sqlQueryObject, expression, distinct, fields.toArray(new IField[1]));
  278.         
  279.                     for(Map<String, Object> map: returnMap) {
  280.                         list.add((TransazioneApplicativoServer)this.getTransazioneApplicativoServerFetch().fetch(jdbcProperties.getDatabase(), TransazioneApplicativoServer.model(), map));
  281.                     }
  282.                     
  283.                 }
  284.                     
  285.             }catch(NotFoundException notFound){}
  286.         }
  287.         else {
  288.        
  289.             List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  290.             
  291.             for(Long id: ids) {
  292.                 list.add(this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour));
  293.             }
  294.             
  295.         }

  297.         return list;      
  298.         
  299.     }
  300.     
  301.     @Override
  302.     public TransazioneApplicativoServer find(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) 
  303.         throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {

  305.         if(efficiente){
  306.         
  307.             JDBCPaginatedExpression pagExpr = this.toPaginatedExpression(expression, log);
  308.             pagExpr.limit(2);
  309.             
  310.             List<TransazioneApplicativoServer> list = findAll(jdbcProperties, log, connection, sqlQueryObject, pagExpr, idMappingResolutionBehaviour);
  311.             
  312.             if(list==null || list.size()<1) {
  313.                 throw new NotFoundException();
  314.             }
  315.             else if(list.size()>1) {
  316.                 throw new MultipleResultException();
  317.             }
  318.             else {
  319.                 return list.get(0);
  320.             }
  321.             
  322.         }
  323.         else {
  324.             
  325.             
  326.             long id = this.findTableId(jdbcProperties, log, connection, sqlQueryObject, expression);
  327.             if(id>0){
  328.                 return this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour);
  329.             }else{
  330.                 throw new NotFoundException("Entry with id["+id+"] not found");
  331.             }
  332.             
  333.         }
  334.         
  335.     }
  336.     
  337.     @Override
  338.     public NonNegativeNumber count(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws NotImplementedException, ServiceException,Exception {
  339.         
  340.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareCount(jdbcProperties, log, connection, sqlQueryObject, expression,
  341.                                                 this.getTransazioneApplicativoServerFieldConverter(), TransazioneApplicativoServer.model());
  342.         
  343.         sqlQueryObject.addSelectCountField(this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model())+".id","tot",true);
  344.         
  345.         joinEngine(expression,sqlQueryObject);
  346.         
  347.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.count(jdbcProperties, log, connection, sqlQueryObject, expression,
  348.                                                                             this.getTransazioneApplicativoServerFieldConverter(), TransazioneApplicativoServer.model(),listaQuery);
  349.     }

  351.     @Override
  352.     public InUse inUse(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdTransazioneApplicativoServer id) throws NotFoundException, NotImplementedException, ServiceException,Exception {
  353.         
  354.         Long id_transazioneApplicativoServer = this.findIdTransazioneApplicativoServer(jdbcProperties, log, connection, sqlQueryObject, id, true);
  355.         return this.inUseEngine(jdbcProperties, log, connection, sqlQueryObject, id_transazioneApplicativoServer);
  356.         
  357.     }

  359.     @Override
  360.     public List<Object> select(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  361.                                                     JDBCPaginatedExpression paginatedExpression, IField field) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  362.         return this.select(jdbcProperties, log, connection, sqlQueryObject,
  363.                                 paginatedExpression, false, field);
  364.     }
  365.     
  366.     @Override
  367.     public List<Object> select(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  368.                                                     JDBCPaginatedExpression paginatedExpression, boolean distinct, IField field) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  369.         List<Map<String,Object>> map = 
  370.             this.select(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression, distinct, new IField[]{field});
  371.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.selectSingleObject(map);
  372.     }
  373.     
  374.     @Override
  375.     public List<Map<String,Object>> select(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  376.                                                     JDBCPaginatedExpression paginatedExpression, IField ... field) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  377.         return this.select(jdbcProperties, log, connection, sqlQueryObject,
  378.                                 paginatedExpression, false, field);
  379.     }
  380.     
  381.     @Override
  382.     public List<Map<String,Object>> select(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  383.                                                     JDBCPaginatedExpression paginatedExpression, boolean distinct, IField ... field) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  384.         
  385.         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.setFields(sqlQueryObject,paginatedExpression,field);
  386.         try{
  387.         
  388.             ISQLQueryObject sqlQueryObjectDistinct = 
  389.                         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareSqlQueryObjectForSelectDistinct(distinct,sqlQueryObject, paginatedExpression, log,
  390.                                                 this.getTransazioneApplicativoServerFieldConverter(), field);

  392.             return selectEngine(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression, sqlQueryObjectDistinct);
  393.             
  394.         }finally{
  395.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,paginatedExpression,field);
  396.         }
  397.     }

  399.     @Override
  400.     public Object aggregate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  401.                                                     JDBCExpression expression, FunctionField functionField) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  402.         Map<String,Object> map = 
  403.             this.aggregate(jdbcProperties, log, connection, sqlQueryObject, expression, new FunctionField[]{functionField});
  404.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.selectAggregateObject(map,functionField);
  405.     }
  406.     
  407.     @Override
  408.     public Map<String,Object> aggregate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  409.                                                     JDBCExpression expression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException,Exception {                                                   
  410.         
  411.         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.setFields(sqlQueryObject,expression,functionField);
  412.         try{
  413.             List<Map<String,Object>> list = selectEngine(jdbcProperties, log, connection, sqlQueryObject, expression);
  414.             return list.get(0);
  415.         }finally{
  416.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,expression,functionField);
  417.         }
  418.     }

  420.     @Override
  421.     public List<Map<String,Object>> groupBy(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  422.                                                     JDBCExpression expression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  423.         
  424.         if(expression.getGroupByFields().isEmpty()){
  425.             throw new ServiceException("GroupBy conditions not found in expression");
  426.         }
  427.         
  428.         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.setFields(sqlQueryObject,expression,functionField);
  429.         try{
  430.             return selectEngine(jdbcProperties, log, connection, sqlQueryObject, expression);
  431.         }finally{
  432.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,expression,functionField);
  433.         }
  434.     }
  435.     

  437.     @Override
  438.     public List<Map<String,Object>> groupBy(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  439.                                                     JDBCPaginatedExpression paginatedExpression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  440.         
  441.         if(paginatedExpression.getGroupByFields().isEmpty()){
  442.             throw new ServiceException("GroupBy conditions not found in expression");
  443.         }
  444.         
  445.         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.setFields(sqlQueryObject,paginatedExpression,functionField);
  446.         try{
  447.             return selectEngine(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression);
  448.         }finally{
  449.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,paginatedExpression,functionField);
  450.         }
  451.     }
  452.     
  453.     protected List<Map<String,Object>> selectEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  454.                                                 IExpression expression) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  455.         return selectEngine(jdbcProperties, log, connection, sqlQueryObject, expression, null);
  456.     }
  457.     protected List<Map<String,Object>> selectEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  458.                                                 IExpression expression, ISQLQueryObject sqlQueryObjectDistinct) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  459.         
  460.         List<Object> listaQuery = new ArrayList<>();
  461.         List<JDBCObject> listaParams = new ArrayList<>();
  462.         List<Object> returnField = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareSelect(jdbcProperties, log, connection, sqlQueryObject, 
  463.                                 expression, this.getTransazioneApplicativoServerFieldConverter(), TransazioneApplicativoServer.model(), 
  464.                                 listaQuery,listaParams);
  465.         
  466.         joinEngine(expression,sqlQueryObject);
  467.         
  468.         List<Map<String,Object>> list = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.select(jdbcProperties, log, connection,
  469.                                         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareSqlQueryObjectForSelectDistinct(sqlQueryObject,sqlQueryObjectDistinct), 
  470.                                         expression, this.getTransazioneApplicativoServerFieldConverter(), TransazioneApplicativoServer.model(),
  471.                                         listaQuery,listaParams,returnField);
  472.         if(list!=null && !list.isEmpty()){
  473.             return list;
  474.         }
  475.         else{
  476.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  477.         }
  478.     }
  479.     
  480.     @Override
  481.     public List<Map<String,Object>> union(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  482.                                                 Union union, UnionExpression ... unionExpression) throws ServiceException,NotFoundException,NotImplementedException,Exception {     
  483.         
  484.         List<ISQLQueryObject> sqlQueryObjectInnerList = new ArrayList<>();
  485.         List<JDBCObject> jdbcObjects = new ArrayList<>();
  486.         List<Class<?>> returnClassTypes = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareUnion(jdbcProperties, log, connection, sqlQueryObject, 
  487.                                 this.getTransazioneApplicativoServerFieldConverter(), TransazioneApplicativoServer.model(), 
  488.                                 sqlQueryObjectInnerList, jdbcObjects, union, unionExpression);
  489.         
  490.         if(unionExpression!=null){
  491.             for (int i = 0; i < unionExpression.length; i++) {
  492.                 UnionExpression ue = unionExpression[i];
  493.                 IExpression expression = ue.getExpression();
  494.                 joinEngine(expression,sqlQueryObjectInnerList.get(i));
  495.             }
  496.         }
  497.         
  498.         List<Map<String,Object>> list = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.union(jdbcProperties, log, connection, sqlQueryObject, 
  499.                                         this.getTransazioneApplicativoServerFieldConverter(), TransazioneApplicativoServer.model(), 
  500.                                         sqlQueryObjectInnerList, jdbcObjects, returnClassTypes, union, unionExpression);
  501.         if(list!=null && !list.isEmpty()){
  502.             return list;
  503.         }
  504.         else{
  505.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  506.         }                               
  507.     }
  508.     
  509.     @Override
  510.     public NonNegativeNumber unionCount(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  511.                                                 Union union, UnionExpression ... unionExpression) throws ServiceException,NotFoundException,NotImplementedException,Exception {     
  512.         
  513.         List<ISQLQueryObject> sqlQueryObjectInnerList = new ArrayList<>();
  514.         List<JDBCObject> jdbcObjects = new ArrayList<>();
  515.         List<Class<?>> returnClassTypes = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareUnionCount(jdbcProperties, log, connection, sqlQueryObject, 
  516.                                 this.getTransazioneApplicativoServerFieldConverter(), TransazioneApplicativoServer.model(), 
  517.                                 sqlQueryObjectInnerList, jdbcObjects, union, unionExpression);
  518.         
  519.         if(unionExpression!=null){
  520.             for (int i = 0; i < unionExpression.length; i++) {
  521.                 UnionExpression ue = unionExpression[i];
  522.                 IExpression expression = ue.getExpression();
  523.                 joinEngine(expression,sqlQueryObjectInnerList.get(i));
  524.             }
  525.         }
  526.         
  527.         NonNegativeNumber number = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.unionCount(jdbcProperties, log, connection, sqlQueryObject, 
  528.                                         this.getTransazioneApplicativoServerFieldConverter(), TransazioneApplicativoServer.model(), 
  529.                                         sqlQueryObjectInnerList, jdbcObjects, returnClassTypes, union, unionExpression);
  530.         if(number!=null && number.longValue()>=0){
  531.             return number;
  532.         }
  533.         else{
  534.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  535.         }
  536.     }



  540.     // -- ConstructorExpression 

  542.     @Override
  543.     public JDBCExpression newExpression(Logger log) throws NotImplementedException, ServiceException {
  544.         try{
  545.             return new JDBCExpression(this.getTransazioneApplicativoServerFieldConverter());
  546.         }catch(Exception e){
  547.             throw new ServiceException(e);
  548.         }
  549.     }


  552.     @Override
  553.     public JDBCPaginatedExpression newPaginatedExpression(Logger log) throws NotImplementedException, ServiceException {
  554.         try{
  555.             return new JDBCPaginatedExpression(this.getTransazioneApplicativoServerFieldConverter());
  556.         }catch(Exception e){
  557.             throw new ServiceException(e);
  558.         }
  559.     }
  560.     
  561.     @Override
  562.     public JDBCExpression toExpression(JDBCPaginatedExpression paginatedExpression, Logger log) throws NotImplementedException, ServiceException {
  563.         try{
  564.             return new JDBCExpression(paginatedExpression);
  565.         }catch(Exception e){
  566.             throw new ServiceException(e);
  567.         }
  568.     }

  570.     @Override
  571.     public JDBCPaginatedExpression toPaginatedExpression(JDBCExpression expression, Logger log) throws NotImplementedException, ServiceException {
  572.         try{
  573.             return new JDBCPaginatedExpression(expression);
  574.         }catch(Exception e){
  575.             throw new ServiceException(e);
  576.         }
  577.     }
  578.     
  579.     
  580.     
  581.     // -- DB

  583.     @Override
  584.     public void mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdTransazioneApplicativoServer id, TransazioneApplicativoServer obj) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  585.         _mappingTableIds(jdbcProperties,log,connection,sqlQueryObject,obj,
  586.                 this.get(jdbcProperties,log,connection,sqlQueryObject,id,null));
  587.     }
  588.     
  589.     @Override
  590.     public void mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, TransazioneApplicativoServer obj) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  591.         _mappingTableIds(jdbcProperties,log,connection,sqlQueryObject,obj,
  592.                 this.get(jdbcProperties,log,connection,sqlQueryObject,tableId,null));
  593.     }
  594.     private void _mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, TransazioneApplicativoServer obj, TransazioneApplicativoServer imgSaved) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  595.         if(imgSaved==null){
  596.             return;
  597.         }
  598.         obj.setId(imgSaved.getId());

  600.     }
  601.     
  602.     @Override
  603.     public TransazioneApplicativoServer get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  604.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId), idMappingResolutionBehaviour);
  605.     }
  606.     
  607.     private TransazioneApplicativoServer getEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  608.     
  609.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  610.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  611.         
  612.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();
  613.                 
  614.         TransazioneApplicativoServer transazioneApplicativoServer = new TransazioneApplicativoServer();
  615.         

  617.         // Object transazioneApplicativoServer
  618.         ISQLQueryObject sqlQueryObjectGet_transazioneApplicativoServer = sqlQueryObjectGet.newSQLQueryObject();
  619.         sqlQueryObjectGet_transazioneApplicativoServer.setANDLogicOperator(true);
  620.         sqlQueryObjectGet_transazioneApplicativoServer.addFromTable(this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model()));
  621.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField("id");
  622.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().ID_TRANSAZIONE,true));
  623.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().SERVIZIO_APPLICATIVO_EROGATORE,true));
  624.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CONNETTORE_NOME,true));
  625.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_REGISTRAZIONE,true));
  626.         // NONSERIALIZZATO SU DB sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().PROTOCOLLO,true));
  627.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CONSEGNA_TERMINATA,true));
  628.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_MESSAGGIO_SCADUTO,true));
  629.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DETTAGLIO_ESITO,true));
  630.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CONSEGNA_TRASPARENTE,true));
  631.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CONSEGNA_INTEGRATION_MANAGER,true));
  632.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().IDENTIFICATIVO_MESSAGGIO,true));
  633.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_ACCETTAZIONE_RICHIESTA,true));
  634.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_USCITA_RICHIESTA,true));
  635.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_USCITA_RICHIESTA_STREAM,true));
  636.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_ACCETTAZIONE_RISPOSTA,true));
  637.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_INGRESSO_RISPOSTA,true));
  638.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_INGRESSO_RISPOSTA_STREAM,true));
  639.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().RICHIESTA_USCITA_BYTES,true));
  640.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().RISPOSTA_INGRESSO_BYTES,true));
  641.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().LOCATION_CONNETTORE,true));
  642.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CODICE_RISPOSTA,true));
  643.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().FAULT,true));
  644.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().FORMATO_FAULT,true));
  645.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_PRIMO_TENTATIVO,true));
  646.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().NUMERO_TENTATIVI,true));
  647.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CLUSTER_ID_PRESA_IN_CARICO,true));
  648.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CLUSTER_ID_CONSEGNA,true));
  649.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_ULTIMO_ERRORE,true));
  650.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DETTAGLIO_ESITO_ULTIMO_ERRORE,true));
  651.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CODICE_RISPOSTA_ULTIMO_ERRORE,true));
  652.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().ULTIMO_ERRORE,true));
  653.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().LOCATION_ULTIMO_ERRORE,true));
  654.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CLUSTER_ID_ULTIMO_ERRORE,true));
  655.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().FAULT_ULTIMO_ERRORE,true));
  656.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().FORMATO_FAULT_ULTIMO_ERRORE,true));
  657.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_PRIMO_PRELIEVO_IM,true));
  658.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_PRELIEVO_IM,true));
  659.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().NUMERO_PRELIEVI_IM,true));
  660.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().DATA_ELIMINAZIONE_IM,true));
  661.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CLUSTER_ID_PRELIEVO_IM,true));
  662.         sqlQueryObjectGet_transazioneApplicativoServer.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().CLUSTER_ID_ELIMINAZIONE_IM,true));
  663.         sqlQueryObjectGet_transazioneApplicativoServer.addWhereCondition("id=?");

  665.         // Get transazioneApplicativoServer
  666.         transazioneApplicativoServer = (TransazioneApplicativoServer) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_transazioneApplicativoServer.createSQLQuery(), jdbcProperties.isShowSql(), TransazioneApplicativoServer.model(), this.getTransazioneApplicativoServerFetch(),
  667.             new JDBCObject(tableId,Long.class));



  671.         
  672.         return transazioneApplicativoServer;  
  673.     
  674.     } 
  675.     
  676.     @Override
  677.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  678.         return this._exists(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  679.     }
  680.     
  681.     private boolean _exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  682.     
  683.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  684.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  685.                 
  686.         boolean existsTransazioneApplicativoServer = false;

  688.         sqlQueryObject = sqlQueryObject.newSQLQueryObject();
  689.         sqlQueryObject.setANDLogicOperator(true);

  691.         sqlQueryObject.addFromTable(this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model()));
  692.         sqlQueryObject.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().ID_TRANSAZIONE,true));
  693.         sqlQueryObject.addWhereCondition("id=?");


  696.         // Exists transazioneApplicativoServer
  697.         existsTransazioneApplicativoServer = jdbcUtilities.exists(sqlQueryObject.createSQLQuery(), jdbcProperties.isShowSql(),
  698.             new JDBCObject(tableId,Long.class));

  700.         
  701.         return existsTransazioneApplicativoServer;
  702.     
  703.     }
  704.     
  705.     private void joinEngine(IExpression expression, ISQLQueryObject sqlQueryObject) throws NotImplementedException, ServiceException, Exception{
  706.     
  707.         // NOP;
  708.         
  709.     }
  710.     
  711.     protected java.util.List<Object> getRootTablePrimaryKeyValuesEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdTransazioneApplicativoServer id) throws NotFoundException, ServiceException, NotImplementedException, Exception{
  712.         // Identificativi
  713.         java.util.List<Object> rootTableIdValues = new java.util.ArrayList<>();
  714.         Long longId = this.findIdTransazioneApplicativoServer(jdbcProperties, log, connection, sqlQueryObject.newSQLQueryObject(), id, true);
  715.         rootTableIdValues.add(longId);
  716.         return rootTableIdValues;
  717.     }
  718.     
  719.     protected Map<String, List<IField>> getMapTableToPKColumnEngine() throws NotImplementedException, Exception{
  720.     
  721.         TransazioneApplicativoServerFieldConverter converter = this.getTransazioneApplicativoServerFieldConverter();
  722.         Map<String, List<IField>> mapTableToPKColumn = new java.util.HashMap<>();
  723.         UtilsTemplate<IField> utilities = new UtilsTemplate<>();

  725.         // TransazioneApplicativoServer.model()
  726.         mapTableToPKColumn.put(converter.toTable(TransazioneApplicativoServer.model()),
  727.             utilities.newList(
  728.                 new CustomField("id", Long.class, "id", converter.toTable(TransazioneApplicativoServer.model()))
  729.             ));

  731.         
  732.         return mapTableToPKColumn;      
  733.     }
  734.     
  735.     @Override
  736.     public List<Long> findAllTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression paginatedExpression) throws ServiceException, NotImplementedException, Exception {
  737.         
  738.         List<Long> list = new ArrayList<Long>();

  740.         sqlQueryObject.setSelectDistinct(true);
  741.         sqlQueryObject.setANDLogicOperator(true);
  742.         sqlQueryObject.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model())+".id");
  743.         Class<?> objectIdClass = Long.class;
  744.         
  745.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFindAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  746.                                                 this.getTransazioneApplicativoServerFieldConverter(), TransazioneApplicativoServer.model());
  747.         
  748.         joinEngine(paginatedExpression,sqlQueryObject);
  749.         
  750.         List<Object> listObjects = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.findAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  751.                                                                             this.getTransazioneApplicativoServerFieldConverter(), TransazioneApplicativoServer.model(), objectIdClass, listaQuery);
  752.         for(Object object: listObjects) {
  753.             list.add((Long)object);
  754.         }

  756.         return list;
  757.         
  758.     }
  759.     
  760.     @Override
  761.     public long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException, Exception {
  762.     
  763.         sqlQueryObject.setSelectDistinct(true);
  764.         sqlQueryObject.setANDLogicOperator(true);
  765.         sqlQueryObject.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model())+".id");
  766.         Class<?> objectIdClass = Long.class;
  767.         
  768.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFind(jdbcProperties, log, connection, sqlQueryObject, expression,
  769.                                                 this.getTransazioneApplicativoServerFieldConverter(), TransazioneApplicativoServer.model());
  770.         
  771.         joinEngine(expression,sqlQueryObject);

  773.         Object res = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.find(jdbcProperties, log, connection, sqlQueryObject, expression,
  774.                                                         this.getTransazioneApplicativoServerFieldConverter(), TransazioneApplicativoServer.model(), objectIdClass, listaQuery);
  775.         if(res!=null && (((Long) res).longValue()>0) ){
  776.             return ((Long) res).longValue();
  777.         }
  778.         else{
  779.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  780.         }
  781.         
  782.     }

  784.     @Override
  785.     public InUse inUse(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws ServiceException, NotFoundException, NotImplementedException, Exception {
  786.         return this.inUseEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  787.     }

  789.     private InUse inUseEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId) throws ServiceException, NotFoundException, NotImplementedException, Exception {

  791.         InUse inUse = new InUse();
  792.         inUse.setInUse(false);
  793.         
  794.         /* 
  795.          * TODO: implement code that checks whether the object identified by the id parameter is used by other objects
  796.         */
  797.         
  798.         // Delete this line when you have implemented the method
  799.         int throwNotImplemented = 1;
  800.         if(throwNotImplemented==1){
  801.                 throw new NotImplementedException("NotImplemented");
  802.         }
  803.         // Delete this line when you have implemented the method

  805.         return inUse;

  807.     }
  808.     
  809.     @Override
  810.     public IdTransazioneApplicativoServer findId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, boolean throwNotFound)
  811.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  812.         
  813.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  814.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  816.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();            

  818.         // Object _transazioneApplicativoServer
  819.         sqlQueryObjectGet.addFromTable(this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model()));
  820.         sqlQueryObjectGet.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().ID_TRANSAZIONE,true));
  821.         sqlQueryObjectGet.addSelectField(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().SERVIZIO_APPLICATIVO_EROGATORE,true));
  822.         sqlQueryObjectGet.setANDLogicOperator(true);
  823.         sqlQueryObjectGet.addWhereCondition("id=?");

  825.         // Recupero _transazioneApplicativoServer
  826.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_transazioneApplicativoServer = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  827.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(tableId,Long.class)
  828.         };
  829.         List<Class<?>> listaFieldIdReturnType_transazioneApplicativoServer = new ArrayList<Class<?>>();
  830.         listaFieldIdReturnType_transazioneApplicativoServer.add(String.class);
  831.         listaFieldIdReturnType_transazioneApplicativoServer.add(String.class);
  832.         org.openspcoop2.core.transazioni.IdTransazioneApplicativoServer id_transazioneApplicativoServer = null;
  833.         List<Object> listaFieldId_transazioneApplicativoServer = jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  834.                 listaFieldIdReturnType_transazioneApplicativoServer, searchParams_transazioneApplicativoServer);
  835.         if(listaFieldId_transazioneApplicativoServer==null || listaFieldId_transazioneApplicativoServer.size()<=0){
  836.             if(throwNotFound){
  837.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  838.             }
  839.         }
  840.         else{
  841.             // set _transazioneApplicativoServer
  842.             id_transazioneApplicativoServer = new org.openspcoop2.core.transazioni.IdTransazioneApplicativoServer();
  843.             id_transazioneApplicativoServer.setIdTransazione((String)listaFieldId_transazioneApplicativoServer.get(0));
  844.             id_transazioneApplicativoServer.setServizioApplicativoErogatore((String)listaFieldId_transazioneApplicativoServer.get(1));
  845.         }
  846.         
  847.         return id_transazioneApplicativoServer;
  848.         
  849.     }

  851.     @Override
  852.     public Long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdTransazioneApplicativoServer id, boolean throwNotFound)
  853.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  854.     
  855.         return this.findIdTransazioneApplicativoServer(jdbcProperties,log,connection,sqlQueryObject,id,throwNotFound);
  856.             
  857.     }
  858.     
  859.     @Override
  860.     public List<List<Object>> nativeQuery(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  861.                                             String sql,List<Class<?>> returnClassTypes,Object ... param) throws ServiceException,NotFoundException,NotImplementedException,Exception{
  862.         
  863.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeQuery(jdbcProperties, log, connection, sqlQueryObject,
  864.                                                                                             sql,returnClassTypes,param);
  865.                                                         
  866.     }
  867.     
  868.     protected Long findIdTransazioneApplicativoServer(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdTransazioneApplicativoServer id, boolean throwNotFound) throws NotFoundException, ServiceException, NotImplementedException, Exception {

  870.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  871.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  873.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();

  875.         if(id==null) {
  876.             throw new ServiceException("Id non definito");
  877.         }
  878.         if(id.getIdTransazione()==null) {
  879.             throw new ServiceException("IdTransazione non definito");
  880.         }
  881.         if(id.getServizioApplicativoErogatore()==null) {
  882.             throw new ServiceException("IdServizioApplicativoErogatore non definito");
  883.         }
  884.         
  885.         // Object _transazioneApplicativoServer
  886.         sqlQueryObjectGet.addFromTable(this.getTransazioneApplicativoServerFieldConverter().toTable(TransazioneApplicativoServer.model()));
  887.         sqlQueryObjectGet.addSelectField("id");
  888.         // Devono essere mappati nella where condition i metodi dell'oggetto id.getXXX
  889.         sqlQueryObjectGet.setANDLogicOperator(true);
  890.         sqlQueryObjectGet.setSelectDistinct(true);
  891.         sqlQueryObjectGet.addWhereCondition(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().ID_TRANSAZIONE,true)+"=?");
  892.         sqlQueryObjectGet.addWhereCondition(this.getTransazioneApplicativoServerFieldConverter().toColumn(TransazioneApplicativoServer.model().SERVIZIO_APPLICATIVO_EROGATORE,true)+"=?");

  894.         // Recupero _transazioneApplicativoServer
  895.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_transazioneApplicativoServer = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  896.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(id.getIdTransazione(),String.class),
  897.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(id.getServizioApplicativoErogatore(),String.class)
  898.         };
  899.         Long id_transazioneApplicativoServer = null;
  900.         try{
  901.             id_transazioneApplicativoServer = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  902.                         Long.class, searchParams_transazioneApplicativoServer);
  903.         }catch(NotFoundException notFound){
  904.             if(throwNotFound){
  905.                 throw new NotFoundException(notFound);
  906.             }
  907.         }
  908.         if(id_transazioneApplicativoServer==null || id_transazioneApplicativoServer<=0){
  909.             if(throwNotFound){
  910.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  911.             }
  912.         }
  913.         
  914.         return id_transazioneApplicativoServer;
  915.     }
  916. }
Created with JaCoCo 0.8.8.202204050719