JDBCStatisticaOrariaServiceSearchImpl.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.statistiche.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.statistiche.StatisticaContenuti;
  28. import org.openspcoop2.core.statistiche.StatisticaOraria;
  29. import org.openspcoop2.core.statistiche.dao.jdbc.converter.StatisticaOrariaFieldConverter;
  30. import org.openspcoop2.core.statistiche.dao.jdbc.fetch.StatisticaOrariaFetch;
  31. import org.openspcoop2.core.statistiche.utils.AliasTableRicerchePersonalizzate;
  32. import org.openspcoop2.core.statistiche.utils.StatisticheIndexUtils;
  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.IJDBCServiceSearchWithoutId;
  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.openspcoop2.utils.sql.SQLQueryObjectCore;
  55. import org.slf4j.Logger;

  57. /**     
  58.  * JDBCStatisticaOrariaServiceSearchImpl
  59.  *
  60.  * @author Poli Andrea (poli@link.it)
  61.  * @author $Author$
  62.  * @version $Rev$, $Date$
  63.  */
  64. public class JDBCStatisticaOrariaServiceSearchImpl implements IJDBCServiceSearchWithoutId<StatisticaOraria, JDBCServiceManager> {

  66.     private StatisticaOrariaFieldConverter _statisticaOrariaFieldConverter = null;
  67.     public StatisticaOrariaFieldConverter getStatisticaOrariaFieldConverter() {
  68.         if(this._statisticaOrariaFieldConverter==null){
  69.             this._statisticaOrariaFieldConverter = new StatisticaOrariaFieldConverter(this.jdbcServiceManager.getJdbcProperties().getDatabaseType());
  70.         }       
  71.         return this._statisticaOrariaFieldConverter;
  72.     }
  73.     @Override
  74.     public ISQLFieldConverter getFieldConverter() {
  75.         return this.getStatisticaOrariaFieldConverter();
  76.     }
  77.     
  78.     private StatisticaOrariaFetch statisticaOrariaFetch = new StatisticaOrariaFetch();
  79.     public StatisticaOrariaFetch getStatisticaOrariaFetch() {
  80.         return this.statisticaOrariaFetch;
  81.     }
  82.     @Override
  83.     public IJDBCFetch getFetch() {
  84.         return getStatisticaOrariaFetch();
  85.     }
  86.     
  87.     
  88.     private JDBCServiceManager jdbcServiceManager = null;

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

  101.     
  102.     
  103.     
  104.     
  105.     @Override
  106.     public List<StatisticaOraria> findAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException, ServiceException,Exception {

  108.         List<StatisticaOraria> list = new ArrayList<StatisticaOraria>();
  109.         
  110.         boolean soloColonneIndicizzateFullIndex = StatisticheIndexUtils.isEnabledSoloColonneIndicizzateFullIndex(expression); 
  111.         
  112.         if(soloColonneIndicizzateFullIndex) {
  113.             List<IField> fields = StatisticheIndexUtils.LISTA_COLONNE_INDEX_STAT_ORARIA;
  114.             List<Map<String, Object>> returnMap = null;
  115.             try{
  116.                  // Il distinct serve solo se ci sono le ricerche con contenuto.
  117.                 // NOTA: il distinct rende le ricerce inefficenti (ed inoltre non e' utilizzabile con campi clob in oracle)
  118.                 boolean distinct = false;
  119.                 ISQLQueryObject sqlQueryObjectCheckJoin = sqlQueryObject.newSQLQueryObject();
  120.                 joinEngine(expression, sqlQueryObjectCheckJoin);
  121.                 distinct = ((SQLQueryObjectCore)sqlQueryObjectCheckJoin).sizeConditions()>0;
  122.                 
  123.                 // BUG FIX: Siccome tra le colonne lette ci sono dei CLOB, in oracle non e' consentito utilizzare il DISTINCT.
  124.                 // Per questo motivo se c'e' da usare il distinct viene utilizzato il vecchio metodo
  125.                 if(distinct) {
  126.                     //System.out.println("NON EFFICIENTE");
  127.                     
  128.                     List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  129.                     
  130.                     for(Long id: ids) {
  131.                         list.add(this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour));
  132.                     }
  133.                     
  134.                 }
  135.                 else {
  136.                 
  137.                     //System.out.println("EFFICIENTE");
  138.                     
  139.                     returnMap = this.select(jdbcProperties, log, connection, sqlQueryObject, expression, distinct, fields.toArray(new IField[1]));
  140.         
  141.                     for(Map<String, Object> map: returnMap) {
  142.                         list.add((StatisticaOraria)this.getStatisticaOrariaFetch().fetch(jdbcProperties.getDatabase(), StatisticaOraria.model(), map));
  143.                     }
  144.                     
  145.                 }
  146.                     
  147.             }catch(NotFoundException notFound){}
  148.         }
  149.         else {
  150.         
  151.             // TODO: implementazione non efficiente. 
  152.             // Per ottenere una implementazione efficiente:
  153.             // 1. Usare metodo select di questa classe indirizzando esattamente i field necessari
  154.             // 2. Usare metodo getStatisticaOrariaFetch() sul risultato della select per ottenere un oggetto StatisticaOraria
  155.             //    La fetch con la map inserirà nell'oggetto solo i valori estratti 
  156.     
  157.             List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  158.             
  159.             for(Long id: ids) {
  160.                 list.add(this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour));
  161.             }
  162.             
  163.         }

  165.         return list;      
  166.         
  167.     }
  168.     
  169.     @Override
  170.     public StatisticaOraria find(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) 
  171.         throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {

  173.         long id = this.findTableId(jdbcProperties, log, connection, sqlQueryObject, expression);
  174.         if(id>0){
  175.             return this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour);
  176.         }else{
  177.             throw new NotFoundException("Entry with id["+id+"] not found");
  178.         }
  179.         
  180.     }
  181.     
  182.     @Override
  183.     public NonNegativeNumber count(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws NotImplementedException, ServiceException,Exception {
  184.         
  185.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareCount(jdbcProperties, log, connection, sqlQueryObject, expression,
  186.                                                 this.getStatisticaOrariaFieldConverter(), StatisticaOraria.model());
  187.         
  188.         // Il distinct serve solo se ci sono le statistiche con contenuto.
  189.         // NOTA: il distinct rende le ricerce inefficenti (ed inoltre non e' utilizzabile con campi clob in oracle)
  190.         boolean distinct = false;
  191.         ISQLQueryObject sqlQueryObjectCheckJoin = sqlQueryObject.newSQLQueryObject();
  192.         joinEngine(expression, sqlQueryObjectCheckJoin);
  193.         distinct = ((SQLQueryObjectCore)sqlQueryObjectCheckJoin).sizeConditions()>0;
  194.         
  195.         if(!distinct && expression.inUseField(StatisticaOraria.model().STATISTICA_BASE.DATA, true)){
  196.             // uso la prima colonna dell'indice (se c'è la data e non è distinct)
  197.             sqlQueryObject.addSelectCountField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.DATA, true),"tot",distinct);
  198.         }
  199.         else{
  200.             sqlQueryObject.addSelectCountField(this.getStatisticaOrariaFieldConverter().toTable(StatisticaOraria.model())+".id","tot",distinct);
  201.         }
  202.         
  203.         joinEngine(expression,sqlQueryObject);
  204.         
  205.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.count(jdbcProperties, log, connection, sqlQueryObject, expression,
  206.                                                                             this.getStatisticaOrariaFieldConverter(), StatisticaOraria.model(),listaQuery);
  207.     }


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

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

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

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

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



  391.     // -- ConstructorExpression 

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


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

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

  434.     
  435.     @Override
  436.     public StatisticaOraria get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  437.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId), idMappingResolutionBehaviour);
  438.     }
  439.     
  440.     private StatisticaOraria getEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  441.     
  442.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  443.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  444.         
  445.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();
  446.                 
  447.         StatisticaOraria statisticaOraria = new StatisticaOraria();
  448.         

  450.         // Object statisticaOraria
  451.         sqlQueryObjectGet.setANDLogicOperator(true);
  452.         sqlQueryObjectGet.addFromTable(this.getStatisticaOrariaFieldConverter().toTable(StatisticaOraria.model().STATISTICA_BASE));
  453.         sqlQueryObjectGet.addSelectField("id");
  454.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.DATA,true));
  455.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.STATO_RECORD,true));
  456.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.ID_PORTA,true));
  457.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.TIPO_PORTA,true));
  458.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.TIPO_MITTENTE,true));
  459.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.MITTENTE,true));
  460.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.TIPO_DESTINATARIO,true));
  461.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.DESTINATARIO,true));
  462.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.TIPO_SERVIZIO,true));
  463.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.SERVIZIO,true));
  464.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.VERSIONE_SERVIZIO,true));
  465.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.AZIONE,true));
  466.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.SERVIZIO_APPLICATIVO,true));
  467.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.TRASPORTO_MITTENTE,true));
  468.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.TOKEN_ISSUER,true));
  469.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.TOKEN_CLIENT_ID,true));
  470.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.TOKEN_SUBJECT,true));
  471.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.TOKEN_USERNAME,true));
  472.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.TOKEN_MAIL,true));
  473.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.ESITO,true));
  474.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.ESITO_CONTESTO,true));
  475.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.CLIENT_ADDRESS,true));
  476.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.GRUPPI,true));
  477.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.URI_API,true));
  478.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.CLUSTER_ID,true));
  479.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.NUMERO_TRANSAZIONI,true));
  480.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.DIMENSIONI_BYTES_BANDA_COMPLESSIVA,true));
  481.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.DIMENSIONI_BYTES_BANDA_INTERNA,true));
  482.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.DIMENSIONI_BYTES_BANDA_ESTERNA,true));
  483.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.LATENZA_TOTALE,true));
  484.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.LATENZA_PORTA,true));
  485.         sqlQueryObjectGet.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_BASE.LATENZA_SERVIZIO,true));
  486.         sqlQueryObjectGet.addWhereCondition("id=?");

  488.         // Get statisticaOraria
  489.         statisticaOraria = (StatisticaOraria) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(), StatisticaOraria.model(), this.getStatisticaOrariaFetch(),
  490.             new JDBCObject(tableId,Long.class));



  494.         // Object statisticaOraria_statisticaContenuti
  495.         ISQLQueryObject sqlQueryObjectGet_statisticaOrariaContenuti = sqlQueryObjectGet.newSQLQueryObject();
  496.         sqlQueryObjectGet_statisticaOrariaContenuti.setANDLogicOperator(true);
  497.         sqlQueryObjectGet_statisticaOrariaContenuti.addFromTable(this.getStatisticaOrariaFieldConverter().toTable(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI));
  498.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField("id");
  499.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.DATA,true));
  500.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.RISORSA_NOME,true));
  501.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.RISORSA_VALORE,true));
  502.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_NOME_1,true));
  503.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_VALORE_1,true));
  504.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_NOME_2,true));
  505.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_VALORE_2,true));
  506.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_NOME_3,true));
  507.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_VALORE_3,true));
  508.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_NOME_4,true));
  509.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_VALORE_4,true));
  510.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_NOME_5,true));
  511.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_VALORE_5,true));
  512.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_NOME_6,true));
  513.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_VALORE_6,true));
  514.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_NOME_7,true));
  515.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_VALORE_7,true));
  516.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_NOME_8,true));
  517.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_VALORE_8,true));
  518.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_NOME_9,true));
  519.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_VALORE_9,true));
  520.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_NOME_10,true));
  521.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.FILTRO_VALORE_10,true));
  522.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.NUMERO_TRANSAZIONI,true));
  523.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.DIMENSIONI_BYTES_BANDA_COMPLESSIVA,true));
  524.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.DIMENSIONI_BYTES_BANDA_INTERNA,true));
  525.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.DIMENSIONI_BYTES_BANDA_ESTERNA,true));
  526.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.LATENZA_TOTALE,true));
  527.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.LATENZA_PORTA,true));
  528.         sqlQueryObjectGet_statisticaOrariaContenuti.addSelectField(this.getStatisticaOrariaFieldConverter().toColumn(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI.LATENZA_SERVIZIO,true));
  529.         sqlQueryObjectGet_statisticaOrariaContenuti.addWhereCondition("id_stat=?");

  531.         // Get statisticaOraria_statisticaContenuti
  532.         java.util.List<Object> statisticaOraria_statisticaContenuti_list = jdbcUtilities.executeQuery(sqlQueryObjectGet_statisticaOrariaContenuti.createSQLQuery(), jdbcProperties.isShowSql(), StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI, this.getStatisticaOrariaFetch(),
  533.             new JDBCObject(statisticaOraria.getId(),Long.class));

  535.         if(statisticaOraria_statisticaContenuti_list != null) {
  536.             for (Object statisticaOraria_statisticaContenuti_object: statisticaOraria_statisticaContenuti_list) {
  537.                 StatisticaContenuti statisticaOraria_statisticaContenuti = (StatisticaContenuti) statisticaOraria_statisticaContenuti_object;


  540.                 statisticaOraria.addStatisticaOrariaContenuti(statisticaOraria_statisticaContenuti);
  541.             }
  542.         }

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

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

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


  567.         // Exists statisticaOraria
  568.         existsStatisticaOraria = jdbcUtilities.exists(sqlQueryObject.createSQLQuery(), jdbcProperties.isShowSql(),
  569.             new JDBCObject(tableId,Long.class));

  571.         
  572.         return existsStatisticaOraria;
  573.     
  574.     }
  575.     
  576.     private void joinEngine(IExpression expression, ISQLQueryObject sqlQueryObject) throws NotImplementedException, ServiceException, Exception{
  577.     
  578.         AliasTableRicerchePersonalizzate.join(expression, sqlQueryObject, StatisticaOraria.model().STATISTICA_BASE, 
  579.                 StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI, this.getFieldConverter());
  580.         
  581.     }
  582.     
  583.     protected java.util.List<Object> getRootTablePrimaryKeyValuesEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, StatisticaOraria statisticaOraria) throws NotFoundException, ServiceException, NotImplementedException, Exception{
  584.         // Identificativi
  585.         java.util.List<Object> rootTableIdValues = new java.util.ArrayList<>();
  586.         rootTableIdValues.add(statisticaOraria.getId());
  587.         return rootTableIdValues;
  588.     }
  589.     
  590.     protected Map<String, List<IField>> getMapTableToPKColumnEngine() throws NotImplementedException, Exception{
  591.     
  592.         StatisticaOrariaFieldConverter converter = this.getStatisticaOrariaFieldConverter();
  593.         Map<String, List<IField>> mapTableToPKColumn = new java.util.HashMap<>();
  594.         UtilsTemplate<IField> utilities = new UtilsTemplate<>();

  596.         // StatisticaOraria.model()
  597.         mapTableToPKColumn.put(converter.toTable(StatisticaOraria.model()),
  598.             utilities.newList(
  599.                 new CustomField("id", Long.class, "id", converter.toTable(StatisticaOraria.model()))
  600.             ));

  602.         // StatisticaOraria.model().STATISTICA_BASE
  603.         mapTableToPKColumn.put(converter.toTable(StatisticaOraria.model().STATISTICA_BASE),
  604.             utilities.newList(
  605.                 new CustomField("id", Long.class, "id", converter.toTable(StatisticaOraria.model().STATISTICA_BASE))
  606.             ));

  608.         // StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI
  609.         mapTableToPKColumn.put(converter.toTable(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI),
  610.             utilities.newList(
  611.                 new CustomField("id", Long.class, "id", converter.toTable(StatisticaOraria.model().STATISTICA_ORARIA_CONTENUTI))
  612.             ));
  613.         
  614.         return mapTableToPKColumn;      
  615.     }
  616.     
  617.     @Override
  618.     public List<Long> findAllTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression paginatedExpression) throws ServiceException, NotImplementedException, Exception {
  619.         
  620.         List<Long> list = new ArrayList<Long>();

  622.         // Il distinct serve solo se ci sono le statistiche con contenuto.
  623.         // NOTA: il distinct rende le ricerce inefficenti (ed inoltre non e' utilizzabile con campi clob in oracle)
  624.         boolean distinct = false;
  625.         ISQLQueryObject sqlQueryObjectCheckJoin = sqlQueryObject.newSQLQueryObject();
  626.         joinEngine(paginatedExpression, sqlQueryObjectCheckJoin);
  627.         distinct = ((SQLQueryObjectCore)sqlQueryObjectCheckJoin).sizeConditions()>0;
  628.         
  629.         sqlQueryObject.setSelectDistinct(distinct);
  630.         sqlQueryObject.setANDLogicOperator(true);
  631.         sqlQueryObject.addSelectField(this.getStatisticaOrariaFieldConverter().toTable(StatisticaOraria.model())+".id");
  632.         Class<?> objectIdClass = Long.class;
  633.         
  634.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFindAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  635.                                                 this.getStatisticaOrariaFieldConverter(), StatisticaOraria.model());
  636.         
  637.         joinEngine(paginatedExpression,sqlQueryObject);
  638.         
  639.         List<Object> listObjects = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.findAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  640.                                                                             this.getStatisticaOrariaFieldConverter(), StatisticaOraria.model(), objectIdClass, listaQuery);
  641.         for(Object object: listObjects) {
  642.             list.add((Long)object);
  643.         }

  645.         return list;
  646.         
  647.     }
  648.     
  649.     @Override
  650.     public long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException, Exception {
  651.     
  652.         // Il distinct serve solo se ci sono le statistiche con contenuto.
  653.         // NOTA: il distinct rende le ricerce inefficenti (ed inoltre non e' utilizzabile con campi clob in oracle)
  654.         boolean distinct = false;
  655.         ISQLQueryObject sqlQueryObjectCheckJoin = sqlQueryObject.newSQLQueryObject();
  656.         joinEngine(expression, sqlQueryObjectCheckJoin);
  657.         distinct = ((SQLQueryObjectCore)sqlQueryObjectCheckJoin).sizeConditions()>0;
  658.         
  659.         sqlQueryObject.setSelectDistinct(distinct);
  660.         sqlQueryObject.setANDLogicOperator(true);
  661.         sqlQueryObject.addSelectField(this.getStatisticaOrariaFieldConverter().toTable(StatisticaOraria.model())+".id");
  662.         Class<?> objectIdClass = Long.class;
  663.         
  664.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFind(jdbcProperties, log, connection, sqlQueryObject, expression,
  665.                                                 this.getStatisticaOrariaFieldConverter(), StatisticaOraria.model());
  666.         
  667.         joinEngine(expression,sqlQueryObject);

  669.         Object res = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.find(jdbcProperties, log, connection, sqlQueryObject, expression,
  670.                                                         this.getStatisticaOrariaFieldConverter(), StatisticaOraria.model(), objectIdClass, listaQuery);
  671.         if(res!=null && (((Long) res).longValue()>0) ){
  672.             return ((Long) res).longValue();
  673.         }
  674.         else{
  675.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  676.         }
  677.         
  678.     }

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

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

  687.         InUse inUse = new InUse();
  688.         inUse.setInUse(false);
  689.         
  690.         /* 
  691.          * TODO: implement code that checks whether the object identified by the id parameter is used by other objects
  692.         */
  693.         
  694.         // Delete this line when you have implemented the method
  695.         int throwNotImplemented = 1;
  696.         if(throwNotImplemented==1){
  697.                 throw new NotImplementedException("NotImplemented");
  698.         }
  699.         // Delete this line when you have implemented the method

  701.         return inUse;

  703.     }
  704.     

  706.     
  707.     @Override
  708.     public List<List<Object>> nativeQuery(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  709.                                             String sql,List<Class<?>> returnClassTypes,Object ... param) throws ServiceException,NotFoundException,NotImplementedException,Exception{
  710.         
  711.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeQuery(jdbcProperties, log, connection, sqlQueryObject,
  712.                                                                                             sql,returnClassTypes,param);
  713.                                                         
  714.     }
  715.     
  716. }
Created with JaCoCo 0.8.8.202204050719