JDBCConfigurazioneServizioAzioneServiceSearchImpl.java

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

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

  26. import java.sql.Connection;

  28. import org.slf4j.Logger;

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

  32. import org.openspcoop2.generic_project.expression.impl.sql.ISQLFieldConverter;
  33. import org.openspcoop2.generic_project.dao.jdbc.utils.IJDBCFetch;
  34. import org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject;
  35. import org.openspcoop2.generic_project.dao.jdbc.IJDBCServiceSearchWithId;
  36. import org.openspcoop2.core.plugins.IdConfigurazioneServizioAzione;
  37. import org.openspcoop2.generic_project.utils.UtilsTemplate;
  38. import org.openspcoop2.generic_project.beans.CustomField;
  39. import org.openspcoop2.generic_project.beans.InUse;
  40. import org.openspcoop2.generic_project.beans.IField;
  41. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  42. import org.openspcoop2.generic_project.beans.UnionExpression;
  43. import org.openspcoop2.generic_project.beans.Union;
  44. import org.openspcoop2.generic_project.beans.FunctionField;
  45. import org.openspcoop2.generic_project.exception.MultipleResultException;
  46. import org.openspcoop2.generic_project.exception.NotFoundException;
  47. import org.openspcoop2.generic_project.exception.NotImplementedException;
  48. import org.openspcoop2.generic_project.exception.ServiceException;
  49. import org.openspcoop2.generic_project.expression.IExpression;
  50. import org.openspcoop2.generic_project.dao.jdbc.JDBCExpression;
  51. import org.openspcoop2.generic_project.dao.jdbc.JDBCPaginatedExpression;

  53. import org.openspcoop2.generic_project.dao.jdbc.JDBCServiceManagerProperties;
  54. import org.openspcoop2.core.plugins.dao.jdbc.converter.ConfigurazioneServizioAzioneFieldConverter;
  55. import org.openspcoop2.core.plugins.dao.jdbc.fetch.ConfigurazioneServizioAzioneFetch;
  56. import org.openspcoop2.core.plugins.dao.IDBConfigurazioneServizioServiceSearch;
  57. import org.openspcoop2.core.plugins.ConfigurazioneServizio;
  58. import org.openspcoop2.core.plugins.ConfigurazioneServizioAzione;
  59. import org.openspcoop2.core.plugins.IdConfigurazioneServizio;

  61. /**     
  62.  * JDBCConfigurazioneServizioAzioneServiceSearchImpl
  63.  *
  64.  * @author Poli Andrea (poli@link.it)
  65.  * @author $Author$
  66.  * @version $Rev$, $Date$
  67.  */
  68. public class JDBCConfigurazioneServizioAzioneServiceSearchImpl implements IJDBCServiceSearchWithId<ConfigurazioneServizioAzione, IdConfigurazioneServizioAzione, JDBCServiceManager> {

  70.     private ConfigurazioneServizioAzioneFieldConverter _configurazioneServizioAzioneFieldConverter = null;
  71.     public ConfigurazioneServizioAzioneFieldConverter getConfigurazioneServizioAzioneFieldConverter() {
  72.         if(this._configurazioneServizioAzioneFieldConverter==null){
  73.             this._configurazioneServizioAzioneFieldConverter = new ConfigurazioneServizioAzioneFieldConverter(this.jdbcServiceManager.getJdbcProperties().getDatabaseType());
  74.         }       
  75.         return this._configurazioneServizioAzioneFieldConverter;
  76.     }
  77.     @Override
  78.     public ISQLFieldConverter getFieldConverter() {
  79.         return this.getConfigurazioneServizioAzioneFieldConverter();
  80.     }
  81.     
  82.     private ConfigurazioneServizioAzioneFetch configurazioneServizioAzioneFetch = new ConfigurazioneServizioAzioneFetch();
  83.     public ConfigurazioneServizioAzioneFetch getConfigurazioneServizioAzioneFetch() {
  84.         return this.configurazioneServizioAzioneFetch;
  85.     }
  86.     @Override
  87.     public IJDBCFetch getFetch() {
  88.         return getConfigurazioneServizioAzioneFetch();
  89.     }
  90.     
  91.     
  92.     private JDBCServiceManager jdbcServiceManager = null;

  94.     @Override
  95.     public void setServiceManager(JDBCServiceManager serviceManager) throws ServiceException{
  96.         this.jdbcServiceManager = serviceManager;
  97.     }
  98.     
  99.     @Override
  100.     public JDBCServiceManager getServiceManager() throws ServiceException{
  101.         return this.jdbcServiceManager;
  102.     }
  103.     

  105.     @Override
  106.     public IdConfigurazioneServizioAzione convertToId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, ConfigurazioneServizioAzione configurazioneServizioAzione) throws NotImplementedException, ServiceException, Exception{
  107.     
  108.         IdConfigurazioneServizioAzione idConfigurazioneServizioAzione = new IdConfigurazioneServizioAzione();
  109.         idConfigurazioneServizioAzione.setAzione(configurazioneServizioAzione.getAzione());
  110.         idConfigurazioneServizioAzione.setIdConfigurazioneServizio(configurazioneServizioAzione.getIdConfigurazioneServizio());
  111.         return idConfigurazioneServizioAzione;

  113.     }
  114.     
  115.     @Override
  116.     public ConfigurazioneServizioAzione get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneServizioAzione id, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {
  117.         Long id_configurazioneServizioAzione = ( (id!=null && id.getId()!=null && id.getId()>0) ? id.getId() : this.findIdConfigurazioneServizioAzione(jdbcProperties, log, connection, sqlQueryObject, id, true));
  118.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, id_configurazioneServizioAzione,idMappingResolutionBehaviour);
  119.         
  120.         
  121.     }
  122.     
  123.     @Override
  124.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneServizioAzione id) throws MultipleResultException, NotImplementedException, ServiceException,Exception {

  126.         Long id_configurazioneServizioAzione = this.findIdConfigurazioneServizioAzione(jdbcProperties, log, connection, sqlQueryObject, id, false);
  127.         return id_configurazioneServizioAzione != null && id_configurazioneServizioAzione > 0;
  128.         
  129.     }
  130.     
  131.     @Override
  132.     public List<IdConfigurazioneServizioAzione> findAllIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException, ServiceException,Exception {

  134.         List<IdConfigurazioneServizioAzione> list = new ArrayList<IdConfigurazioneServizioAzione>();

  136.         // TODO: implementazione non efficiente. 
  137.         // Per ottenere una implementazione efficiente:
  138.         // 1. Usare metodo select di questa classe indirizzando esattamente i field necessari a create l'ID logico
  139.         // 2. Usare metodo getConfigurazioneServizioAzioneFetch() sul risultato della select per ottenere un oggetto ConfigurazioneServizioAzione
  140.         //    La fetch con la map inserirà nell'oggetto solo i valori estratti 
  141.         // 3. Usare metodo convertToId per ottenere l'id

  143.         List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  144.         
  145.         for(Long id: ids) {
  146.             ConfigurazioneServizioAzione configurazioneServizioAzione = this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour);
  147.             IdConfigurazioneServizioAzione idConfigurazioneServizioAzione = this.convertToId(jdbcProperties,log,connection,sqlQueryObject,configurazioneServizioAzione);
  148.             list.add(idConfigurazioneServizioAzione);
  149.         }

  151.         return list;
  152.         
  153.     }
  154.     
  155.     @Override
  156.     public List<ConfigurazioneServizioAzione> findAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException, ServiceException,Exception {

  158.         List<ConfigurazioneServizioAzione> list = new ArrayList<ConfigurazioneServizioAzione>();
  159.         
  160.         // TODO: implementazione non efficiente. 
  161.         // Per ottenere una implementazione efficiente:
  162.         // 1. Usare metodo select di questa classe indirizzando esattamente i field necessari
  163.         // 2. Usare metodo getConfigurazioneServizioAzioneFetch() sul risultato della select per ottenere un oggetto ConfigurazioneServizioAzione
  164.         //    La fetch con la map inserirà nell'oggetto solo i valori estratti 

  166.         List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  167.         
  168.         for(Long id: ids) {
  169.             list.add(this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour));
  170.         }

  172.         return list;      
  173.         
  174.     }
  175.     
  176.     @Override
  177.     public ConfigurazioneServizioAzione find(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) 
  178.         throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {

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

  203.     @Override
  204.     public InUse inUse(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneServizioAzione id) throws NotFoundException, NotImplementedException, ServiceException,Exception {
  205.         
  206.         Long id_configurazioneServizioAzione = this.findIdConfigurazioneServizioAzione(jdbcProperties, log, connection, sqlQueryObject, id, true);
  207.         return this.inUseEngine(jdbcProperties, log, connection, sqlQueryObject, id_configurazioneServizioAzione);
  208.         
  209.     }

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

  244.             return selectEngine(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression, sqlQueryObjectDistinct);
  245.             
  246.         }finally{
  247.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,paginatedExpression,field);
  248.         }
  249.     }

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

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

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



  392.     // -- ConstructorExpression 

  394.     @Override
  395.     public JDBCExpression newExpression(Logger log) throws NotImplementedException, ServiceException {
  396.         try{
  397.             return new JDBCExpression(this.getConfigurazioneServizioAzioneFieldConverter());
  398.         }catch(Exception e){
  399.             throw new ServiceException(e);
  400.         }
  401.     }


  404.     @Override
  405.     public JDBCPaginatedExpression newPaginatedExpression(Logger log) throws NotImplementedException, ServiceException {
  406.         try{
  407.             return new JDBCPaginatedExpression(this.getConfigurazioneServizioAzioneFieldConverter());
  408.         }catch(Exception e){
  409.             throw new ServiceException(e);
  410.         }
  411.     }
  412.     
  413.     @Override
  414.     public JDBCExpression toExpression(JDBCPaginatedExpression paginatedExpression, Logger log) throws NotImplementedException, ServiceException {
  415.         try{
  416.             return new JDBCExpression(paginatedExpression);
  417.         }catch(Exception e){
  418.             throw new ServiceException(e);
  419.         }
  420.     }

  422.     @Override
  423.     public JDBCPaginatedExpression toPaginatedExpression(JDBCExpression expression, Logger log) throws NotImplementedException, ServiceException {
  424.         try{
  425.             return new JDBCPaginatedExpression(expression);
  426.         }catch(Exception e){
  427.             throw new ServiceException(e);
  428.         }
  429.     }
  430.     
  431.     
  432.     
  433.     // -- DB

  435.     @Override
  436.     public void mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneServizioAzione id, ConfigurazioneServizioAzione obj) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  437.         _mappingTableIds(jdbcProperties,log,connection,sqlQueryObject,obj,
  438.                 this.get(jdbcProperties,log,connection,sqlQueryObject,id,null));
  439.     }
  440.     
  441.     @Override
  442.     public void mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, ConfigurazioneServizioAzione obj) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  443.         _mappingTableIds(jdbcProperties,log,connection,sqlQueryObject,obj,
  444.                 this.get(jdbcProperties,log,connection,sqlQueryObject,tableId,null));
  445.     }
  446.     private void _mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, ConfigurazioneServizioAzione obj, ConfigurazioneServizioAzione imgSaved) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  447.         if(imgSaved==null){
  448.             return;
  449.         }
  450.         obj.setId(imgSaved.getId());
  451.         if(obj.getIdConfigurazioneServizio()!=null && 
  452.                 imgSaved.getIdConfigurazioneServizio()!=null){
  453.             obj.getIdConfigurazioneServizio().setId(imgSaved.getIdConfigurazioneServizio().getId());
  454.         }

  456.     }
  457.     
  458.     @Override
  459.     public ConfigurazioneServizioAzione get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  460.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId), idMappingResolutionBehaviour);
  461.     }
  462.     
  463.     private ConfigurazioneServizioAzione getEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  464.     
  465.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  466.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  467.         
  468.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();
  469.                 
  470.         ConfigurazioneServizioAzione configurazioneServizioAzione = new ConfigurazioneServizioAzione();
  471.         

  473.         // Object configurazioneServizioAzione
  474.         ISQLQueryObject sqlQueryObjectGet_configurazioneServizioAzione = sqlQueryObjectGet.newSQLQueryObject();
  475.         sqlQueryObjectGet_configurazioneServizioAzione.setANDLogicOperator(true);
  476.         sqlQueryObjectGet_configurazioneServizioAzione.addFromTable(this.getConfigurazioneServizioAzioneFieldConverter().toTable(ConfigurazioneServizioAzione.model()));
  477.         sqlQueryObjectGet_configurazioneServizioAzione.addSelectField("id");
  478.         sqlQueryObjectGet_configurazioneServizioAzione.addSelectField(this.getConfigurazioneServizioAzioneFieldConverter().toColumn(ConfigurazioneServizioAzione.model().AZIONE,true));
  479.         sqlQueryObjectGet_configurazioneServizioAzione.addWhereCondition("id=?");

  481.         // Get configurazioneServizioAzione
  482.         configurazioneServizioAzione = (ConfigurazioneServizioAzione) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_configurazioneServizioAzione.createSQLQuery(), jdbcProperties.isShowSql(), ConfigurazioneServizioAzione.model(), this.getConfigurazioneServizioAzioneFetch(),
  483.             new JDBCObject(tableId,Long.class));


  486.         if(idMappingResolutionBehaviour==null ||
  487.             (org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour) || org.openspcoop2.generic_project.beans.IDMappingBehaviour.USE_TABLE_ID.equals(idMappingResolutionBehaviour))
  488.         ){
  489.             // Recupero IdConfigurazioneServizio
  490.             ISQLQueryObject sqlQueryObjectGet_idConfigurazioneServizio = sqlQueryObjectGet.newSQLQueryObject();
  491.             sqlQueryObjectGet_idConfigurazioneServizio.addFromTable(this.getConfigurazioneServizioAzioneFieldConverter().toTable(ConfigurazioneServizioAzione.model()));
  492.             sqlQueryObjectGet_idConfigurazioneServizio.addSelectField("id_config_servizio");
  493.             sqlQueryObjectGet_idConfigurazioneServizio.addWhereCondition("id=?");
  494.             sqlQueryObjectGet_idConfigurazioneServizio.setANDLogicOperator(true);
  495.             Long id_idConfigurazioneServizio = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_idConfigurazioneServizio.createSQLQuery(), jdbcProperties.isShowSql(),Long.class,
  496.                     new JDBCObject(configurazioneServizioAzione.getId(),Long.class));
  497.         
  498.             ConfigurazioneServizio configuraServizio = 
  499.                     ((IDBConfigurazioneServizioServiceSearch)this.getServiceManager().getConfigurazioneServizioServiceSearch()).get(id_idConfigurazioneServizio);
  500.             IdConfigurazioneServizio idConfigurazioneServizio = new IdConfigurazioneServizio();
  501.             idConfigurazioneServizio.setAccordo(configuraServizio.getAccordo());
  502.             idConfigurazioneServizio.setTipoSoggettoReferente(configuraServizio.getTipoSoggettoReferente());
  503.             idConfigurazioneServizio.setNomeSoggettoReferente(configuraServizio.getNomeSoggettoReferente());
  504.             idConfigurazioneServizio.setVersione(configuraServizio.getVersione());
  505.             idConfigurazioneServizio.setServizio(configuraServizio.getServizio());
  506.             configurazioneServizioAzione.setIdConfigurazioneServizio(idConfigurazioneServizio);
  507.         }
  508.         
  509.         return configurazioneServizioAzione;  
  510.     
  511.     } 
  512.     
  513.     @Override
  514.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  515.         return this._exists(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  516.     }
  517.     
  518.     private boolean _exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  519.     
  520.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  521.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  522.                 
  523.         boolean existsConfigurazioneServizioAzione = false;

  525.         sqlQueryObject = sqlQueryObject.newSQLQueryObject();
  526.         sqlQueryObject.setANDLogicOperator(true);

  528.         sqlQueryObject.addFromTable(this.getConfigurazioneServizioAzioneFieldConverter().toTable(ConfigurazioneServizioAzione.model()));
  529.         sqlQueryObject.addSelectField(this.getConfigurazioneServizioAzioneFieldConverter().toColumn(ConfigurazioneServizioAzione.model().AZIONE,true));
  530.         sqlQueryObject.addWhereCondition("id=?");


  533.         // Exists configurazioneServizioAzione
  534.         existsConfigurazioneServizioAzione = jdbcUtilities.exists(sqlQueryObject.createSQLQuery(), jdbcProperties.isShowSql(),
  535.             new JDBCObject(tableId,Long.class));

  537.         
  538.         return existsConfigurazioneServizioAzione;
  539.     
  540.     }
  541.     
  542.     private void joinEngine(IExpression expression, ISQLQueryObject sqlQueryObject) throws NotImplementedException, ServiceException, Exception{
  543.     
  544.         if(expression.inUseModel(ConfigurazioneServizioAzione.model().ID_CONFIGURAZIONE_SERVIZIO,false)){
  545.             String tableName1 = this.getConfigurazioneServizioAzioneFieldConverter().toTable(ConfigurazioneServizioAzione.model());
  546.             String tableName2 = this.getConfigurazioneServizioAzioneFieldConverter().toTable(ConfigurazioneServizioAzione.model().ID_CONFIGURAZIONE_SERVIZIO);
  547.             sqlQueryObject.addWhereCondition(tableName1+".id_config_servizio="+tableName2+".id");
  548.         }
  549.         
  550.     }
  551.     
  552.     protected java.util.List<Object> getRootTablePrimaryKeyValuesEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneServizioAzione id) throws NotFoundException, ServiceException, NotImplementedException, Exception{
  553.         // Identificativi
  554.         java.util.List<Object> rootTableIdValues = new java.util.ArrayList<>();
  555.         Long longId = this.findIdConfigurazioneServizioAzione(jdbcProperties, log, connection, sqlQueryObject.newSQLQueryObject(), id, true);
  556.         rootTableIdValues.add(longId);        
  557.         return rootTableIdValues;
  558.     }
  559.     
  560.     protected Map<String, List<IField>> getMapTableToPKColumnEngine() throws NotImplementedException, Exception{
  561.     
  562.         ConfigurazioneServizioAzioneFieldConverter converter = this.getConfigurazioneServizioAzioneFieldConverter();
  563.         Map<String, List<IField>> mapTableToPKColumn = new java.util.HashMap<>();
  564.         UtilsTemplate<IField> utilities = new UtilsTemplate<>();

  566.         // ConfigurazioneServizioAzione.model()
  567.         mapTableToPKColumn.put(converter.toTable(ConfigurazioneServizioAzione.model()),
  568.             utilities.newList(
  569.                 new CustomField("id", Long.class, "id", converter.toTable(ConfigurazioneServizioAzione.model()))
  570.             ));

  572.         // ConfigurazioneServizioAzione.model().ID_CONFIGURAZIONE_SERVIZIO
  573.         mapTableToPKColumn.put(converter.toTable(ConfigurazioneServizioAzione.model().ID_CONFIGURAZIONE_SERVIZIO),
  574.             utilities.newList(
  575.                 new CustomField("id", Long.class, "id", converter.toTable(ConfigurazioneServizioAzione.model().ID_CONFIGURAZIONE_SERVIZIO))
  576.             ));
  577.         
  578.         return mapTableToPKColumn;      
  579.     }
  580.     
  581.     @Override
  582.     public List<Long> findAllTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression paginatedExpression) throws ServiceException, NotImplementedException, Exception {
  583.         
  584.         List<Long> list = new ArrayList<Long>();

  586.         sqlQueryObject.setSelectDistinct(true);
  587.         sqlQueryObject.setANDLogicOperator(true);
  588.         sqlQueryObject.addSelectField(this.getConfigurazioneServizioAzioneFieldConverter().toTable(ConfigurazioneServizioAzione.model())+".id");
  589.         Class<?> objectIdClass = Long.class;
  590.         
  591.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFindAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  592.                                                 this.getConfigurazioneServizioAzioneFieldConverter(), ConfigurazioneServizioAzione.model());
  593.         
  594.         joinEngine(paginatedExpression,sqlQueryObject);
  595.         
  596.         List<Object> listObjects = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.findAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  597.                                                                             this.getConfigurazioneServizioAzioneFieldConverter(), ConfigurazioneServizioAzione.model(), objectIdClass, listaQuery);
  598.         for(Object object: listObjects) {
  599.             list.add((Long)object);
  600.         }

  602.         return list;
  603.         
  604.     }
  605.     
  606.     @Override
  607.     public long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException, Exception {
  608.     
  609.         sqlQueryObject.setSelectDistinct(true);
  610.         sqlQueryObject.setANDLogicOperator(true);
  611.         sqlQueryObject.addSelectField(this.getConfigurazioneServizioAzioneFieldConverter().toTable(ConfigurazioneServizioAzione.model())+".id");
  612.         Class<?> objectIdClass = Long.class;
  613.         
  614.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFind(jdbcProperties, log, connection, sqlQueryObject, expression,
  615.                                                 this.getConfigurazioneServizioAzioneFieldConverter(), ConfigurazioneServizioAzione.model());
  616.         
  617.         joinEngine(expression,sqlQueryObject);

  619.         Object res = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.find(jdbcProperties, log, connection, sqlQueryObject, expression,
  620.                                                         this.getConfigurazioneServizioAzioneFieldConverter(), ConfigurazioneServizioAzione.model(), objectIdClass, listaQuery);
  621.         if(res!=null && (((Long) res).longValue()>0) ){
  622.             return ((Long) res).longValue();
  623.         }
  624.         else{
  625.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  626.         }
  627.         
  628.     }

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

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

  637.         InUse inUse = new InUse();
  638.         inUse.setInUse(false);
  639.         
  640.         /* 
  641.          * TODO: implement code that checks whether the object identified by the id parameter is used by other objects
  642.         */
  643.         
  644.         // Delete this line when you have implemented the method
  645.         int throwNotImplemented = 1;
  646.         if(throwNotImplemented==1){
  647.                 throw new NotImplementedException("NotImplemented");
  648.         }
  649.         // Delete this line when you have implemented the method

  651.         return inUse;

  653.     }
  654.     
  655.     @Override
  656.     public IdConfigurazioneServizioAzione findId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, boolean throwNotFound)
  657.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  658.         
  659.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  660.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  662.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();

  664.          
  665.         // Object _configurazioneServizioAzione
  666.         sqlQueryObjectGet.addFromTable(this.getConfigurazioneServizioAzioneFieldConverter().toTable(ConfigurazioneServizioAzione.model()));
  667.         sqlQueryObjectGet.addSelectField(this.getConfigurazioneServizioAzioneFieldConverter().toColumn(ConfigurazioneServizioAzione.model().AZIONE,true));
  668.         sqlQueryObjectGet.addSelectField("id_config_servizio");
  669.         sqlQueryObjectGet.addSelectField(this.getConfigurazioneServizioAzioneFieldConverter().toColumn(ConfigurazioneServizioAzione.model().ID_CONFIGURAZIONE_SERVIZIO.TIPO_SOGGETTO_REFERENTE,true));
  670.         sqlQueryObjectGet.addSelectField(this.getConfigurazioneServizioAzioneFieldConverter().toColumn(ConfigurazioneServizioAzione.model().ID_CONFIGURAZIONE_SERVIZIO.NOME_SOGGETTO_REFERENTE,true));
  671.         sqlQueryObjectGet.addSelectField(this.getConfigurazioneServizioAzioneFieldConverter().toColumn(ConfigurazioneServizioAzione.model().ID_CONFIGURAZIONE_SERVIZIO.ACCORDO,true));
  672.         sqlQueryObjectGet.addSelectField(this.getConfigurazioneServizioAzioneFieldConverter().toColumn(ConfigurazioneServizioAzione.model().ID_CONFIGURAZIONE_SERVIZIO.SERVIZIO,true));
  673.         sqlQueryObjectGet.addSelectField(this.getConfigurazioneServizioAzioneFieldConverter().toColumn(ConfigurazioneServizioAzione.model().ID_CONFIGURAZIONE_SERVIZIO.VERSIONE,true));
  674.         sqlQueryObjectGet.setANDLogicOperator(true);
  675.         sqlQueryObjectGet.addWhereCondition("id=?");

  677.         // Recupero _configurazioneServizioAzione
  678.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_configurazioneServizioAzione = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  679.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(tableId,Long.class)
  680.         };
  681.         List<Class<?>> listaFieldIdReturnType_configurazioneServizioAzione = new ArrayList<Class<?>>();
  682.         listaFieldIdReturnType_configurazioneServizioAzione.add(String.class);
  683.         listaFieldIdReturnType_configurazioneServizioAzione.add(Long.class);
  684.         listaFieldIdReturnType_configurazioneServizioAzione.add(String.class);
  685.         listaFieldIdReturnType_configurazioneServizioAzione.add(String.class);
  686.         listaFieldIdReturnType_configurazioneServizioAzione.add(String.class);
  687.         listaFieldIdReturnType_configurazioneServizioAzione.add(String.class);
  688.         listaFieldIdReturnType_configurazioneServizioAzione.add(Integer.class);
  689.         org.openspcoop2.core.plugins.IdConfigurazioneServizioAzione id_configurazioneServizioAzione = null;
  690.         List<Object> listaFieldId_configurazioneServizioAzione = jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  691.                 listaFieldIdReturnType_configurazioneServizioAzione, searchParams_configurazioneServizioAzione);
  692.         if(listaFieldId_configurazioneServizioAzione==null || listaFieldId_configurazioneServizioAzione.size()<=0){
  693.             if(throwNotFound){
  694.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  695.             }
  696.         }
  697.         else{
  698.             // set _configurazioneServizioAzione
  699.             id_configurazioneServizioAzione = new org.openspcoop2.core.plugins.IdConfigurazioneServizioAzione();
  700.             id_configurazioneServizioAzione.setAzione((String)listaFieldId_configurazioneServizioAzione.get(0));
  701.             Long idConfigurazioneServizio = (Long)listaFieldId_configurazioneServizioAzione.get(1);
  702.             IdConfigurazioneServizio idConf = new IdConfigurazioneServizio();
  703.             idConf.setTipoSoggettoReferente((String)listaFieldId_configurazioneServizioAzione.get(2));
  704.             idConf.setNomeSoggettoReferente((String)listaFieldId_configurazioneServizioAzione.get(3));
  705.             idConf.setAccordo((String)listaFieldId_configurazioneServizioAzione.get(4));
  706.             idConf.setId(idConfigurazioneServizio);
  707.             idConf.setServizio((String)listaFieldId_configurazioneServizioAzione.get(5));
  708.             idConf.setVersione((Integer)listaFieldId_configurazioneServizioAzione.get(6));
  709.             id_configurazioneServizioAzione.setIdConfigurazioneServizio(idConf);
  710.         }
  711.         
  712.         return id_configurazioneServizioAzione;
  713.         
  714.     }

  716.     @Override
  717.     public Long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneServizioAzione id, boolean throwNotFound)
  718.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  719.     
  720.         return this.findIdConfigurazioneServizioAzione(jdbcProperties,log,connection,sqlQueryObject,id,throwNotFound);
  721.             
  722.     }
  723.     
  724.     @Override
  725.     public List<List<Object>> nativeQuery(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  726.                                             String sql,List<Class<?>> returnClassTypes,Object ... param) throws ServiceException,NotFoundException,NotImplementedException,Exception{
  727.         
  728.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeQuery(jdbcProperties, log, connection, sqlQueryObject,
  729.                                                                                             sql,returnClassTypes,param);
  730.                                                         
  731.     }
  732.     
  733.     protected Long findIdConfigurazioneServizioAzione(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdConfigurazioneServizioAzione id, boolean throwNotFound) throws NotFoundException, ServiceException, NotImplementedException, Exception {

  735.         if(jdbcProperties==null) {
  736.             throw new ServiceException("Param jdbcProperties is null");
  737.         }
  738.         if(sqlQueryObject==null) {
  739.             throw new ServiceException("Param sqlQueryObject is null");
  740.         }
  741.         if(id==null) {
  742.             throw new ServiceException("Param id is null");
  743.         }
  744.         
  745.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  746.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  748.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();

  750.         // Object _configurazioneServizio
  751.         if(id.getIdConfigurazioneServizio()==null){
  752.             throw new ServiceException("IdConfigurazioneServizio is null");
  753.         }
  754.                 
  755.         IExpression expressionSearchConfigurazioneServizio = this.getServiceManager().getConfigurazioneServizioServiceSearch().newExpression();
  756.         expressionSearchConfigurazioneServizio.
  757.                                                     and().
  758.                                                     equals(ConfigurazioneServizio.model().ACCORDO, id.getIdConfigurazioneServizio().getAccordo()).
  759.                                                     equals(ConfigurazioneServizio.model().TIPO_SOGGETTO_REFERENTE, id.getIdConfigurazioneServizio().getTipoSoggettoReferente()).
  760.                                                     equals(ConfigurazioneServizio.model().NOME_SOGGETTO_REFERENTE, id.getIdConfigurazioneServizio().getNomeSoggettoReferente()).
  761.                                                     equals(ConfigurazioneServizio.model().VERSIONE, id.getIdConfigurazioneServizio().getVersione()).
  762.                                                     equals(ConfigurazioneServizio.model().SERVIZIO, id.getIdConfigurazioneServizio().getServizio());
  763.         ConfigurazioneServizio configurazioneServizio = this.getServiceManager().getConfigurazioneServizioServiceSearch().find(expressionSearchConfigurazioneServizio);
  764.         Long id_configurazioneServizio = configurazioneServizio.getId();
  765.         
  766.         
  767.         // Object _configurazioneServizioAzione
  768.         sqlQueryObjectGet.addFromTable(this.getConfigurazioneServizioAzioneFieldConverter().toTable(ConfigurazioneServizioAzione.model()));
  769.         sqlQueryObjectGet.addSelectField("id");
  770.         sqlQueryObjectGet.setANDLogicOperator(true);
  771.         sqlQueryObjectGet.setSelectDistinct(true);
  772.         sqlQueryObjectGet.addWhereCondition("id_config_servizio=?");
  773.         sqlQueryObjectGet.addWhereCondition(ConfigurazioneServizioAzione.model().AZIONE.getFieldName() + "=?");

  775.         // Recupero _configurazioneServizioAzione
  776.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_configurazioneServizioAzione = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  777.                 new JDBCObject( id_configurazioneServizio, Long.class ),
  778.                 new JDBCObject( id.getAzione(), String.class )
  779.         };
  780.         Long id_configurazioneServizioAzione = null;
  781.         try{
  782.             id_configurazioneServizioAzione = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  783.                         Long.class, searchParams_configurazioneServizioAzione);
  784.         }catch(NotFoundException notFound){
  785.             if(throwNotFound){
  786.                 throw new NotFoundException(notFound);
  787.             }
  788.         }
  789.         if(id_configurazioneServizioAzione==null || id_configurazioneServizioAzione<=0){
  790.             if(throwNotFound){
  791.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  792.             }
  793.         }
  794.         
  795.         return id_configurazioneServizioAzione;
  796.     }
  797. }
Created with JaCoCo 0.8.8.202204050719