JDBCDumpMessaggioServiceSearchImpl.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.util.List;
  23. import java.util.ArrayList;
  24. import java.util.Map;
  25. import java.io.InputStream;
  26. import java.sql.Connection;
  27. import java.sql.PreparedStatement;
  28. import java.sql.ResultSet;
  29. import java.sql.SQLException;

  31. import org.slf4j.Logger;
  32. import org.openspcoop2.utils.UtilsException;
  33. import org.openspcoop2.utils.jdbc.IJDBCAdapter;
  34. import org.openspcoop2.utils.jdbc.JDBCAdapterException;
  35. import org.openspcoop2.utils.jdbc.JDBCAdapterFactory;
  36. import org.openspcoop2.utils.sql.ISQLQueryObject;
  37. import org.openspcoop2.utils.sql.SQLQueryObjectException;
  38. import org.openspcoop2.generic_project.expression.impl.sql.ISQLFieldConverter;
  39. import org.openspcoop2.generic_project.dao.jdbc.utils.IJDBCFetch;
  40. import org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject;
  41. import org.openspcoop2.generic_project.dao.jdbc.IJDBCServiceSearchWithId;
  42. import org.openspcoop2.core.transazioni.IdDumpMessaggio;
  43. import org.openspcoop2.core.transazioni.constants.TipoMessaggio;
  44. import org.openspcoop2.generic_project.utils.UtilsTemplate;
  45. import org.openspcoop2.generic_project.beans.CustomField;
  46. import org.openspcoop2.generic_project.beans.InUse;
  47. import org.openspcoop2.generic_project.beans.IField;
  48. import org.openspcoop2.generic_project.beans.NonNegativeNumber;
  49. import org.openspcoop2.generic_project.beans.UnionExpression;
  50. import org.openspcoop2.generic_project.beans.Union;
  51. import org.openspcoop2.generic_project.beans.FunctionField;
  52. import org.openspcoop2.generic_project.exception.ExpressionException;
  53. import org.openspcoop2.generic_project.exception.MultipleResultException;
  54. import org.openspcoop2.generic_project.exception.NotFoundException;
  55. import org.openspcoop2.generic_project.exception.NotImplementedException;
  56. import org.openspcoop2.generic_project.exception.ServiceException;
  57. import org.openspcoop2.generic_project.expression.IExpression;
  58. import org.openspcoop2.generic_project.dao.jdbc.JDBCExpression;
  59. import org.openspcoop2.generic_project.dao.jdbc.JDBCPaginatedExpression;

  61. import org.openspcoop2.generic_project.dao.jdbc.JDBCServiceManagerProperties;
  62. import org.openspcoop2.core.transazioni.dao.jdbc.converter.DumpMessaggioFieldConverter;
  63. import org.openspcoop2.core.transazioni.dao.jdbc.fetch.DumpMessaggioFetch;
  64. import org.openspcoop2.core.transazioni.utils.DumpUtils;
  65. import org.openspcoop2.core.transazioni.DumpHeaderTrasporto;
  66. import org.openspcoop2.core.transazioni.DumpHeaderAllegato;
  67. import org.openspcoop2.core.transazioni.DumpContenuto;
  68. import org.openspcoop2.core.transazioni.DumpAllegato;
  69. import org.openspcoop2.core.transazioni.DumpMessaggio;
  70. import org.openspcoop2.core.transazioni.DumpMultipartHeader;

  72. /**     
  73.  * JDBCDumpMessaggioServiceSearchImpl
  74.  *
  75.  * @author Poli Andrea (poli@link.it)
  76.  * @author $Author$
  77.  * @version $Rev$, $Date$
  78.  */
  79. public class JDBCDumpMessaggioServiceSearchImpl implements IJDBCServiceSearchWithId<DumpMessaggio, IdDumpMessaggio, JDBCServiceManager> {

  81.     private DumpMessaggioFieldConverter _dumpMessaggioFieldConverter = null;
  82.     public DumpMessaggioFieldConverter getDumpMessaggioFieldConverter() {
  83.         if(this._dumpMessaggioFieldConverter==null){
  84.             this._dumpMessaggioFieldConverter = new DumpMessaggioFieldConverter(this.jdbcServiceManager.getJdbcProperties().getDatabaseType());
  85.         }       
  86.         return this._dumpMessaggioFieldConverter;
  87.     }
  88.     @Override
  89.     public ISQLFieldConverter getFieldConverter() {
  90.         return this.getDumpMessaggioFieldConverter();
  91.     }
  92.     
  93.     private DumpMessaggioFetch dumpMessaggioFetch = new DumpMessaggioFetch();
  94.     public DumpMessaggioFetch getDumpMessaggioFetch() {
  95.         return this.dumpMessaggioFetch;
  96.     }
  97.     @Override
  98.     public IJDBCFetch getFetch() {
  99.         return getDumpMessaggioFetch();
  100.     }
  101.     
  102.     
  103.     private JDBCServiceManager jdbcServiceManager = null;

  105.     @Override
  106.     public void setServiceManager(JDBCServiceManager serviceManager) throws ServiceException{
  107.         this.jdbcServiceManager = serviceManager;
  108.     }
  109.     
  110.     @Override
  111.     public JDBCServiceManager getServiceManager() throws ServiceException{
  112.         return this.jdbcServiceManager;
  113.     }
  114.     

  116.     @Override
  117.     public IdDumpMessaggio convertToId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, DumpMessaggio dumpMessaggio) throws NotImplementedException, ServiceException, Exception{
  118.     
  119.         IdDumpMessaggio idDumpMessaggio = new IdDumpMessaggio();
  120.         idDumpMessaggio.setIdTransazione(dumpMessaggio.getIdTransazione());
  121.         idDumpMessaggio.setTipoMessaggio(dumpMessaggio.getTipoMessaggio());
  122.         idDumpMessaggio.setServizioApplicativoErogatore(dumpMessaggio.getServizioApplicativoErogatore());
  123.         return idDumpMessaggio;
  124.     }
  125.     
  126.     @Override
  127.     public DumpMessaggio get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdDumpMessaggio id, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {
  128.         Long id_dumpMessaggio = ( (id!=null && id.getId()!=null && id.getId()>0) ? id.getId() : this.findIdDumpMessaggio(jdbcProperties, log, connection, sqlQueryObject, id, true));
  129.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, id_dumpMessaggio,idMappingResolutionBehaviour);
  130.         
  131.         
  132.     }
  133.     
  134.     @Override
  135.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdDumpMessaggio id) throws MultipleResultException, NotImplementedException, ServiceException,Exception {

  137.         Long id_dumpMessaggio = this.findIdDumpMessaggio(jdbcProperties, log, connection, sqlQueryObject, id, false);
  138.         return id_dumpMessaggio != null && id_dumpMessaggio > 0;
  139.         
  140.     }
  141.     
  142.     @Override
  143.     public List<IdDumpMessaggio> findAllIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException, ServiceException,Exception {

  145.         List<IdDumpMessaggio> list = new ArrayList<IdDumpMessaggio>();

  147.         // TODO: implementazione non efficiente. 
  148.         // Per ottenere una implementazione efficiente:
  149.         // 1. Usare metodo select di questa classe indirizzando esattamente i field necessari a create l'ID logico
  150.         // 2. Usare metodo getDumpMessaggioFetch() sul risultato della select per ottenere un oggetto DumpMessaggio
  151.         //    La fetch con la map inserirà nell'oggetto solo i valori estratti 
  152.         // 3. Usare metodo convertToId per ottenere l'id

  154.         List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  155.         
  156.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  157.                 new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  158.         
  159.         for(Long id: ids) {
  160.             
  161.             ISQLQueryObject sqlQueryObjectReadIds = sqlQueryObject.newSQLQueryObject();
  162.             sqlQueryObjectReadIds.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model()));
  163.             sqlQueryObjectReadIds.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ID_TRANSAZIONE, false));
  164.             sqlQueryObjectReadIds.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().TIPO_MESSAGGIO, false));
  165.             sqlQueryObjectReadIds.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().SERVIZIO_APPLICATIVO_EROGATORE, false));
  166.             sqlQueryObjectReadIds.addWhereCondition("id=?");
  167.             
  168.             List<Class<?>> returnTypes = new ArrayList<Class<?>>();
  169.             returnTypes.add(String.class);
  170.             returnTypes.add(String.class);
  171.             returnTypes.add(String.class);
  172.             JDBCObject param = new JDBCObject(id, Long.class);
  173.             List<Object> result = jdbcUtilities.executeQuerySingleResult(sqlQueryObjectReadIds.toString(), jdbcProperties.isShowSql(), returnTypes, param);
  174.             
  175.             IdDumpMessaggio idDumpMessaggio = new IdDumpMessaggio();
  176.             idDumpMessaggio.setIdTransazione((String)result.get(0));
  177.             idDumpMessaggio.setTipoMessaggio(TipoMessaggio.toEnumConstant((String)result.get(1)));
  178.             Object sa = result.get(2);
  179.             if(sa!=null && sa instanceof String) {
  180.                 idDumpMessaggio.setServizioApplicativoErogatore((String)sa);
  181.             }
  182.             list.add(idDumpMessaggio);
  183.         }

  185.         return list;
  186.         
  187.     }
  188.     
  189.     @Override
  190.     public List<DumpMessaggio> findAll(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotImplementedException, ServiceException,Exception {

  192.         List<DumpMessaggio> list = new ArrayList<DumpMessaggio>();
  193.         
  194.         // TODO: implementazione non efficiente. 
  195.         // Per ottenere una implementazione efficiente:
  196.         // 1. Usare metodo select di questa classe indirizzando esattamente i field necessari
  197.         // 2. Usare metodo getDumpMessaggioFetch() sul risultato della select per ottenere un oggetto DumpMessaggio
  198.         //    La fetch con la map inserirà nell'oggetto solo i valori estratti 

  200.         List<Long> ids = this.findAllTableIds(jdbcProperties, log, connection, sqlQueryObject, expression);
  201.         
  202.         for(Long id: ids) {
  203.             list.add(this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour));
  204.         }

  206.         return list;      
  207.         
  208.     }
  209.     
  210.     @Override
  211.     public DumpMessaggio find(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) 
  212.         throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException,Exception {

  214.         long id = this.findTableId(jdbcProperties, log, connection, sqlQueryObject, expression);
  215.         if(id>0){
  216.             return this.get(jdbcProperties, log, connection, sqlQueryObject, id, idMappingResolutionBehaviour);
  217.         }else{
  218.             throw new NotFoundException("Entry with id["+id+"] not found");
  219.         }
  220.         
  221.     }
  222.     
  223.     public JDBCDumpMessaggioStream getContentInputStream(JDBCServiceManagerProperties jdbcProperties, Logger log, 
  224.             Connection connection, JDBCServiceManager jdbcServiceManager, 
  225.             ISQLQueryObject sqlQueryObject, JDBCExpression expression) 
  226.             throws NotFoundException, ServiceException {

  228.         long id = -1;
  229.         try {
  230.             id = this.findTableId(jdbcProperties, log, connection, sqlQueryObject, expression);
  231.         }catch(Exception e) {
  232.             throw new ServiceException(e.getMessage(),e);
  233.         }
  234.         if(id>0){
  235.             try {
  236.                 return getContentInputStream(connection, jdbcServiceManager, 
  237.                         sqlQueryObject,
  238.                         id);
  239.             }catch(Exception e) {
  240.                 throw new ServiceException(e.getMessage(),e);
  241.             }
  242.         }else{
  243.             throw new NotFoundException("Entry with id["+id+"] not found");
  244.         }
  245.         
  246.     }
  247.     private JDBCDumpMessaggioStream getContentInputStream(Connection connection, JDBCServiceManager jdbcServiceManager, 
  248.             ISQLQueryObject sqlQueryObject,
  249.             long id) 
  250.             throws JDBCAdapterException, ExpressionException, SQLQueryObjectException, SQLException, UtilsException {
  251.         IJDBCAdapter jdbcAdapter = JDBCAdapterFactory.createJDBCAdapter(this.getDumpMessaggioFieldConverter().getDatabaseType());
  252.         ISQLQueryObject sqlQueryObjectGetDumpMessaggio = buildSQLQueryObjectGetContentInputStream(sqlQueryObject);
  253.         ResultSet rs = null;
  254.         PreparedStatement pstmt = null;
  255.         try {
  256.             String query = sqlQueryObjectGetDumpMessaggio.createSQLQuery();
  257.             pstmt = connection.prepareStatement(query);
  258.             pstmt.setLong(1, id);
  259.             rs = pstmt.executeQuery();
  260.             if(rs.next()) {
  261.                 InputStream is = jdbcAdapter.getBinaryStream(rs, "contentBodyStream");
  262.                 return new JDBCDumpMessaggioStream(is,
  263.                         rs,pstmt,
  264.                         connection,jdbcServiceManager);
  265.             }
  266.             return null;
  267.         }finally {
  268.             /** OP-1635
  269.                 try {
  270.                     if(rs!=null) {
  271.                         rs.close();
  272.                     }
  273.                 }catch(Exception eClose) {
  274.                     // ignore
  275.                 }
  276.                 try {
  277.                     if(pstmt!=null) {
  278.                         pstmt.close();
  279.                     }
  280.                 }catch(Exception eClose)  {
  281.                     // ignore
  282.                 }
  283.             }
  284.             */
  285.         }
  286.     }
  287.     private ISQLQueryObject buildSQLQueryObjectGetContentInputStream(ISQLQueryObject sqlQueryObject) throws SQLQueryObjectException, ExpressionException {
  288.         ISQLQueryObject sqlQueryObjectGetDumpMessaggio = sqlQueryObject.newSQLQueryObject();
  289.          sqlQueryObjectGetDumpMessaggio.setANDLogicOperator(true);
  290.          sqlQueryObjectGetDumpMessaggio.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model()));
  291.          sqlQueryObjectGetDumpMessaggio.addSelectAliasField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().BODY,true),"contentBodyStream");
  292.          sqlQueryObjectGetDumpMessaggio.addWhereCondition("id=?");
  293.          return sqlQueryObjectGetDumpMessaggio;
  294.     }
  295.     
  296.     @Override
  297.     public NonNegativeNumber count(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws NotImplementedException, ServiceException,Exception {
  298.         
  299.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareCount(jdbcProperties, log, connection, sqlQueryObject, expression,
  300.                                                 this.getDumpMessaggioFieldConverter(), DumpMessaggio.model());
  301.         
  302.         sqlQueryObject.addSelectCountField(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model())+".id","tot",true);
  303.         
  304.         joinEngine(expression,sqlQueryObject);
  305.         
  306.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.count(jdbcProperties, log, connection, sqlQueryObject, expression,
  307.                                                                             this.getDumpMessaggioFieldConverter(), DumpMessaggio.model(),listaQuery);
  308.     }

  310.     @Override
  311.     public InUse inUse(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdDumpMessaggio id) throws NotFoundException, NotImplementedException, ServiceException,Exception {
  312.         
  313.         Long id_dumpMessaggio = this.findIdDumpMessaggio(jdbcProperties, log, connection, sqlQueryObject, id, true);
  314.         return this.inUseEngine(jdbcProperties, log, connection, sqlQueryObject, id_dumpMessaggio);
  315.         
  316.     }

  318.     @Override
  319.     public List<Object> select(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  320.                                                     JDBCPaginatedExpression paginatedExpression, IField field) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  321.         return this.select(jdbcProperties, log, connection, sqlQueryObject,
  322.                                 paginatedExpression, false, field);
  323.     }
  324.     
  325.     @Override
  326.     public List<Object> select(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  327.                                                     JDBCPaginatedExpression paginatedExpression, boolean distinct, IField field) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  328.         List<Map<String,Object>> map = 
  329.             this.select(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression, distinct, new IField[]{field});
  330.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.selectSingleObject(map);
  331.     }
  332.     
  333.     @Override
  334.     public List<Map<String,Object>> select(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  335.                                                     JDBCPaginatedExpression paginatedExpression, IField ... field) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  336.         return this.select(jdbcProperties, log, connection, sqlQueryObject,
  337.                                 paginatedExpression, false, field);
  338.     }
  339.     
  340.     @Override
  341.     public List<Map<String,Object>> select(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  342.                                                     JDBCPaginatedExpression paginatedExpression, boolean distinct, IField ... field) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  343.         
  344.         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.setFields(sqlQueryObject,paginatedExpression,field);
  345.         try{
  346.         
  347.             ISQLQueryObject sqlQueryObjectDistinct = 
  348.                         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareSqlQueryObjectForSelectDistinct(distinct,sqlQueryObject, paginatedExpression, log,
  349.                                                 this.getDumpMessaggioFieldConverter(), field);

  351.             return selectEngine(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression, sqlQueryObjectDistinct);
  352.             
  353.         }finally{
  354.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,paginatedExpression,field);
  355.         }
  356.     }

  358.     @Override
  359.     public Object aggregate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  360.                                                     JDBCExpression expression, FunctionField functionField) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  361.         Map<String,Object> map = 
  362.             this.aggregate(jdbcProperties, log, connection, sqlQueryObject, expression, new FunctionField[]{functionField});
  363.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.selectAggregateObject(map,functionField);
  364.     }
  365.     
  366.     @Override
  367.     public Map<String,Object> aggregate(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  368.                                                     JDBCExpression expression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException,Exception {                                                   
  369.         
  370.         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.setFields(sqlQueryObject,expression,functionField);
  371.         try{
  372.             List<Map<String,Object>> list = selectEngine(jdbcProperties, log, connection, sqlQueryObject, expression);
  373.             return list.get(0);
  374.         }finally{
  375.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,expression,functionField);
  376.         }
  377.     }

  379.     @Override
  380.     public List<Map<String,Object>> groupBy(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  381.                                                     JDBCExpression expression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  382.         
  383.         if(expression.getGroupByFields().isEmpty()){
  384.             throw new ServiceException("GroupBy conditions not found in expression");
  385.         }
  386.         
  387.         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.setFields(sqlQueryObject,expression,functionField);
  388.         try{
  389.             return selectEngine(jdbcProperties, log, connection, sqlQueryObject, expression);
  390.         }finally{
  391.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,expression,functionField);
  392.         }
  393.     }
  394.     

  396.     @Override
  397.     public List<Map<String,Object>> groupBy(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  398.                                                     JDBCPaginatedExpression paginatedExpression, FunctionField ... functionField) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  399.         
  400.         if(paginatedExpression.getGroupByFields().isEmpty()){
  401.             throw new ServiceException("GroupBy conditions not found in expression");
  402.         }
  403.         
  404.         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.setFields(sqlQueryObject,paginatedExpression,functionField);
  405.         try{
  406.             return selectEngine(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression);
  407.         }finally{
  408.             org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.removeFields(sqlQueryObject,paginatedExpression,functionField);
  409.         }
  410.     }
  411.     
  412.     protected List<Map<String,Object>> selectEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  413.                                                 IExpression expression) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  414.         return selectEngine(jdbcProperties, log, connection, sqlQueryObject, expression, null);
  415.     }
  416.     protected List<Map<String,Object>> selectEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  417.                                                 IExpression expression, ISQLQueryObject sqlQueryObjectDistinct) throws ServiceException,NotFoundException,NotImplementedException,Exception {
  418.         
  419.         List<Object> listaQuery = new ArrayList<>();
  420.         List<JDBCObject> listaParams = new ArrayList<>();
  421.         List<Object> returnField = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareSelect(jdbcProperties, log, connection, sqlQueryObject, 
  422.                                 expression, this.getDumpMessaggioFieldConverter(), DumpMessaggio.model(), 
  423.                                 listaQuery,listaParams);
  424.         
  425.         joinEngine(expression,sqlQueryObject);
  426.         
  427.         List<Map<String,Object>> list = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.select(jdbcProperties, log, connection,
  428.                                         org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareSqlQueryObjectForSelectDistinct(sqlQueryObject,sqlQueryObjectDistinct), 
  429.                                         expression, this.getDumpMessaggioFieldConverter(), DumpMessaggio.model(),
  430.                                         listaQuery,listaParams,returnField);
  431.         if(list!=null && !list.isEmpty()){
  432.             return list;
  433.         }
  434.         else{
  435.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  436.         }
  437.     }
  438.     
  439.     @Override
  440.     public List<Map<String,Object>> union(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  441.                                                 Union union, UnionExpression ... unionExpression) throws ServiceException,NotFoundException,NotImplementedException,Exception {     
  442.         
  443.         List<ISQLQueryObject> sqlQueryObjectInnerList = new ArrayList<>();
  444.         List<JDBCObject> jdbcObjects = new ArrayList<>();
  445.         List<Class<?>> returnClassTypes = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareUnion(jdbcProperties, log, connection, sqlQueryObject, 
  446.                                 this.getDumpMessaggioFieldConverter(), DumpMessaggio.model(), 
  447.                                 sqlQueryObjectInnerList, jdbcObjects, union, unionExpression);
  448.         
  449.         if(unionExpression!=null){
  450.             for (int i = 0; i < unionExpression.length; i++) {
  451.                 UnionExpression ue = unionExpression[i];
  452.                 IExpression expression = ue.getExpression();
  453.                 joinEngine(expression,sqlQueryObjectInnerList.get(i));
  454.             }
  455.         }
  456.         
  457.         List<Map<String,Object>> list = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.union(jdbcProperties, log, connection, sqlQueryObject, 
  458.                                         this.getDumpMessaggioFieldConverter(), DumpMessaggio.model(), 
  459.                                         sqlQueryObjectInnerList, jdbcObjects, returnClassTypes, union, unionExpression);
  460.         if(list!=null && !list.isEmpty()){
  461.             return list;
  462.         }
  463.         else{
  464.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  465.         }                               
  466.     }
  467.     
  468.     @Override
  469.     public NonNegativeNumber unionCount(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  470.                                                 Union union, UnionExpression ... unionExpression) throws ServiceException,NotFoundException,NotImplementedException,Exception {     
  471.         
  472.         List<ISQLQueryObject> sqlQueryObjectInnerList = new ArrayList<>();
  473.         List<JDBCObject> jdbcObjects = new ArrayList<>();
  474.         List<Class<?>> returnClassTypes = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareUnionCount(jdbcProperties, log, connection, sqlQueryObject, 
  475.                                 this.getDumpMessaggioFieldConverter(), DumpMessaggio.model(), 
  476.                                 sqlQueryObjectInnerList, jdbcObjects, union, unionExpression);
  477.         
  478.         if(unionExpression!=null){
  479.             for (int i = 0; i < unionExpression.length; i++) {
  480.                 UnionExpression ue = unionExpression[i];
  481.                 IExpression expression = ue.getExpression();
  482.                 joinEngine(expression,sqlQueryObjectInnerList.get(i));
  483.             }
  484.         }
  485.         
  486.         NonNegativeNumber number = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.unionCount(jdbcProperties, log, connection, sqlQueryObject, 
  487.                                         this.getDumpMessaggioFieldConverter(), DumpMessaggio.model(), 
  488.                                         sqlQueryObjectInnerList, jdbcObjects, returnClassTypes, union, unionExpression);
  489.         if(number!=null && number.longValue()>=0){
  490.             return number;
  491.         }
  492.         else{
  493.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  494.         }
  495.     }



  499.     // -- ConstructorExpression 

  501.     @Override
  502.     public JDBCExpression newExpression(Logger log) throws NotImplementedException, ServiceException {
  503.         try{
  504.             return new JDBCExpression(this.getDumpMessaggioFieldConverter());
  505.         }catch(Exception e){
  506.             throw new ServiceException(e);
  507.         }
  508.     }


  511.     @Override
  512.     public JDBCPaginatedExpression newPaginatedExpression(Logger log) throws NotImplementedException, ServiceException {
  513.         try{
  514.             return new JDBCPaginatedExpression(this.getDumpMessaggioFieldConverter());
  515.         }catch(Exception e){
  516.             throw new ServiceException(e);
  517.         }
  518.     }
  519.     
  520.     @Override
  521.     public JDBCExpression toExpression(JDBCPaginatedExpression paginatedExpression, Logger log) throws NotImplementedException, ServiceException {
  522.         try{
  523.             return new JDBCExpression(paginatedExpression);
  524.         }catch(Exception e){
  525.             throw new ServiceException(e);
  526.         }
  527.     }

  529.     @Override
  530.     public JDBCPaginatedExpression toPaginatedExpression(JDBCExpression expression, Logger log) throws NotImplementedException, ServiceException {
  531.         try{
  532.             return new JDBCPaginatedExpression(expression);
  533.         }catch(Exception e){
  534.             throw new ServiceException(e);
  535.         }
  536.     }
  537.     
  538.     
  539.     
  540.     // -- DB

  542.     @Override
  543.     public void mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdDumpMessaggio id, DumpMessaggio obj) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  544.         _mappingTableIds(jdbcProperties,log,connection,sqlQueryObject,obj,
  545.                 this.get(jdbcProperties,log,connection,sqlQueryObject,id,null));
  546.     }
  547.     
  548.     @Override
  549.     public void mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, DumpMessaggio obj) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  550.         _mappingTableIds(jdbcProperties,log,connection,sqlQueryObject,obj,
  551.                 this.get(jdbcProperties,log,connection,sqlQueryObject,tableId,null));
  552.     }
  553.     private void _mappingTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, DumpMessaggio obj, DumpMessaggio imgSaved) throws NotFoundException,NotImplementedException,ServiceException,Exception{
  554.         if(imgSaved==null){
  555.             return;
  556.         }
  557.         obj.setId(imgSaved.getId());
  558.         if(obj.getMultipartHeaderList()!=null){
  559.             List<org.openspcoop2.core.transazioni.DumpMultipartHeader> listObj_ = obj.getMultipartHeaderList();
  560.             for(org.openspcoop2.core.transazioni.DumpMultipartHeader itemObj_ : listObj_){
  561.                 org.openspcoop2.core.transazioni.DumpMultipartHeader itemAlreadySaved_ = null;
  562.                 if(imgSaved.getMultipartHeaderList()!=null){
  563.                     List<org.openspcoop2.core.transazioni.DumpMultipartHeader> listImgSaved_ = imgSaved.getMultipartHeaderList();
  564.                     for(org.openspcoop2.core.transazioni.DumpMultipartHeader itemImgSaved_ : listImgSaved_){
  565.                         boolean objEqualsToImgSaved_ = false;
  566.                         objEqualsToImgSaved_ = org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getNome(),itemImgSaved_.getNome());
  567.                         if(objEqualsToImgSaved_){
  568.                             itemAlreadySaved_=itemImgSaved_;
  569.                             break;
  570.                         }
  571.                     }
  572.                 }
  573.                 if(itemAlreadySaved_!=null){
  574.                     itemObj_.setId(itemAlreadySaved_.getId());
  575.                 }
  576.             }
  577.         }
  578.         if(obj.getHeaderTrasportoList()!=null){
  579.             List<org.openspcoop2.core.transazioni.DumpHeaderTrasporto> listObj_ = obj.getHeaderTrasportoList();
  580.             for(org.openspcoop2.core.transazioni.DumpHeaderTrasporto itemObj_ : listObj_){
  581.                 org.openspcoop2.core.transazioni.DumpHeaderTrasporto itemAlreadySaved_ = null;
  582.                 if(imgSaved.getHeaderTrasportoList()!=null){
  583.                     List<org.openspcoop2.core.transazioni.DumpHeaderTrasporto> listImgSaved_ = imgSaved.getHeaderTrasportoList();
  584.                     for(org.openspcoop2.core.transazioni.DumpHeaderTrasporto itemImgSaved_ : listImgSaved_){
  585.                         boolean objEqualsToImgSaved_ = false;
  586.                         objEqualsToImgSaved_ = org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getNome(),itemImgSaved_.getNome());
  587.                         if(objEqualsToImgSaved_){
  588.                             itemAlreadySaved_=itemImgSaved_;
  589.                             break;
  590.                         }
  591.                     }
  592.                 }
  593.                 if(itemAlreadySaved_!=null){
  594.                     itemObj_.setId(itemAlreadySaved_.getId());
  595.                 }
  596.             }
  597.         }
  598.         if(obj.getAllegatoList()!=null){
  599.             List<org.openspcoop2.core.transazioni.DumpAllegato> listObj_ = obj.getAllegatoList();
  600.             for(org.openspcoop2.core.transazioni.DumpAllegato itemObj_ : listObj_){
  601.                 org.openspcoop2.core.transazioni.DumpAllegato itemAlreadySaved_ = null;
  602.                 if(imgSaved.getAllegatoList()!=null){
  603.                     List<org.openspcoop2.core.transazioni.DumpAllegato> listImgSaved_ = imgSaved.getAllegatoList();
  604.                     for(org.openspcoop2.core.transazioni.DumpAllegato itemImgSaved_ : listImgSaved_){
  605.                         boolean objEqualsToImgSaved_ = false;
  606.                         objEqualsToImgSaved_ = org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getContentId(),itemImgSaved_.getContentId());
  607.                         if(objEqualsToImgSaved_){
  608.                             itemAlreadySaved_=itemImgSaved_;
  609.                             break;
  610.                         }
  611.                     }
  612.                 }
  613.                 if(itemAlreadySaved_!=null){
  614.                     itemObj_.setId(itemAlreadySaved_.getId());
  615.                     if(itemObj_.getHeaderList()!=null){
  616.                         List<org.openspcoop2.core.transazioni.DumpHeaderAllegato> listObj_allegato = itemObj_.getHeaderList();
  617.                         for(org.openspcoop2.core.transazioni.DumpHeaderAllegato itemObj_allegato : listObj_allegato){
  618.                             org.openspcoop2.core.transazioni.DumpHeaderAllegato itemAlreadySaved_allegato = null;
  619.                             if(itemAlreadySaved_.getHeaderList()!=null){
  620.                                 List<org.openspcoop2.core.transazioni.DumpHeaderAllegato> listImgSaved_allegato = itemAlreadySaved_.getHeaderList();
  621.                                 for(org.openspcoop2.core.transazioni.DumpHeaderAllegato itemImgSaved_allegato : listImgSaved_allegato){
  622.                                     boolean objEqualsToImgSaved_allegato = false;
  623.                                     objEqualsToImgSaved_allegato = org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_allegato.getNome(),itemImgSaved_allegato.getNome());
  624.                                     if(objEqualsToImgSaved_allegato){
  625.                                         itemAlreadySaved_allegato=itemImgSaved_allegato;
  626.                                         break;
  627.                                     }
  628.                                 }
  629.                             }
  630.                             if(itemAlreadySaved_allegato!=null){
  631.                                 itemObj_allegato.setId(itemAlreadySaved_allegato.getId());
  632.                             }
  633.                         }
  634.                     }
  635.                 }
  636.             }
  637.         }
  638.         if(obj.getContenutoList()!=null){
  639.             List<org.openspcoop2.core.transazioni.DumpContenuto> listObj_ = obj.getContenutoList();
  640.             for(org.openspcoop2.core.transazioni.DumpContenuto itemObj_ : listObj_){
  641.                 org.openspcoop2.core.transazioni.DumpContenuto itemAlreadySaved_ = null;
  642.                 if(imgSaved.getContenutoList()!=null){
  643.                     List<org.openspcoop2.core.transazioni.DumpContenuto> listImgSaved_ = imgSaved.getContenutoList();
  644.                     for(org.openspcoop2.core.transazioni.DumpContenuto itemImgSaved_ : listImgSaved_){
  645.                         boolean objEqualsToImgSaved_ = false;
  646.                         objEqualsToImgSaved_ = org.openspcoop2.generic_project.utils.Utilities.equals(itemObj_.getNome(),itemImgSaved_.getNome());
  647.                         if(objEqualsToImgSaved_){
  648.                             itemAlreadySaved_=itemImgSaved_;
  649.                             break;
  650.                         }
  651.                     }
  652.                 }
  653.                 if(itemAlreadySaved_!=null){
  654.                     itemObj_.setId(itemAlreadySaved_.getId());
  655.                 }
  656.             }
  657.         }

  659.     }
  660.     
  661.     @Override
  662.     public DumpMessaggio get(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  663.         return this.getEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId), idMappingResolutionBehaviour);
  664.     }
  665.     
  666.     protected DumpMessaggio getEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId, org.openspcoop2.generic_project.beans.IDMappingBehaviour idMappingResolutionBehaviour) throws NotFoundException, MultipleResultException, NotImplementedException, ServiceException, Exception {
  667.     
  668.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  669.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  670.         
  671.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();
  672.                 
  673.         DumpMessaggio dumpMessaggio = new DumpMessaggio();
  674.         
  675.         List<JDBCObject> listJDBCObject = new ArrayList<>();
  676.         
  677.         // Object dumpMessaggio
  678.         ISQLQueryObject sqlQueryObjectGet_dumpMessaggio = sqlQueryObjectGet.newSQLQueryObject();
  679.         sqlQueryObjectGet_dumpMessaggio.setANDLogicOperator(true);
  680.         sqlQueryObjectGet_dumpMessaggio.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model()));
  681.         sqlQueryObjectGet_dumpMessaggio.addSelectField("id");
  682.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ID_TRANSAZIONE,true));
  683.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().PROTOCOLLO,true));
  684.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().SERVIZIO_APPLICATIVO_EROGATORE,true));
  685.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().DATA_CONSEGNA_EROGATORE,true));
  686.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().TIPO_MESSAGGIO,true));
  687.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().FORMATO_MESSAGGIO,true));
  688.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENT_TYPE,true));
  689.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENT_LENGTH,true));
  690.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_CONTENT_TYPE,true));
  691.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_CONTENT_ID,true));
  692.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_CONTENT_LOCATION,true));
  693.         DumpUtils.selectContentByThreshold(sqlQueryObjectGet_dumpMessaggio, this.getDumpMessaggioFieldConverter(), listJDBCObject);
  694.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().DUMP_TIMESTAMP,true));
  695.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESS_HEADER,true));
  696.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESS_FILENAME,true));
  697.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESS_CONTENT,true));
  698.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESS_CONFIG_ID,true));
  699.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESS_TIMESTAMP,true));
  700.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().POST_PROCESSED,true));
  701.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_HEADER_EXT,true));
  702.         sqlQueryObjectGet_dumpMessaggio.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().HEADER_EXT,true));
  703.         sqlQueryObjectGet_dumpMessaggio.addWhereCondition("id=?");

  705.         // Get dumpMessaggio
  706.         listJDBCObject.add(new JDBCObject(tableId,Long.class));
  707.         dumpMessaggio = (DumpMessaggio) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet_dumpMessaggio.createSQLQuery(), jdbcProperties.isShowSql(), DumpMessaggio.model(), this.getDumpMessaggioFetch(),
  708.                 listJDBCObject.toArray(new JDBCObject[1]));



  712.         // Object dumpMessaggio_dumpMultipartHeader
  713.         ISQLQueryObject sqlQueryObjectGet_dumpMessaggio_dumpMultipartHeader = sqlQueryObjectGet.newSQLQueryObject();
  714.         sqlQueryObjectGet_dumpMessaggio_dumpMultipartHeader.setANDLogicOperator(true);
  715.         sqlQueryObjectGet_dumpMessaggio_dumpMultipartHeader.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().MULTIPART_HEADER));
  716.         sqlQueryObjectGet_dumpMessaggio_dumpMultipartHeader.addSelectField("id");
  717.         sqlQueryObjectGet_dumpMessaggio_dumpMultipartHeader.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_HEADER.NOME,true));
  718.         sqlQueryObjectGet_dumpMessaggio_dumpMultipartHeader.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_HEADER.VALORE,true));
  719.         sqlQueryObjectGet_dumpMessaggio_dumpMultipartHeader.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().MULTIPART_HEADER.DUMP_TIMESTAMP,true));
  720.         sqlQueryObjectGet_dumpMessaggio_dumpMultipartHeader.addWhereCondition("id_messaggio=?");

  722.         // Get dumpMessaggio_dumpMultipartHeader
  723.         java.util.List<Object> dumpMessaggio_dumpMultipartHeader_list = jdbcUtilities.executeQuery(sqlQueryObjectGet_dumpMessaggio_dumpMultipartHeader.createSQLQuery(), jdbcProperties.isShowSql(), DumpMessaggio.model().MULTIPART_HEADER, this.getDumpMessaggioFetch(),
  724.             new JDBCObject(dumpMessaggio.getId(),Long.class));

  726.         if(dumpMessaggio_dumpMultipartHeader_list != null) {
  727.             for (Object dumpMessaggio_dumpMultipartHeader_object: dumpMessaggio_dumpMultipartHeader_list) {
  728.                 DumpMultipartHeader dumpMessaggio_dumpMultipartHeader = (DumpMultipartHeader) dumpMessaggio_dumpMultipartHeader_object;

  730.                 // Bug fix OPPT-466 per gestione empty string as null on oracle
  731.                 // Rilasciare il vincolo di not null 'fisico' sul database.
  732.                 // Imporlo logicamente, in modo che non siano permessi insert o update con valori null.
  733.                 // Dopodichè, se nella get viene recuperato un valore null, deve essere trasformato in stringa vuota.
  734.                 if(dumpMessaggio_dumpMultipartHeader.getValore()==null){
  735.                     dumpMessaggio_dumpMultipartHeader.setValore("");
  736.                 }

  738.                 dumpMessaggio.addMultipartHeader(dumpMessaggio_dumpMultipartHeader);
  739.             }
  740.         }

  742.         // Object dumpMessaggio_dumpHeaderTrasporto
  743.         ISQLQueryObject sqlQueryObjectGet_dumpMessaggio_dumpHeaderTrasporto = sqlQueryObjectGet.newSQLQueryObject();
  744.         sqlQueryObjectGet_dumpMessaggio_dumpHeaderTrasporto.setANDLogicOperator(true);
  745.         sqlQueryObjectGet_dumpMessaggio_dumpHeaderTrasporto.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().HEADER_TRASPORTO));
  746.         sqlQueryObjectGet_dumpMessaggio_dumpHeaderTrasporto.addSelectField("id");
  747.         sqlQueryObjectGet_dumpMessaggio_dumpHeaderTrasporto.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().HEADER_TRASPORTO.NOME,true));
  748.         sqlQueryObjectGet_dumpMessaggio_dumpHeaderTrasporto.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().HEADER_TRASPORTO.VALORE,true));
  749.         sqlQueryObjectGet_dumpMessaggio_dumpHeaderTrasporto.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().HEADER_TRASPORTO.DUMP_TIMESTAMP,true));
  750.         sqlQueryObjectGet_dumpMessaggio_dumpHeaderTrasporto.addWhereCondition("id_messaggio=?");

  752.         // Get dumpMessaggio_dumpHeaderTrasporto
  753.         java.util.List<Object> dumpMessaggio_dumpHeaderTrasporto_list = jdbcUtilities.executeQuery(sqlQueryObjectGet_dumpMessaggio_dumpHeaderTrasporto.createSQLQuery(), jdbcProperties.isShowSql(), DumpMessaggio.model().HEADER_TRASPORTO, this.getDumpMessaggioFetch(),
  754.             new JDBCObject(dumpMessaggio.getId(),Long.class));

  756.         if(dumpMessaggio_dumpHeaderTrasporto_list != null) {
  757.             for (Object dumpMessaggio_dumpHeaderTrasporto_object: dumpMessaggio_dumpHeaderTrasporto_list) {
  758.                 DumpHeaderTrasporto dumpMessaggio_dumpHeaderTrasporto = (DumpHeaderTrasporto) dumpMessaggio_dumpHeaderTrasporto_object;

  760.                 // Bug fix OPPT-466 per gestione empty string as null on oracle
  761.                 // Rilasciare il vincolo di not null 'fisico' sul database.
  762.                 // Imporlo logicamente, in modo che non siano permessi insert o update con valori null.
  763.                 // Dopodichè, se nella get viene recuperato un valore null, deve essere trasformato in stringa vuota.
  764.                 if(dumpMessaggio_dumpHeaderTrasporto.getValore()==null){
  765.                     dumpMessaggio_dumpHeaderTrasporto.setValore("");
  766.                 }

  768.                 dumpMessaggio.addHeaderTrasporto(dumpMessaggio_dumpHeaderTrasporto);
  769.             }
  770.         }

  772.         // Object dumpMessaggio_dumpAllegato
  773.         ISQLQueryObject sqlQueryObjectGet_dumpMessaggio_dumpAllegato = sqlQueryObjectGet.newSQLQueryObject();
  774.         sqlQueryObjectGet_dumpMessaggio_dumpAllegato.setANDLogicOperator(true);
  775.         sqlQueryObjectGet_dumpMessaggio_dumpAllegato.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO));
  776.         sqlQueryObjectGet_dumpMessaggio_dumpAllegato.addSelectField("id");
  777.         sqlQueryObjectGet_dumpMessaggio_dumpAllegato.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.CONTENT_TYPE,true));
  778.         sqlQueryObjectGet_dumpMessaggio_dumpAllegato.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.CONTENT_ID,true));
  779.         sqlQueryObjectGet_dumpMessaggio_dumpAllegato.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.CONTENT_LOCATION,true));
  780.         sqlQueryObjectGet_dumpMessaggio_dumpAllegato.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.ALLEGATO,true));
  781.         sqlQueryObjectGet_dumpMessaggio_dumpAllegato.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.DUMP_TIMESTAMP,true));
  782.         sqlQueryObjectGet_dumpMessaggio_dumpAllegato.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER_EXT,true));
  783.         sqlQueryObjectGet_dumpMessaggio_dumpAllegato.addWhereCondition("id_messaggio=?");

  785.         // Get dumpMessaggio_dumpAllegato
  786.         java.util.List<Object> dumpMessaggio_dumpAllegato_list = jdbcUtilities.executeQuery(sqlQueryObjectGet_dumpMessaggio_dumpAllegato.createSQLQuery(), jdbcProperties.isShowSql(), DumpMessaggio.model().ALLEGATO, this.getDumpMessaggioFetch(),
  787.             new JDBCObject(dumpMessaggio.getId(),Long.class));

  789.         if(dumpMessaggio_dumpAllegato_list != null) {
  790.             for (Object dumpMessaggio_dumpAllegato_object: dumpMessaggio_dumpAllegato_list) {
  791.                 DumpAllegato dumpMessaggio_dumpAllegato = (DumpAllegato) dumpMessaggio_dumpAllegato_object;



  795.                 // Object dumpMessaggio_dumpAllegato_dumpHeaderAllegato
  796.                 ISQLQueryObject sqlQueryObjectGet_dumpMessaggio_dumpAllegato_dumpHeaderAllegato = sqlQueryObjectGet.newSQLQueryObject();
  797.                 sqlQueryObjectGet_dumpMessaggio_dumpAllegato_dumpHeaderAllegato.setANDLogicOperator(true);
  798.                 sqlQueryObjectGet_dumpMessaggio_dumpAllegato_dumpHeaderAllegato.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO.HEADER));
  799.                 sqlQueryObjectGet_dumpMessaggio_dumpAllegato_dumpHeaderAllegato.addSelectField("id");
  800.                 sqlQueryObjectGet_dumpMessaggio_dumpAllegato_dumpHeaderAllegato.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER.NOME,true));
  801.                 sqlQueryObjectGet_dumpMessaggio_dumpAllegato_dumpHeaderAllegato.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER.VALORE,true));
  802.                 sqlQueryObjectGet_dumpMessaggio_dumpAllegato_dumpHeaderAllegato.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ALLEGATO.HEADER.DUMP_TIMESTAMP,true));
  803.                 sqlQueryObjectGet_dumpMessaggio_dumpAllegato_dumpHeaderAllegato.addWhereCondition("id_allegato=?");

  805.                 // Get dumpMessaggio_dumpAllegato_dumpHeaderAllegato
  806.                 java.util.List<Object> dumpMessaggio_dumpAllegato_dumpHeaderAllegato_list = jdbcUtilities.executeQuery(sqlQueryObjectGet_dumpMessaggio_dumpAllegato_dumpHeaderAllegato.createSQLQuery(), jdbcProperties.isShowSql(), DumpMessaggio.model().ALLEGATO.HEADER, this.getDumpMessaggioFetch(),
  807.                     new JDBCObject(dumpMessaggio_dumpAllegato.getId(),Long.class));

  809.                 if(dumpMessaggio_dumpAllegato_dumpHeaderAllegato_list != null) {
  810.                     for (Object dumpMessaggio_dumpAllegato_dumpHeaderAllegato_object: dumpMessaggio_dumpAllegato_dumpHeaderAllegato_list) {
  811.                         DumpHeaderAllegato dumpMessaggio_dumpAllegato_dumpHeaderAllegato = (DumpHeaderAllegato) dumpMessaggio_dumpAllegato_dumpHeaderAllegato_object;

  813.                         // Bug fix OPPT-466 per gestione empty string as null on oracle
  814.                         // Rilasciare il vincolo di not null 'fisico' sul database.
  815.                         // Imporlo logicamente, in modo che non siano permessi insert o update con valori null.
  816.                         // Dopodichè, se nella get viene recuperato un valore null, deve essere trasformato in stringa vuota.
  817.                         if(dumpMessaggio_dumpAllegato_dumpHeaderAllegato.getValore()==null){
  818.                             dumpMessaggio_dumpAllegato_dumpHeaderAllegato.setValore("");
  819.                         }

  821.                         dumpMessaggio_dumpAllegato.addHeader(dumpMessaggio_dumpAllegato_dumpHeaderAllegato);
  822.                     }
  823.                 }
  824.                 dumpMessaggio.addAllegato(dumpMessaggio_dumpAllegato);
  825.             }
  826.         }

  828.         // Object dumpMessaggio_dumpContenuto
  829.         ISQLQueryObject sqlQueryObjectGet_dumpMessaggio_dumpContenuto = sqlQueryObjectGet.newSQLQueryObject();
  830.         sqlQueryObjectGet_dumpMessaggio_dumpContenuto.setANDLogicOperator(true);
  831.         sqlQueryObjectGet_dumpMessaggio_dumpContenuto.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().CONTENUTO));
  832.         sqlQueryObjectGet_dumpMessaggio_dumpContenuto.addSelectField("id");
  833.         sqlQueryObjectGet_dumpMessaggio_dumpContenuto.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENUTO.NOME,true));
  834.         sqlQueryObjectGet_dumpMessaggio_dumpContenuto.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENUTO.VALORE,true));
  835.         sqlQueryObjectGet_dumpMessaggio_dumpContenuto.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENUTO.VALORE_AS_BYTES,true));
  836.         sqlQueryObjectGet_dumpMessaggio_dumpContenuto.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().CONTENUTO.DUMP_TIMESTAMP,true));
  837.         sqlQueryObjectGet_dumpMessaggio_dumpContenuto.addWhereCondition("id_messaggio=?");

  839.         // Get dumpMessaggio_dumpContenuto
  840.         java.util.List<Object> dumpMessaggio_dumpContenuto_list = jdbcUtilities.executeQuery(sqlQueryObjectGet_dumpMessaggio_dumpContenuto.createSQLQuery(), jdbcProperties.isShowSql(), DumpMessaggio.model().CONTENUTO, this.getDumpMessaggioFetch(),
  841.             new JDBCObject(dumpMessaggio.getId(),Long.class));

  843.         if(dumpMessaggio_dumpContenuto_list != null) {
  844.             for (Object dumpMessaggio_dumpContenuto_object: dumpMessaggio_dumpContenuto_list) {
  845.                 DumpContenuto dumpMessaggio_dumpContenuto = (DumpContenuto) dumpMessaggio_dumpContenuto_object;


  848.                 dumpMessaggio.addContenuto(dumpMessaggio_dumpContenuto);
  849.             }
  850.         }

  852.         
  853.         return dumpMessaggio;  
  854.     
  855.     } 
  856.     
  857.     @Override
  858.     public boolean exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  859.         return this._exists(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  860.     }
  861.     
  862.     private boolean _exists(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId) throws MultipleResultException, NotImplementedException, ServiceException, Exception {
  863.     
  864.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  865.                     new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);
  866.                 
  867.         boolean existsDumpMessaggio = false;

  869.         sqlQueryObject = sqlQueryObject.newSQLQueryObject();
  870.         sqlQueryObject.setANDLogicOperator(true);

  872.         sqlQueryObject.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model()));
  873.         sqlQueryObject.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ID_TRANSAZIONE,true));
  874.         sqlQueryObject.addWhereCondition("id=?");


  877.         // Exists dumpMessaggio
  878.         existsDumpMessaggio = jdbcUtilities.exists(sqlQueryObject.createSQLQuery(), jdbcProperties.isShowSql(),
  879.             new JDBCObject(tableId,Long.class));

  881.         
  882.         return existsDumpMessaggio;
  883.     
  884.     }
  885.     
  886.     private void joinEngine(IExpression expression, ISQLQueryObject sqlQueryObject) throws NotImplementedException, ServiceException, Exception{
  887.     
  888.         if(expression.inUseModel(DumpMessaggio.model().ALLEGATO,false)){
  889.             String tableName1 = this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO);
  890.             String tableName2 = this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model());
  891.             sqlQueryObject.addWhereCondition(tableName1+".id_messaggio="+tableName2+".id");
  892.         }
  893.         if(expression.inUseModel(DumpMessaggio.model().ALLEGATO.HEADER,false)){
  894.             String tableName1 = this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO.HEADER);
  895.             String tableName2 = this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO);
  896.             sqlQueryObject.addWhereCondition(tableName1+".id_allegato="+tableName2+".id");
  897.         }
  898.         if(expression.inUseModel(DumpMessaggio.model().CONTENUTO,false)){
  899.             String tableName1 = this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().CONTENUTO);
  900.             String tableName2 = this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model());
  901.             sqlQueryObject.addWhereCondition(tableName1+".id_messaggio="+tableName2+".id");
  902.         }
  903.         if(expression.inUseModel(DumpMessaggio.model().HEADER_TRASPORTO,false)){
  904.             String tableName1 = this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().HEADER_TRASPORTO);
  905.             String tableName2 = this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model());
  906.             sqlQueryObject.addWhereCondition(tableName1+".id_messaggio="+tableName2+".id");
  907.         }
  908.         if(expression.inUseModel(DumpMessaggio.model().MULTIPART_HEADER,false)){
  909.             String tableName1 = this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().MULTIPART_HEADER);
  910.             String tableName2 = this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model());
  911.             sqlQueryObject.addWhereCondition(tableName1+".id_messaggio="+tableName2+".id");
  912.         }
  913.         
  914.         if(expression.inUseModel(DumpMessaggio.model().ALLEGATO.HEADER,false)){
  915.             if(expression.inUseModel(DumpMessaggio.model().ALLEGATO,false)==false){
  916.                 sqlQueryObject.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model().ALLEGATO));
  917.             }
  918.         }
  919.         
  920.     }
  921.     
  922.     protected java.util.List<Object> getRootTablePrimaryKeyValuesEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdDumpMessaggio id) throws NotFoundException, ServiceException, NotImplementedException, Exception{
  923.         // Identificativi
  924.         java.util.List<Object> rootTableIdValues = new java.util.ArrayList<>();
  925.         Long longId = this.findIdDumpMessaggio(jdbcProperties, log, connection, sqlQueryObject.newSQLQueryObject(), id, true);
  926.         rootTableIdValues.add(longId);
  927.         return rootTableIdValues;
  928.     }
  929.     
  930.     protected Map<String, List<IField>> getMapTableToPKColumnEngine() throws NotImplementedException, Exception{
  931.     
  932.         DumpMessaggioFieldConverter converter = this.getDumpMessaggioFieldConverter();
  933.         Map<String, List<IField>> mapTableToPKColumn = new java.util.HashMap<>();
  934.         UtilsTemplate<IField> utilities = new UtilsTemplate<>();

  936.         // DumpMessaggio.model()
  937.         mapTableToPKColumn.put(converter.toTable(DumpMessaggio.model()),
  938.             utilities.newList(
  939.                 new CustomField("id", Long.class, "id", converter.toTable(DumpMessaggio.model()))
  940.             ));

  942.         // DumpMessaggio.model().ALLEGATO
  943.         mapTableToPKColumn.put(converter.toTable(DumpMessaggio.model().ALLEGATO),
  944.             utilities.newList(
  945.                 new CustomField("id", Long.class, "id", converter.toTable(DumpMessaggio.model().ALLEGATO))
  946.             ));

  948.         // DumpMessaggio.model().CONTENUTO
  949.         mapTableToPKColumn.put(converter.toTable(DumpMessaggio.model().CONTENUTO),
  950.             utilities.newList(
  951.                 new CustomField("id", Long.class, "id", converter.toTable(DumpMessaggio.model().CONTENUTO))
  952.             ));

  954.         // DumpMessaggio.model().HEADER_TRASPORTO
  955.         mapTableToPKColumn.put(converter.toTable(DumpMessaggio.model().HEADER_TRASPORTO),
  956.             utilities.newList(
  957.                 new CustomField("id", Long.class, "id", converter.toTable(DumpMessaggio.model().HEADER_TRASPORTO))
  958.             ));

  960.         
  961.         return mapTableToPKColumn;      
  962.     }
  963.     
  964.     @Override
  965.     public List<Long> findAllTableIds(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCPaginatedExpression paginatedExpression) throws ServiceException, NotImplementedException, Exception {
  966.         
  967.         List<Long> list = new ArrayList<Long>();

  969.         sqlQueryObject.setSelectDistinct(true);
  970.         sqlQueryObject.setANDLogicOperator(true);
  971.         sqlQueryObject.addSelectField(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model())+".id");
  972.         Class<?> objectIdClass = Long.class;
  973.         
  974.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFindAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  975.                                                 this.getDumpMessaggioFieldConverter(), DumpMessaggio.model());
  976.         
  977.         joinEngine(paginatedExpression,sqlQueryObject);
  978.         
  979.         List<Object> listObjects = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.findAll(jdbcProperties, log, connection, sqlQueryObject, paginatedExpression,
  980.                                                                             this.getDumpMessaggioFieldConverter(), DumpMessaggio.model(), objectIdClass, listaQuery);
  981.         for(Object object: listObjects) {
  982.             list.add((Long)object);
  983.         }

  985.         return list;
  986.         
  987.     }
  988.     
  989.     @Override
  990.     public long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, JDBCExpression expression) throws ServiceException, NotFoundException, MultipleResultException, NotImplementedException, Exception {
  991.     
  992.         sqlQueryObject.setSelectDistinct(true);
  993.         sqlQueryObject.setANDLogicOperator(true);
  994.         sqlQueryObject.addSelectField(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model())+".id");
  995.         Class<?> objectIdClass = Long.class;
  996.         
  997.         List<Object> listaQuery = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.prepareFind(jdbcProperties, log, connection, sqlQueryObject, expression,
  998.                                                 this.getDumpMessaggioFieldConverter(), DumpMessaggio.model());
  999.         
  1000.         joinEngine(expression,sqlQueryObject);

  1002.         Object res = org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.find(jdbcProperties, log, connection, sqlQueryObject, expression,
  1003.                                                         this.getDumpMessaggioFieldConverter(), DumpMessaggio.model(), objectIdClass, listaQuery);
  1004.         if(res!=null && (((Long) res).longValue()>0) ){
  1005.             return ((Long) res).longValue();
  1006.         }
  1007.         else{
  1008.             throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  1009.         }
  1010.         
  1011.     }

  1013.     @Override
  1014.     public InUse inUse(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId) throws ServiceException, NotFoundException, NotImplementedException, Exception {
  1015.         return this.inUseEngine(jdbcProperties, log, connection, sqlQueryObject, Long.valueOf(tableId));
  1016.     }

  1018.     private InUse inUseEngine(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, Long tableId) throws ServiceException, NotFoundException, NotImplementedException, Exception {

  1020.         InUse inUse = new InUse();
  1021.         inUse.setInUse(false);
  1022.         
  1023.         /* 
  1024.          * TODO: implement code that checks whether the object identified by the id parameter is used by other objects
  1025.         */
  1026.         
  1027.         // Delete this line when you have implemented the method
  1028.         int throwNotImplemented = 1;
  1029.         if(throwNotImplemented==1){
  1030.                 throw new NotImplementedException("NotImplemented");
  1031.         }
  1032.         // Delete this line when you have implemented the method

  1034.         return inUse;

  1036.     }
  1037.     
  1038.     @Override
  1039.     public IdDumpMessaggio findId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, long tableId, boolean throwNotFound)
  1040.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  1041.         
  1042.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  1043.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  1045.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();             

  1047.         // Object _dumpMessaggio
  1048.         sqlQueryObjectGet.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model()));
  1049.         sqlQueryObjectGet.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ID_TRANSAZIONE,true));
  1050.         sqlQueryObjectGet.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().TIPO_MESSAGGIO,true));
  1051.         sqlQueryObjectGet.addSelectField(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().SERVIZIO_APPLICATIVO_EROGATORE,true));
  1052.         sqlQueryObjectGet.setANDLogicOperator(true);
  1053.         sqlQueryObjectGet.addWhereCondition("id=?");

  1055.         // Recupero _dumpMessaggio
  1056.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParams_dumpMessaggio = new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] { 
  1057.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject(tableId,Long.class)
  1058.         };
  1059.         List<Class<?>> listaFieldIdReturnType_dumpMessaggio = new ArrayList<Class<?>>();
  1060.         listaFieldIdReturnType_dumpMessaggio.add(String.class);
  1061.         listaFieldIdReturnType_dumpMessaggio.add(String.class);
  1062.         listaFieldIdReturnType_dumpMessaggio.add(String.class);
  1063.         IdDumpMessaggio id_dumpMessaggio = null;
  1064.         List<Object> listaFieldId_dumpMessaggio = jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  1065.                 listaFieldIdReturnType_dumpMessaggio, searchParams_dumpMessaggio);
  1066.         if(listaFieldId_dumpMessaggio==null || listaFieldId_dumpMessaggio.size()<=0){
  1067.             if(throwNotFound){
  1068.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  1069.             }
  1070.         }
  1071.         else{
  1072.             // set _dumpMessaggio
  1073.             id_dumpMessaggio = new IdDumpMessaggio();
  1074.             id_dumpMessaggio.setIdTransazione((String)listaFieldId_dumpMessaggio.get(0));
  1075.             id_dumpMessaggio.setTipoMessaggio(TipoMessaggio.toEnumConstant((String)listaFieldId_dumpMessaggio.get(1)));
  1076.             Object sa = listaFieldId_dumpMessaggio.get(2);
  1077.             if(sa!=null && sa instanceof String) {
  1078.                 id_dumpMessaggio.setServizioApplicativoErogatore((String)sa);
  1079.             }
  1080.         }
  1081.         
  1082.         return id_dumpMessaggio;
  1083.         
  1084.     }

  1086.     @Override
  1087.     public Long findTableId(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdDumpMessaggio id, boolean throwNotFound)
  1088.             throws NotFoundException, ServiceException, NotImplementedException, Exception {
  1089.     
  1090.         return this.findIdDumpMessaggio(jdbcProperties,log,connection,sqlQueryObject,id,throwNotFound);
  1091.             
  1092.     }
  1093.     
  1094.     @Override
  1095.     public List<List<Object>> nativeQuery(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, 
  1096.                                             String sql,List<Class<?>> returnClassTypes,Object ... param) throws ServiceException,NotFoundException,NotImplementedException,Exception{
  1097.         
  1098.         return org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.nativeQuery(jdbcProperties, log, connection, sqlQueryObject,
  1099.                                                                                             sql,returnClassTypes,param);
  1100.                                                         
  1101.     }
  1102.     
  1103.     protected Long findIdDumpMessaggio(JDBCServiceManagerProperties jdbcProperties, Logger log, Connection connection, ISQLQueryObject sqlQueryObject, IdDumpMessaggio id, boolean throwNotFound) throws NotFoundException, ServiceException, NotImplementedException, Exception {

  1105.         if(jdbcProperties==null) {
  1106.             throw new ServiceException("jdbcProperties parameter is null");
  1107.         }
  1108.         if(sqlQueryObject==null) {
  1109.             throw new ServiceException("sqlQueryObject parameter is null");
  1110.         }
  1111.         if(id==null) {
  1112.             throw new ServiceException("id parameter is null");
  1113.         }
  1114.         
  1115.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities jdbcUtilities = 
  1116.             new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCPreparedStatementUtilities(sqlQueryObject.getTipoDatabaseOpenSPCoop2(), log, connection);

  1118.         ISQLQueryObject sqlQueryObjectGet = sqlQueryObject.newSQLQueryObject();

  1120.         // Object _dumpMessaggio
  1121.         sqlQueryObjectGet.addFromTable(this.getDumpMessaggioFieldConverter().toTable(DumpMessaggio.model()));
  1122.         sqlQueryObjectGet.addSelectField("id");
  1123.         sqlQueryObjectGet.setANDLogicOperator(true);
  1124.         sqlQueryObjectGet.setSelectDistinct(true);
  1125.         sqlQueryObjectGet.addWhereCondition(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().ID_TRANSAZIONE,true)+"=?");
  1126.         sqlQueryObjectGet.addWhereCondition(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().TIPO_MESSAGGIO,true)+"=?");
  1127.         if(id.getServizioApplicativoErogatore() == null) {
  1128.             sqlQueryObjectGet.addWhereIsNotNullCondition(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().SERVIZIO_APPLICATIVO_EROGATORE,true));
  1129.         }
  1130.         else {
  1131.             sqlQueryObjectGet.addWhereCondition(this.getDumpMessaggioFieldConverter().toColumn(DumpMessaggio.model().SERVIZIO_APPLICATIVO_EROGATORE,true)+"=?");
  1132.         }
  1133.         
  1134.         // Recupero _dumpMessaggio
  1135.         List<org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject> searchParamsDumpMessaggioList = new ArrayList<>();
  1136.         searchParamsDumpMessaggioList.add(new JDBCObject(id.getIdTransazione(), String.class));
  1137.         searchParamsDumpMessaggioList.add(new JDBCObject(id.getTipoMessaggioRawEnumValue(), String.class));
  1138.         if(id.getServizioApplicativoErogatore() != null) {
  1139.             searchParamsDumpMessaggioList.add(new JDBCObject(id.getServizioApplicativoErogatore(), String.class));
  1140.         }
  1141.         org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [] searchParamsDumpMessaggio = searchParamsDumpMessaggioList.toArray(new org.openspcoop2.generic_project.dao.jdbc.utils.JDBCObject [1]);

  1143.         Long idDumpMessaggio = null;
  1144.         try{
  1145.             idDumpMessaggio = (Long) jdbcUtilities.executeQuerySingleResult(sqlQueryObjectGet.createSQLQuery(), jdbcProperties.isShowSql(),
  1146.                         Long.class, searchParamsDumpMessaggio);
  1147.         }catch(NotFoundException notFound){
  1148.             if(throwNotFound){
  1149.                 throw new NotFoundException(notFound);
  1150.             }
  1151.         }
  1152.         if(idDumpMessaggio==null || idDumpMessaggio<=0){
  1153.             if(throwNotFound){
  1154.                 throw org.openspcoop2.generic_project.dao.jdbc.utils.GenericJDBCUtilities.newNotFoundException();
  1155.             }
  1156.         }
  1157.         
  1158.         return idDumpMessaggio;
  1159.     }
  1160. }
Created with JaCoCo 0.8.8.202204050719