JDBCAttivazionePolicyServiceSearchImpl.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.controllo_traffico.dao.jdbc;

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

  28. import org.openspcoop2.core.controllo_traffico.AttivazionePolicy;
  29. import org.openspcoop2.core.controllo_traffico.IdActivePolicy;
  30. import org.openspcoop2.core.controllo_traffico.constants.RuoloPolicy;
  31. import org.openspcoop2.core.controllo_traffico.dao.jdbc.converter.AttivazionePolicyFieldConverter;
  32. import org.openspcoop2.core.controllo_traffico.dao.jdbc.fetch.AttivazionePolicyFetch;
  33. import org.openspcoop2.generic_project.beans.CustomField;
  34. import org.openspcoop2.generic_project.beans.FunctionField;
  35. import org.openspcoop2.generic_project.beans.IField;
  36. import org.openspcoop2.generic_project.beans.InUse;
  37. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  38. import org.openspcoop2.generic_project.beans.Union;
  39. import org.openspcoop2.generic_project.beans.UnionExpression;
  40. import org.openspcoop2.generic_project.dao.jdbc.IJDBCServiceSearchWithId;
  41. import org.openspcoop2.generic_project.dao.jdbc.JDBCExpression;
  42. import org.openspcoop2.generic_project.dao.jdbc.JDBCPaginatedExpression;
  43. import org.openspcoop2.generic_project.dao.jdbc.JDBCServiceManagerProperties;
  44. import org.openspcoop2.generic_project.dao.jdbc.utils.IJDBCFetch;
  45. import org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject;
  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.expression.impl.sql.ISQLFieldConverter;
  52. import org.openspcoop2.generic_project.utils.UtilsTemplate;
  53. import org.openspcoop2.utils.sql.ISQLQueryObject;
  54. import org.slf4j.Logger;

  56. /**     
  57.  * JDBCAttivazionePolicyServiceSearchImpl
  58.  *
  59.  * @author Poli Andrea (poli@link.it)
  60.  * @author $Author$
  61.  * @version $Rev$, $Date$
  62.  */
  63. public class JDBCAttivazionePolicyServiceSearchImpl implements IJDBCServiceSearchWithId<AttivazionePolicy, IdActivePolicy, JDBCServiceManager> {

  65.     private AttivazionePolicyFieldConverter _attivazionePolicyFieldConverter = null;
  66.     public AttivazionePolicyFieldConverter getAttivazionePolicyFieldConverter() {
  67.         if(this._attivazionePolicyFieldConverter==null){
  68.             this._attivazionePolicyFieldConverter = new AttivazionePolicyFieldConverter(this.jdbcServiceManager.getJdbcProperties().getDatabaseType());
  69.         }       
  70.         return this._attivazionePolicyFieldConverter;
  71.     }
  72.     @Override
  73.     public ISQLFieldConverter getFieldConverter() {
  74.         return this.getAttivazionePolicyFieldConverter();
  75.     }
  76.     
  77.     private AttivazionePolicyFetch attivazionePolicyFetch = new AttivazionePolicyFetch();
  78.     public AttivazionePolicyFetch getAttivazionePolicyFetch() {
  79.         return this.attivazionePolicyFetch;
  80.     }
  81.     @Override
  82.     public IJDBCFetch getFetch() {
  83.         return getAttivazionePolicyFetch();
  84.     }
  85.     
  86.     
  87.     private JDBCServiceManager jdbcServiceManager = null;

  89.     @Override
  90.     public void setServiceManager(JDBCServiceManager serviceManager) throws ServiceException{
  91.         this.jdbcServiceManager = serviceManager;
  92.     }
  93.     
  94.     @Override
  95.     public JDBCServiceManager getServiceManager() throws ServiceException{
  96.         return this.jdbcServiceManager;
  97.     }
  98.     

  100.     @Override
  101.     public IdActivePolicy convertToId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, AttivazionePolicy attivazionePolicy) throws NotImplementedException, ServiceException, Exception{
  102.     
  103.         IdActivePolicy idAttivazionePolicy = new IdActivePolicy();
  104.         idAttivazionePolicy.setNome(attivazionePolicy.getIdActivePolicy());
  105.         
  106.         // opzionali
  107.         idAttivazionePolicy.setIdPolicy(attivazionePolicy.getIdPolicy());
  108.         idAttivazionePolicy.setAlias(attivazionePolicy.getAlias());
  109.         idAttivazionePolicy.setEnabled(attivazionePolicy.isEnabled());
  110.         idAttivazionePolicy.setUpdateTime(attivazionePolicy.getUpdateTime());
  111.         idAttivazionePolicy.setPosizione(attivazionePolicy.getPosizione());
  112.         idAttivazionePolicy.setContinuaValutazione(attivazionePolicy.isContinuaValutazione());
  113.         if(attivazionePolicy.getFiltro()!=null) {
  114.             idAttivazionePolicy.setFiltroRuoloPorta(attivazionePolicy.getFiltro().getRuoloPorta());
  115.             idAttivazionePolicy.setFiltroNomePorta(attivazionePolicy.getFiltro().getNomePorta());
  116.         }
  117.         
  118.         return idAttivazionePolicy;
  119.         
  120.     }
  121.     
  122.     @Override
  123.     public AttivazionePolicy get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdActivePolicy id, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {
  124.         Long id_attivazionePolicy = ( (id!=null && id.getId()!=null && id.getId()>0) ? id.getId() : this.findIdAttivazionePolicy(jdbcProperties, log, connection, sqlQueryObject, id, true));
  125.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, id_attivazionePolicy,idMappingResolutionBehaviour);
  126.         
  127.         
  128.     }
  129.     
  130.     @Override
  131.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdActivePolicy id) throws MultipleResultException, NotImplementedException, ServiceException,Exception {

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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



  399.     // -- ConstructorExpression 

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


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

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

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

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

  484.         // Object attivazionePolicy
  485.         sqlQueryObjectGet.setANDLogicOperator(true);
  486.         sqlQueryObjectGet.addFromTable(this.getAttivazionePolicyFieldConverter().toTable(AttivazionePolicy.model()));
  487.         sqlQueryObjectGet.addSelectField("id");
  488.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ID_ACTIVE_POLICY,true));
  489.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ALIAS,true));
  490.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().UPDATE_TIME,true));
  491.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().POSIZIONE,true));
  492.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().CONTINUA_VALUTAZIONE,true));
  493.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ID_POLICY,true));
  494.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ENABLED,true));
  495.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().WARNING_ONLY,true));
  496.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().RIDEFINISCI,true));
  497.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().VALORE,true));
  498.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().VALORE_2,true));
  499.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.ENABLED,true));
  500.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.PROTOCOLLO,true));
  501.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.RUOLO_PORTA,true));
  502.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.NOME_PORTA,true));
  503.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.TIPO_FRUITORE,true));
  504.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.NOME_FRUITORE,true));
  505.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.RUOLO_FRUITORE,true));
  506.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.SERVIZIO_APPLICATIVO_FRUITORE,true));
  507.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.TIPO_EROGATORE,true));
  508.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.NOME_EROGATORE,true));
  509.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.RUOLO_EROGATORE,true));
  510.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.SERVIZIO_APPLICATIVO_EROGATORE,true));
  511.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.TAG,true));
  512.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.TIPO_SERVIZIO,true));
  513.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.NOME_SERVIZIO,true));
  514.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.VERSIONE_SERVIZIO,true));
  515.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.AZIONE,true));
  516.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.TOKEN_CLAIMS,true));
  517.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_ENABLED,true));
  518.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_TIPO,true));
  519.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_NOME,true));
  520.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.INFORMAZIONE_APPLICATIVA_VALORE,true));
  521.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.ENABLED,true));
  522.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.RUOLO_PORTA,true));
  523.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.PROTOCOLLO,true));
  524.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.FRUITORE,true));
  525.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.SERVIZIO_APPLICATIVO_FRUITORE,true));
  526.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.IDENTIFICATIVO_AUTENTICATO,true));
  527.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.TOKEN,true));
  528.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.EROGATORE,true));
  529.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.SERVIZIO_APPLICATIVO_EROGATORE,true));
  530.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.SERVIZIO,true));
  531.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.AZIONE,true));
  532.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_ENABLED,true));
  533.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_TIPO,true));
  534.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().GROUP_BY.INFORMAZIONE_APPLICATIVA_NOME,true));
  535.         sqlQueryObjectGet.addWhereCondition("id=?");

  537.         // Get attivazionePolicy
  538.         attivazionePolicy = (AttivazionePolicy) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(), AttivazionePolicy.model(), this.getAttivazionePolicyFetch(),
  539.             new JDBCObject(tableId,Long.class));



  543.         
  544.         return attivazionePolicy;  
  545.     
  546.     } 
  547.     
  548.     @Override
  549.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  550.         return this._exists(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  551.     }
  552.     
  553.     private boolean _exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  554.     
  555.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  556.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  557.                 
  558.         boolean existsAttivazionePolicy = false;

  560.         sqlQueryObject = sqlQueryObject.newSQLQueryObject();
  561.         sqlQueryObject.setANDLogicOperator(true);

  563.         sqlQueryObject.addFromTable(this.getAttivazionePolicyFieldConverter().toTable(AttivazionePolicy.model()));
  564.         sqlQueryObject.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ID_ACTIVE_POLICY,true));
  565.         sqlQueryObject.addWhereCondition("id=?");


  568.         // Exists attivazionePolicy
  569.         existsAttivazionePolicy = jdbcUtilities.exists(sqlQueryObject.createSQLQuery(), jdbcProperties.isShowSql(),
  570.             new JDBCObject(tableId,Long.class));

  572.         
  573.         return existsAttivazionePolicy;
  574.     
  575.     }
  576.     
  577.     private void joinEngine(IExpression expression, ISQLQueryObject sqlQueryObject) throws NotImplementedException, ServiceException, Exception{
  578.     
  579.         
  580.     }
  581.     
  582.     protected java.util.List<Object> getRootTablePrimaryKeyValuesEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdActivePolicy id) throws NotFoundException, ServiceException, NotImplementedException, Exception{
  583.         // Identificativi
  584.         java.util.List<Object> rootTableIdValues = new java.util.ArrayList<>();
  585.         Long longId = this.findIdAttivazionePolicy(jdbcProperties, log, connection, sqlQueryObject.newSQLQueryObject(), id, true);
  586.         rootTableIdValues.add(longId);
  587.         
  588.         return rootTableIdValues;
  589.     }
  590.     
  591.     protected Map<String, List<IField>> getMapTableToPKColumnEngine() throws NotImplementedException, Exception{
  592.     
  593.         AttivazionePolicyFieldConverter converter = this.getAttivazionePolicyFieldConverter();
  594.         Map<String, List<IField>> mapTableToPKColumn = new java.util.HashMap<>();
  595.         UtilsTemplate<IField> utilities = new UtilsTemplate<>();

  597.         // AttivazionePolicy.model()
  598.         mapTableToPKColumn.put(converter.toTable(AttivazionePolicy.model()),
  599.             utilities.newList(
  600.                 new CustomField("id", Long.class, "id", converter.toTable(AttivazionePolicy.model()))
  601.             ));
  602.         
  603.         return mapTableToPKColumn;      
  604.     }
  605.     
  606.     @Override
  607.     public List<Long> findAllTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression paginatedExpression) throws ServiceException, NotImplementedException, Exception {
  608.         
  609.         List<Long> list = new ArrayList<Long>();

  611.         sqlQueryObject.setSelectDistinct(true);
  612.         sqlQueryObject.setANDLogicOperator(true);
  613.         sqlQueryObject.addSelectField(this.getAttivazionePolicyFieldConverter().toTable(AttivazionePolicy.model())+".id");
  614.         Class<?> objectIdClass = Long.class;
  615.         
  616.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFindAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  617.                                                 this.getAttivazionePolicyFieldConverter(), AttivazionePolicy.model());
  618.         
  619.         joinEngine(paginatedExpression,sqlQueryObject);
  620.         
  621.         List<Object> listObjects = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.findAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  622.                                                                             this.getAttivazionePolicyFieldConverter(), AttivazionePolicy.model(), objectIdClass, listaQuery);
  623.         for(Object object: listObjects) {
  624.             list.add((Long)object);
  625.         }

  627.         return list;
  628.         
  629.     }
  630.     
  631.     @Override
  632.     public long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException, Exception {
  633.     
  634.         sqlQueryObject.setSelectDistinct(true);
  635.         sqlQueryObject.setANDLogicOperator(true);
  636.         sqlQueryObject.addSelectField(this.getAttivazionePolicyFieldConverter().toTable(AttivazionePolicy.model())+".id");
  637.         Class<?> objectIdClass = Long.class;
  638.         
  639.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFind(jdbcProperties, log, connection, sqlQueryObject, expression,
  640.                                                 this.getAttivazionePolicyFieldConverter(), AttivazionePolicy.model());
  641.         
  642.         joinEngine(expression,sqlQueryObject);

  644.         Object res = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.find(jdbcProperties, log, connection, sqlQueryObject, expression,
  645.                                                         this.getAttivazionePolicyFieldConverter(), AttivazionePolicy.model(), objectIdClass, listaQuery);
  646.         if(res!=null && (((Long) res).longValue()>0) ){
  647.             return ((Long) res).longValue();
  648.         }
  649.         else{
  650.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  651.         }
  652.         
  653.     }

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

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

  662.         InUse inUse = new InUse();
  663.         inUse.setInUse(false);
  664.         
  665.         /* 
  666.          * TODO: implement code that checks whether the object identified by the id parameter is used by other objects
  667.         */
  668.         
  669.         // Delete this line when you have implemented the method
  670.         int throwNotImplemented = 1;
  671.         if(throwNotImplemented==1){
  672.                 throw new NotImplementedException("NotImplemented");
  673.         }
  674.         // Delete this line when you have implemented the method

  676.         return inUse;

  678.     }
  679.     
  680.     @Override
  681.     public IdActivePolicy findId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, boolean throwNotFound)
  682.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  683.         
  684.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  685.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  687.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();

  689.         // Object _attivazionePolicy
  690.         sqlQueryObjectGet.addFromTable(this.getAttivazionePolicyFieldConverter().toTable(AttivazionePolicy.model()));
  691.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ID_ACTIVE_POLICY,true));
  692.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ALIAS,true));
  693.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ID_POLICY,true));
  694.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ENABLED,true));
  695.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().UPDATE_TIME,true));
  696.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().POSIZIONE,true));
  697.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().CONTINUA_VALUTAZIONE,true));
  698.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.RUOLO_PORTA,true));
  699.         sqlQueryObjectGet.addSelectField(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().FILTRO.NOME_PORTA,true));
  700.         sqlQueryObjectGet.setANDLogicOperator(true);
  701.         sqlQueryObjectGet.addWhereCondition("id=?");

  703.         // Recupero _attivazionePolicy
  704.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_attivazionePolicy = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  705.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(tableId,Long.class)
  706.         };
  707.         List<Class<?>> listaFieldIdReturnType_attivazionePolicy = new ArrayList<Class<?>>();
  708.         listaFieldIdReturnType_attivazionePolicy.add(AttivazionePolicy.model().ID_ACTIVE_POLICY.getFieldType());
  709.         listaFieldIdReturnType_attivazionePolicy.add(AttivazionePolicy.model().ALIAS.getFieldType());
  710.         listaFieldIdReturnType_attivazionePolicy.add(AttivazionePolicy.model().ID_POLICY.getFieldType());
  711.         listaFieldIdReturnType_attivazionePolicy.add(AttivazionePolicy.model().ENABLED.getFieldType());
  712.         listaFieldIdReturnType_attivazionePolicy.add(AttivazionePolicy.model().UPDATE_TIME.getFieldType());
  713.         listaFieldIdReturnType_attivazionePolicy.add(AttivazionePolicy.model().POSIZIONE.getFieldType());
  714.         listaFieldIdReturnType_attivazionePolicy.add(AttivazionePolicy.model().CONTINUA_VALUTAZIONE.getFieldType());
  715.         listaFieldIdReturnType_attivazionePolicy.add(AttivazionePolicy.model().FILTRO.RUOLO_PORTA.getFieldType());
  716.         listaFieldIdReturnType_attivazionePolicy.add(AttivazionePolicy.model().FILTRO.NOME_PORTA.getFieldType());
  717.         org.openspcoop2.core.controllo_traffico.IdActivePolicy id_attivazionePolicy = null;
  718.         List<Object> listaFieldId_attivazionePolicy = jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  719.                 listaFieldIdReturnType_attivazionePolicy, searchParams_attivazionePolicy);
  720.         if(listaFieldId_attivazionePolicy==null || listaFieldId_attivazionePolicy.size()<=0){
  721.             if(throwNotFound){
  722.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  723.             }
  724.         }
  725.         else{
  726.             // set _attivazionePolicy
  727.             id_attivazionePolicy = new org.openspcoop2.core.controllo_traffico.IdActivePolicy();
  728.             id_attivazionePolicy.setNome((String)listaFieldId_attivazionePolicy.get(0));
  729.             id_attivazionePolicy.setAlias((String)listaFieldId_attivazionePolicy.get(1));
  730.             id_attivazionePolicy.setIdPolicy((String)listaFieldId_attivazionePolicy.get(2));
  731.             id_attivazionePolicy.setEnabled((Boolean)listaFieldId_attivazionePolicy.get(3));
  732.             id_attivazionePolicy.setUpdateTime((Date)listaFieldId_attivazionePolicy.get(4));
  733.             Object posizione = listaFieldId_attivazionePolicy.get(5);
  734.             if(posizione instanceof Integer) {
  735.                 id_attivazionePolicy.setPosizione((Integer)posizione);
  736.             }
  737.             id_attivazionePolicy.setContinuaValutazione((Boolean)listaFieldId_attivazionePolicy.get(6));
  738.             Object ruoloPorta = listaFieldId_attivazionePolicy.get(7);
  739.             if(ruoloPorta!=null) {
  740.                 if(ruoloPorta instanceof RuoloPolicy) {
  741.                     id_attivazionePolicy.setFiltroRuoloPorta((RuoloPolicy)ruoloPorta);
  742.                 }
  743.                 else if(ruoloPorta instanceof String) {
  744.                     id_attivazionePolicy.setFiltroRuoloPorta(RuoloPolicy.toEnumConstant((String)ruoloPorta));
  745.                 }
  746.             }
  747.             Object nomePorta = listaFieldId_attivazionePolicy.get(8);
  748.             if(nomePorta!=null) {
  749.                 if(nomePorta instanceof String) {
  750.                     id_attivazionePolicy.setFiltroNomePorta((String)nomePorta);
  751.                 }
  752.             }
  753.         }
  754.         
  755.         return id_attivazionePolicy;
  756.         
  757.     }

  759.     @Override
  760.     public Long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdActivePolicy id, boolean throwNotFound)
  761.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  762.     
  763.         return this.findIdAttivazionePolicy(jdbcProperties,log,connection,sqlQueryObject,id,throwNotFound);
  764.             
  765.     }
  766.     
  767.     @Override
  768.     public List<List<Object>> nativeQuery(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  769.                                             String sql,List<Class<?>> returnClassTypes,Object ... param) throws ServiceException,NotFoundException,NotImplementedException,Exception{
  770.         
  771.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeQuery(jdbcProperties, log, connection, sqlQueryObject,
  772.                                                                                             sql,returnClassTypes,param);
  773.                                                         
  774.     }
  775.     
  776.     protected Long findIdAttivazionePolicy(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdActivePolicy id, boolean throwNotFound) throws NotFoundException, ServiceException, NotImplementedException, Exception {

  778.         if(jdbcProperties==null) {
  779.             throw new ServiceException("Param jdbcProperties is null");
  780.         }
  781.         if(sqlQueryObject==null) {
  782.             throw new ServiceException("Param sqlQueryObject is null");
  783.         }
  784.         if(id==null) {
  785.             throw new ServiceException("Param id is null");
  786.         }
  787.         
  788.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  789.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  791.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();

  793.         // Object _attivazionePolicy
  794.         sqlQueryObjectGet.addFromTable(this.getAttivazionePolicyFieldConverter().toTable(AttivazionePolicy.model()));
  795.         sqlQueryObjectGet.addSelectField("id");
  796.         // Devono essere mappati nella where condition i metodi dell'oggetto id.getXXX
  797.         sqlQueryObjectGet.setANDLogicOperator(true);
  798.         sqlQueryObjectGet.setSelectDistinct(true);
  799.         sqlQueryObjectGet.addWhereCondition(this.getAttivazionePolicyFieldConverter().toColumn(AttivazionePolicy.model().ID_ACTIVE_POLICY,true)+"=?");

  801.         // Recupero _attivazionePolicy
  802.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_attivazionePolicy = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  803.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(id.getNome(),String.class)
  804.         };
  805.         Long id_attivazionePolicy = null;
  806.         try{
  807.             id_attivazionePolicy = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  808.                         Long.class, searchParams_attivazionePolicy);
  809.         }catch(NotFoundException notFound){
  810.             if(throwNotFound){
  811.                 throw new NotFoundException(notFound);
  812.             }
  813.         }
  814.         if(id_attivazionePolicy==null || id_attivazionePolicy<=0){
  815.             if(throwNotFound){
  816.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  817.             }
  818.         }
  819.         
  820.         return id_attivazionePolicy;
  821.     }
  822. }
Created with JaCoCo 0.8.8.202204050719