JDBCConfigurazioneGeneraleServiceSearch.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.controllo_traffico.dao.jdbc;

  22. import org.openspcoop2.generic_project.dao.IDBServiceUtilities;
  23. import org.openspcoop2.generic_project.dao.jdbc.IJDBCServiceSearchSingleObject;
  24. import org.openspcoop2.generic_project.beans.InUse;
  25. import org.openspcoop2.generic_project.beans.IField;
  26. import org.openspcoop2.generic_project.dao.jdbc.JDBCServiceManagerProperties;
  27. import org.openspcoop2.generic_project.exception.ExpressionException;
  28. import org.openspcoop2.generic_project.exception.MultipleResultException;
  29. import org.openspcoop2.generic_project.exception.NotFoundException;
  30. import org.openspcoop2.generic_project.exception.NotImplementedException;
  31. import org.openspcoop2.generic_project.exception.ServiceException;
  32. import org.openspcoop2.generic_project.exception.ValidationException;
  33. import org.openspcoop2.generic_project.expression.IExpression;
  34. import org.openspcoop2.generic_project.expression.IPaginatedExpression;
  35. import org.openspcoop2.generic_project.expression.impl.sql.ISQLFieldConverter;
  36. import org.openspcoop2.generic_project.dao.jdbc.JDBCExpression;
  37. import org.openspcoop2.generic_project.dao.jdbc.JDBCPaginatedExpression;
  38. import org.openspcoop2.generic_project.dao.jdbc.JDBCProperties;
  39. import org.openspcoop2.generic_project.dao.jdbc.utils.IJDBCFetch;
  40. import org.openspcoop2.generic_project.dao.jdbc.utils.JDBC_SQLObjectFactory;

  42. import org.openspcoop2.core.controllo_traffico.ConfigurazioneGenerale;
  43. import org.openspcoop2.core.controllo_traffico.dao.IDBConfigurazioneGeneraleServiceSearch;
  44. import org.openspcoop2.core.controllo_traffico.utils.ProjectInfo;

  46. import java.sql.Connection;
  47. import java.util.List;
  48. import java.util.Map;

  50. import org.slf4j.Logger;
  51. import org.openspcoop2.utils.sql.ISQLQueryObject;

  53. /**     
  54.  * Service can be used to search for the backend objects of type {@link org.openspcoop2.core.controllo_traffico.ConfigurazioneGenerale} 
  55.  *
  56.  * @author Poli Andrea (poli@link.it)
  57.  * @author $Author$
  58.  * @version $Rev$, $Date$
  59. */
  60. public class JDBCConfigurazioneGeneraleServiceSearch implements IDBConfigurazioneGeneraleServiceSearch, IDBServiceUtilities<ConfigurazioneGenerale> {


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

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

  148.     @Override
  149.     public ISQLFieldConverter getFieldConverter() {
  150.         return this.serviceSearch.getFieldConverter();
  151.     }
  152.     
  153.         
  154.     @Override
  155.     public ConfigurazioneGenerale get() throws ServiceException, NotFoundException,MultipleResultException, NotImplementedException {
  156.     
  157.         Connection connection = null;
  158.         try{
  159.             
  160.             
  161.             // ISQLQueryObject
  162.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  163.             sqlQueryObject.setANDLogicOperator(true);
  164.             // Connection sql
  165.             connection = this.jdbcServiceManager.getConnection();
  166.         
  167.             return this.serviceSearch.get(this.jdbcProperties,this.log,connection,sqlQueryObject,null); 
  168.         
  169.         }catch(ServiceException | MultipleResultException | NotImplementedException e){
  170.             this.logError(e); throw e;
  171.         }catch(NotFoundException e){
  172.             this.logDebug(e); throw e;
  173.         }catch(Exception e){
  174.             this.logError(e); throw new ServiceException("Get not completed: "+e.getMessage(),e);
  175.         }finally{
  176.             if(connection!=null){
  177.                 this.jdbcServiceManager.closeConnection(connection);
  178.             }
  179.         }
  180.     
  181.     }

  183.     @Override
  184.     public ConfigurazioneGenerale get(org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws ServiceException, NotFoundException,MultipleResultException, NotImplementedException {
  185.         Connection connection = null;
  186.         try{
  187.             
  188.             if(idMappingResolutionBehaviour==null){
  189.                 throw this.newServiceExceptionParameterIdMappingResolutionBehaviourIsNull();
  190.             }
  191.             
  192.             // ISQLQueryObject
  193.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  194.             sqlQueryObject.setANDLogicOperator(true);
  195.             // Connection sql
  196.             connection = this.jdbcServiceManager.getConnection();
  197.         
  198.             return this.serviceSearch.get(this.jdbcProperties,this.log,connection,sqlQueryObject,idMappingResolutionBehaviour); 
  199.         
  200.         }catch(ServiceException | MultipleResultException | NotImplementedException e){
  201.             this.logError(e); throw e;
  202.         }catch(NotFoundException e){
  203.             this.logDebug(e); throw e;
  204.         }catch(Exception e){
  205.             this.logError(e); throw new ServiceException("Get (idMappingResolutionBehaviour) not completed: "+e.getMessage(),e);
  206.         }finally{
  207.             if(connection!=null){
  208.                 this.jdbcServiceManager.closeConnection(connection);
  209.             }
  210.         }
  211.     
  212.     }

  214.     @Override
  215.     public boolean exists() throws MultipleResultException,ServiceException,NotImplementedException {

  217.         Connection connection = null;
  218.         try{
  219.             

  221.             // ISQLQueryObject
  222.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  223.             sqlQueryObject.setANDLogicOperator(true);
  224.             // Connection sql
  225.             connection = this.jdbcServiceManager.getConnection();

  227.             return this.serviceSearch.exists(this.jdbcProperties,this.log,connection,sqlQueryObject);
  228.     
  229.         }catch(MultipleResultException | ServiceException | NotImplementedException e){
  230.             this.logError(e); throw e;
  231.         }catch(Exception e){
  232.             this.logError(e); throw new ServiceException("Exists not completed: "+e.getMessage(),e);
  233.         }finally{
  234.             if(connection!=null){
  235.                 this.jdbcServiceManager.closeConnection(connection);
  236.             }
  237.         }
  238.         
  239.     }
  240.     




  245.     @Override
  246.     public InUse inUse() throws ServiceException, NotFoundException,NotImplementedException {

  248.         Connection connection = null;
  249.         try{
  250.             
  251.             
  252.             // ISQLQueryObject
  253.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  254.             sqlQueryObject.setANDLogicOperator(true);
  255.             // Connection sql
  256.             connection = this.jdbcServiceManager.getConnection();

  258.             return this.serviceSearch.inUse(this.jdbcProperties,this.log,connection,sqlQueryObject);    
  259.     
  260.         }catch(ServiceException | NotImplementedException e){
  261.             this.logError(e); throw e;
  262.         }catch(NotFoundException e){
  263.             this.logDebug(e); throw e;
  264.         }catch(Exception e){
  265.             this.logError(e); throw new ServiceException("InUse not completed: "+e.getMessage(),e);
  266.         }finally{
  267.             if(connection!=null){
  268.                 this.jdbcServiceManager.closeConnection(connection);
  269.             }
  270.         }
  271.         
  272.     }
  273.     
  274.     @Override
  275.     public List<Object> select(IPaginatedExpression paginatedExpression, IField field) throws ServiceException,NotFoundException,NotImplementedException {
  276.     
  277.         Connection connection = null;
  278.         try{
  279.             
  280.             // check parameters
  281.             if(paginatedExpression==null){
  282.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNullErrorParameterPaginated();
  283.             }
  284.             if( ! (paginatedExpression instanceof JDBCPaginatedExpression) ){
  285.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongTypeErrorParameterPaginated(paginatedExpression);
  286.             }
  287.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) paginatedExpression;
  288.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

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

  296.             return this.serviceSearch.select(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,field);         
  297.     
  298.         }catch(ServiceException | NotImplementedException e){
  299.             this.logError(e); throw e;
  300.         }catch(NotFoundException e){
  301.             this.logDebug(e); throw e;
  302.         }catch(Exception e){
  303.             this.logError(e); throw new ServiceException("Select 'field' not completed: "+e.getMessage(),e);
  304.         }finally{
  305.             if(connection!=null){
  306.                 this.jdbcServiceManager.closeConnection(connection);
  307.             }
  308.         }
  309.     
  310.     }
  311.     
  312.     @Override
  313.     public List<Object> select(IPaginatedExpression paginatedExpression, boolean distinct, IField field) throws ServiceException,NotFoundException,NotImplementedException {

  315.         Connection connection = null;
  316.         try{
  317.             
  318.             // check parameters
  319.             if(paginatedExpression==null){
  320.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNullErrorParameterPaginated();
  321.             }
  322.             if( ! (paginatedExpression instanceof JDBCPaginatedExpression) ){
  323.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongTypeErrorParameterPaginated(paginatedExpression);
  324.             }
  325.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) paginatedExpression;
  326.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  328.             // ISQLQueryObject
  329.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  330.             sqlQueryObject.setANDLogicOperator(true);
  331.             // Connection sql
  332.             connection = this.jdbcServiceManager.getConnection();

  334.             return this.serviceSearch.select(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,distinct,field);            
  335.     
  336.         }catch(ServiceException | NotImplementedException e){
  337.             this.logError(e); throw e;
  338.         }catch(NotFoundException e){
  339.             this.logDebug(e); throw e;
  340.         }catch(Exception e){
  341.             this.logError(e); throw new ServiceException("Select 'distinct:"+distinct+"' field not completed: "+e.getMessage(),e);
  342.         }finally{
  343.             if(connection!=null){
  344.                 this.jdbcServiceManager.closeConnection(connection);
  345.             }
  346.         }
  347.         
  348.     }
  349.     
  350.     @Override
  351.     public List<Map<String,Object>> select(IPaginatedExpression paginatedExpression, IField ... field) throws ServiceException,NotFoundException,NotImplementedException {
  352.     
  353.         Connection connection = null;
  354.         try{
  355.             
  356.             // check parameters
  357.             if(paginatedExpression==null){
  358.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNullErrorParameterPaginated();
  359.             }
  360.             if( ! (paginatedExpression instanceof JDBCPaginatedExpression) ){
  361.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongTypeErrorParameterPaginated(paginatedExpression);
  362.             }
  363.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) paginatedExpression;
  364.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

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

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

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

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

  409.             return this.serviceSearch.select(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression,distinct,field);            
  410.     
  411.         }catch(ServiceException | NotImplementedException e){
  412.             this.logError(e); throw e;
  413.         }catch(NotFoundException e){
  414.             this.logDebug(e); throw e;
  415.         }catch(Exception e){
  416.             this.logError(e); throw new ServiceException("Select distinct:"+distinct+" not completed: "+e.getMessage(),e);
  417.         }finally{
  418.             if(connection!=null){
  419.                 this.jdbcServiceManager.closeConnection(connection);
  420.             }
  421.         }
  422.         
  423.     }
  424.     
  425.     
  426.     
  427.     
  428.     
  429.     

  431.     @Override
  432.     public IExpression newExpression() throws ServiceException,NotImplementedException {

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

  436.     }

  438.     @Override
  439.     public IPaginatedExpression newPaginatedExpression() throws ServiceException, NotImplementedException {

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

  443.     }
  444.     
  445.     @Override
  446.     public IExpression toExpression(IPaginatedExpression paginatedExpression) throws ServiceException,NotImplementedException {

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

  450.     }

  452.     @Override
  453.     public IPaginatedExpression toPaginatedExpression(IExpression expression) throws ServiceException, NotImplementedException {

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

  457.     }
  458.     

  460.     // -- DB
  461.     
  462.     @Override
  463.     public void mappingTableIds(ConfigurazioneGenerale obj) throws ServiceException,NotFoundException,NotImplementedException{
  464.         Connection connection = null;
  465.         try{
  466.             
  467.             // check parameters
  468.             if(obj==null){
  469.                 throw this.newServiceExceptionParameterObjIsNull();
  470.             }
  471.             
  472.             // ISQLQueryObject
  473.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  474.             sqlQueryObject.setANDLogicOperator(true);
  475.             // Connection sql
  476.             connection = this.jdbcServiceManager.getConnection();
  477.         
  478.             this.serviceSearch.mappingTableIds(this.jdbcProperties,this.log,connection,sqlQueryObject,obj);
  479.         
  480.         }catch(ServiceException | NotImplementedException e){
  481.             this.logError(e); throw e;
  482.         }catch(NotFoundException e){
  483.             this.logDebug(e); throw e;
  484.         }catch(Exception e){
  485.             this.logError(e); throw new ServiceException("mappingIds not completed: "+e.getMessage(),e);
  486.         }finally{
  487.             if(connection!=null){
  488.                 this.jdbcServiceManager.closeConnection(connection);
  489.             }
  490.         }
  491.     }
  492.         
  493.     @Override
  494.     public ConfigurazioneGenerale get(long tableId) throws ServiceException, NotFoundException,MultipleResultException, NotImplementedException {
  495.     
  496.         Connection connection = null;
  497.         try{
  498.             
  499.             // check parameters
  500.             if(tableId<=0){
  501.                 throw this.newServiceExceptionParameterTableIdLessEqualsZero();
  502.             }
  503.             
  504.             // ISQLQueryObject
  505.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  506.             sqlQueryObject.setANDLogicOperator(true);
  507.             // Connection sql
  508.             connection = this.jdbcServiceManager.getConnection();
  509.         
  510.             return this.serviceSearch.get(this.jdbcProperties,this.log,connection,sqlQueryObject,tableId,null);
  511.         
  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("Get(tableId) not completed: "+e.getMessage(),e);
  518.         }finally{
  519.             if(connection!=null){
  520.                 this.jdbcServiceManager.closeConnection(connection);
  521.             }
  522.         }
  523.     
  524.     }
  525.     
  526.     @Override
  527.     public ConfigurazioneGenerale get(long tableId,org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws ServiceException, NotFoundException,MultipleResultException, NotImplementedException {
  528.     
  529.         Connection connection = null;
  530.         try{
  531.             
  532.             // check parameters
  533.             if(tableId<=0){
  534.                 throw this.newServiceExceptionParameterTableIdLessEqualsZero();
  535.             }
  536.             if(idMappingResolutionBehaviour==null){
  537.                 throw this.newServiceExceptionParameterIdMappingResolutionBehaviourIsNull();
  538.             }
  539.             
  540.             // ISQLQueryObject
  541.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  542.             sqlQueryObject.setANDLogicOperator(true);
  543.             // Connection sql
  544.             connection = this.jdbcServiceManager.getConnection();
  545.         
  546.             return this.serviceSearch.get(this.jdbcProperties,this.log,connection,sqlQueryObject,tableId,idMappingResolutionBehaviour);
  547.         
  548.         }catch(ServiceException | MultipleResultException | NotImplementedException e){
  549.             this.logError(e); throw e;
  550.         }catch(NotFoundException e){
  551.             this.logDebug(e); throw e;
  552.         }catch(Exception e){
  553.             this.logError(e); throw new ServiceException("Get(tableId,idMappingResolutionBehaviour) not completed: "+e.getMessage(),e);
  554.         }finally{
  555.             if(connection!=null){
  556.                 this.jdbcServiceManager.closeConnection(connection);
  557.             }
  558.         }
  559.     
  560.     }
  561.     
  562.     @Override
  563.     public boolean exists(long tableId) throws MultipleResultException,ServiceException,NotImplementedException {

  565.         Connection connection = null;
  566.         try{
  567.             
  568.             // check parameters
  569.             if(tableId<=0){
  570.                 throw this.newServiceExceptionParameterTableIdLessEqualsZero();
  571.             }

  573.             // ISQLQueryObject
  574.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  575.             sqlQueryObject.setANDLogicOperator(true);
  576.             // Connection sql
  577.             connection = this.jdbcServiceManager.getConnection();

  579.             return this.serviceSearch.exists(this.jdbcProperties,this.log,connection,sqlQueryObject,tableId);           
  580.     
  581.         }catch(MultipleResultException | ServiceException | NotImplementedException e){
  582.             this.logError(e); throw e;
  583.         }catch(Exception e){
  584.             this.logError(e); throw new ServiceException("Exists(tableId) not completed: "+e.getMessage(),e);
  585.         }finally{
  586.             if(connection!=null){
  587.                 this.jdbcServiceManager.closeConnection(connection);
  588.             }
  589.         }
  590.         
  591.     }
  592.     
  593.     @Override
  594.     public List<Long> findAllTableIds(IPaginatedExpression expression) throws ServiceException, NotImplementedException {
  595.         
  596.         Connection connection = null;
  597.         try{
  598.             
  599.             // check parameters
  600.             if(expression==null){
  601.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNull();
  602.             }
  603.             if( ! (expression instanceof JDBCPaginatedExpression) ){
  604.                 throw this.newServiceExceptionParameterPaginatedExpressionWrongType(expression);
  605.             }
  606.             JDBCPaginatedExpression jdbcPaginatedExpression = (JDBCPaginatedExpression) expression;
  607.             logJDBCPaginatedExpression(jdbcPaginatedExpression);

  609.             // ISQLQueryObject
  610.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  611.             sqlQueryObject.setANDLogicOperator(true);
  612.             // Connection sql
  613.             connection = this.jdbcServiceManager.getConnection();
  614.             
  615.             return this.serviceSearch.findAllTableIds(this.jdbcProperties,this.log,connection,sqlQueryObject,jdbcPaginatedExpression);
  616.     
  617.         }catch(ServiceException | NotImplementedException e){
  618.             this.logError(e); throw e;
  619.         }catch(Exception e){
  620.             this.logError(e); throw new ServiceException("findAllTableIds not completed: "+e.getMessage(),e);
  621.         }finally{
  622.             if(connection!=null){
  623.                 this.jdbcServiceManager.closeConnection(connection);
  624.             }
  625.         }
  626.         
  627.     }
  628.     
  629.     @Override
  630.     public long findTableId(IExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException {
  631.     
  632.         Connection connection = null;
  633.         try{
  634.             
  635.             // check parameters
  636.             if(expression==null){
  637.                 throw this.newServiceExceptionParameterPaginatedExpressionIsNull();
  638.             }
  639.             if( ! (expression instanceof JDBCExpression) ){
  640.                 throw this.newServiceExceptionParameterExpressionWrongType(expression);
  641.             }
  642.             JDBCExpression jdbcExpression = (JDBCExpression) expression;
  643.             this.logJDBCExpression(jdbcExpression);

  645.             // ISQLQueryObject
  646.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  647.             sqlQueryObject.setANDLogicOperator(true);
  648.             // Connection sql
  649.             connection = this.jdbcServiceManager.getConnection();

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

  653.         }catch(ServiceException | MultipleResultException | NotImplementedException e){
  654.             this.logError(e); throw e;
  655.         }catch(NotFoundException e){
  656.             this.logDebug(e); throw e;
  657.         }catch(Exception e){
  658.             this.logError(e); throw new ServiceException("findTableId not completed: "+e.getMessage(),e);
  659.         }finally{
  660.             if(connection!=null){
  661.                 this.jdbcServiceManager.closeConnection(connection);
  662.             }
  663.         }
  664.     
  665.     }
  666.     
  667.     @Override
  668.     public InUse inUse(long tableId) throws ServiceException, NotFoundException, NotImplementedException {
  669.     
  670.         Connection connection = null;
  671.         try{
  672.             
  673.             // check parameters
  674.             if(tableId<=0){
  675.                 throw this.newServiceExceptionParameterTableIdLessEqualsZero();
  676.             }
  677.             
  678.             // ISQLQueryObject
  679.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  680.             sqlQueryObject.setANDLogicOperator(true);
  681.             // Connection sql
  682.             connection = this.jdbcServiceManager.getConnection();

  684.             return this.serviceSearch.inUse(this.jdbcProperties,this.log,connection,sqlQueryObject,tableId);        
  685.     
  686.         }catch(ServiceException | NotImplementedException e){
  687.             this.logError(e); throw e;
  688.         }catch(NotFoundException e){
  689.             this.logDebug(e); throw e;
  690.         }catch(Exception e){
  691.             this.logError(e); throw new ServiceException("InUse(tableId) not completed: "+e.getMessage(),e);
  692.         }finally{
  693.             if(connection!=null){
  694.                 this.jdbcServiceManager.closeConnection(connection);
  695.             }
  696.         }
  697.     
  698.     }
  699.     
  700.     
  701.     @Override
  702.     public void disableSelectForUpdate() throws ServiceException,NotImplementedException {
  703.         this.jdbcSqlObjectFactory.setSelectForUpdate(false);
  704.     }

  706.     @Override
  707.     public void enableSelectForUpdate() throws ServiceException,NotImplementedException {
  708.         this.jdbcSqlObjectFactory.setSelectForUpdate(true);
  709.     }
  710.     
  711.     
  712.     @Override
  713.     public List<List<Object>> nativeQuery(String sql,List<Class<?>> returnClassTypes,Object ... param) throws ServiceException,NotFoundException,NotImplementedException{
  714.     
  715.         Connection connection = null;
  716.         try{
  717.             
  718.             // check parameters
  719.             if(returnClassTypes==null || returnClassTypes.isEmpty()){
  720.                 throw new ServiceException("Parameter 'returnClassTypes' is less equals 0");
  721.             }
  722.             
  723.             // ISQLQueryObject
  724.             ISQLQueryObject sqlQueryObject = this.jdbcSqlObjectFactory.createSQLQueryObject(this.jdbcProperties.getDatabase());
  725.             sqlQueryObject.setANDLogicOperator(true);
  726.             // Connection sql
  727.             connection = this.jdbcServiceManager.getConnection();

  729.             return this.serviceSearch.nativeQuery(this.jdbcProperties,this.log,connection,sqlQueryObject,sql,returnClassTypes,param);       
  730.     
  731.         }catch(ServiceException | NotImplementedException e){
  732.             this.logError(e); throw e;
  733.         }catch(NotFoundException e){
  734.             this.logDebug(e); throw e;
  735.         }catch(Exception e){
  736.             this.logError(e); throw new ServiceException("nativeQuery not completed: "+e.getMessage(),e);
  737.         }finally{
  738.             if(connection!=null){
  739.                 this.jdbcServiceManager.closeConnection(connection);
  740.             }
  741.         }
  742.     
  743.     }
  744.     
  745. }
Created with JaCoCo 0.8.8.202204050719