DriverRegistroServiziDB_accordiRestDriver.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.  */



  23. package org.openspcoop2.core.registry.driver.db;

  25. import java.sql.Connection;
  26. import java.sql.PreparedStatement;
  27. import java.sql.ResultSet;
  28. import java.util.ArrayList;
  29. import java.util.List;

  31. import org.openspcoop2.core.commons.Filtri;
  32. import org.openspcoop2.core.commons.ISearch;
  33. import org.openspcoop2.core.commons.Liste;
  34. import org.openspcoop2.core.commons.SearchUtils;
  35. import org.openspcoop2.core.constants.CostantiDB;
  36. import org.openspcoop2.core.constants.ProprietariProtocolProperty;
  37. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  38. import org.openspcoop2.core.registry.ProtocolProperty;
  39. import org.openspcoop2.core.registry.Resource;
  40. import org.openspcoop2.core.registry.ResourceParameter;
  41. import org.openspcoop2.core.registry.ResourceRepresentation;
  42. import org.openspcoop2.core.registry.ResourceRepresentationJson;
  43. import org.openspcoop2.core.registry.ResourceRepresentationXml;
  44. import org.openspcoop2.core.registry.ResourceRequest;
  45. import org.openspcoop2.core.registry.ResourceResponse;
  46. import org.openspcoop2.core.registry.constants.CostantiRegistroServizi;
  47. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  48. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  49. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  50. import org.openspcoop2.utils.sql.ISQLQueryObject;
  51. import org.openspcoop2.utils.sql.SQLObjectFactory;

  53. /**
  54.  * DriverRegistroServiziDB_accordiRestDriver
  55.  * 
  56.  * 
  57.  * @author Sandra Giangrandi (sandra@link.it)
  58.  * @author Stefano Corallo (corallo@link.it)
  59.  * @author $Author$
  60.  * @version $Rev$, $Date$
  61.  */
  62. public class DriverRegistroServiziDB_accordiRestDriver {

  64.     private DriverRegistroServiziDB driver = null;
  65.     
  66.     protected DriverRegistroServiziDB_accordiRestDriver(DriverRegistroServiziDB driver) {
  67.         this.driver = driver;
  68.     }
  69.     

  71.     protected void readResources(AccordoServizioParteComune as,Connection conParam, boolean readDatiRegistro) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  72.         // Aggiungo resource

  74.         Connection con = null;
  75.         PreparedStatement stm = null;
  76.         ResultSet rs = null;
  77.         String sqlQuery = null;

  79.         try {
  80.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  81.             // prendo la connessione dal pool
  82.             if(conParam!=null)
  83.                 con = conParam;
  84.             else if (this.driver.atomica)
  85.                 con = this.driver.getConnectionFromDatasource("readResources");
  86.             else
  87.                 con = this.driver.globalConnection;

  89.             if(as.getId()==null || as.getId()<=0)
  90.                 throw new Exception("Accordo id non definito");

  92.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  93.             sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES);
  94.             sqlQueryObject.addSelectField("*");
  95.             sqlQueryObject.addWhereCondition("id_accordo = ?");
  96.             sqlQueryObject.setANDLogicOperator(true);
  97.             sqlQueryObject.addOrderBy("path");
  98.             sqlQueryObject.addOrderBy("http_method");
  99.             sqlQueryObject.setSortType(true);
  100.             sqlQuery = sqlQueryObject.createSQLQuery();
  101.             stm = con.prepareStatement(sqlQuery);
  102.             stm.setLong(1, as.getId());

  104.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, as.getId()));
  105.             rs = stm.executeQuery();

  107.             while (rs.next()) {

  109.                 Resource resource = new Resource();

  111.                 String tmp = rs.getString("nome");
  112.                 resource.setNome(((tmp == null || tmp.equals("")) ? null : tmp));

  114.                 tmp = rs.getString("descrizione");
  115.                 resource.setDescrizione(((tmp == null || tmp.equals("")) ? null : tmp));

  117.                 tmp = rs.getString("http_method");
  118.                 resource.setMethod(DriverRegistroServiziDB_LIB.getEnumHttpMethod(((tmp == null || tmp.equals("")) ? null : tmp)));

  120.                 tmp = rs.getString("path");
  121.                 if(tmp!=null) {
  122.                     if(CostantiDB.API_RESOURCE_PATH_ALL_VALUE.equals(tmp.trim())==false) {
  123.                         resource.setPath(tmp);
  124.                     }
  125.                 }
  126.                 
  127.                 tmp = rs.getString("message_type");
  128.                 resource.setMessageType(DriverRegistroServiziDB_LIB.getEnumMessageType((tmp == null || tmp.equals("")) ? null : tmp));
  129.                 
  130.                 tmp = rs.getString("message_type_request");
  131.                 resource.setRequestMessageType(DriverRegistroServiziDB_LIB.getEnumMessageType((tmp == null || tmp.equals("")) ? null : tmp));
  132.                 
  133.                 tmp = rs.getString("message_type_response");
  134.                 resource.setResponseMessageType(DriverRegistroServiziDB_LIB.getEnumMessageType((tmp == null || tmp.equals("")) ? null : tmp));
  135.                 
  136.                 
  137.                 tmp = rs.getString("conferma_ricezione");
  138.                 resource.setConfermaRicezione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  140.                 tmp = rs.getString("consegna_in_ordine");
  141.                 resource.setConsegnaInOrdine(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  143.                 tmp = rs.getString("filtro_duplicati");
  144.                 resource.setFiltroDuplicati(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  146.                 tmp = rs.getString("identificativo_collaborazione");
  147.                 resource.setIdCollaborazione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  149.                 tmp = rs.getString("id_riferimento_richiesta");
  150.                 resource.setIdRiferimentoRichiesta(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(((tmp == null || tmp.equals("")) ? null : tmp)));

  152.                 tmp = rs.getString("scadenza");
  153.                 resource.setScadenza(((tmp == null || tmp.equals("")) ? null : tmp));

  155.                 tmp = rs.getString("profilo_azione");
  156.                 if (tmp == null || tmp.equals(""))
  157.                     resource.setProfAzione(CostantiRegistroServizi.PROFILO_AZIONE_DEFAULT);
  158.                 else
  159.                     resource.setProfAzione(tmp);
  160.                             
  161.                 
  162.                 resource.setIdAccordo(as.getId());

  164.                 long idResource = rs.getLong("id");
  165.                 resource.setId(idResource);

  167.                 if(readDatiRegistro) {
  168.                     // Aggiungo dettagli della richiesta
  169.                     this.readResourcesDetails(resource,true,con);
  170.                     
  171.                     // Aggiungo dettagli della risposta
  172.                     this.readResourcesDetails(resource,false,con);
  173.                 }

  175.                 // Protocol Properties
  176.                 try{
  177.                     List<ProtocolProperty> listPP = DriverRegistroServiziDB_LIB.getListaProtocolProperty(idResource, ProprietariProtocolProperty.RESOURCE, con, 
  178.                             this.driver.tipoDB, this.driver.getDriverUnwrapBYOK());
  179.                     if(listPP!=null && !listPP.isEmpty()){
  180.                         for (ProtocolProperty protocolProperty : listPP) {
  181.                             resource.addProtocolProperty(protocolProperty);
  182.                         }
  183.                     }
  184.                 }catch(DriverRegistroServiziNotFound dNotFound){
  185.                     // ignore
  186.                 }
  187.                 
  188.                 as.addResource(resource);

  190.             }
  191.             rs.close();
  192.             stm.close();

  194.         }catch (DriverRegistroServiziNotFound e) {
  195.             throw e;
  196.         }catch (Exception se) {
  197.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::readResources] Exception :" + se.getMessage(),se);
  198.         } finally {

  200.             JDBCUtilities.closeResources(rs, stm);

  202.             this.driver.closeConnection(conParam, con);

  204.         }
  205.     }
  206.     
  207.     private void readResourcesDetails(Resource resource,boolean request, Connection conParam) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  208.         // Aggiungo resource

  210.         Connection con = null;
  211.         PreparedStatement stm = null;
  212.         ResultSet rs = null;
  213.         String sqlQuery = null;

  215.         try {
  216.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  217.             // prendo la connessione dal pool
  218.             if(conParam!=null)
  219.                 con = conParam;
  220.             else if (this.driver.atomica)
  221.                 con = this.driver.getConnectionFromDatasource("readResourcesDetails(request:"+request+")");
  222.             else
  223.                 con = this.driver.globalConnection;

  225.             if(resource.getId()==null || resource.getId()<=0)
  226.                 throw new Exception("Resource id non definito");

  228.             if(request) {
  229.                 resource.setRequest(new ResourceRequest());
  230.                 resource.getRequest().setIdResource(resource.getId());
  231.                 
  232.                 List<ResourceRepresentation> l = this.readResourcesMedia(resource.getId(), true, con);
  233.                 if(l!=null && l.size() > 0) {
  234.                     resource.getRequest().getRepresentationList().addAll(l);
  235.                 }
  236.                 
  237.                 List<ResourceParameter> lp = this.readResourcesParameters(resource.getId(), true, con);
  238.                 if(lp!=null && lp.size() > 0) {
  239.                     resource.getRequest().getParameterList().addAll(lp);
  240.                 }
  241.             }
  242.             else {
  243.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  244.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_RESPONSE);
  245.                 sqlQueryObject.addSelectField("*");
  246.                 sqlQueryObject.addWhereCondition("id_resource = ?");
  247.                 sqlQueryObject.addOrderBy("status");
  248.                 sqlQueryObject.setANDLogicOperator(true);
  249.                 sqlQuery = sqlQueryObject.createSQLQuery();
  250.                 stm = con.prepareStatement(sqlQuery);
  251.                 stm.setLong(1, resource.getId());
  252.                 this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, resource.getId()));
  253.                 rs = stm.executeQuery();
  254.                 while (rs.next()) {
  255.                     
  256.                     ResourceResponse rr = new ResourceResponse();
  257.                     
  258.                     rr.setIdResource(resource.getId());
  259.                     
  260.                     String tmp = rs.getString("descrizione");
  261.                     rr.setDescrizione(((tmp == null || tmp.equals("")) ? null : tmp));
  262.                     
  263.                     int status = rs.getInt("status");
  264.                     rr.setStatus(status);
  265.                     
  266.                     long idRR = rs.getLong("id");
  267.                     rr.setId(idRR);
  268.                                         
  269.                     List<ResourceRepresentation> l = this.readResourcesMedia(idRR, false, con);
  270.                     if(l!=null && l.size() > 0) {
  271.                         rr.getRepresentationList().addAll(l);
  272.                     }
  273.                     
  274.                     List<ResourceParameter> lp = this.readResourcesParameters(idRR, false, con);
  275.                     if(lp!=null && lp.size() > 0) {
  276.                         rr.getParameterList().addAll(lp);
  277.                     }
  278.                     
  279.                     resource.addResponse(rr);
  280.                 }
  281.                 rs.close();
  282.                 stm.close();
  283.             }

  285.         }catch (DriverRegistroServiziNotFound e) {
  286.             throw e;
  287.         }catch (Exception se) {
  288.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::readResourcesDetails] Exception :" + se.getMessage(),se);
  289.         } finally {

  291.             JDBCUtilities.closeResources(rs, stm);

  293.             this.driver.closeConnection(conParam, con);

  295.         }
  296.     }
  297.     
  298.     private List<ResourceRepresentation> readResourcesMedia(long idResourceDetail,boolean request,Connection conParam) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  299.         // Aggiungo resource

  301.         Connection con = null;
  302.         PreparedStatement stm = null;
  303.         ResultSet rs = null;
  304.         String sqlQuery = null;

  306.         try {
  307.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  308.             // prendo la connessione dal pool
  309.             if(conParam!=null)
  310.                 con = conParam;
  311.             else if (this.driver.atomica)
  312.                 con = this.driver.getConnectionFromDatasource("readResourcesMedia("+idResourceDetail+")");
  313.             else
  314.                 con = this.driver.globalConnection;

  316.             if(idResourceDetail<=0)
  317.                 throw new Exception("ResourceDetail id non definito");

  319.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  320.             sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_MEDIA);
  321.             sqlQueryObject.addSelectField("*");
  322.             if(request) {
  323.                 sqlQueryObject.addWhereCondition("id_resource_media = ?");
  324.             }
  325.             else {
  326.                 sqlQueryObject.addWhereCondition("id_resource_response_media = ?");
  327.             }
  328.             sqlQueryObject.addOrderBy("media_type");
  329.             sqlQueryObject.setANDLogicOperator(true);
  330.             sqlQuery = sqlQueryObject.createSQLQuery();
  331.             stm = con.prepareStatement(sqlQuery);
  332.             stm.setLong(1, idResourceDetail);


  335.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idResourceDetail));
  336.             rs = stm.executeQuery();
  337.             
  338.             List<ResourceRepresentation> list = new ArrayList<ResourceRepresentation>();
  339.             
  340.             while(rs.next()) {
  341.                 
  342.                 ResourceRepresentation rr = new ResourceRepresentation();
  343.                                 
  344.                 String tmp = rs.getString("media_type");
  345.                 rr.setMediaType(((tmp == null || tmp.equals("")) ? null : tmp));
  346.                 
  347.                 tmp = rs.getString("message_type");
  348.                 rr.setMessageType(DriverRegistroServiziDB_LIB.getEnumMessageType((tmp == null || tmp.equals("")) ? null : tmp));
  349.                 
  350.                 tmp = rs.getString("nome");
  351.                 rr.setNome(((tmp == null || tmp.equals("")) ? null : tmp));
  352.                 
  353.                 tmp = rs.getString("descrizione");
  354.                 rr.setDescrizione(((tmp == null || tmp.equals("")) ? null : tmp));
  355.                 
  356.                 tmp = rs.getString("tipo");
  357.                 rr.setRepresentationType(DriverRegistroServiziDB_LIB.getEnumRepresentationType((tmp == null || tmp.equals("")) ? null : tmp));
  358.                 
  359.                 if(rr.getRepresentationType()!=null) {
  360.                     switch (rr.getRepresentationType()) {
  361.                     case XML:
  362.                         
  363.                         ResourceRepresentationXml xml = new ResourceRepresentationXml();
  364.                         
  365.                         tmp = rs.getString("xml_tipo");
  366.                         xml.setXmlType(DriverRegistroServiziDB_LIB.getEnumRepresentationXmlType((tmp == null || tmp.equals("")) ? null : tmp));
  367.                         
  368.                         tmp = rs.getString("xml_name");
  369.                         xml.setNome(((tmp == null || tmp.equals("")) ? null : tmp));
  370.                         
  371.                         tmp = rs.getString("xml_namespace");
  372.                         xml.setNamespace(((tmp == null || tmp.equals("")) ? null : tmp));
  373.                         
  374.                         rr.setXml(xml);
  375.                         
  376.                         break;
  377.     
  378.                     case JSON:
  379.                         
  380.                         ResourceRepresentationJson json = new ResourceRepresentationJson();
  381.                         
  382.                         tmp = rs.getString("json_type");
  383.                         json.setTipo(((tmp == null || tmp.equals("")) ? null : tmp));
  384.                         
  385.                         rr.setJson(json);
  386.                         
  387.                         break;
  388.                     }
  389.                 }
  390.                 
  391.                 long idRR = rs.getLong("id");
  392.                 rr.setId(idRR);
  393.                 
  394.                 list.add(rr);
  395.             
  396.             }
  397.             rs.close();
  398.             stm.close();
  399.             
  400.             return list;

  402.         }catch (DriverRegistroServiziNotFound e) {
  403.             throw e;
  404.         }catch (Exception se) {
  405.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::readResourcesMedia] Exception :" + se.getMessage(),se);
  406.         } finally {

  408.             JDBCUtilities.closeResources(rs, stm);

  410.             this.driver.closeConnection(conParam, con);

  412.         }
  413.     }
  414.     
  415.     private List<ResourceParameter> readResourcesParameters(long idResourceDetail,boolean request,Connection conParam) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  416.         // Aggiungo resource

  418.         Connection con = null;
  419.         PreparedStatement stm = null;
  420.         ResultSet rs = null;
  421.         String sqlQuery = null;

  423.         try {
  424.             this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  425.             // prendo la connessione dal pool
  426.             if(conParam!=null)
  427.                 con = conParam;
  428.             else if (this.driver.atomica)
  429.                 con = this.driver.getConnectionFromDatasource("readResourcesMedia("+idResourceDetail+")");
  430.             else
  431.                 con = this.driver.globalConnection;

  433.             if(idResourceDetail<=0)
  434.                 throw new Exception("ResourceDetail id non definito");

  436.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  437.             sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_PARAMETER);
  438.             sqlQueryObject.addSelectField("*");
  439.             if(request) {
  440.                 sqlQueryObject.addWhereCondition("id_resource_parameter = ?");
  441.             }
  442.             else {
  443.                 sqlQueryObject.addWhereCondition("id_resource_response_par = ?");
  444.             }
  445.             sqlQueryObject.addOrderBy("nome");
  446.             sqlQueryObject.setANDLogicOperator(true);
  447.             sqlQuery = sqlQueryObject.createSQLQuery();
  448.             stm = con.prepareStatement(sqlQuery);
  449.             stm.setLong(1, idResourceDetail);


  452.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idResourceDetail));
  453.             rs = stm.executeQuery();
  454.             
  455.             List<ResourceParameter> list = new ArrayList<ResourceParameter>();
  456.             
  457.             while(rs.next()) {
  458.                 
  459.                 ResourceParameter rr = new ResourceParameter();
  460.                                 
  461.                 String tmp = rs.getString("nome");
  462.                 rr.setNome(((tmp == null || tmp.equals("")) ? null : tmp));
  463.                 
  464.                 tmp = rs.getString("descrizione");
  465.                 rr.setDescrizione(((tmp == null || tmp.equals("")) ? null : tmp));
  466.                 
  467.                 tmp = rs.getString("tipo_parametro");
  468.                 rr.setParameterType(DriverRegistroServiziDB_LIB.getEnumParameterType((tmp == null || tmp.equals("")) ? null : tmp));
  469.                 
  470.                 boolean req = rs.getBoolean("required");
  471.                 rr.setRequired(req);
  472.                 
  473.                 tmp = rs.getString("tipo");
  474.                 rr.setTipo(((tmp == null || tmp.equals("")) ? null : tmp));
  475.                 
  476.                 tmp = rs.getString("restrizioni");
  477.                 rr.setRestrizioni(((tmp == null || tmp.equals("")) ? null : tmp));
  478.                 
  479.                 long idRR = rs.getLong("id");
  480.                 rr.setId(idRR);
  481.                 
  482.                 list.add(rr);
  483.             
  484.             }
  485.             rs.close();
  486.             stm.close();
  487.             
  488.             return list;
  489.             
  490.         }catch (DriverRegistroServiziNotFound e) {
  491.             throw e;
  492.         }catch (Exception se) {
  493.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::readResourcesParameters] Exception :" + se.getMessage(),se);
  494.         } finally {

  496.             JDBCUtilities.closeResources(rs, stm);

  498.             this.driver.closeConnection(conParam, con);

  500.         }
  501.     }
  502.     
  503.     protected List<Resource> accordiResourceList(long idAccordo, ISearch ricerca) throws DriverRegistroServiziException {
  504.         String nomeMetodo = "accordiResourceList";
  505.         int idLista = Liste.ACCORDI_API_RESOURCES;
  506.         int offset;
  507.         int limit;
  508.         String search;
  509.         String queryString;

  511.         limit = ricerca.getPageSize(idLista);
  512.         offset = ricerca.getIndexIniziale(idLista);
  513.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  514.         ricerca.getSearchString(idLista);

  516.         String filterHttpMethod = SearchUtils.getFilter(ricerca, idLista, Filtri.FILTRO_HTTP_METHOD);
  517.         org.openspcoop2.core.registry.constants.HttpMethod httpMethod = null;
  518.         if(filterHttpMethod!=null) {
  519.             httpMethod = org.openspcoop2.core.registry.constants.HttpMethod.toEnumConstant(filterHttpMethod);
  520.         }
  521.         
  522.         this.driver.logDebug("search : " + search);
  523.         this.driver.logDebug("filterHttpMethod : " + filterHttpMethod);
  524.         
  525.         Connection con = null;
  526.         PreparedStatement stmt = null;
  527.         ResultSet risultato = null;

  529.         ArrayList<Resource> lista = new ArrayList<Resource>();

  531.         if (this.driver.atomica) {
  532.             try {
  533.                 con = this.driver.getConnectionFromDatasource("accordiResourceList");

  535.             } catch (Exception e) {
  536.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  538.             }

  540.         } else
  541.             con = this.driver.globalConnection;

  543.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  545.         try {

  547.             if (!search.equals("")) {
  548.                 //query con search
  549.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  550.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES);
  551.                 sqlQueryObject.addSelectCountField("*", "cont");
  552.                 sqlQueryObject.addWhereCondition("id_accordo = ?");
  553.                 sqlQueryObject.addWhereCondition(false, 
  554.                         //sqlQueryObject.getWhereLikeCondition("nome", search, true, true),
  555.                         //sqlQueryObject.getWhereLikeCondition("http_method", search, true, true),
  556.                         sqlQueryObject.getWhereLikeCondition("path", search, true, true));
  557.                 if(httpMethod!=null) {
  558.                     sqlQueryObject.addWhereCondition("http_method = ?");
  559.                 }
  560.                 sqlQueryObject.setANDLogicOperator(true);
  561.                 queryString = sqlQueryObject.createSQLQuery();
  562.             } else {
  563.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  564.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES);
  565.                 sqlQueryObject.addSelectCountField("*", "cont");
  566.                 sqlQueryObject.addWhereCondition("id_accordo = ?");
  567.                 if(httpMethod!=null) {
  568.                     sqlQueryObject.addWhereCondition("http_method = ?");
  569.                 }
  570.                 sqlQueryObject.setANDLogicOperator(true);
  571.                 queryString = sqlQueryObject.createSQLQuery();
  572.             }
  573.             stmt = con.prepareStatement(queryString);
  574.             int index = 1;
  575.             stmt.setLong(index++,idAccordo);
  576.             if(httpMethod!=null) {
  577.                 stmt.setString(index++,httpMethod.name());
  578.             }
  579.             risultato = stmt.executeQuery();
  580.             if (risultato.next())
  581.                 ricerca.setNumEntries(idLista,risultato.getInt("cont"));
  582.             risultato.close();
  583.             stmt.close();

  585.             // ricavo le entries
  586.             if (limit == 0) // con limit
  587.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  588.             if (!search.equals("")) { // con search
  589.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  590.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES);
  591.                 sqlQueryObject.addSelectField("id_accordo");
  592.                 sqlQueryObject.addSelectField("nome");
  593.                 sqlQueryObject.addSelectField("descrizione");
  594.                 sqlQueryObject.addSelectField("http_method");
  595.                 sqlQueryObject.addSelectField("path");
  596.                 sqlQueryObject.addSelectField("message_type");
  597.                 sqlQueryObject.addSelectField("conferma_ricezione");
  598.                 sqlQueryObject.addSelectField("consegna_in_ordine");
  599.                 sqlQueryObject.addSelectField("filtro_duplicati");
  600.                 sqlQueryObject.addSelectField("identificativo_collaborazione");
  601.                 sqlQueryObject.addSelectField("id_riferimento_richiesta");
  602.                 sqlQueryObject.addSelectField("scadenza");
  603.                 sqlQueryObject.addSelectField("profilo_azione");
  604.                 sqlQueryObject.addSelectField("id");
  605.                 sqlQueryObject.addWhereCondition("id_accordo = ?");
  606.                 sqlQueryObject.addWhereCondition(false, 
  607.                         //sqlQueryObject.getWhereLikeCondition("nome", search, true, true),
  608.                         //sqlQueryObject.getWhereLikeCondition("http_method", search, true, true),
  609.                         sqlQueryObject.getWhereLikeCondition("path", search, true, true));
  610.                 if(httpMethod!=null) {
  611.                     sqlQueryObject.addWhereCondition("http_method = ?");
  612.                 }
  613.                 sqlQueryObject.setANDLogicOperator(true);
  614.                 sqlQueryObject.addOrderBy("path");
  615.                 sqlQueryObject.addOrderBy("http_method");
  616.                 sqlQueryObject.setSortType(true);
  617.                 sqlQueryObject.setLimit(limit);
  618.                 sqlQueryObject.setOffset(offset);
  619.                 queryString = sqlQueryObject.createSQLQuery();
  620.             } else {
  621.                 // senza search
  622.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  623.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES);
  624.                 sqlQueryObject.addSelectField("id_accordo");
  625.                 sqlQueryObject.addSelectField("nome");
  626.                 sqlQueryObject.addSelectField("descrizione");
  627.                 sqlQueryObject.addSelectField("http_method");
  628.                 sqlQueryObject.addSelectField("path");
  629.                 sqlQueryObject.addSelectField("message_type");
  630.                 sqlQueryObject.addSelectField("conferma_ricezione");
  631.                 sqlQueryObject.addSelectField("consegna_in_ordine");
  632.                 sqlQueryObject.addSelectField("filtro_duplicati");
  633.                 sqlQueryObject.addSelectField("identificativo_collaborazione");
  634.                 sqlQueryObject.addSelectField("id_riferimento_richiesta");
  635.                 sqlQueryObject.addSelectField("scadenza");
  636.                 sqlQueryObject.addSelectField("profilo_azione");
  637.                 sqlQueryObject.addSelectField("id");
  638.                 sqlQueryObject.addWhereCondition("id_accordo = ?");
  639.                 if(httpMethod!=null) {
  640.                     sqlQueryObject.addWhereCondition("http_method = ?");
  641.                 }
  642.                 sqlQueryObject.setANDLogicOperator(true);
  643.                 sqlQueryObject.addOrderBy("path");
  644.                 sqlQueryObject.addOrderBy("http_method");
  645.                 sqlQueryObject.setSortType(true);
  646.                 sqlQueryObject.setLimit(limit);
  647.                 sqlQueryObject.setOffset(offset);
  648.                 queryString = sqlQueryObject.createSQLQuery();
  649.             }
  650.             stmt = con.prepareStatement(queryString);
  651.             index = 1;
  652.             stmt.setLong(index++, idAccordo);
  653.             if(httpMethod!=null) {
  654.                 stmt.setString(index++,httpMethod.name());
  655.             }
  656.             risultato = stmt.executeQuery();

  658.             while (risultato.next()) {
  659.                 
  660.                 Resource resource = new Resource();

  662.                 String tmp = risultato.getString("nome");
  663.                 resource.setNome(((tmp == null || tmp.equals("")) ? null : tmp));

  665.                 tmp = risultato.getString("descrizione");
  666.                 resource.setDescrizione(((tmp == null || tmp.equals("")) ? null : tmp));

  668.                 tmp = risultato.getString("http_method");
  669.                 resource.setMethod(DriverRegistroServiziDB_LIB.getEnumHttpMethod(((tmp == null || tmp.equals("")) ? null : tmp)));

  671.                 tmp = risultato.getString("path");
  672.                 if(tmp!=null) {
  673.                     if(CostantiDB.API_RESOURCE_PATH_ALL_VALUE.equals(tmp.trim())==false) {
  674.                         resource.setPath(tmp);
  675.                     }
  676.                 }
  677.                 
  678.                 resource.setConfermaRicezione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(risultato.getString("conferma_ricezione")));
  679.                 resource.setConsegnaInOrdine(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(risultato.getString("consegna_in_ordine")));
  680.                 resource.setFiltroDuplicati(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(risultato.getString("filtro_duplicati")));
  681.                 resource.setIdCollaborazione(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(risultato.getString("identificativo_collaborazione")));
  682.                 resource.setIdRiferimentoRichiesta(DriverRegistroServiziDB_LIB.getEnumStatoFunzionalita(risultato.getString("id_riferimento_richiesta")));
  683.                 resource.setScadenza(risultato.getString("scadenza"));
  684.                 resource.setProfAzione(risultato.getString("profilo_azione"));
  685.                 
  686.                 tmp = risultato.getString("message_type");
  687.                 resource.setMessageType(DriverRegistroServiziDB_LIB.getEnumMessageType((tmp == null || tmp.equals("")) ? null : tmp));
  688.                 
  689.                 resource.setIdAccordo(risultato.getLong("id_accordo"));

  691.                 long idResource = risultato.getLong("id");
  692.                 resource.setId(idResource);
  693.                 
  694.                 lista.add(resource);
  695.             }

  697.             return lista;

  699.         } catch (Exception se) {

  701.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  702.         } finally {
  703.             //Chiudo statement and resultset
  704.             JDBCUtilities.closeResources(risultato, stmt);
  705.             this.driver.closeConnection(con);
  706.         }
  707.     }
  708.     
  709.     protected List<ResourceResponse> accordiResourceResponseList(long idRisorsa, ISearch ricerca) throws DriverRegistroServiziException {
  710.         String nomeMetodo = "accordiResourceResponseList";
  711.         int idLista = Liste.ACCORDI_API_RESOURCES_RESPONSE;
  712.         int offset;
  713.         int limit;
  714.         String search;
  715.         String queryString;

  717.         limit = ricerca.getPageSize(idLista);
  718.         offset = ricerca.getIndexIniziale(idLista);
  719.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  720.         ricerca.getSearchString(idLista);

  722.         Connection con = null;
  723.         PreparedStatement stmt = null;
  724.         ResultSet risultato = null;

  726.         ArrayList<ResourceResponse> lista = new ArrayList<ResourceResponse>();

  728.         if (this.driver.atomica) {
  729.             try {
  730.                 con = this.driver.getConnectionFromDatasource("accordiResourceList");

  732.             } catch (Exception e) {
  733.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  735.             }

  737.         } else
  738.             con = this.driver.globalConnection;

  740.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  742.         try {

  744.             if (!search.equals("")) {
  745.                 //query con search
  746.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  747.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_RESPONSE);
  748.                 sqlQueryObject.addSelectCountField("*", "cont");
  749.                 sqlQueryObject.addWhereCondition("id_resource = ?");
  750.                 sqlQueryObject.addWhereCondition(false, 
  751.                         sqlQueryObject.getWhereLikeCondition("descrizione", search, true, true),
  752.                         "status = ?");
  753.                 sqlQueryObject.setANDLogicOperator(true);
  754.                 queryString = sqlQueryObject.createSQLQuery();
  755.             } else {
  756.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  757.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_RESPONSE);
  758.                 sqlQueryObject.addSelectCountField("*", "cont");
  759.                 sqlQueryObject.addWhereCondition("id_resource = ?");
  760.                 queryString = sqlQueryObject.createSQLQuery();
  761.             }
  762.             stmt = con.prepareStatement(queryString);
  763.             stmt.setLong(1,idRisorsa);
  764.             if (!search.equals("")) {
  765.                 try {
  766.                     stmt.setInt(2,Integer.parseInt(search));
  767.                 }catch(Exception e) {
  768.                     stmt.setInt(2,-1);  
  769.                 }
  770.             }
  771.             risultato = stmt.executeQuery();
  772.             if (risultato.next())
  773.                 ricerca.setNumEntries(idLista,risultato.getInt("cont"));
  774.             risultato.close();
  775.             stmt.close();

  777.             // ricavo le entries
  778.             if (limit == 0) // con limit
  779.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  780.             if (!search.equals("")) { // con search
  781.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  782.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_RESPONSE);
  783.                 sqlQueryObject.addSelectField("id_resource");
  784.                 sqlQueryObject.addSelectField("descrizione");
  785.                 sqlQueryObject.addSelectField("status");
  786.                 sqlQueryObject.addSelectField("id");
  787.                 sqlQueryObject.addWhereCondition("id_resource = ?");
  788.                 sqlQueryObject.addWhereCondition(false, 
  789.                         sqlQueryObject.getWhereLikeCondition("descrizione", search, true, true),
  790.                         "status = ?");
  791.                 sqlQueryObject.setANDLogicOperator(true);
  792.                 sqlQueryObject.addOrderBy("status");
  793.                 sqlQueryObject.setSortType(true);
  794.                 sqlQueryObject.setLimit(limit);
  795.                 sqlQueryObject.setOffset(offset);
  796.                 queryString = sqlQueryObject.createSQLQuery();
  797.             } else {
  798.                 // senza search
  799.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  800.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_RESPONSE);
  801.                 sqlQueryObject.addSelectField("id_resource");
  802.                 sqlQueryObject.addSelectField("descrizione");
  803.                 sqlQueryObject.addSelectField("status");
  804.                 sqlQueryObject.addSelectField("id");
  805.                 sqlQueryObject.addWhereCondition("id_resource = ?");
  806.                 sqlQueryObject.addOrderBy("status");
  807.                 sqlQueryObject.setSortType(true);
  808.                 sqlQueryObject.setLimit(limit);
  809.                 sqlQueryObject.setOffset(offset);
  810.                 queryString = sqlQueryObject.createSQLQuery();
  811.             }
  812.             stmt = con.prepareStatement(queryString);
  813.             stmt.setLong(1, idRisorsa);
  814.             if (!search.equals("")) {
  815.                 try {
  816.                     stmt.setInt(2,Integer.parseInt(search));
  817.                 }catch(Exception e) {
  818.                     stmt.setInt(2,-1);  
  819.                 }
  820.             }
  821.             risultato = stmt.executeQuery();

  823.             while (risultato.next()) {
  824.                 
  825.                 ResourceResponse resource = new ResourceResponse();

  827.                 resource.setStatus(risultato.getInt("status"));

  829.                 String tmp = risultato.getString("descrizione");
  830.                 resource.setDescrizione(((tmp == null || tmp.equals("")) ? null : tmp));

  832.                 resource.setIdResource(risultato.getLong("id_resource"));

  834.                 long idResource = risultato.getLong("id");
  835.                 resource.setId(idResource);
  836.                 
  837.                 lista.add(resource);
  838.             }

  840.             return lista;

  842.         } catch (Exception se) {

  844.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  845.         } finally {
  846.             //Chiudo statement and resultset
  847.             JDBCUtilities.closeResources(risultato, stmt);
  848.             this.driver.closeConnection(con);
  849.         }
  850.     }
  851.     
  852.     protected List<ResourceRepresentation> accordiResourceRepresentationsList(Long idRisorsa, boolean isRequest, Long idRisposta, ISearch ricerca)  throws DriverRegistroServiziException {
  853.         String nomeMetodo = "accordiResourceRepresentationsList";
  854.         int idLista = Liste.ACCORDI_API_RESOURCES_REPRESENTATION_REQUEST;
  855.         if(!isRequest)
  856.             idLista = Liste.ACCORDI_API_RESOURCES_REPRESENTATION_RESPONSE;
  857.         int offset;
  858.         int limit;
  859.         String search;
  860.         String queryString;

  862.         limit = ricerca.getPageSize(idLista);
  863.         offset = ricerca.getIndexIniziale(idLista);
  864.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  865.         ricerca.getSearchString(idLista);

  867.         Connection con = null;
  868.         PreparedStatement stmt = null;
  869.         ResultSet risultato = null;

  871.         ArrayList<ResourceRepresentation> lista = new ArrayList<ResourceRepresentation>();
  872.         
  873.         if (this.driver.atomica) {
  874.             try {
  875.                 con = this.driver.getConnectionFromDatasource("accordiPorttypeOperationMessagePartList");

  877.             } catch (Exception e) {
  878.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  880.             }

  882.         } else
  883.             con = this.driver.globalConnection;

  885.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  887.         try {

  889.             if (!search.equals("")) {
  890.                 //query con search
  891.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  892.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_MEDIA);
  893.                 sqlQueryObject.addSelectCountField("*", "cont");
  894.                 if(isRequest)
  895.                     sqlQueryObject.addWhereCondition("id_resource_media = ?");
  896.                 else
  897.                     sqlQueryObject.addWhereCondition("id_resource_response_media = ?");
  898.                 sqlQueryObject.addWhereLikeCondition("media_type", search, true, true);
  899.                 sqlQueryObject.setANDLogicOperator(true);
  900.                 queryString = sqlQueryObject.createSQLQuery();
  901.             } else {
  902.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  903.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_MEDIA);
  904.                 sqlQueryObject.addSelectCountField("*", "cont");
  905.                 if(isRequest)
  906.                     sqlQueryObject.addWhereCondition("id_resource_media = ?");
  907.                 else
  908.                     sqlQueryObject.addWhereCondition("id_resource_response_media = ?");
  909.                 sqlQueryObject.setANDLogicOperator(true);
  910.                 queryString = sqlQueryObject.createSQLQuery();
  911.             }
  912.             stmt = con.prepareStatement(queryString);
  913.             
  914.             if(isRequest)
  915.                 stmt.setLong(1,idRisorsa);
  916.             else 
  917.                 stmt.setLong(1,idRisposta);
  918.             
  919.             risultato = stmt.executeQuery();
  920.             if (risultato.next())
  921.                 ricerca.setNumEntries(idLista,risultato.getInt("cont"));
  922.             risultato.close();
  923.             stmt.close();

  925.             // ricavo le entries
  926.             if (limit == 0) // con limit
  927.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  928.             if (!search.equals("")) { // con search
  929.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  930.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_MEDIA);
  931.                 sqlQueryObject.addSelectField("id_resource_media");
  932.                 sqlQueryObject.addSelectField("id_resource_response_media");
  933.                 sqlQueryObject.addSelectField("media_type");
  934.                 sqlQueryObject.addSelectField("message_type");
  935.                 sqlQueryObject.addSelectField("nome");
  936.                 sqlQueryObject.addSelectField("descrizione");
  937.                 sqlQueryObject.addSelectField("tipo");
  938.                 sqlQueryObject.addSelectField("xml_tipo");
  939.                 sqlQueryObject.addSelectField("xml_name");
  940.                 sqlQueryObject.addSelectField("xml_namespace");
  941.                 sqlQueryObject.addSelectField("json_type");
  942.                 sqlQueryObject.addSelectField("id");
  943.                 if(isRequest)
  944.                     sqlQueryObject.addWhereCondition("id_resource_media = ?");
  945.                 else
  946.                     sqlQueryObject.addWhereCondition("id_resource_response_media = ?");
  947.                 sqlQueryObject.addWhereLikeCondition("media_type", search, true, true);
  948.                 sqlQueryObject.setANDLogicOperator(true);
  949.                 sqlQueryObject.addOrderBy("nome");
  950.                 sqlQueryObject.setSortType(true);
  951.                 sqlQueryObject.setLimit(limit);
  952.                 sqlQueryObject.setOffset(offset);
  953.                 queryString = sqlQueryObject.createSQLQuery();
  954.             } else {
  955.                 // senza search
  956.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  957.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_MEDIA);
  958.                 sqlQueryObject.addSelectField("id_resource_media");
  959.                 sqlQueryObject.addSelectField("id_resource_response_media");
  960.                 sqlQueryObject.addSelectField("media_type");
  961.                 sqlQueryObject.addSelectField("message_type");
  962.                 sqlQueryObject.addSelectField("nome");
  963.                 sqlQueryObject.addSelectField("descrizione");
  964.                 sqlQueryObject.addSelectField("tipo");
  965.                 sqlQueryObject.addSelectField("xml_tipo");
  966.                 sqlQueryObject.addSelectField("xml_name");
  967.                 sqlQueryObject.addSelectField("xml_namespace");
  968.                 sqlQueryObject.addSelectField("json_type");
  969.                 sqlQueryObject.addSelectField("id");
  970.                 if(isRequest)
  971.                     sqlQueryObject.addWhereCondition("id_resource_media = ?");
  972.                 else
  973.                     sqlQueryObject.addWhereCondition("id_resource_response_media = ?");
  974.                 sqlQueryObject.setANDLogicOperator(true);
  975.                 sqlQueryObject.addOrderBy("nome");
  976.                 sqlQueryObject.setSortType(true);
  977.                 sqlQueryObject.setLimit(limit);
  978.                 sqlQueryObject.setOffset(offset);
  979.                 queryString = sqlQueryObject.createSQLQuery();
  980.             }
  981.             stmt = con.prepareStatement(queryString);
  982.             if(isRequest)
  983.                 stmt.setLong(1,idRisorsa);
  984.             else 
  985.                 stmt.setLong(1,idRisposta);
  986.             risultato = stmt.executeQuery();
  987.             
  988.             while (risultato.next()) {
  989.                 ResourceRepresentation rr = new ResourceRepresentation();
  990.                 
  991.                 String tmp = risultato.getString("media_type");
  992.                 rr.setMediaType(((tmp == null || tmp.equals("")) ? null : tmp));
  993.                 
  994.                 tmp = risultato.getString("message_type");
  995.                 rr.setMessageType(DriverRegistroServiziDB_LIB.getEnumMessageType((tmp == null || tmp.equals("")) ? null : tmp));
  996.                 
  997.                 tmp = risultato.getString("nome");
  998.                 rr.setNome(((tmp == null || tmp.equals("")) ? null : tmp));
  999.                 
  1000.                 tmp = risultato.getString("descrizione");
  1001.                 rr.setDescrizione(((tmp == null || tmp.equals("")) ? null : tmp));
  1002.                 
  1003.                 tmp = risultato.getString("tipo");
  1004.                 rr.setRepresentationType(DriverRegistroServiziDB_LIB.getEnumRepresentationType((tmp == null || tmp.equals("")) ? null : tmp));
  1005.                 
  1006.                 if(rr.getRepresentationType()!=null) {
  1007.                     switch (rr.getRepresentationType()) {
  1008.                     case XML:
  1009.                         
  1010.                         ResourceRepresentationXml xml = new ResourceRepresentationXml();
  1011.                         
  1012.                         tmp = risultato.getString("xml_tipo");
  1013.                         xml.setXmlType(DriverRegistroServiziDB_LIB.getEnumRepresentationXmlType((tmp == null || tmp.equals("")) ? null : tmp));
  1014.                         
  1015.                         tmp = risultato.getString("xml_name");
  1016.                         xml.setNome(((tmp == null || tmp.equals("")) ? null : tmp));
  1017.                         
  1018.                         tmp = risultato.getString("xml_namespace");
  1019.                         xml.setNamespace(((tmp == null || tmp.equals("")) ? null : tmp));
  1020.                         
  1021.                         rr.setXml(xml);
  1022.                         
  1023.                         break;
  1024.     
  1025.                     case JSON:
  1026.                         
  1027.                         ResourceRepresentationJson json = new ResourceRepresentationJson();
  1028.                         
  1029.                         tmp = risultato.getString("json_type");
  1030.                         json.setTipo(((tmp == null || tmp.equals("")) ? null : tmp));
  1031.                         
  1032.                         rr.setJson(json);
  1033.                         
  1034.                         break;
  1035.                     }
  1036.                 }
  1037.                 
  1038.                 long idRR = risultato.getLong("id");
  1039.                 rr.setId(idRR);
  1040.                 
  1041.                 lista.add(rr);
  1042.             }

  1044.             return lista;

  1046.         } catch (Exception se) {

  1048.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1049.         } finally {
  1050.             //Chiudo statement and resultset
  1051.             JDBCUtilities.closeResources(risultato, stmt);
  1052.             this.driver.closeConnection(con);
  1053.         }
  1054.     }
  1055.     
  1056.     protected List<ResourceParameter> accordiResourceParametersList(Long idRisorsa, boolean isRequest, Long idRisposta, ISearch ricerca)  throws DriverRegistroServiziException {
  1057.         String nomeMetodo = "accordiResourceParametersList";
  1058.         int idLista = Liste.ACCORDI_API_RESOURCES_PARAMETERS_REQUEST;
  1059.         if(!isRequest)
  1060.             idLista = Liste.ACCORDI_API_RESOURCES_PARAMETERS_RESPONSE;
  1061.         int offset;
  1062.         int limit;
  1063.         String search;
  1064.         String queryString;

  1066.         limit = ricerca.getPageSize(idLista);
  1067.         offset = ricerca.getIndexIniziale(idLista);
  1068.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  1069.         ricerca.getSearchString(idLista);

  1071.         Connection con = null;
  1072.         PreparedStatement stmt = null;
  1073.         ResultSet risultato = null;

  1075.         ArrayList<ResourceParameter> lista = new ArrayList<ResourceParameter>();
  1076.         
  1077.         if (this.driver.atomica) {
  1078.             try {
  1079.                 con = this.driver.getConnectionFromDatasource("accordiPorttypeOperationMessagePartList");

  1081.             } catch (Exception e) {
  1082.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  1084.             }

  1086.         } else
  1087.             con = this.driver.globalConnection;

  1089.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  1091.         try {

  1093.             if (!search.equals("")) {
  1094.                 //query con search
  1095.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1096.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_PARAMETER);
  1097.                 sqlQueryObject.addSelectCountField("*", "cont");
  1098.                 if(isRequest)
  1099.                     sqlQueryObject.addWhereCondition("id_resource_parameter = ?");
  1100.                 else
  1101.                     sqlQueryObject.addWhereCondition("id_resource_response_par = ?");
  1102.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1103.                 sqlQueryObject.setANDLogicOperator(true);
  1104.                 queryString = sqlQueryObject.createSQLQuery();
  1105.             } else {
  1106.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1107.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_PARAMETER);
  1108.                 sqlQueryObject.addSelectCountField("*", "cont");
  1109.                 if(isRequest)
  1110.                     sqlQueryObject.addWhereCondition("id_resource_parameter = ?");
  1111.                 else
  1112.                     sqlQueryObject.addWhereCondition("id_resource_response_par = ?");
  1113.                 sqlQueryObject.setANDLogicOperator(true);
  1114.                 queryString = sqlQueryObject.createSQLQuery();
  1115.             }
  1116.             stmt = con.prepareStatement(queryString);
  1117.             
  1118.             if(isRequest)
  1119.                 stmt.setLong(1,idRisorsa);
  1120.             else 
  1121.                 stmt.setLong(1,idRisposta);
  1122.             
  1123.             risultato = stmt.executeQuery();
  1124.             if (risultato.next())
  1125.                 ricerca.setNumEntries(idLista,risultato.getInt("cont"));
  1126.             risultato.close();
  1127.             stmt.close();

  1129.             // ricavo le entries
  1130.             if (limit == 0) // con limit
  1131.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;
  1132.             if (!search.equals("")) { // con search
  1133.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1134.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_PARAMETER);
  1135.                 sqlQueryObject.addSelectField("id_resource_parameter");
  1136.                 sqlQueryObject.addSelectField("id_resource_response_par");
  1137.                 sqlQueryObject.addSelectField("nome");
  1138.                 sqlQueryObject.addSelectField("descrizione");
  1139.                 sqlQueryObject.addSelectField("tipo_parametro");
  1140.                 sqlQueryObject.addSelectField("required");
  1141.                 sqlQueryObject.addSelectField("tipo");
  1142.                 sqlQueryObject.addSelectField("restrizioni");
  1143.                 sqlQueryObject.addSelectField("id");
  1144.                 if(isRequest)
  1145.                     sqlQueryObject.addWhereCondition("id_resource_parameter = ?");
  1146.                 else
  1147.                     sqlQueryObject.addWhereCondition("id_resource_response_par = ?");
  1148.                 sqlQueryObject.addWhereLikeCondition("nome", search, true, true);
  1149.                 sqlQueryObject.setANDLogicOperator(true);
  1150.                 sqlQueryObject.addOrderBy("tipo_parametro");
  1151.                 sqlQueryObject.addOrderBy("nome");
  1152.                 sqlQueryObject.setSortType(true);
  1153.                 sqlQueryObject.setLimit(limit);
  1154.                 sqlQueryObject.setOffset(offset);
  1155.                 queryString = sqlQueryObject.createSQLQuery();
  1156.             } else {
  1157.                 // senza search
  1158.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  1159.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_PARAMETER);
  1160.                 sqlQueryObject.addSelectField("id_resource_parameter");
  1161.                 sqlQueryObject.addSelectField("id_resource_response_par");
  1162.                 sqlQueryObject.addSelectField("nome");
  1163.                 sqlQueryObject.addSelectField("descrizione");
  1164.                 sqlQueryObject.addSelectField("tipo_parametro");
  1165.                 sqlQueryObject.addSelectField("required");
  1166.                 sqlQueryObject.addSelectField("tipo");
  1167.                 sqlQueryObject.addSelectField("restrizioni");
  1168.                 sqlQueryObject.addSelectField("id");
  1169.                 if(isRequest)
  1170.                     sqlQueryObject.addWhereCondition("id_resource_parameter = ?");
  1171.                 else
  1172.                     sqlQueryObject.addWhereCondition("id_resource_response_par = ?");
  1173.                 sqlQueryObject.setANDLogicOperator(true);
  1174.                 sqlQueryObject.addOrderBy("tipo_parametro");
  1175.                 sqlQueryObject.addOrderBy("nome");
  1176.                 sqlQueryObject.setSortType(true);
  1177.                 sqlQueryObject.setLimit(limit);
  1178.                 sqlQueryObject.setOffset(offset);
  1179.                 queryString = sqlQueryObject.createSQLQuery();
  1180.             }
  1181.             stmt = con.prepareStatement(queryString);
  1182.             if(isRequest)
  1183.                 stmt.setLong(1,idRisorsa);
  1184.             else 
  1185.                 stmt.setLong(1,idRisposta);
  1186.             risultato = stmt.executeQuery();
  1187.             
  1188.             while (risultato.next()) {
  1189.                 ResourceParameter rr = new ResourceParameter();
  1190.                 
  1191.                 String tmp = risultato.getString("nome");
  1192.                 rr.setNome(((tmp == null || tmp.equals("")) ? null : tmp));
  1193.                 
  1194.                 tmp = risultato.getString("descrizione");
  1195.                 rr.setDescrizione(((tmp == null || tmp.equals("")) ? null : tmp));
  1196.                 
  1197.                 tmp = risultato.getString("tipo_parametro");
  1198.                 rr.setParameterType(DriverRegistroServiziDB_LIB.getEnumParameterType((tmp == null || tmp.equals("")) ? null : tmp));
  1199.                 
  1200.                 boolean req = risultato.getBoolean("required");
  1201.                 rr.setRequired(req);
  1202.                 
  1203.                 tmp = risultato.getString("tipo");
  1204.                 rr.setTipo(((tmp == null || tmp.equals("")) ? null : tmp));
  1205.                 
  1206.                 tmp = risultato.getString("restrizioni");
  1207.                 rr.setRestrizioni(((tmp == null || tmp.equals("")) ? null : tmp));
  1208.                 
  1209.                 long idRR = risultato.getLong("id");
  1210.                 rr.setId(idRR);
  1211.                 
  1212.                 lista.add(rr);
  1213.             }

  1215.             return lista;

  1217.         } catch (Exception se) {

  1219.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  1220.         } finally {
  1221.             //Chiudo statement and resultset
  1222.             JDBCUtilities.closeResources(risultato, stmt);
  1223.             this.driver.closeConnection(con);
  1224.         }
  1225.     }
  1226. }
Created with JaCoCo 0.8.8.202204050719