JDBCAccordoServizioParteComuneServiceSearchImpl.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.commons.search.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.commons.search.IdAccordoServizioParteComune;
  37. import org.openspcoop2.core.commons.search.IdSoggetto;
  38. import org.openspcoop2.generic_project.utils.UtilsTemplate;
  39. import org.openspcoop2.generic_project.beans.CustomField;
  40. import org.openspcoop2.generic_project.beans.InUse;
  41. import org.openspcoop2.generic_project.beans.IField;
  42. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  43. import org.openspcoop2.generic_project.beans.UnionExpression;
  44. import org.openspcoop2.generic_project.beans.Union;
  45. import org.openspcoop2.generic_project.beans.FunctionField;
  46. import org.openspcoop2.generic_project.exception.MultipleResultException;
  47. import org.openspcoop2.generic_project.exception.NotFoundException;
  48. import org.openspcoop2.generic_project.exception.NotImplementedException;
  49. import org.openspcoop2.generic_project.exception.ServiceException;
  50. import org.openspcoop2.generic_project.expression.IExpression;
  51. import org.openspcoop2.generic_project.dao.jdbc.JDBCExpression;
  52. import org.openspcoop2.generic_project.dao.jdbc.JDBCPaginatedExpression;

  54. import org.openspcoop2.generic_project.dao.jdbc.JDBCServiceManagerProperties;
  55. import org.openspcoop2.core.commons.search.dao.jdbc.converter.AccordoServizioParteComuneFieldConverter;
  56. import org.openspcoop2.core.commons.search.dao.jdbc.fetch.AccordoServizioParteComuneFetch;
  57. import org.openspcoop2.core.commons.search.dao.IDBSoggettoServiceSearch;
  58. import org.openspcoop2.core.commons.search.AccordoServizioParteComune;
  59. import org.openspcoop2.core.commons.search.AccordoServizioParteComuneAzione;
  60. import org.openspcoop2.core.commons.search.AccordoServizioParteComuneGruppo;
  61. import org.openspcoop2.core.commons.search.PortType;
  62. import org.openspcoop2.core.commons.search.Soggetto;
  63. import org.openspcoop2.core.commons.search.Resource;
  64. import org.openspcoop2.core.commons.search.Operation;

  66. /**     
  67.  * JDBCAccordoServizioParteComuneServiceSearchImpl
  68.  *
  69.  * @author Poli Andrea (poli@link.it)
  70.  * @author $Author$
  71.  * @version $Rev$, $Date$
  72.  */
  73. public class JDBCAccordoServizioParteComuneServiceSearchImpl implements IJDBCServiceSearchWithId<AccordoServizioParteComune, IdAccordoServizioParteComune, JDBCServiceManager> {

  75.     private AccordoServizioParteComuneFieldConverter _accordoServizioParteComuneFieldConverter = null;
  76.     public AccordoServizioParteComuneFieldConverter getAccordoServizioParteComuneFieldConverter() {
  77.         if(this._accordoServizioParteComuneFieldConverter==null){
  78.             this._accordoServizioParteComuneFieldConverter = new AccordoServizioParteComuneFieldConverter(this.jdbcServiceManager.getJdbcProperties().getDatabaseType());
  79.         }       
  80.         return this._accordoServizioParteComuneFieldConverter;
  81.     }
  82.     @Override
  83.     public ISQLFieldConverter getFieldConverter() {
  84.         return this.getAccordoServizioParteComuneFieldConverter();
  85.     }
  86.     
  87.     private AccordoServizioParteComuneFetch accordoServizioParteComuneFetch = new AccordoServizioParteComuneFetch();
  88.     public AccordoServizioParteComuneFetch getAccordoServizioParteComuneFetch() {
  89.         return this.accordoServizioParteComuneFetch;
  90.     }
  91.     @Override
  92.     public IJDBCFetch getFetch() {
  93.         return getAccordoServizioParteComuneFetch();
  94.     }
  95.     
  96.     
  97.     private JDBCServiceManager jdbcServiceManager = null;

  99.     @Override
  100.     public void setServiceManager(JDBCServiceManager serviceManager) throws ServiceException{
  101.         this.jdbcServiceManager = serviceManager;
  102.     }
  103.     
  104.     @Override
  105.     public JDBCServiceManager getServiceManager() throws ServiceException{
  106.         return this.jdbcServiceManager;
  107.     }
  108.     public JDBCServiceManager getServiceManager(Connection connection, JDBCServiceManagerProperties jdbcProperties, Logger log) throws ServiceException{
  109.         return new JDBCServiceManager(connection, jdbcProperties, log);
  110.     }
  111.     

  113.     @Override
  114.     public IdAccordoServizioParteComune convertToId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, AccordoServizioParteComune accordoServizioParteComune) throws NotImplementedException, ServiceException, Exception{
  115.     
  116.         IdAccordoServizioParteComune idAccordoServizioParteComune = new IdAccordoServizioParteComune();
  117.         idAccordoServizioParteComune.setIdSoggetto(accordoServizioParteComune.getIdReferente());
  118.         idAccordoServizioParteComune.setNome(accordoServizioParteComune.getNome());
  119.         idAccordoServizioParteComune.setVersione(accordoServizioParteComune.getVersione());
  120.        
  121.         idAccordoServizioParteComune.setServiceBinding(accordoServizioParteComune.getServiceBinding());
  122.         
  123.         return idAccordoServizioParteComune;

  125.     }
  126.     
  127.     @Override
  128.     public AccordoServizioParteComune get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAccordoServizioParteComune id, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {
  129.         Long id_accordoServizioParteComune = ( (id!=null && id.getId()!=null && id.getId()>0) ? id.getId() : this.findIdAccordoServizioParteComune(jdbcProperties, log, connection, sqlQueryObject, id, true));
  130.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, id_accordoServizioParteComune,idMappingResolutionBehaviour);
  131.         
  132.         
  133.     }
  134.     
  135.     @Override
  136.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAccordoServizioParteComune id) throws MultipleResultException, NotImplementedException, ServiceException,Exception {

  138.         Long id_accordoServizioParteComune = this.findIdAccordoServizioParteComune(jdbcProperties, log, connection, sqlQueryObject, id, false);
  139.         return id_accordoServizioParteComune != null && id_accordoServizioParteComune > 0;
  140.         
  141.     }
  142.     
  143.     @Override
  144.     public List<IdAccordoServizioParteComune> findAllIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException, ServiceException,Exception {

  146.         List<IdAccordoServizioParteComune> list = new ArrayList<IdAccordoServizioParteComune>();

  148.         // TODO: implementazione non efficiente. 
  149.         // Per ottenere una implementazione efficiente:
  150.         // 1. Usare metodo select di questa classe indirizzando esattamente i field necessari a create l'ID logico
  151.         // 2. Usare metodo getAccordoServizioParteComuneFetch() sul risultato della select per ottenere un oggetto AccordoServizioParteComune
  152.         //    La fetch con la map inserirà nell'oggetto solo i valori estratti 
  153.         // 3. Usare metodo convertToId per ottenere l'id

  155.         List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  156.         
  157.         for(Long id: ids) {
  158.             AccordoServizioParteComune accordoServizioParteComune = this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour);
  159.             IdAccordoServizioParteComune idAccordoServizioParteComune = this.convertToId(jdbcProperties,log,connection,sqlQueryObject,accordoServizioParteComune);
  160.             list.add(idAccordoServizioParteComune);
  161.         }

  163.         return list;
  164.         
  165.     }
  166.     
  167.     @Override
  168.     public List<AccordoServizioParteComune> findAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException, ServiceException,Exception {

  170.         List<AccordoServizioParteComune> list = new ArrayList<AccordoServizioParteComune>();
  171.         
  172.         // TODO: implementazione non efficiente. 
  173.         // Per ottenere una implementazione efficiente:
  174.         // 1. Usare metodo select di questa classe indirizzando esattamente i field necessari
  175.         // 2. Usare metodo getAccordoServizioParteComuneFetch() sul risultato della select per ottenere un oggetto AccordoServizioParteComune
  176.         //    La fetch con la map inserirà nell'oggetto solo i valori estratti 

  178.         List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  179.         
  180.         for(Long id: ids) {
  181.             list.add(this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour));
  182.         }

  184.         return list;      
  185.         
  186.     }
  187.     
  188.     @Override
  189.     public AccordoServizioParteComune find(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) 
  190.         throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {

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

  215.     @Override
  216.     public InUse inUse(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAccordoServizioParteComune id) throws NotFoundException, NotImplementedException, ServiceException,Exception {
  217.         
  218.         Long id_accordoServizioParteComune = this.findIdAccordoServizioParteComune(jdbcProperties, log, connection, sqlQueryObject, id, true);
  219.         return this.inUseEngine(jdbcProperties, log, connection, sqlQueryObject, id_accordoServizioParteComune);
  220.         
  221.     }

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

  256.             return selectEngine(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression, sqlQueryObjectDistinct);
  257.             
  258.         }finally{
  259.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,paginatedExpression,field);
  260.         }
  261.     }

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

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

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



  404.     // -- ConstructorExpression 

  406.     @Override
  407.     public JDBCExpression newExpression(Logger log) throws NotImplementedException, ServiceException {
  408.         try{
  409.             return new JDBCExpression(this.getAccordoServizioParteComuneFieldConverter());
  410.         }catch(Exception e){
  411.             throw new ServiceException(e);
  412.         }
  413.     }


  416.     @Override
  417.     public JDBCPaginatedExpression newPaginatedExpression(Logger log) throws NotImplementedException, ServiceException {
  418.         try{
  419.             return new JDBCPaginatedExpression(this.getAccordoServizioParteComuneFieldConverter());
  420.         }catch(Exception e){
  421.             throw new ServiceException(e);
  422.         }
  423.     }
  424.     
  425.     @Override
  426.     public JDBCExpression toExpression(JDBCPaginatedExpression paginatedExpression, Logger log) throws NotImplementedException, ServiceException {
  427.         try{
  428.             return new JDBCExpression(paginatedExpression);
  429.         }catch(Exception e){
  430.             throw new ServiceException(e);
  431.         }
  432.     }

  434.     @Override
  435.     public JDBCPaginatedExpression toPaginatedExpression(JDBCExpression expression, Logger log) throws NotImplementedException, ServiceException {
  436.         try{
  437.             return new JDBCPaginatedExpression(expression);
  438.         }catch(Exception e){
  439.             throw new ServiceException(e);
  440.         }
  441.     }
  442.     
  443.     
  444.     
  445.     // -- DB

  447.     @Override
  448.     public void mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAccordoServizioParteComune id, AccordoServizioParteComune obj) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  449.         _mappingTableIds(jdbcProperties,log,connection,sqlQueryObject,obj,
  450.                 this.get(jdbcProperties,log,connection,sqlQueryObject,id,null));
  451.     }
  452.     
  453.     @Override
  454.     public void mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, AccordoServizioParteComune obj) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  455.         _mappingTableIds(jdbcProperties,log,connection,sqlQueryObject,obj,
  456.                 this.get(jdbcProperties,log,connection,sqlQueryObject,tableId,null));
  457.     }
  458.     private void _mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, AccordoServizioParteComune obj, AccordoServizioParteComune imgSaved) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  459.         if(imgSaved==null){
  460.             return;
  461.         }
  462.         obj.setId(imgSaved.getId());
  463.         if(obj.getIdReferente()!=null && 
  464.                 imgSaved.getIdReferente()!=null){
  465.             obj.getIdReferente().setId(imgSaved.getIdReferente().getId());
  466.         }
  467.         if(obj.getAccordoServizioParteComuneAzioneList()!=null){
  468.             List<org.openspcoop2.core.commons.search.AccordoServizioParteComuneAzione> listObj_ = obj.getAccordoServizioParteComuneAzioneList();
  469.             for(org.openspcoop2.core.commons.search.AccordoServizioParteComuneAzione itemObj_ : listObj_){
  470.                 org.openspcoop2.core.commons.search.AccordoServizioParteComuneAzione itemAlreadySaved_ = null;
  471.                 if(imgSaved.getAccordoServizioParteComuneAzioneList()!=null){
  472.                     List<org.openspcoop2.core.commons.search.AccordoServizioParteComuneAzione> listImgSaved_ = imgSaved.getAccordoServizioParteComuneAzioneList();
  473.                     for(org.openspcoop2.core.commons.search.AccordoServizioParteComuneAzione itemImgSaved_ : listImgSaved_){
  474.                         boolean objEqualsToImgSaved_ = false;
  475.                         objEqualsToImgSaved_ = org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getNome(),itemImgSaved_.getNome());
  476.                         if(objEqualsToImgSaved_){
  477.                             itemAlreadySaved_=itemImgSaved_;
  478.                             break;
  479.                         }
  480.                     }
  481.                 }
  482.                 if(itemAlreadySaved_!=null){
  483.                     itemObj_.setId(itemAlreadySaved_.getId());
  484.                     if(itemObj_.getIdAccordoServizioParteComune()!=null && 
  485.                             itemAlreadySaved_.getIdAccordoServizioParteComune()!=null){
  486.                         itemObj_.getIdAccordoServizioParteComune().setId(itemAlreadySaved_.getIdAccordoServizioParteComune().getId());
  487.                         if(itemObj_.getIdAccordoServizioParteComune().getIdSoggetto()!=null && 
  488.                                 itemAlreadySaved_.getIdAccordoServizioParteComune().getIdSoggetto()!=null){
  489.                             itemObj_.getIdAccordoServizioParteComune().getIdSoggetto().setId(itemAlreadySaved_.getIdAccordoServizioParteComune().getIdSoggetto().getId());
  490.                         }
  491.                     }
  492.                 }
  493.             }
  494.         }
  495.         if(obj.getPortTypeList()!=null){
  496.             List<org.openspcoop2.core.commons.search.PortType> listObj_ = obj.getPortTypeList();
  497.             for(org.openspcoop2.core.commons.search.PortType itemObj_ : listObj_){
  498.                 org.openspcoop2.core.commons.search.PortType itemAlreadySaved_ = null;
  499.                 if(imgSaved.getPortTypeList()!=null){
  500.                     List<org.openspcoop2.core.commons.search.PortType> listImgSaved_ = imgSaved.getPortTypeList();
  501.                     for(org.openspcoop2.core.commons.search.PortType itemImgSaved_ : listImgSaved_){
  502.                         boolean objEqualsToImgSaved_ = false;
  503.                         objEqualsToImgSaved_ = org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getNome(),itemImgSaved_.getNome());
  504.                         if(objEqualsToImgSaved_){
  505.                             itemAlreadySaved_=itemImgSaved_;
  506.                             break;
  507.                         }
  508.                     }
  509.                 }
  510.                 if(itemAlreadySaved_!=null){
  511.                     itemObj_.setId(itemAlreadySaved_.getId());
  512.                     if(itemObj_.getOperationList()!=null){
  513.                         List<org.openspcoop2.core.commons.search.Operation> listObj_portType = itemObj_.getOperationList();
  514.                         for(org.openspcoop2.core.commons.search.Operation itemObj_portType : listObj_portType){
  515.                             org.openspcoop2.core.commons.search.Operation itemAlreadySaved_portType = null;
  516.                             if(itemAlreadySaved_.getOperationList()!=null){
  517.                                 List<org.openspcoop2.core.commons.search.Operation> listImgSaved_portType = itemAlreadySaved_.getOperationList();
  518.                                 for(org.openspcoop2.core.commons.search.Operation itemImgSaved_portType : listImgSaved_portType){
  519.                                     boolean objEqualsToImgSaved_portType = false;
  520.                                     objEqualsToImgSaved_portType = org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_portType.getNome(),itemImgSaved_portType.getNome());
  521.                                     if(objEqualsToImgSaved_portType){
  522.                                         itemAlreadySaved_portType=itemImgSaved_portType;
  523.                                         break;
  524.                                     }
  525.                                 }
  526.                             }
  527.                             if(itemAlreadySaved_portType!=null){
  528.                                 itemObj_portType.setId(itemAlreadySaved_portType.getId());
  529.                                 if(itemObj_portType.getIdPortType()!=null && 
  530.                                         itemAlreadySaved_portType.getIdPortType()!=null){
  531.                                     itemObj_portType.getIdPortType().setId(itemAlreadySaved_portType.getIdPortType().getId());
  532.                                     if(itemObj_portType.getIdPortType().getIdAccordoServizioParteComune()!=null && 
  533.                                             itemAlreadySaved_portType.getIdPortType().getIdAccordoServizioParteComune()!=null){
  534.                                         itemObj_portType.getIdPortType().getIdAccordoServizioParteComune().setId(itemAlreadySaved_portType.getIdPortType().getIdAccordoServizioParteComune().getId());
  535.                                         if(itemObj_portType.getIdPortType().getIdAccordoServizioParteComune().getIdSoggetto()!=null && 
  536.                                                 itemAlreadySaved_portType.getIdPortType().getIdAccordoServizioParteComune().getIdSoggetto()!=null){
  537.                                             itemObj_portType.getIdPortType().getIdAccordoServizioParteComune().getIdSoggetto().setId(itemAlreadySaved_portType.getIdPortType().getIdAccordoServizioParteComune().getIdSoggetto().getId());
  538.                                         }
  539.                                     }
  540.                                 }
  541.                             }
  542.                         }
  543.                     }
  544.                     if(itemObj_.getIdAccordoServizioParteComune()!=null && 
  545.                             itemAlreadySaved_.getIdAccordoServizioParteComune()!=null){
  546.                         itemObj_.getIdAccordoServizioParteComune().setId(itemAlreadySaved_.getIdAccordoServizioParteComune().getId());
  547.                         if(itemObj_.getIdAccordoServizioParteComune().getIdSoggetto()!=null && 
  548.                                 itemAlreadySaved_.getIdAccordoServizioParteComune().getIdSoggetto()!=null){
  549.                             itemObj_.getIdAccordoServizioParteComune().getIdSoggetto().setId(itemAlreadySaved_.getIdAccordoServizioParteComune().getIdSoggetto().getId());
  550.                         }
  551.                     }
  552.                 }
  553.             }
  554.         }
  555.         if(obj.getResourceList()!=null){
  556.             List<org.openspcoop2.core.commons.search.Resource> listObj_ = obj.getResourceList();
  557.             for(org.openspcoop2.core.commons.search.Resource itemObj_ : listObj_){
  558.                 org.openspcoop2.core.commons.search.Resource itemAlreadySaved_ = null;
  559.                 if(imgSaved.getResourceList()!=null){
  560.                     List<org.openspcoop2.core.commons.search.Resource> listImgSaved_ = imgSaved.getResourceList();
  561.                     for(org.openspcoop2.core.commons.search.Resource itemImgSaved_ : listImgSaved_){
  562.                         boolean objEqualsToImgSaved_ = false;
  563.                         objEqualsToImgSaved_ = org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getNome(),itemImgSaved_.getNome());
  564.                         if(objEqualsToImgSaved_){
  565.                             itemAlreadySaved_=itemImgSaved_;
  566.                             break;
  567.                         }
  568.                     }
  569.                 }
  570.                 if(itemAlreadySaved_!=null){
  571.                     itemObj_.setId(itemAlreadySaved_.getId());
  572.                     if(itemObj_.getIdAccordoServizioParteComune()!=null && 
  573.                             itemAlreadySaved_.getIdAccordoServizioParteComune()!=null){
  574.                         itemObj_.getIdAccordoServizioParteComune().setId(itemAlreadySaved_.getIdAccordoServizioParteComune().getId());
  575.                         if(itemObj_.getIdAccordoServizioParteComune().getIdSoggetto()!=null && 
  576.                                 itemAlreadySaved_.getIdAccordoServizioParteComune().getIdSoggetto()!=null){
  577.                             itemObj_.getIdAccordoServizioParteComune().getIdSoggetto().setId(itemAlreadySaved_.getIdAccordoServizioParteComune().getIdSoggetto().getId());
  578.                         }
  579.                     }
  580.                 }
  581.             }
  582.         }
  583.         if(obj.getAccordoServizioParteComuneGruppoList()!=null){
  584.             List<org.openspcoop2.core.commons.search.AccordoServizioParteComuneGruppo> listObj_ = obj.getAccordoServizioParteComuneGruppoList();
  585.             for(org.openspcoop2.core.commons.search.AccordoServizioParteComuneGruppo itemObj_ : listObj_){
  586.                 org.openspcoop2.core.commons.search.AccordoServizioParteComuneGruppo itemAlreadySaved_ = null;
  587.                 if(imgSaved.getAccordoServizioParteComuneGruppoList()!=null){
  588.                     List<org.openspcoop2.core.commons.search.AccordoServizioParteComuneGruppo> listImgSaved_ = imgSaved.getAccordoServizioParteComuneGruppoList();
  589.                     for(org.openspcoop2.core.commons.search.AccordoServizioParteComuneGruppo itemImgSaved_ : listImgSaved_){
  590.                         boolean objEqualsToImgSaved_ = false;
  591.                         objEqualsToImgSaved_ = org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getIdGruppo().getNome(),itemImgSaved_.getIdGruppo().getNome()) &&
  592.                                                  org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getIdAccordoServizioParteComune().getNome(),itemImgSaved_.getIdAccordoServizioParteComune().getNome())  &&
  593.                                                  org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getIdAccordoServizioParteComune().getIdSoggetto().getTipo(),itemImgSaved_.getIdAccordoServizioParteComune().getIdSoggetto().getTipo())  &&
  594.                                                  org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getIdAccordoServizioParteComune().getIdSoggetto().getNome(),itemImgSaved_.getIdAccordoServizioParteComune().getIdSoggetto().getNome())  &&
  595.                                                  org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getIdAccordoServizioParteComune().getVersione(),itemImgSaved_.getIdAccordoServizioParteComune().getVersione());
  596.                         if(objEqualsToImgSaved_){
  597.                             itemAlreadySaved_=itemImgSaved_;
  598.                             break;
  599.                         }
  600.                     }
  601.                 }
  602.                 if(itemAlreadySaved_!=null){
  603.                     itemObj_.setId(itemAlreadySaved_.getId());
  604.                     if(itemObj_.getIdGruppo()!=null && 
  605.                             itemAlreadySaved_.getIdGruppo()!=null){
  606.                         itemObj_.getIdGruppo().setId(itemAlreadySaved_.getIdGruppo().getId());
  607.                     }
  608.                     if(itemObj_.getIdAccordoServizioParteComune()!=null && 
  609.                             itemAlreadySaved_.getIdAccordoServizioParteComune()!=null){
  610.                         itemObj_.getIdAccordoServizioParteComune().setId(itemAlreadySaved_.getIdAccordoServizioParteComune().getId());
  611.                         if(itemObj_.getIdAccordoServizioParteComune().getIdSoggetto()!=null && 
  612.                                 itemAlreadySaved_.getIdAccordoServizioParteComune().getIdSoggetto()!=null){
  613.                             itemObj_.getIdAccordoServizioParteComune().getIdSoggetto().setId(itemAlreadySaved_.getIdAccordoServizioParteComune().getIdSoggetto().getId());
  614.                         }
  615.                     }
  616.                 }
  617.             }
  618.         }
  619.               
  620.     }
  621.     
  622.     @Override
  623.     public AccordoServizioParteComune get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  624.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId), idMappingResolutionBehaviour);
  625.     }
  626.     
  627.     private AccordoServizioParteComune getEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  628.     
  629.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  630.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  631.         
  632.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();
  633.                 
  634.         AccordoServizioParteComune accordoServizioParteComune = new AccordoServizioParteComune();
  635.         

  637.         // Object accordoServizioParteComune
  638.         ISQLQueryObject sqlQueryObjectGet_accordoServizioParteComune = sqlQueryObjectGet.newSQLQueryObject();
  639.         sqlQueryObjectGet_accordoServizioParteComune.setANDLogicOperator(true);
  640.         sqlQueryObjectGet_accordoServizioParteComune.addFromTable(this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model()));
  641.         sqlQueryObjectGet_accordoServizioParteComune.addSelectField("id");
  642.         sqlQueryObjectGet_accordoServizioParteComune.addSelectField(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().NOME,true));
  643.         sqlQueryObjectGet_accordoServizioParteComune.addSelectField(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().VERSIONE,true));
  644.         sqlQueryObjectGet_accordoServizioParteComune.addSelectField(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().SERVICE_BINDING,true));
  645.         sqlQueryObjectGet_accordoServizioParteComune.addSelectField(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().CANALE,true));
  646.         sqlQueryObjectGet_accordoServizioParteComune.addWhereCondition("id=?");

  648.         // Get accordoServizioParteComune
  649.         accordoServizioParteComune = (AccordoServizioParteComune) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_accordoServizioParteComune.createSQLQuery(), jdbcProperties.isShowSql(), AccordoServizioParteComune.model(), this.getAccordoServizioParteComuneFetch(),
  650.             new JDBCObject(tableId,Long.class));

  652.         
  653.         // Recupero idSoggetto
  654.         ISQLQueryObject sqlQueryObjectGet_accordoServizioParteComune_soggetto = sqlQueryObjectGet.newSQLQueryObject();
  655.         sqlQueryObjectGet_accordoServizioParteComune_soggetto.addFromTable(this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model()));
  656.         sqlQueryObjectGet_accordoServizioParteComune_soggetto.addSelectField("id_referente");
  657.         sqlQueryObjectGet_accordoServizioParteComune_soggetto.setANDLogicOperator(true);
  658.         sqlQueryObjectGet_accordoServizioParteComune_soggetto.addWhereCondition("id=?");
  659.         
  660.         // Recupero _accordoServizioParteComune_soggetto
  661.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_accordoServizioParteComune_soggetto = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  662.                 new JDBCObject(accordoServizioParteComune.getId(), Long.class)
  663.         };
  664.         Long id_accordoServizioParteComune_soggetto = 
  665.             (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_accordoServizioParteComune_soggetto.createSQLQuery(), jdbcProperties.isShowSql(),
  666.             Long.class, searchParams_accordoServizioParteComune_soggetto);
  667.         
  668.         if(id_accordoServizioParteComune_soggetto!=null && id_accordoServizioParteComune_soggetto>0){
  669.             Soggetto soggetto = ((IDBSoggettoServiceSearch)this.getServiceManager(connection, jdbcProperties, log).getSoggettoServiceSearch()).get(id_accordoServizioParteComune_soggetto);
  670.             IdSoggetto idReferente = new IdSoggetto();
  671.             idReferente.setTipo(soggetto.getTipoSoggetto());
  672.             idReferente.setNome(soggetto.getNomeSoggetto());
  673.             accordoServizioParteComune.setIdReferente(idReferente);
  674.         }


  677.         // Object accordoServizioParteComune_accordoServizioParteComuneAzione
  678.         ISQLQueryObject sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneAzione = sqlQueryObjectGet.newSQLQueryObject();
  679.         sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneAzione.setANDLogicOperator(true);
  680.         sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneAzione.addFromTable(this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_AZIONE));
  681.         sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneAzione.addSelectField("id");
  682.         sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneAzione.addSelectField(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_AZIONE.NOME,true));
  683.         sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneAzione.addWhereCondition("id_accordo=?");

  685.         // Get accordoServizioParteComune_accordoServizioParteComuneAzione
  686.         java.util.List<Object> accordoServizioParteComune_accordoServizioParteComuneAzione_list = jdbcUtilities.executeQuery(sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneAzione.createSQLQuery(), jdbcProperties.isShowSql(), AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_AZIONE, this.getAccordoServizioParteComuneFetch(),
  687.             new JDBCObject(accordoServizioParteComune.getId(),Long.class));

  689.         if(accordoServizioParteComune_accordoServizioParteComuneAzione_list != null) {
  690.             for (Object accordoServizioParteComune_accordoServizioParteComuneAzione_object: accordoServizioParteComune_accordoServizioParteComuneAzione_list) {
  691.                 AccordoServizioParteComuneAzione accordoServizioParteComune_accordoServizioParteComuneAzione = (AccordoServizioParteComuneAzione) accordoServizioParteComune_accordoServizioParteComuneAzione_object;


  694.                 accordoServizioParteComune.addAccordoServizioParteComuneAzione(accordoServizioParteComune_accordoServizioParteComuneAzione);
  695.             }
  696.         }

  698.         // Object accordoServizioParteComune_portType
  699.         ISQLQueryObject sqlQueryObjectGet_accordoServizioParteComune_portType = sqlQueryObjectGet.newSQLQueryObject();
  700.         sqlQueryObjectGet_accordoServizioParteComune_portType.setANDLogicOperator(true);
  701.         sqlQueryObjectGet_accordoServizioParteComune_portType.addFromTable(this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().PORT_TYPE));
  702.         sqlQueryObjectGet_accordoServizioParteComune_portType.addSelectField("id");
  703.         sqlQueryObjectGet_accordoServizioParteComune_portType.addSelectField(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().PORT_TYPE.NOME,true));
  704.         sqlQueryObjectGet_accordoServizioParteComune_portType.addWhereCondition("id_accordo=?");

  706.         // Get accordoServizioParteComune_portType
  707.         java.util.List<Object> accordoServizioParteComune_portType_list = jdbcUtilities.executeQuery(sqlQueryObjectGet_accordoServizioParteComune_portType.createSQLQuery(), jdbcProperties.isShowSql(), AccordoServizioParteComune.model().PORT_TYPE, this.getAccordoServizioParteComuneFetch(),
  708.             new JDBCObject(accordoServizioParteComune.getId(),Long.class));

  710.         if(accordoServizioParteComune_portType_list != null) {
  711.             for (Object accordoServizioParteComune_portType_object: accordoServizioParteComune_portType_list) {
  712.                 PortType accordoServizioParteComune_portType = (PortType) accordoServizioParteComune_portType_object;



  716.                 // Object accordoServizioParteComune_portType_operation
  717.                 ISQLQueryObject sqlQueryObjectGet_accordoServizioParteComune_portType_operation = sqlQueryObjectGet.newSQLQueryObject();
  718.                 sqlQueryObjectGet_accordoServizioParteComune_portType_operation.setANDLogicOperator(true);
  719.                 sqlQueryObjectGet_accordoServizioParteComune_portType_operation.addFromTable(this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().PORT_TYPE.OPERATION));
  720.                 sqlQueryObjectGet_accordoServizioParteComune_portType_operation.addSelectField("id");
  721.                 sqlQueryObjectGet_accordoServizioParteComune_portType_operation.addSelectField(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().PORT_TYPE.OPERATION.NOME,true));
  722.                 sqlQueryObjectGet_accordoServizioParteComune_portType_operation.addWhereCondition("id_port_type=?");

  724.                 // Get accordoServizioParteComune_portType_operation
  725.                 java.util.List<Object> accordoServizioParteComune_portType_operation_list = jdbcUtilities.executeQuery(sqlQueryObjectGet_accordoServizioParteComune_portType_operation.createSQLQuery(), jdbcProperties.isShowSql(), AccordoServizioParteComune.model().PORT_TYPE.OPERATION, this.getAccordoServizioParteComuneFetch(),
  726.                     new JDBCObject(accordoServizioParteComune_portType.getId(),Long.class));

  728.                 if(accordoServizioParteComune_portType_operation_list != null) {
  729.                     for (Object accordoServizioParteComune_portType_operation_object: accordoServizioParteComune_portType_operation_list) {
  730.                         Operation accordoServizioParteComune_portType_operation = (Operation) accordoServizioParteComune_portType_operation_object;


  733.                         accordoServizioParteComune_portType.addOperation(accordoServizioParteComune_portType_operation);
  734.                     }
  735.                 }
  736.                 accordoServizioParteComune.addPortType(accordoServizioParteComune_portType);
  737.             }
  738.         }

  740.         // Object accordoServizioParteComune_resource
  741.         ISQLQueryObject sqlQueryObjectGet_accordoServizioParteComune_resource = sqlQueryObjectGet.newSQLQueryObject();
  742.         sqlQueryObjectGet_accordoServizioParteComune_resource.setANDLogicOperator(true);
  743.         sqlQueryObjectGet_accordoServizioParteComune_resource.addFromTable(this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().RESOURCE));
  744.         sqlQueryObjectGet_accordoServizioParteComune_resource.addSelectField("id");
  745.         sqlQueryObjectGet_accordoServizioParteComune_resource.addSelectField(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().RESOURCE.NOME,true));
  746.         sqlQueryObjectGet_accordoServizioParteComune_resource.addSelectField(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().RESOURCE.HTTP_METHOD,true));
  747.         sqlQueryObjectGet_accordoServizioParteComune_resource.addSelectField(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().RESOURCE.PATH,true));
  748.         sqlQueryObjectGet_accordoServizioParteComune_resource.addWhereCondition("id_accordo=?");

  750.         // Get accordoServizioParteComune_resource
  751.         java.util.List<Object> accordoServizioParteComune_resource_list = jdbcUtilities.executeQuery(sqlQueryObjectGet_accordoServizioParteComune_resource.createSQLQuery(), jdbcProperties.isShowSql(), AccordoServizioParteComune.model().RESOURCE, this.getAccordoServizioParteComuneFetch(),
  752.             new JDBCObject(accordoServizioParteComune.getId(),Long.class));

  754.         if(accordoServizioParteComune_resource_list != null) {
  755.             for (Object accordoServizioParteComune_resource_object: accordoServizioParteComune_resource_list) {
  756.                 Resource accordoServizioParteComune_resource = (Resource) accordoServizioParteComune_resource_object;


  759.                 accordoServizioParteComune.addResource(accordoServizioParteComune_resource);
  760.             }
  761.         }

  763.         // Object accordoServizioParteComune_accordoServizioParteComuneGruppo
  764.         ISQLQueryObject sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo = sqlQueryObjectGet.newSQLQueryObject();
  765.         sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo.setANDLogicOperator(true);
  766.         sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo.addFromTable(this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO));
  767.         sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo.addSelectField("id");
  768.         sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo.addWhereCondition("id_accordo=?");

  770.         // Get accordoServizioParteComune_accordoServizioParteComuneGruppo
  771.         java.util.List<Object> accordoServizioParteComune_accordoServizioParteComuneGruppo_list = (java.util.List<Object>) jdbcUtilities.executeQuery(sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo.createSQLQuery(), jdbcProperties.isShowSql(), AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO, this.getAccordoServizioParteComuneFetch(),
  772.             new JDBCObject(accordoServizioParteComune.getId(),Long.class));

  774.         if(accordoServizioParteComune_accordoServizioParteComuneGruppo_list != null) {
  775.             for (Object accordoServizioParteComune_accordoServizioParteComuneGruppo_object: accordoServizioParteComune_accordoServizioParteComuneGruppo_list) {
  776.                 AccordoServizioParteComuneGruppo accordoServizioParteComune_accordoServizioParteComuneGruppo = (AccordoServizioParteComuneGruppo) accordoServizioParteComune_accordoServizioParteComuneGruppo_object;


  779.                 if(idMappingResolutionBehaviour==null ||
  780.                     (org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour) || org.openspcoop2.generic_project.beans.IDMappingBehaviour.USE_TABLE_ID.equals(idMappingResolutionBehaviour))
  781.                 ){
  782.                     // Object _accordoServizioParteComune_accordoServizioParteComuneGruppo_gruppo (recupero id)
  783.                     ISQLQueryObject sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo_gruppo_readFkId = sqlQueryObjectGet.newSQLQueryObject();
  784.                     sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo_gruppo_readFkId.addFromTable(this.getAccordoServizioParteComuneFieldConverter().toTable(org.openspcoop2.core.commons.search.AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO));
  785.                     sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo_gruppo_readFkId.addSelectField("id_gruppo");
  786.                     sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo_gruppo_readFkId.addWhereCondition("id=?");
  787.                     sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo_gruppo_readFkId.setANDLogicOperator(true);
  788.                     Long idFK_accordoServizioParteComune_accordoServizioParteComuneGruppo_gruppo = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo_gruppo_readFkId.createSQLQuery(), jdbcProperties.isShowSql(),Long.class,
  789.                             new JDBCObject(accordoServizioParteComune_accordoServizioParteComuneGruppo.getId(),Long.class));
  790.                     
  791.                     org.openspcoop2.core.commons.search.IdGruppo id_accordoServizioParteComune_accordoServizioParteComuneGruppo_gruppo = null;
  792.                     if(idMappingResolutionBehaviour==null || org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour)){
  793.                         id_accordoServizioParteComune_accordoServizioParteComuneGruppo_gruppo = ((JDBCGruppoServiceSearch)(this.getServiceManager(connection, jdbcProperties, log).getGruppoServiceSearch())).findId(idFK_accordoServizioParteComune_accordoServizioParteComuneGruppo_gruppo, false);
  794.                     }else{
  795.                         id_accordoServizioParteComune_accordoServizioParteComuneGruppo_gruppo = new org.openspcoop2.core.commons.search.IdGruppo();
  796.                     }
  797.                     id_accordoServizioParteComune_accordoServizioParteComuneGruppo_gruppo.setId(idFK_accordoServizioParteComune_accordoServizioParteComuneGruppo_gruppo);
  798.                     accordoServizioParteComune_accordoServizioParteComuneGruppo.setIdGruppo(id_accordoServizioParteComune_accordoServizioParteComuneGruppo_gruppo);
  799.                 }

  801.                 /*
  802.                 if(idMappingResolutionBehaviour==null ||
  803.                     (org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour) || org.openspcoop2.generic_project.beans.IDMappingBehaviour.USE_TABLE_ID.equals(idMappingResolutionBehaviour))
  804.                 ){
  805.                     // Object _accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune (recupero id)
  806.                     ISQLQueryObject sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune_readFkId = sqlQueryObjectGet.newSQLQueryObject();
  807.                     sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune_readFkId.addFromTable(this.getAccordoServizioParteComuneFieldConverter().toTable(org.openspcoop2.core.commons.search.AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO));
  808.                     sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune_readFkId.addSelectField("id_accordo");
  809.                     sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune_readFkId.addWhereCondition("id=?");
  810.                     sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune_readFkId.setANDLogicOperator(true);
  811.                     Long idFK_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune_readFkId.createSQLQuery(), jdbcProperties.isShowSql(),Long.class,
  812.                             new JDBCObject(accordoServizioParteComune_accordoServizioParteComuneGruppo.getId(),Long.class));
  813.                     
  814.                     org.openspcoop2.core.commons.search.IdAccordoServizioParteComune id_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune = null;
  815.                     if(idMappingResolutionBehaviour==null || org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour)){
  816.                         id_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune = ((JDBCAccordoServizioParteComuneServiceSearch)(this.getServiceManager(connection, jdbcProperties, log).getAccordoServizioParteComuneServiceSearch())).findId(idFK_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune, false);
  817.                     }else{
  818.                         id_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune = new org.openspcoop2.core.commons.search.IdAccordoServizioParteComune();
  819.                     }
  820.                     id_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune.setId(idFK_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune);
  821.                     accordoServizioParteComune_accordoServizioParteComuneGruppo.setIdAccordoServizioParteComune(id_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune);
  822.                 }*/
  823.                 //  me stesso
  824.                 org.openspcoop2.core.commons.search.IdAccordoServizioParteComune id_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune = new org.openspcoop2.core.commons.search.IdAccordoServizioParteComune();
  825.                 id_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune.setId(accordoServizioParteComune.getId());
  826.                 id_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune.setNome(accordoServizioParteComune.getNome());
  827.                 id_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune.setIdSoggetto(accordoServizioParteComune.getIdReferente());
  828.                 id_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune.setVersione(accordoServizioParteComune.getVersione());
  829.                 accordoServizioParteComune_accordoServizioParteComuneGruppo.setIdAccordoServizioParteComune(id_accordoServizioParteComune_accordoServizioParteComuneGruppo_accordoServizioParteComune);
  830.                     

  832.                 accordoServizioParteComune.addAccordoServizioParteComuneGruppo(accordoServizioParteComune_accordoServizioParteComuneGruppo);
  833.             }
  834.         }              
  835.         
  836.         return accordoServizioParteComune;  
  837.     
  838.     } 
  839.     
  840.     @Override
  841.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  842.         return this._exists(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  843.     }
  844.     
  845.     private boolean _exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  846.     
  847.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  848.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  849.                 
  850.         boolean existsAccordoServizioParteComune = false;

  852.         sqlQueryObject = sqlQueryObject.newSQLQueryObject();
  853.         sqlQueryObject.setANDLogicOperator(true);

  855.         sqlQueryObject.addFromTable(this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model()));
  856.         sqlQueryObject.addSelectField(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().NOME,true));
  857.         sqlQueryObject.addWhereCondition("id=?");


  860.         // Exists accordoServizioParteComune
  861.         existsAccordoServizioParteComune = jdbcUtilities.exists(sqlQueryObject.createSQLQuery(), jdbcProperties.isShowSql(),
  862.             new JDBCObject(tableId,Long.class));

  864.         
  865.         return existsAccordoServizioParteComune;
  866.     
  867.     }
  868.     
  869.     private void joinEngine(IExpression expression, ISQLQueryObject sqlQueryObject) throws NotImplementedException, ServiceException, Exception{
  870.     
  871.         boolean addReferente = false;
  872.         if(expression.inUseModel(AccordoServizioParteComune.model().ID_REFERENTE,false)){
  873.             String tableName1 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model());
  874.             String tableName2 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().ID_REFERENTE);
  875.             sqlQueryObject.addWhereCondition(tableName1+".id_referente="+tableName2+".id");
  876.             addReferente = true;
  877.         }
  878.         if(expression.inUseModel(AccordoServizioParteComune.model().PORT_TYPE.OPERATION.ID_PORT_TYPE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO,false) &&
  879.                 !addReferente){
  880.             String tableName1 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model());
  881.             String tableName2 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().PORT_TYPE.OPERATION.ID_PORT_TYPE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO);
  882.             sqlQueryObject.addWhereCondition(tableName1+".id_referente="+tableName2+".id");
  883.             addReferente = true;
  884.         }
  885.         if(expression.inUseModel(AccordoServizioParteComune.model().PORT_TYPE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO,false) &&
  886.                 !addReferente){
  887.             String tableName1 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model());
  888.             String tableName2 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().PORT_TYPE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO);
  889.             sqlQueryObject.addWhereCondition(tableName1+".id_referente="+tableName2+".id");
  890.             addReferente = true;
  891.         }
  892.         if(expression.inUseModel(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_AZIONE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO,false) &&
  893.                 !addReferente){
  894.             String tableName1 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model());
  895.             String tableName2 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_AZIONE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO);
  896.             sqlQueryObject.addWhereCondition(tableName1+".id_referente="+tableName2+".id");
  897.             addReferente = true;
  898.         }
  899.         if(expression.inUseModel(AccordoServizioParteComune.model().RESOURCE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO,false) &&
  900.                 !addReferente){
  901.             String tableName1 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model());
  902.             String tableName2 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().RESOURCE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO);
  903.             sqlQueryObject.addWhereCondition(tableName1+".id_referente="+tableName2+".id");
  904.             addReferente = true;
  905.         }
  906.         if(expression.inUseModel(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO,false) &&
  907.                 !addReferente){
  908.             String tableName1 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model());
  909.             String tableName2 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO);
  910.             sqlQueryObject.addWhereCondition(tableName1+".id_referente="+tableName2+".id");
  911.             addReferente = true;
  912.         }
  913.         
  914.         
  915.         if(expression.inUseModel(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_AZIONE,false)){
  916.             String tableName1 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_AZIONE);
  917.             String tableName2 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model());
  918.             sqlQueryObject.addWhereCondition(tableName1+".id_accordo="+tableName2+".id");
  919.         }
  920.         
  921.         if(expression.inUseModel(AccordoServizioParteComune.model().PORT_TYPE,false)){
  922.             String tableName1 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().PORT_TYPE);
  923.             String tableName2 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model());
  924.             sqlQueryObject.addWhereCondition(tableName1+".id_accordo="+tableName2+".id");
  925.         }
  926.         if(expression.inUseModel(AccordoServizioParteComune.model().PORT_TYPE.OPERATION.ID_PORT_TYPE,false) &&
  927.                 !expression.inUseModel(AccordoServizioParteComune.model().PORT_TYPE,false)){
  928.             String tableName1 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().PORT_TYPE.OPERATION.ID_PORT_TYPE);
  929.             String tableName2 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model());
  930.             sqlQueryObject.addWhereCondition(tableName1+".id_accordo="+tableName2+".id");
  931.         }
  932.         
  933.         if(expression.inUseModel(AccordoServizioParteComune.model().PORT_TYPE.OPERATION,false)){
  934.             String tableName1 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().PORT_TYPE.OPERATION);
  935.             String tableName2 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().PORT_TYPE);
  936.             sqlQueryObject.addWhereCondition(tableName1+".id_port_type="+tableName2+".id");
  937.         }
  938.         
  939.         if(expression.inUseModel(AccordoServizioParteComune.model().RESOURCE,false)){
  940.             String tableName1 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().RESOURCE);
  941.             String tableName2 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model());
  942.             sqlQueryObject.addWhereCondition(tableName1+".id_accordo="+tableName2+".id");
  943.         }
  944.         
  945.         boolean addJoinAccordiToAccordiGruppi = false;
  946.         if(expression.inUseModel(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO,false)){
  947.             String tableName1 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO);
  948.             String tableName2 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model());
  949.             sqlQueryObject.addWhereCondition(tableName1+".id_accordo="+tableName2+".id");
  950.             addJoinAccordiToAccordiGruppi = true;
  951.         }
  952.         if(expression.inUseModel(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO.ID_GRUPPO,false)){
  953.             String tableName1 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO.ID_GRUPPO);
  954.             String tableName2 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO);
  955.             sqlQueryObject.addWhereCondition(tableName1+".id="+tableName2+".id_gruppo");
  956.             if(!addJoinAccordiToAccordiGruppi) {
  957.                 tableName1 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO);
  958.                 tableName2 = this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model());
  959.                 sqlQueryObject.addWhereCondition(tableName1+".id_accordo="+tableName2+".id");
  960.             }
  961.         }

  963.         
  964.         // 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
  965.         if(expression.inUseModel(AccordoServizioParteComune.model().PORT_TYPE.OPERATION,false)){
  966.             if(expression.inUseModel(AccordoServizioParteComune.model().PORT_TYPE,false)==false){
  967.                 sqlQueryObject.addFromTable(this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().PORT_TYPE));
  968.             }
  969.         }
  970.         
  971.         if(expression.inUseModel(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO.ID_GRUPPO,false)){
  972.             if(expression.inUseModel(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO,false)==false){
  973.                 sqlQueryObject.addFromTable(this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO));
  974.             }
  975.         }
  976.         
  977.     }
  978.     
  979.     protected java.util.List<Object> getRootTablePrimaryKeyValuesEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAccordoServizioParteComune id) throws NotFoundException, ServiceException, NotImplementedException, Exception{
  980.         // Identificativi
  981.         java.util.List<Object> rootTableIdValues = new java.util.ArrayList<>();
  982.         Long longId = this.findIdAccordoServizioParteComune(jdbcProperties, log, connection, sqlQueryObject.newSQLQueryObject(), id, true);
  983.         rootTableIdValues.add(longId);
  984.         return rootTableIdValues;
  985.     }
  986.     
  987.     protected Map<String, List<IField>> getMapTableToPKColumnEngine() throws NotImplementedException, Exception{
  988.     
  989.         AccordoServizioParteComuneFieldConverter converter = this.getAccordoServizioParteComuneFieldConverter();
  990.         Map<String, List<IField>> mapTableToPKColumn = new java.util.HashMap<>();
  991.         UtilsTemplate<IField> utilities = new UtilsTemplate<>();

  993.         // AccordoServizioParteComune.model()
  994.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model()),
  995.             utilities.newList(
  996.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model()))
  997.             ));

  999.         // AccordoServizioParteComune.model().ID_REFERENTE
  1000.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model().ID_REFERENTE),
  1001.             utilities.newList(
  1002.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model().ID_REFERENTE))
  1003.             ));

  1005.         // AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_AZIONE
  1006.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_AZIONE),
  1007.             utilities.newList(
  1008.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_AZIONE))
  1009.             ));

  1011.         // AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_AZIONE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE
  1012.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_AZIONE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE),
  1013.             utilities.newList(
  1014.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_AZIONE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE))
  1015.             ));

  1017.         // AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_AZIONE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO
  1018.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_AZIONE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO),
  1019.             utilities.newList(
  1020.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_AZIONE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO))
  1021.             ));

  1023.         // AccordoServizioParteComune.model().PORT_TYPE
  1024.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model().PORT_TYPE),
  1025.             utilities.newList(
  1026.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model().PORT_TYPE))
  1027.             ));

  1029.         // AccordoServizioParteComune.model().PORT_TYPE.OPERATION
  1030.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model().PORT_TYPE.OPERATION),
  1031.             utilities.newList(
  1032.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model().PORT_TYPE.OPERATION))
  1033.             ));

  1035.         // AccordoServizioParteComune.model().PORT_TYPE.OPERATION.ID_PORT_TYPE
  1036.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model().PORT_TYPE.OPERATION.ID_PORT_TYPE),
  1037.             utilities.newList(
  1038.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model().PORT_TYPE.OPERATION.ID_PORT_TYPE))
  1039.             ));

  1041.         // AccordoServizioParteComune.model().PORT_TYPE.OPERATION.ID_PORT_TYPE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE
  1042.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model().PORT_TYPE.OPERATION.ID_PORT_TYPE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE),
  1043.             utilities.newList(
  1044.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model().PORT_TYPE.OPERATION.ID_PORT_TYPE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE))
  1045.             ));

  1047.         // AccordoServizioParteComune.model().PORT_TYPE.OPERATION.ID_PORT_TYPE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO
  1048.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model().PORT_TYPE.OPERATION.ID_PORT_TYPE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO),
  1049.             utilities.newList(
  1050.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model().PORT_TYPE.OPERATION.ID_PORT_TYPE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO))
  1051.             ));

  1053.         // AccordoServizioParteComune.model().PORT_TYPE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE
  1054.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model().PORT_TYPE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE),
  1055.             utilities.newList(
  1056.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model().PORT_TYPE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE))
  1057.             ));

  1059.         // AccordoServizioParteComune.model().PORT_TYPE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO
  1060.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model().PORT_TYPE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO),
  1061.             utilities.newList(
  1062.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model().PORT_TYPE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO))
  1063.             ));

  1065.         // AccordoServizioParteComune.model().RESOURCE
  1066.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model().RESOURCE),
  1067.             utilities.newList(
  1068.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model().RESOURCE))
  1069.             ));

  1071.         // AccordoServizioParteComune.model().RESOURCE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE
  1072.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model().RESOURCE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE),
  1073.             utilities.newList(
  1074.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model().RESOURCE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE))
  1075.             ));

  1077.         // AccordoServizioParteComune.model().RESOURCE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO
  1078.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model().RESOURCE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO),
  1079.             utilities.newList(
  1080.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model().RESOURCE.ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO))
  1081.             ));

  1083.         // AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO
  1084.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO),
  1085.             utilities.newList(
  1086.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO))
  1087.             ));

  1089.         // AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO.ID_GRUPPO
  1090.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO.ID_GRUPPO),
  1091.             utilities.newList(
  1092.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComune.model().ACCORDO_SERVIZIO_PARTE_COMUNE_GRUPPO.ID_GRUPPO))
  1093.             ));

  1095.         
  1096.         return mapTableToPKColumn;      
  1097.     }
  1098.     
  1099.     @Override
  1100.     public List<Long> findAllTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression paginatedExpression) throws ServiceException, NotImplementedException, Exception {
  1101.         
  1102.         List<Long> list = new ArrayList<Long>();

  1104.         sqlQueryObject.setSelectDistinct(true);
  1105.         sqlQueryObject.setANDLogicOperator(true);
  1106.         sqlQueryObject.addSelectField(this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model())+".id");
  1107.         Class<?> objectIdClass = Long.class;
  1108.         
  1109.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFindAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  1110.                                                 this.getAccordoServizioParteComuneFieldConverter(), AccordoServizioParteComune.model());
  1111.         
  1112.         joinEngine(paginatedExpression,sqlQueryObject);
  1113.         
  1114.         List<Object> listObjects = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.findAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  1115.                                                                             this.getAccordoServizioParteComuneFieldConverter(), AccordoServizioParteComune.model(), objectIdClass, listaQuery);
  1116.         for(Object object: listObjects) {
  1117.             list.add((Long)object);
  1118.         }

  1120.         return list;
  1121.         
  1122.     }
  1123.     
  1124.     @Override
  1125.     public long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException, Exception {
  1126.     
  1127.         sqlQueryObject.setSelectDistinct(true);
  1128.         sqlQueryObject.setANDLogicOperator(true);
  1129.         sqlQueryObject.addSelectField(this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model())+".id");
  1130.         Class<?> objectIdClass = Long.class;
  1131.         
  1132.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFind(jdbcProperties, log, connection, sqlQueryObject, expression,
  1133.                                                 this.getAccordoServizioParteComuneFieldConverter(), AccordoServizioParteComune.model());
  1134.         
  1135.         joinEngine(expression,sqlQueryObject);

  1137.         Object res = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.find(jdbcProperties, log, connection, sqlQueryObject, expression,
  1138.                                                         this.getAccordoServizioParteComuneFieldConverter(), AccordoServizioParteComune.model(), objectIdClass, listaQuery);
  1139.         if(res!=null && (((Long) res).longValue()>0) ){
  1140.             return ((Long) res).longValue();
  1141.         }
  1142.         else{
  1143.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  1144.         }
  1145.         
  1146.     }

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

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

  1155.         InUse inUse = new InUse();
  1156.         inUse.setInUse(false);
  1157.         
  1158.         /* 
  1159.          * TODO: implement code that checks whether the object identified by the id parameter is used by other objects
  1160.         */
  1161.         
  1162.         // Delete this line when you have implemented the method
  1163.         int throwNotImplemented = 1;
  1164.         if(throwNotImplemented==1){
  1165.                 throw new NotImplementedException("NotImplemented");
  1166.         }
  1167.         // Delete this line when you have implemented the method

  1169.         return inUse;

  1171.     }
  1172.     
  1173.     @Override
  1174.     public IdAccordoServizioParteComune findId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, boolean throwNotFound)
  1175.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  1176.         
  1177.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  1178.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  1180.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();

  1182.         // Object _accordoServizioParteComune
  1183.         sqlQueryObjectGet.addFromTable(this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model()));
  1184.         sqlQueryObjectGet.addSelectField(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().NOME,true));
  1185.         sqlQueryObjectGet.addSelectField(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().VERSIONE,true));
  1186.         sqlQueryObjectGet.addSelectField("id_referente");
  1187.         sqlQueryObjectGet.addSelectField(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().SERVICE_BINDING,true));
  1188.         sqlQueryObjectGet.setANDLogicOperator(true);
  1189.         sqlQueryObjectGet.addWhereCondition("id=?");

  1191.         // Recupero _accordoServizioParteComune
  1192.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_accordoServizioParteComune = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  1193.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(tableId,Long.class)
  1194.         };
  1195.         List<Class<?>> listaFieldIdReturnType_accordoServizioParteComune = new ArrayList<Class<?>>();
  1196.         listaFieldIdReturnType_accordoServizioParteComune.add(String.class);
  1197.         listaFieldIdReturnType_accordoServizioParteComune.add(Integer.class);
  1198.         listaFieldIdReturnType_accordoServizioParteComune.add(Long.class);
  1199.         listaFieldIdReturnType_accordoServizioParteComune.add(String.class);
  1200.         org.openspcoop2.core.commons.search.IdAccordoServizioParteComune id_accordoServizioParteComune = null;
  1201.         List<Object> listaFieldId_accordoServizioParteComune = jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  1202.                 listaFieldIdReturnType_accordoServizioParteComune, searchParams_accordoServizioParteComune);
  1203.         if(listaFieldId_accordoServizioParteComune==null || listaFieldId_accordoServizioParteComune.size()<=0){
  1204.             if(throwNotFound){
  1205.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  1206.             }
  1207.         }
  1208.         else{
  1209.             // set _accordoServizioParteComune
  1210.             id_accordoServizioParteComune = new org.openspcoop2.core.commons.search.IdAccordoServizioParteComune();
  1211.             id_accordoServizioParteComune.setNome((String)listaFieldId_accordoServizioParteComune.get(0));
  1212.             id_accordoServizioParteComune.setVersione((Integer)listaFieldId_accordoServizioParteComune.get(1));
  1213.             Long idSoggettoFK = (Long) listaFieldId_accordoServizioParteComune.get(2);
  1214.             id_accordoServizioParteComune.setServiceBinding((String)listaFieldId_accordoServizioParteComune.get(3));
  1215.             id_accordoServizioParteComune.
  1216.                 setIdSoggetto(((IDBSoggettoServiceSearch)this.getServiceManager(connection, jdbcProperties, log).
  1217.                         getSoggettoServiceSearch()).findId(idSoggettoFK, true));
  1218.         }
  1219.         
  1220.         return id_accordoServizioParteComune;
  1221.         
  1222.     }

  1224.     @Override
  1225.     public Long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAccordoServizioParteComune id, boolean throwNotFound)
  1226.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  1227.     
  1228.         return this.findIdAccordoServizioParteComune(jdbcProperties,log,connection,sqlQueryObject,id,throwNotFound);
  1229.             
  1230.     }
  1231.     
  1232.     @Override
  1233.     public List<List<Object>> nativeQuery(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  1234.                                             String sql,List<Class<?>> returnClassTypes,Object ... param) throws ServiceException,NotFoundException,NotImplementedException,Exception{
  1235.         
  1236.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeQuery(jdbcProperties, log, connection, sqlQueryObject,
  1237.                                                                                             sql,returnClassTypes,param);
  1238.                                                         
  1239.     }
  1240.     
  1241.     protected Long findIdAccordoServizioParteComune(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAccordoServizioParteComune id, boolean throwNotFound) throws NotFoundException, ServiceException, NotImplementedException, Exception {

  1243.         if(jdbcProperties==null) {
  1244.             throw new ServiceException("Param jdbcProperties is null");
  1245.         }
  1246.         if(sqlQueryObject==null) {
  1247.             throw new ServiceException("Param sqlQueryObject is null");
  1248.         }
  1249.         if(id==null) {
  1250.             throw new ServiceException("Param id is null");
  1251.         }
  1252.         
  1253.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  1254.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  1256.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();

  1258.         // found idSoggetto
  1259. //      if(id.getIdSoggetto()==null){
  1260. //          throw new ServiceException("Id soggetto non fornito");
  1261. //      }
  1262.         Soggetto soggetto = null;
  1263.         
  1264.         // Object _accordoServizioParteComune
  1265.         sqlQueryObjectGet.addFromTable(this.getAccordoServizioParteComuneFieldConverter().toTable(AccordoServizioParteComune.model()));
  1266.         sqlQueryObjectGet.addSelectField("id");
  1267.         sqlQueryObjectGet.setANDLogicOperator(true);
  1268.         sqlQueryObjectGet.setSelectDistinct(true);
  1269.         sqlQueryObjectGet.addWhereCondition(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().NOME,true)+"=?");
  1270.         if(id.getVersione()!=null)
  1271.             sqlQueryObjectGet.addWhereCondition(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().VERSIONE,true)+"=?");
  1272.         else
  1273.             sqlQueryObjectGet.addWhereCondition(this.getAccordoServizioParteComuneFieldConverter().toColumn(AccordoServizioParteComune.model().VERSIONE,true)+" is null");
  1274.         if(id.getIdSoggetto()==null){
  1275.             sqlQueryObjectGet.addWhereCondition("( (id_referente is null) OR (id_referente<=0) )");
  1276.         }else{
  1277.             sqlQueryObjectGet.addWhereCondition("id_referente=?");
  1278.             soggetto = this.getServiceManager(connection, jdbcProperties, log).getSoggettoServiceSearch().get(id.getIdSoggetto());
  1279.         }
  1280.         

  1282.         // Recupero _accordoServizioParteComune
  1283.         List<org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject> listJDBCObject = new ArrayList<org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject>();
  1284.         listJDBCObject.add(new JDBCObject(id.getNome(), String.class));
  1285.         if(id.getVersione()!=null){
  1286.             listJDBCObject.add(new JDBCObject(id.getVersione(), Integer.class));
  1287.         }
  1288.         if(soggetto!=null){
  1289.             listJDBCObject.add(new JDBCObject(soggetto.getId(), Long.class));
  1290.         }
  1291.         Long id_accordoServizioParteComune = null;
  1292.         try{
  1293.             id_accordoServizioParteComune = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  1294.                         Long.class, listJDBCObject.toArray(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [1]));
  1295.         }catch(NotFoundException notFound){
  1296.             if(throwNotFound){
  1297.                 throw new NotFoundException(notFound);
  1298.             }
  1299.         }
  1300.         if(id_accordoServizioParteComune==null || id_accordoServizioParteComune<=0){
  1301.             if(throwNotFound){
  1302.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  1303.             }
  1304.         }
  1305.         
  1306.         return id_accordoServizioParteComune;
  1307.     }
  1308. }
Created with JaCoCo 0.8.8.202204050719