JDBCStatisticaOrariaServiceSearch.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 org.openspcoop2.generic_project.dao.IDBServiceUtilities;
  23. import org.openspcoop2.generic_project.dao.jdbc.IJDBCServiceSearchWithoutId;
  24. import org.openspcoop2.generic_project.beans.InUse;
  25. import org.openspcoop2.generic_project.beans.IField;
  26. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  27. import org.openspcoop2.generic_project.beans.UnionExpression;
  28. import org.openspcoop2.generic_project.beans.Union;
  29. import org.openspcoop2.generic_project.beans.FunctionField;
  30. import org.openspcoop2.generic_project.dao.jdbc.JDBCServiceManagerProperties;
  31. import org.openspcoop2.generic_project.exception.ExpressionException;
  32. import org.openspcoop2.generic_project.exception.MultipleResultException;
  33. import org.openspcoop2.generic_project.exception.NotFoundException;
  34. import org.openspcoop2.generic_project.exception.NotImplementedException;
  35. import org.openspcoop2.generic_project.exception.ServiceException;
  36. import org.openspcoop2.generic_project.exception.ValidationException;
  37. import org.openspcoop2.generic_project.expression.IExpression;
  38. import org.openspcoop2.generic_project.expression.IPaginatedExpression;
  39. import org.openspcoop2.generic_project.expression.impl.sql.ISQLFieldConverter;
  40. import org.openspcoop2.generic_project.dao.jdbc.JDBCExpression;
  41. import org.openspcoop2.generic_project.dao.jdbc.JDBCPaginatedExpression;
  42. import org.openspcoop2.generic_project.dao.jdbc.JDBCProperties;
  43. import org.openspcoop2.generic_project.dao.jdbc.utils.IJDBCFetch;
  44. import org.openspcoop2.generic_project.dao.jdbc.utils.JDBC_SQLObjectFactory;

  46. import org.openspcoop2.core.statistiche.StatisticaOraria;
  47. import org.openspcoop2.core.statistiche.dao.IDBStatisticaOrariaServiceSearch;
  48. import org.openspcoop2.core.statistiche.utils.ProjectInfo;

  50. import java.sql.Connection;
  51. import java.util.List;
  52. import java.util.Map;

  54. import org.slf4j.Logger;
  55. import org.openspcoop2.utils.sql.ISQLQueryObject;

  57. /**     
  58.  * Service can be used to search for the backend objects of type {@link org.openspcoop2.core.statistiche.StatisticaOraria} 
  59.  *
  60.  * @author Poli Andrea (poli@link.it)
  61.  * @author $Author$
  62.  * @version $Rev$, $Date$
  63. */
  64. public class JDBCStatisticaOrariaServiceSearch implements IDBStatisticaOrariaServiceSearch, IDBServiceUtilities<StatisticaOraria> {


  67.     protected JDBCServiceManagerProperties jdbcProperties = null;
  68.     protected JDBCServiceManager jdbcServiceManager = null;
  69.     protected Logger log = null;
  70.     protected IJDBCServiceSearchWithoutId<StatisticaOraria, JDBCServiceManager> serviceSearch = null;
  71.     protected JDBC_SQLObjectFactory jdbcSqlObjectFactory = null;
  72.     public JDBCStatisticaOrariaServiceSearch(JDBCServiceManager jdbcServiceManager) throws ServiceException {
  73.         this.jdbcServiceManager = jdbcServiceManager;
  74.         this.jdbcProperties = jdbcServiceManager.getJdbcProperties();
  75.         this.log = jdbcServiceManager.getLog();
  76.         String msgInit = JDBCStatisticaOrariaServiceSearch.class.getName()+ " initialized";
  77.         this.log.debug(msgInit);
  78.         this.serviceSearch = JDBCProperties.getInstance(org.openspcoop2.core.statistiche.dao.jdbc.JDBCServiceManager.class.getPackage(),ProjectInfo.getInstance()).getServiceSearch("statisticaOraria");
  79.         this.serviceSearch.setServiceManager(new JDBCLimitedServiceManager(this.jdbcServiceManager));
  80.         this.jdbcSqlObjectFactory = new JDBC_SQLObjectFactory();
  81.     }
  82.     
  83.     protected void logError(Exception e) {
  84.         if(e!=null && this.log!=null) {
  85.             this.log.error(e.getMessage(),e);
  86.         }
  87.     }
  88.     protected void logDebug(Exception e) {
  89.         if(e!=null && this.log!=null) {
  90.             this.log.debug(e.getMessage(),e);
  91.         }
  92.     }
  93.     protected void logJDBCExpression(JDBCExpression jdbcExpression) throws ExpressionException{
  94.         if(this.log!=null) {
  95.             String msgDebug = "sql = "+jdbcExpression.toSql();
  96.             this.log.debug(msgDebug);
  97.         }
  98.     }
  99.     protected void logJDBCPaginatedExpression(JDBCPaginatedExpression jdbcPaginatedExpression) throws ExpressionException{
  100.         if(this.log!=null) {
  101.             String msgDebug = "sql = "+jdbcPaginatedExpression.toSql();
  102.             this.log.debug(msgDebug);
  103.         }
  104.     }
  105.     
  106.     private static final String PARAMETER_TYPE_PREFIX = "Parameter (type:";
  107.         
  108.     private ServiceException newServiceExceptionParameterIdMappingResolutionBehaviourIsNull(){
  109.         return new ServiceException(PARAMETER_TYPE_PREFIX+org.openspcoop2.generic_project.beans.IDMappingBehaviour.class.getName()+") 'idMappingResolutionBehaviour' is null");
  110.     }

  112.     protected ServiceException newServiceExceptionParameterExpressionWrongType(IExpression expression){
  113.         return new ServiceException(PARAMETER_TYPE_PREFIX+expression.getClass().getName()+") 'expression' has wrong type, expect "+JDBCExpression.class.getName());
  114.     }
  115.     protected ServiceException newServiceExceptionParameterExpressionIsNull(){
  116.         return new ServiceException(PARAMETER_TYPE_PREFIX+IExpression.class.getName()+") 'expression' is null");
  117.     }
  118.     
  119.     private ServiceException newServiceExceptionParameterPaginatedExpressionIsNull(){
  120.         return new ServiceException(PARAMETER_TYPE_PREFIX+IPaginatedExpression.class.getName()+") 'expression' is null");
  121.     }
  122.     private ServiceException newServiceExceptionParameterPaginatedExpressionIsNullErrorParameterPaginated(){
  123.         return new ServiceException(PARAMETER_TYPE_PREFIX+IPaginatedExpression.class.getName()+") 'paginatedExpression' is null");
  124.     }
  125.     private ServiceException newServiceExceptionParameterPaginatedExpressionWrongType(IPaginatedExpression expression){
  126.         return new ServiceException(PARAMETER_TYPE_PREFIX+expression.getClass().getName()+") 'expression' has wrong type, expect "+JDBCPaginatedExpression.class.getName());
  127.     }
  128.     private ServiceException newServiceExceptionParameterPaginatedExpressionWrongTypeErrorParameterPaginated(IPaginatedExpression paginatedExpression){
  129.         return new ServiceException(PARAMETER_TYPE_PREFIX+paginatedExpression.getClass().getName()+") 'paginatedExpression' has wrong type, expect "+JDBCPaginatedExpression.class.getName());
  130.     }
  131.     
  132.     private ServiceException newServiceExceptionParameterUnionExpressionIsNull(){
  133.         return new ServiceException(PARAMETER_TYPE_PREFIX+UnionExpression.class.getName()+") 'unionExpression' is null");
  134.     }
  135.     
  136.     private ServiceException newServiceExceptionParameterTableIdLessEqualsZero(){
  137.         return new ServiceException("Parameter 'tableId' is less equals 0");
  138.     }
  139.     
  140.     @Override
  141.     public void validate(StatisticaOraria statisticaOraria) throws ServiceException,
  142.             ValidationException, NotImplementedException {
  143.         org.openspcoop2.generic_project.utils.XSDValidator.validate(statisticaOraria, this.log, 
  144.                 org.openspcoop2.core.statistiche.utils.XSDValidator.getXSDValidator(this.log));
  145.     }
  146.     
  147.     @Override
  148.     public IJDBCFetch getFetch() {
  149.         return this.serviceSearch.getFetch();
  150.     }

  152.     @Override
  153.     public ISQLFieldConverter getFieldConverter() {
  154.         return this.serviceSearch.getFieldConverter();
  155.     }
  156.     
  157.         


  160.     

  162.     @Override
  163.     public List<StatisticaOraria> findAll(IPaginatedExpression expression) throws ServiceException, NotImplementedException {

  165.         Connection connection = null;
  166.         try{
  167.             
  168.             // check parameters
  169.             if(expression==null){
  170.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNull();
  171.             }
  172.             if( ! (expression instanceof JDBCPaginatedExpression) ){
  173.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongType(expression);
  174.             }
  175.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) expression;
  176.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  178.             // ISQLQueryObject
  179.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  180.             sqlQueryObject.setANDLogicOperator(true);
  181.             // Connection sql
  182.             connection = this.jdbcServiceManager.getConnection();

  184.             return this.serviceSearch.findAll(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,null);         
  185.     
  186.         }catch(ServiceException | NotImplementedException e){
  187.             this.logError(e); throw e;
  188.         }catch(Exception e){
  189.             this.logError(e); throw new ServiceException("FindAll not completed: "+e.getMessage(),e);
  190.         }finally{
  191.             if(connection!=null){
  192.                 this.jdbcServiceManager.closeConnection(connection);
  193.             }
  194.         }
  195.         
  196.     }
  197.     
  198.     @Override
  199.     public List<StatisticaOraria> findAll(IPaginatedExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws ServiceException, NotImplementedException {

  201.         Connection connection = null;
  202.         try{
  203.             
  204.             // check parameters
  205.             if(idMappingResolutionBehaviour==null){
  206.                 throw this.newServiceExceptionParameterIdMappingResolutionBehaviourIsNull();
  207.             }
  208.             if(expression==null){
  209.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNull();
  210.             }
  211.             if( ! (expression instanceof JDBCPaginatedExpression) ){
  212.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongType(expression);
  213.             }
  214.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) expression;
  215.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  217.             // ISQLQueryObject
  218.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  219.             sqlQueryObject.setANDLogicOperator(true);
  220.             // Connection sql
  221.             connection = this.jdbcServiceManager.getConnection();

  223.             return this.serviceSearch.findAll(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,idMappingResolutionBehaviour);         
  224.     
  225.         }catch(ServiceException | NotImplementedException e){
  226.             this.logError(e); throw e;
  227.         }catch(Exception e){
  228.             this.logError(e); throw new ServiceException("FindAll not completed: "+e.getMessage(),e);
  229.         }finally{
  230.             if(connection!=null){
  231.                 this.jdbcServiceManager.closeConnection(connection);
  232.             }
  233.         }
  234.         
  235.     }

  237.     @Override
  238.     public StatisticaOraria find(IExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException {

  240.         Connection connection = null;
  241.         try{
  242.             
  243.             // check parameters
  244.             if(expression==null){
  245.                 throw this.newServiceExceptionParameterExpressionIsNull();
  246.             }
  247.             if( ! (expression instanceof JDBCExpression) ){
  248.                 throw this.newServiceExceptionParameterExpressionWrongType(expression);
  249.             }
  250.             JDBCExpression jdbcExpression = (JDBCExpression) expression;
  251.             this.logJDBCExpression(jdbcExpression);

  253.             // ISQLQueryObject
  254.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  255.             sqlQueryObject.setANDLogicOperator(true);
  256.             // Connection sql
  257.             connection = this.jdbcServiceManager.getConnection();

  259.             return this.serviceSearch.find(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcExpression,null);         

  261.         }catch(ServiceException | MultipleResultException | NotImplementedException e){
  262.             this.logError(e); throw e;
  263.         }catch(NotFoundException e){
  264.             this.logDebug(e); throw e;
  265.         }catch(Exception e){
  266.             this.logError(e); throw new ServiceException("Find not completed: "+e.getMessage(),e);
  267.         }finally{
  268.             if(connection!=null){
  269.                 this.jdbcServiceManager.closeConnection(connection);
  270.             }
  271.         }
  272.         
  273.     }
  274.     
  275.     @Override
  276.     public StatisticaOraria find(IExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException {

  278.         Connection connection = null;
  279.         try{
  280.             
  281.             // check parameters
  282.             if(idMappingResolutionBehaviour==null){
  283.                 throw this.newServiceExceptionParameterIdMappingResolutionBehaviourIsNull();
  284.             }
  285.             if(expression==null){
  286.                 throw this.newServiceExceptionParameterExpressionIsNull();
  287.             }
  288.             if( ! (expression instanceof JDBCExpression) ){
  289.                 throw this.newServiceExceptionParameterExpressionWrongType(expression);
  290.             }
  291.             JDBCExpression jdbcExpression = (JDBCExpression) expression;
  292.             this.logJDBCExpression(jdbcExpression);

  294.             // ISQLQueryObject
  295.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  296.             sqlQueryObject.setANDLogicOperator(true);
  297.             // Connection sql
  298.             connection = this.jdbcServiceManager.getConnection();

  300.             return this.serviceSearch.find(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcExpression,idMappingResolutionBehaviour);         

  302.         }catch(ServiceException | MultipleResultException | NotImplementedException e){
  303.             this.logError(e); throw e;
  304.         }catch(NotFoundException e){
  305.             this.logDebug(e); throw e;
  306.         }catch(Exception e){
  307.             this.logError(e); throw new ServiceException("Find not completed: "+e.getMessage(),e);
  308.         }finally{
  309.             if(connection!=null){
  310.                 this.jdbcServiceManager.closeConnection(connection);
  311.             }
  312.         }
  313.         
  314.     }

  316.     @Override
  317.     public NonNegativeNumber count(IExpression expression) throws ServiceException, NotImplementedException {

  319.         Connection connection = null;
  320.         try{
  321.             
  322.             // check parameters
  323.             if(expression==null){
  324.                 throw this.newServiceExceptionParameterExpressionIsNull();
  325.             }
  326.             if( ! (expression instanceof JDBCExpression) ){
  327.                 throw this.newServiceExceptionParameterExpressionWrongType(expression);
  328.             }
  329.             JDBCExpression jdbcExpression = (JDBCExpression) expression;
  330.             this.logJDBCExpression(jdbcExpression);
  331.             
  332.             // ISQLQueryObject
  333.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  334.             sqlQueryObject.setANDLogicOperator(true);
  335.             // Connection sql
  336.             connection = this.jdbcServiceManager.getConnection();

  338.             return this.serviceSearch.count(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcExpression);
  339.     
  340.         }catch(ServiceException | NotImplementedException e){
  341.             this.logError(e); throw e;
  342.         }catch(Exception e){
  343.             this.logError(e); throw new ServiceException("Count not completed: "+e.getMessage(),e);
  344.         }finally{
  345.             if(connection!=null){
  346.                 this.jdbcServiceManager.closeConnection(connection);
  347.             }
  348.         }
  349.         
  350.     }

  352.     
  353.     @Override
  354.     public List<Object> select(IPaginatedExpression paginatedExpression, IField field) throws ServiceException,NotFoundException,NotImplementedException {
  355.     
  356.         Connection connection = null;
  357.         try{
  358.             
  359.             // check parameters
  360.             if(paginatedExpression==null){
  361.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNullErrorParameterPaginated();
  362.             }
  363.             if( ! (paginatedExpression instanceof JDBCPaginatedExpression) ){
  364.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongTypeErrorParameterPaginated(paginatedExpression);
  365.             }
  366.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) paginatedExpression;
  367.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  369.             // ISQLQueryObject
  370.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  371.             sqlQueryObject.setANDLogicOperator(true);
  372.             // Connection sql
  373.             connection = this.jdbcServiceManager.getConnection();

  375.             return this.serviceSearch.select(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,field);         
  376.     
  377.         }catch(ServiceException | NotImplementedException e){
  378.             this.logError(e); throw e;
  379.         }catch(NotFoundException e){
  380.             this.logDebug(e); throw e;
  381.         }catch(Exception e){
  382.             this.logError(e); throw new ServiceException("Select 'field' not completed: "+e.getMessage(),e);
  383.         }finally{
  384.             if(connection!=null){
  385.                 this.jdbcServiceManager.closeConnection(connection);
  386.             }
  387.         }
  388.     
  389.     }
  390.     
  391.     @Override
  392.     public List<Object> select(IPaginatedExpression paginatedExpression, boolean distinct, IField field) throws ServiceException,NotFoundException,NotImplementedException {

  394.         Connection connection = null;
  395.         try{
  396.             
  397.             // check parameters
  398.             if(paginatedExpression==null){
  399.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNullErrorParameterPaginated();
  400.             }
  401.             if( ! (paginatedExpression instanceof JDBCPaginatedExpression) ){
  402.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongTypeErrorParameterPaginated(paginatedExpression);
  403.             }
  404.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) paginatedExpression;
  405.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  407.             // ISQLQueryObject
  408.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  409.             sqlQueryObject.setANDLogicOperator(true);
  410.             // Connection sql
  411.             connection = this.jdbcServiceManager.getConnection();

  413.             return this.serviceSearch.select(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,distinct,field);            
  414.     
  415.         }catch(ServiceException | NotImplementedException e){
  416.             this.logError(e); throw e;
  417.         }catch(NotFoundException e){
  418.             this.logDebug(e); throw e;
  419.         }catch(Exception e){
  420.             this.logError(e); throw new ServiceException("Select 'distinct:"+distinct+"' field not completed: "+e.getMessage(),e);
  421.         }finally{
  422.             if(connection!=null){
  423.                 this.jdbcServiceManager.closeConnection(connection);
  424.             }
  425.         }
  426.         
  427.     }
  428.     
  429.     @Override
  430.     public List<Map<String,Object>> select(IPaginatedExpression paginatedExpression, IField ... field) throws ServiceException,NotFoundException,NotImplementedException {
  431.     
  432.         Connection connection = null;
  433.         try{
  434.             
  435.             // check parameters
  436.             if(paginatedExpression==null){
  437.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNullErrorParameterPaginated();
  438.             }
  439.             if( ! (paginatedExpression instanceof JDBCPaginatedExpression) ){
  440.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongTypeErrorParameterPaginated(paginatedExpression);
  441.             }
  442.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) paginatedExpression;
  443.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  445.             // ISQLQueryObject
  446.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  447.             sqlQueryObject.setANDLogicOperator(true);
  448.             // Connection sql
  449.             connection = this.jdbcServiceManager.getConnection();

  451.             return this.serviceSearch.select(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,field);         
  452.     
  453.         }catch(ServiceException | NotImplementedException e){
  454.             this.logError(e); throw e;
  455.         }catch(NotFoundException e){
  456.             this.logDebug(e); throw e;
  457.         }catch(Exception e){
  458.             this.logError(e); throw new ServiceException("Select not completed: "+e.getMessage(),e);
  459.         }finally{
  460.             if(connection!=null){
  461.                 this.jdbcServiceManager.closeConnection(connection);
  462.             }
  463.         }
  464.     
  465.     }
  466.     @Override
  467.     public List<Map<String,Object>> select(IPaginatedExpression paginatedExpression, boolean distinct, IField ... field) throws ServiceException,NotFoundException,NotImplementedException {

  469.         Connection connection = null;
  470.         try{
  471.             
  472.             // check parameters
  473.             if(paginatedExpression==null){
  474.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNullErrorParameterPaginated();
  475.             }
  476.             if( ! (paginatedExpression instanceof JDBCPaginatedExpression) ){
  477.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongTypeErrorParameterPaginated(paginatedExpression);
  478.             }
  479.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) paginatedExpression;
  480.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  482.             // ISQLQueryObject
  483.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  484.             sqlQueryObject.setANDLogicOperator(true);
  485.             // Connection sql
  486.             connection = this.jdbcServiceManager.getConnection();

  488.             return this.serviceSearch.select(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,distinct,field);            
  489.     
  490.         }catch(ServiceException | NotImplementedException e){
  491.             this.logError(e); throw e;
  492.         }catch(NotFoundException e){
  493.             this.logDebug(e); throw e;
  494.         }catch(Exception e){
  495.             this.logError(e); throw new ServiceException("Select distinct:"+distinct+" not completed: "+e.getMessage(),e);
  496.         }finally{
  497.             if(connection!=null){
  498.                 this.jdbcServiceManager.closeConnection(connection);
  499.             }
  500.         }
  501.         
  502.     }
  503.     
  504.     @Override
  505.     public Object aggregate(IExpression expression, FunctionField functionField) throws ServiceException,NotFoundException,NotImplementedException {

  507.         Connection connection = null;
  508.         try{
  509.             
  510.             // check parameters
  511.             if(expression==null){
  512.                 throw this.newServiceExceptionParameterExpressionIsNull();
  513.             }
  514.             if( ! (expression instanceof JDBCExpression) ){
  515.                 throw this.newServiceExceptionParameterExpressionWrongType(expression);
  516.             }
  517.             JDBCExpression jdbcExpression = (JDBCExpression) expression;
  518.             this.logJDBCExpression(jdbcExpression);

  520.             // ISQLQueryObject
  521.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  522.             sqlQueryObject.setANDLogicOperator(true);
  523.             // Connection sql
  524.             connection = this.jdbcServiceManager.getConnection();

  526.             return this.serviceSearch.aggregate(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcExpression,functionField);           
  527.     
  528.         }catch(ServiceException | NotImplementedException e){
  529.             this.logError(e); throw e;
  530.         }catch(NotFoundException e){
  531.             this.logDebug(e); throw e;
  532.         }catch(Exception e){
  533.             this.logError(e); throw new ServiceException("Aggregate not completed: "+e.getMessage(),e);
  534.         }finally{
  535.             if(connection!=null){
  536.                 this.jdbcServiceManager.closeConnection(connection);
  537.             }
  538.         }
  539.         
  540.     }
  541.     
  542.     @Override
  543.     public Map<String,Object> aggregate(IExpression expression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException {

  545.         Connection connection = null;
  546.         try{
  547.             
  548.             // check parameters
  549.             if(expression==null){
  550.                 throw this.newServiceExceptionParameterExpressionIsNull();
  551.             }
  552.             if( ! (expression instanceof JDBCExpression) ){
  553.                 throw this.newServiceExceptionParameterExpressionWrongType(expression);
  554.             }
  555.             JDBCExpression jdbcExpression = (JDBCExpression) expression;
  556.             this.logJDBCExpression(jdbcExpression);

  558.             // ISQLQueryObject
  559.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  560.             sqlQueryObject.setANDLogicOperator(true);
  561.             // Connection sql
  562.             connection = this.jdbcServiceManager.getConnection();

  564.             return this.serviceSearch.aggregate(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcExpression,functionField);           
  565.     
  566.         }catch(ServiceException | NotImplementedException e){
  567.             this.logError(e); throw e;
  568.         }catch(NotFoundException e){
  569.             this.logDebug(e); throw e;
  570.         }catch(Exception e){
  571.             this.logError(e); throw new ServiceException("Aggregate not completed: "+e.getMessage(),e);
  572.         }finally{
  573.             if(connection!=null){
  574.                 this.jdbcServiceManager.closeConnection(connection);
  575.             }
  576.         }
  577.         
  578.     }
  579.     
  580.     @Override
  581.     public List<Map<String,Object>> groupBy(IExpression expression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException {

  583.         Connection connection = null;
  584.         try{
  585.             
  586.             // check parameters
  587.             if(expression==null){
  588.                 throw this.newServiceExceptionParameterExpressionIsNull();
  589.             }
  590.             if( ! (expression instanceof JDBCExpression) ){
  591.                 throw this.newServiceExceptionParameterExpressionWrongType(expression);
  592.             }
  593.             JDBCExpression jdbcExpression = (JDBCExpression) expression;
  594.             this.logJDBCExpression(jdbcExpression);

  596.             // ISQLQueryObject
  597.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  598.             sqlQueryObject.setANDLogicOperator(true);
  599.             // Connection sql
  600.             connection = this.jdbcServiceManager.getConnection();

  602.             return this.serviceSearch.groupBy(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcExpression,functionField);         
  603.     
  604.         }catch(ServiceException | NotImplementedException e){
  605.             this.logError(e); throw e;
  606.         }catch(NotFoundException e){
  607.             this.logDebug(e); throw e;
  608.         }catch(Exception e){
  609.             this.logError(e); throw new ServiceException("GroupBy not completed: "+e.getMessage(),e);
  610.         }finally{
  611.             if(connection!=null){
  612.                 this.jdbcServiceManager.closeConnection(connection);
  613.             }
  614.         }
  615.         
  616.     }
  617.     
  618.     @Override
  619.     public List<Map<String,Object>> groupBy(IPaginatedExpression paginatedExpression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException {

  621.         Connection connection = null;
  622.         try{
  623.             
  624.             // check parameters
  625.             if(paginatedExpression==null){
  626.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNullErrorParameterPaginated();
  627.             }
  628.             if( ! (paginatedExpression instanceof JDBCPaginatedExpression) ){
  629.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongTypeErrorParameterPaginated(paginatedExpression);
  630.             }
  631.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) paginatedExpression;
  632.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  634.             // ISQLQueryObject
  635.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  636.             sqlQueryObject.setANDLogicOperator(true);
  637.             // Connection sql
  638.             connection = this.jdbcServiceManager.getConnection();

  640.             return this.serviceSearch.groupBy(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,functionField);            
  641.     
  642.         }catch(ServiceException | NotImplementedException e){
  643.             this.logError(e); throw e;
  644.         }catch(NotFoundException e){
  645.             this.logDebug(e); throw e;
  646.         }catch(Exception e){
  647.             this.logError(e); throw new ServiceException("GroupBy not completed: "+e.getMessage(),e);
  648.         }finally{
  649.             if(connection!=null){
  650.                 this.jdbcServiceManager.closeConnection(connection);
  651.             }
  652.         }
  653.         
  654.     }
  655.     
  656.     @Override
  657.     public List<Map<String,Object>> union(Union union, UnionExpression ... unionExpression) throws ServiceException,NotFoundException,NotImplementedException {

  659.         Connection connection = null;
  660.         try{
  661.             
  662.             // check parameters
  663.             if(unionExpression==null){
  664.                 throw this.newServiceExceptionParameterUnionExpressionIsNull();
  665.             }
  666.             
  667.             // ISQLQueryObject
  668.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  669.             sqlQueryObject.setANDLogicOperator(true);
  670.             // Connection sql
  671.             connection = this.jdbcServiceManager.getConnection();

  673.             return this.serviceSearch.union(this.jdbcProperties,this.log,connection,sqlQueryObject,union,unionExpression);          
  674.     
  675.         }catch(ServiceException | NotImplementedException e){
  676.             this.logError(e); throw e;
  677.         }catch(NotFoundException e){
  678.             this.logDebug(e); throw e;
  679.         }catch(Exception e){
  680.             this.logError(e); throw new ServiceException("Union not completed: "+e.getMessage(),e);
  681.         }finally{
  682.             if(connection!=null){
  683.                 this.jdbcServiceManager.closeConnection(connection);
  684.             }
  685.         }
  686.         
  687.     }
  688.     
  689.     @Override
  690.     public NonNegativeNumber unionCount(Union union, UnionExpression ... unionExpression) throws ServiceException,NotFoundException,NotImplementedException {

  692.         Connection connection = null;
  693.         try{
  694.             
  695.             // check parameters
  696.             if(unionExpression==null){
  697.                 throw this.newServiceExceptionParameterUnionExpressionIsNull();
  698.             }
  699.             
  700.             // ISQLQueryObject
  701.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  702.             sqlQueryObject.setANDLogicOperator(true);
  703.             // Connection sql
  704.             connection = this.jdbcServiceManager.getConnection();

  706.             return this.serviceSearch.unionCount(this.jdbcProperties,this.log,connection,sqlQueryObject,union,unionExpression);         
  707.     
  708.         }catch(ServiceException | NotImplementedException e){
  709.             this.logError(e); throw e;
  710.         }catch(NotFoundException e){
  711.             this.logDebug(e); throw e;
  712.         }catch(Exception e){
  713.             this.logError(e); throw new ServiceException("UnionCount not completed: "+e.getMessage(),e);
  714.         }finally{
  715.             if(connection!=null){
  716.                 this.jdbcServiceManager.closeConnection(connection);
  717.             }
  718.         }
  719.         
  720.     }

  722.     @Override
  723.     public IExpression newExpression() throws ServiceException,NotImplementedException {

  725.         return this.serviceSearch.newExpression(this.log);

  727.     }

  729.     @Override
  730.     public IPaginatedExpression newPaginatedExpression() throws ServiceException, NotImplementedException {

  732.         return this.serviceSearch.newPaginatedExpression(this.log);

  734.     }
  735.     
  736.     @Override
  737.     public IExpression toExpression(IPaginatedExpression paginatedExpression) throws ServiceException,NotImplementedException {

  739.         return this.serviceSearch.toExpression((JDBCPaginatedExpression)paginatedExpression,this.log);

  741.     }

  743.     @Override
  744.     public IPaginatedExpression toPaginatedExpression(IExpression expression) throws ServiceException, NotImplementedException {

  746.         return this.serviceSearch.toPaginatedExpression((JDBCExpression)expression,this.log);

  748.     }
  749.     

  751.     // -- DB
  752.     
  753.         
  754.     @Override
  755.     public StatisticaOraria get(long tableId) throws ServiceException, NotFoundException,MultipleResultException, NotImplementedException {
  756.     
  757.         Connection connection = null;
  758.         try{
  759.             
  760.             // check parameters
  761.             if(tableId<=0){
  762.                 throw this.newServiceExceptionParameterTableIdLessEqualsZero();
  763.             }
  764.             
  765.             // ISQLQueryObject
  766.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  767.             sqlQueryObject.setANDLogicOperator(true);
  768.             // Connection sql
  769.             connection = this.jdbcServiceManager.getConnection();
  770.         
  771.             return this.serviceSearch.get(this.jdbcProperties,this.log,connection,sqlQueryObject,tableId,null);
  772.         
  773.         }catch(ServiceException | MultipleResultException | NotImplementedException e){
  774.             this.logError(e); throw e;
  775.         }catch(NotFoundException e){
  776.             this.logDebug(e); throw e;
  777.         }catch(Exception e){
  778.             this.logError(e); throw new ServiceException("Get(tableId) not completed: "+e.getMessage(),e);
  779.         }finally{
  780.             if(connection!=null){
  781.                 this.jdbcServiceManager.closeConnection(connection);
  782.             }
  783.         }
  784.     
  785.     }
  786.     
  787.     @Override
  788.     public StatisticaOraria get(long tableId,org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws ServiceException, NotFoundException,MultipleResultException, NotImplementedException {
  789.     
  790.         Connection connection = null;
  791.         try{
  792.             
  793.             // check parameters
  794.             if(tableId<=0){
  795.                 throw this.newServiceExceptionParameterTableIdLessEqualsZero();
  796.             }
  797.             if(idMappingResolutionBehaviour==null){
  798.                 throw this.newServiceExceptionParameterIdMappingResolutionBehaviourIsNull();
  799.             }
  800.             
  801.             // ISQLQueryObject
  802.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  803.             sqlQueryObject.setANDLogicOperator(true);
  804.             // Connection sql
  805.             connection = this.jdbcServiceManager.getConnection();
  806.         
  807.             return this.serviceSearch.get(this.jdbcProperties,this.log,connection,sqlQueryObject,tableId,idMappingResolutionBehaviour);
  808.         
  809.         }catch(ServiceException | MultipleResultException | NotImplementedException e){
  810.             this.logError(e); throw e;
  811.         }catch(NotFoundException e){
  812.             this.logDebug(e); throw e;
  813.         }catch(Exception e){
  814.             this.logError(e); throw new ServiceException("Get(tableId,idMappingResolutionBehaviour) not completed: "+e.getMessage(),e);
  815.         }finally{
  816.             if(connection!=null){
  817.                 this.jdbcServiceManager.closeConnection(connection);
  818.             }
  819.         }
  820.     
  821.     }
  822.     
  823.     @Override
  824.     public boolean exists(long tableId) throws MultipleResultException,ServiceException,NotImplementedException {

  826.         Connection connection = null;
  827.         try{
  828.             
  829.             // check parameters
  830.             if(tableId<=0){
  831.                 throw this.newServiceExceptionParameterTableIdLessEqualsZero();
  832.             }

  834.             // ISQLQueryObject
  835.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  836.             sqlQueryObject.setANDLogicOperator(true);
  837.             // Connection sql
  838.             connection = this.jdbcServiceManager.getConnection();

  840.             return this.serviceSearch.exists(this.jdbcProperties,this.log,connection,sqlQueryObject,tableId);           
  841.     
  842.         }catch(MultipleResultException | ServiceException | NotImplementedException e){
  843.             this.logError(e); throw e;
  844.         }catch(Exception e){
  845.             this.logError(e); throw new ServiceException("Exists(tableId) not completed: "+e.getMessage(),e);
  846.         }finally{
  847.             if(connection!=null){
  848.                 this.jdbcServiceManager.closeConnection(connection);
  849.             }
  850.         }
  851.         
  852.     }
  853.     
  854.     @Override
  855.     public List<Long> findAllTableIds(IPaginatedExpression expression) throws ServiceException, NotImplementedException {
  856.         
  857.         Connection connection = null;
  858.         try{
  859.             
  860.             // check parameters
  861.             if(expression==null){
  862.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNull();
  863.             }
  864.             if( ! (expression instanceof JDBCPaginatedExpression) ){
  865.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongType(expression);
  866.             }
  867.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) expression;
  868.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  870.             // ISQLQueryObject
  871.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  872.             sqlQueryObject.setANDLogicOperator(true);
  873.             // Connection sql
  874.             connection = this.jdbcServiceManager.getConnection();
  875.             
  876.             return this.serviceSearch.findAllTableIds(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression);
  877.     
  878.         }catch(ServiceException | NotImplementedException e){
  879.             this.logError(e); throw e;
  880.         }catch(Exception e){
  881.             this.logError(e); throw new ServiceException("findAllTableIds not completed: "+e.getMessage(),e);
  882.         }finally{
  883.             if(connection!=null){
  884.                 this.jdbcServiceManager.closeConnection(connection);
  885.             }
  886.         }
  887.         
  888.     }
  889.     
  890.     @Override
  891.     public long findTableId(IExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException {
  892.     
  893.         Connection connection = null;
  894.         try{
  895.             
  896.             // check parameters
  897.             if(expression==null){
  898.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNull();
  899.             }
  900.             if( ! (expression instanceof JDBCExpression) ){
  901.                 throw this.newServiceExceptionParameterExpressionWrongType(expression);
  902.             }
  903.             JDBCExpression jdbcExpression = (JDBCExpression) expression;
  904.             this.logJDBCExpression(jdbcExpression);

  906.             // ISQLQueryObject
  907.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  908.             sqlQueryObject.setANDLogicOperator(true);
  909.             // Connection sql
  910.             connection = this.jdbcServiceManager.getConnection();

  912.             return this.serviceSearch.findTableId(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcExpression);           

  914.         }catch(ServiceException | MultipleResultException | NotImplementedException e){
  915.             this.logError(e); throw e;
  916.         }catch(NotFoundException e){
  917.             this.logDebug(e); throw e;
  918.         }catch(Exception e){
  919.             this.logError(e); throw new ServiceException("findTableId not completed: "+e.getMessage(),e);
  920.         }finally{
  921.             if(connection!=null){
  922.                 this.jdbcServiceManager.closeConnection(connection);
  923.             }
  924.         }
  925.     
  926.     }
  927.     
  928.     @Override
  929.     public InUse inUse(long tableId) throws ServiceException, NotFoundException, NotImplementedException {
  930.     
  931.         Connection connection = null;
  932.         try{
  933.             
  934.             // check parameters
  935.             if(tableId<=0){
  936.                 throw this.newServiceExceptionParameterTableIdLessEqualsZero();
  937.             }
  938.             
  939.             // ISQLQueryObject
  940.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  941.             sqlQueryObject.setANDLogicOperator(true);
  942.             // Connection sql
  943.             connection = this.jdbcServiceManager.getConnection();

  945.             return this.serviceSearch.inUse(this.jdbcProperties,this.log,connection,sqlQueryObject,tableId);        
  946.     
  947.         }catch(ServiceException | NotImplementedException e){
  948.             this.logError(e); throw e;
  949.         }catch(NotFoundException e){
  950.             this.logDebug(e); throw e;
  951.         }catch(Exception e){
  952.             this.logError(e); throw new ServiceException("InUse(tableId) not completed: "+e.getMessage(),e);
  953.         }finally{
  954.             if(connection!=null){
  955.                 this.jdbcServiceManager.closeConnection(connection);
  956.             }
  957.         }
  958.     
  959.     }
  960.     
  961.     
  962.     @Override
  963.     public void disableSelectForUpdate() throws ServiceException,NotImplementedException {
  964.         this.jdbcSqlObjectFactory.setSelectForUpdate(false);
  965.     }

  967.     @Override
  968.     public void enableSelectForUpdate() throws ServiceException,NotImplementedException {
  969.         this.jdbcSqlObjectFactory.setSelectForUpdate(true);
  970.     }
  971.     
  972.     
  973.     @Override
  974.     public List<List<Object>> nativeQuery(String sql,List<Class<?>> returnClassTypes,Object ... param) throws ServiceException,NotFoundException,NotImplementedException{
  975.     
  976.         Connection connection = null;
  977.         try{
  978.             
  979.             // check parameters
  980.             if(returnClassTypes==null || returnClassTypes.isEmpty()){
  981.                 throw new ServiceException("Parameter 'returnClassTypes' is less equals 0");
  982.             }
  983.             
  984.             // ISQLQueryObject
  985.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  986.             sqlQueryObject.setANDLogicOperator(true);
  987.             // Connection sql
  988.             connection = this.jdbcServiceManager.getConnection();

  990.             return this.serviceSearch.nativeQuery(this.jdbcProperties,this.log,connection,sqlQueryObject,sql,returnClassTypes,param);       
  991.     
  992.         }catch(ServiceException | NotImplementedException e){
  993.             this.logError(e); throw e;
  994.         }catch(NotFoundException e){
  995.             this.logDebug(e); throw e;
  996.         }catch(Exception e){
  997.             this.logError(e); throw new ServiceException("nativeQuery not completed: "+e.getMessage(),e);
  998.         }finally{
  999.             if(connection!=null){
  1000.                 this.jdbcServiceManager.closeConnection(connection);
  1001.             }
  1002.         }
  1003.     
  1004.     }
  1005.     
  1006. }
Created with JaCoCo 0.8.8.202204050719