JDBCStatisticaSettimanaleServiceSearchImpl.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.StatisticaSettimanale;
  29. import org.openspcoop2.core.statistiche.dao.jdbc.converter.StatisticaSettimanaleFieldConverter;
  30. import org.openspcoop2.core.statistiche.dao.jdbc.fetch.StatisticaSettimanaleFetch;
  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.  * JDBCStatisticaSettimanaleServiceSearchImpl
  59.  *
  60.  * @author Poli Andrea (poli@link.it)
  61.  * @author $Author$
  62.  * @version $Rev$, $Date$
  63.  */
  64. public class JDBCStatisticaSettimanaleServiceSearchImpl implements IJDBCServiceSearchWithoutId<StatisticaSettimanale, JDBCServiceManager> {

  66.     private StatisticaSettimanaleFieldConverter _statisticaSettimanaleFieldConverter = null;
  67.     public StatisticaSettimanaleFieldConverter getStatisticaSettimanaleFieldConverter() {
  68.         if(this._statisticaSettimanaleFieldConverter==null){
  69.             this._statisticaSettimanaleFieldConverter = new StatisticaSettimanaleFieldConverter(this.jdbcServiceManager.getJdbcProperties().getDatabaseType());
  70.         }       
  71.         return this._statisticaSettimanaleFieldConverter;
  72.     }
  73.     @Override
  74.     public ISQLFieldConverter getFieldConverter() {
  75.         return this.getStatisticaSettimanaleFieldConverter();
  76.     }
  77.     
  78.     private StatisticaSettimanaleFetch statisticaSettimanaleFetch = new StatisticaSettimanaleFetch();
  79.     public StatisticaSettimanaleFetch getStatisticaSettimanaleFetch() {
  80.         return this.statisticaSettimanaleFetch;
  81.     }
  82.     @Override
  83.     public IJDBCFetch getFetch() {
  84.         return getStatisticaSettimanaleFetch();
  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<StatisticaSettimanale> findAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException, ServiceException,Exception {

  108.         List<StatisticaSettimanale> list = new ArrayList<StatisticaSettimanale>();
  109.         
  110.         boolean soloColonneIndicizzateFullIndex = StatisticheIndexUtils.isEnabledSoloColonneIndicizzateFullIndex(expression); 
  111.         
  112.         if(soloColonneIndicizzateFullIndex) {
  113.             List<IField> fields = StatisticheIndexUtils.LISTA_COLONNE_INDEX_STAT_SETTIMANALE;
  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((StatisticaSettimanale)this.getStatisticaSettimanaleFetch().fetch(jdbcProperties.getDatabase(), StatisticaSettimanale.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 getStatisticaSettimanaleFetch() sul risultato della select per ottenere un oggetto StatisticaSettimanale
  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.         }

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

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


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

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

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

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

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



  390.     // -- ConstructorExpression 

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


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

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

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

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

  487.         // Get statisticaSettimanale
  488.         statisticaSettimanale = (StatisticaSettimanale) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(), StatisticaSettimanale.model(), this.getStatisticaSettimanaleFetch(),
  489.             new JDBCObject(tableId,Long.class));



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

  530.         // Get statisticaSettimanale_statisticaContenuti
  531.         java.util.List<Object> statisticaSettimanale_statisticaContenuti_list = jdbcUtilities.executeQuery(sqlQueryObjectGet_statisticaSettimanaleContenuti.createSQLQuery(), jdbcProperties.isShowSql(), StatisticaSettimanale.model().STATISTICA_SETTIMANALE_CONTENUTI, this.getStatisticaSettimanaleFetch(),
  532.             new JDBCObject(statisticaSettimanale.getId(),Long.class));

  534.         if(statisticaSettimanale_statisticaContenuti_list != null) {
  535.             for (Object statisticaSettimanale_statisticaContenuti_object: statisticaSettimanale_statisticaContenuti_list) {
  536.                 StatisticaContenuti statisticaSettimanale_statisticaContenuti = (StatisticaContenuti) statisticaSettimanale_statisticaContenuti_object;


  539.                 statisticaSettimanale.addStatisticaSettimanaleContenuti(statisticaSettimanale_statisticaContenuti);
  540.             }
  541.         }

  543.         
  544.         return statisticaSettimanale;  
  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 existsStatisticaSettimanale = false;

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

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


  566.         // Exists statisticaSettimanale
  567.         existsStatisticaSettimanale = jdbcUtilities.exists(sqlQueryObject.createSQLQuery(), jdbcProperties.isShowSql(),
  568.             new JDBCObject(tableId,Long.class));

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

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

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

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

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

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

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

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

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

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

  700.         return inUse;

  702.     }
  703.     

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