JDBCSoggettoRuoloServiceSearchImpl.java

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

  22. import java.sql.Connection;
  23. import java.util.ArrayList;
  24. import java.util.List;
  25. import java.util.Map;

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

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

  69.     private SoggettoRuoloFieldConverter _soggettoRuoloFieldConverter = null;
  70.     public SoggettoRuoloFieldConverter getSoggettoRuoloFieldConverter() {
  71.         if(this._soggettoRuoloFieldConverter==null){
  72.             this._soggettoRuoloFieldConverter = new SoggettoRuoloFieldConverter(this.jdbcServiceManager.getJdbcProperties().getDatabaseType());
  73.         }       
  74.         return this._soggettoRuoloFieldConverter;
  75.     }
  76.     @Override
  77.     public ISQLFieldConverter getFieldConverter() {
  78.         return this.getSoggettoRuoloFieldConverter();
  79.     }
  80.     
  81.     private SoggettoRuoloFetch soggettoRuoloFetch = new SoggettoRuoloFetch();
  82.     public SoggettoRuoloFetch getSoggettoRuoloFetch() {
  83.         return this.soggettoRuoloFetch;
  84.     }
  85.     @Override
  86.     public IJDBCFetch getFetch() {
  87.         return getSoggettoRuoloFetch();
  88.     }
  89.     
  90.     
  91.     private JDBCServiceManager jdbcServiceManager = null;

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

  107.     @Override
  108.     public IdSoggettoRuolo convertToId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, SoggettoRuolo soggettoRuolo) throws NotImplementedException, ServiceException, Exception{
  109.     
  110.         IdSoggettoRuolo idSoggettoRuolo = new IdSoggettoRuolo();
  111.         idSoggettoRuolo.setIdRuolo(soggettoRuolo.getIdRuolo());
  112.         idSoggettoRuolo.setIdSoggetto(soggettoRuolo.getIdSoggetto());
  113.         return idSoggettoRuolo;
  114.     }
  115.     
  116.     @Override
  117.     public SoggettoRuolo get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdSoggettoRuolo id, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {
  118.         Long id_soggettoRuolo = ( (id!=null && id.getId()!=null && id.getId()>0) ? id.getId() : this.findIdSoggettoRuolo(jdbcProperties, log, connection, sqlQueryObject, id, true));
  119.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, id_soggettoRuolo,idMappingResolutionBehaviour);
  120.         
  121.         
  122.     }
  123.     
  124.     @Override
  125.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdSoggettoRuolo id) throws MultipleResultException, NotImplementedException, ServiceException,Exception {

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

  135.         List<IdSoggettoRuolo> list = new ArrayList<IdSoggettoRuolo>();

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

  144.         List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  145.         
  146.         for(Long id: ids) {
  147.             SoggettoRuolo soggettoRuolo = this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour);
  148.             IdSoggettoRuolo idSoggettoRuolo = this.convertToId(jdbcProperties,log,connection,sqlQueryObject,soggettoRuolo);
  149.             list.add(idSoggettoRuolo);
  150.         }

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

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

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

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

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

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

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

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

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

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

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



  393.     // -- ConstructorExpression 

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


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

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

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

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

  478.         // Object soggettoRuolo
  479.         ISQLQueryObject sqlQueryObjectGet_soggettoRuolo = sqlQueryObjectGet.newSQLQueryObject();
  480.         sqlQueryObjectGet_soggettoRuolo.setANDLogicOperator(true);
  481.         sqlQueryObjectGet_soggettoRuolo.addFromTable(this.getSoggettoRuoloFieldConverter().toTable(SoggettoRuolo.model()));
  482.         sqlQueryObjectGet_soggettoRuolo.addSelectField("id");
  483.         sqlQueryObjectGet_soggettoRuolo.addWhereCondition("id=?");

  485.         // Get soggettoRuolo
  486.         soggettoRuolo = (SoggettoRuolo) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_soggettoRuolo.createSQLQuery(), jdbcProperties.isShowSql(), SoggettoRuolo.model(), this.getSoggettoRuoloFetch(),
  487.             new JDBCObject(tableId,Long.class));


  490.         if(idMappingResolutionBehaviour==null ||
  491.             (org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour) || org.openspcoop2.generic_project.beans.IDMappingBehaviour.USE_TABLE_ID.equals(idMappingResolutionBehaviour))
  492.         ){
  493.             // Object _soggettoRuolo_ruolo (recupero id)
  494.             ISQLQueryObject sqlQueryObjectGet_soggettoRuolo_ruolo_readFkId = sqlQueryObjectGet.newSQLQueryObject();
  495.             sqlQueryObjectGet_soggettoRuolo_ruolo_readFkId.addFromTable(this.getSoggettoRuoloFieldConverter().toTable(org.openspcoop2.core.commons.search.SoggettoRuolo.model()));
  496.             sqlQueryObjectGet_soggettoRuolo_ruolo_readFkId.addSelectField("id_ruolo");
  497.             sqlQueryObjectGet_soggettoRuolo_ruolo_readFkId.addWhereCondition("id=?");
  498.             sqlQueryObjectGet_soggettoRuolo_ruolo_readFkId.setANDLogicOperator(true);
  499.             Long idFK_soggettoRuolo_ruolo = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_soggettoRuolo_ruolo_readFkId.createSQLQuery(), jdbcProperties.isShowSql(),Long.class,
  500.                     new JDBCObject(soggettoRuolo.getId(),Long.class));
  501.             
  502.             org.openspcoop2.core.commons.search.IdRuolo id_soggettoRuolo_ruolo = null;
  503.             if(idMappingResolutionBehaviour==null || org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour)){
  504.                 id_soggettoRuolo_ruolo = ((JDBCRuoloServiceSearch)(this.getServiceManager(connection, jdbcProperties, log).getRuoloServiceSearch())).findId(idFK_soggettoRuolo_ruolo, false);
  505.             }else{
  506.                 id_soggettoRuolo_ruolo = new org.openspcoop2.core.commons.search.IdRuolo();
  507.             }
  508.             id_soggettoRuolo_ruolo.setId(idFK_soggettoRuolo_ruolo);
  509.             soggettoRuolo.setIdRuolo(id_soggettoRuolo_ruolo);
  510.         }

  512.         if(idMappingResolutionBehaviour==null ||
  513.             (org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour) || org.openspcoop2.generic_project.beans.IDMappingBehaviour.USE_TABLE_ID.equals(idMappingResolutionBehaviour))
  514.         ){
  515.             // Object _soggettoRuolo_soggetto (recupero id)
  516.             ISQLQueryObject sqlQueryObjectGet_soggettoRuolo_soggetto_readFkId = sqlQueryObjectGet.newSQLQueryObject();
  517.             sqlQueryObjectGet_soggettoRuolo_soggetto_readFkId.addFromTable(this.getSoggettoRuoloFieldConverter().toTable(org.openspcoop2.core.commons.search.SoggettoRuolo.model()));
  518.             sqlQueryObjectGet_soggettoRuolo_soggetto_readFkId.addSelectField("id_soggetto");
  519.             sqlQueryObjectGet_soggettoRuolo_soggetto_readFkId.addWhereCondition("id=?");
  520.             sqlQueryObjectGet_soggettoRuolo_soggetto_readFkId.setANDLogicOperator(true);
  521.             Long idFK_soggettoRuolo_soggetto = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_soggettoRuolo_soggetto_readFkId.createSQLQuery(), jdbcProperties.isShowSql(),Long.class,
  522.                     new JDBCObject(soggettoRuolo.getId(),Long.class));
  523.             
  524.             org.openspcoop2.core.commons.search.IdSoggetto id_soggettoRuolo_soggetto = null;
  525.             if(idMappingResolutionBehaviour==null || org.openspcoop2.generic_project.beans.IDMappingBehaviour.ENABLED.equals(idMappingResolutionBehaviour)){
  526.                 id_soggettoRuolo_soggetto = ((JDBCSoggettoServiceSearch)(this.getServiceManager(connection, jdbcProperties, log).getSoggettoServiceSearch())).findId(idFK_soggettoRuolo_soggetto, false);
  527.             }else{
  528.                 id_soggettoRuolo_soggetto = new org.openspcoop2.core.commons.search.IdSoggetto();
  529.             }
  530.             id_soggettoRuolo_soggetto.setId(idFK_soggettoRuolo_soggetto);
  531.             soggettoRuolo.setIdSoggetto(id_soggettoRuolo_soggetto);
  532.         }

  534.         return soggettoRuolo;  
  535.     
  536.     } 
  537.     
  538.     @Override
  539.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  540.         return this._exists(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  541.     }
  542.     
  543.     private boolean _exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  544.     
  545.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  546.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  547.                 
  548.         boolean existsSoggettoRuolo = false;

  550.         sqlQueryObject = sqlQueryObject.newSQLQueryObject();
  551.         sqlQueryObject.setANDLogicOperator(true);

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


  556.         // Exists soggettoRuolo
  557.         existsSoggettoRuolo = jdbcUtilities.exists(sqlQueryObject.createSQLQuery(), jdbcProperties.isShowSql(),
  558.             new JDBCObject(tableId,Long.class));

  560.         
  561.         return existsSoggettoRuolo;
  562.     
  563.     }
  564.     
  565.     private void joinEngine(IExpression expression, ISQLQueryObject sqlQueryObject) throws NotImplementedException, ServiceException, Exception{
  566.     
  567.         if(expression.inUseModel(SoggettoRuolo.model().ID_RUOLO,false)){
  568.             String tableName1 = this.getSoggettoRuoloFieldConverter().toAliasTable(SoggettoRuolo.model());
  569.             String tableName2 = this.getSoggettoRuoloFieldConverter().toAliasTable(SoggettoRuolo.model().ID_RUOLO);
  570.             sqlQueryObject.addWhereCondition(tableName1+".id_ruolo="+tableName2+".id");
  571.         }
  572.         if(expression.inUseModel(SoggettoRuolo.model().ID_SOGGETTO,false)){
  573.             String tableName1 = this.getSoggettoRuoloFieldConverter().toAliasTable(SoggettoRuolo.model());
  574.             String tableName2 = this.getSoggettoRuoloFieldConverter().toAliasTable(SoggettoRuolo.model().ID_SOGGETTO);
  575.             sqlQueryObject.addWhereCondition(tableName1+".id_soggetto="+tableName2+".id");
  576.         }
  577.     
  578.     }
  579.     
  580.     protected java.util.List<Object> getRootTablePrimaryKeyValuesEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdSoggettoRuolo id) throws NotFoundException, ServiceException, NotImplementedException, Exception{
  581.         // Identificativi
  582.         java.util.List<Object> rootTableIdValues = new java.util.ArrayList<>();
  583.         Long longId = this.findIdSoggettoRuolo(jdbcProperties, log, connection, sqlQueryObject.newSQLQueryObject(), id, true);
  584.         rootTableIdValues.add(longId);
  585.         return rootTableIdValues;
  586.     }
  587.     
  588.     protected Map<String, List<IField>> getMapTableToPKColumnEngine() throws NotImplementedException, Exception{
  589.     
  590.         SoggettoRuoloFieldConverter converter = this.getSoggettoRuoloFieldConverter();
  591.         Map<String, List<IField>> mapTableToPKColumn = new java.util.HashMap<>();
  592.         UtilsTemplate<IField> utilities = new UtilsTemplate<>();

  594.         // SoggettoRuolo.model()
  595.         mapTableToPKColumn.put(converter.toTable(SoggettoRuolo.model()),
  596.             utilities.newList(
  597.                 new CustomField("id", Long.class, "id", converter.toTable(SoggettoRuolo.model()))
  598.             ));

  600.         // SoggettoRuolo.model().ID_RUOLO
  601.         mapTableToPKColumn.put(converter.toTable(SoggettoRuolo.model().ID_RUOLO),
  602.             utilities.newList(
  603.                 new CustomField("id", Long.class, "id", converter.toTable(SoggettoRuolo.model().ID_RUOLO))
  604.             ));

  606.         // SoggettoRuolo.model().ID_SOGGETTO
  607.         mapTableToPKColumn.put(converter.toTable(SoggettoRuolo.model().ID_SOGGETTO),
  608.             utilities.newList(
  609.                 new CustomField("id", Long.class, "id", converter.toTable(SoggettoRuolo.model().ID_SOGGETTO))
  610.             ));

  612.         return mapTableToPKColumn;      
  613.     }
  614.     
  615.     @Override
  616.     public List<Long> findAllTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression paginatedExpression) throws ServiceException, NotImplementedException, Exception {
  617.         
  618.         List<Long> list = new ArrayList<Long>();

  620.         sqlQueryObject.setSelectDistinct(true);
  621.         sqlQueryObject.setANDLogicOperator(true);
  622.         sqlQueryObject.addSelectField(this.getSoggettoRuoloFieldConverter().toTable(SoggettoRuolo.model())+".id");
  623.         Class<?> objectIdClass = Long.class;
  624.         
  625.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFindAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  626.                                                 this.getSoggettoRuoloFieldConverter(), SoggettoRuolo.model());
  627.         
  628.         joinEngine(paginatedExpression,sqlQueryObject);
  629.         
  630.         List<Object> listObjects = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.findAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  631.                                                                             this.getSoggettoRuoloFieldConverter(), SoggettoRuolo.model(), objectIdClass, listaQuery);
  632.         for(Object object: listObjects) {
  633.             list.add((Long)object);
  634.         }

  636.         return list;
  637.         
  638.     }
  639.     
  640.     @Override
  641.     public long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException, Exception {
  642.     
  643.         sqlQueryObject.setSelectDistinct(true);
  644.         sqlQueryObject.setANDLogicOperator(true);
  645.         sqlQueryObject.addSelectField(this.getSoggettoRuoloFieldConverter().toTable(SoggettoRuolo.model())+".id");
  646.         Class<?> objectIdClass = Long.class;
  647.         
  648.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFind(jdbcProperties, log, connection, sqlQueryObject, expression,
  649.                                                 this.getSoggettoRuoloFieldConverter(), SoggettoRuolo.model());
  650.         
  651.         joinEngine(expression,sqlQueryObject);

  653.         Object res = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.find(jdbcProperties, log, connection, sqlQueryObject, expression,
  654.                                                         this.getSoggettoRuoloFieldConverter(), SoggettoRuolo.model(), objectIdClass, listaQuery);
  655.         if(res!=null && (((Long) res).longValue()>0) ){
  656.             return ((Long) res).longValue();
  657.         }
  658.         else{
  659.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  660.         }
  661.         
  662.     }

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

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

  671.         InUse inUse = new InUse();
  672.         inUse.setInUse(false);
  673.         
  674.         /* 
  675.          * TODO: implement code that checks whether the object identified by the id parameter is used by other objects
  676.         */
  677.         
  678.         // Delete this line when you have implemented the method
  679.         int throwNotImplemented = 1;
  680.         if(throwNotImplemented==1){
  681.                 throw new NotImplementedException("NotImplemented");
  682.         }
  683.         // Delete this line when you have implemented the method

  685.         return inUse;

  687.     }
  688.     
  689.     @Override
  690.     public IdSoggettoRuolo findId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, boolean throwNotFound)
  691.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  692.         
  693.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  694.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  696.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();

  698.         // Object _soggettoRuolo
  699.         sqlQueryObjectGet.addFromTable(this.getSoggettoRuoloFieldConverter().toTable(SoggettoRuolo.model()));
  700.         sqlQueryObjectGet.addSelectField("id_soggetto");
  701.         sqlQueryObjectGet.addSelectField("id_ruolo");
  702.         sqlQueryObjectGet.setANDLogicOperator(true);
  703.         sqlQueryObjectGet.addWhereCondition("id=?");

  705.         // Recupero _soggettoRuolo
  706.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_soggettoRuolo = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  707.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(tableId,Long.class)
  708.         };
  709.         List<Class<?>> listaFieldIdReturnType_soggettoRuolo = new ArrayList<Class<?>>();
  710.         listaFieldIdReturnType_soggettoRuolo.add(Long.class);
  711.         listaFieldIdReturnType_soggettoRuolo.add(Long.class);
  712.         org.openspcoop2.core.commons.search.IdSoggettoRuolo id_soggettoRuolo = null;
  713.         List<Object> listaFieldId_soggettoRuolo = jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  714.                 listaFieldIdReturnType_soggettoRuolo, searchParams_soggettoRuolo);
  715.         if(listaFieldId_soggettoRuolo==null || listaFieldId_soggettoRuolo.size()<=0){
  716.             if(throwNotFound){
  717.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  718.             }
  719.         }
  720.         else{
  721.             // set _soggettoRuolo
  722.             id_soggettoRuolo = new org.openspcoop2.core.commons.search.IdSoggettoRuolo();
  723.             
  724.             IdSoggetto idSoggetto = new IdSoggetto();
  725.             idSoggetto.setId((Long) listaFieldId_soggettoRuolo.get(0));
  726.             Soggetto soggetto = ((IDBSoggettoServiceSearch)this.getServiceManager(connection, jdbcProperties, log).getSoggettoServiceSearch()).get(idSoggetto.getId());
  727.             idSoggetto.setTipo(soggetto.getTipoSoggetto());
  728.             idSoggetto.setNome(soggetto.getNomeSoggetto());
  729.             id_soggettoRuolo.setIdSoggetto(idSoggetto);
  730.             
  731.             IdRuolo idRuolo = new IdRuolo();
  732.             idRuolo.setId((Long) listaFieldId_soggettoRuolo.get(1));
  733.             Ruolo ruolo = ((IDBRuoloServiceSearch)this.getServiceManager(connection, jdbcProperties, log).getRuoloServiceSearch()).get(idRuolo.getId());
  734.             idRuolo.setNome(ruolo.getNome());
  735.             id_soggettoRuolo.setIdRuolo(idRuolo);
  736.             
  737.         }
  738.         
  739.         return id_soggettoRuolo;
  740.         
  741.     }

  743.     @Override
  744.     public Long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdSoggettoRuolo id, boolean throwNotFound)
  745.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  746.     
  747.         return this.findIdSoggettoRuolo(jdbcProperties,log,connection,sqlQueryObject,id,throwNotFound);
  748.             
  749.     }
  750.     
  751.     @Override
  752.     public List<List<Object>> nativeQuery(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  753.                                             String sql,List<Class<?>> returnClassTypes,Object ... param) throws ServiceException,NotFoundException,NotImplementedException,Exception{
  754.         
  755.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeQuery(jdbcProperties, log, connection, sqlQueryObject,
  756.                                                                                             sql,returnClassTypes,param);
  757.                                                         
  758.     }
  759.     
  760.     protected Long findIdSoggettoRuolo(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdSoggettoRuolo id, boolean throwNotFound) throws NotFoundException, ServiceException, NotImplementedException, Exception {

  762.         if(jdbcProperties==null) {
  763.             throw new ServiceException("Param jdbcProperties is null");
  764.         }
  765.         if(sqlQueryObject==null) {
  766.             throw new ServiceException("Param sqlQueryObject is null");
  767.         }
  768.         if(id==null) {
  769.             throw new ServiceException("Param id is null");
  770.         }
  771.         
  772.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  773.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  775.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();

  777.         
  778.         // Object _soggettoRuolo
  779.         sqlQueryObjectGet.addFromTable(this.getSoggettoRuoloFieldConverter().toTable(SoggettoRuolo.model()));
  780.         sqlQueryObjectGet.addSelectField("id");
  781.         // Devono essere mappati nella where condition i metodi dell'oggetto id.getXXX
  782.         sqlQueryObjectGet.setANDLogicOperator(true);
  783.         sqlQueryObjectGet.setSelectDistinct(true);
  784.         sqlQueryObjectGet.addWhereCondition("id_soggetto=?");
  785.         sqlQueryObjectGet.addWhereCondition("id_ruolo=?");

  787.         long idSoggetto = ((IDBSoggettoServiceSearch)this.getServiceManager(connection, jdbcProperties, log).getSoggettoServiceSearch()).findTableId(id.getIdSoggetto(), true);
  788.         long idRuolo = ((IDBRuoloServiceSearch)this.getServiceManager(connection, jdbcProperties, log).getRuoloServiceSearch()).findTableId(id.getIdRuolo(), true);
  789.         
  790.         // Recupero _soggettoRuolo
  791.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_soggettoRuolo = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  792.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(idSoggetto,long.class),
  793.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(idRuolo,long.class)
  794.         };
  795.         Long id_soggettoRuolo = null;
  796.         try{
  797.             id_soggettoRuolo = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  798.                         Long.class, searchParams_soggettoRuolo);
  799.         }catch(NotFoundException notFound){
  800.             if(throwNotFound){
  801.                 throw new NotFoundException(notFound);
  802.             }
  803.         }
  804.         if(id_soggettoRuolo==null || id_soggettoRuolo<=0){
  805.             if(throwNotFound){
  806.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  807.             }
  808.         }
  809.         
  810.         return id_soggettoRuolo;
  811.     }
  812. }
Created with JaCoCo 0.8.8.202204050719