JDBCServizioApplicativoServiceSearchImpl.java

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

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

  26. import java.sql.Connection;

  28. import org.slf4j.Logger;

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

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

  54. import org.openspcoop2.generic_project.dao.jdbc.JDBCServiceManagerProperties;
  55. import org.openspcoop2.core.commons.search.dao.jdbc.converter.ServizioApplicativoFieldConverter;
  56. import org.openspcoop2.core.commons.search.dao.jdbc.fetch.ServizioApplicativoFetch;
  57. import org.openspcoop2.core.constants.CostantiDB;
  58. import org.openspcoop2.core.constants.ProprietariProtocolProperty;
  59. import org.openspcoop2.core.commons.search.dao.IDBSoggettoServiceSearch;
  60. import org.openspcoop2.core.commons.search.dao.ISoggettoServiceSearch;
  61. import org.openspcoop2.core.commons.search.ServizioApplicativoProprietaProtocollo;
  62. import org.openspcoop2.core.commons.search.ServizioApplicativo;
  63. import org.openspcoop2.core.commons.search.Soggetto;
  64. import org.openspcoop2.core.commons.search.ServizioApplicativoRuolo;

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

  75.     private ServizioApplicativoFieldConverter _servizioApplicativoFieldConverter = null;
  76.     public ServizioApplicativoFieldConverter getServizioApplicativoFieldConverter() {
  77.         if(this._servizioApplicativoFieldConverter==null){
  78.             this._servizioApplicativoFieldConverter = new ServizioApplicativoFieldConverter(this.jdbcServiceManager.getJdbcProperties().getDatabaseType());
  79.         }       
  80.         return this._servizioApplicativoFieldConverter;
  81.     }
  82.     @Override
  83.     public ISQLFieldConverter getFieldConverter() {
  84.         return this.getServizioApplicativoFieldConverter();
  85.     }
  86.     
  87.     private ServizioApplicativoFetch servizioApplicativoFetch = new ServizioApplicativoFetch();
  88.     public ServizioApplicativoFetch getServizioApplicativoFetch() {
  89.         return this.servizioApplicativoFetch;
  90.     }
  91.     @Override
  92.     public IJDBCFetch getFetch() {
  93.         return getServizioApplicativoFetch();
  94.     }
  95.     
  96.     
  97.     private JDBCServiceManager jdbcServiceManager = null;

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

  113.     @Override
  114.     public IdServizioApplicativo convertToId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, ServizioApplicativo servizioApplicativo) throws NotImplementedException, ServiceException, Exception{
  115.     
  116.         IdServizioApplicativo idServizioApplicativo = new IdServizioApplicativo();
  117.         idServizioApplicativo.setNome(servizioApplicativo.getNome());
  118.         idServizioApplicativo.setIdSoggetto(servizioApplicativo.getIdSoggetto());
  119.         return idServizioApplicativo;

  121.     }
  122.     
  123.     @Override
  124.     public ServizioApplicativo get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdServizioApplicativo id, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {
  125.         Long id_servizioApplicativo = ( (id!=null && id.getId()!=null && id.getId()>0) ? id.getId() : this.findIdServizioApplicativo(jdbcProperties, log, connection, sqlQueryObject, id, true));
  126.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, id_servizioApplicativo,idMappingResolutionBehaviour);
  127.         
  128.         
  129.     }
  130.     
  131.     @Override
  132.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdServizioApplicativo id) throws MultipleResultException, NotImplementedException, ServiceException,Exception {

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

  142.         List<IdServizioApplicativo> list = new ArrayList<IdServizioApplicativo>();

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

  151.         List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  152.         
  153.         for(Long id: ids) {
  154.             ServizioApplicativo servizioApplicativo = this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour);
  155.             IdServizioApplicativo idServizioApplicativo = this.convertToId(jdbcProperties,log,connection,sqlQueryObject,servizioApplicativo);
  156.             list.add(idServizioApplicativo);
  157.         }

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

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

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

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

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

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

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

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

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

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

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



  400.     // -- ConstructorExpression 

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


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

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

  443.     @Override
  444.     public void mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdServizioApplicativo id, ServizioApplicativo obj) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  445.         _mappingTableIds(jdbcProperties,log,connection,sqlQueryObject,obj,
  446.                 this.get(jdbcProperties,log,connection,sqlQueryObject,id,null));
  447.     }
  448.     
  449.     @Override
  450.     public void mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, ServizioApplicativo obj) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  451.         _mappingTableIds(jdbcProperties,log,connection,sqlQueryObject,obj,
  452.                 this.get(jdbcProperties,log,connection,sqlQueryObject,tableId,null));
  453.     }
  454.     private void _mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, ServizioApplicativo obj, ServizioApplicativo imgSaved) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  455.         if(imgSaved==null){
  456.             return;
  457.         }
  458.         obj.setId(imgSaved.getId());
  459.         if(obj.getIdSoggetto()!=null && 
  460.                 imgSaved.getIdSoggetto()!=null){
  461.             obj.getIdSoggetto().setId(imgSaved.getIdSoggetto().getId());
  462.         }
  463.         if(obj.getServizioApplicativoRuoloList()!=null){
  464.             List<org.openspcoop2.core.commons.search.ServizioApplicativoRuolo> listObj_ = obj.getServizioApplicativoRuoloList();
  465.             for(org.openspcoop2.core.commons.search.ServizioApplicativoRuolo itemObj_ : listObj_){
  466.                 org.openspcoop2.core.commons.search.ServizioApplicativoRuolo itemAlreadySaved_ = null;
  467.                 if(imgSaved.getServizioApplicativoRuoloList()!=null){
  468.                     List<org.openspcoop2.core.commons.search.ServizioApplicativoRuolo> listImgSaved_ = imgSaved.getServizioApplicativoRuoloList();
  469.                     for(org.openspcoop2.core.commons.search.ServizioApplicativoRuolo itemImgSaved_ : listImgSaved_){
  470.                         boolean objEqualsToImgSaved_ = false;
  471.                         objEqualsToImgSaved_ = org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getNome(),itemImgSaved_.getNome());
  472.                         if(objEqualsToImgSaved_){
  473.                             itemAlreadySaved_=itemImgSaved_;
  474.                             break;
  475.                         }
  476.                     }
  477.                 }
  478.                 if(itemAlreadySaved_!=null){
  479.                     itemObj_.setId(itemAlreadySaved_.getId());
  480.                 }
  481.             }
  482.         }
  483.         if(obj.getServizioApplicativoProprietaProtocolloList()!=null){
  484.             List<org.openspcoop2.core.commons.search.ServizioApplicativoProprietaProtocollo> listObj_ = obj.getServizioApplicativoProprietaProtocolloList();
  485.             for(org.openspcoop2.core.commons.search.ServizioApplicativoProprietaProtocollo itemObj_ : listObj_){
  486.                 org.openspcoop2.core.commons.search.ServizioApplicativoProprietaProtocollo itemAlreadySaved_ = null;
  487.                 if(imgSaved.getServizioApplicativoProprietaProtocolloList()!=null){
  488.                     List<org.openspcoop2.core.commons.search.ServizioApplicativoProprietaProtocollo> listImgSaved_ = imgSaved.getServizioApplicativoProprietaProtocolloList();
  489.                     for(org.openspcoop2.core.commons.search.ServizioApplicativoProprietaProtocollo itemImgSaved_ : listImgSaved_){
  490.                         boolean objEqualsToImgSaved_ = false;
  491.                         objEqualsToImgSaved_ = org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getName(),itemImgSaved_.getName());
  492.                         if(objEqualsToImgSaved_){
  493.                             itemAlreadySaved_=itemImgSaved_;
  494.                             break;
  495.                         }
  496.                     }
  497.                 }
  498.                 if(itemAlreadySaved_!=null){
  499.                     itemObj_.setId(itemAlreadySaved_.getId());
  500.                 }
  501.             }
  502.         }

  504.     }
  505.     
  506.     @Override
  507.     public ServizioApplicativo get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  508.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId), idMappingResolutionBehaviour);
  509.     }
  510.     
  511.     private ServizioApplicativo getEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  512.     
  513.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  514.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  515.         
  516.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();
  517.                 
  518.         ServizioApplicativo servizioApplicativo = new ServizioApplicativo();
  519.         

  521.         // Object servizioApplicativo
  522.         ISQLQueryObject sqlQueryObjectGet_servizioApplicativo = sqlQueryObjectGet.newSQLQueryObject();
  523.         sqlQueryObjectGet_servizioApplicativo.setANDLogicOperator(true);
  524.         sqlQueryObjectGet_servizioApplicativo.addFromTable(this.getServizioApplicativoFieldConverter().toTable(ServizioApplicativo.model()));
  525.         sqlQueryObjectGet_servizioApplicativo.addSelectField("id");
  526.         sqlQueryObjectGet_servizioApplicativo.addSelectField(this.getServizioApplicativoFieldConverter().toColumn(ServizioApplicativo.model().NOME,true));
  527.         sqlQueryObjectGet_servizioApplicativo.addSelectField(this.getServizioApplicativoFieldConverter().toColumn(ServizioApplicativo.model().TIPOLOGIA_FRUIZIONE,true));
  528.         sqlQueryObjectGet_servizioApplicativo.addSelectField(this.getServizioApplicativoFieldConverter().toColumn(ServizioApplicativo.model().TIPOLOGIA_EROGAZIONE,true));
  529.         sqlQueryObjectGet_servizioApplicativo.addSelectField(this.getServizioApplicativoFieldConverter().toColumn(ServizioApplicativo.model().TIPO,true));
  530.         sqlQueryObjectGet_servizioApplicativo.addSelectField(this.getServizioApplicativoFieldConverter().toColumn(ServizioApplicativo.model().AS_CLIENT,true));
  531.         sqlQueryObjectGet_servizioApplicativo.addSelectField(this.getServizioApplicativoFieldConverter().toColumn(ServizioApplicativo.model().TIPOAUTH,true));
  532.         sqlQueryObjectGet_servizioApplicativo.addSelectField(this.getServizioApplicativoFieldConverter().toColumn(ServizioApplicativo.model().UTENTE,true));
  533.         sqlQueryObjectGet_servizioApplicativo.addSelectField(this.getServizioApplicativoFieldConverter().toColumn(ServizioApplicativo.model().TOKEN_POLICY,true));
  534.         sqlQueryObjectGet_servizioApplicativo.addWhereCondition("id=?");

  536.         // Get servizioApplicativo
  537.         servizioApplicativo = (ServizioApplicativo) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_servizioApplicativo.createSQLQuery(), jdbcProperties.isShowSql(), ServizioApplicativo.model(), this.getServizioApplicativoFetch(),
  538.             new JDBCObject(tableId,Long.class));


  541.         // Object _servizioApplicativo_soggetto (recupero id)
  542.         ISQLQueryObject sqlQueryObjectGet_servizioApplicativo_soggetto_readFkId = sqlQueryObjectGet.newSQLQueryObject();
  543.         sqlQueryObjectGet_servizioApplicativo_soggetto_readFkId.addFromTable(CostantiDB.SERVIZI_APPLICATIVI);
  544.         sqlQueryObjectGet_servizioApplicativo_soggetto_readFkId.addSelectField("id_soggetto");
  545.         sqlQueryObjectGet_servizioApplicativo_soggetto_readFkId.addWhereCondition("id=?");
  546.         sqlQueryObjectGet_servizioApplicativo_soggetto_readFkId.setANDLogicOperator(true);
  547.         Long idFK_servizioApplicativo_soggetto = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_servizioApplicativo_soggetto_readFkId.createSQLQuery(), jdbcProperties.isShowSql(),Long.class,
  548.                 new JDBCObject(servizioApplicativo.getId(),Long.class));
  549.         
  550.         // Object _servizioApplicativo_soggetto
  551.         ISQLQueryObject sqlQueryObjectGet_servizioApplicativo_soggetto = sqlQueryObjectGet.newSQLQueryObject();
  552.         sqlQueryObjectGet_servizioApplicativo_soggetto.addFromTable(CostantiDB.SOGGETTI);
  553.         sqlQueryObjectGet_servizioApplicativo_soggetto.addSelectField("tipo_soggetto");
  554.         sqlQueryObjectGet_servizioApplicativo_soggetto.addSelectField("nome_soggetto");
  555.         sqlQueryObjectGet_servizioApplicativo_soggetto.setANDLogicOperator(true);
  556.         sqlQueryObjectGet_servizioApplicativo_soggetto.addWhereCondition("id=?");

  558.         // Recupero _servizioApplicativo_soggetto
  559.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_servizioApplicativo_soggetto = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  560.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(idFK_servizioApplicativo_soggetto,Long.class)
  561.         };
  562.         List<Class<?>> listaFieldIdReturnType_servizioApplicativo_soggetto = new ArrayList<Class<?>>();
  563.         listaFieldIdReturnType_servizioApplicativo_soggetto.add(String.class);
  564.         listaFieldIdReturnType_servizioApplicativo_soggetto.add(String.class);
  565.         List<Object> listaFieldId_servizioApplicativo_soggetto = jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_servizioApplicativo_soggetto.createSQLQuery(), jdbcProperties.isShowSql(),
  566.                 listaFieldIdReturnType_servizioApplicativo_soggetto, searchParams_servizioApplicativo_soggetto);
  567.         // set _servizioApplicativo_soggetto
  568.         IdSoggetto id_servizioApplicativo_soggetto = new IdSoggetto();
  569.         id_servizioApplicativo_soggetto.setTipo((String)listaFieldId_servizioApplicativo_soggetto.get(0));
  570.         id_servizioApplicativo_soggetto.setNome((String)listaFieldId_servizioApplicativo_soggetto.get(1));
  571.         servizioApplicativo.setIdSoggetto(id_servizioApplicativo_soggetto);

  573.         // Object servizioApplicativo_servizioApplicativoRuolo
  574.         ISQLQueryObject sqlQueryObjectGet_servizioApplicativo_servizioApplicativoRuolo = sqlQueryObjectGet.newSQLQueryObject();
  575.         sqlQueryObjectGet_servizioApplicativo_servizioApplicativoRuolo.setANDLogicOperator(true);
  576.         sqlQueryObjectGet_servizioApplicativo_servizioApplicativoRuolo.addFromTable(this.getServizioApplicativoFieldConverter().toTable(ServizioApplicativo.model().SERVIZIO_APPLICATIVO_RUOLO));
  577.         sqlQueryObjectGet_servizioApplicativo_servizioApplicativoRuolo.addSelectField("id");
  578.         sqlQueryObjectGet_servizioApplicativo_servizioApplicativoRuolo.addSelectField(this.getServizioApplicativoFieldConverter().toColumn(ServizioApplicativo.model().SERVIZIO_APPLICATIVO_RUOLO.NOME,true));
  579.         sqlQueryObjectGet_servizioApplicativo_servizioApplicativoRuolo.addWhereCondition("id_servizio_applicativo=?");

  581.         // Get servizioApplicativo_servizioApplicativoRuolo
  582.         java.util.List<Object> servizioApplicativo_servizioApplicativoRuolo_list = (java.util.List<Object>) jdbcUtilities.executeQuery(sqlQueryObjectGet_servizioApplicativo_servizioApplicativoRuolo.createSQLQuery(), jdbcProperties.isShowSql(), ServizioApplicativo.model().SERVIZIO_APPLICATIVO_RUOLO, this.getServizioApplicativoFetch(),
  583.             new JDBCObject(servizioApplicativo.getId(),Long.class));

  585.         if(servizioApplicativo_servizioApplicativoRuolo_list != null) {
  586.             for (Object servizioApplicativo_servizioApplicativoRuolo_object: servizioApplicativo_servizioApplicativoRuolo_list) {
  587.                 ServizioApplicativoRuolo servizioApplicativo_servizioApplicativoRuolo = (ServizioApplicativoRuolo) servizioApplicativo_servizioApplicativoRuolo_object;


  590.                 servizioApplicativo.addServizioApplicativoRuolo(servizioApplicativo_servizioApplicativoRuolo);
  591.             }
  592.         }

  594.         // Object servizioApplicativo_servizioApplicativoProprietaProtocollo
  595.         ISQLQueryObject sqlQueryObjectGet_servizioApplicativo_servizioApplicativoProprietaProtocollo = sqlQueryObjectGet.newSQLQueryObject();
  596.         sqlQueryObjectGet_servizioApplicativo_servizioApplicativoProprietaProtocollo.setANDLogicOperator(true);
  597.         sqlQueryObjectGet_servizioApplicativo_servizioApplicativoProprietaProtocollo.addFromTable(this.getServizioApplicativoFieldConverter().toTable(ServizioApplicativo.model().SERVIZIO_APPLICATIVO_PROPRIETA_PROTOCOLLO));
  598.         sqlQueryObjectGet_servizioApplicativo_servizioApplicativoProprietaProtocollo.addSelectField("id");
  599.         sqlQueryObjectGet_servizioApplicativo_servizioApplicativoProprietaProtocollo.addSelectField(this.getServizioApplicativoFieldConverter().toColumn(ServizioApplicativo.model().SERVIZIO_APPLICATIVO_PROPRIETA_PROTOCOLLO.NAME,true));
  600.         sqlQueryObjectGet_servizioApplicativo_servizioApplicativoProprietaProtocollo.addSelectField(this.getServizioApplicativoFieldConverter().toColumn(ServizioApplicativo.model().SERVIZIO_APPLICATIVO_PROPRIETA_PROTOCOLLO.VALUE_STRING,true));
  601.         sqlQueryObjectGet_servizioApplicativo_servizioApplicativoProprietaProtocollo.addSelectField(this.getServizioApplicativoFieldConverter().toColumn(ServizioApplicativo.model().SERVIZIO_APPLICATIVO_PROPRIETA_PROTOCOLLO.VALUE_NUMBER,true));
  602.         sqlQueryObjectGet_servizioApplicativo_servizioApplicativoProprietaProtocollo.addSelectField(this.getServizioApplicativoFieldConverter().toColumn(ServizioApplicativo.model().SERVIZIO_APPLICATIVO_PROPRIETA_PROTOCOLLO.VALUE_BOOLEAN,true));
  603.         sqlQueryObjectGet_servizioApplicativo_servizioApplicativoProprietaProtocollo.addWhereCondition("id_proprietario=?");
  604.         sqlQueryObjectGet_servizioApplicativo_servizioApplicativoProprietaProtocollo.addWhereCondition("tipo_proprietario=?");

  606.         // Get servizioApplicativo_servizioApplicativoProprietaProtocollo
  607.         java.util.List<Object> servizioApplicativo_servizioApplicativoProprietaProtocollo_list = (java.util.List<Object>) jdbcUtilities.executeQuery(sqlQueryObjectGet_servizioApplicativo_servizioApplicativoProprietaProtocollo.createSQLQuery(), jdbcProperties.isShowSql(), ServizioApplicativo.model().SERVIZIO_APPLICATIVO_PROPRIETA_PROTOCOLLO, this.getServizioApplicativoFetch(),
  608.             new JDBCObject(servizioApplicativo.getId(),Long.class),
  609.             new JDBCObject(ProprietariProtocolProperty.SERVIZIO_APPLICATIVO.name(),String.class));

  611.         if(servizioApplicativo_servizioApplicativoProprietaProtocollo_list != null) {
  612.             for (Object servizioApplicativo_servizioApplicativoProprietaProtocollo_object: servizioApplicativo_servizioApplicativoProprietaProtocollo_list) {
  613.                 ServizioApplicativoProprietaProtocollo servizioApplicativo_servizioApplicativoProprietaProtocollo = (ServizioApplicativoProprietaProtocollo) servizioApplicativo_servizioApplicativoProprietaProtocollo_object;


  616.                 servizioApplicativo.addServizioApplicativoProprietaProtocollo(servizioApplicativo_servizioApplicativoProprietaProtocollo);
  617.             }
  618.         }               
  619.         
  620.         return servizioApplicativo;  
  621.     
  622.     } 
  623.     
  624.     @Override
  625.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  626.         return this._exists(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  627.     }
  628.     
  629.     private boolean _exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  630.     
  631.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  632.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  633.                 
  634.         boolean existsServizioApplicativo = false;

  636.         sqlQueryObject = sqlQueryObject.newSQLQueryObject();
  637.         sqlQueryObject.setANDLogicOperator(true);

  639.         sqlQueryObject.addFromTable(this.getServizioApplicativoFieldConverter().toTable(ServizioApplicativo.model()));
  640.         sqlQueryObject.addSelectField(this.getServizioApplicativoFieldConverter().toColumn(ServizioApplicativo.model().NOME,true));
  641.         sqlQueryObject.addWhereCondition("id=?");


  644.         // Exists servizioApplicativo
  645.         existsServizioApplicativo = jdbcUtilities.exists(sqlQueryObject.createSQLQuery(), jdbcProperties.isShowSql(),
  646.             new JDBCObject(tableId,Long.class));

  648.         
  649.         return existsServizioApplicativo;
  650.     
  651.     }
  652.     
  653.     private void joinEngine(IExpression expression, ISQLQueryObject sqlQueryObject) throws NotImplementedException, ServiceException, Exception{
  654.     
  655.         if(expression.inUseModel(ServizioApplicativo.model().ID_SOGGETTO,false)){
  656.             String tableName1 = this.getServizioApplicativoFieldConverter().toTable(ServizioApplicativo.model());
  657.             String tableName2 = this.getServizioApplicativoFieldConverter().toTable(ServizioApplicativo.model().ID_SOGGETTO);
  658.             sqlQueryObject.addWhereCondition(tableName1+".id_soggetto="+tableName2+".id");
  659.         }
  660.         if(expression.inUseModel(ServizioApplicativo.model().SERVIZIO_APPLICATIVO_RUOLO,false)){
  661.             String tableName1 = this.getServizioApplicativoFieldConverter().toTable(ServizioApplicativo.model());
  662.             String tableName2 = this.getServizioApplicativoFieldConverter().toTable(ServizioApplicativo.model().SERVIZIO_APPLICATIVO_RUOLO);
  663.             sqlQueryObject.addWhereCondition(tableName1+".id="+tableName2+".id_servizio_applicativo");
  664.         }
  665.         if(expression.inUseModel(ServizioApplicativo.model().SERVIZIO_APPLICATIVO_PROPRIETA_PROTOCOLLO,false)){
  666.             String tableName1 = this.getServizioApplicativoFieldConverter().toTable(ServizioApplicativo.model());
  667.             String tableName2 = this.getServizioApplicativoFieldConverter().toTable(ServizioApplicativo.model().SERVIZIO_APPLICATIVO_PROPRIETA_PROTOCOLLO);
  668.             sqlQueryObject.addWhereCondition(tableName1+".id="+tableName2+".id_proprietario");
  669.             sqlQueryObject.addWhereCondition(tableName2+".tipo_proprietario='"+ProprietariProtocolProperty.SERVIZIO_APPLICATIVO.name()+"'");
  670.         }
  671.     }
  672.     
  673.     protected java.util.List<Object> getRootTablePrimaryKeyValuesEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdServizioApplicativo id) throws NotFoundException, ServiceException, NotImplementedException, Exception{
  674.         // Identificativi
  675.         java.util.List<Object> rootTableIdValues = new java.util.ArrayList<>();
  676.         Long longId = this.findIdServizioApplicativo(jdbcProperties, log, connection, sqlQueryObject.newSQLQueryObject(), id, true);
  677.         rootTableIdValues.add(longId);
  678.         return rootTableIdValues;
  679.     }
  680.     
  681.     protected Map<String, List<IField>> getMapTableToPKColumnEngine() throws NotImplementedException, Exception{
  682.     
  683.         ServizioApplicativoFieldConverter converter = this.getServizioApplicativoFieldConverter();
  684.         Map<String, List<IField>> mapTableToPKColumn = new java.util.HashMap<>();
  685.         UtilsTemplate<IField> utilities = new UtilsTemplate<>();

  687.         // ServizioApplicativo.model()
  688.         mapTableToPKColumn.put(converter.toTable(ServizioApplicativo.model()),
  689.             utilities.newList(
  690.                 new CustomField("id", Long.class, "id", converter.toTable(ServizioApplicativo.model()))
  691.             ));

  693.         // ServizioApplicativo.model().ID_SOGGETTO
  694.         mapTableToPKColumn.put(converter.toTable(ServizioApplicativo.model().ID_SOGGETTO),
  695.             utilities.newList(
  696.                 new CustomField("id", Long.class, "id", converter.toTable(ServizioApplicativo.model().ID_SOGGETTO))
  697.             ));

  699.         // ServizioApplicativo.model().SERVIZIO_APPLICATIVO_RUOLO
  700.         mapTableToPKColumn.put(converter.toTable(ServizioApplicativo.model().SERVIZIO_APPLICATIVO_RUOLO),
  701.             utilities.newList(
  702.                 new CustomField("id", Long.class, "id", converter.toTable(ServizioApplicativo.model().SERVIZIO_APPLICATIVO_RUOLO))
  703.             ));

  705.         // ServizioApplicativo.model().SERVIZIO_APPLICATIVO_PROPRIETA
  706.         mapTableToPKColumn.put(converter.toTable(ServizioApplicativo.model().SERVIZIO_APPLICATIVO_PROPRIETA_PROTOCOLLO),
  707.             utilities.newList(
  708.                 new CustomField("id", Long.class, "id", converter.toTable(ServizioApplicativo.model().SERVIZIO_APPLICATIVO_PROPRIETA_PROTOCOLLO))
  709.             ));

  711.         return mapTableToPKColumn;      
  712.     }
  713.     
  714.     @Override
  715.     public List<Long> findAllTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression paginatedExpression) throws ServiceException, NotImplementedException, Exception {
  716.         
  717.         List<Long> list = new ArrayList<Long>();

  719.         sqlQueryObject.setSelectDistinct(true);
  720.         sqlQueryObject.setANDLogicOperator(true);
  721.         sqlQueryObject.addSelectField(this.getServizioApplicativoFieldConverter().toTable(ServizioApplicativo.model())+".id");
  722.         Class<?> objectIdClass = Long.class;
  723.         
  724.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFindAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  725.                                                 this.getServizioApplicativoFieldConverter(), ServizioApplicativo.model());
  726.         
  727.         joinEngine(paginatedExpression,sqlQueryObject);
  728.         
  729.         List<Object> listObjects = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.findAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  730.                                                                             this.getServizioApplicativoFieldConverter(), ServizioApplicativo.model(), objectIdClass, listaQuery);
  731.         for(Object object: listObjects) {
  732.             list.add((Long)object);
  733.         }

  735.         return list;
  736.         
  737.     }
  738.     
  739.     @Override
  740.     public long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException, Exception {
  741.     
  742.         sqlQueryObject.setSelectDistinct(true);
  743.         sqlQueryObject.setANDLogicOperator(true);
  744.         sqlQueryObject.addSelectField(this.getServizioApplicativoFieldConverter().toTable(ServizioApplicativo.model())+".id");
  745.         Class<?> objectIdClass = Long.class;
  746.         
  747.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFind(jdbcProperties, log, connection, sqlQueryObject, expression,
  748.                                                 this.getServizioApplicativoFieldConverter(), ServizioApplicativo.model());
  749.         
  750.         joinEngine(expression,sqlQueryObject);

  752.         Object res = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.find(jdbcProperties, log, connection, sqlQueryObject, expression,
  753.                                                         this.getServizioApplicativoFieldConverter(), ServizioApplicativo.model(), objectIdClass, listaQuery);
  754.         if(res!=null && (((Long) res).longValue()>0) ){
  755.             return ((Long) res).longValue();
  756.         }
  757.         else{
  758.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  759.         }
  760.         
  761.     }

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

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

  770.         InUse inUse = new InUse();
  771.         inUse.setInUse(false);
  772.         
  773.         /* 
  774.          * TODO: implement code that checks whether the object identified by the id parameter is used by other objects
  775.         */
  776.         
  777.         // Delete this line when you have implemented the method
  778.         int throwNotImplemented = 1;
  779.         if(throwNotImplemented==1){
  780.                 throw new NotImplementedException("NotImplemented");
  781.         }
  782.         // Delete this line when you have implemented the method

  784.         return inUse;

  786.     }
  787.     
  788.     @Override
  789.     public IdServizioApplicativo findId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, boolean throwNotFound)
  790.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  791.         
  792.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  793.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  795.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();               

  797.         // Object _servizioApplicativo
  798.         sqlQueryObjectGet.addFromTable(this.getServizioApplicativoFieldConverter().toTable(ServizioApplicativo.model()));
  799.         sqlQueryObjectGet.addSelectField(this.getServizioApplicativoFieldConverter().toColumn(ServizioApplicativo.model().NOME,true));
  800.         sqlQueryObjectGet.addSelectField("id_soggetto");
  801.         sqlQueryObjectGet.setANDLogicOperator(true);
  802.         sqlQueryObjectGet.addWhereCondition("id=?");

  804.         // Recupero _servizioApplicativo
  805.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_servizioApplicativo = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  806.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(tableId,Long.class)
  807.         };
  808.         List<Class<?>> listaFieldIdReturnType_servizioApplicativo = new ArrayList<Class<?>>();
  809.         listaFieldIdReturnType_servizioApplicativo.add(String.class);
  810.         listaFieldIdReturnType_servizioApplicativo.add(Long.class);
  811.         org.openspcoop2.core.commons.search.IdServizioApplicativo id_servizioApplicativo = null;
  812.         List<Object> listaFieldId_servizioApplicativo = jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  813.                 listaFieldIdReturnType_servizioApplicativo, searchParams_servizioApplicativo);
  814.         if(listaFieldId_servizioApplicativo==null || listaFieldId_servizioApplicativo.size()<=0){
  815.             if(throwNotFound){
  816.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  817.             }
  818.         }
  819.         else{
  820.             // set _servizioApplicativo
  821.             id_servizioApplicativo = new org.openspcoop2.core.commons.search.IdServizioApplicativo();
  822.             id_servizioApplicativo.setNome((String)listaFieldId_servizioApplicativo.get(0));
  823.             
  824.             Long idSoggettoFK = (Long) listaFieldId_servizioApplicativo.get(1);
  825.             id_servizioApplicativo.
  826.                 setIdSoggetto(((IDBSoggettoServiceSearch)this.getServiceManager(connection, jdbcProperties, log).
  827.                         getSoggettoServiceSearch()).findId(idSoggettoFK, true));
  828.         }
  829.         
  830.         return id_servizioApplicativo;
  831.         
  832.     }

  834.     @Override
  835.     public Long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdServizioApplicativo id, boolean throwNotFound)
  836.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  837.     
  838.         return this.findIdServizioApplicativo(jdbcProperties,log,connection,sqlQueryObject,id,throwNotFound);
  839.             
  840.     }
  841.     
  842.     @Override
  843.     public List<List<Object>> nativeQuery(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  844.                                             String sql,List<Class<?>> returnClassTypes,Object ... param) throws ServiceException,NotFoundException,NotImplementedException,Exception{
  845.         
  846.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeQuery(jdbcProperties, log, connection, sqlQueryObject,
  847.                                                                                             sql,returnClassTypes,param);
  848.                                                         
  849.     }
  850.     
  851.     protected Long findIdServizioApplicativo(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdServizioApplicativo id, boolean throwNotFound) throws NotFoundException, ServiceException, NotImplementedException, Exception {

  853.         if(jdbcProperties==null) {
  854.             throw new ServiceException("Param jdbcProperties is null");
  855.         }
  856.         if(sqlQueryObject==null) {
  857.             throw new ServiceException("Param sqlQueryObject is null");
  858.         }
  859.         if(id==null) {
  860.             throw new ServiceException("Param id is null");
  861.         }
  862.         
  863.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  864.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  866.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();

  868.         if(id.getIdSoggetto()==null){
  869.             throw new ServiceException("IdSoggetto non fornito");
  870.         }
  871.         
  872.         // Recupero id soggetto
  873.         ISoggettoServiceSearch soggettoServiceSearch = this.getServiceManager(connection, jdbcProperties, log).getSoggettoServiceSearch();
  874.         Soggetto sa_id_soggetto = ((IDBSoggettoServiceSearch)soggettoServiceSearch).get(id.getIdSoggetto());
  875.         
  876.         // Object _servizioApplicativo
  877.         sqlQueryObjectGet.addFromTable(this.getServizioApplicativoFieldConverter().toTable(ServizioApplicativo.model()));
  878.         sqlQueryObjectGet.addSelectField("id");
  879.         // Devono essere mappati nella where condition i metodi dell'oggetto id.getXXX
  880.         sqlQueryObjectGet.setANDLogicOperator(true);
  881.         sqlQueryObjectGet.setSelectDistinct(true);
  882.         sqlQueryObjectGet.addWhereCondition(this.getServizioApplicativoFieldConverter().toColumn(ServizioApplicativo.model().NOME,true)+"=?");
  883.         sqlQueryObjectGet.addWhereCondition("id_soggetto=?");

  885.         // Recupero _servizioApplicativo
  886.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_servizioApplicativo = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  887.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(id.getNome(),String.class),
  888.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(sa_id_soggetto.getId(),Long.class)
  889.         };
  890.         Long id_servizioApplicativo = null;
  891.         try{
  892.             id_servizioApplicativo = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  893.                         Long.class, searchParams_servizioApplicativo);
  894.         }catch(NotFoundException notFound){
  895.             if(throwNotFound){
  896.                 throw new NotFoundException(notFound);
  897.             }
  898.         }
  899.         if(id_servizioApplicativo==null || id_servizioApplicativo<=0){
  900.             if(throwNotFound){
  901.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  902.             }
  903.         }
  904.         
  905.         return id_servizioApplicativo;
  906.     }
  907. }
Created with JaCoCo 0.8.8.202204050719