JDBCAccordoServizioParteComuneGruppoServiceSearchImpl.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.  */

  21. package org.openspcoop2.core.commons.search.dao.jdbc;

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

  27. import java.sql.Connection;

  29. import org.slf4j.Logger;

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

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

  55. import org.openspcoop2.generic_project.dao.jdbc.JDBCServiceManagerProperties;
  56. import org.openspcoop2.core.commons.search.dao.jdbc.converter.AccordoServizioParteComuneGruppoFieldConverter;
  57. import org.openspcoop2.core.commons.search.dao.jdbc.fetch.AccordoServizioParteComuneGruppoFetch;
  58. import org.openspcoop2.core.commons.search.dao.IDBAccordoServizioParteComuneServiceSearch;
  59. import org.openspcoop2.core.commons.search.dao.IDBGruppoServiceSearch;
  60. import org.openspcoop2.core.commons.search.AccordoServizioParteComune;
  61. import org.openspcoop2.core.commons.search.AccordoServizioParteComuneGruppo;
  62. import org.openspcoop2.core.commons.search.Gruppo;
  63. import org.openspcoop2.core.commons.search.IdAccordoServizioParteComune;

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

  74.     private AccordoServizioParteComuneGruppoFieldConverter _accordoServizioParteComuneGruppoFieldConverter = null;
  75.     public AccordoServizioParteComuneGruppoFieldConverter getAccordoServizioParteComuneGruppoFieldConverter() {
  76.         if(this._accordoServizioParteComuneGruppoFieldConverter==null){
  77.             this._accordoServizioParteComuneGruppoFieldConverter = new AccordoServizioParteComuneGruppoFieldConverter(this.jdbcServiceManager.getJdbcProperties().getDatabaseType());
  78.         }       
  79.         return this._accordoServizioParteComuneGruppoFieldConverter;
  80.     }
  81.     @Override
  82.     public ISQLFieldConverter getFieldConverter() {
  83.         return this.getAccordoServizioParteComuneGruppoFieldConverter();
  84.     }
  85.     
  86.     private AccordoServizioParteComuneGruppoFetch accordoServizioParteComuneGruppoFetch = new AccordoServizioParteComuneGruppoFetch();
  87.     public AccordoServizioParteComuneGruppoFetch getAccordoServizioParteComuneGruppoFetch() {
  88.         return this.accordoServizioParteComuneGruppoFetch;
  89.     }
  90.     @Override
  91.     public IJDBCFetch getFetch() {
  92.         return getAccordoServizioParteComuneGruppoFetch();
  93.     }
  94.     
  95.     
  96.     private JDBCServiceManager jdbcServiceManager = null;

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

  112.     @Override
  113.     public IdAccordoServizioParteComuneGruppo convertToId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, AccordoServizioParteComuneGruppo accordoServizioParteComuneGruppo) throws NotImplementedException, ServiceException, Exception{
  114.     
  115.         IdAccordoServizioParteComuneGruppo idAccordoServizioParteComuneGruppo = new IdAccordoServizioParteComuneGruppo();
  116.         idAccordoServizioParteComuneGruppo.setIdGruppo(accordoServizioParteComuneGruppo.getIdGruppo());
  117.         idAccordoServizioParteComuneGruppo.setIdAccordoServizioParteComune(accordoServizioParteComuneGruppo.getIdAccordoServizioParteComune());
  118.         
  119.         return idAccordoServizioParteComuneGruppo;
  120.     }
  121.     
  122.     @Override
  123.     public AccordoServizioParteComuneGruppo get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAccordoServizioParteComuneGruppo id, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {
  124.         Long id_accordoServizioParteComuneGruppo = ( (id!=null && id.getId()!=null && id.getId()>0) ? id.getId() : this.findIdAccordoServizioParteComuneGruppo(jdbcProperties, log, connection, sqlQueryObject, id, true));
  125.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, id_accordoServizioParteComuneGruppo,idMappingResolutionBehaviour);
  126.         
  127.         
  128.     }
  129.     
  130.     @Override
  131.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAccordoServizioParteComuneGruppo id) throws MultipleResultException, NotImplementedException, ServiceException,Exception {

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

  141.         List<IdAccordoServizioParteComuneGruppo> list = new ArrayList<IdAccordoServizioParteComuneGruppo>();

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

  150.         List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  151.         
  152.         for(Long id: ids) {
  153.             AccordoServizioParteComuneGruppo accordoServizioParteComuneGruppo = this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour);
  154.             IdAccordoServizioParteComuneGruppo idAccordoServizioParteComuneGruppo = this.convertToId(jdbcProperties,log,connection,sqlQueryObject,accordoServizioParteComuneGruppo);
  155.             list.add(idAccordoServizioParteComuneGruppo);
  156.         }

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

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

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

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

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

  210.     @Override
  211.     public InUse inUse(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAccordoServizioParteComuneGruppo id) throws NotFoundException, NotImplementedException, ServiceException,Exception {
  212.         
  213.         Long id_accordoServizioParteComuneGruppo = this.findIdAccordoServizioParteComuneGruppo(jdbcProperties, log, connection, sqlQueryObject, id, true);
  214.         return this.inUseEngine(jdbcProperties, log, connection, sqlQueryObject, id_accordoServizioParteComuneGruppo);
  215.         
  216.     }

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

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

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

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

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



  399.     // -- ConstructorExpression 

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


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

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

  442.     @Override
  443.     public void mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAccordoServizioParteComuneGruppo id, AccordoServizioParteComuneGruppo obj) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  444.         _mappingTableIds(jdbcProperties,log,connection,sqlQueryObject,obj,
  445.                 this.get(jdbcProperties,log,connection,sqlQueryObject,id,null));
  446.     }
  447.     
  448.     @Override
  449.     public void mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, AccordoServizioParteComuneGruppo obj) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  450.         _mappingTableIds(jdbcProperties,log,connection,sqlQueryObject,obj,
  451.                 this.get(jdbcProperties,log,connection,sqlQueryObject,tableId,null));
  452.     }
  453.     private void _mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, AccordoServizioParteComuneGruppo obj, AccordoServizioParteComuneGruppo imgSaved) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  454.         if(imgSaved==null){
  455.             return;
  456.         }
  457.         obj.setId(imgSaved.getId());
  458.         if(obj.getIdGruppo()!=null && 
  459.                 imgSaved.getIdGruppo()!=null){
  460.             obj.getIdGruppo().setId(imgSaved.getIdGruppo().getId());
  461.         }
  462.         if(obj.getIdAccordoServizioParteComune()!=null && 
  463.                 imgSaved.getIdAccordoServizioParteComune()!=null){
  464.             obj.getIdAccordoServizioParteComune().setId(imgSaved.getIdAccordoServizioParteComune().getId());
  465.             if(obj.getIdAccordoServizioParteComune().getIdSoggetto()!=null && 
  466.                     imgSaved.getIdAccordoServizioParteComune().getIdSoggetto()!=null){
  467.                 obj.getIdAccordoServizioParteComune().getIdSoggetto().setId(imgSaved.getIdAccordoServizioParteComune().getIdSoggetto().getId());
  468.             }
  469.         }

  471.     }
  472.     
  473.     @Override
  474.     public AccordoServizioParteComuneGruppo get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  475.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId), idMappingResolutionBehaviour);
  476.     }
  477.     
  478.     private AccordoServizioParteComuneGruppo getEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  479.     
  480.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  481.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  482.         
  483.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();
  484.                 
  485.         AccordoServizioParteComuneGruppo accordoServizioParteComuneGruppo = new AccordoServizioParteComuneGruppo();
  486.         

  488.         // Object accordoServizioParteComuneGruppo
  489.         ISQLQueryObject sqlQueryObjectGet_accordoServizioParteComuneGruppo = sqlQueryObjectGet.newSQLQueryObject();
  490.         sqlQueryObjectGet_accordoServizioParteComuneGruppo.setANDLogicOperator(true);
  491.         sqlQueryObjectGet_accordoServizioParteComuneGruppo.addFromTable(this.getAccordoServizioParteComuneGruppoFieldConverter().toTable(AccordoServizioParteComuneGruppo.model()));
  492.         sqlQueryObjectGet_accordoServizioParteComuneGruppo.addSelectField("id");
  493.         sqlQueryObjectGet_accordoServizioParteComuneGruppo.addWhereCondition("id=?");

  495.         // Get accordoServizioParteComuneGruppo
  496.         accordoServizioParteComuneGruppo = (AccordoServizioParteComuneGruppo) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_accordoServizioParteComuneGruppo.createSQLQuery(), jdbcProperties.isShowSql(), AccordoServizioParteComuneGruppo.model(), this.getAccordoServizioParteComuneGruppoFetch(),
  497.             new JDBCObject(tableId,Long.class));


  500.         if(idMappingResolutionBehaviour==null ||
  501.             (org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour) || org.openspcoop2.generic_project.beans.IDMappingBehaviour.USE_TABLE_ID.equals(idMappingResolutionBehaviour))
  502.         ){
  503.             // Object _accordoServizioParteComuneGruppo_gruppo (recupero id)
  504.             ISQLQueryObject sqlQueryObjectGet_accordoServizioParteComuneGruppo_gruppo_readFkId = sqlQueryObjectGet.newSQLQueryObject();
  505.             sqlQueryObjectGet_accordoServizioParteComuneGruppo_gruppo_readFkId.addFromTable(this.getAccordoServizioParteComuneGruppoFieldConverter().toTable(org.openspcoop2.core.commons.search.AccordoServizioParteComuneGruppo.model()));
  506.             sqlQueryObjectGet_accordoServizioParteComuneGruppo_gruppo_readFkId.addSelectField("id_gruppo");
  507.             sqlQueryObjectGet_accordoServizioParteComuneGruppo_gruppo_readFkId.addWhereCondition("id=?");
  508.             sqlQueryObjectGet_accordoServizioParteComuneGruppo_gruppo_readFkId.setANDLogicOperator(true);
  509.             Long idFK_accordoServizioParteComuneGruppo_gruppo = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_accordoServizioParteComuneGruppo_gruppo_readFkId.createSQLQuery(), jdbcProperties.isShowSql(),Long.class,
  510.                     new JDBCObject(accordoServizioParteComuneGruppo.getId(),Long.class));
  511.             
  512.             org.openspcoop2.core.commons.search.IdGruppo id_accordoServizioParteComuneGruppo_gruppo = null;
  513.             if(idMappingResolutionBehaviour==null || org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour)){
  514.                 id_accordoServizioParteComuneGruppo_gruppo = ((JDBCGruppoServiceSearch)(this.getServiceManager(connection, jdbcProperties, log).getGruppoServiceSearch())).findId(idFK_accordoServizioParteComuneGruppo_gruppo, false);
  515.             }else{
  516.                 id_accordoServizioParteComuneGruppo_gruppo = new org.openspcoop2.core.commons.search.IdGruppo();
  517.             }
  518.             id_accordoServizioParteComuneGruppo_gruppo.setId(idFK_accordoServizioParteComuneGruppo_gruppo);
  519.             
  520.             Gruppo gruppo = ((IDBGruppoServiceSearch)this.getServiceManager(connection, jdbcProperties, log).getGruppoServiceSearch()).get(id_accordoServizioParteComuneGruppo_gruppo.getId());
  521.             id_accordoServizioParteComuneGruppo_gruppo.setNome(gruppo.getNome());
  522.             
  523.             accordoServizioParteComuneGruppo.setIdGruppo(id_accordoServizioParteComuneGruppo_gruppo);
  524.         }

  526.         if(idMappingResolutionBehaviour==null ||
  527.             (org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour) || org.openspcoop2.generic_project.beans.IDMappingBehaviour.USE_TABLE_ID.equals(idMappingResolutionBehaviour))
  528.         ){
  529.             // Object _accordoServizioParteComuneGruppo_accordoServizioParteComune (recupero id)
  530.             ISQLQueryObject sqlQueryObjectGet_accordoServizioParteComuneGruppo_accordoServizioParteComune_readFkId = sqlQueryObjectGet.newSQLQueryObject();
  531.             sqlQueryObjectGet_accordoServizioParteComuneGruppo_accordoServizioParteComune_readFkId.addFromTable(this.getAccordoServizioParteComuneGruppoFieldConverter().toTable(org.openspcoop2.core.commons.search.AccordoServizioParteComuneGruppo.model()));
  532.             sqlQueryObjectGet_accordoServizioParteComuneGruppo_accordoServizioParteComune_readFkId.addSelectField("id_accordo");
  533.             sqlQueryObjectGet_accordoServizioParteComuneGruppo_accordoServizioParteComune_readFkId.addWhereCondition("id=?");
  534.             sqlQueryObjectGet_accordoServizioParteComuneGruppo_accordoServizioParteComune_readFkId.setANDLogicOperator(true);
  535.             Long idFK_accordoServizioParteComuneGruppo_accordoServizioParteComune = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_accordoServizioParteComuneGruppo_accordoServizioParteComune_readFkId.createSQLQuery(), jdbcProperties.isShowSql(),Long.class,
  536.                     new JDBCObject(accordoServizioParteComuneGruppo.getId(),Long.class));
  537.             
  538.             org.openspcoop2.core.commons.search.IdAccordoServizioParteComune id_accordoServizioParteComuneGruppo_accordoServizioParteComune = null;
  539.             if(idMappingResolutionBehaviour==null || org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour)){
  540.                 id_accordoServizioParteComuneGruppo_accordoServizioParteComune = ((JDBCAccordoServizioParteComuneServiceSearch)(this.getServiceManager(connection, jdbcProperties, log).getAccordoServizioParteComuneServiceSearch())).findId(idFK_accordoServizioParteComuneGruppo_accordoServizioParteComune, false);
  541.             }else{
  542.                 id_accordoServizioParteComuneGruppo_accordoServizioParteComune = new org.openspcoop2.core.commons.search.IdAccordoServizioParteComune();
  543.             }
  544.             id_accordoServizioParteComuneGruppo_accordoServizioParteComune.setId(idFK_accordoServizioParteComuneGruppo_accordoServizioParteComune);
  545.             
  546.             AccordoServizioParteComune aspc = ((IDBAccordoServizioParteComuneServiceSearch)this.getServiceManager(connection, jdbcProperties, log).getAccordoServizioParteComuneServiceSearch()).get(id_accordoServizioParteComuneGruppo_accordoServizioParteComune.getId());
  547.             id_accordoServizioParteComuneGruppo_accordoServizioParteComune.setIdSoggetto(aspc.getIdReferente());
  548.             id_accordoServizioParteComuneGruppo_accordoServizioParteComune.setNome(aspc.getNome());
  549.             id_accordoServizioParteComuneGruppo_accordoServizioParteComune.setServiceBinding(aspc.getServiceBinding());
  550.             id_accordoServizioParteComuneGruppo_accordoServizioParteComune.setVersione(aspc.getVersione());
  551.             
  552.             accordoServizioParteComuneGruppo.setIdAccordoServizioParteComune(id_accordoServizioParteComuneGruppo_accordoServizioParteComune);
  553.         }


  556.         return accordoServizioParteComuneGruppo;  
  557.     
  558.     } 
  559.     
  560.     @Override
  561.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  562.         return this._exists(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  563.     }
  564.     
  565.     private boolean _exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  566.     
  567.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  568.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  569.                 
  570.         boolean existsAccordoServizioParteComuneGruppo = false;

  572.         sqlQueryObject = sqlQueryObject.newSQLQueryObject();
  573.         sqlQueryObject.setANDLogicOperator(true);

  575.         sqlQueryObject.addWhereCondition("id=?");


  578.         // Exists accordoServizioParteComuneGruppo
  579.         existsAccordoServizioParteComuneGruppo = jdbcUtilities.exists(sqlQueryObject.createSQLQuery(), jdbcProperties.isShowSql(),
  580.             new JDBCObject(tableId,Long.class));

  582.         
  583.         return existsAccordoServizioParteComuneGruppo;
  584.     
  585.     }
  586.     
  587.     private void joinEngine(IExpression expression, ISQLQueryObject sqlQueryObject) throws NotImplementedException, ServiceException, Exception{
  588.     
  589.         if(expression.inUseModel(AccordoServizioParteComuneGruppo.model().ID_GRUPPO,false)){
  590.             String tableName1 = this.getAccordoServizioParteComuneGruppoFieldConverter().toAliasTable(AccordoServizioParteComuneGruppo.model());
  591.             String tableName2 = this.getAccordoServizioParteComuneGruppoFieldConverter().toAliasTable(AccordoServizioParteComuneGruppo.model().ID_GRUPPO);
  592.             sqlQueryObject.addWhereCondition(tableName1+".id_gruppo="+tableName2+".id");
  593.         }
  594.         if(expression.inUseModel(AccordoServizioParteComuneGruppo.model().ID_ACCORDO_SERVIZIO_PARTE_COMUNE,false)){
  595.             String tableName1 = this.getAccordoServizioParteComuneGruppoFieldConverter().toAliasTable(AccordoServizioParteComuneGruppo.model());
  596.             String tableName2 = this.getAccordoServizioParteComuneGruppoFieldConverter().toAliasTable(AccordoServizioParteComuneGruppo.model().ID_ACCORDO_SERVIZIO_PARTE_COMUNE);
  597.             sqlQueryObject.addWhereCondition(tableName1+".id_accordo="+tableName2+".id");
  598.         }
  599.         
  600.         
  601.         if(expression.inUseModel(AccordoServizioParteComuneGruppo.model().ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO,false)){
  602.             if(expression.inUseModel(AccordoServizioParteComuneGruppo.model().ID_ACCORDO_SERVIZIO_PARTE_COMUNE,false)==false){
  603.                 sqlQueryObject.addFromTable(this.getAccordoServizioParteComuneGruppoFieldConverter().toTable(AccordoServizioParteComuneGruppo.model().ID_ACCORDO_SERVIZIO_PARTE_COMUNE));
  604.             }
  605.         }
  606.         
  607.     }
  608.     
  609.     protected java.util.List<Object> getRootTablePrimaryKeyValuesEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAccordoServizioParteComuneGruppo id) throws NotFoundException, ServiceException, NotImplementedException, Exception{
  610.         // Identificativi
  611.         java.util.List<Object> rootTableIdValues = new java.util.ArrayList<>();
  612.         // TODO: Define the column values used to identify the primary key
  613.         Long longId = this.findIdAccordoServizioParteComuneGruppo(jdbcProperties, log, connection, sqlQueryObject.newSQLQueryObject(), id, true);
  614.         rootTableIdValues.add(longId);
  615.         
  616.         // Delete this line when you have verified the method
  617.         int throwNotImplemented = 1;
  618.         if(throwNotImplemented==1){
  619.                 throw new NotImplementedException("NotImplemented");
  620.         }
  621.         // Delete this line when you have verified the method
  622.         
  623.         return rootTableIdValues;
  624.     }
  625.     
  626.     protected Map<String, List<IField>> getMapTableToPKColumnEngine() throws NotImplementedException, Exception{
  627.     
  628.         AccordoServizioParteComuneGruppoFieldConverter converter = this.getAccordoServizioParteComuneGruppoFieldConverter();
  629.         Map<String, List<IField>> mapTableToPKColumn = new java.util.HashMap<>();
  630.         UtilsTemplate<IField> utilities = new UtilsTemplate<>();

  632.         // TODO: Define the columns used to identify the primary key
  633.         //        If a table doesn't have a primary key, don't add it to this map

  635.         // AccordoServizioParteComuneGruppo.model()
  636.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComuneGruppo.model()),
  637.             utilities.newList(
  638.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComuneGruppo.model()))
  639.             ));

  641.         // AccordoServizioParteComuneGruppo.model().ID_GRUPPO
  642.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComuneGruppo.model().ID_GRUPPO),
  643.             utilities.newList(
  644.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComuneGruppo.model().ID_GRUPPO))
  645.             ));

  647.         // AccordoServizioParteComuneGruppo.model().ID_ACCORDO_SERVIZIO_PARTE_COMUNE
  648.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComuneGruppo.model().ID_ACCORDO_SERVIZIO_PARTE_COMUNE),
  649.             utilities.newList(
  650.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComuneGruppo.model().ID_ACCORDO_SERVIZIO_PARTE_COMUNE))
  651.             ));

  653.         // AccordoServizioParteComuneGruppo.model().ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO
  654.         mapTableToPKColumn.put(converter.toTable(AccordoServizioParteComuneGruppo.model().ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO),
  655.             utilities.newList(
  656.                 new CustomField("id", Long.class, "id", converter.toTable(AccordoServizioParteComuneGruppo.model().ID_ACCORDO_SERVIZIO_PARTE_COMUNE.ID_SOGGETTO))
  657.             ));


  660.         // Delete this line when you have verified the method
  661.         int throwNotImplemented = 1;
  662.         if(throwNotImplemented==1){
  663.                 throw new NotImplementedException("NotImplemented");
  664.         }
  665.         // Delete this line when you have verified the method
  666.         
  667.         return mapTableToPKColumn;      
  668.     }
  669.     
  670.     @Override
  671.     public List<Long> findAllTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression paginatedExpression) throws ServiceException, NotImplementedException, Exception {
  672.         
  673.         List<Long> list = new ArrayList<Long>();

  675.         sqlQueryObject.setSelectDistinct(true);
  676.         sqlQueryObject.setANDLogicOperator(true);
  677.         sqlQueryObject.addSelectField(this.getAccordoServizioParteComuneGruppoFieldConverter().toTable(AccordoServizioParteComuneGruppo.model())+".id");
  678.         Class<?> objectIdClass = Long.class;
  679.         
  680.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFindAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  681.                                                 this.getAccordoServizioParteComuneGruppoFieldConverter(), AccordoServizioParteComuneGruppo.model());
  682.         
  683.         joinEngine(paginatedExpression,sqlQueryObject);
  684.         
  685.         List<Object> listObjects = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.findAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  686.                                                                             this.getAccordoServizioParteComuneGruppoFieldConverter(), AccordoServizioParteComuneGruppo.model(), objectIdClass, listaQuery);
  687.         for(Object object: listObjects) {
  688.             list.add((Long)object);
  689.         }

  691.         return list;
  692.         
  693.     }
  694.     
  695.     @Override
  696.     public long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException, Exception {
  697.     
  698.         sqlQueryObject.setSelectDistinct(true);
  699.         sqlQueryObject.setANDLogicOperator(true);
  700.         sqlQueryObject.addSelectField(this.getAccordoServizioParteComuneGruppoFieldConverter().toTable(AccordoServizioParteComuneGruppo.model())+".id");
  701.         Class<?> objectIdClass = Long.class;
  702.         
  703.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFind(jdbcProperties, log, connection, sqlQueryObject, expression,
  704.                                                 this.getAccordoServizioParteComuneGruppoFieldConverter(), AccordoServizioParteComuneGruppo.model());
  705.         
  706.         joinEngine(expression,sqlQueryObject);

  708.         Object res = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.find(jdbcProperties, log, connection, sqlQueryObject, expression,
  709.                                                         this.getAccordoServizioParteComuneGruppoFieldConverter(), AccordoServizioParteComuneGruppo.model(), objectIdClass, listaQuery);
  710.         if(res!=null && (((Long) res).longValue()>0) ){
  711.             return ((Long) res).longValue();
  712.         }
  713.         else{
  714.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  715.         }
  716.         
  717.     }

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

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

  726.         InUse inUse = new InUse();
  727.         inUse.setInUse(false);
  728.         
  729.         /* 
  730.          * TODO: implement code that checks whether the object identified by the id parameter is used by other objects
  731.         */
  732.         
  733.         // Delete this line when you have implemented the method
  734.         int throwNotImplemented = 1;
  735.         if(throwNotImplemented==1){
  736.                 throw new NotImplementedException("NotImplemented");
  737.         }
  738.         // Delete this line when you have implemented the method

  740.         return inUse;

  742.     }
  743.     
  744.     @Override
  745.     public IdAccordoServizioParteComuneGruppo findId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, boolean throwNotFound)
  746.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  747.         
  748.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  749.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  751.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();

  753.         // Object _accordoServizioParteComuneGruppo
  754.         sqlQueryObjectGet.addFromTable(this.getAccordoServizioParteComuneGruppoFieldConverter().toTable(AccordoServizioParteComuneGruppo.model()));
  755.         sqlQueryObjectGet.addSelectField("id_accordo");
  756.         sqlQueryObjectGet.addSelectField("id_gruppo");
  757.         sqlQueryObjectGet.setANDLogicOperator(true);
  758.         sqlQueryObjectGet.addWhereCondition("id=?");

  760.         // Recupero _accordoServizioParteComuneGruppo
  761.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_accordoServizioParteComuneGruppo = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  762.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(tableId,Long.class)
  763.         };
  764.         List<Class<?>> listaFieldIdReturnType_accordoServizioParteComuneGruppo = new ArrayList<Class<?>>();
  765.         listaFieldIdReturnType_accordoServizioParteComuneGruppo.add(Long.class);
  766.         listaFieldIdReturnType_accordoServizioParteComuneGruppo.add(Long.class);
  767.         org.openspcoop2.core.commons.search.IdAccordoServizioParteComuneGruppo id_accordoServizioParteComuneGruppo = null;
  768.         List<Object> listaFieldId_accordoServizioParteComuneGruppo = jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  769.                 listaFieldIdReturnType_accordoServizioParteComuneGruppo, searchParams_accordoServizioParteComuneGruppo);
  770.         if(listaFieldId_accordoServizioParteComuneGruppo==null || listaFieldId_accordoServizioParteComuneGruppo.size()<=0){
  771.             if(throwNotFound){
  772.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  773.             }
  774.         }
  775.         else{
  776.             // set _accordoServizioParteComuneGruppo
  777.             id_accordoServizioParteComuneGruppo = new org.openspcoop2.core.commons.search.IdAccordoServizioParteComuneGruppo();
  778.             
  779.             IdAccordoServizioParteComune idApsc = new IdAccordoServizioParteComune();
  780.             idApsc.setId((Long) listaFieldId_accordoServizioParteComuneGruppo.get(0));
  781.             AccordoServizioParteComune aspc = ((IDBAccordoServizioParteComuneServiceSearch)this.getServiceManager(connection, jdbcProperties, log).getAccordoServizioParteComuneServiceSearch()).get(idApsc.getId());
  782.             idApsc.setIdSoggetto(aspc.getIdReferente());
  783.             idApsc.setNome(aspc.getNome());
  784.             idApsc.setServiceBinding(aspc.getServiceBinding());
  785.             idApsc.setVersione(aspc.getVersione());
  786.             id_accordoServizioParteComuneGruppo.setIdAccordoServizioParteComune(idApsc);
  787.             
  788.             IdGruppo idGruppo = new IdGruppo();
  789.             idGruppo.setId((Long) listaFieldId_accordoServizioParteComuneGruppo.get(1));
  790.             Gruppo gruppo = ((IDBGruppoServiceSearch)this.getServiceManager(connection, jdbcProperties, log).getGruppoServiceSearch()).get(idGruppo.getId());
  791.             idGruppo.setNome(gruppo.getNome());
  792.             id_accordoServizioParteComuneGruppo.setIdGruppo(idGruppo);

  794.         }
  795.         
  796.         return id_accordoServizioParteComuneGruppo;
  797.         
  798.     }

  800.     @Override
  801.     public Long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAccordoServizioParteComuneGruppo id, boolean throwNotFound)
  802.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  803.     
  804.         return this.findIdAccordoServizioParteComuneGruppo(jdbcProperties,log,connection,sqlQueryObject,id,throwNotFound);
  805.             
  806.     }
  807.     
  808.     @Override
  809.     public List<List<Object>> nativeQuery(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  810.                                             String sql,List<Class<?>> returnClassTypes,Object ... param) throws ServiceException,NotFoundException,NotImplementedException,Exception{
  811.         
  812.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeQuery(jdbcProperties, log, connection, sqlQueryObject,
  813.                                                                                             sql,returnClassTypes,param);
  814.                                                         
  815.     }
  816.     
  817.     protected Long findIdAccordoServizioParteComuneGruppo(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdAccordoServizioParteComuneGruppo id, boolean throwNotFound) throws NotFoundException, ServiceException, NotImplementedException, Exception {

  819.         if(jdbcProperties==null) {
  820.             throw new ServiceException("Param jdbcProperties is null");
  821.         }
  822.         if(sqlQueryObject==null) {
  823.             throw new ServiceException("Param sqlQueryObject is null");
  824.         }
  825.         if(id==null) {
  826.             throw new ServiceException("Param id is null");
  827.         }
  828.         
  829.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  830.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  832.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();

  834.         // Object _accordoServizioParteComuneGruppo
  835.         sqlQueryObjectGet.addFromTable(this.getAccordoServizioParteComuneGruppoFieldConverter().toTable(AccordoServizioParteComuneGruppo.model()));
  836.         sqlQueryObjectGet.addSelectField("id");
  837.         // Devono essere mappati nella where condition i metodi dell'oggetto id.getXXX
  838.         sqlQueryObjectGet.setANDLogicOperator(true);
  839.         sqlQueryObjectGet.setSelectDistinct(true);
  840.         sqlQueryObjectGet.addWhereCondition("id_accordo=?");
  841.         sqlQueryObjectGet.addWhereCondition("id_gruppo=?");

  843.         long idAccordo = ((IDBAccordoServizioParteComuneServiceSearch)this.getServiceManager(connection, jdbcProperties, log).getAccordoServizioParteComuneServiceSearch()).findTableId(id.getIdAccordoServizioParteComune(), true);
  844.         long idGruppo = ((IDBGruppoServiceSearch)this.getServiceManager(connection, jdbcProperties, log).getGruppoServiceSearch()).findTableId(id.getIdGruppo(), true);
  845.         
  846.         // Recupero _accordoServizioParteComuneGruppo
  847.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_accordoServizioParteComuneGruppo = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  848.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(idAccordo,long.class),
  849.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(idGruppo,long.class)
  850.         };
  851.         Long id_accordoServizioParteComuneGruppo = null;
  852.         try{
  853.             id_accordoServizioParteComuneGruppo = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  854.                         Long.class, searchParams_accordoServizioParteComuneGruppo);
  855.         }catch(NotFoundException notFound){
  856.             if(throwNotFound){
  857.                 throw new NotFoundException(notFound);
  858.             }
  859.         }
  860.         if(id_accordoServizioParteComuneGruppo==null || id_accordoServizioParteComuneGruppo<=0){
  861.             if(throwNotFound){
  862.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  863.             }
  864.         }
  865.         
  866.         return id_accordoServizioParteComuneGruppo;
  867.     }
  868. }
Created with JaCoCo 0.8.8.202204050719