JDBCConfigurazioneTransazioneServiceSearchImpl.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it).
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */
  20. package org.openspcoop2.monitor.engine.config.transazioni.dao.jdbc;

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

  27. import java.sql.Connection;

  29. import org.slf4j.Logger;

  31. import org.openspcoop2.utils.sql.ISQLQueryObject;

  33. import org.openspcoop2.core.plugins.IdConfigurazioneServizioAzione;
  34. import org.openspcoop2.core.plugins.Plugin;
  35. import org.openspcoop2.core.plugins.dao.jdbc.JDBCConfigurazioneServizioAzioneBaseLib;
  36. import org.openspcoop2.core.plugins.dao.jdbc.JDBCPluginsBaseLib;

  38. import org.openspcoop2.generic_project.expression.impl.sql.ISQLFieldConverter;
  39. import org.openspcoop2.generic_project.dao.jdbc.utils.IJDBCFetch;
  40. import org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject;
  41. import org.openspcoop2.generic_project.dao.jdbc.IJDBCServiceSearchWithId;
  42. import org.openspcoop2.monitor.engine.config.transazioni.IdConfigurazioneTransazione;
  43. import org.openspcoop2.monitor.engine.config.transazioni.IdConfigurazioneTransazioneStato;
  44. import org.openspcoop2.generic_project.utils.UtilsTemplate;
  45. import org.openspcoop2.generic_project.beans.CustomField;
  46. import org.openspcoop2.generic_project.beans.InUse;
  47. import org.openspcoop2.generic_project.beans.IField;
  48. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  49. import org.openspcoop2.generic_project.beans.UnionExpression;
  50. import org.openspcoop2.generic_project.beans.Union;
  51. import org.openspcoop2.generic_project.beans.FunctionField;
  52. import org.openspcoop2.generic_project.exception.MultipleResultException;
  53. import org.openspcoop2.generic_project.exception.NotFoundException;
  54. import org.openspcoop2.generic_project.exception.NotImplementedException;
  55. import org.openspcoop2.generic_project.exception.ServiceException;
  56. import org.openspcoop2.generic_project.expression.IExpression;
  57. import org.openspcoop2.generic_project.dao.jdbc.JDBCExpression;
  58. import org.openspcoop2.generic_project.dao.jdbc.JDBCPaginatedExpression;

  60. import org.openspcoop2.generic_project.dao.jdbc.JDBCServiceManagerProperties;
  61. import org.openspcoop2.monitor.engine.config.transazioni.dao.jdbc.converter.ConfigurazioneTransazioneFieldConverter;
  62. import org.openspcoop2.monitor.engine.config.transazioni.dao.jdbc.fetch.ConfigurazioneTransazioneFetch;
  63. import org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazione;
  64. import org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazionePlugin;
  65. import org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazioneStato;
  66. import org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazioneRisorsaContenuto;

  68. /**     
  69.  * JDBCConfigurazioneTransazioneServiceSearchImpl
  70.  *
  71.  * @author Poli Andrea (poli@link.it)
  72.  * @author $Author$
  73.  * @version $Rev$, $Date$
  74.  */
  75. public class JDBCConfigurazioneTransazioneServiceSearchImpl implements IJDBCServiceSearchWithId<ConfigurazioneTransazione, IdConfigurazioneTransazione, JDBCServiceManager> {

  77.     private ConfigurazioneTransazioneFieldConverter _configurazioneTransazioneFieldConverter = null;
  78.     public ConfigurazioneTransazioneFieldConverter getConfigurazioneTransazioneFieldConverter() {
  79.         if(this._configurazioneTransazioneFieldConverter==null){
  80.             this._configurazioneTransazioneFieldConverter = new ConfigurazioneTransazioneFieldConverter(this.jdbcServiceManager.getJdbcProperties().getDatabaseType());
  81.         }       
  82.         return this._configurazioneTransazioneFieldConverter;
  83.     }
  84.     @Override
  85.     public ISQLFieldConverter getFieldConverter() {
  86.         return this.getConfigurazioneTransazioneFieldConverter();
  87.     }
  88.     
  89.     private ConfigurazioneTransazioneFetch configurazioneTransazioneFetch = new ConfigurazioneTransazioneFetch();
  90.     public ConfigurazioneTransazioneFetch getConfigurazioneTransazioneFetch() {
  91.         return this.configurazioneTransazioneFetch;
  92.     }
  93.     @Override
  94.     public IJDBCFetch getFetch() {
  95.         return getConfigurazioneTransazioneFetch();
  96.     }
  97.     
  98.     
  99.     private JDBCServiceManager jdbcServiceManager = null;

  101.     @Override
  102.     public void setServiceManager(JDBCServiceManager serviceManager) throws ServiceException{
  103.         this.jdbcServiceManager = serviceManager;
  104.     }
  105.     
  106.     @Override
  107.     public JDBCServiceManager getServiceManager() throws ServiceException{
  108.         return this.jdbcServiceManager;
  109.     }
  110.     

  112.     @Override
  113.     public IdConfigurazioneTransazione convertToId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, ConfigurazioneTransazione configurazioneTransazione) throws NotImplementedException, ServiceException, Exception{
  114.     
  115.         IdConfigurazioneTransazione idTransazione = new IdConfigurazioneTransazione();
  116.         idTransazione.setIdConfigurazioneServizioAzione(configurazioneTransazione.getIdConfigurazioneServizioAzione());
  117.         return idTransazione;
  118.     }
  119.     
  120.     @Override
  121.     public ConfigurazioneTransazione get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneTransazione id, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {
  122.         Long id_configurazioneTransazione = ( (id!=null && id.getId()!=null && id.getId()>0) ? id.getId() : this.findIdConfigurazioneTransazione(jdbcProperties, log, connection, sqlQueryObject, id, true));
  123.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, id_configurazioneTransazione,idMappingResolutionBehaviour);
  124.         
  125.         
  126.     }
  127.     
  128.     @Override
  129.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneTransazione id) throws MultipleResultException, NotImplementedException, ServiceException,Exception {

  131.         Long id_configurazioneTransazione = this.findIdConfigurazioneTransazione(jdbcProperties, log, connection, sqlQueryObject, id, false);
  132.         return id_configurazioneTransazione != null && id_configurazioneTransazione > 0;
  133.         
  134.     }
  135.     
  136.     @Override
  137.     public List<IdConfigurazioneTransazione> findAllIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException, ServiceException,Exception {

  139.         List<IdConfigurazioneTransazione> list = new ArrayList<IdConfigurazioneTransazione>();

  141.         // TODO: implementazione non efficiente. 
  142.         // Per ottenere una implementazione efficiente:
  143.         // 1. Usare metodo select di questa classe indirizzando esattamente i field necessari a create l'ID logico
  144.         // 2. Usare metodo getConfigurazioneTransazioneFetch() sul risultato della select per ottenere un oggetto ConfigurazioneTransazione
  145.         //    La fetch con la map inserirà nell'oggetto solo i valori estratti 
  146.         // 3. Usare metodo convertToId per ottenere l'id

  148.         List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  149.         
  150.         for(Long id: ids) {
  151.             ConfigurazioneTransazione configurazioneTransazione = this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour);
  152.             IdConfigurazioneTransazione idConfigurazioneTransazione = this.convertToId(jdbcProperties,log,connection,sqlQueryObject,configurazioneTransazione);
  153.             list.add(idConfigurazioneTransazione);
  154.         }

  156.         return list;
  157.         
  158.     }
  159.     
  160.     @Override
  161.     public List<ConfigurazioneTransazione> findAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException, ServiceException,Exception {

  163.         List<ConfigurazioneTransazione> list = new ArrayList<ConfigurazioneTransazione>();
  164.         
  165.         // TODO: implementazione non efficiente. 
  166.         // Per ottenere una implementazione efficiente:
  167.         // 1. Usare metodo select di questa classe indirizzando esattamente i field necessari
  168.         // 2. Usare metodo getConfigurazioneTransazioneFetch() sul risultato della select per ottenere un oggetto ConfigurazioneTransazione
  169.         //    La fetch con la map inserirà nell'oggetto solo i valori estratti 

  171.         List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  172.         
  173.         for(Long id: ids) {
  174.             list.add(this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour));
  175.         }

  177.         return list;      
  178.         
  179.     }
  180.     
  181.     @Override
  182.     public ConfigurazioneTransazione find(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) 
  183.         throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {

  185.         long id = this.findTableId(jdbcProperties, log, connection, sqlQueryObject, expression);
  186.         if(id>0){
  187.             return this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour);
  188.         }else{
  189.             throw new NotFoundException("Entry with id["+id+"] not found");
  190.         }
  191.         
  192.     }
  193.     
  194.     @Override
  195.     public NonNegativeNumber count(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws NotImplementedException, ServiceException,Exception {
  196.         
  197.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareCount(jdbcProperties, log, connection, sqlQueryObject, expression,
  198.                                                 this.getConfigurazioneTransazioneFieldConverter(), ConfigurazioneTransazione.model());
  199.         
  200.         sqlQueryObject.addSelectCountField(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model())+".id","tot",true);
  201.         
  202.         joinEngine(expression,sqlQueryObject);
  203.         
  204.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.count(jdbcProperties, log, connection, sqlQueryObject, expression,
  205.                                                                             this.getConfigurazioneTransazioneFieldConverter(), ConfigurazioneTransazione.model(),listaQuery);
  206.     }

  208.     @Override
  209.     public InUse inUse(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneTransazione id) throws NotFoundException, NotImplementedException, ServiceException,Exception {
  210.         
  211.         Long id_configurazioneTransazione = this.findIdConfigurazioneTransazione(jdbcProperties, log, connection, sqlQueryObject, id, true);
  212.         return this.inUseEngine(jdbcProperties, log, connection, sqlQueryObject, id_configurazioneTransazione);
  213.         
  214.     }

  216.     @Override
  217.     public List<Object> select(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  218.                                                     JDBCPaginatedExpression paginatedExpression, IField field) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  219.         return this.select(jdbcProperties, log, connection, sqlQueryObject,
  220.                                 paginatedExpression, false, field);
  221.     }
  222.     
  223.     @Override
  224.     public List<Object> select(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  225.                                                     JDBCPaginatedExpression paginatedExpression, boolean distinct, IField field) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  226.         List<Map<String,Object>> map = 
  227.             this.select(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression, distinct, new IField[]{field});
  228.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.selectSingleObject(map);
  229.     }
  230.     
  231.     @Override
  232.     public List<Map<String,Object>> select(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  233.                                                     JDBCPaginatedExpression paginatedExpression, IField ... field) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  234.         return this.select(jdbcProperties, log, connection, sqlQueryObject,
  235.                                 paginatedExpression, false, field);
  236.     }
  237.     
  238.     @Override
  239.     public List<Map<String,Object>> select(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  240.                                                     JDBCPaginatedExpression paginatedExpression, boolean distinct, IField ... field) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  241.         
  242.         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.setFields(sqlQueryObject,paginatedExpression,field);
  243.         try{
  244.         
  245.             ISQLQueryObject sqlQueryObjectDistinct = 
  246.                         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareSqlQueryObjectForSelectDistinct(distinct,sqlQueryObject, paginatedExpression, log,
  247.                                                 this.getConfigurazioneTransazioneFieldConverter(), field);

  249.             return selectEngine(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression, sqlQueryObjectDistinct);
  250.             
  251.         }finally{
  252.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,paginatedExpression,field);
  253.         }
  254.     }

  256.     @Override
  257.     public Object aggregate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  258.                                                     JDBCExpression expression, FunctionField functionField) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  259.         Map<String,Object> map = 
  260.             this.aggregate(jdbcProperties, log, connection, sqlQueryObject, expression, new FunctionField[]{functionField});
  261.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.selectAggregateObject(map,functionField);
  262.     }
  263.     
  264.     @Override
  265.     public Map<String,Object> aggregate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  266.                                                     JDBCExpression expression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException,Exception {                                                   
  267.         
  268.         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.setFields(sqlQueryObject,expression,functionField);
  269.         try{
  270.             List<Map<String,Object>> list = selectEngine(jdbcProperties, log, connection, sqlQueryObject, expression);
  271.             return list.get(0);
  272.         }finally{
  273.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,expression,functionField);
  274.         }
  275.     }

  277.     @Override
  278.     public List<Map<String,Object>> groupBy(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  279.                                                     JDBCExpression expression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  280.         
  281.         if(expression.getGroupByFields().isEmpty()){
  282.             throw new ServiceException("GroupBy conditions not found in expression");
  283.         }
  284.         
  285.         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.setFields(sqlQueryObject,expression,functionField);
  286.         try{
  287.             return selectEngine(jdbcProperties, log, connection, sqlQueryObject, expression);
  288.         }finally{
  289.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,expression,functionField);
  290.         }
  291.     }
  292.     

  294.     @Override
  295.     public List<Map<String,Object>> groupBy(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  296.                                                     JDBCPaginatedExpression paginatedExpression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  297.         
  298.         if(paginatedExpression.getGroupByFields().isEmpty()){
  299.             throw new ServiceException("GroupBy conditions not found in expression");
  300.         }
  301.         
  302.         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.setFields(sqlQueryObject,paginatedExpression,functionField);
  303.         try{
  304.             return selectEngine(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression);
  305.         }finally{
  306.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,paginatedExpression,functionField);
  307.         }
  308.     }
  309.     
  310.     protected List<Map<String,Object>> selectEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  311.                                                 IExpression expression) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  312.         return selectEngine(jdbcProperties, log, connection, sqlQueryObject, expression, null);
  313.     }
  314.     protected List<Map<String,Object>> selectEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  315.                                                 IExpression expression, ISQLQueryObject sqlQueryObjectDistinct) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  316.         
  317.         List<Object> listaQuery = new ArrayList<>();
  318.         List<JDBCObject> listaParams = new ArrayList<>();
  319.         List<Object> returnField = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareSelect(jdbcProperties, log, connection, sqlQueryObject, 
  320.                                 expression, this.getConfigurazioneTransazioneFieldConverter(), ConfigurazioneTransazione.model(), 
  321.                                 listaQuery,listaParams);
  322.         
  323.         joinEngine(expression,sqlQueryObject);
  324.         
  325.         List<Map<String,Object>> list = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.select(jdbcProperties, log, connection,
  326.                                         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareSqlQueryObjectForSelectDistinct(sqlQueryObject,sqlQueryObjectDistinct), 
  327.                                         expression, this.getConfigurazioneTransazioneFieldConverter(), ConfigurazioneTransazione.model(),
  328.                                         listaQuery,listaParams,returnField);
  329.         if(list!=null && !list.isEmpty()){
  330.             return list;
  331.         }
  332.         else{
  333.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  334.         }
  335.     }
  336.     
  337.     @Override
  338.     public List<Map<String,Object>> union(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  339.                                                 Union union, UnionExpression ... unionExpression) throws ServiceException,NotFoundException,NotImplementedException,Exception {     
  340.         
  341.         List<ISQLQueryObject> sqlQueryObjectInnerList = new ArrayList<>();
  342.         List<JDBCObject> jdbcObjects = new ArrayList<>();
  343.         List<Class<?>> returnClassTypes = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareUnion(jdbcProperties, log, connection, sqlQueryObject, 
  344.                                 this.getConfigurazioneTransazioneFieldConverter(), ConfigurazioneTransazione.model(), 
  345.                                 sqlQueryObjectInnerList, jdbcObjects, union, unionExpression);
  346.         
  347.         if(unionExpression!=null){
  348.             for (int i = 0; i < unionExpression.length; i++) {
  349.                 UnionExpression ue = unionExpression[i];
  350.                 IExpression expression = ue.getExpression();
  351.                 joinEngine(expression,sqlQueryObjectInnerList.get(i));
  352.             }
  353.         }
  354.         
  355.         List<Map<String,Object>> list = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.union(jdbcProperties, log, connection, sqlQueryObject, 
  356.                                         this.getConfigurazioneTransazioneFieldConverter(), ConfigurazioneTransazione.model(), 
  357.                                         sqlQueryObjectInnerList, jdbcObjects, returnClassTypes, union, unionExpression);
  358.         if(list!=null && !list.isEmpty()){
  359.             return list;
  360.         }
  361.         else{
  362.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  363.         }                               
  364.     }
  365.     
  366.     @Override
  367.     public NonNegativeNumber unionCount(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  368.                                                 Union union, UnionExpression ... unionExpression) throws ServiceException,NotFoundException,NotImplementedException,Exception {     
  369.         
  370.         List<ISQLQueryObject> sqlQueryObjectInnerList = new ArrayList<>();
  371.         List<JDBCObject> jdbcObjects = new ArrayList<>();
  372.         List<Class<?>> returnClassTypes = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareUnionCount(jdbcProperties, log, connection, sqlQueryObject, 
  373.                                 this.getConfigurazioneTransazioneFieldConverter(), ConfigurazioneTransazione.model(), 
  374.                                 sqlQueryObjectInnerList, jdbcObjects, union, unionExpression);
  375.         
  376.         if(unionExpression!=null){
  377.             for (int i = 0; i < unionExpression.length; i++) {
  378.                 UnionExpression ue = unionExpression[i];
  379.                 IExpression expression = ue.getExpression();
  380.                 joinEngine(expression,sqlQueryObjectInnerList.get(i));
  381.             }
  382.         }
  383.         
  384.         NonNegativeNumber number = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.unionCount(jdbcProperties, log, connection, sqlQueryObject, 
  385.                                         this.getConfigurazioneTransazioneFieldConverter(), ConfigurazioneTransazione.model(), 
  386.                                         sqlQueryObjectInnerList, jdbcObjects, returnClassTypes, union, unionExpression);
  387.         if(number!=null && number.longValue()>=0){
  388.             return number;
  389.         }
  390.         else{
  391.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  392.         }
  393.     }



  397.     // -- ConstructorExpression 

  399.     @Override
  400.     public JDBCExpression newExpression(Logger log) throws NotImplementedException, ServiceException {
  401.         try{
  402.             return new JDBCExpression(this.getConfigurazioneTransazioneFieldConverter());
  403.         }catch(Exception e){
  404.             throw new ServiceException(e);
  405.         }
  406.     }


  409.     @Override
  410.     public JDBCPaginatedExpression newPaginatedExpression(Logger log) throws NotImplementedException, ServiceException {
  411.         try{
  412.             return new JDBCPaginatedExpression(this.getConfigurazioneTransazioneFieldConverter());
  413.         }catch(Exception e){
  414.             throw new ServiceException(e);
  415.         }
  416.     }
  417.     
  418.     @Override
  419.     public JDBCExpression toExpression(JDBCPaginatedExpression paginatedExpression, Logger log) throws NotImplementedException, ServiceException {
  420.         try{
  421.             return new JDBCExpression(paginatedExpression);
  422.         }catch(Exception e){
  423.             throw new ServiceException(e);
  424.         }
  425.     }

  427.     @Override
  428.     public JDBCPaginatedExpression toPaginatedExpression(JDBCExpression expression, Logger log) throws NotImplementedException, ServiceException {
  429.         try{
  430.             return new JDBCPaginatedExpression(expression);
  431.         }catch(Exception e){
  432.             throw new ServiceException(e);
  433.         }
  434.     }
  435.     
  436.     
  437.     
  438.     // -- DB

  440.     @Override
  441.     public void mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneTransazione id, ConfigurazioneTransazione obj) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  442.         _mappingTableIds(jdbcProperties,log,connection,sqlQueryObject,obj,
  443.                 this.get(jdbcProperties,log,connection,sqlQueryObject,id,null));
  444.     }
  445.     
  446.     @Override
  447.     public void mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, ConfigurazioneTransazione obj) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  448.         _mappingTableIds(jdbcProperties,log,connection,sqlQueryObject,obj,
  449.                 this.get(jdbcProperties,log,connection,sqlQueryObject,tableId,null));
  450.     }
  451.     private void _mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, ConfigurazioneTransazione obj, ConfigurazioneTransazione imgSaved) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  452.         if(imgSaved==null){
  453.             return;
  454.         }
  455.         obj.setId(imgSaved.getId());
  456.         if(obj.getIdConfigurazioneServizioAzione()!=null && 
  457.                 imgSaved.getIdConfigurazioneServizioAzione()!=null){
  458.             obj.getIdConfigurazioneServizioAzione().setId(imgSaved.getIdConfigurazioneServizioAzione().getId());
  459.             if(obj.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio()!=null && 
  460.                     imgSaved.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio()!=null){
  461.                 obj.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().setId(imgSaved.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().getId());
  462.             }
  463.         }
  464.         if(obj.getConfigurazioneTransazionePluginList()!=null){
  465.             List<org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazionePlugin> listObj_ = obj.getConfigurazioneTransazionePluginList();
  466.             for(org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazionePlugin itemObj_ : listObj_){
  467.                 org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazionePlugin itemAlreadySaved_ = null;
  468.                 if(imgSaved.getConfigurazioneTransazionePluginList()!=null){
  469.                     List<org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazionePlugin> listImgSaved_ = imgSaved.getConfigurazioneTransazionePluginList();
  470.                     for(org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazionePlugin itemImgSaved_ : listImgSaved_){
  471.                         boolean objEqualsToImgSaved_ = false;
  472.                         objEqualsToImgSaved_ = org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getIdConfigurazioneTransazionePlugin(),itemImgSaved_.getIdConfigurazioneTransazionePlugin());
  473.                         if(objEqualsToImgSaved_){
  474.                             itemAlreadySaved_=itemImgSaved_;
  475.                             break;
  476.                         }
  477.                     }
  478.                 }
  479.                 if(itemAlreadySaved_!=null){
  480.                     itemObj_.setId(itemAlreadySaved_.getId());
  481.                     if(itemObj_.getPlugin()!=null && 
  482.                             itemAlreadySaved_.getPlugin()!=null){
  483.                         itemObj_.getPlugin().setId(itemAlreadySaved_.getPlugin().getId());
  484.                     }
  485.                 }
  486.             }
  487.         }
  488.         if(obj.getConfigurazioneTransazioneStatoList()!=null){
  489.             List<org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazioneStato> listObj_ = obj.getConfigurazioneTransazioneStatoList();
  490.             for(org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazioneStato itemObj_ : listObj_){
  491.                 org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazioneStato itemAlreadySaved_ = null;
  492.                 if(imgSaved.getConfigurazioneTransazioneStatoList()!=null){
  493.                     List<org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazioneStato> listImgSaved_ = imgSaved.getConfigurazioneTransazioneStatoList();
  494.                     for(org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazioneStato itemImgSaved_ : listImgSaved_){
  495.                         boolean objEqualsToImgSaved_ = false;
  496.                         objEqualsToImgSaved_ = org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getNome(),itemImgSaved_.getNome()) &&
  497.                                 org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getTipoMessaggio(),itemImgSaved_.getTipoMessaggio());
  498.                         if(objEqualsToImgSaved_){
  499.                             itemAlreadySaved_=itemImgSaved_;
  500.                             break;
  501.                         }
  502.                     }
  503.                 }
  504.                 if(itemAlreadySaved_!=null){
  505.                     itemObj_.setId(itemAlreadySaved_.getId());
  506.                 }
  507.             }
  508.         }
  509.         if(obj.getConfigurazioneTransazioneRisorsaContenutoList()!=null){
  510.             List<org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazioneRisorsaContenuto> listObj_ = obj.getConfigurazioneTransazioneRisorsaContenutoList();
  511.             for(org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazioneRisorsaContenuto itemObj_ : listObj_){
  512.                 org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazioneRisorsaContenuto itemAlreadySaved_ = null;
  513.                 if(imgSaved.getConfigurazioneTransazioneRisorsaContenutoList()!=null){
  514.                     List<org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazioneRisorsaContenuto> listImgSaved_ = imgSaved.getConfigurazioneTransazioneRisorsaContenutoList();
  515.                     for(org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazioneRisorsaContenuto itemImgSaved_ : listImgSaved_){
  516.                         boolean objEqualsToImgSaved_ = false;
  517.                         objEqualsToImgSaved_ = org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getNome(),itemImgSaved_.getNome()) &&
  518.                                     org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getTipoMessaggio(),itemImgSaved_.getTipoMessaggio());
  519.                         if(objEqualsToImgSaved_){
  520.                             itemAlreadySaved_=itemImgSaved_;
  521.                             break;
  522.                         }
  523.                     }
  524.                 }
  525.                 if(itemAlreadySaved_!=null){
  526.                     itemObj_.setId(itemAlreadySaved_.getId());
  527.                     if(itemObj_.getIdConfigurazioneTransazioneStato()!=null && 
  528.                             itemAlreadySaved_.getIdConfigurazioneTransazioneStato()!=null){
  529.                         itemObj_.getIdConfigurazioneTransazioneStato().setId(itemAlreadySaved_.getIdConfigurazioneTransazioneStato().getId());
  530.                     }
  531.                 }
  532.             }
  533.         }           
  534.     }
  535.     
  536.     @Override
  537.     public ConfigurazioneTransazione get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  538.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId), idMappingResolutionBehaviour);
  539.     }
  540.     
  541.     private ConfigurazioneTransazione getEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  542.     
  543.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  544.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  545.         
  546.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();
  547.                 
  548.         ConfigurazioneTransazione configurazioneTransazione = new ConfigurazioneTransazione();
  549.         

  551.         // Object configurazioneTransazione
  552.         ISQLQueryObject sqlQueryObjectGet_configurazioneTransazione = sqlQueryObjectGet.newSQLQueryObject();
  553.         sqlQueryObjectGet_configurazioneTransazione.setANDLogicOperator(true);
  554.         sqlQueryObjectGet_configurazioneTransazione.addFromTable(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model()));
  555.         sqlQueryObjectGet_configurazioneTransazione.addSelectField("id");
  556.         sqlQueryObjectGet_configurazioneTransazione.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().ENABLED,true));
  557.         sqlQueryObjectGet_configurazioneTransazione.addWhereCondition("id=?");

  559.         // Get configurazioneTransazione
  560.         configurazioneTransazione = (ConfigurazioneTransazione) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_configurazioneTransazione.createSQLQuery(), jdbcProperties.isShowSql(), ConfigurazioneTransazione.model(), this.getConfigurazioneTransazioneFetch(),
  561.             new JDBCObject(tableId,Long.class));


  564.         if(idMappingResolutionBehaviour==null ||
  565.             (org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour) || org.openspcoop2.generic_project.beans.IDMappingBehaviour.USE_TABLE_ID.equals(idMappingResolutionBehaviour))
  566.         ){
  567.             // Recupero idConfigurazioneServizioAzione
  568.                 
  569.             ISQLQueryObject sqlQueryObjectGet_configurazioneTransazione_idConfigurazioneServizioAzione = sqlQueryObjectGet.newSQLQueryObject();
  570.             sqlQueryObjectGet_configurazioneTransazione_idConfigurazioneServizioAzione.addFromTable(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model()));
  571.             sqlQueryObjectGet_configurazioneTransazione_idConfigurazioneServizioAzione.addSelectField("id_conf_servizio_azione");
  572.             sqlQueryObjectGet_configurazioneTransazione_idConfigurazioneServizioAzione.addWhereCondition("id=?");
  573.             sqlQueryObjectGet_configurazioneTransazione_idConfigurazioneServizioAzione.setANDLogicOperator(true);
  574.             Long id_configurazioneTransazione_idConfigurazioneServizioAzione = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_configurazioneTransazione_idConfigurazioneServizioAzione.createSQLQuery(), jdbcProperties.isShowSql(),Long.class,
  575.                     new JDBCObject(configurazioneTransazione.getId(),Long.class));
  576.         
  577.             IdConfigurazioneServizioAzione _tmpIdConfigurazioneServizioAzione = 
  578.                     JDBCConfigurazioneServizioAzioneBaseLib.getIdConfigurazioneServizioAzione(connection, jdbcProperties, log, id_configurazioneTransazione_idConfigurazioneServizioAzione);
  579.             org.openspcoop2.monitor.engine.config.transazioni.IdConfigurazioneServizioAzione idConfigurazioneServizioAzione = new org.openspcoop2.monitor.engine.config.transazioni.IdConfigurazioneServizioAzione();
  580.             idConfigurazioneServizioAzione.setAzione(_tmpIdConfigurazioneServizioAzione.getAzione());
  581.             org.openspcoop2.monitor.engine.config.transazioni.IdConfigurazioneServizio idConfigurazioneServizio = new org.openspcoop2.monitor.engine.config.transazioni.IdConfigurazioneServizio();
  582.             idConfigurazioneServizio.setAccordo(_tmpIdConfigurazioneServizioAzione.getIdConfigurazioneServizio().getAccordo());
  583.             idConfigurazioneServizio.setTipoSoggettoReferente(_tmpIdConfigurazioneServizioAzione.getIdConfigurazioneServizio().getTipoSoggettoReferente());
  584.             idConfigurazioneServizio.setNomeSoggettoReferente(_tmpIdConfigurazioneServizioAzione.getIdConfigurazioneServizio().getNomeSoggettoReferente());
  585.             idConfigurazioneServizio.setVersione(_tmpIdConfigurazioneServizioAzione.getIdConfigurazioneServizio().getVersione());
  586.             idConfigurazioneServizio.setServizio(_tmpIdConfigurazioneServizioAzione.getIdConfigurazioneServizio().getServizio());
  587.             idConfigurazioneServizioAzione.setIdConfigurazioneServizio(idConfigurazioneServizio);
  588.             configurazioneTransazione.setIdConfigurazioneServizioAzione(idConfigurazioneServizioAzione);
  589.         }


  592.         // Object configurazioneTransazione_configurazioneTransazionePlugin
  593.         ISQLQueryObject sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin = sqlQueryObjectGet.newSQLQueryObject();
  594.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin.setANDLogicOperator(true);
  595.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin.addFromTable(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN));
  596.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin.addFromTable(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN.PLUGIN));
  597.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN)+".id");
  598.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN.ID_CONFIGURAZIONE_TRANSAZIONE_PLUGIN,true));
  599.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN.ENABLED,true));
  600.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin.addWhereCondition("id_configurazione_transazione=?");
  601.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin.addWhereCondition(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN)+".id_plugin="+
  602.                 this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN.PLUGIN)+".id");
  603.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin.addOrderBy(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN.PLUGIN.LABEL,true));
  604.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin.setSortType(true);
  605.         
  606.         
  607.         
  608.         // Get configurazioneTransazione_configurazioneTransazionePlugin
  609.         java.util.List<Object> configurazioneTransazione_configurazioneTransazionePlugin_list = jdbcUtilities.executeQuery(sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin.createSQLQuery(), jdbcProperties.isShowSql(), ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN, this.getConfigurazioneTransazioneFetch(),
  610.             new JDBCObject(configurazioneTransazione.getId(),Long.class));

  612.         if(configurazioneTransazione_configurazioneTransazionePlugin_list != null) {
  613.             for (Object configurazioneTransazione_configurazioneTransazionePlugin_object: configurazioneTransazione_configurazioneTransazionePlugin_list) {
  614.                 ConfigurazioneTransazionePlugin configurazioneTransazione_configurazioneTransazionePlugin = (ConfigurazioneTransazionePlugin) configurazioneTransazione_configurazioneTransazionePlugin_object;


  617.                 if(idMappingResolutionBehaviour==null ||
  618.                     (org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour) || org.openspcoop2.generic_project.beans.IDMappingBehaviour.USE_TABLE_ID.equals(idMappingResolutionBehaviour))
  619.                 ){
  620.                     // Object _configurazioneTransazione_configurazioneTransazionePlugin_plugin (recupero id)
  621.                     ISQLQueryObject sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin_plugin_readFkId = sqlQueryObjectGet.newSQLQueryObject();
  622.                     sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin_plugin_readFkId.addFromTable(this.getConfigurazioneTransazioneFieldConverter().toTable(org.openspcoop2.monitor.engine.config.transazioni.ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_PLUGIN));
  623.                     sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin_plugin_readFkId.addSelectField("id_plugin");
  624.                     sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin_plugin_readFkId.addWhereCondition("id=?");
  625.                     sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin_plugin_readFkId.setANDLogicOperator(true);
  626.                     Long idFK_configurazioneTransazione_configurazioneTransazionePlugin_plugin = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazionePlugin_plugin_readFkId.createSQLQuery(), jdbcProperties.isShowSql(),Long.class,
  627.                             new JDBCObject(configurazioneTransazione_configurazioneTransazionePlugin.getId(),Long.class));
  628.                 
  629.                     Plugin plugin = JDBCPluginsBaseLib.getPlugin(connection, jdbcProperties, log, idFK_configurazioneTransazione_configurazioneTransazionePlugin_plugin);
  630.                     org.openspcoop2.monitor.engine.config.transazioni.InfoPlugin info = new org.openspcoop2.monitor.engine.config.transazioni.InfoPlugin();
  631.                     info.setTipoPlugin(plugin.getTipoPlugin());
  632.                     info.setTipo(plugin.getTipo());
  633.                     info.setClassName(plugin.getClassName());
  634.                     info.setDescrizione(plugin.getDescrizione());
  635.                     info.setLabel(plugin.getLabel());
  636.                     configurazioneTransazione_configurazioneTransazionePlugin.setPlugin(info);
  637.                 
  638.                     configurazioneTransazione.addConfigurazioneTransazionePlugin(configurazioneTransazione_configurazioneTransazionePlugin);
  639.                 }

  641.                 configurazioneTransazione.addConfigurazioneTransazionePlugin(configurazioneTransazione_configurazioneTransazionePlugin);
  642.             }
  643.         }

  645.         // Object configurazioneTransazione_configurazioneTransazioneStato
  646.         ISQLQueryObject sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneStato = sqlQueryObjectGet.newSQLQueryObject();
  647.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneStato.setANDLogicOperator(true);
  648.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneStato.addFromTable(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO));
  649.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneStato.addSelectField("id");
  650.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneStato.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.ENABLED,true));
  651.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneStato.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.NOME,true));
  652.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneStato.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.TIPO_CONTROLLO,true));
  653.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneStato.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.TIPO_MESSAGGIO,true));
  654.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneStato.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.VALORE,true));
  655.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneStato.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.XPATH,true));
  656.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneStato.addWhereCondition("id_configurazione_transazione=?");
  657.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneStato.addOrderBy(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO.NOME,true));
  658.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneStato.setSortType(true);
  659.         
  660.         
  661.         
  662.         // Get configurazioneTransazione_configurazioneTransazioneStato
  663.         java.util.List<Object> configurazioneTransazione_configurazioneTransazioneStato_list = jdbcUtilities.executeQuery(sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneStato.createSQLQuery(), jdbcProperties.isShowSql(), ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO, this.getConfigurazioneTransazioneFetch(),
  664.             new JDBCObject(configurazioneTransazione.getId(),Long.class));

  666.         HashMap<Long, String> mapIdTransazioneStatoToName = new HashMap<Long, String>();
  667.         
  668.         if(configurazioneTransazione_configurazioneTransazioneStato_list != null) {
  669.             for (Object configurazioneTransazione_configurazioneTransazioneStato_object: configurazioneTransazione_configurazioneTransazioneStato_list) {
  670.                 ConfigurazioneTransazioneStato configurazioneTransazione_configurazioneTransazioneStato = (ConfigurazioneTransazioneStato) configurazioneTransazione_configurazioneTransazioneStato_object;
  671.                 configurazioneTransazione.addConfigurazioneTransazioneStato(configurazioneTransazione_configurazioneTransazioneStato);
  672.                 mapIdTransazioneStatoToName.put(configurazioneTransazione_configurazioneTransazioneStato.getId(), configurazioneTransazione_configurazioneTransazioneStato.getNome());
  673.             }
  674.         }

  676.         // Object configurazioneTransazione_configurazioneTransazioneRisorsaContenuto
  677.         ISQLQueryObject sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto = sqlQueryObjectGet.newSQLQueryObject();
  678.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.setANDLogicOperator(true);
  679.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.addFromTable(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO));
  680.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.addSelectField("id");
  681.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ABILITA_ANONIMIZZAZIONE,true));
  682.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ABILITA_COMPRESSIONE,true));
  683.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.TIPO_COMPRESSIONE,true));
  684.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.CARATTERE_MASCHERA,true));
  685.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.NUMERO_CARATTERI_MASCHERA,true));
  686.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.POSIZIONAMENTO_MASCHERA,true));
  687.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.TIPO_MASCHERAMENTO,true));
  688.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ENABLED,true));
  689.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.NOME,true));
  690.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.TIPO_MESSAGGIO,true));
  691.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.XPATH,true));
  692.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.STAT_ENABLED,true));
  693.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.addWhereCondition("id_conf_transazione=?");
  694.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.addOrderBy(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.NOME,true));
  695.         sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.setSortType(true);
  696.                 
  697.         
  698.         // Get configurazioneTransazione_configurazioneTransazioneRisorsaContenuto
  699.         java.util.List<Object> configurazioneTransazione_configurazioneTransazioneRisorsaContenuto_list = jdbcUtilities.executeQuery(sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.createSQLQuery(), jdbcProperties.isShowSql(), ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO, this.getConfigurazioneTransazioneFetch(),
  700.             new JDBCObject(configurazioneTransazione.getId(),Long.class));

  702.         if(configurazioneTransazione_configurazioneTransazioneRisorsaContenuto_list != null) {
  703.             for (Object configurazioneTransazione_configurazioneTransazioneRisorsaContenuto_object: configurazioneTransazione_configurazioneTransazioneRisorsaContenuto_list) {
  704.                 ConfigurazioneTransazioneRisorsaContenuto configurazioneTransazione_configurazioneTransazioneRisorsaContenuto = (ConfigurazioneTransazioneRisorsaContenuto) configurazioneTransazione_configurazioneTransazioneRisorsaContenuto_object;


  707.                 if(idMappingResolutionBehaviour==null ||
  708.                     (org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour) || org.openspcoop2.generic_project.beans.IDMappingBehaviour.USE_TABLE_ID.equals(idMappingResolutionBehaviour))
  709.                 ){
  710.                     // Recupero idConfigurazioneTransazioneStato
  711.                     ISQLQueryObject sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto_idConfigurazioneTransazioneStato = 
  712.                             sqlQueryObjectGet.newSQLQueryObject();
  713.                     sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto_idConfigurazioneTransazioneStato.addFromTable(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO));
  714.                     sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto_idConfigurazioneTransazioneStato.addSelectField("id_configurazione_stato");
  715.                     sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto_idConfigurazioneTransazioneStato.addWhereCondition("id=?");
  716.                     sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto_idConfigurazioneTransazioneStato.setANDLogicOperator(true);
  717.                     Long id_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto_idConfigurazioneTransazioneStato = null;
  718.                     try{
  719.                         id_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto_idConfigurazioneTransazioneStato = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto_idConfigurazioneTransazioneStato.createSQLQuery(), jdbcProperties.isShowSql(),Long.class,
  720.                             new JDBCObject(configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.getId(),Long.class));
  721.                     }catch(NotFoundException  e){
  722.                         id_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto_idConfigurazioneTransazioneStato = null;
  723.                     }
  724.                 
  725.                     IdConfigurazioneTransazioneStato idConfigurazioneTransazioneStato = new IdConfigurazioneTransazioneStato();
  726.                     if(id_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto_idConfigurazioneTransazioneStato != null)
  727.                         idConfigurazioneTransazioneStato.setStato(mapIdTransazioneStatoToName.get(id_configurazioneTransazione_configurazioneTransazioneRisorsaContenuto_idConfigurazioneTransazioneStato));
  728.                     configurazioneTransazione_configurazioneTransazioneRisorsaContenuto.setIdConfigurazioneTransazioneStato(idConfigurazioneTransazioneStato);
  729.                 
  730.                 }

  732.                 configurazioneTransazione.addConfigurazioneTransazioneRisorsaContenuto(configurazioneTransazione_configurazioneTransazioneRisorsaContenuto);
  733.             }
  734.         }
  735.              
  736.         return configurazioneTransazione;  
  737.     
  738.     } 
  739.     
  740.     @Override
  741.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  742.         return this._exists(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  743.     }
  744.     
  745.     private boolean _exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  746.     
  747.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  748.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  749.                 
  750.         boolean existsConfigurazioneTransazione = false;

  752.         sqlQueryObject = sqlQueryObject.newSQLQueryObject();
  753.         sqlQueryObject.setANDLogicOperator(true);

  755.         sqlQueryObject.addFromTable(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model()));
  756.         sqlQueryObject.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toColumn(ConfigurazioneTransazione.model().ENABLED,true));
  757.         sqlQueryObject.addWhereCondition("id=?");


  760.         // Exists configurazioneTransazione
  761.         existsConfigurazioneTransazione = jdbcUtilities.exists(sqlQueryObject.createSQLQuery(), jdbcProperties.isShowSql(),
  762.             new JDBCObject(tableId,Long.class));

  764.         
  765.         return existsConfigurazioneTransazione;
  766.     
  767.     }
  768.     
  769.     private void joinEngine(IExpression expression, ISQLQueryObject sqlQueryObject) throws NotImplementedException, ServiceException, Exception{
  770.     
  771.         if(expression.inUseModel(ConfigurazioneTransazione.model().ID_CONFIGURAZIONE_SERVIZIO_AZIONE,false)){
  772.             String tableName1 = this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model());
  773.             String tableName2 = this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().ID_CONFIGURAZIONE_SERVIZIO_AZIONE);
  774.             sqlQueryObject.addWhereCondition(tableName1+".id_conf_servizio_azione="+tableName2+".id");
  775.         }
  776.         if(expression.inUseModel(ConfigurazioneTransazione.model().ID_CONFIGURAZIONE_SERVIZIO_AZIONE.ID_CONFIGURAZIONE_SERVIZIO,false)){
  777.             String tableName1 = this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().ID_CONFIGURAZIONE_SERVIZIO_AZIONE);
  778.             String tableName2 = this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().ID_CONFIGURAZIONE_SERVIZIO_AZIONE.ID_CONFIGURAZIONE_SERVIZIO);
  779.             sqlQueryObject.addWhereCondition(tableName1+".id_config_servizio="+tableName2+".id");
  780.         }
  781.         if(expression.inUseModel(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO,false)){
  782.             String tableName1 = this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO);
  783.             String tableName2 = this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model());
  784.             sqlQueryObject.addWhereCondition(tableName1+".id_configurazione_transazione="+tableName2+".id");
  785.         }
  786.         if(expression.inUseModel(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO,false)){
  787.             String tableName1 = this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO);
  788.             String tableName2 = this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model());
  789.             sqlQueryObject.addWhereCondition(tableName1+".id_conf_transazione="+tableName2+".id");
  790.         }
  791.         if(expression.inUseModel(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ID_CONFIGURAZIONE_TRANSAZIONE_STATO,false)){
  792.             String tableName1 = this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO);
  793.             String tableName2 = this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ID_CONFIGURAZIONE_TRANSAZIONE_STATO);
  794.             sqlQueryObject.addWhereCondition(tableName1+".id_configurazione_stato="+tableName2+".id");
  795.         }
  796.         
  797.         // Check FROM Table necessarie per le join di oggetti annidati dal secondo livello in poi dove pero' non viene poi utilizzato l'oggetto del livello precedente nella espressione
  798.         if(expression.inUseModel(ConfigurazioneTransazione.model().ID_CONFIGURAZIONE_SERVIZIO_AZIONE.ID_CONFIGURAZIONE_SERVIZIO,false)){
  799.             if(expression.inUseModel(ConfigurazioneTransazione.model().ID_CONFIGURAZIONE_SERVIZIO_AZIONE,false)==false){
  800.                 sqlQueryObject.addFromTable(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().ID_CONFIGURAZIONE_SERVIZIO_AZIONE));
  801.             }
  802.         }
  803.         if(expression.inUseModel(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ID_CONFIGURAZIONE_TRANSAZIONE_STATO,false)){
  804.             if(expression.inUseModel(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO,false)==false){
  805.                 sqlQueryObject.addFromTable(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO));
  806.             }
  807.         }
  808.         
  809.     }
  810.     
  811.     protected java.util.List<Object> getRootTablePrimaryKeyValuesEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneTransazione id) throws NotFoundException, ServiceException, NotImplementedException, Exception{
  812.         // Identificativi
  813.         java.util.List<Object> rootTableIdValues = new java.util.ArrayList<>();
  814.         // TODO: Define the column values used to identify the primary key
  815.         Long longId = this.findIdConfigurazioneTransazione(jdbcProperties, log, connection, sqlQueryObject.newSQLQueryObject(), id, true);
  816.         rootTableIdValues.add(longId);
  817.         
  818.         // Delete this line when you have verified the method
  819.         int throwNotImplemented = 1;
  820.         if(throwNotImplemented==1){
  821.                 throw new NotImplementedException("NotImplemented");
  822.         }
  823.         // Delete this line when you have verified the method
  824.         
  825.         return rootTableIdValues;
  826.     }
  827.     
  828.     protected Map<String, List<IField>> getMapTableToPKColumnEngine() throws NotImplementedException, Exception{
  829.     
  830.         ConfigurazioneTransazioneFieldConverter converter = this.getConfigurazioneTransazioneFieldConverter();
  831.         Map<String, List<IField>> mapTableToPKColumn = new java.util.HashMap<>();
  832.         UtilsTemplate<IField> utilities = new UtilsTemplate<>();

  834.         // ConfigurazioneTransazione.model()
  835.         mapTableToPKColumn.put(converter.toTable(ConfigurazioneTransazione.model()),
  836.             utilities.newList(
  837.                 new CustomField("id", Long.class, "id", converter.toTable(ConfigurazioneTransazione.model()))
  838.             ));

  840.         // ConfigurazioneTransazione.model().ID_CONFIGURAZIONE_SERVIZIO_AZIONE
  841.         mapTableToPKColumn.put(converter.toTable(ConfigurazioneTransazione.model().ID_CONFIGURAZIONE_SERVIZIO_AZIONE),
  842.             utilities.newList(
  843.                 new CustomField("id", Long.class, "id", converter.toTable(ConfigurazioneTransazione.model().ID_CONFIGURAZIONE_SERVIZIO_AZIONE))
  844.             ));

  846.         // ConfigurazioneTransazione.model().ID_CONFIGURAZIONE_SERVIZIO_AZIONE.ID_CONFIGURAZIONE_SERVIZIO
  847.         mapTableToPKColumn.put(converter.toTable(ConfigurazioneTransazione.model().ID_CONFIGURAZIONE_SERVIZIO_AZIONE.ID_CONFIGURAZIONE_SERVIZIO),
  848.             utilities.newList(
  849.                 new CustomField("id", Long.class, "id", converter.toTable(ConfigurazioneTransazione.model().ID_CONFIGURAZIONE_SERVIZIO_AZIONE.ID_CONFIGURAZIONE_SERVIZIO))
  850.             ));

  852.         // ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO
  853.         mapTableToPKColumn.put(converter.toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO),
  854.             utilities.newList(
  855.                 new CustomField("id", Long.class, "id", converter.toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_STATO))
  856.             ));

  858.         // ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO
  859.         mapTableToPKColumn.put(converter.toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO),
  860.             utilities.newList(
  861.                 new CustomField("id", Long.class, "id", converter.toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO))
  862.             ));

  864.         // ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ID_CONFIGURAZIONE_TRANSAZIONE_STATO
  865.         mapTableToPKColumn.put(converter.toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ID_CONFIGURAZIONE_TRANSAZIONE_STATO),
  866.             utilities.newList(
  867.                 new CustomField("id", Long.class, "id", converter.toTable(ConfigurazioneTransazione.model().CONFIGURAZIONE_TRANSAZIONE_RISORSA_CONTENUTO.ID_CONFIGURAZIONE_TRANSAZIONE_STATO))
  868.             ));
  869.         
  870.         return mapTableToPKColumn;      
  871.     }
  872.     
  873.     @Override
  874.     public List<Long> findAllTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression paginatedExpression) throws ServiceException, NotImplementedException, Exception {
  875.         
  876.         List<Long> list = new ArrayList<Long>();

  878.         sqlQueryObject.setSelectDistinct(true);
  879.         sqlQueryObject.setANDLogicOperator(true);
  880.         sqlQueryObject.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model())+".id");
  881.         Class<?> objectIdClass = Long.class;
  882.         
  883.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFindAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  884.                                                 this.getConfigurazioneTransazioneFieldConverter(), ConfigurazioneTransazione.model());
  885.         
  886.         joinEngine(paginatedExpression,sqlQueryObject);
  887.         
  888.         List<Object> listObjects = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.findAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  889.                                                                             this.getConfigurazioneTransazioneFieldConverter(), ConfigurazioneTransazione.model(), objectIdClass, listaQuery);
  890.         for(Object object: listObjects) {
  891.             list.add((Long)object);
  892.         }

  894.         return list;
  895.         
  896.     }
  897.     
  898.     @Override
  899.     public long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException, Exception {
  900.     
  901.         sqlQueryObject.setSelectDistinct(true);
  902.         sqlQueryObject.setANDLogicOperator(true);
  903.         sqlQueryObject.addSelectField(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model())+".id");
  904.         Class<?> objectIdClass = Long.class;
  905.         
  906.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFind(jdbcProperties, log, connection, sqlQueryObject, expression,
  907.                                                 this.getConfigurazioneTransazioneFieldConverter(), ConfigurazioneTransazione.model());
  908.         
  909.         joinEngine(expression,sqlQueryObject);

  911.         Object res = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.find(jdbcProperties, log, connection, sqlQueryObject, expression,
  912.                                                         this.getConfigurazioneTransazioneFieldConverter(), ConfigurazioneTransazione.model(), objectIdClass, listaQuery);
  913.         if(res!=null && (((Long) res).longValue()>0) ){
  914.             return ((Long) res).longValue();
  915.         }
  916.         else{
  917.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  918.         }
  919.         
  920.     }

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

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

  929.         InUse inUse = new InUse();
  930.         inUse.setInUse(false);
  931.         
  932.         /* 
  933.          * TODO: implement code that checks whether the object identified by the id parameter is used by other objects
  934.         */
  935.         
  936.         // Delete this line when you have implemented the method
  937.         int throwNotImplemented = 1;
  938.         if(throwNotImplemented==1){
  939.                 throw new NotImplementedException("NotImplemented");
  940.         }
  941.         // Delete this line when you have implemented the method

  943.         return inUse;

  945.     }
  946.     
  947.     @Override
  948.     public IdConfigurazioneTransazione findId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, boolean throwNotFound)
  949.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  950.         
  951.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  952.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  954.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();             

  956.         // Object _configurazioneTransazione
  957.         sqlQueryObjectGet.addFromTable(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model()));
  958.         sqlQueryObjectGet.addSelectField("id_conf_servizio_azione");
  959.         sqlQueryObjectGet.setANDLogicOperator(true);
  960.         sqlQueryObjectGet.addWhereCondition("id=?");

  962.         // Recupero _configurazioneTransazione
  963.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_configurazioneTransazione = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  964.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(tableId,Long.class)
  965.         };
  966.         List<Class<?>> listaFieldIdReturnType_configurazioneTransazione = new ArrayList<Class<?>>();
  967.         listaFieldIdReturnType_configurazioneTransazione.add(Long.class);
  968.         org.openspcoop2.monitor.engine.config.transazioni.IdConfigurazioneTransazione id_configurazioneTransazione = null;
  969.         List<Object> listaFieldId_configurazioneTransazione = jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  970.                 listaFieldIdReturnType_configurazioneTransazione, searchParams_configurazioneTransazione);
  971.         if(listaFieldId_configurazioneTransazione==null || listaFieldId_configurazioneTransazione.size()<=0){
  972.             if(throwNotFound){
  973.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  974.             }
  975.         }
  976.         else{
  977.             // set _configurazioneTransazione
  978.             id_configurazioneTransazione = new org.openspcoop2.monitor.engine.config.transazioni.IdConfigurazioneTransazione();
  979.             Long idFK_configurazioneTransazione_configurazioneServizioAzione = (Long) listaFieldId_configurazioneTransazione.get(1);
  980.             IdConfigurazioneServizioAzione _tmpIdConfigurazioneServizioAzione = 
  981.                     JDBCConfigurazioneServizioAzioneBaseLib.getIdConfigurazioneServizioAzione(connection, jdbcProperties, log, idFK_configurazioneTransazione_configurazioneServizioAzione);
  982.             
  983.             org.openspcoop2.monitor.engine.config.transazioni.IdConfigurazioneServizioAzione idConfigurazioneServizioAzione = new org.openspcoop2.monitor.engine.config.transazioni.IdConfigurazioneServizioAzione();
  984.             idConfigurazioneServizioAzione.setAzione(_tmpIdConfigurazioneServizioAzione.getAzione());
  985.             org.openspcoop2.monitor.engine.config.transazioni.IdConfigurazioneServizio idConfigurazioneServizio = new org.openspcoop2.monitor.engine.config.transazioni.IdConfigurazioneServizio();
  986.             idConfigurazioneServizio.setAccordo(_tmpIdConfigurazioneServizioAzione.getIdConfigurazioneServizio().getAccordo());
  987.             idConfigurazioneServizio.setTipoSoggettoReferente(_tmpIdConfigurazioneServizioAzione.getIdConfigurazioneServizio().getTipoSoggettoReferente());
  988.             idConfigurazioneServizio.setNomeSoggettoReferente(_tmpIdConfigurazioneServizioAzione.getIdConfigurazioneServizio().getNomeSoggettoReferente());
  989.             idConfigurazioneServizio.setVersione(_tmpIdConfigurazioneServizioAzione.getIdConfigurazioneServizio().getVersione());
  990.             idConfigurazioneServizio.setServizio(_tmpIdConfigurazioneServizioAzione.getIdConfigurazioneServizio().getServizio());
  991.             idConfigurazioneServizioAzione.setIdConfigurazioneServizio(idConfigurazioneServizio);
  992.             id_configurazioneTransazione.setIdConfigurazioneServizioAzione(idConfigurazioneServizioAzione);
  993.         }
  994.         
  995.         return id_configurazioneTransazione;
  996.         
  997.     }

  999.     @Override
  1000.     public Long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneTransazione id, boolean throwNotFound)
  1001.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  1002.     
  1003.         return this.findIdConfigurazioneTransazione(jdbcProperties,log,connection,sqlQueryObject,id,throwNotFound);
  1004.             
  1005.     }
  1006.     
  1007.     @Override
  1008.     public List<List<Object>> nativeQuery(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  1009.                                             String sql,List<Class<?>> returnClassTypes,Object ... param) throws ServiceException,NotFoundException,NotImplementedException,Exception{
  1010.         
  1011.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeQuery(jdbcProperties, log, connection, sqlQueryObject,
  1012.                                                                                             sql,returnClassTypes,param);
  1013.                                                         
  1014.     }
  1015.     
  1016.     protected Long findIdConfigurazioneTransazione(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneTransazione id, boolean throwNotFound) throws NotFoundException, ServiceException, NotImplementedException, Exception {

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

  1021.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();

  1023.         
  1024.         // Object _configurazioneServizioAzione
  1025.         
  1026.         if(id==null){
  1027.             throw new ServiceException("Id is null");
  1028.         }
  1029.         if(id.getIdConfigurazioneServizioAzione()==null){
  1030.             throw new ServiceException("IdConfigurazioneServizioAzione is null");
  1031.         }
  1032.         if(id.getIdConfigurazioneServizioAzione().getAzione()==null){
  1033.             throw new ServiceException("IdConfigurazioneServizioAzione.azione is null");
  1034.         }
  1035.         if(id.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio()==null){
  1036.             throw new ServiceException("IdConfigurazioneServizioAzione.idConfigurazioneServizio is null");
  1037.         }
  1038.                 
  1039.         Long id_configurazioneServizioAzione = 
  1040.                 JDBCConfigurazioneServizioAzioneBaseLib.getIdConfigurazioneServizioAzione(connection, jdbcProperties, log, 
  1041.                         id.getIdConfigurazioneServizioAzione().getAzione(),
  1042.                         id.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().getAccordo(), 
  1043.                         id.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().getTipoSoggettoReferente(), 
  1044.                         id.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().getNomeSoggettoReferente(), 
  1045.                         id.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().getVersione(), 
  1046.                         id.getIdConfigurazioneServizioAzione().getIdConfigurazioneServizio().getServizio(),
  1047.                         throwNotFound);
  1048.         if(id_configurazioneServizioAzione==null){
  1049.             return null; // permesso se throwNotFound==false
  1050.         }
  1051.         
  1052.         
  1053.         // Object _configurazioneTransazione
  1054.         sqlQueryObjectGet.addFromTable(this.getConfigurazioneTransazioneFieldConverter().toTable(ConfigurazioneTransazione.model()));
  1055.         sqlQueryObjectGet.addSelectField("id");
  1056.         sqlQueryObjectGet.setANDLogicOperator(true);
  1057.         sqlQueryObjectGet.setSelectDistinct(true);
  1058.         sqlQueryObjectGet.addWhereCondition("id_conf_servizio_azione=?");

  1060.         // Recupero _configurazioneTransazione
  1061.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_configurazioneTransazione = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  1062.                 new JDBCObject( id_configurazioneServizioAzione, Long.class )
  1063.         };
  1064.         Long id_configurazioneTransazione = null;
  1065.         try{
  1066.             id_configurazioneTransazione = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  1067.                         Long.class, searchParams_configurazioneTransazione);
  1068.         }catch(NotFoundException notFound){
  1069.             if(throwNotFound){
  1070.                 throw new NotFoundException(notFound);
  1071.             }
  1072.         }
  1073.         if(id_configurazioneTransazione==null || id_configurazioneTransazione<=0){
  1074.             if(throwNotFound){
  1075.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  1076.             }
  1077.         }
  1078.         
  1079.         return id_configurazioneTransazione;
  1080.     }
  1081. }
Created with JaCoCo 0.8.8.202204050719