JDBCFruitoreServiceSearchImpl.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.sql.Connection;
  23. import java.util.ArrayList;
  24. import java.util.List;
  25. import java.util.Map;

  27. import org.openspcoop2.core.commons.search.Fruitore;
  28. import org.openspcoop2.core.commons.search.IdAccordoServizioParteSpecifica;
  29. import org.openspcoop2.core.commons.search.IdFruitore;
  30. import org.openspcoop2.core.commons.search.IdSoggetto;
  31. import org.openspcoop2.core.commons.search.dao.IDBAccordoServizioParteSpecificaServiceSearch;
  32. import org.openspcoop2.core.commons.search.dao.IDBSoggettoServiceSearch;
  33. import org.openspcoop2.core.commons.search.dao.jdbc.converter.FruitoreFieldConverter;
  34. import org.openspcoop2.core.commons.search.dao.jdbc.fetch.FruitoreFetch;
  35. import org.openspcoop2.generic_project.beans.AliasField;
  36. import org.openspcoop2.generic_project.beans.CustomField;
  37. import org.openspcoop2.generic_project.beans.FunctionField;
  38. import org.openspcoop2.generic_project.beans.IField;
  39. import org.openspcoop2.generic_project.beans.InUse;
  40. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  41. import org.openspcoop2.generic_project.beans.Union;
  42. import org.openspcoop2.generic_project.beans.UnionExpression;
  43. import org.openspcoop2.generic_project.dao.jdbc.IJDBCServiceSearchWithId;
  44. import org.openspcoop2.generic_project.dao.jdbc.JDBCExpression;
  45. import org.openspcoop2.generic_project.dao.jdbc.JDBCPaginatedExpression;
  46. import org.openspcoop2.generic_project.dao.jdbc.JDBCServiceManagerProperties;
  47. import org.openspcoop2.generic_project.dao.jdbc.utils.IJDBCFetch;
  48. import org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject;
  49. import org.openspcoop2.generic_project.exception.MultipleResultException;
  50. import org.openspcoop2.generic_project.exception.NotFoundException;
  51. import org.openspcoop2.generic_project.exception.NotImplementedException;
  52. import org.openspcoop2.generic_project.exception.ServiceException;
  53. import org.openspcoop2.generic_project.expression.IExpression;
  54. import org.openspcoop2.generic_project.expression.impl.sql.ISQLFieldConverter;
  55. import org.openspcoop2.generic_project.utils.UtilsTemplate;
  56. import org.openspcoop2.utils.sql.ISQLQueryObject;
  57. import org.slf4j.Logger;

  59. /**     
  60.  * JDBCFruitoreServiceSearchImpl
  61.  *
  62.  * @author Poli Andrea (poli@link.it)
  63.  * @author $Author$
  64.  * @version $Rev$, $Date$
  65.  */
  66. public class JDBCFruitoreServiceSearchImpl implements IJDBCServiceSearchWithId<Fruitore, IdFruitore, JDBCServiceManager> {

  68.     private FruitoreFieldConverter _fruitoreFieldConverter = null;
  69.     public FruitoreFieldConverter getFruitoreFieldConverter() {
  70.         if(this._fruitoreFieldConverter==null){
  71.             this._fruitoreFieldConverter = new FruitoreFieldConverter(this.jdbcServiceManager.getJdbcProperties().getDatabaseType());
  72.         }       
  73.         return this._fruitoreFieldConverter;
  74.     }
  75.     @Override
  76.     public ISQLFieldConverter getFieldConverter() {
  77.         return this.getFruitoreFieldConverter();
  78.     }
  79.     
  80.     private FruitoreFetch fruitoreFetch = new FruitoreFetch();
  81.     public FruitoreFetch getFruitoreFetch() {
  82.         return this.fruitoreFetch;
  83.     }
  84.     @Override
  85.     public IJDBCFetch getFetch() {
  86.         return getFruitoreFetch();
  87.     }
  88.     
  89.     
  90.     private JDBCServiceManager jdbcServiceManager = null;

  92.     @Override
  93.     public void setServiceManager(JDBCServiceManager serviceManager) throws ServiceException{
  94.         this.jdbcServiceManager = serviceManager;
  95.     }
  96.     
  97.     @Override
  98.     public JDBCServiceManager getServiceManager() throws ServiceException{
  99.         return this.jdbcServiceManager;
  100.     }
  101.     public JDBCServiceManager getServiceManager(Connection connection, JDBCServiceManagerProperties jdbcProperties, Logger log) throws ServiceException{
  102.         return new JDBCServiceManager(connection, jdbcProperties, log);
  103.     }
  104.     

  106.     @Override
  107.     public IdFruitore convertToId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Fruitore fruitore) throws NotImplementedException, ServiceException, Exception{
  108.     
  109.         IdFruitore idFruitore = new IdFruitore();
  110.         idFruitore.setIdAccordoServizioParteSpecifica(fruitore.getIdAccordoServizioParteSpecifica());
  111.         idFruitore.setIdFruitore(fruitore.getIdFruitore());
  112.         return idFruitore;
  113.     }
  114.     
  115.     @Override
  116.     public Fruitore get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdFruitore id, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {
  117.         Long id_fruitore = ( (id!=null && id.getId()!=null && id.getId()>0) ? id.getId() : this.findIdFruitore(jdbcProperties, log, connection, sqlQueryObject, id, true));
  118.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, id_fruitore,idMappingResolutionBehaviour);
  119.         
  120.         
  121.     }
  122.     
  123.     @Override
  124.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdFruitore id) throws MultipleResultException, NotImplementedException, ServiceException,Exception {

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

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

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

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

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

  160.         List<Fruitore> list = new ArrayList<Fruitore>();
  161.         
  162.         if(efficiente){
  163.             
  164.             List<IField> fields = new ArrayList<IField>();
  165.             String aliasAccordoTipo = "accordoTipo";
  166.             fields.add(new AliasField(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA.TIPO, aliasAccordoTipo));
  167.             String aliasAccordoNome = "accordoNome";
  168.             fields.add(new AliasField(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA.NOME, aliasAccordoNome));
  169.             String aliasAccordoVersione = "accordoVersione";
  170.             fields.add(new AliasField(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA.VERSIONE, aliasAccordoVersione));
  171.             String aliasAccordoSoggettoErogatoreTipo = "accordoSoggettoReferenteTipo";
  172.             fields.add(new AliasField(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA.ID_EROGATORE.TIPO, aliasAccordoSoggettoErogatoreTipo));
  173.             String aliasAccordoSoggettoErogatoreNome = "accordoSoggettoReferenteNome";
  174.             fields.add(new AliasField(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA.ID_EROGATORE.NOME, aliasAccordoSoggettoErogatoreNome));
  175.             String aliasSoggettoFruitoreTipo = "accordoSoggettoErogatoreTipo";
  176.             fields.add(new AliasField(Fruitore.model().ID_FRUITORE.TIPO, aliasSoggettoFruitoreTipo));
  177.             String aliasSoggettoFruitoreNome = "accordoSoggettoErogatoreNome";
  178.             fields.add(new AliasField(Fruitore.model().ID_FRUITORE.NOME, aliasSoggettoFruitoreNome));
  179.             
  180.             List<Map<String, Object>> returnMap = null;
  181.             try{
  182.                 // non usare true altrimenti non funzionano alcuni meccanismi di ricerca, ad es. la valorizzazione dei select field nel servizio della govwayMonitor.
  183.                 // Tanto le join non comportano righe multiple uguali
  184.                 boolean distinct = false; 
  185.                 returnMap = this.select(jdbcProperties, log, connection, sqlQueryObject, expression, distinct, fields.toArray(new IField[1]));
  186.                 
  187.                 for(Map<String, Object> map: returnMap) {
  188.                     
  189.                     Fruitore fruitore = (Fruitore) this.getFruitoreFetch().fetch(jdbcProperties.getDatabase(), Fruitore.model(), map);
  190.                     
  191.                     Object apcTipo = this.getObjectFromMap(map, aliasAccordoTipo);
  192.                     Object apcNome = this.getObjectFromMap(map, aliasAccordoNome);
  193.                     Object apcVersione = this.getObjectFromMap(map, aliasAccordoVersione);
  194.                     Object apcSoggettoErogatoreTipo = this.getObjectFromMap(map, aliasAccordoSoggettoErogatoreTipo);
  195.                     Object apcSoggettoErogatoreNome = this.getObjectFromMap(map, aliasAccordoSoggettoErogatoreNome);
  196.                     Object soggettoFruitoreTipo = this.getObjectFromMap(map, aliasSoggettoFruitoreTipo);
  197.                     Object soggettoFruitoreNome = this.getObjectFromMap(map, aliasSoggettoFruitoreNome);
  198.                     if(apcTipo!=null && apcNome!=null && apcVersione!=null) {
  199.                         IdAccordoServizioParteSpecifica idAccordoServizioParteSpecifica = new IdAccordoServizioParteSpecifica();
  200.                         if(apcTipo!=null && apcTipo instanceof String) {
  201.                             idAccordoServizioParteSpecifica.setTipo((String) apcTipo);
  202.                         }
  203.                         if(apcNome!=null && apcNome instanceof String) {
  204.                             idAccordoServizioParteSpecifica.setNome((String) apcNome);
  205.                         }
  206.                         if(apcVersione!=null && apcVersione instanceof Integer) {
  207.                             idAccordoServizioParteSpecifica.setVersione((Integer) apcVersione);
  208.                         }
  209.                         if(apcSoggettoErogatoreTipo!=null && apcSoggettoErogatoreNome!=null) {
  210.                             IdSoggetto idSoggetto = new IdSoggetto();
  211.                             if(apcSoggettoErogatoreTipo!=null && apcSoggettoErogatoreTipo instanceof String) {
  212.                                 idSoggetto.setTipo((String) apcSoggettoErogatoreTipo);
  213.                             }
  214.                             if(apcSoggettoErogatoreNome!=null && apcSoggettoErogatoreNome instanceof String) {
  215.                                 idSoggetto.setNome((String) apcSoggettoErogatoreNome);
  216.                             }
  217.                             idAccordoServizioParteSpecifica.setIdErogatore(idSoggetto);
  218.                         }
  219.                         fruitore.setIdAccordoServizioParteSpecifica(idAccordoServizioParteSpecifica);
  220.                     }
  221.                     if(soggettoFruitoreTipo!=null && soggettoFruitoreNome!=null) {
  222.                         IdSoggetto idSoggetto = new IdSoggetto();
  223.                         if(soggettoFruitoreTipo!=null && soggettoFruitoreTipo instanceof String) {
  224.                             idSoggetto.setTipo((String) soggettoFruitoreTipo);
  225.                         }
  226.                         if(soggettoFruitoreNome!=null && soggettoFruitoreNome instanceof String) {
  227.                             idSoggetto.setNome((String) soggettoFruitoreNome);
  228.                         }
  229.                         fruitore.setIdFruitore(idSoggetto);
  230.                     }           
  231.                     
  232.                     list.add(fruitore);
  233.                 }
  234.             }catch(NotFoundException notFound){}
  235.         }

  237.         else{
  238.         
  239.             // TODO: implementazione non efficiente. 
  240.             // Per ottenere una implementazione efficiente:
  241.             // 1. Usare metodo select di questa classe indirizzando esattamente i field necessari
  242.             // 2. Usare metodo getFruitoreFetch() sul risultato della select per ottenere un oggetto Fruitore
  243.             //    La fetch con la map inserirà nell'oggetto solo i valori estratti 
  244.     
  245.             List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  246.             
  247.             for(Long id: ids) {
  248.                 list.add(this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour));
  249.             }
  250.             
  251.         }

  253.         return list;      
  254.         
  255.     }
  256.     
  257.     private Object getObjectFromMap(Map<String,Object> map,String name){
  258.         if(map==null){
  259.             return null;
  260.         }
  261.         else if(map.containsKey(name)){
  262.             Object o = map.get(name);
  263.             if(o instanceof org.apache.commons.lang.ObjectUtils.Null){
  264.                 return null;
  265.             }
  266.             else{
  267.                 return o;
  268.             }
  269.         }
  270.         else{
  271.             return null;
  272.         }
  273.     }
  274.     
  275.     @Override
  276.     public Fruitore find(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) 
  277.         throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {

  279.         long id = this.findTableId(jdbcProperties, log, connection, sqlQueryObject, expression);
  280.         if(id>0){
  281.             return this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour);
  282.         }else{
  283.             throw new NotFoundException("Entry with id["+id+"] not found");
  284.         }
  285.         
  286.     }
  287.     
  288.     @Override
  289.     public NonNegativeNumber count(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws NotImplementedException, ServiceException,Exception {
  290.         
  291.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareCount(jdbcProperties, log, connection, sqlQueryObject, expression,
  292.                                                 this.getFruitoreFieldConverter(), Fruitore.model());
  293.         
  294.         sqlQueryObject.addSelectCountField(this.getFruitoreFieldConverter().toTable(Fruitore.model())+".id","tot",true);
  295.         
  296.         joinEngine(expression,sqlQueryObject);
  297.         
  298.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.count(jdbcProperties, log, connection, sqlQueryObject, expression,
  299.                                                                             this.getFruitoreFieldConverter(), Fruitore.model(),listaQuery);
  300.     }

  302.     @Override
  303.     public InUse inUse(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdFruitore id) throws NotFoundException, NotImplementedException, ServiceException,Exception {
  304.         
  305.         Long id_fruitore = this.findIdFruitore(jdbcProperties, log, connection, sqlQueryObject, id, true);
  306.         return this.inUseEngine(jdbcProperties, log, connection, sqlQueryObject, id_fruitore);
  307.         
  308.     }

  310.     @Override
  311.     public List<Object> select(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  312.                                                     JDBCPaginatedExpression paginatedExpression, IField field) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  313.         return this.select(jdbcProperties, log, connection, sqlQueryObject,
  314.                                 paginatedExpression, false, field);
  315.     }
  316.     
  317.     @Override
  318.     public List<Object> select(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  319.                                                     JDBCPaginatedExpression paginatedExpression, boolean distinct, IField field) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  320.         List<Map<String,Object>> map = 
  321.             this.select(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression, distinct, new IField[]{field});
  322.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.selectSingleObject(map);
  323.     }
  324.     
  325.     @Override
  326.     public List<Map<String,Object>> select(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  327.                                                     JDBCPaginatedExpression paginatedExpression, IField ... field) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  328.         return this.select(jdbcProperties, log, connection, sqlQueryObject,
  329.                                 paginatedExpression, false, field);
  330.     }
  331.     
  332.     @Override
  333.     public List<Map<String,Object>> select(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  334.                                                     JDBCPaginatedExpression paginatedExpression, boolean distinct, IField ... field) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  335.         
  336.         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.setFields(sqlQueryObject,paginatedExpression,field);
  337.         try{
  338.         
  339.             ISQLQueryObject sqlQueryObjectDistinct = 
  340.                         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareSqlQueryObjectForSelectDistinct(distinct,sqlQueryObject, paginatedExpression, log,
  341.                                                 this.getFruitoreFieldConverter(), field);

  343.             return selectEngine(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression, sqlQueryObjectDistinct);
  344.             
  345.         }finally{
  346.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,paginatedExpression,field);
  347.         }
  348.     }

  350.     @Override
  351.     public Object aggregate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  352.                                                     JDBCExpression expression, FunctionField functionField) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  353.         Map<String,Object> map = 
  354.             this.aggregate(jdbcProperties, log, connection, sqlQueryObject, expression, new FunctionField[]{functionField});
  355.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.selectAggregateObject(map,functionField);
  356.     }
  357.     
  358.     @Override
  359.     public Map<String,Object> aggregate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  360.                                                     JDBCExpression expression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException,Exception {                                                   
  361.         
  362.         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.setFields(sqlQueryObject,expression,functionField);
  363.         try{
  364.             List<Map<String,Object>> list = selectEngine(jdbcProperties, log, connection, sqlQueryObject, expression);
  365.             return list.get(0);
  366.         }finally{
  367.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,expression,functionField);
  368.         }
  369.     }

  371.     @Override
  372.     public List<Map<String,Object>> groupBy(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  373.                                                     JDBCExpression expression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  374.         
  375.         if(expression.getGroupByFields().isEmpty()){
  376.             throw new ServiceException("GroupBy conditions not found in expression");
  377.         }
  378.         
  379.         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.setFields(sqlQueryObject,expression,functionField);
  380.         try{
  381.             return selectEngine(jdbcProperties, log, connection, sqlQueryObject, expression);
  382.         }finally{
  383.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,expression,functionField);
  384.         }
  385.     }
  386.     

  388.     @Override
  389.     public List<Map<String,Object>> groupBy(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  390.                                                     JDBCPaginatedExpression paginatedExpression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  391.         
  392.         if(paginatedExpression.getGroupByFields().isEmpty()){
  393.             throw new ServiceException("GroupBy conditions not found in expression");
  394.         }
  395.         
  396.         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.setFields(sqlQueryObject,paginatedExpression,functionField);
  397.         try{
  398.             return selectEngine(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression);
  399.         }finally{
  400.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,paginatedExpression,functionField);
  401.         }
  402.     }
  403.     
  404.     protected List<Map<String,Object>> selectEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  405.                                                 IExpression expression) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  406.         return selectEngine(jdbcProperties, log, connection, sqlQueryObject, expression, null);
  407.     }
  408.     protected List<Map<String,Object>> selectEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  409.                                                 IExpression expression, ISQLQueryObject sqlQueryObjectDistinct) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  410.         
  411.         List<Object> listaQuery = new ArrayList<>();
  412.         List<JDBCObject> listaParams = new ArrayList<>();
  413.         List<Object> returnField = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareSelect(jdbcProperties, log, connection, sqlQueryObject, 
  414.                                 expression, this.getFruitoreFieldConverter(), Fruitore.model(), 
  415.                                 listaQuery,listaParams);
  416.         
  417.         joinEngine(expression,sqlQueryObject);
  418.         
  419.         List<Map<String,Object>> list = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.select(jdbcProperties, log, connection,
  420.                                         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareSqlQueryObjectForSelectDistinct(sqlQueryObject,sqlQueryObjectDistinct), 
  421.                                         expression, this.getFruitoreFieldConverter(), Fruitore.model(),
  422.                                         listaQuery,listaParams,returnField);
  423.         if(list!=null && !list.isEmpty()){
  424.             return list;
  425.         }
  426.         else{
  427.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  428.         }
  429.     }
  430.     
  431.     @Override
  432.     public List<Map<String,Object>> union(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  433.                                                 Union union, UnionExpression ... unionExpression) throws ServiceException,NotFoundException,NotImplementedException,Exception {     
  434.         
  435.         List<ISQLQueryObject> sqlQueryObjectInnerList = new ArrayList<>();
  436.         List<JDBCObject> jdbcObjects = new ArrayList<>();
  437.         List<Class<?>> returnClassTypes = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareUnion(jdbcProperties, log, connection, sqlQueryObject, 
  438.                                 this.getFruitoreFieldConverter(), Fruitore.model(), 
  439.                                 sqlQueryObjectInnerList, jdbcObjects, union, unionExpression);
  440.         
  441.         if(unionExpression!=null){
  442.             for (int i = 0; i < unionExpression.length; i++) {
  443.                 UnionExpression ue = unionExpression[i];
  444.                 IExpression expression = ue.getExpression();
  445.                 joinEngine(expression,sqlQueryObjectInnerList.get(i));
  446.             }
  447.         }
  448.         
  449.         List<Map<String,Object>> list = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.union(jdbcProperties, log, connection, sqlQueryObject, 
  450.                                         this.getFruitoreFieldConverter(), Fruitore.model(), 
  451.                                         sqlQueryObjectInnerList, jdbcObjects, returnClassTypes, union, unionExpression);
  452.         if(list!=null && !list.isEmpty()){
  453.             return list;
  454.         }
  455.         else{
  456.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  457.         }                               
  458.     }
  459.     
  460.     @Override
  461.     public NonNegativeNumber unionCount(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  462.                                                 Union union, UnionExpression ... unionExpression) throws ServiceException,NotFoundException,NotImplementedException,Exception {     
  463.         
  464.         List<ISQLQueryObject> sqlQueryObjectInnerList = new ArrayList<>();
  465.         List<JDBCObject> jdbcObjects = new ArrayList<>();
  466.         List<Class<?>> returnClassTypes = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareUnionCount(jdbcProperties, log, connection, sqlQueryObject, 
  467.                                 this.getFruitoreFieldConverter(), Fruitore.model(), 
  468.                                 sqlQueryObjectInnerList, jdbcObjects, union, unionExpression);
  469.         
  470.         if(unionExpression!=null){
  471.             for (int i = 0; i < unionExpression.length; i++) {
  472.                 UnionExpression ue = unionExpression[i];
  473.                 IExpression expression = ue.getExpression();
  474.                 joinEngine(expression,sqlQueryObjectInnerList.get(i));
  475.             }
  476.         }
  477.         
  478.         NonNegativeNumber number = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.unionCount(jdbcProperties, log, connection, sqlQueryObject, 
  479.                                         this.getFruitoreFieldConverter(), Fruitore.model(), 
  480.                                         sqlQueryObjectInnerList, jdbcObjects, returnClassTypes, union, unionExpression);
  481.         if(number!=null && number.longValue()>=0){
  482.             return number;
  483.         }
  484.         else{
  485.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  486.         }
  487.     }



  491.     // -- ConstructorExpression 

  493.     @Override
  494.     public JDBCExpression newExpression(Logger log) throws NotImplementedException, ServiceException {
  495.         try{
  496.             return new JDBCExpression(this.getFruitoreFieldConverter());
  497.         }catch(Exception e){
  498.             throw new ServiceException(e);
  499.         }
  500.     }


  503.     @Override
  504.     public JDBCPaginatedExpression newPaginatedExpression(Logger log) throws NotImplementedException, ServiceException {
  505.         try{
  506.             return new JDBCPaginatedExpression(this.getFruitoreFieldConverter());
  507.         }catch(Exception e){
  508.             throw new ServiceException(e);
  509.         }
  510.     }
  511.     
  512.     @Override
  513.     public JDBCExpression toExpression(JDBCPaginatedExpression paginatedExpression, Logger log) throws NotImplementedException, ServiceException {
  514.         try{
  515.             return new JDBCExpression(paginatedExpression);
  516.         }catch(Exception e){
  517.             throw new ServiceException(e);
  518.         }
  519.     }

  521.     @Override
  522.     public JDBCPaginatedExpression toPaginatedExpression(JDBCExpression expression, Logger log) throws NotImplementedException, ServiceException {
  523.         try{
  524.             return new JDBCPaginatedExpression(expression);
  525.         }catch(Exception e){
  526.             throw new ServiceException(e);
  527.         }
  528.     }
  529.     
  530.     
  531.     
  532.     // -- DB

  534.     @Override
  535.     public void mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdFruitore id, Fruitore obj) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  536.         _mappingTableIds(jdbcProperties,log,connection,sqlQueryObject,obj,
  537.                 this.get(jdbcProperties,log,connection,sqlQueryObject,id,null));
  538.     }
  539.     
  540.     @Override
  541.     public void mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, Fruitore obj) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  542.         _mappingTableIds(jdbcProperties,log,connection,sqlQueryObject,obj,
  543.                 this.get(jdbcProperties,log,connection,sqlQueryObject,tableId,null));
  544.     }
  545.     private void _mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Fruitore obj, Fruitore imgSaved) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  546.         if(imgSaved==null){
  547.             return;
  548.         }
  549.         obj.setId(imgSaved.getId());
  550.         if(obj.getIdFruitore()!=null && 
  551.                 imgSaved.getIdFruitore()!=null){
  552.             obj.getIdFruitore().setId(imgSaved.getIdFruitore().getId());
  553.         }
  554.         if(obj.getIdAccordoServizioParteSpecifica()!=null && 
  555.                 imgSaved.getIdAccordoServizioParteSpecifica()!=null){
  556.             obj.getIdAccordoServizioParteSpecifica().setId(imgSaved.getIdAccordoServizioParteSpecifica().getId());
  557.             if(obj.getIdAccordoServizioParteSpecifica().getIdErogatore()!=null && 
  558.                     imgSaved.getIdAccordoServizioParteSpecifica().getIdErogatore()!=null){
  559.                 obj.getIdAccordoServizioParteSpecifica().getIdErogatore().setId(imgSaved.getIdAccordoServizioParteSpecifica().getIdErogatore().getId());
  560.             }
  561.         }

  563.     }
  564.     
  565.     @Override
  566.     public Fruitore get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  567.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId), idMappingResolutionBehaviour);
  568.     }
  569.     
  570.     private Fruitore getEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  571.     
  572.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  573.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  574.         
  575.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();
  576.                 
  577.         Fruitore fruitore = new Fruitore();
  578.         

  580.         // Object fruitore
  581.         ISQLQueryObject sqlQueryObjectGet_fruitore = sqlQueryObjectGet.newSQLQueryObject();
  582.         sqlQueryObjectGet_fruitore.setANDLogicOperator(true);
  583.         sqlQueryObjectGet_fruitore.addFromTable(this.getFruitoreFieldConverter().toTable(Fruitore.model()));
  584.         sqlQueryObjectGet_fruitore.addSelectField("id");
  585.         sqlQueryObjectGet_fruitore.addSelectField(this.getFruitoreFieldConverter().toColumn(Fruitore.model().ORA_REGISTRAZIONE,true));
  586.         sqlQueryObjectGet_fruitore.addWhereCondition("id=?");

  588.         // Get fruitore
  589.         fruitore = (Fruitore) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_fruitore.createSQLQuery(), jdbcProperties.isShowSql(), Fruitore.model(), this.getFruitoreFetch(),
  590.             new JDBCObject(tableId,Long.class));


  593.         // Object _fruitore_soggetto (recupero id)
  594.         ISQLQueryObject sqlQueryObjectGet_fruitore_soggetto_readFkId = sqlQueryObjectGet.newSQLQueryObject();
  595.         sqlQueryObjectGet_fruitore_soggetto_readFkId.addFromTable("servizi_fruitori");
  596.         sqlQueryObjectGet_fruitore_soggetto_readFkId.addSelectField("id_soggetto");
  597.         sqlQueryObjectGet_fruitore_soggetto_readFkId.addWhereCondition("id=?");
  598.         sqlQueryObjectGet_fruitore_soggetto_readFkId.setANDLogicOperator(true);
  599.         Long idFK_fruitore_soggetto = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_fruitore_soggetto_readFkId.createSQLQuery(), jdbcProperties.isShowSql(),Long.class,
  600.                 new JDBCObject(fruitore.getId(),Long.class));
  601.         
  602.         // Object _fruitore_soggetto
  603.         ISQLQueryObject sqlQueryObjectGet_fruitore_soggetto = sqlQueryObjectGet.newSQLQueryObject();
  604.         sqlQueryObjectGet_fruitore_soggetto.addFromTable("soggetti");
  605.         sqlQueryObjectGet_fruitore_soggetto.addSelectField("tipo_soggetto");
  606.         sqlQueryObjectGet_fruitore_soggetto.addSelectField("nome_soggetto");
  607.         sqlQueryObjectGet_fruitore_soggetto.setANDLogicOperator(true);
  608.         sqlQueryObjectGet_fruitore_soggetto.addWhereCondition("id=?");

  610.         // Recupero _fruitore_soggetto
  611.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_fruitore_soggetto = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  612.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(idFK_fruitore_soggetto,Long.class)
  613.         };
  614.         List<Class<?>> listaFieldIdReturnType_fruitore_soggetto = new ArrayList<Class<?>>();
  615.         listaFieldIdReturnType_fruitore_soggetto.add(String.class);
  616.         listaFieldIdReturnType_fruitore_soggetto.add(String.class);
  617.         List<Object> listaFieldId_fruitore_soggetto = jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_fruitore_soggetto.createSQLQuery(), jdbcProperties.isShowSql(),
  618.                 listaFieldIdReturnType_fruitore_soggetto, searchParams_fruitore_soggetto);
  619.         // set _fruitore_soggetto
  620.         IdSoggetto id_fruitore_soggetto = new IdSoggetto();
  621.         id_fruitore_soggetto.setTipo((String)listaFieldId_fruitore_soggetto.get(0));
  622.         id_fruitore_soggetto.setNome((String)listaFieldId_fruitore_soggetto.get(1));
  623.         fruitore.setIdFruitore(id_fruitore_soggetto);

  625.         // Object _fruitore_accordoServizioParteSpecifica (recupero id)
  626.         ISQLQueryObject sqlQueryObjectGet_fruitore_accordoServizioParteSpecifica_readFkId = sqlQueryObjectGet.newSQLQueryObject();
  627.         sqlQueryObjectGet_fruitore_accordoServizioParteSpecifica_readFkId.addFromTable("servizi_fruitori");
  628.         sqlQueryObjectGet_fruitore_accordoServizioParteSpecifica_readFkId.addSelectField("id_servizio");
  629.         sqlQueryObjectGet_fruitore_accordoServizioParteSpecifica_readFkId.addWhereCondition("id=?");
  630.         sqlQueryObjectGet_fruitore_accordoServizioParteSpecifica_readFkId.setANDLogicOperator(true);
  631.         Long idFK_fruitore_accordoServizioParteSpecifica = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_fruitore_accordoServizioParteSpecifica_readFkId.createSQLQuery(), jdbcProperties.isShowSql(),Long.class,
  632.                 new JDBCObject(fruitore.getId(),Long.class));
  633.         
  634.         // Object _fruitore_accordoServizioParteSpecifica
  635.         ISQLQueryObject sqlQueryObjectGet_fruitore_accordoServizioParteSpecifica = sqlQueryObjectGet.newSQLQueryObject();
  636.         sqlQueryObjectGet_fruitore_accordoServizioParteSpecifica.addFromTable("servizi");
  637.         sqlQueryObjectGet_fruitore_accordoServizioParteSpecifica.addSelectField("tipo_servizio");
  638.         sqlQueryObjectGet_fruitore_accordoServizioParteSpecifica.addSelectField("nome_servizio");
  639.         sqlQueryObjectGet_fruitore_accordoServizioParteSpecifica.addSelectField("id_soggetto");
  640.         sqlQueryObjectGet_fruitore_accordoServizioParteSpecifica.setANDLogicOperator(true);
  641.         sqlQueryObjectGet_fruitore_accordoServizioParteSpecifica.addWhereCondition("id=?");

  643.         // Recupero _fruitore_accordoServizioParteSpecifica
  644.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_fruitore_accordoServizioParteSpecifica = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  645.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(idFK_fruitore_accordoServizioParteSpecifica,Long.class)
  646.         };
  647.         List<Class<?>> listaFieldIdReturnType_fruitore_accordoServizioParteSpecifica = new ArrayList<Class<?>>();
  648.         listaFieldIdReturnType_fruitore_accordoServizioParteSpecifica.add(String.class);
  649.         listaFieldIdReturnType_fruitore_accordoServizioParteSpecifica.add(String.class);
  650.         listaFieldIdReturnType_fruitore_accordoServizioParteSpecifica.add(Long.class);
  651.         List<Object> listaFieldId_fruitore_accordoServizioParteSpecifica = jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_fruitore_accordoServizioParteSpecifica.createSQLQuery(), jdbcProperties.isShowSql(),
  652.                 listaFieldIdReturnType_fruitore_accordoServizioParteSpecifica, searchParams_fruitore_accordoServizioParteSpecifica);
  653.         // set _fruitore_accordoServizioParteSpecifica
  654.         IdAccordoServizioParteSpecifica id_fruitore_accordoServizioParteSpecifica = new IdAccordoServizioParteSpecifica();
  655.         id_fruitore_accordoServizioParteSpecifica.setTipo((String)listaFieldId_fruitore_accordoServizioParteSpecifica.get(0));
  656.         id_fruitore_accordoServizioParteSpecifica.setNome((String)listaFieldId_fruitore_accordoServizioParteSpecifica.get(1));
  657.         
  658.         // Recupero IdSoggettoAPS
  659.         long idSoggettoAccordoParteSpecifica = (Long) listaFieldId_fruitore_accordoServizioParteSpecifica.get(2);
  660.         
  661.         // Recupero IdSoggettoAPS query
  662.         ISQLQueryObject sqlQueryObjectGet_erogatore_soggetto = sqlQueryObjectGet.newSQLQueryObject();
  663.         sqlQueryObjectGet_erogatore_soggetto.addFromTable("soggetti");
  664.         sqlQueryObjectGet_erogatore_soggetto.addSelectField("tipo_soggetto");
  665.         sqlQueryObjectGet_erogatore_soggetto.addSelectField("nome_soggetto");
  666.         sqlQueryObjectGet_erogatore_soggetto.setANDLogicOperator(true);
  667.         sqlQueryObjectGet_erogatore_soggetto.addWhereCondition("id=?");
  668.         
  669.         // Recupero IdSoggettoAPS execute
  670.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_erogatore_soggetto = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  671.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(idSoggettoAccordoParteSpecifica,Long.class)
  672.         };
  673.         List<Class<?>> listaFieldIdReturnType_erogatore_soggetto = new ArrayList<Class<?>>();
  674.         listaFieldIdReturnType_erogatore_soggetto.add(String.class);
  675.         listaFieldIdReturnType_erogatore_soggetto.add(String.class);
  676.         List<Object> listaFieldId_erogatore_soggetto = jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_fruitore_soggetto.createSQLQuery(), jdbcProperties.isShowSql(),
  677.                 listaFieldIdReturnType_erogatore_soggetto, searchParams_erogatore_soggetto);
  678.         // set _fruitore_soggetto
  679.         IdSoggetto id_erogatore_soggetto = new IdSoggetto();
  680.         id_erogatore_soggetto.setTipo((String)listaFieldId_erogatore_soggetto.get(0));
  681.         id_erogatore_soggetto.setNome((String)listaFieldId_erogatore_soggetto.get(1));
  682.         id_fruitore_accordoServizioParteSpecifica.setIdErogatore(id_erogatore_soggetto);
  683.         
  684.         // Set idAccordoServizioParteSpecifica nel fruitore
  685.         fruitore.setIdAccordoServizioParteSpecifica(id_fruitore_accordoServizioParteSpecifica);

  687.         
  688.         return fruitore;  
  689.     
  690.     } 
  691.     
  692.     @Override
  693.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  694.         return this._exists(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  695.     }
  696.     
  697.     private boolean _exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  698.     
  699.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  700.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  701.                 
  702.         boolean existsFruitore = false;

  704.         sqlQueryObject = sqlQueryObject.newSQLQueryObject();
  705.         sqlQueryObject.setANDLogicOperator(true);

  707.         sqlQueryObject.addFromTable(this.getFruitoreFieldConverter().toTable(Fruitore.model()));
  708.         sqlQueryObject.addSelectField(this.getFruitoreFieldConverter().toColumn(Fruitore.model().ORA_REGISTRAZIONE,true));
  709.         sqlQueryObject.addWhereCondition("id=?");


  712.         // Exists fruitore
  713.         existsFruitore = jdbcUtilities.exists(sqlQueryObject.createSQLQuery(), jdbcProperties.isShowSql(),
  714.             new JDBCObject(tableId,Long.class));

  716.         
  717.         return existsFruitore;
  718.     
  719.     }
  720.     
  721.     private void joinEngine(IExpression expression, ISQLQueryObject sqlQueryObject) throws NotImplementedException, ServiceException, Exception{
  722.     
  723.         if(expression.inUseModel(Fruitore.model().ID_FRUITORE,false)){
  724.             String tableName1 = this.getFruitoreFieldConverter().toTable(Fruitore.model());
  725.             //String tableName2 = "sfr";
  726.             String tableName2 =  this.getFruitoreFieldConverter().toAliasTable(Fruitore.model().ID_FRUITORE);
  727.             sqlQueryObject.addWhereCondition(tableName1+".id_soggetto="+tableName2+".id");
  728.         }
  729.         if(expression.inUseModel(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA,false)){
  730.             String tableName1 = this.getFruitoreFieldConverter().toTable(Fruitore.model());
  731.             String tableName2 = this.getFruitoreFieldConverter().toTable(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA);
  732.             sqlQueryObject.addWhereCondition(tableName1+".id_servizio="+tableName2+".id");
  733.         }
  734.         if(expression.inUseModel(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA.ID_EROGATORE,false)){
  735.             String tableName1 = this.getFruitoreFieldConverter().toTable(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA);
  736.             String tableName2 = this.getFruitoreFieldConverter().toAliasTable(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA.ID_EROGATORE);
  737.             //String tableName2 = "ser";
  738.             sqlQueryObject.addWhereCondition(tableName1+".id_soggetto="+tableName2+".id");
  739.         }
  740.         
  741.         
  742.         if(expression.inUseModel(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA.ID_EROGATORE,false)){
  743.             if(expression.inUseModel(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA,false)==false){
  744.                 sqlQueryObject.addFromTable(this.getFruitoreFieldConverter().toTable(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA));
  745.             }
  746.         }
  747.         
  748.     }
  749.     
  750.     protected java.util.List<Object> getRootTablePrimaryKeyValuesEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdFruitore id) throws NotFoundException, ServiceException, NotImplementedException, Exception{
  751.         // Identificativi
  752.         java.util.List<Object> rootTableIdValues = new java.util.ArrayList<>();
  753.         Long longId = this.findIdFruitore(jdbcProperties, log, connection, sqlQueryObject.newSQLQueryObject(), id, true);
  754.         rootTableIdValues.add(longId);
  755.         return rootTableIdValues;
  756.     }
  757.     
  758.     protected Map<String, List<IField>> getMapTableToPKColumnEngine() throws NotImplementedException, Exception{
  759.     
  760.         FruitoreFieldConverter converter = this.getFruitoreFieldConverter();
  761.         Map<String, List<IField>> mapTableToPKColumn = new java.util.HashMap<>();
  762.         UtilsTemplate<IField> utilities = new UtilsTemplate<>();

  764.         // Fruitore.model()
  765.         mapTableToPKColumn.put(converter.toTable(Fruitore.model()),
  766.             utilities.newList(
  767.                 new CustomField("id", Long.class, "id", converter.toTable(Fruitore.model()))
  768.             ));

  770.         // Fruitore.model().ID_FRUITORE
  771.         mapTableToPKColumn.put(converter.toTable(Fruitore.model().ID_FRUITORE),
  772.             utilities.newList(
  773.                 new CustomField("id", Long.class, "id", converter.toTable(Fruitore.model().ID_FRUITORE))
  774.             ));

  776.         // Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA
  777.         mapTableToPKColumn.put(converter.toTable(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA),
  778.             utilities.newList(
  779.                 new CustomField("id", Long.class, "id", converter.toTable(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA))
  780.             ));

  782.         // Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA.ID_EROGATORE
  783.         mapTableToPKColumn.put(converter.toTable(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA.ID_EROGATORE),
  784.             utilities.newList(
  785.                 new CustomField("id", Long.class, "id", converter.toTable(Fruitore.model().ID_ACCORDO_SERVIZIO_PARTE_SPECIFICA.ID_EROGATORE))
  786.             ));

  788.         return mapTableToPKColumn;      
  789.     }
  790.     
  791.     @Override
  792.     public List<Long> findAllTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression paginatedExpression) throws ServiceException, NotImplementedException, Exception {
  793.         
  794.         List<Long> list = new ArrayList<Long>();

  796.         sqlQueryObject.setSelectDistinct(true);
  797.         sqlQueryObject.setANDLogicOperator(true);
  798.         sqlQueryObject.addSelectField(this.getFruitoreFieldConverter().toTable(Fruitore.model())+".id");
  799.         Class<?> objectIdClass = Long.class;
  800.         
  801.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFindAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  802.                                                 this.getFruitoreFieldConverter(), Fruitore.model());
  803.         
  804.         joinEngine(paginatedExpression,sqlQueryObject);
  805.         
  806.         List<Object> listObjects = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.findAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  807.                                                                             this.getFruitoreFieldConverter(), Fruitore.model(), objectIdClass, listaQuery);
  808.         for(Object object: listObjects) {
  809.             list.add((Long)object);
  810.         }

  812.         return list;
  813.         
  814.     }
  815.     
  816.     @Override
  817.     public long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException, Exception {
  818.     
  819.         sqlQueryObject.setSelectDistinct(true);
  820.         sqlQueryObject.setANDLogicOperator(true);
  821.         sqlQueryObject.addSelectField(this.getFruitoreFieldConverter().toTable(Fruitore.model())+".id");
  822.         Class<?> objectIdClass = Long.class;
  823.         
  824.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFind(jdbcProperties, log, connection, sqlQueryObject, expression,
  825.                                                 this.getFruitoreFieldConverter(), Fruitore.model());
  826.         
  827.         joinEngine(expression,sqlQueryObject);

  829.         Object res = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.find(jdbcProperties, log, connection, sqlQueryObject, expression,
  830.                                                         this.getFruitoreFieldConverter(), Fruitore.model(), objectIdClass, listaQuery);
  831.         if(res!=null && (((Long) res).longValue()>0) ){
  832.             return ((Long) res).longValue();
  833.         }
  834.         else{
  835.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  836.         }
  837.         
  838.     }

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

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

  847.         InUse inUse = new InUse();
  848.         inUse.setInUse(false);
  849.         
  850.         /* 
  851.          * TODO: implement code that checks whether the object identified by the id parameter is used by other objects
  852.         */
  853.         
  854.         // Delete this line when you have implemented the method
  855.         int throwNotImplemented = 1;
  856.         if(throwNotImplemented==1){
  857.                 throw new NotImplementedException("NotImplemented");
  858.         }
  859.         // Delete this line when you have implemented the method

  861.         return inUse;

  863.     }
  864.     
  865.     @Override
  866.     public IdFruitore findId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, boolean throwNotFound)
  867.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  868.         
  869.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  870.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  872.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();
  873.          
  874.         // Object _fruitore
  875.         sqlQueryObjectGet.addFromTable(this.getFruitoreFieldConverter().toTable(Fruitore.model()));
  876.         sqlQueryObjectGet.addSelectField("id_soggetto");
  877.         sqlQueryObjectGet.addSelectField("id_servizio");
  878.         sqlQueryObjectGet.setANDLogicOperator(true);
  879.         sqlQueryObjectGet.addWhereCondition("id=?");

  881.         // Recupero _fruitore
  882.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_fruitore = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  883.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(tableId,Long.class)
  884.         };
  885.         List<Class<?>> listaFieldIdReturnType_fruitore = new ArrayList<Class<?>>();
  886.         listaFieldIdReturnType_fruitore.add(Long.class);
  887.         listaFieldIdReturnType_fruitore.add(Long.class);
  888.         org.openspcoop2.core.commons.search.IdFruitore id_fruitore = null;
  889.         List<Object> listaFieldId_fruitore = jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  890.                 listaFieldIdReturnType_fruitore, searchParams_fruitore);
  891.         if(listaFieldId_fruitore==null || listaFieldId_fruitore.size()<=0){
  892.             if(throwNotFound){
  893.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  894.             }
  895.         }
  896.         else{
  897.             // set _fruitore
  898.             id_fruitore = new org.openspcoop2.core.commons.search.IdFruitore();
  899.             
  900.             Long idSoggettoFK = (Long) listaFieldId_fruitore.get(0);
  901.             id_fruitore.
  902.                 setIdFruitore(((IDBSoggettoServiceSearch)this.getServiceManager(connection, jdbcProperties, log).
  903.                         getSoggettoServiceSearch()).findId(idSoggettoFK, true));
  904.             
  905.             Long idParteSpecificaFK = (Long) listaFieldId_fruitore.get(1);
  906.             id_fruitore.
  907.                 setIdAccordoServizioParteSpecifica(((IDBAccordoServizioParteSpecificaServiceSearch)this.getServiceManager(connection, jdbcProperties, log).
  908.                         getAccordoServizioParteSpecificaServiceSearch()).findId(idParteSpecificaFK, true));
  909.         }
  910.         
  911.         return id_fruitore;
  912.         
  913.     }

  915.     @Override
  916.     public Long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdFruitore id, boolean throwNotFound)
  917.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  918.     
  919.         return this.findIdFruitore(jdbcProperties,log,connection,sqlQueryObject,id,throwNotFound);
  920.             
  921.     }
  922.     
  923.     @Override
  924.     public List<List<Object>> nativeQuery(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  925.                                             String sql,List<Class<?>> returnClassTypes,Object ... param) throws ServiceException,NotFoundException,NotImplementedException,Exception{
  926.         
  927.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeQuery(jdbcProperties, log, connection, sqlQueryObject,
  928.                                                                                             sql,returnClassTypes,param);
  929.                                                         
  930.     }
  931.     
  932.     protected Long findIdFruitore(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdFruitore id, boolean throwNotFound) throws NotFoundException, ServiceException, NotImplementedException, Exception {

  934.         if(jdbcProperties==null) {
  935.             throw new ServiceException("Param jdbcProperties is null");
  936.         }
  937.         if(sqlQueryObject==null) {
  938.             throw new ServiceException("Param sqlQueryObject is null");
  939.         }
  940.         if(id==null) {
  941.             throw new ServiceException("Param id is null");
  942.         }
  943.         
  944.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  945.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  947.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();

  949.         IDBSoggettoServiceSearch soggettoServiceSearch = (IDBSoggettoServiceSearch) this.getServiceManager(connection, jdbcProperties, log).getSoggettoServiceSearch();
  950.         Long idSoggettoFruitore = soggettoServiceSearch.get(id.getIdFruitore()).getId();
  951.         
  952.         IDBAccordoServizioParteSpecificaServiceSearch accordoServizioParteSpecificaServiceSearch = (IDBAccordoServizioParteSpecificaServiceSearch) this.getServiceManager(connection, jdbcProperties, log).getAccordoServizioParteSpecificaServiceSearch();
  953.         Long idAccordoServizioParteSpecifica = accordoServizioParteSpecificaServiceSearch.get(id.getIdAccordoServizioParteSpecifica()).getId();
  954.         
  955.         // Object _fruitore
  956.         sqlQueryObjectGet.addFromTable(this.getFruitoreFieldConverter().toTable(Fruitore.model()));
  957.         sqlQueryObjectGet.addSelectField("id");
  958.         // Devono essere mappati nella where condition i metodi dell'oggetto id.getXXX
  959.         sqlQueryObjectGet.setANDLogicOperator(true);
  960.         sqlQueryObjectGet.setSelectDistinct(true);
  961.         sqlQueryObjectGet.addWhereCondition("id_soggetto=?");
  962.         sqlQueryObjectGet.addWhereCondition("id_servizio=?");

  964.         // Recupero _fruitore
  965.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_fruitore = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  966.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(idSoggettoFruitore,Long.class),
  967.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(idAccordoServizioParteSpecifica,Long.class)
  968.         };
  969.         Long id_fruitore = null;
  970.         try{
  971.             id_fruitore = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  972.                         Long.class, searchParams_fruitore);
  973.         }catch(NotFoundException notFound){
  974.             if(throwNotFound){
  975.                 throw new NotFoundException(notFound);
  976.             }
  977.         }
  978.         if(id_fruitore==null || id_fruitore<=0){
  979.             if(throwNotFound){
  980.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  981.             }
  982.         }
  983.         
  984.         return id_fruitore;
  985.     }
  986. }
Created with JaCoCo 0.8.8.202204050719