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

  45. import org.openspcoop2.core.statistiche.StatisticaInfo;
  46. import org.openspcoop2.core.statistiche.dao.IStatisticaInfoServiceSearch;
  47. import org.openspcoop2.core.statistiche.utils.ProjectInfo;

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

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

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


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

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

  148.     @Override
  149.     public ISQLFieldConverter getFieldConverter() {
  150.         return this.serviceSearch.getFieldConverter();
  151.     }
  152.     
  153.         


  156.     

  158.     @Override
  159.     public List<StatisticaInfo> findAll(IPaginatedExpression expression) throws ServiceException, NotImplementedException {

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

  174.             // ISQLQueryObject
  175.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  176.             sqlQueryObject.setANDLogicOperator(true);
  177.             // Connection sql
  178.             connection = this.jdbcServiceManager.getConnection();

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

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

  213.             // ISQLQueryObject
  214.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  215.             sqlQueryObject.setANDLogicOperator(true);
  216.             // Connection sql
  217.             connection = this.jdbcServiceManager.getConnection();

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

  233.     @Override
  234.     public StatisticaInfo find(IExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException {

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

  249.             // ISQLQueryObject
  250.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  251.             sqlQueryObject.setANDLogicOperator(true);
  252.             // Connection sql
  253.             connection = this.jdbcServiceManager.getConnection();

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

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

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

  290.             // ISQLQueryObject
  291.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  292.             sqlQueryObject.setANDLogicOperator(true);
  293.             // Connection sql
  294.             connection = this.jdbcServiceManager.getConnection();

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

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

  312.     @Override
  313.     public NonNegativeNumber count(IExpression expression) throws ServiceException, NotImplementedException {

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

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

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

  365.             // ISQLQueryObject
  366.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  367.             sqlQueryObject.setANDLogicOperator(true);
  368.             // Connection sql
  369.             connection = this.jdbcServiceManager.getConnection();

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

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

  403.             // ISQLQueryObject
  404.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  405.             sqlQueryObject.setANDLogicOperator(true);
  406.             // Connection sql
  407.             connection = this.jdbcServiceManager.getConnection();

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

  441.             // ISQLQueryObject
  442.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  443.             sqlQueryObject.setANDLogicOperator(true);
  444.             // Connection sql
  445.             connection = this.jdbcServiceManager.getConnection();

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

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

  478.             // ISQLQueryObject
  479.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  480.             sqlQueryObject.setANDLogicOperator(true);
  481.             // Connection sql
  482.             connection = this.jdbcServiceManager.getConnection();

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

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

  516.             // ISQLQueryObject
  517.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  518.             sqlQueryObject.setANDLogicOperator(true);
  519.             // Connection sql
  520.             connection = this.jdbcServiceManager.getConnection();

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

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

  554.             // ISQLQueryObject
  555.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  556.             sqlQueryObject.setANDLogicOperator(true);
  557.             // Connection sql
  558.             connection = this.jdbcServiceManager.getConnection();

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

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

  592.             // ISQLQueryObject
  593.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  594.             sqlQueryObject.setANDLogicOperator(true);
  595.             // Connection sql
  596.             connection = this.jdbcServiceManager.getConnection();

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

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

  630.             // ISQLQueryObject
  631.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  632.             sqlQueryObject.setANDLogicOperator(true);
  633.             // Connection sql
  634.             connection = this.jdbcServiceManager.getConnection();

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

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

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

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

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

  718.     @Override
  719.     public IExpression newExpression() throws ServiceException,NotImplementedException {

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

  723.     }

  725.     @Override
  726.     public IPaginatedExpression newPaginatedExpression() throws ServiceException, NotImplementedException {

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

  730.     }
  731.     
  732.     @Override
  733.     public IExpression toExpression(IPaginatedExpression paginatedExpression) throws ServiceException,NotImplementedException {

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

  737.     }

  739.     @Override
  740.     public IPaginatedExpression toPaginatedExpression(IExpression expression) throws ServiceException, NotImplementedException {

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

  744.     }
  745.     

  747.     
  748.     @Override
  749.     public List<List<Object>> nativeQuery(String sql,List<Class<?>> returnClassTypes,Object ... param) throws ServiceException,NotFoundException,NotImplementedException{
  750.     
  751.         Connection connection = null;
  752.         try{
  753.             
  754.             // check parameters
  755.             if(returnClassTypes==null || returnClassTypes.isEmpty()){
  756.                 throw new ServiceException("Parameter 'returnClassTypes' is less equals 0");
  757.             }
  758.             
  759.             // ISQLQueryObject
  760.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  761.             sqlQueryObject.setANDLogicOperator(true);
  762.             // Connection sql
  763.             connection = this.jdbcServiceManager.getConnection();

  765.             return this.serviceSearch.nativeQuery(this.jdbcProperties,this.log,connection,sqlQueryObject,sql,returnClassTypes,param);       
  766.     
  767.         }catch(ServiceException | NotImplementedException e){
  768.             this.logError(e); throw e;
  769.         }catch(NotFoundException e){
  770.             this.logDebug(e); throw e;
  771.         }catch(Exception e){
  772.             this.logError(e); throw new ServiceException("nativeQuery not completed: "+e.getMessage(),e);
  773.         }finally{
  774.             if(connection!=null){
  775.                 this.jdbcServiceManager.closeConnection(connection);
  776.             }
  777.         }
  778.     
  779.     }
  780.     
  781. }
Created with JaCoCo 0.8.8.202204050719