JDBCDumpMessaggioServiceSearch.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.transazioni.dao.jdbc;

  22. import java.lang.reflect.Method;
  23. import java.sql.Connection;
  24. import java.util.List;
  25. import java.util.Map;

  27. import org.openspcoop2.core.transazioni.DumpMessaggio;
  28. import org.openspcoop2.core.transazioni.IdDumpMessaggio;
  29. import org.openspcoop2.core.transazioni.dao.IDBDumpMessaggioServiceSearch;
  30. import org.openspcoop2.core.transazioni.utils.ProjectInfo;
  31. import org.openspcoop2.generic_project.beans.FunctionField;
  32. import org.openspcoop2.generic_project.beans.IField;
  33. import org.openspcoop2.generic_project.beans.InUse;
  34. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  35. import org.openspcoop2.generic_project.beans.Union;
  36. import org.openspcoop2.generic_project.beans.UnionExpression;
  37. import org.openspcoop2.generic_project.dao.IDBServiceUtilities;
  38. import org.openspcoop2.generic_project.dao.jdbc.IJDBCServiceSearchWithId;
  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.JDBCServiceManagerProperties;
  43. import org.openspcoop2.generic_project.dao.jdbc.utils.IJDBCFetch;
  44. import org.openspcoop2.generic_project.dao.jdbc.utils.JDBC_SQLObjectFactory;
  45. import org.openspcoop2.generic_project.exception.ExpressionException;
  46. import org.openspcoop2.generic_project.exception.MultipleResultException;
  47. import org.openspcoop2.generic_project.exception.NotFoundException;
  48. import org.openspcoop2.generic_project.exception.NotImplementedException;
  49. import org.openspcoop2.generic_project.exception.ServiceException;
  50. import org.openspcoop2.generic_project.exception.ValidationException;
  51. import org.openspcoop2.generic_project.expression.IExpression;
  52. import org.openspcoop2.generic_project.expression.IPaginatedExpression;
  53. import org.openspcoop2.generic_project.expression.impl.sql.ISQLFieldConverter;
  54. import org.openspcoop2.utils.sql.ISQLQueryObject;
  55. import org.slf4j.Logger;

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


  67.     protected JDBCServiceManagerProperties jdbcProperties = null;
  68.     protected JDBCServiceManager jdbcServiceManager = null;
  69.     protected Logger log = null;
  70.     protected IJDBCServiceSearchWithId<DumpMessaggio, IdDumpMessaggio, JDBCServiceManager> serviceSearch = null;
  71.     protected JDBC_SQLObjectFactory jdbcSqlObjectFactory = null;
  72.     public JDBCDumpMessaggioServiceSearch(JDBCServiceManager jdbcServiceManager) throws ServiceException {
  73.         this.jdbcServiceManager = jdbcServiceManager;
  74.         this.jdbcProperties = jdbcServiceManager.getJdbcProperties();
  75.         this.log = jdbcServiceManager.getLog();
  76.         String msgInit = JDBCDumpMessaggioServiceSearch.class.getName()+ " initialized";
  77.         this.log.debug(msgInit);
  78.         this.serviceSearch = JDBCProperties.getInstance(org.openspcoop2.core.transazioni.dao.jdbc.JDBCServiceManager.class.getPackage(),ProjectInfo.getInstance()).getServiceSearch("dumpMessaggio");
  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 newServiceExceptionParameterObjIsNull(){
  109.         return new ServiceException(PARAMETER_TYPE_PREFIX+DumpMessaggio.class.getName()+") 'obj' is null");
  110.     }
  111.     protected ServiceException newServiceExceptionParameterIdIsNull(){
  112.         return new ServiceException(PARAMETER_TYPE_PREFIX+IdDumpMessaggio.class.getName()+") 'id' is null");
  113.     }
  114.     private ServiceException newServiceExceptionParameterIdMappingResolutionBehaviourIsNull(){
  115.         return new ServiceException(PARAMETER_TYPE_PREFIX+org.openspcoop2.generic_project.beans.IDMappingBehaviour.class.getName()+") 'idMappingResolutionBehaviour' is null");
  116.     }

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

  161.     @Override
  162.     public ISQLFieldConverter getFieldConverter() {
  163.         return this.serviceSearch.getFieldConverter();
  164.     }
  165.     
  166.     @Override
  167.     public IdDumpMessaggio convertToId(DumpMessaggio obj)
  168.             throws ServiceException, NotImplementedException {
  169.         
  170.         Connection connection = null;
  171.         try{
  172.             
  173.             // check parameters
  174.             if(obj==null){
  175.                 throw this.newServiceExceptionParameterObjIsNull();
  176.             }
  177.             
  178.             // ISQLQueryObject
  179.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  180.             sqlQueryObject.setANDLogicOperator(true);
  181.             // Connection sql
  182.             connection = this.jdbcServiceManager.getConnection();
  183.         
  184.             return this.serviceSearch.convertToId(this.jdbcProperties,this.log,connection,sqlQueryObject,obj);
  185.         
  186.         }catch(ServiceException | NotImplementedException e){
  187.             this.logError(e); throw e;
  188.         }catch(Exception e){
  189.             this.logError(e); throw new ServiceException("ConvertToId 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 DumpMessaggio get(IdDumpMessaggio id) throws ServiceException, NotFoundException,MultipleResultException, NotImplementedException {
  200.     
  201.         Connection connection = null;
  202.         try{
  203.             
  204.             // check parameters
  205.             if(id==null){
  206.                 throw this.newServiceExceptionParameterIdIsNull();
  207.             }
  208.             
  209.             // ISQLQueryObject
  210.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  211.             sqlQueryObject.setANDLogicOperator(true);
  212.             // Connection sql
  213.             connection = this.jdbcServiceManager.getConnection();
  214.         
  215.             return this.serviceSearch.get(this.jdbcProperties,this.log,connection,sqlQueryObject,id,null);
  216.         
  217.         }catch(ServiceException | MultipleResultException | NotImplementedException e){
  218.             this.logError(e); throw e;
  219.         }catch(NotFoundException e){
  220.             this.logDebug(e); throw e;
  221.         }catch(Exception e){
  222.             this.logError(e); throw new ServiceException("Get not completed: "+e.getMessage(),e);
  223.         }finally{
  224.             if(connection!=null){
  225.                 this.jdbcServiceManager.closeConnection(connection);
  226.             }
  227.         }
  228.     
  229.     }

  231.     @Override
  232.     public DumpMessaggio get(IdDumpMessaggio id, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws ServiceException, NotFoundException,MultipleResultException, NotImplementedException {
  233.         Connection connection = null;
  234.         try{
  235.             
  236.             // check parameters
  237.             if(id==null){
  238.                 throw this.newServiceExceptionParameterIdIsNull();
  239.             }
  240.             if(idMappingResolutionBehaviour==null){
  241.                 throw this.newServiceExceptionParameterIdMappingResolutionBehaviourIsNull();
  242.             }
  243.             
  244.             // ISQLQueryObject
  245.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  246.             sqlQueryObject.setANDLogicOperator(true);
  247.             // Connection sql
  248.             connection = this.jdbcServiceManager.getConnection();
  249.         
  250.             return this.serviceSearch.get(this.jdbcProperties,this.log,connection,sqlQueryObject,id,idMappingResolutionBehaviour);
  251.         
  252.         }catch(ServiceException | MultipleResultException | NotImplementedException e){
  253.             this.logError(e); throw e;
  254.         }catch(NotFoundException e){
  255.             this.logDebug(e); throw e;
  256.         }catch(Exception e){
  257.             this.logError(e); throw new ServiceException("Get (idMappingResolutionBehaviour) not completed: "+e.getMessage(),e);
  258.         }finally{
  259.             if(connection!=null){
  260.                 this.jdbcServiceManager.closeConnection(connection);
  261.             }
  262.         }
  263.     
  264.     }

  266.     @Override
  267.     public boolean exists(IdDumpMessaggio id) throws MultipleResultException,ServiceException,NotImplementedException {

  269.         Connection connection = null;
  270.         try{
  271.             
  272.             // check parameters
  273.             if(id==null){
  274.                 throw this.newServiceExceptionParameterIdIsNull();
  275.             }

  277.             // ISQLQueryObject
  278.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  279.             sqlQueryObject.setANDLogicOperator(true);
  280.             // Connection sql
  281.             connection = this.jdbcServiceManager.getConnection();

  283.             return this.serviceSearch.exists(this.jdbcProperties,this.log,connection,sqlQueryObject,id);
  284.     
  285.         }catch(MultipleResultException | ServiceException | NotImplementedException e){
  286.             this.logError(e); throw e;
  287.         }catch(Exception e){
  288.             this.logError(e); throw new ServiceException("Exists not completed: "+e.getMessage(),e);
  289.         }finally{
  290.             if(connection!=null){
  291.                 this.jdbcServiceManager.closeConnection(connection);
  292.             }
  293.         }
  294.         
  295.     }
  296.     
  297.     @Override
  298.     public List<IdDumpMessaggio> findAllIds(IPaginatedExpression expression) throws ServiceException, NotImplementedException {

  300.         Connection connection = null;
  301.         try{
  302.             
  303.             // check parameters
  304.             if(expression==null){
  305.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNull();
  306.             }
  307.             if( ! (expression instanceof JDBCPaginatedExpression) ){
  308.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongType(expression);
  309.             }
  310.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) expression;
  311.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  313.             // ISQLQueryObject
  314.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  315.             sqlQueryObject.setANDLogicOperator(true);
  316.             // Connection sql
  317.             connection = this.jdbcServiceManager.getConnection();
  318.             
  319.             return this.serviceSearch.findAllIds(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,null);
  320.     
  321.         }catch(ServiceException | NotImplementedException e){
  322.             this.logError(e); throw e;
  323.         }catch(Exception e){
  324.             this.logError(e); throw new ServiceException("FindAllIds not completed: "+e.getMessage(),e);
  325.         }finally{
  326.             if(connection!=null){
  327.                 this.jdbcServiceManager.closeConnection(connection);
  328.             }
  329.         }
  330.         
  331.     }
  332.     
  333.     @Override
  334.     public List<IdDumpMessaggio> findAllIds(IPaginatedExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws ServiceException, NotImplementedException {

  336.         Connection connection = null;
  337.         try{
  338.             
  339.             // check parameters
  340.             if(idMappingResolutionBehaviour==null){
  341.                 throw this.newServiceExceptionParameterIdMappingResolutionBehaviourIsNull();
  342.             }
  343.             if(expression==null){
  344.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNull();
  345.             }
  346.             if( ! (expression instanceof JDBCPaginatedExpression) ){
  347.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongType(expression);
  348.             }
  349.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) expression;
  350.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  352.             // ISQLQueryObject
  353.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  354.             sqlQueryObject.setANDLogicOperator(true);
  355.             // Connection sql
  356.             connection = this.jdbcServiceManager.getConnection();
  357.             
  358.             return this.serviceSearch.findAllIds(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,idMappingResolutionBehaviour);
  359.     
  360.         }catch(ServiceException | NotImplementedException e){
  361.             this.logError(e); throw e;
  362.         }catch(Exception e){
  363.             this.logError(e); throw new ServiceException("FindAllIds not completed: "+e.getMessage(),e);
  364.         }finally{
  365.             if(connection!=null){
  366.                 this.jdbcServiceManager.closeConnection(connection);
  367.             }
  368.         }
  369.         
  370.     }

  372.     @Override
  373.     public List<DumpMessaggio> findAll(IPaginatedExpression expression) throws ServiceException, NotImplementedException {

  375.         Connection connection = null;
  376.         try{
  377.             
  378.             // check parameters
  379.             if(expression==null){
  380.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNull();
  381.             }
  382.             if( ! (expression instanceof JDBCPaginatedExpression) ){
  383.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongType(expression);
  384.             }
  385.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) expression;
  386.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  388.             // ISQLQueryObject
  389.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  390.             sqlQueryObject.setANDLogicOperator(true);
  391.             // Connection sql
  392.             connection = this.jdbcServiceManager.getConnection();

  394.             return this.serviceSearch.findAll(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,null);         
  395.     
  396.         }catch(ServiceException | NotImplementedException e){
  397.             this.logError(e); throw e;
  398.         }catch(Exception e){
  399.             this.logError(e); throw new ServiceException("FindAll not completed: "+e.getMessage(),e);
  400.         }finally{
  401.             if(connection!=null){
  402.                 this.jdbcServiceManager.closeConnection(connection);
  403.             }
  404.         }
  405.         
  406.     }
  407.     
  408.     @Override
  409.     public List<DumpMessaggio> findAll(IPaginatedExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws ServiceException, NotImplementedException {

  411.         Connection connection = null;
  412.         try{
  413.             
  414.             // check parameters
  415.             if(idMappingResolutionBehaviour==null){
  416.                 throw this.newServiceExceptionParameterIdMappingResolutionBehaviourIsNull();
  417.             }
  418.             if(expression==null){
  419.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNull();
  420.             }
  421.             if( ! (expression instanceof JDBCPaginatedExpression) ){
  422.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongType(expression);
  423.             }
  424.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) expression;
  425.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  427.             // ISQLQueryObject
  428.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  429.             sqlQueryObject.setANDLogicOperator(true);
  430.             // Connection sql
  431.             connection = this.jdbcServiceManager.getConnection();

  433.             return this.serviceSearch.findAll(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,idMappingResolutionBehaviour);         
  434.     
  435.         }catch(ServiceException | NotImplementedException e){
  436.             this.logError(e); throw e;
  437.         }catch(Exception e){
  438.             this.logError(e); throw new ServiceException("FindAll not completed: "+e.getMessage(),e);
  439.         }finally{
  440.             if(connection!=null){
  441.                 this.jdbcServiceManager.closeConnection(connection);
  442.             }
  443.         }
  444.         
  445.     }

  447.     @Override
  448.     public DumpMessaggio find(IExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException {

  450.         Connection connection = null;
  451.         try{
  452.             
  453.             // check parameters
  454.             if(expression==null){
  455.                 throw this.newServiceExceptionParameterExpressionIsNull();
  456.             }
  457.             if( ! (expression instanceof JDBCExpression) ){
  458.                 throw this.newServiceExceptionParameterExpressionWrongType(expression);
  459.             }
  460.             JDBCExpression jdbcExpression = (JDBCExpression) expression;
  461.             this.logJDBCExpression(jdbcExpression);

  463.             // ISQLQueryObject
  464.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  465.             sqlQueryObject.setANDLogicOperator(true);
  466.             // Connection sql
  467.             connection = this.jdbcServiceManager.getConnection();

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

  471.         }catch(ServiceException | MultipleResultException | NotImplementedException e){
  472.             this.logError(e); throw e;
  473.         }catch(NotFoundException e){
  474.             this.logDebug(e); throw e;
  475.         }catch(Exception e){
  476.             this.logError(e); throw new ServiceException("Find not completed: "+e.getMessage(),e);
  477.         }finally{
  478.             if(connection!=null){
  479.                 this.jdbcServiceManager.closeConnection(connection);
  480.             }
  481.         }
  482.         
  483.     }
  484.     
  485.     @Override
  486.     public DumpMessaggio find(IExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException {

  488.         Connection connection = null;
  489.         try{
  490.             
  491.             // check parameters
  492.             if(idMappingResolutionBehaviour==null){
  493.                 throw this.newServiceExceptionParameterIdMappingResolutionBehaviourIsNull();
  494.             }
  495.             if(expression==null){
  496.                 throw this.newServiceExceptionParameterExpressionIsNull();
  497.             }
  498.             if( ! (expression instanceof JDBCExpression) ){
  499.                 throw this.newServiceExceptionParameterExpressionWrongType(expression);
  500.             }
  501.             JDBCExpression jdbcExpression = (JDBCExpression) expression;
  502.             this.logJDBCExpression(jdbcExpression);

  504.             // ISQLQueryObject
  505.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  506.             sqlQueryObject.setANDLogicOperator(true);
  507.             // Connection sql
  508.             connection = this.jdbcServiceManager.getConnection();

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

  512.         }catch(ServiceException | MultipleResultException | NotImplementedException e){
  513.             this.logError(e); throw e;
  514.         }catch(NotFoundException e){
  515.             this.logDebug(e); throw e;
  516.         }catch(Exception e){
  517.             this.logError(e); throw new ServiceException("Find not completed: "+e.getMessage(),e);
  518.         }finally{
  519.             if(connection!=null){
  520.                 this.jdbcServiceManager.closeConnection(connection);
  521.             }
  522.         }
  523.         
  524.     }

  526.     @Override
  527.     public JDBCDumpMessaggioStream getContentInputStream(IExpression expression) 
  528.             throws ServiceException {
  529.         
  530.         Connection connection = null;
  531.         try{
  532.             
  533.             // check parameters
  534.             if(expression==null){
  535.                 throw newServiceExceptionParameterPaginatedExpressionIsNull();
  536.             }
  537.             if( ! (expression instanceof JDBCExpression) ){
  538.                 throw newServiceExceptionParameterExpressionWrongType(expression);
  539.             }
  540.             JDBCExpression jdbcExpression = (JDBCExpression) expression;
  541.             logJDBCExpression(jdbcExpression);

  543.             // ISQLQueryObject
  544.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  545.             sqlQueryObject.setANDLogicOperator(true);
  546.             // Connection sql
  547.             connection = this.jdbcServiceManager.getConnection();

  549.             Method method = this.serviceSearch.getClass().getMethod("getContentInputStream", 
  550.                     JDBCServiceManagerProperties.class, Logger.class, 
  551.                     Connection.class, JDBCServiceManager.class, 
  552.                     ISQLQueryObject.class, JDBCExpression.class);
  553.             return (JDBCDumpMessaggioStream) method.invoke(this.serviceSearch, 
  554.                     this.jdbcProperties,this.log, 
  555.                     connection, this.jdbcServiceManager, 
  556.                     sqlQueryObject,jdbcExpression);         

  558.         }catch(ServiceException e){
  559.             this.logError(e); throw e;
  560.         }catch(Exception e){
  561.             this.logError(e); throw new ServiceException("Find not completed: "+e.getMessage(),e);
  562.         }finally{
  563.             /**
  564.              * OP-1635
  565.             if(connection!=null){
  566.                 this.jdbcServiceManager.closeConnection(connection);
  567.             }
  568.             */
  569.         }
  570.         
  571.     }

  573.     @Override
  574.     public NonNegativeNumber count(IExpression expression) throws ServiceException, NotImplementedException {

  576.         Connection connection = null;
  577.         try{
  578.             
  579.             // check parameters
  580.             if(expression==null){
  581.                 throw this.newServiceExceptionParameterExpressionIsNull();
  582.             }
  583.             if( ! (expression instanceof JDBCExpression) ){
  584.                 throw this.newServiceExceptionParameterExpressionWrongType(expression);
  585.             }
  586.             JDBCExpression jdbcExpression = (JDBCExpression) expression;
  587.             this.logJDBCExpression(jdbcExpression);
  588.             
  589.             // ISQLQueryObject
  590.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  591.             sqlQueryObject.setANDLogicOperator(true);
  592.             // Connection sql
  593.             connection = this.jdbcServiceManager.getConnection();

  595.             return this.serviceSearch.count(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcExpression);
  596.     
  597.         }catch(ServiceException | NotImplementedException e){
  598.             this.logError(e); throw e;
  599.         }catch(Exception e){
  600.             this.logError(e); throw new ServiceException("Count not completed: "+e.getMessage(),e);
  601.         }finally{
  602.             if(connection!=null){
  603.                 this.jdbcServiceManager.closeConnection(connection);
  604.             }
  605.         }
  606.         
  607.     }

  609.     @Override
  610.     public InUse inUse(IdDumpMessaggio id) throws ServiceException, NotFoundException,NotImplementedException {

  612.         Connection connection = null;
  613.         try{
  614.             
  615.             // check parameters
  616.             if(id==null){
  617.                 throw this.newServiceExceptionParameterIdIsNull();
  618.             }
  619.             
  620.             // ISQLQueryObject
  621.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  622.             sqlQueryObject.setANDLogicOperator(true);
  623.             // Connection sql
  624.             connection = this.jdbcServiceManager.getConnection();

  626.             return this.serviceSearch.inUse(this.jdbcProperties,this.log,connection,sqlQueryObject,id); 
  627.     
  628.         }catch(ServiceException | NotImplementedException e){
  629.             this.logError(e); throw e;
  630.         }catch(NotFoundException e){
  631.             this.logDebug(e); throw e;
  632.         }catch(Exception e){
  633.             this.logError(e); throw new ServiceException("InUse not completed: "+e.getMessage(),e);
  634.         }finally{
  635.             if(connection!=null){
  636.                 this.jdbcServiceManager.closeConnection(connection);
  637.             }
  638.         }
  639.         
  640.     }
  641.     
  642.     @Override
  643.     public List<Object> select(IPaginatedExpression paginatedExpression, IField field) throws ServiceException,NotFoundException,NotImplementedException {
  644.     
  645.         Connection connection = null;
  646.         try{
  647.             
  648.             // check parameters
  649.             if(paginatedExpression==null){
  650.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNullErrorParameterPaginated();
  651.             }
  652.             if( ! (paginatedExpression instanceof JDBCPaginatedExpression) ){
  653.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongTypeErrorParameterPaginated(paginatedExpression);
  654.             }
  655.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) paginatedExpression;
  656.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  658.             // ISQLQueryObject
  659.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  660.             sqlQueryObject.setANDLogicOperator(true);
  661.             // Connection sql
  662.             connection = this.jdbcServiceManager.getConnection();

  664.             return this.serviceSearch.select(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,field);         
  665.     
  666.         }catch(ServiceException | NotImplementedException e){
  667.             this.logError(e); throw e;
  668.         }catch(NotFoundException e){
  669.             this.logDebug(e); throw e;
  670.         }catch(Exception e){
  671.             this.logError(e); throw new ServiceException("Select 'field' not completed: "+e.getMessage(),e);
  672.         }finally{
  673.             if(connection!=null){
  674.                 this.jdbcServiceManager.closeConnection(connection);
  675.             }
  676.         }
  677.     
  678.     }
  679.     
  680.     @Override
  681.     public List<Object> select(IPaginatedExpression paginatedExpression, boolean distinct, IField field) throws ServiceException,NotFoundException,NotImplementedException {

  683.         Connection connection = null;
  684.         try{
  685.             
  686.             // check parameters
  687.             if(paginatedExpression==null){
  688.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNullErrorParameterPaginated();
  689.             }
  690.             if( ! (paginatedExpression instanceof JDBCPaginatedExpression) ){
  691.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongTypeErrorParameterPaginated(paginatedExpression);
  692.             }
  693.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) paginatedExpression;
  694.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  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.select(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,distinct,field);            
  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("Select 'distinct:"+distinct+"' field not completed: "+e.getMessage(),e);
  710.         }finally{
  711.             if(connection!=null){
  712.                 this.jdbcServiceManager.closeConnection(connection);
  713.             }
  714.         }
  715.         
  716.     }
  717.     
  718.     @Override
  719.     public List<Map<String,Object>> select(IPaginatedExpression paginatedExpression, IField ... field) throws ServiceException,NotFoundException,NotImplementedException {
  720.     
  721.         Connection connection = null;
  722.         try{
  723.             
  724.             // check parameters
  725.             if(paginatedExpression==null){
  726.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNullErrorParameterPaginated();
  727.             }
  728.             if( ! (paginatedExpression instanceof JDBCPaginatedExpression) ){
  729.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongTypeErrorParameterPaginated(paginatedExpression);
  730.             }
  731.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) paginatedExpression;
  732.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  734.             // ISQLQueryObject
  735.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  736.             sqlQueryObject.setANDLogicOperator(true);
  737.             // Connection sql
  738.             connection = this.jdbcServiceManager.getConnection();

  740.             return this.serviceSearch.select(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,field);         
  741.     
  742.         }catch(ServiceException | NotImplementedException e){
  743.             this.logError(e); throw e;
  744.         }catch(NotFoundException e){
  745.             this.logDebug(e); throw e;
  746.         }catch(Exception e){
  747.             this.logError(e); throw new ServiceException("Select not completed: "+e.getMessage(),e);
  748.         }finally{
  749.             if(connection!=null){
  750.                 this.jdbcServiceManager.closeConnection(connection);
  751.             }
  752.         }
  753.     
  754.     }
  755.     @Override
  756.     public List<Map<String,Object>> select(IPaginatedExpression paginatedExpression, boolean distinct, IField ... field) throws ServiceException,NotFoundException,NotImplementedException {

  758.         Connection connection = null;
  759.         try{
  760.             
  761.             // check parameters
  762.             if(paginatedExpression==null){
  763.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNullErrorParameterPaginated();
  764.             }
  765.             if( ! (paginatedExpression instanceof JDBCPaginatedExpression) ){
  766.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongTypeErrorParameterPaginated(paginatedExpression);
  767.             }
  768.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) paginatedExpression;
  769.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  771.             // ISQLQueryObject
  772.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  773.             sqlQueryObject.setANDLogicOperator(true);
  774.             // Connection sql
  775.             connection = this.jdbcServiceManager.getConnection();

  777.             return this.serviceSearch.select(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,distinct,field);            
  778.     
  779.         }catch(ServiceException | NotImplementedException e){
  780.             this.logError(e); throw e;
  781.         }catch(NotFoundException e){
  782.             this.logDebug(e); throw e;
  783.         }catch(Exception e){
  784.             this.logError(e); throw new ServiceException("Select distinct:"+distinct+" not completed: "+e.getMessage(),e);
  785.         }finally{
  786.             if(connection!=null){
  787.                 this.jdbcServiceManager.closeConnection(connection);
  788.             }
  789.         }
  790.         
  791.     }
  792.     
  793.     @Override
  794.     public Object aggregate(IExpression expression, FunctionField functionField) throws ServiceException,NotFoundException,NotImplementedException {

  796.         Connection connection = null;
  797.         try{
  798.             
  799.             // check parameters
  800.             if(expression==null){
  801.                 throw this.newServiceExceptionParameterExpressionIsNull();
  802.             }
  803.             if( ! (expression instanceof JDBCExpression) ){
  804.                 throw this.newServiceExceptionParameterExpressionWrongType(expression);
  805.             }
  806.             JDBCExpression jdbcExpression = (JDBCExpression) expression;
  807.             this.logJDBCExpression(jdbcExpression);

  809.             // ISQLQueryObject
  810.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  811.             sqlQueryObject.setANDLogicOperator(true);
  812.             // Connection sql
  813.             connection = this.jdbcServiceManager.getConnection();

  815.             return this.serviceSearch.aggregate(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcExpression,functionField);           
  816.     
  817.         }catch(ServiceException | NotImplementedException e){
  818.             this.logError(e); throw e;
  819.         }catch(NotFoundException e){
  820.             this.logDebug(e); throw e;
  821.         }catch(Exception e){
  822.             this.logError(e); throw new ServiceException("Aggregate not completed: "+e.getMessage(),e);
  823.         }finally{
  824.             if(connection!=null){
  825.                 this.jdbcServiceManager.closeConnection(connection);
  826.             }
  827.         }
  828.         
  829.     }
  830.     
  831.     @Override
  832.     public Map<String,Object> aggregate(IExpression expression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException {

  834.         Connection connection = null;
  835.         try{
  836.             
  837.             // check parameters
  838.             if(expression==null){
  839.                 throw this.newServiceExceptionParameterExpressionIsNull();
  840.             }
  841.             if( ! (expression instanceof JDBCExpression) ){
  842.                 throw this.newServiceExceptionParameterExpressionWrongType(expression);
  843.             }
  844.             JDBCExpression jdbcExpression = (JDBCExpression) expression;
  845.             this.logJDBCExpression(jdbcExpression);

  847.             // ISQLQueryObject
  848.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  849.             sqlQueryObject.setANDLogicOperator(true);
  850.             // Connection sql
  851.             connection = this.jdbcServiceManager.getConnection();

  853.             return this.serviceSearch.aggregate(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcExpression,functionField);           
  854.     
  855.         }catch(ServiceException | NotImplementedException e){
  856.             this.logError(e); throw e;
  857.         }catch(NotFoundException e){
  858.             this.logDebug(e); throw e;
  859.         }catch(Exception e){
  860.             this.logError(e); throw new ServiceException("Aggregate not completed: "+e.getMessage(),e);
  861.         }finally{
  862.             if(connection!=null){
  863.                 this.jdbcServiceManager.closeConnection(connection);
  864.             }
  865.         }
  866.         
  867.     }
  868.     
  869.     @Override
  870.     public List<Map<String,Object>> groupBy(IExpression expression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException {

  872.         Connection connection = null;
  873.         try{
  874.             
  875.             // check parameters
  876.             if(expression==null){
  877.                 throw this.newServiceExceptionParameterExpressionIsNull();
  878.             }
  879.             if( ! (expression instanceof JDBCExpression) ){
  880.                 throw this.newServiceExceptionParameterExpressionWrongType(expression);
  881.             }
  882.             JDBCExpression jdbcExpression = (JDBCExpression) expression;
  883.             this.logJDBCExpression(jdbcExpression);

  885.             // ISQLQueryObject
  886.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  887.             sqlQueryObject.setANDLogicOperator(true);
  888.             // Connection sql
  889.             connection = this.jdbcServiceManager.getConnection();

  891.             return this.serviceSearch.groupBy(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcExpression,functionField);         
  892.     
  893.         }catch(ServiceException | NotImplementedException e){
  894.             this.logError(e); throw e;
  895.         }catch(NotFoundException e){
  896.             this.logDebug(e); throw e;
  897.         }catch(Exception e){
  898.             this.logError(e); throw new ServiceException("GroupBy not completed: "+e.getMessage(),e);
  899.         }finally{
  900.             if(connection!=null){
  901.                 this.jdbcServiceManager.closeConnection(connection);
  902.             }
  903.         }
  904.         
  905.     }
  906.     
  907.     @Override
  908.     public List<Map<String,Object>> groupBy(IPaginatedExpression paginatedExpression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException {

  910.         Connection connection = null;
  911.         try{
  912.             
  913.             // check parameters
  914.             if(paginatedExpression==null){
  915.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNullErrorParameterPaginated();
  916.             }
  917.             if( ! (paginatedExpression instanceof JDBCPaginatedExpression) ){
  918.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongTypeErrorParameterPaginated(paginatedExpression);
  919.             }
  920.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) paginatedExpression;
  921.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  923.             // ISQLQueryObject
  924.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  925.             sqlQueryObject.setANDLogicOperator(true);
  926.             // Connection sql
  927.             connection = this.jdbcServiceManager.getConnection();

  929.             return this.serviceSearch.groupBy(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,functionField);            
  930.     
  931.         }catch(ServiceException | NotImplementedException e){
  932.             this.logError(e); throw e;
  933.         }catch(NotFoundException e){
  934.             this.logDebug(e); throw e;
  935.         }catch(Exception e){
  936.             this.logError(e); throw new ServiceException("GroupBy not completed: "+e.getMessage(),e);
  937.         }finally{
  938.             if(connection!=null){
  939.                 this.jdbcServiceManager.closeConnection(connection);
  940.             }
  941.         }
  942.         
  943.     }
  944.     
  945.     @Override
  946.     public List<Map<String,Object>> union(Union union, UnionExpression ... unionExpression) throws ServiceException,NotFoundException,NotImplementedException {

  948.         Connection connection = null;
  949.         try{
  950.             
  951.             // check parameters
  952.             if(unionExpression==null){
  953.                 throw this.newServiceExceptionParameterUnionExpressionIsNull();
  954.             }
  955.             
  956.             // ISQLQueryObject
  957.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  958.             sqlQueryObject.setANDLogicOperator(true);
  959.             // Connection sql
  960.             connection = this.jdbcServiceManager.getConnection();

  962.             return this.serviceSearch.union(this.jdbcProperties,this.log,connection,sqlQueryObject,union,unionExpression);          
  963.     
  964.         }catch(ServiceException | NotImplementedException e){
  965.             this.logError(e); throw e;
  966.         }catch(NotFoundException e){
  967.             this.logDebug(e); throw e;
  968.         }catch(Exception e){
  969.             this.logError(e); throw new ServiceException("Union not completed: "+e.getMessage(),e);
  970.         }finally{
  971.             if(connection!=null){
  972.                 this.jdbcServiceManager.closeConnection(connection);
  973.             }
  974.         }
  975.         
  976.     }
  977.     
  978.     @Override
  979.     public NonNegativeNumber unionCount(Union union, UnionExpression ... unionExpression) throws ServiceException,NotFoundException,NotImplementedException {

  981.         Connection connection = null;
  982.         try{
  983.             
  984.             // check parameters
  985.             if(unionExpression==null){
  986.                 throw this.newServiceExceptionParameterUnionExpressionIsNull();
  987.             }
  988.             
  989.             // ISQLQueryObject
  990.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  991.             sqlQueryObject.setANDLogicOperator(true);
  992.             // Connection sql
  993.             connection = this.jdbcServiceManager.getConnection();

  995.             return this.serviceSearch.unionCount(this.jdbcProperties,this.log,connection,sqlQueryObject,union,unionExpression);         
  996.     
  997.         }catch(ServiceException | NotImplementedException e){
  998.             this.logError(e); throw e;
  999.         }catch(NotFoundException e){
  1000.             this.logDebug(e); throw e;
  1001.         }catch(Exception e){
  1002.             this.logError(e); throw new ServiceException("UnionCount not completed: "+e.getMessage(),e);
  1003.         }finally{
  1004.             if(connection!=null){
  1005.                 this.jdbcServiceManager.closeConnection(connection);
  1006.             }
  1007.         }
  1008.         
  1009.     }

  1011.     @Override
  1012.     public IExpression newExpression() throws ServiceException,NotImplementedException {

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

  1016.     }

  1018.     @Override
  1019.     public IPaginatedExpression newPaginatedExpression() throws ServiceException, NotImplementedException {

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

  1023.     }
  1024.     
  1025.     @Override
  1026.     public IExpression toExpression(IPaginatedExpression paginatedExpression) throws ServiceException,NotImplementedException {

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

  1030.     }

  1032.     @Override
  1033.     public IPaginatedExpression toPaginatedExpression(IExpression expression) throws ServiceException, NotImplementedException {

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

  1037.     }
  1038.     

  1040.     // -- DB
  1041.     
  1042.     @Override
  1043.     public void mappingTableIds(IdDumpMessaggio id, DumpMessaggio obj) throws ServiceException,NotFoundException,NotImplementedException{
  1044.         Connection connection = null;
  1045.         try{
  1046.             
  1047.             // check parameters
  1048.             if(id==null){
  1049.                 throw this.newServiceExceptionParameterIdIsNull();
  1050.             }
  1051.             if(obj==null){
  1052.                 throw this.newServiceExceptionParameterObjIsNull();
  1053.             }
  1054.             
  1055.             // ISQLQueryObject
  1056.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  1057.             sqlQueryObject.setANDLogicOperator(true);
  1058.             // Connection sql
  1059.             connection = this.jdbcServiceManager.getConnection();
  1060.         
  1061.             this.serviceSearch.mappingTableIds(this.jdbcProperties,this.log,connection,sqlQueryObject,id,obj);
  1062.         
  1063.         }catch(ServiceException | NotImplementedException e){
  1064.             this.logError(e); throw e;
  1065.         }catch(NotFoundException e){
  1066.             this.logDebug(e); throw e;
  1067.         }catch(Exception e){
  1068.             this.logError(e); throw new ServiceException("mappingIds(IdObject) not completed: "+e.getMessage(),e);
  1069.         }finally{
  1070.             if(connection!=null){
  1071.                 this.jdbcServiceManager.closeConnection(connection);
  1072.             }
  1073.         }
  1074.     }
  1075.     
  1076.     @Override
  1077.     public void mappingTableIds(long tableId, DumpMessaggio obj) throws ServiceException,NotFoundException,NotImplementedException{
  1078.         Connection connection = null;
  1079.         try{
  1080.             
  1081.             // check parameters
  1082.             if(tableId<=0){
  1083.                 throw this.newServiceExceptionParameterWithTypeTableIdLessEqualsZero();
  1084.             }
  1085.             if(obj==null){
  1086.                 throw this.newServiceExceptionParameterObjIsNull();
  1087.             }
  1088.             
  1089.             // ISQLQueryObject
  1090.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  1091.             sqlQueryObject.setANDLogicOperator(true);
  1092.             // Connection sql
  1093.             connection = this.jdbcServiceManager.getConnection();
  1094.         
  1095.             this.serviceSearch.mappingTableIds(this.jdbcProperties,this.log,connection,sqlQueryObject,tableId,obj);
  1096.         
  1097.         }catch(ServiceException | NotImplementedException e){
  1098.             this.logError(e); throw e;
  1099.         }catch(NotFoundException e){
  1100.             this.logDebug(e); throw e;
  1101.         }catch(Exception e){
  1102.             this.logError(e); throw new ServiceException("mappingIds(tableId) not completed: "+e.getMessage(),e);
  1103.         }finally{
  1104.             if(connection!=null){
  1105.                 this.jdbcServiceManager.closeConnection(connection);
  1106.             }
  1107.         }
  1108.     }
  1109.         
  1110.     @Override
  1111.     public DumpMessaggio get(long tableId) throws ServiceException, NotFoundException,MultipleResultException, NotImplementedException {
  1112.     
  1113.         Connection connection = null;
  1114.         try{
  1115.             
  1116.             // check parameters
  1117.             if(tableId<=0){
  1118.                 throw this.newServiceExceptionParameterTableIdLessEqualsZero();
  1119.             }
  1120.             
  1121.             // ISQLQueryObject
  1122.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  1123.             sqlQueryObject.setANDLogicOperator(true);
  1124.             // Connection sql
  1125.             connection = this.jdbcServiceManager.getConnection();
  1126.         
  1127.             return this.serviceSearch.get(this.jdbcProperties,this.log,connection,sqlQueryObject,tableId,null);
  1128.         
  1129.         }catch(ServiceException | MultipleResultException | NotImplementedException e){
  1130.             this.logError(e); throw e;
  1131.         }catch(NotFoundException e){
  1132.             this.logDebug(e); throw e;
  1133.         }catch(Exception e){
  1134.             this.logError(e); throw new ServiceException("Get(tableId) not completed: "+e.getMessage(),e);
  1135.         }finally{
  1136.             if(connection!=null){
  1137.                 this.jdbcServiceManager.closeConnection(connection);
  1138.             }
  1139.         }
  1140.     
  1141.     }
  1142.     
  1143.     @Override
  1144.     public DumpMessaggio get(long tableId,org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws ServiceException, NotFoundException,MultipleResultException, NotImplementedException {
  1145.     
  1146.         Connection connection = null;
  1147.         try{
  1148.             
  1149.             // check parameters
  1150.             if(tableId<=0){
  1151.                 throw this.newServiceExceptionParameterTableIdLessEqualsZero();
  1152.             }
  1153.             if(idMappingResolutionBehaviour==null){
  1154.                 throw this.newServiceExceptionParameterIdMappingResolutionBehaviourIsNull();
  1155.             }
  1156.             
  1157.             // ISQLQueryObject
  1158.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  1159.             sqlQueryObject.setANDLogicOperator(true);
  1160.             // Connection sql
  1161.             connection = this.jdbcServiceManager.getConnection();
  1162.         
  1163.             return this.serviceSearch.get(this.jdbcProperties,this.log,connection,sqlQueryObject,tableId,idMappingResolutionBehaviour);
  1164.         
  1165.         }catch(ServiceException | MultipleResultException | NotImplementedException e){
  1166.             this.logError(e); throw e;
  1167.         }catch(NotFoundException e){
  1168.             this.logDebug(e); throw e;
  1169.         }catch(Exception e){
  1170.             this.logError(e); throw new ServiceException("Get(tableId,idMappingResolutionBehaviour) not completed: "+e.getMessage(),e);
  1171.         }finally{
  1172.             if(connection!=null){
  1173.                 this.jdbcServiceManager.closeConnection(connection);
  1174.             }
  1175.         }
  1176.     
  1177.     }
  1178.     
  1179.     @Override
  1180.     public boolean exists(long tableId) throws MultipleResultException,ServiceException,NotImplementedException {

  1182.         Connection connection = null;
  1183.         try{
  1184.             
  1185.             // check parameters
  1186.             if(tableId<=0){
  1187.                 throw this.newServiceExceptionParameterTableIdLessEqualsZero();
  1188.             }

  1190.             // ISQLQueryObject
  1191.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  1192.             sqlQueryObject.setANDLogicOperator(true);
  1193.             // Connection sql
  1194.             connection = this.jdbcServiceManager.getConnection();

  1196.             return this.serviceSearch.exists(this.jdbcProperties,this.log,connection,sqlQueryObject,tableId);           
  1197.     
  1198.         }catch(MultipleResultException | ServiceException | NotImplementedException e){
  1199.             this.logError(e); throw e;
  1200.         }catch(Exception e){
  1201.             this.logError(e); throw new ServiceException("Exists(tableId) not completed: "+e.getMessage(),e);
  1202.         }finally{
  1203.             if(connection!=null){
  1204.                 this.jdbcServiceManager.closeConnection(connection);
  1205.             }
  1206.         }
  1207.         
  1208.     }
  1209.     
  1210.     @Override
  1211.     public List<Long> findAllTableIds(IPaginatedExpression expression) throws ServiceException, NotImplementedException {
  1212.         
  1213.         Connection connection = null;
  1214.         try{
  1215.             
  1216.             // check parameters
  1217.             if(expression==null){
  1218.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNull();
  1219.             }
  1220.             if( ! (expression instanceof JDBCPaginatedExpression) ){
  1221.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongType(expression);
  1222.             }
  1223.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) expression;
  1224.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  1226.             // ISQLQueryObject
  1227.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  1228.             sqlQueryObject.setANDLogicOperator(true);
  1229.             // Connection sql
  1230.             connection = this.jdbcServiceManager.getConnection();
  1231.             
  1232.             return this.serviceSearch.findAllTableIds(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression);
  1233.     
  1234.         }catch(ServiceException | NotImplementedException e){
  1235.             this.logError(e); throw e;
  1236.         }catch(Exception e){
  1237.             this.logError(e); throw new ServiceException("findAllTableIds not completed: "+e.getMessage(),e);
  1238.         }finally{
  1239.             if(connection!=null){
  1240.                 this.jdbcServiceManager.closeConnection(connection);
  1241.             }
  1242.         }
  1243.         
  1244.     }
  1245.     
  1246.     @Override
  1247.     public long findTableId(IExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException {
  1248.     
  1249.         Connection connection = null;
  1250.         try{
  1251.             
  1252.             // check parameters
  1253.             if(expression==null){
  1254.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNull();
  1255.             }
  1256.             if( ! (expression instanceof JDBCExpression) ){
  1257.                 throw this.newServiceExceptionParameterExpressionWrongType(expression);
  1258.             }
  1259.             JDBCExpression jdbcExpression = (JDBCExpression) expression;
  1260.             this.logJDBCExpression(jdbcExpression);

  1262.             // ISQLQueryObject
  1263.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  1264.             sqlQueryObject.setANDLogicOperator(true);
  1265.             // Connection sql
  1266.             connection = this.jdbcServiceManager.getConnection();

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

  1270.         }catch(ServiceException | MultipleResultException | NotImplementedException e){
  1271.             this.logError(e); throw e;
  1272.         }catch(NotFoundException e){
  1273.             this.logDebug(e); throw e;
  1274.         }catch(Exception e){
  1275.             this.logError(e); throw new ServiceException("findTableId not completed: "+e.getMessage(),e);
  1276.         }finally{
  1277.             if(connection!=null){
  1278.                 this.jdbcServiceManager.closeConnection(connection);
  1279.             }
  1280.         }
  1281.     
  1282.     }
  1283.     
  1284.     @Override
  1285.     public InUse inUse(long tableId) throws ServiceException, NotFoundException, NotImplementedException {
  1286.     
  1287.         Connection connection = null;
  1288.         try{
  1289.             
  1290.             // check parameters
  1291.             if(tableId<=0){
  1292.                 throw this.newServiceExceptionParameterTableIdLessEqualsZero();
  1293.             }
  1294.             
  1295.             // ISQLQueryObject
  1296.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  1297.             sqlQueryObject.setANDLogicOperator(true);
  1298.             // Connection sql
  1299.             connection = this.jdbcServiceManager.getConnection();

  1301.             return this.serviceSearch.inUse(this.jdbcProperties,this.log,connection,sqlQueryObject,tableId);        
  1302.     
  1303.         }catch(ServiceException | NotImplementedException e){
  1304.             this.logError(e); throw e;
  1305.         }catch(NotFoundException e){
  1306.             this.logDebug(e); throw e;
  1307.         }catch(Exception e){
  1308.             this.logError(e); throw new ServiceException("InUse(tableId) not completed: "+e.getMessage(),e);
  1309.         }finally{
  1310.             if(connection!=null){
  1311.                 this.jdbcServiceManager.closeConnection(connection);
  1312.             }
  1313.         }
  1314.     
  1315.     }
  1316.     
  1317.     @Override
  1318.     public IdDumpMessaggio findId(long tableId, boolean throwNotFound)
  1319.             throws NotFoundException, ServiceException, NotImplementedException {
  1320.         
  1321.         Connection connection = null;
  1322.         try{
  1323.             
  1324.             // check parameters
  1325.             if(tableId<=0){
  1326.                 throw this.newServiceExceptionParameterTableIdLessEqualsZero();
  1327.             }
  1328.             
  1329.             // ISQLQueryObject
  1330.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  1331.             sqlQueryObject.setANDLogicOperator(true);
  1332.             // Connection sql
  1333.             connection = this.jdbcServiceManager.getConnection();

  1335.             return this.serviceSearch.findId(this.jdbcProperties,this.log,connection,sqlQueryObject,tableId,throwNotFound);     
  1336.     
  1337.         }catch(ServiceException | NotImplementedException e){
  1338.             this.logError(e); throw e;
  1339.         }catch(NotFoundException e){
  1340.             this.logDebug(e); throw e;
  1341.         }catch(Exception e){
  1342.             this.logError(e); throw new ServiceException("findId(tableId,throwNotFound) not completed: "+e.getMessage(),e);
  1343.         }finally{
  1344.             if(connection!=null){
  1345.                 this.jdbcServiceManager.closeConnection(connection);
  1346.             }
  1347.         }
  1348.         
  1349.     }

  1351.     @Override
  1352.     public Long findTableId(IdDumpMessaggio id, boolean throwNotFound)
  1353.             throws NotFoundException, ServiceException, NotImplementedException {
  1354.         
  1355.         Connection connection = null;
  1356.         try{
  1357.             
  1358.             // check parameters
  1359.             if(id==null){
  1360.                 throw new ServiceException("Parameter 'id' is null");
  1361.             }
  1362.             
  1363.             // ISQLQueryObject
  1364.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  1365.             sqlQueryObject.setANDLogicOperator(true);
  1366.             // Connection sql
  1367.             connection = this.jdbcServiceManager.getConnection();

  1369.             return this.serviceSearch.findTableId(this.jdbcProperties,this.log,connection,sqlQueryObject,id,throwNotFound);     
  1370.     
  1371.         }catch(ServiceException | NotImplementedException e){
  1372.             this.logError(e); throw e;
  1373.         }catch(NotFoundException e){
  1374.             this.logDebug(e); throw e;
  1375.         }catch(Exception e){
  1376.             this.logError(e); throw new ServiceException("findId(tableId,throwNotFound) not completed: "+e.getMessage(),e);
  1377.         }finally{
  1378.             if(connection!=null){
  1379.                 this.jdbcServiceManager.closeConnection(connection);
  1380.             }
  1381.         }
  1382.     }
  1383.     
  1384.     @Override
  1385.     public void disableSelectForUpdate() throws ServiceException,NotImplementedException {
  1386.         this.jdbcSqlObjectFactory.setSelectForUpdate(false);
  1387.     }

  1389.     @Override
  1390.     public void enableSelectForUpdate() throws ServiceException,NotImplementedException {
  1391.         this.jdbcSqlObjectFactory.setSelectForUpdate(true);
  1392.     }
  1393.     
  1394.     
  1395.     @Override
  1396.     public List<List<Object>> nativeQuery(String sql,List<Class<?>> returnClassTypes,Object ... param) throws ServiceException,NotFoundException,NotImplementedException{
  1397.     
  1398.         Connection connection = null;
  1399.         try{
  1400.             
  1401.             // check parameters
  1402.             if(returnClassTypes==null || returnClassTypes.isEmpty()){
  1403.                 throw new ServiceException("Parameter 'returnClassTypes' is less equals 0");
  1404.             }
  1405.             
  1406.             // ISQLQueryObject
  1407.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  1408.             sqlQueryObject.setANDLogicOperator(true);
  1409.             // Connection sql
  1410.             connection = this.jdbcServiceManager.getConnection();

  1412.             return this.serviceSearch.nativeQuery(this.jdbcProperties,this.log,connection,sqlQueryObject,sql,returnClassTypes,param);       
  1413.     
  1414.         }catch(ServiceException | NotImplementedException e){
  1415.             this.logError(e); throw e;
  1416.         }catch(NotFoundException e){
  1417.             this.logDebug(e); throw e;
  1418.         }catch(Exception e){
  1419.             this.logError(e); throw new ServiceException("nativeQuery not completed: "+e.getMessage(),e);
  1420.         }finally{
  1421.             if(connection!=null){
  1422.                 this.jdbcServiceManager.closeConnection(connection);
  1423.             }
  1424.         }
  1425.     
  1426.     }
  1427.     
  1428. }
Created with JaCoCo 0.8.8.202204050719