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.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.StatisticaInfo;
  47. import org.openspcoop2.core.statistiche.dao.IDBStatisticaInfoServiceSearch;
  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.StatisticaInfo} 
  59.  *
  60.  * @author Poli Andrea (poli@link.it)
  61.  * @author Tommaso Burlon (tommaso.burlon@link.it)
  62.  * @author $Author$
  63.  * @version $Rev$, $Date$
  64. */
  65. public class JDBCStatisticaInfoServiceSearch implements IDBStatisticaInfoServiceSearch, IDBServiceUtilities<StatisticaInfo> {


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

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

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


  161.     

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

  728.     }

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

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

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

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

  742.     }

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

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

  749.     }
  750.     

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

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

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

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

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

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

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

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

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

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

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